活跃消息

yujian

2020-04-18 b803abf95ed0cc721f8f9e767283e5ac6b8ca090

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/vip/UserVIPInfoServiceImpl.java

@@ -10,9 +10,12 @@
import org.springframework.context.annotation.Lazy;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.yeshi.utils.DateUtil;



import com.aliyun.openservices.ons.api.Message;

import com.aliyun.openservices.ons.api.Producer;

import com.yeshi.fanli.dao.mybatis.user.vip.UserVIPInfoMapper;

import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;

import com.yeshi.fanli.dto.mq.user.body.UserLevelChangedMQMsg;

import com.yeshi.fanli.entity.bus.user.HongBaoV2;

import com.yeshi.fanli.entity.bus.user.UserInfoExtra;

import com.yeshi.fanli.entity.bus.user.UserInviteValidNum;

@@ -42,6 +45,8 @@
import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

import com.yeshi.fanli.util.TimeUtil;

import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;

import com.yeshi.fanli.util.rocketmq.MQTopicName;



@Service

public class UserVIPInfoServiceImpl implements UserVIPInfoService {

@@ -95,6 +100,12 @@
   

   @Resource

   private UserLevelUpgradedNotifyService userLevelUpgradedNotifyService;

	
	
   @Resource(name = "producer")

   private Producer producer;

	
	


   @Override

   @Transactional(rollbackFor = Exception.class)

@@ -259,6 +270,13 @@
      } catch (Exception e) {

         e.printStackTrace();

      }

		


      if (!Constant.IS_TEST) {

         UserLevelChangedMQMsg msg = new UserLevelChangedMQMsg(uid, UserLevelEnum.highVIP,UserLevelEnum.superVIP, new Date());

         Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userLevelChanged, msg);

         producer.send(message);

      }

   }