|
@@ -402,31 +402,6 @@ public class MarketingServiceImpl extends ServiceImpl<MarketingMapper, Marketing
|
|
|
redisCache.deleteObject(userLowLotteryPool);
|
|
|
redisCache.deleteObject(insideLotteryPool);
|
|
|
|
|
|
-
|
|
|
-
|
|
|
- // 保存开奖消息
|
|
|
- // 获取所有的参与用户的用户id去重
|
|
|
- List<MarketingUserCode> sendMsgUserList = marketingUserCodeService.list(new LambdaQueryWrapper<MarketingUserCode>()
|
|
|
- .select(MarketingUserCode::getUserId)
|
|
|
- .eq(MarketingUserCode::getMarketingId, marketing.getId())
|
|
|
- .eq(MarketingUserCode::getUserType, UserTypeEnum.ORDINARY.getValue())
|
|
|
- .groupBy(MarketingUserCode::getUserId));
|
|
|
- if (CollectionUtils.isEmpty(sendMsgUserList)) {
|
|
|
- return;
|
|
|
- }
|
|
|
- List<MarketingMsg> marketingMsgList = new ArrayList<>();
|
|
|
- for (MarketingUserCode marketingUserCode : sendMsgUserList) {
|
|
|
- // 封装开奖订阅消息
|
|
|
- MarketingMsg marketingMsg = new MarketingMsg();
|
|
|
- marketingMsg.setType(1);
|
|
|
- marketingMsg.setMarketingId(marketing.getId());
|
|
|
- marketingMsg.setContext(marketing.getTitle());
|
|
|
- marketingMsg.setUserId(marketingUserCode.getUserId());
|
|
|
- marketingMsgList.add(marketingMsg);
|
|
|
- }
|
|
|
- rtn = marketingMsgService.saveBatch(marketingMsgList);
|
|
|
- Assert.isTrue(rtn, "保存活动开奖消息失败。marketingId:" + marketing.getId());
|
|
|
-
|
|
|
}
|
|
|
|
|
|
private MarketingHitPrize exchangeMarketingHitPrize(Marketing marketing, List<MarketingHitPrize> allHitPrizeList, MarketingAwards marketingAwards, List<MarketingAwardsPrize> marketingAwardsPrizeList, MarketingUserCode marketingUserCode) {
|