Merge remote-tracking branch 'origin/MVP1.5.1' into MVP1.5.1

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

@@ -28,12 +28,12 @@ import com.yifu.cloud.plus.v1.yifu.archives.mapper.TElecEmployeeInfoMapper;
 import com.yifu.cloud.plus.v1.yifu.archives.service.FileUploadService;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TElecEmployeeInfoService;
 import com.yifu.cloud.plus.v1.yifu.archives.service.TEmployeeInfoService;
+import com.yifu.cloud.plus.v1.yifu.common.core.constant.CacheConstants;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.CommonConstants;
-import com.yifu.cloud.plus.v1.yifu.common.core.constant.SecurityConstants;
 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.core.util.RedisUtil;
 import com.yifu.cloud.plus.v1.yifu.common.dapr.config.DaprUpmsProperties;
-import com.yifu.cloud.plus.v1.yifu.common.dapr.util.HttpDaprUtil;
 import lombok.RequiredArgsConstructor;
 import org.apache.commons.fileupload.FileItem;
 import org.apache.commons.fileupload.FileItemFactory;
@@ -145,19 +145,19 @@ public class TElecEmployeeInfoServiceImpl extends ServiceImpl<TElecEmployeeInfoM
 	 */
 	private R unZip(File srcFile, String destDirPath) throws RuntimeException {
 
-		// 调用字典服务，渲染字典值
-		R<Map<String, Map<String, Map<String, String>>>> dictR = HttpDaprUtil.invokeMethodPost(daprUpmsProperties.getAppUrl(), daprUpmsProperties.getAppId()
-				, "/dict/inner/getDictToLable", null, Map.class, SecurityConstants.FROM_IN);
-		Map<String, Map<String, Map<String, String>>> dictMap;
-		// 电子档案类型
-		Map<String, Map<String, String>> elecTypeMapData;
-		Map<String, String> elecTypeMap;
-		if (dictR == null) {
+		Map<String, String> elecTypeMap = new HashMap<>();
+		// 渲染字典值
+		Map<String,String> dicObj = (Map<String, String>) RedisUtil.redis.opsForValue()
+				.get(CacheConstants.DICT_DETAILS
+						+ CommonConstants.COLON_STRING
+						+ "literature_types");
+		if (Common.isNotNull(dicObj)) {
+			for (Map.Entry<String, String> entry : dicObj.entrySet()) {
+				elecTypeMap.put(entry.getValue(),entry.getKey());
+			}
+		}
+		if (!elecTypeMap.isEmpty()) {
 			return R.failed("获取字典失败！");
-		} else {
-			dictMap = dictR.getData();
-			elecTypeMapData = dictMap.get("data");
-			elecTypeMap = elecTypeMapData.get("literature_types");
 		}
 		// 判断源文件是否存在
 		if (!srcFile.exists()) {
@@ -173,15 +173,18 @@ public class TElecEmployeeInfoServiceImpl extends ServiceImpl<TElecEmployeeInfoM
 			Set<String> infoList =new HashSet<>();
 			Set<String> idCardList =new HashSet<>();
 			Set<String> cardType =new HashSet<>();
+
+			TEmployeeInfo tEmployeeInfo;
+			ZipEntry entry;
 			while (entriesCheck.hasMoreElements()) {
-				ZipEntry entry = (ZipEntry) entriesCheck.nextElement();
+				entry = (ZipEntry) entriesCheck.nextElement();
 				//添加进filesName
 				String empInfo = entry.getName();
 				infoList.add(empInfo);
 				String dataType = "";
 				if (empInfo.length() == empInfo.lastIndexOf("/") + 1) {
 					String idCard = empInfo.substring(0, empInfo.indexOf("/"));
-					TEmployeeInfo tEmployeeInfo = tEmployeeInfoService.getOne((Wrappers.<TEmployeeInfo>query().lambda()
+					tEmployeeInfo = tEmployeeInfoService.getOne((Wrappers.<TEmployeeInfo>query().lambda()
 							.eq(TEmployeeInfo::getEmpIdcard, idCard)).eq(TEmployeeInfo::getFileStatus, CommonConstants.ZERO_INT)
 							.eq(TEmployeeInfo::getDeleteFlag, CommonConstants.ZERO_STRING)
 							.eq(TEmployeeInfo::getFileStatus, CommonConstants.ZERO_INT));
@@ -191,7 +194,6 @@ public class TElecEmployeeInfoServiceImpl extends ServiceImpl<TElecEmployeeInfoM
 					idCardList.add(idCard);
 					if (empInfo.length() > 20) {
 						dataType = empInfo.substring(empInfo.indexOf("/") + 1, empInfo.lastIndexOf("/"));
-						if (Common.isNotNull(elecTypeMap)) {
 						if (!Common.isNotNull(elecTypeMap.get(dataType))) {
 							return R.failed("资料类型错误：" + dataType);
 						}
@@ -199,26 +201,23 @@ public class TElecEmployeeInfoServiceImpl extends ServiceImpl<TElecEmployeeInfoM
 					}
 				}
 			}
-			}
 			for (String idCarInfo : idCardList) {
-				if (!infoList.stream().anyMatch(e-> containsCheckTwo(e,idCarInfo))) {
+				if (infoList.stream().noneMatch(e-> containsCheckTwo(e,idCarInfo))) {
 					return R.failed(idCarInfo + ":"+"证件数据不可为空");
 				}
 			}
 			if (cardType.size() > CommonConstants.ZERO_INT) {
 				for (String typeInfo :cardType) {
-					if (!infoList.stream().anyMatch(e -> containsCheckOne(e, typeInfo))) {
+					if (infoList.stream().noneMatch(e -> containsCheckOne(e, typeInfo))) {
 						return R.failed(typeInfo + ":" + "证件数据不可为空");
 					}
 				}
 			}
 
 			Map<String, String> insMap = new HashMap<>();
-
-			List<TElecEmployeeInfo> infolist = new ArrayList<>();
-			List<String> list = new ArrayList<>();
+			TEmployeeInfo employeeInfo;
 			while (entries.hasMoreElements()) {
-				ZipEntry entry = (ZipEntry) entries.nextElement();
+				entry = (ZipEntry) entries.nextElement();
 				//添加进filesName
 				String empInfo = entry.getName();
 				// 如果是文件夹，就创建个文件夹
@@ -249,26 +248,22 @@ public class TElecEmployeeInfoServiceImpl extends ServiceImpl<TElecEmployeeInfoM
 						String idCard = empInfo.substring(0, empInfo.indexOf("/"));
 						String dataType = empInfo.substring(empInfo.indexOf("/") + 1, empInfo.lastIndexOf("/"));
 						String empName = "";
-						TEmployeeInfo tEmployeeInfo = tEmployeeInfoService.getOne((Wrappers.<TEmployeeInfo>query().lambda()
+						employeeInfo = tEmployeeInfoService.getOne((Wrappers.<TEmployeeInfo>query().lambda()
 								.eq(TEmployeeInfo::getEmpIdcard, idCard)).eq(TEmployeeInfo::getFileStatus, CommonConstants.ZERO_INT)
 								.eq(TEmployeeInfo::getDeleteFlag, CommonConstants.ZERO_STRING));
-						if (Common.isNotNull(tEmployeeInfo)) {
-							empName = tEmployeeInfo.getEmpName();
+						if (Common.isNotNull(employeeInfo)) {
+							empName = employeeInfo.getEmpName();
 						}
 						tElecEmployeeInfo.setEmpIdcard(idCard);
 						tElecEmployeeInfo.setEmpName(empName);
-						if (Common.isNotNull(elecTypeMap)) {
 						if (Common.isNotNull(elecTypeMap.get(dataType))) {
 							tElecEmployeeInfo.setDataType(elecTypeMap.get(dataType));
 						}
-						}
 						String id = insMap.get(idCard + CommonConstants.DOWN_LINE_STRING + dataType);
 						if (Common.isEmpty(id)) {
-							infolist.add(tElecEmployeeInfo);
 							this.save(tElecEmployeeInfo);
 							insMap.put(idCard + CommonConstants.DOWN_LINE_STRING + dataType, tElecEmployeeInfo.getId());
 						}
-						list.add(insMap.get(idCard + CommonConstants.DOWN_LINE_STRING + dataType));
 						fileUploadService.uploadImg(fileCovertMultipartFile(targetFile), "", CommonConstants.EIGHT_INT, insMap.get(idCard + CommonConstants.DOWN_LINE_STRING + dataType));
 					}
 

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

@@ -159,6 +159,12 @@ public class TEmpChangeInfoServiceImpl extends ServiceImpl<TEmpChangeInfoMapper,
 
 		List<TEmployeeProject> updateList = new ArrayList<>();
 		Set<String> errorMsg;
+		//对象声明
+		TEmpChangeInfoVO excel;
+		TSettleDomain tSettleDomain;
+		TEmployeeProject employeeProject;
+		TEmployeeProject updateTEmployeePro;
+		TEmployeeProject tEmployeeProjectOld;
 		// 执行数据插入操作 组装
 		for (int i = 0; i < excelVOList.size(); i++) {
 			// 已有验证报错直接下一个
@@ -166,7 +172,7 @@ public class TEmpChangeInfoServiceImpl extends ServiceImpl<TEmpChangeInfoMapper,
 				continue;
 			}
 			errorMsg = new HashSet<>();
-			TEmpChangeInfoVO excel = excelVOList.get(i);
+			excel = excelVOList.get(i);
 			excel.setUnsettleDeal(CommonConstants.IS_NO_CHANGE);
 			if (Common.isNotNull(excel.getChangeStartMonth()) && excel.getChangeStartMonth().length() > CommonConstants.dingleDigitIntArray[6]) {
 				errorMsg.add("划转起始月长度不能超过6位");
@@ -184,7 +190,7 @@ public class TEmpChangeInfoServiceImpl extends ServiceImpl<TEmpChangeInfoMapper,
 			}
 
 			//项目编码校验
-			TSettleDomain tSettleDomain = tSettleDomainMapper.selectOne(Wrappers.<TSettleDomain>query().lambda()
+			tSettleDomain = tSettleDomainMapper.selectOne(Wrappers.<TSettleDomain>query().lambda()
 					.eq(TSettleDomain::getDepartNo, excel.getNewSettleCode())
 					.eq(TSettleDomain::getStopFlag, CommonConstants.ZERO_STRING)
 					.eq(TSettleDomain::getDeleteFlag, CommonConstants.ZERO_STRING));
@@ -193,17 +199,17 @@ public class TEmpChangeInfoServiceImpl extends ServiceImpl<TEmpChangeInfoMapper,
 			}
 
 			//待划转员工已在目标项目下不可划转
-			TEmployeeProject tEmployeeProject = tEmployeeProjectService.getOne(Wrappers.<TEmployeeProject>query().lambda()
+			employeeProject = tEmployeeProjectService.getOne(Wrappers.<TEmployeeProject>query().lambda()
 					.eq(TEmployeeProject::getEmpIdcard, excel.getEmpIdcard()).eq(TEmployeeProject::getDeptNo,excel.getNewSettleCode())
 					.eq(TEmployeeProject::getDeleteFlag,CommonConstants.STATUS_NORMAL)
 					.eq(TEmployeeProject::getProjectStatus,CommonConstants.ZERO_INT));
-			if (Common.isNotNull(tEmployeeProject)) {
+			if (Common.isNotNull(employeeProject)) {
 				errorMsg.add(MsgUtils.getMessage(ErrorCodes.PROJECT_NEW_SEARCH_NOT_EXIST, excel.getNewSettleCode()));
 			}
 			// 数据合法情况
 			if (CollUtil.isEmpty(errorMsg)) {
 				//划转,更新项目信息
-				TEmployeeProject updateTEmployeePro = tEmployeeProjectService.getOne(Wrappers.<TEmployeeProject>query().lambda()
+				updateTEmployeePro = tEmployeeProjectService.getOne(Wrappers.<TEmployeeProject>query().lambda()
 						.eq(TEmployeeProject::getEmpIdcard, excel.getEmpIdcard()).eq(TEmployeeProject::getDeptNo,excel.getOldSettleCode())
 						.eq(TEmployeeProject::getDeleteFlag,CommonConstants.STATUS_NORMAL));
 				if (Common.isNotNull(updateTEmployeePro)) {
@@ -214,7 +220,7 @@ public class TEmpChangeInfoServiceImpl extends ServiceImpl<TEmpChangeInfoMapper,
 					if (CommonConstants.ONE_INT == updateTEmployeePro.getProjectStatus()) {
 						errorMsg.add(MsgUtils.getMessage(ErrorCodes.PROJECT_PERSON_DELETE_EXIT, excel.getOldSettleCode()));
 					} else if (Common.isNotNull(tSettleDomain)) {
-						TEmployeeProject tEmployeeProjectOld = tEmployeeProjectService.getById(updateTEmployeePro.getId());
+						tEmployeeProjectOld = tEmployeeProjectService.getById(updateTEmployeePro.getId());
 						updateTEmployeePro.setDeptNo(tSettleDomain.getDepartNo());
 						updateTEmployeePro.setDeptId(tSettleDomain.getId());
 						updateTEmployeePro.setDeptName(tSettleDomain.getDepartName());
@@ -300,7 +306,6 @@ public class TEmpChangeInfoServiceImpl extends ServiceImpl<TEmpChangeInfoMapper,
 	 */
 	@Override
 	public R<List<TCustomerInfo>> getAllUint(String customerName) {
-		//List<TCustomerInfo> list = tCustomerInfoService.list(Wrappers.<TCustomerInfo>query().lambda().eq(TCustomerInfo::getDeleteFlag, CommonConstants.STATUS_NORMAL));
 		List<TCustomerInfo> list = tCustomerInfoService.getAllUnit(customerName);
 		return R.ok(list);
 	}

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

@@ -949,9 +949,13 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 		// 新老项目档案List
 		List<EmployeeProjectNewOldVO> updateProjectList = new ArrayList<>();
 
+		EmployeeProjectUpdateVO excel;
+		TEmployeeProject tEmployeeProject;
+		TEmployeeInfo tEmployeeInfo;
+		TEmployeeProject tEmployeeProjectOld;
 		// 执行数据插入操作 组装
 		for (int i = 0; i < excelVOList.size(); i++) {
-			EmployeeProjectUpdateVO excel = excelVOList.get(i);
+			excel = excelVOList.get(i);
 
 			String checkCount = excel.getEmpIdcard().concat(excel.getDeptNo());
 			if (Common.isNotNull(checkCountMap.get(checkCount))) {
@@ -960,7 +964,7 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 				checkCountMap.put(checkCount, i + 2);
 			}
 			//根据身份证和项目编码获取项目档案
-			TEmployeeProject tEmployeeProject = this.getOne(Wrappers.<TEmployeeProject>query().lambda()
+			tEmployeeProject = this.getOne(Wrappers.<TEmployeeProject>query().lambda()
 					.eq(TEmployeeProject::getEmpIdcard, excel.getEmpIdcard())
 					.eq(TEmployeeProject::getDeptNo, excel.getDeptNo())
 					.eq(TEmployeeProject::getDeleteFlag, CommonConstants.STATUS_NORMAL));
@@ -971,13 +975,13 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 					errorMessageList.add(new ErrorMessage(excel.getRowIndex(), MsgUtils.getMessage(ErrorCodes.CHECKS_EMP_DELETE_ERROR)));
 				} else {
 					updateExcelProj(excel, updateList, tEmployeeProject);
-					TEmployeeProject tEmployeeProjectOld = this.getById(tEmployeeProject.getId());
+					tEmployeeProjectOld = this.getById(tEmployeeProject.getId());
 					newOldProject = new EmployeeProjectNewOldVO();
 					newOldProject.setOldProjectEmployee(tEmployeeProjectOld);
 					newOldProject.setNewProjectEmployee(tEmployeeProject);
 					updateProjectList.add(newOldProject);
 
-					TEmployeeInfo tEmployeeInfo = tEmployeeInfoMapper.selectOne(Wrappers.<TEmployeeInfo>query().lambda()
+					tEmployeeInfo = tEmployeeInfoMapper.selectOne(Wrappers.<TEmployeeInfo>query().lambda()
 							.eq(TEmployeeInfo::getEmpIdcard, excel.getEmpIdcard())
 							.eq(TEmployeeInfo::getFileStatus, CommonConstants.ZERO_INT)
 							.eq(TEmployeeInfo::getDeleteFlag, CommonConstants.STATUS_NORMAL));
@@ -1065,6 +1069,7 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 					.eq(TEmployeeProject::getProjectStatus, CommonConstants.ZERO_INT));
 		}
 		if (Common.isNotEmpty(list)) {
+			TEmployeeInfo tEmployeeInfo;
 			int i = 0;
 			for (TEmployeeProject delProject : list) {
 				++i;
@@ -1072,7 +1077,7 @@ public class TEmployeeProjectServiceImpl extends ServiceImpl<TEmployeeProjectMap
 					if (CommonConstants.dingleDigitIntArray[0] == delProject.getStatus()) {
 						delProject.setDeleteFlag(CommonConstants.ONE_STRING);
 						updList.add(delProject);
-						TEmployeeInfo tEmployeeInfo = tEmployeeInfoMapper.selectOne(Wrappers.<TEmployeeInfo>query().lambda()
+						tEmployeeInfo = tEmployeeInfoMapper.selectOne(Wrappers.<TEmployeeInfo>query().lambda()
 								.eq(TEmployeeInfo::getEmpIdcard, delProject.getEmpIdcard())
 								.eq(TEmployeeInfo::getDeleteFlag, CommonConstants.STATUS_NORMAL));
 						infoUpdList.add(tEmployeeInfo);

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

@@ -1806,7 +1806,11 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 				//查数据：姓名 + 身份证号 + 保险公司 + 险种名称 + 保单开始时间 + 保单结束时间 + 购买标准
 				detail = success.getDetail();
 				actualMoney = detail.getActualPremium();
+				boolean booleanInvoiceNo = false;
 				if (StringUtils.isNotBlank(success.getInvoiceNo())){
+					if (Common.isEmpty(detail.getInvoiceNo()) || success.getInvoiceNo().equals(detail.getInvoiceNo())) {
+						booleanInvoiceNo = true;
+					}
 					detail.setInvoiceNo(success.getInvoiceNo());
 					//如果发票号不为空，将替换类型的发票号也全部更新
 					list = tInsuranceReplaceService.list(Wrappers.<TInsuranceReplace>query().lambda()
@@ -1831,7 +1835,11 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 						doJointInsuranceTask.asynchronousEkpInfo(detail,settle,CommonConstants.ONE_INT);
 					}
 				}
+				boolean booleanPolicyNo = false;
 				if (StringUtils.isNotBlank(success.getPolicyNo())){
+					if (Common.isEmpty(detail.getPolicyNo()) || success.getPolicyNo().equals(detail.getPolicyNo())) {
+						booleanPolicyNo = true;
+					}
 					detail.setPolicyNo(success.getPolicyNo());
 					//保单号不为空，维护到保单表中
 					one = tInsurancePolicyService.getOne(Wrappers.<TInsurancePolicy>query().lambda()
@@ -1933,12 +1941,10 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 						}
 					}
 				}
-				boolean booleanInvoiceNo = StringUtils.isNotBlank(success.getInvoiceNo()) && !success.getInvoiceNo().equals(detail.getInvoiceNo());
-				boolean booleanPolicyNo = StringUtils.isNotBlank(success.getPolicyNo()) && !success.getPolicyNo().equals(detail.getPolicyNo());
-				boolean isEquals = Common.isNotNull(detail.getActualPremium()) && Common.isNotNull(success.getActualPremium()) && new BigDecimal(success.getActualPremium()).compareTo(detail.getActualPremium()) == 0;
 				//如果当前保费为空，且保单号或发票号不一样
-				if ((StringUtils.isBlank(success.getActualPremium()) || isEquals) && (booleanInvoiceNo || booleanPolicyNo)
-						&& StringUtils.isNotBlank(detail.getDefaultSettleId())) {
+				if ((StringUtils.isBlank(success.getActualPremium()) || (Common.isNotNull(detail.getActualPremium())
+						&& Common.isNotNull(success.getActualPremium()) && new BigDecimal(success.getActualPremium()).compareTo(detail.getActualPremium()) == 0))
+						&& (booleanInvoiceNo || booleanPolicyNo) && StringUtils.isNotBlank(detail.getDefaultSettleId())) {
 					settle = tInsuranceSettleService.getById(detail.getDefaultSettleId());
 					if (Optional.ofNullable(settle).isPresent()) {
 						//如果当前实缴信息未推送，则新增实缴单推送
@@ -3568,12 +3574,8 @@ public class TInsuranceDetailServiceImpl extends ServiceImpl<TInsuranceDetailMap
 					continue;
 				}
 				//商险办理地权限校验
-				Integer c = detail.getInsuranceHandleCity();
-				Integer p = detail.getInsuranceHandleProvince();
-				log.error("省市权限：" + c.toString() + "_" + p.toString());
-				if(insuranceAreaResList.stream().noneMatch(s -> c.equals(s.getCity()) && p.equals(s.getProvince()))){
-					TInsuranceAreaRes a = insuranceAreaResList.get(0);
-					log.error("数据库省市权限：" + a.getProvince() + "_" + a.getCity());
+				String c = detail.getInsuranceHandleCity().toString();
+				if(insuranceAreaResList.stream().noneMatch(s -> c.equals(s.getCity()))){
 					param.setErrorMessage(InsurancesConstants.NO_DETAIL_JURISDICTION);
 					continue;
 				}

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

@@ -663,6 +663,13 @@ public class TPaymentInfo extends BaseEntity {
 	@ExcelProperty("支出信息付款状态")
 	private String payCollectFlag;
 
+	/**
+	 * EKP的 是否BPO：  是  否
+	 */
+	@Schema(description = "是否BPO", name = "bpoFlag")
+	@ExcelIgnore
+	private String bpoFlag;
+
 	/**
 	 * 是否需要生成收入
 	 */

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

@@ -211,6 +211,15 @@ public class TProvidentFund extends BaseEntity {
 	@HeadFontStyle(fontHeightInPoints = 11)
 	@ExcelProperty("项目" )
 	private String settleDomain;
+	/**
+	 * 项目编码
+	 */
+	@Length(max = 32, message = "项目编码 不能超过32个字符" )
+	@ExcelAttribute(name = "项目编码", maxLength = 32)
+	@Schema(description = "项目编码" )
+	@HeadFontStyle(fontHeightInPoints = 11)
+	@ExcelProperty("项目编码" )
+	private String settleDomainCode;
 	/**
 	 * 缴纳地-省
 	 */

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

@@ -314,6 +314,15 @@ public class TSocialInfo extends BaseEntity {
 	@HeadFontStyle(fontHeightInPoints = 11)
 	@ExcelProperty("项目" )
 	private String settleDomain;
+	/**
+	 * 项目编码
+	 */
+	@Length(max = 32, message = "项目编码 不能超过32个字符" )
+	@ExcelAttribute(name = "项目编码", maxLength = 32)
+	@Schema(description = "项目编码" )
+	@HeadFontStyle(fontHeightInPoints = 11)
+	@ExcelProperty("项目编码" )
+	private String settleDomainCode;
 	/**
 	 * 缴纳地-省
 	 */

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

@@ -260,5 +260,12 @@ public class TPaymentInfoPushVo implements Serializable {
 	@HeadFontStyle(fontHeightInPoints = 11)
 	@ExcelProperty("创建时间")
 	private String createTime;
+	/**
+	 * 是否bpo标识
+	 */
+	@Schema(description = "是否bpo标识")
+	@HeadFontStyle(fontHeightInPoints = 11)
+	@ExcelProperty("是否bpo标识")
+	private String bpoFlag;
 
 }

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

@@ -1373,6 +1373,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 			fund.setDeleteFlag(CommonConstants.ZERO_STRING);
 			fund.setBelongUnit(excel.getCustomerId());
 			fund.setSettleDomain(excel.getSettleDomainId());
+			fund.setSettleDomainCode(excel.getSettleDomainCode());
 			if (Common.isNotNull(empVo)){
 				fund.setEmpId(empVo.getId());
 				fund.setEmpNo(empVo.getEmpNo());
@@ -1504,6 +1505,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 			//  封装单位信息 结算信息
 			social.setBelongUnit(excel.getCustomerId());
 			social.setSettleDomain(excel.getSettleDomainId());
+			social.setSettleDomainCode(excel.getSettleDomainCode());
 			if (Common.isNotNull(empVo)){
 				social.setEmpId(empVo.getId());
 				social.setEmpName(empVo.getEmpName());

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

@@ -437,7 +437,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 		ConcurrentHashMap<String, BigDecimal> medicalMoneyMap = new ConcurrentHashMap<>();
 		//补缴利息
 		ConcurrentHashMap<String, BigDecimal> accrualMoneyMap = new ConcurrentHashMap<>();
-
+		//获取所有项目信息
+		Map<String, TSettleDomainSelectVo> domainMap = this.getSelectVoMap();
 		ExcelUtil<TPaymentInfoVo> util1 = new ExcelUtil<>(TPaymentInfoVo.class);
 		// 写法2：
 		// 匿名内部类 不用额外写一个DemoDataListener
@@ -487,7 +488,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 					log.info("{}条数据，开始存储数据库！", cachedDataList.size());
 					importTPaymentSocialInfo(cachedDataList, sumNumKey, importSuccessKey, errorMessageList, user,
 							rowNumber, pensionMoneyMap, bigMoneyMap, unEmpMoneyMap, birMoneyMap, injuryMoneyMap,
-							medicalMoneyMap, accrualMoneyMap);
+							medicalMoneyMap, accrualMoneyMap ,domainMap);
 					log.info("存储数据库成功！");
 				}
 			}).sheet().doRead();
@@ -495,6 +496,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 			log.error(CommonConstants.IMPORT_DATA_ANALYSIS_ERROR, e);
 			return R.failed(CommonConstants.IMPORT_DATA_ANALYSIS_ERROR);
 		}
+		domainMap.clear();
 		pensionMoneyMap.clear();
 		bigMoneyMap.clear();
 		unEmpMoneyMap.clear();
@@ -544,7 +546,8 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 										  ConcurrentHashMap<String, BigDecimal> birMoneyMap,
 										  ConcurrentHashMap<String, BigDecimal> injuryMoneyMap,
 										  ConcurrentHashMap<String, BigDecimal> medicalMoneyMap,
-										  ConcurrentHashMap<String, BigDecimal> accrualMoneyMap) {
+										  ConcurrentHashMap<String, BigDecimal> accrualMoneyMap,
+										  Map<String,TSettleDomainSelectVo> domainMap) {
 		HashMap<String, String> areaMap = new HashMap<>();
 		HashMap<String, String> areaMap2 = new HashMap<>();
 		R<AreaVo> areaListR = upmsDaprUtils.getAreaListR();
@@ -797,69 +800,23 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 					redisUtil.set(importSuccessKey, maerialRatio, 360L);
 
 					try {
-						// 1.list.size()不足partSize，直接执行
-						if (list.size() < partSize) {
-							CompletableFuture<List<ErrorDetailVO>> listCompletableFuture = CompletableFuture.supplyAsync(() ->
-									executeImportSocialList(user, list, areaMap, areaMap2,
-											paymentInfoPensionMap, paymentInfoBigMap, paymentInfoBirMap,
-											paymentInfoMedicalMap, paymentInfoUnEmpMap, paymentInfoInjuryMap,
-											errorMessageList, pensionMoneyMap, bigMoneyMap, unEmpMoneyMap, birMoneyMap,
-											injuryMoneyMap, medicalMoneyMap, accrualMoneyMap, paymentInfoaccrualMap
-									), yfSocialImportThreadPoolExecutor);
-							completableFutureList.add(listCompletableFuture);
-						}
-
-						// 2.list.size()大于partSize，循环分批执行
-						int lastIdx = 0;
-						if (partSize <= list.size()) {
-							// 处理第一个0位元素
-							final List<TPaymentInfoVo> finalList = list.subList(0, 1);
+						// 1.list.size()不足100时直接执行
+						if (list.size() < 100) {
 							CompletableFuture<List<ErrorDetailVO>> listCompletableFuture = CompletableFuture.supplyAsync(() ->
-									executeImportSocialList(user, finalList, areaMap, areaMap2,
+									executeImportSocialList(user, list, areaMap, areaMap2,domainMap,
 											paymentInfoPensionMap, paymentInfoBigMap, paymentInfoBirMap,
 											paymentInfoMedicalMap, paymentInfoUnEmpMap, paymentInfoInjuryMap,
 											errorMessageList, pensionMoneyMap, bigMoneyMap, unEmpMoneyMap, birMoneyMap,
 											injuryMoneyMap, medicalMoneyMap, accrualMoneyMap, paymentInfoaccrualMap
 									), yfSocialImportThreadPoolExecutor);
 							completableFutureList.add(listCompletableFuture);
-
-							lastIdx = 1;
-							for (int i = 1; i < list.size(); i++) {
-								// partSize数量的list为一个执行单元
-								tempList.add(list.get(i));
-								if (i % partSize == 0) {
-									lastIdx = i;
-									List<TPaymentInfoVo> finalTempList = tempList;
-									CompletableFuture<List<ErrorDetailVO>> oneCompletableFuture = CompletableFuture.supplyAsync(() ->
-											executeImportSocialList(user, finalTempList, areaMap, areaMap2,
-													paymentInfoPensionMap, paymentInfoBigMap, paymentInfoBirMap,
-													paymentInfoMedicalMap, paymentInfoUnEmpMap, paymentInfoInjuryMap,
-													errorMessageList, pensionMoneyMap, bigMoneyMap, unEmpMoneyMap, birMoneyMap,
-													injuryMoneyMap, medicalMoneyMap, accrualMoneyMap, paymentInfoaccrualMap
-											), yfSocialImportThreadPoolExecutor);
-									completableFutureList.add(oneCompletableFuture);
-									tempList = new ArrayList<>();
-								}
-							}
-						}
-
-						// 3.第2种方式执行完后，有余数的情况下，执行3
-						if (lastIdx != 0) {
-							tempList = new ArrayList<>();
-							if (lastIdx == 1) {
-								for (int i = lastIdx; i < list.size(); i++) {
-									tempList.add(list.get(i));
-								}
 						} else {
-								for (int i = lastIdx + 1; i < list.size(); i++) {
-									tempList.add(list.get(i));
-								}
-								lastIdx += 1;
-							}
-
-							List<TPaymentInfoVo> finalTempList = tempList;
+							int j = 25;
+							for (int i = 0; i < 100; i = i + 25) {
+								// 单个线程每次执行25条
+								final List<TPaymentInfoVo> finalList = list.subList(i,i+j);
 								CompletableFuture<List<ErrorDetailVO>> listCompletableFuture = CompletableFuture.supplyAsync(() ->
-									executeImportSocialList(user, finalTempList, areaMap, areaMap2,
+										executeImportSocialList(user, finalList, areaMap, areaMap2,domainMap,
 												paymentInfoPensionMap, paymentInfoBigMap, paymentInfoBirMap,
 												paymentInfoMedicalMap, paymentInfoUnEmpMap, paymentInfoInjuryMap,
 												errorMessageList, pensionMoneyMap, bigMoneyMap, unEmpMoneyMap, birMoneyMap,
@@ -867,6 +824,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 										), yfSocialImportThreadPoolExecutor);
 								completableFutureList.add(listCompletableFuture);
 							}
+						}
 						// 阻塞当前线程，等待所有的线程执行完毕
 						boolean computeFlag;
 						do {
@@ -932,6 +890,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 														List<TPaymentInfoVo> list,
 														HashMap<String, String> areaMap,
 														HashMap<String, String> areaMap2,
+														Map<String,TSettleDomainSelectVo> domainMap,
 														ConcurrentHashMap<String, TPaymentInfo> paymentInfoPensionMap,
 														ConcurrentHashMap<String, TPaymentInfo> paymentInfoBigMap,
 														ConcurrentHashMap<String, TPaymentInfo> paymentInfoBirMap,
@@ -954,8 +913,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 			String temp;
 			int res;
 			List<TSocialInfo> socialist;
-			List<TSettleDomainSelectVo> settleDomainR;
-			R<TSettleDomainListVo> listVo;
+			TSettleDomain domain;
 
 			List<TSocialFundInfo> socialInfoList = socialFundInfoMapper.selectList(Wrappers.<TSocialFundInfo>query().lambda()
 					.in(TSocialFundInfo::getEmpIdcard, Common.listObjectToStrList(list, ExcelAttributeConstants.EMPIDCARD)));
@@ -1294,6 +1252,18 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 					paymentInfo.setEmpId(socialInfo.getEmpId());
 					paymentInfo.setEmpIdcard(socialInfo.getEmpIdcard());
 					paymentInfo.setEmpName(socialInfo.getEmpName());
+					//获取项目信息
+					if (Common.isNotNull(domainMap)) {
+						domain = domainMap.get(socialInfo.getSettleDomainCode());
+					} else {
+						domain = null;
+					}
+					if (Common.isNotNull(domain)) {
+						paymentInfo.setBpoFlag(domain.getBpoFlag());
+					} else {
+						errorMessageList.add(new ErrorDetailVO(infoVo.getRowIndex(), CommonConstants.ZERO_INT, infoVo.getEmpIdcard(), paymentInfo.getSocialHousehold(), paymentInfo.getProvidentHousehold(), infoVo.getEmpName(), "未找到对应的项目信息，请核实"));
+						continue;
+					}
 					paymentInfo.setSettleDomainId(socialInfo.getSettleDomain());
 					paymentInfo.setSettleDomainName(socialInfo.getSettleDomainName());
 					paymentInfo.setSettleDomainCode(socialInfo.getSettleDomainCode());
@@ -1307,20 +1277,23 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 					paymentInfo.setEmpId(tSocialInfo.getEmpId());
 					paymentInfo.setEmpIdcard(tSocialInfo.getEmpIdcard());
 					paymentInfo.setEmpName(tSocialInfo.getEmpName());
-					paymentInfo.setSettleDomainId(tSocialInfo.getSettleDomain());
-					listVo = archivesDaprUtil.selectSettleDomainSelectVoById(tSocialInfo.getSettleDomain());
-					if (Common.isNotNull(listVo)) {
-						TSettleDomainListVo tSettleDomainListVo = listVo.getData();
-						if (Common.isNotNull(tSettleDomainListVo) && Common.isNotEmpty(tSettleDomainListVo.getListSelectVO())) {
-							settleDomainR = tSettleDomainListVo.getListSelectVO();
-							for (TSettleDomainSelectVo vo : settleDomainR) {
-								paymentInfo.setSettleDomainName(vo.getDepartName());
-								paymentInfo.setSettleDomainCode(vo.getDepartNo());
-								paymentInfo.setUnitId(vo.getCustomerId());
-								paymentInfo.setUnitName(vo.getCustomerName());
-							}
+					//获取项目信息
+					if (Common.isNotNull(domainMap)) {
+						domain = domainMap.get(tSocialInfo.getSettleDomainCode());
+					} else {
+						domain = null;
 					}
+					if (Common.isNotNull(domain)) {
+						paymentInfo.setSettleDomainName(domain.getDepartName());
+						paymentInfo.setUnitId(domain.getCustomerId());
+						paymentInfo.setUnitName(domain.getCustomerName());
+						paymentInfo.setBpoFlag(domain.getBpoFlag());
+					} else {
+						errorMessageList.add(new ErrorDetailVO(infoVo.getRowIndex(), CommonConstants.ZERO_INT, infoVo.getEmpIdcard(), paymentInfo.getSocialHousehold(), paymentInfo.getProvidentHousehold(), infoVo.getEmpName(), "未找到对应的项目信息，请核实"));
+						continue;
 					}
+					paymentInfo.setSettleDomainId(tSocialInfo.getSettleDomainCode());
+					paymentInfo.setSettleDomainCode(tSocialInfo.getSettleDomain());
 					paymentInfo.setSocialProvince(tSocialInfo.getSocialProvince());
 					paymentInfo.setSocialCity(tSocialInfo.getSocialCity());
 					paymentInfo.setSocialTown(tSocialInfo.getSocialTown());
@@ -1444,7 +1417,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 		//医疗插入的集合
 		ConcurrentHashMap<String,TPaymentInfo> batchYyInsertList = new ConcurrentHashMap<>();
 		//获取所有项目信息
-		Map<String, TSettleDomainSelectVo> domainMap = this.getSelectVoMapById();
+		Map<String, TSettleDomainSelectVo> domainMap = this.getSelectVoMap();
 		//地区数据
 		HashMap<String, String> areaMap = new HashMap<>();
 		HashMap<String, String> areaMap2 = new HashMap<>();
@@ -1574,7 +1547,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 		//批量插入的集合
 		List<TPaymentInfo> batchInsertList = new ArrayList<>();
 		//获取所有项目信息
-		Map<String, TSettleDomainSelectVo> domainMap = this.getSelectVoMapById();
+		Map<String, TSettleDomainSelectVo> domainMap = this.getSelectVoMap();
 		//地区数据
 		HashMap<String, String> areaMap = new HashMap<>();
 		HashMap<String, String> areaMap2 = new HashMap<>();
@@ -1794,6 +1767,17 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 							paymentInfo.setEmpId(fund.getEmpId());
 							paymentInfo.setEmpIdcard(fund.getEmpIdcard());
 							paymentInfo.setEmpName(fund.getEmpName());
+							if (Common.isNotNull(domainMap)) {
+								domain = domainMap.get(fund.getSettleDomainCodeFund());
+							} else {
+								domain = null;
+							}
+							if (Common.isNotNull(domain)) {
+								paymentInfo.setBpoFlag(domain.getBpoFlag());
+							} else {
+								errorMessageList.add(new ErrorDetailVO(infoVo.getRowIndex(), CommonConstants.ZERO_INT, infoVo.getEmpIdcard(), paymentInfo.getSocialHousehold(), paymentInfo.getProvidentHousehold(), infoVo.getEmpName(), "未找到对应的项目信息，请核实"));
+								continue;
+							}
 							paymentInfo.setSettleDomainId(fund.getSettleDomainFund());
 							paymentInfo.setSettleDomainName(fund.getSettleDomainNameFund());
 							paymentInfo.setSettleDomainCode(fund.getSettleDomainCodeFund());
@@ -1807,24 +1791,23 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 							paymentInfo.setEmpId(tProvidentFund.getEmpId());
 							paymentInfo.setEmpIdcard(tProvidentFund.getEmpIdcard());
 							paymentInfo.setEmpName(tProvidentFund.getEmpName());
-							paymentInfo.setSettleDomainId(tProvidentFund.getSettleDomain());
 							//获取项目信息
 							if (Common.isNotNull(domainMap)) {
-								domain = domainMap.get(tProvidentFund.getSettleDomain());
+								domain = domainMap.get(tProvidentFund.getSettleDomainCode());
 							} else {
 								domain = null;
 							}
 							if (Common.isNotNull(domain)) {
 								paymentInfo.setSettleDomainName(domain.getDepartName());
-								paymentInfo.setSettleDomainCode(domain.getDepartNo());
 								paymentInfo.setUnitId(domain.getCustomerId());
 								paymentInfo.setUnitName(domain.getCustomerName());
+								paymentInfo.setBpoFlag(domain.getBpoFlag());
 							} else {
-								paymentInfo.setSettleDomainName("");
-								paymentInfo.setSettleDomainCode("");
-								paymentInfo.setUnitId("");
-								paymentInfo.setUnitName("");
+								errorMessageList.add(new ErrorDetailVO(infoVo.getRowIndex(), CommonConstants.ZERO_INT, infoVo.getEmpIdcard(), paymentInfo.getSocialHousehold(), paymentInfo.getProvidentHousehold(), infoVo.getEmpName(), "未找到对应的项目信息，请核实"));
+								continue;
 							}
+							paymentInfo.setSettleDomainId(tProvidentFund.getSettleDomain());
+							paymentInfo.setSettleDomainCode(tProvidentFund.getSettleDomainCode());
 							paymentInfo.setFundProvince(tProvidentFund.getFundProvince());
 							paymentInfo.setFundCity(tProvidentFund.getFundCity());
 							paymentInfo.setFundTown(tProvidentFund.getFundTown());
@@ -2088,7 +2071,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 				redisUtil.set(importSuccessKey, maerialRatio, 360L);
 
 				try {
-					// 1.list.size()不足partSize，直接执行
+					// 1.list.size()不足100时直接执行
 					if (list.size() < 100) {
 						CompletableFuture<ConcurrentHashMap<String, ErrorDetailVO>> listCompletableFuture = CompletableFuture.supplyAsync(()
 										-> executeImportSocialListThree(list, areaMap, areaMap2,
@@ -2101,7 +2084,7 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 					} else {
 						int j = 25;
 						for (int i = 0; i < 100; i = i + 25) {
-							// partSize数量的list为一个执行单元
+							// 单个线程每次执行25条
 							List<TPaymentHeFeiVo> finalTempList1 = list.subList(i,i+j);
 							CompletableFuture<ConcurrentHashMap<String, ErrorDetailVO>> listCompletableFuture = CompletableFuture.supplyAsync(()
 											-> executeImportSocialListThree(finalTempList1
@@ -2453,6 +2436,17 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 					payExists.setEmpId(socialInfo.getEmpId());
 					payExists.setEmpIdcard(socialInfo.getEmpIdcard());
 					payExists.setEmpName(socialInfo.getEmpName());
+					if (Common.isNotNull(domainMap)) {
+						domain = domainMap.get(tSocialInfo.getSettleDomainCode());
+					} else {
+						domain = null;
+					}
+					if (Common.isNotNull(domain)) {
+						payExists.setBpoFlag(domain.getBpoFlag());
+					} else {
+						errorMessageList.put(UUID.randomUUID().toString(),new ErrorDetailVO(infoVo.getRowIndex(), CommonConstants.ZERO_INT, infoVo.getEmpIdcard(), payExists.getSocialHousehold(), payExists.getProvidentHousehold(), infoVo.getEmpName(), "未找到对应的项目信息，请核实"));
+						continue;
+					}
 					payExists.setSettleDomainId(socialInfo.getSettleDomain());
 					payExists.setSettleDomainCode(Common.isNotNull(socialInfo.getSettleDomainCode()) ? socialInfo.getSettleDomainCode(): "");
 					payExists.setUnitId(Common.isNotNull(socialInfo.getUnitId()) ? socialInfo.getUnitId(): "");
@@ -2466,23 +2460,22 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 					payExists.setEmpId(tSocialInfo.getEmpId());
 					payExists.setEmpIdcard(tSocialInfo.getEmpIdcard());
 					payExists.setEmpName(tSocialInfo.getEmpName());
-					payExists.setSettleDomainId(tSocialInfo.getSettleDomain());
 					if (Common.isNotNull(domainMap)) {
-						domain = domainMap.get(tSocialInfo.getSettleDomain());
+						domain = domainMap.get(tSocialInfo.getSettleDomainCode());
 					} else {
 						domain = null;
 					}
 					if (Common.isNotNull(domain)) {
 						payExists.setSettleDomainName(domain.getDepartName());
-						payExists.setSettleDomainCode(domain.getDepartNo());
 						payExists.setUnitId(domain.getCustomerId());
 						payExists.setUnitName(domain.getCustomerName());
+						payExists.setBpoFlag(domain.getBpoFlag());
 					} else {
-						payExists.setSettleDomainName("");
-						payExists.setSettleDomainCode("");
-						payExists.setUnitId("");
-						payExists.setUnitName("");
+						errorMessageList.put(UUID.randomUUID().toString(),new ErrorDetailVO(infoVo.getRowIndex(), CommonConstants.ZERO_INT, infoVo.getEmpIdcard(), payExists.getSocialHousehold(), payExists.getProvidentHousehold(), infoVo.getEmpName(), "未找到对应的项目信息，请核实"));
+						continue;
 					}
+					payExists.setSettleDomainId(tSocialInfo.getSettleDomain());
+					payExists.setSettleDomainCode(tSocialInfo.getSettleDomainCode());
 					payExists.setSocialProvince(tSocialInfo.getSocialProvince());
 					payExists.setSocialCity(tSocialInfo.getSocialCity());
 					payExists.setSocialTown(tSocialInfo.getSocialTown());
@@ -3443,18 +3436,6 @@ public class TPaymentInfoServiceImpl extends ServiceImpl<TPaymentInfoMapper, TPa
 		return mapSelectVo;
 	}
 
-	private Map<String, TSettleDomainSelectVo> getSelectVoMapById() {
-		R<TSettleDomainListVo> settleDomainR = archivesDaprUtil.selectAllSettleDomainSelectVo();
-		Map<String,TSettleDomainSelectVo> mapSelectVo = null;
-		if (Common.isNotNull(settleDomainR) && Common.isNotNull(settleDomainR.getData())){
-			mapSelectVo = settleDomainR.getData().getMapSelectVo();
-		}
-		if (Common.isEmpty(mapSelectVo)){
-			ServiceUtil.runTimeExceptionDiy(CommonConstants.SETTLE_DOMAIN_GET_ERROR);
-		}
-		return mapSelectVo;
-	}
-
 	// hgw2023-1-6 10:44:00以下：B端相关接口
 	/**
 	 * 按年查询指定人的缴费库数据

yifu-social/yifu-social-biz/src/main/java/com/yifu/cloud/plus/v1/yifu/social/util/DoJointSocialTask.java

@@ -510,11 +510,7 @@ public class DoJointSocialTask {
 					socialParam.setFd_3adfe8c73cb5a4(CommonConstants.EMPTY_STRING);
 				}
 				//是否为BPO业务
-				if (Common.isNotNull(settleDomain) && Common.isNotNull(settleDomain.getBpoFlag())) {
-					socialParam.setFd_3b178dfcf9e3e6(settleDomain.getBpoFlag());
-				} else {
-					socialParam.setFd_3b178dfcf9e3e6(CommonConstants.EMPTY_STRING);
-				}
+				socialParam.setFd_3b178dfcf9e3e6(library.getBpoFlag());
 				//客户名称
 				if (Common.isNotNull(library.getUnitName())) {
 					socialParam.setFd_3adfe8c81a0e42(library.getUnitName());
@@ -809,11 +805,7 @@ public class DoJointSocialTask {
 					fundParam.setFd_3adfe8c73cb5a4(CommonConstants.EMPTY_STRING);
 				}
 				//是否为BPO业务
-				if (Common.isNotNull(settleDomain) && Common.isNotNull(settleDomain.getBpoFlag())) {
-					fundParam.setFd_3b178ea361cabe(settleDomain.getBpoFlag());
-				} else {
-					fundParam.setFd_3b178ea361cabe(CommonConstants.EMPTY_STRING);
-				}
+				fundParam.setFd_3b178ea361cabe(library.getBpoFlag());
 				//单位代缴
 				if (Common.isNotNull(library.getUnitProvidentSum())) {
 					fundParam.setFd_3adfeb52fbe966(library.getUnitProvidentSum().toString());

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

@@ -103,8 +103,9 @@
 		<result property="isIncomeStatus" column="IS_INCOME_STATUS"/>
 		<result property="incomeSettleFlag" column="INCOME_SETTLE_FLAG"/>
 		<result property="incomeCollectFlag" column="INCOME_COLLECT_FLAG"/>
-		<result property="paySettleFlag" column="PAY_COLLECT_FLAG"/>
-		<result property="payCollectFlag" column="PAY_SETTLE_FLAG"/>
+		<result property="paySettleFlag" column="PAY_SETTLE_FLAG"/>
+		<result property="payCollectFlag" column="PAY_COLLECT_FLAG"/>
+		<result property="bpoFlag" column="BPO_FLAG"/>
 	</resultMap>
 	<resultMap id="tPaymentInfoSumMap" type="com.yifu.cloud.plus.v1.yifu.social.vo.TPaymentInfoExportVo">
 		<result property="empName" column="EMP_NAME"/>
@@ -188,6 +189,7 @@
 		<result property="personalBigmailmentMoney" column="PERSONAL_BIGMAILMENT_MONEY"/>
 		<result property="createName" column="CREATE_NAME"/>
 		<result property="createTime" column="CREATE_TIME"/>
+		<result property="bpoFlag" column="BPO_FLAG"/>
 	</resultMap>
 
 	<resultMap id="tPaymentInfoBatchMap" type="com.yifu.cloud.plus.v1.yifu.social.vo.TPaymentInfoBatchVo">
@@ -1178,6 +1180,7 @@
 		SUM( a.PERSONAL_MEDICAL_MONEY ) AS PERSONAL_MEDICAL_MONEY,
 		SUM( a.PERSONAL_UNEMPLOYMENT_MONEY ) AS PERSONAL_UNEMPLOYMENT_MONEY,
 		SUM( a.PERSONAL_BIGMAILMENT_MONEY ) AS PERSONAL_BIGMAILMENT_MONEY,
+		a.BPO_FLAG,
 		a.CREATE_NAME,
 		DATE_FORMAT(a.CREATE_TIME,'%Y-%m-%d') AS CREATE_NAME
 		FROM t_payment_info a
@@ -1297,7 +1300,11 @@
 	<!--tPaymentInfo 按ID查收缴费库包含社保和公积金明细的数据查询-->
 	<select id="getAllPushInfoById" resultMap="tPaymentInfoMap">
 		SELECT
-		*
+		ID,
+		INCOME_SETTLE_FLAG,
+		INCOME_COLLECT_FLAG,
+		PAY_COLLECT_FLAG,
+		PAY_SETTLE_FLAG
 		FROM t_payment_info a
 		where a.ID in (${idStr})
 	</select>

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

@@ -43,6 +43,7 @@
     <result property="empName" column="EMP_NAME"/>
     <result property="empIdcard" column="EMP_IDCARD"/>
     <result property="settleDomain" column="SETTLE_DOMAIN"/>
+    <result property="settleDomainCode" column="SETTLE_DOMAIN_CODE"/>
     <result property="fundProvince" column="FUND_PROVINCE"/>
     <result property="fundCity" column="FUND_CITY"/>
     <result property="fundTown" column="FUND_TOWN"/>

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

@@ -56,6 +56,7 @@
     <result property="cardinalId" column="CARDINAL_ID"/>
     <result property="oldId" column="OLD_ID"/>
     <result property="settleDomain" column="SETTLE_DOMAIN"/>
+    <result property="settleDomainCode" column="SETTLE_DOMAIN_CODE"/>
     <result property="socialProvince" column="SOCIAL_PROVINCE"/>
     <result property="socialCity" column="SOCIAL_CITY"/>
     <result property="socialTown" column="SOCIAL_TOWN"/>