huyc 项目档案代码提交

yifu-archives/yifu-archives-api/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/vo/EmployeeProjectNewOldVO.java

+/*
+ *    Copyright (c) 2018-2025, lengleng All rights reserved.
+ *
+ * Redistribution and use in source and binary forms, with or without
+ * modification, are permitted provided that the following conditions are met:
+ *
+ * Redistributions of source code must retain the above copyright notice,
+ * this list of conditions and the following disclaimer.
+ * Redistributions in binary form must reproduce the above copyright
+ * notice, this list of conditions and the following disclaimer in the
+ * documentation and/or other materials provided with the distribution.
+ * Neither the name of the yifu4cloud.com developer nor the names of its
+ * contributors may be used to endorse or promote products derived from
+ * this software without specific prior written permission.
+ * Author: lengleng (wangiegie@gmail.com)
+ */
+package com.yifu.cloud.plus.v1.yifu.archives.vo;
+
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
+import lombok.Data;
+
+import java.io.Serializable;
+
+/**
+ * 项目档案更新记录需要的信息
+ *
+ * @author huyc
+ * @date 2022-06-20 17:54:40
+ */
+@Data
+public class EmployeeProjectNewOldVO implements Serializable {
+
+	private static final long serialVersionUID = 1L;
+
+	/**
+	 * 变更前的项目档案
+	 */
+	private TEmployeeProject oldProjectEmployee;
+
+	/**
+	 * 变更后的项目档案
+	 */
+	private TEmployeeProject newProjectEmployee;
+
+}

yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/service/impl/TEmployeeProjectServiceImpl.java

@@ -38,10 +38,7 @@ import com.yifu.cloud.plus.v1.yifu.archives.mapper.TEmployeeProjectMapper;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TEmployeeLogService;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TEmployeeProjectService;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TSettleDomainService;
-import com.yifu.cloud.plus.v1.yifu.archives.vo.EmployeeProjectExportVO;
-import com.yifu.cloud.plus.v1.yifu.archives.vo.EmployeeProjectUpdateVO;
-import com.yifu.cloud.plus.v1.yifu.archives.vo.EmployeeProjectVO;
-import com.yifu.cloud.plus.v1.yifu.archives.vo.EmployeeXProjectVO;
+import com.yifu.cloud.plus.v1.yifu.archives.vo.*;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
 import com.yifu.cloud.plus.v1.yifu.common.core.exception.ErrorCodes;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.*;
@@ -49,7 +46,6 @@ import com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser;
 import com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 import org.springframework.validation.BindingResult;
@@ -194,6 +190,7 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 	}
 
 	@Override
+	@Transactional
 	public R removeProjectInfo(String id) {
 		TEmployeeProject tEmployeeProject = this.getById(id);
 
@@ -204,9 +201,10 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 		this.removeById(id);
 
 		TEmployeeInfo tEmployeeInfoCop = tEmployeeInfoMapper.selectById(tEmployeeInfo.getId());
-
+		List<String> idList = new ArrayList<>();
+		idList.add(id);
 		//从剩下的项目档案中查找员工类型并更新
-		setEmpNature(tEmployeeProject.getEmpIdcard(),tEmployeeInfo);
+		setEmpNature(tEmployeeProject.getEmpIdcard(), tEmployeeInfo, idList);
 		tEmployeeInfoMapper.updateById(tEmployeeInfo);
 		//更新操作日志
 		tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[0], tEmployeeInfoCop.getId(), "", tEmployeeInfoCop, tEmployeeInfo);
@@ -296,8 +294,8 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 				}
 				tEmployeeInfoMapper.updateById(tEmployeeInfo);
 
