新单跟进v2

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

@@ -262,18 +262,17 @@ public class ApiCommissionController {
         return Result.success(commissionService.addCommissionBatch(customerAddRequestList));
     }
 
-    // commissionAsyncService.commissionCompareBatch(commissionList);
-    @GetMapping("/test")
-    public Result<List<Commission>> testCompareBatch(@RequestParam("commissionBizId") String commissionBizId) {
+    @GetMapping("/compare")
+    public Result<Boolean> compare(@RequestParam("commissionBizId") String commissionBizId) {
         if (StringUtils.isBlank(commissionBizId)) {
-            return Result.fail(ResultCode.PARAMS_ERROR.getCode(), "来佣业务id不能为空");
+            return Result.fail(ResultCode.PARAMS_ERROR.getCode(), "commissionBizId不能为空");
         }
-        List<Commission> commissionList = commissionService.list(new QueryWrapper<Commission>().eq("commission_biz_id", commissionBizId));
-        if (CollectionUtils.isEmpty(commissionList)) {
+        Commission commission = commissionService.lambdaQuery().eq(Commission::getCommissionBizId, commissionBizId).one();
+        if (commission == null) {
             return Result.fail(ResultCode.PARAMS_ERROR.getCode(), "未查询到来佣数据");
         }
-        commissionAsyncService.commissionCompareBatch(commissionList);
-        return Result.success(commissionList);
+        commissionAsyncService.commissionCompare(commission);
+        return Result.success(Boolean.TRUE);
     }
 
     /**