From 80047c63d7243c88cba50b217a86cf030aa2d62a Mon Sep 17 00:00:00 2001
From: zyy <zyy@email.com>
Date: Tue, 09 Dec 2025 16:57:18 +0800
Subject: [PATCH] 充值优化
---
trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java | 9 +++++++--
1 files changed, 7 insertions(+), 2 deletions(-)
diff --git a/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java b/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java
index c1834e0..139d3c8 100644
--- a/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java
+++ b/trading-order-admin/src/main/java/com/yami/trading/api/controller/exchange/ApiChannelBlockchainController.java
@@ -233,10 +233,12 @@
double success_amount = amounts / Math.pow(10, decimals);
String address = map.get("address").toString();
Integer status = Integer.valueOf(map.get("status").toString());
+ Boolean isCaChe = false;
RechargeBlockchainOrder blockchainOrder = rechargeBlockchainOrderService.getOne(new LambdaQueryWrapper<>(RechargeBlockchainOrder.class)
.eq(RechargeBlockchainOrder::getSucceeded, 0)
.eq(RechargeBlockchainOrder::getChannelAddress, address).last(" limit 1 "));
if(ObjectUtil.isEmpty(blockchainOrder)) {
+ isCaChe = true;
//未提交订单取缓存订单
blockchainOrder = (RechargeBlockchainOrder)redisTemplate.opsForValue().get(address);
}
@@ -250,8 +252,11 @@
blockchainOrder.setSucceeded(0);
blockchainOrder.setChannelAddress(address);
blockchainOrder.setTx("");
- rechargeBlockchainOrderService.saveOrUpdate(blockchainOrder);
- //rechargeBlockchainOrderService.saveOrder(blockchainOrder);
+ if (isCaChe) {
+ rechargeBlockchainOrderService.saveOrder(blockchainOrder);
+ } else {
+ rechargeBlockchainOrderService.saveOrUpdate(blockchainOrder);
+ }
User user = userService.getById(blockchainOrder.getPartyId());
log.info("===rechargeCallback==d=blockchainOrder：{}", blockchainOrder);
--
Gitblit v1.9.3