1

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);
@@ -242,15 +241,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);
 
     }