blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2025-01-06 8490eb11583ffdc586436f165860de5cfc39f915 
 screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java


@@ -1,45 +1,45 @@


package com.moral.api.service.impl;




import com.alibaba.fastjson.JSON;


import com.alibaba.fastjson.JSONObject;


import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;


import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper;


import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;


import com.baomidou.mybatisplus.extension.plugins.pagination.Page;


import com.moral.api.entity.Device;


import com.moral.api.entity.ManageAccount;


import com.moral.api.entity.MonitorPoint;


import com.moral.api.entity.Organization;


import com.moral.api.entity.SysDictData;


import com.moral.api.entity.SysDictType;


import com.moral.api.entity.Version;


import com.moral.api.mapper.DeviceMapper;


import com.moral.api.mapper.ManageAccountMapper;


import com.moral.api.mapper.MonitorPointMapper;


import com.moral.api.mapper.OrganizationMapper;


import com.moral.api.mapper.SysDictDataMapper;


import com.moral.api.mapper.SysDictTypeMapper;


import com.googlecode.aviator.AviatorEvaluator;


import com.googlecode.aviator.Expression;


import com.moral.api.entity.*;


import com.moral.api.mapper.*;


import com.moral.api.pojo.vo.device.DeviceVO;


import com.moral.api.service.DeviceService;


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




import com.moral.api.service.OrganizationService;


import com.moral.api.service.SysDictDataService;


import com.moral.api.util.CacheUtils;


import com.moral.api.util.AdjustDataUtils;


import com.moral.api.util.LogUtils;


import com.moral.constant.Constants;


import com.moral.redis.RedisUtil;


import com.moral.constant.RedisConstants;


import com.moral.util.ConvertUtils;


import com.moral.util.DateUtils;




import lombok.extern.slf4j.Slf4j;


import org.springframework.beans.factory.annotation.Autowired;


import org.springframework.data.redis.core.RedisTemplate;


import org.springframework.stereotype.Service;


import org.springframework.transaction.annotation.Transactional;


import org.springframework.util.ObjectUtils;


import org.springframework.util.StringUtils;


import org.springframework.web.context.request.RequestContextHolder;


import org.springframework.web.context.request.ServletRequestAttributes;




import java.beans.PropertyDescriptor;


import java.lang.reflect.Field;


import java.lang.reflect.Method;


import java.util.ArrayList;


import java.util.LinkedHashMap;


import java.util.List;


import java.util.Map;


import java.util.Objects;


import java.lang.reflect.Type;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.stream.Collectors;




import javax.servlet.http.HttpServletRequest;




@@ -52,6 +52,7 @@


 * @since 2021-05-11


 */


@Service


@Slf4j


public class DeviceServiceImpl extends ServiceImpl<DeviceMapper, Device> implements DeviceService {




    @Autowired


@@ -73,7 +74,47 @@


    private SysDictDataMapper sysDictDataMapper;




    @Autowired


    private LogUtils logUtils;


    private SysDictDataService sysDictDataService;






    @Autowired


    private RedisTemplate redisTemplate;




    @Autowired


    private OrganizationUnitAlarmMapper organizationUnitAlarmMapper;




    @Autowired


    private VersionSensorUnitMapper versionSensorUnitMapper;




    @Autowired


    private SpecialDeviceMapper specialDeviceMapper;




    @Autowired


    private AdjustDataUtils adjustDataUtils;




    @Autowired


    private OrganizationService organizationService;




    /*


     * 从redis获取设备信息


     * */


    private Map<String, Object> getDeviceInfoFromRedis(String mac) {


        return (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DEVICE, mac);


    }




    /*


     * 设备信息存入redis


     */


    private void setDeviceInfoToRedis(String mac, Map<String, Object> deviceInfo) {


        redisTemplate.opsForHash().put(RedisConstants.DEVICE, mac, deviceInfo);


    }




    /*


     * 从redis删除设备信息


     */


    private void delDeviceInfoFromRedis(String mac) {


        redisTemplate.opsForHash().delete(RedisConstants.DEVICE, mac);


    }




    @Override


    @Transactional


@@ -82,30 +123,44 @@


        device.setOrganizationId(orgId);


