新单跟进101

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

@@ -327,10 +327,10 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
     public Boolean addCommission(CommissionAddRequest commissionAddRequest) {
         // 校验来佣所属保单是否存在
         String policyNo = commissionAddRequest.getPolicyNo();
-        boolean exists = policyService.exists(new QueryWrapper<Policy>().eq("policy_no", policyNo));
+        Policy policy = policyService.getOne(new QueryWrapper<Policy>().eq("policy_no", policyNo));
         // 校验来佣所属保单跟进是否存在
         boolean policyFollowExists = policyFollowService.exists(new QueryWrapper<PolicyFollow>().eq("policy_no", policyNo));
-        if (!exists && !policyFollowExists) {
+        if (policy == null && !policyFollowExists) {
             throw new BusinessException(ResultCode.NULL_ERROR.getCode(), "该保单号不存在，不能添加来佣");
         }
 
@@ -343,6 +343,15 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
         // 生成新单编号
         String commissionBizId = RandomStringGenerator.generateBizId16(CommonEnum.UID_TYPE_COMMISSION.getCode());
         commission.setCommissionBizId(commissionBizId);
+        // 保费为空时，查询保单初始保费或支付保费，为空时默认0
+        if (ObjectUtils.isEmpty(commission.getPremium())) {
+            Object object = policy.getInitialPremium() != null ? policy.getInitialPremium() : policy.getPaymentPremium();
+            if (object != null) {
+                commission.setPremium(object.toString());
+            } else {
+                commission.setPremium(BigDecimal.ZERO.toString());
+            }
+        }
         // 查询预计来佣
         CommissionExpected commissionExpected = queryByCommission(commission);
         if (commissionExpected != null) {