From e94e5dbbfc544c558a09fb388e7f4d4341fe8ec4 Mon Sep 17 00:00:00 2001
From: cjl <276999030@qq.com>
Date: Thu, 28 Sep 2023 16:59:01 +0800
Subject: [PATCH] ci:添加自有权限
---
screen-common/src/main/java/com/moral/util/AmendUtils.java | 143 +++++++++++++++++++++++++++++++++++------------
1 files changed, 107 insertions(+), 36 deletions(-)
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 7c15de8..3c726b1 100644
--- a/screen-common/src/main/java/com/moral/util/AmendUtils.java
+++ b/screen-common/src/main/java/com/moral/util/AmendUtils.java
@@ -53,14 +53,14 @@
Object lower = params.get("o3Lower");
double max;
List<Double> avgs = new ArrayList<>();
- for (int i = 8; i <= 24; i++) {
+ for (int i = 7; i <= 23; i++) {
List<Double> data = new ArrayList<>();
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);
+ Object flag = dataValue.get(Constants.SENSOR_CODE_O3 + "-" + Constants.MARKER_BIT_KEY);
//������������������������������
if (!Constants.MARKER_BIT_TRUE.equals(flag)) {
continue;
@@ -68,20 +68,17 @@
//������������������������������
if (!ObjectUtils.isEmpty(upper)) {
- if (o3 < (Double) upper) {
+ if (o3 > (Double) upper) {
continue;
}
}
if (!ObjectUtils.isEmpty(lower)) {
- if (o3 > (Double) upper) {
+ if (o3 < (Double) lower) {
continue;
}
}
int hour = DateUtils.getHour((Date) dataMap.get("time"));
- if (hour == 0) {
- hour = 24;
- }
if (hour <= i && hour >= i - 7) {
data.add(o3);
}
@@ -99,6 +96,52 @@
}
}
result.put(Constants.SENSOR_CODE_O3, sciCal(max, 4));
+ return result;
+ }
+
+ //������aqi���������
+ public static Double o3OfDay(List<Map<String, Object>> value) {
+ List<Map<String, Object>> o3_8H = getO3_8H(value);
+ if (!ObjectUtils.isEmpty(o3_8H)) {
+ double o3 = 0d;
+ for (Map<String, Object> o : o3_8H) {
+ double temp = (double) o.get("O3");
+ if (temp > o3) {
+ o3 = temp;
+ }
+ }
+ return sciCal(o3, 0);
+ }
+ return null;
+ }
+
+ /**
+ * @param data ������ time:Date������,������key:o3
+ * @return ���������������8���������������������
+ */
+ public static List<Map<String, Object>> getO3_8H(List<Map<String, Object>> data) {
+ Date date = (Date) data.get(0).get("time");
+ List<Map<String, Object>> result = new ArrayList<>();
+ for (int i = 7; i <= 23; i++) {
+ Map<String, Object> map = new HashMap<>();
+ map.put("time", DateUtils.addHours(date, i));
+ List<Double> value = new ArrayList<>();
+ for (Map<String, Object> dataMap : data) {
+ Map<String, Object> sensorValue = JSONObject.parseObject((String) dataMap.get("value"), Map.class);
+ Double o3 = Double.parseDouble(sensorValue.get("O3").toString());
+ Date time = (Date) dataMap.get("time");
+ int hour = DateUtils.getHour(time);
+ if (hour <= i && hour >= i - 7) {
+ value.add(o3);
+ }
+ }
+ if (value.size() < 6) {
+ continue;
+ }
+ double average = value.stream().mapToDouble(aDouble -> aDouble).summaryStatistics().getAverage();
+ map.put("O3", sciCal(average, 0));
+ result.add(map);
+ }
return result;
}
@@ -123,10 +166,13 @@
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);
- 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;
+ 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 (!ObjectUtils.isEmpty(flagDir) && !ObjectUtils.isEmpty(flagSpeed)) {
+ if (!Constants.MARKER_BIT_TRUE.equals(flagDir) || !Constants.MARKER_BIT_TRUE.equals(flagSpeed)) {
+ continue;
+ }
}
if (ObjectUtils.isEmpty(wind) || ObjectUtils.isEmpty(speed)) {
@@ -137,25 +183,25 @@
//���������������������������������������������������
if (!ObjectUtils.isEmpty(windDirUpper)) {
- if (windDir < (Double) windDirUpper) {
+ if (windDir > (Double) windDirUpper) {
continue;
}
}
if (!ObjectUtils.isEmpty(windDirLower)) {
- if (windDir > (Double) windDirLower) {
+ if (windDir < (Double) windDirLower) {
continue;
}
}
if (!ObjectUtils.isEmpty(windSpeedUpper)) {
- if (windSpeed < (Double) windSpeedUpper) {
+ if (windSpeed > (Double) windSpeedUpper) {
continue;
}
}
if (!ObjectUtils.isEmpty(windSpeedLower)) {
- if (windSpeed > (Double) windSpeedLower) {
+ if (windSpeed < (Double) windSpeedLower) {
continue;
}
}
@@ -186,9 +232,9 @@
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);
+ 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);
+ result.put(Constants.SENSOR_CODE_WIND_DIR + "-" + Constants.MARKER_BIT_KEY, Constants.MARKER_BIT_FALSE);
}
}
}
@@ -203,15 +249,12 @@
public static double percentile(List<Double> data, int p) {
int n = data.size();
Collections.sort(data);
- double v = n / (100 / p);
- if (n % (100 / p) == 0) {
- if (v == n) {
- return data.get(n - 1);
- }
- return (data.get((int) v - 1) + data.get((int) v)) / 2;
- }
+ double v = MathUtils.division(MathUtils.mul(n, p),100d,1);
+ v = Math.ceil(v)-1;
return sciCal(data.get((int) v), 4);
}
+
+
//������������������������������
public static Map<String, Object> getCOAvgOfWeekOrMonth(Map<String, Object> params) {
@@ -224,22 +267,18 @@
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);
- 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) {
+ if (co > (Double) upper) {
continue;
}
}
if (!ObjectUtils.isEmpty(lower)) {
- if (co > (Double) upper) {
+ if (co < (Double) lower) {
continue;
}
}
@@ -262,22 +301,18 @@
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);
- 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) {
+ if (o3 > (Double) upper) {
continue;
}
}
if (!ObjectUtils.isEmpty(lower)) {
- if (o3 > (Double) upper) {
+ if (o3 < (Double) lower) {
continue;
}
}
@@ -289,4 +324,40 @@
result.put(Constants.SENSOR_CODE_O3, percentile(data, 90));
return result;
}
+
+ //������������������������
+ /**
+ * ���������������
+ * PM2.5,PM10,CO,���������95���������
+ * SO2,NO2,���������98���������
+ * O3���������������90���������
+ *
+ * @param list ������
+ * @param sensorCode ������code
+ */
+ public static Double getAvgOfYear(List<Map<String, Object>> list, String sensorCode) {
+ 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(sensorCode);
+ if (ObjectUtils.isEmpty(o)) {
+ continue;
+ }
+ Double sensorValue = Double.parseDouble(o.toString());
+ data.add(sensorValue);
+ }
+ if (data.size() == 0) {
+ return null;
+ }
+
+ Double v = null;
+ if ("PM2_5".equals(sensorCode) || "PM10".equals(sensorCode) || "CO".equals(sensorCode)) {
+ v = percentile(data, 95);
+ } else if ("SO2".equals(sensorCode) || "NO2".equals(sensorCode)) {
+ v = percentile(data, 98);
+ } else if ("O3".equals(sensorCode)) {
+ v = percentile(data, 90);
+ }
+ return v;
+ }
}
--
Gitblit v1.8.0