修改只读

fs-service/src/main/java/com/fs/statis/mapper/ConsumptionBalanceMapper.java

@@ -12,14 +12,18 @@ public interface ConsumptionBalanceMapper {
     /**
      * 分析概览 - 经销商统计
      */
+    @DataSource(DataSourceType.SLAVE)
     AnalysisPreviewDTO analysisPreview(AnalysisPreviewQueryDTO queryDTO);
 
     /**
      * 消费余额
      */
+    @DataSource(DataSourceType.SLAVE)
     ConsumptionBalanceDataDTO rechargeConsumption();
 
+    @DataSource(DataSourceType.SLAVE)
     DealerAggregatedDTO dealerAggregated();
+    @DataSource(DataSourceType.SLAVE)
     DealerAggregatedDTO dealerAggregatedCompanyId(@Param("companyId") Long companyId);
 
     /**
@@ -27,6 +31,7 @@ public interface ConsumptionBalanceMapper {
      * @param queryDTO 请求参数
      * @return 观看人数
      */
+    @DataSource(DataSourceType.SLAVE)
     Long queryWatchUserCount(AnalysisPreviewQueryDTO queryDTO);
 
     /**
@@ -34,6 +39,7 @@ public interface ConsumptionBalanceMapper {
      * @param queryDTO 请求参数
      * @return  完播人数
      */
+    @DataSource(DataSourceType.SLAVE)
     Long queryCompletedUserCount(AnalysisPreviewQueryDTO queryDTO);
 
     /**
@@ -41,6 +47,7 @@ public interface ConsumptionBalanceMapper {
      * @param queryDTO 请求参数
      * @return 观看次数
      */
+    @DataSource(DataSourceType.SLAVE)
     Long queryWatchCount(AnalysisPreviewQueryDTO queryDTO);
 
     /**
@@ -48,6 +55,7 @@ public interface ConsumptionBalanceMapper {
      * @param queryDTO 请求参数
      * @return 完播次数
      */
+    @DataSource(DataSourceType.SLAVE)
     Long queryCompletedCount(AnalysisPreviewQueryDTO queryDTO);
 
     /**
@@ -55,6 +63,7 @@ public interface ConsumptionBalanceMapper {
      * @param queryDTO 请求参数
      * @return 答题人数
      */
+    @DataSource(DataSourceType.SLAVE)
     Long queryAnswerMemberCount(AnalysisPreviewQueryDTO queryDTO);
 
 
@@ -63,6 +72,7 @@ public interface ConsumptionBalanceMapper {
      * @param queryDTO 请求参数
      * @return 正确人数
      */
+    @DataSource(DataSourceType.SLAVE)
     Long queryCorrectUserCount(AnalysisPreviewQueryDTO queryDTO);
 
     /**
@@ -71,6 +81,7 @@ public interface ConsumptionBalanceMapper {
      * @return 奖励人数
      * @return
      */
+    @DataSource(DataSourceType.SLAVE)
     Long queryRewardCount(AnalysisPreviewQueryDTO queryDTO);
 
     /**
@@ -78,6 +89,7 @@ public interface ConsumptionBalanceMapper {
      * @param queryDTO 请求参数
      * @return 奖励金额
      */
+    @DataSource(DataSourceType.SLAVE)
     BigDecimal queryRewardMoney(AnalysisPreviewQueryDTO queryDTO);
 
     /**
@@ -93,6 +105,7 @@ public interface ConsumptionBalanceMapper {
      * @param param 请求参数
      * @return 观看完播趋势
      */
+    @DataSource(DataSourceType.SLAVE)
     List<WatchEndPlayTrendDTO> watchEndPlayTrend(AnalysisPreviewQueryDTO param);
 
     /**
@@ -100,6 +113,7 @@ public interface ConsumptionBalanceMapper {
      * @param param 请求参数
      * @return TOP10
      */
+    @DataSource(DataSourceType.SLAVE)
     List<DeaMemberTopTenDTO> deaMemberTopTen(AnalysisPreviewQueryDTO param);
 
     /**
@@ -115,6 +129,7 @@ public interface ConsumptionBalanceMapper {
      * @param param 请求参数
      * @return TOP10
      */
+    @DataSource(DataSourceType.SLAVE)
     List<RewardMoneyTopTenDTO> rewardMoneyTopTen(AnalysisPreviewQueryDTO param);
 
     /**
@@ -122,6 +137,7 @@ public interface ConsumptionBalanceMapper {
      * @param param 请求参数
      * @return 趋势
      */
+    @DataSource(DataSourceType.SLAVE)
     List<RewardMoneyTrendDTO> rewardMoneyTrendDTO(AnalysisPreviewQueryDTO param);
 
     BigDecimal getCurrentBalance();