-				tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[0], tEmployeeInfo.getId(), "", tEmployeeProjectOld, tEmployeeInfo);
-				tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[1], "", tEmployeeProject.getId(), tEmployeeInfoOld, tEmployeeProject);
+				tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[0], tEmployeeInfo.getId(), "", tEmployeeInfoOld, tEmployeeInfo);
+				tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[1], "", tEmployeeProject.getId(), tEmployeeProjectOld, tEmployeeProject);
 				if (CommonConstants.ONE_STRING.equals(code)) {
 					return R.ok(null, "减项减档成功");
 				} else {
@@ -313,9 +311,24 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 		// 通用校验获取失败的数据
 		List<ErrorMessage> errorMessageList = (List<ErrorMessage>) bindingResult.getTarget();
 
+		//项目档案更新list
+		List<TEmployeeProject> updProjectList = new ArrayList<>();
+		//人员档案更新list
+		List<TEmployeeInfo> updList = new ArrayList<>();
+		// 新老档案List
+		List<EmployeeNewOldVO> updateList = new ArrayList<>();
+		// 新老档案vo
+		EmployeeNewOldVO newOld;
+		// 新老项目档案vo
+		EmployeeProjectNewOldVO newOldProject;
+		// 新老项目档案List
+		List<EmployeeProjectNewOldVO> updateProjectList = new ArrayList<>();
+
+		List<EmployeeXProjectVO> selectList = excelVOList.stream().filter(e -> e.getIsLeaveEmployee().equals(CommonConstants.ONE_STRING)).collect(Collectors.toList());
 		// 执行数据插入操作 组装 PostDto
 		for (int i = 0; i < excelVOList.size(); i++) {
 			EmployeeXProjectVO excel = excelVOList.get(i);
+
 			//根据身份证和项目编码获取项目档案
 			TEmployeeProject tEmployeeProject = this.getOne(Wrappers.<TEmployeeProject>query().lambda()
 					.eq(TEmployeeProject::getEmpIdcard, excel.getEmpIdcard())
@@ -328,44 +341,90 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 				if (tEmployeeProject.getInsuranceStatus() != CommonConstants.dingleDigitIntArray[0] || tEmployeeProject.getSocialStatus() != CommonConstants.dingleDigitIntArray[0] ||
 						tEmployeeProject.getFundStatus() != CommonConstants.dingleDigitIntArray[0]) {
 					errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.ARCHIVES_PROJECT_CHANGE_NOT_EXIST)));
-				} else {
+				} else if (CommonConstants.ONE_STRING.equals(excel.getIsLeaveEmployee())) {
+
+					//查询该人员其他的项目档案
+					List<TEmployeeProject> list = this.list(Wrappers.<TEmployeeProject>query().lambda()
+							.ne(TEmployeeProject::getDeptNo, tEmployeeProject.getDeptNo())
+							.eq(TEmployeeProject::getEmpIdcard, tEmployeeProject.getEmpIdcard())
+							.eq(TEmployeeProject::getDeleteFlag, CommonConstants.STATUS_NORMAL)
+							.eq(TEmployeeProject::getProjectStatus, CommonConstants.ZERO_INT));
+
 					TEmployeeInfo tEmployeeInfo = tEmployeeInfoMapper.selectById(tEmployeeProject.getEmpId());
-					if (CommonConstants.ONE_STRING.equals(excel.getIsLeaveEmployee())) {
-
-						//查询该人员其他的项目档案
-						List<TEmployeeProject> list = this.list(Wrappers.<TEmployeeProject>query().lambda()
-								.ne(TEmployeeProject::getDeptNo, tEmployeeProject.getDeptNo())
-								.eq(TEmployeeProject::getEmpIdcard, tEmployeeProject.getEmpIdcard())
-								.eq(TEmployeeProject::getDeleteFlag, CommonConstants.STATUS_NORMAL)
-								.eq(TEmployeeProject::getProjectStatus, CommonConstants.ZERO_INT));
-
-						if (tEmployeeProject.getIsLeaveEmployee() == CommonConstants.dingleDigitIntArray[1]) {
-							if (Common.isNotNull(list)) {
-								errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.QT_PROJECT_CHANGE_NOT_EXIST)));
-							}else {
-								tEmployeeInfo.setFileStatus(CommonConstants.dingleDigitIntArray[1]);
-								tEmployeeInfo.setLeaveReason(excel.getLeaveReason());
-								tEmployeeInfo.setLeaveRemark(excel.getLeaveRemark());
-								tEmployeeInfo.setLeaveTime(LocalDateTime.now());
+					if (Common.isNotNull(list)) {
+						boolean flag = false;
+						for (TEmployeeProject tEmployeeProject1 : list) {
+							if (!selectList.stream().anyMatch(e -> saveCheck(e, tEmployeeProject1))) {
+								flag = true;
 							}
 						}
+						if (flag) {
+							tEmployeeInfo.setFileStatus(CommonConstants.dingleDigitIntArray[1]);
+							tEmployeeInfo.setLeaveReason(excel.getLeaveReason());
+							tEmployeeInfo.setLeaveRemark(excel.getLeaveRemark());
+							tEmployeeInfo.setLeaveTime(LocalDateTime.now());
+
+							List<String> idList = list.stream().map(TEmployeeProject::getId).collect(Collectors.toList());
+							//从剩下的项目档案中查找员工类型并更新
+							setEmpNature(tEmployeeProject.getEmpIdcard(), tEmployeeInfo, idList);
+							updList.add(tEmployeeInfo);
+						} else {
+							errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.QT_PROJECT_CHANGE_NOT_EXIST)));
+						}
+					} else {
+						tEmployeeInfo.setFileStatus(CommonConstants.dingleDigitIntArray[1]);
+						tEmployeeInfo.setLeaveReason(excel.getLeaveReason());
+						tEmployeeInfo.setLeaveRemark(excel.getLeaveRemark());
+						tEmployeeInfo.setLeaveTime(LocalDateTime.now());
+						updList.add(tEmployeeInfo);
 					}
