Parcourir la source

fix : SDK回传逻辑, 增加日志打印

bilingfeng il y a 1 an
Parent
commit
0d6b674c98

+ 7 - 0
game-module/game-module-sdk/src/main/java/com/zanxiang/game/module/sdk/service/impl/CallBackServiceImpl.java

@@ -14,6 +14,7 @@ import com.zanxiang.game.module.base.pojo.enums.GameCategoryEnum;
 import com.zanxiang.game.module.mybatis.entity.*;
 import com.zanxiang.game.module.mybatis.entity.*;
 import com.zanxiang.game.module.sdk.pojo.dto.PlatformOrderDTO;
 import com.zanxiang.game.module.sdk.pojo.dto.PlatformOrderDTO;
 import com.zanxiang.game.module.sdk.service.*;
 import com.zanxiang.game.module.sdk.service.*;
+import com.zanxiang.module.util.JsonUtil;
 import lombok.extern.slf4j.Slf4j;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.apache.dubbo.config.annotation.DubboReference;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Autowired;
@@ -75,10 +76,12 @@ public class CallBackServiceImpl implements ICallBackService {
         //查询小游戏信息或者H5游戏相关公众号信息
         //查询小游戏信息或者H5游戏相关公众号信息
         GameApplet gameApplet = gameAppletService.getOne(new LambdaQueryWrapper<GameApplet>()
         GameApplet gameApplet = gameAppletService.getOne(new LambdaQueryWrapper<GameApplet>()
                 .eq(GameApplet::getGameId, user.getGameId()));
                 .eq(GameApplet::getGameId, user.getGameId()));
+        log.error("用户注册回传, userId : {}", user.getId());
         try {
         try {
             //腾讯回传
             //腾讯回传
             if (Objects.equals(agent.getAccountType(), Agent.ACCOUNT_TYPE_TENCENT)) {
             if (Objects.equals(agent.getAccountType(), Agent.ACCOUNT_TYPE_TENCENT)) {
                 TencentUserDTO tencentUserDTO = this.transform(user, agent, gameApplet);
                 TencentUserDTO tencentUserDTO = this.transform(user, agent, gameApplet);
+                log.error("用户注册 --> 腾讯回传提交, tencentUserDTO : {}", JsonUtil.toString(tencentUserDTO));
                 gameBackTencentRpc.backUser(tencentUserDTO);
                 gameBackTencentRpc.backUser(tencentUserDTO);
             }
             }
             //头条回传
             //头条回传
@@ -87,6 +90,7 @@ public class CallBackServiceImpl implements ICallBackService {
                 //判断是微信小游戏
                 //判断是微信小游戏
                 if (Objects.equals(game.getCategory(), GameCategoryEnum.CATEGORY_WX_APPLET.getId())) {
                 if (Objects.equals(game.getCategory(), GameCategoryEnum.CATEGORY_WX_APPLET.getId())) {
                     UserActiveReportRpcDTO activeReportRpcDTO = this.transform(user, agent, gameApplet, urlParamMap);
                     UserActiveReportRpcDTO activeReportRpcDTO = this.transform(user, agent, gameApplet, urlParamMap);
+                    log.error("用户注册 --> 头条回传提交, activeReportRpcDTO : {}", JsonUtil.toString(activeReportRpcDTO));
                     wechatMiniGameDataReportRpc.userActiveReport(activeReportRpcDTO);
                     wechatMiniGameDataReportRpc.userActiveReport(activeReportRpcDTO);
                 }
                 }
             }
             }
@@ -112,10 +116,12 @@ public class CallBackServiceImpl implements ICallBackService {
         //查询小游戏信息或者H5游戏相关公众号信息
         //查询小游戏信息或者H5游戏相关公众号信息
         GameApplet gameApplet = gameAppletService.getOne(new LambdaQueryWrapper<GameApplet>()
         GameApplet gameApplet = gameAppletService.getOne(new LambdaQueryWrapper<GameApplet>()
                 .eq(GameApplet::getGameId, user.getGameId()));
                 .eq(GameApplet::getGameId, user.getGameId()));
+        log.error("用户订单回传, orderId : {}", platformOrderDTO.getOrderId());
         try {
         try {
             //腾讯回传
             //腾讯回传
             if (Objects.equals(agent.getAccountType(), Agent.ACCOUNT_TYPE_TENCENT)) {
             if (Objects.equals(agent.getAccountType(), Agent.ACCOUNT_TYPE_TENCENT)) {
                 TencentOrderDTO tencentOrderDTO = this.transform(platformOrderDTO, user, agent, gameApplet);
                 TencentOrderDTO tencentOrderDTO = this.transform(platformOrderDTO, user, agent, gameApplet);
+                log.error("用户下单 --> 腾讯回传提交, tencentOrderDTO : {}", JsonUtil.toString(tencentOrderDTO));
                 gameBackTencentRpc.backOrder(tencentOrderDTO);
                 gameBackTencentRpc.backOrder(tencentOrderDTO);
             }
             }
             //头条回传
             //头条回传
@@ -124,6 +130,7 @@ public class CallBackServiceImpl implements ICallBackService {
                 Game game = gameService.getById(platformOrderDTO.getGameId());
                 Game game = gameService.getById(platformOrderDTO.getGameId());
                 if (Objects.equals(game.getCategory(), GameCategoryEnum.CATEGORY_WX_APPLET.getId())) {
                 if (Objects.equals(game.getCategory(), GameCategoryEnum.CATEGORY_WX_APPLET.getId())) {
                     OrderReportRpcDTO orderReportRpcDTO = this.transform(platformOrderDTO, user.getOpenId(), agent, gameApplet);
                     OrderReportRpcDTO orderReportRpcDTO = this.transform(platformOrderDTO, user.getOpenId(), agent, gameApplet);
+                    log.error("用户下单 --> 头条回传提交, orderReportRpcDTO : {}", JsonUtil.toString(orderReportRpcDTO));
                     wechatMiniGameDataReportRpc.orderReport(orderReportRpcDTO);
                     wechatMiniGameDataReportRpc.orderReport(orderReportRpcDTO);
                 }
                 }
             }
             }