From 6cdfe1d568d06bc63bb513ce0ef1df6aac3c7c3d Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Sat, 20 Feb 2021 15:32:12 +0800
Subject: [PATCH] fix
---
src/main/java/com/xcong/excoin/modules/blackchain/service/XrpService.java | 436 +----------------------------------------------------
1 files changed, 15 insertions(+), 421 deletions(-)
diff --git a/src/main/java/com/xcong/excoin/modules/blackchain/service/XrpService.java b/src/main/java/com/xcong/excoin/modules/blackchain/service/XrpService.java
index 397ce7d..781eee7 100644
--- a/src/main/java/com/xcong/excoin/modules/blackchain/service/XrpService.java
+++ b/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);
}
}
--
Gitblit v1.9.1