社保公积金批量新增

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

@@ -2,6 +2,7 @@ package com.yifu.cloud.plus.v1.yifu.archives.vo;
 
 import com.alibaba.excel.annotation.format.DateTimeFormat;
 import com.baomidou.mybatisplus.annotation.TableField;
+import com.fasterxml.jackson.annotation.JsonFormat;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttribute;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttributeConstants;
 import io.swagger.v3.oas.annotations.media.Schema;
@@ -123,6 +124,7 @@ public class EmpContractDispatchVo implements Serializable {
 	 */
 	@NotBlank(message = "起始日期不能为空")
 	@DateTimeFormat("yyyy-MM-dd")
+	@JsonFormat(pattern = "yyyy-MM-dd")
 	@ExcelAttribute(name = "起始日期", isDate = true)
 	@Schema(description = "起始日期", name = "contractStart")
 	private Date contractStart;
@@ -131,6 +133,7 @@ public class EmpContractDispatchVo implements Serializable {
 	 */
 	@ExcelAttribute(name = "截止日期", needExport = true, isDate = true)
 	@DateTimeFormat("yyyy-MM-dd")
+	@JsonFormat(pattern = "yyyy-MM-dd")
 	@Schema(description = "截止日期", name = "contractEnd")
 	private Date contractEnd;
 

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

@@ -35,7 +35,7 @@ public class EmpProjectDispatchVo implements Serializable {
 	 */
 	@Schema(description ="员工编码")
 	@Size(max = 20, message = "员工编码不可超过20位")
-	private String empNo;
+	private String empCode;
 	/**
 	 * 员工类型（字典值，0外包1派遣2代理）
 	 */
@@ -90,4 +90,11 @@ public class EmpProjectDispatchVo implements Serializable {
 	@ExcelProperty(value ="就职岗位")
 	@ExcelAttribute(name = "就职岗位",isNotEmpty = true, errorInfo = "就职岗位不能为空",maxLength = 20)
 	private String post;
+
+	/**
+	 * 员工编码
+	 */
+	@Schema(description ="员工编码")
+	@Size(max = 20, message = "员工编码不可超过20位")
+	private String empNo;
 }

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

@@ -187,4 +187,7 @@ public interface TEmployeeProjectService extends IService<TEmployeeProject> {
 	TEmployeeProject getByEmpIdAndDeptId(String empId, String deptId);
 
 	R<Map<String, String>> getProjectByIdCard(String empIdCard);
+
+    //获取员工编码
+    String getEmpNo(String deptNo);
 }

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

@@ -2079,14 +2079,14 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
 		// 新增项目档案不需要返回ID
 		saveProject(empAddsMap, projectsMap);
 		// 新增合同
-		saveContract(empAddsMap, contractsMap);
+		saveContract(projectsMap, contractsMap);
 		addVo.setProjectsMap(projectsMap);
 		addVo.setEmpAddsMap(empAddsMap);
 		addVo.setContractsMap(contractsMap);
 		return addVo;
 	}
 
-	private void saveContract(Map<String, EmpAddDispatchVo> empAddsMap, Map<String, EmpContractDispatchVo> contractsMap) {
+	private void saveContract(Map<String, EmpProjectDispatchVo> projectsMap, Map<String, EmpContractDispatchVo> contractsMap) {
 		if (Common.isNotNull(contractsMap)) {
 			EmpContractDispatchVo contractAdd;
 			TEmployeeContractInfo contract;
@@ -2096,19 +2096,19 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
 					if (Common.isNotNull(contractAdd)) {
 						contract = new TEmployeeContractInfo();
 						BeanUtil.copyProperties(contractAdd, contract);
-						if (Common.isEmpty(contract.getEmpId()) && Common.isNotNull(empAddsMap)) {
-							EmpAddDispatchVo emp = empAddsMap.get(contract.getEmpIdcard());
-							if (Common.isNotNull(emp)) {
-								contract.setEmpId(emp.getId());
-								contract.setEmpNo(emp.getEmpCode());
+						if (Common.isEmpty(contract.getEmpId()) && Common.isNotNull(projectsMap)) {
+							EmpProjectDispatchVo project = projectsMap.get(contract.getEmpIdcard());
+							if (Common.isNotNull(project)) {
+								contract.setEmpId(project.getId());
+								contract.setEmpNo(project.getEmpNo());
 							}
-							contractMapper.insert(contract);
-							contractAdd.setId(contract.getId());
-							contractsMap.put(contractAdd.getEmpIdcard() + CommonConstants.DOWN_LINE_STRING + contractAdd.getDeptNo(), contractAdd);
 						}
+						contractMapper.insert(contract);
+						contractAdd.setId(contract.getId());
+						contractsMap.put(contractAdd.getEmpIdcard() + CommonConstants.DOWN_LINE_STRING + contractAdd.getDeptNo(), contractAdd);
 					}
 				} catch (Exception e) {
-					log.error(contractAdd.getEmpIdcard() + CommonConstants.COLON_STRING + "派单新增合同失败");
+					log.error(contractAdd.getEmpIdcard() + CommonConstants.COLON_STRING + "派单新增合同失败",e);
 				}
 			}
 		}
@@ -2131,7 +2131,7 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
 						empAddsMap.put(empAdd.getEmpIdcard(), empAdd);
 					}
 				} catch (Exception e) {
-					log.error(empAdd.getEmpIdcard() + CommonConstants.COLON_STRING + "派单新增档案失败");
+					log.error(empAdd.getEmpIdcard() + CommonConstants.COLON_STRING + "派单新增档案失败",e);
 				}
 			}
 		}
