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

bravo-pool-batchGen-batchGiftNum

Browse Source
This commit is contained in:
khalil
2025-03-26 10:56:40 +08:00
parent 4b6e692f8e
commit 597258db13
2 changed files with 7 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/gift/BravoGiftSendService.java
View File

@@ -138,10 +138,11 @@ public class BravoGiftSendService {
private Map<Long, BravoRecord> drawMultiple(BravoGiftConfig config, Long senderUid, int partitionId, Gift gift, int everyGiftNum, BigDecimal everyInput,
BigDecimal divisor, int multipleGiftNum, List<Long> receiverList, Room room, Date sendGiftTime){
int batchGiftNum = receiverList.size() * multipleGiftNum;
return receiverList.parallelStream()
.collect(Collectors.toMap(receiverUid-> receiverUid,
receiverUid-> drawMultiple(config, senderUid, partitionId, gift, everyGiftNum,
receiverUid, everyInput, divisor, multipleGiftNum, room, sendGiftTime)));
receiverUid, everyInput, divisor, multipleGiftNum, batchGiftNum, room, sendGiftTime)));
}
private void sendMq(Map<Long, BravoRecord> recordMap, SuperLuckyGiftIncomeAllot incomeAllot) {
@@ -212,8 +213,9 @@ public class BravoGiftSendService {
}
public BravoRecord drawMultiple(BravoGiftConfig config, long senderUid, int partitionId,
Gift gift, int giftNum, long receiverUid, BigDecimal totalInput, BigDecimal divisor, int multipleGiftNum, Room room, Date sendGiftTime) {
List<BravoResult> drawResultList = poolService.drawMultipleFromPool(config, senderUid, partitionId, multipleGiftNum);
Gift gift, int giftNum, long receiverUid, BigDecimal totalInput, BigDecimal divisor,
int multipleGiftNum, int batchGiftNum, Room room, Date sendGiftTime) {
List<BravoResult> drawResultList = poolService.drawMultipleFromPool(config, senderUid, partitionId, multipleGiftNum, batchGiftNum);
return updateMeta(senderUid, partitionId, gift, giftNum, receiverUid, totalInput, divisor, multipleGiftNum, room, sendGiftTime, drawResultList);
}

4
accompany-business/accompany-business-service/src/main/java/com/accompany/business/service/lucky/BravoPoolService.java
View File

@@ -36,7 +36,7 @@ public class BravoPoolService {
private BravoPoolMapper bravoPoolMapper;
public List<BravoResult> drawMultipleFromPool(BravoGiftConfig config, Long uid, int partitionId,
int multipleGiftNum){
int multipleGiftNum, int batchGiftNum){
RQueue<BravoResult> userPool = getUserPool(uid);
int thisNum = multipleGiftNum;
List<BravoResult> resultList = new ArrayList<>(multipleGiftNum);
@@ -51,7 +51,7 @@ public class BravoPoolService {
return resultList;
}
}
int poolNum = thisNum / config.getPoolSize() + 1;
int poolNum = batchGiftNum / config.getPoolSize() + 1;
genPool(config, uid, partitionId, userPool, poolNum);
}
//还回去