shayu/cai-server
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

123

Browse Source
This commit is contained in:
鲨鱼
2024-12-21 00:21:28 +08:00
parent 10a5f1c903
commit 583fb29acc
15 changed files with 712 additions and 57 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
ruoyi-cai/src/main/java/com/ruoyi/cai/filter/EncryptionFilter.java
View File

@@ -1,6 +1,7 @@
package com.ruoyi.cai.filter;
import com.ruoyi.cai.config.CaiProperties;
import com.ruoyi.cai.trdpay.TrdPayTypeEnum;
import com.ruoyi.cai.util.AES;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
@@ -23,9 +24,10 @@ public class EncryptionFilter implements Filter {
IGNORE_URL.add("/api/pay/wx/notify");
IGNORE_URL.add("/api/yx/im/notify");
IGNORE_URL.add("/api/yx/im/check");
IGNORE_URL.add("/api/pay/trd/notify/v1");
IGNORE_URL.add("/api/pay/trd/notify/v2");
IGNORE_URL.add("/api/pay/trd/notify/v3");
TrdPayTypeEnum[] values = TrdPayTypeEnum.values();
for (TrdPayTypeEnum value : values) {
IGNORE_URL.add(value.getNotifyPath());
}
}
private static final AntPathMatcher ANT_PATH_MATCHER = new AntPathMatcher();

2
ruoyi-cai/src/main/java/com/ruoyi/cai/service/PayTrdConfigService.java
View File

@@ -17,7 +17,7 @@ public interface PayTrdConfigService extends IService<PayTrdConfig> {
JSONObject queryOrder(String orderNo, String trdPayType);
JSONObject resetOrder(String orderNo, String trdPayType);
JSONObject resetOrder(String orderNo, String trdPayType,boolean updateData);
void enableStatus(Long id, Integer enableStatus);
}

18
ruoyi-cai/src/main/java/com/ruoyi/cai/service/impl/PayTrdConfigServiceImpl.java
View File

