feat:count channel

repository/src/main/java/com/jiejing/fitness/finance/repository/service/PartyToMerchantRpService.java

@@ -112,10 +112,9 @@ public class PartyToMerchantRpService extends
     this.baseMapper.delete(wrapper);
     this.baseMapper.delete(wrapper);
   }
   }
 
 
-
-  public long countAll(){
+  public Integer countByChannelNo(String channelNo) {
     QueryWrapper<PartyToMerchant> wrapper = new QueryWrapper<>();
     QueryWrapper<PartyToMerchant> wrapper = new QueryWrapper<>();
+    wrapper.eq(PartyToMerchant.CHANNEL_NO, channelNo);
     return this.baseMapper.selectCount(wrapper);
     return this.baseMapper.selectCount(wrapper);
   }
   }
-
 }
 }

service/src/main/java/com/jiejing/fitness/finance/service/axf/impl/AxfServiceImpl.java

@@ -571,7 +571,7 @@ public class AxfServiceImpl implements AxfService {
     Future<Integer> total = ((ThreadPoolTaskExecutor) executor).submit(
     Future<Integer> total = ((ThreadPoolTaskExecutor) executor).submit(
         () -> studioAxfApplyRpService.countDistinctStudioId());
         () -> studioAxfApplyRpService.countDistinctStudioId());
     Future<Integer> success = ((ThreadPoolTaskExecutor) executor).submit(
     Future<Integer> success = ((ThreadPoolTaskExecutor) executor).submit(
-        () -> ((Long) partyToMerchantRpService.countAll()).intValue());
+        () -> (partyToMerchantRpService.countByChannelNo(AxfConst.CHANNEL_NO)));
     try {
     try {
       return AggStudioAxfApplyVO.builder().total(total.get(5, TimeUnit.SECONDS))
       return AggStudioAxfApplyVO.builder().total(total.get(5, TimeUnit.SECONDS))
           .success(success.get(5, TimeUnit.SECONDS)).build();
           .success(success.get(5, TimeUnit.SECONDS)).build();