yujian
2019-12-12 8c04d27e5cebb7e654c208533e9567c4df2c8acc
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java
@@ -29,6 +29,7 @@
import com.yeshi.fanli.service.inter.user.tb.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.util.Constant;
import com.yeshi.fanli.util.StringUtil;
import com.yeshi.fanli.util.rocketmq.MQMsgBodyFactory;
import com.yeshi.fanli.util.rocketmq.MQTopicName;
@Service
@@ -107,8 +108,8 @@
                  mqMsg = new UserAccountBindingMQMsg(uid, UserAccountBindingMQMsg.TYPE_ALIPAY, value,
                        new Date());
               }
               Message message = new Message(MQTopicName.TOPIC_USER.name(),
                     UserTopicTagEnum.userAccountBinding.name(), new Gson().toJson(mqMsg).getBytes());
               Message message =MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,
                     UserTopicTagEnum.userAccountBinding,mqMsg);
               producer.send(message);
            }
         }