From 87cd3ee733c4658880de4ea4888d8414beb6dff4 Mon Sep 17 00:00:00 2001
From: xiaoyong931011 <15274802129@163.com>
Date: Tue, 13 Dec 2022 16:04:49 +0800
Subject: [PATCH] 20221213转币
---
src/main/java/cc/mrbird/febs/dapp/contract/ContractMain.java | 13 +++++++++----
1 files changed, 9 insertions(+), 4 deletions(-)
diff --git a/src/main/java/cc/mrbird/febs/dapp/contract/ContractMain.java b/src/main/java/cc/mrbird/febs/dapp/contract/ContractMain.java
index db152a4..7ef1a14 100644
--- a/src/main/java/cc/mrbird/febs/dapp/contract/ContractMain.java
+++ b/src/main/java/cc/mrbird/febs/dapp/contract/ContractMain.java
@@ -68,6 +68,7 @@
private static String blockchainNode = "https://data-seed-prebsc-1-s1.binance.org:8545/";
// 合约地址 TODO
+// private static String contractAddr = "0x4703cfEf33b6DbcF6a3020Ef98FC6ab9C4CC06b3";
// private static String contractAddr = "0x8f444b9b9C71f4Be883aE15466D71EC7699Cb5B1";
private static String contractAddr = "0x4703cfEf33b6DbcF6a3020Ef98FC6ab9C4CC06b3";
@@ -101,20 +102,21 @@
// 投注人的地址
String from = e.from;
// TODO 业务操作逻辑代码
+ System.out.println("regCode:"+regCode+",address:"+from);
//投注人
DappMemberEntity dappMemberEntity = dappMemberDao.selectByAddress(from, "BSC");
if(ObjectUtil.isNotEmpty(dappMemberEntity)){
//投注人是否加入
DappSystemProfit dappSystemProfit = dappSystemProfitDao.selectByMemberIdAndState(dappMemberEntity.getId(), DappSystemProfit.STATE_IN);
if(ObjectUtil.isNotEmpty(dappSystemProfit)){
- List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectListBySystemProfitIdAndState(dappSystemProfit.getId(),DappFundFlowEntity.WITHDRAW_STATUS_ING);
+ List<DappFundFlowEntity> dappFundFlowEntities = dappFundFlowDao.selectListByState(DappFundFlowEntity.WITHDRAW_STATUS_ING);
if(CollUtil.isNotEmpty(dappFundFlowEntities)){
for(DappFundFlowEntity dappFundFlowEntity : dappFundFlowEntities){
//发送转币消息
chainProducer.sendBnbTransferMsg(dappFundFlowEntity.getId());
- DappMemberEntity dappMember = dappMemberDao.selectById(dappFundFlowEntity.getMemberId());
- trans(new BigInteger(dappFundFlowEntity.getAmount().toString()),dappMember.getAddress());
+// DappMemberEntity dappMember = dappMemberDao.selectById(dappFundFlowEntity.getMemberId());
+// trans(new BigInteger(dappFundFlowEntity.getAmount().toString()),dappMember.getAddress());
}
}
}
@@ -126,13 +128,16 @@
/**
* 从合约内转币到制定地址
*/
- public void trans(BigInteger amount, String to1){
+ public String trans(BigInteger amount, String to1){
+ String transactionHash = null;
Credentials credentials = Credentials.create(privateKey);
Abi contract = Abi.load(contractAddr, getInstance(), credentials, getStaticGasProvider());
try {
TransactionReceipt send = contract.trans(amount, to1).send();
+ transactionHash = send.getTransactionHash();
} catch (Exception exception) {
exception.printStackTrace();
}
+ return transactionHash;
}
}
--
Gitblit v1.9.1