From 4024ef51a8d22d575dc929d806d49b30598b422d Mon Sep 17 00:00:00 2001 From: jinpengyong <jpy123456> Date: Fri, 10 Nov 2023 16:50:45 +0800 Subject: [PATCH] chore:推送修改提交 --- 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