From eb6b6dbb35a9f029e0b7d269773685c19fd40976 Mon Sep 17 00:00:00 2001
From: 无关风月 <443237572@qq.com>
Date: 星期四, 11 七月 2024 10:47:51 +0800
Subject: [PATCH] 玩湃微信商户认证代码

---
 cloud-server-other/src/main/java/com/dsh/other/controller/GameController.java |  291 +++++++++++++++++++++++++++++++++++++++++++--------------
 1 files changed, 218 insertions(+), 73 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 b5e85a8..b591aed 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
@@ -2,20 +2,21 @@
 
 import cn.hutool.http.HttpRequest;
 import com.alibaba.fastjson.JSONObject;
+import com.alipay.api.AlipayClient;
+import com.alipay.api.DefaultAlipayClient;
+import com.alipay.api.request.AlipayTradeOrderSettleRequest;
+import com.alipay.api.response.AlipayTradeOrderSettleResponse;
 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.SiteLock;
-import com.dsh.other.entity.TGame;
-import com.dsh.other.entity.TGameConfig;
-import com.dsh.other.entity.TGameRecord;
+import com.dsh.other.entity.*;
+import com.dsh.other.feignclient.CourseRecordClient;
+import com.dsh.other.feignclient.StoreClient;
 import com.dsh.other.feignclient.account.AppUserClient;
 import com.dsh.other.feignclient.account.model.AppUser;
 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 io.swagger.annotations.ApiImplicitParam;
@@ -27,10 +28,13 @@
 import org.springframework.web.bind.annotation.ResponseBody;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.annotation.Resource;
 import java.math.BigDecimal;
+import java.math.RoundingMode;
 import java.text.SimpleDateFormat;
 import java.util.*;
 import java.util.stream.Collectors;
