From c97fe0e22ac0a2c38b0636f619d3bcf030870c0c Mon Sep 17 00:00:00 2001
From: 孔祥富 <kongxf@daryun.com>
Date: 星期一, 01 三月 2021 21:28:02 +0800
Subject: [PATCH] 提交bug

---
 febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpUnemploymentServiceImpl.java |   55 ++++++++++++++++++++++++++++++++++++++++++++++++++++---
 1 files changed, 52 insertions(+), 3 deletions(-)

diff --git a/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpUnemploymentServiceImpl.java b/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpUnemploymentServiceImpl.java
index 6cf699e..7f81dd7 100644
--- a/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpUnemploymentServiceImpl.java
+++ b/febs-server/febs-server-hr/src/main/java/cc/mrbird/febs/server/hr/service/impl/EmpUnemploymentServiceImpl.java
@@ -6,6 +6,8 @@
 import java.util.List;
 import java.util.Optional;
 
+import cc.mrbird.febs.common.core.exception.FebsException;
+import cc.mrbird.febs.server.hr.entity.EmpLaborTrouble;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Propagation;
@@ -18,11 +20,15 @@
 
 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.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.EmpUnemployment;
 import cc.mrbird.febs.server.hr.mapper.EmpUnemploymentMapper;
 import cc.mrbird.febs.server.hr.service.IEmpUnemploymentService;
+import cn.hutool.core.date.DateUtil;
 import lombok.RequiredArgsConstructor;
 
 /**
@@ -39,6 +45,7 @@
 @Transactional(propagation = Propagation.SUPPORTS, readOnly = true)
 class EmpUnemploymentServiceImpl extends ServiceImpl<EmpUnemploymentMapper, EmpUnemployment> implements IEmpUnemploymentService {
 
+	private final RedisService redisService;
     private final EmpUnemploymentMapper empUnemploymentMapper;
     private final String operatorId = Optional.ofNullable(FebsUtil.getCurrentUser())
             .map(u -> u.getUserId().toString())
@@ -79,7 +86,14 @@
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void createEmpUnemployment(EmpUnemployment empUnemployment) {
+    public void createEmpUnemployment(EmpUnemployment empUnemployment) throws FebsException {
+        LambdaQueryWrapper<EmpUnemployment> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(EmpUnemployment::getEmpId, empUnemployment.getEmpId());
+        lambdaQueryWrapper.eq(EmpUnemployment::getApplayDate,empUnemployment.getApplayDate() );
+        lambdaQueryWrapper.ne(EmpUnemployment::getDelFlag,1);
+        if (this.count(lambdaQueryWrapper) > 0) {
+            throw new FebsException(MyConstant.MESSAGE);
+        }
         empUnemployment.setUnemploymentId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE));
         empUnemployment.setCreator(operatorId);
         empUnemployment.setModifier(operatorId);
@@ -88,7 +102,15 @@
 
     @Override
     @Transactional(rollbackFor = Exception.class)
-    public void updateEmpUnemployment(EmpUnemployment empUnemployment) {
+    public void updateEmpUnemployment(EmpUnemployment empUnemployment) throws FebsException {
+        LambdaQueryWrapper<EmpUnemployment> lambdaQueryWrapper = new LambdaQueryWrapper<>();
+        lambdaQueryWrapper.eq(EmpUnemployment::getEmpId, empUnemployment.getEmpId());
+        lambdaQueryWrapper.eq(EmpUnemployment::getApplayDate, empUnemployment.getApplayDate());
+        lambdaQueryWrapper.ne(EmpUnemployment::getDelFlag,1);
+        lambdaQueryWrapper.ne(EmpUnemployment::getUnemploymentId,empUnemployment.getUnemploymentId());
+        if (this.count(lambdaQueryWrapper) > 0) {
+            throw new FebsException(MyConstant.MESSAGE);
+        }
         EmpUnemployment dbData = this.getById(empUnemployment.getUnemploymentId());
         empUnemployment.setCreateTime(dbData.getCreateTime());
         empUnemployment.setCreator(dbData.getCreator());
@@ -129,4 +151,31 @@
         List<String> list = new ArrayList<>(Arrays.asList(str));
         return empUnemploymentMapper.momentToNormal(list, operatorId)>0;
     }
-}
\ No newline at end of file
+
+
+    @Override
+	@Transactional(rollbackFor = Exception.class)
+    public void importEmpUnemployment(List<List<Object>> listObject) {
+    	for (List<Object> list : listObject) {
+    		EmpUnemployment empUnemployment=new EmpUnemployment();
+    		empUnemployment.setUnemploymentId(SequenceUtil.generateId(0L, ModuleCode.HR_EMPLOYEE));
+    		empUnemployment.setEmpNumb(list.get(0).toString());
+			List<Dept> depts = CastUtil.castList(redisService.get("depts"), Dept.class);
+			Long deptId = depts.stream().filter(d -> d.getDeptName().equals(list.get(1).toString())).findFirst().get()
+					.getDeptId();
+			empUnemployment.setDeptName(list.get(1).toString());
+			empUnemployment.setDeptId(deptId);
+			empUnemployment.setJobName(list.get(2).toString());
+			empUnemployment.setEmpName(list.get(3).toString());
+			empUnemployment.setCertificateNumb(list.get(4).toString());
+			if (StringUtils.isNotBlank(list.get(5).toString())) {
+				empUnemployment.setApplayDate(DateUtil.parseDate(list.get(5).toString()));
+			}
+			empUnemployment.setApplayReason(list.get(6).toString());
+			empUnemployment.setReporter(list.get(7).toString());
+			empUnemployment.setAuditor(list.get(8).toString());
+			empUnemployment.setRemark(list.get(9).toString());
+			this.save(empUnemployment);
+    	}
+	}
+}

--
Gitblit v1.8.0