支付版本更新 根据资金流向使用V2或V3服务商版本支付

无关风月

2 天以前 5dc40fcd64b0513150f1d8335ab849e6d8cdc28e

 cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java

@@ -1,6 +1,8 @@
package com.dsh.other.controller;

import cn.hutool.http.HttpRequest;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONArray;
import com.alibaba.fastjson.JSONObject;
import com.alipay.api.response.AlipayTradeQueryResponse;
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
@@ -9,30 +11,35 @@
import com.dsh.other.feignclient.CourseRecordClient;
import com.dsh.other.feignclient.account.AppUserClient;
import com.dsh.other.feignclient.account.model.AppUser;
import com.dsh.other.model.GetTGameRecord;
import com.dsh.other.model.QueryMySiteVo;
import com.dsh.other.service.ISiteLockService;
import com.dsh.other.service.TGameConfigService;
import com.dsh.other.service.TGameRecordService;
import com.dsh.other.service.TGameService;
import com.dsh.other.model.User;
import com.dsh.other.service.*;
import com.dsh.other.util.*;
import com.dsh.other.util.httpClinet.HttpResult;
import com.dsh.other.util.wx.WxV3PayConfig;
import com.wechat.pay.contrib.apache.httpclient.util.AesUtil;
import io.swagger.annotations.ApiImplicitParam;
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.util.StringUtils;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.PrintWriter;
import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.*;
import java.util.stream.Collectors;

@RestController
@RequestMapping("/api/game")
@RequestMapping("")
public class GameController {

    @Autowired
@@ -48,7 +55,7 @@
    @Autowired
    private TokenUtil tokenUtil;

    @Autowired
    @Resource
    private AppUserClient appUserClient;

    @Autowired
@@ -57,9 +64,21 @@
    @Resource
    private CourseRecordClient courseRecordClient;

    @Autowired
    private IUserService userService;

    @Autowired
    private ISiteBookingService siteBookingService;

    private String smid = "2088330203191220";//平台支付宝商户号
    @Autowired
    private ISiteService siteService;




