| | |
| | | import com.zy.acs.common.domain.protocol.AGV_01_UP; |
| | | import com.zy.acs.common.utils.RedisSupport; |
| | | import com.zy.acs.framework.common.Cools; |
| | | import com.zy.acs.manager.core.service.MainService; |
| | | import com.zy.acs.manager.core.service.MainLxtService; |
| | | import com.zy.acs.manager.core.service.MapService; |
| | | import com.zy.acs.manager.manager.entity.Action; |
| | | import com.zy.acs.manager.manager.entity.Agv; |
| | |
| | | @Autowired |
| | | private AgvDetailService agvDetailService; |
| | | @Autowired |
| | | private AgvModelService agvModelService; |
| | | @Autowired |
| | | private ActionService actionService; |
| | | @Autowired |
| | | private ConfigService configService; |
| | |
| | | @Autowired |
| | | private JamService jamService; |
| | | @Autowired |
| | | private MainService mainService; |
| | | private MainLxtService mainService; |
| | | |
| | | @PostConstruct |
| | | public void init() { |
| | |
| | | for (Agv agv : agvList) { |
| | | |
| | | if (!AGV_PROCESSING_MAP.get(agv.getId())) { |
| | | AGV_PROCESSING_MAP.put(agv.getId(), true); |
| | | List<Action> actionList = actionService.queryLatestGroup(agv.getId(), ActionStsType.ISSUED); |
| | | if (!Cools.isEmpty(actionList)) { |
| | | AGV_PROCESSING_MAP.put(agv.getId(), true); |
| | | executorService.submit(new AgvSimulatorTask( |
| | | agv |
| | | , redis |
| | | , agvDetailService |
| | | , agvModelService |
| | | , actionService |
| | | , codeService |
| | | , mapService |
| | |
| | | , mainService |
| | | , actionList |
| | | )); |
| | | } else { |
| | | AGV_PROCESSING_MAP.put(agv.getId(), false); |
| | | } |
| | | } |
| | | |