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); } } 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); } } 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); 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; } 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(); } } } 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; } }
