来佣接口16

yd-csf-api/src/main/java/com/yd/csf/api/controller/ApiPolicyFollowController.java

@@ -23,6 +23,7 @@ import com.yd.csf.service.service.*;
 import com.yd.csf.service.vo.PolicyFollowVO;
 import io.swagger.v3.oas.annotations.Operation;
 import io.swagger.v3.oas.annotations.tags.Tag;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -110,9 +111,9 @@ public class ApiPolicyFollowController {
 
         List<PolicyExcelDTO> dtoList = policyDataListener.getList();
 
-        // 预计来佣根据保单号分组
-        Map<String, List<CommissionExcelDTO>> commissionMap = dataList.stream()
-                .collect(Collectors.groupingBy(CommissionExcelDTO::getPolicyNo));
+        // 校验保单号是否存在
+        String validateMsg = validate(dtoList);
+        if (StringUtils.isNotBlank(validateMsg)) return Result.fail(ErrorCode.OPERATION_ERROR.getCode(), validateMsg);
 
         // 转换为PolicyFollow对象
         List<PolicyFollowDTO> list = convertToObj(dtoList);
@@ -144,6 +145,28 @@ public class ApiPolicyFollowController {
         return Result.success(true);
     }
 
+    private String validate(List<PolicyExcelDTO> dtoList) {
+        String validateMsg = "";
+        // 校验保单号是否为空
+        if (dtoList.isEmpty()) {
+            validateMsg = "保单数据不能为空";
+        }
+
+        Set<String> policyNos = dtoList.stream()
+                .map(PolicyExcelDTO::getPolicyNo)
+                .collect(Collectors.toSet());
+        List<Policy> existingPolicies = policyService.lambdaQuery()
+                .in(Policy::getPolicyNo, policyNos)
+                .list();
+        Set<String> existingPolicyNos = existingPolicies.stream()
+                .map(Policy::getPolicyNo)
+                .collect(Collectors.toSet());
+        if (CollectionUtils.isNotEmpty(existingPolicyNos)) {
+            validateMsg = "保单号 " + String.join(", ", existingPolicyNos) + " 已存在，请检查后重新上传!";
+        }
+        return validateMsg;
+    }
+
     private List<PolicyFollowDTO> convertToObj(List<PolicyExcelDTO> list) throws ParseException {
         List<PolicyFollowDTO> policyFollowDTOList = new ArrayList<>();