From 74ffc8ebf3a25d2e3cee758954ce6efc163cb864 Mon Sep 17 00:00:00 2001
From: feiyu02 <risaku@163.com>
Date: 星期四, 02 十二月 2021 16:11:57 +0800
Subject: [PATCH] 1. 用电量日分析
---
src/main/kotlin/com/flightfeather/uav/dataprocess/ElectricDailyAnalysis.kt | 52 +++++++++++++++++++++++++++++++++++++++++++++++-----
1 files changed, 47 insertions(+), 5 deletions(-)
diff --git a/src/main/kotlin/com/flightfeather/uav/dataprocess/ElectricDailyAnalysis.kt b/src/main/kotlin/com/flightfeather/uav/dataprocess/ElectricDailyAnalysis.kt
index aca6e91..8c1d2e7 100644
--- a/src/main/kotlin/com/flightfeather/uav/dataprocess/ElectricDailyAnalysis.kt
+++ b/src/main/kotlin/com/flightfeather/uav/dataprocess/ElectricDailyAnalysis.kt
@@ -6,6 +6,7 @@
import com.flightfeather.uav.lightshare.bean.ElectricDailyInfo
import java.time.LocalDateTime
import java.time.ZoneId
+import kotlin.math.round
/**
* 鐢ㄧ數閲忔棩鍒嗘瀽
@@ -39,24 +40,30 @@
if (dataMap[it.mvStatCode]?.containsKey(day) != true) dataMap[it.mvStatCode]?.put(day, mutableListOf())
val dayList = dataMap[it.mvStatCode]?.get(day)!!
dayList.add(it)
+ // 鏁版嵁瀵瑰簲鐘舵��
+ val device = deviceMap[it.mvStatCode]
+ val status = getStatus(it, device)
// 2.1 鏍规嵁鏁版嵁鍒囨崲褰撳墠璁惧绫诲瀷
if (!dailyInfoMap.containsKey(day)) dailyInfoMap[day] = ElectricDailyInfo()
val dayResult = dailyInfoMap[day]!!
dayResult.day = day
- dayResult.changeType(deviceMap[it.mvStatCode])
+ dayResult.changeType(device)
// 2.2 姣忔棩鑾峰彇鐨勯涓暟鎹紝鍗充负褰撴棩璇ヨ澶囧紑鍚椂闂�
if (dayList.size == 1) dayResult.setStartTime(it.mvDataTime)
- // 2.3 姣忎釜鏁版嵁涓哄垎閽熷潎鍊硷紝鎬绘暟浠ｈ〃寮�鍚椂闀�
- dayResult.addRunTime(1)
- // 2.4 缁熻褰撴棩璁惧杩愯鏃舵锛堝皬鏃讹級
+ // 2.3 姣忔棩鑾峰彇鐨勯涓负杩愯鐘舵�佺殑鏁版嵁锛屽嵆涓哄綋鏃ヨ璁惧姝ｅ紡杩愯寮�濮嬫椂闂�
+ dayResult.setRunningTime(status, it)
+ // 2.4 姣忎釜鏁版嵁涓哄垎閽熷潎鍊硷紝鎬绘暟浠ｈ〃寮�鍚椂闀�
+ dayResult.addRunTime(status)
+ // 2.5 缁熻褰撴棩璁惧杩愯鏃舵锛堝皬鏃讹級
val hour = LocalDateTime.ofInstant(it.mvDataTime.toInstant(), ZoneId.systemDefault()).hour
dayResult.addRunPeriod(hour)
}
- // 2.5 缁熻鍚勫彴璁惧姣忔棩缁撴潫鏃堕棿鍙婂垎鏋愮粨鏋�
+ // 2.6 缁熻鍚勫彴璁惧姣忔棩缁撴潫鏃堕棿鍙婂垎鏋愮粨鏋�
dataMap.forEach { (dCode, dayMap) ->
dayMap.forEach { (day, list) ->
dailyInfoMap[day]?.apply {
+
changeType(deviceMap[dCode])
setEndTime(list.last().mvDataTime)
}
@@ -66,4 +73,39 @@
return result
}
+
+ /**
+ * 鑾峰彇璁惧褰撳墠杩愯鐘舵��
+ * @param e 璁惧鐢ㄧ數閲忕洃娴嬫暟鎹�
+ * @param d 浼佷笟璁惧淇℃伅
+ * @return 鏁版嵁瀵瑰簲缁撴灉淇℃伅锛�<鐘舵�佺紪鍙凤紝鐘舵�佹弿杩帮紝鐢垫祦鍧囧��>
+ */
+ fun getStatus(e: ElectricMinuteValue?, d: CompanyDevice?): Triple<String, String, Double> {
+ var values = mutableListOf<Int>().apply {
+ d?.cdLimits?.split(";")?.forEach {
+ it.toIntOrNull()?.let { i -> add(i) }
+ }
+ }
+ var status = d?.cdStatus?.split(";") ?: emptyList()
+ var statusNames = d?.cdStatusName?.split(";") ?: emptyList()
+ if (values.isEmpty()) values = mutableListOf(1, 100)
+ if (status.isEmpty()) status = listOf("0", "2", "3")
+ if (statusNames.isEmpty()) statusNames = listOf("寰呮満", "杩愯", "瓒呰礋鑽�")
+ if (e == null) {
+ return Triple(status.first(), statusNames.first(), .0)
+ }
+
+ val electricityList = mutableListOf<Double>()
+ electricityList.add(e.mvElectricityA)
+ electricityList.add(e.mvElectricityB)
+ electricityList.add(e.mvElectricityC)
+
+ val avg = round(electricityList.average() * 100) / 100
+ for (i in values.indices) {
+ if (avg < values[i]) {
+ return Triple(status[i], statusNames[i], avg)
+ }
+ }
+ return Triple(status.last(), statusNames.last(), avg)
+ }
}
\ No newline at end of file
--
Gitblit v1.9.3