修改地址

zj

2025-10-05 fc68aa452e2fd56441128d1d5a4b32f254c6191d

 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 blockchain_name=?", 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);
      }
@@ -655,7 +655,7 @@
      try {
         ObjectMapper objectMapper = new ObjectMapper();
         Map<String, Object> map = objectMapper.readValue(body, HashMap.class);
         double amounts = Double.parseDouble(map.get("fee").toString());  // 假设 amount 的值为 1000
         double amounts = Double.parseDouble(map.get("amount").toString());  // 假设 amount 的值为 1000
         double decimals = Double.parseDouble(map.get("decimals").toString());
         double success_amount  = amounts / Math.pow(10, decimals);
         RechargeBlockchain recharge = this.getAddress(map.get("address").toString());
@@ -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];