From 8d9197af3ec0b06565aa44aae631f0f8a661897b Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Thu, 10 Jul 2025 19:27:26 +0800
Subject: [PATCH] 1
---
src/main/java/project/blockchain/internal/RechargeBlockchainServiceImpl.java | 13 ++++++++++++-
1 files changed, 12 insertions(+), 1 deletions(-)
diff --git a/src/main/java/project/blockchain/internal/RechargeBlockchainServiceImpl.java b/src/main/java/project/blockchain/internal/RechargeBlockchainServiceImpl.java
index 02a1eb1..66524fd 100644
--- a/src/main/java/project/blockchain/internal/RechargeBlockchainServiceImpl.java
+++ b/src/main/java/project/blockchain/internal/RechargeBlockchainServiceImpl.java
@@ -379,7 +379,7 @@
* 根据区块地址获取充值订单
*/
public RechargeBlockchain getAddress(String address) {
- List<RechargeBlockchain> list = jdbcTemplate.query("SELECT * FROM T_RECHARGE_BLOCKCHAIN_ORDER WHERE CHANNEL_ADDRESS=?", RecordObjectMapper.newInstance(RechargeBlockchain.class), address);
+ List<RechargeBlockchain> list = jdbcTemplate.query("SELECT * FROM T_RECHARGE_BLOCKCHAIN_ORDER WHERE succeeded = 0 and CHANNEL_ADDRESS=?", RecordObjectMapper.newInstance(RechargeBlockchain.class), address);
if (null != list && list.size() > 0) {
return list.get(0);
}
@@ -849,6 +849,17 @@
}
}
+ @Override
+ public List<RechargeBlockchain> getByAddressUndone(String channelAddress) {
+ return getUndone(channelAddress);
+ }
+ public List<RechargeBlockchain> getUndone(String channelAddress){
+ List<RechargeBlockchain> list = jdbcTemplate.query("SELECT * FROM T_RECHARGE_BLOCKCHAIN_ORDER WHERE succeeded = 0 and CHANNEL_ADDRESS=?", RecordObjectMapper.newInstance(RechargeBlockchain.class), channelAddress);
+ return list;
+ }
+
+
+
public void insertRechargeBlockchain(RechargeBlockchain rechargeBlockchain) {
Object[] jdbcParams = ApplicationUtil.getInsertStatement(rechargeBlockchain);
String insertUserSql = (String)jdbcParams[0];
--
Gitblit v1.9.3