Merge branch 'develop' into feature-zhaji

yifu-archives/yifu-archives-api/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/entity/TEmployeeContractInfo.java

@@ -462,4 +462,8 @@ public class TEmployeeContractInfo extends BaseEntity {
 	@Schema(description = "创建时间止")
 	private String createTimeEnd;
 
+	@TableField(exist = false)
+	@Schema(description = "归档列表查询标志，1：是归档，去除作废、终止两种")
+	private Integer isFilePage;
+
 }

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

 package com.yifu.cloud.plus.v1.yifu.archives.vo;
 
+import lombok.Data;
+
 import java.util.List;
 
 /**
@@ -8,6 +10,7 @@ import java.util.List;
  * @Description  派单新增档案|项目档案|员工合同
  * @Version 1.0
  */
+@Data
 public class DispatchAddVo {
 	/**
 	 *  员工档案

yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/controller/FddContractAttachInfoController.java

@@ -172,18 +172,22 @@ public class FddContractAttachInfoController {
 			} else {
 				if (null != util1.getEntityList()) {
 					List<ErrorMessage> errorInfo = fddContractAttachInfoService.batchAdd(util1.getEntityList());
-					Map<String,Object> variableMap = new HashMap<>();
-					Map<Integer,Object> map = new HashMap<>();
-					boolean allExitContract = errorInfo.stream().allMatch(e-> e.getMessage().equals("存在“在用”的合同"));
-					if (allExitContract) {
-						variableMap.put("allMatch","true");
-						for (ErrorMessage errorMessage :errorInfo){
-							map.put(errorMessage.getLineNum(),util1.getEntityList().get(errorMessage.getLineNum()-2));
+					if (errorInfo.size() > CommonConstants.ZERO_INT) {
+						Map<String, Object> variableMap = new HashMap<>();
+						Map<Integer, Object> map = new HashMap<>();
+						boolean allExitContract = errorInfo.stream().allMatch(e -> e.getMessage().equals("存在“在用”的合同"));
+						if (allExitContract) {
+							variableMap.put("allMatch", "true");
+							for (ErrorMessage errorMessage : errorInfo) {
+								map.put(errorMessage.getLineNum(), util1.getEntityList().get(errorMessage.getLineNum() - 2));
+							}
+							variableMap.put("data", map);
+							return R.ok(variableMap, "存在“在用”的合同");
 						}
-						variableMap.put("data",map);
-						return R.ok(variableMap,"存在“在用”的合同");
+						return R.failed(errorInfo);
+					} else {
+						return R.ok(null,"保存成功");
 					}
-					return R.failed(errorInfo,"");
 				} else {
 					return R.ok(null,"无数据可导入");
 				}
@@ -271,6 +275,9 @@ public class FddContractAttachInfoController {
 			return R.failed("数据为空！");
 		}
 		List<ErrorMessage> errorInfo = fddContractAttachInfoService.sendTask(entityList);
-		return R.ok(errorInfo);
+		if (errorInfo.size() > CommonConstants.ZERO_INT) {
+			return R.failed(errorInfo);
+		}
+		return R.ok(null,"保存成功");
 	}
 }

yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/controller/TEmployeeContractInfoController.java

@@ -70,7 +70,7 @@ public class TEmployeeContractInfoController {
 	@Operation(summary = "归档分页查询（审核通过的数据（后面加上权限：自己创建的））", description = "归档分页查询")
 	@GetMapping("/filingPage")
 	public R<IPage<TEmployeeContractInfo>> getFilingPage(Page<TEmployeeContractInfo> page, TEmployeeContractInfo tEmployeeContractInfo) {
-		tEmployeeContractInfo.setSituation(EmployeeConstants.SITUATION_SIX);
+		tEmployeeContractInfo.setIsFilePage(CommonConstants.ONE_INT);
 		tEmployeeContractInfo.setAuditStatus(CommonConstants.dingleDigitIntArray[2]);
 		return new R<>(tEmployeeContractInfoService.getTEmployeeContractInfoPage(page, tEmployeeContractInfo));
 	}

yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/controller/TEmployeeInfoController.java

@@ -243,6 +243,19 @@ public class TEmployeeInfoController {
 		return R.ok(tEmployeeInfoService.getById(id));
 	}
 
+	/**
+	 * @param empId
+	 * @Description: 内部接口获取档案基本信息
+	 * @Author: hgw
+	 * @Date: 2022/7/21 14:47
+	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo>
+	 **/
+	@Inner
+	@GetMapping("/inner/getByEmpId")
+	public TEmployeeInfo getByEmpId(@RequestParam String empId) {
+		return tEmployeeInfoService.getById(empId);
+	}
+
 	/**
 	 * @param empName   姓名
 	 * @param empIdCard 身份证

yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/controller/TEmployeeProjectController.java

@@ -22,11 +22,13 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TEmployeeProjectService;
+import com.yifu.cloud.plus.v1.yifu.archives.vo.EmpDispatchAddVo;
 import com.yifu.cloud.plus.v1.yifu.archives.vo.EmployeeProjectExportVO;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.ErrorMessage;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
 import com.yifu.cloud.plus.v1.yifu.common.log.annotation.SysLog;
+import com.yifu.cloud.plus.v1.yifu.common.security.annotation.Inner;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
@@ -276,4 +278,17 @@ public class TEmployeeProjectController {
 	public R<Map<String,String>> getProjectByIdCard(@RequestParam String empIdCard) {
 		return tEmployeeProjectService.getProjectByIdCard(empIdCard);
 	}
+
+	/**
+	 * @param employeeProject
+	 * @Description: 获取项目档案
+	 * @Author: hgw
+	 * @Date: 2022/7/21 15:10
+	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject>
+	 **/
+	@Inner
+	@PostMapping("/inner/getByEmpIdAndDeptId")
+	public TEmployeeProject getByEmpIdAndDeptId(@RequestBody TEmployeeProject employeeProject) {
+		return  tEmployeeProjectService.getByEmpIdAndDeptId(employeeProject.getEmpId(), employeeProject.getDeptId());
+	}
 }

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

@@ -18,6 +18,7 @@
 package com.yifu.cloud.plus.v1.yifu.archives.service;
 
 import com.baomidou.mybatisplus.extension.service.IService;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.FddContractAttachInfo;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeLog;
 import com.yifu.cloud.plus.v1.yifu.common.core.vo.YifuUser;
 
@@ -54,4 +55,17 @@ public interface TEmployeeLogService extends IService<TEmployeeLog> {
 	 * @return
 	 **/
 	<T> TEmployeeLog saveModificationRecord(Integer type, String empId, String projectId, T oldInfo, T newInfo, YifuUser user);
+
+	/**
+	 * 生成修改记录
+	 * @Author pwang
+	 * @Date 2022-06-22 11:32
+	 * @param type 类型：0人员档案；1项目档案；2人员和项目档案；3员工合同更新
+	 * @param empId 档案id
+	 * @param projectId 项目id
+	 * @param oldInfo
+	 * @param newInfo
+	 * @return
+	 **/
+	<T> TEmployeeLog saveModificationRecord(Integer type, String empId, String projectId, T oldInfo, T newInfo, FddContractAttachInfo fddContractAttachInfo);
 }

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

@@ -176,5 +176,15 @@ public interface TEmployeeProjectService extends IService<TEmployeeProject> {
 
 	R getItemByEmpNo(String empIdcard, String empNo);
 
+	/**
+	 * @param empId
+	 * @param deptId
+	 * @Description: 获取项目信息
+	 * @Author: hgw
+	 * @Date: 2022/7/21 15:09
+	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject>
+	 **/
+	TEmployeeProject getByEmpIdAndDeptId(String empId, String deptId);
+
 	R<Map<String, String>> getProjectByIdCard(String empIdCard);
 }

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

@@ -197,7 +197,6 @@ public class FddContractAttachInfoServiceImpl extends ServiceImpl<FddContractAtt
 				});
 			}
 			i++;
-			errorList.add(new ErrorMessage(i, "保存成功", CommonConstants.GREEN));
 		}
 		return errorList;
 	}
@@ -259,7 +258,7 @@ public class FddContractAttachInfoServiceImpl extends ServiceImpl<FddContractAtt
 					tEmployeeProject.setContractStatus(CommonConstants.ONE_INT);
 					employeeProjectMapper.updateById(tEmployeeProject);
 					//保存操作记录
-					tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[1], "", tEmployeeProject.getId(), tEmployeeProjectCompare, tEmployeeProject);
+					tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[1], "", tEmployeeProject.getId(), tEmployeeProjectCompare, tEmployeeProject,fddContractAttachInfo);
 
 					//更新人员档案
 					tEmployeeInfo.setEmpPhone(fddContractAttachInfo.getEmpPhone());
@@ -286,7 +285,7 @@ public class FddContractAttachInfoServiceImpl extends ServiceImpl<FddContractAtt
 						//更新合同id
 						updateContractId(fddContractInfo, fddContractAttachInfo, newEmployeeContractInfo2);
 					}
-					doJointTask.doUpdateEmployeeInfo(updateList, user);
+					doJointTask.updateFddEmployeeInfo(updateList, fddContractAttachInfo);
 				} else {
 					//判断人员档案是否存在，不存在就新增人员档案，存在则判断档案状态，如果是减档就复档
 					if (Common.isNotNull(tEmployeeInfo)) {
@@ -312,7 +311,7 @@ public class FddContractAttachInfoServiceImpl extends ServiceImpl<FddContractAtt
 						saveTEmployeeContractInfo(newEmployeeContractInfo1, fddContractAttachInfo, settleDomain, fddContractTemplate, tEmployeeInfo, tCustomerInfo, project);
 						//更新合同id
 						updateContractId(fddContractInfo, fddContractAttachInfo, newEmployeeContractInfo1);
-						doJointTask.doUpdateEmployeeInfo(updateList, user);
+						doJointTask.updateFddEmployeeInfo(updateList, fddContractAttachInfo);
 					} else {
 						//新增人员档案
 						TEmployeeInfo newEmployeeInfo = new TEmployeeInfo();
@@ -479,7 +478,6 @@ public class FddContractAttachInfoServiceImpl extends ServiceImpl<FddContractAtt
 							}
 						});
 					}
