新单跟进43

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

@@ -165,16 +165,18 @@ public class PolicyFollowServiceImpl extends ServiceImpl<PolicyFollowMapper, Pol
             // 先删除原有的转介人
             policyBrokerService.remove(new QueryWrapper<PolicyBroker>().eq("policy_biz_id", policyBizId));
 
-            List<PolicyBroker> policyBrokerList = brokerList.stream().map(policyBrokerDto -> {
+            List<PolicyBroker> policyBrokerList = new ArrayList<>();
+            for (PolicyBrokerDto policyBrokerDto : brokerList) {
                 PolicyBroker policyBroker = new PolicyBroker();
                 BeanUtils.copyProperties(policyBrokerDto, policyBroker);
                 policyBroker.setPolicyBizId(policyBizId);
+                policyBroker.setPolicyNo(policyFollow.getPolicyNo());
                 policyBroker.setCreatorId(loginUserId);
                 policyBroker.setCreateTime(new Date());
                 policyBroker.setUpdaterId(loginUserId);
                 policyBroker.setUpdateTime(new Date());
-                return policyBroker;
-            }).collect(Collectors.toList());
+                policyBrokerList.add(policyBroker);
+            }
 
             if (CollUtil.isNotEmpty(policyBrokerList)) {
                 policyBrokerService.saveBatch(policyBrokerList);