package com.stylefeng.guns.modular.system.task;
|
|
import com.baomidou.mybatisplus.mapper.EntityWrapper;
|
import com.stylefeng.guns.modular.system.model.Reassign;
|
import com.stylefeng.guns.modular.system.service.IReassignService;
|
import com.stylefeng.guns.modular.system.util.PushUtil;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.scheduling.annotation.Scheduled;
|
import org.springframework.stereotype.Component;
|
|
import java.util.Date;
|
import java.util.List;
|
|
/**
|
* 改派超时检查定时任务
|
* 每30秒检查一次待确认且已超时的改派申请
|
*/
|
@Component
|
public class ReassignTimeoutTask {
|
|
@Autowired
|
private IReassignService reassignService;
|
|
@Autowired
|
private PushUtil pushUtil;
|
|
/**
|
* 每30秒检查一次超时的改派申请
|
*/
|
@Scheduled(cron = "0/30 * * * * ?")
|
public void checkTimeoutReassigns() {
|
try {
|
// 查询超时的改派申请
|
List<Reassign> timeoutList = reassignService.selectList(
|
new EntityWrapper<Reassign>()
|
.eq("needConfirm", 2) // 需要确认的
|
.eq("confirmStatus", 1) // 待确认状态
|
.le("expireTime", new Date()) // 已超时
|
);
|
|
for (Reassign reassign : timeoutList) {
|
// 设置超时并恢复订单状态
|
reassignService.timeoutReassign(reassign);
|
|
// 通知原司机超时
|
pushReassignTimeout(reassign);
|
|
System.out.println("改派申请超时处理：reassignId=" + reassign.getId() +
|
", orderId=" + reassign.getOrderId() +
|
", originalDriverId=" + reassign.getOriginalDriverId());
|
}
|
|
if (timeoutList.size() > 0) {
|
System.out.println("本次共处理 " + timeoutList.size() + " 条超时改派申请");
|
}
|
} catch (Exception e) {
|
System.err.println("改派超时检查任务执行失败：" + e.getMessage());
|
e.printStackTrace();
|
}
|
}
|
|
/**
|
* 通知原司机改派超时（使用Socket推送）
|
*/
|
private void pushReassignTimeout(Reassign reassign) {
|
try {
|
pushUtil.pushReassignTimeout(
|
reassign.getOriginalDriverId(),
|
reassign.getId(),
|
reassign.getOrderId(),
|
reassign.getOrderType()
|
);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
}
|