-					errorList.add(new ErrorMessage(i, "保存成功", CommonConstants.GREEN));
 				}
 			} else {
 				errorList.add(new ErrorMessage(i, "无数据保存"));

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

@@ -586,7 +586,7 @@ public class FddContractInfoServiceImpl extends ServiceImpl<FddContractInfoMappe
 						// 1：保存为
 						TAttaInfo attaInfo = initUnitAttaForInsert(name, key, (long)rspData.getFileBytes().length);
 						attaInfo.setRelationType(CommonConstants.FOUR_STRING);
-						attaInfo.setDomainId(fddContractInfo.getId());
+						attaInfo.setDomainId(entity.getContractId());
 						tAttaInfoService.save(attaInfo);
 
 						FddContractAttachInfo fddContractAttachInfo = fddContractAttachInfoMapper.selectOne(Wrappers.<FddContractAttachInfo>query().lambda()

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

@@ -29,10 +29,10 @@ import com.yifu.cloud.plus.v1.yifu.archives.constants.ArchivesConstants;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmpBadRecord;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmpContractAlert;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeContractInfo;
-import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
 import com.yifu.cloud.plus.v1.yifu.archives.mapper.TEmpContractAlertMapper;
 import com.yifu.cloud.plus.v1.yifu.archives.mapper.TEmployeeContractInfoMapper;
-import com.yifu.cloud.plus.v1.yifu.archives.mapper.TEmployeeInfoMapper;
+import com.yifu.cloud.plus.v1.yifu.archives.mapper.TEmployeeProjectMapper;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TEmpContractAlertService;
 import com.yifu.cloud.plus.v1.yifu.archives.vo.ContractAlertSearchVo;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
@@ -63,7 +63,7 @@ public class TEmpContractAlertServiceImpl extends ServiceImpl<TEmpContractAlertM
 
 	private final TEmployeeContractInfoMapper  contractInfoMapper;
 
-	private final TEmployeeInfoMapper employeeInfoMapper;
+	private final TEmployeeProjectMapper projectMapper;
 
 	@Override
 	public IPage<TEmpContractAlert> pageDiy(Page page, ContractAlertSearchVo searchVo) {
@@ -216,6 +216,7 @@ public class TEmpContractAlertServiceImpl extends ServiceImpl<TEmpContractAlertM
 				.lambda().eq(TEmployeeContractInfo::getAuditStatus,CommonConstants.TWO_STRING)
 				.isNotNull(TEmployeeContractInfo::getAuditTimeLast)
 				.eq(TEmployeeContractInfo::getContractType,"1")
+				.eq(TEmployeeContractInfo::getInUse,CommonConstants.ZERO_STRING)
 				.eq(TEmployeeContractInfo::getWorkFlag,CommonConstants.ZERO_STRING)
 				.le(TEmployeeContractInfo::getContractEnd,DateUtil.dateIncreaseByDay(
 						DateUtil.dateIncreaseByMonth(DateUtil.getCurrentDateTime(),
@@ -254,10 +255,13 @@ public class TEmpContractAlertServiceImpl extends ServiceImpl<TEmpContractAlertM
 	private void extracted(Date nowDate,
 						   TEmployeeContractInfo contract,
 						   Map<String,TEmpContractAlert> alertMap) {
-		TEmployeeInfo employeeInfo = employeeInfoMapper.selectById(contract.getEmpId());
-		if (Common.isNotNull(employeeInfo)
-				&& !CommonConstants.ZERO_STRING.equals(employeeInfo.getEmpNatrue())
-				&& !CommonConstants.ONE_STRING.equals(employeeInfo.getEmpNatrue())){
+		TEmployeeProject project = projectMapper.selectOne(Wrappers.<TEmployeeProject>query().lambda()
+				.eq(TEmployeeProject::getEmpId,contract.getEmpId())
+				.eq(TEmployeeProject::getDeptNo,contract.getDeptNo())
+				.last(CommonConstants.LAST_ONE_SQL));
+		if (Common.isNotNull(project)
+				&& !CommonConstants.ZERO_STRING.equals(project.getEmpNatrue())
+				&& !CommonConstants.ONE_STRING.equals(project.getEmpNatrue())){
 			return;
 		}
 		TEmpContractAlert alert = alertMap.get(contract.getEmpIdcard());

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

@@ -19,6 +19,7 @@ package com.yifu.cloud.plus.v1.yifu.archives.service.impl;
 import com.alibaba.fastjson.JSON;
 import com.alibaba.fastjson.serializer.SerializerFeature;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.FddContractAttachInfo;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeLog;
 import com.yifu.cloud.plus.v1.yifu.archives.mapper.TEmployeeLogMapper;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TEmployeeLogService;
@@ -94,6 +95,36 @@ public class TEmployeeLogServiceImpl extends ServiceImpl<TEmployeeLogMapper, TEm
 		return null;
 	}
 
+	@Override
+	public <T> TEmployeeLog saveModificationRecord(Integer type, String empId, String projectId, T oldInfo, T newInfo, FddContractAttachInfo fddContractAttachInfo) {
+		try{
+			//比较记录不影响业务逻辑，用try套住
+			//比较差异
+			String differenceKey = HrEquator.comparisonValue(oldInfo, newInfo);
+			//如果有差异保存差异
+			if(!Common.isEmpty(differenceKey)){
+				TEmployeeLog employeeLog = new TEmployeeLog();
+				employeeLog.setProjectId(projectId);
+				employeeLog.setType(type);
+				employeeLog.setEmpId(empId);
+				employeeLog.setCreateTime(LocalDateTime.now());
+				if (Common.isNotNull(fddContractAttachInfo)) {
+					employeeLog.setCreateBy(fddContractAttachInfo.getCreateBy());
+					employeeLog.setCreateName(fddContractAttachInfo.getCreateName());
+					employeeLog.setUpdateBy(fddContractAttachInfo.getUpdateBy());
+				}
+				employeeLog.setOldInfo(JSON.toJSONString(oldInfo,features));
+				employeeLog.setNewInfo(JSON.toJSONString(newInfo,features));
+				employeeLog.setDifferenceInfo(differenceKey);
+				baseMapper.insert(employeeLog);
+				return employeeLog;
+			}
+		}catch (Exception e){
+			log.error(JSON.toJSON(oldInfo)+"插入修改记录报错>>>",e);
+		}
+		return null;
+	}
+
 	private SerializerFeature[] features = new SerializerFeature[] {
 			WriteMapNullValue, WriteNullNumberAsZero, WriteNullListAsEmpty,
 			WriteNullStringAsEmpty,WriteDateUseDateFormat

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

@@ -1358,6 +1358,20 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 		return R.ok(map);
 	}
 
+	@Override
+	public TEmployeeProject getByEmpIdAndDeptId(String empId, String deptId) {
+		TEmployeeProject employeeProject = null;
+		if (Common.isEmpty(empId) || Common.isEmpty(deptId)) {
+			return employeeProject;
+		}
+		employeeProject = this.getOne(Wrappers.<TEmployeeProject>query().lambda()
+				.eq(TEmployeeProject::getEmpId, empId)
+				.eq(TEmployeeProject::getDeptId, deptId)
+				.eq(TEmployeeProject::getProjectStatus, CommonConstants.ZERO_INT)
+				.eq(TEmployeeProject::getDeleteFlag, CommonConstants.ZERO_STRING).last(CommonConstants.LAST_ONE_SQL));
+		return employeeProject;
+	}
+
 	@Override
 	public R<Map<String, String>> getProjectByIdCard(String empIdCard) {
 		List<TEmployeeProject> projects = baseMapper.selectList(Wrappers.<TEmployeeProject>query().lambda()

yifu-archives/yifu-archives-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/archives/utils/DoJointTask.java

 package com.yifu.cloud.plus.v1.yifu.archives.utils;
 
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.FddContractAttachInfo;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo;
 import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TEmployeeInfoService;
@@ -77,4 +78,44 @@ public class DoJointTask {
         log.info("档案-批量更新人员档案结束");
     }
 
+	/**
+	 * @Description: 合同-批量更换负责人
+	 * @Author: huyc
+	 * @Date: 2022-7-8
+	 * @return: void
+	 **/
+	@Async
+	public void updateFddEmployeeInfo(List<TEmployeeInfo> tEmployeeInfoList, FddContractAttachInfo fddContractAttachInfo) {
+		log.info("法大大档案-批量更新人员档案-线程开始");
+		try {
+			for(TEmployeeInfo tEmployeeInfo:tEmployeeInfoList) {
+				TEmployeeInfo tEmployeeInfoOld = tEmployeeInfoService.getById(tEmployeeInfo.getId());
+				//查询该人员所有的项目档案
+				List<TEmployeeProject> list = tEmployeeProjectService.list(Wrappers.<TEmployeeProject>query().lambda()
+						.eq(TEmployeeProject::getEmpIdcard, tEmployeeInfo.getEmpIdcard())
+						.eq(TEmployeeProject::getDeleteFlag, CommonConstants.STATUS_NORMAL)
+						.eq(TEmployeeProject::getProjectStatus, CommonConstants.ZERO_INT));
+				if (Common.isNotNull(list)) {
+					Set<String> empNatrue = list.stream().map(TEmployeeProject::getEmpNatrue).collect(Collectors.toSet());
+					if (empNatrue.stream().anyMatch(e -> e.equals(CommonConstants.ZERO_STRING))) {
+						tEmployeeInfo.setEmpNatrue(CommonConstants.ZERO_STRING);
+					} else if (empNatrue.stream().anyMatch(e -> e.equals(CommonConstants.ONE_STRING))) {
+						tEmployeeInfo.setEmpNatrue(CommonConstants.ONE_STRING);
+					} else {
+						tEmployeeInfo.setEmpNatrue(CommonConstants.TWO_STRING);
+					}
+					tEmployeeInfo.setProjectNum(list.size());
+				} else {
+					tEmployeeInfo.setProjectNum(CommonConstants.ZERO_INT);
+				}
+				tEmployeeInfoService.updateById(tEmployeeInfo);
+				tEmployeeLogService.saveModificationRecord(CommonConstants.dingleDigitIntArray[0]
+						, tEmployeeInfo.getId(), "", tEmployeeInfoOld, tEmployeeInfo,fddContractAttachInfo);
+			}
+		} catch (Exception e) {
+			log.error("法大大档案-批量更新人员档案错误", e);
+		}
+		log.info("法大大档案-批量更新人员档案结束");
+	}
+
 }

yifu-archives/yifu-archives-biz/src/main/resources/mapper/TEmployeeContractInfoMapper.xml

@@ -245,12 +245,10 @@
 				AND a.SUBJECT_UNIT = #{tEmployeeContractInfo.subjectUnit}
 			</if>
 			<if test="tEmployeeContractInfo.situation != null and tEmployeeContractInfo.situation.trim() != ''">
-				<if test="tEmployeeContractInfo.situation == '作废' ">
-					AND a.SITUATION != '作废' AND a.SITUATION != '终止'
-				</if>
-				<if test="tEmployeeContractInfo.situation != '作废' ">
-					AND a.SITUATION = #{tEmployeeContractInfo.situation}
-				</if>
+				AND a.SITUATION = #{tEmployeeContractInfo.situation}
+			</if>
+			<if test="tEmployeeContractInfo.isFilePage != null">
+				AND a.SITUATION != '作废' AND a.SITUATION != '终止'
 			</if>
 			<if test="tEmployeeContractInfo.contractTerm != null">
 				AND a.CONTRACT_TERM = #{tEmployeeContractInfo.contractTerm}

yifu-common/yifu-common-core/src/main/java/com/yifu.cloud.plus.v1/yifu/common/core/constant/CommonConstants.java

@@ -337,6 +337,12 @@ public interface CommonConstants {
 	 */
 	int ONE_INT_NEGATE = -1;
 
+	/**
+	 * 数字int -1
+	 * @author fxj
+	 */
+	String ONE_STRING_NEGATE = "-1";
+
 	/**
 	 * 数字int -1
 	 * @author fxj

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

@@ -382,4 +382,18 @@ public interface ErrorCodes {
 	 * 新增异常：未找到对应项目编码信息
 	 */
 	String EMP_DISPATCH_PROJECT_NOT_FOUND = "emp.dispatch.project.not.found";
+
+	/**
+	 * 新增异常：派单新增档案失败，请重试
+	 */
+	String EMP_DISPATCH_ADD_EMP_ERROR = "emp.dispatch.add.emp.error";
+	/**
+	 * 新增异常：派单新增合同失败，请重试
+	 */
+	String EMP_DISPATCH_ADD_CONTRACT_ERROR="emp.dispatch.add.contract.error";
+
+	/**
+	 * 新增异常：派单新增项目档案失败，请重试
+	 */
+	String EMP_DISPATCH_ADD_PROJECT_ERROR="emp.dispatch.add.project.error";
 }

yifu-common/yifu-common-core/src/main/java/com/yifu.cloud.plus.v1/yifu/common/core/util/Common.java

@@ -6,6 +6,8 @@ import org.apache.commons.lang.StringUtils;
 
 import java.lang.reflect.Method;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
+import java.text.DecimalFormat;
 import java.util.*;
 import java.util.regex.Matcher;
 import java.util.regex.Pattern;
@@ -345,4 +347,34 @@ public class Common {
 		year = Integer.valueOf(endYear).intValue() - Integer.valueOf(startYear).intValue() ;
 		return year < 0?0:year;
 	}
+
+
+	/**
+	 * 公积金单边小数点格式化
+	 *
+	 * @param money
+	 * @param type
+	 * @return
+	 * @Author fxj
+	 * @Date 2019-09-26
+	 **/
+	public static BigDecimal formatMoneyForFund(BigDecimal money, int type) {
+		DecimalFormat formater = new DecimalFormat("#0.#");
+		if (type == 1) {//四舍五入取整
+			return BigDecimal.valueOf(money.doubleValue()).setScale(0, RoundingMode.HALF_UP);
+		}
+		if (type == 2) {//元一下全部舍去，取整
+			return BigDecimal.valueOf(Math.floor(money.doubleValue())).setScale(0, BigDecimal.ROUND_UP);
+		}
+		if (type == 3) {//见角进元
+			return BigDecimal.valueOf(Math.ceil(BigDecimal.valueOf(money.doubleValue()).setScale(1, RoundingMode.HALF_DOWN).doubleValue())).setScale(0, BigDecimal.ROUND_UP);
+		}
+		if (type == 4) {//保留两位小数
+			return BigDecimal.valueOf(money.doubleValue()).setScale(2, RoundingMode.HALF_UP);
+		}
+		if (type == 5) {//保留一位小数
+			return BigDecimal.valueOf(money.doubleValue()).setScale(1, RoundingMode.HALF_UP);
+		}
+		return money;
+	}
 }

yifu-common/yifu-common-dapr/src/main/java/com/yifu/cloud/plus/v1/yifu/common/dapr/util/ArchivesDaprUtil.java

 package com.yifu.cloud.plus.v1.yifu.common.dapr.util;
 
 import com.alibaba.fastjson.JSON;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
 import com.yifu.cloud.plus.v1.yifu.archives.vo.DispatchAddVo;
 import com.yifu.cloud.plus.v1.yifu.archives.vo.DispatchCheckVo;
 import com.yifu.cloud.plus.v1.yifu.archives.vo.EmpDispatchAddVo;
@@ -100,11 +102,44 @@ public class ArchivesDaprUtil {
 		return res;
 	}
 
-	public R<DispatchAddVo> addDispatchInfo(EmpDispatchAddVo addVo) {
-		R<DispatchAddVo> res = HttpDaprUtil.invokeMethodPost(daprArchivesProperties.getAppUrl(),daprArchivesProperties.getAppId(),"/temployeeinfo/addDispatchInfo" , JSON.toJSONString(addVo), DispatchAddVo.class, SecurityConstants.FROM_IN);
+	public R<EmpDispatchAddVo> addDispatchInfo(EmpDispatchAddVo addVo) {
+		R<EmpDispatchAddVo> res = HttpDaprUtil.invokeMethodPost(daprArchivesProperties.getAppUrl(),daprArchivesProperties.getAppId(),"/temployeeinfo/addDispatchInfo" , JSON.toJSONString(addVo), EmpDispatchAddVo.class, SecurityConstants.FROM_IN);
 		if (Common.isEmpty(res)){
 			return R.failed("新增档案|项目档案|合同信息失败！");
 		}
 		return res;
 	}
+
+	/**
+	 * @param empId
+	 * @Description: 获取档案基本信息
+	 * @Author: hgw
+	 * @Date: 2022/7/21 14:48
+	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo>
+	 **/
+	public R<TEmployeeInfo> getTEmployeeInfoById(String empId) {
+		R<TEmployeeInfo> res = HttpDaprUtil.invokeMethodGet(
+				daprArchivesProperties.getAppUrl(),daprArchivesProperties.getAppId()
+				,"/temployeeinfo/inner/getByEmpId" , empId, TEmployeeInfo.class, SecurityConstants.FROM_IN);
+		if (Common.isEmpty(res)){
+			return R.failed("获取档案信息失败！");
+		}
+		return res;
+	}
+
+	/**
+	 * @Description: 获取项目档案基本信息
+	 * @Author: hgw
+	 * @Date: 2022/7/21 14:48
+	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo>
+	 **/
+	public R<TEmployeeProject> getTEmployeeProjectById(TEmployeeProject employeeProject) {
+		R<TEmployeeProject> res = HttpDaprUtil.invokeMethodPost(
+				daprArchivesProperties.getAppUrl(),daprArchivesProperties.getAppId()
+				,"/temployeeproject/inner/getByEmpIdAndDeptId" , JSON.toJSONString(employeeProject), TEmployeeProject.class, SecurityConstants.FROM_IN);
+		if (Common.isEmpty(res)){
+			return R.failed("获取档案信息失败！");
+		}
+		return res;
+	}
 }

yifu-common/yifu-common-dapr/src/main/resources/daprConfig.properties

-dapr.upms.appUrl=http://yifu-upms.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
+dapr.upms.appUrl=http://localhost:3500/v1.0/invoke/
 dapr.upms.appId=yifu-upms
-dapr.upms.appPort=4000
-dapr.upms.httpPort=3500
-dapr.upms.grpcPort=52000
-dapr.upms.metricsPort=9094
+
 
 #\u6D4B\u8BD5\u73AF\u5883
-dapr.check.appUrl=http://yifu-check.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
+#dapr.check.appUrl=http://yifu-check.qas-mvp.svc.cluster.local:3500/v1.0/invoke/
 #\u672C\u5730
-#dapr.check.appUrl=http://localhost:3502/v1.0/invoke/
+dapr.check.appUrl=http://localhost:3507/v1.0/invoke/
 dapr.check.appId=yifu-check
-dapr.check.appPort=5022
-dapr.check.httpPort=3502
-dapr.check.grpcPort=52002
-dapr.check.metricsPort=9092
+
+
+#\u672C\u5730
+dapr.archives.appUrl=http://localhost:3508/v1.0/invoke/
\ No newline at end of file
+dapr.archives.appId=yifu-archives
+
+
+dapr.social.appUrl=http://localhost:3510/v1.0/invoke/
+dapr.social.appId=yifu-social

yifu-insurances/yifu-insurances-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/insurances/controller/TInsuranceDetailController.java

@@ -154,6 +154,32 @@ public class TInsuranceDetailController {
 		return R.ok(tInsuranceDetailService.getInsuranceExportList(param));
 	}
 
+	/**
+	 * 投保退回
+	 *
+	 * @author licancan
+	 * @param idList
+	 * @return {@link R<String>}
+	 */
+	@Operation(summary = "投保退回", description = "投保退回")
+	@PostMapping("/rollBackInsurance")
+	public R<String> rollBackInsurance(@RequestBody @Valid @Size(min = 1,message = "集合不能为空") List<String> idList){
+		return tInsuranceDetailService.rollBackInsurance(idList);
+	}
+
+	/**
+	 * 办理成功
+	 *
+	 * @author licancan
+	 * @param idList
+	 * @return {@link R<String>}
+	 */
+	@Operation(summary = "办理成功", description = "办理成功")
+	@PostMapping("/successfulInsurance")
+	public R<String> successfulInsurance(@RequestBody @Valid @Size(min = 1,message = "集合不能为空") List<String> idList){
+		return tInsuranceDetailService.successfulInsurance(idList);
+	}
+
 	/***********************减员办理********************************/
 	/**
 	 * 导入减员校验

yifu-insurances/yifu-insurances-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/insurances/service/TInsuranceDetailService.java

@@ -99,6 +99,24 @@ public interface TInsuranceDetailService extends IService<TInsuranceDetail> {
 	 */
 	List<InsuranceExportListVO> getInsuranceExportList(InsuranceExportListParam param);
 
+	/**
+	 * 投保退回
+	 *
+	 * @author licancan
+	 * @param idList
+	 * @return {@link R<String>}
+	 */
+	R<String> rollBackInsurance(List<String> idList);
+
+	/**
+	 * 办理成功
+	 *
+	 * @author licancan
+	 * @param idList
+	 * @return {@link R<String>}
+	 */
+	R<String> successfulInsurance(List<String> idList);
+
 	/***********************减员办理********************************/
 	/**
 	 * 减员导入校验

yifu-insurances/yifu-insurances-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/insurances/service/impl/TInsuranceDetailServiceImpl.java

@@ -458,6 +458,71 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 		return insuranceExportList;
 	}
 
+	/**
+	 * 投保退回
+	 *
+	 * @param idList
+	 * @return {@link R<String>}
+	 * @author licancan
+	 */
+	@Override
+	public R<String> rollBackInsurance(List<String> idList) {
+		YifuUser user = SecurityUtils.getUser();
+		if (user == null || Common.isEmpty(user.getId())) {
+			return R.failed(CommonConstants.PLEASE_LOG_IN);
+		}
+		if (CollectionUtils.isEmpty(idList)){
+			return R.failed(CommonConstants.PARAM_IS_NOT_EMPTY);
+		}
+		List<TInsuranceDetail> detailList = baseMapper.selectBatchIds(idList);
+		if (CollectionUtils.isNotEmpty(detailList)){
+			detailList.stream().forEach(e ->{
+				// 记录状态置为「退回」
+				e.setBuyHandleStatus(CommonConstants.FOUR_INT);
+				e.setUpdateBy(user.getId());
+				e.setUpdateTime(LocalDateTime.now());
+			});
+			//更新
+			this.saveOrUpdateBatch(detailList);
+		}
+		return R.ok(InsurancesConstants.OPERATE_SUCCESS);
+	}
+
+	/**
+	 * 办理成功
+	 *
+	 * @param idList
+	 * @return {@link R<String>}
+	 * @author licancan
+	 */
+	@Override
+	public R<String> successfulInsurance(List<String> idList) {
+		YifuUser user = SecurityUtils.getUser();
+		if (user == null || Common.isEmpty(user.getId())) {
+			return R.failed(CommonConstants.PLEASE_LOG_IN);
+		}
+		if (CollectionUtils.isEmpty(idList)){
+			return R.failed(CommonConstants.PARAM_IS_NOT_EMPTY);
+		}
+		List<TInsuranceDetail> detailList = baseMapper.selectBatchIds(idList);
+		if (CollectionUtils.isNotEmpty(detailList)){
+			for (TInsuranceDetail detail : detailList) {
+				if (detail.getBuyType() == CommonConstants.THREE_INT){
+					detail.setPolicyEffect(LocalDate.now().plusDays(CommonConstants.ONE_INT));
+				}
+				//记录状态均置为「已投保」
+				detail.setBuyHandleStatus(CommonConstants.THREE_INT);
+				//记录的有效状态，置为「有效」
+				detail.setIsEffect(CommonConstants.ZERO_INT);
+				detail.setIsOverdue(CommonConstants.ZERO_INT);
+			}
+			//更新
+			this.saveOrUpdateBatch(detailList);
+			//todo 根据结算类型推送ekp
+		}
+		return R.ok(InsurancesConstants.OPERATE_SUCCESS);
+	}
+
 	/**
 	 * 商险新增校验
 	 *

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/entity/TAuditInfo.java

@@ -109,38 +109,15 @@ public class TAuditInfo extends BaseEntity {
 	@Schema(description = "公积金ID" )
 	@ExcelProperty("公积金ID" )
 	private String providentId;
+
 	/**
-	 * 基数变更ID
-	 */
-	@Length(max = 32, message = "基数变更ID 不能超过32个字符" )
-	@ExcelAttribute(name = "基数变更ID", maxLength = 32)
-	@Schema(description = "基数变更ID" )
-	@ExcelProperty("基数变更ID" )
-	private String cardinalId;
-	/**
-	 * 社保代理结算信息ID
-	 */
-	@Length(max = 32, message = "社保代理结算信息ID 不能超过32个字符" )
-	@ExcelAttribute(name = "社保代理结算信息ID", maxLength = 32)
-	@Schema(description = "社保代理结算信息ID" )
-	@ExcelProperty("社保代理结算信息ID" )
-	private String forecastFormId;
-	/**
-	 * 人员离职派单ID
-	 */
-	@Length(max = 32, message = "人员离职派单ID 不能超过32个字符" )
-	@ExcelAttribute(name = "人员离职派单ID", maxLength = 32)
-	@Schema(description = "人员离职派单ID" )
-	@ExcelProperty("人员离职派单ID" )
-	private String empLeaveId;
-	/**
-	 * 社保、公积金核准表
+	 * 身份证
 	 */
-	@Length(max = 32, message = "社保、公积金核准表 不能超过32个字符" )
-	@ExcelAttribute(name = "社保、公积金核准表", maxLength = 32)
-	@Schema(description = "社保、公积金核准表" )
-	@ExcelProperty("社保、公积金核准表" )
-	private String aprovalFormId;
+	@ExcelAttribute(name = "身份证", maxLength = 32)
+	@Schema(description = "身份证" )
+	@ExcelProperty("身份证" )
+	private String empIdcard;
+
 	/**
 	 * 派单id
 	 */
@@ -150,13 +127,13 @@ public class TAuditInfo extends BaseEntity {
 	@ExcelProperty("派单id" )
 	private String dispatchInfoId;
 	/**
-	 * type类型：0：其他；1：社 保办理备注
+	 * type类型：0：其他；1：社保 2.公积金
 	 */
 	@NotBlank(message = "type类型不能为空" )
 	@Length(max = 1, message = "type类型不能超过1个字符" )
 	@ExcelAttribute(name = "type类型", isNotEmpty = true, errorInfo = "type类型不能为空", maxLength = 1)
-	@Schema(description = "type类型：0：其他；1：社 保办理备注" )
-	@ExcelProperty("type类型：0：其他；1：社 保办理备注" )
+	@Schema(description = "ype类型：0：其他；1：社保 2.公积金" )
+	@ExcelProperty("type类型" )
 	private String type;
 
 }

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/entity/TSocialFundInfo.java

@@ -17,9 +17,7 @@
 package com.yifu.cloud.plus.v1.yifu.social.entity;
 
 import com.alibaba.excel.annotation.ExcelProperty;
-import com.baomidou.mybatisplus.annotation.IdType;
-import com.baomidou.mybatisplus.annotation.TableId;
-import com.baomidou.mybatisplus.annotation.TableName;
+import com.baomidou.mybatisplus.annotation.*;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttribute;
 import com.yifu.cloud.plus.v1.yifu.common.mybatis.base.BaseEntity;
 import io.swagger.v3.oas.annotations.media.Schema;
@@ -371,13 +369,7 @@ public class TSocialFundInfo extends BaseEntity {
 	@Schema(description = "个人失业基数" )
 	@ExcelProperty("个人失业基数" )
 	private BigDecimal personalUnemploymentCardinal;
-	/**
-	 * 单位工伤基数
-	 */
-	@ExcelAttribute(name = "单位工伤基数" )
-	@Schema(description = "单位工伤基数" )
-	@ExcelProperty("单位工伤基数" )
-	private BigDecimal personalWorkInjuryCardinal;
+
 	/**
 	 * 单位养老比例
 	 */
@@ -462,6 +454,7 @@ public class TSocialFundInfo extends BaseEntity {
 	 */
 	@ExcelAttribute(name = "社保停缴日期", isDate = true)
 	@Schema(description = "社保停缴日期" )
+	@TableField(updateStrategy = FieldStrategy.IGNORED)
 	@ExcelProperty("社保停缴日期" )
 	private Date socialReduceDate;
 	/**
@@ -914,18 +907,19 @@ public class TSocialFundInfo extends BaseEntity {
 	 */
 	@ExcelAttribute(name = "公积金停缴日期", isDate = true)
 	@Schema(description = "公积金停缴日期" )
+	@TableField(updateStrategy = FieldStrategy.IGNORED)
 	@ExcelProperty("公积金停缴日期" )
 	private Date fundReduceDate;
 
 	/**
-	 * 单位补缴利息
+	 * 单位补缴利息  逻辑不明确-暂无实现
 	 */
 	@ExcelAttribute(name = "单位补缴利息")
 	@Schema(description = "单位补缴利息")
 	@ExcelProperty("单位补缴利息")
 	private BigDecimal unitInterestFee;
 	/**
-	 * 个人补缴利息
+	 * 个人补缴利息 逻辑不明确-暂无实现
 	 */
 	@ExcelAttribute(name = "个人补缴利息")
 	@Schema(description = "个人补缴利息")

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/entity/TSocialLog.java

@@ -48,11 +48,11 @@ public class TSocialLog extends BaseEntity {
 	private String id;
 
 	/**
-	 * 类型：1社保基数配置；2公积金基数配置
+	 * 类型：1社保基数配置；2公积金基数配置；3:调基
 	 */
-	@ExcelAttribute(name = "类型：1社保基数配置；2公积金基数配置")
-	@Schema(description = "类型：1社保基数配置；2公积金基数配置")
-	@ExcelProperty("类型：1社保基数配置；2公积金基数配置")
+	@ExcelAttribute(name = "类型：1社保基数配置；2公积金基数配置；3:调基")
+	@Schema(description = "类型：1社保基数配置；2公积金基数配置；3:调基")
+	@ExcelProperty("类型：1社保基数配置；2公积金基数配置；3:调基")
 	private Integer type;
 
 	/**

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/controller/TSocialFundInfoController.java

@@ -24,6 +24,7 @@ import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
 import com.yifu.cloud.plus.v1.yifu.common.log.annotation.SysLog;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
 import com.yifu.cloud.plus.v1.yifu.social.service.TSocialFundInfoService;
+import com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoDetailVo;
 import com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoSearchVo;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.security.SecurityRequirement;
@@ -154,4 +155,18 @@ public class TSocialFundInfoController {
     public void export(HttpServletResponse response, @RequestBody TSocialFundInfoSearchVo searchVo) {
             tSocialFundInfoService.listExport(response,searchVo);
     }
+
+	/**
+	 * @param id 社保公积金查询表的主键
+	 * @Description: 根据id查询详情
+	 * @Author: hgw
+	 * @Date: 2022/7/21 16:08
+	 * @return: com.yifu.cloud.plus.v1.yifu.common.core.util.R<com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoDetailVo>
+	 **/
+	@Operation(description = "前端使用：根据id查询详情")
+    @PostMapping("/getDetailById")
+    public R<TSocialFundInfoDetailVo> getDetailById(@RequestParam String id) {
+		return R.ok(tSocialFundInfoService.getDetailById(id));
+    }
+
 }

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/TSocialFundInfoService.java

@@ -23,6 +23,7 @@ import com.baomidou.mybatisplus.extension.service.IService;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.ErrorMessage;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
+import com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoDetailVo;
 import com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoSearchVo;
 
 import javax.servlet.http.HttpServletResponse;
@@ -48,4 +49,14 @@ public interface TSocialFundInfoService extends IService<TSocialFundInfo> {
     void listExport(HttpServletResponse response, TSocialFundInfoSearchVo searchVo);
 
     List<TSocialFundInfo> noPageDiy(TSocialFundInfoSearchVo searchVo);
+
+	/**
+	 * @param id
+	 * @Description: 社保公积金查询的详情
+	 * @Author: hgw
+	 * @Date: 2022/7/21 16:05
+	 * @return: com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoDetailVo
+	 **/
+	TSocialFundInfoDetailVo getDetailById(String id);
+	
 }

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TDispatchInfoServiceImpl.java

@@ -40,9 +40,7 @@ import com.yifu.cloud.plus.v1.yifu.common.dapr.util.ArchivesDaprUtil;
 import com.yifu.cloud.plus.v1.yifu.common.mybatis.base.BaseEntity;
 import com.yifu.cloud.plus.v1.yifu.common.security.util.SecurityUtils;
 import com.yifu.cloud.plus.v1.yifu.social.entity.*;
-import com.yifu.cloud.plus.v1.yifu.social.mapper.SysBaseSetInfoMapper;
-import com.yifu.cloud.plus.v1.yifu.social.mapper.TDispatchInfoMapper;
-import com.yifu.cloud.plus.v1.yifu.social.mapper.TSocialFundInfoMapper;
+import com.yifu.cloud.plus.v1.yifu.social.mapper.*;
 import com.yifu.cloud.plus.v1.yifu.social.service.TDispatchInfoService;
 import com.yifu.cloud.plus.v1.yifu.social.vo.TDispatchImportVo;
 import com.yifu.cloud.plus.v1.yifu.social.vo.TDispatchInfoSearchVo;
@@ -77,6 +75,10 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 
 	private final SysBaseSetInfoMapper baseSetMapper;
 
+	private final TSocialInfoMapper socialMapper;
+
+	private final TProvidentFundMapper fundMapper;
+
 
 	/**
 	 * 派单信息记录表简单分页查询
@@ -260,7 +262,6 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 			return;
 		}
 		// 个性化校验逻辑
-		ErrorMessage errorMsg;
 		List<String> idcards = new ArrayList<>();
 		List<String> codes = new ArrayList<>();
 
@@ -292,16 +293,9 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 		Map<String,TDispatchInfo> dispatchMap = new HashMap<>();
 		// 新增社保公积金查询
 		Map<String,TSocialFundInfo> socialFundAddMap = new HashMap<>();
-		EmpAddDispatchVo emp;
-		EmpContractDispatchVo contract;
-		EmpProjectDispatchVo project;
-		TSocialFundInfo sf;
 		DispatchEmpVo empVo = null;
-		TSocialInfo social;
-		TProvidentFund fund;
 		SysBaseSetInfo socialSet;
 		SysBaseSetInfo fundSet;
-		TDispatchInfo dispatch;
 		ProjectSetInfoVo setInfoVo;
 		TSocialFundInfo socialFund;
 		TDispatchImportVo excel;
@@ -318,7 +312,6 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 				continue;
 			}
 			if (Common.isNotNull(excel.getSocialHousehold())){
-
 				if (Common.isEmpty(socialSet)){
 					errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.EMP_DISPATCH_SOCIAL_HOLD_NOT_EXIST)));
 					continue;
@@ -353,22 +346,256 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 		addVo.setEmpAddsMap(empAddsMap);
 		addVo.setContractsMap(contractsMap);
 		addVo.setProjectsMap(projectsMap);
-		R<DispatchAddVo> res = archivesDaprUtil.addDispatchInfo(addVo);
+		R<EmpDispatchAddVo> res = archivesDaprUtil.addDispatchInfo(addVo);
+		// 开始插入各种数据了
+		insertAllInfo(excelVOList, errorMessageList, empVoMap, res,socialsMap,fundsMap,socialFundAddMap,dispatchMap);
+		// 清理map list 等数据
+		excelVOList.clear();
+		empAddsMap.clear();
+		contractsMap.clear();
+		projectsMap.clear();
+		empVoMap.clear();
+		idcards.clear();
+		codes.clear();
+		socialholds.clear();
+		fundholds.clear();
+		socialsMap.clear();
+		fundsMap.clear();
+		dispatchMap.clear();
+		socialFundAddMap.clear();
+		socialHoldMap.clear();
+		fundHoldMap.clear();
+	}
+
+	private void insertAllInfo(List<TDispatchImportVo> excelVOList,
+							   List<ErrorMessage> errorMessageList,
+							   Map<String, DispatchEmpVo> empVoMap,
+							   R<EmpDispatchAddVo> res,
+							   Map<String, TSocialInfo> socialsMap,
+							   Map<String, TProvidentFund> fundsMap,
+							   Map<String, TSocialFundInfo> socialFundAddMap,
+							   Map<String, TDispatchInfo> dispatchMap) {
+		Map<String, EmpAddDispatchVo> empAddsMap = null;
+		Map<String, EmpContractDispatchVo> contractsMap = null;
+		Map<String, EmpProjectDispatchVo> projectsMap = null;
+		TDispatchImportVo excel;
+		DispatchEmpVo empVo;
+		EmpContractDispatchVo contract;
+		EmpProjectDispatchVo project;
+		EmpAddDispatchVo emp = null;
+		TSocialInfo social = null;
+		TProvidentFund fund = null;
+		TSocialFundInfo socialFund = null;
+		TDispatchInfo dispatch = null;
+		if (Common.isNotNull(res) && Common.isNotNull(res.getData())){
+			empAddsMap =  res.getData().getEmpAddsMap();
+			contractsMap = res.getData().getContractsMap();
+			projectsMap = res.getData().getProjectsMap();
+		}
 		for (int i = 0; i < excelVOList.size(); i++) {
 			excel = excelVOList.get(i);
 			empVo = empVoMap.get(excel.getEmpIdcard());
-			// 验证档案是否插入成功
+			// 验证档案是否插入成功  如果MAP 无数据直接不处理
+			if (Common.isEmpty(empVo) && Common.isNotNull(empAddsMap)){
+				emp = empAddsMap.get(excel.getEmpIdcard());
+				if (Common.isEmpty(emp) || Common.isEmpty(emp.getId())){
+					errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.EMP_DISPATCH_ADD_EMP_ERROR)));
+					continue;
+				}
+			}else if (Common.isNotNull(empVo)){
+				// 验证合同是否插入成功
+				if (Common.isEmpty(empVo.getContractType()) && Common.isNotNull(contractsMap)){
+					contract = contractsMap.get(excel.getEmpIdcard()+CommonConstants.DOWN_LINE_STRING+excel.getSettleDomainCode());
+					if (Common.isEmpty(contract) || Common.isEmpty(contract.getId())){
+						errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.EMP_DISPATCH_ADD_CONTRACT_ERROR)));
+						continue;
+					}
+				}
+				// 验证项目档案是否插入成功
+				if (Common.isEmpty(empVo.getEmpCode()) && Common.isNotNull(projectsMap)){
+					project = projectsMap.get(excel.getEmpIdcard()+CommonConstants.DOWN_LINE_STRING+excel.getSettleDomainCode());
+					if (Common.isEmpty(project) || Common.isEmpty(project.getId())){
+						errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.EMP_DISPATCH_ADD_PROJECT_ERROR)));
+						continue;
+					}
+				}
+			}
+			try {
+				// 插入社保信息并封装社保公积金查询信息
+				if (Common.isNotNull(socialsMap)){
+					social = socialsMap.get(excel.getEmpIdcard());
+					insertSocial(emp, social);
+				}
+				//  插入公积金信息并封装社保公积金查询信息
+				if (Common.isNotNull(fundsMap)){
+					fund = fundsMap.get(excel.getEmpIdcard());
+					insertFund(emp, fund);
+				}
+				//  插入派单信息
+				if (Common.isNotNull(dispatchMap)){
+					dispatch = dispatchMap.get(excel.getEmpIdcard());
+					insertDispatch(emp, dispatch);
+				}
+				//  插入或更新社保公积金查询信息  大病在封装社保的时候已经算了 大病技术和金额了
+				if (Common.isNotNull(socialFundAddMap)){
+					socialFund = socialFundAddMap.get(excel.getEmpIdcard());
+					initSocialFundAndInsert(emp, social, fund, socialFund);
+				}
+			}catch (Exception e){
+				log.error("派单新增异常：", e);
+				errorMessageList.add(new ErrorMessage(excel.getRowIndex(), "派单新增异常："+e.getMessage()));
+				continue;
+			}
+			errorMessageList.add(new ErrorMessage(excel.getRowIndex(), CommonConstants.SAVE_SUCCESS));
+			// 清理map list 等数据
+			empAddsMap.clear();
+			contractsMap.clear();
+			projectsMap.clear();
 
-			// 验证项目档案是否插入成功
+		}
+	}
 
-			// 验证合同是否插入成功
+	private void insertSocial(EmpAddDispatchVo emp, TSocialInfo social) {
+		if (Common.isNotNull(emp) && Common.isNotNull(social)){
+			social.setEmpNo(emp.getEmpCode());
+			social.setEmpId(emp.getEmpIdcard());
+			socialMapper.insert(social);
+		}
+	}
 
-			// 插入社保信息并封装社保公积金查询信息
+	private void insertFund(EmpAddDispatchVo emp, TProvidentFund fund) {
+		if (Common.isNotNull(emp) && Common.isNotNull(fund)){
+			fund.setEmpNo(emp.getEmpCode());
+			fund.setEmpId(emp.getId());
+			fundMapper.insert(fund);
+		}
+	}
 
-			//  插入公积金信息并封装社保公积金查询信息
+	private void insertDispatch(EmpAddDispatchVo emp, TDispatchInfo dispatch) {
+		if (Common.isNotNull(emp) && Common.isNotNull(dispatch)){
+			dispatch.setEmpNo(emp.getEmpCode());
+			dispatch.setEmpId(emp.getId());
+			baseMapper.insert(dispatch);
+		}
+	}
 
-			//  插入或更新社保公积金查询信息
-			errorMessageList.add(new ErrorMessage(excel.getRowIndex(), CommonConstants.SAVE_SUCCESS));
+	private void initSocialFundAndInsert(EmpAddDispatchVo emp, TSocialInfo social, TProvidentFund fund, TSocialFundInfo socialFund) {
+		if (Common.isNotNull(socialFund)){
+			if (Common.isNotNull(emp)){
+				socialFund.setEmpNo(emp.getEmpCode());
+				socialFund.setEmpId(emp.getId());
+			}
+			if (Common.isNotNull(social)){
+				socialFund.setSocialStartDate(social.getSocialStartDate());
+				socialFund.setSocialAddStatus(CommonConstants.ZERO_STRING);
+				socialFund.setSocialReduceDate(null);
+				socialFund.setSocialReduceStatus(CommonConstants.ONE_STRING_NEGATE);
+				socialFund.setSocialId(social.getId());
+				if (Common.isEmpty(socialFund.getFirstBuyMonthSocial())){
+					socialFund.setFirstBuyMonthSocial(social.getSocialStartDate());
+				}
+				socialFund.setUnitPensionCardinal(social.getUnitPensionCardinal());
+				socialFund.setUnitMedicalCardinal(social.getUnitMedicalCardinal());
+				socialFund.setUnitUnemploymentCardinal(social.getUnitUnemploymentCardinal());
+				socialFund.setUnitBigailmentCardinal(social.getUnitBigailmentCardinal());
+				socialFund.setUnitWorkInjuryCardinal(social.getUnitWorkInjuryCardinal());
+				socialFund.setUnitBirthCardinal(social.getUnitBirthCardinal());
+				socialFund.setPersonalPensionCardinal(social.getPersonalPensionCardinal());
+				socialFund.setPersonalMedicalCardinal(social.getPersonalMedicalCardinal());
+				socialFund.setPersonalBigailmentCardinal(social.getPersonalBigailmentCardinal());
+				socialFund.setPersonalUnemploymentCardinal(social.getPersonalUnemploymentCardinal());
+				socialFund.setUnitPensionPer(social.getUnitPensionPer());
+				socialFund.setUnitMedicalPer(social.getUnitMedicalPer());
+				socialFund.setUnitUnemploymentPer(social.getUnitUnemploymentPer());
+				socialFund.setUnitBigailmentPer(social.getUnitBigailmentPer());
+				socialFund.setUnitWorkUnjuryPer(social.getUnitWorkUnjuryPer());
+				socialFund.setUnitBirthPer(social.getUnitBirthPer());
+				socialFund.setPersonalPensionPer(social.getPersonalPensionPer());
+				socialFund.setPersonalMedicalPer(social.getPersonalMedicalPer());
+				socialFund.setPersonalUnemploymentPer(social.getPersonalUnemploymentPer());
+				socialFund.setPersonalBigailmentPer(social.getPersonalBigailmentPer());
+				socialFund.setCanOverpay(social.getCanOverpay());
+				socialFund.setOverpayNumber(social.getOverpayNumber());
+				socialFund.setHaveThisMonth(social.getHaveThisMonth());
+				socialFund.setInsuranceBigailment(social.getInsuranceBigailment());
+				socialFund.setInsuranceBirth(social.getInsuranceBirth());
+				socialFund.setInsuranceInjury(social.getInsuranceInjury());
+				socialFund.setInsuranceMedical(social.getInsuranceMedical());
+				socialFund.setInsurancePension(social.getInsurancePension());
+				socialFund.setInsuranceUnemployment(social.getInsuranceUnemployment());
+				socialFund.setLatestCardinality(social.getInsuranceIsLatestCardinality());
+				socialFund.setIsIllness(social.getIsIllness());
+				socialFund.setCollectType(social.getCollectType());
+				socialFund.setValueType(social.getValueType());
+				socialFund.setIsChargePersonal(social.getIsChargePersonal());
+				socialFund.setRecordBase(social.getRecordBase());
+				socialFund.setTrustRemark(social.getTrustRemark());
+				socialFund.setPaymentType(social.getPaymentType());
+				socialFund.setPensionStart(social.getPensionStart());
+				socialFund.setMedicalStart(social.getMedicalStart());
+				socialFund.setUnemployStart(social.getUnemployStart());
+				socialFund.setWorkInjuryStart(social.getWorkInjuryStart());
+				socialFund.setBirthStart(social.getBirthStart());
+				socialFund.setBigailmentStart(social.getBigailmentStart());
+				socialFund.setPensionHandle(social.getPensionHandle());
+				socialFund.setMedicalHandle(social.getMedicalHandle());
+				socialFund.setUnemployHandle(social.getUnemployHandle());
+				socialFund.setWorkInjuryHandle(social.getWorkInjuryHandle());
+				socialFund.setBirthHandle(social.getBirthHandle());
+				socialFund.setBigailmentHandle(social.getBigailmentHandle());
+
+				socialFund.setUnitPersionMoney(BigDecimal.ZERO);
+				socialFund.setUnitMedicalMoney(BigDecimal.ZERO);
+				socialFund.setUnitUnemploymentMoney(BigDecimal.ZERO);
+				socialFund.setUnitInjuryMoney(BigDecimal.ZERO);
+				socialFund.setUnitBirthMoney(BigDecimal.ZERO);
+
+				socialFund.setUnitPersionMoney(BigDecimalUtils.safeMultiply(social.getUnitPensionCardinal(), social.getUnitPensionPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+				socialFund.setUnitMedicalMoney(BigDecimalUtils.safeMultiply(social.getUnitMedicalCardinal(), social.getUnitMedicalPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+				socialFund.setUnitBirthMoney(BigDecimalUtils.safeMultiply(social.getUnitBirthCardinal(), social.getUnitBirthPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+				socialFund.setUnitInjuryMoney(BigDecimalUtils.safeMultiply(social.getUnitWorkInjuryCardinal(), social.getUnitWorkUnjuryPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+				socialFund.setUnitUnemploymentMoney(BigDecimalUtils.safeMultiply(social.getUnitUnemploymentCardinal(), social.getUnitUnemploymentPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+
+				socialFund.setPersonalPersionMoney(BigDecimalUtils.safeMultiply(social.getPersonalPensionCardinal(), social.getPersonalPensionPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+				socialFund.setPersonalMedicalMoney(BigDecimalUtils.safeMultiply(social.getPersonalMedicalCardinal(), social.getPersonalMedicalPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+				socialFund.setPersonalUnemploymentMoney(BigDecimalUtils.safeMultiply(social.getPersonalUnemploymentCardinal(), social.getPersonalUnemploymentPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+
+				socialFund.setUnitSocialSum(BigDecimalUtils.safeAdd(socialFund.getUnitPersionMoney()
+						, socialFund.getUnitMedicalMoney(), socialFund.getUnitBirthMoney()
+						, socialFund.getUnitInjuryMoney()
+						, socialFund.getUnitUnemploymentMoney()
+						, socialFund.getUnitBigailmentMoney()));
+				socialFund.setPersonalSocialSum(BigDecimalUtils.safeAdd(socialFund.getPersonalBigailmentMoney()
+						, socialFund.getPersonalPersionMoney()
+						, socialFund.getPersonalMedicalMoney()
+						, socialFund.getPersonalUnemploymentMoney()));
+			}
+			if (Common.isNotNull(fund)){
+				socialFund.setUnitProvidengCardinal(fund.getUnitProvidengCardinal());
+				socialFund.setUnitProvidentPer(fund.getUnitProvidentPer());
+				socialFund.setPersonalProvidentCardinal(fund.getPersonalProvidentCardinal());
+				socialFund.setPersonalProvidentPer(fund.getPersonalProvidentPer());
+				socialFund.setProvidentStart(fund.getProvidentStart());
+				socialFund.setFundPayPoint(fund.getFundPayPoint());
+				socialFund.setPayPolicy(fund.getFundPayPoint());
+				socialFund.setTrustRemarkFund(fund.getTrustRemark());
+				socialFund.setCanOverpayFund(fund.getCanOverpay());
+				socialFund.setOverpayNumberFund(fund.getOverpayNumber());
+				if (Common.isEmpty(socialFund.getFirstBuyMothFund())){
+					socialFund.setFirstBuyMothFund(fund.getProvidentStart());
+				}
+				socialFund.setHaveThisMonthFund(fund.getHaveThisMonth());
+				// 设置公积金信息派增 派减状态
+				socialFund.setLatestCardinalityFund(fund.getInsuranceIsLatestCardinality());
+				socialFund.setFundReduceDate(null);
+				socialFund.setFundAddStatus(CommonConstants.ZERO_STRING);
+				socialFund.setFundReduceStatus(CommonConstants.ONE_STRING_NEGATE);
+				//单边小数点处理逻辑
+				if (Common.isNotNull(fund.getFundPayPoint())){
+					socialFund.setUnitFundSum(Common.formatMoneyForFund(BigDecimalUtils.safeMultiply(fund.getUnitProvidengCardinal(), fund.getUnitProvidentPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())),Integer.valueOf(fund.getFundPayPoint())));
+					socialFund.setPersonalFundSum(Common.formatMoneyForFund(BigDecimalUtils.safeMultiply(fund.getPersonalProvidentCardinal(), fund.getPersonalProvidentPer(),BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())),Integer.valueOf(fund.getFundPayPoint())));
+				}
+			}
 		}
 	}
 
@@ -386,6 +613,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 			socialFund.setEmpIdcard(empVo.getEmpIdcard());
 			socialFund.setEmpId(empVo.getId());
 			socialFund.setEmpType(excel.getEmpType());
+			// 按社保公积金户判断具体封装那些信息，如果社保或公积金新增失败，后面就不会去更新或插入社保公积金查询了
 			if (Common.isNotNull(setInfoVo)){
 				if (Common.isNotNull(excel.getSocialHousehold())){
 					socialFund.setSettleDomain(setInfoVo.getId());
@@ -399,6 +627,9 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 						socialFund.setSocialProvince(Common.isNotNullToStr(socialSet.getProvince()));
 						socialFund.setSocialCity(Common.isNotNullToStr(socialSet.getCity()));
 						socialFund.setSocialTown(Common.isNotNullToStr(socialSet.getTown()));
+						socialFund.setLowerLimit(socialSet.getLowerLimit());
+						socialFund.setUpperLimit(socialSet.getUpperLimit());
+						socialFund.setPayPolicy(socialSet.getPayPolicy());
 					}
 				}
 				if (Common.isNotNull(excel.getProvidentHousehold())){
@@ -413,11 +644,13 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 						socialFund.setFundProvince(Common.isNotNullToStr(fundSet.getProvince()));
 						socialFund.setFundCity(Common.isNotNullToStr(fundSet.getCity()));
 						socialFund.setFundTown(Common.isNotNullToStr(fundSet.getTown()));
+						socialFund.setLowerLimitFund(fundSet.getLowerLimit());
+						socialFund.setUpperLimitFund(fundSet.getUpperLimit());
+						socialFund.setPayPolicyFund(fundSet.getPayPolicy());
 					}
 				}
 
 			}
-			//TODO
 		}
 		socialFundAddMap.put(excel.getEmpIdcard(), socialFund);
 	}
@@ -692,6 +925,26 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 					social.setUnitBirthCardinal(socialSet.getUpperLimit());
 				}
 			}
+			boolean flag = CommonConstants.ZERO_STRING.equals(social.getIsIllness()) && (CommonConstants.ZERO_STRING.equals(social.getCollectType())||CommonConstants.ONE_STRING.equals(social.getCollectType()));
+			if (flag) {
+				//收取方式按年 且为指定月份时产生数据
+				if (CommonConstants.ZERO_STRING.equals(social.getCollectType()) && Common.isNotNull(socialSet)) {
+					//按年收取大病方式按定值
+					social.setUnitBigailmentMoney(socialSet.getPayCompany());
+					social.setPersonalBigailmentMoney(socialSet.getPayPersonal());
+				}else if (CommonConstants.ONE_STRING.equals(social.getCollectType())) {
+					//收取方式按月
+					if (CommonConstants.ZERO_STRING.equals(social.getValueType())) {
+						//收取大病按比例
+						social.setUnitBigailmentMoney(BigDecimalUtils.safeMultiply(social.getUnitBigailmentCardinal(), social.getUnitBigailmentPer(), BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+						social.setPersonalBigailmentMoney(BigDecimalUtils.safeMultiply(social.getPersonalBigailmentCardinal(), social.getPersonalBigailmentPer(), BigDecimal.valueOf(CommonConstants.ONE_OF_PERCENT.doubleValue())));
+					} else if (CommonConstants.ONE_STRING.equals(social.getValueType()) && Common.isNotNull(socialSet)) {
+						//收取大病方式按定值
+						social.setUnitBigailmentMoney(socialSet.getPayCompany());
+						social.setPersonalBigailmentMoney(socialSet.getPayPersonal());
+					}
+				}
+			}
 			socials.put(excel.getEmpIdcard(),social);
 		}
 	}

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TForecastLibraryServiceImpl.java

@@ -334,7 +334,7 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 			if (Common.isNotNull(fundList)) {
 				for (TSocialFundInfo providentFund : fundList) {
 					createMonth = ServiceUtil.initCreateMonth(providentFund.getCreateTime(), payMonth);
-					sfMapKey = this.getMapKey(providentFund.getEmpIdcard(), providentFund.getSettleDomain(), payMonth, createMonth);
+					sfMapKey = this.getMapKey(providentFund.getEmpIdcard(), providentFund.getSettleDomainFund(), payMonth, createMonth);
 					// 变更：已推送的，计算变更值
 					tForecastLibrary = fundPushMap.get(sfMapKey);
 					if (null != tForecastLibrary) {
@@ -1160,8 +1160,8 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 		lib.setFundCity(providentFund.getFundCity());
 		lib.setFundTown(providentFund.getFundTown());
 		lib.setProvidentId(providentFund.getId());
-		lib.setUnitId(providentFund.getUnitId());
-		lib.setSettleDomainId(providentFund.getSettleDomain());
+		lib.setUnitId(providentFund.getUnitIdFund());
+		lib.setSettleDomainId(providentFund.getSettleDomainFund());
 
 		//判断是否允许补缴 是否可补缴 0：是
 		Integer monthT = null;

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/service/impl/TSocialFundInfoServiceImpl.java

@@ -30,14 +30,25 @@ import com.baomidou.mybatisplus.core.metadata.IPage;
 import com.baomidou.mybatisplus.core.toolkit.Wrappers;
 import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
 import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.*;
+import com.yifu.cloud.plus.v1.yifu.common.dapr.util.ArchivesDaprUtil;
 import com.yifu.cloud.plus.v1.yifu.common.mybatis.base.BaseEntity;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TAuditInfo;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TDispatchInfo;
 import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialLog;
 import com.yifu.cloud.plus.v1.yifu.social.mapper.TSocialFundInfoMapper;
+import com.yifu.cloud.plus.v1.yifu.social.service.TAuditInfoService;
+import com.yifu.cloud.plus.v1.yifu.social.service.TDispatchInfoService;
 import com.yifu.cloud.plus.v1.yifu.social.service.TSocialFundInfoService;
+import com.yifu.cloud.plus.v1.yifu.social.service.TSocialLogService;
+import com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoDetailVo;
 import com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoSearchVo;
 import com.yifu.cloud.plus.v1.yifu.social.vo.TSocialFundInfoVo;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.log4j.Log4j2;
 import org.springframework.stereotype.Service;
 
@@ -55,8 +66,15 @@ import java.util.List;
  * @date 2022-07-15 11:38:05
  */
 @Log4j2
+@RequiredArgsConstructor
 @Service
 public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMapper, TSocialFundInfo> implements TSocialFundInfoService {
+
+	private final ArchivesDaprUtil archivesDaprUtil;
+	private final TDispatchInfoService tDispatchInfoService;
+	private final TSocialLogService tSocialLogService;
+	private final TAuditInfoService tAuditInfoService;
+
     /**
      * 社保公积金查询表简单分页查询
      * @param tSocialFundInfo 社保公积金查询表
@@ -243,4 +261,73 @@ public class TSocialFundInfoServiceImpl extends ServiceImpl<TSocialFundInfoMappe
         BeanUtil.copyProperties(excel, insert);
         this.save(insert);
     }
-}
+
+	@Override
+	public TSocialFundInfoDetailVo getDetailById(String id) {
+		TSocialFundInfoDetailVo detailVo = new TSocialFundInfoDetailVo();
+		TSocialFundInfo socialFundInfo = this.getById(id);
+		if (socialFundInfo != null) {
+			// 主表信息
+			detailVo.setSocialFundInfo(socialFundInfo);
+			// 人员信息
+			if (Common.isNotNull(socialFundInfo.getEmpId())) {
+				R<TEmployeeInfo> employeeInfoR = archivesDaprUtil.getTEmployeeInfoById(socialFundInfo.getEmpId());
+				if (employeeInfoR != null && employeeInfoR.getCode() == CommonConstants.SUCCESS) {
+					detailVo.setEmployeeInfo(employeeInfoR.getData());
+				}
+				// 社保所属项目
+				if (Common.isNotNull(socialFundInfo.getSettleDomain())) {
+					TEmployeeProject employeeProject = new TEmployeeProject();
+					employeeProject.setEmpId(socialFundInfo.getEmpId());
+					employeeProject.setDeptId(socialFundInfo.getSettleDomain());
+					R<TEmployeeProject> employeeProjectR = archivesDaprUtil.getTEmployeeProjectById(employeeProject);
+					if (employeeProjectR != null && employeeProjectR.getCode() == CommonConstants.SUCCESS) {
+						detailVo.setSocialProject(employeeProjectR.getData());
+					}
+				}
+				// 公积金所属项目
+				if (Common.isNotNull(socialFundInfo.getSettleDomainFund())) {
+					TEmployeeProject employeeProject = new TEmployeeProject();
+					employeeProject.setEmpId(socialFundInfo.getEmpId());
+					employeeProject.setDeptId(socialFundInfo.getSettleDomainFund());
+					R<TEmployeeProject> employeeProjectR = archivesDaprUtil.getTEmployeeProjectById(employeeProject);
+					if (employeeProjectR != null && employeeProjectR.getCode() == CommonConstants.SUCCESS) {
+						detailVo.setFundProject(employeeProjectR.getData());
+					}
+				}
+			}
+			// 2022-7-21 12:00
+			// 倩倩已确认，社保公积金详情里的合同，采用社保/公积金对应的派单的合同信息（去除状态）
+			// 另外，基数sheet，采用变更日志，不是调基表。
+			// 社保所属合同
+			if (Common.isNotNull(socialFundInfo.getSocialId())) {
+				TDispatchInfo dispatchInfo = tDispatchInfoService.getOne(Wrappers.<TDispatchInfo>query().lambda()
+						.eq(TDispatchInfo::getSocialId, socialFundInfo.getSocialId())
+						.eq(TDispatchInfo::getType, CommonConstants.ZERO_STRING)
+						.orderByDesc(TDispatchInfo::getCreateTime).last(CommonConstants.LAST_ONE_SQL));
+				detailVo.setSocialContract(dispatchInfo);
+			}
+			// 公积金所属合同
+			if (Common.isNotNull(socialFundInfo.getFundId())) {
+				TDispatchInfo dispatchInfo = tDispatchInfoService.getOne(Wrappers.<TDispatchInfo>query().lambda()
+						.eq(TDispatchInfo::getFundId, socialFundInfo.getFundId())
+						.eq(TDispatchInfo::getType, CommonConstants.ZERO_STRING)
+						.orderByDesc(TDispatchInfo::getCreateTime).last(CommonConstants.LAST_ONE_SQL));
+				detailVo.setFundContract(dispatchInfo);
+			}
+			// 调基记录
+			List<TSocialLog> socialLogList = tSocialLogService.list(Wrappers.<TSocialLog>query().lambda()
+					.eq(TSocialLog::getType, CommonConstants.THREE_INT)
+					.eq(TSocialLog::getMainId, socialFundInfo.getId())
+					.orderByDesc(TSocialLog::getCreateTime));
+			detailVo.setLogList(socialLogList);
+			// 流程进展明细
+			List<TAuditInfo> auditInfoList = tAuditInfoService.list(Wrappers.<TAuditInfo>query().lambda()
+					.eq(TAuditInfo::getEmpIdcard, socialFundInfo.getEmpIdcard())
+					.orderByDesc(TAuditInfo::getCreateTime));
+			detailVo.setAuditList(auditInfoList);
+		}
+		return detailVo;
+	}
+
+}
\ No newline at end of file

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TSocialFundInfoDetailVo.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.social.vo;
+
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeInfo;
+import com.yifu.cloud.plus.v1.yifu.archives.entity.TEmployeeProject;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TAuditInfo;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TDispatchInfo;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialFundInfo;
+import com.yifu.cloud.plus.v1.yifu.social.entity.TSocialLog;
+import io.swagger.v3.oas.annotations.media.Schema;
+import lombok.Data;
+
+import java.io.Serializable;
+import java.util.List;
+
+/**
+ * 社保公积金查询表
+ *
+ * @author fxj
+ * @date 2022-07-15 11:38:05
+ */
+@Data
+public class TSocialFundInfoDetailVo implements Serializable {
+
+	@Schema(description = "主表信息")
+	private TSocialFundInfo socialFundInfo;
+
+	@Schema(description = "人员信息")
+	private TEmployeeInfo employeeInfo;
+
+	@Schema(description = "社保所属项目")
+	private TEmployeeProject socialProject;
+
+	@Schema(description = "公积金所属项目")
+	private TEmployeeProject fundProject;
+
+	@Schema(description = "社保所属合同（社保对应的派单里的合同信息）")
+	private TDispatchInfo socialContract;
+
+	@Schema(description = "公积金所属合同")
+	private TDispatchInfo fundContract;
+
+	@Schema(description = "调基记录")
+	private List<TSocialLog> logList;
+
+	@Schema(description = "流程进展明细")
+	private List<TAuditInfo> auditList;
+
+}

yifu-social/yifu-social-biz/src/main/resources/mapper/TAuditInfoMapper.xml

@@ -32,28 +32,23 @@
     <result property="auditTime" column="AUDIT_TIME"/>
     <result property="isCommision" column="IS_COMMISION"/>
     <result property="providentId" column="PROVIDENT_ID"/>
-    <result property="cardinalId" column="CARDINAL_ID"/>
-    <result property="forecastFormId" column="FORECAST_FORM_ID"/>
-    <result property="empLeaveId" column="EMP_LEAVE_ID"/>
-    <result property="aprovalFormId" column="APROVAL_FORM_ID"/>
     <result property="dispatchInfoId" column="DISPATCH_INFO_ID"/>
     <result property="type" column="TYPE"/>
+	<result property="empIdcard" column="EMP_IDCARD"/>
+
   </resultMap>
     <sql id="Base_Column_List">
-                a.ID,
-                a.SOCIAL_ID,
-                a.AUDIT_STATUS,
-                a.AUDIT_REMARK,
-                a.AUDIT_USER,
-                a.AUDIT_TIME,
-                a.IS_COMMISION,
-                a.PROVIDENT_ID,
-                a.CARDINAL_ID,
-                a.FORECAST_FORM_ID,
-                a.EMP_LEAVE_ID,
-                a.APROVAL_FORM_ID,
-                a.DISPATCH_INFO_ID,
-                a.TYPE
+		a.ID,
+		a.SOCIAL_ID,
+		a.AUDIT_STATUS,
+		a.AUDIT_REMARK,
+		a.AUDIT_USER,
+		a.AUDIT_TIME,
+		a.IS_COMMISION,
+		a.PROVIDENT_ID,
+		a.DISPATCH_INFO_ID,
+		a.TYPE,
+		a.EMP_IDCARD
     </sql>
     <sql id="tAuditInfo_where">
         <if test="tAuditInfo != null">
@@ -81,18 +76,6 @@
                     <if test="tAuditInfo.providentId != null and tAuditInfo.providentId.trim() != ''">
                         AND a.PROVIDENT_ID = #{tAuditInfo.providentId}
                     </if>
-                    <if test="tAuditInfo.cardinalId != null and tAuditInfo.cardinalId.trim() != ''">
-                        AND a.CARDINAL_ID = #{tAuditInfo.cardinalId}
-                    </if>
-                    <if test="tAuditInfo.forecastFormId != null and tAuditInfo.forecastFormId.trim() != ''">
-                        AND a.FORECAST_FORM_ID = #{tAuditInfo.forecastFormId}
-                    </if>
-                    <if test="tAuditInfo.empLeaveId != null and tAuditInfo.empLeaveId.trim() != ''">
-                        AND a.EMP_LEAVE_ID = #{tAuditInfo.empLeaveId}
-                    </if>
-                    <if test="tAuditInfo.aprovalFormId != null and tAuditInfo.aprovalFormId.trim() != ''">
-                        AND a.APROVAL_FORM_ID = #{tAuditInfo.aprovalFormId}
-                    </if>
                     <if test="tAuditInfo.dispatchInfoId != null and tAuditInfo.dispatchInfoId.trim() != ''">
                         AND a.DISPATCH_INFO_ID = #{tAuditInfo.dispatchInfoId}
                     </if>