package cn.lili.timetask.handler.impl.order;
|
|
import cn.hutool.core.date.DateTime;
|
import cn.hutool.core.date.DateUtil;
|
import cn.hutool.json.JSONUtil;
|
import cn.lili.modules.order.order.entity.enums.PayStatusEnum;
|
import cn.lili.modules.system.entity.dos.Setting;
|
import cn.lili.modules.system.entity.dto.OrderSetting;
|
import cn.lili.modules.system.entity.enums.SettingEnum;
|
import cn.lili.modules.system.service.SettingService;
|
import cn.lili.modules.wallet.entity.dos.Recharge;
|
import cn.lili.modules.wallet.service.RechargeService;
|
import cn.lili.timetask.handler.EveryMinuteExecute;
|
import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.util.List;
|
import java.util.stream.Collectors;
|
|
/**
|
* 充值订单自动取消（每分钟执行）
|
*
|
* @author zhuhai
|
* @since 2021/3/11
|
**/
|
@Slf4j
|
@Component
|
public class RechargeOrderTaskExecute implements EveryMinuteExecute {
|
/**
|
* 充值
|
*/
|
@Autowired
|
private RechargeService rechargeService;
|
/**
|
* 设置
|
*/
|
@Autowired
|
private SettingService settingService;
|
|
|
@Override
|
public void execute() {
|
Setting setting = settingService.get(SettingEnum.ORDER_SETTING.name());
|
OrderSetting orderSetting = JSONUtil.toBean(setting.getSettingValue(), OrderSetting.class);
|
if (orderSetting != null && orderSetting.getAutoCancel() != null) {
|
//充值订单自动取消时间 = 当前时间 - 自动取消时间分钟数
|
DateTime cancelTime = DateUtil.offsetMinute(DateUtil.date(), -orderSetting.getAutoCancel());
|
LambdaQueryWrapper<Recharge> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(Recharge::getPayStatus, PayStatusEnum.UNPAID.name());
|
//充值订单创建时间 <= 订单自动取消时间
|
queryWrapper.le(Recharge::getCreateTime, cancelTime);
|
List<Recharge> list = rechargeService.list(queryWrapper);
|
List<String> cancelSnList = list.stream().map(Recharge::getRechargeSn).collect(Collectors.toList());
|
for (String sn : cancelSnList) {
|
rechargeService.rechargeOrderCancel(sn);
|
}
|
}
|
}
|
}
|
