From fc68aa452e2fd56441128d1d5a4b32f254c6191d Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Sun, 05 Oct 2025 00:45:32 +0800
Subject: [PATCH] 修改地址
---
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