From 36c7c8b1fb398fbbec6951a68844a09ad0cc0e9c Mon Sep 17 00:00:00 2001
From: zj <1772600164@qq.com>
Date: Mon, 30 Jun 2025 23:58:55 +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