注册充值时间差

game-back/game-back-serve/src/main/java/com/zanxiang/game/back/serve/pojo/dto/GameOceanengineOrderLogDTO.java

@@ -44,5 +44,8 @@ public class GameOceanengineOrderLogDTO extends BaseListDTO<GameOceanengineOrder
     private Integer backStatus;
 
     @ApiModelProperty("充值到支付的间隔时间（分）")
-    private Long regPayIntervalTime;
+    private Long regPayIntervalTimeMin;
+
+    @ApiModelProperty("充值到支付的间隔时间（分）")
+    private Long regPayIntervalTimeMax;
 }

game-back/game-back-serve/src/main/java/com/zanxiang/game/back/serve/pojo/dto/GameTencentMiniGameOrderDTO.java

@@ -70,5 +70,8 @@ public class GameTencentMiniGameOrderDTO extends BaseListDTO<GameTencentMiniGame
     private Integer orderStatus;
 
     @ApiModelProperty("充值到支付的间隔时间（分）")
-    private Long regPayIntervalTime;
+    private Long regPayIntervalTimeMin;
+
+    @ApiModelProperty("充值到支付的间隔时间（分）")
+    private Long regPayIntervalTimeMax;
 }

game-back/game-back-serve/src/main/java/com/zanxiang/game/back/serve/pojo/dto/GameTencentOrderDTO.java

@@ -76,5 +76,8 @@ public class GameTencentOrderDTO extends BaseListDTO<GameTencentOrder> {
     private Long userActionSetId;
 
     @ApiModelProperty("充值到支付的间隔时间（分）")
-    private Long regPayIntervalTime;
+    private Long regPayIntervalTimeMin;
+
+    @ApiModelProperty("充值到支付的间隔时间（分）")
+    private Long regPayIntervalTimeMax;
 }

game-back/game-back-serve/src/main/java/com/zanxiang/game/back/serve/service/impl/GameOceanengineOrderLogServiceImpl.java

@@ -116,7 +116,8 @@ public class GameOceanengineOrderLogServiceImpl extends ServiceImpl<GameOceaneng
                 .eq(StringUtils.isNotBlank(dto.getOrderNo()), GameOceanengineOrderLog::getOrderNo, dto.getOrderNo())
                 .eq(null != dto.getBackStatus(), GameOceanengineOrderLog::getBackStatus, dto.getBackStatus())
                 .eq(null != dto.getOrderStatus(), GameOceanengineOrderLog::getOrderStatus, dto.getOrderStatus())
-                .apply(dto.getRegPayIntervalTime() != null && dto.getRegPayIntervalTime() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, reg_time, pay_time), null) >= {0}", dto.getRegPayIntervalTime())
+                .apply(dto.getRegPayIntervalTimeMin() != null && dto.getRegPayIntervalTimeMin() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, reg_time, pay_time), null) >= {0}", dto.getRegPayIntervalTimeMin())
+                .apply(dto.getRegPayIntervalTimeMax() != null && dto.getRegPayIntervalTimeMax() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, reg_time, pay_time), null) <= {0}", dto.getRegPayIntervalTimeMax())
                 .orderByDesc(GameOceanengineOrderLog::getCreateTime)
         );
         IPage<GameOceanengineOrderLogVO> result = new Page<>(page.getCurrent(), page.getSize(), page.getTotal());

game-back/game-back-serve/src/main/java/com/zanxiang/game/back/serve/service/impl/GameTencentMiniGameOrderServiceImpl.java

@@ -124,7 +124,8 @@ public class GameTencentMiniGameOrderServiceImpl extends ServiceImpl<GameTencent
                 .eq(StringUtils.isNotBlank(dto.getOrderId()), GameTencentMiniGameOrder::getOrderId, dto.getOrderId())
                 .eq(null != dto.getBackStatus(), GameTencentMiniGameOrder::getBackStatus, dto.getBackStatus())
                 .eq(null != dto.getOrderStatus(), GameTencentMiniGameOrder::getOrderStatus, dto.getOrderStatus())
-                .apply(dto.getRegPayIntervalTime() != null && dto.getRegPayIntervalTime() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, recharge_time, pay_time), null) >= {0}", dto.getRegPayIntervalTime())
+                .apply(dto.getRegPayIntervalTimeMin() != null && dto.getRegPayIntervalTimeMin() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, recharge_time, pay_time), null) >= {0}", dto.getRegPayIntervalTimeMin())
+                .apply(dto.getRegPayIntervalTimeMax() != null && dto.getRegPayIntervalTimeMax() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, recharge_time, pay_time), null) <= {0}", dto.getRegPayIntervalTimeMax())
                 .orderByDesc(GameTencentMiniGameOrder::getCreateTime)
         );
         IPage<GameTencentMiniGameOrderVO> result = new Page<>(page.getCurrent(), page.getSize(), page.getTotal());

game-back/game-back-serve/src/main/java/com/zanxiang/game/back/serve/service/impl/GameTencentOrderServiceImpl.java

