1

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

@@ -7,6 +7,7 @@ import com.baomidou.dynamic.datasource.annotation.DSTransactional;
 import com.game.business.domain.*;
 import com.game.business.dto.AppItemCountDTO;
 import com.game.business.service.*;
+import com.game.business.util.Common;
 import com.game.business.util.im.TencentCloudImUtil;
 import com.game.business.vo.AppGameItemBettingVO;
 import com.game.common.constant.finance.FinTranType1;
@@ -78,10 +79,10 @@ public class AppGameBettingTask {
             String gameCode = null;
             String time = null;
             String classCode = null;
+            Integer state = null;
             for (int i = 0; i < dataArry.size(); i++) {
                 JSONObject jsonObject = dataArry.getJSONObject(i);
                 if(jsonObject.containsKey("data")){
-//                    gameDataArry = jsonObject.getJSONArray("data");
                     gameCode = jsonObject.getString("id");
                 }
                 if(jsonObject.containsKey("time")){
@@ -90,6 +91,9 @@ public class AppGameBettingTask {
                 if(jsonObject.containsKey("id")){
                     classCode = jsonObject.getString("id");
                 }
+                if(jsonObject.containsKey("state")){
+                    state = jsonObject.getInteger("state");
+                }
             }
 
             if(classCode == null){
@@ -124,9 +128,16 @@ public class AppGameBettingTask {
                 return;
             }
             if(!codeGameMap.containsKey(gameCode)){
-//                    System.out.println("开奖游戏不存在：" + gameCode);
+//               System.out.println("开奖游戏不存在：" + gameCode);
                 return;
             }
+
+            if(gameCode.equals(Common.GAME_FOUR_CODE)){
+                if(state == null || state != 1){
+                    return;
+                }
+            }
+
             AppGame appGame = codeGameMap.get(gameCode).get(0);
             appGame.setGameTime(time);
             appGameService.updateAppGame(appGame);