From 7b65fb8c1001850e468a51c2d9af474621ce7115 Mon Sep 17 00:00:00 2001
From: 44323 <443237572@qq.com>
Date: 星期二, 19 三月 2024 18:11:45 +0800
Subject: [PATCH] Merge branch '2.0' of http://120.76.84.145:10101/gitblit/r/java/PlayPai into 2.0

---
 cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java |   33 ++++++++++++++++++---------------
 1 files changed, 18 insertions(+), 15 deletions(-)

diff --git a/cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java b/cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java
index 482a6be..c2abaf0 100644
--- a/cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java
+++ b/cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java
@@ -18,10 +18,7 @@
 import io.swagger.annotations.ApiImplicitParams;
 import io.swagger.annotations.ApiOperation;
 import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.web.bind.annotation.PostMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.ResponseBody;
-import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.bind.annotation.*;
 
 import javax.annotation.Resource;
 import java.math.BigDecimal;
@@ -92,25 +89,18 @@
     })
     public ResultUtil<List<TGameConfig>> queryGameList(Integer siteId, Integer storeId) {
         try {
-
             Integer uid = tokenUtil.getUserIdFormRedis();
             AppUser appUser = appUserClient.queryAppUser(uid);
             List<TGameConfig> tGameConfigs = new ArrayList<>();
-
             if (appUser.getAddUserId() == null) {
-
-
                 List<SiteLock> lock = lockService.list(new QueryWrapper<SiteLock>().eq("siteId", siteId));
-
                 Date now = new Date();
                 for (SiteLock siteLock : lock) {
                     if (now.after(siteLock.getStartTime()) && now.before(siteLock.getEndTime())) {
                         return ResultUtil.error("当前场地已被锁定");
                     }
                 }
-
             }
-
             List<TGame> list = gameService.list(new LambdaQueryWrapper<TGame>().eq(TGame::getSiteId, siteId).eq(TGame::getStoreId, storeId).eq(TGame::getState, 0));
             if (list.size() > 0) {
                 Integer id = list.get(0).getId();
@@ -215,11 +205,12 @@
                             try {
                                 int num = 1;
                                 int wait = 0;
-                                while (num <= 10) {
+                                while (num <= 15) {
                                     int min = 5000;
                                     wait += (min * num);
                                     Thread.sleep(wait);
-                                    List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("code", code).eq("payType", 2));
+                                    List<TGameRecord> list = gameRecordService
+                                            .list(new QueryWrapper<TGameRecord>().eq("number", code).eq("payType", 1));
                                     TGameRecord one = list.get(0);
 
                                     if (one.getStatus() == 1) {
@@ -239,7 +230,7 @@
                                         Map<String, String> data1 = resultUtil.getData();
                                         String s = data1.get("trade_state");
                                         String transaction_id = data1.get("transaction_id");
-                                        if ("REFUND".equals(s) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) {
+                                        if ("REFUND".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) {
                                             break;
                                         }
                                         if ("SUCCESS".equals(s)) {
@@ -247,12 +238,13 @@
                                                 coursePackagePayment.setStatus(1);
                                                 coursePackagePayment.setMoney(config.getCash());
                                                 coursePackagePayment.setOrderNo(transaction_id);
+
                                             }
                                             gameRecordService.updateBatchById(list);
                                             Integer integer = startGame(uid, gameId, spaceId, sutuId);
                                             break;
                                         }
-                                        if ("USERPAYING".equals(s)) {
+                                        if ("USERPAYING".equals(s) || "NOTPAY".equals(s)) {
                                             num++;
                                         }
                                     }
@@ -411,4 +403,15 @@
     }
 
 
+    /**
+     * 根据sutuid获取游戏数据
+     * @param sutuId
+     * @return
+     */
+    @ResponseBody
+    @PostMapping("/getTGameBySutuId")
+    public TGame getTGameBySutuId(@RequestBody String sutuId){
+        return gameService.getOne(new QueryWrapper<TGame>().eq("blue", sutuId).or()
+                .eq("red", sutuId).eq("state", 0));
+    }
 }

--
Gitblit v1.7.1