小游戏推送MQ_basishunfixed

This commit is contained in:
2025-04-23 17:22:21 +08:00
parent 1dfe50ca51
commit 162d4e8f77

View File

@@ -246,10 +246,6 @@ 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);
taskExecutor.execute(() -> {
//公屏与飘屏消息
baseGameMessageService.sendGameMessage(String.valueOf(gameId), roomUid, uid, diamondNum, ResourceCodeEnum.BAISHUN, Constant.SysConfId.MINI_GAME_FOR_BAI_SHUN);
});
} 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));