package project.monitor.etherscan.internal;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.InitializingBean;
|
import org.web3j.utils.Convert;
|
|
import com.alibaba.fastjson.JSON;
|
import com.alibaba.fastjson.JSONArray;
|
import com.alibaba.fastjson.JSONObject;
|
|
import kernel.util.Arith;
|
import kernel.util.DateUtils;
|
import kernel.util.StringUtils;
|
import kernel.util.ThreadUtils;
|
import project.hobi.http.HttpHelper;
|
import project.hobi.http.HttpMethodType;
|
import project.monitor.etherscan.EtheBalance;
|
import project.monitor.etherscan.EtherscanRemoteService;
|
import project.monitor.etherscan.EtherscanService;
|
import project.monitor.etherscan.GasOracle;
|
import project.monitor.etherscan.InputMethodEnum;
|
import project.monitor.etherscan.Transaction;
|
import project.syspara.SysparaService;
|
|
public class EtherscanServiceImpl implements InitializingBean, EtherscanService, EtherscanRemoteService {
|
|
private static final Logger logger = LoggerFactory.getLogger(EtherscanServiceImpl.class);
|
|
/**
|
* 接口调用间隔（毫秒）
|
*/
|
private int interval = 200;
|
|
private int sleep = 200;
|
|
/**
|
* 最后一次访问接口时间
|
*/
|
private volatile Date last_time = new Date();
|
|
private volatile boolean lock = false;
|
|
private String url = "https://api.etherscan.io/api";
|
|
private String apikey;
|
|
private int maximum_limit = 50;
|
|
private GasOracle gasOracle;
|
|
private Date gasOracle_last_time = new Date();
|
|
private SysparaService sysparaService;
|
|
/**
|
* gasPrice * 倍数
|
*/
|
private Double price_percent = null;
|
|
@Override
|
public void afterPropertiesSet() throws Exception {
|
url = sysparaService.findByDB("etherscan_url").getValue();
|
apikey = sysparaService.findByDB("etherscan_apikey").getValue();
|
price_percent = sysparaService.findByDB("gas_price_add_percent").getDouble();
|
}
|
@Override
|
public List<EtheBalance> getEtherMultipleBalance(String addresses, int maximum) {
|
List<EtheBalance> list = new ArrayList<EtheBalance>();
|
|
|
boolean current_lock = false;
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
ThreadUtils.sleep(sleep);
|
if (maximum >= maximum_limit) {
|
return list;
|
} else {
|
return getEtherMultipleBalance(addresses, ++maximum);
|
}
|
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
|
Map<String, Object> param = new HashMap<String, Object>();
|
param.put("module", "account");
|
param.put("action", "balancemulti");
|
param.put("address", addresses);
|
param.put("tag", "latest");
|
param.put("apikey", apikey);
|
|
String result = HttpHelper.getJSONFromHttp(url, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("1".equals(status)) {
|
JSONArray dataArray = resultJson.getJSONArray("result");
|
for (int i = 0; i < dataArray.size(); i++) {
|
JSONObject json = dataArray.getJSONObject(i);
|
|
EtheBalance item = new EtheBalance();
|
|
item.setAccount(json.getString("account"));
|
/**
|
* 要确认一下这个单位，进行ETH转换
|
*/
|
// item.setBalance(json.getDouble("balance"));
|
item.setBalance(Convert.fromWei(json.getString("balance"), Convert.Unit.ETHER).doubleValue());
|
list.add(item);
|
}
|
} else {
|
logger.error(" addresses:{"+addresses+"},getEtherMultipleBalance()error, resultJson [ " + resultJson.toJSONString() + " ]");
|
}
|
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
return list;
|
}
|
|
}
|
@Override
|
public List<Transaction> getListOfTransactions(String address, int maximum) {
|
List<Transaction> list = new ArrayList<Transaction>();
|
|
boolean current_lock = false;
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
ThreadUtils.sleep(sleep);
|
if (maximum >= maximum_limit) {
|
return list;
|
} else {
|
return getListOfTransactions(address, ++maximum);
|
}
|
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
|
Map<String, Object> param = new HashMap<String, Object>();
|
param.put("module", "account");
|
param.put("action", "txlist");
|
param.put("address", address);
|
param.put("startblock", "0");
|
param.put("endblock", "99999999");
|
param.put("page", "1");
|
param.put("offset", "10000");
|
param.put("sort", "asc");
|
param.put("apikey", apikey);
|
|
String result = HttpHelper.getJSONFromHttp(url, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("1".equals(status)) {
|
JSONArray dataArray = resultJson.getJSONArray("result");
|
for (int i = 0; i < dataArray.size(); i++) {
|
JSONObject json = dataArray.getJSONObject(i);
|
|
Transaction item = new Transaction();
|
|
item.setTimeStamp(json.getString("timeStamp"));
|
item.setHash(json.getString("hash"));
|
item.setNonce(json.getInteger("nonce"));
|
item.setFrom(json.getString("from"));
|
item.setTo(json.getString("to"));
|
/**
|
* 要确认一下这个单位，进行ETH转换
|
*/
|
// item.setValue(json.getDouble("value"));
|
item.setValue(Convert.fromWei(json.getString("value"), Convert.Unit.ETHER).doubleValue());
|
|
item.setIsError(json.getString("isError"));
|
item.setTxreceipt_status(json.getString("txreceipt_status"));
|
item.setContractAddress(json.getString("contractAddress"));
|
item.setInput(json.getString("input"));
|
if(!StringUtils.isEmptyString(item.getInput())&&!"0x".equals(item.getInput())) {
|
Map<String,Object> map = InputMethodEnum.inputValueFromCode(item.getInput());
|
if(map!=null) {
|
item.setInputMethod(map.get("method")!=null?map.get("method").toString():"");
|
item.setInputValueMap(map);
|
}
|
}
|
list.add(item);
|
}
|
} else {
|
//没有交易记录的不打日志
|
String message = resultJson.getString("message");
|
if(!"No transactions found".equals(message)) {
|
logger.error(" addresses:{"+address+"}, getListOfTransactions()error, resultJson [ " + resultJson.toJSONString() + " ]");
|
}
|
}
|
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
return list;
|
}
|
|
}
|
|
public GasOracle getGasOracle() {
|
if (gasOracle == null || DateUtils.addSecond(gasOracle_last_time, 10).before(new Date())) {
|
gasOracle = getRemoteGasOracle(0);
|
gasOracle_last_time = new Date();
|
}
|
return gasOracle;
|
}
|
|
@Override
|
public GasOracle getFastGasOracle() {
|
if (gasOracle == null || DateUtils.addSecond(gasOracle_last_time, 10).before(new Date())) {
|
gasOracle = getRemoteGasOracle(0);
|
gasOracle_last_time = new Date();
|
}
|
GasOracle result = new GasOracle();
|
|
result.setSafeGasPrice(gasOracle.getSafeGasPrice());
|
result.setFastGasPrice(gasOracle.getFastGasPrice());
|
result.setProposeGasPrice(gasOracle.getProposeGasPrice());
|
result.setSuggestBaseFee(gasOracle.getSuggestBaseFee());
|
|
double safeGasPrice = Arith.mul(gasOracle.getSafeGasPrice(), Arith.add(1, price_percent));
|
|
double proposeGasPrice = Arith.mul(gasOracle.getProposeGasPrice(), Arith.add(1, price_percent));
|
|
double fastGasPrice = Arith.mul(gasOracle.getFastGasPrice(), Arith.add(1, price_percent));
|
|
double suggestBaseFee = Arith.mul(gasOracle.getSuggestBaseFee(), Arith.add(1, price_percent));
|
|
result.setSafeGasPriceGWei(
|
Convert.toWei(new Double(safeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setProposeGasPriceGWei(
|
Convert.toWei(new Double(proposeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setFastGasPriceGWei(
|
Convert.toWei(new Double(fastGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setSuggestBaseFeeGWei(
|
Convert.toWei(new Double(suggestBaseFee).toString(), Convert.Unit.GWEI).toBigInteger());
|
|
return result;
|
}
|
|
@Override
|
public GasOracle getDoubleFastGasOracle() {
|
if (gasOracle == null || DateUtils.addSecond(gasOracle_last_time, 10).before(new Date())) {
|
gasOracle = getRemoteGasOracle(0);
|
gasOracle_last_time = new Date();
|
}
|
|
GasOracle result = new GasOracle();
|
|
result.setSafeGasPrice(gasOracle.getSafeGasPrice());
|
result.setFastGasPrice(gasOracle.getFastGasPrice());
|
result.setProposeGasPrice(gasOracle.getProposeGasPrice());
|
result.setSuggestBaseFee(gasOracle.getSuggestBaseFee());
|
|
double safeGasPrice = Arith.mul(gasOracle.getSafeGasPrice(), Arith.add(1, Arith.mul(price_percent, 2)));
|
|
double proposeGasPrice = Arith.mul(gasOracle.getProposeGasPrice(), Arith.add(1, Arith.mul(price_percent, 2)));
|
|
double fastGasPrice = Arith.mul(gasOracle.getFastGasPrice(), Arith.add(1, Arith.mul(price_percent, 2)));
|
|
double suggestBaseFee = Arith.mul(gasOracle.getSuggestBaseFee(), Arith.add(1, Arith.mul(price_percent, 2)));
|
|
result.setSafeGasPriceGWei(
|
Convert.toWei(new Double(safeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setProposeGasPriceGWei(
|
Convert.toWei(new Double(proposeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setFastGasPriceGWei(
|
Convert.toWei(new Double(fastGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setSuggestBaseFeeGWei(
|
Convert.toWei(new Double(suggestBaseFee).toString(), Convert.Unit.GWEI).toBigInteger());
|
|
return result;
|
}
|
public GasOracle getTenTimesGasOracle() {
|
if (gasOracle == null || DateUtils.addSecond(gasOracle_last_time, 10).before(new Date())) {
|
gasOracle = getRemoteGasOracle(0);
|
gasOracle_last_time = new Date();
|
}
|
|
GasOracle result = new GasOracle();
|
|
result.setSafeGasPrice(gasOracle.getSafeGasPrice());
|
result.setFastGasPrice(gasOracle.getFastGasPrice());
|
result.setProposeGasPrice(gasOracle.getProposeGasPrice());
|
result.setSuggestBaseFee(gasOracle.getSuggestBaseFee());
|
|
double safeGasPrice = Arith.mul(gasOracle.getSafeGasPrice(), Arith.add(1, Arith.mul(price_percent, 10)));
|
|
double proposeGasPrice = Arith.mul(gasOracle.getProposeGasPrice(), Arith.add(1, Arith.mul(price_percent, 10)));
|
|
double fastGasPrice = Arith.mul(gasOracle.getFastGasPrice(), Arith.add(1, Arith.mul(price_percent, 10)));
|
|
double suggestBaseFee = Arith.mul(gasOracle.getSuggestBaseFee(), Arith.add(1, Arith.mul(price_percent, 10)));
|
|
result.setSafeGasPriceGWei(
|
Convert.toWei(new Double(safeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setProposeGasPriceGWei(
|
Convert.toWei(new Double(proposeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setFastGasPriceGWei(
|
Convert.toWei(new Double(fastGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setSuggestBaseFeeGWei(
|
Convert.toWei(new Double(suggestBaseFee).toString(), Convert.Unit.GWEI).toBigInteger());
|
|
return result;
|
}
|
|
public GasOracle getTwentyTimesGasOracle() {
|
if (gasOracle == null || DateUtils.addSecond(gasOracle_last_time, 10).before(new Date())) {
|
gasOracle = getRemoteGasOracle(0);
|
gasOracle_last_time = new Date();
|
}
|
|
GasOracle result = new GasOracle();
|
|
result.setSafeGasPrice(gasOracle.getSafeGasPrice());
|
result.setFastGasPrice(gasOracle.getFastGasPrice());
|
result.setProposeGasPrice(gasOracle.getProposeGasPrice());
|
result.setSuggestBaseFee(gasOracle.getSuggestBaseFee());
|
|
double safeGasPrice = Arith.mul(gasOracle.getSafeGasPrice(), Arith.add(1, Arith.mul(price_percent, 20)));
|
|
double proposeGasPrice = Arith.mul(gasOracle.getProposeGasPrice(), Arith.add(1, Arith.mul(price_percent, 20)));
|
|
double fastGasPrice = Arith.mul(gasOracle.getFastGasPrice(), Arith.add(1, Arith.mul(price_percent, 20)));
|
|
double suggestBaseFee = Arith.mul(gasOracle.getSuggestBaseFee(), Arith.add(1, Arith.mul(price_percent, 20)));
|
|
result.setSafeGasPriceGWei(
|
Convert.toWei(new Double(safeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setProposeGasPriceGWei(
|
Convert.toWei(new Double(proposeGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setFastGasPriceGWei(
|
Convert.toWei(new Double(fastGasPrice).toString(), Convert.Unit.GWEI).toBigInteger());
|
result.setSuggestBaseFeeGWei(
|
Convert.toWei(new Double(suggestBaseFee).toString(), Convert.Unit.GWEI).toBigInteger());
|
|
return result;
|
}
|
public GasOracle getRemoteGasOracle(Integer maximum) {
|
boolean current_lock = false;
|
if (lock || (new Date().getTime() - last_time.getTime()) < interval) {
|
ThreadUtils.sleep(sleep);
|
if (maximum >= maximum_limit) {
|
return null;
|
} else {
|
return getRemoteGasOracle(++maximum);
|
}
|
|
} else {
|
try {
|
current_lock = true;
|
lock = true;
|
|
Map<String, Object> param = new HashMap<String, Object>();
|
param.put("module", "gastracker");
|
param.put("action", "gasoracle");
|
param.put("apikey", apikey);
|
|
String result = HttpHelper.getJSONFromHttp(url, param, HttpMethodType.GET);
|
JSONObject resultJson = JSON.parseObject(result);
|
String status = resultJson.getString("status");
|
if ("1".equals(status)) {
|
JSONObject json = resultJson.getJSONObject("result");
|
GasOracle gasOracle = new GasOracle();
|
gasOracle.setSafeGasPrice(json.getDouble("SafeGasPrice"));
|
gasOracle.setProposeGasPrice(json.getDouble("ProposeGasPrice"));
|
gasOracle.setFastGasPrice(json.getDouble("FastGasPrice"));
|
gasOracle.setSuggestBaseFee(json.getDouble("suggestBaseFee"));
|
|
gasOracle.setSafeGasPriceGWei(
|
Convert.toWei(new Double(gasOracle.getSafeGasPrice()).toString(), Convert.Unit.GWEI)
|
.toBigInteger());
|
gasOracle.setProposeGasPriceGWei(
|
Convert.toWei(new Double(gasOracle.getProposeGasPrice()).toString(), Convert.Unit.GWEI)
|
.toBigInteger());
|
gasOracle.setFastGasPriceGWei(
|
Convert.toWei(new Double(gasOracle.getFastGasPrice()).toString(), Convert.Unit.GWEI)
|
.toBigInteger());
|
gasOracle.setSuggestBaseFeeGWei(
|
Convert.toWei(new Double(gasOracle.getSuggestBaseFee()).toString(), Convert.Unit.GWEI)
|
.toBigInteger());
|
return gasOracle;
|
} else {
|
logger.error(" getGasOracle()error, resultJson [ " + resultJson.toJSONString() + " ]");
|
}
|
|
} catch (Exception e) {
|
logger.error("error", e);
|
} finally {
|
if (current_lock) {
|
lock = false;
|
last_time = new Date();
|
}
|
|
}
|
|
return null;
|
}
|
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
}
|
