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; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.dsh.other.entity.*; 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.model.User; import com.dsh.other.service.*; import com.dsh.other.util.*; import com.dsh.other.util.httpClinet.HttpResult; 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.*; import javax.annotation.Resource; import javax.servlet.http.HttpServletRequest; import javax.servlet.http.HttpServletResponse; import java.io.IOException; import java.io.PrintWriter; import java.math.BigDecimal; import java.text.SimpleDateFormat; import java.util.*; import java.util.stream.Collectors; @RestController @RequestMapping("") public class GameController { @Autowired private TGameRecordService gameRecordService; @Autowired private TGameService gameService; @Autowired private TGameConfigService gameConfigService; @Autowired private TokenUtil tokenUtil; @Resource private AppUserClient appUserClient; @Autowired private PayMoneyUtil payMoneyUtil; @Resource private CourseRecordClient courseRecordClient; @Autowired private IUserService userService; @Autowired private ISiteBookingService siteBookingService; private String smid = "2088330203191220";//平台支付宝商户号 @Autowired private ISiteService siteService; @ResponseBody @PostMapping("/api/game/getIntro") @ApiOperation(value = "获取步骤说明", tags = {"用户—游戏"}) @ApiImplicitParams({ @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."), }) public ResultUtil getIntro() { try { return ResultUtil.success(gameService.getIntro()); } catch (Exception e) { e.printStackTrace(); return ResultUtil.runErr(); } } @Autowired private ISiteLockService lockService; @ResponseBody @PostMapping("/api/game/queryGameList") @ApiOperation(value = "获取当前场地的游戏列表配置", tags = {"用户—游戏"}) @ApiImplicitParams({ @ApiImplicitParam(value = "siteId", name = "siteId", dataType = "int", required = true), @ApiImplicitParam(value = "storeId", name = "storeId", dataType = "int", required = true), @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."), }) public ResultUtil> queryGameList(Integer siteId, Integer storeId) { try { Integer uid = tokenUtil.getUserIdFormRedis(); AppUser appUser = appUserClient.queryAppUser(uid); List tGameConfigs = new ArrayList<>(); if (appUser.getAddUserId() == null) { List lock = lockService.list(new QueryWrapper().eq("siteId", siteId)); Date now = new Date(); for (SiteLock siteLock : lock) { if (now.after(siteLock.getStartTime()) && now.before(siteLock.getEndTime())) { return ResultUtil.error("当前场地已被锁定"); } } } List list = gameService.list(new LambdaQueryWrapper().eq(TGame::getSiteId, siteId).eq(TGame::getStoreId, storeId).eq(TGame::getState, 0)); if (list.size() > 0) { Integer id = list.get(0).getId(); tGameConfigs = gameConfigService.listJs(id); } tGameConfigs.forEach(g -> { if(g.getGameId() == 0){ g.setGameType(2); }else{ g.setGameType(1); } }); List filteredList = tGameConfigs.stream() .filter(gameConfig -> !gameConfig.getImg().isEmpty()) .collect(Collectors.toList()); return ResultUtil.success(filteredList); } catch (Exception e) { e.printStackTrace(); return ResultUtil.runErr(); } } @ResponseBody @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 gameStartupCheck(Integer gameId){ try { Integer uid = tokenUtil.getUserIdFormRedis(); if (null == uid) { return ResultUtil.tokenErr(); } AppUser appUser1 = appUserClient.queryAppUser(uid); //判断当前用户是否是员工 List one = userService.list(new QueryWrapper().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() .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(); } } @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), @ApiImplicitParam(value = "spaceId", name = "spaceId", dataType = "int", required = true), @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 gameType, Integer gameId, Integer configId, Integer type, Integer sutuId, Integer spaceId) { try { Integer uid = tokenUtil.getUserIdFormRedis(); if (null == uid) { return ResultUtil.tokenErr(); } Site byId = siteService.getById(spaceId); Store byId1 = storeService.getById(byId.getStoreId()); // 是否分账 0否1是 int isFenZhang= 1; String merchantNumber = ""; if (byId1.getOperatorId()==null || byId1.getOperatorId()==0){ // 平台 isFenZhang = 0; } //判断当前用户是否是员工 AppUser appUser1 = appUserClient.queryAppUser(uid); List one = userService.list(new QueryWrapper().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); TGameConfig config = gameConfigService.getById(configId); TGameRecord tGameRecord = new TGameRecord(); tGameRecord.setGameId(gameId); tGameRecord.setPayType(type); tGameRecord.setUserId(uid); tGameRecord.setNumber(code); tGameRecord.setTime(new Date()); tGameRecord.setSiteId(spaceId); gameRecordService.save(tGameRecord); System.err.println("启动游戏支付"); if (type == 1) { 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 (weixinpay.getCode() == 200) { new Thread(new Runnable() { @Override public void run() { try { int num = 1; int wait = 0; while (num <= 15) { int min = 5000; wait += (min * num); Thread.sleep(wait); List list = gameRecordService .list(new QueryWrapper().eq("number", code).eq("payType", 1)); TGameRecord one = list.get(0); if (one.getStatus() == 1) { break; } ResultUtil> resultUtil = payMoneyUtil.queryWXOrder(code, ""); if (resultUtil.getCode() == 200 && one.getStatus() == 0) { /** * SUCCESS—支付成功, * REFUND—转入退款, * NOTPAY—未支付, * CLOSED—已关闭, * REVOKED—已撤销(刷卡支付), * USERPAYING--用户支付中, * PAYERROR--支付失败(其他原因,如银行返回失败) */ Map data1 = resultUtil.getData(); String s = data1.get("trade_state"); String transaction_id = data1.get("transaction_id"); if ("REFUND".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) { break; } if ("SUCCESS".equals(s)) { for (TGameRecord gameRecord : list) { gameRecord.setStatus(1); gameRecord.setOrderNo(transaction_id); } gameRecordService.updateBatchById(list); Integer integer = startGame(uid, gameType, gameId, spaceId, sutuId); break; } if ("USERPAYING".equals(s) || "NOTPAY".equals(s)) { num++; } } } } catch (Exception e) { e.printStackTrace(); } } }).start(); } return weixinpay; } else if (type == 2) { 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().eq("blue", sutuId).or().eq("red", sutuId)); Integer operationId = game.getOperationId(); if (operationId==0){ // 是平台的 smid1 = smid; }else{ String smidByOperatorId = siteService.getSMIDByOperatorId(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 list = gameRecordService.list(new QueryWrapper().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()); gameRecordService.updateById(tGameRecord); AppUser appUser = appUserClient.queryAppUser(uid); Integer playPaiCoins = appUser.getPlayPaiCoins(); BigDecimal playCoin = config.getPlayCoin(); int i = playCoin.intValue(); if (playPaiCoins < i) { return ResultUtil.error("玩湃币不足"); } int i1 = playPaiCoins - i; appUser.setPlayPaiCoins(i1); appUserClient.updateAppUser(appUser); startGame(uid, gameType, gameId, spaceId, sutuId); return ResultUtil.success(); } else if (type == 5) { AppUser appUser = appUserClient.queryAppUser(uid); Integer playPaiCoins = appUser.getIntegral(); BigDecimal playCoin = config.getIntegral(); int i = playCoin.intValue(); if (playPaiCoins < i) { return ResultUtil.error("积分不足"); } int i1 = playPaiCoins - i; appUser.setIntegral(i1); appUser.setPoints(playCoin.intValue()); appUserClient.updateAppUser(appUser); startGame(uid, gameType, gameId, spaceId, sutuId); return ResultUtil.success(); } else { return ResultUtil.error("支付方式错误"); } } catch (Exception e) { e.printStackTrace(); return ResultUtil.runErr(); } } public Integer startGame(Integer uid, Integer gameType, Integer gameId, Integer spaceId, Integer sutuId) { TGame game = gameService.getOne(new QueryWrapper().eq("blue", sutuId).or().eq("red", sutuId)); if(1 == gameType){ HashMap 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://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 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().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 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 list = gameRecordService.list(new QueryWrapper().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().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().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/aliPaymentGameCallback") public void aliPaymentGameCallback(HttpServletRequest request, HttpServletResponse response){ Map 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 list = gameRecordService.list(new QueryWrapper().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 getTGameRecord(@RequestBody GetTGameRecord getTGameRecord){ SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); return gameRecordService.list(new QueryWrapper().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()) + "'")); } }