kafa数据从redis获取型号，当前组织下走航车设备列表

jinpengyong

2021-08-26 3be7bd55ff0a4ab2ed25b46cdfd1dede92300ea3

 screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java

@@ -140,9 +140,9 @@
            OrganizationUnitAlarm organizationUnitAlarm = new OrganizationUnitAlarm();
            organizationUnitAlarm.setSensorCode(updateSensorMap.get("code").toString());
            organizationUnitAlarmMapper.update(organizationUnitAlarm,wrapper_OUA);
            //刷新deviceInfo缓存
            CacheUtils.flushDeviceAlarmInfo();
        }
        //刷新deviceInfo缓存
        CacheUtils.refreshDeviceAlarmInfo();
        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();
        String content = "修改因子:"+oldSensor.getName()+";";
        for (Object key:updateSensorMap.keySet()) {
@@ -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){