From 389745c23c0c279f9f79bd2aa028128beb18cd5c Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Thu, 20 Jan 2022 16:55:01 +0800
Subject: [PATCH] 热力图接口修改
---
screen-api/src/main/java/com/moral/api/service/impl/DataDisplayServiceImpl.java | 431 ++++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 387 insertions(+), 44 deletions(-)
diff --git a/screen-api/src/main/java/com/moral/api/service/impl/DataDisplayServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/DataDisplayServiceImpl.java
index 971a459..8172916 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/DataDisplayServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/DataDisplayServiceImpl.java
@@ -1,19 +1,18 @@
package com.moral.api.service.impl;
import com.alibaba.fastjson.JSON;
-import com.moral.api.entity.Device;
-import com.moral.api.entity.HistoryDaily;
+import com.moral.api.entity.*;
import com.moral.api.pojo.dto.dataDisplay.MonitorPointDataDisplayDTO;
+import com.moral.api.pojo.dto.dataDisplay.SensorComparisonDisplayDTO;
import com.moral.api.pojo.form.dataDisplay.MonitorPointDataDisplayForm;
-import com.moral.api.service.DataDisplayService;
-import com.moral.api.service.DeviceService;
-import com.moral.api.service.HistoryDailyService;
-import com.moral.api.service.OrganizationService;
-import com.moral.util.AQIUtils;
-import com.moral.util.AmendUtils;
-import com.moral.util.DateUtils;
-import com.moral.util.MathUtils;
+import com.moral.api.pojo.form.dataDisplay.SensorComparisonDisplayForm;
+import com.moral.api.service.*;
+import com.moral.constant.Constants;
+import com.moral.pojo.AQI;
+import com.moral.util.*;
import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+import org.springframework.util.ObjectUtils;
import java.util.*;
@@ -24,6 +23,7 @@
* @Date 2021/9/26 9:55
* @Version TODO
**/
+@Service
public class DataDisplayServiceImpl implements DataDisplayService {
@Autowired
@@ -31,11 +31,14 @@
@Autowired
HistoryDailyService historyDailyService;
@Autowired
- OrganizationService organizationService;
-
+ HistoryHourlyService historyHourlyService;
+ @Autowired
+ HistoryWeeklyService historyWeeklyService;
+ @Autowired
+ HistoryMonthlyService historyMonthlyService;
@Override
- public void getMonitorPointDisplayData(MonitorPointDataDisplayForm form) {
+ public List<MonitorPointDataDisplayDTO> getMonitorPointDisplayData(MonitorPointDataDisplayForm form) {
//������
Integer monitorPointId = form.getMonitorPointId();
String reportType = form.getReportType();
@@ -49,16 +52,201 @@
macs.add(value.getMac());
deviceMap.put(value.getMac(), value);
});
- //���������������������null������������������������������������������������������
- if (reportType == null) {
+ List<MonitorPointDataDisplayDTO> dtos = new ArrayList<>();
+ if (reportType == null) {//���������������������
Map<String, List<HistoryDaily>> macDataMap = new HashMap<>();//key���mac
+ //������������
macs.forEach(value -> {
+ //������������
List<HistoryDaily> datas = historyDailyService.getHistoryDailyByMacAndTimeSlot(value, startTime, endTime);
- macDataMap.put(value, datas);
+ //���������������������������������
+ if (datas.size() != 0)
+ macDataMap.put(value, datas);
});
+ //���������������������������������������
+ if (macDataMap.size() != 0)
+ dtos = calculateCustomData(macDataMap, deviceMap, startTime, endTime);
}
+ //���������������������������������������������������������
+ else if (reportType.equals(Constants.HOURLY_REPORT)) {
+ Map<String, HistoryHourly> macDataMap = new HashMap<>();
+ //������������
+ macs.forEach(value -> {
+ List<HistoryHourly> datas = historyHourlyService.getValueByMacAndTime(value, startTime, startTime);
+ if (datas.size() != 0)
+ macDataMap.put(value, datas.get(0));
+ });
+ if (macDataMap.size() != 0)
+ dtos = calculateReportData(macDataMap, deviceMap, reportType, startTime);
+ }
+ //���������������������������������������������
+ else if (reportType.equals(Constants.DAILY_REPORT)) {
+ //������������
+ Map<String, HistoryDaily> macDataMap = historyDailyService.getHistoryDailyByMacsAndDate(macs, startTime);
+ if (macDataMap.size() != 0)
+ dtos = calculateReportData(macDataMap, deviceMap, reportType, startTime);
+ }
+ //���������������������������������������������
+ else if (reportType.equals(Constants.WEEKLY_REPORT)) {
+ //������������
+ Map<String, HistoryWeekly> macDataMap = historyWeeklyService.getHistoryWeeklyByMacsAndDate(macs, startTime);
+ if (macDataMap.size() != 0)
+ dtos = calculateReportData(macDataMap, deviceMap, reportType, startTime, endTime);
+ }
+ //������������������
+ else if (reportType.equals(Constants.MONTHLY_REPORT)) {
+ //������������������������������������������������������������������������������������������������
+ Map<String, List<HistoryDaily>> macDataDailyMap = new HashMap<>();
+ Map<String, HistoryMonthly> macDataMonthlyMap = historyMonthlyService.getHistoryMonthlyByMacsAndDate(macs, startTime);
+ macs.forEach(mac -> {
+ List<HistoryDaily> dailyDatas = historyDailyService.getHistoryDailyByMacAndTimeSlot(mac, startTime, endTime);
+ if (!ObjectUtils.isEmpty(dailyDatas))
+ macDataDailyMap.put(mac, dailyDatas);
+ });
+ if (macDataMonthlyMap.size() != 0)
+ dtos = calculateReportData(macDataMonthlyMap, deviceMap, reportType, startTime);
+ //������������������
+ injectComprehensiveIndex(dtos, macDataDailyMap);
+ }
+ return dtos;
}
+ @Override
+ public List<SensorComparisonDisplayDTO> getSensorComparisonDisplayData(SensorComparisonDisplayForm form) {
+ //������
+ List<String> sensors = form.getSensors();
+ Date startDate = form.getStartDate();
+ Date endDate = form.getEndDate();
+ String mac = form.getMac();
+ String reportType = form.getReportType();
+ Map<String, String> timeValueMap = new LinkedHashMap<>();//key���time���value������������json
+ //������������������
+ if (reportType.equals(Constants.DAILY_REPORT)) {
+ List<HistoryHourly> hourlies = historyHourlyService.getValueByMacAndTime(mac, startDate, endDate);
+ for (HistoryHourly historyHourly : hourlies) {
+ Date time = historyHourly.getTime();
+ String dateStr = DateUtils.dateToDateString(time, "yyyy-MM-dd HH");
+ String value = historyHourly.getValue();
+ timeValueMap.put(dateStr, value);
+ }
+ //���������������������������������������24������������������
+ for (int i = 0; i < 24; i++) {
+ //������������
+ String time = DateUtils.dateToDateString(startDate, "yyyy-MM-dd");
+ if (i < 10)
+ time = time + " 0" + i;
+ else
+ time = time + " " + i;
+ if (timeValueMap.get(time) == null)
+ timeValueMap.put(time, null);
+ }
+ }
+ //������������������
+ else if (reportType.equals(Constants.MONTHLY_REPORT)) {
+ List<HistoryDaily> dailies = historyDailyService.getHistoryDailyByMacAndTimeSlot(mac, startDate, endDate);
+ for (HistoryDaily historyDaily : dailies) {
+ Date time = historyDaily.getTime();
+ String dateStr = DateUtils.dateToDateString(time, "yyyy-MM-dd");
+ String value = historyDaily.getValue();
+ timeValueMap.put(String.valueOf(dateStr), value);
+ }
+ //������������������������������������������������������
+ int days = DateUtils.getMonthDay(startDate);
+ for (int i = 1; i <= days; i++) {
+ //������������
+ String time = DateUtils.dateToDateString(startDate, "yyyy-MM");
+ if (i < 10)
+ time = time + "-0" + i;
+ else
+ time = time + "-" + i;
+ if (timeValueMap.get(time) == null)
+ timeValueMap.put(time, null);
+ }
+ } else
+ return null;
+ //������������
+ timeValueMap = sortMapByTime(timeValueMap, reportType);
+ //������������������
+ List<SensorComparisonDisplayDTO> dtos = new ArrayList<>();
+ for (String sensor : sensors) {
+ SensorComparisonDisplayDTO dto = new SensorComparisonDisplayDTO();
+ List<Map<String, Object>> dtoTimeValueList = new ArrayList<>();
+ dto.setSensorCode(sensor);
+ timeValueMap.forEach((time, valueJson) -> {
+ Map<String, Object> listMap = new HashMap<>();
+ //���������������������������������������������
+ if (valueJson == null) {
+ listMap.put("time", time);
+ listMap.put("value", "");
+ dtoTimeValueList.add(listMap);
+ return;
+ }
+ Map<String, Object> valueMap = JSON.parseObject(valueJson, Map.class);
+ Object sensorValueObject = valueMap.get(sensor);
+ //���������������������������������������������
+ if (sensorValueObject == null) {
+ listMap.put("time", time);
+ listMap.put("value", "");
+ dtoTimeValueList.add(listMap);
+ return;
+ }
+ //������������������������������������������
+ if (reportType.equals(Constants.DAILY_REPORT)) {
+ //���������������������N���������������
+ if (!Constants.NORMAL_FLAG.equals(valueMap.get(sensor + "-Flag"))) {
+ listMap.put("time", time);
+ listMap.put("value", "");
+ dtoTimeValueList.add(listMap);
+ return;
+ }
+ }
+ //������������
+ Double sensorValue = Double.parseDouble(sensorValueObject.toString());
+ //������������
+ listMap.put("time", time);
+ listMap.put("value", sensorValue);
+ dtoTimeValueList.add(listMap);
+ });
+ dto.setTimeValueList(dtoTimeValueList);
+ dtos.add(dto);
+ }
+ return dtos;
+ }
+
+ /**
+ * @Description: ������������������������
+ * @Param: [timeValueMap, reportType]
+ * @return: java.util.Map<java.lang.String , java.lang.String>
+ * @Author: ���������
+ * @Date: 2021/11/3
+ */
+ private Map<String, String> sortMapByTime(Map<String, String> timeValueMap, String reportType) {
+ List<Map.Entry<String, String>> entries = new ArrayList(timeValueMap.entrySet());
+ Collections.sort(entries, new Comparator<Map.Entry<String, String>>() {
+ @Override
+ public int compare(Map.Entry<String, String> o1, Map.Entry<String, String> o2) {
+ if (Constants.DAILY_REPORT.equals(reportType)) {
+ String atime = o1.getKey();
+ String btime = o2.getKey();
+ atime = atime.substring(11, 13);
+ btime = btime.substring(11, 13);
+ return Integer.parseInt(atime) - Integer.parseInt(btime);
+ } else if (Constants.MONTHLY_REPORT.equals(reportType)) {
+ String atime = o1.getKey();
+ String btime = o2.getKey();
+ atime = atime.substring(8, 10);
+ btime = btime.substring(8, 10);
+ return Integer.parseInt(atime) - Integer.parseInt(btime);
+ }
+ return 0;
+ }
+ });
+ Map<String, String> sortedMap = new LinkedHashMap<>();
+ for (Map.Entry<String, String> entry : entries) {
+ sortedMap.put(entry.getKey(), entry.getValue());
+ }
+ return sortedMap;
+ }
/**
* @Description: ������������������������������
@@ -67,20 +255,18 @@
* @Author: ���������
* @Date: 2021/9/26
*/
- private void calculateCustomData(Map<String, List<HistoryDaily>> macDataMap, Map<String, Device> deviceMap, Date startDate, Date endDate) {
+ private List<MonitorPointDataDisplayDTO> calculateCustomData(Map<String, List<HistoryDaily>> macDataMap, Map<String, Device> deviceMap, Date startDate, Date endDate) {
List<MonitorPointDataDisplayDTO> dtos = new ArrayList<>();
macDataMap.forEach((key, value) -> {
MonitorPointDataDisplayDTO dto = new MonitorPointDataDisplayDTO();
+ dto.setMac(key);
//������������������
String deviceName = deviceMap.get(key).getName();
- //������������������
- organizationService.getOrganizationById(deviceMap.get(key).getOrganizationId());
//������������
String startTime = DateUtils.dateToDateString(startDate, "yyyy-MM-dd");
String endTime = DateUtils.dateToDateString(endDate, "yyyy-MM-dd");
String time = startTime + " - " + endTime;
//������������������
- Double AQINum = 0d;
Double PM25Num = 0d;
Double PM10Num = 0d;
Double SO2Num = 0d;
@@ -88,8 +274,7 @@
Double CONum = 0d;
Double O3Num = 0d;
Double TVOCNum = 0d;
- //������AQI,PM2.5,PM10,SO2,NO2,CO,O3,TVOC���������
- Double AQISum = 0d;
+ //������PM2.5,PM10,SO2,NO2,CO,O3,TVOC���������
Double PM25Sum = 0d;
Double PM10Sum = 0d;
Double SO2Sum = 0d;
@@ -135,39 +320,197 @@
TVOCSum = MathUtils.add(TVOCSum, Double.valueOf(TVOC.toString()));
TVOCNum++;
}
- //���AQI
- int aqi = AQIUtils.hourlyAqi(valueMap);
- if (aqi != 0) {
- AQISum += Double.valueOf(aqi);
- }
}
- //������aqi������
- double AQID = AmendUtils.sciCal(AQISum / AQINum, 0);
- int AQIAvg = new Double(AQID).intValue();
//������PM2.5������
- double PM25D = AmendUtils.sciCal(PM25Sum / PM25Num, 0);
- int PM25Avg = new Double(PM25D).intValue();
+ if (PM25Num != 0d) {
+ Double PM25D = AmendUtils.sciCal(PM25Sum / PM25Num, 0);
+ int PM25Avg = new Double(PM25D).intValue();
+ dto.setA34004(PM25Avg);
+ }
//������PM10������
- double PM10D = AmendUtils.sciCal(PM10Sum / PM10Num,0);
- int PM10Avg = new Double(PM10D).intValue();
+ if (PM10Num != 0d) {
+ Double PM10D = AmendUtils.sciCal(PM10Sum / PM10Num, 0);
+ int PM10Avg = new Double(PM10D).intValue();
+ dto.setA34002(PM10Avg);
+ }
//������SO2������
- double SO2D = AmendUtils.sciCal(SO2Sum / SO2Num,0);
- int SO2Avg = new Double(SO2D).intValue();
+ if (SO2Num != 0d) {
+ Double SO2D = AmendUtils.sciCal(SO2Sum / SO2Num, 0);
+ int SO2Avg = new Double(SO2D).intValue();
+ dto.setA21026(SO2Avg);
+ }
//������NO2������
- double NO2D = AmendUtils.sciCal(NO2Sum / NO2Num,0);
- int NO2Avg = new Double(NO2D).intValue();
+ if (NO2Num != 0d) {
+ Double NO2D = AmendUtils.sciCal(NO2Sum / NO2Num, 0);
+ int NO2Avg = new Double(NO2D).intValue();
+ dto.setA21004(NO2Avg);
+ }
//������CO���������������������������
- double COAvg = AmendUtils.sciCal(COSum / CONum,2);
+ if (CONum != 0d) {
+ Double COAvg = AmendUtils.sciCal(COSum / CONum, 2);
+ dto.setA21005(COAvg);
+ }
//������O3������
- double O3D = AmendUtils.sciCal(O3Sum / O3Num,0);
- int O3Avg = new Double(O3D).intValue();
+ if (O3Num != 0d) {
+ Double O3D = AmendUtils.sciCal(O3Sum / O3Num, 0);
+ int O3Avg = new Double(O3D).intValue();
+ dto.setA05024(O3Avg);
+ }
//������TVOC������,������������������
- double TVOCAvg = AmendUtils.sciCal(TVOCSum / TVOCNum,2);
-
-
+ if (TVOCNum != 0d) {
+ Double TVOCAvg = AmendUtils.sciCal(TVOCSum / TVOCNum, 2);
+ dto.setA99054(TVOCAvg);
+ }
+ //������AQI
+ Map<String,Object> sixParamMap = new HashMap<>();
+ sixParamMap.put("a05024",dto.getA05024());
+ sixParamMap.put("a21004",dto.getA21004());
+ sixParamMap.put("a21005",dto.getA21005());
+ sixParamMap.put("a34002",dto.getA34002());
+ sixParamMap.put("a34004",dto.getA34004());
+ sixParamMap.put("a21026",dto.getA21026());
+ AQI aqi = AQIUtils.dailyAQI(sixParamMap);
+ dto.setAQI(aqi.getAQIValue());
+ dto.setDeviceName(deviceName);
+ dto.setTime(time);
+ dtos.add(dto);
});
+ return dtos;
}
+ /**
+ * @Description: ���������������������, ������,���������������(���������6������AQI���TVOC)
+ * @Param: [macDataMap, deviceMap, startDate]
+ * @return: java.util.List<com.moral.api.pojo.dto.dataDisplay.MonitorPointDataDisplayDTO>
+ * @Author: ���������
+ * @Date: 2021/9/28
+ */
+ private <T> List<MonitorPointDataDisplayDTO> calculateReportData(Map<String, T> macDataMap, Map<String, Device> deviceMap, String reportType, Date... date) {
+ List<MonitorPointDataDisplayDTO> dtos = new ArrayList<>();
+ macDataMap.forEach((key, valueObject) -> {
+ MonitorPointDataDisplayDTO dto = new MonitorPointDataDisplayDTO();
+ dto.setMac(key);
+ //���������map
+ Map<String, Object> valueMap;
+ //���������������value���������
+ Object valueO = ClassUtils.getPropertyValue(valueObject, "value");
+ if (valueO == null)
+ return;
+ String value = (String) valueO;
+ valueMap = JSON.parseObject(value, Map.class);
+ //������������������
+ String deviceName = deviceMap.get(key).getName();
+ dto.setDeviceName(deviceName);
+ //������������,������������������������������������������������������������������������������������������������������
+ String startTime = "";
+ if (valueObject instanceof HistoryHourly && date.length == 1)
+ startTime = DateUtils.dateToDateString(date[0], "yyyy-MM-dd HH:mm:ss");
+ else if (valueObject instanceof HistoryDaily && date.length == 1)
+ startTime = DateUtils.dateToDateString(date[0], "yyyy-MM-dd");
+ else if (valueObject instanceof HistoryWeekly && date.length == 2)
+ startTime = DateUtils.dateToDateString(date[0], "yyyy-MM-dd") + " -- " + DateUtils.dateToDateString(date[1], "yyyy-MM-dd");
+ else if (valueObject instanceof HistoryMonthly && date.length == 1)
+ startTime = DateUtils.dateToDateString(date[0], "yyyy-MM");
+ dto.setTime(startTime);
+ //������������
+ injectDataToDto(valueMap, false, dto, reportType);
+ dtos.add(dto);
+ });
+ return dtos;
+ }
+
+
+ /**
+ * @Description: ���DTO���������������������������������������������������������������flag������true���������������false
+ * @Param: [valueMap, flag, dto]
+ * @return: void
+ * @Author: ���������
+ * @Date: 2021/9/28
+ */
+ private void injectDataToDto(Map<String, Object> valueMap, boolean flag, MonitorPointDataDisplayDTO dto, String reportType) {
+ //������CO
+ String COFlag = (String) valueMap.get("a21005-Flag");
+ Object COObject = valueMap.get("a21005");
+ if ((flag == false || Constants.NORMAL_FLAG.equals(COFlag)) && COObject != null) {
+ Double CO = Double.valueOf(COObject.toString());
+ dto.setA21005(AmendUtils.sciCal(CO, 2));
+ }
+ //������SO2
+ String SO2Flag = (String) valueMap.get("a21026-Flag");
+ Object SO2Object = valueMap.get("a21026");
+ if ((flag == false || Constants.NORMAL_FLAG.equals(SO2Flag)) && SO2Object != null) {
+ Double SO2 = Double.valueOf(SO2Object.toString());
+ dto.setA21026(new Double(AmendUtils.sciCal(SO2, 0)).intValue());
+ }
+ //������NO2
+ String NO2Flag = (String) valueMap.get("a21004-Flag");
+ Object NO2Object = valueMap.get("a21004");
+ if ((flag == false || Constants.NORMAL_FLAG.equals(NO2Flag)) && NO2Object != null) {
+ Double NO2 = Double.valueOf(NO2Object.toString());
+ dto.setA21004(new Double(AmendUtils.sciCal(NO2, 0)).intValue());
+ }
+ //������PM10
+ String PM10Flag = (String) valueMap.get("a34002-Flag");
+ Object PM10Object = valueMap.get("a34002");
+ if ((flag == false || Constants.NORMAL_FLAG.equals(PM10Flag)) && PM10Object != null) {
+ Double PM10 = Double.valueOf(PM10Object.toString());
+ dto.setA34002(new Double(AmendUtils.sciCal(PM10, 0)).intValue());
+ }
+ //������TVOC
+ String TVOCFlag = (String) valueMap.get("a99054-Flag");
+ Object TVOCObject = valueMap.get("a99054");
+ if ((flag == false || Constants.NORMAL_FLAG.equals(TVOCFlag)) && TVOCObject != null) {
+ Double TVOC = Double.valueOf(TVOCObject.toString());
+ dto.setA99054(AmendUtils.sciCal(TVOC, 2));
+ }
+ //������PM2.5
+ String PM25Flag = (String) valueMap.get("a34004-Flag");
+ Object PM25Object = valueMap.get("a34004");
+ if ((flag == false || Constants.NORMAL_FLAG.equals(PM25Flag)) && PM25Object != null) {
+ Double PM25 = Double.valueOf(PM25Object.toString());
+ dto.setA34004(new Double(AmendUtils.sciCal(PM25, 0)).intValue());
+ }
+ //������O3
+ String O3Flag = (String) valueMap.get("a05024-Flag");
+ Object O3Object = valueMap.get("a05024");
+ if ((flag == false || Constants.NORMAL_FLAG.equals(O3Flag)) && O3Object != null) {
+ Double O3 = Double.valueOf(O3Object.toString());
+ dto.setA05024(new Double(AmendUtils.sciCal(O3, 0)).intValue());
+ }
+ //������AQI
+ Integer aqi;
+ if (reportType.equals(Constants.HOURLY_REPORT)) {
+ aqi = AQIUtils.hourlyAQI(valueMap).getAQIValue();
+ } else {
+ aqi = AQIUtils.dailyAQI(valueMap).getAQIValue();
+ }
+ dto.setAQI(aqi);
+ }
+
+
+ /**
+ * @Description: ������������������������
+ * @Param: [dtos, macDataDailyMap]
+ * @return: void
+ * @Author: ���������
+ * @Date: 2021/9/29
+ */
+ private void injectComprehensiveIndex(List<MonitorPointDataDisplayDTO> dtos, Map<String, List<HistoryDaily>> macDataDailyMap) {
+ Map<String, MonitorPointDataDisplayDTO> macDtoMap = new HashMap<>();
+ dtos.forEach(value -> macDtoMap.put(value.getMac(), value));
+ macDataDailyMap.forEach((key, value) -> {
+ List<Map<String, Object>> list = new ArrayList<>();
+ for (HistoryDaily historyDaily : value) {
+ Map valueMap = JSON.parseObject(historyDaily.getValue(), Map.class);
+ list.add(valueMap);
+ }
+ Double comIndex = ComprehensiveIndexUtils.monthData(list);
+ MonitorPointDataDisplayDTO dto = macDtoMap.get(key);
+ if (dto != null)
+ dto.setComIndex(comIndex);
+ });
+ }
}
+
--
Gitblit v1.8.0