forked from moral

blame | history | patch | commit | commitdiff | ignore whitespace
cjl
2023-09-12 ea1373d4e1511b620bb87872e692643e2edb81f8 
 screen-api/src/main/java/com/moral/api/service/impl/HistoryFiveMinutelyServiceImpl.java


@@ -1,32 +1,36 @@


package com.moral.api.service.impl;




import com.alibaba.fastjson.JSONArray;


import com.moral.api.entity.Device;


import com.moral.api.entity.HistoryFiveMinutely;


import com.moral.api.entity.MonitorPoint;


import com.alibaba.fastjson.JSON;


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


import com.moral.api.config.mybatis.MybatisPlusConfig;


import com.moral.api.entity.*;


import com.moral.api.mapper.DeviceMapper;


import com.moral.api.mapper.HistoryFiveMinutelyMapper;


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


import com.moral.api.mapper.HistoryHourlyMapper;


import com.moral.api.pojo.dto.Wind.WindData;


import com.moral.api.pojo.dto.historyFiveMinutely.DeviceAndFiveMinuteDataDTO;


import com.moral.api.pojo.form.device.MonitorPointQueryForm;


import com.moral.api.pojo.form.historyFiveMinutely.QueryDeviceAndFiveMinuteDataForm;


import com.moral.api.service.DeviceService;


import com.moral.api.service.HistoryFiveMinutelyService;


import com.moral.api.service.MonitorPointService;


import com.moral.api.utils.UnitConvertUtils;


import com.moral.constant.Constants;


import com.moral.constant.RedisConstants;


import com.moral.constant.SeparateTableType;


import com.moral.util.DateUtils;




import com.moral.util.MybatisPLUSUtils;


import com.moral.util.RegionCodeUtils;


import io.lettuce.core.GeoCoordinates;


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.util.ObjectUtils;




import java.util.ArrayList;


import java.util.Collections;


import java.util.Date;


import java.util.HashMap;


import java.util.List;


import java.util.Map;


import java.util.*;




/**


 * <p>


@@ -37,56 +41,235 @@


 * @since 2021-07-15


 */


@Service


@Slf4j


public class HistoryFiveMinutelyServiceImpl extends ServiceImpl<HistoryFiveMinutelyMapper, HistoryFiveMinutely> implements HistoryFiveMinutelyService {




    @Autowired


    MonitorPointService monitorPointService;




    @Autowired


    RedisTemplate redisTemplate;


    @Autowired


    HistoryFiveMinutelyMapper historyFiveMinutelyMapper;




    @Autowired


    private HistoryFiveMinutelyMapper historyFiveMinutelyMapper;


    HistoryHourlyMapper historyHourlyMapper;


    @Autowired


    DeviceService deviceService;


    @Autowired


    DeviceMapper deviceMapper;




    @Override


