package cc.mrbird.febs.mall.quartz;
|
|
import cc.mrbird.febs.common.enumerates.*;
|
import cc.mrbird.febs.mall.entity.*;
|
import cc.mrbird.febs.mall.mapper.DataDictionaryCustomMapper;
|
import cc.mrbird.febs.mall.mapper.MallMemberMapper;
|
import cc.mrbird.febs.mall.mapper.MallMemberStarBuyMapper;
|
import cc.mrbird.febs.mall.mapper.MallOrderInfoMapper;
|
import cc.mrbird.febs.mall.service.IApiMallMemberWalletService;
|
import cc.mrbird.febs.mall.service.IMallMoneyFlowService;
|
import cn.hutool.core.collection.CollUtil;
|
import cn.hutool.core.date.DateUnit;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.core.util.ObjectUtil;
|
import cn.hutool.json.JSONObject;
|
import cn.hutool.json.JSONUtil;
|
import lombok.extern.slf4j.Slf4j;
|
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;
|
|
/**
|
* @author wzy
|
* @date 2021-09-25
|
**/
|
@Slf4j
|
@Component
|
public class OrderOvertimeJob {
|
|
@Autowired
|
private MallOrderInfoMapper orderInfoMapper;
|
|
@Autowired
|
private MallMemberMapper mallMemberMapper;
|
|
@Autowired
|
private DataDictionaryCustomMapper dataDictionaryCustomMapper;
|
|
@Autowired
|
private MallMemberStarBuyMapper mallMemberStarBuyMapper;
|
|
@Autowired
|
private IApiMallMemberWalletService memberWalletService;
|
|
@Autowired
|
private IMallMoneyFlowService mallMoneyFlowService;
|
|
@Scheduled(cron = "0 0/5 * * * ? ")
|
public void overtimeJob() {
|
log.info("订单超时任务执行");
|
List<MallOrderInfo> orderList = orderInfoMapper.selectOrderInfoByStatus(OrderStatusEnum.WAIT_PAY.getValue());
|
if (CollUtil.isNotEmpty(orderList)) {
|
for (MallOrderInfo orderInfo : orderList) {
|
long subTime = DateUtil.between(orderInfo.getOrderTime(), new Date(), DateUnit.MINUTE, false);
|
|
if (subTime > 15) {
|
orderInfo.setStatus(OrderStatusEnum.CANCEL.getValue());
|
orderInfo.setCancelType(MallOrderInfo.CANCEL_OVERTIME_NO_PAY);
|
orderInfoMapper.updateById(orderInfo);
|
}
|
}
|
}
|
|
}
|
|
@Scheduled(cron = "0 0 2 * * ? ")
|
public void returnBuyStarAmount(){
|
log.info("会员星级保证金返还任务执行");
|
/**
|
* 1、生效中的记录
|
* 2、判断剩余返还金额
|
* 3、生成流水记录
|
* 4、增加用户金额
|
*/
|
//生效中记录
|
List<MallMemberStarBuy> mallMemberStarBuys = mallMemberStarBuyMapper.selectByStatus(1);
|
if(CollUtil.isEmpty(mallMemberStarBuys)){
|
return;
|
}
|
for(MallMemberStarBuy mallMemberStarBuy : mallMemberStarBuys){
|
Long memberId = mallMemberStarBuy.getMemberId();
|
MallMember mallMember = mallMemberMapper.selectById(memberId);
|
//用户不存在跳出本次循环
|
if(ObjectUtil.isEmpty(mallMember)){
|
continue;
|
}
|
//返还总金额
|
BigDecimal amount = mallMemberStarBuy.getAmount();
|
//剩余返还总金额不足，跳出本次循环
|
BigDecimal avaAmount = mallMemberStarBuy.getAvaAmount();
|
if(avaAmount.compareTo(BigDecimal.ZERO) <= 0){
|
continue;
|
}
|
//每次返还比例
|
DataDictionaryCustom returnPercentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
|
DataDictionaryEnum.RETURN_PERCENT.getType(),
|
DataDictionaryEnum.RETURN_PERCENT.getCode()
|
);
|
String returnPercentStr = returnPercentDic.getValue();
|
BigDecimal returnPercent = new BigDecimal(returnPercentStr).multiply(new BigDecimal(0.01)).setScale(2,BigDecimal.ROUND_DOWN);
|
//本次返还金额
|
BigDecimal returnAmount = amount.multiply(returnPercent).setScale(2,BigDecimal.ROUND_DOWN);
|
/**
|
* 如果本次返还金额大于剩余返还总金额
|
*/
|
if(returnAmount.compareTo(avaAmount) >= 0){
|
returnAmount = avaAmount;
|
avaAmount = BigDecimal.ZERO;
|
}else{
|
avaAmount = avaAmount.subtract(returnAmount).setScale(2,BigDecimal.ROUND_DOWN);
|
}
|
//增加用户金额
|
memberWalletService.addBalance(returnAmount,mallMember.getId());
|
//生成流水记录
|
Long subsidyAmountFlowId = mallMoneyFlowService.addMoneyFlow(
|
mallMember.getId(),
|
mallMemberStarBuy.getBuyCode(),
|
returnAmount,
|
MallMoneyFlowTypeEnum.RETURN_MARKET_STAR.getCode(),
|
MallMoneyFlow.STATUS_SUCCESS,
|
MallMoneyFlow.IS_RETURN_Y,
|
mallMember.getId(),
|
FlowTypeEnum.BALANCE.getValue(),
|
MallMoneyFlowTypeEnum.RETURN_MARKET_STAR.getName()
|
);
|
//更新记录
|
mallMemberStarBuyMapper.updateAvaAmountById(avaAmount,mallMemberStarBuy.getId());
|
}
|
}
|
|
@Scheduled(cron = "0 30 2 * * ? ")
|
public void updateMemberAccountLevelAndBuyStarRecord(){
|
log.info("会员星级更新任务执行");
|
//生效中的记录
|
List<MallMemberStarBuy> mallMemberStarBuys = mallMemberStarBuyMapper.selectByStatus(1);
|
if(CollUtil.isEmpty(mallMemberStarBuys)){
|
return;
|
}
|
for(MallMemberStarBuy mallMemberStarBuy : mallMemberStarBuys){
|
Long memberId = mallMemberStarBuy.getMemberId();
|
MallMember mallMember = mallMemberMapper.selectById(memberId);
|
//用户不存在跳出本次循环
|
if(ObjectUtil.isEmpty(mallMember)){
|
continue;
|
}
|
BigDecimal avaAmount = mallMemberStarBuy.getAvaAmount();
|
/**
|
* 剩余返还总金额等于零，更新为已结束
|
* 判断用户是否还有其他的购买星级的生效记录
|
*/
|
if(BigDecimal.ZERO.compareTo(avaAmount) >= 0){
|
mallMemberStarBuyMapper.updateStatusById(2,mallMemberStarBuy.getId());
|
List<MallMemberStarBuy> mallMemberStarBuysIng = mallMemberStarBuyMapper.selectByStatusAndMemberId(1,memberId);
|
//如果没有其他生效中的记录，则更新用户的星级为普通,更新会员代理等级为代理
|
if(CollUtil.isEmpty(mallMemberStarBuysIng)){
|
mallMemberMapper.updateAccountLevelById(MemberAccountLevelEnum.NORMAL.getName(), memberId);
|
|
//如果代理等级为手动设置，则跳过该会员
|
int levelStatus = ObjectUtil.isEmpty(mallMember.getLevelStatus()) ? 0 : 1;
|
if(1 == levelStatus){
|
continue;
|
}
|
mallMemberMapper.updateLevelById(MemberAgentLevelEnum.AGENT.getName(),mallMember.getId());
|
}
|
}
|
}
|
}
|
|
@Scheduled(cron = "0 0 1 * * ? ")
|
public void updateMemberAgentLevel() {
|
log.info("会员代理等级升级任务执行");
|
/**
|
* 获取会员信息
|
* 1、已经升级成为一星
|
*/
|
/**
|
* 区代
|
* 1、自身一星
|
* 2、直推三个星级
|
* 3、团队五个星级
|
*/
|
updateMemberAgentLevelByName(DataDictionaryEnum.AGENT_ONE.getType(),DataDictionaryEnum.AGENT_ONE.getCode());
|
/**
|
* 县代
|
* 1、自身2星
|
* 2、直推5个星级
|
* 3、团队50个星级
|
*/
|
updateMemberAgentLevelByName(DataDictionaryEnum.AGENT_TWO.getType(),DataDictionaryEnum.AGENT_TWO.getCode());
|
updateMemberAgentLevelByName(DataDictionaryEnum.AGENT_THREE.getType(),DataDictionaryEnum.AGENT_THREE.getCode());
|
updateMemberAgentLevelByName(DataDictionaryEnum.AGENT_FOUR.getType(),DataDictionaryEnum.AGENT_FOUR.getCode());
|
updateMemberAgentLevelByName(DataDictionaryEnum.AGENT_FIVE.getType(),DataDictionaryEnum.AGENT_FIVE.getCode());
|
}
|
|
private void updateMemberAgentLevelByName(String name,String code){
|
DataDictionaryCustom agentDic = dataDictionaryCustomMapper.selectDicDataByTypeAndCode(
|
name,
|
code
|
);
|
JSONObject jsonObject = JSONUtil.parseObj(agentDic.getValue());
|
//自身星级
|
String levelSelf = jsonObject.get("levelSelf").toString();
|
//直推星级数量
|
String directLevelCnt = jsonObject.get("directLevelCnt").toString();
|
//团队星级数量
|
String teamLevelCnt = jsonObject.get("teamLevelCnt").toString();
|
//两个市场均有上一个代理等级
|
String minTeamLevelCnt = jsonObject.get("minTeamLevelCnt").toString();
|
List<MallMember> agentLevelList = mallMemberMapper.selectByAccountLevel(levelSelf);
|
if(CollUtil.isNotEmpty(agentLevelList)){
|
for(MallMember mallMember : agentLevelList){
|
//如果代理等级为手动设置，则跳过该会员
|
int levelStatus = ObjectUtil.isEmpty(mallMember.getLevelStatus()) ? 0 : 1;
|
if(1 == levelStatus){
|
continue;
|
}
|
//有星级的直推
|
Integer directCnt = mallMemberMapper.selectByRefererIdAndAccountLevel(mallMember.getInviteId(),MemberAccountLevelEnum.NORMAL.getName());
|
//团队中星级会员数量
|
Integer teamCnt = mallMemberMapper.selectByReferersIdAndAccountLevel(mallMember.getInviteId(),MemberAccountLevelEnum.NORMAL.getName());
|
//两个市场均有上一个代理等级
|
Integer minCnt = 0;
|
if(0 < Integer.parseInt(minTeamLevelCnt)){
|
String minLevel = MemberAgentLevelEnum.AGENT_ONE.minLevel(code);
|
//获取所有直推用户
|
List<MallMember> mallMembers = mallMemberMapper.selectByRefererId(mallMember.getInviteId());
|
if(CollUtil.isNotEmpty(mallMembers) && mallMembers.size() > 2){
|
Integer levelCnt = 0;
|
for(MallMember directMember : mallMembers){
|
Integer minlevelCnt = mallMemberMapper.selectByReferersIdAndLevel(directMember.getInviteId(),minLevel);
|
if(0 < minlevelCnt){
|
levelCnt = levelCnt + 1;
|
}
|
if(levelCnt >= Integer.parseInt(minTeamLevelCnt)){
|
minCnt = 1;
|
break;
|
}
|
}
|
}
|
}else{
|
//区代不需要判断这个市场条件
|
minCnt = 1;
|
}
|
if(Integer.parseInt(directLevelCnt) <= directCnt
|
&& Integer.parseInt(teamLevelCnt) <= teamCnt
|
&& minCnt > 0){
|
//更新会员代理等级
|
mallMemberMapper.updateLevelById(MemberAgentLevelEnum.AGENT_ONE.getNameByCode(code),mallMember.getId());
|
}
|
}
|
}
|
}
|
}
|
