瀏覽代碼

fix : 订单优化回传修改

bilingfeng 8 月之前
父節點
當前提交
4e30f8b376

+ 1 - 1
game-module/game-module-sdk/src/main/java/com/zanxiang/game/module/sdk/SDKApplication.java

@@ -23,7 +23,7 @@ public class SDKApplication {
 
     public static void main(String[] args) {
         SpringApplication.run(SDKApplication.class, args);
-        System.out.println("赞象SDK服务启动成功 <创角回传, 新增角色等级参数> ( ´・・)ノ(._.`) \n" +
+        System.out.println("赞象SDK服务启动成功 <订单回传优化> ( ´・・)ノ(._.`) \n" +
                 " ___________ _   __\n" +
                 "/  ___|  _  \\ | / /\n" +
                 "\\ `--.| | | | |/ / \n" +

+ 2 - 2
game-module/game-module-sdk/src/main/java/com/zanxiang/game/module/sdk/listener/OrderPaySuccessListener.java

@@ -61,6 +61,8 @@ public class OrderPaySuccessListener {
         } catch (Exception e) {
             log.error("充值回调CP异常, orderId : {}, e : {}", platformOrderDTO.getOrderId(), e.getMessage());
         }
+        //订单回传
+        callBackService.orderCallBack(platformOrderDTO);
         //用户充值统计更新
         performOrderService.userRechargeTotal(platformOrderDTO);
         //用户首冲统计
@@ -73,8 +75,6 @@ public class OrderPaySuccessListener {
             //商户号额度统计更新
             performOrderService.payMerchantTotal(platformOrderDTO);
         }
-        //订单回传
-        callBackService.orderCallBack(platformOrderDTO);
         //订单支付埋点数据发送到卡夫卡
         kafkaService.eventTrack(KafkaEventTrackEnum.KAFKA_EVENT_TRACK_ORDER_PAY, JsonUtil.toString(platformOrderDTO));
         //订单充值消息推送

+ 5 - 0
game-module/game-module-sdk/src/main/java/com/zanxiang/game/module/sdk/pojo/result/PushCpResult.java

@@ -15,6 +15,11 @@ public class PushCpResult {
      */
     public static final String SUCCESS_CODE = "200";
 
+    /**
+     * 返回码
+     */
+    private String code;
+
     /**
      * 返回码
      */

+ 2 - 1
game-module/game-module-sdk/src/main/java/com/zanxiang/game/module/sdk/service/impl/PerformOrderServiceImpl.java

@@ -124,7 +124,8 @@ public class PerformOrderServiceImpl implements IPerformOrderService {
             return false;
         }
         PushCpResult pushCpResult = JsonUtil.toObj(resultStr, PushCpResult.class);
-        boolean pushSuccess = Objects.equals(pushCpResult.getResult(), PushCpResult.SUCCESS_CODE);
+        boolean pushSuccess = Objects.equals(pushCpResult.getResult(), PushCpResult.SUCCESS_CODE)
+                || Objects.equals(pushCpResult.getCode(), PushCpResult.SUCCESS_CODE);
         log.error("通知CP支付回调结果, url : {}, resultStr : {}, pushSuccess : {}", url, resultStr, pushSuccess);
         //更新订单信息
         orderService.update(new LambdaUpdateWrapper<Order>()