| | |
| | | AgvErrorType errorType = AgvErrorType.query(agv_04_up.getHexFaultId()); |
| | | |
| | | Long agvId = agvService.getAgvId(vehicle); |
| | | |
| | | VehFaultRec vehFaultRec = new VehFaultRec(); |
| | | VehFaultRec vehFaultRec = vehFaultRecService.getTopVehFaultRec(agvId, String.valueOf(agv_04_up.getFaultId())); |
| | | if (null == vehFaultRec) { |
| | | vehFaultRec = new VehFaultRec(); |
| | | vehFaultRec.setUuid(String.valueOf(snowflakeIdWorker.nextId()).substring(3)); |
| | | vehFaultRec.setAgvId(agvId); |
| | | vehFaultRec.setFaultNo(String.valueOf(agv_04_up.getFaultId())); |
| | |
| | | if (!vehFaultRecService.save(vehFaultRec)) { |
| | | log.error("{}号车辆故障!记录故障信息失败......", dto.getVehicle()); |
| | | } |
| | | |
| | | } else { |
| | | vehFaultRec.setUpdateTime(new Date()); |
| | | if (!vehFaultRecService.updateById(vehFaultRec)) { |
| | | log.error("{}号车辆故障!更新故障信息失败......", dto.getVehicle()); |
| | | } |
| | | } |
| | | } catch (Exception e) { |
| | | log.error("FaultProcessor", e); |
| | | } |
| | | } |
| | | |
| | | @Async |
| | | public void reset(Long agvId) { |
| | | vehFaultRecService.resetError(agvId); |
| | | } |
| | | |
| | | |
| | | } |