    public List<DeviceAndFiveMinuteDataDTO> queryDeviceAndFiveMinuteData(QueryDeviceAndFiveMinuteDataForm form) {


    public List<Map<String, Object>> queryDeviceAndFiveMinuteData(QueryDeviceAndFiveMinuteDataForm form) {


        //取参


        String times = DateUtils.dateToDateString(new Date(),DateUtils.yyyyMM_EN);


        Integer organizationId = form.getOrganizationId();


        Integer regionCode = form.getRegionCode();


        String sensorCode = form.getSensorCode();


        String type = "$."+ sensorCode;


        String region = null;


        String endHourlyTime = null;


        if (regionCode != null && organizationId!=24) {


            region = RegionCodeUtils.regionCodeConvertToName(regionCode);


        }


        if (form.getChooseTime().equals("true")) {


            endHourlyTime = form.getTime();


            Date time = DateUtils.convertDate(endHourlyTime);


            times = DateUtils.dateToDateString(time,DateUtils.yyyyMM_EN);


        }


        List<Map<String, Object>> listAll = deviceMapper.deviceList(organizationId,regionCode,region,type,sensorCode,times,endHourlyTime);


        //查询组织在对应地区下的站点以及设备


        List<MonitorPoint> monitorPoints = monitorPointService.queryByOrgIdAndRegionCode(new MonitorPointQueryForm(organizationId, regionCode));


        /*List<MonitorPoint> monitorPoints = monitorPointService.queryByOrgIdAndRegionCode(new MonitorPointQueryForm(organizationId, regionCode));


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


        for (MonitorPoint monitorPoint : monitorPoints) {


            List<Device> monitorPointDevices = monitorPoint.getDevices();


            if (!ObjectUtils.isEmpty(monitorPointDevices))


                devices.addAll(monitorPointDevices);


        }


            if (!ObjectUtils.isEmpty(monitorPointDevices)) {


                //过滤掉线设备


                for (Device device : monitorPointDevices) {


                    if (!device.getState().equals(Constants.DEVICE_STATE_OFFLINE))


                        devices.add(device);


                }


            }




        }*/


        //查询所有设备对应的数据


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


        List<DeviceAndFiveMinuteDataDTO> dtos = new ArrayList<>();


        if (form.getChooseTime().equals("true")) {


            String time = form.getTime();


            String timeUnits = DateUtils.stringToDateString(time, "yyyy-MM-dd HH:mm", DateUtils.yyyyMM_EN);


            for (Device device : devices) {


                DeviceAndFiveMinuteDataDTO dto = new DeviceAndFiveMinuteDataDTO();


                String mac = device.getMac();


                String dbDataStr = historyHourlyMapper.queryLastHourlyMac(mac, time, timeUnits);


//                String dbDataStr = historyFiveMinutelyMapper.queryLastFiveMinutely(mac, time, timeUnits);


                HashMap sensorValues = JSON.parseObject(dbDataStr, HashMap.class);


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


                if (sensorValues != null && sensorValues.get(sensorCode) != null)


                    sensorValue.put(sensorCode, sensorValues.get(sensorCode));


                else


                    sensorValue.put(sensorCode, null);


                dto.setDevice(device);


                dto.setSensorValue(sensorValue);


                dtos.add(dto);


            }


            return dtos;


        }


        //List<Map<String, Object>> sensorValuess = (List<Map<String, Object>>) redisTemplate.opsForValue().multiGet(Arrays.asList("data_five_minutes:p5dnd7a0245400","data_five_minutes:p5dnd7a0245412"));


        for (Device device : devices) {


            DeviceAndFiveMinuteDataDTO dto = new DeviceAndFiveMinuteDataDTO();


            String mac = device.getMac();


            Map<String, Object> sensorValues = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DATA_FIVE_MINUTES, mac);


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


            Map<String, Object> sensorValues = queryLastDataByMac(mac);




            String dbDataStr = JSON.toJSONString(sensorValues);


            sensorValues = JSON.parseObject(dbDataStr, HashMap.class);


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


            if (sensorValues != null && sensorValues.get(sensorCode) != null)


                value.put(sensorCode, sensorValues.get(sensorCode));


                sensorValue.put(sensorCode, sensorValues.get(sensorCode));


            else


                value.put(sensorCode, null);


                sensorValue.put(sensorCode, null);


            dto.setDevice(device);


            dto.setSensorValue(value);


            dto.setSensorValue(sensorValue);


            dtos.add(dto);


        }


        return dtos;


        }*/


