来佣接口23

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

@@ -262,8 +262,8 @@ public class ApiPolicyFollowController {
     @Operation(summary = "保存到保单库")
     @PostMapping("/addToPolicy")
     public Result<Boolean> addToPolicy(@RequestBody AddToPolicyRequest addToPolicyRequest, HttpServletRequest request) {
-        if (StringUtils.isBlank(addToPolicyRequest.getPolicyBizId())) {
-            return Result.fail(ErrorCode.PARAMS_ERROR.getCode(), ErrorCode.PARAMS_ERROR.getMessage());
+        if (CollectionUtils.isEmpty(addToPolicyRequest.getPolicyNoList())) {
+            return Result.fail(ErrorCode.PARAMS_ERROR.getCode(), "保单号列表不能为空");
         }
         return Result.success(policyFollowService.addToPolicy(addToPolicyRequest));
     }

yd-csf-service/src/main/java/com/yd/csf/service/dto/AddToPolicyRequest.java

@@ -4,14 +4,15 @@ import io.swagger.v3.oas.annotations.media.Schema;
 import lombok.Data;
 
 import java.io.Serializable;
+import java.util.List;
 
 @Data
 public class AddToPolicyRequest implements Serializable {
     /**
-     * 新单编号
+     * 保单号
      */
-    @Schema(description = "新单编号", requiredMode = Schema.RequiredMode.REQUIRED)
-    private String policyBizId;
+    @Schema(description = "保单号列表", requiredMode = Schema.RequiredMode.REQUIRED)
+    private List<String> policyNoList;
 
     private static final long serialVersionUID = 1L;
 }

yd-csf-service/src/main/java/com/yd/csf/service/service/impl/PolicyFollowServiceImpl.java

@@ -193,41 +193,41 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
 
     @Override
     public Boolean addToPolicy(AddToPolicyRequest addToPolicyRequest) {
-        String policyBizId = addToPolicyRequest.getPolicyBizId();
-        PolicyFollow policyFollow = getByPolicyBizId(policyBizId);
-        if (policyFollow == null) {
-            throw new BusinessException(ErrorCode.NOT_FOUND_ERROR.getCode(), "Policy biz id not found");
-        }
-
         // 获取当前登录用户
         AuthUserDto currentLoginUser = SecurityUtil.getCurrentLoginUser();
         String loginUserId = currentLoginUser.getId().toString();
 
-        // 保存到保单库
-        Policy policy = policyService.getOne(new QueryWrapper<Policy>().eq("policy_biz_id", policyBizId));
-        if (policy != null) {
-            // 更新
-            BeanUtils.copyProperties(policyFollow, policy, "id");
-            policy.setUpdaterId(loginUserId);
-            policy.setUpdateTime(new Date());
-
-            return policyService.updateById(policy);
-        } else {
-            // 不存在则创建
-            policy = new Policy();
-            BeanUtils.copyProperties(policyFollow, policy, "id");
-            policy.setId(null);
-            policy.setPolicyBizId(policyBizId);
-            policy.setCreatorId(loginUserId);
-            policy.setCreateTime(new Date());
-            policy.setUpdaterId(loginUserId);
-            policy.setUpdateTime(new Date());
-
-            return policyService.save(policy);
+        List<String> policyNoList = addToPolicyRequest.getPolicyNoList();
+        // 查询所有跟进记录
+        List<PolicyFollow> policyFollowList = list(new QueryWrapper<PolicyFollow>().in("policy_no", policyNoList));
+        for (PolicyFollow policyFollow : policyFollowList) {
+            // 查询保单是否存在
+            String policyBizId = policyFollow.getPolicyBizId();
+            Policy policy = policyService.getOne(new QueryWrapper<Policy>().eq("policy_biz_id", policyBizId));
+            if (policy != null) {
+                // 更新
+                BeanUtils.copyProperties(policyFollow, policy, "id");
+                policy.setUpdaterId(loginUserId);
+                policy.setUpdateTime(new Date());
+
+                policyService.updateById(policy);
+            } else {
+                // 不存在则创建
+                policy = new Policy();
+                BeanUtils.copyProperties(policyFollow, policy, "id");
+                policy.setId(null);
+                policy.setPolicyBizId(policyBizId);
+                policy.setCreatorId(loginUserId);
+                policy.setCreateTime(new Date());
+                policy.setUpdaterId(loginUserId);
+                policy.setUpdateTime(new Date());
+
+                policyService.save(policy);
+            }
         }
+        return true;
     }
 
-
 }