From a6f34b99ee20e528b766c8ed5a61bd9c5aa0e7ae Mon Sep 17 00:00:00 2001
From: admin <weikou2014>
Date: 星期六, 16 十一月 2019 18:10:33 +0800
Subject: [PATCH] 淘宝相似商品推荐接口优化，根据商品ID搜索商品基本信息优化
---
fanli/src/main/java/com/yeshi/fanli/service/impl/user/UserInfoModifyRecordServiceImpl.java | 37 ++++++++++++++++++++++++++++++++++---
1 files changed, 34 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 3d2a2af..8ac3017 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
@@ -6,8 +6,14 @@
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+import com.aliyun.openservices.ons.api.Message;
+import com.aliyun.openservices.ons.api.Producer;
+import com.google.gson.Gson;
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.entity.bus.user.BindingAccount;
import com.yeshi.fanli.entity.bus.user.UserExtraTaoBaoInfo;
import com.yeshi.fanli.entity.bus.user.UserInfo;
@@ -15,14 +21,15 @@
import com.yeshi.fanli.entity.bus.user.UserInfoModifyRecord;
import com.yeshi.fanli.entity.bus.user.UserInfoModifyRecord.ModifyTypeEnum;
import com.yeshi.fanli.log.LogHelper;
-import com.yeshi.fanli.service.inter.integral.IntegralGetService;
import com.yeshi.fanli.service.inter.money.extract.BindingAccountService;
-import com.yeshi.fanli.service.inter.user.UserExtraTaoBaoInfoService;
import com.yeshi.fanli.service.inter.user.UserInfoExtraService;
import com.yeshi.fanli.service.inter.user.UserInfoModifyRecordService;
import com.yeshi.fanli.service.inter.user.UserInfoService;
+import com.yeshi.fanli.service.inter.user.integral.IntegralGetService;
+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.MQTopicName;
@Service
public class UserInfoModifyRecordServiceImpl implements UserInfoModifyRecordService {
@@ -45,7 +52,11 @@
@Resource
private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;
+ @Resource(name = "producer")
+ private Producer producer;
+
@Async()
+ @Transactional
@Override
public void addModifyRecord(Long uid, ModifyTypeEnum type, String value) {
try {
@@ -81,6 +92,25 @@
record.setValue(value);
record.setCreateTime(new Date());
userInfoModifyRecordMapper.insertSelective(record);
+
+ if (oldRecord == null) {// 鏂板缓
+ // 鍙戦�佽处鍙蜂慨鏀规秷鎭�
+ UserAccountBindingMQMsg mqMsg = null;
+ if (type == ModifyTypeEnum.bindPhone) {
+ mqMsg = new UserAccountBindingMQMsg(uid, UserAccountBindingMQMsg.TYPE_PHONE, value, new Date());
+ } else if (type == ModifyTypeEnum.bindTaoBao) {
+ mqMsg = new UserAccountBindingMQMsg(uid, UserAccountBindingMQMsg.TYPE_TAOBAO, value,
+ new Date());
+ } else if (type == ModifyTypeEnum.bindWeiXin) {
+ mqMsg = new UserAccountBindingMQMsg(uid, UserAccountBindingMQMsg.TYPE_WX, value, new Date());
+ } else if (type == ModifyTypeEnum.bindAlipay) {
+ 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());
+ producer.send(message);
+ }
}
} catch (Exception e) {
e.printStackTrace();
@@ -113,7 +143,8 @@
addModifyRecord(uid, ModifyTypeEnum.bindWeiXin, user.getWxUnionId());
}
- if (user.getNickName() != null && !user.getNickName().startsWith("杩斿埄鍒�")) {
+ if (user.getNickName() != null && !user.getNickName().startsWith("杩斿埄鍒�")
+ && !user.getNickName().startsWith(Constant.systemCommonConfig.getDefaultNickName())) {
addModifyRecord(uid, ModifyTypeEnum.nickName, user.getNickName() + "");
}
--
Gitblit v1.8.0