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.dos.Order;
|
import cn.lili.modules.order.order.entity.enums.OrderStatusEnum;
|
import cn.lili.modules.order.order.service.OrderService;
|
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.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 paulG
|
* @since 2021/3/11
|
**/
|
@Slf4j
|
@Component
|
public class CancelOrderTaskExecute implements EveryMinuteExecute {
|
/**
|
* 订单
|
*/
|
@Autowired
|
private OrderService orderService;
|
/**
|
* 设置
|
*/
|
@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<Order> queryWrapper = new LambdaQueryWrapper<>();
|
queryWrapper.eq(Order::getOrderStatus, OrderStatusEnum.UNPAID.name());
|
//订单创建时间 <= 订单自动取消时间
|
queryWrapper.le(Order::getCreateTime, cancelTime);
|
List<Order> list = orderService.list(queryWrapper);
|
List<String> cancelSnList = list.stream().map(Order::getSn).collect(Collectors.toList());
|
for (String sn : cancelSnList) {
|
orderService.systemCancel(sn, "超时未支付自动取消",false);
|
}
|
}
|
}
|
}
|
