package com.gear.swx.task;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.gear.common.constant.SwxConstons;
|
import com.gear.swx.domain.SwxLoanRecord;
|
import com.gear.swx.domain.SwxMoneyLog;
|
import com.gear.swx.domain.SwxSmartOrder;
|
import com.gear.swx.domain.SwxUser;
|
import com.gear.swx.service.ISwxLoanRecordService;
|
import com.gear.swx.service.ISwxMoneyLogService;
|
import com.gear.swx.service.ISwxSmartOrderService;
|
import com.gear.swx.service.ISwxUserService;
|
import lombok.extern.slf4j.Slf4j;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
import org.springframework.util.CollectionUtils;
|
|
import java.math.BigDecimal;
|
import java.text.ParseException;
|
import java.text.SimpleDateFormat;
|
import java.util.Calendar;
|
import java.util.Date;
|
import java.util.List;
|
import java.util.Queue;
|
|
/**
|
* 计息定时任务
|
*/
|
@Component("BearingTask")
|
//@Slf4j
|
@Transactional
|
public class BearingTask {
|
private static final Logger lg = LoggerFactory.getLogger("taskFile");
|
@Autowired
|
private ISwxLoanRecordService swxLoanRecordService;
|
|
@Autowired
|
private ISwxUserService swxUserService;
|
|
@Autowired
|
private ISwxMoneyLogService swxMoneyLogService;
|
|
@Autowired
|
private ISwxSmartOrderService swxSmartOrderService;
|
|
/**利润补偿，防止分润时出现错误。以至于数据状态停滞*/
|
public void profitCompensate() {
|
List<SwxSmartOrder> profitCompensateList = swxSmartOrderService.getProfitCompensateList();
|
updateProfit(profitCompensateList, null);
|
lg.info("利润补偿,补偿{}条", profitCompensateList.size());
|
}
|
|
/**分润和贷款*/
|
public void BearingTask() throws ParseException {
|
Date date = new Date();
|
SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:00");
|
String dateM = dateFormat.format(date);
|
System.out.println("当前时间："+dateM);
|
QueryWrapper<SwxLoanRecord> loanQuery = new QueryWrapper<>();
|
loanQuery.lambda().eq(SwxLoanRecord::getStatus, SwxConstons.SWX_EXAMINE_STATUS_YES);
|
loanQuery.lambda().eq(SwxLoanRecord::getNextInterstTime,dateM);
|
List<SwxLoanRecord> loanList = swxLoanRecordService.list(loanQuery);
|
if (!CollectionUtils.isEmpty(loanList)){
|
for (SwxLoanRecord item : loanList){
|
//本次利息
|
BigDecimal interest = item.getAmount().multiply(item.getRete()).divide(new BigDecimal(100));
|
//计算当前总利息
|
item.setCurrentInterest(item.getCurrentInterest().add(interest));
|
//如果当前时间大于等于还款日期，那么进行还款，并将状态改为已完成
|
if (compareDates(date,dateFormat.parse(item.getMaturityDate())) >= 0){
|
item.setStatus(SwxConstons.SWX_EXAMINE_STATUS_NO);
|
SwxUser swxUser = swxUserService.getById(item.getUserId());
|
if(swxUser != null){
|
//插入资金日志
|
SwxMoneyLog moneyLog = new SwxMoneyLog();
|
moneyLog.setInfo("用户贷款编号"+item.getId()+"进行还款，本金为："+item.getAmount()+"利息为:"+item.getInterest());
|
moneyLog.setStatus(SwxConstons.SWX_EXAMINE_STATUS_YES);
|
moneyLog.setType(SwxConstons.SWX_MONEY_LOG_TYPE_LOAN_REPAY);
|
moneyLog.setSymbol(SwxConstons.SWX_MONEY_TYPE_PAY);
|
moneyLog.setTitle("贷款还款");
|
moneyLog.setOldAmount(swxUser.getAmount());
|
//修改用户资金
|
swxUser.setAmount(swxUser.getAmount().subtract(item.getAmount()).subtract(item.getInterest()));
|
//到期之后清除用户贷款金额
|
swxUser.setLoanAmount(swxUser.getLoanAmount().subtract(item.getAmount()));
|
swxUserService.updateById(swxUser);
|
moneyLog.setNowAmount(swxUser.getAmount());
|
moneyLog.setUserId(swxUser.getId());
|
moneyLog.setBusiId(item.getId());
|
moneyLog.setMoney(item.getAmount());
|
swxMoneyLogService.save(moneyLog);
|
}
|
}else{
|
//更新下次计息时间
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(date);
|
calendar.add(Calendar.DAY_OF_MONTH, 1);
|
item.setNextInterstTime(dateFormat.format(calendar.getTime()));
|
}
|
swxLoanRecordService.updateById(item);
|
}
|
}
|
/* ==============================智能交易订单分润======================================== */
|
//获取下次返利时间为此时的智能交易对象
|
QueryWrapper<SwxSmartOrder> smartQuery = new QueryWrapper<>();
|
smartQuery.lambda().eq(SwxSmartOrder::getStatus, 0);
|
smartQuery.lambda().eq(SwxSmartOrder::getNextProfitTime,dateM);
|
List<SwxSmartOrder> smartList = swxSmartOrderService.list(smartQuery);
|
|
updateProfit(smartList, dateFormat);
|
|
}
|
|
|
public int compareDates(Date date1, Date date2) {
|
if(date1.before(date2)) {
|
return -1;
|
} else if(date1.after(date2)) {
|
return 1;
|
} else {
|
return 0;
|
}
|
}
|
|
/**更新智能交易订单收益*/
|
public void updateProfit(List<SwxSmartOrder> smartList, SimpleDateFormat dateFormat){
|
if (CollectionUtils.isEmpty(smartList)) return;
|
|
if (dateFormat == null) {
|
dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:00");
|
}
|
for (SwxSmartOrder item : smartList){
|
//计算本期利润
|
BigDecimal rateAll = item.getRate().add(item.getAddRate());
|
BigDecimal profit = item.getAmount().multiply(rateAll).divide(new BigDecimal(100)).setScale(2,BigDecimal.ROUND_HALF_UP);
|
item.setAllProfit(item.getAllProfit().add(profit));
|
item.setCurrentDay(item.getCurrentDay()+1);
|
SwxUser swxUser = swxUserService.getById(item.getUserId());
|
if(swxUser != null){
|
if (item.getProfitType()!=null && item.getProfitType()==1){
|
updateProfitDay(swxUser, item, dateFormat, profit);
|
}else {
|
updateProfitCycle(swxUser, item, dateFormat);
|
}
|
}else{
|
//如果没找到对应用户，则终止该交易
|
item.setStatus(1);
|
}
|
lg.info("智能交易订单分润，用户：{},本次收益={}，余额={}，总利润={}",item.getUserId(), profit, item.getAmount(), item.getAllProfit());
|
swxSmartOrderService.updateById(item);
|
}
|
}
|
|
/**周期*/
|
private void updateProfitCycle(SwxUser swxUser, SwxSmartOrder smartOrder, SimpleDateFormat dateFormat){
|
//判断当前收益天数是否已满
|
if(smartOrder.getAllDay() <= smartOrder.getCurrentDay()){
|
//收益满的话，就将钱返回给用户，并重置状态
|
smartOrder.setStatus(1);
|
SwxMoneyLog moneyLog = new SwxMoneyLog();
|
moneyLog.setInfo("用户购买产品"+smartOrder.getId()+"收益完成，本金为："+smartOrder.getAmount()+"利润为:"+smartOrder.getAllProfit());
|
moneyLog.setStatus(SwxConstons.SWX_EXAMINE_STATUS_YES);
|
moneyLog.setType(SwxConstons.SWX_MONEY_LOG_TYPE_SMART_PROFIT);
|
moneyLog.setSymbol(SwxConstons.SWX_MONEY_TYPE_INCOME);
|
moneyLog.setTitle("智能交易周期收益");
|
moneyLog.setOldAmount(swxUser.getAmount());
|
//修改用户资金
|
swxUser.setAmount(swxUser.getAmount().add(smartOrder.getAmount()).add(smartOrder.getAllProfit()));
|
swxUser.setProfit(swxUser.getProfit().add(smartOrder.getAllProfit()));
|
moneyLog.setNowAmount(swxUser.getAmount());
|
moneyLog.setUserId(swxUser.getId());
|
moneyLog.setBusiId(smartOrder.getId());
|
moneyLog.setMoney(smartOrder.getAmount());
|
swxMoneyLogService.save(moneyLog);
|
}else{
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.add(Calendar.DAY_OF_MONTH, 1);
|
smartOrder.setNextProfitTime(dateFormat.format(calendar.getTime()));
|
}
|
swxUserService.updateById(swxUser);
|
}
|
|
/**每日*/
|
private void updateProfitDay(SwxUser swxUser, SwxSmartOrder smartOrder, SimpleDateFormat dateFormat, BigDecimal profit){
|
SwxMoneyLog moneyLog = new SwxMoneyLog();
|
moneyLog.setStatus(SwxConstons.SWX_EXAMINE_STATUS_YES);
|
moneyLog.setSymbol(SwxConstons.SWX_MONEY_TYPE_INCOME);
|
moneyLog.setTitle("智能交易日收益");
|
moneyLog.setOldAmount(swxUser.getAmount());
|
swxUser.setProfit(swxUser.getProfit().add(profit));
|
moneyLog.setNowAmount(swxUser.getAmount());
|
moneyLog.setUserId(swxUser.getId());
|
moneyLog.setBusiId(smartOrder.getId());
|
moneyLog.setMoney(smartOrder.getAmount());
|
|
//判断当前收益天数是否已满
|
if(smartOrder.getAllDay() <= smartOrder.getCurrentDay()){
|
//收益满的话，就将钱返回给用户，并重置状态
|
smartOrder.setStatus(1);
|
moneyLog.setType(SwxConstons.SWX_MONEY_LOG_TYPE_SMART_PROFIT);
|
moneyLog.setInfo("用户购买产品"+smartOrder.getId()+"收益完成，本金为："+smartOrder.getAmount()+"收到每日收益："+profit+"总利润为:"+smartOrder.getAllProfit());
|
swxUser.setAmount(swxUser.getAmount().add(smartOrder.getAmount()).add(profit));
|
}else{
|
moneyLog.setType(SwxConstons.SWX_MONEY_LOG_TYPE_SMART_DAY_PROFIT);
|
moneyLog.setInfo("用户购买产品"+smartOrder.getId()+"收到每日收益:"+profit);
|
swxUser.setAmount(swxUser.getAmount().add(profit));
|
Calendar calendar = Calendar.getInstance();
|
calendar.setTime(new Date());
|
calendar.add(Calendar.DAY_OF_MONTH, 1);
|
smartOrder.setNextProfitTime(dateFormat.format(calendar.getTime()));
|
}
|
|
swxMoneyLogService.save(moneyLog);
|
swxUserService.updateById(swxUser);
|
}
|
}
|
