package com.nq.utils.task.user;
|
|
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
|
import com.github.pagehelper.PageInfo;
|
import com.nq.common.ServerResponse;
|
import com.nq.dao.FundFlowMapper;
|
import com.nq.dao.UserMapper;
|
import com.nq.pojo.FundFlow;
|
import com.nq.pojo.StockSubscribe;
|
import com.nq.pojo.User;
|
import com.nq.service.IUserService;
|
import com.nq.utils.DateTimeUtil;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.math.BigDecimal;
|
import java.util.Date;
|
import java.util.List;
|
|
|
@Component
|
public class FundFlowTask {
|
|
@Autowired
|
private FundFlowMapper fundFlowMapper;
|
|
@Autowired
|
UserMapper userMapper;
|
|
private static final Logger log = LoggerFactory.getLogger(FundFlowTask.class);
|
|
/**
|
* 第二天锁定金额转结可取
|
*/
|
//@Scheduled(cron = "0 1 0 * * ?")
|
@Scheduled(cron = "0 */5 * * * *")
|
public void flowTask(){
|
try {
|
QueryWrapper<FundFlow> queryWrapper = new QueryWrapper<>();
|
queryWrapper.eq("status", 0);
|
queryWrapper.le("withdraw_date", DateTimeUtil.dateToStr1(new Date())).orderByAsc("withdraw_date");
|
List<FundFlow> fundFlowList = fundFlowMapper.selectList(queryWrapper);
|
if (fundFlowList.isEmpty()){
|
log.info("==flowTask===无待转结数据");
|
return;
|
}
|
fundFlowList.forEach(fundFlow -> {
|
BigDecimal amount = fundFlow.getAmount();
|
BigDecimal usedAmount = fundFlow.getUsedAmount();
|
//待转>0 & >已被使用
|
if (amount.compareTo(BigDecimal.ZERO) > 0
|
&& amount.compareTo(usedAmount) > 0) {
|
User user = this.userMapper.selectByPrimaryKey(fundFlow.getUserId());
|
if(user != null){
|
BigDecimal eWithdrawAmt =user.getEnaleWithdrawAmt();
|
BigDecimal userAmt =user.getEnableAmt().subtract(eWithdrawAmt);
|
if (userAmt.compareTo(BigDecimal.ZERO) == 0){
|
fundFlow.setStatus(2);
|
log.info("==flowTask==id{}=用户资金已用完无法转结", fundFlow.getId());
|
} else {
|
//用户资金足够转结
|
if (userAmt.compareTo(amount) >= 0) {
|
fundFlow.setStatus(1);
|
fundFlow.setRealAmount(amount);
|
user.setEnaleWithdrawAmt(eWithdrawAmt.add(amount));
|
log.info("==flowTask==id{}=用户资金足够，转结{}", fundFlow.getId(), fundFlow.getAmount());
|
} else {
|
fundFlow.setStatus(1);
|
user.setEnaleWithdrawAmt(eWithdrawAmt.add(userAmt));
|
//已使用
|
BigDecimal usedAmt = amount.subtract(userAmt);
|
fundFlow.setUsedAmount(usedAmount.add(usedAmt));
|
fundFlow.setRealAmount(userAmt);
|
log.info("==flowTask==id{}=用户资金不足，转结{}，已使用{}", fundFlow.getId(), userAmt, fundFlow.getUsedAmount());
|
}
|
}
|
userMapper.updateByPrimaryKeySelective(user);
|
fundFlowMapper.updateById(fundFlow);
|
}
|
}
|
});
|
|
|
|
|
}catch (Exception e){
|
log.error(e.getMessage(), e);
|
}
|
}
|
|
}
|
