From fe77a3519cb16e799da49a33082bd86a7452cd63 Mon Sep 17 00:00:00 2001 From: tianfeng <769204422@qq.com> Date: Tue, 2 Dec 2025 18:55:46 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9E=E6=B8=B8=E6=88=8F=E6=8E=92?= =?UTF-8?q?=E8=A1=8C=E6=A6=9C=E7=BB=9F=E8=AE=A1=E5=8A=9F=E8=83=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../app/sys/AppConfigRestController.java | 13 +++ .../game/ranking/GameRankingQryExe.java | 57 ++++++++++ .../convertor/game/GameRankingConvertor.java | 34 ++++++ .../service/game/GameBaishunServiceImpl.java | 1 + .../service/game/GameRankingServiceImpl.java | 32 ++++++ .../dto/clientobject/game/GameRankingCO.java | 52 +++++++++ .../app/dto/cmd/game/GameRankingQry.java | 20 ++++ .../app/service/game/GameRankingService.java | 21 ++++ .../domain/game/GameRankingIncrementCmd.java | 49 +++++++++ .../domain/game/GameRankingPeriodType.java | 47 ++++++++ .../other/domain/game/GameRankingRecord.java | 52 +++++++++ .../gateway/game/GameRankingGateway.java | 30 ++++++ .../mongo/entity/game/rank/GameRanking.java | 81 ++++++++++++++ .../game/GameRankingRepository.java | 15 +++ .../gateway/game/GameRankingGatewayImpl.java | 102 ++++++++++++++++++ .../other-start/src/test/java/SpringTest.java | 15 +++ 16 files changed, 621 insertions(+) create mode 100644 rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/game/ranking/GameRankingQryExe.java create mode 100644 rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/convertor/game/GameRankingConvertor.java create mode 100644 rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameRankingServiceImpl.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/game/GameRankingCO.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/game/GameRankingQry.java create mode 100644 rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/game/GameRankingService.java create mode 100644 rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingIncrementCmd.java create mode 100644 rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingPeriodType.java create mode 100644 rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingRecord.java create mode 100644 rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/gateway/game/GameRankingGateway.java create mode 100644 rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/entity/game/rank/GameRanking.java create mode 100644 rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/repository/game/GameRankingRepository.java create mode 100644 rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/gateway/game/GameRankingGatewayImpl.java diff --git a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/sys/AppConfigRestController.java b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/sys/AppConfigRestController.java index 3c293d82..4bdb4ec7 100644 --- a/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/sys/AppConfigRestController.java +++ b/rc-service/rc-service-other/other-adapter/src/main/java/com/red/circle/other/adapter/app/sys/AppConfigRestController.java @@ -3,6 +3,7 @@ package com.red.circle.other.adapter.app.sys; import com.red.circle.common.business.core.ControllerRedisKeyConstant; import com.red.circle.common.business.dto.cmd.AppExtCommand; import com.red.circle.framework.core.dto.AppCommand; +import com.red.circle.framework.dto.PageResult; import com.red.circle.framework.web.controller.BaseController; import com.red.circle.framework.web.props.EnvProperties; import com.red.circle.mq.business.model.event.game.GameSudProperties; @@ -14,8 +15,11 @@ import com.red.circle.other.app.dto.clientobject.sys.GameListConfigCO; import com.red.circle.other.app.dto.clientobject.sys.GameMatchModelConfigGroupCO; import com.red.circle.other.app.dto.clientobject.sys.NoticeMessageCO; import com.red.circle.other.app.dto.clientobject.sys.SudCodeCO; +import com.red.circle.other.app.dto.clientobject.game.GameRankingCO; import com.red.circle.other.app.dto.cmd.game.GameListQryCmd; +import com.red.circle.other.app.dto.cmd.game.GameRankingQry; import com.red.circle.other.app.service.sys.AppConfigService; +import com.red.circle.other.app.service.game.GameRankingService; import com.red.circle.other.domain.gateway.user.UserProfileGateway; import com.red.circle.other.domain.model.user.UserConsumptionLevel; import com.red.circle.other.infra.database.cache.service.other.EnumConfigCacheService; @@ -58,6 +62,7 @@ public class AppConfigRestController extends BaseController { private final UserProfileGateway userProfileGateway; private final EnumConfigCacheService enumConfigCacheService; private final RedisTemplate redisTemplate; + private final GameRankingService gameRankingService; /** * 房间内-快捷入口-游戏. @@ -222,4 +227,12 @@ public class AppConfigRestController extends BaseController { return appConfigService.listNoticeMessageLastMonth(cmd); } + /** + * 热门游戏排行榜. + */ + @GetMapping("/game/ranking") + public PageResult gameRanking(GameRankingQry qry) { + return gameRankingService.pageRanking(qry); + } + } diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/game/ranking/GameRankingQryExe.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/game/ranking/GameRankingQryExe.java new file mode 100644 index 00000000..359880c6 --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/game/ranking/GameRankingQryExe.java @@ -0,0 +1,57 @@ +package com.red.circle.other.app.command.game.ranking; + +import com.baomidou.mybatisplus.extension.plugins.pagination.Page; +import com.red.circle.framework.dto.PageResult; +import com.red.circle.other.app.convertor.game.GameRankingConvertor; +import com.red.circle.other.app.dto.clientobject.game.GameRankingCO; +import com.red.circle.other.app.dto.cmd.game.GameRankingQry; +import com.red.circle.other.domain.game.GameRankingPeriodType; +import com.red.circle.other.domain.game.GameRankingRecord; +import com.red.circle.other.domain.gateway.game.GameRankingGateway; +import lombok.RequiredArgsConstructor; +import org.springframework.stereotype.Component; + +import java.util.Collection; +import java.util.List; +import java.util.stream.Collectors; +import java.util.stream.IntStream; + +/** + * 游戏排行榜查询执行器. + * + * @author system + */ +@Component +@RequiredArgsConstructor +public class GameRankingQryExe { + + private final GameRankingGateway gameRankingGateway; + private final GameRankingConvertor gameRankingConvertor; + + public PageResult execute(GameRankingQry qry) { + String periodType = qry.getPeriodType() == null ? GameRankingPeriodType.ALL.getCode() : qry.getPeriodType(); + Integer pageNum = qry.getCurrent().intValue(); + Integer pageSize = qry.getSize().intValue(); + + // 查询排行榜数据 + PageResult pageResult = gameRankingGateway.pageRanking(periodType, pageNum, pageSize); + + // 计算排名（从当前页的起始排名开始） + int startRank = (pageNum - 1) * pageSize + 1; + List coList = IntStream.range(0, pageResult.getRecords().size()) + .mapToObj(i -> { + List records = (List) pageResult.getRecords(); + GameRankingRecord record = records.get(i); + int rank = startRank + i; + return gameRankingConvertor.toCO(record, rank); + }) + .collect(Collectors.toList()); + + PageResult result = new PageResult<>(); + result.setRecords(coList); + result.setTotal(pageResult.getTotal()); + result.setCurrent(pageResult.getCurrent()); + result.setSize(pageResult.getSize()); + return result; + } +} diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/convertor/game/GameRankingConvertor.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/convertor/game/GameRankingConvertor.java new file mode 100644 index 00000000..3ad05d3b --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/convertor/game/GameRankingConvertor.java @@ -0,0 +1,34 @@ +package com.red.circle.other.app.convertor.game; + +import com.red.circle.other.app.dto.clientobject.game.GameRankingCO; +import com.red.circle.other.domain.game.GameRankingRecord; +import org.springframework.stereotype.Component; + +/** + * 游戏排行榜转换器. + * + * @author system + */ +@Component +public class GameRankingConvertor { + + /** + * 领域对象转客户端对象. + */ + public GameRankingCO toCO(GameRankingRecord record, Integer rank) { + if (record == null) { + return null; + } + + GameRankingCO co = new GameRankingCO(); + co.setRank(rank); + co.setGameId(record.getGameId()); + co.setGameName(record.getGameName()); + co.setGameCover(record.getGameCover()); + co.setGameOrigin(record.getGameOrigin()); + co.setSysOrigin(record.getSysOrigin()); + co.setTotalPrizeAmount(record.getTotalPrizeAmount()); + co.setPeriodType(record.getPeriodType()); + return co; + } +} diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java index 22887f3c..e329ef21 100644 --- a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameBaishunServiceImpl.java @@ -217,6 +217,7 @@ public class GameBaishunServiceImpl implements GameBaishunService { } + log.warn("{} 发送游戏获奖通知--金币数量{}", GoldOrigin.BAISHUN_GAME.name(), request.getCurrencyDiff()); return BaishunResponse.success(new BaishunChangeCurrencyResponse() .setCurrencyBalance(receiptRes.getBalance().getDollarAmount().stripTrailingZeros()), diff --git a/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameRankingServiceImpl.java b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameRankingServiceImpl.java new file mode 100644 index 00000000..c1704630 --- /dev/null +++ b/rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/service/game/GameRankingServiceImpl.java @@ -0,0 +1,32 @@ +package com.red.circle.other.app.service.game; + +import com.red.circle.framework.dto.PageResult; +import com.red.circle.other.app.command.game.ranking.GameRankingQryExe; +import com.red.circle.other.app.dto.clientobject.game.GameRankingCO; +import com.red.circle.other.app.dto.cmd.game.GameRankingQry; +import com.red.circle.other.app.service.game.GameRankingService; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.cache.annotation.Cacheable; +import org.springframework.stereotype.Service; + +/** + * 游戏排行榜服务实现. + * + * @author system + */ +@Slf4j +@Service +@RequiredArgsConstructor +public class GameRankingServiceImpl implements GameRankingService { + + private final GameRankingQryExe gameRankingQryExe; + + private static final String CACHE_NAME = "game:ranking"; + private static final int CACHE_TTL_MINUTES = 5; + + @Override + public PageResult pageRanking(GameRankingQry qry) { + return gameRankingQryExe.execute(qry); + } +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/game/GameRankingCO.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/game/GameRankingCO.java new file mode 100644 index 00000000..32c37f6a --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/clientobject/game/GameRankingCO.java @@ -0,0 +1,52 @@ +package com.red.circle.other.app.dto.clientobject.game; + +import lombok.Data; + +/** + * 游戏排行榜返回对象. + * + * @author system + */ +@Data +public class GameRankingCO { + + /** + * 排名 + */ + private Integer rank; + + /** + * 游戏ID + */ + private String gameId; + + /** + * 游戏名称 + */ + private String gameName; + + /** + * 游戏封面 + */ + private String gameCover; + + /** + * 游戏源 + */ + private String gameOrigin; + + /** + * 归属系统 + */ + private String sysOrigin; + + /** + * 总中奖金额（单位：分） + */ + private Long totalPrizeAmount; + + /** + * 周期类型 + */ + private String periodType; +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/game/GameRankingQry.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/game/GameRankingQry.java new file mode 100644 index 00000000..6a974e2d --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/dto/cmd/game/GameRankingQry.java @@ -0,0 +1,20 @@ +package com.red.circle.other.app.dto.cmd.game; + +import com.red.circle.common.business.dto.PageQueryCmd; +import lombok.Data; +import lombok.EqualsAndHashCode; + +/** + * 游戏排行榜查询参数. + * + * @author system + */ +@Data +@EqualsAndHashCode(callSuper = true) +public class GameRankingQry extends PageQueryCmd { + + /** + * 周期类型：ALL-全部，WEEK-本周，MONTH-本月 + */ + private String periodType; +} diff --git a/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/game/GameRankingService.java b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/game/GameRankingService.java new file mode 100644 index 00000000..0a9007a5 --- /dev/null +++ b/rc-service/rc-service-other/other-client/src/main/java/com/red/circle/other/app/service/game/GameRankingService.java @@ -0,0 +1,21 @@ +package com.red.circle.other.app.service.game; + +import com.red.circle.framework.dto.PageResult; +import com.red.circle.other.app.dto.clientobject.game.GameRankingCO; +import com.red.circle.other.app.dto.cmd.game.GameRankingQry; + +/** + * 游戏排行榜服务. + * + * @author system + */ +public interface GameRankingService { + + /** + * 分页查询游戏排行榜. + * + * @param qry 查询参数 + * @return 分页结果 + */ + PageResult pageRanking(GameRankingQry qry); +} diff --git a/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingIncrementCmd.java b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingIncrementCmd.java new file mode 100644 index 00000000..6625a0b0 --- /dev/null +++ b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingIncrementCmd.java @@ -0,0 +1,49 @@ +package com.red.circle.other.domain.game; + +import lombok.Data; +import lombok.experimental.Accessors; + +/** + * 游戏排行榜累加命令. + * + * @author system + */ +@Data +@Accessors(chain=true) +public class GameRankingIncrementCmd { + + /** + * 归属系统 + */ + private String sysOrigin; + + /** + * 游戏源 + */ + private String gameOrigin; + + /** + * 游戏ID + */ + private String gameId; + + /** + * 游戏名称 + */ + private String gameName; + + /** + * 游戏封面 + */ + private String gameCover; + + /** + * 周期类型：ALL-全部，WEEK-本周，MONTH-本月 + */ + private String periodType; + + /** + * 中奖金额（单位：分） + */ + private Long amount; +} diff --git a/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingPeriodType.java b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingPeriodType.java new file mode 100644 index 00000000..de4d3d15 --- /dev/null +++ b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingPeriodType.java @@ -0,0 +1,47 @@ +package com.red.circle.other.domain.game; + +import lombok.Getter; + +/** + * 游戏排行榜周期类型. + * + * @author system + */ +@Getter +public enum GameRankingPeriodType { + + /** + * 全部时间 + */ + ALL("ALL", "全部"), + + /** + * 本周 + */ + WEEK("WEEK", "本周"), + + /** + * 本月 + */ + MONTH("MONTH", "本月"); + + private final String code; + private final String name; + + GameRankingPeriodType(String code, String name) { + this.code = code; + this.name = name; + } + + /** + * 根据 code 获取枚举. + */ + public static GameRankingPeriodType fromCode(String code) { + for (GameRankingPeriodType type : values()) { + if (type.code.equals(code)) { + return type; + } + } + return ALL; + } +} diff --git a/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingRecord.java b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingRecord.java new file mode 100644 index 00000000..296a519e --- /dev/null +++ b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/game/GameRankingRecord.java @@ -0,0 +1,52 @@ +package com.red.circle.other.domain.game; + +import lombok.Data; + +/** + * 游戏排行榜领域对象. + * + * @author system + */ +@Data +public class GameRankingRecord { + + /** + * 主键 + */ + private String id; + + /** + * 归属系统 + */ + private String sysOrigin; + + /** + * 游戏源 + */ + private String gameOrigin; + + /** + * 游戏ID + */ + private String gameId; + + /** + * 游戏名称 + */ + private String gameName; + + /** + * 游戏封面 + */ + private String gameCover; + + /** + * 周期类型：ALL-全部，WEEK-本周，MONTH-本月 + */ + private String periodType; + + /** + * 总中奖金额（单位：分） + */ + private Long totalPrizeAmount; +} diff --git a/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/gateway/game/GameRankingGateway.java b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/gateway/game/GameRankingGateway.java new file mode 100644 index 00000000..4ba3ef18 --- /dev/null +++ b/rc-service/rc-service-other/other-domain/src/main/java/com/red/circle/other/domain/gateway/game/GameRankingGateway.java @@ -0,0 +1,30 @@ +package com.red.circle.other.domain.gateway.game; + +import com.red.circle.framework.dto.PageResult; +import com.red.circle.other.domain.game.GameRankingIncrementCmd; +import com.red.circle.other.domain.game.GameRankingRecord; + +/** + * 游戏排行榜网关. + * + * @author system + */ +public interface GameRankingGateway { + + /** + * 分页查询游戏排行榜. + * + * @param periodType 周期类型 + * @param pageNum 页码 + * @param pageSize 每页大小 + * @return 分页结果 + */ + PageResult pageRanking(String periodType, Integer pageNum, Integer pageSize); + + /** + * 累加中奖金额. + * + * @param cmd 累加命令 + */ + void incrementPrizeAmount(GameRankingIncrementCmd cmd); +} diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/entity/game/rank/GameRanking.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/entity/game/rank/GameRanking.java new file mode 100644 index 00000000..ce0c0e27 --- /dev/null +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/entity/game/rank/GameRanking.java @@ -0,0 +1,81 @@ +package com.red.circle.other.infra.database.mongo.entity.game.rank; + +import lombok.Data; +import org.springframework.data.annotation.Id; +import org.springframework.data.mongodb.core.index.CompoundIndex; +import org.springframework.data.mongodb.core.index.CompoundIndexes; +import org.springframework.data.mongodb.core.mapping.Document; + +import java.time.LocalDateTime; + +/** + * 游戏排行榜实体. + * + * @author system + */ +@Data +@Document(collection = "game_ranking") +@CompoundIndexes({ + @CompoundIndex( + name = "idx_unique_game_ranking", + def = "{'sysOrigin': 1, 'gameOrigin': 1, 'gameId': 1, 'periodType': 1}", + unique = true + ), + @CompoundIndex( + name = "idx_period_amount", + def = "{'periodType': 1, 'totalPrizeAmount': -1}" + ) +}) +public class GameRanking { + + /** + * 主键 + */ + @Id + private String id; + + /** + * 归属系统 + */ + private String sysOrigin; + + /** + * 游戏源 + */ + private String gameOrigin; + + /** + * 游戏ID + */ + private String gameId; + + /** + * 游戏名称 + */ + private String gameName; + + /** + * 游戏封面 + */ + private String gameCover; + + /** + * 周期类型：ALL-全部，WEEK-本周，MONTH-本月 + */ + private String periodType; + + /** + * 总中奖金额 + */ + private Long totalPrizeAmount; + + /** + * 创建时间 + */ + private LocalDateTime createTime; + + /** + * 更新时间 + */ + private LocalDateTime updateTime; +} diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/repository/game/GameRankingRepository.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/repository/game/GameRankingRepository.java new file mode 100644 index 00000000..f8ae908c --- /dev/null +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/database/mongo/repository/game/GameRankingRepository.java @@ -0,0 +1,15 @@ +package com.red.circle.other.infra.database.mongo.repository.game; + +import com.red.circle.other.infra.database.mongo.entity.game.rank.GameRanking; +import org.springframework.data.mongodb.repository.MongoRepository; +import org.springframework.stereotype.Repository; + +/** + * 游戏排行榜 Mapper. + * + * @author system + */ +@Repository +public interface GameRankingRepository extends MongoRepository { + +} diff --git a/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/gateway/game/GameRankingGatewayImpl.java b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/gateway/game/GameRankingGatewayImpl.java new file mode 100644 index 00000000..235e60ae --- /dev/null +++ b/rc-service/rc-service-other/other-infrastructure/src/main/java/com/red/circle/other/infra/gateway/game/GameRankingGatewayImpl.java @@ -0,0 +1,102 @@ +package com.red.circle.other.infra.gateway.game; + +import com.mongodb.client.result.UpdateResult; +import com.red.circle.framework.dto.PageResult; +import com.red.circle.other.domain.game.GameRankingIncrementCmd; +import com.red.circle.other.domain.game.GameRankingRecord; +import com.red.circle.other.domain.gateway.game.GameRankingGateway; +import com.red.circle.other.infra.database.mongo.entity.game.rank.GameRanking; +import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; +import org.springframework.data.domain.PageRequest; +import org.springframework.data.domain.Sort; +import org.springframework.data.mongodb.core.MongoTemplate; +import org.springframework.data.mongodb.core.query.Criteria; +import org.springframework.data.mongodb.core.query.Query; +import org.springframework.data.mongodb.core.query.Update; +import org.springframework.stereotype.Component; + +import java.time.LocalDateTime; +import java.util.List; +import java.util.stream.Collectors; + +/** + * 游戏排行榜网关实现. + * + * @author system + */ +@Slf4j +@Component +@RequiredArgsConstructor +public class GameRankingGatewayImpl implements GameRankingGateway { + + private final MongoTemplate mongoTemplate; + + @Override + public PageResult pageRanking(String periodType, Integer pageNum, Integer pageSize) { + // 创建分页请求，按中奖金额降序排序 + PageRequest pageRequest = PageRequest.of( + pageNum - 1, + pageSize, + Sort.by(Sort.Direction.DESC, "totalPrizeAmount") + ); + + // 构建查询条件 + Query query = new Query(); + query.addCriteria(Criteria.where("periodType").is(periodType)); + query.with(pageRequest); + + // 查询总数 + long total = mongoTemplate.count(Query.of(query).limit(-1).skip(-1), GameRanking.class); + + // 查询数据 + List entities = mongoTemplate.find(query, GameRanking.class); + + // 转换为领域对象 + List records = entities.stream() + .map(this::toDomain) + .collect(Collectors.toList()); + + PageResult pageResult = new PageResult<>(); + pageResult.setTotal(total); + pageResult.setCurrent(pageNum); + pageResult.setRecords(records); + pageResult.setSize(pageSize); + return pageResult; + } + + @Override + public void incrementPrizeAmount(GameRankingIncrementCmd cmd) { + Query query = new Query(); + query.addCriteria(Criteria.where("sysOrigin").is(cmd.getSysOrigin())) + .addCriteria(Criteria.where("gameOrigin").is(cmd.getGameOrigin())) + .addCriteria(Criteria.where("gameId").is(cmd.getGameId())) + .addCriteria(Criteria.where("periodType").is(cmd.getPeriodType())); + + Update update = new Update(); + update.inc("totalPrizeAmount", cmd.getAmount()); + update.set("updateTime", LocalDateTime.now()); + update.setOnInsert("createTime", LocalDateTime.now()); + update.setOnInsert("sysOrigin", cmd.getSysOrigin()); + update.setOnInsert("gameOrigin", cmd.getGameOrigin()); + update.setOnInsert("gameId", cmd.getGameId()); + update.setOnInsert("periodType", cmd.getPeriodType()); + mongoTemplate.upsert(query, update, GameRanking.class); + } + + /** + * 实体转领域对象. + */ + private GameRankingRecord toDomain(GameRanking entity) { + GameRankingRecord record = new GameRankingRecord(); + record.setId(entity.getId()); + record.setSysOrigin(entity.getSysOrigin()); + record.setGameOrigin(entity.getGameOrigin()); + record.setGameId(entity.getGameId()); + record.setGameName(entity.getGameName()); + record.setGameCover(entity.getGameCover()); + record.setPeriodType(entity.getPeriodType()); + record.setTotalPrizeAmount(entity.getTotalPrizeAmount()); + return record; + } +} diff --git a/rc-service/rc-service-other/other-start/src/test/java/SpringTest.java b/rc-service/rc-service-other/other-start/src/test/java/SpringTest.java index 20305d7a..355252f6 100644 --- a/rc-service/rc-service-other/other-start/src/test/java/SpringTest.java +++ b/rc-service/rc-service-other/other-start/src/test/java/SpringTest.java @@ -14,7 +14,9 @@ import com.red.circle.other.app.enums.violation.GameOriginEnum; import com.red.circle.other.app.service.activity.RankingActivityService; import com.red.circle.other.app.service.user.user.AppUserDataViolationService; import com.red.circle.other.app.util.OfficialNoticeUtils; +import com.red.circle.other.domain.game.GameRankingIncrementCmd; import com.red.circle.other.domain.gateway.PropCouponGateway; +import com.red.circle.other.domain.gateway.game.GameRankingGateway; import com.red.circle.other.domain.gateway.user.UserProfileGateway; import com.red.circle.other.domain.gateway.user.ability.InviteUserGateway; import com.red.circle.other.domain.propcoupon.PropCoupon; @@ -62,6 +64,19 @@ public class SpringTest { private AppUserDataViolationService userDataViolationService; @Autowired private RankingActivityService rankingActivityService; + @Autowired + private GameRankingGateway gameRankingGateway; + + @Test + public void testGameRanking() { + String sysOrigin = "LIKEI"; // 例如: "LIKEI" + String gameOrigin = "BAISHUN"; // 例如: "THIRD_PARTY" 或 "APP" + String gameId = "1053"; // 例如: "1001" + Long prizeAmount = 500L; // 中奖金额（单位：分） + + // 同时更新三个维度的排行榜 + gameRankingGateway.incrementPrizeAmount(new GameRankingIncrementCmd()); + } @Test public void testGame() {