package project.data;
|
|
import java.util.HashMap;
|
import java.util.List;
|
import java.util.Map;
|
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import kernel.exception.BusinessException;
|
import kernel.util.Arith;
|
import kernel.util.ThreadUtils;
|
import project.Constants;
|
import project.contract.ContractApplyOrder;
|
import project.contract.ContractApplyOrderService;
|
import project.contract.ContractOrder;
|
import project.contract.ContractOrderService;
|
import project.data.model.Realtime;
|
import project.exchange.ExchangeApplyOrder;
|
import project.exchange.ExchangeApplyOrderService;
|
import project.finance.FinanceOrder;
|
import project.finance.FinanceOrderService;
|
import project.futures.FuturesOrder;
|
import project.futures.FuturesOrderService;
|
import project.miner.MinerOrderService;
|
import project.miner.model.MinerOrder;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.wallet.Wallet;
|
import project.wallet.WalletExtend;
|
import project.wallet.WalletService;
|
|
/**
|
* 每日定时清除当日提现限额
|
*
|
* @author User
|
*
|
*/
|
public class WithdrawLimitAmountr1DayJob {
|
|
private static final Logger logger = LoggerFactory.getLogger(WithdrawLimitAmountr1DayJob.class);
|
|
private PartyService partyService;
|
|
private WalletService walletService;
|
private FinanceOrderService financeOrderService;
|
private MinerOrderService minerOrderService;
|
private ContractApplyOrderService contractApplyOrderService;
|
private ContractOrderService contractOrderService;
|
private FuturesOrderService futuresOrderService;
|
private ExchangeApplyOrderService exchangeApplyOrderService;
|
private DataService dataService;
|
|
public void taskJob() {
|
|
try {
|
List<Party> partys = partyService.getAll();
|
Map<String, Double> party_amount = new HashMap<String, Double>();
|
/**
|
* 理财资产
|
*/
|
List<FinanceOrder> financeOrders = financeOrderService.getAllStateBy_1();
|
if (financeOrders != null) {
|
for (FinanceOrder financeOrder : financeOrders) {
|
Double amount = party_amount.get(financeOrder.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
party_amount.put(financeOrder.getPartyId().toString(), Arith.add(amount, financeOrder.getAmount()));
|
}
|
}
|
/**
|
* 矿机资产
|
*/
|
// List<MinerOrder> minerOrders = minerOrderService.getAllStateBy_1();
|
List<MinerOrder> minerOrders = minerOrderService.findByState(null, "1");
|
if (minerOrders != null) {
|
for (MinerOrder minerOrder : minerOrders) {
|
Double amount = party_amount.get(minerOrder.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
party_amount.put(minerOrder.getPartyId().toString(), Arith.add(amount, minerOrder.getAmount()));
|
}
|
}
|
/**
|
* 所有限价 永续委托单
|
*/
|
List<ContractApplyOrder> contractApplyOrders = this.contractApplyOrderService.findSubmitted();
|
if (contractApplyOrders != null) {
|
for (ContractApplyOrder contractApplyOrder : contractApplyOrders) {
|
Double amount = party_amount.get(contractApplyOrder.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
party_amount.put(contractApplyOrder.getPartyId().toString(), Arith.add(amount,
|
Arith.mul(contractApplyOrder.getVolume_open(), contractApplyOrder.getUnit_amount())));
|
}
|
}
|
/**
|
* 永续合约资产，持仓单
|
*/
|
List<ContractOrder> contractOrders = contractOrderService.findSubmitted();
|
if (contractOrders != null) {
|
for (ContractOrder contractOrder : contractOrders) {
|
Double amount = party_amount.get(contractOrder.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
party_amount.put(contractOrder.getPartyId().toString(), Arith.add(amount,
|
Arith.mul(contractOrder.getVolume_open(), contractOrder.getUnit_amount())));
|
}
|
}
|
/**
|
* 交割合约资产---------------------->
|
*/
|
List<FuturesOrder> futuresOrders = futuresOrderService.cacheSubmitted();
|
if (futuresOrders != null) {
|
for (FuturesOrder futuresOrder : futuresOrders) {
|
Double amount = party_amount.get(futuresOrder.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
party_amount.put(futuresOrder.getPartyId().toString(), Arith.add(amount, futuresOrder.getVolume()));
|
}
|
}
|
/**
|
* 币币交易限价单
|
*/
|
List<ExchangeApplyOrder> exchangeApplyOrders = exchangeApplyOrderService.findSubmitted();
|
if (exchangeApplyOrders != null) {
|
for (ExchangeApplyOrder exchangeApplyOrder : exchangeApplyOrders) {
|
Double amount = party_amount.get(exchangeApplyOrder.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
if ("open".equals(exchangeApplyOrder.getOffset())) {
|
party_amount.put(exchangeApplyOrder.getPartyId().toString(),
|
Arith.add(amount, exchangeApplyOrder.getVolume()));
|
}
|
if ("close".equals(exchangeApplyOrder.getOffset())) {
|
List<Realtime> realtime_list = this.dataService.realtime(exchangeApplyOrder.getSymbol());
|
Realtime realtime = null;
|
if (realtime_list.size() > 0) {
|
realtime = realtime_list.get(0);
|
} else {
|
throw new BusinessException("系统错误，请稍后重试");
|
}
|
party_amount.put(exchangeApplyOrder.getPartyId().toString(),
|
Arith.add(amount, Arith.mul(exchangeApplyOrder.getVolume(), realtime.getClose())));
|
}
|
|
}
|
}
|
/**
|
* usdt资产
|
*/
|
List<Wallet> wallets = walletService.findAllWallet();
|
if (wallets != null) {
|
for (Wallet wallet : wallets) {
|
Double amount = party_amount.get(wallet.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
if (amount != 0 || wallet.getMoney() != 0) {
|
party_amount.put(wallet.getPartyId().toString(), Arith.add(amount, wallet.getMoney()));
|
}
|
|
}
|
}
|
/**
|
* 各类币种资产
|
*/
|
List<WalletExtend> walletExtends = walletService.findAllWalletExtend();
|
if (walletExtends != null) {
|
for (WalletExtend walletExtend : walletExtends) {
|
if("".equals(walletExtend.getWallettype()) || walletExtend.getWallettype() == null){
|
continue;
|
}
|
|
if (Constants.WALLETEXTEND_DAPP_USDT_USER.equals(walletExtend.getWallettype())
|
|| Constants.WALLETEXTEND_DAPP_ETH_USER.equals(walletExtend.getWallettype())
|
|| Constants.WALLETEXTEND_DAPP_ETH.equals(walletExtend.getWallettype())
|
|| Constants.WALLETEXTEND_EXPERIENCE_GOLD.equals(walletExtend.getWallettype())
|
|| Constants.WALLETEXTEND_DAPP_USDT.equals(walletExtend.getWallettype())) {
|
continue;
|
}
|
|
Double amount = party_amount.get(walletExtend.getPartyId().toString());
|
if (amount == null) {
|
amount = 0D;
|
}
|
if (amount != 0 || walletExtend.getAmount() != 0) {
|
List<Realtime> realtime_list = this.dataService.realtime(walletExtend.getWallettype());
|
Realtime realtime = null;
|
if (realtime_list.size() > 0) {
|
realtime = realtime_list.get(0);
|
} else {
|
throw new BusinessException("系统错误，请稍后重试");
|
}
|
|
party_amount.put(walletExtend.getPartyId().toString(),
|
Arith.add(amount, Arith.mul(realtime.getClose(), walletExtend.getAmount())));
|
}
|
}
|
}
|
for (int i = 0; i < partys.size(); i++) {
|
Party party = partys.get(i);
|
Double withdraw_limit_amount = party_amount.get(party.getId().toString());
|
if ((withdraw_limit_amount == null || withdraw_limit_amount == 0D)
|
&& party.getWithdraw_limit_amount() != 0) {
|
party.setWithdraw_limit_amount(0);
|
partyService.update(party);
|
}
|
if (withdraw_limit_amount != null) {
|
party.setWithdraw_limit_amount(withdraw_limit_amount);
|
partyService.update(party);
|
}
|
}
|
|
} catch (Throwable e) {
|
logger.error("WithdrawLimit run fail", e);
|
} finally {
|
/**
|
* 暂停0.1秒
|
*/
|
ThreadUtils.sleep(1000);
|
}
|
|
}
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
public void setWalletService(WalletService walletService) {
|
this.walletService = walletService;
|
}
|
|
public void setMinerOrderService(MinerOrderService minerOrderService) {
|
this.minerOrderService = minerOrderService;
|
}
|
|
public void setContractApplyOrderService(ContractApplyOrderService contractApplyOrderService) {
|
this.contractApplyOrderService = contractApplyOrderService;
|
}
|
|
public void setContractOrderService(ContractOrderService contractOrderService) {
|
this.contractOrderService = contractOrderService;
|
}
|
|
public void setFuturesOrderService(FuturesOrderService futuresOrderService) {
|
this.futuresOrderService = futuresOrderService;
|
}
|
|
public void setExchangeApplyOrderService(ExchangeApplyOrderService exchangeApplyOrderService) {
|
this.exchangeApplyOrderService = exchangeApplyOrderService;
|
}
|
|
public void setDataService(DataService dataService) {
|
this.dataService = dataService;
|
}
|
|
public void setFinanceOrderService(FinanceOrderService financeOrderService) {
|
this.financeOrderService = financeOrderService;
|
}
|
|
}
|
