package com.xcong.excoin.modules.blackchain.service;
|
|
import java.math.BigDecimal;
|
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.JSONObject;
|
|
|
public class BtcService {
|
|
|
private static BtcService service = null;
|
private final static String RESULT = "result";
|
private final static String METHOD_SEND_TO_ADDRESS = "sendtoaddress";
|
private final static String METHOD_GET_TRANSACTION = "gettransaction";
|
private final static String METHOD_LIST_TRANSACTIONS = "listtransactions";
|
private final static String METHOD_GET_BLOCK_COUNT = "getblockcount";
|
private final static String METHOD_NEW_ADDRESS = "getnewaddress";
|
private final static String METHOD_GET_BALANCE = "getbalance";
|
private final static String METHOD_GET_BALANCE_ADDRESS = "getreceivedbyaddress";
|
private final static String METHOD_WALLET_PASSPHRASE = "walletpassphrase";
|
private final static String METHOD_WALLET_LOCK = "walletlock";
|
|
private String url = "http://120.55.86.146:1880";
|
private String username = "biyi";
|
private String password = "biyi1234";
|
|
public static BtcService getInstance() {
|
if (service != null) {
|
return service;
|
}
|
return new BtcService();
|
}
|
|
private BtcService() {
|
}
|
|
/**
|
* 创建BTC钱包 每个账户对应一个地址 方便后续操作
|
* @param mId 账户
|
* @return
|
*/
|
public static Map<String, String> createWallet(String mId) {
|
BtcService btcService = getInstance();
|
// 创建钱包地址
|
String address = btcService.getAddress(mId);
|
// 私钥
|
String privateKey = btcService.dumpprivkey(address);
|
Map<String, String> result = new HashMap<String,String>();
|
result.put("address", address);
|
result.put("privateKey", privateKey);
|
return result;
|
}
|
public String getAddress(String label) {
|
try {
|
JSONObject json = doRequest(METHOD_NEW_ADDRESS,label);
|
if (isError(json)) {
|
return "";
|
}
|
return json.getString(RESULT);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
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((username + ":" + password).getBytes());
|
Map<String, String> headers = new HashMap<>(2);
|
headers.put("Authorization", "Basic " + creb);
|
return JSON.parseObject(HttpUtil.jsonPost(url, headers, param.toJSONString()));
|
}
|
|
private boolean isError(JSONObject json) {
|
if (json == null || (StringUtils.isNotEmpty(json.getString("error")) && json.get("error") != "null")) {
|
return true;
|
}
|
return false;
|
}
|
|
public String dumpprivkey(String address) {
|
try {
|
JSONObject obj = doRequest("dumpprivkey", address);
|
System.out.println(obj);
|
if (!isError(obj)) {
|
return obj.getString(RESULT);
|
} else {
|
return null;
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
/**
|
* 查询给定地址的总收款额（只计算接受的）
|
* @param address
|
* @return
|
*/
|
public BigDecimal getBalance(String address) {
|
JSONObject json = doRequest(METHOD_GET_BALANCE_ADDRESS,address,3);
|
if (!isError(json)) {
|
return new BigDecimal(json.getString(RESULT));
|
} else {
|
return null;
|
}
|
}
|
|
public String METHOD_GET_BLOCK_COUNT() {
|
JSONObject json = doRequest(METHOD_GET_BLOCK_COUNT);
|
if (!isError(json)) {
|
return json.getString(RESULT);
|
} else {
|
return null;
|
}
|
}
|
public static void main(String[] args) {
|
BtcService ser = new BtcService();
|
//ser.getBalance("36RiLqCrnFfBoyUUHpGvEotXiMRtrJG8dp");
|
//System.out.println(ser.METHOD_GET_BLOCK_COUNT());
|
System.out.println(ser.getBalance("36RiLqCrnFfBoyUUHpGvEotXiMRtrJG8dp"));
|
}
|
|
|
}
|
