| | |
| | | import com.zy.acs.framework.common.Cools; |
| | | import com.zy.acs.framework.common.R; |
| | | import com.zy.acs.manager.core.cache.CoreCache; |
| | | import com.zy.acs.manager.manager.entity.*; |
| | | import com.zy.acs.manager.core.domain.CodeStepDto; |
| | | import com.zy.acs.manager.core.domain.type.JobType; |
| | | import com.zy.acs.manager.manager.entity.Agv; |
| | | import com.zy.acs.manager.manager.entity.AgvDetail; |
| | | import com.zy.acs.manager.manager.entity.Code; |
| | | import com.zy.acs.manager.manager.entity.Travel; |
| | | import com.zy.acs.manager.manager.enums.StatusType; |
| | | import com.zy.acs.manager.manager.enums.TaskTypeType; |
| | | import com.zy.acs.manager.manager.enums.TravelStateType; |
| | |
| | | }}; |
| | | |
| | | private Map<String, JobType> agvJobMap = new ConcurrentHashMap<>(); |
| | | public enum JobType { |
| | | CONVEYOR_PICK, |
| | | CONVEYOR_DROP, |
| | | LOC_PICK, |
| | | LOCK_DROP, |
| | | ; |
| | | } |
| | | |
| | | @Autowired |
| | | private AgvService agvService; |
| | |
| | | |
| | | if (mainLockWrapService.buildMinorTask(agvId, TaskTypeType.MOVE, destinationCodeData, null)) { |
| | | log.info( "{}开始作业演示...", agvNo); |
| | | |
| | | CoreCache.AGV_MOCK_STEP_CACHE.put(agvId, CodeStepDto.build(destinationCodeData, jobType)); |
| | | switch (jobType) { |
| | | case LOC_PICK: |
| | | Integer usedSlotsByLocPick = CoreCache.AGV_BACKPACK_USED_CACHE.get(agvId); |
| | |
| | | if (cancelled) { |
| | | AGV_PATROL_MAP.remove(agvNo); |
| | | CoreCache.AGV_BACKPACK_USED_CACHE.remove(agvId); |
| | | CoreCache.AGV_MOCK_STEP_CACHE.remove(agvId); |
| | | this.agvJobMap.remove(agvNo); |
| | | log.info("已停止AGV " + agvNo + " 的跑库任务。"); |
| | | return R.ok("已停止AGV " + agvNo + " 的跑库任务。"); |