| | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 出库任务---通知容器流动
|
|---|
| | | * 每隔3秒，获取当前出库任务列表状态为WCS_EXECUTE_OUT_ARRIVED的任务，并通知ESS流动输送线
|
|---|
| | | * 每隔3秒，获取当前出库任务列表状态为COMPLETE_OUT的任务，并通知ESS流动输送线
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0/5 * * * * ? ")
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void conveyorToNotify() {
|
|---|
| | | List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()
|
|---|
| | | .eq(Task::getTaskSts, TaskStsType.WCS_EXECUTE_OUT_ARRIVED.id).eq(Task::getStatus, 1));
|
|---|
| | | .eq(Task::getTaskSts, TaskStsType.WCS_EXECUTE_OUT_CONVEYOR.id).eq(Task::getStatus, 1));
|
|---|
| | |
|
|---|
| | | // 还需要再修改
|
|---|
| | | tasks.forEach(task -> {
|
|---|