-					tEmployeeProject.setProjectStatus(CommonConstants.dingleDigitIntArray[1]);
-					tEmployeeProject.setLeaveReason(excel.getLeaveReason());
-					tEmployeeProject.setLeaveRemark(excel.getLeaveRemark());
-					tEmployeeProject.setLeaveTime(LocalDateTime.now());
-					this.updateById(tEmployeeProject);
-
-					//从剩下的项目档案中查找员工类型并更新
-					setEmpNature(tEmployeeProject.getEmpIdcard(), tEmployeeInfo);
-					tEmployeeInfoMapper.updateById(tEmployeeInfo);
-					tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[0], tEmployeeInfo.getId(), "", tEmployeeProjectOld, tEmployeeInfo);
-					tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[1], "", tEmployeeProject.getId(), tEmployeeInfoOld, tEmployeeProject);
+					newOld = new EmployeeNewOldVO();
+					newOld.setOldEmployee(tEmployeeInfoOld);
+					newOld.setNewEmployee(tEmployeeInfo);
+					updateList.add(newOld);
 				}
+				tEmployeeProject.setProjectStatus(CommonConstants.dingleDigitIntArray[1]);
+				tEmployeeProject.setLeaveReason(excel.getLeaveReason());
+				tEmployeeProject.setLeaveRemark(excel.getLeaveRemark());
+				tEmployeeProject.setLeaveTime(LocalDateTime.now());
+				updProjectList.add(tEmployeeProject);
+
+				newOldProject = new EmployeeProjectNewOldVO();
+				newOldProject.setOldProjectEmployee(tEmployeeProjectOld);
+				newOldProject.setNewProjectEmployee(tEmployeeProject);
+				updateProjectList.add(newOldProject);
+			} else {
+				errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.PROJECT_PERSON_SEARCH_EXIT)));
 			}
 		}
 		if (errorMessageList.size() > CommonConstants.ZERO_INT) {
 			return R.failed(errorMessageList);
+		} else {
+			//更新项目档案
+			if (updProjectList.size() > CommonConstants.dingleDigitIntArray[0]) {
+				this.updateBatchById(updProjectList);
+			}
+			//更新人员档案
+			if (updList.size() > CommonConstants.dingleDigitIntArray[0]) {
+				for (TEmployeeInfo tEmployeeInfo : updList) {
+					tEmployeeInfoMapper.updateById(tEmployeeInfo);
+				}
+			}
+			// 记录变更日志
+			if (updateList.size() > CommonConstants.dingleDigitIntArray[0]) {
+				for (EmployeeNewOldVO newOldInfo : updateList) {
+					tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[0]
+							, newOldInfo.getOldEmployee().getId(), ""
+							, newOldInfo.getOldEmployee(), newOldInfo.getNewEmployee());
+				}
+			}
+			if (updateProjectList.size() > CommonConstants.dingleDigitIntArray[0]) {
+				for (EmployeeProjectNewOldVO newOldVO : updateProjectList) {
+					tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[1]
+							, "", newOldVO.getNewProjectEmployee().getId()
+							, newOldVO.getOldProjectEmployee(), newOldVO.getNewProjectEmployee());
+				}
+			}
 		}
 		return R.ok();
 	}
