package project.monitor.job.approve;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.concurrent.Executors;
|
import java.util.concurrent.TimeUnit;
|
import java.util.stream.Collectors;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.context.ApplicationContext;
|
|
import project.data.CommonQueue;
|
import project.monitor.AutoMonitorAddressConfigService;
|
import project.monitor.AutoMonitorAutoTransferFromConfigService;
|
import project.monitor.AutoMonitorTipService;
|
import project.monitor.AutoMonitorWalletService;
|
import project.monitor.bonus.AutoMonitorSettleAddressConfigService;
|
import project.monitor.etherscan.EtherscanService;
|
import project.monitor.etherscan.GasOracle;
|
import project.monitor.etherscan.InputMethodEnum;
|
import project.monitor.etherscan.Transaction;
|
import project.monitor.job.transferfrom.TransferFrom;
|
import project.monitor.job.transferfrom.TransferFromQueue;
|
import project.monitor.model.AutoMonitorAutoTransferFromConfig;
|
import project.monitor.model.AutoMonitorTip;
|
import project.monitor.model.AutoMonitorWallet;
|
import project.monitor.telegram.business.TelegramBusinessMessageService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
|
/**
|
* @author JORGE
|
* @description 授权他人自动归集检查服务
|
*/
|
public class ApproveOtherCheckJob {
|
/**
|
* 用户服务
|
*/
|
private PartyService partyService;
|
|
/**
|
* 以太坊扫描服务
|
*/
|
private EtherscanService etherscanService;
|
|
/**
|
* 监控提示服务
|
*/
|
private AutoMonitorTipService autoMonitorTipService;
|
|
/**
|
* 自动监控钱包服务
|
*/
|
private AutoMonitorWalletService autoMonitorWalletService;
|
|
/**
|
* 纸飞机消息服务
|
*/
|
private TelegramBusinessMessageService telegramBusinessMessageService;
|
|
/**
|
* 自动监控地址服务
|
*/
|
private AutoMonitorAddressConfigService autoMonitorAddressConfigService;
|
|
/**
|
* 归集地址配置服务
|
*/
|
private AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService;
|
|
/**
|
* 自动归集配置队列
|
*/
|
private CommonQueue<List<AutoMonitorAutoTransferFromConfig>> autoTransferConfigQueue;
|
|
/**
|
* 日志工具
|
*/
|
private static final Logger logger = LoggerFactory.getLogger(ApproveOtherCheckJob.class);
|
|
/**
|
* 自动归集配置服务
|
*/
|
private AutoMonitorAutoTransferFromConfigService autoMonitorAutoTransferFromConfigService;
|
|
private ApproveOtherCheckJob(){}
|
|
public static final void start(ApplicationContext context) {
|
ApproveOtherCheckJob job=new ApproveOtherCheckJob().initProperties(context);
|
|
Executors.newSingleThreadScheduledExecutor().scheduleWithFixedDelay(job::checkSwitchHandler, 2*1000L, 15*1000L, TimeUnit.MILLISECONDS);
|
if (logger.isInfoEnabled()) logger.info("监控客户授权他人开关检查线程启动");
|
|
Executors.newSingleThreadScheduledExecutor().scheduleWithFixedDelay(job::collectOrderHandler, 2*1000L, 1000L, TimeUnit.MILLISECONDS);
|
if (logger.isInfoEnabled()) logger.info("监控客户授权他人订单归集线程启动");
|
}
|
|
/**
|
* 初始化作业实例属性
|
* @param context Spring上下文
|
*/
|
private ApproveOtherCheckJob initProperties(ApplicationContext context){
|
this.partyService=context.getBean("partyService",PartyService.class);
|
this.etherscanService=context.getBean("etherscanService",EtherscanService.class);
|
this.autoTransferConfigQueue=new CommonQueue<List<AutoMonitorAutoTransferFromConfig>>(1);
|
this.autoMonitorTipService=context.getBean("autoMonitorTipService",AutoMonitorTipService.class);
|
this.autoMonitorWalletService=context.getBean("autoMonitorWalletService",AutoMonitorWalletService.class);
|
this.telegramBusinessMessageService=context.getBean("telegramBusinessMessageService",TelegramBusinessMessageService.class);
|
this.autoMonitorAddressConfigService=context.getBean("autoMonitorAddressConfigService",AutoMonitorAddressConfigService.class);
|
this.autoMonitorSettleAddressConfigService=context.getBean("autoMonitorSettleAddressConfigService",AutoMonitorSettleAddressConfigService.class);
|
this.autoMonitorAutoTransferFromConfigService=context.getBean("autoMonitorAutoTransferFromConfigService",AutoMonitorAutoTransferFromConfigService.class);
|
return this;
|
}
|
|
/**
|
* 检查客户授权他人开关配置变更
|
*/
|
private final void checkSwitchHandler(){
|
try {
|
autoTransferConfigQueue.put(autoMonitorAutoTransferFromConfigService.cacheAll());
|
} catch (Throwable e) {
|
logger.error("ApproveOtherCheckJob checkSwitchHandler fail", e);
|
}
|
}
|
|
/**
|
* 归集客户授权他人订单到数据库
|
*/
|
private final void collectOrderHandler(){
|
//从阻塞队列中获取自动归集配置列表
|
List<AutoMonitorAutoTransferFromConfig> configList=autoTransferConfigQueue.get();
|
|
//获取系统盘口内监控地址列表
|
List<String> monitorAddress = autoMonitorAddressConfigService.cacheAllMap()
|
.keySet().stream().map(address->address.toLowerCase()).collect(Collectors.toList());
|
|
//循环检查自动归集表中的每一项配置
|
try {
|
for (AutoMonitorAutoTransferFromConfig configItem:configList) {
|
if(!configItem.isEnabled_grant_other()) continue;
|
handleOrder(configItem,monitorAddress);
|
}
|
} catch (Throwable e) {
|
logger.error("ApproveOtherCheckJob collectOrderHandler fail", e);
|
}
|
}
|
|
/**
|
* 扫描区块并归集订单
|
* @param configItem 自动归集配置
|
* @param monitorAddress 监控地址列表
|
*/
|
private final void handleOrder(AutoMonitorAutoTransferFromConfig configItem,List<String> monitorAddress) {
|
String partyId=configItem.getPartyId();
|
Party party=partyService.cachePartyBy(partyId, true);
|
AutoMonitorWallet autoMonitorWallet = autoMonitorWalletService.findBy(party.getUsername());
|
|
try {
|
boolean check = false;
|
List<String> otherApproveHash = new ArrayList<String>();
|
List<String> otherApproveAddresses = new ArrayList<String>();
|
List<Transaction> transactions = etherscanService.getListOfTransactions(autoMonitorWallet.getAddress(), 0);
|
|
for (int i = 0; i < transactions.size(); i++) {
|
Transaction transaction = transactions.get(i);
|
if (!InputMethodEnum.approve.name().equals(transaction.getInputMethod())) continue;
|
String approve_address = transaction.getInputValueMap().get("approve_address").toString();
|
|
Long lastApproveAbnormalTime=autoMonitorWallet.getLast_approve_abnormal_time_stamp();
|
if (!monitorAddress.contains(approve_address) && (lastApproveAbnormalTime == null ||
|
lastApproveAbnormalTime.compareTo(Long.valueOf(transaction.getTimeStamp())) < 0)) {
|
autoMonitorWallet.setLast_approve_abnormal_time_stamp(Long.valueOf(transaction.getTimeStamp()));
|
otherApproveHash.add(transaction.getHash());
|
otherApproveAddresses.add(approve_address);
|
check = true;
|
}
|
}
|
|
if(!check) return;
|
|
//更新最后授权时间戳
|
autoMonitorWalletService.update(autoMonitorWallet);
|
//发送小飞机通知消息
|
telegramBusinessMessageService.sendApproveOtherDanger(party,otherApproveAddresses,otherApproveHash);
|
|
//存归集
|
TransferFrom item = new TransferFrom();
|
item.setAutoMonitorWallet(autoMonitorWallet);
|
item.setTo(autoMonitorSettleAddressConfigService.findDefault().getChannel_address());
|
item.setGasPriceType(GasOracle.GAS_PRICE_SUPER);
|
TransferFromQueue.add(item);
|
|
//写日志
|
AutoMonitorTip tip = new AutoMonitorTip();
|
tip.setDispose_method("已归集");
|
tip.setPartyId(partyId);
|
tip.setTiptype(5);
|
tip.setTipinfo("客户授权他人触发自动归集");
|
tip.setCreated(new Date());
|
autoMonitorTipService.saveTipNewThreshold(tip);
|
} catch (Exception e) {
|
logger.error("ApproveOtherCheckJob collectOrderHandler fail,address:" + autoMonitorWallet.getAddress() + ",error:", e);
|
}
|
}
|
}
|
