moliparty/peko-java
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

游戏添加win飘屏

Browse Source
This commit is contained in:
hokli
2025-08-19 16:42:02 +08:00
parent f63c16d680
commit 1f6795b049
5 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
accompany-business/accompany-business-sdk/src/main/java/com/accompany/business/message/GameMsgMessage.java
View File

@@ -1,8 +1,8 @@
package com.accompany.business.message;
import com.accompany.business.enums.resource.ResourceCodeEnum;
import com.accompany.mq.model.BaseMqMessage;
import lombok.Data;
import com.accompany.business.enums.resource.ResourceCodeEnum ;
import java.util.Date;
@@ -19,6 +19,7 @@ public class GameMsgMessage extends BaseMqMessage {
private Integer type;
private Double coin;
private Double win = 0.0;
private ResourceCodeEnum resourceCodeEnum;

1
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/game/GameService.java
View File

@@ -171,6 +171,7 @@ public class GameService {
afterPurse = userPurseService.addDiamond(uid, goldNum, BillObjTypeEnum.LEADERCC_GAME_IN,
(up) -> billRecordService.insertGeneralBillRecord(uid, param.getOrderId(), BillObjTypeEnum.LEADERCC_GAME_IN, goldNum, up));
gameMsgMessage.setPushScreen(Boolean.TRUE);
gameMsgMessage.setWin(goldNum);
}
if (param.getType() == Constant.GameGoldType.REDUCT) {

1
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/game/JoyGameService.java
View File

@@ -156,6 +156,7 @@ public class JoyGameService {
afterPurse = userPurseService.addDiamond(uid, goldNum, BillObjTypeEnum.JOY_GAME_IN,
(up) -> billRecordService.insertGeneralBillRecord(uid, orderId, BillObjTypeEnum.JOY_GAME_IN, goldNum, up));
gameMsgMessage.setPushScreen(Boolean.TRUE);
gameMsgMessage.setWin(goldNum);
break;
case Constant.GameGoldType.REDUCT:
// 扣减用户钻石

1
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/game/MiniGameForBaiShunServiceImpl.java
View File

@@ -238,6 +238,7 @@ public class MiniGameForBaiShunServiceImpl implements MiniGameForBaiShunService
(userPurse -> billRecordService.insertGeneralBillRecord(uid, orderId, BillObjTypeEnum.MINI_GAME_IN, diamondNum, userPurse)));
gameMsgMessage.setPushScreen(Boolean.TRUE);
gameMsgMessage.setType(Constant.GameGoldType.ADD);
gameMsgMessage.setWin(diamondNum);
} else {
afterPurse = userPurseService.subDiamond(uid, diamondNum, BillObjTypeEnum.MINI_GAME_OUT, BusiStatus.BAI_SHUN_CURRENCY_NUM_NOT_ENOUGH,
(userPurse)-> billRecordService.insertGeneralBillRecord(uid, orderId, BillObjTypeEnum.MINI_GAME_OUT, diamondNum, userPurse));

6
accompany-mq/accompany-mq-web/src/main/java/com/accompany/mq/consumer/GameMsgPushMessageConsumer.java
View File

@@ -1,15 +1,11 @@
package com.accompany.mq.consumer;
import com.accompany.business.constant.dailytask.DailyTaskTypeEnum;
import com.accompany.business.enums.resource.ResourceCodeEnum;
import com.accompany.business.event.miniGame.MiniGameChangeCurrencyEvent;
import com.accompany.business.message.BillMessage;
import com.accompany.business.message.GameMsgMessage;
import com.accompany.business.service.dailytask.DailyTaskService;
import com.accompany.business.service.game.BaseGameMessageService;
import com.accompany.business.service.gift.BillMessageService;
import com.accompany.business.vo.dailytask.DailyProgressContext;
import com.accompany.common.constant.Constant;
import com.accompany.mq.constant.MqConstant;
import com.accompany.mq.listener.AbstractMessageListener;
import lombok.extern.slf4j.Slf4j;
@@ -38,7 +34,7 @@ public class GameMsgPushMessageConsumer extends AbstractMessageListener<GameMsgM
String gameId = gameMsgMessage.getGameId();
Long uid = gameMsgMessage.getUid();
if (gameMsgMessage.getPushScreen()) {
baseGameMessageService.sendGameMessage(gameId, gameMsgMessage.getRoomUid(), uid, Math.abs(gameMsgMessage.getCoin()),
baseGameMessageService.sendGameMessage(gameId, gameMsgMessage.getRoomUid(), uid, Math.abs(gameMsgMessage.getWin()),
gameMsgMessage.getResourceCodeEnum(), gameMsgMessage.getConfigId());
}
applicationContext.publishEvent(new MiniGameChangeCurrencyEvent(gameMsgMessage));