admin
2020-08-26 26f7accb815f55f18f8eedfca4324700a96884ec
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserActiveLogServiceImpl.java
@@ -17,6 +17,8 @@
import com.yeshi.fanli.service.inter.user.UserActiveLogService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserInfoRegisterService;
import com.yeshi.fanli.service.manger.msg.RocketMQManager;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
import com.yeshi.fanli.util.rocketmq.MQTopicName;
@@ -32,8 +34,8 @@
   @Resource
   private UserInfoRegisterService userInfoRegisterService;
   @Resource(name = "producer")
   private Producer producer;
   @Resource
   private RocketMQManager rocketMQManager;
   @Override
   public void addUserActiveLog(UserActiveLog userActiveLog) {
@@ -83,10 +85,14 @@
   //添加活跃消息
   private void addMQMsg(Long uid) {
      if (Constant.IS_TEST) {
         return;
      }
      UserActiveMQMsg msg = new UserActiveMQMsg(uid, new Date());
      Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userActve, msg);
      message.setStartDeliverTime(System.currentTimeMillis() + 1000 * 5L);// 5s后发送活跃消息
      producer.send(message);
      rocketMQManager.sendNormalMsg(message,  1000 * 5L, null);
   }
   @Override