| | |
| | | |
| | | // 解析入库工作档 |
| | | public synchronized void analyzeInBoundTask() { |
| | | |
| | | List<Task> chargetaskList = taskService.list(new LambdaQueryWrapper<Task>() |
| | | .in(Task::getTaskSts |
| | | , TaskStsType.NEW_CHARGE.sts |
| | | , TaskStsType.ANALYZE_CHARGE.sts |
| | | , TaskStsType.EXECUTE_CHARGE.sts |
| | | , TaskStsType.COMPLETE_CHARGE.sts |
| | | ) |
| | | ); |
| | | if (!chargetaskList.isEmpty()) { |
| | | return; |
| | | } |
| | | for (Task task : taskService.selectWaitAnalyzeInBoundTask()) { |
| | | BasConveyorSta basConveyorSta = basConveyorStaService.getOne(new LambdaQueryWrapper<BasConveyorSta>().eq(BasConveyorSta::getSiteNo, task.getDestSite())); |
| | | if (basConveyorSta == null) { |
| | |
| | | continue; |
| | | } |
| | | |
| | | List<Task> chargetaskList = taskService.list(new LambdaQueryWrapper<Task>() |
| | | .in(Task::getTaskSts |
| | | , TaskStsType.NEW_CHARGE.sts |
| | | , TaskStsType.ANALYZE_CHARGE.sts |
| | | , TaskStsType.EXECUTE_CHARGE.sts |
| | | , TaskStsType.COMPLETE_CHARGE.sts |
| | | ) |
| | | ); |
| | | if (!chargetaskList.isEmpty()) { |
| | | return; |
| | | } |
| | | |
| | | List<Task> taskList = taskService.list(new LambdaQueryWrapper<Task>() |
| | | .in(Task::getTaskSts |
| | | , TaskStsType.NEW_INBOUND.sts |