| | |
|---|
| | | 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;
|
|---|
| | |
|---|
| | | 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) {
|
|---|
