大淘客搜索接口升级

admin

2020-11-28 dc5be7d38446f70e6ff86df311119c32b41fe7f8

 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