modify

Helius

2021-06-17 bc1350318fc28f23b22a07d2e41c5e00c504ddaa

 src/main/java/com/xcong/excoin/modules/blackchain/service/XrpService.java

@@ -24,7 +24,10 @@


public class XrpService {



   // private //logger //logger = //logger.get//logger(getClass());

   /**

    *  平台钱包地址

    */

   public final static String ACCOUNT="rKMGEyjXErL2dx9ck5QXFJVH8onSfHF5gn";

   /**

    * 官方接口地址

    */

@@ -32,65 +35,13 @@
   private String postUrl = "https://s1.ripple.com:51234";



   /**

    * 本地nodejs创建钱包地址

    * 结果类型

    */

   private static String localUrl = "http://121.40.86.163:1886";

   private String address;

   private String password;



   private static final String gasFee = "100";

   private static final String COIN_XRP = "XRP";



   private final static String RESULT = "result";

   private final static String SUCCESS = "success";

   private final static String TES_SUCCESS = "tesSUCCESS";



   private final static String METHOD_GET_TRANSACTION = "/v2/accounts/{0}/transactions";

   private final static String METHOD_GET_BALANCE = "/v2/accounts/{0}/balances";

   private final static String METHOD_POST_SIGN = "sign";

   private final static String METHOD_POST_INDEX = "ledger_current";

   private final static String METHOD_POST_ACCOUNT_INFO = "account_info";

   private final static String METHOD_POST_SUBMIT = "submit";



   public XrpService(String address, String password) {

      try {

         this.address = address;

         this.password = password;

      } catch (Exception e) {

         e.printStackTrace();

      }

   }



   public String getAddress() {

      return address;

   }



   public static void main(String[] args) {

      // 十分钟查一次 每次100条

        String result =  HttpUtil.get("https://data.ripple.com/v2/accounts/rBEXvZL66VvaMzX5R2W5g5xC9Z3D81wkzb/transactions?start=2019-09-01T10:10:00Z");

        JSONObject json = JSONObject.parseObject(result);

        XrpTransResult res = json.toJavaObject(XrpTransResult.class);

   }



   /**

    * 创建钱包 { "xAddress":"X7bpbHDKxS3Mr417RPtgS3TFFHwAHqULXJUVZntHWAKnccw",

    * "secret":"snYpXT4wrhi8ve2miSUHUdn9wgzz7",

    * "classicAddress":"rsJftGoh49zju51k2LdvUYrzLzJ44XJpXh",

    * "address":"rsJftGoh49zju51k2LdvUYrzLzJ44XJpXh" }

    * 
    * @return

    */

   public static JSONObject createWallet() {

      String res = HttpUtil.get(localUrl);

      JSONObject obj = JSONObject.parseObject(res);

      return obj;

   }



   /**

    * 查询交易记录 用于更新用户的余额 本系统的地址：X75MxY8sjcebBasymUXDYcYHWj6v8wqWLGmg9N3x65SXUJw

    * https://data.ripple.com/v2/accounts/rBEXvZL66VvaMzX5R2W5g5xC9Z3D81wkzb/transactions

    * https://data.ripple.com/v2/accounts/rBEXvZL66VvaMzX5R2W5g5xC9Z3D81wkzb/transactions?start=2019-09-01T10:10:00Z&limit=1

    */



   /**

    * start YYYY-MM-DDThh:mm:ssZ String - Timestamp Start time of query range. The default is the

@@ -109,379 +60,22 @@
    * returned response.

    * 

    * https://github.com/ripple/rippled-historical-database

    *  接口文档：https://xrpl.org/data-api.html#get-account

    */

   public static XrpTransResult getTransactions(Date start) {

        // SimpleDateFormat dateFormat = new SimpleDateFormat("YYYY-MM-DDThh:mm:ssZ");

       SimpleDateFormat formatDay = new SimpleDateFormat("YYYY-MM-dd");

       SimpleDateFormat formatHour = new SimpleDateFormat("hh:mm:ss");

         String startTime = formatDay.format(start)+"T"+formatHour.format(start)+"Z";

         String url ="https://data.ripple.com/v2/accounts/X75MxY8sjcebBasymUXDYcYHWj6v8wqWLGmg9N3x65SXUJw/transactions?start="+startTime+"&limit=1000"; 
         // 十分钟查一次 每次100条

         String result =  HttpUtil.get(url);

        try {

           JSONObject json = JSONObject.parseObject(result);

           XrpTransResult res = json.toJavaObject(XrpTransResult.class); 
           return res;

        }catch(Exception e) {

           e.printStackTrace();

        }

       return null;

   }



   /**

    * XRP查询余额

    * 
    * @return

    */

