新单跟进49

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

@@ -89,6 +89,7 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
     }
 
     @Override
+    @Transactional(rollbackFor = Exception.class)
     public Boolean updateCommission(CommissionUpdateRequest commissionUpdateRequest) {
         String commissionBizId = commissionUpdateRequest.getCommissionBizId();
         Commission commission = this.getOne(new QueryWrapper<Commission>().eq("commission_biz_id", commissionBizId));
@@ -96,6 +97,19 @@ public class CommissionServiceImpl extends ServiceImpl<CommissionMapper, Commiss
             throw new BusinessException(ResultCode.NULL_ERROR.getCode(), "未找到该来佣记录");
         }
         BeanUtils.copyProperties(commissionUpdateRequest, commission, "id", "commissionBizId");
+        // 查询预计来佣
+        QueryWrapper<CommissionExpected> queryWrapper = new QueryWrapper<>();
+        queryWrapper.eq("commission_biz_id", commissionBizId);
+        queryWrapper.eq("commission_name", commission.getCommissionName());
+        queryWrapper.eq("commission_period", commission.getCommissionPeriod());
+        queryWrapper.eq("commission_currency", commission.getCurrency());
+        CommissionExpected commissionExpected = commissionExpectedService.getOne(queryWrapper);
+        if (commissionExpected != null) {
+            // 对比预计来佣
+            compareWithExpected(commission, commissionExpected);
+            commissionExpectedService.updateById(commissionExpected);
+        }
+
         // 获取当前登录用户
         AuthUserDto currentLoginUser = SecurityUtil.getCurrentLoginUser();
         String loginUserId = currentLoginUser.getId().toString();