@@ -2156,12 +2156,14 @@ public class TEmployeeInfoServiceImpl extends ServiceImpl<TEmployeeInfoMapper, T
 								project.setEmpId(emp.getId());
 							}
 						}
+						project.setEmpNo(tEmployeeProjectService.getEmpNo(project.getDeptNo()));
 						tEmployeeProjectService.save(project);
 						projectAdd.setId(project.getId());
+						projectAdd.setEmpNo(project.getEmpNo());
 						projectsMap.put(project.getEmpIdcard() + CommonConstants.DOWN_LINE_STRING + project.getDeptNo(), projectAdd);
 					}
 				} catch (Exception e) {
-					log.error(projectAdd.getEmpIdcard() + CommonConstants.COLON_STRING + "派单新增项目档案失败");
+					log.error(projectAdd.getEmpIdcard() + CommonConstants.COLON_STRING + "派单新增项目档案失败",e);
 				}
 			}
 		}

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

@@ -1388,6 +1388,7 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 	}
 
 	//获取员工编码
+	@Override
 	public String getEmpNo(String deptNo) {
 		String str = "";
 		String EmpNo = baseMapper.findEmployeeMaxOnlyNoByDepId(deptNo);

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

@@ -375,6 +375,8 @@ public interface CommonConstants {
 	public static final int SIXTEEN_INT = 16;
 	public static final String FIFTEEN = "15";
 	public static final String NINETEEN = "19";
+	public static final String NINE_STRING = "9";
+	String EIGHT_STRING = "8";
 
 	//百分之一 1/100
 	public static final BigDecimal ONE_OF_PERCENT = new BigDecimal("0.01");
@@ -382,4 +384,7 @@ public interface CommonConstants {
 	// 1/2
 	public static final BigDecimal HALF_OF_ONE = new BigDecimal("0.5");
 	public static final BigDecimal TWO_BIG = new BigDecimal("2");
+
+	String SIX_STRING = "6";
+	String SEVEN_STRING = "7";
 }

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

@@ -341,10 +341,8 @@ public interface ErrorCodes {
 	 */
 	String EMP_DISPATCH_FUND_NOT_EMPTY = "emp.dispatch.fund.not.empty";
 
-
-
 	/**
-	 * 新增异常：存在派增待审核|待办理|办理成功但未派减办理成功的社保数据
+	 * 新增异常：已存在社保数据
 	 */
 	String EMP_DISPATCH_SOCIAL_EXISTING = "emp.dispatch.social.existing";
 	/**
@@ -394,4 +392,8 @@ public interface ErrorCodes {
 	 * 新增异常：派单新增项目档案失败，请重试
 	 */
 	String EMP_DISPATCH_ADD_PROJECT_ERROR="emp.dispatch.add.project.error";
+	/**
+	 * 新增异常：已存在公积金数据
+	 */
+	String EMP_DISPATCH_FUND_EXISTING = "emp.dispatch.fund.existing";
 }

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

@@ -115,7 +115,7 @@ emp.dispatch.social.not.empty=\u6D3E\u5355\u5458\u5DE5\u793E\u4FDD\u76F8\u5173\u
 
 emp.dispatch.fund.not.empty=\u6D3E\u5355\u5458\u5DE5\u516C\u79EF\u91D1\u76F8\u5173\u4FE1\u606F\u4E0D\u53EF\u4E3A\u7A7A
 
-emp.dispatch.social.existing=\u65B0\u589E\u5F02\u5E38\uFF1A\u5B58\u5728\u6D3E\u589E\u5F85\u5BA1\u6838|\u5F85\u529E\u7406|\u529E\u7406\u6210\u529F\u4F46\u672A\u6D3E\u51CF\u529E\u7406\u6210\u529F\u7684\u793E\u4FDD\u6570\u636E
+emp.dispatch.social.existing=\u65B0\u589E\u5F02\u5E38\uFF1A\u5DF2\u5B58\u5728\u793E\u4FDD\u6570\u636E
 
 emp.dispatch.social.injury.existing=\u65B0\u589E\u5F02\u5E38\uFF1A\u5B58\u5728\u529E\u7406\u6210\u529F\u672A\u6D3E\u51CF\u7684\u5DE5\u4F24\u793E\u4FDD\u6570\u636E
 
@@ -139,6 +139,8 @@ emp.dispatch.add.contract.error=\u65B0\u589E\u5F02\u5E38\uFF1A\u6D3E\u5355\u65B0
 
 emp.dispatch.add.project.error=\u65B0\u589E\u5F02\u5E38\uFF1A\u6D3E\u5355\u65B0\u589E\u9879\u76EE\u6863\u6848\u5931\u8D25\uFF0C\u8BF7\u91CD\u8BD5
 
+emp.dispatch.fund.existing=\u65B0\u589E\u5F02\u5E38\uFF1A\u5DF2\u5B58\u5728\u516C\u79EF\u91D1\u6570\u636E
+
 
 
 

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.alibaba.fastjson.JSONObject;
+import com.alibaba.fastjson.TypeReference;
 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.*;
@@ -10,9 +10,11 @@ import com.yifu.cloud.plus.v1.yifu.common.core.util.Common;
 import com.yifu.cloud.plus.v1.yifu.common.core.util.R;
 import com.yifu.cloud.plus.v1.yifu.common.dapr.config.DaprArchivesProperties;
 import lombok.extern.log4j.Log4j2;
+import org.apache.poi.ss.formula.functions.T;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 
+import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 
@@ -48,18 +50,13 @@ public class ArchivesDaprUtil {
 	 * @Param
 	 * @return
 	**/
-	public R<Map> getDispatchEmpVo(DispatchCheckVo checkVo){
+	public R<Map<String, DispatchEmpVo>> getDispatchEmpVo(DispatchCheckVo checkVo){
 		R<Map> res = HttpDaprUtil.invokeMethodPost(daprArchivesProperties.getAppUrl(),daprArchivesProperties.getAppId(),"/temployeeinfo/getDispatchEmpVo" , JSON.toJSONString(checkVo), Map.class, SecurityConstants.FROM_IN);
 		if (Common.isEmpty(res)){
 			return R.failed("获取档案派单信息失败！");
 		}
-		R<String> test = HttpDaprUtil.invokeMethodObject(daprArchivesProperties.getAppUrl(),daprArchivesProperties.getAppId(),"/temployeeinfo/getDispatchEmpVo" , JSON.toJSONString(checkVo), String.class, SecurityConstants.FROM_IN);
-		//Map<String,DispatchEmpVo> map = JSON.parseArray()
-		if (Common.isEmpty(res)){
-			return R.failed("获取档案派单信息失败！");
-		}
-
-		return res;
+		Map<String,DispatchEmpVo> map  = JSON.parseObject(JSON.toJSONString(res.getData()),new TypeReference<HashMap<String,DispatchEmpVo>>(){});
+		return R.ok(map);
 	}
 	/**
 	 * @Author fxj

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

@@ -120,35 +120,6 @@ public class HttpDaprUtil {
 			return R.failed("获取信息失败！");
 		}
 
-	}
-	public static <T> R<T> invokeMethodObject(String appUrl,
-											String appId,
-											String method,
-											Object param,
-											Class cs,
-											@RequestHeader(SecurityConstants.FROM) String from){
-		// 实例化 RestTemplate
-		initResTemplate();
-		// 初始化请求URL
-		initUrl(appUrl, appId, method, "");
-		ResponseEntity<String> res;
-		HttpHeaders headers = new HttpHeaders();
-		headers.add(SecurityConstants.FROM, from);
-		headers.setContentType(MediaType.APPLICATION_JSON);
-		headers.add("Authorization", null);
-		HttpEntity<String> entity = new HttpEntity(param, headers);
-		try {
-			res  = restTemplate.postForEntity(URI.create(stringBuffer.toString()),entity, cs);
-		} catch (Exception e) {
-			log.error("日志保存异常：",e);
-			return R.failed("获取信息失败:" + e.getMessage());
-		}
-		if (null != res && CommonConstants.SUCCESS == res.getStatusCodeValue()) {
-			return (R<T>) R.ok(res.getBody());
-		} else {
-			return R.failed("获取信息失败！");
-		}
-
 	}
 	private static void initResTemplate() {
 		if (null == restTemplate) {

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

@@ -512,4 +512,5 @@ public class TDispatchInfo extends BaseEntity {
 
 
 
+
 }

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

@@ -961,4 +961,28 @@ public class TSocialFundInfo extends BaseEntity {
 	@ExcelAttribute(name = "个人公积金金额")
 	@ExcelProperty("个人公积金金额")
 	private BigDecimal personalFundSum;
+
+	/**
+	 * 社保状态：派增（0待审核、1待办理、2办理中 3办理成功、4部分办理失败 5 办理失败）、派减（6待审核 7待办理 8办理成功 9 办理失败）
+	 */
+	@ExcelAttribute(name = "社保状态", maxLength = 1)
+	@Schema(description = "社保状态：派增（0待审核、1待办理、2办理中 3办理成功、4部分办理失败 5 办理失败）、派减（6待审核 7待办理 8办理成功 9 办理失败）" )
+	@ExcelProperty("社保派增状态" )
+	private String socialStatus;
+	/**
+	 * 公积金状态：派增（0待审核、1待办理、3办理成功、4办理失败）、派减（5待审核 6待办理 7 办理成功 8 办理失败）
+	 */
+	@Length(max = 1, message = "公积金状态 不能超过1个字符" )
+	@ExcelAttribute(name = "公积金状态", maxLength = 1)
+	@Schema(description = "公积金状态：派增（0待审核、1待办理、3办理成功、4办理失败）、派减（5待审核 6待办理 7 办理成功 8 办理失败）" )
+	@ExcelProperty("公积金状态" )
+	private String fundStatus;
+
+	/**
+	 * 派单ID （实时更新）
+	 */
+	@ExcelAttribute(name = "派单ID", maxLength = 32)
+	@Schema(description = "派单ID" )
+	@ExcelProperty("派单ID" )
+	private String dispatchId;
 }

yifu-social/yifu-social-api/src/main/java/com/yifu/cloud/plus/v1/yifu/social/vo/TDispatchImportVo.java

@@ -437,4 +437,12 @@ public class TDispatchImportVo extends RowIndex implements Serializable {
 	@ExcelIgnore
 	private String customerCode;
 
+	/**
+	 * 派单ID （实时更新）
+	 */
+	@ExcelIgnore
+	@Schema(description = "派单ID" )
+	@ExcelProperty("派单ID" )
+	private String dispatchId;
+
 }

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

@@ -154,4 +154,19 @@ public class TDispatchInfoController {
     public void export(HttpServletResponse response, @RequestBody TDispatchInfoSearchVo searchVo) {
             tDispatchInfoService.listExport(response,searchVo);
     }
+
+	/**
+	 * 派单信息记录表 批量导入-派减
+	 *
+	 * @author fxj
+	 * @date 2022-07-15 11:38:05
+	 **/
+	@SneakyThrows
+	@Operation(description = "派单信息记录表 批量导入-派减 hasPermission('demo_tdispatchinfo-batch-reduce')")
+	@SysLog("派单信息记录表 批量导入-派减")
+	@PostMapping("/importListReduce")
+	//@PreAuthorize("@pms.hasPermission('demo_tdispatchinfo-batch-reduce')")
+	public R<List<ErrorMessage>> importListReduce(@RequestBody MultipartFile file){
+		return tDispatchInfoService.importDiy(file.getInputStream());
+	}
 }

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

@@ -152,7 +152,9 @@
 	  <result property="personalSocialSum" column="PERSONAL_SOCIAL_SUM"/>
 	  <result property="unitInterestFee" column="UNIT_INTEREST_FEE"/>
 	  <result property="personalInterestFee" column="PERSONAL_INTEREST_FEE"/>
-
+	  <result property="socialStatus" column="SOCIAL_STATUS"/>
+	  <result property="fundStatus" column="FUND_STATUS"/>
+	  <result property="dispatchId" column="DISPATCH_ID"/>
 
   </resultMap>
     <sql id="Base_Column_List">
@@ -280,7 +282,10 @@
 				a.UNIT_SOCIAL_SUM,
 				a.PERSONAL_SOCIAL_SUM,
 				a.UNIT_INTEREST_FEE,
-				a.PERSONAL_INTEREST_FEE
+				a.PERSONAL_INTEREST_FEE,
+				a.SOCIAL_STATUS,
+				a.FUND_STATUS,
+				a.DISPATCH_ID
     </sql>
     <sql id="tSocialFundInfo_where">
         <if test="tSocialFundInfo != null">