Fna接口55

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

@@ -23,6 +23,7 @@ import com.yd.csf.service.service.PolicyBrokerService;
 import com.yd.csf.service.service.PolicyService;
 import com.yd.csf.service.vo.CommissionVO;
 import com.yd.csf.service.vo.FnaVO;
+import org.apache.commons.collections4.CollectionUtils;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.beans.BeanUtils;
 import org.springframework.stereotype.Service;
@@ -145,17 +146,19 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
             String policyNo = commission.getPolicyNo();
 
             List<PolicyBroker> policyBrokers = brokerMap.get(policyNo);
-            for (PolicyBroker policyBroker : policyBrokers) {
-                Fortune fortune = new Fortune();
-                fortune.setFortuneBizId(RandomStringGenerator.generateBizId16(CommonEnum.UID_TYPE_FORTUNE.getCode()));
-                fortune.setPolicyNo(policyNo);
-                fortune.setBroker(policyBroker.getBrokerName());
-                fortune.setStatus(FortuneStatusEnum.IN_PROCESS.getItemValue());
-
-                fortune.setCreateTime(new Date());
-                fortune.setUpdateTime(new Date());
-
-                newFortuneList.add(fortune);
+            if (CollectionUtils.isNotEmpty(policyBrokers)) {
+                for (PolicyBroker policyBroker : policyBrokers) {
+                    Fortune fortune = new Fortune();
+                    fortune.setFortuneBizId(RandomStringGenerator.generateBizId16(CommonEnum.UID_TYPE_FORTUNE.getCode()));
+                    fortune.setPolicyNo(policyNo);
+                    fortune.setBroker(policyBroker.getBrokerName());
+                    fortune.setStatus(FortuneStatusEnum.IN_PROCESS.getItemValue());
+
+                    fortune.setCreateTime(new Date());
+                    fortune.setUpdateTime(new Date());
+
+                    newFortuneList.add(fortune);
+                }
             }
         }
         // 5. 保存发佣记录