From d92f097bf2ad1cbab44f620831e10b2dbe8324b3 Mon Sep 17 00:00:00 2001
From: lizijie <lzjiiie@163.com>
Date: Tue, 17 Aug 2021 08:50:27 +0800
Subject: [PATCH] 特殊设备更新接口
---
screen-common/src/main/java/com/moral/util/AmendUtils.java | 33 ++++++++++++++++++---------------
1 files changed, 18 insertions(+), 15 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 960de0b..7c15de8 100644
--- a/screen-common/src/main/java/com/moral/util/AmendUtils.java
+++ b/screen-common/src/main/java/com/moral/util/AmendUtils.java
@@ -115,10 +115,10 @@
Object windSpeedUpper = params.get("windSpeedUpper");
Object windSpeedLower = params.get("windSpeedLower");
- double avgDir;
- double sumSin = 0d;
- double sumCos = 0d;
- int size = 0;
+ Double avgDir = null;
+ Double sumSin = 0d;
+ Double sumCos = 0d;
+ Integer size = 0;
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);
@@ -161,8 +161,8 @@
}
size++;
- double sin = windSpeed * Math.sin(windDir / 180d) * Math.PI;
- double cos = windSpeed * Math.cos(windDir / 180d) * Math.PI;
+ double sin = windSpeed * Math.sin(windDir / 180d * Math.PI);
+ double cos = windSpeed * Math.cos(windDir / 180d * Math.PI);
sumSin += sin;
sumCos += cos;
}
@@ -172,21 +172,24 @@
double avgSin = sumSin / size;
double avgCos = sumCos / size;
+
if (avgSin > 0 && avgCos > 0) {
avgDir = Math.atan(avgSin / avgCos) * 180 / Math.PI;
} else if ((avgSin > 0 && avgCos < 0) || (avgSin < 0 && avgCos < 0)) {
avgDir = Math.atan(avgSin / avgCos) * 180 / Math.PI + 180;
- } else {
+ } else if (avgSin < 0 && avgCos > 0) {
avgDir = Math.atan(avgSin / avgCos) * 180 / Math.PI + 360;
}
- 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);
+ if (!ObjectUtils.isEmpty(avgDir)) {
+ 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;
--
Gitblit v1.8.0