放开统帅、方舟

game-business/src/main/java/com/game/business/task/AppGameBettingTask.java

@@ -52,7 +52,6 @@ public class AppGameBettingTask {
     @Autowired
     private IAppUserCountService appUserCountService;
 
-    @Async("asyncExecutor")
     public void gameDataTask(String message, String gameCodeFinal) throws Exception {
 
         JSONArray dataArry = JSONArray.parseArray(message);
@@ -232,15 +231,22 @@ public class AppGameBettingTask {
             appGameLottery.setGameLotterySucc(gameLotterySucc);
             appGameLotteryService.save(appGameLottery);
 
-            this.updateItme(appGame.getId(), gameLotterySucc);
+            lotteryTask(appGame, appGameClassify, gameLotterySucc, gameDate);
+        }
+
+    }
+
+    @Async("asyncExecutor")
+    public void lotteryTask(AppGame appGame, AppGameClassify appGameClassify, String gameLotterySucc, String gameDate) throws Exception {
+
+        this.updateItme(appGame.getId(), gameLotterySucc);
 
-            List<String> userIds = this.gameBettingTask(appGameClassify.getId(), appGame.getId(), gameDate, gameLotterySucc);
+        List<String> userIds = this.gameBettingTask(appGameClassify.getId(), appGame.getId(), gameDate, gameLotterySucc);
 
-            appUserCountService.staticsUserCount(appGame.getId(),null,appGame.getGameDate());
+        appUserCountService.staticsUserCount(appGame.getId(),null,appGame.getGameDate());
 
-            // 给中奖人发送刷新余额通知
-            sendMsg(userIds);
-        }
+        // 给中奖人发送刷新余额通知
+        sendMsg(userIds);
 
     }
 

game-business/src/main/java/com/game/business/websocket/client/GameOneClient.java

@@ -32,7 +32,6 @@ public class GameOneClient {
     @OnOpen
     public void onOpen(Session session) throws Exception{
         System.out.println("game one 游戏已连接 server");
-        // 发送游戏编码
         session.getBasicRemote().sendText("ping");
         Common.sessionMap.put(Common.GAME_ONE_CODE, session);
     }