| | |
| | | @Autowired |
| | | private AgvModelService agvModelService; |
| | | |
| | | |
| | | @Scheduled(cron = "0/1 * * * * ? ") |
| | | private void startupBus() throws InterruptedException { |
| | | // if (!configService.getVal("TaskAssignMode", Boolean.class)) { return; } |
| | |
| | | try { |
| | | Thread.sleep(CORE_SCAN_FREQUENCY_MILLISECOND); |
| | | |
| | | if (configService.getVal("stopDownData", Boolean.class)) { return; } |
| | | |
| | | |
| | | List<Segment> segments = segmentService.list(new LambdaQueryWrapper<Segment>() |
| | | .eq(Segment::getState, SegmentStateType.WAITING.toString()) |
| | | ); |
| | |
| | | try { |
| | | Thread.sleep(CORE_SCAN_FREQUENCY_MILLISECOND); |
| | | |
| | | if (configService.getVal("stopDownData", Boolean.class)) { return; } |
| | | |
| | | List<String> actionGroupIds = actionService.selectGroupNo(ActionStsType.PREPARE); |
| | | for (String actionGroupId : actionGroupIds) { |
| | | mainService.publishAction(actionGroupId); |