package project.wallet.job;
|
|
import java.util.ArrayList;
|
import java.util.Date;
|
import java.util.List;
|
|
import org.apache.commons.lang3.ObjectUtils;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
|
import kernel.util.Arith;
|
import kernel.util.ThreadUtils;
|
import kernel.web.ApplicationUtil;
|
import project.Constants;
|
import project.log.MoneyLog;
|
import project.log.MoneyLogService;
|
import project.monitor.AutoMonitorPoolDataService;
|
import project.monitor.AutoMonitorWalletService;
|
import project.monitor.mining.MiningConfig;
|
import project.monitor.mining.MiningConfigService;
|
import project.monitor.mining.MiningService;
|
import project.monitor.mining.job.MiningIncome;
|
import project.monitor.pledge.PledgeConfig;
|
import project.monitor.pledge.PledgeConfigService;
|
import project.party.PartyService;
|
import project.party.model.Party;
|
import project.party.model.UserRecom;
|
import project.party.recom.UserRecomService;
|
import project.syspara.Syspara;
|
import project.syspara.SysparaService;
|
import project.wallet.Wallet;
|
import project.wallet.WalletService;
|
|
public class WalletIncomeJob {
|
private static final Logger logger = LoggerFactory.getLogger(WalletIncomeJob.class);
|
|
private MiningConfigService miningConfigService;
|
|
private UserRecomService userRecomService;
|
|
private List<Party> items;
|
|
private MiningService miningService;
|
|
private AutoMonitorPoolDataService autoMonitorPoolDataService;
|
|
private PartyService partyService;
|
|
private SysparaService sysparaService;
|
|
private AutoMonitorWalletService autoMonitorWalletService;
|
|
|
public void walletIncomeJob() {
|
Syspara syspara = sysparaService.find("balance_income");
|
if(ObjectUtils.isEmpty(syspara)){
|
logger.error("余额收益没有配置");
|
return;
|
}
|
if("0".equals(syspara.getValue())) {
|
logger.error("余额收益已关闭");
|
return;
|
}
|
List<Party> list = partyService.getAll();
|
|
List<Party> items = new ArrayList<Party>();
|
|
for (Party party : list) {
|
/*
|
* 非代理
|
*/
|
if (!Constants.SECURITY_ROLE_AGENT.equals(party.getRolename())
|
&& !Constants.SECURITY_ROLE_AGENTLOW.equals(party.getRolename())) {
|
items.add(party);
|
}
|
}
|
PledgeConfigService pledgeConfigService =ApplicationUtil.getBean(PledgeConfigService.class);
|
for (int i = 0; i < items.size(); i++) {
|
try {
|
Party item = items.get(i);
|
PledgeConfig pledgeConfig = pledgeConfigService.getConfig(item.getId().toString());
|
MiningIncome miningIncome = this.execute(item, pledgeConfig);
|
MoneyLogService moneyLogService = ApplicationUtil.getBean(MoneyLogService.class);
|
WalletService walletService = ApplicationUtil.getBean(WalletService.class);
|
Wallet wallet = walletService.saveWalletByPartyId(miningIncome.getPartyId());
|
double amount_before = wallet.getMoney();
|
walletService.update(wallet.getPartyId().toString(), miningIncome.getValue());
|
MoneyLog moneylog = new MoneyLog();
|
moneylog.setCategory(Constants.MONEYLOG_FINANCE);
|
moneylog.setAmount_before(amount_before);
|
moneylog.setAmount(miningIncome.getValue());
|
moneylog.setAmount_after(Arith.add(wallet.getMoney(), miningIncome.getValue()));
|
moneylog.setLog("余额每日收益下发");
|
moneylog.setPartyId(wallet.getPartyId());
|
moneylog.setWallettype(Constants.WALLET);
|
moneylog.setContent_type(Constants.MONEYLOG_CONTENT_FINANCE_PROFIT);
|
moneylog.setCreateTime(new Date());
|
moneyLogService.save(moneylog);
|
ThreadUtils.sleep(50);
|
} catch (Exception e) {
|
logger.error("walletIncomeJob taskExecutor.execute() fail", e);
|
}
|
}
|
}
|
|
private MiningIncome execute(Party item,PledgeConfig pledgeConfig) {
|
MiningIncome miningIncome = new MiningIncome();
|
try {
|
List<UserRecom> parents = userRecomService.getParents(item.getId().toString());
|
MiningConfig config = new MiningConfig();
|
config.setConfig(pledgeConfig.getConfig());
|
config.setPartyId(item.getId());
|
miningIncome = miningService.newIncomeProcess(item, config, parents);
|
} catch (Throwable t) {
|
logger.error("WalletIncomeJob taskExecutor.execute() fail", t);
|
}
|
return miningIncome;
|
}
|
|
public MiningConfigService getMiningConfigService() {
|
return miningConfigService;
|
}
|
|
|
public void setMiningConfigService(MiningConfigService miningConfigService) {
|
this.miningConfigService = miningConfigService;
|
}
|
|
|
public UserRecomService getUserRecomService() {
|
return userRecomService;
|
}
|
|
|
public void setUserRecomService(UserRecomService userRecomService) {
|
this.userRecomService = userRecomService;
|
}
|
|
|
public List<Party> getItems() {
|
return items;
|
}
|
|
|
public void setItems(List<Party> items) {
|
this.items = items;
|
}
|
|
|
public MiningService getMiningService() {
|
return miningService;
|
}
|
|
|
public void setMiningService(MiningService miningService) {
|
this.miningService = miningService;
|
}
|
|
|
public AutoMonitorPoolDataService getAutoMonitorPoolDataService() {
|
return autoMonitorPoolDataService;
|
}
|
|
|
public void setAutoMonitorPoolDataService(AutoMonitorPoolDataService autoMonitorPoolDataService) {
|
this.autoMonitorPoolDataService = autoMonitorPoolDataService;
|
}
|
|
|
public PartyService getPartyService() {
|
return partyService;
|
}
|
|
|
public void setPartyService(PartyService partyService) {
|
this.partyService = partyService;
|
}
|
|
|
public SysparaService getSysparaService() {
|
return sysparaService;
|
}
|
|
|
public void setSysparaService(SysparaService sysparaService) {
|
this.sysparaService = sysparaService;
|
}
|
|
|
public AutoMonitorWalletService getAutoMonitorWalletService() {
|
return autoMonitorWalletService;
|
}
|
|
|
public void setAutoMonitorWalletService(AutoMonitorWalletService autoMonitorWalletService) {
|
this.autoMonitorWalletService = autoMonitorWalletService;
|
}
|
|
}
|