@@ -430,6 +489,7 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 
 	/**
 	 * 新增档案操作记录
+	 *
 	 * @param excelVOList
 	 * @param errorMessageList
 	 * @param
@@ -544,21 +604,23 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 			}
 		}
 
-		try {
-			if (updateList.size() > CommonConstants.dingleDigitIntArray[0]) {
-				tEmployeeInfoMapper.updateExcelEmployeeInfo(updateList);
-			}
-			if (proInsList.size() > CommonConstants.dingleDigitIntArray[0]) {
-				baseMapper.insertExcelEmpProject(proInsList);
-				List<String> idList = proInsList.stream().map(TEmployeeProject::getEmpIdcard).collect(Collectors.toList());
-				List<TEmployeeInfo> updList = tEmployeeInfoMapper.selectList(Wrappers.<TEmployeeInfo>query().lambda().in(TEmployeeInfo::getEmpIdcard, idList));
-				baseMapper.updateEmpIdById(updList);
-			}
-			if (proupdateList.size() > CommonConstants.dingleDigitIntArray[0]) {
-				baseMapper.updateExcelEmpProject(proupdateList);
+		if (CollUtil.isEmpty(errorMessageList)) {
+			try {
+				if (updateList.size() > CommonConstants.dingleDigitIntArray[0]) {
+					tEmployeeInfoMapper.updateExcelEmployeeInfo(updateList);
+				}
+				if (proInsList.size() > CommonConstants.dingleDigitIntArray[0]) {
+					baseMapper.insertExcelEmpProject(proInsList);
+					List<String> idList = proInsList.stream().map(TEmployeeProject::getEmpIdcard).collect(Collectors.toList());
+					List<TEmployeeInfo> updList = tEmployeeInfoMapper.selectList(Wrappers.<TEmployeeInfo>query().lambda().in(TEmployeeInfo::getEmpIdcard, idList));
+					baseMapper.updateEmpIdById(updList);
+				}
+				if (proupdateList.size() > CommonConstants.dingleDigitIntArray[0]) {
+					baseMapper.updateExcelEmpProject(proupdateList);
+				}
+			} catch (Exception e) {
+				log.error("数据更新异常", e);
 			}
-		} catch (Exception e) {
-			log.error("数据更新异常", e);
 		}
 	}
 
@@ -999,8 +1061,9 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 	}
 
 	//从剩下的项目档案中查找员工类型
-	public void setEmpNature(String empIdcard,TEmployeeInfo tEmployeeInfo) {
+	public void setEmpNature(String empIdcard, TEmployeeInfo tEmployeeInfo, List<String> idlist) {
 		List<TEmployeeProject> list = this.list(Wrappers.<TEmployeeProject>query().lambda()
+				.notIn(TEmployeeProject::getId, idlist)
 				.eq(TEmployeeProject::getEmpIdcard, empIdcard)
 				.eq(TEmployeeProject::getDeleteFlag, CommonConstants.STATUS_NORMAL)
 				.eq(TEmployeeProject::getProjectStatus, CommonConstants.ZERO_INT));
@@ -1018,4 +1081,12 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 			}
 		}
 	}
+
+	public boolean saveCheck(EmployeeXProjectVO employeeXProjectVO, TEmployeeProject tEmployeeProject) {
+		if (employeeXProjectVO.getDeptNo().equals(tEmployeeProject.getDeptNo()) &&
+				employeeXProjectVO.getEmpIdcard().equals(tEmployeeProject.getEmpIdcard())) {
+			return true;
+		}
+		return false;
+	}
 }

yifu-common/yifu-common-core/src/main/java/com/yifu.cloud.plus.v1/yifu/common/core/exception/ErrorCodes.java

@@ -296,7 +296,7 @@ public interface ErrorCodes {
 	 */
 	String ARCHIVES_PROJECT_CHANGE_NOT_EXIST = "archives.project.change.not.exist";
 	/**
-	 * 存在其他草稿/已审核的状态的项目，不允许同步减档
+	 * 该人员存在其他进行中的项目，禁止同步减档！
 	 */
 	String QT_PROJECT_CHANGE_NOT_EXIST = "qt.project.change.not.exist";
 	/**

yifu-common/yifu-common-core/src/main/resources/i18n/messages_zh_CN.properties

@@ -98,7 +98,7 @@ archives.project.change.not.exist=\u4EBA\u5458\u5728\u8BE5\u9879\u76EE\u4E0B\u5B
 
 archives.project.emp.lose.fee.not.empty=\u4E0D\u826F\u8BB0\u5F55\u8D39\u7528\u635F\u5931\u548C\u5176\u4ED6\u635F\u5931\u4E0D\u53EF\u540C\u65F6\u4E3A\u7A7A
 
-qt.project.change.not.exist=\u5B58\u5728\u5176\u4ED6\u8349\u7A3F/\u5DF2\u5BA1\u6838\u7684\u72B6\u6001\u7684\u9879\u76EE\uFF0C\u4E0D\u5141\u8BB8\u540C\u6B65\u51CF\u6863
+qt.project.change.not.exist=\u8BE5\u4EBA\u5458\u5B58\u5728\u5176\u4ED6\u8FDB\u884C\u4E2D\u7684\u9879\u76EE\uFF0C\u7981\u6B62\u540C\u6B65\u51CF\u6863
 project.search.not.exist=\u672A\u627E\u5230\u5BF9\u5E94\u7684\u9879\u76EE\uFF0C\u8BF7\u6838\u5B9E
 
 change.strat.month.exit=\u5212\u8F6C\u8D77\u59CB\u6708\u4E0D\u80FD\u4E3A\u7A7A