package com.yeshi.fanli.service.impl.user;
|
|
import java.util.Date;
|
|
import javax.annotation.Resource;
|
|
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.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;
|
import com.yeshi.fanli.entity.bus.user.UserInfoExtra;
|
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.money.extract.BindingAccountService;
|
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.MQMsgBodyFactory;
|
import com.yeshi.fanli.util.rocketmq.MQTopicName;
|
|
@Service
|
public class UserInfoModifyRecordServiceImpl implements UserInfoModifyRecordService {
|
|
@Resource
|
private UserInfoModifyRecordMapper userInfoModifyRecordMapper;
|
|
@Resource
|
private IntegralGetService integralGetService;
|
|
@Resource
|
private UserInfoService userInfoService;
|
|
@Resource
|
private UserInfoExtraService userInfoExtraService;
|
|
@Resource
|
private BindingAccountService bindingAccountService;
|
|
@Resource
|
private UserExtraTaoBaoInfoService userExtraTaoBaoInfoService;
|
|
@Resource(name = "producer")
|
private Producer producer;
|
|
@Async()
|
@Transactional
|
@Override
|
public void addModifyRecord(Long uid, ModifyTypeEnum type, String value) {
|
try {
|
if (uid == null || StringUtil.isNullOrEmpty(value))
|
return;
|
|
long count = countByUid(uid, type.name());
|
if (count == 0) {
|
if (type == ModifyTypeEnum.bindPhone) {
|
integralGetService.addBindPhone(uid);
|
} else if (type == ModifyTypeEnum.bindAlipay) {
|
integralGetService.addBindAlipay(uid);
|
} else if (type == ModifyTypeEnum.bindTaoBao) {
|
integralGetService.addBindTaoBao(uid);
|
} else if (type == ModifyTypeEnum.bindWeiXin) {
|
integralGetService.addBindWeiXin(uid);
|
} else if (type == ModifyTypeEnum.gender) {
|
integralGetService.addSetGender(uid);
|
} else if (type == ModifyTypeEnum.nickName) {
|
integralGetService.addSetNickname(uid);
|
} else if (type == ModifyTypeEnum.portrait) {
|
integralGetService.addSetPortrait(uid);
|
} else if (type == ModifyTypeEnum.setWeiXinNum) {
|
integralGetService.addSetWeiXinNum(uid);
|
}
|
}
|
|
UserInfoModifyRecord oldRecord = userInfoModifyRecordMapper.selectLatestByUidAndType(uid, type.name());
|
if (oldRecord == null || !oldRecord.getValue().equalsIgnoreCase(value)) {// 不能修改重复的数据
|
UserInfoModifyRecord record = new UserInfoModifyRecord();
|
record.setUid(uid);
|
record.setType(type);
|
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 = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,
|
UserTopicTagEnum.userAccountBinding, mqMsg);
|
if (!Constant.IS_TEST)
|
producer.send(message);
|
} else {// 修改
|
UserInfoUpdateMQMsg mqMsg = null;
|
|
if (type == ModifyTypeEnum.portrait) {
|
mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.portrait, value, new Date());
|
} else if (type == ModifyTypeEnum.nickName)
|
mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.nickName, value, new Date());
|
else if (type == ModifyTypeEnum.setWeiXinNum)
|
mqMsg = new UserInfoUpdateMQMsg(uid, UserInfoUpdateTypeEnum.wxId, value, new Date());
|
|
if (mqMsg != null) {
|
Message message = MQMsgBodyFactory.create(MQTopicName.TOPIC_USER,
|
UserTopicTagEnum.userInfoUpdate, mqMsg);
|
producer.send(message);
|
}
|
}
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
LogHelper.errorDetailInfo(e);
|
}
|
}
|
|
@Override
|
public long countByUid(Long uid, String type) {
|
return userInfoModifyRecordMapper.countByUid(uid, type);
|
}
|
|
@Override
|
public void syncBeforeInfo(Long uid) {
|
// 获取用户基本信息
|
UserInfo user = userInfoService.selectByPKey(uid);
|
if (user == null || user.getState() != UserInfo.STATE_NORMAL) {// 用户不正常
|
return;
|
}
|
if (!StringUtil.isNullOrEmpty(user.getPhone())) {
|
addModifyRecord(uid, ModifyTypeEnum.bindPhone, user.getPhone());
|
}
|
|
BindingAccount account = bindingAccountService.getBindingAccountByUidAndType(uid, BindingAccount.TYPE_ALIPAY);
|
if (account != null) {
|
addModifyRecord(uid, ModifyTypeEnum.bindAlipay, account.getAccount());
|
}
|
|
if (!StringUtil.isNullOrEmpty(user.getWxUnionId())) {
|
addModifyRecord(uid, ModifyTypeEnum.bindWeiXin, user.getWxUnionId());
|
}
|
|
if (user.getNickName() != null && !user.getNickName().startsWith("返利券")
|
&& !user.getNickName().startsWith(Constant.systemCommonConfig.getDefaultNickName())) {
|
addModifyRecord(uid, ModifyTypeEnum.nickName, user.getNickName() + "");
|
}
|
|
if (!Constant.systemCommonConfig.getDefaultPortrait().equalsIgnoreCase(user.getPortrait())) {
|
addModifyRecord(uid, ModifyTypeEnum.portrait, user.getPortrait());
|
}
|
|
UserInfoExtra userInfoExtra = userInfoExtraService.getUserInfoExtra(uid);
|
if (userInfoExtra != null) {
|
if (userInfoExtra.getSex() != null)
|
addModifyRecord(uid, ModifyTypeEnum.gender, userInfoExtra.getSex() + "");
|
|
if (!StringUtil.isNullOrEmpty(userInfoExtra.getWeiXin()))
|
addModifyRecord(uid, ModifyTypeEnum.setWeiXinNum, userInfoExtra.getWeiXin());
|
}
|
|
UserExtraTaoBaoInfo taoBaoExtra = userExtraTaoBaoInfoService.getByUid(uid);
|
if (taoBaoExtra != null && !StringUtil.isNullOrEmpty(taoBaoExtra.getRelationId())
|
&& !StringUtil.isNullOrEmpty(taoBaoExtra.getSpecialId()) && taoBaoExtra.getRelationValid()
|
&& taoBaoExtra.getSpecialValid()) {
|
addModifyRecord(uid, ModifyTypeEnum.bindTaoBao, taoBaoExtra.getTaoBaoUid());
|
}
|
|
}
|
}
|