@@ -92,10 +92,10 @@ public class GameTencentOrderServiceImpl extends ServiceImpl<GameTencentOrderMap
                 doBack = BackPolicyUtil.backOrder(orderLog.getOrderId(), gameBackPolicy, orderLog.getRechargeMoney(),
                         () -> getOne(new LambdaQueryWrapper<GameTencentOrder>()
                                 .eq(GameTencentOrder::getGameId, orderLog.getGameId())
-                                .eq(GameTencentOrder::getWechatAppId, orderLog.getWechatAppId())
                                 .eq(GameTencentOrder::getAdAccountId, orderLog.getAdAccountId())
-                                .eq(GameTencentOrder::getOrderStatus, OrderStatusEnum.SUCCESS_PAY.getValue())
+                                .eq(GameTencentOrder::getWechatAppId, orderLog.getWechatAppId())
                                 .eq(GameTencentOrder::getWechatOpenid, orderLog.getWechatOpenid())
+                                .eq(GameTencentOrder::getOrderStatus, OrderStatusEnum.SUCCESS_PAY.getValue())
                                 .last("limit 1")
                         ) == null, backUnit -> Long.valueOf(list(new LambdaQueryWrapper<GameTencentOrder>()
                                         .eq(GameTencentOrder::getGameId, orderLog.getGameId())
@@ -133,7 +133,8 @@ public class GameTencentOrderServiceImpl extends ServiceImpl<GameTencentOrderMap
                 .eq(StringUtils.isNotBlank(dto.getOrderId()), GameTencentOrder::getOrderId, dto.getOrderId())
                 .eq(null != dto.getIsBack(), GameTencentOrder::getIsBack, dto.getIsBack())
                 .eq(null != dto.getOrderStatus(), GameTencentOrder::getOrderStatus, dto.getOrderStatus())
-                .apply(dto.getRegPayIntervalTime() != null && dto.getRegPayIntervalTime() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, recharge_time, pay_time), null) >= {0}", dto.getRegPayIntervalTime())
+                .apply(dto.getRegPayIntervalTimeMin() != null && dto.getRegPayIntervalTimeMin() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, recharge_time, pay_time), null) >= {0}", dto.getRegPayIntervalTimeMin())
+                .apply(dto.getRegPayIntervalTimeMax() != null && dto.getRegPayIntervalTimeMax() > 0, "if(pay_time is not null, TIMESTAMPDIFF(minute, recharge_time, pay_time), null) <= {0}", dto.getRegPayIntervalTimeMax())
                 .orderByDesc(GameTencentOrder::getCreateTime)
         );
         IPage<GameTencentOrderVO> result = new Page<>(page.getCurrent(), page.getSize(), page.getTotal());

game-back/game-back-serve/src/main/java/com/zanxiang/game/back/serve/utils/BackPolicyUtil.java

@@ -3,6 +3,7 @@ package com.zanxiang.game.back.serve.utils;
 import com.github.sd4324530.jtuple.Tuple2;
 import com.github.sd4324530.jtuple.Tuples;
 import com.zanxiang.game.back.serve.pojo.entity.GameBackPolicy;
+import com.zanxiang.module.util.JsonUtil;
 import com.zanxiang.module.util.NumberUtil;
 import lombok.extern.slf4j.Slf4j;
 import org.apache.commons.lang3.RandomUtils;
@@ -20,6 +21,37 @@ public class BackPolicyUtil {
         Arrays.sort(RECHARGE_LEVEL);
     }
 
+    public static void main(String[] args) {
+        GameBackPolicy backPolicy = GameBackPolicy.builder()
+                .id(8L)
+                .backPolicyName("只传首充")
+                .firstMinMoney(3000L)
+                .firstMinMoneyType(0)
+                .firstMinMoneyRate("1:0")
+                .firstMaxMoney(19800L)
+                .firstMaxMoneyType(0)
+                .firstMaxMoneyRate("1:0")
+                .firstOtherMoneyType(0)
+                .firstOtherMoneyRate("1:0")
+                .rechargeMinMoney(3000L)
+                .rechargeMinMoneyType(1)
+                .rechargeMinMoneyRate("0")
+                .rechargeMaxMoney(19800L)
+                .rechargeMaxMoneyType(1)
+                .rechargeMaxMoneyRate("0")
+                .rechargeOtherMoneyType(1)
+                .rechargeOtherMoneyRate("0")
+                .levelDown(0)
+                .build();
+        String orderId = "2023072623022469103393434";
+        long money = 800;
+        System.out.println(backOrder(orderId, backPolicy, money, () -> {
+            return true;
+        }, (count) -> {
+            return 0;
+        }));
+    }
+
     /**
      * 订单回传
      *
@@ -33,6 +65,7 @@ public class BackPolicyUtil {
             log.error("订单 id[{}]通过回传策略[null]判断后，是否回传：{}.", orderId, true);
             return true;
         }
+        log.error("----orderId: {}, backPolicy: {}, money: {}", orderId, JsonUtil.toString(gameBackPolicy), rechargeMoney);
         Integer firstType;
         String firstRate;
         Integer rechargeType;
@@ -66,9 +99,11 @@ public class BackPolicyUtil {
             backRate = firstRate;
         } else {
             if (firstOrder.isFirstOrder()) {
+                log.error("订单{}是首单", orderId);
                 backType = firstType;
                 backRate = firstRate;
             } else {
+                log.error("订单{}不是首单", orderId);
                 backType = rechargeType;
                 backRate = rechargeRate;
             }