From 2dee01ae6f13a72b1d2ba9ca3d1ffbea72ab513b Mon Sep 17 00:00:00 2001
From: kaiyu <404897439@qq.com>
Date: Sat, 09 Oct 2021 08:59:28 +0800
Subject: [PATCH] screen-aqi 增加监测因子对比图接口
---
screen-api/src/main/java/com/moral/api/service/impl/DataDisplayServiceImpl.java | 66 +++++++++++++++++++++++++++++++--
1 files changed, 62 insertions(+), 4 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 ac689eb..1f34fd1 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
@@ -3,7 +3,9 @@
import com.alibaba.fastjson.JSON;
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.pojo.form.dataDisplay.SensorComparisonDisplayForm;
import com.moral.api.service.*;
import com.moral.constant.Constants;
import com.moral.util.*;
@@ -65,7 +67,7 @@
dtos = calculateCustomData(macDataMap, deviceMap, startTime, endTime);
}
//���������������������������������������������������������
- else if (reportType.equals(Constants.HOURYLYREPORT)) {
+ else if (reportType.equals(Constants.HOURLY_REPORT)) {
Map<String, HistoryHourly> macDataMap = new HashMap<>();
//������������
macs.forEach(value -> {
@@ -77,21 +79,21 @@
dtos = calculateReportData(macDataMap, deviceMap, startTime);
}
//���������������������������������������������
- else if (reportType.equals(Constants.DAILYREPORT)) {
+ else if (reportType.equals(Constants.DAILY_REPORT)) {
//������������
Map<String, HistoryDaily> macDataMap = historyDailyService.getHistoryDailyByMacsAndDate(macs, startTime);
if (macDataMap.size() != 0)
dtos = calculateReportData(macDataMap, deviceMap, startTime);
}
//���������������������������������������������
- else if (reportType.equals(Constants.WEEKLYREPORT)) {
+ else if (reportType.equals(Constants.WEEKLY_REPORT)) {
//������������
Map<String, HistoryWeekly> macDataMap = historyWeeklyService.getHistoryWeeklyByMacsAndDate(macs, startTime);
if (macDataMap.size() != 0)
dtos = calculateReportData(macDataMap, deviceMap, startTime, endTime);
}
//������������������
- else if (reportType.equals(Constants.MONTHLYREPORT)) {
+ else if (reportType.equals(Constants.MONTHLY_REPORT)) {
//������������������������������������������������������������������������������������������������
Map<String, List<HistoryDaily>> macDataDailyMap = new HashMap<>();
Map<String, HistoryMonthly> macDataMonthlyMap = historyMonthlyService.getHistoryMonthlyByMacsAndDate(macs, startTime);
@@ -108,6 +110,62 @@
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();
+ int hour = DateUtils.getHour(time);
+ String value = historyHourly.getValue();
+ timeValueMap.put(String.valueOf(hour), value);
+ }
+ }
+ //������������������
+ else if (reportType.equals(Constants.MONTHLY_REPORT)) {
+ List<HistoryDaily> dailies = historyDailyService.getHistoryDailyByMacAndTimeSlot(mac, startDate, endDate);
+ for (HistoryDaily historyDaily : dailies) {
+ Date time = historyDaily.getTime();
+ int day = DateUtils.getDay(time);
+ String value = historyDaily.getValue();
+ timeValueMap.put(String.valueOf(day), value);
+ }
+ } else
+ return null;
+ //������������������
+ List<SensorComparisonDisplayDTO> dtos = new ArrayList<>();
+ for (String sensor : sensors) {
+ SensorComparisonDisplayDTO dto = new SensorComparisonDisplayDTO();
+ Map<String,Double> dtoTimeValueMap = new LinkedHashMap<>();
+ dto.setSensorCode(sensor);
+ timeValueMap.forEach((time, valueJson) -> {
+ Map<String, Object> valueMap = JSON.parseObject(valueJson, Map.class);
+ Object sensorValueObject = valueMap.get(sensor);
+ if(sensorValueObject==null)
+ return;
+ Double sensorValue = Double.parseDouble(sensorValueObject.toString());
+ //������������������������������������������
+ if(reportType.equals(Constants.HOURLY_REPORT)){
+ if(!Constants.NORMAL_FLAG.equals(valueMap.get(sensor+"-Flag")))
+ return;
+ }
+ //������������
+ dtoTimeValueMap.put(time,sensorValue);
+ dto.setTimeValueMap(dtoTimeValueMap);
+ });
+ dtos.add(dto);
+ }
+ return dtos;
+ }
+
/**
* @Description: ������������������������������
--
Gitblit v1.8.0