From ee03b526152d335dd1e42bc01a1f717d1205204c Mon Sep 17 00:00:00 2001 From: zxl <763096477@qq.com> Date: 星期一, 26 五月 2025 15:27:04 +0800 Subject: [PATCH] (部级录像可用率,重点录像可用率,录像可用率)计算可用率bug修复,hk接口bug修复, --- ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java | 712 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 700 insertions(+), 12 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java index f8ae9e7..1397a1e 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java @@ -1,7 +1,7 @@ package com.ycl.platform.service.impl; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.metadata.IPage; +import com.alibaba.excel.EasyExcel; +import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; @@ -9,7 +9,7 @@ import com.mongodb.client.MongoCollection; import com.mongodb.client.MongoDatabase; import com.ycl.platform.domain.entity.*; -import com.ycl.platform.domain.excel.TMonitorExp; +import com.ycl.platform.domain.form.UpdateDynamicValueForm; import com.ycl.platform.domain.query.DataCenterQuery; import com.ycl.platform.domain.result.HK.*; import com.ycl.platform.domain.result.SYS.TMonitorResult; @@ -17,23 +17,23 @@ import com.ycl.platform.domain.vo.DataCenter.BigPicUsefulVO; import com.ycl.platform.domain.vo.DataCenter.MonitorQualifyResultVO; import com.ycl.platform.domain.vo.DataCenter.SnapClockVO; -import com.ycl.platform.domain.vo.PointDetailVO; -import com.ycl.platform.domain.vo.home.HomeFaceVO; +import com.ycl.platform.domain.vo.DynamicColumnVO; +import com.ycl.platform.mapper.DynamicColumnMapper; import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper; import com.ycl.platform.mapper.YwPointMapper; import com.ycl.platform.service.*; import com.ycl.system.Result; -import com.ycl.system.page.PageUtil; +import com.ycl.system.service.ISysConfigService; import com.ycl.utils.DateUtils; import com.ycl.utils.MongoUtil; import com.ycl.utils.StringUtils; import com.ycl.utils.bean.BeanUtils; import com.ycl.utils.poi.ExcelUtil; -import constant.ApiConstants; -import constant.CheckConstants; +import constant.*; import enumeration.general.AreaDeptEnum; import jakarta.servlet.http.HttpServletResponse; import lombok.RequiredArgsConstructor; +import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.bson.Document; import org.springframework.data.domain.Sort; @@ -41,9 +41,9 @@ import org.springframework.data.mongodb.core.aggregation.*; import org.springframework.data.mongodb.core.query.Criteria; import org.springframework.data.mongodb.core.query.Query; -import org.springframework.data.mongodb.core.query.TextCriteria; import org.springframework.stereotype.Service; +import java.io.IOException; import java.math.BigDecimal; import java.math.RoundingMode; import java.text.DecimalFormat; @@ -60,6 +60,7 @@ */ @Service @RequiredArgsConstructor +@Slf4j public class DataCenterServiceImpl implements DataCenterService { private final MongoTemplate mongoTemplate; @@ -68,11 +69,568 @@ private final ICheckIndexVideoService checkIndexVideoService; private final ICheckIndexCarService checkIndexCarService; private final ICheckIndexFaceService checkIndexFaceService; + private final DynamicColumnMapper dynamicColumnMapper; + private final static String TIME_FIELD = "mongoCreateTime"; private static DecimalFormat DF = new DecimalFormat("#.####"); + + + + public Map<String,List<DynamicColumnVO>> getDynamicByConditions(DataCenterQuery params,List<DynamicColumnVO> list){ + //鑾峰緱鍒板搴攊d锛屼笖鍖呭惈浼犲叆瀛楃涓� 鍔ㄦ�佸垪闆嗗悎 + List<DynamicColumnVO> likeFieldDynamicColumnVOList = list.stream() + .filter(dynamicColumnVO -> + dynamicColumnVO.getLabelId().equals(params.getDyId()) && + dynamicColumnVO.getColumnValue().contains(params.getDyValue()) + ).collect(Collectors.toList()); + //鑾峰緱婊¤冻鏉′欢鐨刬d闆嗗悎 + List<String> ids = likeFieldDynamicColumnVOList.stream().map(DynamicColumnVO::getRefStringId).toList(); + Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = list.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); + Set<String> removeSet = new HashSet<>(ids); + //绉婚櫎鎺変笉绗﹀悎鏉′欢鐨刱ey + groupByRefStringIdMap.keySet().retainAll(removeSet); + + return groupByRefStringIdMap; + } + + @Override + public void recordingAvailabilityExport(HttpServletResponse response,DataCenterQuery params) throws IOException { + + List<String> likeFileds = Arrays.asList("deviceId", "deviceName"); + Query query = MongoUtil.getQuery(params, "createTime", likeFileds, null); + //涓嬫媺妗嗗綍鍍忔儏鍐垫煡璇㈡潯浠� + if (params.getOption() != null) { + query.addCriteria(Criteria.where("recordStatus").is(params.getOption())); + } + MongoUtil.setNoPage(query, params, TIME_FIELD); + List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + //缈昏瘧琛屾斂鍖哄煙 + resultList.forEach(item -> { + String areaCode = item.getArealayername().substring(0, 6); + AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode); + if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName()); + }); + //鑾峰緱鍔ㄦ�佸垪鏁版嵁 + List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_VIDEO); + + //鍒ゆ柇鏄惁鏈夋煡璇㈡潯浠� + boolean conditions = false; + Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>(); + if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ + conditions = true; + //鑾峰緱鍔ㄦ�佸垪闆嗗悎涓寘鍚簡鐨勫瓧绗︿覆鍊肩殑闆嗗悎 鍖哄垎澶у皬鍐� + groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); + }else{ + groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); + } + //鍥哄畾琛ㄥご + LinkedHashSet<String> headers = new LinkedHashSet<>(); + headers.add(RecordingAvailabilityHeaders.arealayername); + headers.add(RecordingAvailabilityHeaders.arealayerno); + headers.add(RecordingAvailabilityHeaders.createTime); + headers.add(RecordingAvailabilityHeaders.deviceId); + headers.add(RecordingAvailabilityHeaders.missDuration); + headers.add(RecordingAvailabilityHeaders.platId); + headers.add(RecordingAvailabilityHeaders.recordDuration); + headers.add(RecordingAvailabilityHeaders.recordStatusText); + headers.add(RecordingAvailabilityHeaders.statTime); + + List<String> headersList = new LinkedList<>(); + List<String> dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_VIDEO); + + //娣诲姞鍔ㄦ�佽〃澶� + if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { + //浣跨敤閾捐〃淇濊瘉鍚庣画琛ュ厖鏁版嵁鏃惰幏鍙栨暟鎹『搴忎竴鑷� + headersList.addAll(dynamicsHeaders); + headers.addAll(headersList); + } +// SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); + //鏌ヨ鍒版湁鍔ㄦ�佸垪鏌ヨ鏉′欢 + //鑾峰緱瀵瑰簲鍔ㄦ�佸垪涓璻ef鐨勫璞d 涓� 鏌ヨ缁撴灉id杩囨护 + if (conditions){ + Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap; + resultList = resultList.stream() + .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getId())) + .collect(Collectors.toList()); + } + SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); + List<List<Object>> data = new ArrayList<>(); + for (RecordMetaDSumResult result : resultList){ + List<Object> row = new ArrayList<>(); + row.add(result.getArealayername()); + row.add(result.getArealayerno()); + row.add(dateFormat.format(result.getCreateTime())); + row.add(result.getDeviceId()); + row.add(result.getMissDuration()); + row.add(result.getPlatId()); + row.add(result.getRecordDuration()); + row.add(result.getRecordStatusText()); + row.add(dateFormat.format(result.getCreateTime())); + //娣诲姞鍔ㄦ�佸垪鏁版嵁 + for (String header : headersList){ + boolean flag = false; + List<DynamicColumnVO> columnVOS = groupByRefStringIdMap.get(result.getId()); + if (!CollectionUtils.isEmpty(columnVOS)) { + for (DynamicColumnVO columnVO : columnVOS) { + if (header.equals(columnVO.getLabelValue())) { + row.add(columnVO.getColumnValue()); + flag = true; + } + } + } + //娌℃壘鍒扮敤绌轰覆鍗犱綅 + if (!flag) row.add(""); + } + data.add(row); + } + List<List<String>> headList = new ArrayList<>(); + for (String header : headers) { + headList.add(Collections.singletonList(header)); + } + EasyExcel.write(response.getOutputStream()) + .head(headList) // 璁剧疆琛ㄥご + .sheet("褰曞儚鍙敤鐜�") // 璁剧疆sheet鍚嶇О + .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) + .doWrite(data); // 鍐欏叆鏁版嵁 + } + + @Override + public void pointOnlineFaceExport(HttpServletResponse response, DataCenterQuery params) throws IOException { + List<String> likeFileds = Arrays.asList("name", "no", "ip"); + Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); + //鏌ヤ汉鑴歌澶� + query.addCriteria(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Face + ".*")); + //涓嬫媺妗嗗湪绾挎儏鍐垫煡璇㈡潯浠� + if (params.getOption() != null) { + query.addCriteria(Criteria.where("online").is(params.getOption())); + } + Sort sort = Sort.by( + Sort.Order.asc("pingOnline"), // 棣栧厛鎸夌収 pingOnline 鍗囧簭鎺掑簭 + Sort.Order.desc("offLineCount") // 棣栧厛鎸夌収 pingOnline 鍗囧簭鎺掑簭 + ); + // 閫氳繃pingOnline瀛楁鎺掑簭锛屼负false鐨勬帓鍦ㄥ墠闈� + query.with(sort); + MongoUtil.setNoPage(query, params, TIME_FIELD); + //鍒嗛〉鏁伴噺 + List<TMonitorResult> resultList = mongoTemplate.find(query, TMonitorResult.class); + resultList.forEach(item -> { + if (item.getPingOnline() == null) { + item.setPingOnlineStr("鏈煡"); + } else if (item.getPingOnline()) { + item.setPingOnlineStr("鍦ㄧ嚎"); + } else if (!item.getPingOnline()) { + item.setPingOnlineStr("绂荤嚎"); + } + if (1 == item.getOnline()) { + item.setOnlineStr("鍦ㄧ嚎"); + } else if (-1 == item.getOnline()) { + item.setOnlineStr("绂荤嚎"); + } else { + item.setOnlineStr("鏈煡"); + } + List<String> offLineTime = item.getOffLineTimeStr(); + if (!CollectionUtils.isEmpty(offLineTime)) { + //鍚庣画鍙互鏀规垚閰嶇疆鐨勭绾挎鏁�(鎻愬彇鍓峮娆★紝n涓洪厤缃殑绂荤嚎娆℃暟) + if (offLineTime.size() > 1) { + offLineTime = offLineTime.subList(0, 2); + } + item.setOffLineTimeStr(offLineTime); + } + }); + + + + List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_FACE_POINT); + + + //鍒ゆ柇鏄惁鏈夋煡璇㈡潯浠� + boolean conditions = false; + Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>(); + if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ + conditions = true; + //鑾峰緱鍔ㄦ�佸垪闆嗗悎涓寘鍚簡鐨勫瓧绗︿覆鍊肩殑闆嗗悎 鍖哄垎澶у皬鍐� + groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); + }else{ + groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); + } + + //鍥哄畾琛ㄥご + LinkedHashSet<String> headers = new LinkedHashSet<>(); + headers.add(PointOnlineHeaders.no); + headers.add(PointOnlineHeaders.name); + headers.add(PointOnlineHeaders.ip); + headers.add(PointOnlineHeaders.onlineStr); + headers.add(PointOnlineHeaders.pingOnlineStr); + headers.add(PointOnlineHeaders.checkCount); + headers.add(PointOnlineHeaders.offLineCount); + headers.add(PointOnlineHeaders.offLineTimeStr); + headers.add(PointOnlineHeaders.mongoCreateTime); + + List<String> headersList = new LinkedList<>(); + List<String> dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_FACE_POINT); + + //娣诲姞鍔ㄦ�佽〃澶� + if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { + //浣跨敤閾捐〃淇濊瘉鍚庣画琛ュ厖鏁版嵁鏃惰幏鍙栨暟鎹『搴忎竴鑷� + headersList.addAll(dynamicsHeaders); + headers.addAll(headersList); + } + + if (conditions){ + Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap; + resultList = resultList.stream() + .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo())) + .collect(Collectors.toList()); + } + + List<List<Object>> data = new ArrayList<>(); + for (TMonitorResult result : resultList){ + List<Object> row = new ArrayList<>(); + row.add(result.getNo()); + row.add(result.getName()); + row.add(result.getIp()); + row.add(result.getOnlineStr()); + row.add(result.getPingOnlineStr()); + row.add(result.getCheckCount()); + row.add(result.getOffLineCount()); + if (CollectionUtils.isEmpty(result.getOffLineTimeStr())){ + row.add(null); + }else { + row.add(result.getOffLineTimeStr().toString()); + } + row.add(result.getMongoCreateTime()); + //娣诲姞鍔ㄦ�佸垪鏁版嵁 + for (String header : headersList){ + boolean flag = false; + List<DynamicColumnVO> columnVOS = groupByRefStringIdMap.get(result.getNo()); + if (!CollectionUtils.isEmpty(columnVOS)) { + for (DynamicColumnVO columnVO : columnVOS) { + if (header.equals(columnVO.getLabelValue())) { + row.add(columnVO.getColumnValue()); + flag = true; + } + } + } + //娌℃壘鍒扮敤绌轰覆鍗犱綅 + if (!flag) row.add(""); + } + data.add(row); + } + + List<List<String>> headList = new ArrayList<>(); + for (String header : headers) { + headList.add(Collections.singletonList(header)); + } + + EasyExcel.write(response.getOutputStream()) + .head(headList) // 璁剧疆琛ㄥご + .sheet("浜鸿劯鐐逛綅鍦ㄧ嚎鐜�") // 璁剧疆sheet鍚嶇О + .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) + .doWrite(data); // 鍐欏叆鏁版嵁 + } + + @Override + public void pointOnlineVideoExport(HttpServletResponse response, DataCenterQuery params) throws IOException { + List<String> likeFileds = Arrays.asList("name", "no", "ip"); + Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); + //鏌ヨ棰戣澶� + query.addCriteria(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); + //涓嬫媺妗嗗湪绾挎儏鍐垫煡璇㈡潯浠� + if (params.getOption() != null) { + query.addCriteria(Criteria.where("online").is(params.getOption())); + } + Sort sort = Sort.by( + Sort.Order.asc("pingOnline"), // 棣栧厛鎸夌収 pingOnline 鍗囧簭鎺掑簭 + Sort.Order.desc("offLineCount") // 棣栧厛鎸夌収 pingOnline 鍗囧簭鎺掑簭 + ); + // 閫氳繃pingOnline瀛楁鎺掑簭锛屼负false鐨勬帓鍦ㄥ墠闈� + query.with(sort); + MongoUtil.setNoPage(query, params, TIME_FIELD); + List<TMonitorResult> resultList = mongoTemplate.find(query, TMonitorResult.class); + resultList.forEach(item -> { + if (item.getPingOnline() == null) { + item.setPingOnlineStr("鏈煡"); + } else if (item.getPingOnline()) { + item.setPingOnlineStr("鍦ㄧ嚎"); + } else if (!item.getPingOnline()) { + item.setPingOnlineStr("绂荤嚎"); + } + if (1 == item.getOnline()) { + item.setOnlineStr("鍦ㄧ嚎"); + } else if (-1 == item.getOnline()) { + item.setOnlineStr("绂荤嚎"); + } else { + item.setOnlineStr("鏈煡"); + } + List<String> offLineTime = item.getOffLineTimeStr(); + if (!CollectionUtils.isEmpty(offLineTime)) { + if (offLineTime.size() > 1) { + offLineTime = offLineTime.subList(offLineTime.size() - 2, offLineTime.size()); + } + item.setOffLineTimeStr(offLineTime); + } + }); + List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_VIDEO_POINT); + //鍒ゆ柇鏄惁鏈夋煡璇㈡潯浠� + boolean conditions = false; + Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>(); + if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ + conditions = true; + //鑾峰緱鍔ㄦ�佸垪闆嗗悎涓寘鍚簡鐨勫瓧绗︿覆鍊肩殑闆嗗悎 鍖哄垎澶у皬鍐� + groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); + }else{ + groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); + } + //鍥哄畾琛ㄥご + LinkedHashSet<String> headers = new LinkedHashSet<>(); + headers.add(PointOnlineHeaders.no); + headers.add(PointOnlineHeaders.name); + headers.add(PointOnlineHeaders.ip); + headers.add(PointOnlineHeaders.onlineStr); + headers.add(PointOnlineHeaders.pingOnlineStr); + headers.add(PointOnlineHeaders.checkCount); + headers.add(PointOnlineHeaders.offLineCount); + headers.add(PointOnlineHeaders.offLineTimeStr); + headers.add(PointOnlineHeaders.mongoCreateTime); + + List<String> headersList = new LinkedList<>(); + List<String> dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_VIDEO_POINT); + + //娣诲姞鍔ㄦ�佽〃澶� + if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { + //浣跨敤閾捐〃淇濊瘉鍚庣画琛ュ厖鏁版嵁鏃惰幏鍙栨暟鎹『搴忎竴鑷� + headersList.addAll(dynamicsHeaders); + headers.addAll(headersList); + } + + + if (conditions){ + Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap; + resultList = resultList.stream() + .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo())) + .collect(Collectors.toList()); + } + + List<List<Object>> data = new ArrayList<>(); + for (TMonitorResult result : resultList){ + List<Object> row = new ArrayList<>(); + row.add(result.getNo()); + row.add(result.getName()); + row.add(result.getIp()); + row.add(result.getOnlineStr()); + row.add(result.getPingOnlineStr()); + row.add(result.getCheckCount()); + row.add(result.getOffLineCount()); + if (CollectionUtils.isEmpty(result.getOffLineTimeStr())){ + row.add(null); + }else { + row.add(result.getOffLineTimeStr().toString()); + } + row.add(result.getMongoCreateTime()); + //娣诲姞鍔ㄦ�佸垪鏁版嵁 + for (String header : headersList){ + boolean flag = false; + List<DynamicColumnVO> columnVOS = groupByRefStringIdMap.get(result.getNo()); + if (!CollectionUtils.isEmpty(columnVOS)) { + for (DynamicColumnVO columnVO : columnVOS) { + if (header.equals(columnVO.getLabelValue())) { + row.add(columnVO.getColumnValue()); + flag = true; + } + } + } + //娌℃壘鍒扮敤绌轰覆鍗犱綅 + if (!flag) row.add(""); + } + data.add(row); + } + + List<List<String>> headList = new ArrayList<>(); + for (String header : headers) { + headList.add(Collections.singletonList(header)); + } + + EasyExcel.write(response.getOutputStream()) + .head(headList) // 璁剧疆琛ㄥご + .sheet("瑙嗛鐐逛綅鍦ㄧ嚎鐜�") // 璁剧疆sheet鍚嶇О + .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) + .doWrite(data); // 鍐欏叆鏁版嵁 + + + } + + @Override + public void pointOnlineCarExport(HttpServletResponse response, DataCenterQuery params) throws IOException { + List<String> likeFileds = Arrays.asList("name", "no", "ip"); + Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); + //鏌ヨ溅杈嗚澶� + query.addCriteria(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Car + ".*")); + //涓嬫媺妗嗗湪绾挎儏鍐垫煡璇㈡潯浠� + if (params.getOption() != null) { + query.addCriteria(Criteria.where("online").is(params.getOption())); + } + Sort sort = Sort.by( + Sort.Order.asc("pingOnline"), // 棣栧厛鎸夌収 pingOnline 鍗囧簭鎺掑簭 + Sort.Order.desc("offLineCount") // 棣栧厛鎸夌収 pingOnline 鍗囧簭鎺掑簭 + ); + // 閫氳繃pingOnline瀛楁鎺掑簭锛屼负false鐨勬帓鍦ㄥ墠闈� + query.with(sort); + //鍒嗛〉鏁伴噺 + //绯荤粺ping鐨勭粨鏋� + List<TMonitorResult> resultList = mongoTemplate.find(query, TMonitorResult.class); + resultList.forEach(item -> { + if (item.getPingOnline() == null) { + item.setPingOnlineStr("鏈煡"); + } else if (item.getPingOnline()) { + item.setPingOnlineStr("鍦ㄧ嚎"); + } else if (!item.getPingOnline()) { + item.setPingOnlineStr("绂荤嚎"); + } + if (1 == item.getOnline()) { + item.setOnlineStr("鍦ㄧ嚎"); + } else if (-1 == item.getOnline()) { + item.setOnlineStr("绂荤嚎"); + } else { + item.setOnlineStr("鏈煡"); + } + List<String> offLineTime = item.getOffLineTimeStr(); + if (!CollectionUtils.isEmpty(offLineTime)) { + //鍚庣画鍙互鏀规垚閰嶇疆鐨勭绾挎鏁�(鎻愬彇鍓峮娆★紝n涓洪厤缃殑绂荤嚎娆℃暟) + if (offLineTime.size() > 1) { + offLineTime = offLineTime.subList(0, 2); + } + item.setOffLineTimeStr(offLineTime); + } + }); + List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_CAR_POINT); + //鍒ゆ柇鏄惁鏈夋煡璇㈡潯浠� + boolean conditions = false; + Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>(); + if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ + conditions = true; + //鑾峰緱鍔ㄦ�佸垪闆嗗悎涓寘鍚簡鐨勫瓧绗︿覆鍊肩殑闆嗗悎 鍖哄垎澶у皬鍐� + groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); + }else{ + groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); + } + //鍥哄畾琛ㄥご + LinkedHashSet<String> headers = new LinkedHashSet<>(); + headers.add(PointOnlineHeaders.no); + headers.add(PointOnlineHeaders.name); + headers.add(PointOnlineHeaders.ip); + headers.add(PointOnlineHeaders.onlineStr); + headers.add(PointOnlineHeaders.pingOnlineStr); + headers.add(PointOnlineHeaders.checkCount); + headers.add(PointOnlineHeaders.offLineCount); + headers.add(PointOnlineHeaders.offLineTimeStr); + headers.add(PointOnlineHeaders.mongoCreateTime); + + List<String> headersList = new LinkedList<>(); + List<String> dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_CAR_POINT); + + //娣诲姞鍔ㄦ�佽〃澶� + if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { + //浣跨敤閾捐〃淇濊瘉鍚庣画琛ュ厖鏁版嵁鏃惰幏鍙栨暟鎹『搴忎竴鑷� + headersList.addAll(dynamicsHeaders); + headers.addAll(headersList); + } + + + if (conditions){ + Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap; + resultList = resultList.stream() + .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo())) + .collect(Collectors.toList()); + } + + List<List<Object>> data = new ArrayList<>(); + for (TMonitorResult result : resultList){ + List<Object> row = new ArrayList<>(); + row.add(result.getNo()); + row.add(result.getName()); + row.add(result.getIp()); + row.add(result.getOnlineStr()); + row.add(result.getPingOnlineStr()); + row.add(result.getCheckCount()); + row.add(result.getOffLineCount()); + if (CollectionUtils.isEmpty(result.getOffLineTimeStr())){ + row.add(null); + }else { + row.add(result.getOffLineTimeStr().toString()); + } + row.add(result.getMongoCreateTime()); + //娣诲姞鍔ㄦ�佸垪鏁版嵁 + for (String header : headersList){ + boolean flag = false; + List<DynamicColumnVO> columnVOS = groupByRefStringIdMap.get(result.getNo()); + if (!CollectionUtils.isEmpty(columnVOS)) { + for (DynamicColumnVO columnVO : columnVOS) { + if (header.equals(columnVO.getLabelValue())) { + row.add(columnVO.getColumnValue()); + flag = true; + } + } + } + //娌℃壘鍒扮敤绌轰覆鍗犱綅 + if (!flag) row.add(""); + } + data.add(row); + } + + List<List<String>> headList = new ArrayList<>(); + for (String header : headers) { + headList.add(Collections.singletonList(header)); + } + + EasyExcel.write(response.getOutputStream()) + .head(headList) // 璁剧疆琛ㄥご + .sheet("杞﹁締鐐逛綅鍦ㄧ嚎鐜�") // 璁剧疆sheet鍚嶇О + .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) + .doWrite(data); // 鍐欏叆鏁版嵁 + } + + @Override + public Result updateDynamicValue(UpdateDynamicValueForm form) { + List<DynamicColumnVO> list = form.getDynamicColumnVOList(); + + if (CollectionUtils.isEmpty(list) || StringUtils.isEmpty(form.getId())) { + throw new RuntimeException("淇敼鑷畾涔夊垪鐨勪紶鍏ュ�间负null鎴栦紶鍏d涓簄ull"); + } + List<DynamicColumnValue> updateList = new ArrayList<>(); + List<DynamicColumnValue> addList = new ArrayList<>(); + + for (DynamicColumnVO dynamicColumnVO : list){ + if(dynamicColumnVO.getColumnValue() == null){ + continue; + } + DynamicColumnValue dynamicColumnValue = new DynamicColumnValue(); + dynamicColumnValue.setColumnValue(dynamicColumnVO.getColumnValue()); + dynamicColumnValue.setDynamicColumnId(dynamicColumnVO.getId()); + dynamicColumnValue.setRefStringId(form.getId()); + dynamicColumnValue.setRefId(0); + if(dynamicColumnVO.getValueId() == null){ + addList.add(dynamicColumnValue); + }else { + dynamicColumnValue.setId(dynamicColumnVO.getValueId()); + updateList.add(dynamicColumnValue); + } + } + log.error("addList:{}",addList); + log.error("updateList:{}",updateList); + if (CollectionUtils.isNotEmpty(addList)){ + dynamicColumnMapper.saveBatch(addList); + } + if (CollectionUtils.isNotEmpty(updateList)) { + dynamicColumnMapper.updateBatch(updateList); + } + return Result.ok("淇敼鎴愬姛"); + + + + } /** * 瑙嗛锛氱偣浣嶅湪绾跨巼 @@ -100,6 +658,7 @@ long total = mongoTemplate.count(query, TMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List<TMonitorResult> resultList = mongoTemplate.find(query, TMonitorResult.class); + resultList.forEach(item -> { if (item.getPingOnline() == null) { item.setPingOnlineStr("鏈煡"); @@ -122,7 +681,12 @@ } item.setOffLineTimeStr(offLineTime); } + //娣诲姞鍔ㄦ�佹暟鎹� + List<DynamicColumnVO> list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_VIDEO_POINT,item.getNo()); + item.setDynamicColumnList(list); }); + + params.setDeptTag(-1); params.setDeviceType(1); @@ -336,6 +900,7 @@ // 娣诲姞鍥哄畾鏉′欢 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); + criteriaList.add(Criteria.where("importantTag").is(Boolean.TRUE)); // 鏍规嵁dataType鍔ㄦ�佹坊鍔犳潯浠� if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); @@ -436,6 +1001,7 @@ // 娣诲姞鍥哄畾鏉′欢 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); + criteriaList.add(Criteria.where("importantCommandImageTag").is(Boolean.TRUE)); // 鏍规嵁dataType鍔ㄦ�佹坊鍔犳潯浠� if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); @@ -789,6 +1355,22 @@ return Result.ok().data(map).total(total); } + private final ISysConfigService configService; + + public double getSySMinTime(){ + //鑾峰彇绯荤粺鍙傛暟 + String dictLabel = configService.selectConfigByKey("recording_min_time"); + double recordingMinTime; + try { + recordingMinTime = Double.parseDouble(dictLabel) / 60; // 濡傛灉 dictLabel 鏄互灏忔椂涓哄崟浣嶏紝鍒欐棤闇�闄や互 60 + } catch (Exception e) { + log.error("閰嶇疆鐨勫垹闄ゆ椂闂磋寖鍥存牸寮忎笉姝g‘: {}", dictLabel, e); + return 12.0; // 榛樿 12 灏忔椂锛堜互灏忔椂涓哄崟浣嶏級 + } + + return recordingMinTime; + } + /** * 瑙嗛锛氬綍鍍忓彲鐢ㄧ巼 * @@ -797,6 +1379,7 @@ */ @Override public Result videoAvailabilityRate(DataCenterQuery params) { + List<String> likeFileds = Arrays.asList("deviceId", "deviceName"); Query query = MongoUtil.getQuery(params, "createTime", likeFileds, null); //涓嬫媺妗嗗綍鍍忔儏鍐垫煡璇㈡潯浠� @@ -806,11 +1389,18 @@ long total = mongoTemplate.count(query, RecordMetaDSumResult.class); MongoUtil.setPage(query, params, "createTime"); List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + //鏌ヨ鍔ㄦ�佸垪鏁版嵁 + //鏌ヨ鍔ㄦ�佸垪鏁版嵁鏇村叿id鏌ヨ +// List<DynamicColumnVO> dynamicColumnNames = dynamicColumnMapper.getDynamicColumnByTableName("uy_record_meta_d_sum"); //缈昏瘧琛屾斂鍖哄煙 resultList.forEach(item -> { String areaCode = item.getArealayername().substring(0, 6); AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode); if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName()); + + List<DynamicColumnVO> list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_VIDEO,item.getId()); + item.setDynamicColumnList(list); + }); // 缁熻鏁伴噺 MongoDatabase database = mongoTemplate.getDb(); @@ -837,6 +1427,33 @@ } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); + + //璁$畻褰曞儚鍙敤鐜� + MongoDatabase databaes2 = mongoTemplate.getDb(); + MongoCollection<Document> collection2 = databaes2.getCollection("uy_record_meta_d_sum"); + + double finalRecordingMinTime = getSySMinTime(); + + List<Document> documentList = new ArrayList<>(2); + setTag(params, documentList); + Document recording = new Document("recordDuration",new Document("$gte", finalRecordingMinTime)); + documentList.add(recording); + + Document filter = new Document("$and", documentList); + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceId")), + new Document("$count", "uniqueDeviceIds") + ); + AggregateIterable<Document> result = collection2.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + log.error("褰曞儚鍙敤鐜囨墦鍗帮細{}",uniqueDeviceIdCount); // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getVideoAvailable) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) @@ -857,8 +1474,12 @@ resultCount.add(0, totalCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; + + +// 1锛氬畬鏁� 0锛氶棿姝� -1锛氬紓甯� | if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) { - onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); + //resultCount.get(0)鏄�绘暟 uniqueDeviceIdCount鏄洿鍏风郴缁熷弬鏁版煡璇㈠埌mongodb涓ぇ浜庣瓑浜� recordDuration瀛楁鐨勬�绘暟 + onlineRate = new BigDecimal(uniqueDeviceIdCount).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } resultCount.add(this.remove0(onlineRate)); @@ -918,6 +1539,35 @@ return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); + + //璁$畻閮ㄧ骇褰曞儚鍙敤鐜� + MongoDatabase database2 = mongoTemplate.getDb(); + MongoCollection<Document> collection2 = database2.getCollection("uy_record_meta_d_sum"); + double finalRecordingMinTime = getSySMinTime(); + + List<Document> documentList = new ArrayList<>(4); + documentList.add(new Document("deptTag", new Document("$eq", Boolean.TRUE))); + setTag(params, documentList); + Document recording = new Document("recordDuration",new Document("$gte", finalRecordingMinTime)); + documentList.add(recording); + Document filter = new Document("$and", documentList); + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceId")), + new Document("$count", "uniqueDeviceIds") + ); + AggregateIterable<Document> result = collection2.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + log.error("閮ㄧ骇褰曞儚鍙敤鐜噞}:",uniqueDeviceIdCount); + + + // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getMinistryVideoAvailable) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) @@ -938,7 +1588,7 @@ resultCount.add(0, totalCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) { - onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); + onlineRate = new BigDecimal(uniqueDeviceIdCount).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } resultCount.add(this.remove0(onlineRate)); HashMap<String, Object> map = new HashMap<>(); @@ -997,6 +1647,32 @@ return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); + //璁$畻閲嶇偣鐐逛綅褰曞儚鍙敤鐜� + MongoDatabase database2 = mongoTemplate.getDb(); + MongoCollection<Document> collection2 = database2.getCollection("uy_record_meta_d_sum"); + double finalRecordingMinTime = getSySMinTime(); + + List<Document> documentList = new ArrayList<>(4); + documentList.add(new Document("importantTag", new Document("$eq", Boolean.TRUE))); + setTag(params, documentList); + Document recording = new Document("recordDuration",new Document("$gte", finalRecordingMinTime)); + documentList.add(recording); + Document filter = new Document("$and", documentList); + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceId")), + new Document("$count", "uniqueDeviceIds") + ); + AggregateIterable<Document> result = collection2.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + log.error("閲嶇偣鐐逛綅褰曞儚鍙敤鐜噞}:",uniqueDeviceIdCount); + // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getKeyVideoAvailable) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) @@ -1017,7 +1693,7 @@ resultCount.add(0, totalCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) { - onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); + onlineRate = new BigDecimal(uniqueDeviceIdCount).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } resultCount.add(this.remove0(onlineRate)); HashMap<String, Object> map = new HashMap<>(); @@ -1561,6 +2237,9 @@ } item.setOffLineTimeStr(offLineTime); } + //娣诲姞鍔ㄦ�佹暟鎹� + List<DynamicColumnVO> list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_CAR_POINT,item.getNo()); + item.setDynamicColumnList(list); }); // 缁熻璁惧鏁伴噺 @@ -2432,6 +3111,9 @@ } item.setOffLineTimeStr(offLineTime); } + //娣诲姞鍔ㄦ�佹暟鎹� + List<DynamicColumnVO> list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_FACE_POINT,item.getNo()); + item.setDynamicColumnList(list); }); params.setDeptTag(-1); params.setDeviceType(3); @@ -2971,6 +3653,10 @@ sampleCount = doc.getInteger("sampleCount"); expCount = doc.getInteger("expCount"); } + + + //鏂版瀯寤鸿仛鍚堟煡璇㈢绾挎椂闂� + List<String> countList = new ArrayList<>(); // 缁熻鏁� @@ -2993,6 +3679,8 @@ onlineRate = new BigDecimal(sampleCount-expCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } countList.add(this.remove0(onlineRate)); + + HashMap<String, Object> map = new HashMap<>(); map.put("count", countList); map.put("list", voList); -- Gitblit v1.8.0