shi
/
game-api
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat(game): 增加游戏投注记录详细信息 

- 在 GameBettingDetails 模型中添加新字段：round, table, seat, betContent
- 更新相关 mapper 和 SQL 文件以支持新字段- 添加 GameDTO 类用于游戏数据传输
- 更新 ApiGameController 和 ApiMemberController 中的相关方法
- 优化部分代码结构，使用 SuperBuilder 等特性
main-p
shi 2025-03-14 14:00:51 +08:00
parent 47235ed870
commit 4200ebbd28
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
ff-game/src/main/java/com/ff/game/api/ng/service/impl/GamesPGServiceImpl.java
View File

@ -485,6 +485,7 @@ public class GamesPGServiceImpl implements IGamesService {
} }
//如果长度一致则清空缓存循环币种 //如果长度一致则清空缓存循环币种
if (cacheSet.size() >= currencys.size()) { if (cacheSet.size() >= currencys.size()) {
cacheSet=new HashSet<>();
redisCache.deleteObject(CacheConstants.PG_GAMES_BET_CURRENCY); redisCache.deleteObject(CacheConstants.PG_GAMES_BET_CURRENCY);
} }
//去掉重复的 //去掉重复的
@ -504,7 +505,7 @@ public class GamesPGServiceImpl implements IGamesService {
betRecordByTimeDTO.setAgentId(currencyDTO.getCode()); betRecordByTimeDTO.setAgentId(currencyDTO.getCode());
betRecordByTimeDTO.setAgentKey(currencyDTO.getKey()); betRecordByTimeDTO.setAgentKey(currencyDTO.getKey());
int pageNo = 1; int pageNo = 1;
int pageSize = 1; int pageSize = 2;
Map<String, Object> paramsMap = new HashMap<>(); Map<String, Object> paramsMap = new HashMap<>();
paramsMap.put("currency", currencyDTO.getCurrency()); paramsMap.put("currency", currencyDTO.getCurrency());
paramsMap.put("pageNo", pageNo); paramsMap.put("pageNo", pageNo);
@ -537,11 +538,9 @@ public class GamesPGServiceImpl implements IGamesService {
//请求参数 //请求参数
Map<String, Object> paramMap = new HashMap<>(); Map<String, Object> paramMap = new HashMap<>();
paramMap.put("currency", currencyDTO.getCurrency()); paramMap.put("currency", currencyDTO.getCurrency());
paramMap.put("pageNo", pageNo); paramMap.put("pageNo", pageNoAtomic.get());
paramMap.put("pageSize", pageSize); paramMap.put("pageSize", pageSize);
//每次翻页请求必须间隔 10 秒钟 ApiNGResponseDTO<ApiGameBetRecordPageResponseDTO> betRecordByTimePage = ngClient.getBetRecordByTime(paramMap, key);
SleepUtil.sleep(10000);
ApiNGResponseDTO<ApiGameBetRecordPageResponseDTO> betRecordByTimePage = ngClient.getBetRecordByTime(paramsMap, key);
data = betRecordByTimePage.getData(); data = betRecordByTimePage.getData();
//数据组装 //数据组装
this.batchInsert(data); this.batchInsert(data);