|
|
|
|
@ -9,19 +9,29 @@ import com.conflux.web.controller.collect.service.ICollectConfigService;
|
|
|
|
|
import com.conflux.web.controller.contract.domain.ContractConfig; |
|
|
|
|
import com.conflux.web.controller.contract.service.IContractConfigService; |
|
|
|
|
import com.conflux.web.controller.nft.domain.*; |
|
|
|
|
import com.conflux.web.controller.nft.domain.vo.FilterMapVO; |
|
|
|
|
import com.conflux.web.controller.nft.service.ConfluxService; |
|
|
|
|
import com.conflux.web.controller.nft.service.IHandlerStrategy; |
|
|
|
|
import com.conflux.web.controller.nft.service.INftCollectionService; |
|
|
|
|
import com.conflux.web.controller.nft.service.INftLogService; |
|
|
|
|
import com.conflux.web.controller.util.AESUtil; |
|
|
|
|
import com.conflux.web.controller.util.AddressUtil; |
|
|
|
|
import com.conflux.web.controller.util.CfxUtils; |
|
|
|
|
import com.conflux.web.controller.util.redis.RedisUtils; |
|
|
|
|
import com.google.gson.Gson; |
|
|
|
|
import conflux.web3j.Account; |
|
|
|
|
import conflux.web3j.Cfx; |
|
|
|
|
import conflux.web3j.Request; |
|
|
|
|
import conflux.web3j.request.Epoch; |
|
|
|
|
import conflux.web3j.request.LogFilter; |
|
|
|
|
import conflux.web3j.response.Log; |
|
|
|
|
import conflux.web3j.response.UsedGasAndCollateral; |
|
|
|
|
import conflux.web3j.types.Address; |
|
|
|
|
import lombok.SneakyThrows; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
|
import org.apache.commons.collections.CollectionUtils; |
|
|
|
|
import org.springframework.beans.factory.annotation.Autowired; |
|
|
|
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor; |
|
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
import org.springframework.transaction.annotation.Transactional; |
|
|
|
|
|
|
|
|
|
@ -49,6 +59,10 @@ public class ConfluxServiceImpl implements ConfluxService {
|
|
|
|
|
private INftCollectionService nftCollectionService; |
|
|
|
|
@Autowired |
|
|
|
|
private INftLogService nftLogService; |
|
|
|
|
@Resource |
|
|
|
|
private IHandlerStrategy iHandlerStrategy; |
|
|
|
|
@Autowired |
|
|
|
|
private ThreadPoolTaskExecutor executor; |
|
|
|
|
|
|
|
|
|
@SneakyThrows |
|
|
|
|
@Override |
|
|
|
|
@ -64,73 +78,81 @@ public class ConfluxServiceImpl implements ConfluxService {
|
|
|
|
|
if (checkArgs.getIds().length > 100) { |
|
|
|
|
return AjaxResult.error("上链数量超出100！"); |
|
|
|
|
} |
|
|
|
|
String checkArgsToken = AESUtil.decrypt(checkArgs.getToken(), ConfluxArt.AESKEY); |
|
|
|
|
String token = (String) redisUtils.get(checkArgsToken); |
|
|
|
|
String sign = AESUtil.decrypt(checkArgs.getSign(), ConfluxArt.AESKEY); |
|
|
|
|
//校验token和sign签名
|
|
|
|
|
if (token.equals(checkArgsToken) && sign.equals(ConfluxArt.SIGN)) { |
|
|
|
|
//校验时间戳
|
|
|
|
|
long time = Long.valueOf(checkArgs.getTimesTamp()); |
|
|
|
|
long timesTamp = System.currentTimeMillis(); |
|
|
|
|
if (timesTamp - time > 10000l) { |
|
|
|
|
return AjaxResult.error("参数错误！"); |
|
|
|
|
} |
|
|
|
|
//删除缓存
|
|
|
|
|
redisUtils.del(checkArgsToken); |
|
|
|
|
redisUtils.del(sign); |
|
|
|
|
//判断上链的数量
|
|
|
|
|
CollectConfig collectConfig = collectConfigService.selectCollectConfigByStatus(); |
|
|
|
|
if (collectConfig.getMintPause()) { |
|
|
|
|
log.info("[--------------------->mintNft][start pause]"); |
|
|
|
|
Thread.sleep(5000); |
|
|
|
|
return AjaxResult.error("pause参数异常！"); |
|
|
|
|
} |
|
|
|
|
Cfx cfx = Cfx.create(collectConfig.getNode(), 3, 1000); |
|
|
|
|
ContractConfig contractConfig = contractConfigService.selectContractConfigByUnitName(checkArgs.getUnitName()); |
|
|
|
|
Account account = Account.create(cfx, AESUtil.decrypt(contractConfig.getPrivateKey())); |
|
|
|
|
Account.Option opt = new Account.Option(); |
|
|
|
|
opt.withValue(BigInteger.ZERO); |
|
|
|
|
opt.withChainId(collectConfig.getChainId()); |
|
|
|
|
opt.withEpochHeight(cfx.getEpochNumber().sendAndGet()); |
|
|
|
|
opt.withGasPrice(contractConfig.getGasPrice()); |
|
|
|
|
//获取余额
|
|
|
|
|
BigInteger balance = cfx.getBalance(account.getAddress()).sendAndGet(); |
|
|
|
|
log.info("[--------------------->mintNft][balance]{}", balance); |
|
|
|
|
if (balance.compareTo(new BigInteger("50000000000000000000")) < 0) { |
|
|
|
|
log.info("[--------------------->mintNft][balance not enough 50]{}", balance); |
|
|
|
|
//sms notice
|
|
|
|
|
return AjaxResult.error("账户余额不足！"); |
|
|
|
|
} |
|
|
|
|
String contract = contractConfig.getContract(); |
|
|
|
|
String owner = contractConfig.getContract(); |
|
|
|
|
ConfluxExecutor confluxExecutor=new ConfluxExecutor(account,contract); |
|
|
|
|
List<String> list = Arrays.asList(checkArgs.getIds()); |
|
|
|
|
long start = DateUtil.currentSeconds(); |
|
|
|
|
log.info("[--------------------->mintNft][time]{}", new SimpleDateFormat("HH:mm:ss").format(new Date(start * 1000))); |
|
|
|
|
List<BigInteger> tokenIds = list.stream().map(n -> new BigInteger(n, 16)).collect(Collectors.toList()); |
|
|
|
|
log.info("[--------------------->mintNft][tokenIds]:{}", tokenIds); |
|
|
|
|
UsedGasAndCollateral est = confluxExecutor.getEstimate(cfx, new Address(owner), |
|
|
|
|
new Address(contract), AddressUtil.getHexAddress(owner), tokenIds); |
|
|
|
|
log.info("[--------------------->mintNft][GasUsed]{}", est.getGasUsed()); |
|
|
|
|
log.info("[--------------------->mintNft][StorageCollateralized]{}", est.getStorageCollateralized()); |
|
|
|
|
opt.withGasLimit(est.getGasUsed()); |
|
|
|
|
opt.withStorageLimit(est.getStorageCollateralized()); |
|
|
|
|
String hash = confluxExecutor.mulMint(opt, |
|
|
|
|
AddressUtil.getHexAddress(owner), tokenIds |
|
|
|
|
); |
|
|
|
|
log.info("[--------------------->mintNft][hash],{}", hash); |
|
|
|
|
log.info("[--------------------->mintNft][time end]{}", +(DateUtil.currentSeconds() - start)); |
|
|
|
|
//保存上链的id
|
|
|
|
|
nftCollectionService.insertListNftCollection(contractConfig.getUnitName(),list); |
|
|
|
|
//保存日志记录
|
|
|
|
|
NftLog nftLog=new NftLog(); |
|
|
|
|
nftLog.setUnitName(contractConfig.getUnitName()); |
|
|
|
|
nftLog.setCreateTime(new Date()); |
|
|
|
|
nftLog.setNftNum(checkArgs.getIds().length); |
|
|
|
|
nftLogService.insertNftLog(nftLog); |
|
|
|
|
log.info("上链日志----->:{"+contractConfig.getUnitName()+"}{"+new Date()+"}{"+checkArgs.getIds().length+"}"); |
|
|
|
|
return AjaxResult.success("上链成功！"); |
|
|
|
|
String checkArgsToken = AESUtil.decrypt(checkArgs.getToken(), ConfluxArt.AESKEY); |
|
|
|
|
String token = (String) redisUtils.get(checkArgsToken); |
|
|
|
|
if (null == token) { |
|
|
|
|
return AjaxResult.error("token已过期！"); |
|
|
|
|
} |
|
|
|
|
String sign = AESUtil.decrypt(checkArgs.getSign(), ConfluxArt.AESKEY); |
|
|
|
|
//校验token和sign签名
|
|
|
|
|
if (token.equals(checkArgsToken) && sign.equals(ConfluxArt.SIGN)) { |
|
|
|
|
//校验时间戳
|
|
|
|
|
long time = Long.valueOf(checkArgs.getTimesTamp()); |
|
|
|
|
long timesTamp = System.currentTimeMillis(); |
|
|
|
|
if (timesTamp - time > 10000l) { |
|
|
|
|
return AjaxResult.error("参数错误！"); |
|
|
|
|
} |
|
|
|
|
//删除缓存
|
|
|
|
|
// redisUtils.del(checkArgsToken);
|
|
|
|
|
// redisUtils.del(sign);
|
|
|
|
|
//判断上链的数量
|
|
|
|
|
CollectConfig collectConfig = collectConfigService.selectCollectConfigByStatus(); |
|
|
|
|
if (collectConfig.getMintPause()) { |
|
|
|
|
log.info("[--------------------->mintNft][start pause]"); |
|
|
|
|
Thread.sleep(5000); |
|
|
|
|
return AjaxResult.error("pause参数异常！"); |
|
|
|
|
} |
|
|
|
|
Cfx cfx = Cfx.create(collectConfig.getNode(), 3, 1000); |
|
|
|
|
ContractConfig contractConfig = contractConfigService.selectContractConfigByUnitName(checkArgs.getUnitName()); |
|
|
|
|
Account account = Account.create(cfx, AESUtil.decrypt(contractConfig.getPrivateKey())); |
|
|
|
|
Account.Option opt = new Account.Option(); |
|
|
|
|
opt.withValue(BigInteger.ZERO); |
|
|
|
|
opt.withChainId(collectConfig.getChainId()); |
|
|
|
|
opt.withEpochHeight(cfx.getEpochNumber().sendAndGet()); |
|
|
|
|
opt.withGasPrice(contractConfig.getGasPrice()); |
|
|
|
|
//获取余额
|
|
|
|
|
BigInteger balance = cfx.getBalance(account.getAddress()).sendAndGet(); |
|
|
|
|
log.info("[--------------------->mintNft][balance]{}", balance); |
|
|
|
|
if (balance.compareTo(new BigInteger("50000000000000000000")) < 0) { |
|
|
|
|
log.info("[--------------------->mintNft][balance not enough 50]{}", balance); |
|
|
|
|
//sms notice
|
|
|
|
|
return AjaxResult.error("账户余额不足！"); |
|
|
|
|
} |
|
|
|
|
String contract = contractConfig.getContract(); |
|
|
|
|
String owner = contractConfig.getContract(); |
|
|
|
|
ConfluxExecutor confluxExecutor = new ConfluxExecutor(account, contract); |
|
|
|
|
List<String> list = Arrays.asList(checkArgs.getIds()); |
|
|
|
|
long start = DateUtil.currentSeconds(); |
|
|
|
|
log.info("[--------------------->mintNft][time]{}", new SimpleDateFormat("HH:mm:ss").format(new Date(start * 1000))); |
|
|
|
|
List<BigInteger> tokenIds = list.stream().map(n -> new BigInteger(n, 16)).collect(Collectors.toList()); |
|
|
|
|
log.info("[--------------------->mintNft][tokenIds]:{}", tokenIds); |
|
|
|
|
UsedGasAndCollateral est = confluxExecutor.getEstimate(cfx, new Address(owner), |
|
|
|
|
new Address(contract), AddressUtil.getHexAddress(owner), tokenIds); |
|
|
|
|
log.info("[--------------------->mintNft][GasUsed]{}", est.getGasUsed()); |
|
|
|
|
log.info("[--------------------->mintNft][StorageCollateralized]{}", est.getStorageCollateralized()); |
|
|
|
|
opt.withGasLimit(est.getGasUsed()); |
|
|
|
|
opt.withStorageLimit(est.getStorageCollateralized()); |
|
|
|
|
String hash = confluxExecutor.mulMint(opt, |
|
|
|
|
AddressUtil.getHexAddress(owner), tokenIds |
|
|
|
|
); |
|
|
|
|
log.info("[--------------------->mintNft][hash],{}", hash); |
|
|
|
|
log.info("[--------------------->mintNft][time end]{}", +(DateUtil.currentSeconds() - start)); |
|
|
|
|
//保存上链的id
|
|
|
|
|
nftCollectionService.insertListNftCollection(contractConfig.getUnitName(), list); |
|
|
|
|
//保存日志记录
|
|
|
|
|
NftLog nftLog = new NftLog(); |
|
|
|
|
nftLog.setUnitName(contractConfig.getUnitName()); |
|
|
|
|
nftLog.setCreateTime(new Date()); |
|
|
|
|
nftLog.setNftNum(checkArgs.getIds().length); |
|
|
|
|
nftLogService.insertNftLog(nftLog); |
|
|
|
|
log.info("上链日志----->:{" + contractConfig.getUnitName() + "}{" + new Date() + "}{" + checkArgs.getIds().length + "}"); |
|
|
|
|
|
|
|
|
|
executor.execute(()->{ |
|
|
|
|
executeMakeUp(contract, contractConfig.getUnitName()); |
|
|
|
|
}); |
|
|
|
|
System.out.println("------------------->"); |
|
|
|
|
return AjaxResult.success("上链成功！"); |
|
|
|
|
} |
|
|
|
|
return AjaxResult.error(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@ -145,4 +167,145 @@ public class ConfluxServiceImpl implements ConfluxService {
|
|
|
|
|
redisUtils.set(token, token); |
|
|
|
|
return AjaxResult.success(map); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
public void executeMakeUp(String contract, String markName) { |
|
|
|
|
log.info("[dispatchHandler]{}", "开始监听数据"); |
|
|
|
|
CollectConfig collect = collectConfigService.selectCollectConfigByStatus(); |
|
|
|
|
if (collect.getOnPause()) { |
|
|
|
|
log.info("[dispatchHandler]{}", "暂停中"); |
|
|
|
|
try { |
|
|
|
|
Thread.sleep(5000); |
|
|
|
|
} catch (InterruptedException e) { |
|
|
|
|
e.printStackTrace(); |
|
|
|
|
} |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
//=======检查数据=======
|
|
|
|
|
List<EventParam> eventParams = new ArrayList<>(); |
|
|
|
|
EventParam eventParam = new EventParam(); |
|
|
|
|
eventParam.setChainId(collect.getChainId()); |
|
|
|
|
eventParam.setContract(contract); |
|
|
|
|
eventParam.setParam("address,address,uint256"); |
|
|
|
|
eventParam.setMethod("Transfer"); |
|
|
|
|
eventParam.setType(20000); |
|
|
|
|
eventParam.setRemark(markName); |
|
|
|
|
eventParams.add(eventParam); |
|
|
|
|
if (CollectionUtils.isEmpty(eventParams)) { |
|
|
|
|
log.error("[dispatchHandler]{}", "没有需要监听的数据"); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
Gson gson = new Gson(); |
|
|
|
|
//获取event，使用 webService
|
|
|
|
|
//记录数据
|
|
|
|
|
Cfx cfx = null; |
|
|
|
|
try { |
|
|
|
|
cfx = Cfx.create(collect.getNode(), 3, 1000); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
e.printStackTrace(); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
FilterMapVO vo = getFilter(eventParams); |
|
|
|
|
//获取数据高度
|
|
|
|
|
long from = collect.getEpochNumber(); |
|
|
|
|
// Invoke cfx method
|
|
|
|
|
BigInteger epoch = cfx.getEpochNumber().sendAndGet(); |
|
|
|
|
log.info("[executeMakeUp][Current epoch]:{}", epoch); |
|
|
|
|
long to = epoch.intValue() - 5; |
|
|
|
|
if (to - from > collect.getLimitCount()) { |
|
|
|
|
to = from + collect.getLimitCount(); |
|
|
|
|
} |
|
|
|
|
vo.getLogFilter().setFromEpoch(Epoch.numberOf(from)); |
|
|
|
|
//当前高度
|
|
|
|
|
vo.getLogFilter().setToEpoch(Epoch.numberOf(to)); |
|
|
|
|
Request<List<Log>, Log.Response> events = cfx.getLogs(vo.getLogFilter()); |
|
|
|
|
try { |
|
|
|
|
events = cfx.getLogs(vo.getLogFilter()); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
e.printStackTrace(); |
|
|
|
|
} |
|
|
|
|
if (events == null) { |
|
|
|
|
log.info("[executeMakeUp][请重启服务]"); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
List<Log> logList = events.sendAndGet(); |
|
|
|
|
boolean isSuccess = false; |
|
|
|
|
if (CollectionUtils.isEmpty(logList)) { |
|
|
|
|
log.info("[executeMakeUp][此区间暂无日志]:from:{} to:{}", from, to); |
|
|
|
|
isSuccess = true; |
|
|
|
|
} |
|
|
|
|
for (Log l : logList) { |
|
|
|
|
//处理高度信息
|
|
|
|
|
String evAddress = l.getTopics().get(0); |
|
|
|
|
String tokenAddress = l.getAddress().getAddress(); |
|
|
|
|
if (tokenAddress.contains("TYPE")) { |
|
|
|
|
Address a = new Address(tokenAddress); |
|
|
|
|
tokenAddress = a.getAddress(); |
|
|
|
|
} |
|
|
|
|
int type = vo.getMap().get(evAddress + "-" + tokenAddress.toLowerCase()); |
|
|
|
|
if (type == 0) { |
|
|
|
|
log.info("[dispatchHandler][暂无符合条件的数据]"); |
|
|
|
|
return; |
|
|
|
|
} |
|
|
|
|
boolean res; |
|
|
|
|
try { |
|
|
|
|
res = iHandlerStrategy.relayHandler(cfx, gson.toJson(l), type); |
|
|
|
|
} catch (Exception e) { |
|
|
|
|
e.printStackTrace(); |
|
|
|
|
isSuccess = false; |
|
|
|
|
log.info("[dispatchHandler][数据错误未分配]{}", l.getData()); |
|
|
|
|
break; |
|
|
|
|
} |
|
|
|
|
if (res) { |
|
|
|
|
log.info("[dispatchHandler][分配成功]{}", evAddress); |
|
|
|
|
isSuccess = true; |
|
|
|
|
} else { |
|
|
|
|
log.info("[dispatchHandler][数据错误未分配]{}", l.getData()); |
|
|
|
|
isSuccess = false; |
|
|
|
|
break; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
//分析数据拉取成功
|
|
|
|
|
CollectConfig t = new CollectConfig(); |
|
|
|
|
t.setId(collect.getId()); |
|
|
|
|
t.setUpdateTime(DateUtil.currentSeconds()); |
|
|
|
|
if (isSuccess) { |
|
|
|
|
t.setEpochNumber(to); |
|
|
|
|
log.info("[dispatchHandler][更新高度]:{}", to); |
|
|
|
|
int i = collectConfigService.updateCollectConfig(t); |
|
|
|
|
if (i <= 0) { |
|
|
|
|
log.error("[dispatchHandler][更新高度失败]:{}", to); |
|
|
|
|
throw new RuntimeException("更新高度失败"); |
|
|
|
|
} |
|
|
|
|
} else { |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
private FilterMapVO getFilter(List<EventParam> eventParams) { |
|
|
|
|
// PubSub Subscribe to incoming events and process incoming events
|
|
|
|
|
LogFilter filter = new LogFilter(); |
|
|
|
|
//添加监听合约：
|
|
|
|
|
List<Address> moList = eventParams.stream().map( |
|
|
|
|
eventParam -> new Address(eventParam.getContract())).collect(Collectors.toList()); |
|
|
|
|
filter.setAddress(moList); |
|
|
|
|
//添加监听方法
|
|
|
|
|
List<String> list = new ArrayList<>(); |
|
|
|
|
//Transfer
|
|
|
|
|
Map<String, Integer> map = new HashMap<>(eventParams.size()); |
|
|
|
|
eventParams.forEach(eventParam -> { |
|
|
|
|
String evAddress = CfxUtils.getEventKeccak(eventParam.getMethod(), Arrays.asList(eventParam.getParam().split(","))); |
|
|
|
|
// log.info("token:{} method:{} kec:{}", eventParam.getContract(), eventParam.getMethod(), evAddress);
|
|
|
|
|
map.put(evAddress + "-" + eventParam.getContract().toLowerCase(), eventParam.getType()); |
|
|
|
|
list.add(evAddress); |
|
|
|
|
}); |
|
|
|
|
List<List<String>> lists = new ArrayList<>(); |
|
|
|
|
lists.add(list); |
|
|
|
|
filter.setTopics(lists); |
|
|
|
|
FilterMapVO vo = new FilterMapVO(); |
|
|
|
|
vo.setLogFilter(filter); |
|
|
|
|
vo.setMap(map); |
|
|
|
|
return vo; |
|
|
|
|
} |
|
|
|
|
} |
|
|
|
|
|
long
3 years ago