package com.nova.sankuai.service.impl;
|
|
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
|
import com.nova.sankuai.domain.api.yinsheng.SerialGenerator;
|
import com.nova.sankuai.domain.api.yinsheng.YinShengFastProtocolUtils;
|
import com.nova.sankuai.domain.api.yinsheng.YinShengOrderEnum;
|
import com.nova.sankuai.domain.api.yinsheng.dto.FastProtocolPayDTO;
|
import com.nova.sankuai.domain.api.yinsheng.dto.FastProtocolSignConfirmDTO;
|
import com.nova.sankuai.domain.api.yinsheng.dto.FastProtocolSignDTO;
|
import com.nova.sankuai.domain.api.yinsheng.dto.SmsConfirmDTO;
|
import com.nova.sankuai.domain.api.yinsheng.enums.SignStatusEnum;
|
import com.nova.sankuai.domain.api.yinsheng.response.FastProtocolPayResponse;
|
import com.nova.sankuai.domain.api.yinsheng.response.FastProtocolQueryResponse;
|
import com.nova.sankuai.domain.api.yinsheng.response.FastProtocolResponse;
|
import com.nova.sankuai.domain.api.yinsheng.response.SmsResendResponse;
|
import com.nova.sankuai.domain.dto.YSProtocolPaySmsConfirmDto;
|
import com.nova.sankuai.domain.dto.YSProtocolPaySmsDto;
|
import com.nova.sankuai.domain.dto.YSProtocolSignConfirmDto;
|
import com.nova.sankuai.domain.dto.YSProtocolSignDto;
|
import com.nova.sankuai.domain.entity.*;
|
import com.nova.sankuai.domain.enums.vipservice.VipCardOrderEnum;
|
import com.nova.sankuai.domain.vo.VipEffectiveTimeVo;
|
import com.nova.sankuai.domain.vo.YSFastProtocolParamVo;
|
import com.nova.sankuai.domain.vo.YSFastProtocolSignCheckVo;
|
import com.nova.sankuai.domain.vo.YSFastProtocolSignVo;
|
import com.nova.sankuai.domain.vo.vipcard.VipCardVo;
|
import com.nova.sankuai.infra.config.CommonException;
|
import com.nova.sankuai.infra.mapper.CustomerMapper;
|
import com.nova.sankuai.infra.mapper.VipCardMapper;
|
import com.nova.sankuai.infra.mapper.VipCardOrderMapper;
|
import com.nova.sankuai.infra.mapper.YinShengSignRecordMapper;
|
import com.nova.sankuai.infra.utils.UserUtil;
|
import com.nova.sankuai.infra.utils.baofu.FormatUtil;
|
import com.nova.sankuai.security.UserDetail;
|
import com.nova.sankuai.service.ICustomerUserService;
|
import com.nova.sankuai.service.IYinShengService;
|
import lombok.RequiredArgsConstructor;
|
import org.apache.commons.lang.StringUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.stereotype.Service;
|
|
import javax.servlet.http.HttpServletRequest;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Objects;
|
|
/**
|
* 银盛接口对接服务
|
*
|
* @author ephemeral
|
*/
|
@Service
|
@RequiredArgsConstructor
|
public class YinShengServiceImpl implements IYinShengService {
|
|
private static final Logger log = LoggerFactory.getLogger("payLogger");
|
|
private final YinShengFastProtocolUtils yinShengUtils;
|
|
private final YinShengSignRecordMapper signRecordMapper;
|
|
private final ICustomerUserService customerUserService;
|
|
private final VipCardOrderMapper vipCardOrderMapper;
|
|
private final VipCardMapper vipCardMapper;
|
|
private final CustomerMapper customerMapper;
|
|
@Override
|
public YinShengSignRecord getSignRecordByUserId(Long userId) {
|
YinShengSignRecord signRecord = null;
|
List<YinShengSignRecord> signRecords = signRecordMapper.selectList(Wrappers.
|
lambdaQuery(YinShengSignRecord.class).eq(YinShengSignRecord::getCustomerUserId, userId).
|
orderByDesc(YinShengSignRecord::getCreationDate));
|
if (!signRecords.isEmpty()) {
|
signRecord = signRecords.get(0);
|
}
|
// YinShengSignRecord signRecord = signRecordMapper.selectOne(Wrappers.<YinShengSignRecord>lambdaQuery()
|
// .eq(YinShengSignRecord::getCustomerUserId, userId));
|
return signRecord;
|
}
|
|
@Override
|
public boolean checkBeforePayment(Long userId) {
|
YinShengSignRecord signRecord = getSignRecordByUserId(userId);
|
if (signRecord != null && StringUtils.isNotEmpty(signRecord.getSignProtocolNo())) {
|
FastProtocolQueryResponse response = yinShengUtils.fastProtocolQuery(signRecord.getSignProtocolNo());
|
if (response != null) {
|
if (response.isSuccess()) {
|
if (SignStatusEnum.SUCCESS.getCode().equals(response.getTradeStatus())) {
|
return true;
|
}
|
}
|
} else {
|
throw new CommonException("查询签约状态异常");
|
}
|
}
|
return false;
|
}
|
|
@Override
|
public YSFastProtocolSignVo protocolPaySignByYs(YSProtocolSignDto signDto, HttpServletRequest request) {
|
String token = request.getHeader("Authorization");
|
UserDetail user = UserUtil.getUser(token);
|
if (user == null || user.getId() == null) {
|
throw new CommonException("Token无效");
|
}
|
CustomerUser customerUser = customerUserService.getById(user.getId());
|
if (customerUser == null) {
|
throw new CommonException("用户不存在");
|
}
|
FastProtocolSignDTO fastProtocolSignDTO = new FastProtocolSignDTO();
|
// 新增于2022-12-07
|
String signIdNo = FormatUtil.toStringTrim(signDto.getSignIdNo());
|
String signCardNumber = FormatUtil.toStringTrim(signDto.getSignCardNumber());
|
// 完
|
|
String orderNo = SerialGenerator.getOrder();
|
fastProtocolSignDTO.setOutTradeNo(orderNo);
|
fastProtocolSignDTO.setBuyerName(signDto.getSignName());
|
fastProtocolSignDTO.setBuyerCardNumber(signCardNumber);
|
fastProtocolSignDTO.setBuyerMobile(signDto.getSignPhone());
|
fastProtocolSignDTO.setPayerIDNo(signIdNo);
|
fastProtocolSignDTO.setUserId(customerUser.getId().toString());
|
fastProtocolSignDTO.setImei(signDto.getImei());
|
FastProtocolResponse response = yinShengUtils.fastProtocolSign(fastProtocolSignDTO);
|
if (response == null) {
|
throw new CommonException("请求异常");
|
}
|
if (!response.isSuccess()) {
|
log.error("银盛快捷协议支付签约失败" + response.toString());
|
throw new CommonException("签约失败");
|
}
|
if (SignStatusEnum.SUCCESS.getCode().equals(response.getTradeStatus())
|
|| SignStatusEnum.WAIT_CONFIRM.getCode().equals(response.getTradeStatus())) {
|
YSFastProtocolSignVo ysFastProtocolSignVo = new YSFastProtocolSignVo();
|
YinShengSignRecord signRecord = new YinShengSignRecord();
|
YinShengSignRecord signRecordDb = getSignRecordByUserId(customerUser.getId());
|
signRecord.setOrderNo(orderNo);
|
signRecord.setSignName(signDto.getSignName());
|
signRecord.setCustomerUserId(customerUser.getId());
|
signRecord.setSignCardNumber(signCardNumber);
|
signRecord.setSignPhone(signDto.getSignPhone());
|
signRecord.setSignIdNo(signIdNo);
|
signRecord.setImei(signDto.getImei());
|
signRecord.setSignResult(response.getTradeStatus());
|
signRecord.setSignProtocolNo(response.getProtocolNo());
|
signRecord.setLastUpdatedDate(new Date());
|
if (signRecordDb != null) {
|
signRecord.setId(signRecordDb.getId());
|
signRecordMapper.updateById(signRecord);
|
} else {
|
signRecord.setCreationDate(signRecord.getLastUpdatedDate());
|
signRecordMapper.insert(signRecord);
|
}
|
if (SignStatusEnum.SUCCESS.getCode().equals(response.getTradeStatus())) {
|
ysFastProtocolSignVo.setNeedVerify(false);
|
} else {
|
ysFastProtocolSignVo.setNeedVerify(true);
|
}
|
return ysFastProtocolSignVo;
|
}
|
throw new CommonException("签约失败");
|
}
|
|
@Override
|
public boolean protocolPaySignConfirmByYs(YSProtocolSignConfirmDto signConfirmDto, HttpServletRequest request) {
|
String token = request.getHeader("Authorization");
|
UserDetail user = UserUtil.getUser(token);
|
if (user == null || user.getId() == null) {
|
throw new CommonException("Token无效");
|
}
|
CustomerUser customerUser = customerUserService.getById(user.getId());
|
if (customerUser == null) {
|
throw new CommonException("用户不存在");
|
}
|
YinShengSignRecord signRecord = getSignRecordByUserId(customerUser.getId());
|
if (signRecord == null) {
|
throw new CommonException("签约记录不存在");
|
}
|
FastProtocolSignConfirmDTO confirmDTO = new FastProtocolSignConfirmDTO();
|
confirmDTO.setOutTradeNo(signRecord.getOrderNo());
|
confirmDTO.setMobileVerifyCode(signConfirmDto.getVerifyCode());
|
FastProtocolResponse response = yinShengUtils.fastProtocolSignConfirm(confirmDTO);
|
if (response == null) {
|
throw new CommonException("签约确认异常");
|
}
|
if (!response.isSuccess()) {
|
log.error("银盛快捷协议支付签约确认失败" + response.toString());
|
return false;
|
}
|
if (SignStatusEnum.SUCCESS.getCode().equals(response.getTradeStatus())) {
|
signRecordMapper.update(null, Wrappers.<YinShengSignRecord>lambdaUpdate()
|
.set(YinShengSignRecord::getSignResult, response.getTradeStatus())
|
.set(YinShengSignRecord::getLastUpdatedDate, new Date())
|
.set(YinShengSignRecord::getSignProtocolNo, response.getProtocolNo())
|
.eq(YinShengSignRecord::getId, signRecord.getId()));
|
return true;
|
} else {
|
signRecordMapper.update(null, Wrappers.<YinShengSignRecord>lambdaUpdate()
|
.set(YinShengSignRecord::getSignResult, response.getTradeStatus())
|
.set(YinShengSignRecord::getLastUpdatedDate, new Date())
|
.eq(YinShengSignRecord::getId, signRecord.getId()));
|
return false;
|
}
|
}
|
|
@Override
|
public YSFastProtocolParamVo buyCardByYSProtocol(VipCardOrder vipCardOrder, VipCardVo cardVo, VipCard card) {
|
YinShengSignRecord signRecord = getSignRecordByUserId(vipCardOrder.getUserId());
|
if (signRecord == null) {
|
throw new CommonException("当前用户尚未完成签约");
|
}
|
FastProtocolPayDTO payDTO = new FastProtocolPayDTO();
|
payDTO.setOutTradeNo(vipCardOrder.getOrderId());
|
payDTO.setSubject(cardVo.getName());
|
payDTO.setTotalAmount(cardVo.getSellingPrice());
|
payDTO.setUserId(vipCardOrder.getUserId());
|
payDTO.setProtocolNo(signRecord.getSignProtocolNo());
|
FastProtocolPayResponse response = yinShengUtils.fastProtocolPay(payDTO);
|
if (response == null) {
|
throw new CommonException("请求异常");
|
}
|
if (!response.isSuccess()) {
|
log.error("银盛快捷协议支付失败" + response.toString());
|
throw new CommonException("支付失败");
|
}
|
YSFastProtocolParamVo protocolParamVo = new YSFastProtocolParamVo();
|
String status = YinShengOrderEnum.parseSystemStatus(response.getTradeStatus());
|
vipCardOrder.setStatus(status);
|
vipCardOrder.setOrderId(response.getTradeNo());
|
vipCardOrder.setPaySn(response.getPaySn());
|
if (VipCardOrderEnum.STATUS_END.getCode().equals(status)) {
|
vipCardOrderMapper.insert(vipCardOrder);
|
VipEffectiveTimeVo vipEffectiveTimeVo = customerUserService.calculateExpiredDate(vipCardOrder.getUserId(), card.getValidDate(), null, null);
|
customerUserService.updateVipEffectiveTime(vipCardOrder, vipEffectiveTimeVo);
|
protocolParamVo.setNeedVerify(false);
|
} else if (VipCardOrderEnum.STATUS_CLOSE.getCode().equals(status)) {
|
throw new CommonException("创建订单失败");
|
} else {
|
if (FastProtocolPayResponse.NEED_SMS.equals(response.getNeedSmsConfirm())) {
|
vipCardOrderMapper.insert(vipCardOrder);
|
protocolParamVo.setNeedVerify(true);
|
protocolParamVo.setPaySn(response.getPaySn());
|
} else {
|
throw new CommonException("创建订单失败");
|
}
|
}
|
return protocolParamVo;
|
}
|
|
@Override
|
public boolean protocolPaySmsConfirmByYs(YSProtocolPaySmsConfirmDto smsConfirmDto) {
|
VipCardOrder vipCardOrder = vipCardOrderMapper.selectOne(Wrappers.<VipCardOrder>lambdaQuery()
|
.eq(VipCardOrder::getPartnerThirdOrderId, smsConfirmDto.getPartnerThirdOrderId()));
|
if (vipCardOrder == null) {
|
throw new CommonException("订单不存在");
|
}
|
VipCard card = vipCardMapper.selectOne(Wrappers.<VipCard>lambdaQuery()
|
.eq(VipCard::getCardId, vipCardOrder.getCardId()));
|
if (card == null) {
|
throw new CommonException("对应会员卡不存在");
|
}
|
SmsConfirmDTO confirmDTO = new SmsConfirmDTO();
|
confirmDTO.setMobileVerifyCode(smsConfirmDto.getVerifyCode());
|
confirmDTO.setPaySn(smsConfirmDto.getPaySn());
|
FastProtocolPayResponse response = yinShengUtils.smsConfirm(confirmDTO);
|
if (response == null) {
|
throw new CommonException("请求异常");
|
}
|
if (!response.isSuccess()) {
|
log.error("银盛快捷协议支付短信确认失败" + response.toString());
|
throw new CommonException(response.getMsg());
|
}
|
String status = YinShengOrderEnum.parseSystemStatus(response.getTradeStatus());
|
if (!Objects.equals(status, vipCardOrder.getStatus())) {
|
vipCardOrder.setStatus(status);
|
vipCardOrder.setOrderId(response.getTradeNo());
|
vipCardOrder.setPaySn(response.getPaySn());
|
vipCardOrderMapper.update(null, Wrappers.<VipCardOrder>lambdaUpdate()
|
.set(VipCardOrder::getStatus, vipCardOrder.getStatus())
|
.set(VipCardOrder::getOrderId, vipCardOrder.getOrderId())
|
.set(VipCardOrder::getPaySn, vipCardOrder.getPaySn())
|
.eq(VipCardOrder::getId, vipCardOrder.getId()));
|
if (VipCardOrderEnum.STATUS_END.getCode().equals(status)) {
|
VipEffectiveTimeVo vipEffectiveTimeVo = customerUserService.calculateExpiredDate(vipCardOrder.getUserId(), card.getValidDate(), null, null);
|
customerUserService.updateVipEffectiveTime(vipCardOrder, vipEffectiveTimeVo);
|
return true;
|
}
|
}
|
return false;
|
}
|
|
@Override
|
public void getProtocolPaySmsByYs(YSProtocolPaySmsDto smsDto) {
|
if (StringUtils.isEmpty(smsDto.getPaySn())) {
|
throw new CommonException("支付流水号不能为空");
|
}
|
SmsResendResponse response = yinShengUtils.smsResend(smsDto.getPaySn());
|
if (response == null) {
|
throw new CommonException("请求异常");
|
}
|
if (!response.isSuccess()) {
|
log.error("银盛快捷协议支付重新获取短信失败" + response.toString());
|
throw new CommonException("获取短信失败");
|
}
|
}
|
|
@Override
|
public YSFastProtocolSignCheckVo checkProtocolSignByYs(HttpServletRequest request) {
|
String token = request.getHeader("Authorization");
|
UserDetail user = UserUtil.getUser(token);
|
if (user == null || user.getId() == null) {
|
throw new CommonException("Token无效");
|
}
|
CustomerUser customerUser = customerUserService.getById(user.getId());
|
if (customerUser == null) {
|
throw new CommonException("用户不存在");
|
}
|
YSFastProtocolSignCheckVo checkVo = new YSFastProtocolSignCheckVo();
|
YinShengSignRecord signRecord = getSignRecordByUserId(customerUser.getId());
|
Customer customer = customerMapper.getLatestCustomerRecord(customerUser.getPhone());
|
if (signRecord != null && SignStatusEnum.SUCCESS.getCode().equals(signRecord.getSignResult())) {
|
checkVo.setSign(true);
|
checkVo.setSignCardNumber(signRecord.getSignCardNumber());
|
checkVo.setSignIdNo(signRecord.getSignIdNo());
|
checkVo.setSignName(signRecord.getSignName());
|
checkVo.setSignPhone(signRecord.getSignPhone());
|
} else {
|
if (customer != null) {
|
checkVo.setSignName(customer.getName());
|
checkVo.setSignIdNo(customer.getIdCard());
|
}
|
}
|
if (customer != null){
|
checkVo.setBankName(customer.getBankName());
|
checkVo.setBankCode(customer.getBankCode());
|
}
|
return checkVo;
|
}
|
}
|
