前端对接问题修复75

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

@@ -372,6 +372,9 @@ public class ApiCommissionController {
             }
             // 更新来佣记录
             Result.success(commissionService.updateCommission(commissionUpdateRequest));
+        } catch (BusinessException e) {
+            log.error("更新来佣记录时，业务异常", e);
+            return Result.fail(ErrorCode.OPERATION_ERROR.getCode(), e.getMessage());
         } catch (InterruptedException e) {
             Thread.currentThread().interrupt();
             log.error("更新来佣记录时，获取锁被中断", e);

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

@@ -291,6 +291,12 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
         if (commission == null) {
             throw new BusinessException(ResultCode.NULL_ERROR.getCode(), "未找到该来佣记录");
         }
+        if (StringUtils.isNotBlank(commission.getPolicyNo())) {
+            Policy policy = policyService.lambdaQuery().eq(Policy::getPolicyNo, commission.getPolicyNo()).one();
+            if (policy == null) {
+                throw new BusinessException(ResultCode.NULL_ERROR.getCode(), "保单不存在:" + commission.getPolicyNo());
+            }
+        }
 
         BigDecimal amount = commission.getAmount();
         BigDecimal requestAmount = commissionUpdateRequest.getAmount();
@@ -729,6 +735,7 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
             // 入账业务id
             commission.setCommissionBizId(RandomStringGenerator.generateBizId16(CommonEnum.UID_TYPE_COMMISSION.getCode()));
             // 关联业务id
+            if ("R".equals(request.getCommissionBizType())) {
                 if (MapUtils.isNotEmpty(policyMap)) {
                     Policy policy = policyMap.get(request.getPolicyNo());
                     if (policy != null) {
@@ -739,6 +746,9 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
                         commission.setPremium(Convert.toStr(policy.getPaymentPremium()));
                         // 本次入账比例
                         commission.setCurrentCommissionRatio(commission.calculateCurrentPaidRatio());
+                    } else {
+                        throw new BusinessException(ResultCode.PARAMS_ERROR.getCode(), "保单不存在, policyNo: " + request.getPolicyNo());
+                    }
                 }
             }
             // 关联预计来佣信息