| | |
| | | private StaReserveService staReserveService; |
| | | @Autowired |
| | | private ConveyorStationService conveyorStationService; |
| | | @Autowired |
| | | private FuncTaskService funcTaskService; |
| | | |
| | | |
| | | @SuppressWarnings("all") |
| | | @Transactional |
| | |
| | | if (taskComplete) { |
| | | // 在充电任务行走到终点,同时判断充电桩的类型 |
| | | if (segment.getPosType().equals(TaskPosDto.PosType.TO_CHARGE)){ |
| | | // 保存一条数据 |
| | | FuncTask funcTask = new FuncTask(); |
| | | FuncSta destFuncSta = funcStaService.getByCodeAndType(task.getDestCode(), FuncStaType.CHARGE.toString()); |
| | | funcTask.setFuncStaId(destFuncSta.getId()); |
| | | funcTask.setAgvId(segment.getAgvId()); |
| | | funcTask.setTaskId(segment.getTaskId()); |
| | | funcTask.setFuncTaskSts(TaskStsType.INIT.val()); |
| | | funcTaskService.save(funcTask); |
| | | if (destFuncSta != null) { |
| | | if (Cools.isEmpty(destFuncSta.getProtocol()) && destFuncSta.getProtocol().equalsIgnoreCase(ProtocolType.MODBUS.toString())) { |
| | | redis.setMap(RedisConstant.AGV_CHARGE_FLAG,segment.getAgvId$(),1); |
| | | } |
| | | } |
| | | } |
| | | task.setTaskSts(TaskStsType.COMPLETE.val()); |
| | | task.setEndTime(now); |