新单跟进41

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

@@ -38,12 +38,12 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
 
     @Resource
     private FortuneService fortuneService;
-
     @Resource
     private PolicyFollowService policyFollowService;
-
     @Resource
     private PolicyBrokerService policyBrokerService;
+    @Resource
+    private PolicyService policyService;
 
     @Override
     public QueryWrapper<Commission> getQueryWrapper(CommissionQueryRequest commissionQueryRequest) {
@@ -166,6 +166,12 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
     @Override
     @Transactional(rollbackFor = Exception.class)
     public Boolean addCommission(CommissionAddRequest commissionAddRequest) {
+        // 校验来佣所属保单是否存在
+        String policyNo = commissionAddRequest.getPolicyNo();
+        Policy policy = policyService.getOne(new QueryWrapper<Policy>().eq("policy_no", policyNo));
+        if (policy == null) {
+            throw new BusinessException(ResultCode.NULL_ERROR.getCode(), "该保单不存在");
+        }
 
         // 获取当前登录用户
         AuthUserDto currentLoginUser = SecurityUtil.getCurrentLoginUser();