dabaogp.git - Gitblit

			@@ -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,11 +117,12 @@
			}

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