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

幸运礼物-mq异步结算-球球消息tip和收益需要实时

Browse Source
This commit is contained in:
khalil
2025-01-10 19:52:35 +08:00
parent a4b9d4a7bd
commit 94d7fc4b3c
2 changed files with 5 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

5
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/Lucky24GiftSendService.java
View File

@@ -143,6 +143,11 @@ public class Lucky24GiftSendService {
}
long winGoldNum = afterMultiple * everyoneGoldNum;
userMetaService.updateUserMeta(config, senderUid, partitionId, curTimes, everyoneGoldNum, winGoldNum);
if (winGoldNum > 0L){
settlementService.syncSendReward(config, senderUid, room, gift, winGoldNum, afterMultiple);
}
return recordService.buildRecord(senderUid, sender.getPartitionId(), gift, giftNum, null != room? room.getUid(): null,
receiverUid, drawResult.getPoolId(), null != supplementMultiple || Boolean.TRUE.equals(drawResult.getIsSupplement()),
drawMultiple, afterMultiple, sendGiftTime);

6
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/Lucky24MessageService.java
View File

@@ -77,12 +77,6 @@ public class Lucky24MessageService extends BaseService {
logger.info("【处理lucky24 mq】 收礼收益已发放 messId: {} incomeAllot: {}", giftMessage.getMessId(), JSON.toJSONString(receiverIncomeAllot));
if (record.getWinGoldNum() > 0L){
settlementService.syncSendReward(partitionConfig, record.getUid(), room, gift, record.getWinGoldNum(), record.getAfterMultiple());
logger.info("【处理lucky24 mq】 送礼收益已发放 messId: {} senderUid: {} winGoldNum: {} afterMultiple: {}",
giftMessage.getMessId(), record.getUid(), record.getWinGoldNum(), record.getAfterMultiple());
}
// 后面都是异步发消息
if (record.getAfterMultiple() >= config.getWarnMulti()){
long totalGoldNum = giftMessage.getGiftNum() * giftMessage.getGiftGoldPrice();