forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
jinpengyong
2021-07-23 f62ce761a5c2dd1f281acbf72a66fd752af3d75d 
 screen-manage/src/main/java/com/moral/api/service/impl/SensorServiceImpl.java


@@ -10,6 +10,7 @@


import com.moral.api.mapper.VersionSensorUnitMapper;


import com.moral.api.service.SensorService;


import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;


import com.moral.api.util.CacheUtils;


import com.moral.api.util.LogUtils;


import com.moral.constant.Constants;


import com.moral.constant.RedisConstants;


@@ -139,6 +140,8 @@


            OrganizationUnitAlarm organizationUnitAlarm = new OrganizationUnitAlarm();


            organizationUnitAlarm.setSensorCode(updateSensorMap.get("code").toString());


            organizationUnitAlarmMapper.update(organizationUnitAlarm,wrapper_OUA);


            //刷新deviceInfo缓存


            CacheUtils.refreshDeviceAlarmInfo();


        }


        HttpServletRequest request = ((ServletRequestAttributes) RequestContextHolder.getRequestAttributes()).getRequest();


        String content = "修改因子:"+oldSensor.getName()+";";


@@ -356,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);


@@ -365,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){