From 6ae790cc95cf87e40f0f1fa49ed04fb722530211 Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Fri, 06 Aug 2021 17:22:15 +0800
Subject: [PATCH] 均值计算加入数据有效性限制条件
---
screen-job/src/main/java/com/moral/api/service/impl/HistoryFiveMinutelyServiceImpl.java | 83 ++++++-
screen-job/src/main/java/com/moral/api/service/impl/HistoryWeeklyServiceImpl.java | 93 ++++++-
screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java | 97 +++++++-
screen-common/src/main/java/com/moral/constant/Constants.java | 26 +
screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java | 93 +++++++-
screen-common/src/main/java/com/moral/util/AmendUtils.java | 158 ++++++++++++-
screen-job/src/main/java/com/moral/api/service/impl/HistoryMonthlyServiceImpl.java | 86 ++++++-
7 files changed, 532 insertions(+), 104 deletions(-)
diff --git a/screen-common/src/main/java/com/moral/constant/Constants.java b/screen-common/src/main/java/com/moral/constant/Constants.java
index 116acc7..853de80 100644
--- a/screen-common/src/main/java/com/moral/constant/Constants.java
+++ b/screen-common/src/main/java/com/moral/constant/Constants.java
@@ -147,7 +147,7 @@
/*
* ������code
* */
- public static final String SENSOR_CODE_WIND_DIR = "a01008";
+ public static final String SENSOR_CODE_WIND_DIR = "a01007";
/*
* ������code
@@ -157,29 +157,41 @@
/*
* ������������code
* */
- public static final String SENSOR_CODE_CO= "a21005";
+ public static final String SENSOR_CODE_CO = "a21005";
/*
* PM2.5 code
* */
- public static final String SENSOR_CODE_PM25= "a34004";
+ public static final String SENSOR_CODE_PM25 = "a34004";
/*
* PM10 code
* */
- public static final String SENSOR_CODE_PM10= "a34002";
+ public static final String SENSOR_CODE_PM10 = "a34002";
/*
* SO2 code
* */
- public static final String SENSOR_CODE_SO2= "a21026";
+ public static final String SENSOR_CODE_SO2 = "a21026";
/*
* NO2 code
* */
- public static final String SENSOR_CODE_NO2= "a21004";
+ public static final String SENSOR_CODE_NO2 = "a21004";
- /** The Constant NULL_VALUE. */
+ /**
+ * The Constant NULL_VALUE.
+ */
public static final String NULL_VALUE = "N/V";
+ //������������������������,������
+ public static final String MARKER_BIT_TRUE = "N";
+
+ //������������������������,���������������
+ public static final String MARKER_BIT_FALSE = "H";
+
+ //������������������������������������������key������
+ public static final String MARKER_BIT_KEY = "-Flag";
+
+
}
diff --git a/screen-common/src/main/java/com/moral/util/AmendUtils.java b/screen-common/src/main/java/com/moral/util/AmendUtils.java
index 9e15cb5..960de0b 100644
--- a/screen-common/src/main/java/com/moral/util/AmendUtils.java
+++ b/screen-common/src/main/java/com/moral/util/AmendUtils.java
@@ -1,9 +1,12 @@
package com.moral.util;
+import org.springframework.util.ObjectUtils;
+
import java.math.BigDecimal;
import java.util.ArrayList;
import java.util.Collections;
import java.util.Date;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
@@ -40,10 +43,14 @@
}
/**
- * @param list ���������[value={"O3"���12},.....]
+ * @param params ���������������������data���������type���������upper���������lower
* @return ������������������������������
*/
- public static Object getO3AvgOfDay(List<Map<String, Object>> list) {
+ public static Map<String, Object> getO3AvgOfDay(Map<String, Object> params) {
+ Map<String, Object> result = new HashMap<>();
+ List<Map<String, Object>> list = (List<Map<String, Object>>) params.get("data");
+ Object upper = params.get("o3Upper");
+ Object lower = params.get("o3Lower");
double max;
List<Double> avgs = new ArrayList<>();
for (int i = 8; i <= 24; i++) {
@@ -51,6 +58,26 @@
for (Map<String, Object> dataMap : list) {
Map<String, Object> dataValue = JSONObject.parseObject((String) dataMap.get("value"), Map.class);
Double o3 = Double.parseDouble(dataValue.get(Constants.SENSOR_CODE_O3).toString());
+
+ //O3���������������
+ Object flag = dataValue.get(Constants.SENSOR_CODE_O3 + Constants.MARKER_BIT_KEY);
+ //������������������������������
+ if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
+ continue;
+ }
+
+ //������������������������������
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (o3 < (Double) upper) {
+ continue;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (o3 > (Double) upper) {
+ continue;
+ }
+ }
+
int hour = DateUtils.getHour((Date) dataMap.get("time"));
if (hour == 0) {
hour = 24;
@@ -68,39 +95,81 @@
max = avgs.stream().mapToDouble(aDouble -> aDouble).summaryStatistics().getMax();
if (avgs.size() < 14) {
if (max < 160d) {
- return null;
+ return result;
}
}
- return sciCal(max, 4);
+ result.put(Constants.SENSOR_CODE_O3, sciCal(max, 4));
+ return result;
}
/**
- * @param list ���������[value={"������"���12������������������200},.....]
+ * @param params ������
* @return ���������������������������
*/
- public static Object getWindDirAvg(List<Map<String, Object>> list) {
+ public static Map<String, Object> getWindDirAvg(Map<String, Object> params) {
+ Map<String, Object> result = new HashMap<>();
+ List<Map<String, Object>> data = (List<Map<String, Object>>) params.get("data");
+ String type = params.get("type").toString();
+ Object windDirUpper = params.get("windDirUpper");
+ Object windDirLower = params.get("windDirLower");
+ Object windSpeedUpper = params.get("windSpeedUpper");
+ Object windSpeedLower = params.get("windSpeedLower");
+
double avgDir;
double sumSin = 0d;
double sumCos = 0d;
int size = 0;
- for (Map<String, Object> map : list) {
+ for (Map<String, Object> map : data) {
Map<String, Object> dataValue = JSONObject.parseObject((String) map.get("value"), Map.class);
Object wind = dataValue.get(Constants.SENSOR_CODE_WIND_DIR);
Object speed = dataValue.get(Constants.SENSOR_CODE_WIND_SPEED);
- if (wind == null || speed == null) {
+ Object flagDir = dataValue.get(Constants.SENSOR_CODE_WIND_DIR + Constants.MARKER_BIT_KEY);
+ Object flagSpeed = dataValue.get(Constants.SENSOR_CODE_WIND_SPEED + Constants.MARKER_BIT_KEY);
+ if (!Constants.MARKER_BIT_TRUE.equals(flagDir) || !Constants.MARKER_BIT_TRUE.equals(flagSpeed)) {
continue;
}
- size++;
+
+ if (ObjectUtils.isEmpty(wind) || ObjectUtils.isEmpty(speed)) {
+ continue;
+ }
double windDir = Double.parseDouble(wind.toString());
double windSpeed = Double.parseDouble(speed.toString());
+
+ //���������������������������������������������������
+ if (!ObjectUtils.isEmpty(windDirUpper)) {
+ if (windDir < (Double) windDirUpper) {
+ continue;
+ }
+ }
+
+ if (!ObjectUtils.isEmpty(windDirLower)) {
+ if (windDir > (Double) windDirLower) {
+ continue;
+ }
+ }
+
+ if (!ObjectUtils.isEmpty(windSpeedUpper)) {
+ if (windSpeed < (Double) windSpeedUpper) {
+ continue;
+ }
+ }
+
+ if (!ObjectUtils.isEmpty(windSpeedLower)) {
+ if (windSpeed > (Double) windSpeedLower) {
+ continue;
+ }
+ }
+
+ size++;
double sin = windSpeed * Math.sin(windDir / 180d) * Math.PI;
double cos = windSpeed * Math.cos(windDir / 180d) * Math.PI;
sumSin += sin;
sumCos += cos;
}
if (size == 0) {
- return null;
+ return result;
}
+
double avgSin = sumSin / size;
double avgCos = sumCos / size;
if (avgSin > 0 && avgCos > 0) {
@@ -110,7 +179,17 @@
} else {
avgDir = Math.atan(avgSin / avgCos) * 180 / Math.PI + 360;
}
- return sciCal(avgDir, 4);
+ double v = sciCal(avgDir, 4);
+ result.put(Constants.SENSOR_CODE_WIND_DIR, v);
+ if ("hour".equals(type)) {
+ //���������>=45���,������������ N,<45���H H:���������������
+ if (size >= 45) {
+ result.put(Constants.SENSOR_CODE_WIND_DIR + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_TRUE);
+ } else {
+ result.put(Constants.SENSOR_CODE_WIND_DIR + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_FALSE);
+ }
+ }
+ return result;
}
/**
@@ -132,38 +211,79 @@
}
//������������������������������
- public static Object getCOAvgOfWeekOrMonth(List<Map<String, Object>> list) {
+ public static Map<String, Object> getCOAvgOfWeekOrMonth(Map<String, Object> params) {
+ Map<String, Object> result = new HashMap<>();
+ List<Map<String, Object>> list = (List<Map<String, Object>>) params.get("data");
+ Object upper = params.get("coUpper");
+ Object lower = params.get("coLower");
+
List<Double> data = new ArrayList<>();
for (Map<String, Object> dataMap : list) {
Map<String, Object> dataValue = JSONObject.parseObject((String) dataMap.get("value"), Map.class);
Object o = dataValue.get(Constants.SENSOR_CODE_CO);
- if (o == null) {
+ Object flag = dataValue.get(Constants.SENSOR_CODE_CO + Constants.MARKER_BIT_KEY);
+ if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
+ continue;
+ }
+ if (ObjectUtils.isEmpty(o)) {
continue;
}
Double co = Double.parseDouble(o.toString());
+ //������������������������������
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (co < (Double) upper) {
+ continue;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (co > (Double) upper) {
+ continue;
+ }
+ }
data.add(co);
}
if (data.size() == 0) {
- return null;
+ return result;
}
- return percentile(data, 95);
+ result.put(Constants.SENSOR_CODE_CO, percentile(data, 95));
+ return result;
}
//������������������������
- public static Object getO3AvgOfWeekOrMonth(List<Map<String, Object>> list) {
+ public static Map<String, Object> getO3AvgOfWeekOrMonth(Map<String, Object> params) {
+ Map<String, Object> result = new HashMap<>();
+ List<Map<String, Object>> list = (List<Map<String, Object>>) params.get("data");
+ Object upper = params.get("o3Upper");
+ Object lower = params.get("o3Lower");
List<Double> data = new ArrayList<>();
for (Map<String, Object> dataMap : list) {
Map<String, Object> dataValue = JSONObject.parseObject((String) dataMap.get("value"), Map.class);
Object o = dataValue.get(Constants.SENSOR_CODE_O3);
- if (o == null) {
+ Object flag = dataValue.get(Constants.SENSOR_CODE_O3 + Constants.MARKER_BIT_KEY);
+ if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
+ continue;
+ }
+ if (ObjectUtils.isEmpty(o)) {
continue;
}
Double o3 = Double.parseDouble(o.toString());
+ //������������������������������
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (o3 < (Double) upper) {
+ continue;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (o3 > (Double) upper) {
+ continue;
+ }
+ }
data.add(o3);
}
if (data.size() == 0) {
- return null;
+ return result;
}
- return percentile(data, 90);
+ result.put(Constants.SENSOR_CODE_O3, percentile(data, 90));
+ return result;
}
}
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java
index fb62517..5409221 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryDailyServiceImpl.java
@@ -59,8 +59,8 @@
Date end = DateUtils.dataToTimeStampTime(now, format);
//������
QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>();
- sensorQueryWrapper.select("code").eq("is_delete", Constants.NOT_DELETE);
- List<Object> sensorCodes = sensorService.listObjs(sensorQueryWrapper);
+ sensorQueryWrapper.select("code", "lower", "upper").eq("is_delete", Constants.NOT_DELETE);
+ List<Sensor> sensors = sensorService.list(sensorQueryWrapper);
//������������������������������
QueryWrapper<HistoryHourly> historyHourlyQueryWrapper = new QueryWrapper<>();
@@ -85,38 +85,107 @@
//���������������������������������������������������
List<Map<String, Object>> tempValue = new ArrayList<>(value);
+ //������������������������0������������O3������������������������������1���-8���
value.removeIf(map -> ((Date) map.get("time")).getTime() == start.getTime());
+
+ Map<String, Object> params = new HashMap<>();
+ params.put("data", value);
+ params.put("type", "day");
+ for (Sensor sensor : sensors) {
+ String sensorCode = sensor.getCode();
+
+ //O3���������
+ if (sensorCode.equals(Constants.SENSOR_CODE_O3)) {
+ if (sensor.getUpper() != null) {
+ params.put("o3Upper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("o3Lower", sensor.getLower());
+ }
+ }
+
+ //���������������
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_DIR)) {
+ if (sensor.getUpper() != null) {
+ params.put("windDirUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("windDirLower", sensor.getLower());
+ }
+ }
+
+ //���������������
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_SPEED)) {
+ if (sensor.getUpper() != null) {
+ params.put("windSpeedUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("windSpeedLower", sensor.getLower());
+ }
+ }
+ }
//������8������������������������������������
- Object o3AvgOfDay = AmendUtils.getO3AvgOfDay(value);
- if (o3AvgOfDay != null) {
- jsonMap.put(Constants.SENSOR_CODE_O3, o3AvgOfDay);
+ Map<String, Object> o3AvgOfDay = AmendUtils.getO3AvgOfDay(params);
+ if (!ObjectUtils.isEmpty(o3AvgOfDay)) {
+ jsonMap.putAll(o3AvgOfDay);
}
//������������������������������������
- tempValue.removeIf(map -> ((Date) map.get("time")).getTime() == end.getTime());
+ tempValue.removeIf(o -> ((Date) o.get("time")).getTime() == end.getTime());
//���������������������������
- Object windDirAvg = AmendUtils.getWindDirAvg(value);
- if (windDirAvg != null) {
- jsonMap.put(Constants.SENSOR_CODE_WIND_DIR, windDirAvg);
+ params.put("data", tempValue);
+
+ Map<String, Object> windDirAvg = AmendUtils.getWindDirAvg(params);
+ if (!ObjectUtils.isEmpty(windDirAvg)) {
+ jsonMap.putAll(windDirAvg);
}
- sensorCodes.forEach(sensorCode -> {
+ sensors.forEach(sensor -> {
+ String sensorCode = sensor.getCode();
+ Double upper = sensor.getUpper();
+ Double lower = sensor.getLower();
OptionalDouble optionalDouble = tempValue.parallelStream()
.flatMapToDouble(v -> {
Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class);
- Object sensorValue = dataValue.get(sensorCode.toString());
- if (ObjectUtils.isEmpty(sensorValue)) {
+ Object sensorValue = dataValue.get(sensorCode);
+ //������������������������
+ Object flag = dataValue.get(sensorCode + Constants.MARKER_BIT_KEY);
+ if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
return null;
}
+
+ if (ObjectUtils.isEmpty(sensorValue)) {
+ System.out.println(456);
+ return null;
+ }
+
+ //O3������������
if (sensorCode.equals(Constants.SENSOR_CODE_O3)) {
return null;
}
- return DoubleStream.of(Double.parseDouble(sensorValue.toString()));
+
+ //������������������������������������
+ double aDouble = Double.parseDouble(sensorValue.toString());
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (aDouble < upper) {
+ return null;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (aDouble > lower) {
+ return null;
+ }
+ }
+ if ("a00e12".equals(sensorCode)) {
+ System.out.println(key + "==" + sensorCode + "==" + v.get("time") + "==" + aDouble);
+ }
+
+ return DoubleStream.of(aDouble);
}).average();
if (optionalDouble.isPresent()) {
//���������������������
double sciCal = AmendUtils.sciCal(optionalDouble.getAsDouble(), 4);
- jsonMap.put(sensorCode.toString(), sciCal);
+ jsonMap.put(sensorCode, sciCal);
}
});
dataMap.put("value", JSONObject.toJSONString(jsonMap));
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryFiveMinutelyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryFiveMinutelyServiceImpl.java
index ecdfd80..9a8f76d 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryFiveMinutelyServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryFiveMinutelyServiceImpl.java
@@ -53,6 +53,7 @@
//������������������yyyy-MM-dd HH:mm
String format = DateUtils.yyyy_MM_dd_HH_mm_EN;
Date now = new Date();
+ //������������������������������
Map<String, Object> params = new HashMap<>();
//������������
Date start = DateUtils.dataToTimeStampTime(DateUtils.getDateOfMin(now, -5), format);
@@ -65,9 +66,9 @@
params.put("timeUnits", timeUnits);
//������
- QueryWrapper<Sensor> queryWrapper = new QueryWrapper<>();
- queryWrapper.select("code").eq("is_delete", Constants.NOT_DELETE);
- List<Object> sensorCodes = sensorService.listObjs(queryWrapper);
+ QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>();
+ sensorQueryWrapper.select("code", "lower", "upper").eq("is_delete", Constants.NOT_DELETE);
+ List<Sensor> sensors = sensorService.list(sensorQueryWrapper);
//���������������������5������������������
List<Map<String, Object>> fiveMinutelyData = historyMinutelyMapper.getHistoryMinutelyData(params);
@@ -88,32 +89,84 @@
dataMap.put("time", end);
Map<String, Object> jsonMap = new HashMap<>();
+
+ Map<String, Object> map = new HashMap<>();
+ map.put("data", value);
+ map.put("type", "fiveMinutes");
+ for (Sensor sensor : sensors) {
+ String sensorCode = sensor.getCode();
+
+ //���������������
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_DIR)) {
+ if (sensor.getUpper() != null) {
+ map.put("windDirUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ map.put("windDirLower", sensor.getLower());
+ }
+ }
+
+ //���������������
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_SPEED)) {
+ if (sensor.getUpper() != null) {
+ map.put("windSpeedUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ map.put("windSpeedLower", sensor.getLower());
+ }
+ }
+ }
+
//���������������������������
- Object windDirAvg = AmendUtils.getWindDirAvg(value);
- if (windDirAvg != null) {
- jsonMap.put(Constants.SENSOR_CODE_WIND_DIR, windDirAvg);
+ Map<String, Object> windDirAvg = AmendUtils.getWindDirAvg(map);
+ if (!ObjectUtils.isEmpty(windDirAvg)) {
+ jsonMap.putAll(windDirAvg);
}
//������������������������������������
- sensorCodes.forEach(sensorCode -> {
- OptionalDouble optionalDouble = value.parallelStream()
+ sensors.forEach(sensor -> {
+ String sensorCode = sensor.getCode();
+ Double upper = sensor.getUpper();
+ Double lower = sensor.getLower();
+ DoubleStream optionalDouble = value.parallelStream()
.flatMapToDouble(v -> {
Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class);
- Object sensorValue = dataValue.get(sensorCode.toString());
+ Object sensorValue = dataValue.get(sensorCode);
+ //������������������������
+ Object flag = dataValue.get(sensorCode + Constants.MARKER_BIT_KEY);
+ if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
+ return null;
+ }
+
if (ObjectUtils.isEmpty(sensorValue)) {
return null;
}
- //������������������
+ //������������������
if (Constants.SENSOR_CODE_WIND_DIR.equals(sensorCode)) {
return null;
}
- return DoubleStream.of(Double.parseDouble(sensorValue.toString()));
- }).average();
- if (optionalDouble.isPresent()) {
+ //������������������������������������
+ double aDouble = Double.parseDouble(sensorValue.toString());
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (aDouble < upper) {
+ return null;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (aDouble > lower) {
+ return null;
+ }
+ }
+ return DoubleStream.of(aDouble);
+ });
+
+ OptionalDouble average = optionalDouble.average();
+ if (average.isPresent()) {
//���������������������
- double sciCal = AmendUtils.sciCal(optionalDouble.getAsDouble(), 4);
- jsonMap.put(sensorCode.toString(), sciCal);
+ double sciCal = AmendUtils.sciCal(average.getAsDouble(), 4);
+ jsonMap.put(sensorCode, sciCal);
}
+
});
dataMap.put("value", JSONObject.toJSONString(jsonMap));
//������redis
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
index dd63413..797334b 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryHourlyServiceImpl.java
@@ -26,6 +26,7 @@
import java.util.Map;
import java.util.OptionalDouble;
import java.util.Set;
+import java.util.concurrent.atomic.AtomicInteger;
import java.util.stream.Collectors;
import java.util.stream.DoubleStream;
@@ -77,8 +78,6 @@
});
}
- Map<String, Object> params = new HashMap<>();
-
//������������
String dateString = DateUtils.getDateStringOfHour(-1, format);
Date start = DateUtils.getDate(dateString, format);
@@ -91,9 +90,11 @@
//������
QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>();
- sensorQueryWrapper.select("code").eq("is_delete", Constants.NOT_DELETE);
- List<Object> sensorCodes = sensorService.listObjs(sensorQueryWrapper);
+ sensorQueryWrapper.select("code", "lower", "upper").eq("is_delete", Constants.NOT_DELETE);
+ List<Sensor> sensors = sensorService.list(sensorQueryWrapper);
+ //������������������������������������������
+ Map<String, Object> params = new HashMap<>();
params.put("timeUnits", timeUnits);
params.put("start", start);
params.put("end", end);
@@ -117,31 +118,91 @@
historyHourly.setTime(end);
Map<String, Object> jsonMap = new HashMap<>();
+ Map<String, Object> map = new HashMap<>();
+ map.put("data", value);
+ map.put("type", "hour");
+
+ for (Sensor sensor : sensors) {
+ String sensorCode = sensor.getCode();
+
+ //���������������
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_DIR)) {
+ if (sensor.getUpper() != null) {
+ map.put("windDirUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ map.put("windDirLower", sensor.getLower());
+ }
+ }
+
+ //���������������
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_SPEED)) {
+ if (sensor.getUpper() != null) {
+ map.put("windSpeedUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ map.put("windSpeedLower", sensor.getLower());
+ }
+ }
+ }
+
//���������������������������
- Object windDirAvg = AmendUtils.getWindDirAvg(value);
- if (windDirAvg != null) {
- jsonMap.put(Constants.SENSOR_CODE_WIND_DIR, windDirAvg);
+ Map<String, Object> windDirAvg = AmendUtils.getWindDirAvg(map);
+ if (!ObjectUtils.isEmpty(windDirAvg)) {
+ jsonMap.putAll(windDirAvg);
}
//������������������������������������
- sensorCodes.forEach(sensorCode -> {
- OptionalDouble optionalDouble = value.parallelStream()
+ sensors.forEach(sensor -> {
+ String sensorCode = sensor.getCode();
+ Double upper = sensor.getUpper();
+ Double lower = sensor.getLower();
+ AtomicInteger size = new AtomicInteger();
+ DoubleStream optionalDouble = value.parallelStream()
.flatMapToDouble(v -> {
Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class);
- Object sensorValue = dataValue.get(sensorCode.toString());
+ Object sensorValue = dataValue.get(sensorCode);
+ //������������������������
+ Object flag = dataValue.get(sensorCode + Constants.MARKER_BIT_KEY);
+ if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
+ return null;
+ }
+
if (ObjectUtils.isEmpty(sensorValue)) {
return null;
}
- //������������������
+
+ //������������������
if (Constants.SENSOR_CODE_WIND_DIR.equals(sensorCode)) {
return null;
}
- return DoubleStream.of(Double.parseDouble(sensorValue.toString()));
- }).average();
- if (optionalDouble.isPresent()) {
+
+ //������������������������������������
+ double aDouble = Double.parseDouble(sensorValue.toString());
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (aDouble < upper) {
+ return null;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (aDouble > lower) {
+ return null;
+ }
+ }
+ size.getAndIncrement();
+ return DoubleStream.of(aDouble);
+ });
+ OptionalDouble average = optionalDouble.average();
+ if (average.isPresent()) {
//���������������������
- double sciCal = AmendUtils.sciCal(optionalDouble.getAsDouble(), 4);
- jsonMap.put(sensorCode.toString(), sciCal);
+ double sciCal = AmendUtils.sciCal(average.getAsDouble(), 4);
+ jsonMap.put(sensorCode, sciCal);
+ //���������
+ if (size.get() >= 45) {
+ jsonMap.put(sensorCode + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_TRUE);
+ } else {
+ jsonMap.put(sensorCode + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_FALSE);
+ }
}
});
historyHourly.setValue(JSONObject.toJSONString(jsonMap));
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryMonthlyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryMonthlyServiceImpl.java
index 8acb57a..1018a88 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryMonthlyServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryMonthlyServiceImpl.java
@@ -57,8 +57,8 @@
Date end = DateUtils.addMonths(start, 1);
//������
QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>();
- sensorQueryWrapper.select("code").eq("is_delete", Constants.NOT_DELETE);
- List<Object> sensorCodes = sensorService.listObjs(sensorQueryWrapper);
+ sensorQueryWrapper.select("code", "lower", "upper").eq("is_delete", Constants.NOT_DELETE);
+ List<Sensor> sensors = sensorService.list(sensorQueryWrapper);
//���������������������������
QueryWrapper<HistoryDaily> historyDailyQueryWrapper = new QueryWrapper<>();
@@ -80,28 +80,72 @@
dataMap.put("time", start);
//���������������������������
- Object windDirAvg = AmendUtils.getWindDirAvg(value);
- if (windDirAvg != null) {
- jsonMap.put(Constants.SENSOR_CODE_WIND_DIR, windDirAvg);
+ Map<String, Object> params = new HashMap<>();
+ params.put("data", value);
+ params.put("type", "month");
+ for (Sensor sensor : sensors) {
+ String sensorCode = sensor.getCode();
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_DIR)) {
+ if (sensor.getUpper() != null) {
+ params.put("windDirUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("windDirLower", sensor.getLower());
+ }
+ }
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_SPEED)) {
+ if (sensor.getUpper() != null) {
+ params.put("windSpeedUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("windSpeedLower", sensor.getLower());
+ }
+ }
+
+ if (sensorCode.equals(Constants.SENSOR_CODE_CO)) {
+ if (sensor.getUpper() != null) {
+ params.put("coUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("coLower", sensor.getLower());
+ }
+ }
+
+ if (sensorCode.equals(Constants.SENSOR_CODE_O3)) {
+ if (sensor.getUpper() != null) {
+ params.put("o3Upper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("o3Lower", sensor.getLower());
+ }
+ }
+
+ }
+ Map<String, Object> windDirAvg = AmendUtils.getWindDirAvg(params);
+ if (!ObjectUtils.isEmpty(windDirAvg)) {
+ jsonMap.putAll(windDirAvg);
}
//CO 95������������������������
- Object coAvg = AmendUtils.getCOAvgOfWeekOrMonth(value);
- if (coAvg != null) {
- jsonMap.put(Constants.SENSOR_CODE_CO, coAvg);
+ Map<String, Object> coAvgOfWeekOrMonth = AmendUtils.getCOAvgOfWeekOrMonth(params);
+ if (!ObjectUtils.isEmpty(coAvgOfWeekOrMonth)) {
+ jsonMap.putAll(coAvgOfWeekOrMonth);
}
//O3 90������������������������
- Object o3Avg = AmendUtils.getO3AvgOfWeekOrMonth(value);
- if (o3Avg != null) {
- jsonMap.put(Constants.SENSOR_CODE_O3, o3Avg);
+ Map<String, Object> o3AvgOfWeekOrMonth = AmendUtils.getO3AvgOfWeekOrMonth(params);
+ if (!ObjectUtils.isEmpty(o3AvgOfWeekOrMonth)) {
+ jsonMap.putAll(o3AvgOfWeekOrMonth);
}
- sensorCodes.forEach(sensorCode -> {
+ sensors.forEach(sensor -> {
+ String sensorCode = sensor.getCode();
+ Double upper = sensor.getUpper();
+ Double lower = sensor.getLower();
OptionalDouble optionalDouble = value.parallelStream()
.flatMapToDouble(v -> {
Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class);
- Object sensorValue = dataValue.get(sensorCode.toString());
+ Object sensorValue = dataValue.get(sensorCode);
if (ObjectUtils.isEmpty(sensorValue)) {
return null;
}
@@ -117,12 +161,24 @@
if (Constants.SENSOR_CODE_O3.equals(sensorCode)) {
return null;
}
- return DoubleStream.of(Double.parseDouble(sensorValue.toString()));
+ //������������������������������������
+ double aDouble = Double.parseDouble(sensorValue.toString());
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (aDouble < upper) {
+ return null;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (aDouble > lower) {
+ return null;
+ }
+ }
+ return DoubleStream.of(aDouble);
}).average();
if (optionalDouble.isPresent()) {
//���������������������
double sciCal = AmendUtils.sciCal(optionalDouble.getAsDouble(), 4);
- jsonMap.put(sensorCode.toString(), sciCal);
+ jsonMap.put(sensorCode, sciCal);
}
});
dataMap.put("value", JSONObject.toJSONString(jsonMap));
diff --git a/screen-job/src/main/java/com/moral/api/service/impl/HistoryWeeklyServiceImpl.java b/screen-job/src/main/java/com/moral/api/service/impl/HistoryWeeklyServiceImpl.java
index b19cd67..2ffa7a7 100644
--- a/screen-job/src/main/java/com/moral/api/service/impl/HistoryWeeklyServiceImpl.java
+++ b/screen-job/src/main/java/com/moral/api/service/impl/HistoryWeeklyServiceImpl.java
@@ -57,8 +57,8 @@
Date end = DateUtils.addDays(start, 7);
//������
QueryWrapper<Sensor> sensorQueryWrapper = new QueryWrapper<>();
- sensorQueryWrapper.select("code").eq("is_delete", Constants.NOT_DELETE);
- List<Object> sensorCodes = sensorService.listObjs(sensorQueryWrapper);
+ sensorQueryWrapper.select("code", "lower", "upper").eq("is_delete", Constants.NOT_DELETE);
+ List<Sensor> sensors = sensorService.list(sensorQueryWrapper);
//���������������������������
QueryWrapper<HistoryDaily> historyDailyQueryWrapper = new QueryWrapper<>();
@@ -81,49 +81,106 @@
dataMap.put("time", start);
//���������������������������
- Object windDirAvg = AmendUtils.getWindDirAvg(value);
- if (windDirAvg != null) {
- jsonMap.put(Constants.SENSOR_CODE_WIND_DIR, windDirAvg);
+ Map<String, Object> params = new HashMap<>();
+ params.put("data", value);
+ params.put("type", "week");
+ for (Sensor sensor : sensors) {
+ String sensorCode = sensor.getCode();
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_DIR)) {
+ if (sensor.getUpper() != null) {
+ params.put("windDirUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("windDirLower", sensor.getLower());
+ }
+ }
+ if (sensorCode.equals(Constants.SENSOR_CODE_WIND_SPEED)) {
+ if (sensor.getUpper() != null) {
+ params.put("windSpeedUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("windSpeedLower", sensor.getLower());
+ }
+ }
+
+ if (sensorCode.equals(Constants.SENSOR_CODE_CO)) {
+ if (sensor.getUpper() != null) {
+ params.put("coUpper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("coLower", sensor.getLower());
+ }
+ }
+
+ if (sensorCode.equals(Constants.SENSOR_CODE_O3)) {
+ if (sensor.getUpper() != null) {
+ params.put("o3Upper", sensor.getUpper());
+ }
+ if (sensor.getLower() != null) {
+ params.put("o3Lower", sensor.getLower());
+ }
+ }
+
+ }
+ Map<String, Object> windDirAvg = AmendUtils.getWindDirAvg(params);
+ if (!ObjectUtils.isEmpty(windDirAvg)) {
+ jsonMap.putAll(windDirAvg);
}
//CO 95������������������������
- Object coAvg = AmendUtils.getCOAvgOfWeekOrMonth(value);
- if (coAvg != null) {
- jsonMap.put(Constants.SENSOR_CODE_CO, coAvg);
+ Map<String, Object> coAvgOfWeekOrMonth = AmendUtils.getCOAvgOfWeekOrMonth(params);
+ if (!ObjectUtils.isEmpty(coAvgOfWeekOrMonth)) {
+ jsonMap.putAll(coAvgOfWeekOrMonth);
}
//O3 90������������������������
- Object o3Avg = AmendUtils.getO3AvgOfWeekOrMonth(value);
- if (o3Avg != null) {
- jsonMap.put(Constants.SENSOR_CODE_O3, o3Avg);
+ Map<String, Object> o3AvgOfWeekOrMonth = AmendUtils.getO3AvgOfWeekOrMonth(params);
+ if (!ObjectUtils.isEmpty(o3AvgOfWeekOrMonth)) {
+ jsonMap.putAll(o3AvgOfWeekOrMonth);
}
- sensorCodes.forEach(sensorCode -> {
+ sensors.forEach(sensor -> {
+ String sensorCode = sensor.getCode();
+ Double upper = sensor.getUpper();
+ Double lower = sensor.getLower();
OptionalDouble optionalDouble = value.parallelStream()
.flatMapToDouble(v -> {
Map<String, Object> dataValue = JSONObject.parseObject((String) v.get("value"), Map.class);
- Object sensorValue = dataValue.get(sensorCode.toString());
+ Object sensorValue = dataValue.get(sensorCode);
if (ObjectUtils.isEmpty(sensorValue)) {
return null;
}
- //������������������
+ //������������������
if (Constants.SENSOR_CODE_WIND_DIR.equals(sensorCode)) {
return null;
}
- //CO������������
+ //CO������������
if (Constants.SENSOR_CODE_CO.equals(sensorCode)) {
return null;
}
- //O3������������
+ //O3������������
if (Constants.SENSOR_CODE_O3.equals(sensorCode)) {
return null;
}
- return DoubleStream.of(Double.parseDouble(sensorValue.toString()));
+
+ //������������������������������������
+ double aDouble = Double.parseDouble(sensorValue.toString());
+ if (!ObjectUtils.isEmpty(upper)) {
+ if (aDouble < upper) {
+ return null;
+ }
+ }
+ if (!ObjectUtils.isEmpty(lower)) {
+ if (aDouble > lower) {
+ return null;
+ }
+ }
+ return DoubleStream.of(aDouble);
}).average();
if (optionalDouble.isPresent()) {
//���������������������
double sciCal = AmendUtils.sciCal(optionalDouble.getAsDouble(), 4);
- jsonMap.put(sensorCode.toString(), sciCal);
+ jsonMap.put(sensorCode, sciCal);
}
});
dataMap.put("value", JSONObject.toJSONString(jsonMap));
--
Gitblit v1.8.0