From 33b9d2c203a9998272088ecdf43a15dd53669967 Mon Sep 17 00:00:00 2001
From: cjl <909710561@qq.com>
Date: Thu, 28 Mar 2024 15:51:53 +0800
Subject: [PATCH] Merge remote-tracking branch 'origin/dev' into cjl

---
 screen-api/src/main/java/com/moral/api/service/impl/AlarmInfoServiceImpl.java |  174 ++++++++++++++++++++++++++++++++++++++++++++++++++-------
 1 files changed, 152 insertions(+), 22 deletions(-)

diff --git a/screen-api/src/main/java/com/moral/api/service/impl/AlarmInfoServiceImpl.java b/screen-api/src/main/java/com/moral/api/service/impl/AlarmInfoServiceImpl.java
index 01941d0..7950927 100644
--- a/screen-api/src/main/java/com/moral/api/service/impl/AlarmInfoServiceImpl.java
+++ b/screen-api/src/main/java/com/moral/api/service/impl/AlarmInfoServiceImpl.java
@@ -16,10 +16,7 @@
 import org.springframework.util.ObjectUtils;
 
 import java.text.SimpleDateFormat;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.List;
-import java.util.Map;
+import java.util.*;
 import java.util.stream.Collectors;
 
 /**
@@ -94,30 +91,30 @@
             String index = parameters.get("index").toString();
             if (!index.equals("all")){
                 map.put("index",index);
-                alarmInfoQueryWrapper.eq("index", index);
+                alarmInfoQueryWrapper.eq("`index`", index);
             }
             String alarmType = parameters.get("alarmType").toString();
             switch (alarmType){
-                case "������" : map.put("alarmType","������");
-                    alarmInfoQueryWrapper.eq("alarmType","������");
+                case "overrun" : map.put("alarmType","������");
+                    alarmInfoQueryWrapper.eq("alarm_type","������");
                     break;
-                case "���������" : map.put("alarmType","���������");
-                    alarmInfoQueryWrapper.eq("alarmType","���������");
+                case "sudden" : map.put("alarmType","���������");
+                    alarmInfoQueryWrapper.eq("alarm_type","���������");
                     break;
-                case "���������100" : map.put("alarmType","������������������100%");
-                    alarmInfoQueryWrapper.eq("alarmType","������������������100%");
+                case "state100" : map.put("alarmType","������������������100%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������100%");
                     break;
-                case "���������150" : map.put("alarmType","������������������150%");
-                    alarmInfoQueryWrapper.eq("alarmType","������������������150%");
+                case "state150" : map.put("alarmType","������������������150%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������150%");
                     break;
-                case "���������250" : map.put("alarmType","������������������250%");
-                    alarmInfoQueryWrapper.eq("alarmType","������������������250%");
+                case "state250" : map.put("alarmType","������������������250%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������250%");
                     break;
-                case "������������150" : map.put("alarmType","������������������150%");
-                    alarmInfoQueryWrapper.eq("alarmType","������������������150%");
+                case "city150" : map.put("alarmType","������������������150%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������150%");
                     break;
-                case "������������250" : map.put("alarmType","������������������250%");
-                    alarmInfoQueryWrapper.eq("alarmType","������������������250%");
+                case "city250" : map.put("alarmType","������������������250%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������250%");
                     break;
                 default:break;
             }
@@ -143,10 +140,10 @@
     }
 
     @Override
-    public Map<String, Object> alarmReminder(Map<String, Object> parameters) {
-        Map<String,Object> resultMap = new HashMap<>();
+    public Map<String, Object> getDataByConditionWithoutPage(Map<String, Object> parameters) {
+        Map<String, Object> resultMap = new HashMap<>();
         int orgId = Integer.parseInt(parameters.get("organization_id").toString());
-        //���������������������������������id
+       /* //���������������������������������id
         List<Integer> allOrgId = new ArrayList<>();
         allOrgId.add(orgId);
         //������������
@@ -175,6 +172,139 @@
             }else {
                 continue;
             }
+        }*/
+        List<Integer> deviceIdList = deviceMapper.deviceIdList(orgId);
+        if (deviceIdList.size()>0){
+            Map<String, Object> map = new HashMap<>();
+            QueryWrapper<AlarmInfo> alarmInfoQueryWrapper = new QueryWrapper<>();
+            map.put("deviceIds",deviceIdList);
+            alarmInfoQueryWrapper.in("device_id",deviceIdList);
+            String startTime = parameters.get("startTime")+" 00:00:00";
+            String endTime = parameters.get("endTime")+" 23:59:59";
+            map.put("startTime",startTime);
+            map.put("endTime",endTime);
+            alarmInfoQueryWrapper.between("alarm_time", startTime, endTime);
+            String index = parameters.get("index").toString();
+            if (!index.equals("all")){
+                map.put("index",index);
+                alarmInfoQueryWrapper.eq("`index`", index);
+            }
+            String alarmType = parameters.get("alarmType").toString();
+            switch (alarmType){
+                case "overrun" : map.put("alarmType","������");
+                    alarmInfoQueryWrapper.eq("alarm_type","������");
+                    break;
+                case "sudden" : map.put("alarmType","���������");
+                    alarmInfoQueryWrapper.eq("alarm_type","���������");
+                    break;
+                case "state100" : map.put("alarmType","������������������100%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������100%");
+                    break;
+                case "state150" : map.put("alarmType","������������������150%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������150%");
+                    break;
+                case "state250" : map.put("alarmType","������������������250%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������250%");
+                    break;
+                case "city150" : map.put("alarmType","������������������150%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������150%");
+                    break;
+                case "city250" : map.put("alarmType","������������������250%");
+                    alarmInfoQueryWrapper.eq("alarm_type","������������������250%");
+                    break;
+                default:break;
+            }
+            List<Map<String, Object>> resultList = alarmInfoMapper.selectDataByConditionWithoutPage(map);
+            SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            for (Map<String, Object> alarmInfo:resultList) {
+                String alarm_time = SDF.format(alarmInfo.get("alarm_time"));
+                alarmInfo.put("alarm_time",alarm_time);
+            }
+            Integer totalNumber = alarmInfoMapper.selectCount(alarmInfoQueryWrapper);
+            resultMap.put("alarmInfos", resultList);
+            return resultMap;
+        }
+        return null;
+    }
+
+    @Override
+    public Map<String, Object> alarmReminder(Map<String, Object> parameters) {
+        Map<String,Object> resultMap = new HashMap<>();
+        int orgId = Integer.parseInt(parameters.get("organization_id").toString());
+        /*//���������������������������������id
+        List<Integer> allOrgId = new ArrayList<>();
+        allOrgId.add(orgId);
+        //������������
+        //���������������
+        List<Organization> allChildrenOrganization = organizationService.getChildrenOrganizationsById(orgId);
+        if (!ObjectUtils.isEmpty(allChildrenOrganization) || allChildrenOrganization.size() < 1){
+            for (Organization organization:allChildrenOrganization) {
+                allOrgId.add(organization.getId());
+            }
+        }
+        //������������
+        List<Integer> allOrgIdWithoutDuplicates = allOrgId.stream().distinct().collect(Collectors.toList());
+        //������������list���������������id
+        List<Integer> deviceIdList = new ArrayList<>();
+        for (Integer orgIdWithoutDuplicates:allOrgIdWithoutDuplicates) {
+            //������id������������������
+            QueryWrapper<Device> wrapper_device = new QueryWrapper<>();
+            wrapper_device.eq("is_delete",Constants.NOT_DELETE).eq("organization_id",orgIdWithoutDuplicates);
+            List<Device> devices = new ArrayList<>();
+            devices = deviceMapper.selectList(wrapper_device);
+            if (devices.size()>0){
+                for (Device device:devices) {
+                    int deviceId = device.getId();
+                    deviceIdList.add(deviceId);
+                }
+            }else {
+                continue;
+            }
+        }*/
+      //  if (deviceIdList.size()>0){
+            Map<String, Object> map = new HashMap<>();
+            //map.put("deviceIds",deviceIdList);
+            int size = Integer.parseInt(parameters.get("size").toString());
+            map.put("size",size);
+            map.put("orgId",orgId);
+            List<Map<String, Object>> resultList = alarmInfoMapper.selectNewestData(map);
+            SimpleDateFormat SDF = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
+            for (Map<String, Object> alarmInfo:resultList) {
+                String alarm_time = SDF.format(alarmInfo.get("alarm_time"));
+                alarmInfo.put("alarm_time",alarm_time);
+            }
+            resultMap.put("alarmInfors",resultList);
+            Integer totalNumber = alarmInfoMapper.numNews(orgId);
+            /*QueryWrapper<AlarmInfo> alarmInfoQueryWrapper = new QueryWrapper<>();
+            alarmInfoQueryWrapper.in("device_id",deviceIdList);
+            Integer totalNumber = alarmInfoMapper.selectCount(alarmInfoQueryWrapper);*/
+            resultMap.put("totalNumber",totalNumber);
+            return resultMap;
+       // }
+       // return null;
+    }
+
+    @Override
+    public Map<String, Object> alarmReminderByMonitorPointIds(Map<String, Object> parameters) {
+        Map<String, Object> resultMap = new HashMap<>();
+        String monitorPointIds = parameters.get("monitorPointIds").toString();
+        monitorPointIds.replace("[","");
+        monitorPointIds.replace("]","");
+        String[] monitorPointIdArray = monitorPointIds.split(",");
+        List<String> monitorPointIdList = new ArrayList<>(Arrays.asList(monitorPointIdArray));
+        //������������list���������������id
+        List<Integer> deviceIdList = new ArrayList<>();
+        //������id������������������
+        QueryWrapper<Device> wrapper_device = new QueryWrapper<>();
+        wrapper_device.eq("is_delete",Constants.NOT_DELETE);
+        wrapper_device.in("monitor_point_id",monitorPointIdList);
+        List<Device> devices = new ArrayList<>();
+        devices = deviceMapper.selectList(wrapper_device);
+        if (devices.size()>0){
+            for (Device device:devices) {
+                int deviceId = device.getId();
+                deviceIdList.add(deviceId);
+            }
         }
         if (deviceIdList.size()>0){
             Map<String, Object> map = new HashMap<>();

--
Gitblit v1.8.0