修改内容：玩家充值排行榜添加时间筛选

game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/pojo/dto/RechargeRankingDTO.java

@@ -1,8 +1,6 @@
 package com.zanxiang.game.data.serve.pojo.dto;
 
 import com.zanxiang.game.data.serve.pojo.base.BasePage;
-import com.zanxiang.game.data.serve.pojo.entity.AdsAccountAgentDay;
-import com.zanxiang.game.data.serve.pojo.entity.AdsGameRechargeRanking;
 import io.swagger.annotations.ApiModelProperty;
 import lombok.AllArgsConstructor;
 import lombok.Builder;
@@ -16,6 +14,7 @@ import java.time.LocalDate;
 @AllArgsConstructor
 @Builder
 public class RechargeRankingDTO extends BasePage{
+
     @ApiModelProperty(notes = "充值开始日期")
     private LocalDate beginDay;
     @ApiModelProperty(notes = "充值结束日期")
@@ -28,4 +27,17 @@ public class RechargeRankingDTO extends BasePage{
 
     @ApiModelProperty(notes = "排序方式：升序asc;降序desc")
     private String sortType;
+
+    /**
+     * 最近充值时间距今的间隔时间（最小分）
+     */
+    @ApiModelProperty("最近充值时间距今的间隔时间（分）")
+    private Long latestAmountUntilNowTimeMin;
+
+    /**
+     * 最近充值时间距今的间隔时间（最大分）
+     */
+    @ApiModelProperty("最近充值时间距今的间隔时间（分）")
+    private Long latestAmountUntilNowTimeMax;
+
 }

game-data/game-data-serve/src/main/java/com/zanxiang/game/data/serve/service/impl/RankingServiceImpl.java

@@ -99,6 +99,13 @@ public class RankingServiceImpl implements IRankingService {
         if (StringUtils.isNotBlank(dto.getSourceSystem())) {
             cri.where().andEquals("source_system", dto.getSourceSystem());
         }
+        if (dto.getLatestAmountUntilNowTimeMin() != null) {
+            cri.where().andGTE("TIMESTAMPDIFF(MINUTE, last_amount_time, NOW())", dto.getLatestAmountUntilNowTimeMin());
+        }
+        if (dto.getLatestAmountUntilNowTimeMax() != null) {
+            cri.where().andLTE("TIMESTAMPDIFF(MINUTE, last_amount_time, NOW())", dto.getLatestAmountUntilNowTimeMax());
+        }
+
         cri.groupBy("source_system,player_id");
         cri.orderBy(CaseFormat.LOWER_CAMEL.to(CaseFormat.LOWER_UNDERSCORE, dto.getSortFiled()), dto.getSortType());
         Sql sql = Sqls.queryEntity(playerRankingSql() + "$condition");