| | |
| | | airEquipment.setCreateTime(airData.getCreateTime()); |
| | | airEquipmentService.addAirEquipment(airEquipment); |
| | | |
| | | //存缓存 |
| | | RedisUtils.getBean().set(AtmoFunctionCode.AIR_HEARTBEAT.getCode() + deviceName, heartBeatDataPackage, 300L); |
| | | //存缓存心跳包 |
| | | RedisUtils.getBean().set(AtmoFunctionCode.AIR_HEARTBEAT.getCode() + deviceName, heartBeatDataPackage); |
| | | //存缓存状态 |
| | | RedisUtils.getBean().set(AtmoFunctionCode.AIR_HEARTBEAT_STATE.getCode() + deviceName, heartBeatDataPackage, 300L); |
| | | |
| | | return save(airData); |
| | | } |
| | |
| | | } |
| | | |
| | | /** |
| | | * 查询大气设备MAC地址 |
| | | */ |
| | | public List<String> listAirEquipmentMAC() { |
| | | return airDataMapper.listAirEquipmentMAC(); |
| | | } |
| | | |
| | | /** |
| | | * + |
| | | * 根据灯杆id查询大气数据 |
| | | */ |
| | | public A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage listAirDataByLightPoleId(Long poleId) { |
| | | public A5AtmosphereHeartbeatReportInnerFrame.HeartBeatDataPackage getDataByPoleid(Long poleId) { |
| | | String code; |
| | | if (SecurityUtils.getClientId() != null) { |
| | | code = baseMapper.getCodeByPoleId(poleId, SecurityUtils.getUserId()); |