+
 @RestController
 @RequestMapping("/api/game")
 public class GameController {
@@ -48,32 +52,40 @@
     @Autowired
     private TokenUtil tokenUtil;
 
-    @Autowired
+    @Resource
     private AppUserClient appUserClient;
 
     @Autowired
     private PayMoneyUtil payMoneyUtil;
 
+    @Resource
+    private CourseRecordClient courseRecordClient;
+
+    @Autowired
+    private IUserService userService;
+
+    @Autowired
+    private ISiteBookingService siteBookingService;
 
 
     @ResponseBody
-        @PostMapping("/getIntro")
+    @PostMapping("/getIntro")
     @ApiOperation(value = "获取步骤说明", tags = {"用户—游戏"})
     @ApiImplicitParams({
             @ApiImplicitParam(name = "Authorization", value = "Bearer +token", required = true, dataType = "String", paramType = "header", defaultValue = "Bearer eyJhbGciOiJIUzUxMiJ9....."),
     })
-    public ResultUtil<String> getIntro(){
+    public ResultUtil<String> getIntro() {
         try {
 
-            return ResultUtil.success( gameService.getIntro());
-        }catch (Exception e){
+            return ResultUtil.success(gameService.getIntro());
+        } catch (Exception e) {
             e.printStackTrace();
             return ResultUtil.runErr();
         }
     }
 
-@Autowired
-private ISiteLockService lockService;
+    @Autowired
+    private ISiteLockService lockService;
 
 
     @ResponseBody
@@ -84,38 +96,85 @@
             @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<List<TGameConfig>> queryGameList(Integer siteId, Integer storeId){
+    public ResultUtil<List<TGameConfig>> queryGameList(Integer siteId, Integer storeId) {
         try {
+
+            Integer uid = tokenUtil.getUserIdFormRedis();
+            AppUser appUser = appUserClient.queryAppUser(uid);
             List<TGameConfig> tGameConfigs = new ArrayList<>();
 
-            List<SiteLock> lock = lockService.list(new QueryWrapper<SiteLock>().eq("siteId", siteId));
+            if (appUser.getAddUserId() == null) {
 
-            Date now = new Date();
-            for (SiteLock siteLock : lock) {
-                if (now.after(siteLock.getStartTime())&&now.before(siteLock.getEndTime())){
-                    return ResultUtil.error("当前场地已被锁定");
+
+                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){
+            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);
-
             }
             List<TGameConfig> 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("/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);
+            User one = userService.getOne(new QueryWrapper<User>().eq("phone", appUser1.getPhone()).eq("status", 1));
+            if (null != one) {
+                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 smid = "2088330203191220";//平台支付宝商户号
+    @Autowired
+    private ISiteService siteService;
+
 
 
     @ResponseBody
@@ -129,11 +188,18 @@
             @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 gameId, Integer configId, Integer type, Integer sutuId, Integer spaceId) {
         try {
             Integer uid = tokenUtil.getUserIdFormRedis();
-            if(null == uid){
+            if (null == uid) {
                 return ResultUtil.tokenErr();
+            }
+            //判断当前用户是否是员工
+            AppUser appUser1 = appUserClient.queryAppUser(uid);
+            User one = userService.getOne(new QueryWrapper<User>().eq("phone", appUser1.getPhone()).eq("status", 1));
+            if (null != one) {
+                Integer integer = startGame(uid, gameId, spaceId, sutuId);
+                return ResultUtil.success();
             }
             SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMddHHmmssSSS");
             String code = sdf.format(new Date()) + UUIDUtil.getNumberRandom(5);
@@ -145,27 +211,28 @@
             tGameRecord.setNumber(code);
             tGameRecord.setTime(new Date());
             gameRecordService.save(tGameRecord);
-            if(type==1){
+
+            if (type == 1) {
                 ResultUtil weixinpay = payMoneyUtil.weixinpay("游戏支付", "", code, config.getCash().toString(), "/base/course/weChatPaymentCourseCallback", "APP", "");
-                if(weixinpay.getCode() == 200){
+                if (weixinpay.getCode() == 200) {
                     new Thread(new Runnable() {
                         @Override
                         public void run() {
                             try {
                                 int num = 1;
                                 int wait = 0;
-                                while (num <= 10){
+                                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){
+                                    if (one.getStatus() == 1) {
                                         break;
                                     }
                                     ResultUtil<Map<String, String>> resultUtil = payMoneyUtil.queryWXOrder(code, "");
-                                    if(resultUtil.getCode() == 200 && one.getStatus() == 0){
+                                    if (resultUtil.getCode() == 200 && one.getStatus() == 0) {
                                         /**
                                          * SUCCESS—支付成功,
                                          * REFUND—转入退款,
@@ -178,10 +245,10 @@
                                         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) || "NOTPAY".equals(s) || "CLOSED".equals(s) || "REVOKED".equals(s) || "PAYERROR".equals(s) || num == 10) {
                                             break;
                                         }
-                                        if("SUCCESS".equals(s)){
+                                        if ("SUCCESS".equals(s)) {
                                             for (TGameRecord coursePackagePayment : list) {
                                                 coursePackagePayment.setStatus(1);
                                                 coursePackagePayment.setMoney(config.getCash());
@@ -191,135 +258,213 @@
                                             Integer integer = startGame(uid, gameId, spaceId, sutuId);
                                             break;
                                         }
-                                        if("USERPAYING".equals(s)){
+                                        if ("USERPAYING".equals(s)) {
                                             num++;
                                         }
                                     }
                                 }
-                            }catch (Exception e){
+                            } catch (Exception e) {
                                 e.printStackTrace();
                             }
                         }
                     }).start();
                 }
                 return weixinpay;
-            }else if(type==2){
-//                Integer gameId, Integer configId,Integer type,Integer sutuId,Integer spaceId;
+            } else if (type == 2) {
+                String smid1="";
+                String params = uid + "_" + gameId + "_" + spaceId + "_" + sutuId+"_"+code+"_"+configId;
+                // 判断这个课包属于哪个门店 属于哪个运营商 根据运营商 id 获取对应的商户号
+                TGame game = gameService.getById(gameId);
 
-                String params = uid+"_"+gameId+"_"+spaceId+"_"+sutuId;
+                Integer operationId = game.getOperationId();
+                if (operationId==0){
+                    // 是平台的
+                    smid1 = smid;
+                }else{
+                    String smidByOperatorId = siteService.getSMIDByOperatorId(operationId);
+                    smid1 = smidByOperatorId;
+                }
 
-                ResultUtil alipay = payMoneyUtil.alipay("游戏支付", "游戏支付", params, code, config.getCash().toString(), "/base/site/gameCallback");
-                if(alipay.getCode() == 200){
+                ResultUtil alipay = payMoneyUtil.alipay(smid1,"游戏支付", "游戏支付", 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){
+                                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", 3));
+                                    List<TGameRecord> list = gameRecordService.list(new QueryWrapper<TGameRecord>().eq("number", code).eq("payType", 2));
                                     TGameRecord one = list.get(0);
-                                    if(one.getStatus() == 1){
+                                    if (one.getStatus() == 1) {
                                         break;
                                     }
                                     AlipayTradeQueryResponse resultUtil = payMoneyUtil.queryALIOrder(code);
-                                    if(resultUtil.getCode().equals("10000") && one.getStatus() == 0){
+                                    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){
+                                        if ("TRADE_CLOSED".equals(s) || "TRADE_FINISHED".equals(s) || num == 10) {
                                             break;
                                         }
-                                        if("TRADE_SUCCESS".equals(s)){
+                                        if ("TRADE_SUCCESS".equals(s)) {
                                             for (TGameRecord coursePackagePayment : list) {
                                                 coursePackagePayment.setStatus(1);
                                                 coursePackagePayment.setMoney(config.getCash());
                                                 coursePackagePayment.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, gameId, spaceId, sutuId);
+                                            // 判断这个课包属于哪个门店 属于哪个运营商 根据运营商 id 获取对应的商户号
+                                            TGame game = gameService.getById(gameId);
+                                            String smid2="";
+                                            Integer operationId = game.getOperationId();
+                                            if (operationId == null || operationId==0  ){
+                                                // 是平台的不冻结资金 不做分账处理
+                                                smid2 = smid;
+                                                payMoneyUtil.confirm1(smid2,code,tradeNo,config.getCash().toString());
+                                            }else{
+                                                String smidByOperatorId = siteService.getSMIDByOperatorId(operationId);
+                                                smid2 = smidByOperatorId;
+                                                payMoneyUtil.confirm(smid2,code,tradeNo,config.getCash().toString());
+                                                extracted(operationId, config.getCash(), tradeNo);
+                                            }
+
                                             break;
                                         }
-                                        if("WAIT_BUYER_PAY".equals(s)){
+                                        if ("WAIT_BUYER_PAY".equals(s)) {
                                             num++;
                                         }
                                     }
                                 }
-                            }catch (Exception e){
+                            } catch (Exception e) {
                                 e.printStackTrace();
                             }
                         }
                     }).start();
                 }
                 return alipay;
-            }else if(type==3){
+            } 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){
+                if (playPaiCoins < i) {
                     return ResultUtil.error("玩湃币不足");
                 }
                 int i1 = playPaiCoins - i;
                 appUser.setPlayPaiCoins(i1);
                 appUserClient.updateAppUser(appUser);
-                startGame(uid,gameId,spaceId,sutuId);
+                startGame(uid, gameId, spaceId, sutuId);
                 return ResultUtil.success();
 
-            }else if(type==5){
+            } else if (type == 5) {
                 AppUser appUser = appUserClient.queryAppUser(uid);
                 Integer playPaiCoins = appUser.getIntegral();
                 BigDecimal playCoin = config.getIntegral();
                 int i = playCoin.intValue();
-                if(playPaiCoins<i){
+                if (playPaiCoins < i) {
                     return ResultUtil.error("积分不足");
                 }
                 int i1 = playPaiCoins - i;
                 appUser.setIntegral(i1);
                 appUser.setPoints(playCoin.intValue());
                 appUserClient.updateAppUser(appUser);
-                startGame(uid,gameId,spaceId,sutuId);
+                startGame(uid, gameId, spaceId, sutuId);
                 return ResultUtil.success();
-            }else {
+            } else {
                 return ResultUtil.error("支付方式错误");
             }
-        }catch (Exception e){
+        } catch (Exception e) {
             e.printStackTrace();
             return ResultUtil.runErr();
         }
+    }
+    @Autowired
+    private IOperatorUserService operatorUserService;
+    @Autowired
+    private StoreClient storeClient;
+    private void extracted(Integer operatorId, BigDecimal coursePackageOrder1, String tradeNo) throws Exception {
+        // 分账
+        AlipayClient alipayClient = new DefaultAlipayClient("https://openapi.alipay.com/gateway.do",
+                "2021004105665036",
+                "MIIEvwIBADANBgkqhkiG9w0BAQEFAASCBKkwggSlAgEAAoIBAQCi5i9nW/hGLJ3A06cZxTQdviFC7THpdSihoTYGLr9q006hu0V26ecBMY/o4w5bvIX0Ok/yofmZsVcCJpAPvbXL/uqVrIjnRRxXiaeBFThlxoBUTdunvbUSDYfzlEhJr5NvUKI6H6lz2niXlQGx4qy8Hau4ccWit9kM8jwUvsBVQoFgJA+xrjMvooA7YLopQtpOD+UJr5thApTSf1xrnr1W12yolTLEH15JmNV372cqXrYUuqnY0QsaPtxeqJUGAOcGdVLllQ7easEznP8DFBvDdHATcmp2SHNQDUEWN6MCVPbMgY06NQVqAXxqjTAYSVh+6TRu6bofPmpYC3TZB003AgMBAAECggEBAJAcR2+PA3NBYUYHeFrqBRMS8uX8ZR19kjZ7IgoSLTFaQsP9opRylPSPXhrPVBKAE5leRQAHn4MCSlESwHvMfxo7KFjFTFAc6dffZZpipYQUOc9bGampwJh58/3e/pyBgVMG6J23CPf/HJQtNFSkjd/V9+ayb/9l2dUEL3bC0fAZ/dbx8HsxdLw8wn3fLlWLj68hOMqa2deCZe3JdSVsPbeWqkh56FFsMLug0Nd+Ar4TgRl9/jnhXF0JWiD0LmPUYLhboY7EfUBzN4w1iYbDi1P+3zvoOYsiVKAXox9GMhQ2VzOO2UcSTuizSza2e98mGpabl/GpKmCz+RDFjtkX6eECgYEA2MyCij65eO3aGIm3FUe93DULRBYTfX8qJQSJq2WOWA3mmQlEW6L3O2B5/lG2h+8WmN6iLEs9eHpgycGYp7vAqgrANEn16ACVcuyx0scFtrZfZ+kmHMzFfiUWxJjVYk/6YngsGVBLdw6ueM42C8TTP67X9tU5TdVGoGWuqEj4W98CgYEAwFqwprXOch5Pqk/RPbb49r0Ou03K/UbciWnWWKzUhFFNS8MdlQPoDvQZbMwHLeWsa2VhaKITK3x5biLQb3U+0GLOn6lTvEyrEUH+ucREyLgVYTRAvwBPtnvlrzpyxPk2HnslQjju8WrvvLLBMKWUjlTrTOzhaHT21gz3pHMiOakCgYEAhLmfaXdBITGshb054sNLDtdCkGpbgEcrzAHdLps769iGxkYQHXHFngpQZUwtTUcoNGqIKknd1jZFrv7gsD+XkgKG7PwimehRlkwmCX5ilxtLiVgJRzRt6+5U5AMVD90a0tHzXYP0z2yjj73fBJF5KtGl0a10KZxaYrQdm1UhB00CgYBZZgzx/k9rtHC8LAqIj1CYhHejT92G53c6Gkl3vyOqN4sgKhfGmSEySfrDGPRBPZxr8ZtbIPCd5mUdberH0osWGMYFaJI1UsCy7aQwvGpniz7MhZeN7dweaOjwDs8mgtjHQ96mL4XGCDhR0BZ/wIURvZ/6iaGdhbbu9unlsWj3uQKBgQCmZYdsbbZkd3ev6f8rwyvMz+DrCQyYpY44cegBYuJgrZiQnL2fJioeN7ixX0UM48SfwsZEIrzshP/LGAwnc2MdjxKUl4jLN8SEe0NAjXOnz9Zaw740+aOmLpXcLWdP4uM2gIhWsvW1tEkQZCXmm7c9s/RsU8Pmzv+YL3+fSijOzA==",
+                "json", "GBK",
+                "MIIBIjANBgkqhkiG9w0BAQEFAAOCAQ8AMIIBCgKCAQEAmu8n/4yTHWbn7VOrNc9OsLtDL1bEQ8gC1dHkj8Wy5z0mkaOsjJRIG/28ze12M0V8jdCKuuDr5Z1OPKiqf+XO3ypguEh+mYUVMBM/cZodDFQfTY1TKLWjvQCuaqlA+QUTCK6f7T7stsgyQ1o9Jj0rXZDz6PM4QHSTzjrLIBaeqM5WIBvH+fy/X+QG5Utd+/UT0kc0JyvuKhZ65yVUd/C9VcwJJAPliRsAQNrqYterwAJ9zvw9tF11wj9W0XgJ8Ccu4x3gR1vrlLRJJo/OA97RmxPQ+5hSacWQZCUd1dwiBq+YCrKVHGTj14izRHXrLc0yBlRXo7tBOIqcy3IsvKVthQIDAQAB",
+                "RSA2");
+        AlipayTradeOrderSettleRequest request = new AlipayTradeOrderSettleRequest();
+        String randomCode = UUIDUtil.getRandomCode(16);
 
-
-
+        String proportionByOperatorId = operatorUserService.getOne(new QueryWrapper<OperatorUser>()
+                .eq("operatorId",operatorId)).getAlipayProportion();
+        // 支付宝分账比例
+        String s1 = proportionByOperatorId.split(",")[1];
+        double i = Double.parseDouble(s1);
+        double v = i * 0.01;
+        BigDecimal bigDecimal1 = new BigDecimal(String.valueOf(v));
+        // 分账金额
+        BigDecimal bigDecimal2 = coursePackageOrder1.multiply(bigDecimal1).setScale(2, RoundingMode.DOWN);
+        request.setBizContent("{" +
+                "  \"out_request_no\":\"" + randomCode + "\"," +
+                "  \"trade_no\":\"" + tradeNo + "\"," +
+                "  \"royalty_parameters\":[" +
+                "    {" +
+                "      \"royalty_type\":\"transfer\"," +
+                "      \"trans_out\":\"" + storeClient.getSMIDByOperatorId(operatorId)+ "\"," +
+                "      \"trans_out_type\":\"userId\"," +
+                "      \"trans_in_type\":\"userId\"," +
+                "      \"trans_in\":\"" + smid + "\"," +
+                "      \"amount\":" + bigDecimal2 + "," +
+                "      \"desc\":\"平台服务费\"," +
+                "      \"royalty_scene\":\"平台服务费\"," +
+                "    }" +
+                "  ]," +
+                "  \"extend_params\":{" +
+                "    \"royalty_finish\":\"true\"" +
+                "  }," +
+                "  \"royalty_mode\":\"async\"" +
+                "}");
+        AlipayTradeOrderSettleResponse response = alipayClient.execute(request);
+        if (response.isSuccess()) {
+            System.out.println("调用成功");
+        } else {
+            System.out.println("调用失败");
+        }
     }
 
-
-    private static Integer startGame(Integer uid,Integer gameId,Integer spaceId,Integer sutuId){
+    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+"");
+        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))){
+        if (String.valueOf(code) != null && "200".equals(String.valueOf(code))) {
+            System.err.println("--------------启动了一次游戏");
             return 200;
-        }else {
+        } else {
             return 500;
         }
     }

--
Gitblit v1.7.1