package com.nova.sankuai.service.impl;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.nova.sankuai.domain.api.externalInterface.*;
|
import com.nova.sankuai.domain.api.externalInterface.yxqb.*;
|
import com.nova.sankuai.domain.entity.ChannelInfo;
|
import com.nova.sankuai.domain.entity.CustomerUser;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.mapper.ChannelInfoMapper;
|
import com.nova.sankuai.service.ICustomerUserService;
|
import com.nova.sankuai.service.YxqbService;
|
import lombok.AllArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
import org.springframework.util.DigestUtils;
|
|
import java.util.ArrayList;
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
|
/**
|
* @author 51913
|
*/
|
@Service
|
@AllArgsConstructor
|
@Slf4j
|
public class YxqbServiceImpl implements YxqbService {
|
|
private static final Logger autoLogger = LoggerFactory.getLogger("autoLogger");
|
|
private final ICustomerUserService customerUserService;
|
|
private final ChannelInfoMapper channelInfoMapper;
|
|
private final EIUtil eiUtil;
|
|
public static final String APPID = "fe608acf-770b-405f-a0a0-bdbb5e49aa7e";
|
|
|
@Override
|
public YXCheckUserResponse checkUser(YXCheckUserDto yxCheckUserDto) {
|
autoLogger.info("有信钱包撞库原始数据" + yxCheckUserDto.getData());
|
String uuId = IdUtil.randomUUID();
|
YXCheckUserResponse checkUserResponse = new YXCheckUserResponse();
|
if (yxCheckUserDto.getChannelCode() == null) {
|
throw new CommonException("渠道号不能为空");
|
}
|
ChannelInfo channelInfo = channelInfoMapper.selectOne(new LambdaQueryWrapper<ChannelInfo>()
|
.eq(ChannelInfo::getAppId, yxCheckUserDto.getChannelCode()));
|
if (channelInfo == null) {
|
throw new CommonException("该渠道AppId不合法");
|
}
|
if (yxCheckUserDto.getData() == null) {
|
throw new CommonException("参数data不能为空");
|
}
|
autoLogger.info("日志编号:" + uuId + "有信钱包撞库原始数据" + yxCheckUserDto.getData());
|
String phone = eiUtil.yXCheckUserDataParse(uuId, yxCheckUserDto.getData());
|
if (StringUtils.isEmpty(phone)) {
|
checkUserResponse.setCode(-1);
|
checkUserResponse.setMsg("system error");
|
return checkUserResponse;
|
}
|
autoLogger.info("日志编号:" + uuId + "有信钱包撞库原始数据data" + phone);
|
String phoneParam = phone.substring(0, 7);
|
List<CustomerUser> list = customerUserService.list(new LambdaQueryWrapper<CustomerUser>().likeRight(CustomerUser::getPhone, phoneParam));
|
if (list == null || list.isEmpty()) {
|
checkUserResponse.setCode(0);
|
checkUserResponse.setMsg("success");
|
checkUserResponse.setData(null);
|
} else {
|
ArrayList<String> phoneMd5s = new ArrayList<>();
|
list.stream().map(item -> {
|
String phoneMd5 = DigestUtils.md5DigestAsHex(item.getPhone().getBytes());
|
phoneMd5s.add(phoneMd5);
|
return item;
|
}).collect(Collectors.toList());
|
checkUserResponse.setCode(1);
|
checkUserResponse.setMsg("success");
|
checkUserResponse.setData(phoneMd5s);
|
}
|
autoLogger.info("日志编号:" + uuId + "有信钱包撞库返回数据" + checkUserResponse.toString());
|
return checkUserResponse;
|
}
|
|
@Override
|
public YXRegisterResponse register(YXRegisterDto yxRegisterDto) {
|
String uuId = IdUtil.randomUUID();
|
YXRegisterResponse yxRegisterResponse = new YXRegisterResponse();
|
if (StringUtils.isEmpty(yxRegisterDto.getPhoneNo())) {
|
throw new CommonException("手机号不能为空");
|
}
|
autoLogger.info("日志编号:" + uuId + "有信钱包联登原始数据" + yxRegisterDto.toString());
|
CustomerUser customerUser = customerUserService.getOne(new LambdaQueryWrapper<CustomerUser>().eq(CustomerUser::getPhone, yxRegisterDto.getPhoneNo()));
|
yxRegisterResponse = eiUtil.yxRegister(customerUser, yxRegisterResponse, yxRegisterDto);
|
if (customerUser == null) {
|
String logNumber = IdUtil.randomUUID();
|
autoLogger.info("日志编号" + logNumber + "有信钱包开始注册新用户，用户手机号:" + yxRegisterDto.getPhoneNo() + "渠道AppId:" + APPID);
|
customerUserService.registerInitCustomerUser(yxRegisterDto.getPhoneNo(), APPID, null, yxRegisterDto.getRegisterFrom());
|
autoLogger.info("日志编号" + logNumber + "有信钱包注册新用户成功，用户Id" + customerUser.getId() + "，用户手机号" + customerUser.getPhone());
|
}
|
autoLogger.info("日志编号:" + uuId + "有信钱包撞库返回数据" + yxRegisterResponse.toString());
|
return yxRegisterResponse;
|
}
|
}
|