    @ResponseBody
    @PostMapping("/getIntro")
    @PostMapping("/api/game/getIntro")
    @ApiOperation(value = "获取步骤说明", tags = {"用户—游戏"})
    @ApiImplicitParams({
            @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
@@ -79,7 +98,7 @@


    @ResponseBody
    @PostMapping("/queryGameList")
    @PostMapping("/api/game/queryGameList")
    @ApiOperation(value = "获取当前场地的游戏列表配置", tags = {"用户—游戏"})
    @ApiImplicitParams({
            @ApiImplicitParam(value = "siteId", name = "siteId", dataType = "int", required = true),
@@ -88,32 +107,30 @@
    })
    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();
//                tGameConfigs = gameConfigService.list(new LambdaQueryWrapper<TGameConfig>().eq(TGameConfig::getOtherId, id));
                tGameConfigs = gameConfigService.listJs(id);

            }
            tGameConfigs.forEach(g -> {
                if(g.getGameId() == 0){
                    g.setGameType(2);
                }else{
                    g.setGameType(1);
                }
            });
            List<TGameConfig> filteredList = tGameConfigs.stream()
                    .filter(gameConfig -> !gameConfig.getImg().isEmpty())
                    .collect(Collectors.toList());
@@ -126,9 +143,54 @@


    @ResponseBody
    @PostMapping("/payGame")
    @PostMapping("/api/game/gameStartupCheck")
    @ApiOperation(value = "扫码启动游戏前的校验（0=不通过，1=通过）", tags = {"用户—游戏"})
    @ApiImplicitParams({
            @ApiImplicitParam(value = "三方游戏id", name = "gameId", dataType = "int", required = true),
            @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
    })
    public ResultUtil<Integer> gameStartupCheck(Integer gameId){
        try {
            Integer uid = tokenUtil.getUserIdFormRedis();
            if (null == uid) {
                return ResultUtil.tokenErr();
            }

            AppUser appUser1 = appUserClient.queryAppUser(uid);
            //判断当前用户是否是员工
            List<User> one = userService.list(new QueryWrapper<User>().eq("phone", appUser1.getPhone()).eq("status", 1));
            if (!one.isEmpty()) {
                return ResultUtil.success(1);
            }
            //普通用户校验当前时间是否在预约时间段内
            TGame game = gameService.getById(gameId);
            Integer siteId = game.getSiteId();
            SiteBooking siteBooking = siteBookingService.getOne(new QueryWrapper<SiteBooking>()
                    .eq("state", 1)
                    .in("status", Arrays.asList(1, 2))
                    .eq("appUserId", uid)
                    .eq("siteId", siteId)
                    .last(" and now() between startTime and endTime")
            );
            return ResultUtil.success(null == siteBooking ? 0 : 1);
        }catch (Exception e){
            e.printStackTrace();
            return ResultUtil.runErr();
        }
    }



    private String smidVx = "2088330203191220";//平台微信商户号

    @Autowired
    private IOperatorUserService operatorUserService;

    @ResponseBody
    @PostMapping("/api/game/payGame")
    @ApiOperation(value = "支付游戏", tags = {"用户—游戏"})
    @ApiImplicitParams({
            @ApiImplicitParam(value = "游戏类型（1=普通游戏，2=世界杯）", name = "gameType", dataType = "int", required = true),
            @ApiImplicitParam(value = "三方游戏id", name = "gameId", dataType = "int", required = true),
            @ApiImplicitParam(value = "游戏配置id", name = "configId", dataType = "int", required = true),
            @ApiImplicitParam(value = "sutuId", name = "sutuId", dataType = "int", required = true),
@@ -136,11 +198,28 @@
            @ApiImplicitParam(value = "1微信 2支付宝 3玩湃币 5积分", name = "type", dataType = "int", required = true),
            @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
    })
    public ResultUtil payGame(Integer gameId, Integer configId, Integer type, Integer sutuId, Integer spaceId) {
    public ResultUtil payGame(Integer gameType, Integer gameId, Integer configId, Integer type, Integer sutuId, Integer spaceId) {
        try {
            Integer uid = tokenUtil.getUserIdFormRedis();
            if (null == uid) {
                return ResultUtil.tokenErr();
            }
            Site site = siteService.getById(spaceId);
            Store store = storeService.getById(site.getStoreId());

            // 是否分账 0否1是
            int isFenZhang= 1;
            String merchantNumber = "";
            if (store.getOperatorId()==null || store.getOperatorId()==0){
                // 平台
                isFenZhang = 0;
            }
            //判断当前用户是否是员工
            AppUser appUser1 = appUserClient.queryAppUser(uid);
            List<User> one = userService.list(new QueryWrapper<User>().eq("phone", appUser1.getPhone()).eq("status", 1));
            if (!one.isEmpty()) {
                Integer integer = startGame(uid, gameType, gameId, spaceId, sutuId);
                return ResultUtil.success();
            }
            SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
            String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5);
@@ -151,133 +230,122 @@
            tGameRecord.setUserId(uid);
            tGameRecord.setNumber(code);
            tGameRecord.setTime(new Date());
            tGameRecord.setSiteId(spaceId);
            gameRecordService.save(tGameRecord);

            System.err.println("启动游戏支付");
            if (type == 1) {
                ResultUtil weixinpay = payMoneyUtil.weixinpay("游戏支付", "", code, config.getCash().toString(), "/base/course/weChatPaymentCourseCallback", "APP", "");
                if (weixinpay.getCode() == 200) {
                    new Thread(new Runnable() {
                        @Override
                        public void run() {
                            try {
                                int num = 1;
                                int wait = 0;
                                while (num <= 10) {
                                    int min = 5000;
                                    wait += (min * num);
                                    Thread.sleep(wait);
                                    List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("code", code).eq("payType", 2));
                                    TGameRecord one = list.get(0);

                                    if (one.getStatus() == 1) {
                                        break;
                                    }
                                    ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(code, "");
                                    if (resultUtil.getCode() == 200 && one.getStatus() == 0) {
                                        /**
                                         * SUCCESS—支付成功，
                                         * REFUND—转入退款，
                                         * NOTPAY—未支付，
                                         * CLOSED—已关闭，
                                         * REVOKED—已撤销（刷卡支付），
                                         * USERPAYING--用户支付中，
                                         * PAYERROR--支付失败(其他原因，如银行返回失败)
                                         */
                                        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) {
                                            break;
                                        }
                                        if ("SUCCESS".equals(s)) {
                                            for (TGameRecord coursePackagePayment : list) {
                                                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)) {
                                            num++;
                                        }
                                    }
                                }
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    }).start();
                tGameRecord.setMoney(config.getCash());
                gameRecordService.updateById(tGameRecord);
                String params = uid + "_" + gameId + "_" + spaceId + "_" + sutuId+"_"+code+"_"+configId + "_" + gameType;
//                ResultUtil weixinpay = payMoneyUtil.weixinpay("游戏支付-"+isFenZhang, params, code, config.getCash().toString(),
//                        "/base/game/wechatPaymentGameCallback", "APP", "");
                System.err.println("启动游戏支付");
                if (store.getOperatorId()==null||store.getOperatorId()==0){
                    // 平台
                                    ResultUtil weixinpay = payMoneyUtil.weixinpay("游戏支付", params, code, config.getCash().toString(),
                        "/base/game/wechatPaymentGameCallback", "APP", "");
                                    return weixinpay;
                }else{
                    String smidVx= operatorUserService.getmerchantNumberByOperatorId(store.getOperatorId());
                    if (!StringUtils.hasLength(smidVx)){
                        return ResultUtil.error("运营商未配置微信商户号，获取支付失败!");
                    }
                    return payMoneyUtil.weixinpayV3(smidVx,"游戏支付"
                            ,code,"/base/huimin/callBack/wechatPaymentGameCallback1",
                          config.getCash().toString(),params);
                }
                return weixinpay;




            } else if (type == 2) {
//                Integer gameId, Integer configId,Integer type,Integer sutuId,Integer spaceId;

                String params = uid + "_" + gameId + "_" + spaceId + "_" + sutuId+"_"+code+"_"+configId;

                ResultUtil alipay = payMoneyUtil.alipay("游戏支付", "游戏支付", params, code, config.getCash().toString(), "/base/site/gameCallback");
                if (alipay.getCode() == 200) {
                    new Thread(new Runnable() {
                        @Override
                        public void run() {
                            try {
                                int num = 1;
                                int wait = 0;
                                while (num <= 10) {
                                    int min = 5000;
                                    wait += (min * num);
                                    Thread.sleep(wait);
                                    List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("number", code).eq("payType", 2));
                                    TGameRecord one = list.get(0);
                                    if (one.getStatus() == 1) {
                                        break;
                                    }
                                    AlipayTradeQueryResponse resultUtil = payMoneyUtil.queryALIOrder(code);
                                    if (resultUtil.getCode().equals("10000") && one.getStatus() == 0) {
                                        /**
                                         * WAIT_BUYER_PAY（交易创建，等待买家付款）、
                                         * TRADE_CLOSED（未付款交易超时关闭，或支付完成后全额退款）、
                                         * TRADE_SUCCESS（交易支付成功）、
                                         * TRADE_FINISHED（交易结束，不可退款）
                                         */
//                                        Map<String, String> data1 = resultUtil.getData();
//                                        String s = data1.get("tradeStatus");
//                                        String tradeNo = data1.get("tradeNo");
                                        String tradeNo = resultUtil.getTradeNo();
                                        String s = resultUtil.getTradeStatus();
                                        if ("TRADE_CLOSED".equals(s) || "TRADE_FINISHED".equals(s) || num == 10) {
                                            break;
                                        }
                                        if ("TRADE_SUCCESS".equals(s)) {
                                            for (TGameRecord coursePackagePayment : list) {
                                                coursePackagePayment.setStatus(1);
                                                coursePackagePayment.setMoney(config.getCash());
                                                coursePackagePayment.setOrderNo(tradeNo);

                                                CourseCounsum courseCounsum = new CourseCounsum();
//                                                courseCounsum.setPaymentId(paymentId);
                                                courseCounsum.setChangeType(3);
                                                courseCounsum.setInsertTime(new Date());
                                                courseCounsum.setReason("智慧球场;" + config.getCash());
                                                courseCounsum.setAppUserId(uid);
                                                courseRecordClient.save(courseCounsum);

                                            }
                                            gameRecordService.updateBatchById(list);
                                            Integer integer = startGame(uid, gameId, spaceId, sutuId);
                                            break;
                                        }
                                        if ("WAIT_BUYER_PAY".equals(s)) {
                                            num++;
                                        }
                                    }
                                }
                            } catch (Exception e) {
                                e.printStackTrace();
                            }
                        }
                    }).start();
                tGameRecord.setMoney(config.getCash());
                gameRecordService.updateById(tGameRecord);
                String smid1="";
                String params = uid + "_" + gameId + "_" + spaceId + "_" + sutuId+"_"+code+"_"+ configId + "_" + gameType;
                // 判断这个课包属于哪个门店 属于哪个运营商 根据运营商 id 获取对应的商户号
                TGame game = gameService.getOne(new QueryWrapper<TGame>().eq("blue", sutuId).or().eq("red", sutuId));
                Integer operationId = game.getOperationId();
                if (operationId==0){
                    // 是平台的
                    smid1 = smid;
                }else{
                    String smidByOperatorId = siteService.getmerchantNumberAliByOperatorId(operationId);
                    smid1 = smidByOperatorId;
                }

                ResultUtil alipay = payMoneyUtil.alipay(smid1,"游戏支付", "游戏支付", params, code, config.getCash().toString(),
                        "/base/game/aliPaymentGameCallback");
//                if (alipay.getCode() == 200) {
//                    new Thread(new Runnable() {
//                        @Override
//                        public void run() {
//                            try {
//                                int num = 1;
//                                int wait = 0;
//                                while (num <= 10) {
//                                    int min = 5000;
//                                    wait += (min * num);
//                                    Thread.sleep(wait);
//                                    List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("number", code).eq("payType", 2));
//                                    TGameRecord one = list.get(0);
//                                    if (one.getStatus() == 1) {
//                                        break;
//                                    }
//                                    AlipayTradeQueryResponse resultUtil = payMoneyUtil.queryALIOrder(code);
//                                    if (resultUtil.getCode().equals("10000") && one.getStatus() == 0) {
//                                        /**
//                                         * WAIT_BUYER_PAY（交易创建，等待买家付款）、
//                                         * TRADE_CLOSED（未付款交易超时关闭，或支付完成后全额退款）、
//                                         * TRADE_SUCCESS（交易支付成功）、
//                                         * TRADE_FINISHED（交易结束，不可退款）
//                                         */
//                                        String tradeNo = resultUtil.getTradeNo();
//                                        String s = resultUtil.getTradeStatus();
//                                        if ("TRADE_CLOSED".equals(s) || "TRADE_FINISHED".equals(s) || num == 10) {
//                                            break;
//                                        }
//                                        if ("TRADE_SUCCESS".equals(s)) {
//                                            for (TGameRecord gameRecord : list) {
//                                                gameRecord.setStatus(1);
//                                                gameRecord.setOrderNo(tradeNo);
//
//                                                CourseCounsum courseCounsum = new CourseCounsum();
//                                                courseCounsum.setChangeType(3);
//                                                courseCounsum.setInsertTime(new Date());
//                                                courseCounsum.setReason("智慧球场;" + config.getCash());
//                                                courseCounsum.setAppUserId(uid);
//                                                courseRecordClient.save(courseCounsum);
//
//                                            }
//                                            gameRecordService.updateBatchById(list);
//                                            Integer integer = startGame(uid, gameType, gameId, spaceId, sutuId);
//                                            // 判断这个课包属于哪个门店 属于哪个运营商 根据运营商 id 获取对应的商户号
//                                            TGame game = gameService.getById(gameId);
//                                            String smid2="";
//                                            Integer operationId = game.getOperationId();
//                                            if (operationId==0){
//                                                // 是平台的
//                                                smid2 = smid;
//                                            }else{
//                                                String smidByOperatorId = siteService.getSMIDByOperatorId(operationId);
//                                                smid2 = smidByOperatorId;
//                                            }
//                                            payMoneyUtil.confirm(smid2,code,tradeNo,config.getCash().toString());
//                                            break;
//                                        }
//                                        if ("WAIT_BUYER_PAY".equals(s)) {
//                                            num++;
//                                        }
//                                    }
//                                }
//                            } catch (Exception e) {
//                                e.printStackTrace();
//                            }
//                        }
//                    }).start();
//                }
                return alipay;
            } else if (type == 3) {
                tGameRecord.setMoney(config.getPlayCoin());
@@ -292,7 +360,7 @@
                int i1 = playPaiCoins - i;
                appUser.setPlayPaiCoins(i1);
                appUserClient.updateAppUser(appUser);
                startGame(uid, gameId, spaceId, sutuId);
                startGame(uid, gameType, gameId, spaceId, sutuId);
                return ResultUtil.success();

            } else if (type == 5) {
@@ -307,7 +375,7 @@
                appUser.setIntegral(i1);
                appUser.setPoints(playCoin.intValue());
                appUserClient.updateAppUser(appUser);
                startGame(uid, gameId, spaceId, sutuId);
                startGame(uid, gameType, gameId, spaceId, sutuId);
                return ResultUtil.success();
            } else {
                return ResultUtil.error("支付方式错误");
@@ -316,29 +384,268 @@
            e.printStackTrace();
            return ResultUtil.runErr();
        }


    }


    private static Integer startGame(Integer uid, Integer gameId, Integer spaceId, Integer sutuId) {
        HashMap<String, String> map = new HashMap<>();
        map.put("sign", "0DB011836143EEE2C2E072967C9F4E4B");
        map.put("app_user_id", uid + "");
        map.put("game_id", gameId + "");
        map.put("space_id", spaceId + "");
        map.put("sutu_id", sutuId + "");
    public Integer startGame(Integer uid, Integer gameType, Integer gameId, Integer spaceId, Integer sutuId) {
        TGame game = gameService.getOne(new QueryWrapper<TGame>().eq("blue", sutuId).or().eq("red", sutuId));
        if(1 == gameType){
            HashMap<String, String> map = new HashMap<>();
            map.put("sign", "0DB011836143EEE2C2E072967C9F4E4B");
            map.put("app_user_id", uid + "");
            map.put("game_id", gameId + "");
            map.put("space_id", spaceId + "");
            map.put("sutu_id", sutuId + "");

        String s = HttpRequestUtil.postRequest("https://try.daowepark.com/v7/user_api/general/gameStart", map);
        JSONObject jsonObject = JSONObject.parseObject(s);
        Object code = jsonObject.get("code");
        if (String.valueOf(code) != null && "200".equals(String.valueOf(code))) {
            System.err.println("--------------启动了一次游戏");
            return 200;
        } else {
            return 500;
            String s = HttpRequestUtil.postRequest("https://port.daowepark.com/v7/user_api/general/gameStart", map);
            JSONObject jsonObject = JSONObject.parseObject(s);
            Object code = jsonObject.get("code");
            if (String.valueOf(code) != null && "200".equals(String.valueOf(code))) {
                System.err.println("--------------启动了一次游戏");
                return 200;
            } else {
                return 500;
            }
        }else{
            //2、调起开启游戏的接口。
            HashMap<String, String> map = new HashMap<>();
            map.put("sign", "0DB011836143EEE2C2E072967C9F4E4B");
            map.put("space_id", spaceId + "");
            map.put("red_sutu_id", game.getRed());
            map.put("blue_sutu_id", game.getBlue());
            map.put("api_url", "http://221.182.45.100:56666/communityWorldCup/base/worldCup/endWorldCupCallback");
            map.put("custom", "{\"gameType\": 2}");

            String s = HttpRequestUtil.postRequest("https://port.daowepark.com/v7/user_api/general/quickStart", map);
            JSONObject jsonObject = JSONObject.parseObject(s);
            Integer code1 = jsonObject.getInteger("code");
            String message = jsonObject.getString("message");
            if (200 == code1) {
                System.err.println("--------------启动了世界杯游戏");
                System.err.println(s);
                return 200;
            } else {
                System.err.println(message);
                return 500;
            }
        }
    }


    /**
     * 根据sutuid获取游戏数据
     * @param sutuId
     * @return
     */
    @ResponseBody
    @PostMapping("/api/game/getTGameBySutuId")
    public TGame getTGameBySutuId(@RequestBody String sutuId){
        return gameService.getOne(new QueryWrapper<TGame>().eq("blue", sutuId).or()
                .eq("red", sutuId).eq("state", 0));
    }


    @Resource
    private StoreService storeService;

    @ResponseBody
    @PostMapping("/base/game/wechatPaymentGameCallback")
    public void wechatPaymentGameCallback(HttpServletRequest request, HttpServletResponse response) throws Exception {
        System.err.println("进入游戏回调");
        Map<String, String> map = payMoneyUtil.weixinpayCallback(request);
        System.err.println("回调参数"+map);
        if(null != map){
            String out_trade_no = map.get("out_trade_no");
            String transaction_id = map.get("transaction_id");
            String result = map.get("result");
            //String params = uid + "_" + gameId + "_" + spaceId + "_" + sutuId+"_"+code+"_"+configId + "_" + gameType;
            //Integer integer = startGame(uid, gameType, gameId, spaceId, sutuId);
            String attach = map.get("attach");

            List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("number", out_trade_no).eq("payType", 1));
            for (TGameRecord gameRecord : list) {
                gameRecord.setStatus(1);
                gameRecord.setOrderNo(transaction_id);


                CourseCounsum courseCounsum = new CourseCounsum();
                courseCounsum.setChangeType(3);
                courseCounsum.setInsertTime(new Date());
                courseCounsum.setReason("智慧球场;" + gameRecord.getMoney());
                courseCounsum.setAppUserId(gameRecord.getUserId());
                courseRecordClient.save(courseCounsum);

            }
            gameRecordService.updateBatchById(list);
            String[] s = attach.split("_");
            Integer integer = startGame(Integer.valueOf(s[0]), Integer.valueOf(s[6]), Integer.valueOf(s[1]), Integer.valueOf(s[2]), Integer.valueOf(s[3]));
            TGameRecord one = gameRecordService.getOne(new QueryWrapper<TGameRecord>().eq("number", out_trade_no).eq("payType", 1));
            System.err.println("游戏支付记录"+one);
//            if (one!=null){
//                Integer gameId = one.getGameId();
//                Site byId1 = siteService.getById(one.getSiteId());
//                Store byId = storeService.getById(byId1.getStoreId());
//                if (byId!=null){
//                    if (byId.getOperatorId()!=null && byId.getOperatorId()!=0){
//                        // 休眠两分钟后再调用分账接口 避免提示订单正在处理中
//                        Thread.sleep(120000);
//                        // 根据运营商id获取对应运营商分账比例 返回格式: 微信分账比例,支付宝分账比例
//                        OperatorUser operatorId = operatorUserService.getOne(
//                                new QueryWrapper<OperatorUser>().eq("operatorId",byId.getOperatorId())
//                        );
//                        if (operatorId.getWechatProportion() == null){
//                            operatorId.setWechatProportion("0");
//                        }
//                        if (operatorId.getAlipayProportion() == null){
//                            operatorId.setAlipayProportion("0");
//                        }
//                        String proportion=  operatorId.getWechatProportion()+","+operatorId.getAlipayProportion();
//                        String[] split = proportion.split(",");
//                        String s1 = split[0];
//                        if (!s1.equals("未设置")){
//                            BigDecimal bigDecimal = new BigDecimal(s1);
//                            // 分账比例
//                            BigDecimal bigDecimal1 = bigDecimal.divide(new BigDecimal(100)).setScale(2);
//                            // 微信商户号
//                            String s2 =siteService.getmerchantNumberByOperatorId(byId.getOperatorId());
//                            String nonce_str = UUIDUtil.getRandomCode(16);
//
//                            ResultUtil fenzhang = payMoneyUtil.fenzhang(transaction_id, one.getMoney().multiply(bigDecimal1), s2,nonce_str,"玩游戏分账");
//                            if (!fenzhang.getCode().equals(200)){
//                                System.err.println("分账失败 原因是:"+fenzhang.getMsg());
//                            }else{
//                                one.setFenzhangNo(fenzhang.getData().toString());
//                                one.setFenzhangOrderNo(nonce_str);
//                                one.setFenzhangAmount(one.getMoney().multiply(bigDecimal1));
//                                gameRecordService.updateById(one);
//                            }
//                        }
//                    }
//                }
//
//            }

            PrintWriter out = null;
            try {
                out = response.getWriter();
            } catch (IOException e) {
                e.printStackTrace();
            }
            out.print(result);
            out.flush();
            out.close();
        }
    }
    @ResponseBody
    @PostMapping("/base/game/wechatPaymentGameCallback1")
    public void wechatPaymentGameCallback1(HttpServletRequest request, HttpServletResponse response) throws Exception {
        System.err.println("进入游戏回调");
        try {
            System.err.println("微信回调");
            System.err.println("请求" + request);
            BufferedReader reader = request.getReader();
            String string1 = reader.toString();
            System.err.println("请求reader" + string1);
            StringBuilder requestBody = new StringBuilder();
            String line;
            while ((line = reader.readLine()) != null) {
                requestBody.append(line);
            }
            System.err.println("全部请求体" + requestBody);
            JSONObject jsonObject = JSONObject.parseObject(requestBody.toString());
            JSONObject resource = jsonObject.getJSONObject("resource");

            AesUtil aesUtil = new AesUtil(WxV3PayConfig.apiV3Key.getBytes(StandardCharsets.UTF_8));
            String decryptedData = aesUtil.decryptToString(resource.getString("associated_data").getBytes(StandardCharsets.UTF_8), resource.getString("nonce").getBytes(StandardCharsets.UTF_8),
                    resource.getString("ciphertext"));
            System.err.println("微信解密的字符串信息" + decryptedData);
            JSONObject jsonInfo = (JSONObject) JSONObject.parse(decryptedData);
            String out_trade_no = jsonInfo.getString("out_trade_no");
            String transaction_id = jsonInfo.getString("transaction_id");
            String trade_state = jsonInfo.getString("trade_state");
            String attach = jsonInfo.getString("attach");
            if (trade_state.equals("SUCCESS")) {
                List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("number", out_trade_no).eq("payType", 1));
                for (TGameRecord gameRecord : list) {
                    gameRecord.setStatus(1);
                    gameRecord.setOrderNo(transaction_id);
                    CourseCounsum courseCounsum = new CourseCounsum();
                    courseCounsum.setChangeType(3);
                    courseCounsum.setInsertTime(new Date());
                    courseCounsum.setReason("智慧球场;" + gameRecord.getMoney());
                    courseCounsum.setAppUserId(gameRecord.getUserId());
                    courseRecordClient.save(courseCounsum);

                }
                gameRecordService.updateBatchById(list);
                String[] s = attach.split("_");
                Integer integer = startGame(Integer.valueOf(s[0]), Integer.valueOf(s[6]), Integer.valueOf(s[1]), Integer.valueOf(s[2]), Integer.valueOf(s[3]));
                TGameRecord one = gameRecordService.getOne(new QueryWrapper<TGameRecord>().eq("number", out_trade_no).eq("payType", 1));
                System.err.println("游戏支付记录" + one);

                PrintWriter out = null;
                try {
                    out = response.getWriter();
                } catch (IOException e) {
                    e.printStackTrace();
                }
                out.print("SUCCESS");
                out.flush();
                out.close();
            }
        }catch (Exception e){
            e.printStackTrace();
        }
    }

    @ResponseBody
    @PostMapping("/base/game/aliPaymentGameCallback")
    public void aliPaymentGameCallback(HttpServletRequest request, HttpServletResponse response){
        Map<String, String> map = payMoneyUtil.alipayCallback(request);
        if(null != map){
            String out_trade_no = map.get("out_trade_no");
            String transaction_id = map.get("trade_no");
            //String params = uid + "_" + gameId + "_" + spaceId + "_" + sutuId+"_"+code+"_"+ configId + "_" + gameType;
            //Integer integer = startGame(uid, gameType, gameId, spaceId, sutuId);
            String attach = map.get("passback_params");

            List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("number", out_trade_no).eq("payType", 2));
            for (TGameRecord gameRecord : list) {
                gameRecord.setStatus(1);
                gameRecord.setOrderNo(transaction_id);


                CourseCounsum courseCounsum = new CourseCounsum();
                courseCounsum.setChangeType(3);
                courseCounsum.setInsertTime(new Date());
                courseCounsum.setReason("智慧球场;" + gameRecord.getMoney());
                courseCounsum.setAppUserId(gameRecord.getUserId());
                courseRecordClient.save(courseCounsum);

            }
            gameRecordService.updateBatchById(list);
            String[] s = attach.split("_");
            Integer integer = startGame(Integer.valueOf(s[0]), Integer.valueOf(s[6]), Integer.valueOf(s[1]), Integer.valueOf(s[2]), Integer.valueOf(s[3]));

            PrintWriter out = null;
            try {
                out = response.getWriter();
            } catch (IOException e) {
                e.printStackTrace();
            }
            out.print("success");
            out.flush();
            out.close();
        }
    }



    @ResponseBody
    @PostMapping("/base/game/getTGameRecord")
    public List<TGameRecord> getTGameRecord(@RequestBody GetTGameRecord getTGameRecord){
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        return gameRecordService.list(new QueryWrapper<TGameRecord>().eq("userId", getTGameRecord.getAppUserId()).eq("status", 1).in("payType", Arrays.asList(1, 2))
                .last(" and DATE_FORMAT(time, '%Y-%m-%d %H:%i:%s') between '" + sdf.format(getTGameRecord.getStartTiem()) +"' and '" + sdf.format(getTGameRecord.getEndTime()) + "'"));
    }
}