        return listAll;


    }




    @Override


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


        //从缓存中获取


        Map<String, Object> sensorValues = (Map<String, Object>) redisTemplate.opsForHash().get(RedisConstants.DATA_FIVE_MINUTES, mac);


        //如果没有数据从数据库查询


        if (sensorValues != null)


            return sensorValues;


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


        queryWrapper.eq("mac", mac);


        queryWrapper.orderByDesc("time");


        queryWrapper.last("limit 0,1");


        //获取当月的表名


        Date date = new Date();


        List<String> tableNames = MybatisPLUSUtils.getTableNamesByWrapper(date, date, SeparateTableType.MONTH);


        List<HistoryFiveMinutely> datas = multiTableQuery(queryWrapper, tableNames);


        if (ObjectUtils.isEmpty(datas))


            return null;


        HistoryFiveMinutely historyFiveMinutely = datas.get(0);


        sensorValues = JSON.parseObject(historyFiveMinutely.getValue(), Map.class);


        sensorValues.put("dataTime", DateUtils.dateToDateString(historyFiveMinutely.getTime(), "yyyy-MM-dd HH:mm:ss"));


        return sensorValues;


    }






    @Override


    public List<Object> getAreaWindData(Map<String, Object> params) {


        String timeUnits = DateUtils.dateToDateString(new Date(), DateUtils.yyyyMM_EN);


        params.put("timeUnits", timeUnits);


        //风场数据


        List<WindData> windData = historyFiveMinutelyMapper.getAreaWindData(params);


//        String timeUnits = DateUtils.dateToDateString(new Date(), DateUtils.yyyyMM_EN);


//        params.put("timeUnits", timeUnits);


//        //风场数据


//        List<WindData> windData = historyFiveMinutelyMapper.getAreaWindData(params);


//        return getWindData(windData);


        String chooseTime = params.get("chooseTime").toString();


        List<WindData> windData = null;


        if (chooseTime.equals("true")) {


            String time = params.get("time").toString();


            String timeUnits = DateUtils.stringToDateString(time, "yyyy-MM-dd HH:mm", DateUtils.yyyyMM_EN);


            params.put("timeUnits", timeUnits);


            windData = historyHourlyMapper.getArea(params);


        } else {


            String timeUnits = DateUtils.dateToDateString(new Date(), DateUtils.yyyyMM_EN);


            params.put("timeUnits", timeUnits);


            //风场数据


            windData = historyFiveMinutelyMapper.getAreaWindData(params);


        }


        return getWindData(windData);


    }






    //获取五分钟弹窗数据


    @Override


    public Map<String, Object> getPopDataByMac(Map<String, Object> params) {


//        Map<String, Object> datas = queryLastDataByMac(mac);


        String chooseTime = params.get("chooseTime").toString();


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


        Map<String, Object> datas = null;


        if (chooseTime.equals("true")) {


            String time = params.get("time").toString();


            String timeUnits = DateUtils.stringToDateString(time, "yyyy-MM-dd HH:mm", DateUtils.yyyyMM_EN);


            String dbDataStr = historyHourlyMapper.queryLastHourlyMac(mac, time, timeUnits);


            if (dbDataStr == null) {


                return null;


            }


//            String dbDataStr = historyFiveMinutelyMapper.queryLastFiveMinutely(mac, time, timeUnits);


            datas = JSON.parseObject(dbDataStr, HashMap.class);


            datas.put("dataTime", time);


        } else {


            datas = queryLastDataByMac(mac);


            if (ObjectUtils.isEmpty(datas)){


                return null;


            }


        }


        //构建返回对象


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


        //创建返回因子code集合


        List<String> sensorCodes = Arrays.asList("a34004", "a34002", "a21005", "a21004", "a21026", "a05024", "a99054", "a01008", "a01007");


        //获取设备信息


        Device device = deviceService.getDeviceUnitAlramInforByMac(mac);


        //转换数据单位和名称


        for (Sensor sensor : device.getVersion().getSensors()) {


            if (!sensorCodes.contains(sensor.getCode()))


                continue;


            Object dataO = datas.get(sensor.getCode());


            if (dataO != null) {


                String data = String.valueOf(dataO);


                //转换单位


                if (!sensor.getShowUnitKey().equals(sensor.getUnitKey()))


                    data = UnitConvertUtils.calculate(data, sensor.getFormula());


                //拼接单位


                data = data + " " + sensor.getShowUnit();


                result.put(sensor.getCode(), data);


            } else {


                result.put(sensor.getCode(), "-");


            }


        }


        //添加设备名称


        result.put("name", device.getName());


        //添加时间


        result.put("dataTime", datas.get("dataTime"));


        //排序


        return orderSixParam(result);


    }




    //对六参以及时间进行排序


    private Map<String, Object> orderSixParam(Map<String, Object> data) {


        LinkedHashMap result = new LinkedHashMap();


        Object PM2_5 = data.get("a34004");


        Object PM10 = data.get("a34002");


        Object SO2 = data.get("a21026");


        Object NO2 = data.get("a21004");


        Object CO = data.get("a21005");


        Object O3 = data.get("a05024");


        Object a01008 = data.get("a01008");


        Object a01007 = data.get("a01007");


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


        Object time = data.get("dataTime");


        if (name != null)


            result.put("名称", name);


        if (PM2_5 != null)


            result.put("PM2.5", PM2_5);


        if (PM10 != null)


            result.put("PM10", PM10);


        if (SO2 != null)


            result.put("二氧化硫（SO₂）", SO2);


        if (NO2 != null)


            result.put("二氧化氮（NO₂）", NO2);


        if (CO != null)


            result.put("一氧化碳（CO）", CO);


        if (O3 != null)


            result.put("臭氧（O₃）", O3);


        if (time != null)


            result.put("时间", time);


        if (a01008 != null)


            result.put("风向", a01008);


        if (a01007 != null)


            result.put("风速", a01007);


        return result;


    }






