修改

src/main/java/com/qtzl/alterSales/dao/repo/jpa/second/AflMchStatisticsRepo.java

@@ -27,8 +27,8 @@ public interface AflMchStatisticsRepo extends JpaRepository<AflMchStatistics, St
      * @param feeType 费用类型
      * @return 、
      */
-    @Query("FROM AflMchStatistics WHERE statisticalDate =?1 AND subMchId = ?2 AND feeType = ?3")
-    AflMchStatistics getAflMchStatistics(Integer statisticalDate, String subMchId, String feeType);
+    @Query("FROM AflMchStatistics WHERE statisticalDate =?1 AND subMchId = ?2 AND feeType = ?3 and agencyId = ?4")
+    AflMchStatistics getAflMchStatistics(Integer statisticalDate, String subMchId, String feeType,String agencyId);
 
     /**
      * 根据子商户号和统计日期查询

src/main/java/com/qtzl/alterSales/manager/service/AflMchStatisticsServiceImpl.java

@@ -66,7 +66,7 @@ public class AflMchStatisticsServiceImpl implements AflMchStatisticsService {
                 continue;
             }
             for (WechatStatisticsVo statisticsVo : wechatStatisticsVos) {
-                AflMchStatistics mchStatistics = aflMchStatisticsRepo.getAflMchStatistics(statisticalDate, configVo.getSubMchId(), statisticsVo.getType());
+                AflMchStatistics mchStatistics = aflMchStatisticsRepo.getAflMchStatistics(statisticalDate, configVo.getSubMchId(), statisticsVo.getType(),statisticsVo.getAgencyId());
                 if (null == mchStatistics) {
                     mchStatistics = new AflMchStatistics();
                     mchStatistics.setInsertTime(LocalDateTime.now());