From 708dd9eadab07345778314db57ab98cbdc77998d Mon Sep 17 00:00:00 2001 From: admin <weikou2014> Date: 星期四, 30 四月 2020 11:55:37 +0800 Subject: [PATCH] 爬单重复消息bug修改,商品详情过滤大淘客推荐语 --- fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java | 7 ++++--- 1 files changed, 4 insertions(+), 3 deletions(-) diff --git a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java index 5fda055..e63aecd 100644 --- a/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java +++ b/fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java @@ -112,12 +112,13 @@ } Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, UserTopicTagEnum.userAccountBinding, mqMsg); - producer.send(message); + if (!Constant.IS_TEST) + producer.send(message); } else {// 淇敼 if (type == ModifyTypeEnum.portrait) { Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER, - UserTopicTagEnum.userInfoUpdate, new Gson().toJson(new UserInfoUpdateMQMsg(uid, - UserInfoUpdateTypeEnum.portrait, value, new Date()))); + UserTopicTagEnum.userInfoUpdate,new UserInfoUpdateMQMsg(uid, + UserInfoUpdateTypeEnum.portrait, value, new Date())); producer.send(message); } } -- Gitblit v1.8.0