package com.taoke.autopay.task;
|
|
import com.taoke.autopay.dao.OrderTaskMapper;
|
import com.taoke.autopay.entity.js2.OrderTask;
|
import com.taoke.autopay.service.js2.OrderTaskService;
|
import org.springframework.beans.factory.annotation.Value;
|
import org.springframework.context.annotation.Configuration;
|
import org.springframework.scheduling.annotation.EnableScheduling;
|
import org.springframework.scheduling.annotation.Scheduled;
|
|
import javax.annotation.Resource;
|
import java.util.Date;
|
import java.util.List;
|
|
@Configuration
|
@EnableScheduling
|
public class OrderTaskDistributeTask {
|
|
@Value("${task-enable}")
|
private boolean taskEnable;
|
|
@Resource
|
private OrderTaskService orderTaskService;
|
|
|
/**
|
* 为下单任务分配客户端设备
|
*/
|
@Scheduled(cron = "0/5 * * * * ? ")
|
private void assignOrderTask() {
|
if(!taskEnable){
|
return;
|
}
|
// 对处于分配中的任务进行分配
|
try {
|
OrderTaskMapper.DaoQuery query=new OrderTaskMapper.DaoQuery();
|
query.status = OrderTask.STATUS_ASSIGNING;
|
// 对1小时内创建的任务进行分配
|
query.minCreateTime=new Date(System.currentTimeMillis() - 1000 * 60 * 60L);
|
List<OrderTask> orderTaskList = orderTaskService.listOrderTasks(query, 1, 20);
|
if (orderTaskList != null) {
|
for (OrderTask orderTask : orderTaskList) {
|
orderTaskService.assignTask(orderTask.getId());
|
}
|
}
|
} catch (Exception e) {
|
|
}
|
}
|
|
}
|
