大淘客搜索接口升级

admin

2020-11-28 dc5be7d38446f70e6ff86df311119c32b41fe7f8

 fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java

@@ -29,6 +29,7 @@
import com.yeshi.fanli.service.inter.user.UserInfoService;

import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;

import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;

import com.yeshi.fanli.service.manger.msg.RocketMQManager;

import com.yeshi.fanli.util.Constant;

import com.yeshi.fanli.util.StringUtil;

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

@@ -55,8 +56,8 @@
   @Resource

   private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;



   @Resource(name = "producer")

   private Producer producer;

   @Resource

   private RocketMQManager rocketMQManager;



   @Async()

   @Transactional

@@ -113,13 +114,21 @@
               Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,

                     UserTopicTagEnum.userAccountBinding, mqMsg);

               if (!Constant.IS_TEST)

                  producer.send(message);

                  rocketMQManager.sendNormalMsg(message, null);

            } else {// 修改

               UserInfoUpdateMQMsg mqMsg = null;



               if (type == ModifyTypeEnum.portrait) {

                  mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.portrait, value, new Date());

               } else if (type == ModifyTypeEnum.nickName)

                  mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.nickName, value, new Date());

               else if (type == ModifyTypeEnum.setWeiXinNum)

                  mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.wxId, value, new Date());



               if (mqMsg != null) {

                  Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,

                        UserTopicTagEnum.userInfoUpdate, new Gson().toJson(new UserInfoUpdateMQMsg(uid,

                              UserInfoUpdateTypeEnum.portrait, value, new Date())));

                  producer.send(message);

                        UserTopicTagEnum.userInfoUpdate, mqMsg);

                  rocketMQManager.sendNormalMsg(message, null);

               }

            }

         }