Merge remote-tracking branch 'origin/div' into div

admin

2020-02-18 ddf5db7d31af51fcf697eac0cee7dd46ff73bcc1

 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,17 @@
                  mqMsg = new UserAccountBindingMQMsg(uid, UserAccountBindingMQMsg.TYPE_ALIPAY, value,

                        new Date());

               }

               Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,

                     UserTopicTagEnum.userAccountBinding,mqMsg);

               producer.send(message);

               Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,

                     UserTopicTagEnum.userAccountBinding, mqMsg);

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

                  producer.send(message);

               }

            }

         }

      } catch (Exception e) {