|
|
@ -467,7 +467,7 @@ public class RealMonitorServiceImpl implements IRealMonitorService { |
|
|
|
} |
|
|
|
} |
|
|
|
pool.shutdown(); |
|
|
|
pool.shutdown(); |
|
|
|
log.info(thread.getName() + "步骤12所有线程完成 耗时 : {}",System.currentTimeMillis() - beginTime); |
|
|
|
log.info(thread.getName() + "步骤12所有线程完成 耗时 : {}",System.currentTimeMillis() - beginTime); |
|
|
|
redisTemplate.opsForValue().set(moniter_station_key, stationList); |
|
|
|
redisTemplate.opsForValue().set(moniter_station_key, JSONObject.toJSONString(stationList)); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
/** |
|
|
@ -851,12 +851,10 @@ public class RealMonitorServiceImpl implements IRealMonitorService { |
|
|
|
if(ObjectUtil.isEmpty(message) || CollectionUtil.isEmpty(message.getDeptIds())){ |
|
|
|
if(ObjectUtil.isEmpty(message) || CollectionUtil.isEmpty(message.getDeptIds())){ |
|
|
|
return null; |
|
|
|
return null; |
|
|
|
} |
|
|
|
} |
|
|
|
Object json = redisTemplate.opsForValue().get(moniter_station_key); |
|
|
|
List<RealStationVo> realStationVoList = (List<RealStationVo>) redisTemplate.opsForValue().get(moniter_station_key); |
|
|
|
if(ObjectUtil.isEmpty(json)){ |
|
|
|
if(ObjectUtil.isEmpty(realStationVoList)){ |
|
|
|
return null; |
|
|
|
return null; |
|
|
|
} |
|
|
|
} |
|
|
|
// 获取所有监控缓存数据
|
|
|
|
|
|
|
|
List<RealStationVo> realStationVoList = JSONObject.parseObject(json.toString(),new TypeReference<List<RealStationVo>>() {}); |
|
|
|
|
|
|
|
if(CollectionUtil.isEmpty(realStationVoList)){ |
|
|
|
if(CollectionUtil.isEmpty(realStationVoList)){ |
|
|
|
return null; |
|
|
|
return null; |
|
|
|
} |
|
|
|
} |
|
|
|