@@ -1,6 +1,5 @@
package com.ruoyi.cai.service.impl;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.baomidou.mybatisplus.core.toolkit.Wrappers;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@@ -9,21 +8,16 @@ import com.ruoyi.cai.mapper.PayTrdConfigMapper;
import com.ruoyi.cai.pay.PayManager;
import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp;
import com.ruoyi.cai.pay.PayTypeEnum;
import com.ruoyi.cai.service.OrderLogsService;
import com.ruoyi.cai.service.PayTrdConfigService;
import com.ruoyi.cai.trdpay.TrdPayManager;
import com.ruoyi.cai.trdpay.TrdPayTypeEnum;
import com.ruoyi.common.exception.ServiceException;
import com.tencentcloudapi.gme.v20180711.models.AppStatisticsItem;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import java.util.HashMap;
import java.util.Map;
/**
* 四方支付配置Service业务层处理
*
@@ -51,6 +45,9 @@ public class PayTrdConfigServiceImpl extends ServiceImpl<PayTrdConfigMapper, Pay
if(typeEnum == null){
throw new ServiceException("未开启支付，请联系客服");
}
PayReturnResp orderAliMerge = trdPayManager.createOrderAliMerge(dto, payTrdConfig, typeEnum);
return orderAliMerge;
/*
JSONObject jsonObject = trdPayManager.createOrderAli(dto, payTrdConfig, typeEnum);
if(jsonObject == null){
log.error("第三方支付失败 返回数据为空");
@@ -82,7 +79,7 @@ public class PayTrdConfigServiceImpl extends ServiceImpl<PayTrdConfigMapper, Pay
String payUrl = jsonObject.getJSONObject("payParams").getString("payUrl");
return PayReturnResp.createH5(payUrl);
}
return null;
return null;*/
}
@@ -118,7 +115,7 @@ public class PayTrdConfigServiceImpl extends ServiceImpl<PayTrdConfigMapper, Pay
}
@Override
public JSONObject resetOrder(String orderNo, String trdPayType){
public JSONObject resetOrder(String orderNo, String trdPayType,boolean updateData){
// PayOrderInfoDTO orderInfo = payManager.getOrderInfo(orderNo);
// if(orderInfo == null){
// throw new ServiceException("订单不存在");
@@ -132,7 +129,8 @@ public class PayTrdConfigServiceImpl extends ServiceImpl<PayTrdConfigMapper, Pay
if(typeEnum == null || payTrdConfig == null){
throw new ServiceException("配置数据为空");
}
JSONObject jsonObject = trdPayManager.queryOrder(orderNo,payTrdConfig,typeEnum);
return trdPayManager.resetQuery(orderNo,payTrdConfig,typeEnum,updateData);
/* JSONObject jsonObject = trdPayManager.queryOrder(orderNo,payTrdConfig,typeEnum);
if(typeEnum == TrdPayTypeEnum.V1){ // V1
if(!"SUCCESS".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V1统一支付失败失败 orderNo={}, payTrdConfig={}, typeEnum={}", orderNo, JSON.toJSONString(payTrdConfig),JSON.toJSONString(typeEnum));
@@ -185,7 +183,7 @@ public class PayTrdConfigServiceImpl extends ServiceImpl<PayTrdConfigMapper, Pay
}
return jsonObject;
}
return jsonObject;
return jsonObject;*/
}
@Override

23
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/PayMd5Util.java Normal file
View File

@@ -0,0 +1,23 @@
package com.ruoyi.cai.trdpay;
import cn.hutool.crypto.digest.DigestUtil;
import org.apache.commons.lang3.StringUtils;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
public class PayMd5Util {
public static String createParams(Map<String, String> params, String key) {
List<String> url = new ArrayList<>();
for (Map.Entry<String, String> entry : params.entrySet()) {
url.add(entry.getKey() + "=" + entry.getValue());
}
url = url.stream().sorted().collect(Collectors.toList());
String stringSignTemp = StringUtils.join(url, "&") + "&key=" + key;
String sign = DigestUtil.md5Hex(stringSignTemp).toUpperCase();
url.add("sign=" + sign);
return StringUtils.join(url, "&");
}
}

22
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/PayTrdService.java Normal file
View File

@@ -0,0 +1,22 @@
package com.ruoyi.cai.trdpay;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.cai.domain.PayTrdConfig;
import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp;
import com.ruoyi.cai.trdpay.dto.NotifyResp;
import java.util.Map;
public interface PayTrdService {
TrdPayTypeEnum getType();
PayReturnResp createOrderAli(PayOrderInfoDTO payOrderInfoDTO, PayTrdConfig payTrdConfig);
NotifyResp getNotifyResp(Map<String,String> sourceData);
JSONObject queryOrder(String orderNo, PayTrdConfig payTrdConfig);
JSONObject resetOrder(String orderNo, PayTrdConfig payTrdConfig,boolean updateData);
}

75
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/TrdPayManager.java
View File

@@ -1,22 +1,16 @@
package com.ruoyi.cai.trdpay;
import cn.hutool.crypto.digest.DigestUtil;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.cai.domain.Account;
import com.ruoyi.cai.domain.OrderLogs;
import com.ruoyi.cai.domain.PayTrdConfig;
import com.ruoyi.cai.enums.SystemConfigEnum;
import com.ruoyi.cai.manager.SystemConfigManager;
import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp;
import com.ruoyi.cai.service.AccountService;
import com.ruoyi.cai.service.OrderLogsService;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.ServletUtils;
import lombok.Data;
import com.ruoyi.cai.trdpay.dto.NotifyResp;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.http.client.BufferingClientHttpRequestFactory;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
@@ -25,15 +19,12 @@ import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.stereotype.Component;
import org.springframework.web.client.RestTemplate;
import javax.annotation.PostConstruct;
import java.math.BigDecimal;
import java.nio.charset.StandardCharsets;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import java.util.stream.Collectors;
@Component
@Slf4j
@@ -56,6 +47,47 @@ public class TrdPayManager {
}
}
@Autowired
private List<PayTrdService> payTrdServiceList;
private final Map<String,PayTrdService> payTrdServiceMap = new HashMap<>();
@PostConstruct
public void init(){
for (PayTrdService payTrdService : payTrdServiceList) {
payTrdServiceMap.put(payTrdService.getType().name(),payTrdService);
}
}
public PayTrdService getPayTrdService(String key){
return payTrdServiceMap.get(key);
}
@Autowired
private AccountService accountService;
@Autowired
private SystemConfigManager systemConfigManager;
public PayReturnResp createOrderAliMerge(PayOrderInfoDTO payOrderInfoDTO, PayTrdConfig payTrdConfig,TrdPayTypeEnum typeEnum){
PayTrdService payTrdService = getPayTrdService(typeEnum.name());
return payTrdService.createOrderAli(payOrderInfoDTO,payTrdConfig);
}
public NotifyResp getNotifyResp(Map<String,String> sourceData,TrdPayTypeEnum typeEnum){
PayTrdService payTrdService = getPayTrdService(typeEnum.name());
return payTrdService.getNotifyResp(sourceData);
}
public JSONObject queryOrder(String orderNo, PayTrdConfig payTrdConfig,TrdPayTypeEnum typeEnum){
PayTrdService payTrdService = getPayTrdService(typeEnum.name());
return payTrdService.queryOrder(orderNo, payTrdConfig);
}
public JSONObject resetQuery(String orderNo, PayTrdConfig payTrdConfig,TrdPayTypeEnum typeEnum,boolean updateData){
PayTrdService payTrdService = getPayTrdService(typeEnum.name());
return payTrdService.resetOrder(orderNo, payTrdConfig,updateData);
}
/*@Deprecated
public JSONObject createOrderAli(PayOrderInfoDTO payOrderInfoDTO, PayTrdConfig payTrdConfig,TrdPayTypeEnum typeEnum){
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
@@ -84,15 +116,9 @@ public class TrdPayManager {
log.info("第三方支付成功 URL={}, body={}",url, body);
orderLogsService.createAliPayLogs(payOrderInfoDTO.getOrderNo(),url,jsonObject,typeEnum);
return jsonObject;
}
}*/
@Autowired
private OrderLogsService orderLogsService;
@Autowired
private AccountService accountService;
@Autowired
private SystemConfigManager systemConfigManager;
public boolean useTrdPay(Long userId){
Account account = accountService.getByUserId(userId);
@@ -109,6 +135,7 @@ public class TrdPayManager {
return true;
}
/* @Deprecated
public JSONObject queryOrder(String orderNo, PayTrdConfig payTrdConfig,TrdPayTypeEnum typeEnum){
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
@@ -128,10 +155,10 @@ public class TrdPayManager {
}
log.info("第三方支付成功 URL={}, body={}",url, body);
return jsonObject;
}
}*/
private String createParams(Map<String, String> params,String key){
/*private String createParams(Map<String, String> params,String key){
List<String> url = new ArrayList<>();
for (Map.Entry<String, String> entry : params.entrySet()) {
url.add(entry.getKey()+"="+entry.getValue());
@@ -141,11 +168,7 @@ public class TrdPayManager {
String sign = DigestUtil.md5Hex(stringSignTemp).toUpperCase();
url.add("sign="+sign);
return StringUtils.join(url, "&");
}
}*/
public static void main(String[] args) {
}
}

1
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/TrdPayTypeEnum.java
View File

@@ -8,6 +8,7 @@ public enum TrdPayTypeEnum {
V1("http://pay.jpay.one/api","/pay/create_order","/pay/query_order","/api/pay/trd/notify/v1"),
V2("http://121.40.24.67:56700/api","/pay/create_order","/pay/query_order","/api/pay/trd/notify/v2"),
V3("http://pay.linken.click/api","/pay/create_order","/pay/query_order","/api/pay/trd/notify/v3"),
V4("http://47.243.172.120:8089","/channel/apiPay","/channel/order/query","/api/pay/trd/notify/v4"),
;
private final String gatewayUrl;
private final String createOrderUrl;

14
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/dto/NotifyResp.java Normal file
View File

@@ -0,0 +1,14 @@
package com.ruoyi.cai.trdpay.dto;
import com.ruoyi.cai.trdpay.TrdPayTypeEnum;
import lombok.Data;
import java.util.Map;
@Data
public class NotifyResp {
private String orderNo;
private String trdOrderNo;
private TrdPayTypeEnum payTypeEnum;
private Map<String,String> sourceData;
}

132
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/handle/PayTrdV1Service.java Normal file
View File

@@ -0,0 +1,132 @@
package com.ruoyi.cai.trdpay.handle;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ijpay.alipay.AliPayApi;
import com.ruoyi.cai.domain.PayTrdConfig;
import com.ruoyi.cai.pay.PayManager;
import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp;
import com.ruoyi.cai.pay.PayTypeEnum;
import com.ruoyi.cai.service.OrderLogsService;
import com.ruoyi.cai.trdpay.PayMd5Util;
import com.ruoyi.cai.trdpay.PayTrdService;
import com.ruoyi.cai.trdpay.TrdPayTypeEnum;
import com.ruoyi.cai.trdpay.dto.NotifyResp;
import com.ruoyi.cai.util.RestTemplateUtil;
import com.ruoyi.common.exception.ServiceException;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import java.util.HashMap;
import java.util.Map;
@Service
@Slf4j
public class PayTrdV1Service implements PayTrdService {
@Autowired
private OrderLogsService orderLogsService;
@Autowired
private PayManager payManager;
@Override
public TrdPayTypeEnum getType() {
return TrdPayTypeEnum.V1;
}
@Override
public PayReturnResp createOrderAli(PayOrderInfoDTO payOrderInfoDTO, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
RestTemplate rest = RestTemplateUtil.getRest();
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
params.put("productId", payTrdConfig.getAliProductId());
params.put("mchOrderNo", payOrderInfoDTO.getOrderNo());
params.put("amount", payOrderInfoDTO.getPriceFenStr());
String notifyUrl = payTrdConfig.getNotifyUrl() + type.getNotifyPath();
params.put("notifyUrl", notifyUrl);
String para = PayMd5Util.createParams(params, payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if (StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())) {
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String createOrderUrl = gatewayUrl + type.getCreateOrderUrl();
String url = createOrderUrl + "?" + para;
String body = rest.getForEntity(url, String.class).getBody();
JSONObject jsonObject = JSON.parseObject(body);
orderLogsService.createAliPayLogs(payOrderInfoDTO.getOrderNo(), url, jsonObject, type);
if(jsonObject == null){
log.error("第三方支付失败 V1返回数据为空 url={}",url);
throw new ServiceException("调用支付失败");
}
if(!"SUCCESS".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V1统一支付失败失败 dto={}, payTrdConfig={}, typeEnum={}", body, JSON.toJSONString(payTrdConfig), JSON.toJSONString(jsonObject));
throw new ServiceException("调用支付失败");
}
String payUrl = jsonObject.getJSONObject("payParams").getString("payUrl");
return PayReturnResp.createH5(payUrl);
}
@Override
public NotifyResp getNotifyResp(Map<String, String> sourceData) {
String mchOrderNo = sourceData.get("mchOrderNo");
String payOrderId = sourceData.get("payOrderId");
NotifyResp resp = new NotifyResp();
resp.setOrderNo(mchOrderNo);
resp.setTrdOrderNo(payOrderId);
resp.setPayTypeEnum(getType());
resp.setSourceData(sourceData);
return resp;
}
@Override
public JSONObject queryOrder(String orderNo, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
params.put("mchOrderNo", orderNo);
String para = PayMd5Util.createParams(params,payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if(StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())){
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String queryOrderUrl = gatewayUrl + type.getQueryOrderUrl();
String url = queryOrderUrl + "?" + para;
String body = RestTemplateUtil.getRest().getForEntity(url, String.class).getBody();
JSONObject jsonObject = JSON.parseObject(body);
if(jsonObject == null){
log.error("第三方支付查询失败 返回数据为空 URL={}",url);
throw new ServiceException("调用支付失败");
}
log.info("第三方支付查询成功 V1 URL={}, body={}",url, body);
return jsonObject;
}
@Override
public JSONObject resetOrder(String orderNo, PayTrdConfig payTrdConfig,boolean updateData) {
JSONObject jsonObject = this.queryOrder(orderNo,payTrdConfig);
if(!"SUCCESS".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V1统一支付失败失败 orderNo={}, payTrdConfig={}", orderNo, JSON.toJSONString(payTrdConfig));
throw new ServiceException("调用支付失败");
}
Integer status = jsonObject.getInteger("status");
if(status != null && status.equals(2)){
String mchOrderNo = jsonObject.getString("mchOrderNo");
String payOrderId = jsonObject.getString("payOrderId");
String productId = jsonObject.getString("productId");
Map<String,String> objectJson = new HashMap<>();
for (String key : jsonObject.keySet()) {
objectJson.put(key, jsonObject.getString(key));
}
if(updateData){
payManager.callBack(mchOrderNo,payOrderId,objectJson,"V1", PayTypeEnum.TRD);
}
}
return jsonObject;
}
}

146
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/handle/PayTrdV2Service.java Normal file
View File

@@ -0,0 +1,146 @@
package com.ruoyi.cai.trdpay.handle;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.cai.domain.PayTrdConfig;
import com.ruoyi.cai.pay.PayManager;
import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp;
import com.ruoyi.cai.pay.PayTypeEnum;
import com.ruoyi.cai.service.OrderLogsService;
import com.ruoyi.cai.trdpay.PayMd5Util;
import com.ruoyi.cai.trdpay.PayTrdService;
import com.ruoyi.cai.trdpay.TrdPayTypeEnum;
import com.ruoyi.cai.trdpay.dto.NotifyResp;
import com.ruoyi.cai.util.RestTemplateUtil;
import com.ruoyi.common.exception.ServiceException;
import com.ruoyi.common.utils.ServletUtils;
import lombok.Getter;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
import java.util.HashMap;
import java.util.Map;
@Service
@Slf4j
@Deprecated
public class PayTrdV2Service implements PayTrdService {
@Autowired
private OrderLogsService orderLogsService;
@Autowired
private PayManager payManager;
@Override
public TrdPayTypeEnum getType() {
return TrdPayTypeEnum.V2;
}
@Override
public PayReturnResp createOrderAli(PayOrderInfoDTO payOrderInfoDTO, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
RestTemplate rest = RestTemplateUtil.getRest();
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
params.put("productId", payTrdConfig.getAliProductId());
params.put("mchOrderNo", payOrderInfoDTO.getOrderNo());
params.put("amount", payOrderInfoDTO.getPriceFenStr());
params.put("reqTime", LocalDateTime.now().format(DateTimeFormatter.ofPattern("yyyyMMddHHmmss")));
params.put("version","1.0");
params.put("clientIp", ServletUtils.getClientIP());
params.put("subject",payOrderInfoDTO.getSubject());
params.put("body",payOrderInfoDTO.getBody());
params.put("currency","cny");
String notifyUrl = payTrdConfig.getNotifyUrl() + type.getNotifyPath();
params.put("notifyUrl", notifyUrl);
String para = PayMd5Util.createParams(params, payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if (StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())) {
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String createOrderUrl = gatewayUrl + type.getCreateOrderUrl();
String url = createOrderUrl + "?" + para;
String body = rest.getForEntity(url, String.class).getBody();
JSONObject jsonObject = JSON.parseObject(body);
orderLogsService.createAliPayLogs(payOrderInfoDTO.getOrderNo(), url, jsonObject, type);
if(jsonObject == null){
log.error("第三方支付失败 V2返回数据为空 url={}",url);
throw new ServiceException("调用支付失败");
}
if(!"0".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V2统一支付失败失败 dto={}, payTrdConfig={}, typeEnum={}", body, JSON.toJSONString(payTrdConfig), JSON.toJSONString(jsonObject));
throw new ServiceException("调用支付失败");
}
String payMethod = jsonObject.getString("payMethod");
if("alipayApp".equals(payMethod)){
String appStr = jsonObject.getJSONObject("payParams").getString("appStr");
return PayReturnResp.createApp(appStr);
}
return PayReturnResp.createH5(JSON.toJSONString(jsonObject));
}
@Override
public NotifyResp getNotifyResp(Map<String, String> sourceData) {
String mchOrderNo = sourceData.get("mchOrderNo");
String payOrderId = sourceData.get("payOrderId");
NotifyResp resp = new NotifyResp();
resp.setOrderNo(mchOrderNo);
resp.setTrdOrderNo(payOrderId);
resp.setPayTypeEnum(TrdPayTypeEnum.V1);
resp.setSourceData(sourceData);
return resp;
}
@Override
public JSONObject queryOrder(String orderNo, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
params.put("mchOrderNo", orderNo);
String para = PayMd5Util.createParams(params,payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if(StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())){
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String queryOrderUrl = gatewayUrl + type.getQueryOrderUrl();
String url = queryOrderUrl + "?" + para;
String body = RestTemplateUtil.getRest().getForEntity(url, String.class).getBody();
JSONObject jsonObject = JSON.parseObject(body);
if(jsonObject == null){
log.error("第三方支付查询失败 返回数据为空 URL={}",url);
throw new ServiceException("调用支付失败");
}
log.info("第三方支付查询成功 V2 URL={}, body={}",url, body);
return jsonObject;
}
@Override
public JSONObject resetOrder(String orderNo, PayTrdConfig payTrdConfig, boolean updateData) {
JSONObject jsonObject = this.queryOrder(orderNo,payTrdConfig);
if(!"0".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V2统一支付失败失败 orderNo={}, payTrdConfig={}", orderNo, JSON.toJSONString(payTrdConfig));
throw new ServiceException("调用支付失败");
}
Integer status = jsonObject.getInteger("status");
if(status != null && (status.equals(2) || status.equals(3))){
String mchOrderNo = jsonObject.getString("mchOrderNo");
String payOrderId = jsonObject.getString("payOrderId");
String productId = jsonObject.getString("productId");
Map<String,String> objectJson = new HashMap<>();
for (String key : jsonObject.keySet()) {
objectJson.put(key, jsonObject.getString(key));
}
if(updateData){
payManager.callBack(mchOrderNo,payOrderId,objectJson,"V2", PayTypeEnum.TRD);
}
}
return jsonObject;
}
}

131
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/handle/PayTrdV3Service.java Normal file
View File

@@ -0,0 +1,131 @@
package com.ruoyi.cai.trdpay.handle;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.cai.domain.PayTrdConfig;
import com.ruoyi.cai.pay.PayManager;
import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp;
import com.ruoyi.cai.pay.PayTypeEnum;
import com.ruoyi.cai.service.OrderLogsService;
import com.ruoyi.cai.trdpay.PayMd5Util;
import com.ruoyi.cai.trdpay.PayTrdService;
import com.ruoyi.cai.trdpay.TrdPayTypeEnum;
import com.ruoyi.cai.trdpay.dto.NotifyResp;
import com.ruoyi.cai.util.RestTemplateUtil;
import com.ruoyi.common.exception.ServiceException;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import java.util.HashMap;
import java.util.Map;
@Service
@Slf4j
public class PayTrdV3Service implements PayTrdService {
@Autowired
private OrderLogsService orderLogsService;
@Autowired
private PayManager payManager;
@Override
public TrdPayTypeEnum getType() {
return TrdPayTypeEnum.V3;
}
@Override
public PayReturnResp createOrderAli(PayOrderInfoDTO payOrderInfoDTO, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
RestTemplate rest = RestTemplateUtil.getRest();
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
params.put("productId", payTrdConfig.getAliProductId());
params.put("mchOrderNo", payOrderInfoDTO.getOrderNo());
params.put("amount", payOrderInfoDTO.getPriceFenStr());
String notifyUrl = payTrdConfig.getNotifyUrl() + type.getNotifyPath();
params.put("notifyUrl", notifyUrl);
String para = PayMd5Util.createParams(params, payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if (StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())) {
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String createOrderUrl = gatewayUrl + type.getCreateOrderUrl();
String url = createOrderUrl + "?" + para;
String body = rest.getForEntity(url, String.class).getBody();
JSONObject jsonObject = JSON.parseObject(body);
orderLogsService.createAliPayLogs(payOrderInfoDTO.getOrderNo(), url, jsonObject, type);
if(jsonObject == null){
log.error("第三方支付失败 V3 返回数据为空 url={}",url);
throw new ServiceException("调用支付失败");
}
if(!"SUCCESS".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V3 统一支付失败失败 dto={}, payTrdConfig={}, typeEnum={}", body, JSON.toJSONString(payTrdConfig), JSON.toJSONString(jsonObject));
throw new ServiceException("调用支付失败");
}
String payUrl = jsonObject.getJSONObject("payParams").getString("payUrl");
return PayReturnResp.createH5(payUrl);
}
@Override
public NotifyResp getNotifyResp(Map<String, String> sourceData) {
String mchOrderNo = sourceData.get("mchOrderNo");
String payOrderId = sourceData.get("payOrderId");
NotifyResp resp = new NotifyResp();
resp.setOrderNo(mchOrderNo);
resp.setTrdOrderNo(payOrderId);
resp.setPayTypeEnum(getType());
resp.setSourceData(sourceData);
return resp;
}
@Override
public JSONObject queryOrder(String orderNo, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
Map<String, String> params = new HashMap<>();
params.put("mchId", payTrdConfig.getMchId());
params.put("mchOrderNo", orderNo);
String para = PayMd5Util.createParams(params,payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if(StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())){
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String queryOrderUrl = gatewayUrl + type.getQueryOrderUrl();
String url = queryOrderUrl + "?" + para;
String body = RestTemplateUtil.getRest().getForEntity(url, String.class).getBody();
JSONObject jsonObject = JSON.parseObject(body);
if(jsonObject == null){
log.error("第三方支付查询失败 返回数据为空 URL={}",url);
throw new ServiceException("调用支付失败");
}
log.info("第三方支付查询成功 V3 URL={}, body={}",url, body);
return jsonObject;
}
@Override
public JSONObject resetOrder(String orderNo, PayTrdConfig payTrdConfig, boolean updateData) {
JSONObject jsonObject = this.queryOrder(orderNo,payTrdConfig);
if(!"SUCCESS".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V3统一支付失败失败 orderNo={}, payTrdConfig={}", orderNo, JSON.toJSONString(payTrdConfig));
throw new ServiceException("调用支付失败");
}
Integer status = jsonObject.getInteger("status");
if(status != null && status.equals(2)){
String mchOrderNo = jsonObject.getString("mchOrderNo");
String payOrderId = jsonObject.getString("payOrderId");
String productId = jsonObject.getString("productId");
Map<String,String> objectJson = new HashMap<>();
for (String key : jsonObject.keySet()) {
objectJson.put(key, jsonObject.getString(key));
}
if(updateData){
payManager.callBack(mchOrderNo,payOrderId,objectJson,"V3", PayTypeEnum.TRD);
}
}
return jsonObject;
}
}

132
ruoyi-cai/src/main/java/com/ruoyi/cai/trdpay/handle/PayTrdV4Service.java Normal file
View File

@@ -0,0 +1,132 @@
package com.ruoyi.cai.trdpay.handle;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.cai.domain.PayTrdConfig;
import com.ruoyi.cai.pay.PayManager;
import com.ruoyi.cai.pay.PayOrderInfoDTO;
import com.ruoyi.cai.pay.PayReturnResp;
import com.ruoyi.cai.service.OrderLogsService;
import com.ruoyi.cai.trdpay.PayMd5Util;
import com.ruoyi.cai.trdpay.PayTrdService;
import com.ruoyi.cai.trdpay.TrdPayTypeEnum;
import com.ruoyi.cai.trdpay.dto.NotifyResp;
import com.ruoyi.cai.util.RestTemplateUtil;
import com.ruoyi.common.exception.ServiceException;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.web.client.RestTemplate;
import java.util.HashMap;
import java.util.Map;
@Service
@Slf4j
public class PayTrdV4Service implements PayTrdService {
@Autowired
private OrderLogsService orderLogsService;
@Autowired
private PayManager payManager;
@Override
public TrdPayTypeEnum getType() {
return TrdPayTypeEnum.V4;
}
@Override
public PayReturnResp createOrderAli(PayOrderInfoDTO payOrderInfoDTO, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
RestTemplate rest = RestTemplateUtil.getRest();
Map<String, String> params = new HashMap<>();
params.put("merchantId", payTrdConfig.getMchId());
params.put("tradeType", payTrdConfig.getAliProductId());
params.put("merchantPayNo", payOrderInfoDTO.getOrderNo());
params.put("amt", payOrderInfoDTO.getPrice().toString());
String notifyUrl = payTrdConfig.getNotifyUrl() + type.getNotifyPath();
params.put("notifyUrl", notifyUrl);
params.put("goodsName",payOrderInfoDTO.getBody());
String para = PayMd5Util.createParams(params, payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if (StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())) {
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String createOrderUrl = gatewayUrl + type.getCreateOrderUrl();
String url = createOrderUrl + "?" + para;
String body = rest.postForObject(url, null, String.class);
JSONObject jsonObject = JSON.parseObject(body);
orderLogsService.createAliPayLogs(payOrderInfoDTO.getOrderNo(), url, jsonObject, type);
if(jsonObject == null){
log.error("第三方支付失败 V4 返回数据为空 url={}",url);
throw new ServiceException("调用支付失败");
}
if(!"0000".equals(jsonObject.getString("code"))){
log.info("第三方支付失败 V4 统一支付失败失败 dto={}, payTrdConfig={}, typeEnum={}", body, JSON.toJSONString(payTrdConfig), JSON.toJSONString(jsonObject));
throw new ServiceException("调用支付失败");
}
String payUrl = jsonObject.getJSONObject("data").getString("url");
return PayReturnResp.createH5(payUrl);
}
@Override
public NotifyResp getNotifyResp(Map<String, String> sourceData) {
String mchOrderNo = sourceData.get("merchantPayNo");
String payOrderId = sourceData.get("payNo");
NotifyResp resp = new NotifyResp();
resp.setOrderNo(mchOrderNo);
resp.setTrdOrderNo(payOrderId);
resp.setPayTypeEnum(getType());
resp.setSourceData(sourceData);
return resp;
}
@Override
public JSONObject queryOrder(String orderNo, PayTrdConfig payTrdConfig) {
TrdPayTypeEnum type = getType();
Map<String, String> params = new HashMap<>();
params.put("merchantId", payTrdConfig.getMchId());
params.put("merchantPayNo", orderNo);
String para = PayMd5Util.createParams(params,payTrdConfig.getSign());
String gatewayUrl = type.getGatewayUrl();
if(StringUtils.isNotBlank(payTrdConfig.getGatewayUrl())){
gatewayUrl = payTrdConfig.getGatewayUrl();
}
String queryOrderUrl = gatewayUrl + type.getQueryOrderUrl();
String url = queryOrderUrl + "?" + para;
String body = RestTemplateUtil.getRest().getForEntity(url, String.class).getBody();
JSONObject jsonObject = JSON.parseObject(body);
if(jsonObject == null){
log.error("第三方支付查询失败 返回数据为空 URL={}",url);
throw new ServiceException("调用支付失败");
}
log.info("第三方支付查询成功 V4 URL={}, body={}",url, body);
return jsonObject;
}
@Override
public JSONObject resetOrder(String orderNo, PayTrdConfig payTrdConfig, boolean updateData) {
throw new ServiceException("V4不支持订单查询");
/*JSONObject jsonObject = this.queryOrder(orderNo,payTrdConfig);
if(!"SUCCESS".equals(jsonObject.getString("retCode"))){
log.info("第三方支付失败 V4统一支付失败失败 orderNo={}, payTrdConfig={}", orderNo, JSON.toJSONString(payTrdConfig));
throw new ServiceException("调用支付失败");
}
Integer status = jsonObject.getInteger("status");
if(status != null && status.equals(1)){
String mchOrderNo = jsonObject.getString("mchOrderNo");
String payOrderId = jsonObject.getString("payOrderId");
String productId = jsonObject.getString("productId");
Map<String,String> objectJson = new HashMap<>();
for (String key : jsonObject.keySet()) {
objectJson.put(key, jsonObject.getString(key));
}
if(updateData){
payManager.callBack(mchOrderNo,payOrderId,objectJson,"V4", PayTypeEnum.TRD);
}
}
return jsonObject;*/
}
}

35
ruoyi-cai/src/main/java/com/ruoyi/cai/util/RestTemplateUtil.java Normal file
View File

@@ -0,0 +1,35 @@
package com.ruoyi.cai.util;
import org.springframework.http.client.BufferingClientHttpRequestFactory;
import org.springframework.http.client.SimpleClientHttpRequestFactory;
import org.springframework.http.converter.HttpMessageConverter;
import org.springframework.http.converter.StringHttpMessageConverter;
import org.springframework.web.client.RestTemplate;
import java.nio.charset.StandardCharsets;
import java.util.List;
public class RestTemplateUtil {
public static RestTemplate restTemplate;
static {
SimpleClientHttpRequestFactory requestFactory = new SimpleClientHttpRequestFactory();
requestFactory.setConnectTimeout(3000);
requestFactory.setReadTimeout(3000);
restTemplate = new RestTemplate(new BufferingClientHttpRequestFactory(requestFactory));
List<HttpMessageConverter<?>> messageConverters = restTemplate.getMessageConverters();
//添加转换器
for (HttpMessageConverter<?> messageConverter : messageConverters) {
if (messageConverter instanceof StringHttpMessageConverter) {
StringHttpMessageConverter converter = (StringHttpMessageConverter) messageConverter;
converter.setDefaultCharset(StandardCharsets.UTF_8);
}
}
}
public static RestTemplate getRest(){
return restTemplate;
}
}