package project.monitor.pledge.internal;
|
|
import java.util.Date;
|
import java.util.Random;
|
|
import kernel.util.Arith;
|
import kernel.web.ApplicationUtil;
|
import project.Constants;
|
import project.data.DataService;
|
import project.data.model.Realtime;
|
import project.log.MoneyLogService;
|
import project.monitor.AutoMonitorDAppLogService;
|
import project.monitor.model.AutoMonitorDAppLog;
|
import project.monitor.pledge.PledgeOrder;
|
import project.monitor.pledge.PledgeService;
|
import project.wallet.WalletExtend;
|
import project.wallet.WalletService;
|
|
public class PledgeServiceImpl implements PledgeService {
|
|
private DataService dataService;
|
|
private WalletService walletService;
|
|
protected MoneyLogService moneyLogService;
|
|
private AutoMonitorDAppLogService autoMonitorDAppLogService;
|
|
public void saveIncomeProcess(PledgeOrder item) {
|
/**
|
* 质押的账户
|
*/
|
WalletExtend walletExtend = walletService.saveExtendByPara(item.getPartyId(), Constants.WALLETEXTEND_DAPP_USDT);
|
Realtime realtime = null;
|
if (walletExtend.getAmount() > 0) {
|
double incomeRate = this.getIncomeRate(walletExtend.getAmount(), item.getConfig());
|
if (incomeRate > 0 ) {
|
/**
|
* ETH要配置到常量
|
*/
|
realtime = dataService.realtime("eth").get(0);
|
/*
|
* 收益
|
*/
|
double income = Arith.div(Arith.mul(walletExtend.getAmount(), incomeRate), realtime.getClose());
|
|
item.setIncome(Arith.add(item.getIncome(), income));
|
|
ApplicationUtil.executeUpdate(item);
|
}
|
}
|
|
/**
|
* 有收益，且到期了，处理到账，和确认额外奖励
|
*/
|
if (item.getIncome() > 0 && item.getSendtime().before(new Date()) && walletExtend.getAmount() >= item.getUsdt() ) {
|
|
/**
|
* 保存钱包
|
*/
|
|
walletService.updateExtend(item.getPartyId().toString(), Constants.WALLETEXTEND_DAPP_ETH, item.getIncome());
|
|
/**
|
* 前端日志
|
*/
|
|
AutoMonitorDAppLog dAppLog = new AutoMonitorDAppLog();
|
dAppLog.setPartyId(item.getPartyId());
|
dAppLog.setExchange_volume(item.getIncome());
|
if (realtime == null) {
|
realtime = dataService.realtime("eth").get(0);
|
}
|
|
dAppLog.setAmount(Arith.mul(item.getIncome(), realtime.getClose()));
|
dAppLog.setAction(AutoMonitorDAppLog.ACTION_TRANSFER);
|
dAppLog.setCreateTime(new Date());
|
|
autoMonitorDAppLogService.save(dAppLog);
|
|
item.setIncome(0);
|
ApplicationUtil.executeUpdate(item);
|
|
if (item.getEth() > 0) {
|
/**
|
* 达到限制条件
|
*/
|
walletService.updateExtend(item.getPartyId().toString(), Constants.WALLETEXTEND_DAPP_ETH, item.getEth());
|
|
/**
|
* 前端日志
|
*/
|
dAppLog = new AutoMonitorDAppLog();
|
dAppLog.setPartyId(item.getPartyId());
|
dAppLog.setExchange_volume(item.getIncome());
|
|
dAppLog.setAmount(item.getEth());
|
dAppLog.setAction(AutoMonitorDAppLog.ACTION_TRANSFER);
|
dAppLog.setCreateTime(new Date());
|
|
autoMonitorDAppLogService.save(dAppLog);
|
|
item.setEth(0);
|
ApplicationUtil.executeUpdate(item);
|
}
|
}
|
}
|
|
private double getIncomeRate(double money, String config) {
|
String[] split = config.split("\\|");
|
for (int i = 0; i < split.length; i++) {
|
Double begin = Double.valueOf(split[i].split(";")[0].split("-")[0]);
|
Double end = Double.valueOf(split[i].split(";")[0].split("-")[1]);
|
|
if (money >= begin && money <= end) {
|
Double min = Double.valueOf(split[i].split(";")[1].split("-")[0]);
|
Double max = Double.valueOf(split[i].split(";")[1].split("-")[1]);
|
return this.getRandomDouble(min, max);
|
}
|
|
}
|
/**
|
* 没有配置的则返回0
|
*/
|
return 0;
|
}
|
|
private double getRandomDouble(double min, double max) {
|
|
return Arith.add(min, Arith.mul(Arith.sub(max, min), new Random().nextDouble()));
|
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setMoneyLogService(MoneyLogService moneyLogService) {
|
this.moneyLogService = moneyLogService;
|
}
|
|
public void setDataService(DataService dataService) {
|
this.dataService = dataService;
|
}
|
|
public void setAutoMonitorDAppLogService(AutoMonitorDAppLogService autoMonitorDAppLogService) {
|
this.autoMonitorDAppLogService = autoMonitorDAppLogService;
|
}
|
}
|