   public static double getBalance(String address) {

      SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss'Z'");

      String startTime = dateFormat.format(start);

      String url ="https://data.ripple.com/v2/accounts/"+ACCOUNT+"/transactions?type=Payment&result=tesSUCCESS&limit=100&start="+startTime;

      // 十分钟查一次 每次100条

      String result =  HttpUtil.get(url);

      try {

         HashMap<String, String> params = new HashMap<String, String>();

         params.put("currency", COIN_XRP);

         String re = HttpUtil.jsonGet(getUrl + MessageFormat.format(METHOD_GET_BALANCE, address), params);

         if (!StringUtils.isEmpty(re)) {

            JSONObject json = JSON.parseObject(re);

            if (SUCCESS.equals(json.getString(RESULT))) {

               JSONArray array = json.getJSONArray("balances");

               if (array != null && array.size() > 0) {

                  // 总余额

                  double balance = array.getJSONObject(0).getDoubleValue("value");

                  if (balance >= 20) {

                     // 可用余额 xrp会冻结20个币

                     return BigDecimalUtil.sub(balance, 20);

                  }

               }

            }

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币getBalance失败！");

         e.printStackTrace();

      }

      return 0.00;

   }



   /**

    * 发送交易

    * 
    * @param address

    * @param value

    * @return

    */

   public synchronized String send(String toAddress, double value, String tag) {

      try {

         String txBlob = this.sign(toAddress, value, tag);

         if (StringUtils.isEmpty(txBlob)) {

            // logger.error("签名失败:{" + toAddress + "}");

            return null;

         }

         HashMap<String, Object> params = new HashMap<String, Object>();

         params.put("tx_blob", txBlob);

         // 签名

         JSONObject json = doRequest(METHOD_POST_SUBMIT, params);

         if (!isError(json)) {

            // logger.error("============瑞波币XRP转账返回！json="+json);

            JSONObject result = json.getJSONObject(RESULT);

            if (result != null) {

               if (TES_SUCCESS.equals(result.getString("engine_result"))) {

                  String hash = result.getJSONObject("tx_json").getString("hash");

                  if (!StringUtils.isEmpty(hash)) {

                     // logger.error("转账成功：toAddress:{" + toAddress + "},value:{" + value +

                     // "},hash:{" + hash + "}");

                     return hash;

                  } else {

                     // logger.error(

                     // "转账失败：toAddress:{" + toAddress + "},value:{" + value + "},hash:{" + hash +

                     // "}");

                  }

               }

            }

         } else {

            // logger.error("============瑞波币XRP转账失败！json="+json);

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币send失败！");

         JSONObject json = JSONObject.parseObject(result);

         XrpTransResult res = json.toJavaObject(XrpTransResult.class);

         return res;

      }catch(Exception e) {

         e.printStackTrace();

      }

      return null;

   }



   public synchronized String sendOnLine(String toAddress, double value, String tag) {

      try {

         String txBlob = this.signOnLine(toAddress, value, tag);

         if (StringUtils.isEmpty(txBlob)) {

            // logger.error("签名失败:{" + toAddress + "}");

            return null;

         }

         HashMap<String, Object> params = new HashMap<String, Object>();

         params.put("tx_blob", txBlob);

         // 签名

         JSONObject json = doRequest(METHOD_POST_SUBMIT, params);

         if (!isError(json)) {

            // logger.error("============瑞波币XRP转账返回！json="+json);

            JSONObject result = json.getJSONObject(RESULT);

            if (result != null) {

               if (TES_SUCCESS.equals(result.getString("engine_result"))) {

                  String hash = result.getJSONObject("tx_json").getString("hash");

                  if (!StringUtils.isEmpty(hash)) {

                     // logger.error("转账成功：toAddress:{" + toAddress + "},value:{" + value +

                     // "},hash:{" + hash + "}");

                     return hash;

                  } else {

                     // logger.error(

                     // "转账失败：toAddress:{" + toAddress + "},value:{" + value + "},hash:{" + hash +

                     // "}");

                  }

               }

            }

         } else {

            // logger.error("==============瑞波币XRP转账失败！json="+json);

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币send失败！");

         e.printStackTrace();

      }

      return null;

   }



   @Deprecated

   public String signOnLine(String toAddress, Double value, String tag) {

      try {

         // 瑞波币余额存储加六位长度

         value = BigDecimalUtil.mul(value, 1000000);

         Integer vInteger = BigDecimal.valueOf(value).intValue();

         JSONObject txJson = new JSONObject();

         txJson.put("Account", address);

         txJson.put("Amount", vInteger.toString());

         txJson.put("Destination", toAddress);// 标签

         txJson.put("TransactionType", "Payment");

         txJson.put("DestinationTag", tag);

         HashMap<String, Object> params = new HashMap<String, Object>();

         params.put("secret", password);

         params.put("tx_json", txJson);

         params.put("offline", false);

         // 签名

         JSONObject json = doRequest(METHOD_POST_SIGN, params);

         if (!isError(json)) {

            // logger.error("==============XRP签名返回："+json);

            JSONObject result = json.getJSONObject(RESULT);

            if (result != null) {

               if (SUCCESS.equals(result.getString("status"))) {

                  return result.getString("tx_blob");

               }

            }

         } else {

            // logger.error("瑞波币XRP签名失败！json="+json);

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币signOnLine失败！");

         e.printStackTrace();

      }

      return null;

   }



   /**

    * 签名

    * 
    * @param address

    * @param value

    * @return tx_blob

    */

   public String sign(String toAddress, Double value, String tag) {

      try {

         value = BigDecimalUtil.mul(value, 1000000);

         Integer vInteger = BigDecimal.valueOf(value).intValue();

         Map<String, String> map = getAccountSequenceAndLedgerCurrentIndex();

         Payment payment = new Payment();

         payment.as(AccountID.Account, address);

         payment.as(AccountID.Destination, toAddress);

         payment.as(UInt32.DestinationTag, tag);

         payment.as(Amount.Amount, vInteger.toString());

         payment.as(UInt32.Sequence, map.get("accountSequence"));

         payment.as(UInt32.LastLedgerSequence, map.get("ledgerCurrentIndex") + 4);

         payment.as(Amount.Fee, gasFee);

         SignedTransaction signed = payment.sign(password);

         if (signed != null) {

            return signed.tx_blob;

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币sign失败！");

         e.printStackTrace();

      }

      return null;

   }



   public Map<String, String> getAccountSequenceAndLedgerCurrentIndex() {

      try {

         HashMap<String, String> params = new HashMap<String, String>();

         params.put("account", address);

         params.put("strict", "true");

         params.put("ledger_index", "current");

         params.put("queue", "true");

         JSONObject re = doRequest(METHOD_POST_ACCOUNT_INFO, params);

         if (re != null) {

            JSONObject result = re.getJSONObject("result");

            if (SUCCESS.equals(result.getString("status"))) {

               Map<String, String> map = new HashMap<String, String>();

               map.put("accountSequence", result.getJSONObject("account_data").getString("Sequence"));

               map.put("ledgerCurrentIndex", result.getString("ledger_current_index"));

               return map;

            }

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币getAccountSequenceAndLedgerCurrentIndex失败！");

         e.printStackTrace();

      }

      return null;

   }



   /**

    * 获取用户交易序列号

    * 
    * @return

    */

   public long getAccountSequence() {

      try {

         HashMap<String, String> params = new HashMap<String, String>();

         params.put("account", address);

         params.put("strict", "true");

         params.put("ledger_index", "current");

         params.put("queue", "true");

         JSONObject re = doRequest(METHOD_POST_ACCOUNT_INFO, params);

         if (re != null) {

            JSONObject result = re.getJSONObject("result");

            if (SUCCESS.equals(result.getString("status"))) {

               return result.getJSONObject("account_data").getLongValue("Sequence");

            }

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币getAccountSequence失败！");

         e.printStackTrace();

      }

      return 0L;

   }



   /**

    * 获取最新序列

    * 
    * @return

    */

   public long getLedgerIndex() {

      try {

         JSONObject re = doRequest(METHOD_POST_INDEX);

         if (re != null) {

            JSONObject result = re.getJSONObject("result");

            if (SUCCESS.equals(result.getString("status"))) {

               return result.getLongValue("ledger_current_index");

            }

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币getLedgerIndex失败！");

         e.printStackTrace();

      }

      return 0L;

   }



   public String getTransaction(Date dateGMT, String limit) throws ParseException {

      try {

         HashMap<String, String> params = new HashMap<String, String>();

         params.put("start", DateUtil.formatDate(dateGMT, "yyyy-MM-dd'T'HH:mm:ss"));

         params.put("result", "tesSUCCESS");

         params.put("type", "Payment");

         params.put("limit", limit);

         return HttpUtil.jsonGet(getUrl + MessageFormat.format(METHOD_GET_TRANSACTION, address), params);

         // {"result":"success","count":1,"transactions":[{"hash":"86859CBEFB870C941727E291BB13312BC3D6042D8DA08BF1DEDE6BB55F21B8EC","ledger_index":42268358,"date":"2018-10-16T06:49:30+00:00","tx":{"TransactionType":"Payment","Flags":2147483648,"Sequence":37996,"Amount":"29840000","Fee":"1000","SigningPubKey":"0279154FA62D1F28B6CB1F0264663F19EF3A1718D15363CAC1B47A9C6987231F94","TxnSignature":"304502210089F6526134F335C01C65D3E82284C06E22598A4EAD912604BF4FEAA42D5ACCE402203C044F32D399CEA6F4A16DD6DCBB339A7D0CF76E52C1AB090330A67EDFBABBE4","Account":"rH8yTBLm2SYgcL5HQGDznuNxMiy5ayYcmK","Destination":"raHb1tR1BcNB92nEqxiTuKsDap46szkJG2"},"meta":{"TransactionIndex":1,"AffectedNodes":[{"CreatedNode":{"LedgerEntryType":"AccountRoot","LedgerIndex":"56419B3209DA988033F6F0BD921806B4821A73EDF8C338FB5F06C785E527E967","NewFields":{"Sequence":1,"Balance":"29840000","Account":"raHb1tR1BcNB92nEqxiTuKsDap46szkJG2"}}},{"ModifiedNode":{"LedgerEntryType":"AccountRoot","PreviousTxnLgrSeq":42268355,"PreviousTxnID":"63D5A3121F2706099835D9A3A9E5DA574070A4E08FC70956DB1CC196DE6CDEFC","LedgerIndex":"7D2FC14FA2B344F41BB8A6E10B319301EA1C11705AE159B3E2FA82D9F3079E4C","PreviousFields":{"Sequence":37996,"Balance":"2051629511468"},"FinalFields":{"Flags":131072,"Sequence":37997,"OwnerCount":0,"Balance":"2051599670468","Account":"rH8yTBLm2SYgcL5HQGDznuNxMiy5ayYcmK"}}}],"TransactionResult":"tesSUCCESS","delivered_amount":"29840000"}}]}

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币getBalance失败！");

         e.printStackTrace();

      }

      return null;

   }



   public Long parseTransaction(String startTm) throws ParseException {

      try {

         HashMap<String, String> params = new HashMap<String, String>();

         if (!StringUtils.isEmpty(startTm)) {

            Date d = new Date(BigDecimalUtil.longAdd(Long.parseLong(startTm), 1000L));

            params.put("start", DateUtil.formatDate(d, "yyyy-MM-dd'T'HH:mm:ss"));

         }

         params.put("result", "tesSUCCESS");

         params.put("type", "Payment");

         params.put("limit", "1");

         String re = HttpUtil.jsonGet(getUrl + MessageFormat.format(METHOD_GET_TRANSACTION, address), params);

         if (!StringUtils.isEmpty(re)) {

            JSONObject json = JSON.parseObject(re);

            if (SUCCESS.equals(json.getString(RESULT))) {

               // marker = json.getString("marker");

               JSONArray transactions = json.getJSONArray("transactions");

               if (transactions != null && transactions.size() > 0) {

                  for (Object object : transactions) {

                     JSONObject transaction = (JSONObject) object;

                     String hash = transaction.getString("hash");

                     String dateString = transaction.getString("date");

                     Date date = DateUtil.parseDate(dateString, "yyyy-MM-dd'T'HH:mm:ss");

                     JSONObject tx = transaction.getJSONObject("tx");

                     String destinationTag = tx.getString("DestinationTag");

                     if (StringUtils.isEmpty(destinationTag)) {

                        // logger.info("非用户充值记录");

                        return date.getTime();

                     }

                     String to = tx.getString("Destination");

                     if (!address.equals(to)) {

                        // logger.info("非用户充值记录,地址不一致");

                        return date.getTime();

                     }

                     // 校验用户是否存在

                     /*

                      * UserEntity user = userService.getUserById(Integer.parseInt( destinationTag));

                      * if (user == null) { //logger.info("用户不存在：{}",destinationTag); return

                      * date.getTime(); }

                      */

                     double amount = tx.getDoubleValue("Amount");

                     if (amount > 0) {

                        amount = BigDecimalUtil.div(amount, 1000000, 6);

                     } else {

                        // logger.error("交易金额异常：{" + amount + "}");

                        return date.getTime();

                     }

                     // 添加充值记录

                  }

               }

            }

         }

      } catch (Exception e) {

         // logger.error("==============虚拟币-瑞波币parseTransaction失败！");

         e.printStackTrace();

      }

      return null;

   }



   private boolean isError(JSONObject json) {

      if (json == null || (!StringUtils.isEmpty(json.getString("error")) && json.get("error") != "null")) {

         return true;

      }

      return false;

   }



   private JSONObject doRequest(String method, Object... params) {

      JSONObject param = new JSONObject();

      param.put("id", System.currentTimeMillis() + "");

      param.put("jsonrpc", "2.0");

      param.put("method", method);

      if (params != null) {

         param.put("params", params);

      }

      String creb = Base64.encodeBase64String((address + ":" + password).getBytes());

      Map<String, String> headers = new HashMap<>(2);

      headers.put("Authorization", "Basic " + creb);

      String resp = "";

      try {

         resp = HttpUtil.jsonPost(postUrl, headers, param.toJSONString());

      } catch (Exception e) {

         // logger.info(e.getMessage());

         if (e instanceof IOException) {

            resp = "{}";

         }

      }

      return JSON.parseObject(resp);

   }



}