hy/aslan-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

百顺语聊房游戏数据上报逻辑去除

Browse Source
This commit is contained in:
tianfeng 2026-03-18 14:35:10 +08:00
parent bb67a73d64
commit b5747387bd
1 changed files with 3 additions and 100 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

103
rc-service/rc-service-other/other-application/src/main/java/com/red/circle/other/app/command/game/GameBaishunReportCmdExe.java
View File

@ -43,109 +43,12 @@ public class GameBaishunReportCmdExe {
private final AuthClient authClient;
public BaishunResponse<Void> execute(GameBaishunReportCmd cmd) {
if (!checkTokenStrict(cmd)) {
log.error("BaishunReportCmdExe execute checkTokenStrict fail !");
}
log.info("Baishun game report: type={}, userId={}", cmd.getReportType(), cmd.getUserId());
log.error("Baishun game report: {}", JSONObject.toJSONString(cmd));
/*switch (cmd.getReportType()) {
case REPORT_TYPE_START:
return handleGameStart(cmd);
case REPORT_TYPE_SETTLE:
return handleGameSettle(cmd);
default:
log.warn("Unknown report_type: {}", cmd.getReportType());
return BaishunResponse.fail(BaishunErrorCode.DATE_ERROR);
}*/
// if (!checkTokenStrict(cmd)) {
// log.error("BaishunReportCmdExe execute checkTokenStrict fail !");
// }
return BaishunResponse.success(null);
}
private BaishunResponse<Void> handleGameStart(GameBaishunReportCmd cmd) {
GameStartInfo startInfo = parseReportMsg(cmd.getReportMsg(), GameStartInfo.class);
if (startInfo == null) {
return BaishunResponse.fail(BaishunErrorCode.READ_DATE_ERROR);
}
// 扣除开局 bet（非AI玩家）
if (startInfo.getPlayers() != null) {
for (GameBaishunReportCmd.PlayerStartInfo player : startInfo.getPlayers()) {
if (Objects.equals(player.getIsAi(), 1) || player.getBet() == null || player.getBet() <= 0) {
continue;
}
try {
Long userId = DataTypeUtils.toLong(player.getUserId());
walletGoldClient.changeBalance(GoldReceiptCmd.builder()
.appExpenditure()
.userId(userId)
.sysOrigin(resolveTokenSysOrigin(cmd.getSsToken()))
.origin(GoldOrigin.BAISHUN_GAME.name())
.originDescribe(GoldOrigin.BAISHUN_GAME.getDesc())
.eventId(startInfo.getGameRoundId() + "_" + userId + "_start")
.amount(BigDecimal.valueOf(player.getBet()))
.build());
} catch (Exception e) {
log.error("Baishun game start deduct failed: userId={}, roundId={}", player.getUserId(), startInfo.getGameRoundId(), e);
}
}
}
return BaishunResponse.success(null);
}
private BaishunResponse<Void> handleGameSettle(GameBaishunReportCmd cmd) {
GameSettleInfo settleInfo = parseReportMsg(cmd.getReportMsg(), GameSettleInfo.class);
if (settleInfo == null) {
return BaishunResponse.fail(BaishunErrorCode.READ_DATE_ERROR);
}
List<PlayerResultInfo> players = settleInfo.getPlayers();
if (players == null || players.isEmpty()) {
return BaishunResponse.success(null);
}
for (PlayerResultInfo player : players) {
if (Objects.equals(player.getIsAi(), 1) || player.getReward() == null || player.getReward() <= 0) {
continue;
}
try {
Long userId = DataTypeUtils.toLong(player.getUserId());
walletGoldClient.changeBalance(GoldReceiptCmd.builder()
.appIncome()
.userId(userId)
.sysOrigin(resolveTokenSysOrigin(cmd.getSsToken()))
.origin(GoldOrigin.BAISHUN_GAME.name())
.originDescribe(GoldOrigin.BAISHUN_GAME.getDesc())
.eventId(settleInfo.getGameRoundId() + "_" + userId + "_settle")
.amount(BigDecimal.valueOf(player.getReward()))
.build());
} catch (Exception e) {
log.error("Baishun game settle reward failed: userId={}, roundId={}", player.getUserId(), settleInfo.getGameRoundId(), e);
}
}
return BaishunResponse.success(null);
}
private <T> T parseReportMsg(Object reportMsg, Class<T> clazz) {
try {
return objectMapper.convertValue(reportMsg, clazz);
} catch (Exception e) {
log.error("Failed to parse report_msg to {}: {}", clazz.getSimpleName(), reportMsg, e);
return null;
}
}
private String resolveTokenSysOrigin(String ssToken) {
try {
return com.red.circle.framework.core.security.UserCredential.parseToken(ssToken).getSysOrigin();
} catch (Exception e) {
return "LIKEI";
}
}
private boolean checkTokenStrict(GameBaishunReportCmd request) {
UserCredential accessToken = ResponseAssert.requiredSuccess(
authClient.getUserCredential(DataTypeUtils.toLong(request.getUserId())));