Browse Source

fix : 增加充值流水日志-3

bilingfeng 1 week ago
parent
commit
1bcbb885b2

+ 1 - 1
game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/GameDataApplication.java

@@ -18,7 +18,7 @@ public class GameDataApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(GameDataApplication.class, args);
-        System.out.println("游戏数据服务启动成功 增加充值流水日志-2 ( ´・・)ノ(._.`) \n" +
+        System.out.println("游戏数据服务启动成功 增加充值流水日志-3 ( ´・・)ノ(._.`) \n" +
                 " ______  __     __     \n" +
                 "/_____/\\/__/\\ /__/\\    \n" +
                 "\\:::__\\/\\ \\::\\\\:.\\ \\   \n" +

+ 20 - 17
game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/service/impl/GameDataServiceImpl.java

@@ -1091,7 +1091,8 @@ public class GameDataServiceImpl implements IGameDataService {
             //父游戏维度
             switch (dto.getTableTypes()) {
                 case "buy" -> dayN = getDayNByTableName(dayNMap, "game_ads_parent.ads_dayn_game_buy_parent");
-                case "nature" -> dayN = getDayNByTableNameNature(dayNMap, "game_ads_parent.ads_dayn_game_nature_parent");
+                case "nature" ->
+                        dayN = getDayNByTableNameNature(dayNMap, "game_ads_parent.ads_dayn_game_nature_parent");
                 case "total" -> dayN = getDayNByTableName(dayNMap, "game_ads_parent.ads_dayn_game_parent");
                 default -> dayN = getDayNByTableName(dayNMap, "game_ads_parent.ads_dayn_game_parent");
             }
@@ -6491,6 +6492,7 @@ public class GameDataServiceImpl implements IGameDataService {
             countSql = Sqls.create(getCountNumSql(cri, agentCri, yesterdayTotalAmountCri));
         }
         countSql.setCallback(Sqls.callback.integer());
+        log.error("充值流水执行查询总记录数, SQL : {}",  countSql);
         dao.execute(countSql);
         pager.setRecordCount(countSql.getInt());
 
@@ -6506,7 +6508,7 @@ public class GameDataServiceImpl implements IGameDataService {
         sql.setEntity(dao.getEntity(FlowMonitorVO.class));
         sql.setPager(pager);
         //执行sql
-        log.error("充值流水执行, dto : {}, SQL : {}", JsonUtil.toString(dto), sql);
+        log.error("充值流水执行查询记录数据, SQL : {}", sql);
         dao.execute(sql);
         //得到结果集list
         List<FlowMonitorVO> list = sql.getList(FlowMonitorVO.class);
@@ -7480,6 +7482,7 @@ public class GameDataServiceImpl implements IGameDataService {
         //查询总消耗
         Sql costSql = Sqls.create(getTotalCostSql(costCri, costTable));
         costSql.setCallback(Sqls.callback.doubleValue());
+        log.error("充值流水执行查询消耗SQL : {}", costSql);
         dao.execute(costSql);
         return costSql.getDouble(0.00);
     }
@@ -7849,21 +7852,21 @@ public class GameDataServiceImpl implements IGameDataService {
                                    sum(amount)     twentyfour_amount
                             from game_dw.dw_order_day_amount
                             """ + cri + """
-                              group by source_system, day, pitcher_id, zx_pitcher_name, order_agent_id, agent_name,
-                                       account_id, parent_game_id, account_type
-                        )a
-                     left join (
-                                  select
-                                       source_system,
-                                       day,
-                                       pitcher_id,
-                                       order_agent_id,
-                                       account_id,
-                                       parent_game_id,
-                                       account_type,
-                                       sum(amount) ten_amount -- 10
-                                from game_dw.dw_order_day_amount
-                                """ + cri + """
+                         group by source_system, day, pitcher_id, zx_pitcher_name, order_agent_id, agent_name,
+                                  account_id, parent_game_id, account_type
+                   )a
+                left join (
+                             select
+                                  source_system,
+                                  day,
+                                  pitcher_id,
+                                  order_agent_id,
+                                  account_id,
+                                  parent_game_id,
+                                  account_type,
+                                  sum(amount) ten_amount -- 10
+                           from game_dw.dw_order_day_amount
+                           """ + cri + """
                                 and hour(order_create_time) < 10
                                 group by source_system, day, pitcher_id, order_agent_id, account_id, parent_game_id,
                                          account_type) b