From a20da8817adb2342bd60f79e47487186a586f93a Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Mon, 05 Jan 2026 19:23:31 +0800
Subject: [PATCH] 代收，代付
---
src/main/java/com/nq/service/IPayService.java | 10 +
src/main/java/com/nq/controller/protol/UserController.java | 24 +++
src/main/java/com/nq/controller/protol/UserWithdrawController.java | 5
src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java | 119 +++++++++++++++++
src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java | 11
src/main/java/com/nq/service/impl/PayServiceImpl.java | 225 ++++++++++++++++++++++++++++++-
6 files changed, 376 insertions(+), 18 deletions(-)
diff --git a/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java b/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java
index 3fe002c..8a333ba 100644
--- a/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java
+++ b/src/main/java/com/nq/common/interceptor/ApiUserAuthorityInterceptor.java
@@ -81,6 +81,12 @@
if ("/user/rechargeCallbackZero.do".equals(url)) {//支付回调
return true;
}
+ if ("/user/rechargeCallbackThree.do".equals(url)) {//支付回调
+ return true;
+ }
+ if ("/user/payoutCallback.do".equals(url)) {//代付回调
+ return true;
+ }
User currentUser = getCurrentUser(httpServletRequest);
GoogleTranslateUtil googleTranslateUtil = new GoogleTranslateUtil();
String lang = httpServletRequest.getHeader("lang");
@@ -193,20 +199,15 @@
public User getCurrentUser(HttpServletRequest request) {
String property = PropertiesUtil.getProperty("user.cookie.name");
- System.out.println(property);
String loginToken = request.getHeader(property);
if (loginToken == null) {
- System.out.println("loginToken is null");
return null;
}
- System.out.println(loginToken);
String userJson = RedisShardedPoolUtils.get(loginToken);
if (userJson == null||"".equals(userJson)){
- System.out.println("userJson is null");
return null;
}
-// System.out.println(userJson);
return (User) JsonUtil.string2Obj(userJson, User.class);
}
}
diff --git a/src/main/java/com/nq/controller/protol/UserController.java b/src/main/java/com/nq/controller/protol/UserController.java
index 330c6dd..6c32bb6 100644
--- a/src/main/java/com/nq/controller/protol/UserController.java
+++ b/src/main/java/com/nq/controller/protol/UserController.java
@@ -492,4 +492,28 @@
vo.setSign(sign);
payService.rechargeCallbackTwo(vo,response);
}
+
+ /**
+ * 充值2异步接收地址
+ */
+ @PostMapping({"rechargeCallbackThree.do"})
+ public void rechargeCallbackThree(@RequestBody RechargeCallbackThreeVo callbackVo, HttpServletResponse response) throws IOException {
+ TransactionStatusVo vo = new TransactionStatusVo();
+ vo.setStatus(callbackVo.getOrder_status());
+ vo.setMerchantid(callbackVo.getMerchant_id());
+ vo.setOut_trade_no(callbackVo.getSystem_order_id());
+ vo.setTotal_fee(callbackVo.getAmount());
+ vo.setAccount_fee(callbackVo.getAccount_amount());
+ vo.setSign(callbackVo.getSign());
+ vo.setPoundage("0");
+ payService.rechargeCallbackThree(vo,response);
+ }
+
+ /**
+ * 代付回调接口
+ */
+ @PostMapping({"payoutCallback.do"})
+ public void payoutCallback(@RequestBody PayoutCallbackVo callbackVo, HttpServletResponse response) throws IOException {
+ payService.payoutCallback(callbackVo, response);
+ }
}
diff --git a/src/main/java/com/nq/controller/protol/UserWithdrawController.java b/src/main/java/com/nq/controller/protol/UserWithdrawController.java
index f513fb5..fa607d8 100644
--- a/src/main/java/com/nq/controller/protol/UserWithdrawController.java
+++ b/src/main/java/com/nq/controller/protol/UserWithdrawController.java
@@ -51,10 +51,7 @@
String requestId = user.getId() + "_" + amt + "_" + bankId;
- if (user.getId() == 1888 || user.getId() == 1752) {
- return ServerResponse.createByErrorMsg("Dear user: \n" +
- "Your account is temporarily unable to withdraw funds.",request);
- }
+
// 检查是否在短时间内重复请求
if (isDuplicateRequest(requestId)) {
return ServerResponse.createByErrorMsg("重复提交，请稍后再试。！",request);
diff --git a/src/main/java/com/nq/service/IPayService.java b/src/main/java/com/nq/service/IPayService.java
index 61d5b44..b90fe5c 100644
--- a/src/main/java/com/nq/service/IPayService.java
+++ b/src/main/java/com/nq/service/IPayService.java
@@ -3,7 +3,9 @@
import com.nq.common.ServerResponse;
import com.nq.pojo.PaymentResponse;
+import com.nq.pojo.PayoutCallbackVo;
import com.nq.pojo.RechargeCallbackVo;
+import com.nq.pojo.TransactionStatusVo;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
@@ -30,4 +32,12 @@
ServerResponse withdrawNotify(HttpServletRequest paramHttpServletRequest,String key) throws IOException;
void rechargeCallback(PaymentResponse vo, HttpServletResponse response) throws IOException;
+
+ void rechargeCallbackTwo(TransactionStatusVo vo, HttpServletResponse response) throws IOException;
+
+ void rechargeCallbackZero(com.nq.pojo.PaymentNotifyResponse vo, HttpServletResponse response) throws IOException;
+
+ void rechargeCallbackThree(TransactionStatusVo vo, HttpServletResponse response) throws IOException;
+
+ void payoutCallback(PayoutCallbackVo vo, HttpServletResponse response) throws IOException;
}
diff --git a/src/main/java/com/nq/service/impl/PayServiceImpl.java b/src/main/java/com/nq/service/impl/PayServiceImpl.java
index 4d59e79..506fe3e 100644
--- a/src/main/java/com/nq/service/impl/PayServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/PayServiceImpl.java
@@ -95,6 +95,9 @@
@Autowired
UserAssetsServices userAssetsServices;
+ @Autowired
+ TransferResponseService transferResponseService;
+
private static final String KEY_ALGORITHM = "AES";
private static final String AES128CBC = "AES/CBC/PKCS5Padding";
@@ -114,13 +117,14 @@
}
if(type == 0){//支付1
- return getPaymentOne(tradeAmount, reqUrl,user,request);
- }else if(type == 2){//支付2
- return getPaymentTwo(tradeAmount, uipReqRul, user,request);
- } else if(type == 3){//支付2
return getPaymentThree(tradeAmount, threeUrl, user,request);
+ }else if(type == 2){//支付2
+ return getPaymentThree(tradeAmount, threeUrl, user,request);
+ } else if(type == 3){//支付2
+// return getPaymentOne(tradeAmount, reqUrl,user,request);
+ return getPaymentTwo(tradeAmount, uipReqRul, user,request);
}else if(type == 1){
- return getPaymentZero(tradeAmount, uipReqRul, user,request);
+ return getPaymentZero(tradeAmount, uipReqRul, user,request);
}
return ServerResponse.createByErrorMsg("获取支付方式失败",request);
}
@@ -219,8 +223,8 @@
private ServerResponse getPaymentThree(String tradeAmount, String uipReqRul, User user, HttpServletRequest request) throws Exception {
// 配置参数（建议放到配置文件中）
- String appId = "your_app_id_here"; // 从商户后台获取
- String key = "your_key_here"; // 商户密钥
+ String appId = "db270b73dc384c89ae7241d6465cee03"; // 从商户后台获取
+ String key = "PAXkm5ptBhvzNYBSpdm3p7ipwGUQOF8Fm3tYp0"; // 商户密钥
String payChannel = "INDIA_NATIVE"; // 支付通道，根据实际情况选择
// 生成商户订单号
@@ -236,8 +240,8 @@
params.put("merchant_order_id", merchantOrderId);
params.put("amount", amount.toString());
params.put("pay_channel", payChannel);
- params.put("notify_url", "https://api.durocaspitall.com/user/rechargeCallbackTwo.do"); // 异步通知地址
- params.put("page_return_url", "https://yourdomain.com/pay/return"); // 前端返回地址
+ params.put("notify_url", "https://api.durocaspitall.com/user/rechargeCallbackThree.do"); // 异步通知地址
+ params.put("page_return_url", "https://stock.durocapital.net/#/user"); // 前端返回地址
// 可选参数
if (user != null) {
@@ -1274,4 +1278,207 @@
pw.close();
}
}
+
+ public void rechargeCallbackThree(TransactionStatusVo vo, HttpServletResponse response) throws IOException {
+
+ log.info("充值回调进来了："+vo.toString());
+ synchronized (vo.getOut_trade_no()){
+ PrintWriter pw = response.getWriter();
+
+ PaymentRecharge paymentRecharge = paymentRechargeService.getOne(new LambdaQueryWrapper<>(PaymentRecharge.class)
+ .eq(PaymentRecharge::getMchOrderNo,vo.getOut_trade_no())
+ .eq(PaymentRecharge::getStatus,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.getStatus().equals("PAY_ING")){
+ log.error("充值3回调交易中："+vo.toString());
+ return;
+ }else if(vo.getStatus().equals("PAY_FAIL")){
+ paymentRecharge.setStatus(2);
+ paymentRecharge.setAmount(new BigDecimal(vo.getTotal_fee()));
+ paymentRecharge.setPayInfo(vo.toString());
+ paymentRechargeService.updateById(paymentRecharge);
+ userRecharge.setOrderStatus(2);
+ userRechargeMapper.updateById(userRecharge);
+ log.error("充值回调失败："+vo.toString());
+ return;
+ }else if(!vo.getStatus().equals("PAY_ING") && !vo.getStatus().equals("PAY_FAIL") && !vo.getStatus().equals("PAY_SUCCESS")){
+ log.error("充值回调失败----未知状态："+vo.toString());
+ return;
+ }
+
+ userAssetsServices.availablebalanceChange(EStockType.IN.getCode(),
+ paymentRecharge.getUserId(), EUserAssets.TOP_UP,new BigDecimal(vo.getTotal_fee().toString()),"","");
+
+ paymentRecharge.setStatus(2);
+ paymentRecharge.setAmount(new BigDecimal(vo.getTotal_fee()));
+ paymentRecharge.setPayInfo(vo.toString());
+ paymentRechargeService.updateById(paymentRecharge);
+
+ userRecharge.setOrderStatus(1);
+ userRechargeMapper.updateById(userRecharge);
+
+ log.info("充值回调----完成");
+ pw.print("success");
+ pw.flush();
+ pw.close();
+ }
+ }
+
+ /**
+ * 代付回调处理
+ */
+ @Override
+ public void payoutCallback(PayoutCallbackVo vo, HttpServletResponse response) throws IOException {
+ log.info("代付回调进来了：" + vo.toString());
+
+ PrintWriter pw = response.getWriter();
+
+ try {
+ // 验证签名
+ String key = "PAXkm5ptBhvzNYBSpdm3p7ipwGUQOF8Fm3tYp0"; // 商户密钥
+ Map<String, String> signParams = new HashMap<>();
+ signParams.put("merchant_id", vo.getMerchantId());
+ signParams.put("app_id", vo.getAppId());
+ signParams.put("system_order_id", vo.getSystemOrderId());
+ signParams.put("merchant_order_id", vo.getMerchantOrderId());
+ signParams.put("amount", vo.getAmount());
+ signParams.put("order_status", vo.getOrderStatus());
+ signParams.put("msg", vo.getMsg());
+
+ boolean signValid = PaymentSignUtil.verifySign(signParams, key, vo.getSign());
+ if (!signValid) {
+ log.error("代付回调签名验证失败");
+ pw.print("error 签名验证失败");
+ pw.flush();
+ pw.close();
+ return;
+ }
+
+ // 根据商户订单号查找代付记录
+ TransferResponse transferResponse = transferResponseService.getOne(
+ new LambdaQueryWrapper<>(TransferResponse.class)
+ .eq(TransferResponse::getMerTransferId, vo.getMerchantOrderId())
+ .last("limit 1")
+ );
+
+ if (ObjectUtils.isEmpty(transferResponse)) {
+ log.info("未找到代付订单记录，商户订单号：{}", vo.getMerchantOrderId());
+ pw.print("error 未找到代付订单");
+ pw.flush();
+ pw.close();
+ return;
+ }
+
+ // 检查是否已处理过
+ if (transferResponse.getCallbackState() != 0) {
+ log.info("代付回调已处理过，商户订单号：{}", vo.getMerchantOrderId());
+ pw.print("success");
+ pw.flush();
+ pw.close();
+ return;
+ }
+
+ // 查找提现记录
+ UserWithdraw userWithdraw = userWithdrawMapper.selectByPrimaryKey(transferResponse.getWithId());
+ if (ObjectUtils.isEmpty(userWithdraw)) {
+ log.info("未找到提现记录，withId：{}", transferResponse.getWithId());
+ pw.print("error 未找到提现记录");
+ pw.flush();
+ pw.close();
+ return;
+ }
+
+ // 根据订单状态处理
+ String orderStatus = vo.getOrderStatus();
+ if ("WAIT_CONFIRM".equals(orderStatus) || "WAIT_PAY".equals(orderStatus) || "PAY_ING".equals(orderStatus)) {
+ log.info("代付回调交易中，商户订单号：{}，状态：{}", vo.getMerchantOrderId(), orderStatus);
+ pw.print("success");
+ pw.flush();
+ pw.close();
+ return;
+ } else if ("PAY_FAIL".equals(orderStatus)) {
+ // 代付失败
+ transferResponse.setTradeResult(2); // 失败
+ transferResponse.setCallbackState(2); // 失败
+ transferResponse.setRespCode("FAIL"); // 响应状态：失败
+ transferResponse.setErrorMsg(vo.getMsg()); // 失败原因
+ transferResponse.setSignType("MD5"); // 签名方式
+ transferResponse.setSign(vo.getSign()); // 签名
+ transferResponse.setUpdatedAt(new Date());
+ transferResponseService.updateById(transferResponse);
+
+ userWithdraw.setWithStatus(2); // 失败
+ userWithdraw.setWithMsg("代付失败：" + vo.getMsg());
+ userWithdraw.setTransTime(new Date());
+ userWithdrawMapper.updateByPrimaryKeySelective(userWithdraw);
+
+ // 返还用户资金
+ UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId("IN", userWithdraw.getUserId());
+ if (userAssets != null) {
+ userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(userWithdraw.getWithAmt()));
+ userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(userWithdraw.getWithAmt()));
+ userAssetsMapper.updateById(userAssets);
+ }
+
+ log.info("代付回调失败，商户订单号：{}", vo.getMerchantOrderId());
+ pw.print("success");
+ pw.flush();
+ pw.close();
+ return;
+ } else if ("PAY_SUCCESS".equals(orderStatus)) {
+ // 代付成功
+ transferResponse.setTradeResult(1); // 成功
+ transferResponse.setCallbackState(1); // 成功
+ transferResponse.setRespCode("SUCCESS"); // 响应状态：成功
+ transferResponse.setSignType("MD5"); // 签名方式
+ transferResponse.setSign(vo.getSign()); // 签名
+ transferResponse.setUpdatedAt(new Date());
+ transferResponseService.updateById(transferResponse);
+
+ userWithdraw.setWithStatus(1); // 成功
+ userWithdraw.setWithMsg("代付成功");
+ userWithdraw.setTransTime(new Date());
+ userWithdrawMapper.updateByPrimaryKeySelective(userWithdraw);
+
+ // 扣除冻结资金
+ UserAssets userAssets = iUserAssetsServices.assetsByTypeAndUserId("IN", userWithdraw.getUserId());
+ if (userAssets != null) {
+ userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(userWithdraw.getWithAmt()));
+ userAssetsMapper.updateById(userAssets);
+ }
+
+ log.info("代付回调成功，商户订单号：{}", vo.getMerchantOrderId());
+ pw.print("success");
+ pw.flush();
+ pw.close();
+ return;
+ } else {
+ log.error("代付回调未知状态，商户订单号：{}，状态：{}", vo.getMerchantOrderId(), orderStatus);
+ pw.print("error 未知状态");
+ pw.flush();
+ pw.close();
+ return;
+ }
+
+ } catch (Exception e) {
+ log.error("代付回调处理异常：", e);
+ pw.print("error 处理异常");
+ pw.flush();
+ pw.close();
+ }
+ }
}
\ No newline at end of file
diff --git a/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java b/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java
index ded5e4a..b90e97d 100644
--- a/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java
+++ b/src/main/java/com/nq/service/impl/UserWithdrawServiceImpl.java
@@ -25,6 +25,7 @@
import java.time.LocalDate;
import java.time.LocalDateTime;
import java.time.format.DateTimeFormatter;
+import java.text.SimpleDateFormat;
import java.util.*;
import javax.annotation.Resource;
@@ -393,6 +394,8 @@
if (updateCount > 0) {
return ServerResponse.createBySuccessMsg("操作成功！");
}
+ }else if(state == 1){//走代付
+ return getObjectServerResponseOne(withId, request, response, userWithdraw, user, userAssets);
}else{
return ServerResponse.createByErrorMsg("请选择对应的操作！");
}
@@ -402,6 +405,8 @@
}
return ServerResponse.createBySuccessMsg("操作失败！");
}
+
+
public int deleteByUserId(Integer userId) {
return this.userWithdrawMapper.deleteByUserId(userId);
@@ -434,5 +439,119 @@
}
+
+ /**
+ * 代付接口调用
+ */
+ private ServerResponse getObjectServerResponseOne(Integer withId, HttpServletRequest request,
+ HttpServletResponse response, UserWithdraw userWithdraw,
+ User user, UserAssets userAssets) throws Exception {
+ try {
+ // 配置参数（建议放到配置文件中）
+ String appId = "db270b73dc384c89ae7241d6465cee03"; // 从商户后台获取
+ String key = "PAXkm5ptBhvzNYBSpdm3p7ipwGUQOF8Fm3tYp0"; // 商户密钥
+ String payoutUrl = "https://www.copays.net/open-api/create-payout-order"; // 代付接口地址
+
+ // 生成商户订单号
+ String merchantOrderId = generatePayoutOrderId(withId);
+
+ // 处理金额，保留两位小数
+ BigDecimal amount = userWithdraw.getWithAmt();
+ amount = amount.setScale(2, BigDecimal.ROUND_HALF_UP);
+
+ // 构建请求参数
+ Map<String, String> params = new HashMap<>();
+ params.put("app_id", appId);
+ params.put("merchant_order_id", merchantOrderId);
+ params.put("amount", amount.toString());
+ params.put("payout_mode", "INDIA_IMPS"); // 代付模式，根据实际情况选择
+ params.put("customer_account_type", userWithdraw.getBankAddress()); // 账号类型
+ params.put("customer_account_no", userWithdraw.getBankNo()); // 收款人账号（银行卡号或UPI ID）
+ params.put("notify_url", "https://api.durocaspitall.com/user/payoutCallback.do"); // 异步通知地址
+
+ // 生成签名
+ String sign = PaymentSignUtil.generateSign(params, key);
+ params.put("sign", sign);
+
+ log.info("代付请求参数：{}", params);
+ log.info("生成的签名：{}", sign);
+
+ // 发送请求
+ String result = HttpClientUtil.doPost(payoutUrl, params, "utf-8");
+ log.info("代付返回参数：{}", result);
+
+ // 解析响应
+ ObjectMapper objectMapper = new ObjectMapper();
+ PayoutOrderResponseVo payoutResponse = objectMapper.readValue(result, PayoutOrderResponseVo.class);
+
+ // 检查响应
+ if (!Integer.valueOf(200).equals(payoutResponse.getCode())) {
+ log.error("代付下单失败，返回码：{}，消息：{}，请求参数：{}",
+ payoutResponse.getCode(), payoutResponse.getMessage(), params);
+
+ // 代付失败，返还用户资金
+ userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(userWithdraw.getWithAmt()));
+ userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(userWithdraw.getWithAmt()));
+ userAssetsMapper.updateById(userAssets);
+
+ userWithdraw.setWithStatus(2); // 失败
+ userWithdraw.setWithMsg("代付下单失败：" + payoutResponse.getMessage());
+ userWithdraw.setTransTime(new Date());
+ userWithdrawMapper.updateByPrimaryKeySelective(userWithdraw);
+
+ return ServerResponse.createByErrorMsg("代付下单失败：" + payoutResponse.getMessage());
+ }
+
+ // 保存代付记录
+ PayoutOrderResponseVo.PayoutOrderData responseData = payoutResponse.getData();
+ TransferResponse transferResponse = new TransferResponse();
+ transferResponse.setMerTransferId(merchantOrderId); // 商户订单号
+ transferResponse.setTradeNo(responseData.getSystemOrderId()); // 系统订单号
+ transferResponse.setTransferAmount(amount);
+ transferResponse.setTradeResult(0); // 0:已下单
+ transferResponse.setCallbackState(0); // 0:未处理
+ transferResponse.setRespCode("SUCCESS"); // 响应状态：下单成功
+ transferResponse.setSignType("MD5"); // 签名方式
+ transferResponse.setSign(responseData.getSign()); // 签名
+ transferResponse.setApplyDate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())); // 订单时间
+ transferResponse.setUserId(user.getId());
+ transferResponse.setWithId(withId);
+ transferResponse.setCreatedAt(new Date());
+ transferResponse.setUpdatedAt(new Date());
+ transferResponseService.save(transferResponse);
+
+ // 更新提现记录状态为已提交（4）
+ userWithdraw.setWithStatus(4); // 已提交
+ userWithdraw.setTransTime(new Date());
+ userWithdrawMapper.updateByPrimaryKeySelective(userWithdraw);
+
+ log.info("代付下单成功，订单号：{}", merchantOrderId);
+ return ServerResponse.createBySuccessMsg("代付申请已提交，请等待处理");
+
+ } catch (Exception e) {
+ log.error("代付下单异常：", e);
+
+ // 异常时返还用户资金
+ userAssets.setAvailableBalance(userAssets.getAvailableBalance().add(userWithdraw.getWithAmt()));
+ userAssets.setFreezeMoney(userAssets.getFreezeMoney().subtract(userWithdraw.getWithAmt()));
+ userAssetsMapper.updateById(userAssets);
+
+ userWithdraw.setWithStatus(2); // 失败
+ userWithdraw.setWithMsg("代付下单异常：" + e.getMessage());
+ userWithdraw.setTransTime(new Date());
+ userWithdrawMapper.updateByPrimaryKeySelective(userWithdraw);
+
+ throw e;
+ }
+ }
+
+ /**
+ * 生成代付订单号
+ */
+ private String generatePayoutOrderId(Integer withId) {
+ // 使用提现ID + 时间戳生成唯一订单号
+ long timestamp = System.currentTimeMillis();
+ return "PAYOUT_" + withId + "_" + timestamp;
+ }
}
--
Gitblit v1.9.3