| | |
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * 出库任务---通知容器流动
|
|---|
| | | * 每隔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 -> {
|
|---|
| | |
|---|
| | | //流动通知下发完成后，修改任务状态为输送线流动中。。
|
|---|
| | | taskService.update(new LambdaUpdateWrapper<Task>()
|
|---|
| | | .eq(Task::getId, task.getId())
|
|---|
| | | .set(Task::getTaskSts, TaskStsType.COMPLETE_IN.id));
|
|---|
| | | .set(Task::getTaskSts, TaskStsType.COMPLETE_OUT.id));
|
|---|
| | |
|
|---|
| | | // log.info(task.getTaskNo() + "下发流动通知" + commonReponse.getMsg());
|
|---|
| | | // } else {
|
|---|
