From 736b58a43b0afb40745f885f400ef97d070f46a9 Mon Sep 17 00:00:00 2001
From: 孔祥富 <kongxf@daryun.com>
Date: 星期四, 04 三月 2021 22:02:44 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/master'

---
 febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpLeaveInfoServiceImpl.java |  119 +++++++++++++++++++++++++++++++++++++++++++++++++----------
 1 files changed, 98 insertions(+), 21 deletions(-)

diff --git a/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpLeaveInfoServiceImpl.java b/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpLeaveInfoServiceImpl.java
index c14918c..ca6251c 100644
--- a/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpLeaveInfoServiceImpl.java
+++ b/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpLeaveInfoServiceImpl.java
@@ -1,29 +1,32 @@
 package cc.mrbird.febs.server.hr.service.impl;
 
-import java.util.ArrayList;
-import java.util.Arrays;
-import java.util.Date;
-import java.util.List;
-import java.util.Optional;
-
+import cc.mrbird.febs.common.core.constant.DicCode;
+import cc.mrbird.febs.common.core.constant.ModuleCode;
+import cc.mrbird.febs.common.core.entity.QueryRequest;
+import cc.mrbird.febs.common.core.entity.system.Dept;
+import cc.mrbird.febs.common.core.entity.system.DicItem;
+import cc.mrbird.febs.common.core.utils.CastUtil;
+import cc.mrbird.febs.common.core.utils.FebsUtil;
+import cc.mrbird.febs.common.core.utils.SequenceUtil;
+import cc.mrbird.febs.common.redis.service.RedisService;
+import cc.mrbird.febs.server.hr.entity.EmpLeaveInfo;
+import cc.mrbird.febs.server.hr.mapper.EmpLeaveInfoMapper;
+import cc.mrbird.febs.server.hr.service.IEmpBaseInfoService;
+import cc.mrbird.febs.server.hr.service.IEmpLeaveInfoService;
+import cn.hutool.core.date.DateUtil;
+import cn.hutool.core.util.StrUtil;
+import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import lombok.RequiredArgsConstructor;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
-import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
-import com.baomidou.mybatisplus.core.metadata.IPage;
-import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
-import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
-
-import cc.mrbird.febs.common.core.constant.ModuleCode;
-import cc.mrbird.febs.common.core.entity.QueryRequest;
-import cc.mrbird.febs.common.core.utils.FebsUtil;
-import cc.mrbird.febs.common.core.utils.SequenceUtil;
-import cc.mrbird.febs.server.hr.entity.EmpLeaveInfo;
-import cc.mrbird.febs.server.hr.mapper.EmpLeaveInfoMapper;
-import cc.mrbird.febs.server.hr.service.IEmpLeaveInfoService;
-import lombok.RequiredArgsConstructor;
+import java.math.BigDecimal;
+import java.util.*;
 
 /**
  * name:EmpLeaveinfo
@@ -39,7 +42,9 @@
 @Transactional(propagation = Propagation.SUPPORTS, readOnly = true)
 class EmpLeaveInfoServiceImpl extends ServiceImpl<EmpLeaveInfoMapper, EmpLeaveInfo> implements IEmpLeaveInfoService {
 
+	private final RedisService redisService;
     private final EmpLeaveInfoMapper empLeaveinfoMapper;
+    private final IEmpBaseInfoService empBaseInfoService;
     private final String operatorId = Optional.ofNullable(FebsUtil.getCurrentUser())
             .map(u -> u.getUserId().toString())
             .orElse("1");
@@ -68,7 +73,9 @@
         	queryWrapper.le(EmpLeaveInfo::getEndTime, empLeaveinfo.getLeaveDateStr().split(",")[1]);
         }
         Page<EmpLeaveInfo> page = new Page<>(request.getPageNum(), request.getPageSize());
-        return this.page(page, queryWrapper);
+        IPage<EmpLeaveInfo> iPage = this.page(page, queryWrapper);
+        iPage.setRecords(this.convertDicItemName(iPage.getRecords()));
+        return iPage;
     }
 
     @Override
@@ -130,4 +137,74 @@
         List<String> list = new ArrayList<>(Arrays.asList(str));
         return empLeaveinfoMapper.momentToNormal(list, operatorId)>0;
     }
-}
\ No newline at end of file
+
+	@Override
+	@Transactional(rollbackFor = Exception.class)
+	public void importEmpLeaveInfo(List<List<Object>> listObject,List<String>  returnList) {
+		for (List<Object> list : listObject) {
+            if (list.size()==0){
+                continue;
+            }
+			EmpLeaveInfo leaveInfo = new EmpLeaveInfo();
+			leaveInfo.setLeaveId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE));
+			leaveInfo.setEmpNumb(list.get(0).toString());
+			List<Dept> depts = CastUtil.castList(redisService.get("depts"), Dept.class);
+            Dept dept = depts.stream().filter(d -> d.getDeptName().equals(list.get(1).toString())).findFirst().orElse(null);
+            if (null == dept) {
+                returnList.add(StrUtil.format("导入员工请假记录异常: 出现位置第{}行, 原因:{}部门不存在",listObject.indexOf(list)+1,list.get(1).toString()));
+                continue;
+            }
+            Long empId = empBaseInfoService.getEmpIdByEmpNumb(list.get(0).toString());
+            if (null == empId){
+                returnList.add(StrUtil.format("导入员工请假记录异常: 出现位置第{}行, 原因:{}员工编号不存在",listObject.indexOf(list)+1,list.get(0).toString()));
+                continue;
+            }
+            leaveInfo.setDelFlag(2);
+            leaveInfo.setEmpId(empId);
+			leaveInfo.setDeptName(list.get(1).toString());
+			leaveInfo.setDeptId(dept.getDeptId());
+			leaveInfo.setJobName(list.get(2).toString());
+			leaveInfo.setEmpName(list.get(3).toString());
+			leaveInfo.setCertificateNumb(list.get(4).toString());
+			if (StringUtils.isNotBlank(list.get(5).toString())) {
+				leaveInfo.setBeginTime(DateUtil.parseDate(list.get(5).toString()));
+			}
+			if (StringUtils.isNotBlank(list.get(6).toString())) {
+				leaveInfo.setEndTime(DateUtil.parseDate(list.get(6).toString()));
+			}
+			if (StringUtils.isNotBlank(list.get(7).toString())) {
+				leaveInfo.setLeaveDay(new BigDecimal(list.get(7).toString()));
+			}
+			leaveInfo.setLeaveType(list.get(8).toString());
+			if (StringUtils.isNotBlank(list.get(9).toString())) {
+				leaveInfo.setReturnDate(DateUtil.parseDate(list.get(9).toString()));
+			}
+			leaveInfo.setReporter(list.get(10).toString());
+			leaveInfo.setRemark(list.get(11).toString());
+			this.save(leaveInfo);
+		}
+	}
+
+	/**
+	 *
+	 * 将列表中的字典项转换成字典名称
+	 *
+	 * date 2021-02-26 19:37
+	 * @author: luoyibo
+	 * @param list 1
+	 * @return java.util.List<cc.mrbird.febs.server.hr.entity.EmpLeaveInfo>
+	 */
+	private List<EmpLeaveInfo> convertDicItemName(List<EmpLeaveInfo> list){
+        List<DicItem> dicItems = CastUtil.castList(redisService.get("dicItems"), DicItem.class);
+        list.forEach(p -> {
+            //请假类型
+            p.setLeaveTypeName(dicItems.stream()
+                    .filter(k -> DicCode.LEAVETYPE.equals(k.getDicCode()) && k.getDicItemCode().equals(p.getLeaveType()))
+                    .findFirst()
+                    .map(DicItem::getDicItemName)
+                    .orElse("事假"));
+        });
+
+        return  list;
+    }
+}

--
Gitblit v1.8.0