        deviceMapper.insert(device);


        Map<String, Object> deviceInfo = selectDeviceInfoById(device.getId());


        //维护组织型号关系表


        insertOrganizationUnitAlarm(orgId, device.getDeviceVersionId());


        //新增设备信息存入redis


        RedisUtil.set("device_" + device.getMac(), deviceInfo);


        String mac = device.getMac();


        //从redis中删除设备信息


        delDeviceInfoFromRedis(mac);


        //设备信息存入redis


        setDeviceInfoToRedis(mac, deviceInfo);


        //刷新deviceInfo缓存


        CacheUtils.refreshDeviceAlarmInfo();


        //操作日志记录


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


        StringBuilder content = new StringBuilder();


        content.append("添加了设备：").append(device.getName()).append("；").append("mac：").append(device.getMac());


        logUtils.saveOperationForManage(request, content.toString(), Constants.INSERT_OPERATE_TYPE);


        content.append("添加了设备：").append(device.getName()).append(":").append("mac：").append(mac);


        LogUtils.saveOperationForManage(request, content.toString(), Constants.INSERT_OPERATE_TYPE);


    }




    @Override


    @Transactional


    public void delete(Integer deviceId) {


        Device device = deviceMapper.selectById(deviceId);


        UpdateWrapper<Device> updateWrapper = new UpdateWrapper<>();


        updateWrapper.eq("id", deviceId).set("is_delete", Constants.DELETE);


        deviceMapper.update(null, updateWrapper);


        Device device = deviceMapper.selectById(deviceId);


        String mac = device.getMac();


        //清除redis


        RedisUtil.del("device_" + mac);


        //从redis中删除设备信息


        delDeviceInfoFromRedis(mac);


        //维护组织型号关系表


        Integer versionId = device.getDeviceVersionId();


        Integer orgId = device.getOrganizationId();


        deleteOrganizationUnitAlarm(orgId, versionId);


        //刷新deviceInfo缓存


        CacheUtils.refreshDeviceAlarmInfo();


        //操作日志记录


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


        StringBuilder content = new StringBuilder();


        content.append("删除了设备：").append(device.getName()).append(";").append("mac：").append(mac);


        logUtils.saveOperationForManage(request, content.toString(), Constants.DELETE_OPERATE_TYPE);


        LogUtils.saveOperationForManage(request, content.toString(), Constants.DELETE_OPERATE_TYPE);


    }




    @Override


@@ -113,16 +168,34 @@


    public void update(Device device) {


        Integer deviceId = device.getId();


        Device oldDevice = deviceMapper.selectById(deviceId);


        //判断是否更新了站点，如果更新了站点则查询对应站点的组织id进行更新


        if (!ObjectUtils.isEmpty(device.getMonitorPointId())) {


            MonitorPoint monitorPoint = monitorPointMapper.selectById(device.getMonitorPointId());


            device.setOrganizationId(monitorPoint.getOrganizationId());


        }


        deviceMapper.updateById(device);


        String mac = deviceMapper.selectById(deviceId).getMac();


        //更新redis


        RedisUtil.del("device_" + mac);


        Device updateDevice = deviceMapper.selectById(deviceId);


        String mac = updateDevice.getMac();


        //维护组织型号关系表


        Integer oldOrgId = oldDevice.getOrganizationId();


        Integer newOrgId = updateDevice.getOrganizationId();


        Integer oldVersionId = oldDevice.getDeviceVersionId();


        Integer newVersionId = updateDevice.getDeviceVersionId();


        if (!oldOrgId.equals(newOrgId) || !oldVersionId.equals(newVersionId)) {


            deleteOrganizationUnitAlarm(oldOrgId, oldVersionId);


            insertOrganizationUnitAlarm(newOrgId, newVersionId);


        }


        //从redis中删除设备信息


        delDeviceInfoFromRedis(oldDevice.getMac());


        Map<String, Object> deviceInfo = selectDeviceInfoById(deviceId);


        RedisUtil.set("device_" + mac, deviceInfo);


        //设备信息存入redis


        setDeviceInfoToRedis(mac, deviceInfo);


        //刷新deviceInfo缓存


        CacheUtils.refreshDeviceAlarmInfo(mac);


        //操作日志记录


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


        StringBuilder content = new StringBuilder();


        content.append("修改了设备：").append(mac).append("：");


        content.append("修改了设备：" + oldDevice.getMac()).append("==>").append(mac).append("：");


        Field[] fields = Device.class.getDeclaredFields();


        for (Field field : fields) {


            if (field.getName().equals("id")) {


@@ -139,7 +212,7 @@


                Object o1 = method.invoke(oldDevice);


                Object o2 = method.invoke(device);


                if (o2 != null) {


                    content.append(fieldName).append("：").append(o1).append("-->").append(o2).append("；");


                    content.append(fieldName).append("：").append(o1).append("-->").append(o2).append(":");


                }




            } catch (Exception e) {


@@ -147,7 +220,7 @@


            }




        }


        logUtils.saveOperationForManage(request, content.toString(), Constants.UPDATE_OPERATE_TYPE);


        LogUtils.saveOperationForManage(request, content.toString(), Constants.UPDATE_OPERATE_TYPE);


    }




    @Override


