新单跟进13

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

@@ -9,7 +9,6 @@ import com.yd.auth.core.utils.SecurityUtil;
 import com.yd.common.enums.CommonEnum;
 import com.yd.common.enums.ResultCode;
 import com.yd.common.exception.BusinessException;
-import com.yd.common.result.Result;
 import com.yd.common.utils.RandomStringGenerator;
 import com.yd.csf.service.common.ErrorCode;
 import com.yd.csf.service.dto.*;
@@ -154,23 +153,26 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
         policyFollow.setUpdaterId(loginUserId);
         policyFollow.setUpdateTime(new Date());
 
-        // 先删除原有的转介人
-        policyBrokerService.remove(new QueryWrapper<PolicyBroker>().eq("policy_biz_id", policyBizId));
-        // 保存转介人
+        // 修改转介人
         List<PolicyBrokerDto> brokerList = policyFollowUpdateRequest.getBrokerList();
-        List<PolicyBroker> policyBrokerList = brokerList.stream().map(policyBrokerDto -> {
-            PolicyBroker policyBroker = new PolicyBroker();
-            BeanUtils.copyProperties(policyBrokerDto, policyBroker);
-            policyBroker.setPolicyBizId(policyBizId);
-            policyBroker.setCreatorId(loginUserId);
-            policyBroker.setCreateTime(new Date());
-            policyBroker.setUpdaterId(loginUserId);
-            policyBroker.setUpdateTime(new Date());
-            return policyBroker;
-        }).collect(Collectors.toList());
+        if (CollUtil.isNotEmpty(brokerList)) {
+            // 先删除原有的转介人
+            policyBrokerService.remove(new QueryWrapper<PolicyBroker>().eq("policy_biz_id", policyBizId));
 
-        if (CollUtil.isNotEmpty(policyBrokerList)) {
-            policyBrokerService.saveBatch(policyBrokerList);
+            List<PolicyBroker> policyBrokerList = brokerList.stream().map(policyBrokerDto -> {
+                PolicyBroker policyBroker = new PolicyBroker();
+                BeanUtils.copyProperties(policyBrokerDto, policyBroker);
+                policyBroker.setPolicyBizId(policyBizId);
+                policyBroker.setCreatorId(loginUserId);
+                policyBroker.setCreateTime(new Date());
+                policyBroker.setUpdaterId(loginUserId);
+                policyBroker.setUpdateTime(new Date());
+                return policyBroker;
+            }).collect(Collectors.toList());
+
+            if (CollUtil.isNotEmpty(policyBrokerList)) {
+                policyBrokerService.saveBatch(policyBrokerList);
+            }
         }
         return updateById(policyFollow);
     }