地址

zj

2025-06-30 36c7c8b1fb398fbbec6951a68844a09ad0cc0e9c

 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];