@@ -171,23 +244,25 @@




    @Override


    public List<Map<String, Object>> selectMonitorsByOrgId(Integer orgId) {


        //获取所有子组织


        List<Organization> organizations = organizationService.getAllChildrenOrganization(orgId);


        List<Integer> orgIds = organizations.stream().map(Organization::getId).collect(Collectors.toList());


        orgIds.add(orgId);


        QueryWrapper<MonitorPoint> queryWrapper = new QueryWrapper<>();


        queryWrapper.select("id", "name").eq("organization_id", orgId).eq("is_delete", Constants.NOT_DELETE);


        queryWrapper.select("id", "name")


                .eq("is_delete", Constants.NOT_DELETE)


                .in("organization_id", orgIds);


        return monitorPointMapper.selectMaps(queryWrapper);


    }




    @Override


    public List<Map<String, Object>> selectDevicesByOrgId(Integer orgId) {


        QueryWrapper<Device> queryWrapper = new QueryWrapper<>();


        queryWrapper.eq("is_delete", Constants.NOT_DELETE).eq("organization_id", orgId);


        return deviceMapper.selectMaps(queryWrapper);


    public Map<String, Object> selectDevicesByOrgId(Map<String, Object> parameters) {


        return selectDevices(parameters);


    }




    @Override


    public List<Map<String, Object>> selectDevicesByMpId(Integer mpId) {


        QueryWrapper<Device> queryWrapper = new QueryWrapper<>();


        queryWrapper.eq("is_delete", Constants.NOT_DELETE).eq("monitor_point_id", mpId);


        return deviceMapper.selectMaps(queryWrapper);


    public Map<String, Object> selectDevicesByMpId(Map<String, Object> parameters) {


        return selectDevices(parameters);


    }




    @Override


@@ -199,11 +274,26 @@


        Object orderType = parameters.get("orderType");


        Object name = parameters.get("name");


        Object mac = parameters.get("mac");


        if (name != null) {


            queryWrapper.like("name", name);


        Object orgId = parameters.get("organizationId");


        Object mpId = parameters.get("monitorPointId");




        //查询某组织下所有设备,包括子组织


        if (orgId != null) {


            //查询所有子组织


            List<Organization> organizations = organizationService.getAllChildrenOrganization(Integer.parseInt(orgId.toString()));


            List<Integer> orgIds = organizations.stream().map(Organization::getId).collect(Collectors.toList());


            orgIds.add(Integer.parseInt(orgId.toString()));


            queryWrapper.in("organization_id", orgIds);


        }


        if (mac != null) {


            queryWrapper.like("mac", mac);




        //查询某站点下所有设备


        if (mpId != null) {


            queryWrapper.eq("monitor_point_id", mpId);


        }




        //设备名称或mac模糊查询


        if (name != null && mac != null) {


            queryWrapper.like("name", name).or().like("mac", mac);


        }




        //排序参数,默认create_time降序


@@ -234,11 +324,10 @@


        return result;


    }






    @Override


    public Map<String, Object> selectDeviceInfoById(Integer deviceId) {


        String mac = deviceMapper.selectById(deviceId).getMac();


        Map<String, Object> deviceInfo = (Map<String, Object>) RedisUtil.get("device_" + mac);


        Map<String, Object> deviceInfo = getDeviceInfoFromRedis(mac);


        //先从redis中取


        if (deviceInfo != null) {


            return deviceInfo;


@@ -255,9 +344,14 @@


        deviceInfo.put("createTime", DateUtils.dateToDateString(device.getCreateTime()));


        deviceInfo.put("installTime", device.getInstallTime() == null ? null : DateUtils.dateToDateString(device.getInstallTime()));




        //扩展字段


        deviceInfo.put("extend", device.getExtend());




        //乡镇街道信息


        deviceInfo.put("town", device.getTown());




        //行业


        deviceInfo.put("profession", device.getProfession());


        deviceInfo.put("professionName", device.getProfessionName());


        deviceInfo.put("professions", device.getProfessions());




        //工艺


        deviceInfo.put("tech", device.getTech());


@@ -301,8 +395,22 @@


        MonitorPoint monitorPoint = device.getMonitorPoint();


        mpInfo.put("id", monitorPoint.getId());


        mpInfo.put("name", monitorPoint.getName());


        mpInfo.put("areaCode", monitorPoint.getAreaCode());


        mpInfo.put("cityCode", monitorPoint.getCityCode());


        mpInfo.put("provinceCode", monitorPoint.getProvinceCode());


        deviceInfo.put("monitorPoint", mpInfo);


        RedisUtil.set("device_" + mac, deviceInfo);




        //国控站点


        Map<String, Object> govMpInfo = new LinkedHashMap<>();




        govMpInfo.put("guid", null);


        govMpInfo.put("name", null);


        if (device.getGovMonitorPoint() != null) {


            govMpInfo.put("guid", device.getGovMonitorPoint().getGuid());


            govMpInfo.put("name", device.getGovMonitorPoint().getName());


        }


        deviceInfo.put("govMonitorPoint", govMpInfo);


        setDeviceInfoToRedis(mac, deviceInfo);


        return deviceInfo;


    }




@@ -320,4 +428,210 @@


        return monitorPointMapper.selectMaps(queryWrapper);


    }




    @Override


    public Map<String, Object> getDeviceByMac(String mac) {


        Map<String, Object> deviceInfo = getDeviceInfoFromRedis(mac);


        if (ObjectUtils.isEmpty(deviceInfo)) {


            QueryWrapper<Device> queryWrapper = new QueryWrapper<>();


            queryWrapper.eq("mac", mac).eq("is_delete", Constants.NOT_DELETE);


            Device device = deviceMapper.selectOne(queryWrapper);


            if (device != null) {


                deviceInfo = selectDeviceInfoById(device.getId());


                setDeviceInfoToRedis(mac, deviceInfo);


            }


        }


        return deviceInfo;


    }




    @Override


    public Map<String, Object> adjustDeviceData(Map<String, Object> deviceData,String code) {


//        String mac = deviceData.remove("mac").toString();


        String mac = deviceData.get("mac").toString();


        //从redis获取校准公式


        Map<String, Object> adjustFormula = redisTemplate.opsForHash().entries(RedisConstants.ADJUST + "_" + mac);


        if (!ObjectUtils.isEmpty(adjustFormula)) {


            Map<String, Object> deviceInfo = getDeviceByMac(mac);


            //获取设备绑定的国控站信息


            Map<String, Object> govMpInfo = (Map<String, Object>) deviceInfo.get("govMonitorPoint");


            Map<String, Object> aqiMap = null;


            if (govMpInfo.get("guid") != null) {


                aqiMap = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.AQI_DATA, govMpInfo.get("guid").toString());


            }


            return adjustDataUtils.adjust(deviceData, adjustFormula, ObjectUtils.isEmpty(aqiMap) ? null : aqiMap,code);


        }


        deviceData.remove("DataTime");


        return deviceData;


    }




    @Override


    public Map<String, Object> adjustSpecialDeviceData(Map<String, Object> deviceData) {


//        String mac = deviceData.remove("mac").toString();


        String mac = deviceData.get("mac").toString();


        //从redis获取校准公式


        Map<String, Object> adjustFormula = redisTemplate.opsForHash().entries(RedisConstants.ADJUST + "_" + mac);


        if (!ObjectUtils.isEmpty(adjustFormula)) {


            Organization organization = specialDeviceMapper.selectOrgByMac(mac);


            String areaCode = organization.getAreaCode().toString();


            String cityCode = organization.getCityCode().toString();


            Map<String, Object> aqiMap = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.AQI_DATA, areaCode);


            if (ObjectUtils.isEmpty(aqiMap)) {


                aqiMap = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.AQI_DATA, cityCode);


            }


            return adjustDataUtils.adjust(deviceData, adjustFormula, ObjectUtils.isEmpty(aqiMap) ? null : aqiMap,"0");


        }


        deviceData.remove("DataTime");


        return deviceData;


    }




    @Override


    public void judgeDeviceState(Map<String, Object> deviceData) {


        String mac = deviceData.remove("mac").toString();


        Device device = (Device) redisTemplate.opsForHash().get(RedisConstants.DEVICE_INFO, mac);


        Version version = device.getVersion();


        List<Sensor> sensors = version.getSensors();


        Expression expression;


        int state = 1;


        for (Sensor sensor : sensors) {


            //因子报警等级


            String alarmLevel = sensor.getAlarmLevel();


            if (StringUtils.isEmpty(alarmLevel)) {


                continue;


            }


            List<Object> list = JSONObject.parseObject(alarmLevel, List.class);


            String sensorCode = sensor.getCode();


            //转换公式


            String formula = sensor.getFormula();




            //设备所传因子与配置型号因子不一致的处理逻辑


            if (deviceData.get(sensorCode) != null) {


                String sensorValue = String.valueOf(deviceData.get(sensorCode));


                double value = Double.parseDouble(sensorValue);


                if (formula != null) {


                    //转换后因子值


                    sensorValue = formula.replace("{0}", sensorValue);


                    expression = AviatorEvaluator.compile(sensorValue);


                    value = Double.parseDouble(expression.execute().toString());


                }


                int sensorState = judgeState(list, value);


                if (sensorState > state) {


                    state = sensorState;


                }


            }


        }


        //修改设备状态


        Device device1 = new Device();


        device1.setId(device.getId());


        device1.setState(String.valueOf(state));


        deviceMapper.updateById(device1);


    }




    @Override


    public List<Map<String, Object>> selectMonitorPiontAndDeviceByOrgId(int orgId) {


        QueryWrapper<MonitorPoint> monitorPointQueryWrapper = new QueryWrapper<>();


        monitorPointQueryWrapper.eq("is_delete", Constants.NOT_DELETE);


        monitorPointQueryWrapper.eq("organization_id", orgId);


        List<MonitorPoint> monitorPointList = monitorPointMapper.selectList(monitorPointQueryWrapper);


        List<Map<String, Object>> resultList = new ArrayList<>();


        for (MonitorPoint monitorPoint : monitorPointList) {


            Map<String, Object> resultMap = new HashMap<>();


            resultMap = JSON.parseObject(JSON.toJSONString(monitorPoint), Map.class);


            int mp_id = monitorPoint.getId();


            QueryWrapper<Device> deviceQueryWrapper = new QueryWrapper<>();


            deviceQueryWrapper.eq("is_delete", Constants.NOT_DELETE);


            deviceQueryWrapper.eq("monitor_point_id", mp_id);


            List<Device> devices = new ArrayList<>();


            devices = deviceMapper.selectList(deviceQueryWrapper);


            resultMap.put("devices", devices);


            resultList.add(resultMap);


        }


        return resultList;


    }




    //根据因子值判断状态


    private int judgeState(List<Object> levels, Double data) {


        int state = 1;


        for (int i = levels.size() - 1; i >= 0; i--) {


            Double level = Double.parseDouble(levels.get(i).toString());


            if (data >= level) {


                state = i + 2;


                break;


            }


        }


        return state;


    }




    /**


     * @Description: 判断组织是否含有该设备的型号，如果没有则添加到组织型号关系表中


     * @Param: [orgId, versionId]


     * @return: void


     * @Author: 陈凯裕


     * @Date: 2021/9/6


     */


    private void insertOrganizationUnitAlarm(Integer orgId, Integer versionId) {


        //查询是否含有该型号


        QueryWrapper<OrganizationUnitAlarm> queryOrganizationVersionWrapper = new QueryWrapper<>();


        queryOrganizationVersionWrapper.eq("organization_id", orgId);


        queryOrganizationVersionWrapper.eq("version_id", versionId);


        queryOrganizationVersionWrapper.eq("is_delete", Constants.NOT_DELETE);


        List<OrganizationUnitAlarm> organizationUnitAlarms = organizationUnitAlarmMapper.selectList(queryOrganizationVersionWrapper);


        //如果没有该型号则插入数据


        if (ObjectUtils.isEmpty(organizationUnitAlarms)) {


            //查询型号的因子和单位


            QueryWrapper<VersionSensorUnit> queryVersionSensorUnitWrapper = new QueryWrapper<>();


            queryVersionSensorUnitWrapper.eq("version_id", versionId);


            queryVersionSensorUnitWrapper.eq("is_delete", Constants.NOT_DELETE);


            List<VersionSensorUnit> versionSensorUnits = versionSensorUnitMapper.selectList(queryVersionSensorUnitWrapper);


            //获取所有因子的默认报警值


            Map<String, SysDictData> sensorAlarms = sysDictDataService.getDictDatasByType("defaultAlarm");


            if (!ObjectUtils.isEmpty(versionSensorUnits)) {


                for (VersionSensorUnit versionSensorUnit : versionSensorUnits) {


                    OrganizationUnitAlarm organizationUnitAlarm = new OrganizationUnitAlarm();


                    String sensorCode = versionSensorUnit.getSensorCode();


                    //设置默认报警值


                    SysDictData alarm = sensorAlarms.get(sensorCode);


                    if (alarm != null)


                        organizationUnitAlarm.setAlarmLevel(alarm.getDataValue());


                    organizationUnitAlarm.setOrganizationId(orgId);


                    organizationUnitAlarm.setVersionId(versionId);


                    organizationUnitAlarm.setSensorCode(versionSensorUnit.getSensorCode());


                    organizationUnitAlarm.setUnitKey(versionSensorUnit.getUnitKey());


                    organizationUnitAlarm.setShowUnitKey(versionSensorUnit.getUnitKey());


                    organizationUnitAlarmMapper.insert(organizationUnitAlarm);


                }


            }


        }


    }




    /**


     * @Description: 删除设备后，如果该组织没有这个设备型号其他的设备了，则删除组织型号关系表中该型号的信息。


     * @Param: [orgId, versionId]


     * @return: void


     * @Author: 陈凯裕


     * @Date: 2021/9/6


     */


    private void deleteOrganizationUnitAlarm(Integer orgId, Integer versionId) {


        QueryWrapper<Device> queryOrganizationVersionWrapper = new QueryWrapper<>();


        queryOrganizationVersionWrapper.eq("organization_id", orgId);


        queryOrganizationVersionWrapper.eq("device_version_id", versionId);


        queryOrganizationVersionWrapper.eq("is_delete", Constants.NOT_DELETE);


        List<Device> devices = deviceMapper.selectList(queryOrganizationVersionWrapper);


        if (ObjectUtils.isEmpty(devices)) {//如果为空，则组织没有该型号的设备了。


            UpdateWrapper deleteWrapper = new UpdateWrapper();


            deleteWrapper.eq("organization_id", orgId);


            deleteWrapper.eq("version_id", versionId);


            deleteWrapper.eq("is_delete", Constants.NOT_DELETE);


            deleteWrapper.set("is_delete", Constants.DELETE);


            organizationUnitAlarmMapper.update(null, deleteWrapper);


        }


    }




    @Override


    public void setRedisDevice() {


        List<Device> list = lambdaQuery().eq(Device::getIsDelete,0).list();


        for(Device d : list){


            redisTemplate.opsForHash().delete(RedisConstants.DEVICE, d.getMac());


            Map<String, Object> deviceInfo = selectDeviceInfoById(d.getId());


            setDeviceInfoToRedis(d.getMac(), deviceInfo);


        }


    }


}