From 9c69eb7d1bf4c91649983da5a1af1e9ca53f7c41 Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期三, 18 十二月 2019 11:11:27 +0800
Subject: [PATCH] 邀请图片清除消息添加
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java | 13 +++++++++++--
1 files changed, 11 insertions(+), 2 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 04d098b..5fda055 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
@@ -14,6 +14,8 @@
import com.yeshi.fanli.dao.mybatis.user.UserInfoModifyRecordMapper;
import com.yeshi.fanli.dto.mq.user.UserTopicTagEnum;
import com.yeshi.fanli.dto.mq.user.body.UserAccountBindingMQMsg;
+import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg;
+import com.yeshi.fanli.dto.mq.user.body.UserInfoUpdateMQMsg.UserInfoUpdateTypeEnum;
import com.yeshi.fanli.entity.bus.user.BindingAccount;
import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo;
import com.yeshi.fanli.entity.bus.user.UserInfo;
@@ -108,9 +110,16 @@
mqMsg = new UserAccountBindingMQMsg(uid, UserAccountBindingMQMsg.TYPE_ALIPAY, value,
new Date());
}
- Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,
- UserTopicTagEnum.userAccountBinding,mqMsg);
+ Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,
+ UserTopicTagEnum.userAccountBinding, mqMsg);
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())));
+ producer.send(message);
+ }
}
}
} catch (Exception e) {
--
Gitblit v1.8.0