监听器-注销废旧活动类监听器
This commit is contained in:
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class AnnualCpRankGiftListener extends CpRankGiftListener<AnnualCpRankService> implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Async
|
||||
|
@@ -18,7 +18,7 @@ import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
import java.util.List;
|
||||
|
||||
@Component
|
||||
//@Component
|
||||
public class AnnualGiftRankGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -16,7 +16,7 @@ import org.springframework.stereotype.Component;
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
|
||||
@Component
|
||||
//@Component
|
||||
public class AnnualPopularRankGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -10,7 +10,7 @@ import org.springframework.beans.factory.annotation.Autowired;
|
||||
import org.springframework.context.ApplicationListener;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Component
|
||||
//@Component
|
||||
public class AnnualRoomRankGiftListener extends RoundRankGiftListener<AnnualRoomRankService> implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class AnnualTaskGiftListener implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Autowired
|
||||
|
@@ -7,7 +7,7 @@ import org.springframework.context.ApplicationListener;
|
||||
import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Component
|
||||
//@Component
|
||||
public class AnnualTyrantRankGiftListener extends RankGiftListener<AnnualTyrantRankService> implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Async
|
||||
|
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class ChristmasCpRankGiftListener extends CpRankGiftListener<ChristmasCpRankService> implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Async
|
||||
|
@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class ChristmasCpRewardGiftListener implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Autowired
|
||||
|
@@ -20,7 +20,7 @@ import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class ChristmasLetterTaskGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class ChristmasRankGiftListener extends RankGiftListener<ChristmasRankService> implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Async
|
||||
|
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class DoubleElevenRankGiftListener extends RankGiftListener<DoubleElevenRankService> implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Async
|
||||
|
@@ -20,7 +20,7 @@ import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class DoubleElevenTaskGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -21,7 +21,7 @@ import java.time.LocalDateTime;
|
||||
import java.time.ZoneId;
|
||||
import java.util.Date;
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class ExpBattleRankGiftListener implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Autowired
|
||||
|
@@ -21,7 +21,7 @@ import java.util.List;
|
||||
import java.util.stream.Collectors;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class HalloweenDrawBoxGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class HalloweenRankGiftListener extends RankGiftListener<HalloweenRankService> implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Async
|
||||
|
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class HalloweenTaskGiftListener extends TaskGiftListener<HalloweenTaskService> implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Override
|
||||
|
@@ -16,7 +16,7 @@ import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class LuckyProcessBarGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class MidAutumnRankGiftListener extends RankGiftListener<MidAutumnRankService> implements ApplicationListener<GiftMessageEvent>{
|
||||
|
||||
@Async
|
||||
|
@@ -9,7 +9,7 @@ import org.springframework.scheduling.annotation.Async;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class MidAutumnTaskGiftListener extends TaskGiftListener<MidAutumnTaskService> implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Override
|
||||
|
@@ -17,7 +17,7 @@ import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class QixiRankGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -15,7 +15,7 @@ import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class QixiRoomRankGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -14,7 +14,7 @@ import org.springframework.stereotype.Component;
|
||||
import java.time.LocalDateTime;
|
||||
import java.util.Date;
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class QixiXiqueGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -29,7 +29,7 @@ import java.util.List;
|
||||
* @description:
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class ValentinesCpRankGiftListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -28,7 +28,7 @@ import java.util.List;
|
||||
* @description:
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class LuckyBagCollectForAccumulateListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -34,7 +34,7 @@ import java.util.stream.Collectors;
|
||||
* @description:
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class LuckyBagCollectForLightListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -42,7 +42,7 @@ import java.util.*;
|
||||
* @description:
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
public class LuckyBagFortunateListener implements ApplicationListener<GiftMessageEvent> {
|
||||
|
||||
@Autowired
|
||||
|
@@ -68,9 +68,6 @@ public class GiftMessageService extends BaseService {
|
||||
GiftSendRecord giftSendRecord = insertGiftSendRecord(giftMessage);
|
||||
logger.info("【处理礼物mq】 giftMessageId {} 插入gift_send_record {}", giftMessage.getMessId(), JSON.toJSONString(giftSendRecord));
|
||||
|
||||
//增加送礼用户和收礼用户的财富或魅力经验
|
||||
addUserExper(giftMessage);
|
||||
|
||||
String objId = giftSendRecord.getSendRecordId().toString();
|
||||
BillObjTypeEnum inEnum = BillObjTypeEnum.GIFT_PERSON_INCOME;
|
||||
BillObjTypeEnum outEnum = BillObjTypeEnum.GIFT_PERSON_PAY;
|
||||
@@ -88,6 +85,9 @@ public class GiftMessageService extends BaseService {
|
||||
giftEarnAllotService.allotGiftEarn(giftSendRecord, objId, inEnum);
|
||||
}
|
||||
|
||||
//增加送礼用户和收礼用户的财富或魅力经验
|
||||
addUserExper(giftMessage);
|
||||
|
||||
//发布事件
|
||||
applicationContext.publishEvent(new GiftMessageEvent(giftMessage));
|
||||
applicationContext.publishEvent(new RoomPKEvent(giftMessage));
|
||||
|
@@ -57,7 +57,7 @@ public class WebMVCConfig implements WebMvcConfigurer {
|
||||
// .excludePathPatterns("/payment/mycard/**")
|
||||
// .excludePathPatterns("/payment/payermax/callback/**");
|
||||
registry.addInterceptor(getLoginInterceptor()).addPathPatterns("/**");
|
||||
registry.addInterceptor(getAppVersionInterceptor());
|
||||
//registry.addInterceptor(getAppVersionInterceptor());
|
||||
registry.addInterceptor(getModelHallAuthInterceptor());
|
||||
registry.addInterceptor(getWebInterceptor());
|
||||
registry.addInterceptor(getXssInterceptor());
|
||||
|
@@ -18,7 +18,7 @@ import org.springframework.stereotype.Component;
|
||||
* 线性奖池中奖消息
|
||||
*/
|
||||
@Slf4j
|
||||
@Component
|
||||
//@Component
|
||||
@ConditionalOnProperty(name = "spring.application.name", havingValue = "web")
|
||||
@RocketMQMessageListener(topic = MqConstant.LINEARLY_POOL_TOPIC, consumerGroup = MqConstant.LINEARLY_POOL_CONSUME_GROUP, consumeMode = ConsumeMode.ORDERLY)
|
||||
public class LinearlyPoolPrizeMessageConsumer extends AbstractMessageListener<LinearlyPoolPrizeMessage> {
|
||||
|
Reference in New Issue
Block a user