| | |
|---|
| | | /** |
|---|
| | | * 非光电站点任务下发 |
|---|
| | | */ |
|---|
| | | @Scheduled(cron = "0/55 * * * * ? ") |
|---|
| | | @Scheduled(cron = "0/35 * * * * ? ") |
|---|
| | | @Transactional(rollbackFor = Exception.class) |
|---|
| | | public void pubTaskToWcs() { |
|---|
| | | log.info("定时任务开始执行：任务下发到RCS"); |
|---|
| | | Long loginUserId = SystemAuthUtils.getLoginUserId(); |
|---|
| | | List<Integer> list = Arrays.asList(TaskType.TASK_TYPE_IN.type, TaskType.TASK_TYPE_OUT.type, TaskType.TASK_TYPE_LOC_MOVE.type, TaskType.TASK_TYPE_EMPITY_IN.type |
|---|
| | | , TaskType.TASK_TYPE_CHECK_IN.type, TaskType.TASK_TYPE_MERGE_IN.type, TaskType.TASK_TYPE_EMPITY_OUT.type, TaskType.TASK_TYPE_PICK_IN.type, |
|---|
| | | TaskType.TASK_TYPE_PICK_AGAIN_OUT.type, TaskType.TASK_TYPE_CHECK_OUT.type, TaskType.TASK_TYPE_MERGE_OUT.type); |
|---|
| | | List<Integer> integers = Arrays.asList(TaskStsType.GENERATE_IN.id, TaskStsType.GENERATE_OUT.id); |
|---|
| | | List<Integer> list = Arrays.asList( |
|---|
| | | TaskType.TASK_TYPE_LOC_MOVE.type |
|---|
| | | ,TaskType.TASK_TYPE_OUT.type |
|---|
| | | ,TaskType.TASK_TYPE_EMPITY_OUT.type |
|---|
| | | ,TaskType.TASK_TYPE_CHECK_OUT.type |
|---|
| | | ,TaskType.TASK_TYPE_MERGE_OUT.type |
|---|
| | | ,TaskType.TASK_TYPE_PICK_AGAIN_OUT.type |
|---|
| | | ,TaskType.TASK_TYPE_IN.type |
|---|
| | | ,TaskType.TASK_TYPE_EMPITY_IN.type |
|---|
| | | ,TaskType.TASK_TYPE_CHECK_IN.type |
|---|
| | | ,TaskType.TASK_TYPE_MERGE_IN.type |
|---|
| | | ,TaskType.TASK_TYPE_PICK_IN.type |
|---|
| | | ); |
|---|
| | | List<Integer> integers = Arrays.asList(/*TaskStsType.GENERATE_IN.id,*/ TaskStsType.GENERATE_OUT.id); |
|---|
| | | List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>() |
|---|
| | | .in(Task::getTaskType, list) |
|---|
| | | .in(Task::getTaskStatus, integers) |
|---|
