From 16500ff805484fb876ff9736d21021b242f1d7cd Mon Sep 17 00:00:00 2001 From: kaiyu <404897439@qq.com> Date: Thu, 01 Jul 2021 09:03:55 +0800 Subject: [PATCH] screen-manage 添加websocket实时界面 --- screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java | 13 +++++++------ 1 files changed, 7 insertions(+), 6 deletions(-) diff --git a/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java b/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java index a8323c5..953468c 100644 --- a/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java +++ b/screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java @@ -141,7 +141,7 @@ organizationUnitAlarm.setSensorCode(updateSensorMap.get("code").toString()); organizationUnitAlarmMapper.update(organizationUnitAlarm,wrapper_OUA); //������deviceInfo������ - CacheUtils.flushDeviceAlarmInfo(); + CacheUtils.refreshDeviceAlarmInfo(); } HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest(); String content = "������������:"+oldSensor.getName()+";"; @@ -359,6 +359,12 @@ return sensors; } + @Override + public void refreshCache(){ + Map<String, Sensor> sensors = getAllSensorFromDB(); + refreshCache(sensors); + } + private Map<String,Sensor> getAllSensorFromDB(){ QueryWrapper<Sensor> wrapper = new QueryWrapper<>(); wrapper.eq("is_delete",Constants.NOT_DELETE); @@ -368,11 +374,6 @@ result.put(sensor.getCode(),sensor); } return result; - } - - private void refreshCache(){ - Map<String, Sensor> sensors = getAllSensorFromDB(); - refreshCache(sensors); } private void refreshCache(Map<String,Sensor> sensors){ -- Gitblit v1.8.0