基于springboot+redis+mysql的支付系统源码+数据库.zip

package com.xxx.xpay.service.impl; import com.alibaba.fastjson.JSONObject; import com.xxx.xpay.common.enums.PayStatusEnum; import com.xxx.xpay.common.enums.PayWayEnum; import com.xxx.xpay.common.enums.SignEnum; import com.xxx.xpay.common.enums.StatusEnum; import com.xxx.xpay.common.exception.BizException; import com.xxx.xpay.common.request.dto.NetBankPayDto; import com.xxx.xpay.common.request.dto.TradeQueryDto; import com.xxx.xpay.common.resp.dto.NetBankRespData; import com.xxx.xpay.common.resp.dto.PayResultDto; import com.xxx.xpay.common.resp.dto.PayWayInfo; import com.xxx.xpay.common.resp.dto.ReponseDto; import com.xxx.xpay.common.utils.SignUtil; import com.xxx.xpay.entity.TradePaymentOrder; import com.xxx.xpay.entity.TradePaymentRecord; import com.xxx.xpay.entity.UserInfo; import com.xxx.xpay.entity.UserPayConfig; import com.xxx.xpay.factory.PayStrategyFactory; import com.xxx.xpay.iclient.IAliapyFrontClient; import com.xxx.xpay.mapper.PayWayMapper; import com.xxx.xpay.service.IMchService; import com.xxx.xpay.service.IPayService; import com.xxx.xpay.service.ITradePaymentService; import com.xxx.xpay.service.IUserPayConfigService; import com.xxx.xpay.service.strategy.IPayStrategyService; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Service; import org.springframework.util.CollectionUtils; import org.springframework.util.ObjectUtils; import java.util.ArrayList; import java.util.List; import java.util.Map; import java.util.Optional; import java.util.stream.Collectors; /** * @author fl * @ClassName PayServiceImpl * @description: 支付业务接口实现 * @datetime 2022年 11月 30日 14:52 * @version: 1.0 */ @Service @Slf4j public class PayServiceImpl implements IPayService { @Autowired private IMchService mchService; @Autowired private IUserPayConfigService userPayConfigService; @Autowired private ITradePaymentService tradePaymentService; @Autowired private IAliapyFrontClient iAliapyFrontClient; @Override public NetBankRespData doPay(NetBankPayDto payDto) throws BizException { //1.2验证商户是否存在 UserInfo userInfo = mchService.getMchInfoByMchId(payDto.getUserNo()); if (ObjectUtils.isEmpty(userInfo)) { throw new BizException("商户id不存在"); } //1.2 检查商户状态是否正常 if (!userInfo.getStatus().equals(StatusEnum.NORMAL.getCode())) { throw new BizException("商户状态不可用"); } //1.3 检查支付方式是否存在 List<UserPayConfig> payConfigList = userPayConfigService.getUserPayConfigByMchId(payDto.getUserNo()); if (CollectionUtils.isEmpty(payConfigList)) { throw new BizException("商户没有可用的支付方式"); } //list 转流 取 支付方式等于请求的那一条，取第一条， Optional<UserPayConfig> optional = payConfigList.stream().filter(u -> u.getPayWayCode().equals(payDto.getPayWayCode())).limit(1).findFirst(); //判断Optional 是否为空 if (!optional.isPresent()) { throw new BizException("不支持次支付方式"); } UserPayConfig userPayConfig = optional.get(); if (!StatusEnum.NORMAL.getCode().equals(userPayConfig.getStatus())) { throw new BizException("支付方式状态不可用"); } //2. 验证签名 try { SignUtil.veiryfySign(payDto.getSign(), payDto, SignEnum.MD5, userPayConfig.getPaySecret()); } catch (Exception e) { throw new BizException("验证签名失败，请求非法"); } //2.生成支付订单，支付记录 TradePaymentRecord paymentRecord = tradePaymentService.createOrderAndRecord(payDto, userInfo.getUserName()); if (ObjectUtils.isEmpty(paymentRecord)) { throw new BizException("支付失败，请重试"); } //2.1 投递消息到 延迟队列中：实现交易超时关闭：45关闭 //3.根据支付方式：调用支付公司的接口 : 避免支付流程： if else 逻辑太多： java 设计模式：策略模式 String payWayCode = payDto.getPayWayCode(); //根据 code 去实例化创建对象 IPayStrategyService payStrategyService = PayStrategyFactory.getBean(payWayCode); if (ObjectUtils.isEmpty(payStrategyService)) { throw new BizException("暂不支持此支付方式"); } //执行支付 NetBankRespData netBankRespData = payStrategyService.payment(paymentRecord); //4.解析封装返回 TODO return netBankRespData; } @Override public List<PayWayInfo> queryByMchList(String userNo) throws BizException { //1.检查商户状态 UserInfo userInfo = mchService.getMchInfoByMchId(userNo); if (ObjectUtils.isEmpty(userInfo)) { throw new BizException("商户id不存在"); } if (!userInfo.getStatus().equals(StatusEnum.NORMAL.getCode())) { throw new BizException("商户状态不可用"); } List<PayWayInfo> payWayInfoList = new ArrayList<>(); //2.查询商户的支付列表 List<UserPayConfig> payConfigList = userPayConfigService.getUserPayConfigByMchId(userNo); if (ObjectUtils.isEmpty(payConfigList)) { return payWayInfoList; } //jdk1.8 List<PayWayInfo> wayInfoList = payConfigList.stream().map(u -> { PayWayInfo payWayInfo = new PayWayInfo(); payWayInfo.setPayWayCode(u.getPayWayCode()); payWayInfo.setPayWayName(u.getPayWayName()); payWayInfo.setProductCcode(u.getProductName()); payWayInfo.setImage(""); //TODO return payWayInfo; }).collect(Collectors.toList()); return wayInfoList; } @Override public Map query(TradeQueryDto queryDto) throws BizException { JSONObject object = new JSONObject(); //1.签名验证 TODO //2.查询商户订单号 TradePaymentOrder paymentOrder = tradePaymentService.queryByMchOrderNo(queryDto.getMchOrderNo(), queryDto.getMchId()); //3.交易不存在 if (ObjectUtils.isEmpty(paymentOrder)) { throw new BizException("商户对应的订单不存在"); } TradePaymentRecord paymentRecord = tradePaymentService.queryByTrxNo(paymentOrder.getTrxNo()); if (ObjectUtils.isEmpty(paymentRecord)) { throw new BizException("交易不存在"); } //4交易成功或者失败 if (PayStatusEnum.FAIL.getCode().equals(paymentOrder.getStatus()) || PayStatusEnum.SUCCESS.getCode().equals(paymentOrder.getStatus())) { //回调地址 object.put("notifyUrl", paymentOrder.getNotifyUrl()); //支付状态 object.put("status", paymentOrder.getStatus()); //返回描述 object.put("statusDesc", paymentRecord.getBankReturnMsg()); //todo //商户订单号 object.put("mchOrderNo", paymentOrder.getMerchantOrderNo()); //支付系统的流水 object.put("trxNo", paymentOrder.getTrxNo()); //支付方式 object.put("payWayCode", paymentOrder.getPayWayCode()); //支付完成时间 object.put("paySuccessTime", paymentRecord.getPaySuccessTime()); //商户号 object.put("mchNo", paymentOrder.getMerchantNo()); //签名算法 object.put("signType", SignEnum.MD5.getCode()); //回调地址 object.put("mchNotifyUrl", paymentOrder.getNotifyUrl()); //生成签名 TODO return object; } //4.订单处于支付中，未支付，就调用前置服务