package com.nova.sankuai.service.impl;
|
|
import cn.hutool.core.util.IdUtil;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import com.baomidou.mybatisplus.core.metadata.IPage;
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
|
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
|
import com.nova.sankuai.domain.api.aliyunIP.AliyunUtil;
|
import com.nova.sankuai.domain.dto.ChannelInfoDefaultVipDto;
|
import com.nova.sankuai.domain.dto.ChannelInfoDto;
|
import com.nova.sankuai.domain.dto.ChannelInfoPageDto;
|
import com.nova.sankuai.domain.dto.ChannelLoanMarketHotLinkDto;
|
import com.nova.sankuai.domain.entity.*;
|
import com.nova.sankuai.domain.enums.CustomerInfoStatusEnum;
|
import com.nova.sankuai.domain.enums.vipservice.VipCardTypeEnum;
|
import com.nova.sankuai.domain.vo.ChannelVipConfigVo;
|
import com.nova.sankuai.domain.vo.LoanSupermarketVo;
|
import com.nova.sankuai.domain.vo.auth.AutoLoginVo;
|
import com.nova.sankuai.domain.vo.channel.ChannelConfigVo;
|
import com.nova.sankuai.domain.vo.channel.ChannelInfoVo;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.constants.Constants;
|
import com.nova.sankuai.infra.constants.ResultCode;
|
import com.nova.sankuai.infra.mapper.*;
|
import com.nova.sankuai.infra.utils.*;
|
import com.nova.sankuai.security.UserDetail;
|
import com.nova.sankuai.service.ChannelCityLinkService;
|
import com.nova.sankuai.service.IChannelInfoService;
|
import com.nova.sankuai.service.IChannelSupermarketService;
|
import com.nova.sankuai.service.IH5ChannelLoanMarketService;
|
import lombok.RequiredArgsConstructor;
|
import lombok.extern.slf4j.Slf4j;
|
import org.apache.commons.lang.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.stereotype.Service;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* @author weikangdi
|
*/
|
@Service
|
@RequiredArgsConstructor(onConstructor_ = @Autowired)
|
@Slf4j
|
public class ChannelInfoServiceImpl extends ServiceImpl<ChannelInfoMapper, ChannelInfo> implements IChannelInfoService {
|
|
private final ChannelInfoMapper channelInfoMapper;
|
|
private final ChannelLogMapper channelLogMapper;
|
|
private final ChannelSupermarketMapper channelSupermarketMapper;
|
|
private final IChannelSupermarketService channelSupermarketService;
|
|
private final IH5ChannelLoanMarketService h5ChannelLoanMarketService;
|
|
private final CustomerUserMapper customerUserMapper;
|
|
private final CustomerMapper customerMapper;
|
|
private final PageUtil pageUtil;
|
|
private final SystemParamMapper systemParamMapper;
|
|
private final H5ChannelLoanMarketMapper h5ChannelLoanMarketMapper;
|
|
private final VipCardMapper vipCardMapper;
|
|
private final LoanSupermarketMapper loanSupermarketMapper;
|
|
private final ChannelCityLinkService channelCityLinkService;
|
|
private final AliyunUtil aliyunUtil;
|
|
private static final Logger loginLogger = LoggerFactory.getLogger("loginLogger");
|
|
@Value("${channelInfo.codeInit}")
|
private Integer codeInit;
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public Long createSyncChannel(SyncConfig syncConfig) {
|
ChannelInfo info = lambdaQuery().eq(ChannelInfo::getAppId, syncConfig.getAppId()).one();
|
if (info != null) {
|
log.error("新增同步配置信息渠道失败，原始数据：" + syncConfig);
|
throw new CommonException("该渠道Key已经用于其他渠道");
|
}
|
ChannelInfo channelInfo = new ChannelInfo();
|
channelInfo.setAppId(syncConfig.getAppId());
|
channelInfo.setName(syncConfig.getName());
|
channelInfo.setStatus(Constants.ENABLE);
|
channelInfo.setType(ChannelInfo.TYPE_EXPORT);
|
channelInfo.setCode(generateCode());
|
channelInfo.setSystemFlag(Constants.ENABLE);
|
channelInfo.setVersion2IsOpen(0);
|
channelInfo.setQuotaApprovalTime(10);
|
channelInfo.setMemberDiscount(10000);
|
save(channelInfo);
|
return channelInfo.getId();
|
}
|
|
private Integer generateCode() {
|
Integer code = channelInfoMapper.getMaxCode();
|
if (codeInit != null && code < codeInit) {
|
return codeInit;
|
}
|
return code + 1;
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void updateSyncChannel(SyncConfig syncConfig) {
|
ChannelInfo channelInfo = getById(syncConfig.getChannelId());
|
if (channelInfo == null) {
|
log.error("更新同步配置信息渠道失败，原始数据：" + syncConfig);
|
throw new CommonException("该同步配置对应的出口渠道为空");
|
}
|
channelInfo.setName(syncConfig.getName());
|
channelInfo.setAppId(syncConfig.getAppId());
|
updateById(channelInfo);
|
}
|
|
@Override
|
public ResultJson<?> checkChannel(String appId, String importObjects) {
|
log.info("渠道id检测开始,渠道id值：" + appId);
|
ChannelInfo channelInfo = lambdaQuery().eq(ChannelInfo::getAppId, appId)
|
.eq(ChannelInfo::getType, ChannelInfo.TYPE_IMPORT).one();
|
if (channelInfo == null) {
|
|
log.error("checkChannel：渠道id检测不合法，appId：" + appId + ",原始数据信息：" + importObjects);
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "渠道id非法");
|
}
|
if (Constants.ENABLE != channelInfo.getStatus()) {
|
if (StringUtils.isNotBlank(importObjects)) {
|
ChannelLog channelLog = new ChannelLog();
|
channelLog.setSource(channelInfo.getCode());
|
channelLog.setName(channelInfo.getName());
|
channelLog.setType(ChannelLog.IMPORT);
|
channelLog.setStatus(ChannelLog.FAIL);
|
channelLog.setMessage("渠道已被禁用");
|
channelLog.setImportObjects(importObjects);
|
channelLog.setCreationDate(new Date());
|
channelLogMapper.insert(channelLog);
|
}
|
log.error("渠道id检测:渠道已经被禁用" + "原始数据信息：" + importObjects);
|
return ResultJson.failure(ResultCode.SERVER_ERROR, "渠道已被禁用");
|
}
|
return null;
|
}
|
|
@Override
|
public IPage<ChannelInfoVo> pageImportList(ChannelInfoPageDto pageDto) {
|
Page page = pageUtil.getPage(pageDto);
|
return channelInfoMapper.pageImportChannel(page, pageDto);
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public ChannelInfoVo addChannelInfo(ChannelInfoDto channelInfoDto) {
|
ChannelInfo channelInfo = new ChannelInfo();
|
BeanUtils.copyProperties(channelInfoDto, channelInfo);
|
initChannel(channelInfo);
|
save(channelInfo);
|
channelSupermarketService.saveByChannel(channelInfo.getId());
|
h5ChannelLoanMarketService.saveByChannel(channelInfo.getId());
|
return ChannelInfoVo.parseVo(channelInfo);
|
}
|
|
private void initChannel(ChannelInfo channelInfo) {
|
channelInfo.setType(ChannelInfo.TYPE_IMPORT);
|
channelInfo.setCode(generateCode());
|
channelInfo.setAppId(IdUtil.randomUUID());
|
if (channelInfo.getQuotaApprovalTime() == null) {
|
channelInfo.setQuotaApprovalTime(10);
|
}
|
if (channelInfo.getVersion2IsOpen() == null) {
|
channelInfo.setVersion2IsOpen(0);
|
}
|
if (channelInfo.getMemberDiscount() == null) {
|
channelInfo.setMemberDiscount(10000);
|
}
|
if (StringUtils.isEmpty(channelInfo.getDefaultCardId())) {
|
VipCard defaultCard = vipCardMapper.getDefaultCardByType(VipCardTypeEnum.MEMBER_SERVICE.getCode());
|
channelInfo.setDefaultCardId(defaultCard.getCardId());
|
}
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public void editChannelInfo(ChannelInfoDto channelInfoDto) {
|
ChannelInfo channelInfoDb = checkChannelInfo(channelInfoDto.getId(), null);
|
channelInfoDb.setName(channelInfoDto.getName());
|
channelInfoDb.setLoanMarketOnly(channelInfoDto.getLoanMarketOnly());
|
channelInfoDb.setVersion2IsOpen(channelInfoDto.getVersion2IsOpen());
|
channelInfoDb.setAndroidLink(channelInfoDto.getAndroidLink());
|
channelInfoDb.setIosLink(channelInfoDto.getIosLink());
|
channelInfoDb.setMemberDiscount(channelInfoDto.getMemberDiscount());
|
channelInfoDb.setQuotaApprovalTime(channelInfoDto.getQuotaApprovalTime());
|
channelInfoDb.setLoadAndroidLink(channelInfoDto.getLoadAndroidLink());
|
channelInfoDb.setLoadIosLink(channelInfoDto.getLoadIosLink());
|
channelInfoDb.setVersion3IsOpen(channelInfoDto.getVersion3IsOpen());
|
channelInfoDb.setQueueVipSwitch(channelInfoDto.getQueueVipSwitch());
|
channelInfoDb.setH5PageSwitch(channelInfoDto.getH5PageSwitch());
|
channelInfoDb.setVersion4IsOpen(channelInfoDto.getVersion4IsOpen());
|
channelInfoDb.setVipMode(channelInfoDto.getVipMode());
|
channelInfoDb.setLinkMode(channelInfoDto.getLinkMode());
|
// 于2022-11-15新增：直接放款
|
channelInfoDb.setDirectLoanIsOpen(channelInfoDto.getDirectLoanIsOpen());
|
// 完
|
channelInfoDb.setVipSwitch(channelInfoDto.getVipSwitch());
|
channelInfoDb.setBankCardIsOpen(channelInfoDto.getBankCardIsOpen());
|
channelInfoDb.setLoanProgressOld(channelInfoDto.getLoanProgressOld());
|
channelInfoDb.setVersion2Type(channelInfoDto.getVersion2Type());
|
channelInfoDb.setDhSwitch(channelInfoDto.getDhSwitch());
|
channelInfoDb.setYongxinIsOpen(channelInfoDto.getYongxinIsOpen());
|
channelInfoDb.setLianDeng(channelInfoDto.getLianDeng());
|
channelInfoDb.setH5Match(channelInfoDto.getH5Match()); // ab新增于2024-10-16
|
updateById(channelInfoDb);
|
if(channelInfoDto.getVersion4IsOpen()!=null && channelInfoDto.getVersion4IsOpen().equals(0)){
|
LambdaQueryWrapper<Customer> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(Customer::getSourceChannel, channelInfoDb.getCode());
|
queryWrapper.eq(Customer::getStatus, CustomerInfoStatusEnum.COMPANY_INFO.getCode());
|
queryWrapper.eq(Customer::getDeleteFlag, 0);
|
List<Customer> customers = customerMapper.selectList(queryWrapper);
|
if(customers!= null && customers.size() >0){
|
for (Customer customer: customers) {
|
customer.setStatus(CustomerInfoStatusEnum.BANKCARD_INFO.getCode());
|
customerMapper.updateById(customer);
|
}
|
}
|
}
|
}
|
|
public ChannelInfo checkChannelInfo(Long channelId, String appId) {
|
ChannelInfo channelInfo;
|
if (channelId != null) {
|
channelInfo = getById(channelId);
|
} else {
|
channelInfo = lambdaQuery().eq(ChannelInfo::getAppId, appId).one();
|
}
|
if (channelInfo == null) {
|
throw new CommonException("该渠道不存在");
|
}
|
return channelInfo;
|
}
|
|
@Override
|
public IPage<LoanSupermarketVo> pageSupermarkets(Long channelId, PageRequest pageRequest) {
|
checkChannelInfo(channelId, null);
|
return channelSupermarketMapper.pageSupermarketList(pageUtil.getPage(pageRequest), channelId);
|
}
|
|
|
@Override
|
public ChannelInfo getChannelInfoByCode(Integer code) {
|
return lambdaQuery().eq(ChannelInfo::getCode, code).one();
|
}
|
|
|
@Override
|
public void editMemberDefault(ChannelInfoDefaultVipDto channelInfo) {
|
ChannelInfo channelInfoDb = checkChannelInfo(channelInfo.getId(), null);
|
channelInfoDb.setDefaultCardId(channelInfo.getDefaultCardId());
|
updateById(channelInfoDb);
|
}
|
|
@Override
|
public ChannelConfigVo getChannelInfoByKey(String appId, HttpServletRequest request) {
|
String token = request.getHeader("Authorization");
|
UserDetail user = UserUtil.getUser(token);
|
String phone = null;
|
if (user != null) {
|
phone = user.getPhone();
|
}
|
ChannelInfo channelInfo = getChannelByUser(appId, phone);
|
ChannelConfigVo channelConfigVo = ChannelConfigVo.parseChannelConfig(channelInfo);
|
//获取用户的地理信息，并判断该渠道中是否存在该城市的下载链接
|
String uuid = IdUtil.randomUUID();
|
String ipAddr = IpUtil.getIpAddr(request);
|
loginLogger.info("统一码为" + uuid + "," + "手机号为" + phone + ",获取到的IP为：{}", ipAddr);
|
City cityInfo = aliyunUtil.getCityInfo(request, phone);
|
if (cityInfo != null) {
|
loginLogger.info("统一码为" + uuid + "," + "手机号为" + phone + ",获取到的用户信息：{}", cityInfo);
|
ChannelCityLink channelCityLinkById = channelCityLinkService.getOne(new LambdaQueryWrapper<ChannelCityLink>()
|
.eq(ChannelCityLink::getCityId, cityInfo.getCityId())
|
.eq(ChannelCityLink::getChannelId, channelInfo.getId())
|
.eq(ChannelCityLink::getIsDelete, 0));
|
//渠道城市下载链接若存在此信息则将安卓下载链接返回
|
if (channelCityLinkById != null && StringUtils.isNotEmpty(channelCityLinkById.getAndroidLink())) {
|
channelConfigVo.setAndroidLink(channelCityLinkById.getAndroidLink());
|
loginLogger.info("统一码为" + uuid + "," + "手机号为" + phone + ",获取到的安卓下载链接：{}", channelCityLinkById.getAndroidLink());
|
}
|
//渠道城市下载链接若存在此信息则将ios下载链接返回
|
if (channelCityLinkById != null && StringUtils.isNotEmpty(channelCityLinkById.getIosLink())) {
|
loginLogger.info("统一码为" + uuid + "," + "手机号为" + phone + ",获取到的ios下载链接：{}", channelCityLinkById.getIosLink());
|
channelConfigVo.setIosLink(channelCityLinkById.getIosLink());
|
}
|
} else {
|
loginLogger.info("统一码为" + uuid + "," + "手机号为" + phone + ",未获取到相应城市的下载链接");
|
}
|
SystemParam systemParam = systemParamMapper.getDefaultParam();
|
LoanSupermarket loanSupermarket = loanSupermarketMapper.selectById(channelInfo.getLoanMarketHotLinkId());
|
if (loanSupermarket != null) {
|
channelConfigVo.setLoanMarketLinkUrl(loanSupermarket.getLinkUrl());
|
}
|
//配置系统全局开关
|
channelConfigVo.setLoanMarketArray(systemParam.getLoanMarketArray());
|
channelConfigVo.setPageTabSwitch(systemParam.getPageTabSwitch());
|
channelConfigVo.setIdCardSwitch(systemParam.getIdCardSwitch());
|
loginLogger.info("统一码为" + uuid + "," + "手机号为" + phone + ",获取到的vo为：{}", channelConfigVo);
|
if (0 == channelConfigVo.getLoanMarketHotLinkSwitch()) {
|
channelConfigVo.setLoanMarketHotLinkId(null);
|
channelConfigVo.setLoanMarketLinkUrl(null);
|
}
|
return channelConfigVo;
|
}
|
|
|
private ChannelInfo getChannelByUser(String appId, String phone) {
|
ChannelInfo channelInfo = channelInfoMapper.getChannelByAppId(appId);
|
if (channelInfo == null) {
|
log.error("该渠道配置不存在,渠道值:" + appId);
|
throw new CommonException("该渠道配置不存在");
|
}
|
if (StringUtils.isNotEmpty(phone)) {
|
CustomerUser user = customerUserMapper.selectOne(Wrappers.<CustomerUser>lambdaQuery()
|
.eq(CustomerUser::getPhone, phone).eq(CustomerUser::getDeleteFlag, 0));
|
if (user != null) {
|
ChannelInfo userChannel = lambdaQuery().eq(ChannelInfo::getCode, user.getSourceChannel())
|
.eq(ChannelInfo::getType, ChannelInfo.TYPE_IMPORT).one();
|
if (userChannel != null) {
|
channelInfo = userChannel;
|
}
|
}
|
}
|
return channelInfo;
|
}
|
|
@Override
|
public List<LoanSupermarketVo> getSupermarketListByKey(String appId, String phone) {
|
ChannelInfo channelInfo = getChannelByUser(appId, phone);
|
return channelSupermarketMapper.getSupermarketList(channelInfo.getId());
|
}
|
|
@Override
|
@Transactional(rollbackFor = Exception.class)
|
public String createThirdChannel(AutoLoginVo autoLoginVo, ChannelInfo channelInfo) {
|
String thirdCode = autoLoginVo.getAppId() + autoLoginVo.getChannelCode();
|
ChannelInfo thirdChannel = lambdaQuery().eq(ChannelInfo::getThirdChannelCode, thirdCode).one();
|
if (thirdChannel == null) {
|
thirdChannel = new ChannelInfo();
|
BeanUtils.copyProperties(channelInfo, thirdChannel);
|
thirdChannel.setId(null);
|
thirdChannel.setThirdChannelCode(thirdCode);
|
thirdChannel.setName(channelInfo.getName() + "-" + autoLoginVo.getChannelName());
|
thirdChannel.setCode(generateCode());
|
thirdChannel.setAppId(IdUtil.randomUUID());
|
thirdChannel.setAutoParentCode(channelInfo.getCode());
|
thirdChannel.setHasThirdChannel(0);
|
thirdChannel.setCreationDate(new Date());
|
save(thirdChannel);
|
channelSupermarketService.copyChannel(thirdChannel.getId(), channelInfo.getId());
|
h5ChannelLoanMarketService.copyChannel(thirdChannel.getId(), channelInfo.getId());
|
List<ChannelCityLink> channelCityLinks = channelCityLinkService.list(new LambdaQueryWrapper<ChannelCityLink>()
|
.eq(ChannelCityLink::getChannelId, channelInfo.getId())
|
.eq(ChannelCityLink::getIsDelete, 0));
|
if (channelCityLinks != null && !channelCityLinks.isEmpty()) {
|
ArrayList<ChannelCityLink> channelCityLinklist = new ArrayList<>();
|
for (ChannelCityLink channelCityLink : channelCityLinks) {
|
ChannelCityLink channelCityLinkson = new ChannelCityLink();
|
channelCityLinkson.setChannelId(thirdChannel.getId());
|
channelCityLinkson.setCityId(channelCityLink.getCityId());
|
channelCityLinkson.setAndroidLink(channelCityLink.getAndroidLink());
|
channelCityLinkson.setIosLink(channelCityLink.getIosLink());
|
channelCityLinkson.setCreationDate(new Date());
|
channelCityLinklist.add(channelCityLinkson);
|
}
|
channelCityLinkService.saveBatch(channelCityLinklist);
|
}
|
}
|
if (channelInfo.getHasThirdChannel() == 0) {
|
update(Wrappers.<ChannelInfo>lambdaUpdate()
|
.set(ChannelInfo::getHasThirdChannel, 1)
|
.eq(ChannelInfo::getId, channelInfo.getId()));
|
}
|
return thirdChannel.getAppId();
|
}
|
|
@Override
|
public List<LoanSupermarketVo> getH5LoanMarketListByKey(String appId) {
|
ChannelInfo channelInfo = checkChannelInfo(null, appId);
|
return h5ChannelLoanMarketMapper.getSupermarketList(channelInfo.getId());
|
}
|
|
@Override
|
public IPage<LoanSupermarketVo> pageH5LoanMarkets(Long channelId, PageRequest pageRequest) {
|
checkChannelInfo(channelId, null);
|
return h5ChannelLoanMarketMapper.pageSupermarketList(pageUtil.getPage(pageRequest), channelId);
|
}
|
|
|
@Override
|
public void editLoanMarketHotLink(ChannelLoanMarketHotLinkDto loanMarketHotLinkDto) {
|
ChannelInfo channelInfo = checkChannelInfo(loanMarketHotLinkDto.getChannelId(), null);
|
update(Wrappers.<ChannelInfo>lambdaUpdate()
|
.set(ChannelInfo::getLoanMarketHotLinkId, loanMarketHotLinkDto.getLoanMarketHotLinkId())
|
.set(ChannelInfo::getLoanMarketHotLinkSwitch, loanMarketHotLinkDto.getLoanMarketHotLinkSwitch())
|
.eq(ChannelInfo::getId, channelInfo.getId()));
|
}
|
|
@Override
|
public ChannelVipConfigVo getChannelVipConfig(String appId, String phone) {
|
ChannelVipConfigVo vipConfigVo = new ChannelVipConfigVo();
|
ChannelInfo channelInfo = getChannelByUser(appId, phone);
|
vipConfigVo.setDefaultCardId(channelInfo.getDefaultCardId());
|
vipConfigVo.setMemberDiscount(channelInfo.getMemberDiscount());
|
vipConfigVo.setQuotaApprovalTime(channelInfo.getQuotaApprovalTime());
|
return vipConfigVo;
|
}
|
}
|
