package com.hx.phip.service.impl;
|
|
import javax.annotation.Resource;
|
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.hx.common.service.CommonService;
|
import com.hx.phiappt.common.PlatformConstants;
|
import com.hx.phiappt.common.UserChannelType;
|
import com.hx.phiappt.common.UserStatusConstants;
|
import com.hx.phiappt.constants.tool.UserInfoTool;
|
import com.hx.phiappt.constants.tool.UserStatusTool;
|
import com.hx.phiappt.constants.tool.user.UserAgeTool;
|
import com.hx.phiappt.constants.tool.user.UserRegisterRecordTool;
|
import com.hx.phiappt.constants.tool.user.UserLevelTool;
|
import com.hx.phiappt.dao.mapper.GzhFocusRecordMapper;
|
import com.hx.phiappt.dao.mapper.TransferRecordMapper;
|
import com.hx.phiappt.dto.label.UserLabelDcpAddDto;
|
import com.hx.phiappt.dto.label.UserLabelDcpDto;
|
import com.hx.phiappt.dto.userPretriage.UserPretriageInfoDto;
|
import com.hx.phiappt.model.*;
|
import com.hx.phiappt.model.channels.Channels;
|
import com.hx.phiappt.model.memberLevel.MemberLevel;
|
import com.hx.phiappt.model.user.UserWakeUpLog;
|
import com.hx.phiappt.model.userLevel.UserLevelRecord;
|
import com.hx.phiappt.model.userLevel.UserLevelRule;
|
import com.hx.phiappt.model.userStatus.UserStatusLog;
|
import com.hx.phiappt.model.wechat.gzh.GzhFocusRecord;
|
import com.hx.phiappt.util.UserPretriageAdminMpTool;
|
import com.hx.phiappt.vo.wechat.GzhUnionDto;
|
import com.hx.phip.config.CustomParameter;
|
import com.hx.phip.config.FeignRequestInterceptor;
|
import com.hx.phip.config.GlobalExceptionHandler;
|
import com.hx.phip.dao.mapper.*;
|
import com.hx.phip.entity.user.UserDto;
|
import com.hx.phip.service.SystemParameterService;
|
import com.hx.phip.service.UserUnionHisService;
|
import com.hx.resultTool.Result;
|
import com.hx.util.DateUtil;
|
import com.hx.util.HttpUtil;
|
import com.hx.util.SimpleTool;
|
import com.hx.util.StringUtils;
|
import com.hx.util.mysql.aes.MysqlHexAesTool;
|
import com.hz.his.dto.dcp.UserTagInfoDto;
|
import com.hz.his.dto.token.GetTokenDto;
|
import com.hz.his.dto.user.UserParamDto;
|
import com.hz.his.dto.user.usercompleteInfo.UserInfoCompleteDto;
|
import com.hz.his.feign.service.dcp.SUserTagInfoService;
|
import com.hz.his.feign.service.platform.SWxTokenService;
|
import com.hz.his.feign.service.sync.SyncUserService;
|
import com.platform.exception.PlatTipsException;
|
import com.platform.resultTool.PlatformCode;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import com.hx.exception.TipsException;
|
import com.hx.phip.service.UserService;
|
import com.hx.mybatisTool.SqlSentence;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
|
import java.math.BigDecimal;
|
import java.util.*;
|
import java.util.stream.Collectors;
|
|
@Transactional
|
@Service
|
public class UserServiceImpl implements UserService {
|
|
//log4j日志
|
private static final Logger logger = LoggerFactory.getLogger(UserServiceImpl.class.getName());
|
|
@Resource
|
protected CommonService commonService;
|
@Resource
|
private ShopMapper shopMapper;
|
@Resource
|
private UserMapper userMapper;
|
@Resource
|
private EmployeeMapper employeeMapper;
|
@Resource
|
private CustomParameter customParameter;
|
@Resource
|
private UserInfoMapper userInfoMapper;
|
@Resource
|
private UserPhoneBookMapper userPhoneBookMapper;
|
@Resource
|
private UserAddressBookMapper userAddressBookMapper;
|
@Resource
|
private UserGeneralLabelMapper userGeneralLabelMapper;
|
|
@Resource
|
private UserInterestsMapper userInterestsMapper;
|
@Resource
|
private UserContactInformationMapper userContactInformationMapper;
|
@Resource
|
private UserUnionHisService userUnionHisService;
|
@Resource
|
private UserMoneyMapper userMoneyMapper;
|
@Resource
|
private UserUpdateLogMapper userUpdateLogMapper;
|
@Resource
|
private SyncUserService syncUserService;
|
@Resource
|
private SystemParameterService systemParameterService;
|
@Resource
|
private UserWakeUpLogMapper userWakeUpLogMapper;
|
@Resource
|
private FamiliesRoomMapper familiesRoomMapper;
|
@Resource
|
private UserFamiliesRoomMapper userFamiliesRoomMapper;
|
@Resource
|
private SUserTagInfoService sUserTagInfoService;
|
|
|
/**查询列表*/
|
@Override
|
public List<User> selectList(SqlSentence sqlSentence) {
|
return userMapper.selectList(sqlSentence);
|
}
|
|
/**查询列表*/
|
@Override
|
public List<Map<String,Object>> selectListMap(SqlSentence sqlSentence) {
|
return userMapper.selectListMap(sqlSentence);
|
}
|
|
/**查询单个*/
|
@Override
|
public User selectOne(SqlSentence sqlSentence) {
|
return userMapper.selectOne(sqlSentence);
|
}
|
|
/**
|
* 校验电话号码
|
* @param object 电话号码
|
* @return 返回
|
*/
|
@Override
|
public List<User> selectOneByTel(Object object) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> sqlValue = new HashMap<>();
|
String sql = "select * from user WHERE tel = #{m.tel} and isDel = #{m.isDel}";
|
sqlValue.put("isDel", BaseEntity.NO);
|
sqlValue.put("tel", object);
|
sqlSentence.sqlSentence(sql,sqlValue);
|
return userMapper.selectList(sqlSentence);
|
}
|
|
/**查询单个*/
|
@Override
|
public Map<String,Object> selectOneMap(SqlSentence sqlSentence) {
|
return userMapper.selectOneMap(sqlSentence);
|
}
|
|
/**查询单个，大数据不拿取*/
|
@Override
|
public User selectOneByKey(Object object) {
|
return userMapper.selectOneByKey(object);
|
}
|
|
/**查询单个，大数据拿取*/
|
@Override
|
public User selectOneByKeyBlob(Object object) {
|
return userMapper.selectOneByKeyBlob(object);
|
}
|
|
/**新增*/
|
@Override
|
public void insert(User user) {
|
int count = userMapper.insert(user);
|
if(count != 1) {
|
throw new TipsException("新增失败！");
|
}
|
}
|
|
/**修改*/
|
@Override
|
public void updateAll(User user) {
|
int count = userMapper.updateAll(user);
|
if(count!=1) {
|
throw new TipsException("保存失败！");
|
}
|
}
|
|
/**修改*/
|
@Override
|
public void updateWhere(SqlSentence sqlSentence) {
|
int count = userMapper.updateWhere(sqlSentence);
|
if(count!=1) {
|
throw new TipsException("保存失败！");
|
}
|
}
|
|
/**删除一个*/
|
@Override
|
public void deleteOne(String delId) {
|
int count = userMapper.deleteById(delId);
|
if(count!=1) {
|
throw new TipsException("删除失败！");
|
}
|
}
|
|
/**查询条数*/
|
@Override
|
public int selectCount(SqlSentence sqlSentence) {
|
int count = userMapper.selectCount(sqlSentence);
|
return count;
|
}
|
|
/**新增*/
|
@Override
|
public synchronized String insertInfo(UserDto userDto,String appId) {
|
// 20230105 荣爷说:新增，修改客户，同步领键的时候，“所属tmk”字段分别赋值给领键的“电网咨询师”和“所属客服”字段
|
userDto.setChatCorpUserId(userDto.getInternetCorpUserId());
|
// 用户对象
|
User user = new User();
|
// 处理用户对象
|
user.setName(userDto.getName());
|
user.setImgUrl(userDto.getImgUrl());
|
// 默认新建会员为准会员
|
if (!StringUtils.isEmpty(userDto.getUserLevel())) {
|
user.setUserLevel(userDto.getUserLevel());
|
} else {
|
user.setUserLevel("普卡");
|
// 获取默认会员等级
|
MemberLevel memberLevel = UserInfoTool.getMemberLevelByHisNo(commonService, null);
|
if (memberLevel != null) {
|
user.setMemberLevelId(memberLevel.getId());
|
user.setUserLevel(memberLevel.getName());
|
}
|
}
|
user.setStarLevel(userDto.getStarLevel());
|
user.setUserType(userDto.getUserType());
|
user.setChannelCategory(userDto.getChannelCategory());
|
user.setChannelId(userDto.getChannelId());
|
user.setChannelType(userDto.getChannelType());
|
user.setChannel2Id(userDto.getChannel2Id());
|
user.setChannelType2(userDto.getChannelType2());
|
// 获取冗余渠道信息
|
if (!StringUtils.isEmpty(userDto.getChannel2Id())){
|
String channelInfo = UserInfoTool.getChannelInfo(commonService, userDto.getChannel2Id());
|
user.setChannelInfo(channelInfo);
|
}
|
user.setChannelAssistId(userDto.getChannelAssistId());
|
user.setChannelAssistName(userDto.getChannelAssistName());
|
user.setChannelAssist2Id(userDto.getChannelAssist2Id());
|
user.setChannelAssist2Name(userDto.getChannelAssist2Name());
|
// 获取冗余副渠道信息
|
if (!StringUtils.isEmpty(userDto.getChannelAssist2Id())){
|
String channelInfo = UserInfoTool.getChannelInfo(commonService, userDto.getChannelAssist2Id());
|
user.setChannelAssist2Json(channelInfo);
|
}
|
user.setQQ(userDto.getQQ());
|
user.setGender(userDto.getGender());
|
user.setCIQ(userDto.getCIQ());
|
user.setTel(userDto.getTel());
|
user.setRemark(userDto.getRemark());
|
//user.setMoney(userDto.getMoney());
|
user.setLastDoctorId(userDto.getLastDoctorId());
|
user.setLastCorpUserId(userDto.getLastCorpUserId());
|
user.setCertificateType(userDto.getCertificateType());
|
user.setCertificateNo(userDto.getCertificateNo());
|
user.setBirthDay(userDto.getBirthDay());
|
user.setCorpUserId(userDto.getCorpUserId());
|
//user.setApiId(userDto.getApiId());
|
user.setHisCorpUserId(userDto.getHisCorpUserId());
|
user.setShopId(userDto.getShopId());
|
|
// 生成会员号 废弃
|
/*String memberNO = UserInfoTool.getCreateMemberNO(commonService, null);
|
user.setMemberNO(memberNO);*/
|
// 生成CIQ 要把CIQ和客户唯一编号融合 禅道:933
|
String ciqNo = systemParameterService.createCIQNo(userDto.getShopId());
|
user.setCIQ(ciqNo);
|
user.setMemberNO(ciqNo);
|
|
user.setUserRole(userDto.getUserRole());
|
user.setPinyinCode(userDto.getPinyinCode());
|
user.setCustomerDeveloperId(userDto.getCustomerDeveloperId());
|
user.setInternetCorpUserId(userDto.getInternetCorpUserId());
|
user.setBeauticianCorpUserId(userDto.getBeauticianCorpUserId());
|
user.setChatCorpUserId(userDto.getChatCorpUserId());
|
user.setConsultCorpUserId(userDto.getConsultCorpUserId());
|
user.setShareCustomer(userDto.getShareCustomer());
|
user.setNurseCorpUserId(userDto.getNurseCorpUserId());
|
user.setDoctorCorpUserId(userDto.getDoctorCorpUserId());
|
user.setConsultBelonging(userDto.getConsultBelonging());
|
user.setAppId(appId);
|
user.setInviteeId(userDto.getInviteeId());
|
user.setCreatePersonType(BaseEntity.NO);
|
user.setCreatePersonId(userDto.getCreatePersonId());
|
user.setCreatePersonName(userDto.getCreatePersonName());
|
// 处理下用户渠道信息
|
UserInfoTool.handlerChanelInfo(commonService, user);
|
// 添加用户
|
int count = userMapper.insert(user);
|
if (count != 1) {
|
throw new TipsException("新增失败！");
|
} else {
|
// 处理用户信息
|
UserInfo userInfo = new UserInfo();
|
userInfo.setUserId(user.getId());
|
userInfo.setCountryTypeName(userDto.getCountryTypeName());
|
userInfo.setLanguageTypeName(userDto.getLanguageTypeName());
|
userInfo.setYear(userDto.getYear());
|
userInfo.setConstellationTypeName(userDto.getConstellationTypeName());
|
userInfo.setNationalityTypeName(userDto.getNationalityTypeName());
|
userInfo.setProfessionTypeName(userDto.getProfessionTypeName());
|
userInfo.setIncomeTypeName(userDto.getIncomeTypeName());
|
userInfo.setMarriageTypeName(userDto.getMarriageTypeName());
|
userInfo.setGrowthTypeName(userDto.getGrowthTypeName());
|
userInfo.setNativePlaceTypeName(userDto.getNativePlaceTypeName());
|
userInfo.setUnitName(userDto.getUnitName());
|
userInfo.setIsHaveCar(userDto.getIsHaveCar());
|
userInfo.setCarNumber(userDto.getCarNumber());
|
userInfo.setAllergyLabel(userDto.getAllergyLabel());
|
|
|
int userInfoCount = userInfoMapper.insert(userInfo);
|
if (userInfoCount != 1) {
|
throw new TipsException("新增用户信息失败！");
|
}
|
|
//保存平台来源信息-cjh-2022-04-19
|
userUnionHisService.insertUnion(user.getId(), userDto.getUserUnion());
|
|
// 处理用户联系信息
|
UserContactInformation userContactInformation = new UserContactInformation();
|
userContactInformation.setUserId(user.getId());
|
userContactInformation.setQQ(userDto.getQQ());
|
userContactInformation.setEmail(userDto.getEmail());
|
userContactInformation.setMerchantNo(userDto.getMerchantNo());
|
userContactInformation.setTelPhone(userDto.getTelPhone());
|
userContactInformation.setWechat(userDto.getWechat());
|
userContactInformation.setLine(userDto.getLine());
|
userContactInformation.setContactType(userDto.getContactType());
|
int userContactInsert = userContactInformationMapper.insert(userContactInformation);
|
if (userContactInsert != 1) {
|
throw new TipsException("新增用户联系信息失败！");
|
}
|
|
// 处理新增用户是否触发赠送增值金接口
|
/* if(!StringUtils.isEmpty(userDto.getBirthDay())){
|
Calendar calendar=Calendar.getInstance();
|
String year = String.valueOf(calendar.get(Calendar.YEAR));
|
String month= BirthdayValueAddedFundTool.handleMonth(calendar.get(Calendar.MONTH)+1);
|
if(userDto.getBirthDay().indexOf("-"+month+"-")!=-1){
|
BirthdayValueAddedFundTool.handleUserMoney(user,year);
|
}
|
}*/
|
// 处理用户兴趣标签
|
List<UserInterests> userInterestsList = JSONArray.parseArray(userDto.getUserInterestsJson(), UserInterests.class);
|
if (userInterestsList != null) {
|
userInterestsList.forEach(userInterests -> {
|
userInterests.setUserId(user.getId());
|
int insertUserInterests = userInterestsMapper.insert(userInterests);
|
if (insertUserInterests != 1) {
|
throw new TipsException("新增用户标签信息失败！");
|
}
|
});
|
}
|
|
// 刷新下用户信息
|
User checkUser = userMapper.selectOneByKey(user.getId());
|
// 处理用户电话簿信息
|
List<UserPhoneBook> userPhoneBookList = JSONArray.parseArray(userDto.getPhoneBooksJson(), UserPhoneBook.class);
|
if (userPhoneBookList == null || userPhoneBookList.size() <= 0) {
|
userPhoneBookList = new ArrayList<>();
|
// 主号码处理
|
if (!StringUtils.isEmpty(checkUser.getTel())) {
|
UserPhoneBook primary = new UserPhoneBook();
|
primary.setUserId(checkUser.getId());
|
primary.setTel(checkUser.getTel());
|
primary.setIsPrimary(BaseEntity.YES);
|
userPhoneBookList.add(primary);
|
}
|
}
|
// 处理电话簿号码
|
userPhoneBookList.forEach(userPhoneBook -> {
|
// 电话号码不为空才添加
|
if (!StringUtils.isEmpty(userPhoneBook.getTel())) {
|
if (userPhoneBook.getTel().contains("****")) {
|
throw new TipsException("手机号码格式请检查,不能是加密号码！");
|
}
|
|
// 判断主要号码
|
if (!userPhoneBook.getTel().equals(user.getTel())) {
|
List<User> userList = this.selectOneByTel(userPhoneBook.getTel());
|
if (userList != null && userList.size() > 0) {
|
throw new TipsException(String.format("电话号码：%s,手机号码已有其他客户使用!", userPhoneBook.getTel()));
|
}
|
}
|
|
// 判断次要号码
|
UserPhoneBook checkUserPhoneBook = UserInfoTool.selectOneByTelOtherUser(commonService, userPhoneBook.getAreaCode(), userPhoneBook.getTel(), user.getId());
|
if (checkUserPhoneBook != null) {
|
throw new TipsException(String.format("电话号码：%s,手机号码已有其他客户使用！", userPhoneBook.getTel()));
|
}
|
|
// 新增加电话簿号码
|
userPhoneBook.setUserId(user.getId());
|
int insertUserPhoneBook = userPhoneBookMapper.insert(userPhoneBook);
|
if (insertUserPhoneBook != 1) {
|
throw new TipsException("新增用户次要手机号码失败！");
|
}
|
|
// 判断主要号码 更新用户信息主号码 改其他方式处理
|
/*if (BaseEntity.YES.equals(userPhoneBook.getIsPrimary())) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValue = new HashMap<>();
|
String sql = " tel = #{m.tel} WHERE id = #{m.userId}";
|
sqlValue.put("userId", userPhoneBook.getUserId());
|
sqlValue.put("tel", userPhoneBook.getTel());
|
sqlSentence.sqlSentence(sql, sqlValue);
|
int i = userMapper.updateWhere(sqlSentence);
|
if (i != 1) {
|
throw new TipsException("更新用户主号码失败！");
|
}
|
}*/
|
}
|
});
|
|
// 处理用户地址
|
List<UserAddressBook> userAddressBookList = JSONArray.parseArray(userDto.getAddressJson(), UserAddressBook.class);
|
if (userAddressBookList != null) {
|
userAddressBookList.forEach(userAddressBook -> {
|
if (!StringUtils.isEmpty(userAddressBook.getCountry())) {
|
userAddressBook.setUserId(user.getId());
|
int insertUserAddressBook = userAddressBookMapper.insert(userAddressBook);
|
if (insertUserAddressBook != 1) {
|
throw new TipsException("新增用户地址信息失败！");
|
}
|
}
|
});
|
}
|
|
// 处理用户标签
|
List<UserGeneralLabel> userGeneralLabelList = JSONArray.parseArray(userDto.getImpressionLabelJson(), UserGeneralLabel.class);
|
if (userGeneralLabelList != null) {
|
userGeneralLabelList.forEach(userGeneralLabel -> {
|
userGeneralLabel.setUserId(user.getId());
|
userGeneralLabel.setType(UserGeneralLabel.TYPE_IMPRESSION_LABEL);
|
int insertUserGeneralLabel = userGeneralLabelMapper.insert(userGeneralLabel);
|
if (insertUserGeneralLabel != 1) {
|
throw new TipsException("新增用户标签信息失败！");
|
}
|
});
|
}
|
}
|
// 关闭同步领建代码
|
/*//处理门店信息
|
String hisShopId = "";
|
if (!StringUtils.isEmpty(userDto.getShopId())) {
|
Shop shop = commonService.selectOneByKey(ShopMapper.class, userDto.getShopId());
|
if (shop == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "门店标识错误,门店信息不存在！");
|
}
|
if (shop.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his门店信息不存在！");
|
}
|
hisShopId = shop.getApiId();
|
|
}
|
//处理所属顾问信息
|
String consultantId = "";
|
if (!StringUtils.isEmpty(userDto.getHisCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getHisCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属顾问标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his顾问信息不存在！");
|
}
|
consultantId = employee.getApiId();
|
|
}
|
//处理所属医生信息
|
String doctorId = "";
|
if (!StringUtils.isEmpty(userDto.getDoctorCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getDoctorCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属医生标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his医生信息不存在！");
|
}
|
doctorId = employee.getApiId();
|
}
|
//处理所属美容师信息
|
String beauticianId = "";
|
if (!StringUtils.isEmpty(userDto.getBeauticianCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getBeauticianCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属美容师标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his美容师信息不存在！");
|
}
|
beauticianId = employee.getApiId();
|
}
|
//处理所属客服信息
|
String customerServiceId = "";
|
if (!StringUtils.isEmpty(userDto.getChatCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getChatCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属客服标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his客服信息不存在！");
|
}
|
customerServiceId = employee.getApiId();
|
}
|
//处理所属电网咨询师信息
|
String serviceConsultantId = "";
|
if (!StringUtils.isEmpty(userDto.getInternetCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getInternetCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属电网咨询师标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his电网咨询师信息不存在！");
|
}
|
serviceConsultantId = employee.getApiId();
|
}*/
|
//处理用户资金
|
Map<String, Object> sqlMap = new HashMap<>();
|
sqlMap.put("isDel", BaseEntity.NO);
|
sqlMap.put("userId", user.getId());
|
SqlSentence sqlSentence = new SqlSentence();
|
sqlSentence.sqlSentence(" SELECT * FROM user_money WHERE isDel = #{m.isDel} AND userId = #{m.userId}", sqlMap);
|
UserMoney userMoney = userMoneyMapper.selectOne(sqlSentence);
|
if (userMoney == null) {
|
userMoney = new UserMoney();
|
userMoney.setUserId(user.getId());
|
userMoney.setValueAddedFund(MysqlHexAesTool.encryptData("0", customParameter.getAesFixedKey(), null));
|
userMoney.setStoredValueFund(MysqlHexAesTool.encryptData("0", customParameter.getAesFixedKey(), null));
|
userMoney.setDeposit(MysqlHexAesTool.encryptData("0", customParameter.getAesFixedKey(), null));
|
userMoney.setIntegral(MysqlHexAesTool.encryptData("0", customParameter.getAesFixedKey(), null));
|
if (userMoneyMapper.insert(userMoney) != 1) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "初始化用户资金信息错误!");
|
}
|
}
|
|
// 添加用户日志
|
JSONArray logArray = new JSONArray();
|
// 创建客户的时候,记录变更日志时,同时记录选择的所属顾问和所属tmk,所属门店
|
if (!StringUtils.isEmpty(userDto.getHisCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "添加所属顾问");
|
jsonObject.put("before", "无");
|
Employee after = employeeMapper.selectOneByKey(userDto.getHisCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
} else {
|
jsonObject.put("after", String.format("找不到员工信息,员工id：%s", userDto.getHisCorpUserId()));
|
}
|
logArray.add(jsonObject);
|
}
|
if (!StringUtils.isEmpty(userDto.getInternetCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "添加所属TMK");
|
jsonObject.put("before", "无");
|
Employee after = employeeMapper.selectOneByKey(userDto.getInternetCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
} else {
|
jsonObject.put("after", String.format("找不到员工信息,员工id：%s", userDto.getInternetCorpUserId()));
|
}
|
logArray.add(jsonObject);
|
}
|
if (!StringUtils.isEmpty(userDto.getShopId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "添加所属门店");
|
jsonObject.put("before", "无");
|
Shop after = shopMapper.selectOneByKey(userDto.getShopId());
|
if (after != null) {
|
jsonObject.put("after", after.getName());
|
} else {
|
jsonObject.put("after", String.format("找不到门店信息,门店id：%s", userDto.getShopId()));
|
}
|
logArray.add(jsonObject);
|
}
|
// 获取操作员工名称
|
JSONObject jsonObjectData = new JSONObject();
|
Employee opEmployee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getCreatePersonId());
|
String name = opEmployee != null ? opEmployee.getCnName() : "";
|
jsonObjectData.put("key", String.format("【%s】员工在【%s】创建Phis平台客户账户", name, PlatformConstants.getName(userDto.getAppIdCode())));
|
logArray.add(jsonObjectData);
|
// 记录编号
|
String recordNo = UserInfoTool.createUSLGNo(commonService, user.getId(), user.getCIQ());
|
// 调用工具类处理
|
UserInfoTool.addUserUpdateLog(commonService, userDto.getAppIdCode(), user, userDto.getShopId(), userDto.getCreatePersonId(), null, null, "创建账户", logArray, null, recordNo);
|
|
// 处理用户登记记录
|
UserRegisterRecordTool.handlerUserRegisterRecord(commonService, user.getId(), userDto.getAppIdCode(), BaseEntity.NO);
|
|
//处理新增或者更新用户初诊卡
|
if(userDto.getUserPretriageInfoDto()!= null){
|
UserPretriageInfoDto userPretriageInfoDto = userDto.getUserPretriageInfoDto();
|
userPretriageInfoDto.setUserId(user.getId());
|
UserPretriageAdminMpTool.insertOrEditPretriageInfo(userPretriageInfoDto,commonService);
|
}
|
// 切换领建屏蔽代码 date:20230108
|
/*// 同步用户到his系统 注释 正式区在开放
|
String returnHisData;
|
// 构建请求his同步请求参数
|
JSONObject jsonObject = buildSyncUserHisData(user, hisShopId, consultantId, doctorId, beauticianId, customerServiceId, serviceConsultantId, userDto.getRemark(), BaseEntity.NO);
|
try {
|
jsonObject.put("appIdCode", userDto.getAppIdCode());
|
returnHisData = ApiPlatformUtil.syncHisUser(customParameter, userDto.getAppIdCode(), jsonObject.toJSONString());
|
} catch (Exception ex) {
|
logger.error("同步用户到his系统出现失败！错误消息：", ex);
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "同步用户到his系统出现失败！");
|
}
|
if (!StringUtils.isEmpty(returnHisData)) {
|
JSONObject jsonHisObject = JSONObject.parseObject(returnHisData);
|
if (jsonHisObject != null) {
|
String code = jsonHisObject.getString("code");
|
if ("100".equals(code)) {
|
String apiId = jsonHisObject.getString("data");
|
if (!StringUtils.isEmpty(apiId)) {
|
if (apiId.contains("Internal Server Error")) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "同步用户到his系统失败！");
|
}
|
this.updateUserApiId(user.getId(), apiId);
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "同步用户到his系统获取hisId失败！");
|
}
|
} else {
|
String error = jsonHisObject.getString("msg");
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "同步his用户信息失败! 返回错误消息:" + error);
|
}
|
}
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "同步his用户信息失败! 返回为空消息！");
|
}*/
|
return user.getId();
|
}
|
|
/**编辑*/
|
@Override
|
public synchronized void updateInfo(User user, UserDto userDto) {
|
// 20230105 荣爷说:新增，修改客户，同步领键的时候，“所属tmk”字段分别赋值给领键的“电网咨询师”和“所属客服”字段
|
userDto.setChatCorpUserId(userDto.getInternetCorpUserId());
|
//转诊
|
turnTreat(user,userDto);
|
JSONArray logArray = new JSONArray();
|
// 处理用户对象
|
if (!StringUtils.isEmpty(userDto.getName())) {
|
if (!userDto.getName().equals(user.getName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改姓名");
|
jsonObject.put("before", user.getName());
|
jsonObject.put("after", userDto.getName());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setName(userDto.getName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getImgUrl())) {
|
if (!userDto.getImgUrl().equals(user.getImgUrl())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改头像");
|
jsonObject.put("before", user.getImgUrl());
|
jsonObject.put("after", userDto.getImgUrl());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setImgUrl(userDto.getImgUrl());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getUserLevel())) {
|
if (!userDto.getUserLevel().equals(user.getUserLevel())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户等级");
|
jsonObject.put("before", user.getUserLevel());
|
jsonObject.put("after", userDto.getUserLevel());
|
logArray.add(jsonObject);
|
// 获取等级配置信息
|
UserLevelRule userLevelRule = UserLevelTool.getUserLevelRuleByName(commonService, userDto.getUserLevel());
|
// 添加会员等级记录
|
UserLevelTool.addUserLevelRecord(commonService, user, userLevelRule, null, userDto.getOpId());
|
// 修改数据
|
user.setUserLevel(userDto.getUserLevel());
|
user.setMemberLevelId(userLevelRule.getMemberLevelId());
|
}
|
}
|
if (userDto.getStarLevel() != null) {
|
if (!userDto.getStarLevel().equals(user.getStarLevel())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户星级");
|
jsonObject.put("before", user.getStarLevel());
|
jsonObject.put("after", userDto.getStarLevel());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setStarLevel(userDto.getStarLevel());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getUserType())) {
|
if (!userDto.getUserType().equals(user.getUserType())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户类型");
|
jsonObject.put("before", user.getUserType());
|
jsonObject.put("after", userDto.getUserType());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setUserType(userDto.getUserType());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getTel())) {
|
// 先删除电话薄的子号码
|
UserInfoTool.deleteUserPhoneBookTel(commonService, user.getTel(), user.getId());
|
if (!StringUtils.isEmpty(userDto.getTel())) {
|
if (!userDto.getTel().equals(user.getTel())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改手机号码");
|
jsonObject.put("before", user.getTel());
|
jsonObject.put("after", userDto.getTel());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setTel(userDto.getTel());
|
}
|
}
|
}
|
// 渠道处理
|
if (!StringUtils.isEmpty(userDto.getChannelId()) && !StringUtils.isEmpty(userDto.getChannel2Id())) {
|
// 用户所属信息变更记录
|
String beCommonId = String.format("%s/%s", user.getChannelId(), user.getChannel2Id());
|
String commonId = String.format("%s/%s", userDto.getChannelId(), userDto.getChannel2Id());
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_CHANNEL, beCommonId, commonId, userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
}
|
if (!StringUtils.isEmpty(userDto.getChannelId()) && !StringUtils.isEmpty(userDto.getChannelType())) {
|
if (!userDto.getChannelType().equals(user.getChannelType())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户一级渠道");
|
jsonObject.put("before", user.getChannelType());
|
jsonObject.put("after", userDto.getChannelType());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setChannelId(userDto.getChannelId());
|
user.setChannelType(userDto.getChannelType());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getChannel2Id()) && !StringUtils.isEmpty(userDto.getChannelType2())) {
|
if (!userDto.getChannelType2().equals(user.getChannelType2())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户二级渠道");
|
jsonObject.put("before", user.getChannelType2());
|
jsonObject.put("after", userDto.getChannelType2());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setChannel2Id(userDto.getChannel2Id());
|
user.setChannelType2(userDto.getChannelType2());
|
// 获取冗余渠道信息
|
String channelInfo = UserInfoTool.getChannelInfo(commonService, userDto.getChannel2Id());
|
user.setChannelInfo(channelInfo);
|
}
|
}
|
// 副渠道处理
|
if (!StringUtils.isEmpty(userDto.getChannelAssistId()) && !StringUtils.isEmpty(userDto.getChannelAssist2Id())) {
|
// 用户所属信息变更记录
|
String beCommonId = String.format("%s/%s", user.getChannelAssistId(), user.getChannelAssist2Id());
|
String commonId = String.format("%s/%s", userDto.getChannelAssistId(), userDto.getChannelAssist2Id());
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_CHANNEL_ASSIST, beCommonId, commonId, userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
}
|
if(!StringUtils.isEmpty(userDto.getChannelAssistId()) && !StringUtils.isEmpty(userDto.getChannelAssistName())) {
|
if (!userDto.getChannelAssistName().equals(user.getChannelAssistName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户一级副渠道");
|
jsonObject.put("before", user.getChannelAssistName());
|
jsonObject.put("after", userDto.getChannelAssistName());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setChannelAssistId(userDto.getChannelAssistId());
|
user.setChannelAssistName(userDto.getChannelAssistName());
|
}
|
}
|
if(!StringUtils.isEmpty(userDto.getChannelAssist2Id()) && !StringUtils.isEmpty(userDto.getChannelAssist2Name())) {
|
if (!userDto.getChannelAssist2Name().equals(user.getChannelAssist2Name())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户二级副渠道");
|
jsonObject.put("before", user.getChannelAssist2Name());
|
jsonObject.put("after", userDto.getChannelAssist2Name());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setChannelAssist2Id(userDto.getChannelAssist2Id());
|
user.setChannelAssist2Name(userDto.getChannelAssist2Name());
|
// 获取冗余渠道信息
|
String channelInfo = UserInfoTool.getChannelInfo(commonService, userDto.getChannelAssist2Id());
|
user.setChannelAssist2Json(channelInfo);
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getQQ())) {
|
if (!userDto.getQQ().equals(user.getQQ())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改QQ号码");
|
jsonObject.put("before", user.getQQ());
|
jsonObject.put("after", userDto.getQQ());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setQQ(userDto.getQQ());
|
}
|
}
|
if (userDto.getGender() != null) {
|
if (!userDto.getGender().equals(user.getGender())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改性别(0 未知 1 男 2 女)");
|
jsonObject.put("before", user.getGender());
|
jsonObject.put("after", userDto.getGender());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setGender(userDto.getGender());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getCIQ())) {
|
if (!userDto.getCIQ().equals(user.getCIQ())) {
|
// 判断用户是否有使用CIQ
|
UserInfoTool.checkCIQHasUse(commonService, userDto.getCIQ());
|
// 用户日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改CIQ号码");
|
jsonObject.put("before", user.getCIQ());
|
jsonObject.put("after", userDto.getCIQ());
|
logArray.add(jsonObject);
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_CIQ, user.getCIQ(), userDto.getCIQ(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
// 修改数据
|
user.setCIQ(userDto.getCIQ());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getMemberNO())) {
|
if (!userDto.getMemberNO().equals(user.getMemberNO())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改会员号码");
|
jsonObject.put("before", user.getMemberNO());
|
jsonObject.put("after", userDto.getMemberNO());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setMemberNO(userDto.getMemberNO());
|
}
|
}
|
//user.setMoney(userDto.getMoney());
|
if (!StringUtils.isEmpty(userDto.getLastDoctorId())) {
|
if (!userDto.getLastDoctorId().equals(user.getLastDoctorId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改上一次预约的医生");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getLastDoctorId())) {
|
before = employeeMapper.selectOneByKey(user.getLastDoctorId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getLastDoctorId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setLastDoctorId(userDto.getLastDoctorId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getCustomerDeveloperId())) {
|
if (!userDto.getCustomerDeveloperId().equals(user.getCustomerDeveloperId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改客户开发人");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getCustomerDeveloperId())) {
|
before = employeeMapper.selectOneByKey(user.getCustomerDeveloperId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getCustomerDeveloperId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setCustomerDeveloperId(userDto.getCustomerDeveloperId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getLastCorpUserId())) {
|
if (!userDto.getLastCorpUserId().equals(user.getLastCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改上一次预约的顾问");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getLastCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getLastCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getLastCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setLastCorpUserId(userDto.getLastCorpUserId());
|
}
|
}
|
if (userDto.getCertificateType() != null) {
|
if (!StringUtils.isEmpty(userDto.getCertificateNo())) {
|
// 修改证件或者证件编号
|
if (!userDto.getCertificateType().equals(user.getCertificateType()) || !userDto.getCertificateNo().equals(user.getCertificateNo())) {
|
// 构建日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改证件信息");
|
jsonObject.put("before", String.format("修改证件类型：%s,证件编号:%s", User.getCertificateTypeName(user.getCertificateType()), user.getCertificateNo()));
|
jsonObject.put("after", String.format("修改证件类型：%s,证件编号:%s", User.getCertificateTypeName(userDto.getCertificateType()), userDto.getCertificateNo()));
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setCertificateType(userDto.getCertificateType());
|
user.setCertificateNo(userDto.getCertificateNo());
|
}
|
} else {
|
// 原来的证件信息不为空可以修改为空 -1 为空
|
if (-1 == userDto.getCertificateType() && !StringUtils.isEmpty(user.getCertificateNo())) {
|
// 修改证件信息为空
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改证件信息");
|
jsonObject.put("before", user.getCertificateNo());
|
jsonObject.put("after", "");
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setCertificateType(null);
|
user.setCertificateNo(null);
|
}
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getBirthDay())) {
|
// 判断生日时间格式
|
try{
|
DateUtil.parseString(userDto.getBirthDay(), "yyyy-MM-dd");
|
} catch (Exception ex){
|
throw new TipsException("生日时间格式不正确!");
|
}
|
if (!userDto.getBirthDay().equals(user.getBirthDay())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改生日");
|
jsonObject.put("before", user.getBirthDay());
|
jsonObject.put("after", userDto.getBirthDay());
|
logArray.add(jsonObject);
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_BIRTHDAY, user.getBirthDay(), userDto.getBirthDay(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
// 修改数据
|
user.setBirthDay(userDto.getBirthDay());
|
// 更新用户年龄
|
this.updateUserAge(user.getId(), userDto.getBirthDay());
|
}
|
}
|
/*if(!StringUtils.isEmpty(userDto.getApiId())) {
|
user.setApiId(userDto.getApiId());
|
}*/
|
if (!StringUtils.isEmpty(userDto.getCorpUserId())) {
|
if (!userDto.getCorpUserId().equals(user.getCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改工作人员");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setCorpUserId(userDto.getCorpUserId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getHisCorpUserId())) {
|
if (!userDto.getHisCorpUserId().equals(user.getHisCorpUserId())) {
|
// -1 值咨询师修改为空
|
if ("-1".equals(userDto.getHisCorpUserId())){
|
userDto.setHisCorpUserId(null);
|
}
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属顾问");
|
if (!StringUtils.isEmpty(user.getHisCorpUserId())) {
|
Employee before = employeeMapper.selectOneByKey(user.getHisCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getHisCorpUserId())) {
|
Employee after = employeeMapper.selectOneByKey(userDto.getHisCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
} else {
|
jsonObject.put("after", "无");
|
}
|
logArray.add(jsonObject);
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_ADVISER, user.getHisCorpUserId(), userDto.getHisCorpUserId(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
// 修改数据
|
user.setHisCorpUserId(userDto.getHisCorpUserId());
|
}
|
}
|
|
if (!StringUtils.isEmpty(userDto.getShopId())) {
|
if (!userDto.getShopId().equals(user.getShopId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属门店");
|
Shop before;
|
if (!StringUtils.isEmpty(user.getShopId())) {
|
before = shopMapper.selectOneByKey(user.getShopId());
|
if (before != null) {
|
jsonObject.put("before", before.getName());
|
}
|
}
|
Shop after = shopMapper.selectOneByKey(userDto.getShopId());
|
if (after != null) {
|
jsonObject.put("after", after.getName());
|
}
|
logArray.add(jsonObject);
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_SHOP, user.getShopId(), userDto.getShopId(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
|
// 修改数据
|
user.setShopId(userDto.getShopId());
|
}
|
}
|
if (userDto.getUserRole() != null) {
|
user.setUserRole(userDto.getUserRole());
|
}
|
if (!StringUtils.isEmpty(userDto.getPinyinCode())) {
|
user.setPinyinCode(userDto.getPinyinCode());
|
}
|
if (!StringUtils.isEmpty(userDto.getInternetCorpUserId())) {
|
if (!userDto.getInternetCorpUserId().equals(user.getInternetCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改电网咨询顾问");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getInternetCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getInternetCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getInternetCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_TMK, user.getInternetCorpUserId(), userDto.getInternetCorpUserId(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
// 修改数据
|
user.setInternetCorpUserId(userDto.getInternetCorpUserId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getBeauticianCorpUserId())) {
|
if (!userDto.getBeauticianCorpUserId().equals(user.getBeauticianCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属美容师");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getBeauticianCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getBeauticianCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getBeauticianCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setBeauticianCorpUserId(userDto.getBeauticianCorpUserId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getChatCorpUserId())) {
|
if (!userDto.getChatCorpUserId().equals(user.getChatCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改客服专员");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getChatCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getChatCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getChatCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setChatCorpUserId(userDto.getChatCorpUserId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getConsultCorpUserId())) {
|
if (!userDto.getConsultCorpUserId().equals(user.getConsultCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改咨询助理");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getConsultCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getConsultCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getConsultCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setConsultCorpUserId(userDto.getConsultCorpUserId());
|
}
|
}
|
if (userDto.getShareCustomer() != null) {
|
if (!userDto.getShareCustomer().equals(user.getShareCustomer())) {
|
// 默认否
|
if (user.getShareCustomer() == null) {
|
user.setShareCustomer(BaseEntity.NO);
|
}
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改咨询助理");
|
jsonObject.put("before", user.getShareCustomer() == 0 ? "否" : "是");
|
jsonObject.put("after", userDto.getShareCustomer() == 0 ? "否" : "是");
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setShareCustomer(userDto.getShareCustomer());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getNurseCorpUserId())) {
|
if (!userDto.getNurseCorpUserId().equals(user.getNurseCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属护士");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getNurseCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getNurseCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getNurseCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setNurseCorpUserId(userDto.getNurseCorpUserId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getDoctorCorpUserId())) {
|
if (!userDto.getDoctorCorpUserId().equals(user.getDoctorCorpUserId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属医生");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getDoctorCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getDoctorCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getDoctorCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setDoctorCorpUserId(userDto.getDoctorCorpUserId());
|
}
|
}
|
if(!StringUtils.isEmpty(userDto.getConsultBelonging())) {
|
if (!userDto.getConsultBelonging().equals(user.getConsultBelonging())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改咨询师隶属");
|
jsonObject.put("before", user.getConsultBelonging());
|
jsonObject.put("after", userDto.getConsultBelonging());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setConsultBelonging(userDto.getConsultBelonging());
|
}
|
}
|
// 渠道来源类型(UserChannelType)
|
if (!StringUtils.isEmpty(userDto.getChannelCategory())) {
|
user.setChannelCategory(userDto.getChannelCategory());
|
}
|
String inviteeName = null;
|
if(!StringUtils.isEmpty(userDto.getInviteeId())) {
|
if (!userDto.getInviteeId().equals(user.getInviteeId())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改客户推荐人");
|
User before;
|
if (!StringUtils.isEmpty(user.getInviteeId())) {
|
before = userMapper.selectOneByKey(user.getInviteeId());
|
if (before != null) {
|
jsonObject.put("before", before.getName());
|
}
|
}
|
User after = userMapper.selectOneByKey(userDto.getInviteeId());
|
if (after != null) {
|
jsonObject.put("after", after.getName());
|
inviteeName = after.getName();
|
}
|
logArray.add(jsonObject);
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_INVITE, user.getInviteeId(), userDto.getInviteeId(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
// 修改数据
|
user.setInviteeId(userDto.getInviteeId());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getRemark())) {
|
if (!userDto.getRemark().equals(user.getRemark())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改备注");
|
jsonObject.put("before", user.getRemark());
|
jsonObject.put("after", userDto.getRemark());
|
logArray.add(jsonObject);
|
// 修改数据
|
user.setRemark(userDto.getRemark());
|
}
|
}
|
// 处理下用户渠道信息
|
UserInfoTool.handlerChanelInfo(commonService, user);
|
// 修改用户信息
|
user.setUpdateTime(new Date());
|
int count = userMapper.updateAll(user);
|
if (count != 1) {
|
throw new TipsException("修改失败！");
|
} else {
|
// 处理新增用户是否触发赠送增值金接口
|
/* if(!StringUtils.isEmpty(userDto.getBirthDay())){
|
Calendar calendar=Calendar.getInstance();
|
String year = String.valueOf(calendar.get(Calendar.YEAR));
|
String month= BirthdayValueAddedFundTool.handleMonth(calendar.get(Calendar.MONTH)+1);
|
if(userDto.getBirthDay().indexOf("-"+month+"-")!=-1){
|
BirthdayValueAddedFundTool.handleUserMoney(user,year);
|
}
|
}*/
|
// 处理用户信息
|
UserInfo userInfo = userInfoMapper.selectOneByUserId(user.getId());
|
// 旧数据没有用户信息处理
|
boolean flag = false;
|
if (userInfo == null) {
|
userInfo = new UserInfo();
|
userInfo.setUserId(user.getId());
|
flag = true;
|
}
|
if (!StringUtils.isEmpty(userDto.getCountryTypeName())) {
|
if (!userDto.getCountryTypeName().equals(userInfo.getCountryTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改国家类型名称");
|
jsonObject.put("before", userInfo.getCountryTypeName());
|
jsonObject.put("after", userDto.getCountryTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setCountryTypeName(userDto.getCountryTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getLanguageTypeName())) {
|
if (!userDto.getLanguageTypeName().equals(userInfo.getLanguageTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改语言类型名称");
|
jsonObject.put("before", userInfo.getLanguageTypeName());
|
jsonObject.put("after", userDto.getLanguageTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setLanguageTypeName(userDto.getLanguageTypeName());
|
}
|
}
|
if (userDto.getYear() != null) {
|
if (!userDto.getYear().equals(userInfo.getYear())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改年龄");
|
jsonObject.put("before", userInfo.getYear());
|
jsonObject.put("after", userDto.getYear());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setYear(userDto.getYear());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getConstellationTypeName())) {
|
if (!userDto.getConstellationTypeName().equals(userInfo.getConstellationTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改星座类型名称");
|
jsonObject.put("before", userInfo.getConstellationTypeName());
|
jsonObject.put("after", userDto.getConstellationTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setConstellationTypeName(userDto.getConstellationTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getNationalityTypeName())) {
|
if (!userDto.getNationalityTypeName().equals(userInfo.getNationalityTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改民族类型名称");
|
jsonObject.put("before", userInfo.getNationalityTypeName());
|
jsonObject.put("after", userDto.getNationalityTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setNationalityTypeName(userDto.getNationalityTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getProfessionTypeName())) {
|
if (!userDto.getProfessionTypeName().equals(userInfo.getProfessionTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改职业类型名称");
|
jsonObject.put("before", userInfo.getProfessionTypeName());
|
jsonObject.put("after", userDto.getProfessionTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setProfessionTypeName(userDto.getProfessionTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getIncomeTypeName())) {
|
if (!userDto.getIncomeTypeName().equals(userInfo.getIncomeTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改收入类型名称");
|
jsonObject.put("before", userInfo.getIncomeTypeName());
|
jsonObject.put("after", userDto.getIncomeTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setIncomeTypeName(userDto.getIncomeTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getMarriageTypeName())) {
|
if (!userDto.getMarriageTypeName().equals(userInfo.getMarriageTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改婚姻类型名称");
|
jsonObject.put("before", userInfo.getMarriageTypeName());
|
jsonObject.put("after", userDto.getMarriageTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setMarriageTypeName(userDto.getMarriageTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getGrowthTypeName())) {
|
if (!userDto.getGrowthTypeName().equals(userInfo.getGrowthTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改生育类型名称");
|
jsonObject.put("before", userInfo.getGrowthTypeName());
|
jsonObject.put("after", userDto.getGrowthTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setGrowthTypeName(userDto.getGrowthTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getNativePlaceTypeName())) {
|
if (!userDto.getNativePlaceTypeName().equals(userInfo.getNativePlaceTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改籍贯类型名称");
|
jsonObject.put("before", userInfo.getNativePlaceTypeName());
|
jsonObject.put("after", userDto.getNativePlaceTypeName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setNativePlaceTypeName(userDto.getNativePlaceTypeName());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getUnitName())) {
|
if (!userDto.getUnitName().equals(userInfo.getUnitName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改单位名称");
|
jsonObject.put("before", userInfo.getUnitName());
|
jsonObject.put("after", userDto.getUnitName());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setUnitName(userDto.getUnitName());
|
}
|
}
|
if (userDto.getIsHaveCar() != null) {
|
if (!userDto.getIsHaveCar().equals(userInfo.getIsHaveCar())) {
|
// 默认值
|
if (null == userInfo.getIsHaveCar()){
|
userInfo.setIsHaveCar(BaseEntity.NO);
|
}
|
// 处理数据
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改泊车需求");
|
jsonObject.put("before", userInfo.getIsHaveCar().equals(BaseEntity.NO) ? "否" : "是");
|
jsonObject.put("after", userDto.getIsHaveCar().equals(BaseEntity.NO) ? "否" : "是");
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setIsHaveCar(userDto.getIsHaveCar());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getCarNumber())) {
|
if (!userDto.getCarNumber().equals(userInfo.getCarNumber())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改车牌号码");
|
jsonObject.put("before", userInfo.getCarNumber());
|
jsonObject.put("after", userDto.getCarNumber());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setCarNumber(userDto.getCarNumber());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getAllergyLabel())) {
|
if (!userDto.getAllergyLabel().equals(userInfo.getAllergyLabel())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改过敏标签");
|
jsonObject.put("before", userInfo.getAllergyLabel());
|
jsonObject.put("after", userDto.getAllergyLabel());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setAllergyLabel(userDto.getAllergyLabel());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getMainAppeal())) {
|
if (!userDto.getMainAppeal().equals(userInfo.getMainAppeal())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改主要诉求名称");
|
jsonObject.put("before", userInfo.getMainAppeal());
|
jsonObject.put("after", userDto.getMainAppeal());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setMainAppeal(userDto.getMainAppeal());
|
}
|
}
|
|
if (!StringUtils.isEmpty(userDto.getMinorAppeal())) {
|
if (!userDto.getMinorAppeal().equals(userInfo.getMinorAppeal())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改次要诉求名称");
|
jsonObject.put("before", userInfo.getMinorAppeal());
|
jsonObject.put("after", userDto.getMinorAppeal());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setMinorAppeal(userDto.getMinorAppeal());
|
}
|
}
|
|
if (!StringUtils.isEmpty(userDto.getChannelType2())) {
|
if (!userDto.getChannelType2().equals(userInfo.getSourceName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改冗余来源名称");
|
jsonObject.put("before", userInfo.getSourceName());
|
jsonObject.put("after", userDto.getChannelType2());
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setSourceName(userDto.getChannelType2());
|
}
|
}
|
|
if (!StringUtils.isEmpty(inviteeName)) {
|
if (!inviteeName.equals(userInfo.getFriendName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改冗余好友名称");
|
jsonObject.put("before", userInfo.getFriendName());
|
jsonObject.put("after", inviteeName);
|
logArray.add(jsonObject);
|
// 修改数据
|
userInfo.setFriendName(inviteeName);
|
}
|
}
|
|
int userInfoCount;
|
if (!flag) {
|
userInfoCount = userInfoMapper.updateAll(userInfo);
|
} else {
|
userInfoCount = userInfoMapper.insert(userInfo);
|
}
|
if (userInfoCount != 1) {
|
throw new TipsException("修改用户信息失败！");
|
}
|
|
// 处理用户联系信息
|
UserContactInformation userContactInformation = userContactInformationMapper.selectOneByUserId(user.getId());
|
// 旧数据没有用户信息处理
|
flag = false;
|
if (userContactInformation == null) {
|
userContactInformation = new UserContactInformation();
|
userContactInformation.setUserId(user.getId());
|
flag = true;
|
}
|
if (!StringUtils.isEmpty(userDto.getQQ())) {
|
if (!userDto.getQQ().equals(userContactInformation.getQQ())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改QQ号码");
|
jsonObject.put("before", userContactInformation.getQQ());
|
jsonObject.put("after", userDto.getQQ());
|
logArray.add(jsonObject);
|
// 修改数据
|
userContactInformation.setQQ(userDto.getQQ());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getEmail())) {
|
if (!userDto.getEmail().equals(userContactInformation.getEmail())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改电子邮件");
|
jsonObject.put("before", userContactInformation.getEmail());
|
jsonObject.put("after", userDto.getEmail());
|
logArray.add(jsonObject);
|
// 修改数据
|
userContactInformation.setEmail(userDto.getEmail());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getMerchantNo())) {
|
if (!userDto.getMerchantNo().equals(userContactInformation.getMerchantNo())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改商务通编号");
|
jsonObject.put("before", userContactInformation.getMerchantNo());
|
jsonObject.put("after", userDto.getMerchantNo());
|
logArray.add(jsonObject);
|
// 修改数据
|
userContactInformation.setMerchantNo(userDto.getMerchantNo());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getTelPhone())) {
|
if (!userDto.getTelPhone().equals(userContactInformation.getTelPhone())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改固定号码");
|
jsonObject.put("before", userContactInformation.getTelPhone());
|
jsonObject.put("after", userDto.getTelPhone());
|
logArray.add(jsonObject);
|
// 修改数据
|
userContactInformation.setTelPhone(userDto.getTelPhone());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getWechat())) {
|
if (!userDto.getWechat().equals(userContactInformation.getWechat())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改微信号");
|
jsonObject.put("before", userContactInformation.getWechat());
|
jsonObject.put("after", userDto.getWechat());
|
logArray.add(jsonObject);
|
// 修改数据
|
userContactInformation.setWechat(userDto.getWechat());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getLine())) {
|
if (!userDto.getLine().equals(userContactInformation.getLine())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改Line");
|
jsonObject.put("before", userContactInformation.getLine());
|
jsonObject.put("after", userDto.getLine());
|
logArray.add(jsonObject);
|
// 修改数据
|
userContactInformation.setLine(userDto.getLine());
|
}
|
}
|
if (!StringUtils.isEmpty(userDto.getContactType())) {
|
if (!userDto.getContactType().equals(userContactInformation.getContactType())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改联络方式");
|
jsonObject.put("before", userContactInformation.getContactType());
|
jsonObject.put("after", userDto.getContactType());
|
logArray.add(jsonObject);
|
// 修改数据
|
userContactInformation.setContactType(userDto.getContactType());
|
}
|
}
|
int userContactInsert;
|
if (!flag) {
|
userContactInsert = userContactInformationMapper.updateAll(userContactInformation);
|
} else {
|
userContactInsert = userContactInformationMapper.insert(userContactInformation);
|
}
|
if (userContactInsert != 1) {
|
throw new TipsException("修改用户联系信息失败！");
|
}
|
|
// 处理用户兴趣标签
|
List<UserInterests> userInterestsList = JSONArray.parseArray(userDto.getUserInterestsJson(), UserInterests.class);
|
if (userInterestsList != null) {
|
// 先删除原有记录
|
userInterestsMapper.deleteByUserId(user.getId());
|
// 添加新的记录
|
userInterestsList.forEach(userInterests -> {
|
userInterests.setUserId(user.getId());
|
int insertUserInterests = userInterestsMapper.insert(userInterests);
|
if (insertUserInterests != 1) {
|
throw new TipsException("新增用户标签信息失败！");
|
}
|
});
|
}
|
|
// 刷新下用户信息
|
User checkUser = userMapper.selectOneByKey(user.getId());
|
// 处理用户电话簿信息
|
List<UserPhoneBook> userPhoneBookList = JSONArray.parseArray(userDto.getPhoneBooksJson(), UserPhoneBook.class);
|
if (userPhoneBookList != null && userPhoneBookList.size() > 0) {
|
// 先删除原有记录
|
userPhoneBookMapper.deleteByUserId(user.getId());
|
// 添加新的记录
|
userPhoneBookList.forEach(userPhoneBook -> {
|
// 电话号码不为空才添加
|
if (!StringUtils.isEmpty(userPhoneBook.getTel())) {
|
if (userPhoneBook.getTel().contains("****")) {
|
throw new TipsException("手机号码格式请检查,不能是加密号码！");
|
}
|
|
// 判断主要号码
|
if (!userPhoneBook.getTel().equals(user.getTel())) {
|
List<User> userList = this.selectOneByTel(userPhoneBook.getTel());
|
if (userList != null && userList.size() > 0) {
|
throw new TipsException(String.format("电话号码：%s,手机号码已有其他客户使用!", userPhoneBook.getTel()));
|
}
|
}
|
|
// 判断次要号码
|
UserPhoneBook checkUserPhoneBook = UserInfoTool.selectOneByTelOtherUser(commonService, userPhoneBook.getAreaCode(), userPhoneBook.getTel(), user.getId());
|
if (checkUserPhoneBook != null) {
|
throw new TipsException(String.format("电话号码：%s,手机号码已有其他客户使用！", userPhoneBook.getTel()));
|
}
|
|
// 新增加电话簿号码
|
userPhoneBook.setUserId(user.getId());
|
int insertUserPhoneBook = userPhoneBookMapper.insert(userPhoneBook);
|
if (insertUserPhoneBook != 1) {
|
throw new TipsException("新增用户次要手机号码失败！");
|
}
|
|
// 次要号码添加日志
|
if (BaseEntity.NO.equals(userPhoneBook.getIsPrimary())) {
|
// 添加日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", String.format("添加次要手机号码:%s", userPhoneBook.getTel()));
|
logArray.add(jsonObject);
|
}
|
|
// 判断主要号码更新用户信息主号码
|
if (BaseEntity.YES.equals(userPhoneBook.getIsPrimary())) {
|
if (!userPhoneBook.getTel().equals(user.getTel())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改手机号码");
|
jsonObject.put("before", user.getTel());
|
jsonObject.put("after", userPhoneBook.getTel());
|
logArray.add(jsonObject);
|
}
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValue = new HashMap<>();
|
String sql = " tel = #{m.tel} WHERE id = #{m.userId}";
|
sqlValue.put("userId", userPhoneBook.getUserId());
|
sqlValue.put("tel", userPhoneBook.getTel());
|
sqlSentence.sqlSentence(sql, sqlValue);
|
int i = userMapper.updateWhere(sqlSentence);
|
if (i != 1) {
|
throw new TipsException("更新用户主号码失败！");
|
}
|
}
|
}
|
});
|
} else {
|
// 修改手机号码处理
|
if (!StringUtils.isEmpty(userDto.getTel())) {
|
// 校验id
|
String checkId;
|
// 校验电话号码
|
UserPhoneBook checkUserPhoneBook = UserInfoTool.selectOneByTelUser(commonService, userDto.getTel(), user.getId());
|
if (checkUserPhoneBook == null) {
|
UserPhoneBook primary = new UserPhoneBook();
|
primary.setUserId(checkUser.getId());
|
primary.setTel(userDto.getTel());
|
primary.setIsPrimary(BaseEntity.YES);
|
userPhoneBookMapper.insert(primary);
|
checkUserPhoneBook = primary;
|
}
|
|
// 调整下主号码状态
|
checkId = checkUserPhoneBook.getId();
|
if (BaseEntity.NO.equals(checkUserPhoneBook.getIsPrimary())) {
|
checkUserPhoneBook.setIsPrimary(BaseEntity.YES);
|
userPhoneBookMapper.updateAll(checkUserPhoneBook);
|
}
|
|
// 其他号码处理下状态
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValue = new HashMap<>();
|
sqlValue.put("isDel", BaseEntity.NO);
|
sqlValue.put("id", checkId);
|
sqlValue.put("isPrimary", BaseEntity.NO);
|
sqlValue.put("userId", checkUser.getId());
|
String sql = " isPrimary=#{m.isPrimary} WHERE userId=#{m.userId} AND id !=#{m.id} AND isDel=#{m.isDel}";
|
sqlSentence.sqlSentence(sql, sqlValue);
|
userPhoneBookMapper.updateWhere(sqlSentence);
|
}
|
}
|
|
// 处理用户地址
|
List<UserAddressBook> userAddressBookList = JSONArray.parseArray(userDto.getAddressJson(), UserAddressBook.class);
|
if (userAddressBookList != null) {
|
// 先删除原有记录
|
userAddressBookMapper.deleteByUserId(user.getId());
|
// 添加新的记录
|
userAddressBookList.forEach(userAddressBook -> {
|
userAddressBook.setUserId(user.getId());
|
int insertUserAddressBook = userAddressBookMapper.insert(userAddressBook);
|
if (insertUserAddressBook != 1) {
|
throw new TipsException("新增用户地址信息失败！");
|
}
|
});
|
}
|
|
// 处理用户标签
|
List<UserGeneralLabel> userGeneralLabelList = JSONArray.parseArray(userDto.getImpressionLabelJson(), UserGeneralLabel.class);
|
if (userGeneralLabelList != null) {
|
// 先删除原有记录
|
userGeneralLabelMapper.deleteByUserId(user.getId());
|
// 添加新的记录
|
userGeneralLabelList.forEach(userGeneralLabel -> {
|
userGeneralLabel.setUserId(user.getId());
|
userGeneralLabel.setType(UserGeneralLabel.TYPE_IMPRESSION_LABEL);
|
int insertUserGeneralLabel = userGeneralLabelMapper.insert(userGeneralLabel);
|
if (insertUserGeneralLabel != 1) {
|
throw new TipsException("新增用户标签信息失败!");
|
}
|
});
|
}
|
|
//处理用户修改日志
|
if (!StringUtils.isEmpty(userDto.getNote())
|
|| !StringUtils.isEmpty(userDto.getOpId())
|
|| !StringUtils.isEmpty(userDto.getOpMan())) {
|
UserLog userLog = new UserLog();
|
userLog.setUserId(user.getId());
|
userLog.setLogType(UserLog.LOG_TYPE_UPDATE);
|
userLog.setContent("[" + userDto.getOpMan() + "]:编辑客户信息");
|
userLog.setOpMan(userDto.getOpMan());
|
userLog.setOpId(userDto.getOpId());
|
userLog.setRemark(userDto.getNote());
|
if (commonService.insert(UserLogMapper.class, userLog) != 1) {
|
throw new TipsException("新增客户修改日志记录失败!");
|
}
|
}
|
|
// 关闭同步领建代码
|
/*//处理门店信息
|
String hisShopId = "";
|
if (!StringUtils.isEmpty(userDto.getShopId())) {
|
Shop shop = commonService.selectOneByKey(ShopMapper.class, userDto.getShopId());
|
if (shop == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "门店标识错误,门店信息不存在！");
|
}
|
if (shop.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his门店信息不存在！");
|
}
|
hisShopId = shop.getApiId();
|
|
}
|
//处理所属咨询信息
|
String consultantId = "";
|
if (!StringUtils.isEmpty(userDto.getHisCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getHisCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属顾问标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his顾问信息不存在！");
|
}
|
consultantId = employee.getApiId();
|
}
|
//处理所属医生信息
|
String doctorId = "";
|
if (!StringUtils.isEmpty(userDto.getDoctorCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getDoctorCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属医生标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his医生信息不存在！");
|
}
|
doctorId = employee.getApiId();
|
}
|
//处理所属美容师信息
|
String beauticianId = "";
|
if (!StringUtils.isEmpty(userDto.getBeauticianCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getBeauticianCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属美容师标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his美容师信息不存在！");
|
}
|
beauticianId = employee.getApiId();
|
}
|
//处理所属客服信息
|
String customerServiceId = "";
|
if (!StringUtils.isEmpty(userDto.getChatCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getChatCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属客服标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his客服信息不存在！");
|
}
|
customerServiceId = employee.getApiId();
|
}
|
//处理所属电网咨询师信息
|
String serviceConsultantId = "";
|
if (!StringUtils.isEmpty(userDto.getInternetCorpUserId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getInternetCorpUserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "所属电网咨询师标识错误,顾问信息不存在！");
|
}
|
if (employee.getApiId() == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "his电网咨询师信息不存在！");
|
}
|
serviceConsultantId = employee.getApiId();
|
}*/
|
|
// 记录编号
|
String recordNo = UserInfoTool.createUSLGNo(commonService, user.getId(), user.getCIQ());
|
// 添加用户日志
|
UserInfoTool.addUserUpdateLog(commonService, userDto.getAppIdCode(), user, userDto.getShopId(), userDto.getOpId(), null, null, "修改用户信息", logArray, null, recordNo);
|
|
// 处理用户登记记录
|
UserRegisterRecordTool.handlerUserRegisterRecord(commonService, user.getId(), userDto.getAppIdCode(), BaseEntity.YES);
|
|
// 切换领建屏蔽代码 date:20230108
|
/*// 同步更新his用户系统 注释 正式区在开放
|
String returnHisData;
|
// 构建请求his同步请求参数
|
JSONObject jsonObject = buildSyncUserHisData(user, hisShopId, consultantId, doctorId, beauticianId, customerServiceId, serviceConsultantId, userDto.getRemark(), BaseEntity.YES);
|
try {
|
jsonObject.put("appIdCode", userDto.getAppIdCode());
|
returnHisData = ApiPlatformUtil.syncHisUser(customParameter, userDto.getAppIdCode(), jsonObject.toJSONString());
|
} catch (Exception ex) {
|
logger.error("同步用户编辑到his系统出现失败！错误消息：", ex);
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "同步用户编辑到his系统出现失败！");
|
}
|
if (!StringUtils.isEmpty(returnHisData)) {
|
JSONObject jsonHisObject = JSONObject.parseObject(returnHisData);
|
String code = jsonHisObject.getString("code");
|
if (!"100".equals(code)) {
|
String error = jsonHisObject.getString("msg");
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "更新his编辑用户信息失败! 返回错误消息:" + error);
|
}
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "更新his编辑用户信息失败! 返回为空消息！");
|
}*/
|
}
|
}
|
|
/**
|
* 更新用户年龄
|
* @param userId 用户id
|
* @param birthDay 生日
|
*/
|
public void updateUserAge(String userId, String birthDay) {
|
if (!StringUtils.isEmpty(birthDay)) {
|
// 计算年龄
|
int age = UserAgeTool.getAge(birthDay, 1);
|
if (age > 0) {
|
// 获取年龄
|
UserInfo userInfo = userInfoMapper.selectOneByUserId(userId);
|
// 判断年龄是否 为空或者不是正确年龄
|
if (userInfo != null && (userInfo.getYear() == null || age != userInfo.getYear())) {
|
// 更新年龄
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValues = new HashMap<>();
|
sqlValues.put("year", age);
|
sqlValues.put("userId", userId);
|
sqlSentence.sqlSentence(" year=#{m.year},editTime=NOW() WHERE userId=#{m.userId}", sqlValues);
|
userInfoMapper.updateWhere(sqlSentence);
|
}
|
}
|
}
|
}
|
|
/**转诊新增*/
|
private void turnTreat(User user,UserDto userDto) {
|
if (userDto.getIsTransfer() != null && userDto.getIsTransfer().equals(1)){
|
TransferRecord parameter = userDto.getTransferRecord();
|
if (parameter == null){
|
throw new TipsException("转诊信息为空!");
|
}
|
TransferRecord transferRecord = new TransferRecord();
|
transferRecord.setUserId(user.getId());
|
transferRecord.setStatus(TransferRecord.STATUS_AGREE);
|
transferRecord.setType(0);
|
transferRecord.setTransferOutShopId(user.getShopId());
|
Shop outShop = shopMapper.selectOneByKey(user.getShopId());
|
if (outShop != null){
|
transferRecord.setTransferOutShopName(outShop.getName());
|
}
|
transferRecord.setTransferIntoShopId(userDto.getShopId());
|
Shop inShop = shopMapper.selectOneByKey(userDto.getShopId());
|
if (inShop != null){
|
transferRecord.setTransferIntoShopName(inShop.getName());
|
}
|
|
transferRecord.setApplyAdminType(parameter.getApplyAdminType());
|
transferRecord.setApplyAdminId(parameter.getApplyAdminId());
|
transferRecord.setApplyAdminName(parameter.getApplyAdminName());
|
|
transferRecord.setApprovedAdminType(parameter.getApprovedAdminType());
|
transferRecord.setApprovedAdminId(parameter.getApprovedAdminId());
|
transferRecord.setApprovedAdminName(parameter.getApprovedAdminName());
|
transferRecord.setApprovedTime(parameter.getApprovedTime());
|
|
transferRecord.setRemark(parameter.getRemark());
|
transferRecord.setIsNotice(parameter.getIsNotice());
|
transferRecord.setOperatorType(parameter.getOperatorType());
|
transferRecord.setOperatorId(parameter.getOperatorId());
|
transferRecord.setOperatorName(parameter.getOperatorName());
|
if (commonService.insert(TransferRecordMapper.class,transferRecord) != 1){
|
throw new TipsException("新增转诊记录失败!");
|
}
|
}
|
}
|
|
/**到访更新用户信息*/
|
@Override
|
public JSONObject arriveInfo(User user, UserDto userDto) {
|
//返回部分数据时间
|
JSONObject data = new JSONObject();
|
data.put("CIQ", user.getCIQ());
|
|
// 四个值不能都为空
|
if (!StringUtils.isEmpty(userDto.getHisCorpUserId())
|
|| !StringUtils.isEmpty(userDto.getNurseCorpUserId())
|
|| !StringUtils.isEmpty(userDto.getDoctorCorpUserId())
|
|| !StringUtils.isEmpty(userDto.getShopId())
|
|| userDto.getLastArriveTime() != null
|
) {
|
JSONArray logArray = new JSONArray();
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValue = new HashMap<>();
|
sqlValue.put("userId", user.getId());
|
sqlValue.put("isLoss", BaseEntity.NO);
|
sqlValue.put("editTime", new Date());
|
StringBuilder sql = new StringBuilder();
|
sql.append(" isLoss=#{m.isLoss},editTime=#{m.editTime}");
|
// 有到访会员无消费和无执行
|
String status = null;
|
if (!StringUtils.isEmpty(user.getUserStatus()) && UserStatusConstants.USER_STATUS_NON_MEMBER.equals(user.getUserStatus())
|
&& user.getLastPayOrderTime() == null && user.getLastDeductionTime() == null) {
|
// 旧方案
|
/*Date lastDate = DateUtil.addMonth(new Date(), -3);
|
// 新会员:近3个月成为会员有到访和(没有消费和没有执行) <=3 界定于有没有到访
|
if (user.getCreateTime().compareTo(lastDate) >= 0 && user.getLastPayOrderTime() == null && user.getLastDeductionTime() == null) {
|
// 会员状态有消费或执行的会员
|
status = UserStatusConstants.USER_STATUS_NEW_MEMBER;
|
sqlValue.put("userStatus", status);
|
sql.append(",userStatus=#{m.userStatus}");
|
}*/
|
// 新方案
|
// 有到访和(没有消费和没有执行) 准会员
|
status = UserStatusConstants.USER_STATUS_NEW_MEMBER;
|
sqlValue.put("userStatus", status);
|
sql.append(",userStatus=#{m.userStatus}");
|
}
|
// 最后到店时间
|
if (null != userDto.getLastArriveTime()) {
|
sqlValue.put("lastArriveTime", userDto.getLastArriveTime());
|
sql.append(",lastArriveTime=#{m.lastArriveTime}");
|
//判断如果用户初次到店时间为空，则更新
|
if(user.getFirstArriveTime() == null){
|
sql.append(" , firstArriveTime = #{m.lastArriveTime} ");
|
}
|
}
|
// CIQ 用户CIQ为空处理CIQ
|
if (StringUtils.isEmpty(user.getCIQ())) {
|
// 三少说 用到访门店生成初诊用户CIQ 20230129
|
String ciqNo = systemParameterService.createCIQNo(userDto.getArriveShopId());
|
data.put("CIQ", ciqNo);
|
if (!StringUtils.isEmpty(ciqNo)) {
|
sqlValue.put("CIQ", ciqNo);
|
sql.append(",CIQ=#{m.CIQ},memberNO=#{m.CIQ}");
|
// 添加日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改CIQ");
|
jsonObject.put("before", user.getCIQ());
|
jsonObject.put("after", user.getMemberNO());
|
logArray.add(jsonObject);
|
}
|
}
|
// 所属顾问
|
if (!StringUtils.isEmpty(userDto.getHisCorpUserId())) {
|
sqlValue.put("hisCorpUserId", userDto.getHisCorpUserId());
|
sql.append(",hisCorpUserId=#{m.hisCorpUserId}");
|
// 添加日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属顾问");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getHisCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getHisCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getHisCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_ADVISER, user.getHisCorpUserId(), userDto.getHisCorpUserId(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getOpShopId(), "用户到访修改信息", commonService);
|
}
|
|
//2023-01-16新增逻辑：用户所属顾问为空，则同步更新用户的所属门店为顾问门店
|
if(!StringUtils.isEmpty(userDto.getShopId())){
|
sqlValue.put("shopId", userDto.getShopId());
|
sql.append(" , shopId = #{m.shopId} ");
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属门店");
|
Shop beforeShop;
|
if (!StringUtils.isEmpty(user.getShopId())) {
|
beforeShop = shopMapper.selectOneByKey(user.getShopId());
|
if (beforeShop != null) {
|
jsonObject.put("before", beforeShop.getName());
|
}
|
}
|
Shop afterShop = shopMapper.selectOneByKey(userDto.getShopId());
|
if (afterShop != null) {
|
jsonObject.put("after", afterShop.getName());
|
}
|
logArray.add(jsonObject);
|
// 用户所属信息变更记录
|
UserInfoTool.userBeChangeLogAdd(user.getId(), UserBeChangeLog.CHANGE_TYPE_SHOP, user.getShopId(), userDto.getShopId(), userDto.getAppIdCode(),
|
UserBeChangeLog.OPERATOR_TYPE_EMPLOYEE, userDto.getOpId(), userDto.getShopId(), userDto.getRemark(), commonService);
|
}
|
|
// 所属护士
|
if (!StringUtils.isEmpty(userDto.getNurseCorpUserId())) {
|
sqlValue.put("nurseCorpUserId", userDto.getNurseCorpUserId());
|
sql.append(",nurseCorpUserId=#{m.nurseCorpUserId}");
|
// 添加日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属护士");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getNurseCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getNurseCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getNurseCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
}
|
// 所属医生
|
if (!StringUtils.isEmpty(userDto.getDoctorCorpUserId())) {
|
sqlValue.put("doctorCorpUserId", userDto.getDoctorCorpUserId());
|
sql.append(",doctorCorpUserId=#{m.doctorCorpUserId}");
|
// 添加日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改所属医生");
|
Employee before;
|
if (!StringUtils.isEmpty(user.getDoctorCorpUserId())) {
|
before = employeeMapper.selectOneByKey(user.getDoctorCorpUserId());
|
if (before != null) {
|
jsonObject.put("before", before.getCnName());
|
}
|
}
|
Employee after = employeeMapper.selectOneByKey(userDto.getDoctorCorpUserId());
|
if (after != null) {
|
jsonObject.put("after", after.getCnName());
|
}
|
logArray.add(jsonObject);
|
}
|
|
sql.append(" WHERE id=#{m.userId}");
|
sqlSentence.sqlSentence(sql.toString(), sqlValue);
|
int count = userMapper.updateWhere(sqlSentence);
|
if (count != 1) {
|
throw new TipsException("修改失败！");
|
}
|
|
// 添加用户日志处理
|
JSONObject jsonObjectData = new JSONObject();
|
jsonObjectData.put("key", "用户到访");
|
logArray.add(jsonObjectData);
|
// 记录编号
|
String recordNo = UserInfoTool.createUSLGNo(commonService, user.getId(), user.getCIQ());
|
// 用户日志
|
UserInfoTool.addUserUpdateLog(commonService, userDto.getAppIdCode(), user, userDto.getOpShopId(), userDto.getOpId(), null, user.getId(), "用户到访", logArray, null, recordNo);
|
|
// 添加调整用户状态日志 调整了用户等级在写入日志
|
if (!StringUtils.isEmpty(status)) {
|
// 记录编号
|
recordNo = UserInfoTool.createUSLGNo(commonService, user.getId(), user.getCIQ());
|
// 添加用户日志
|
UserStatusTool.addUserStatusLog(commonService, userDto.getAppIdCode(), user, UserStatusLog.CHANGE_STATUS_TYPE_VISIT, userDto.getVisitRecordId(), UserStatusConstants.USER_STATUS_ACTIVE_MEMBER, recordNo);
|
}
|
|
//处理唤醒记录
|
if(userDto.getUserWakeUpLog() != null && StringUtils.noNull(userDto.getUserWakeUpLog().getAppointmentId())) {
|
UserWakeUpLog userWakeUpLog = userDto.getUserWakeUpLog();
|
sqlValue.clear();
|
sqlValue.put("appointmentId", userWakeUpLog.getAppointmentId());
|
sqlSentence.setSqlSentence(" select id, createTime from user_wake_up_log where isDel = 0 and appointmentId = #{m.appointmentId} ");
|
UserWakeUpLog oldLog = userWakeUpLogMapper.selectOne(sqlSentence);
|
userWakeUpLog.setAppId(userDto.getAppId());
|
userWakeUpLog.setOriginChannel(userDto.getAppIdCode());
|
if (oldLog == null) {
|
//先取消用户其他有效唤醒记录
|
sqlValue.put("userId", userDto.getUserId());
|
sqlValue.put("status", UserWakeUpLog.STATUS_INVALID);
|
sqlValue.put("oldStatus", UserWakeUpLog.STATUS_VALID);
|
sqlSentence.setSqlSentence(" status = #{m.status} where userId = #{m.userId} and status = #{m.oldStatus}");
|
userWakeUpLogMapper.updateWhere(sqlSentence);
|
|
//再新增
|
if (userWakeUpLogMapper.insert(userWakeUpLog) != 1) {
|
throw new TipsException("新增唤醒记录失败");
|
}
|
|
} else {
|
//更新
|
userWakeUpLog.setId(oldLog.getId());
|
userWakeUpLog.setCreateTime(oldLog.getCreateTime());
|
if (userWakeUpLogMapper.updateAll(userWakeUpLog) != 1) {
|
throw new TipsException("更新唤醒记录失败");
|
}
|
}
|
}
|
}
|
return data;
|
}
|
|
/**
|
* 根据员工id查询 用户hisId 用于同步his客户来源
|
* @param employeeId 员工id
|
* @return 用户对象信息
|
*/
|
private User getUserByEmployee(String employeeId) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlMap = new HashMap<>();
|
sqlMap.put("isDel", BaseEntity.NO);
|
sqlMap.put("userBelongingType", UserChannelType.CATEGORY_EMPLOYEE);
|
sqlMap.put("id", employeeId);
|
String sql = "SELECT us.* FROM employee AS emp INNER JOIN `user` AS us ON us.userBelongingId=emp.apiId WHERE emp.isDel=#{m.isDel} AND us.isDel=#{m.isDel}" +
|
" AND us.userBelongingType=#{m.userBelongingType} AND emp.id=#{m.id}";
|
sqlSentence.setSqlSentence(sql);
|
sqlSentence.setM(sqlMap);
|
return userMapper.selectOne(sqlSentence);
|
}
|
|
/**修改*/
|
@Override
|
public void updateHeaderImg(String userId, String imgUrl) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> sqlMap = new HashMap<>();
|
sqlMap.put("isDel", BaseEntity.NO);
|
sqlMap.put("userId", userId);
|
sqlMap.put("imgUrl", imgUrl);
|
sqlSentence.setM(sqlMap);
|
sqlSentence.setSqlSentence(" imgUrl=#{m.imgUrl} WHERE isDel=#{m.isDel} AND id=#{m.userId}");
|
int count = userMapper.updateWhere(sqlSentence);
|
if(count!=1) {
|
throw new TipsException("更新头像失败！");
|
}
|
}
|
|
/**修改*/
|
@Override
|
public void updateUserApiId(String userId, String apiId) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> sql = new HashMap<>();
|
sql.put("isDel",BaseEntity.NO);
|
sql.put("userId",userId);
|
sql.put("apiId",apiId);
|
sqlSentence.setSqlSentence(" apiId=#{m.apiId} WHERE isDel=#{m.isDel} AND id=#{m.userId}");
|
sqlSentence.setM(sql);
|
int count = userMapper.updateWhere(sqlSentence);
|
if(count!=1) {
|
throw new TipsException("保存失败！");
|
}
|
}
|
|
/**
|
* 修改用户商汤id
|
*/
|
@Override
|
public void updateUserShangTangId(String userId, String shangTangId) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sql = new HashMap<>();
|
sql.put("isDel", BaseEntity.NO);
|
sql.put("userId", userId);
|
sql.put("shangTangId", shangTangId);
|
sql.put("bindSTTime", new Date());
|
sql.put("editTime", new Date());
|
sqlSentence.setSqlSentence(" shangTangId=#{m.shangTangId},bindSTTime=#{m.bindSTTime},editTime=#{m.editTime} WHERE id=#{m.userId}");
|
sqlSentence.setM(sql);
|
int count = userMapper.updateWhere(sqlSentence);
|
if (count != 1) {
|
throw new TipsException("保存失败！");
|
}
|
}
|
|
/**
|
* 修改用户KOAP(康柏嘉)id
|
*/
|
@Override
|
public void updateUserKOAPId(String userId, String koapId) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> sql = new HashMap<>();
|
sql.put("isDel",BaseEntity.NO);
|
sql.put("userId",userId);
|
sql.put("koapId",koapId);
|
sql.put("bindKOAPTime", new Date());
|
sql.put("editTime", new Date());
|
sqlSentence.setSqlSentence(" koapId=#{m.koapId},bindKOAPTime=#{m.bindKOAPTime},editTime=#{m.editTime} WHERE id=#{m.userId}");
|
sqlSentence.setM(sql);
|
int count = userMapper.updateWhere(sqlSentence);
|
if(count!=1) {
|
throw new TipsException("保存失败！");
|
}
|
}
|
|
/**
|
* 修改用户phimedId
|
*/
|
@Override
|
public void updateUserPhiMedId(String userId, String phiMedId) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> sql = new HashMap<>();
|
sql.put("isDel",BaseEntity.NO);
|
sql.put("userId",userId);
|
sql.put("phimedId",phiMedId);
|
sql.put("bindPhimedTime", new Date());
|
sql.put("editTime", new Date());
|
sqlSentence.setSqlSentence(" phimedId=#{m.phimedId},bindPhimedTime=#{m.bindPhimedTime},editTime=#{m.editTime} WHERE id=#{m.userId}");
|
sqlSentence.setM(sql);
|
int count = userMapper.updateWhere(sqlSentence);
|
if(count!=1) {
|
throw new TipsException("保存失败！");
|
}
|
}
|
|
/**删除一个*/
|
@Override
|
public void deleteUser(String delId) {
|
// 删除用户信息
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> map = new HashMap<>();
|
map.put("id", delId);
|
map.put("isDel", BaseEntity.YES);
|
sqlSentence.setSqlSentence(" isDel = #{m.isDel} where id = #{m.id}");
|
sqlSentence.setM(map);
|
int count = userMapper.updateWhere(sqlSentence);
|
if(count!=1) {
|
throw new TipsException("删除失败！");
|
}else {
|
// 删除用户后处理
|
sqlSentence.setSqlSentence(" isDel = #{m.isDel} where userId = #{m.id}");
|
// 删除用户详细信息
|
userInfoMapper.updateWhere(sqlSentence);
|
|
// 删除用户联系信息
|
userContactInformationMapper.updateWhere(sqlSentence);
|
|
// 删除用户兴趣爱好数据
|
userInterestsMapper.updateWhere(sqlSentence);
|
|
// 删除用户电话簿
|
userPhoneBookMapper.updateWhere(sqlSentence);
|
|
// 删除用户地址薄
|
userAddressBookMapper.updateWhere(sqlSentence);
|
}
|
}
|
|
/**
|
* 构建同步 his系统 json 请求数据 到访修改用户信息
|
* @param user 用户对象
|
* @param consultantId 顾问id
|
* @param doctorId 医生id
|
* @return 返回JSON对象
|
*/
|
private JSONObject buildSyncUserHisData(User user,String consultantId,String doctorId) {
|
// 重新刷新下数据
|
user = userMapper.selectOneByKey(user.getId());
|
if (user == null) {
|
throw new TipsException("用户信息不存在！");
|
}
|
|
//同步his用户json参数
|
JSONObject userJson = new JSONObject();
|
userJson.put("id", user.getId());
|
userJson.put("type", BaseEntity.YES);
|
userJson.put("hisId", user.getApiId());
|
|
// 性别
|
if (User.SEX_WUMAN.equals(user.getGender())) {
|
userJson.put("gender", "F");
|
} else if (User.SEX_MAN.equals(user.getGender())) {
|
userJson.put("gender", "M");
|
} else {
|
userJson.put("gender", "M");
|
}
|
// 用户名称处理
|
userJson.put("name", user.getName());
|
|
if (!StringUtils.isEmpty(consultantId)) {
|
//更改所属咨询
|
userJson.put("consultantId", consultantId);
|
}
|
if (!StringUtils.isEmpty(doctorId)) {
|
//更改所属医生
|
userJson.put("doctorId", doctorId);
|
}
|
return userJson;
|
}
|
|
/**
|
* 构建同步 his系统 json 请求数据
|
* @param user 用户对象
|
* @param type 操作类型 0新增 1修改
|
* @param note 客户备注(请求参数如果没有更改备注则不修改HIS的客户备注)
|
* @return 返回JSON对象
|
*/
|
private JSONObject buildSyncUserHisData(User user,String hisShopId,String consultantId,String doctorId,String beauticianId, String customerServiceId,String serviceConsultantId,String note,Integer type) {
|
// 重新刷新下数据
|
user = userMapper.selectOneByKey(user.getId());
|
if (user == null) {
|
throw new TipsException("用户信息不存在！");
|
}
|
|
//同步his用户json参数
|
JSONObject userJson = new JSONObject();
|
userJson.put("id", user.getId());
|
userJson.put("type", type);
|
if (BaseEntity.YES == type) {
|
userJson.put("hisId", user.getApiId());
|
}
|
//是否共享客户（默认否）
|
// userJson.put("isShared",true);
|
|
int gender = user.getGender();
|
if (gender == User.SEX_WUMAN) {
|
userJson.put("gender", "F");
|
} else if (gender == User.SEX_MAN) {
|
userJson.put("gender", "M");
|
} else {
|
userJson.put("gender", "M");
|
}
|
|
// 屏蔽传ciq 荣爷说 20220629
|
/*if(!StringUtils.isEmpty(user.getCIQ())){
|
userJson.put("number",user.getCIQ());
|
}*/
|
|
// 多号码同步领建处理
|
// userJson.put("mobile", user.getTel());
|
|
// 用户名称处理
|
userJson.put("name", user.getName());
|
|
// 渠道来源类型不能为空
|
if (!StringUtils.isEmpty(user.getChannelCategory())) {
|
// 来源类型为渠道
|
if (UserChannelType.CATEGORY_CHANNEL.equals(user.getChannelCategory())) {
|
String channel2Id = user.getChannel2Id();
|
if (!StringUtils.isEmpty(channel2Id)) {
|
Channels channels = commonService.selectOneByKey(ChannelsMapper.class, channel2Id);
|
if (channels != null) {
|
// 判断hisId是否为空
|
if (!StringUtils.isEmpty(channels.getHisId())) {
|
JSONObject referrer = new JSONObject();
|
referrer.put("internal", false);
|
referrer.put("referrerId", channels.getHisId());
|
userJson.put("referrer", referrer);
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "渠道的hisId为空！");
|
}
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "客户来源渠道信息不存在！");
|
}
|
}
|
}
|
|
// 来源类型为会员
|
if (UserChannelType.CATEGORY_MEMBERS.equals(user.getChannelCategory())) {
|
String inviteeId = user.getInviteeId();
|
if (!StringUtils.isEmpty(inviteeId)) {
|
User inviteeUser = commonService.selectOneByKey(UserMapper.class, inviteeId);
|
if (inviteeUser != null) {
|
// 判断hisId是否为空
|
if (!StringUtils.isEmpty(inviteeUser.getApiId())) {
|
JSONObject referrer = new JSONObject();
|
referrer.put("internal", true);
|
referrer.put("referrerId", inviteeUser.getApiId());
|
userJson.put("referrer", referrer);
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "用户的hisId为空！");
|
}
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "客户来源员工信息不存在！");
|
}
|
}
|
}
|
|
// 来源类型为员工
|
if (UserChannelType.CATEGORY_EMPLOYEE.equals(user.getChannelCategory())) {
|
String inviteeId = user.getInviteeId();
|
if (!StringUtils.isEmpty(inviteeId)) {
|
User employeeUser = getUserByEmployee(inviteeId);
|
if (employeeUser != null) {
|
// 判断hisId是否为空
|
if (!StringUtils.isEmpty(employeeUser.getApiId())) {
|
JSONObject referrer = new JSONObject();
|
referrer.put("internal", true);
|
referrer.put("referrerId", employeeUser.getApiId());
|
userJson.put("referrer", referrer);
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "员工用户的hisId为空！");
|
}
|
} else {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "客户来源员工的用户信息不存在！");
|
}
|
}
|
}
|
}
|
|
String birthDay = user.getBirthDay();
|
if (!StringUtils.isEmpty(birthDay)) {
|
String[] birthDays = birthDay.split("-");
|
if (birthDays.length >= 3) {
|
JSONObject birthdayJson = new JSONObject();
|
birthdayJson.put("year", birthDays[0]);
|
birthdayJson.put("month", birthDays[1]);
|
birthdayJson.put("day", birthDays[2]);
|
userJson.put("birthday", birthdayJson);
|
}
|
}
|
|
// 修改所属信息
|
if (!StringUtils.isEmpty(hisShopId)) {
|
//更改所属门店
|
userJson.put("organizationId", hisShopId);
|
}
|
if (!StringUtils.isEmpty(consultantId)) {
|
//更改所属咨询
|
userJson.put("consultantId", consultantId);
|
}
|
if (!StringUtils.isEmpty(doctorId)) {
|
//更改所属医生
|
userJson.put("doctorId", doctorId);
|
}
|
if (!StringUtils.isEmpty(beauticianId)) {
|
//更改所属美容师
|
userJson.put("beauticianId", beauticianId);
|
}
|
if (!StringUtils.isEmpty(customerServiceId)) {
|
//更改所属客服
|
userJson.put("customerServiceId", customerServiceId);
|
}
|
if (!StringUtils.isEmpty(serviceConsultantId)) {
|
//更改所属电网咨询师
|
userJson.put("serviceConsultantId", serviceConsultantId);
|
}
|
if (!StringUtils.isEmpty(note)) {
|
//修改备注
|
userJson.put("note", note);
|
}
|
/*else{
|
userJson.put("note","");
|
}*/
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> map = new HashMap<>();
|
sqlSentence.setM(map);
|
sqlSentence.setSqlSentence("SELECT * FROM user_address_book WHERE isDel = 0 and userId = #{m.userId} and addressType = #{m.addressType} ");
|
map.put("userId", user.getId());
|
map.put("addressType", UserAddressBook.TYPE_ADDRESS);
|
List<UserAddressBook> userAddressBooks = userAddressBookMapper.selectList(sqlSentence);
|
JSONObject address = new JSONObject();
|
if (userAddressBooks != null && userAddressBooks.size() > 0) {
|
if (!StringUtils.isEmpty(userAddressBooks.get(0).getCity())) {
|
address.put("country", userAddressBooks.get(0).getCountry());
|
address.put("province", userAddressBooks.get(0).getProvince());
|
address.put("city", userAddressBooks.get(0).getCity());
|
address.put("district", userAddressBooks.get(0).getArea());
|
address.put("street", userAddressBooks.get(0).getDetail());
|
userJson.put("address", address);
|
}
|
}
|
|
// 电话簿同步处理
|
if (!StringUtils.isEmpty(user.getTel())) {
|
JSONArray phoneArray = new JSONArray();
|
// 主号码同步领建处理
|
JSONObject primaryObject = new JSONObject();
|
primaryObject.put("countryCode", "+86");
|
primaryObject.put("number", user.getTel());
|
primaryObject.put("isPrimary", false);
|
// 默认本人
|
primaryObject.put("ownerTypeCode", "self");
|
// 添加到集合
|
phoneArray.add(primaryObject);
|
|
// 查询其他号码
|
String sql = "SELECT * FROM user_phone_book WHERE isDel = #{m.isDel} AND userId = #{m.userId}";
|
map.put("isDel", BaseEntity.NO);
|
map.put("userId", user.getId());
|
sqlSentence.sqlSentence(sql, map);
|
List<UserPhoneBook> userPhoneBookList = userPhoneBookMapper.selectList(sqlSentence);
|
if (userPhoneBookList != null && userPhoneBookList.size() > 0) {
|
for (UserPhoneBook userPhoneBook : userPhoneBookList) {
|
if (!user.getTel().equals(userPhoneBook.getTel())) {
|
// 排除电话号码为空
|
if (StringUtils.isEmpty(userPhoneBook.getTel())) {
|
continue;
|
}
|
JSONObject phoneObject = new JSONObject();
|
phoneObject.put("countryCode", String.format("+%s", userPhoneBook.getAreaCode()));
|
if (Objects.equals(userPhoneBook.getIsPrimary(), BaseEntity.YES)) {
|
phoneObject.put("isPrimary", true);
|
} else {
|
phoneObject.put("isPrimary", false);
|
}
|
phoneObject.put("number", userPhoneBook.getTel());
|
// 默认本人
|
phoneObject.put("ownerTypeCode", "self");
|
// 添加到集合
|
phoneArray.add(phoneObject);
|
}
|
}
|
}
|
userJson.put("phones", phoneArray);
|
}
|
return userJson;
|
}
|
|
/**
|
* 构建康柏嘉用户请求参数
|
* @param user 用户对象
|
* @return json请求数据
|
*/
|
public JSONObject buildKOAPUserData(User user){
|
JSONObject jsonObject = new JSONObject();
|
// 填写患者编号
|
if(!StringUtils.isEmpty(user.getKoapId())){
|
jsonObject.put("patientNo",user.getKoapId());
|
}
|
// 姓名
|
jsonObject.put("patientName",user.getName());
|
// 性别 M：男
|
if(Objects.equals(user.getGender(), User.SEX_MAN)){
|
jsonObject.put("sex","M");
|
}
|
// 性别 F：女
|
if(Objects.equals(user.getGender(), User.SEX_WUMAN)){
|
jsonObject.put("sex","F");
|
}
|
// U：不明
|
if(Objects.equals(user.getGender(), User.SEX_UNKNOWN)){
|
jsonObject.put("sex","U");
|
}
|
// 手机号
|
jsonObject.put("phoneNo",user.getTel());
|
// 出生日期 YYYY-MM-DD
|
jsonObject.put("birthday",user.getBirthDay());
|
// 证件类型 身份证
|
if(!SimpleTool.checkNotNull(user.getCertificateNo()) && !SimpleTool.checkNotNull(user.getCertificateType())) {
|
if (user.getCertificateType() == User.CERTIFICATE_TYPE_ID) {
|
jsonObject.put("idTypeCode", "1");
|
jsonObject.put("idNo", user.getCertificateNo());
|
}
|
// 证件类型 护照
|
if (user.getCertificateType() == User.CERTIFICATE_TYPE_PASSPORT) {
|
jsonObject.put("idTypeCode", "5");
|
jsonObject.put("idNo", user.getCertificateNo());
|
}
|
// 证件类型 台胞证
|
if (user.getCertificateType() == User.CERTIFICATE_TYPE_TAIWAN) {
|
jsonObject.put("idTypeCode", "7");
|
jsonObject.put("idNo", user.getCertificateNo());
|
}
|
}
|
// 备注
|
jsonObject.put("remarks",user.getRemark());
|
|
// 地址获取
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> map = new HashMap<>();
|
sqlSentence.setM(map);
|
sqlSentence.setSqlSentence("SELECT * FROM user_address_book WHERE isDel = 0 and userId = #{m.userId} and addressType = #{m.addressType} ");
|
map.put("userId",user.getId());
|
map.put("addressType",UserAddressBook.TYPE_ADDRESS);
|
List<UserAddressBook> userAddressBooks= commonService.selectList(UserAddressBookMapper.class,sqlSentence);
|
if(userAddressBooks !=null && userAddressBooks.size()>0) {
|
// 省
|
String stateDesc = userAddressBooks.get(0).getProvince();
|
if(!StringUtils.isEmpty(stateDesc)) {
|
if (stateDesc.contains("市")) {
|
stateDesc = stateDesc.replace("市", "");
|
}
|
jsonObject.put("stateDesc", stateDesc);
|
}
|
// 市
|
String cityDesc = userAddressBooks.get(0).getCity();
|
if(!StringUtils.isEmpty(cityDesc)) {
|
if (!StringUtils.isEmpty(userAddressBooks.get(0).getProvince()) && userAddressBooks.get(0).getProvince().contains("市")) {
|
cityDesc = stateDesc;
|
}
|
jsonObject.put("cityDesc", cityDesc);
|
}
|
// 详细地址
|
String address;
|
if (!StringUtils.isEmpty(userAddressBooks.get(0).getArea())) {
|
address = userAddressBooks.get(0).getArea();
|
if (!StringUtils.isEmpty(userAddressBooks.get(0).getDetail())) {
|
address = userAddressBooks.get(0).getDetail();
|
}
|
// 详细地址
|
jsonObject.put("address", address);
|
}
|
}
|
return jsonObject;
|
}
|
|
/**
|
* 根据用户id同步修改领建用户等级
|
* @param userDto 参数
|
* @param user 参数
|
*/
|
@Override
|
public void syncUpdateHisUserLevel(UserDto userDto, User user) {
|
// 添加日志
|
JSONArray jsonArray = new JSONArray();
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "用户等级");
|
jsonObject.put("before", user.getUserLevel());
|
jsonObject.put("after", userDto.getUserLevel());
|
jsonArray.add(jsonObject);
|
// 获取等级配置信息
|
UserLevelRule userLevelRule = UserLevelTool.getUserLevelRuleByName(commonService, userDto.getUserLevel());
|
// 修改数据
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValues = new HashMap<>();
|
sqlValues.put("id", user.getId());
|
sqlValues.put("userLevel", userDto.getUserLevel());
|
sqlValues.put("memberLevelId", userLevelRule.getMemberLevelId());
|
sqlSentence.sqlSentence(" userLevel=#{m.userLevel},memberLevelId=#{m.memberLevelId} WHERE id = #{m.id}", sqlValues);
|
int count = userMapper.updateWhere(sqlSentence);
|
if (count != 1) {
|
throw new TipsException("修改用户等级失败");
|
} else {
|
// 有日志才去添加日志
|
if (jsonArray.size() > 0) {
|
// 处理用户日志
|
UserUpdateLog userUpdateLog = new UserUpdateLog();
|
userUpdateLog.setUserId(userDto.getUserId());
|
// 来源渠道
|
userUpdateLog.setSourceAppCode(userDto.getAppIdCode());
|
if (!StringUtils.isEmpty(userDto.getAppIdCode())){
|
String name = PlatformConstants.getName(userDto.getAppIdCode());
|
userUpdateLog.setSourceAppName(name);
|
}
|
// 门店信息处理
|
if (!StringUtils.isEmpty(userDto.getShopId())) {
|
Shop shop = commonService.selectOneByKey(ShopMapper.class, userDto.getShopId());
|
if (shop != null) {
|
userUpdateLog.setShopId(shop.getId());
|
userUpdateLog.setShopName(shop.getName());
|
}
|
}
|
// 管理员处理
|
if (!StringUtils.isEmpty(userDto.getOpId())) {
|
Employee employee = commonService.selectOneByKey(EmployeeMapper.class, userDto.getOpId());
|
if (employee != null) {
|
userUpdateLog.setOperatorType(UserUpdateLog.OPERATOR_TYPE_EMPLOYEE);
|
userUpdateLog.setOperatorId(employee.getId());
|
userUpdateLog.setOperatorName(employee.getCnName());
|
}
|
} else {
|
userUpdateLog.setOperatorType(UserUpdateLog.OPERATOR_TYPE_SYSTEM);
|
}
|
userUpdateLog.setContent(jsonArray.toJSONString());
|
// 记录编号
|
String recordNo = systemParameterService.createUSLGNo(user.getId(), user.getCIQ());
|
userUpdateLog.setRecordNo(recordNo);
|
int logCount = userUpdateLogMapper.insert(userUpdateLog);
|
if (logCount != 1) {
|
throw new TipsException("记录修改用户日志失败：" + logCount);
|
}
|
}
|
// 用户等级记录添加信息
|
UserLevelTool.addUserLevelRecord(commonService, user, userLevelRule, null, userDto.getOpId());
|
// 调用同步接口同步操作领建
|
UserLevelTool.syncUpdateHisUserLevel(commonService, syncUserService, user.getId(), userDto.getAppIdCode());
|
}
|
}
|
|
/**
|
* 获取用户等级
|
* @param user 用户
|
* @return 返回
|
*/
|
private UserLevelRule getUserNowLevelRule(User user) {
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValue = new HashMap<>();
|
sqlValue.put("isDel", BaseEntity.NO);
|
StringBuilder sql = new StringBuilder();
|
sql.append("SELECT * FROM user_level_rule WHERE isDel = #{m.isDel} ");
|
if (!StringUtils.isEmpty(user.getMemberLevelId())) {
|
sql.append(" AND memberLevelId = #{m.memberLevelId} ");
|
sqlValue.put("memberLevelId", user.getMemberLevelId());
|
} else if (!StringUtils.isEmpty(user.getUserLevel())) {
|
sql.append(" AND levelName = #{m.levelName} ");
|
sqlValue.put("levelName", user.getUserLevel());
|
} else {
|
return null;
|
}
|
sqlSentence.sqlSentence(sql.toString(), sqlValue);
|
return commonService.selectOne(UserLevelRuleMapper.class, sqlSentence);
|
}
|
|
/**
|
* 用户等级计算测试方法
|
* @param user 用户
|
* @return 返回
|
*/
|
@Override
|
public JSONObject userLevelProgress(User user) {
|
// 计算当年消费消费总计
|
BigDecimal nowConsume = UserLevelTool.getAllConsumeOrder(commonService, user.getId(), BaseEntity.YES, BaseEntity.NO);
|
// 等级升级规则
|
UserLevelRule userLevelRule = null;
|
if (StringUtils.isEmpty(user.getUserLevel())) {
|
// 默认会员等级普卡
|
userLevelRule = UserLevelTool.getUserLevelRuleByLeveSort(commonService, 2);
|
} else {
|
// 查询当前等级规则数据
|
UserLevelRule nowUserLevelRule = this.getUserNowLevelRule(user);
|
if (nowUserLevelRule != null) {
|
// 黑钻卡不需要在显示
|
if ("BlackDiamondsCard".equals(nowUserLevelRule.getLevelNo())) {
|
return null;
|
} else {
|
userLevelRule = UserLevelTool.getUserLevelRuleByLeveSort(commonService, nowUserLevelRule.getLevelSort() + 1);
|
}
|
}
|
}
|
// 获取下一个等级的消费金额
|
if (userLevelRule != null) {
|
// 获取规则
|
JSONObject rule = JSONObject.parseObject(userLevelRule.getUpgradeYearConsumeRule());
|
if (rule != null && rule.containsKey("value") && rule.get("value") != null) {
|
BigDecimal upgradeConsume = rule.getBigDecimal("value");
|
// 返回数据
|
JSONObject returnData = new JSONObject();
|
returnData.put("nowConsume", nowConsume);
|
// 准会员大于0就会升级
|
if (BigDecimal.ZERO.compareTo(upgradeConsume) == 0){
|
upgradeConsume = BigDecimal.ONE;
|
}
|
returnData.put("upgradeConsume", upgradeConsume);
|
returnData.put("difference", upgradeConsume.subtract(nowConsume));
|
return returnData;
|
}
|
}
|
return null;
|
}
|
|
/**
|
* 构建日志信息
|
* @return 返回
|
*/
|
private String getUserFamiliesRoomInfo(UserFamiliesRoom userFamiliesRoom) {
|
// 参数数据
|
JSONObject jsonObject = null;
|
if (userFamiliesRoom != null) {
|
// 数据处理
|
jsonObject = new JSONObject();
|
// 所属科室
|
if (!StringUtils.isEmpty(userFamiliesRoom.getFamiliesRoomName())) {
|
jsonObject.put("所属科室", userFamiliesRoom.getFamiliesRoomName());
|
}
|
// 所属顾问
|
if (!StringUtils.isEmpty(userFamiliesRoom.getAdviserName())) {
|
jsonObject.put("所属顾问", userFamiliesRoom.getAdviserName());
|
}
|
// 所属医生
|
if (!StringUtils.isEmpty(userFamiliesRoom.getDoctorName())) {
|
jsonObject.put("所属医生", userFamiliesRoom.getDoctorName());
|
}
|
// 所属护士
|
if (!StringUtils.isEmpty(userFamiliesRoom.getNurseName())) {
|
jsonObject.put("所属护士", userFamiliesRoom.getNurseName());
|
}
|
}
|
// 返回数据
|
if (jsonObject != null) {
|
return jsonObject.toJSONString();
|
}
|
return null;
|
}
|
|
/**
|
* 修改用户科室关系信息
|
* @param userParamDto 参数
|
* @param user 用户信息
|
* @param opEmployee 操作人
|
*/
|
@Override
|
public void updateFamiliesRoom(UserParamDto userParamDto, User user, Employee opEmployee) {
|
// 科室数据
|
List<UserFamiliesRoom> userFamiliesRoomList;
|
try {
|
userFamiliesRoomList = JSONArray.parseArray(userParamDto.getDepartmentJson(), UserFamiliesRoom.class);
|
} catch (Exception ex) {
|
throw new TipsException("科室关系参数解析失败请确认参数!");
|
}
|
// 操作数据处理
|
if (userFamiliesRoomList != null && userFamiliesRoomList.size() > 0) {
|
// 日志数据
|
JSONArray logArray = new JSONArray();
|
// 处理数据
|
for (UserFamiliesRoom userFamiliesRoom : userFamiliesRoomList) {
|
// 科室id
|
FamiliesRoom familiesRoom;
|
if (StringUtils.isEmpty(userFamiliesRoom.getFamiliesRoomId())) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "数据中的科室id不能为空！");
|
} else {
|
familiesRoom = familiesRoomMapper.selectOneByKey(userFamiliesRoom.getFamiliesRoomId());
|
if (familiesRoom == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "数据中的科室信息不存在！");
|
}
|
}
|
// 之前用户科室Json信息
|
String checkUserFamiliesRoomBefore = null;
|
// 校验数据是否存在存在数据就修改 每个科室只有一条
|
UserFamiliesRoom checkUserFamiliesRoom = UserInfoTool.getUserFamiliesRoom(commonService, user.getId(), familiesRoom.getId());
|
if (checkUserFamiliesRoom != null) {
|
checkUserFamiliesRoomBefore = this.getUserFamiliesRoomInfo(checkUserFamiliesRoom);
|
}
|
// 科室信息
|
if (checkUserFamiliesRoom != null) {
|
checkUserFamiliesRoom.setFamiliesRoomId(familiesRoom.getId());
|
checkUserFamiliesRoom.setFamiliesRoomName(familiesRoom.getFamiliesRoomName());
|
} else {
|
userFamiliesRoom.setFamiliesRoomId(familiesRoom.getId());
|
userFamiliesRoom.setFamiliesRoomName(familiesRoom.getFamiliesRoomName());
|
}
|
// 用户信息
|
userFamiliesRoom.setUserId(user.getId());
|
// 顾问
|
if (!StringUtils.isEmpty(userFamiliesRoom.getAdviserId())) {
|
Employee employee = employeeMapper.selectOneByKey(userFamiliesRoom.getAdviserId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "数据中的顾问信息不存在！");
|
} else {
|
if (checkUserFamiliesRoom != null) {
|
checkUserFamiliesRoom.setAdviserId(employee.getId());
|
checkUserFamiliesRoom.setAdviserName(employee.getCnName());
|
} else {
|
userFamiliesRoom.setAdviserId(employee.getId());
|
userFamiliesRoom.setAdviserName(employee.getCnName());
|
}
|
}
|
}
|
// 医生
|
if (!StringUtils.isEmpty(userFamiliesRoom.getDoctorId())) {
|
Employee employee = employeeMapper.selectOneByKey(userFamiliesRoom.getDoctorId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "数据中的医生信息不存在！");
|
} else {
|
if (checkUserFamiliesRoom != null) {
|
checkUserFamiliesRoom.setDoctorId(employee.getId());
|
checkUserFamiliesRoom.setDoctorName(employee.getCnName());
|
} else {
|
userFamiliesRoom.setDoctorId(employee.getId());
|
userFamiliesRoom.setDoctorName(employee.getCnName());
|
}
|
}
|
}
|
// 护士
|
if (!StringUtils.isEmpty(userFamiliesRoom.getNurseId())) {
|
Employee employee = employeeMapper.selectOneByKey(userFamiliesRoom.getNurseId());
|
if (employee == null) {
|
throw new PlatTipsException(PlatformCode.ERROR_TIPS, "数据中的护士信息不存在！");
|
} else {
|
if (checkUserFamiliesRoom != null) {
|
checkUserFamiliesRoom.setNurseId(employee.getId());
|
checkUserFamiliesRoom.setNurseName(employee.getCnName());
|
} else {
|
userFamiliesRoom.setNurseId(employee.getId());
|
userFamiliesRoom.setNurseName(employee.getCnName());
|
}
|
}
|
}
|
// 判断是添加还是修改
|
if (checkUserFamiliesRoom == null) {
|
// 添加用户科室数据
|
userFamiliesRoomMapper.insert(userFamiliesRoom);
|
// 处理用户日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "添加用户科室关系");
|
jsonObject.put("before", "");
|
// 之后信息
|
String userFamiliesRoomAfter = this.getUserFamiliesRoomInfo(userFamiliesRoom);
|
jsonObject.put("after", userFamiliesRoomAfter);
|
logArray.add(jsonObject);
|
} else {
|
// 修改用户科室数据
|
checkUserFamiliesRoom.setEditTime(new Date());
|
userFamiliesRoomMapper.updateAll(checkUserFamiliesRoom);
|
// 处理用户日志
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改用户科室关系");
|
jsonObject.put("before", checkUserFamiliesRoomBefore);
|
// 之后信息
|
String checkUserFamiliesRoomAfter = this.getUserFamiliesRoomInfo(checkUserFamiliesRoom);
|
jsonObject.put("after", checkUserFamiliesRoomAfter);
|
logArray.add(jsonObject);
|
}
|
}
|
// 记录编号
|
String recordNo = systemParameterService.createUSLGNo(user.getId(), user.getCIQ());
|
// 添加用户日志
|
UserInfoTool.addUserUpdateLog(commonService, userParamDto.getApiId(), user, user.getShopId(), opEmployee.getId(), null, null, "调整用户科室关系数据", logArray, null, recordNo);
|
}
|
}
|
|
/**
|
* 重新计算用户等级
|
* @param userParamDto 参数
|
* @param user 用户信息
|
* @param employee 操作人信息
|
*/
|
@Override
|
public void userLevelCalc(UserParamDto userParamDto, User user, Employee employee) {
|
// 获取最后一条等级改变记录
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> sqlValue = new HashMap<>();
|
sqlValue.put("userId", userParamDto.getUserId());
|
sqlValue.put("isDel", BaseEntity.NO);
|
sqlValue.put("isNowLevel", BaseEntity.YES);
|
String sql = "SELECT * FROM user_level_record WHERE userId = #{m.userId} AND isNowLevel = #{m.isNowLevel} AND isDel = #{m.isDel} ORDER BY createTime DESC LIMIT 1";
|
sqlSentence.sqlSentence(sql, sqlValue);
|
UserLevelRecord lastUserLevelRecord = commonService.selectOne(com.hx.phiappt.dao.mapper.UserLevelRecordMapper.class, sqlSentence);
|
if (lastUserLevelRecord != null) {
|
// 备注填写下
|
lastUserLevelRecord.setRemarks("重新计算用户等级-" + userParamDto.getRemark());
|
// 填写下操作人信息
|
lastUserLevelRecord.setOperatorType(UserLevelRecord.OPERATOR_TYPE_EMPLOYEE);
|
lastUserLevelRecord.setOperatorId(employee.getId());
|
lastUserLevelRecord.setOperatorName(employee.getCnName());
|
// 处理重新计算用户等级
|
UserLevelTool.reCalcUserLevel(commonService, lastUserLevelRecord, user);
|
// 添加用户日志
|
User checkUser = commonService.selectOneByKey(UserMapper.class, user.getId());
|
if (checkUser != null && !StringUtils.isEmpty(checkUser.getUserLevel()) && !checkUser.getUserLevel().equals(user.getUserLevel())) {
|
JSONArray logArray = new JSONArray();
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "重新计算用户等级");
|
jsonObject.put("before", user.getUserLevel());
|
jsonObject.put("after", checkUser.getUserLevel());
|
logArray.add(jsonObject);
|
// 记录编号
|
String recordNo = UserInfoTool.createUSLGNo(commonService, user.getId(), user.getCIQ());
|
// 添加日志
|
UserInfoTool.addUserUpdateLog(commonService, PlatformConstants.TYPE_PLATFORM_PHIS, user, user.getShopId(), employee.getId(), null, null, "重新计算用户等级", logArray, userParamDto.getRemark(), recordNo);
|
}
|
} else {
|
throw new TipsException("当前用户没有等级记录不需要重新计算!");
|
}
|
}
|
|
@Override
|
public void userCompleteInfoById(UserInfoCompleteDto userInfoCompleteDto, User user) {
|
|
JSONArray logArray = new JSONArray();
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
String userId = user.getId();
|
values.put("userId", userId);
|
|
// 处理日志
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getName())) {
|
if (!userInfoCompleteDto.getName().equals(user.getName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改姓名");
|
jsonObject.put("before", user.getName());
|
jsonObject.put("after", userInfoCompleteDto.getName());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (userInfoCompleteDto.getGender() != null) {
|
if (!userInfoCompleteDto.getGender().equals(user.getGender())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改性别");
|
jsonObject.put("before", user.getGender());
|
jsonObject.put("after", userInfoCompleteDto.getGender());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getTel())) {
|
if (!userInfoCompleteDto.getTel().equals(user.getTel())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改手机号");
|
jsonObject.put("before", user.getTel());
|
jsonObject.put("after", userInfoCompleteDto.getTel());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (userInfoCompleteDto.getCertificateType() != null && !StringUtils.isEmpty(userInfoCompleteDto.getCertificateNo())) {
|
if (!userInfoCompleteDto.getCertificateType().equals(user.getCertificateType())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改证件类型");
|
jsonObject.put("before", user.getCertificateType());
|
jsonObject.put("after", userInfoCompleteDto.getCertificateType());
|
logArray.add(jsonObject);
|
}
|
|
if (!userInfoCompleteDto.getCertificateNo().equals(user.getCertificateNo())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改身份证号码");
|
jsonObject.put("before", user.getCertificateNo());
|
jsonObject.put("after", userInfoCompleteDto.getCertificateNo());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getBirthDay())) {
|
if (!userInfoCompleteDto.getBirthDay().equals(user.getBirthDay())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改生日");
|
jsonObject.put("before", user.getBirthDay());
|
jsonObject.put("after", userInfoCompleteDto.getBirthDay());
|
logArray.add(jsonObject);
|
}
|
}
|
//user表更新字段
|
values.put("name", userInfoCompleteDto.getName());
|
values.put("gender", userInfoCompleteDto.getGender());
|
values.put("tel", userInfoCompleteDto.getTel());
|
values.put("certificateType", userInfoCompleteDto.getCertificateType());
|
values.put("certificateNo", userInfoCompleteDto.getCertificateNo());
|
values.put("birthday", userInfoCompleteDto.getBirthDay());
|
sqlSentence.setSqlSentence(" name = #{m.name},gender = #{m.gender}, tel = #{m.tel}, certificateType = #{m.certificateType}, certificateNo = #{m.certificateNo},birthday = #{m.birthday} where id = #{m.userId} ");
|
if (userMapper.updateWhere(sqlSentence) != 1) throw new TipsException("更新用户信息失败！");
|
|
|
//user_info 更新字段
|
UserInfo userInfo = userInfoMapper.selectOneByUserId(userInfoCompleteDto.getUserId());
|
if (userInfo != null) {
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getProfessionTypeName())) {
|
if (!userInfoCompleteDto.getProfessionTypeName().equals(userInfo.getProfessionTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改工作");
|
jsonObject.put("before", userInfo.getProfessionTypeName());
|
jsonObject.put("after", userInfoCompleteDto.getProfessionTypeName());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getMarriageTypeName())) {
|
if (!userInfoCompleteDto.getMarriageTypeName().equals(userInfo.getMarriageTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改婚否");
|
jsonObject.put("before", userInfo.getMarriageTypeName());
|
jsonObject.put("after", userInfoCompleteDto.getMarriageTypeName());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getGrowthTypeName())) {
|
if (!userInfoCompleteDto.getGrowthTypeName().equals(userInfo.getGrowthTypeName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改生育");
|
jsonObject.put("before", userInfo.getGrowthTypeName());
|
jsonObject.put("after", userInfoCompleteDto.getGrowthTypeName());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getSourceName())) {
|
if (!userInfoCompleteDto.getSourceName().equals(userInfo.getSourceName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改冗余来源名称");
|
jsonObject.put("before", userInfo.getSourceName());
|
jsonObject.put("after", userInfoCompleteDto.getSourceName());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (userInfoCompleteDto.getIsFriendReferrer() != null && !StringUtils.isEmpty(userInfoCompleteDto.getFriendName())) {
|
if (!userInfoCompleteDto.getIsFriendReferrer().equals(userInfo.getIsFriendReferrer())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改是否好友推荐");
|
jsonObject.put("before", userInfo.getIsFriendReferrer());
|
jsonObject.put("after", userInfoCompleteDto.getIsFriendReferrer());
|
logArray.add(jsonObject);
|
}
|
|
if (!userInfoCompleteDto.getFriendName().equals(userInfo.getFriendName())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改推荐人名称");
|
jsonObject.put("before", userInfo.getFriendName());
|
jsonObject.put("after", userInfoCompleteDto.getFriendName());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getMainAppeal())) {
|
if (!userInfoCompleteDto.getMainAppeal().equals(userInfo.getMainAppeal())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改主要诉求");
|
jsonObject.put("before", userInfo.getMainAppeal());
|
jsonObject.put("after", userInfoCompleteDto.getMainAppeal());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getMinorAppeal())) {
|
if (!userInfoCompleteDto.getMinorAppeal().equals(userInfo.getMinorAppeal())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改次要诉求");
|
jsonObject.put("before", userInfo.getMinorAppeal());
|
jsonObject.put("after", userInfoCompleteDto.getMinorAppeal());
|
logArray.add(jsonObject);
|
}
|
}
|
|
values.put("userInfoId", userInfo.getId());
|
values.put("professionTypeName", userInfoCompleteDto.getProfessionTypeName());
|
values.put("marriageTypeName", userInfoCompleteDto.getMarriageTypeName());
|
values.put("growthTypeName", userInfoCompleteDto.getGrowthTypeName());
|
values.put("sourceName", userInfoCompleteDto.getSourceName());
|
values.put("isFriendReferrer", userInfoCompleteDto.getIsFriendReferrer());
|
values.put("friendName", userInfoCompleteDto.getFriendName());
|
values.put("mainAppeal", userInfoCompleteDto.getMainAppeal());
|
values.put("minorAppeal", userInfoCompleteDto.getMinorAppeal());
|
sqlSentence.setSqlSentence(" professionTypeName = #{m.professionTypeName},marriageTypeName = #{m.marriageTypeName}, growthTypeName = #{m.growthTypeName}, sourceName = #{m.sourceName}, isFriendReferrer = #{m.isFriendReferrer}, friendName = #{m.friendName}, mainAppeal = #{m.mainAppeal}, minorAppeal = #{m.minorAppeal} where id = #{m.userInfoId}");
|
if (userInfoMapper.updateWhere(sqlSentence) != 1) throw new TipsException("更新用户详情信息失败！");
|
|
} else {
|
userInfo = new UserInfo();
|
userInfo.setProfessionTypeName(userInfoCompleteDto.getProfessionTypeName());
|
userInfo.setMarriageTypeName(userInfoCompleteDto.getMarriageTypeName());
|
userInfo.setGrowthTypeName(userInfoCompleteDto.getGrowthTypeName());
|
userInfo.setSourceName(userInfoCompleteDto.getSourceName());
|
userInfo.setIsFriendReferrer(userInfoCompleteDto.getIsFriendReferrer());
|
userInfo.setFriendName(userInfoCompleteDto.getFriendName());
|
userInfo.setMainAppeal(userInfoCompleteDto.getMainAppeal());
|
userInfo.setMinorAppeal(userInfoCompleteDto.getMinorAppeal());
|
userInfo.setUserId(userId);
|
if (userInfoMapper.insert(userInfo) != 1) throw new TipsException("新增用户详情信息失败！");
|
}
|
|
//user_contact_information 更新字段
|
UserContactInformation contactInformation = userContactInformationMapper.selectOneByUserId(userId);
|
if (contactInformation != null) {
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getEmail())) {
|
if (!userInfoCompleteDto.getEmail().equals(contactInformation.getEmail())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改邮箱");
|
jsonObject.put("before", contactInformation.getEmail());
|
jsonObject.put("after", userInfoCompleteDto.getEmail());
|
logArray.add(jsonObject);
|
}
|
}
|
|
values.put("email", userInfoCompleteDto.getEmail());
|
values.put("contactInformationId", contactInformation.getId());
|
sqlSentence.setSqlSentence(" email = #{m.email} where id = #{m.contactInformationId}");
|
if (userContactInformationMapper.updateWhere(sqlSentence) != 1) throw new TipsException("更新用户联系信息失败！");
|
} else {
|
contactInformation = new UserContactInformation();
|
contactInformation.setEmail(userInfoCompleteDto.getEmail());
|
contactInformation.setUserId(userId);
|
if (userContactInformationMapper.insert(contactInformation) != 1)
|
throw new TipsException("新增用户联系信息失败！");
|
}
|
|
// user_address_book 更新字段
|
sqlSentence.setSqlSentence("select * from user_address_book where userId = #{m.userId} and addressType = 1 and isDel = 0 order by createTime desc limit 1");
|
UserAddressBook userAddressBook = userAddressBookMapper.selectOne(sqlSentence);
|
if (userAddressBook != null) {
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getCountry())) {
|
if (!userInfoCompleteDto.getCountry().equals(userAddressBook.getCountry())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改地址-国家");
|
jsonObject.put("before", userAddressBook.getCountry());
|
jsonObject.put("after", userInfoCompleteDto.getCountry());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getCountry())) {
|
if (!userInfoCompleteDto.getProvince().equals(userAddressBook.getProvince())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改地址-省份");
|
jsonObject.put("before", userAddressBook.getProvince());
|
jsonObject.put("after", userInfoCompleteDto.getProvince());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getCity())) {
|
if (!userInfoCompleteDto.getCity().equals(userAddressBook.getCity())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改地址-城市");
|
jsonObject.put("before", userAddressBook.getCity());
|
jsonObject.put("after", userInfoCompleteDto.getCity());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getArea())) {
|
if (!userInfoCompleteDto.getArea().equals(userAddressBook.getArea())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改地址-区域");
|
jsonObject.put("before", userAddressBook.getArea());
|
jsonObject.put("after", userInfoCompleteDto.getArea());
|
logArray.add(jsonObject);
|
}
|
}
|
|
if (!StringUtils.isEmpty(userInfoCompleteDto.getDetail())) {
|
if (!userInfoCompleteDto.getDetail().equals(userAddressBook.getDetail())) {
|
JSONObject jsonObject = new JSONObject();
|
jsonObject.put("key", "修改地址-详细");
|
jsonObject.put("before", userAddressBook.getDetail());
|
jsonObject.put("after", userInfoCompleteDto.getDetail());
|
logArray.add(jsonObject);
|
}
|
}
|
|
values.put("country", userInfoCompleteDto.getCountry());
|
values.put("province", userInfoCompleteDto.getProvince());
|
values.put("city", userInfoCompleteDto.getCity());
|
values.put("area", userInfoCompleteDto.getArea());
|
values.put("detail", userInfoCompleteDto.getDetail());
|
values.put("userAddressBookId", userAddressBook.getId());
|
sqlSentence.setSqlSentence(" country = #{m.country},province = #{m.province}, city = #{m.city}, area = #{m.area}, detail = #{m.detail} where id = #{m.userAddressBookId}");
|
if (userAddressBookMapper.updateWhere(sqlSentence) != 1) throw new TipsException("更新用户地址信息失败！");
|
} else {
|
userAddressBook = new UserAddressBook();
|
userAddressBook.setUserId(userId);
|
userAddressBook.setCountry(userInfoCompleteDto.getCountry());
|
userAddressBook.setProvince(userInfoCompleteDto.getProvince());
|
userAddressBook.setCity(userInfoCompleteDto.getCity());
|
userAddressBook.setArea(userInfoCompleteDto.getArea());
|
userAddressBook.setDetail(userInfoCompleteDto.getDetail());
|
if (userAddressBookMapper.insert(userAddressBook) != 1) throw new TipsException("新增用户地址信息失败！");
|
}
|
|
//------- 处理用户标签数据
|
handleUserTag(userInfoCompleteDto);
|
|
//--------处理关注公众号
|
try {
|
handleGzhFocusRecord(userId);
|
}catch (Exception e){
|
logger.info("完善资料页更新关注公众号记录异常:{}", GlobalExceptionHandler.getExceptionInformation(e));
|
}
|
|
//----------------添加日志
|
// 记录编号
|
String recordNo = UserInfoTool.createUSLGNo(commonService, user.getId(), user.getCIQ());
|
UserInfoTool.addUserUpdateLog(commonService, PlatformConstants.TYPE_PLATFORM_CRM, user, user.getShopId(), user.getId(), null, null, "crm用户扫码编辑自己信息页", logArray, null, recordNo);
|
|
}
|
|
|
///////////////////////////////////////////////////////////////////////////////////////////////////////////////////
|
|
/** 用户信息完善 处理标签信息**/
|
public void handleUserTag(UserInfoCompleteDto userInfoCompleteDto) {
|
|
//------- 处理用户标签数据
|
|
//标签 -职位
|
UserLabelDcpDto professionType= new UserLabelDcpDto();
|
professionType.setIsCustom(1);
|
|
// 标签 - 婚否
|
UserLabelDcpDto marriageTyp = new UserLabelDcpDto();
|
marriageTyp.setIsCustom(0);
|
|
// 标签- 生育
|
UserLabelDcpDto growthType = new UserLabelDcpDto();
|
growthType.setIsCustom(0);
|
|
|
//区分环境处理 职业 生育 婚否
|
if ("prod".equals(customParameter.getPlatformPattern())){
|
//职业
|
professionType.setTypeNo("LT20230406mRbkLG");
|
|
//婚否
|
marriageTyp.setTypeNo("LT202208162cHDcz");
|
if(userInfoCompleteDto.getMarriageTypeName().equals("已婚")){
|
marriageTyp.setTagNo("LA20220816MsuHuP");
|
}else {
|
marriageTyp.setTagNo("LA20220816Gl0vLL");
|
}
|
|
//生育
|
growthType.setTypeNo("LT20230921QnaLns");
|
if(userInfoCompleteDto.getGrowthTypeName().equals("已育")){
|
growthType.setTagNo("LA20230921TgcoAc");
|
}else {
|
growthType.setTagNo("LA20230921HWZNLS");
|
}
|
}else{
|
|
//职业
|
professionType.setTypeNo("profession");
|
|
//婚否
|
marriageTyp.setTypeNo("LT20230921zyrMZC");
|
if(userInfoCompleteDto.getMarriageTypeName().trim().equals("已婚")){
|
marriageTyp.setTagNo("LA20230921hkVYme");
|
}else {
|
marriageTyp.setTagNo("LA20230921s87r0q");
|
}
|
|
//生育
|
growthType.setTypeNo("LT20230921Mg7yoF");
|
if(userInfoCompleteDto.getGrowthTypeName().trim().equals("已育")){
|
growthType.setTagNo("LA202309218d5OFD");
|
}else {
|
growthType.setTagNo("LA20230921KtufiX");
|
}
|
}
|
|
List<UserLabelDcpDto> list = new ArrayList<>();
|
UserLabelDcpAddDto userLabelAddDto = new UserLabelDcpAddDto();
|
userLabelAddDto.setUserId(userInfoCompleteDto.getUserId());
|
professionType.setTagName(userInfoCompleteDto.getProfessionTypeName().trim());
|
list.add(professionType);
|
marriageTyp.setTagName(userInfoCompleteDto.getMarriageTypeName().trim());
|
list.add(marriageTyp);
|
growthType.setTagName(userInfoCompleteDto.getGrowthTypeName().trim());
|
list.add(growthType);
|
userLabelAddDto.setUserLabelDtoList(list);
|
|
List<UserLabelDcpDto> userLabelDtoLists = userLabelAddDto.getUserLabelDtoList();
|
if (userLabelDtoLists == null) {
|
userLabelDtoLists = new ArrayList<>();
|
}
|
for (UserLabelDcpDto userLabelDcpDto : userLabelDtoLists) {
|
if (StringUtils.isEmpty(userLabelDcpDto.getTagName())) {
|
throw new TipsException("标签名称为空!");
|
}
|
if (userLabelDcpDto.getIsCustom() == null) {
|
throw new TipsException("请选择标签是否自定义!");
|
}
|
}
|
|
|
JSONObject data = new JSONObject();
|
data.put("userId", userLabelAddDto.getUserId());
|
data.put("sourceType", "phis");
|
|
List<String> tagList = new ArrayList<>();
|
List<UserLabelDcpDto> userLabelDtoList = userLabelAddDto.getUserLabelDtoList();
|
if (userLabelDtoList != null && userLabelDtoList.size() > 0) {
|
List<Map<String, Object>> editUserTagInfoList = new ArrayList<>();
|
Map<String, Object> editUserTagInfo;
|
for (UserLabelDcpDto userLabelDcpDto : userLabelDtoList) {
|
editUserTagInfo = new HashMap<>();
|
editUserTagInfo.put("typeNo", userLabelDcpDto.getTypeNo());
|
editUserTagInfo.put("tagName", userLabelDcpDto.getTagName().trim());
|
if (userLabelDcpDto.getIsCustom() == 1) {
|
editUserTagInfo.put("isCustom", userLabelDcpDto.getIsCustom());
|
} else if (userLabelDcpDto.getIsCustom() == 0) {
|
editUserTagInfo.put("isCustom", userLabelDcpDto.getIsCustom());
|
editUserTagInfo.put("tagNo", userLabelDcpDto.getTagNo());
|
}
|
tagList.add(userLabelDcpDto.getTagName().trim());
|
editUserTagInfoList.add(editUserTagInfo);
|
}
|
data.put("editUserTagInfoList", editUserTagInfoList);
|
}
|
|
//要删除的标签 固定 - 职位 生育 婚否
|
SqlSentence sqlSentence = new SqlSentence();
|
Map<String,Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
values.put("userId",userLabelAddDto.getUserId());
|
sqlSentence.setSqlSentence(" select * from user_general_label where isDel = 0 and userId = #{m.userId} and labelTypeNo IN ('LT20230921zyrMZC','LT20230921Mg7yoF','LT202208162cHDcz','LT20230921QnaLns','LT202208162cHDcz','LT20230921QnaLns','profession','LT20230406mRbkLG') ");
|
List<UserGeneralLabel> userGeneralLabelList = commonService.selectList(UserGeneralLabelMapper.class,sqlSentence);
|
|
List<String> deleteList = new ArrayList<>();
|
if (userGeneralLabelList != null && userGeneralLabelList.size() > 0) {
|
List<UserGeneralLabel> oldList = userGeneralLabelList.stream().filter(oldInfo -> !tagList.stream().collect(Collectors.toList())
|
.contains(oldInfo.getName())).collect(Collectors.toList());
|
if (oldList != null && oldList.size() > 0) {
|
for (UserGeneralLabel tagInfoDt : oldList) {
|
deleteList.add(tagInfoDt.getSourceId());
|
}
|
data.put("deleteUserTagInfoIdList", deleteList);
|
}
|
}
|
|
logger.info("dcp更新用户基本信息标签(工作/生育/婚否):{}", JSONObject.toJSONString(data));
|
sUserTagInfoService.edit(data);
|
}
|
|
|
/**处理用户关注公众号 */
|
public void handleGzhFocusRecord(String userId) {
|
|
User user = userMapper.selectOneByKey(userId);
|
if(user == null){
|
return;
|
}
|
|
SqlSentence sqlSentence = new SqlSentence();
|
StringBuffer sql = new StringBuffer();
|
Map<String, Object> values = new HashMap<>();
|
sqlSentence.setM(values);
|
|
values.put("isDel", BaseEntity.NO);
|
values.put("userId", userId);
|
|
//查询用户登录数据 获取unionId
|
sql.append(" select * from user_union_his where userId = #{m.userId} AND isDel = #{m.isDel} order by createTime desc limit 1");
|
sqlSentence.setSqlSentence(sql.toString());
|
UserUnionHis userUnionHis = commonService.selectOne(UserUnionHisMapper.class, sqlSentence);
|
if (userUnionHis != null && !StringUtils.isEmpty(userUnionHis.getUnionId())) {
|
//查询公众号关注记录
|
sql.delete(0, sql.length());
|
values.put("unionId", userUnionHis.getUnionId());
|
sql.append(" select * from gzh_focus_record where unionId = #{m.unionId} and isDel = #{m.isDel} order by createTime desc limit 1");
|
sqlSentence.setSqlSentence(sql.toString());
|
GzhFocusRecord gzhFocusRecord = commonService.selectOne(GzhFocusRecordMapper.class, sqlSentence);
|
//用户Id为空时更新
|
if (gzhFocusRecord != null && StringUtils.isEmpty(gzhFocusRecord.getUserId())) {
|
sql.delete(0, sql.length());
|
values.put("id", gzhFocusRecord.getId());
|
values.put("userName", user.getName());
|
values.put("hisId", user.getApiId());
|
sql.append(" userId = #{m.userId}, userName = #{m.userName}, hisId = #{m.hisId} where id = #{m.id} ");
|
sqlSentence.setSqlSentence(sql.toString());
|
if(commonService.updateWhere(GzhFocusRecordMapper.class, sqlSentence) != 1){
|
throw new TipsException("更新绑定公众号失败！");
|
};
|
}
|
}
|
}
|
|
}
|
