From 9b44c17d57474254ca8f7ef9eecc2fe1be1ea695 Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Mon, 08 Sep 2025 18:03:53 +0800
Subject: [PATCH] 1
---
src/main/java/com/nq/pojo/PaymentNotifyResponse.java | 17 ++
src/main/java/com/nq/pojo/NotifyData.java | 26 +++
src/main/java/com/nq/controller/protol/UserController.java | 11 +
src/main/java/com/nq/pojo/PaymentResponseZero.java | 162 +++++++++++++++++++++++
src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java | 3
src/main/java/com/nq/service/impl/PayServiceImpl.java | 183 ++++++++++++++++++++++++++
6 files changed, 401 insertions(+), 1 deletions(-)
diff --git a/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java b/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java
index 8f1ffaf..3fe002c 100644
--- a/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java
+++ b/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java
@@ -78,6 +78,9 @@
if ("/user/rechargeCallbackTwo.do".equals(url)) {//支付回调
return true;
}
+ if ("/user/rechargeCallbackZero.do".equals(url)) {//支付回调
+ return true;
+ }
User currentUser = getCurrentUser(httpServletRequest);
GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
String lang = httpServletRequest.getHeader("lang");
diff --git a/src/main/java/com/nq/controller/protol/UserController.java b/src/main/java/com/nq/controller/protol/UserController.java
index b766346..330c6dd 100644
--- a/src/main/java/com/nq/controller/protol/UserController.java
+++ b/src/main/java/com/nq/controller/protol/UserController.java
@@ -431,6 +431,9 @@
if(new BigDecimal(tradeAmoun).compareTo(new BigDecimal("5000")) < 0){
return ServerResponse.createByErrorMsg("请重新输入，最低充值金额：5000", request);
}
+ if(type == 0 && new BigDecimal(tradeAmoun).compareTo(new BigDecimal("40000")) > 0){
+ return ServerResponse.createByErrorMsg("请重新输入，最大充值金额：40000", request);
+ }
payCreated.set(true);
return payService.thirdPartyRecharge(request,tradeAmoun,type);
@@ -453,6 +456,14 @@
}
/**
+ * 默认充值异步接收地址
+ */
+ @PostMapping({"rechargeCallbackZero.do"})
+ public void rechargeCallbackZero(@RequestBody PaymentNotifyResponse vo, HttpServletResponse response) throws IOException {
+ payService.rechargeCallbackZero(vo,response);
+ }
+
+ /**
* 充值1异步接收地址
*/
@PostMapping({"rechargeCallback.do"})
diff --git a/src/main/java/com/nq/pojo/NotifyData.java b/src/main/java/com/nq/pojo/NotifyData.java
new file mode 100644
index 0000000..878314d
--- /dev/null
+++ b/src/main/java/com/nq/pojo/NotifyData.java
@@ -0,0 +1,26 @@
+package com.nq.pojo;
+
+import lombok.Data;
+
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * @program: dabaogp
+ * @description:
+ * @create: 2025-09-08 17:09
+ **/
+@Data
+public class NotifyData {
+ private String amount;//订单金额
+ private String orderNo;//平台订单号
+ private String message;//失败原因
+ private String type;//类型
+ private String merchantOrderNo;//商户订单号
+ private String processedTime;//成功时间
+ private String status;//订单状态
+ private String payAmount; // 订单实付金额
+ private String partpay; // 订单是否支持部分付款
+ private String utr; // UTR号
+ private String transferMode; // 转账方式
+}
diff --git a/src/main/java/com/nq/pojo/PaymentNotifyResponse.java b/src/main/java/com/nq/pojo/PaymentNotifyResponse.java
new file mode 100644
index 0000000..ddb6ce3
--- /dev/null
+++ b/src/main/java/com/nq/pojo/PaymentNotifyResponse.java
@@ -0,0 +1,17 @@
+package com.nq.pojo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+import java.math.BigDecimal;
+import java.util.Date;
+
+/**
+ * 支付回调通知接收类
+ */
+@Data
+public class PaymentNotifyResponse implements Serializable {
+ private NotifyData data;
+ private String signature;
+ private String signature_n;
+}
\ No newline at end of file
diff --git a/src/main/java/com/nq/pojo/PaymentResponseZero.java b/src/main/java/com/nq/pojo/PaymentResponseZero.java
new file mode 100644
index 0000000..3f6e7ea
--- /dev/null
+++ b/src/main/java/com/nq/pojo/PaymentResponseZero.java
@@ -0,0 +1,162 @@
+package com.nq.pojo;
+
+import lombok.Data;
+
+import java.io.Serializable;
+
+public class PaymentResponseZero implements Serializable {
+ private int code;
+ private String msg;
+ private PaymentData data;
+ private boolean success;
+
+ // 无参构造器
+ public PaymentResponseZero() {}
+
+ // 全参构造器
+ public PaymentResponseZero(int code, String msg, PaymentData data, boolean success) {
+ this.code = code;
+ this.msg = msg;
+ this.data = data;
+ this.success = success;
+ }
+
+ // Getter和Setter方法
+ public int getCode() {
+ return code;
+ }
+
+ public void setCode(int code) {
+ this.code = code;
+ }
+
+ public String getMsg() {
+ return msg;
+ }
+
+ public void setMsg(String msg) {
+ this.msg = msg;
+ }
+
+ public PaymentData getData() {
+ return data;
+ }
+
+ public void setData(PaymentData data) {
+ this.data = data;
+ }
+
+ public boolean isSuccess() {
+ return success;
+ }
+
+ public void setSuccess(boolean success) {
+ this.success = success;
+ }
+
+ @Override
+ public String toString() {
+ return "PaymentResponse{" +
+ "code=" + code +
+ ", msg='" + msg + '\'' +
+ ", data=" + data +
+ ", success=" + success +
+ '}';
+ }
+
+ public class PaymentData implements Serializable {
+ private String status;
+ private String merchantOrderNo;
+ private String orderNo;
+ private String paymentLinkUrl;
+ private String message;
+ private String upiAccount;
+ private String deeplink;
+
+ // 无参构造器
+ public PaymentData() {
+ }
+
+ // 全参构造器
+ public PaymentData(String status, String merchantOrderNo, String orderNo,
+ String paymentLinkUrl, String message, String upiAccount, String deeplink) {
+ this.status = status;
+ this.merchantOrderNo = merchantOrderNo;
+ this.orderNo = orderNo;
+ this.paymentLinkUrl = paymentLinkUrl;
+ this.message = message;
+ this.upiAccount = upiAccount;
+ this.deeplink = deeplink;
+ }
+
+ // Getter和Setter方法
+ public String getStatus() {
+ return status;
+ }
+
+ public void setStatus(String status) {
+ this.status = status;
+ }
+
+ public String getMerchantOrderNo() {
+ return merchantOrderNo;
+ }
+
+ public void setMerchantOrderNo(String merchantOrderNo) {
+ this.merchantOrderNo = merchantOrderNo;
+ }
+
+ public String getOrderNo() {
+ return orderNo;
+ }
+
+ public void setOrderNo(String orderNo) {
+ this.orderNo = orderNo;
+ }
+
+ public String getPaymentLinkUrl() {
+ return paymentLinkUrl;
+ }
+
+ public void setPaymentLinkUrl(String paymentLinkUrl) {
+ this.paymentLinkUrl = paymentLinkUrl;
+ }
+
+ public String getMessage() {
+ return message;
+ }
+
+ public void setMessage(String message) {
+ this.message = message;
+ }
+
+ public String getUpiAccount() {
+ return upiAccount;
+ }
+
+ public void setUpiAccount(String upiAccount) {
+ this.upiAccount = upiAccount;
+ }
+
+ public String getDeeplink() {
+ return deeplink;
+ }
+
+ public void setDeeplink(String deeplink) {
+ this.deeplink = deeplink;
+ }
+
+ @Override
+ public String toString() {
+ return "PaymentData{" +
+ "status='" + status + '\'' +
+ ", merchantOrderNo='" + merchantOrderNo + '\'' +
+ ", orderNo='" + orderNo + '\'' +
+ ", paymentLinkUrl='" + paymentLinkUrl + '\'' +
+ ", message='" + message + '\'' +
+ ", upiAccount='" + upiAccount + '\'' +
+ ", deeplink='" + deeplink + '\'' +
+ '}';
+ }
+ }
+}
\ No newline at end of file
diff --git a/src/main/java/com/nq/service/impl/PayServiceImpl.java b/src/main/java/com/nq/service/impl/PayServiceImpl.java
index c169f61..e96f0ec 100644
--- a/src/main/java/com/nq/service/impl/PayServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/PayServiceImpl.java
@@ -26,6 +26,8 @@
import java.io.UnsupportedEncodingException;
import java.math.BigDecimal;
import java.net.URLDecoder;
+import java.nio.charset.StandardCharsets;
+import java.security.Key;
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
import java.text.SimpleDateFormat;
@@ -33,10 +35,15 @@
import java.time.format.DateTimeFormatter;
import java.util.*;
import javax.annotation.Resource;
+import javax.crypto.Cipher;
+import javax.crypto.spec.IvParameterSpec;
+import javax.crypto.spec.SecretKeySpec;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
+import net.sf.json.JSON;
import net.sf.json.JSONObject;
+import okhttp3.*;
import org.apache.commons.collections.map.HashedMap;
import org.apache.commons.collections.map.LinkedMap;
import org.apache.commons.lang3.ObjectUtils;
@@ -88,7 +95,10 @@
@Autowired
UserAssetsServices userAssetsServices;
- public ServerResponse thirdPartyRecharge(HttpServletRequest request, String tradeAmount, Integer type) throws UnsupportedEncodingException, JsonProcessingException, NoSuchAlgorithmException {
+ private static final String KEY_ALGORITHM = "AES";
+ private static final String AES128CBC = "AES/CBC/PKCS5Padding";
+
+ public ServerResponse thirdPartyRecharge(HttpServletRequest request, String tradeAmount, Integer type) throws Exception {
// 支付1
String reqUrl = "https://api.watchglb.com/pay/web";
// 支付2
@@ -105,11 +115,102 @@
return getPaymentOne(tradeAmount, reqUrl,user,request);
}else if(type == 1){//支付2
return getPaymentTwo(tradeAmount, uipReqRul, user,request);
+ }else if(type == 0){
+ return getPaymentZero(tradeAmount, uipReqRul, user,request);
}
return ServerResponse.createByErrorMsg("获取支付方式失败",request);
}
+ private ServerResponse getPaymentZero(String tradeAmount, String uipReqRul, User user, HttpServletRequest request) throws Exception {
+ //int
+ String url = "https://gateway.king-pays.com/gateway/payment/init";//正式地址
+ String merchantKey = "qqaC1DH/LeR9iPvm";//商户key 需替换
+ String aesKey = "ge6vK40fHNZPFJ4p";//商户aesKey 需替换
+ String aesIv = "6gJoHTEE1i2O3ovE";//商户aesIv 需替换
+ //请求参数
+ JSONObject dataObj = new JSONObject();
+ // 代收请求
+ dataObj.put("amount",tradeAmount);//需替换
+ dataObj.put("customerName",user.getPhone());//需替换
+ dataObj.put("customerEmail","123456@qq.com");//需替换
+ dataObj.put("customerPhone",user.getPhone());//需替换
+ dataObj.put("merchantOrderNo",generatePayOrderId());//自定义订单号
+ dataObj.put("notifyUrl", "https://api.durocaspitall.com/user/rechargeCallbackZero.do");//回调通知地址
+ JSONObject requestObj = new JSONObject();
+ // 加密数据
+ byte[] encryptedData = encrypt(dataObj.toString(), aesKey, aesIv);
+ String base64EncodedData = Base64.getEncoder().encodeToString(encryptedData);
+ requestObj.put("data", base64EncodedData);
+ //消息头
+ Headers headers = new Headers.Builder().add("merchant_key", merchantKey).build();//merchant_key需替换
+ //请求
+ String resp = doPost(url, requestObj.toString(), headers);
+ Gson gson = new Gson();
+ PaymentResponseZero paymentResponse = gson.fromJson(resp, PaymentResponseZero.class);
+ if(paymentResponse.getCode() != 0 && !paymentResponse.getMsg().equals("success")){
+ log.error("默认充值下单失败："+resp);
+ return ServerResponse.createByErrorMsg("获取默认充值链接失败",request);
+ }
+ PaymentRecharge paymentRecharge = new PaymentRecharge();
+ paymentRecharge.setUserId(user.getId());
+ paymentRecharge.setOrderNo(dataObj.getString("merchantOrderNo"));
+ paymentRecharge.setMchOrderNo(paymentResponse.getData().getOrderNo());
+ paymentRecharge.setAmount(new BigDecimal(tradeAmount));
+ paymentRecharge.setStatus(1);
+ paymentRecharge.setPaymentTime(new Date());
+ paymentRecharge.setCreatedAt(new Date());
+ paymentRecharge.setNotifyUrl(getOrderTime());
+ paymentRecharge.setPayInfo(paymentResponse.toString());
+ paymentRechargeService.save(paymentRecharge);
+
+ UserRecharge userRecharge = new UserRecharge();
+ userRecharge.setUserId(user.getId());
+ userRecharge.setNickName(user.getRealName());
+ userRecharge.setAgentId(user.getAgentId());
+ userRecharge.setOrderSn(dataObj.getString("merchantOrderNo"));
+ userRecharge.setPayChannel("Payment 1");
+ userRecharge.setPayAmt(new BigDecimal(tradeAmount));
+ userRecharge.setAddTime(new Date());
+ userRecharge.setPayTime(new Date());
+ userRecharge.setOrderStatus(Integer.valueOf(0));
+ userRecharge.setPayId(1);
+ userRechargeMapper.insert(userRecharge);
+ return ServerResponse.createBySuccess(paymentResponse.getData().getPaymentLinkUrl());
+ }
+
+ public static String doPost(String url, String data, Headers headers) throws IOException {
+ OkHttpClient customClient = new OkHttpClient();
+ Request request = new Request.Builder()
+ .url(url)
+ .headers(headers)
+ .post(RequestBody.create(MediaType.parse("application/json;charset=UTF-8"), data))
+ .build();
+ Response response = customClient.newCall(request).execute();
+ String resp = response.body().string();
+ return resp;
+ }
+
+
+ public static byte[] encrypt(String data, String key, String iv) throws Exception {
+ return encrypt(data.getBytes(StandardCharsets.UTF_8), key.getBytes(StandardCharsets.UTF_8), iv.getBytes(StandardCharsets.UTF_8));
+ }
+
+ /**
+ * 加密
+ *
+ * @param data 待加密数据
+ * @param key 密钥
+ * @return byte[] 加密数据
+ * @throws Exception
+ */
+ public static byte[] encrypt(byte[] data, byte[] key, byte[] iv) throws Exception {
+ Key k = new SecretKeySpec(key, KEY_ALGORITHM);
+ Cipher cipher = Cipher.getInstance(AES128CBC);
+ final IvParameterSpec ivParameterSpec = new IvParameterSpec(iv);
+ cipher.init(Cipher.ENCRYPT_MODE, k, ivParameterSpec);
+ return cipher.doFinal(data);
+ }
//支付2
private ServerResponse getPaymentTwo(String tradeAmount, String uipReqRul, User user, HttpServletRequest request) throws UnsupportedEncodingException, NoSuchAlgorithmException, JsonProcessingException {
// 示例参数
@@ -986,4 +1087,84 @@
}
}
+
+ public void rechargeCallbackZero(PaymentNotifyResponse vo, HttpServletResponse response) throws IOException {
+
+ log.info("充值回调进来了："+vo.toString());
+ synchronized (vo.getData().getOrderNo()){
+ PrintWriter pw = response.getWriter();
+
+ PaymentRecharge paymentRecharge = paymentRechargeService.getOne(new LambdaQueryWrapper<>(PaymentRecharge.class)
+ .eq(PaymentRecharge::getOrderNo,vo.getData().getMerchantOrderNo())
+ .eq(PaymentRecharge::getStatus,1)
+ .last("limit 1")
+ );
+ if(ObjectUtils.isEmpty(paymentRecharge)){
+ log.info("未找到充值订单");
+ pw.print("error 未找到充值订单");
+ return;
+ }
+ UserRecharge userRecharge = userRechargeMapper.selectOne(new LambdaQueryWrapper<>(UserRecharge.class)
+ .eq(UserRecharge::getOrderSn, paymentRecharge.getOrderNo())
+ .eq(UserRecharge::getOrderStatus, 0).last(" limit 1"));
+ if(ObjectUtils.isEmpty(userRecharge)){
+ log.info("未找到充值记录订单");
+ pw.print("error 未找到充值订单");
+ return;
+ }
+
+ if(vo.getData().getStatus().equals("PENDING")){
+ log.error("充值2回调交易中："+vo.toString());
+ pw.print("{code: 200}");
+ pw.flush();
+ pw.close();
+ return;
+ }else if(vo.getData().getStatus().equals("FAILURE")){
+ paymentRecharge.setStatus(2);
+ paymentRecharge.setAmount(new BigDecimal(vo.getData().getAmount()));
+ paymentRecharge.setPayInfo(vo.toString());
+ paymentRechargeService.updateById(paymentRecharge);
+ userRecharge.setOrderStatus(2);
+ userRechargeMapper.updateById(userRecharge);
+ log.error("充值回调失败："+vo.toString());
+ pw.print("{code: 200}");
+ pw.flush();
+ pw.close();
+ return;
+ }else if(vo.getData().getStatus().equals("REFUND")){
+ paymentRecharge.setStatus(2);
+ paymentRecharge.setAmount(new BigDecimal(vo.getData().getAmount()));
+ paymentRecharge.setPayInfo(vo.toString());
+ paymentRechargeService.updateById(paymentRecharge);
+ userRecharge.setOrderStatus(2);
+ userRecharge.setOrderDesc("REFUND");
+ userRechargeMapper.updateById(userRecharge);
+ log.error("充值回调失败(已退款)："+vo.toString());
+ pw.print("{code: 200}");
+ pw.flush();
+ pw.close();
+ return;
+ }else if(!vo.getData().getStatus().equals("PENDING") && !vo.getData().getStatus().equals("FAILURE") && !vo.getData().getStatus().equals("SUCCESS") && !vo.getData().getStatus().equals("REFUND")){
+ log.error("充值回调失败----未知状态："+vo.toString());
+ pw.print("error 未找到充值订单");
+ return;
+ }
+
+ userAssetsServices.availablebalanceChange(EStockType.IN.getCode(),
+ paymentRecharge.getUserId(), EUserAssets.TOP_UP,new BigDecimal(vo.getData().getAmount().toString()),"","");
+
+ paymentRecharge.setStatus(2);
+ paymentRecharge.setAmount(new BigDecimal(vo.getData().getAmount()));
+ paymentRecharge.setPayInfo(vo.toString());
+ paymentRechargeService.updateById(paymentRecharge);
+
+ userRecharge.setOrderStatus(1);
+ userRechargeMapper.updateById(userRecharge);
+
+ log.info("充值回调----完成");
+ pw.print("{code: 200}");
+ pw.flush();
+ pw.close();
+ }
+ }
}
\ No newline at end of file
--
Gitblit v1.9.3