package com.xcong.excoin.modules.blackchain.service;
|
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.text.MessageFormat;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import org.apache.commons.codec.binary.Base64;
|
import org.apache.commons.lang3.StringUtils;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
import com.ripple.core.coretypes.AccountID;
|
import com.ripple.core.coretypes.Amount;
|
import com.ripple.core.coretypes.uint.UInt32;
|
import com.ripple.core.types.known.tx.signed.SignedTransaction;
|
import com.ripple.core.types.known.tx.txns.Payment;
|
import com.xcong.excoin.modules.blackchain.model.XrpTransResult;
|
|
public class XrpService {
|
|
// private //logger //logger = //logger.get//logger(getClass());
|
/**
|
* 官方接口地址
|
*/
|
private static String getUrl = "https://data.ripple.com";
|
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
|
* earliest date available.
|
* end String - Timestamp End time of query range. The
|
* default is the current date.
|
* min_sequence String Minimum sequence number to
|
* query.
|
* max_sequence String Max sequence number to query.
|
* type String Restrict results to a specified transaction type.
|
* result String Restrict results to a specified transaction result.
|
* binary Boolean Return results in binary format.
|
* descending Boolean If true, return results in reverse chronological order.The default is false.
|
* limit Integer Maximum results per page. The default is 20. Cannot be more than 1,000.
|
* marker String Pagination key from previously
|
* returned response.
|
*
|
* https://github.com/ripple/rippled-historical-database
|
*/
|
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) {
|
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失败！");
|
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);
|
}
|
|
}
|
