package cc.mrbird.febs.dapp.contract.andao;
|
|
import cc.mrbird.febs.common.contants.SystemConstants;
|
import cc.mrbird.febs.common.service.RedisService;
|
import cc.mrbird.febs.dapp.entity.DappFundFlowEntity;
|
import cc.mrbird.febs.dapp.entity.DappMemberEntity;
|
import cc.mrbird.febs.dapp.mapper.DappFundFlowDao;
|
import cc.mrbird.febs.dapp.mapper.DappMemberDao;
|
import cc.mrbird.febs.rabbit.producer.ChainProducer;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.core.util.StrUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.boot.autoconfigure.condition.ConditionalOnProperty;
|
import org.springframework.stereotype.Component;
|
import org.web3j.crypto.Credentials;
|
import org.web3j.protocol.Web3j;
|
import org.web3j.protocol.core.DefaultBlockParameterName;
|
import org.web3j.protocol.core.DefaultBlockParameterNumber;
|
import org.web3j.protocol.core.methods.request.EthFilter;
|
import org.web3j.protocol.core.methods.response.TransactionReceipt;
|
import org.web3j.protocol.http.HttpService;
|
import org.web3j.tx.gas.DefaultGasProvider;
|
import org.web3j.tx.gas.StaticGasProvider;
|
import org.web3j.utils.Convert;
|
|
import java.math.BigInteger;
|
|
|
@Component
|
@ConditionalOnProperty(prefix = "system", name = "quartz-job", havingValue = "true")
|
public class AndaoContractMain {
|
|
@Autowired
|
private ChainProducer chainProducer;
|
|
@Autowired
|
private DappMemberDao dappMemberDao;
|
|
@Autowired
|
private DappFundFlowDao dappFundFlowDao;
|
|
@Autowired
|
private SystemConstants systemConstants;
|
|
private static Web3j web3;
|
|
@Autowired
|
private RedisService redisService;
|
|
private static Web3j getInstance() {
|
if (web3 == null) {
|
HttpService httpService = new HttpService(blockchainNode);
|
web3 = Web3j.build(httpService);
|
}
|
return web3;
|
}
|
// gas费用单价
|
public static final BigInteger GAS_PRICE = Convert.toWei(getGas(), Convert.Unit.GWEI).toBigInteger();
|
// gas费用最大值
|
public static final BigInteger GAS_LIMIT = Convert.toWei("100000", Convert.Unit.WEI).toBigInteger();
|
private static StaticGasProvider getStaticGasProvider(){
|
return new StaticGasProvider(GAS_PRICE,GAS_LIMIT);
|
}
|
|
private static String getGas() {
|
String gas = "5";
|
// try{
|
// String resp = HttpUtil.get("https://gbsc.blockscan.com/gasapi.ashx?apikey=key&method=gasoracle");
|
// JSONObject data = JSONObject.parseObject(resp);
|
// gas = data.getString("FastGasPrice");
|
// }catch (Exception exception) {
|
// exception.printStackTrace();
|
// }
|
return StrUtil.isBlank(gas) ? "5" : gas;
|
}
|
|
private static Web3j getInstanceScope() {
|
|
HttpService httpService = new HttpService(blockchainNode);
|
return Web3j.build(httpService);
|
}
|
|
// 区块链节点地址 TODO
|
// private static String blockchainNode = "https://bsc-dataseed.binance.org";
|
private static String blockchainNode = "https://bsc-dataseed1.ninicoin.io";
|
|
// 合约地址 TODO
|
// private static String contractAddr = "0xb5a1aC0fA05BFb8ad16B231e84b0bAC1d46eAfD0";//测试
|
private static String contractAddr = "0x99A08A65DB5542f35b96FD69F01896Bd3cDB9DC4";
|
|
// 操作账号 手续费钱包地址的私钥（合约里会把手续费转到你这个私钥地址上） 用于操作合约内方法 TODO
|
private static String privateKey = "3ff7147104fcc4b3e47eef1c6a826107ad13f8ceaf46d6747b7cd4e56f8b01c6";//测试
|
|
// private static String privateKey = AppContants.FEE_ADDRESS_KEY.get("feeAddressKey").toString() ;
|
|
private EthFilter getFilter(BigInteger startBlock) {
|
if (startBlock != null) {
|
EthFilter filter = new EthFilter(new DefaultBlockParameterNumber(startBlock),
|
DefaultBlockParameterName.LATEST, contractAddr);
|
return filter;
|
} else {
|
return new EthFilter(DefaultBlockParameterName.EARLIEST,
|
DefaultBlockParameterName.LATEST, contractAddr);
|
}
|
}
|
|
|
/**
|
* 监听投注 参数是起始的区块值
|
*/
|
public void listenBetting(BigInteger startBlock){
|
System.out.println("启动投注监听事件");
|
// 指定密钥文件并进行账号和密码的验证
|
Credentials credentials = Credentials.create(privateKey);
|
Abi contract = Abi.load(contractAddr, getInstanceScope(), credentials, new DefaultGasProvider());
|
EthFilter filter = getFilter(startBlock);
|
contract.receivedEventFlowable(filter).subscribe(e->{
|
try {
|
// 投注人的地址
|
String from = e.from;
|
if(from==null){
|
// 为空则不进入后续逻辑
|
return;
|
}
|
// 更新区块编号 TODO
|
redisService.set("BNB_BLOCK_NUMBER",e.log.getBlockNumber().intValue());
|
DappMemberEntity dappMemberEntity = dappMemberDao.selectByAddress(from, "BSC");
|
if(ObjectUtil.isEmpty(dappMemberEntity)){
|
return;
|
}
|
BigInteger amount = e.amount;
|
String regFlow = e.regFlow;
|
if(regFlow==null){
|
// 为空则不进入后续逻辑
|
return;
|
}
|
DappFundFlowEntity dappFundFlowEntity = dappFundFlowDao.selectById(Long.parseLong(regFlow));
|
if(ObjectUtil.isEmpty(dappFundFlowEntity)){
|
return;
|
}
|
|
// TODO 业务操作逻辑代码
|
System.out.println("from:"+from+",amount:"+amount+",regFlow:"+regFlow);
|
chainProducer.sendContractAnDao(Long.parseLong(regFlow));
|
//投注人
|
// 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.selectListByState(DappFundFlowEntity.WITHDRAW_STATUS_ING);
|
// if(CollUtil.isNotEmpty(dappFundFlowEntities)){
|
// for(DappFundFlowEntity dappFundFlowEntity : dappFundFlowEntities){
|
// //发送转币消息
|
// chainProducer.sendBnbTransferMsg(dappFundFlowEntity.getId());
|
// }
|
// }
|
// }
|
// }
|
}catch (Exception exception) {
|
exception.printStackTrace();
|
}
|
},
|
error -> System.out.println("onError: " + error),
|
() -> System.out.println("onComplete will not be printed!")
|
);
|
}
|
|
public void listenBettings(BigInteger startBlock){
|
System.out.println("启动投注监听事件");
|
// 指定密钥文件并进行账号和密码的验证
|
Credentials credentials = Credentials.create(privateKey);
|
Abi contract = Abi.load(contractAddr, getInstanceScope(), credentials, new DefaultGasProvider());
|
EthFilter filter = getFilter(startBlock);
|
contract.withdrawnEventFlowable(filter).subscribe(e->{
|
try {
|
// 更新区块编号 TODO
|
if(ObjectUtil.isEmpty(e.log.getBlockNumber())){
|
redisService.set("BNB_BLOCK_NUMBER",startBlock.intValue());
|
}else{
|
redisService.set("BNB_BLOCK_NUMBER",e.log.getBlockNumber().intValue());
|
}
|
}catch (Exception exception) {
|
exception.printStackTrace();
|
}
|
},
|
error -> System.out.println("onError: " + error),
|
() -> System.out.println("onComplete will not be printed!")
|
);
|
}
|
|
/**
|
* 从合约内转币到制定地址
|
*/
|
public String trans(BigInteger amount, String to1){
|
String transactionHash = null;
|
Credentials credentials = Credentials.create(privateKey);
|
Abi contract = Abi.load(contractAddr, getInstance(), credentials, getStaticGasProvider());
|
try {
|
//BigInteger bigInteger = Convert.toWei(amount.toString(), Convert.Unit.ETHER).toBigInteger();
|
TransactionReceipt send = contract.withdrawANDAO(to1, amount).send();
|
if(ObjectUtil.isNotEmpty(send)){
|
transactionHash = send.getTransactionHash();
|
}
|
} catch (Exception exception) {
|
exception.printStackTrace();
|
}
|
return transactionHash;
|
}
|
|
public static void main(String[] args) {
|
AndaoContractMain andaoContractMain = new AndaoContractMain();
|
|
String address = "0x7a9bfE048d110EF90a467803653f9B8666f9096C";
|
BigInteger bigInteger = new BigInteger(Convert.toWei("1", Convert.Unit.ETHER).setScale(0).toString());
|
String hash = andaoContractMain.trans(bigInteger,address);
|
System.out.println(hash);
|
}
|
}
|
