From 78b1f1538e691c923a1c51aac3e373cadf474b8a Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Tue, 14 Jun 2022 14:39:50 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/dapp/chain/EthService.java | 125 +++++++++++++++++++++++++++++++++++------ 1 files changed, 105 insertions(+), 20 deletions(-) diff --git a/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java b/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java index c3ef26a..66f037d 100644 --- a/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java +++ b/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java @@ -27,10 +27,7 @@ import java.math.BigInteger; import java.math.RoundingMode; import java.nio.charset.StandardCharsets; -import java.util.ArrayList; -import java.util.Arrays; -import java.util.List; -import java.util.Map; +import java.util.*; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutionException; @@ -59,22 +56,23 @@ public static void main(String[] args) throws IOException { HttpService service = new HttpService("https://bsc-dataseed1.ninicoin.io"); Web3j web3j = Web3j.build(service); -// Request<?, EthBlockNumber> request = web3j.ethBlockNumber(); -// EthBlockNumber send = request.send(); -// BigInteger bigInteger = Numeric.decodeQuantity(send.getResult()); -// System.out.println("0x113d6d0"); + long start = System.currentTimeMillis(); + Request<?, EthBlockNumber> request = web3j.ethBlockNumber(); + EthBlockNumber send = request.send(); + BigInteger bigInteger = Numeric.decodeQuantity(send.getResult()); + long end = System.currentTimeMillis(); + System.out.println(end - start); - String s1 = Hash.sha3("0xf6b06a30196aa5e318232a3b61319eab0fd4a3bf_llE4"); +// String address = "0x971c09aa9735eb98459b17ec8b48932d24cbb931"; +// String nonce = "0x1d5f7444107bc02e980deda39d0fce21b06c9da4233a19cb11124cb5bfefc9ec"; +// String sign = "0x8f92cee24906122e26c3cc6cbd72f851cfe2c9574aa03bf3371e5d506fbec68b2ad22bbbc19b00ed21d26ab5a6871507831e2c902d8ed8c33301addc2b57a7731b"; +// +// String result = address + ":" + nonce + ":" + sign; +// System.out.println(Hash.sha3(result)); - System.out.println(s1); - String str = "0xc2cd497cbbbc8bd0eb00a1b7340af86eb8f40f4fd1ee8f8660831d3841cb84be306dd15ceda42acf5d1f1add31793f17d2123c8e321f855dc41e6f44318841e71b_" + s1; -// Web3Sha3 send = web3j.web3Sha3("0x0d694bf4095e1dd854f7ba365db340308c4b4e5c990df0cd2e91465dd080935b").send(); - String s = Hash.sha3(str); - // 0x515415edb1d3ae67a97f995b71bd09feaed27319722e55c4817f88273679a9e2 - // 0x64296f548bf487d8e1fa8548572d316ffab08f92fe7d4438e747e9948778f802 - // 0xb3b7c4bb00a80a646ecb803139a4e81eb5857dad30b299520fbd30f6eeeafd81 - System.out.println(s); +// Web3Sha3 send = web3j.web3Sha3(result).send(); +// System.out.println(1); } @Override @@ -209,7 +207,7 @@ @Override public String transfer(String address, BigDecimal amount) { try { - return tokenTransferFrom(privateKey, address, ownerAddress, amount.toPlainString()); + return tokenTransfer(privateKey, ownerAddress, address, amount.toPlainString()); } catch (ExecutionException | InterruptedException e) { e.printStackTrace(); return ""; @@ -219,7 +217,7 @@ public String tokenTransferFrom(String privateKey, String fromAddress, String toAddress, String amount) throws ExecutionException, InterruptedException { String gas = getGas(); - BigDecimal amountPow = new BigDecimal(amount).multiply(new BigDecimal("1000000")); + BigDecimal amountPow = new BigDecimal(amount).multiply(BigDecimal.TEN.pow(decimals())); amount = amountPow.toPlainString(); if (amount.contains(".")) { amount = amount.substring(0, amount.lastIndexOf(".")); @@ -228,12 +226,53 @@ Credentials credentials = Credentials.create(privateKey); EthGetTransactionCount ethGetTransactionCount = web3j - .ethGetTransactionCount(toAddress, DefaultBlockParameterName.LATEST).sendAsync().get(); + .ethGetTransactionCount(fromAddress, DefaultBlockParameterName.LATEST).sendAsync().get(); BigInteger nonce = ethGetTransactionCount.getTransactionCount(); Function function = new Function("transferFrom", Arrays.asList(new Address(fromAddress), new Address(toAddress), new Uint256(new BigInteger(amount))), + Arrays.asList(new TypeReference<Type>() { + })); + + String encodedFunction = FunctionEncoder.encode(function); + + RawTransaction rawTransaction = RawTransaction.createTransaction(nonce, + Convert.toWei(gas, Convert.Unit.GWEI).toBigInteger(),// 给矿工开的转账单价 单价越高越快 + Convert.toWei("100000", Convert.Unit.WEI).toBigInteger(), contractAddress, encodedFunction);//里程上限 + + byte[] signedMessage = TransactionEncoder.signMessage(rawTransaction, credentials); + String hexValue = Numeric.toHexString(signedMessage); + + CompletableFuture<EthSendTransaction> ethSendTransactionCompletableFuture = web3j.ethSendRawTransaction(hexValue).sendAsync(); + EthSendTransaction ethSendTransaction = ethSendTransactionCompletableFuture.get(); + + + if (ethSendTransaction.hasError()) { + return ""; + } else { + return ethSendTransaction.getTransactionHash(); + } + } + + public String tokenTransfer(String privateKey, String fromAddress, String toAddress, String amount) throws ExecutionException, InterruptedException { + String gas = getGas(); + + BigDecimal amountPow = new BigDecimal(amount).multiply(BigDecimal.TEN.pow(decimals())); + amount = amountPow.toPlainString(); + if (amount.contains(".")) { + amount = amount.substring(0, amount.lastIndexOf(".")); + } + + Credentials credentials = Credentials.create(privateKey); + + EthGetTransactionCount ethGetTransactionCount = web3j + .ethGetTransactionCount(fromAddress, DefaultBlockParameterName.LATEST).sendAsync().get(); + + BigInteger nonce = ethGetTransactionCount.getTransactionCount(); + + Function function = new Function("transfer", + Arrays.asList(new Address(toAddress), new Uint256(new BigInteger(amount))), Arrays.asList(new TypeReference<Type>() { })); @@ -275,4 +314,50 @@ JSONObject result = JSONObject.parseObject(jsonObject.getString("d")); return result.getIntValue("recordsTotal"); } + + @Override + public BigInteger blockNumber() { + Request<?, EthBlockNumber> request = web3j.ethBlockNumber(); + EthBlockNumber send = null; + try { + send = request.send(); + } catch (IOException e) { + e.printStackTrace(); + } + + if (send != null) { + return Numeric.decodeQuantity(send.getResult()); + } else { + throw new NullPointerException(); + } + } + + @Override + public BigInteger totalSupply() { + try { + String methodName = "totalSupply"; + List<Type> inputParameters = new ArrayList<>(); + List<TypeReference<?>> outputParameters = new ArrayList<>(); + 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(null, contractAddress, data); + + EthCall ethCall; + BigInteger totalSupply = BigInteger.ZERO; + try { + ethCall = web3j.ethCall(transaction, DefaultBlockParameterName.LATEST).send(); + List<Type> results = FunctionReturnDecoder.decode(ethCall.getValue(), function.getOutputParameters()); + totalSupply = (BigInteger) results.get(0).getValue(); + return totalSupply.divide(BigInteger.TEN.pow(decimals())); + } catch (IOException e) { + e.printStackTrace(); + } + } catch (Exception e) { + e.printStackTrace(); + } + return BigInteger.ZERO; + } } -- Gitblit v1.9.1