| | |
| | | |
| | | import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper; |
| | | import com.zy.acs.manager.core.domain.AgvTaskDto; |
| | | import com.zy.acs.manager.core.service.MainLockWrapService; |
| | | import com.zy.acs.manager.core.service.MainService; |
| | | import com.zy.acs.manager.core.service.TrafficService; |
| | | import com.zy.acs.manager.manager.entity.Bus; |
| | |
| | | @Autowired |
| | | private MainService mainService; |
| | | @Autowired |
| | | private MainLockWrapService mainLockWrapService; |
| | | @Autowired |
| | | private ActionService actionService; |
| | | @Autowired |
| | | private SegmentService segmentService; |
| | |
| | | if (!this.lock.tryLock(LOCK_TIMEOUT, TimeUnit.SECONDS)) { return; } |
| | | List<Bus> busList = busService.selectBySts(BusStsType.RECEIVE); |
| | | for (Bus bus : busList) { |
| | | mainService.infuseAgvForTask(bus); |
| | | mainService.allocateTask(bus); |
| | | } |
| | | this.lock.unlock(); |
| | | } |
| | |
| | | } |
| | | |
| | | for (AgvTaskDto dto : taskDtoList) { |
| | | mainService.mergeMajorTask(dto.getAgvId(), dto.getTaskList()); |
| | | mainLockWrapService.buildMajorTask(dto.getAgvId(), dto.getTaskList()); |
| | | } |
| | | this.lock.unlock(); |
| | | } |