From 8143ce1b902f99d8333475aa06e3c08e5e4164cf Mon Sep 17 00:00:00 2001
From: jinpengyong <jpy123456>
Date: Wed, 03 Jun 2020 19:19:56 +0800
Subject: [PATCH] alarm_daily统计任务update
---
src/main/java/com/moral/service/impl/AlarmServiceImpl.java | 102 +++++++++++++++++++++++++++++++++++++++++++++++---
1 files changed, 95 insertions(+), 7 deletions(-)
diff --git a/src/main/java/com/moral/service/impl/AlarmServiceImpl.java b/src/main/java/com/moral/service/impl/AlarmServiceImpl.java
index df9dd46..1710632 100644
--- a/src/main/java/com/moral/service/impl/AlarmServiceImpl.java
+++ b/src/main/java/com/moral/service/impl/AlarmServiceImpl.java
@@ -1,14 +1,22 @@
package com.moral.service.impl;
+import java.time.LocalDateTime;
+import java.time.temporal.ChronoUnit;
+import java.util.ArrayList;
+import java.util.Arrays;
+import java.util.HashMap;
import java.util.List;
import java.util.Map;
+import java.util.stream.Collectors;
import javax.annotation.Resource;
import org.springframework.stereotype.Service;
+import com.alibaba.druid.support.json.JSONUtils;
import com.moral.mapper.AlarmMapper;
import com.moral.service.AlarmService;
+import com.moral.service.SensorService;
@Service
@@ -17,19 +25,99 @@
@Resource
private AlarmMapper alarmMapper;
- @Override
- public List<Map<String, Object>> getAvgAlarmData(Map<String, Object> devices) {
- return alarmMapper.getAvgAlarmData(devices);
- }
+ @Resource
+ private SensorService sensorService;
@Override
- public int insertAlarmDaily(List<Map<String, Object>> list) {
- return alarmMapper.insertAlarmDaily(list);
+ public void insertAlarmDaily() {
+ LocalDateTime time = LocalDateTime.now();
+ LocalDateTime endTime = time.truncatedTo(ChronoUnit.DAYS);
+ LocalDateTime startTime = endTime.minusDays(1);
+ List<String> sensorKeys = sensorService.getSensorKeys();
+ String year = startTime.getYear() + "";
+ String month = null;
+ int monthValue = startTime.getMonthValue();
+ if (monthValue < 10) {
+ month = "0" + monthValue;
+ } else {
+ month = monthValue + "";
+ }
+ String yearAndMonth = year + month;
+ Map<String, Object> devices = new HashMap<>();
+ devices.put("sensorKeys", sensorKeys);
+ devices.put("start", startTime);
+ devices.put("end", endTime);
+ devices.put("yearAndMonth", yearAndMonth);
+ List<String> macs = alarmMapper.getMacs(devices);
+ devices.put("macs", macs);
+ for (String mac : macs) {
+ List<Map<String, Object>> resultList = new ArrayList<>();
+ devices.put("mac", mac);
+ List<Map<String, Object>> list = alarmMapper.getAlarmData(devices);
+ List<Map<String, Object>> newList1 = list.stream().distinct().collect(Collectors.toList());
+ for (Map<String, Object> map : newList1) {
+ for (String key : map.keySet()) {
+ if (!"mac".equals(key)) {
+ String[] strings = map.get(key).toString().replace("$.", "")
+ .replace("[", "").replace("]", "")
+ .replace("\"", "").replace(" ", "").split(",");
+
+ List<String> sensors = new ArrayList<String>(Arrays.asList(strings));
+ map.put(key, sensors);
+ }
+ }
+ }
+
+ Map<String, Object> hashMap = new HashMap<>();
+ hashMap.put("mac", mac);
+ ArrayList<String> stateList1 = new ArrayList<>();
+ ArrayList<String> stateList2 = new ArrayList<>();
+ ArrayList<String> stateList3 = new ArrayList<>();
+ for (Map<String, Object> map : newList1) {
+ if (map.get("1") != null) {
+ stateList1.addAll((ArrayList<String>) map.get("1"));
+ hashMap.put("1", stateList1);
+ }
+ if (map.get("2") != null) {
+ stateList2.addAll((ArrayList<String>) map.get("2"));
+ hashMap.put("2", stateList2);
+ }
+ if (map.get("3") != null) {
+ stateList3.addAll((ArrayList<String>) map.get("3"));
+ hashMap.put("3", stateList3);
+ }
+
+ }
+
+ for (String key : hashMap.keySet()) {
+ if (!"mac".equals(key)) {
+ ArrayList<String> arrayList = (ArrayList<String>) hashMap.get(key);
+ List<String> sensorsList = arrayList.stream().distinct().collect(Collectors.toList());
+ hashMap.put(key, sensorsList);
+ }
+ }
+
+ for (String key : hashMap.keySet()) {
+ if(!"mac".equals(key)){
+ Map<String, Object> jsonMap = new HashMap<>();
+ Map<String, Object> map = new HashMap<>();
+ map.put("mac",mac);
+ map.put("time",startTime);
+ map.put("state", key);
+ ArrayList<String> stateList = (ArrayList<String>) hashMap.get(key);
+ for (String state : stateList) {
+ jsonMap.put(state,1);
+ }
+ map.put("json",JSONUtils.toJSONString(jsonMap));
+ resultList.add(map);
+ }
+ }
+ alarmMapper.insertAlarmDaily(resultList);
+ }
}
@Override
public void createTable(String yearAndMonth) {
alarmMapper.createTable(yearAndMonth);
}
-
}
--
Gitblit v1.8.0