blame | history | patch | commit | commitdiff | ignore whitespace
swb
2024-08-26 d56ba0ec51cf2b0afa00bbf6ddb0c02ac16393fa 
 screen-manage/src/main/java/com/moral/api/service/impl/DeviceServiceImpl.java


@@ -4,6 +4,7 @@


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.googlecode.aviator.AviatorEvaluator;


import com.googlecode.aviator.Expression;


@@ -22,7 +23,6 @@


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;


@@ -36,6 +36,8 @@


import java.beans.PropertyDescriptor;


import java.lang.reflect.Field;


import java.lang.reflect.Method;


import java.lang.reflect.Type;


import java.text.SimpleDateFormat;


import java.util.*;


import java.util.stream.Collectors;




@@ -189,7 +191,7 @@


        //设备信息存入redis


        setDeviceInfoToRedis(mac, deviceInfo);


        //刷新deviceInfo缓存


        CacheUtils.refreshDeviceAlarmInfo();


        CacheUtils.refreshDeviceAlarmInfo(mac);


        //操作日志记录


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


        StringBuilder content = new StringBuilder();


@@ -289,9 +291,10 @@


            queryWrapper.eq("monitor_point_id", mpId);


        }






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


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


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


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


        }




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


@@ -304,7 +307,9 @@


        } else {


            queryWrapper.orderByDesc("create_time");


        }


        //过滤已删除的数据


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




        Page<Device> devicePage = new Page<>(page, size);


        deviceMapper.selectPage(devicePage, queryWrapper);


        List<Device> devices = devicePage.getRecords();


@@ -442,8 +447,9 @@


    }




    @Override


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


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


    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)) {


@@ -454,7 +460,7 @@


            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);


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


        }


        deviceData.remove("DataTime");


        return deviceData;


@@ -462,7 +468,8 @@




    @Override


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


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


//        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)) {


@@ -473,14 +480,13 @@


            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);


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


        }


        deviceData.remove("DataTime");


        return deviceData;


    }




    @Override


    @Transactional


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


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


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


@@ -498,44 +504,47 @@


            String sensorCode = sensor.getCode();


            //转换公式


            String formula = sensor.getFormula();


            //转换单位前因子值


            String sensorValue = (String) 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;




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


            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;


                }


            }


        }


        //修改设备状态


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


        updateWrapper.eq("id", device.getId()).set("state", String.valueOf(state));


        deviceMapper.update(null, updateWrapper);


        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);


        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<>();


        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);


            deviceQueryWrapper.eq("monitor_point_id", mp_id);


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


            devices = deviceMapper.selectList(deviceQueryWrapper);


            resultMap.put("devices",devices);


            resultMap.put("devices", devices);


            resultList.add(resultMap);


        }


        return resultList;


@@ -547,7 +556,7 @@


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


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


            if (data >= level) {


                state = i + 1;


                state = i + 2;


                break;


            }


        }


@@ -618,4 +627,14 @@


            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);


        }


    }


}