| | |
|---|
| | | @Autowired
|
|---|
| | | private DictService dictService;
|
|---|
| | |
|
|---|
| | | /**
|
|---|
| | | * modifty：
|
|---|
| | | * original : fetch datasource of task type on WAVE_SEED
|
|---|
| | | * now: Fetch datasource of task type on WCS_EXECUTE_OUT_ARRIVED, After completing the task and for setting the task type equal to WAVE_SEED
|
|---|
| | | */
|
|---|
| | | @Scheduled(cron = "0/15 * * * * ? ")
|
|---|
| | | @Transactional(rollbackFor = Exception.class)
|
|---|
| | | public void taskWave() {
|
|---|
| | |
|---|
| | | if (!autoCreateWaveSeed.equals("true")) {
|
|---|
| | | return;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WAVE_SEED.id));
|
|---|
| | | //查询状态为容器到达状态所有任务单据
|
|---|
| | | // List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WAVE_SEED.id));
|
|---|
| | | List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>().eq(Task::getTaskSts, TaskStsType.WCS_EXECUTE_OUT_ARRIVED.id));
|
|---|
| | | if (taskList.isEmpty()) {
|
|---|
| | | // throw new CoolException("没有可播种任务！！");
|
|---|
| | | } else {
|
|---|
| | |
|---|
| | |
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | task.setTaskSts(TaskStsType.COMPLETE_OUT.id);
|
|---|
| | | task.setTaskSts(TaskStsType.WAVE_SEED.id);
|
|---|
| | | task.setUpdateTime(new Date());
|
|---|
| | | if (!taskService.updateById(task)) {
|
|---|
| | | throw new CoolException("任务更新失败");
|
|---|
