优化修改

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

@@ -26,6 +26,7 @@ import com.baomidou.mybatisplus.annotation.TableName;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttribute;
 import com.yifu.cloud.plus.v1.yifu.common.core.constant.ExcelAttributeConstants;
 import com.yifu.cloud.plus.v1.yifu.common.mybatis.base.BaseEntity;
+import com.yifu.cloud.plus.v1.yifu.social.vo.SocialImportHandleVo;
 import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 import lombok.EqualsAndHashCode;
@@ -750,4 +751,14 @@ public class TDispatchInfo extends BaseEntity {
 	@TableField(exist = false)
 	private String noCreateUser;
 
+
+	@TableField(exist = false)
+	private SocialImportHandleVo excel;
+
+	@TableField(exist = false)
+	private String handlerRemaek;
+
+	@TableField(exist = false)
+	private String socialFailureType;
+
 }

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

@@ -5288,6 +5288,7 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 
 		String handlerRemaek;
 
+		List<TDispatchInfo> failueList = new ArrayList<>();
 		for (int i = 0; i < excelVOList.size(); i++) {
 			StringBuilder socialSucessType = new StringBuilder();
 			StringBuilder socialFailureType = new StringBuilder();
@@ -5375,26 +5376,37 @@ public class TDispatchInfoServiceImpl extends ServiceImpl<TDispatchInfoMapper, T
 					}
 					errorMessageList.add(errorMessage);
 				}
+
 				//办理失败处理
 				if (socialFailureType.length() > 1) {
 					if (!CommonConstants.TWO_STRING.equals(dispatch.getStatus())) {
 						continue;
 					}
+					dispatch.setHandlerRemaek(handlerRemaek);
+					dispatch.setSocialFailureType(socialFailureType.toString());
+					dispatch.setExcel(excel);
+					failueList.add(dispatch);
+				}
+			} catch (Exception e) {
+				log.error("批量导入办理异常：", e);
+				errorMessageList.add(new ErrorMessage(excel.getRowIndex(), CommonConstants.SAVE_FAILED, excel));
+			}
+		}
+		if (!Common.isEmpty(failueList)) {
+			SocialImportHandleVo vo;
+			for (TDispatchInfo dispatchInfo : failueList) {
+				vo = dispatchInfo.getExcel();
 				// 执行数据插入操作 组装
-					messageList = addBatchApplyHandle(Collections.singletonList(dispatch.getId()), CommonConstants.ZERO_STRING, user
-							, 1, CommonConstants.TWO_STRING, handlerRemaek + ServiceUtil.ifNullToEmpty(excel.getRemark()), socialFailureType.substring(0, socialFailureType.length() - 1), handlerRemaek + ServiceUtil.ifNullToEmpty(excel.getRemark()));
+				messageList = addBatchApplyHandle(Collections.singletonList(dispatchInfo.getId()), CommonConstants.ZERO_STRING, user
+						, 1, CommonConstants.TWO_STRING, dispatchInfo.getHandlerRemaek() + ServiceUtil.ifNullToEmpty(vo.getRemark()), dispatchInfo.getSocialFailureType().substring(0, dispatchInfo.getSocialFailureType().length() - 1), dispatchInfo.getHandlerRemaek() + ServiceUtil.ifNullToEmpty(vo.getRemark()));
 				if (Common.isNotNull(messageList)) {
 					errorMessage = messageList.get(CommonConstants.ZERO_INT);
-						errorMessage.setData(excel);
+					errorMessage.setData(vo);
 				} else {
-						errorMessage = new ErrorMessage(excel.getRowIndex(), CommonConstants.SAVE_SUCCESS, CommonConstants.GREEN, excel);
+					errorMessage = new ErrorMessage(vo.getRowIndex(), CommonConstants.SAVE_SUCCESS, CommonConstants.GREEN, vo);
 				}
 				errorMessageList.add(errorMessage);
 			}
-			} catch (Exception e) {
-				log.error("批量导入办理异常：", e);
-				errorMessageList.add(new ErrorMessage(excel.getRowIndex(), CommonConstants.SAVE_FAILED, excel));
-			}
 		}
 	}
 

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

@@ -1864,11 +1864,9 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 		//先删除然后重新生成
 		boolean isSaveAndUpdate = false;
 
-		synchronized (this) {
 		if (Common.isNotNull(librarySocialList)) {
 			baseMapper.deleteBatchIds(librarySocialList);
 		}
-		}
 		if (Common.isNotNull(libraryFundList)) {
 			baseMapper.deleteBatchIds(libraryFundList);
 		}
@@ -1908,12 +1906,8 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				log.error("更新一条预估耗时：" + times + "毫秒");
 				isSaveAndUpdate = true;
 			} else {
-				synchronized (this) {
 				if (BigDecimal.ZERO.compareTo(BigDecimalUtils.isNullToZero(library.getUnitSocialSum())) != CommonConstants.ZERO_INT
 						|| BigDecimal.ZERO.compareTo(BigDecimalUtils.isNullToZero(library.getUnitFundSum())) != CommonConstants.ZERO_INT) {
-						//判断是否有重复数据有则删除
-						baseMapper.deleteForecastSocial(library.getEmpIdcard(),library.getSocialPayMonth(),library.getSocialCreateMonth()
-						,library.getProvidentPayMonth(),library.getProvidentCreateMonth());
 					library.setCreateBy(userId);
 					library.setCreateName(userName);
 					library.setCreateTime(LocalDateTime.now());
@@ -1922,7 +1916,6 @@ public class TForecastLibraryServiceImpl extends ServiceImpl<TForecastLibraryMap
 				}
 			}
 		}
-		}
 		saveLibraryMap.clear();
 		if (Common.isNotNull(socialFundInfo.getSocialId()) && CommonConstants.FOUR_STRING.equals(socialFundInfo.getSocialStatus())
 				|| CommonConstants.THREE_STRING.equals(socialFundInfo.getSocialStatus())) {