@@ -140,7 +323,9 @@


        List<Object> list = new ArrayList<>();


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


        for (WindData data : windData) {


            //经度


            Double longitude = data.getLongitude();


            //纬度


            Double latitude = data.getLatitude();


            GeoCoordinates geoCoordinates = GeoCoordinates.create(longitude, latitude);


            points.add(geoCoordinates);


@@ -148,14 +333,18 @@


            laList.add(latitude);




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


            //风向


            Double windDir = data.getWindDir();


            //风速


            Double windSpeed = data.getWindSpeed();


            if (windDir == null) {


                windDir = 0d;


                windSpeed = 0d;


            }


            double dir = (360.0 - (windDir + 180.0) * Math.PI / 180.0);


            //余弦值


            U = windSpeed * Math.cos(dir);


            //三角正弦值


            V = windSpeed * Math.sin(dir);


            map.put("lo", longitude);


            map.put("la", latitude);


@@ -180,17 +369,23 @@


        laLaMap.put("minLo", lomi);


        laLaMap.put("maxLa", lama);


        laLaMap.put("minLa", lami);




        Double lo1 = lomi - length * 0.00001141;


       //Double lo1 = lomi - length * 0.000001141 * 2;


        Double lo2 = loma + length * 0.00001141;


       //Double lo2 = loma + length * 0.000001141 * 2;


       //Double la2 = lami - length * 0.000000899 * 2;


        Double la2 = lami - length * 0.00000899;


        //Double la1 = lama + length * 0.000000899 * 2;


        Double la1 = lama + length * 0.00000899;




        double dx = 0.00001141 * perdlen;


        double dy = 0.00000899 * perdlen;




       //double dx = 0.000001141 * perdlen * 2;


       //double dy = 0.000000899 * perdlen * 2;




        int nx = (int) Math.floor((lo2 - lo1) / dx);


        int ny = (int) Math.floor((la1 - la2) / dy);






        List<Double> uList = new ArrayList<>();


        List<Double> vList = new ArrayList<>();


@@ -198,6 +393,7 @@


        int y;




        for (int i = 0; i < mapList.size(); i++) {




            Double lo = (Double) mapList.get(i).get("lo");


            Double la = (Double) mapList.get(i).get("la");


            x = (int) Math.floor((lo - lo1) / dx);


@@ -247,6 +443,8 @@


                }


            }


        }






        String uData = "\"" + "data" + "\"" + ": " + uList;


        String vData = "\"" + "data" + "\"" + ": " + vList;




@@ -264,6 +462,7 @@






        String s1 = "[" + "{" + header1 + ", " + uData + "}" + ", " + "{" + header2 + ", " + vData + "}" + "]";


        //System.out.println(s1);


        JSONArray jsonArray = JSONArray.parseArray(s1);




        list.add(jsonArray);


@@ -272,4 +471,39 @@


        list.add(laLaMap);


        return list;


    }




    /**


     * @Description: 查询一段时间内某一mac的数据


     * @Param: [mac, startDate, endDate]


     * @return: java.util.List<com.moral.api.entity.HistoryHourly>


     * @Author: 陈凯裕


     * @Date: 2021/9/23


     */


    public List<HistoryFiveMinutely> getValueByMacAndTime(String mac, Date startDate, Date endDate) {


        QueryWrapper<HistoryFiveMinutely> wrapper = new QueryWrapper<>();


        wrapper.eq("mac", mac);


        wrapper.between("time", startDate, endDate);


        List<String> tableNames = MybatisPLUSUtils.getTableNamesByWrapper(startDate, endDate, SeparateTableType.MONTH);


        List<HistoryFiveMinutely> datas = multiTableQuery(wrapper, tableNames);


        return datas;


    }






    /**


     * @Description: 多表查询，传入表名集合，以及条件wrapper，返回数据


     * @Param: [wrapper, tableNames]


     * @return: java.util.List<com.moral.api.entity.HistoryHourly>


     * @Author: 陈凯裕


     * @Date: 2021/9/23


     */


    private List<HistoryFiveMinutely> multiTableQuery(QueryWrapper<HistoryFiveMinutely> wrapper, List<String> tableNames) {


        List<HistoryFiveMinutely> result = new ArrayList<>();


        for (String tableName : tableNames) {


            MybatisPlusConfig.tableName.set(tableName);


            List<HistoryFiveMinutely> datas = historyFiveMinutelyMapper.selectList(wrapper);


            result.addAll(datas);


        }


        MybatisPlusConfig.tableName.remove();


        return result;


    }


}