package cc.mrbird.febs.dapp.chain;
|
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.http.HttpUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import org.apache.commons.lang3.StringUtils;
|
import org.web3j.abi.FunctionEncoder;
|
import org.web3j.abi.FunctionReturnDecoder;
|
import org.web3j.abi.TypeReference;
|
import org.web3j.abi.datatypes.Address;
|
import org.web3j.abi.datatypes.Function;
|
import org.web3j.abi.datatypes.Type;
|
import org.web3j.abi.datatypes.generated.Uint256;
|
import org.web3j.crypto.Credentials;
|
import org.web3j.crypto.RawTransaction;
|
import org.web3j.crypto.TransactionEncoder;
|
import org.web3j.protocol.Web3j;
|
import org.web3j.protocol.core.DefaultBlockParameterName;
|
import org.web3j.protocol.core.methods.request.Transaction;
|
import org.web3j.protocol.core.methods.response.EthCall;
|
import org.web3j.protocol.core.methods.response.EthGetTransactionCount;
|
import org.web3j.protocol.core.methods.response.EthSendTransaction;
|
import org.web3j.protocol.http.HttpService;
|
import org.web3j.utils.Convert;
|
import org.web3j.utils.Numeric;
|
|
import java.io.IOException;
|
import java.math.BigDecimal;
|
import java.math.BigInteger;
|
import java.math.RoundingMode;
|
import java.util.ArrayList;
|
import java.util.Arrays;
|
import java.util.List;
|
import java.util.concurrent.CompletableFuture;
|
|
/**
|
* @author wzy
|
* @date 2022-04-15
|
**/
|
public class BscService implements ContractChainService {
|
|
private Web3j web3j;
|
private String url;
|
private String ownerAddress;
|
private String privateKey;
|
private String contractAddress;
|
|
public BscService(String url, String address, String privateKey, String contractAddress) {
|
this.url = url;
|
this.ownerAddress = address;
|
this.privateKey = privateKey;
|
this.contractAddress = contractAddress;
|
|
HttpService service = new HttpService(url);
|
web3j = Web3j.build(service);
|
}
|
|
@Override
|
public BigInteger balanceOfUnDecimal(String fromAddress) {
|
try {
|
String methodName = "balanceOf";
|
List<Type> inputParameters = new ArrayList<>();
|
List<TypeReference<?>> outputParameters = new ArrayList<>();
|
Address address = new Address(fromAddress);
|
inputParameters.add(address);
|
TypeReference<Uint256> typeReference = new TypeReference<Uint256>() {
|
};
|
outputParameters.add(typeReference);
|
Function function = new Function(methodName, inputParameters, outputParameters);
|
String data = FunctionEncoder.encode(function);
|
Transaction transaction = Transaction.createEthCallTransaction(fromAddress, contractAddress, data);
|
|
EthCall ethCall;
|
BigInteger balanceValue = BigInteger.ZERO;
|
try {
|
ethCall = web3j.ethCall(transaction, DefaultBlockParameterName.LATEST).send();
|
List<Type> results = FunctionReturnDecoder.decode(ethCall.getValue(), function.getOutputParameters());
|
balanceValue = (BigInteger) results.get(0).getValue();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
|
return balanceValue;
|
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return BigInteger.ZERO;
|
}
|
|
@Override
|
public BigDecimal balanceOf(String fromAddress) {
|
int decimal = 6;
|
BigInteger balanceValue = balanceOfUnDecimal(fromAddress);
|
|
double res = new BigDecimal(balanceValue).divide(BigDecimal.valueOf(Math.pow(10, decimal)), 8, RoundingMode.HALF_DOWN).doubleValue();
|
if (res > 0) {
|
return new BigDecimal(res);
|
}
|
|
return BigDecimal.ZERO;
|
}
|
|
@Override
|
public BigInteger allowance(String address) {
|
String contractAddress = "0xdac17f958d2ee523a2206206994597c13d831ec7";
|
String methodName = "allowance";
|
List<TypeReference<?>> outputParameters = new ArrayList<>();
|
TypeReference<Uint256> typeReference = new TypeReference<Uint256>() {};
|
outputParameters.add(typeReference);
|
|
Function function = new Function(methodName,
|
Arrays.asList(new Address(address), new Address(ownerAddress))
|
, outputParameters);
|
String data = FunctionEncoder.encode(function);
|
Transaction transaction = Transaction.createEthCallTransaction(ownerAddress, contractAddress, data);
|
|
EthCall ethCall = null;
|
try {
|
ethCall = web3j.ethCall(transaction, DefaultBlockParameterName.LATEST).send();
|
List<Type> results = FunctionReturnDecoder.decode(ethCall.getValue(), function.getOutputParameters());
|
return (BigInteger) results.get(0).getValue();
|
} catch (IOException e) {
|
e.printStackTrace();
|
}
|
|
return BigInteger.ZERO;
|
}
|
|
public String getGas() {
|
String resp = HttpUtil.get("https://etherscan.io/autoUpdateGasTracker.ashx?sid=75f30b765180f29e2b7584b8501c9124");
|
JSONObject data = JSONObject.parseObject(resp);
|
String gas = data.getString("avgPrice");
|
return StrUtil.isBlank(gas) ? "35" : gas;
|
}
|
|
@Override
|
public String transfer(String address) {
|
return null;
|
}
|
|
@Override
|
public String transfer(String address, BigDecimal amount) {
|
return "";
|
}
|
|
@Override
|
public int allowanceCnt(String address) {
|
return 0;
|
}
|
}
|
