package com.ycl.platform.service.impl; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.metadata.IPage; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; import com.mongodb.client.AggregateIterable; 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.query.DataCenterQuery; import com.ycl.platform.domain.result.HK.*; import com.ycl.platform.domain.result.SYS.TMonitorResult; import com.ycl.platform.domain.result.UY.*; 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.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.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 enumeration.general.AreaDeptEnum; import jakarta.servlet.http.HttpServletResponse; import lombok.RequiredArgsConstructor; import org.apache.commons.collections.CollectionUtils; import org.bson.Document; import org.springframework.data.domain.Sort; import org.springframework.data.mongodb.core.MongoTemplate; 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.math.BigDecimal; import java.math.RoundingMode; import java.text.DecimalFormat; import java.text.SimpleDateFormat; import java.util.*; import java.util.regex.Pattern; import java.util.stream.Collectors; /** * 数据中心接口 * * @author：xp * @date：2024/8/2 11:07 */ @Service @RequiredArgsConstructor public class DataCenterServiceImpl implements DataCenterService { private final MongoTemplate mongoTemplate; private final ImageResourceSecurityDetailMapper securityDetailMapper; private final YwPointMapper pointMapper; private final ICheckIndexVideoService checkIndexVideoService; private final ICheckIndexCarService checkIndexCarService; private final ICheckIndexFaceService checkIndexFaceService; private final static String TIME_FIELD = "mongoCreateTime"; private static DecimalFormat DF = new DecimalFormat("#.####"); /** * 视频：点位在线率 * * @param params * @return */ @Override public Result videoPointOnlineRate(DataCenterQuery params) { List 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); //分页数量 long total = mongoTemplate.count(query, TMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List 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 offLineTime = item.getOffLineTimeStr(); if (!CollectionUtils.isEmpty(offLineTime)) { if (offLineTime.size() > 1) { offLineTime = offLineTime.subList(offLineTime.size() - 2, offLineTime.size()); } item.setOffLineTimeStr(offLineTime); } }); params.setDeptTag(-1); params.setDeviceType(1); //卡片统计 int totalCount = 0; int onlineCount = 0; int offlineCount = 0; int unknownCount = 0; //构建条件 List criteriaList = new ArrayList<>(); // 添加固定条件 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } else if (params.getDataType() == 2) { criteriaList.add(Criteria.where("deptTag").is(Boolean.TRUE)); } // 构建match操作 MatchOperation match = Aggregation.match( new Criteria().andOperator(criteriaList.toArray(new Criteria[0])) ); GroupOperation group = Aggregation.group() .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Online)).then(1).otherwise(0)).as("onlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Offline)).then(1).otherwise(0)).as("offlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Unknown)).then(1).otherwise(0)).as("unknownCount"); // 将匹配阶段和分组阶段组合起来 Aggregation aggregation = Aggregation.newAggregation(match, group); // 执行聚合查询 AggregationResults results = mongoTemplate.aggregate(aggregation, "t_monitor_online", Map.class); // 替换为你的集合名称 for (Map result : results.getMappedResults()) { offlineCount = (Integer) result.getOrDefault("offlineCount", 0L); unknownCount = (Integer) result.getOrDefault("unknownCount", 0L); onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); totalCount = offlineCount + unknownCount + onlineCount; } BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount!=0) { onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } // /** 查询当天在线率 */ // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getSiteOnline) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) // .list(); // // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getSiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } HashMap map = new HashMap<>(); map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：部级点位在线率 * * @param params * @return */ @Override public Result deptVideoPointOnlineRate(DataCenterQuery params) { List 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 + ".*")); query.addCriteria(Criteria.where("deptTag").is(Boolean.TRUE)); //下拉框在线情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("online").is(params.getOption())); } // 通过pingOnline字段排序，为false的排在前面 query.with(Sort.by(Sort.Order.asc("pingOnline"))); //分页数量 long total = mongoTemplate.count(query, TMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List 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("未知"); } }); // 统计设备数量 //卡片统计 int totalCount = 0; int onlineCount = 0; int offlineCount = 0; int unknownCount = 0; //构建条件 List criteriaList = new ArrayList<>(); // 添加固定条件 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("deptTag").is(Boolean.TRUE)); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } else if (params.getDataType() == 2) { criteriaList.add(Criteria.where("deptTag").is(Boolean.TRUE)); } // 构建match操作 MatchOperation match = Aggregation.match( new Criteria().andOperator(criteriaList.toArray(new Criteria[0])) ); GroupOperation group = Aggregation.group() .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Online)).then(1).otherwise(0)).as("onlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Offline)).then(1).otherwise(0)).as("offlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Unknown)).then(1).otherwise(0)).as("unknownCount"); // 将匹配阶段和分组阶段组合起来 Aggregation aggregation = Aggregation.newAggregation(match, group); // 执行聚合查询 AggregationResults results = mongoTemplate.aggregate(aggregation, "t_monitor_online", Map.class); // 替换为你的集合名称 for (Map result : results.getMappedResults()) { offlineCount = (Integer) result.getOrDefault("offlineCount", 0L); unknownCount = (Integer) result.getOrDefault("unknownCount", 0L); onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); totalCount = offlineCount + unknownCount + onlineCount; } BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount!=0) { onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } // params.setDeptTag(1); // params.setDeviceType(1); // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getMinistrySiteOnline) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMinistrySiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } HashMap map = new HashMap<>(); map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：重点点位在线率 * * @param params * @return */ @Override public Result videoImportantPointOnlineRate(DataCenterQuery params) { List 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 + ".*")); query.addCriteria(Criteria.where("importantTag").is(Boolean.TRUE)); //下拉框在线情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("online").is(params.getOption())); } // 通过pingOnline字段排序，为false的排在前面 query.with(Sort.by(Sort.Order.asc("pingOnline"))); //分页数量 long total = mongoTemplate.count(query, TMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, TMonitorResult.class); params.setDeptTag(3); params.setDeviceType(1); 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("未知"); } }); // 统计设备数量 //卡片统计 int totalCount = 0; int onlineCount = 0; int offlineCount = 0; int unknownCount = 0; //构建条件 List criteriaList = new ArrayList<>(); // 添加固定条件 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } else if (params.getDataType() == 2) { criteriaList.add(Criteria.where("deptTag").is(Boolean.TRUE)); } // 构建match操作 MatchOperation match = Aggregation.match( new Criteria().andOperator(criteriaList.toArray(new Criteria[0])) ); GroupOperation group = Aggregation.group() .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Online)).then(1).otherwise(0)).as("onlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Offline)).then(1).otherwise(0)).as("offlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Unknown)).then(1).otherwise(0)).as("unknownCount"); // 将匹配阶段和分组阶段组合起来 Aggregation aggregation = Aggregation.newAggregation(match, group); // 执行聚合查询 AggregationResults results = mongoTemplate.aggregate(aggregation, "t_monitor_online", Map.class); // 替换为你的集合名称 for (Map result : results.getMappedResults()) { offlineCount = (Integer) result.getOrDefault("offlineCount", 0L); unknownCount = (Integer) result.getOrDefault("unknownCount", 0L); onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); totalCount = offlineCount + unknownCount + onlineCount; } BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount!=0) { onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getKeySiteOnline) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeySiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } HashMap map = new HashMap<>(); map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：重点指挥图像在线率 * * @param params * @return */ @Override public Result videoImportantPointImageOnlineRate(DataCenterQuery params) { List 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 + ".*")); query.addCriteria(Criteria.where("importantCommandImageTag").is(Boolean.TRUE)); //下拉框在线情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("online").is(params.getOption())); } // 通过pingOnline字段排序，为false的排在前面 query.with(Sort.by(Sort.Order.asc("pingOnline"))); //分页数量 long total = mongoTemplate.count(query, TMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, TMonitorResult.class); params.setDeptTag(4); params.setDeviceType(1); 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("未知"); } }); // 统计设备数量 //卡片统计 int totalCount = 0; int onlineCount = 0; int offlineCount = 0; int unknownCount = 0; //构建条件 List criteriaList = new ArrayList<>(); // 添加固定条件 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } else if (params.getDataType() == 2) { criteriaList.add(Criteria.where("deptTag").is(Boolean.TRUE)); } // 构建match操作 MatchOperation match = Aggregation.match( new Criteria().andOperator(criteriaList.toArray(new Criteria[0])) ); GroupOperation group = Aggregation.group() .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Online)).then(1).otherwise(0)).as("onlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Offline)).then(1).otherwise(0)).as("offlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Unknown)).then(1).otherwise(0)).as("unknownCount"); // 将匹配阶段和分组阶段组合起来 Aggregation aggregation = Aggregation.newAggregation(match, group); // 执行聚合查询 AggregationResults results = mongoTemplate.aggregate(aggregation, "t_monitor_online", Map.class); // 替换为你的集合名称 for (Map result : results.getMappedResults()) { offlineCount = (Integer) result.getOrDefault("offlineCount", 0L); unknownCount = (Integer) result.getOrDefault("unknownCount", 0L); onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); totalCount = offlineCount + unknownCount + onlineCount; } BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount!=0) { onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getKeyCommandImageOnline) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyCommandImageOnline).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } HashMap map = new HashMap<>(); map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：一机一档注册率 * * @param params * @return */ @Override public Result videoOneMachineDocumentRegister(DataCenterQuery params) { List likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue"); List andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); Query query = new Query(); Criteria and = new Criteria(); if (params.getOption() != null) { if (params.getOption() == 1) { andCriteria.add(Criteria.where("newDevice").is(Boolean.TRUE)); } else if (params.getOption() == -1) { andCriteria.add(Criteria.where("newDevice").is(Boolean.FALSE)); } } and.andOperator(andCriteria); query = Query.query(and); long total = mongoTemplate.count(query, MonitorQualifyResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, MonitorQualifyResult.class); List resultVOS = new ArrayList<>(); for (MonitorQualifyResult result : resultList) { MonitorQualifyResultVO vo = MonitorQualifyResult.getVO(result); resultVOS.add(vo); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_monitor_qualify"); //总数 List dList1 = new ArrayList<>(2); setTag(params, dList1); Document totalFilter = new Document("$and", dList1); //新设备数 List dList2 = new ArrayList<>(2); setTag(params, dList2); dList2.add(new Document("newDevice", Boolean.TRUE)); Document newFilter = new Document("$and", dList2); List lists = Arrays.asList(totalFilter, newFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$serialNumber.showValue")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getMonitorRegistration) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMonitorRegistration).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal rate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { rate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(rate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultVOS); return Result.ok().data(map).total(total); } /** * 视频：一机一档合格率 * * @param params * @return */ @Override public Result videoOneMachineDocumentQualified(DataCenterQuery params) { List likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue"); List andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); if (params.getOption() != null) { if (params.getOption() == 1) { andCriteria.add(Criteria.where("serialNumber.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("name.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("civilCode.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("integrated_device.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("jkdwlx.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("latitude.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("longitude.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("macdz.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("name.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("sbzt.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("sxjcjqy.error").is(Boolean.FALSE)); andCriteria.add(Criteria.where("sxjgnlx.error").is(Boolean.FALSE)); Criteria and2 = new Criteria(); and2.andOperator(andCriteria); query = Query.query(and2); } else if (params.getOption() == -1) { Criteria c1 = Criteria.where("serialNumber.error").is(Boolean.TRUE); Criteria c2 = Criteria.where("name.error").is(Boolean.TRUE); Criteria c3 = Criteria.where("civilCode.error").is(Boolean.TRUE); Criteria c4 = Criteria.where("integrated_device.error").is(Boolean.TRUE); Criteria c5 = Criteria.where("jkdwlx.error").is(Boolean.TRUE); Criteria c6 = Criteria.where("latitude.error").is(Boolean.TRUE); Criteria c7 = Criteria.where("longitude.error").is(Boolean.TRUE); Criteria c8 = Criteria.where("macdz.error").is(Boolean.TRUE); Criteria c9 = Criteria.where("name.error").is(Boolean.TRUE); Criteria c10 = Criteria.where("sbzt.error").is(Boolean.TRUE); Criteria c11 = Criteria.where("sxjcjqy.error").is(Boolean.TRUE); Criteria c12 = Criteria.where("sxjgnlx.error").is(Boolean.TRUE); Criteria orOperator = new Criteria().orOperator(c1, c2, c3, c4, c5, c6, c7, c8, c9, c10, c11, c12); orOperator.andOperator(andCriteria); query = Query.query(orOperator); } } long total = mongoTemplate.count(query, MonitorQualifyResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, MonitorQualifyResult.class); List resultVOS = new ArrayList<>(); for (MonitorQualifyResult result : resultList) { MonitorQualifyResultVO vo = MonitorQualifyResult.getVO(result); resultVOS.add(vo); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_monitor_qualify"); //总数 List dList1 = new ArrayList<>(2); setTag(params, dList1); Document totalFilter = new Document("$and", dList1); //合格数 List dList2 = new ArrayList<>(2); dList2.add(new Document("serialNumber.error", Boolean.FALSE)); dList2.add(new Document("name.error", Boolean.FALSE)); dList2.add(new Document("civilCode.error", Boolean.FALSE)); dList2.add(new Document("integrated_device.error", Boolean.FALSE)); dList2.add(new Document("jkdwlx.error", Boolean.FALSE)); dList2.add(new Document("latitude.error", Boolean.FALSE)); dList2.add(new Document("longitude.error", Boolean.FALSE)); dList2.add(new Document("macdz.error", Boolean.FALSE)); dList2.add(new Document("name.error", Boolean.FALSE)); dList2.add(new Document("sbzt.error", Boolean.FALSE)); dList2.add(new Document("sxjcjqy.error", Boolean.FALSE)); dList2.add(new Document("sxjgnlx.error", Boolean.FALSE)); setTag(params, dList2); Document qualifyFilter = new Document("$and", dList2); //不合格数 List dList3 = new ArrayList<>(2); setTag(params, dList3); List errorConditions = new ArrayList<>(); errorConditions.add(new Document("serialNumber.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("name.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("civilCode.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("integrated_device.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("jkdwlx.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("name.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("sbzt.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("sxjcjqy.error", new Document("$eq", Boolean.TRUE))); errorConditions.add(new Document("sxjgnlx.error", new Document("$eq", Boolean.TRUE))); Document errorFilter = new Document("$or", errorConditions); dList3.add(errorFilter); Document unQualifyFilter = new Document("$and", dList3); List lists = Arrays.asList(totalFilter, qualifyFilter, unQualifyFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$serialNumber.showValue")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getMonitorQualification) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMonitorQualification).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultVOS); return Result.ok().data(map).total(total); } /** * 视频：档案考核比 * 档案留存总量：mongo存的所有去重后的档案 * 当日档案：当日的档案 * 档案考核比 = 当日档案/档案留存总量 * * @param params * @return1 */ @Override public Result videoAssessmentFileRatio(DataCenterQuery params) { List likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue"); List andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); long total = mongoTemplate.count(query, MonitorQualifyResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, MonitorQualifyResult.class); List resultVOS = new ArrayList<>(); for (MonitorQualifyResult result : resultList) { MonitorQualifyResultVO vo = MonitorQualifyResult.getVO(result); resultVOS.add(vo); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_monitor_qualify"); //总数 List dList1 = new ArrayList<>(2); DataCenterQuery totalParams = new DataCenterQuery(); BeanUtils.copyProperties(params, totalParams); totalParams.setStartTime(null); setTag(totalParams, dList1); Document totalFilter = new Document("$and", dList1); //当日档案数 List dList2 = new ArrayList<>(2); setTag(params, dList2); Document newFilter = new Document("$and", dList2); List lists = Arrays.asList(totalFilter, newFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$serialNumber.showValue")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getArchivesRate) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getArchivesRate).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultVOS); return Result.ok().data(map).total(total); } /** * 视频：录像可用率 * * @param params * @return */ @Override public Result videoAvailabilityRate(DataCenterQuery params) { List 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())); } long total = mongoTemplate.count(query, RecordMetaDSumResult.class); MongoUtil.setPage(query, params, "createTime"); List 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()); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_record_meta_d_sum"); List status = Arrays.asList(1, 0, -1); List resultCount = status.stream().map(item -> { List dList = new ArrayList<>(2); dList.add(new Document("recordStatus", new Document("$eq", item))); setTag(params, dList); Document filter = new Document("$and", dList); // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceId")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getVideoAvailable) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getVideoAvailable).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } //加一个总数 int totalCount = 0; for (String s : resultCount) { totalCount += Integer.parseInt(s); } 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")); } resultCount.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", resultCount); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：部级录像可用率 * * @param params * @return */ @Override public Result deptVideoAvailabilityRate(DataCenterQuery params) { List likeFileds = Arrays.asList("deviceId", "deviceName"); Query query = MongoUtil.getQuery(params, "createTime", likeFileds, 1); //下拉框录像情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("recordStatus").is(params.getOption())); } long total = mongoTemplate.count(query, RecordMetaDSumResult.class); MongoUtil.setPage(query, params, "createTime"); List 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()); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_record_meta_d_sum"); List status = Arrays.asList(1, 0, -1); List resultCount = status.stream().map(item -> { List dList = new ArrayList<>(4); dList.add(new Document("deptTag", new Document("$eq", Boolean.TRUE))); dList.add(new Document("recordStatus", new Document("$eq", item))); setTag(params, dList); Document filter = new Document("$and", dList); // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceId")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getMinistryVideoAvailable) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMinistryVideoAvailable).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } //加一个总数 int totalCount = 0; for (String s : resultCount) { totalCount += Integer.parseInt(s); } 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")); } resultCount.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", resultCount); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：重点点位录像可用率 * * @param params * @return */ @Override public Result videoImportantPointAvailabilityRate(DataCenterQuery params) { List likeFileds = Arrays.asList("deviceId", "deviceName"); Query query = MongoUtil.getQuery(params, "createTime", likeFileds, 3); //下拉框录像情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("recordStatus").is(params.getOption())); } long total = mongoTemplate.count(query, RecordMetaDSumResult.class); MongoUtil.setPage(query, params, "createTime"); List 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()); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_record_meta_d_sum"); List status = Arrays.asList(1, 0, -1); List resultCount = status.stream().map(item -> { List dList = new ArrayList<>(4); dList.add(new Document("importantTag", new Document("$eq", Boolean.TRUE))); dList.add(new Document("recordStatus", new Document("$eq", item))); setTag(params, dList); Document filter = new Document("$and", dList); // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceId")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getKeyVideoAvailable) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyVideoAvailable).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } //加一个总数 int totalCount = 0; for (String s : resultCount) { totalCount += Integer.parseInt(s); } 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")); } resultCount.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", resultCount); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：标注正确率（暂停） * * @param params * @return */ @Override public Result videoLabelingAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("deviceId", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); long total = mongoTemplate.count(query, RecordMetaDSumResult.class); List resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); // 统计数 long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), RecordMetaDSumResult.class); long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), RecordMetaDSumResult.class); long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), RecordMetaDSumResult.class); long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), RecordMetaDSumResult.class); long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), RecordMetaDSumResult.class); HashMap map = new HashMap<>(); map.put("count", Arrays.asList(nonNetwork, network, video, car, face)); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：重点点位标注正确率 * * @param params * @return */ @Override public Result videoImportantPointLabelingAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("deviceNo", "osdName"); List andCriteria = MongoUtil.getAndCriteria(params, "checkTime", likeFileds, null); Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); //下拉框标注正确查询条件 if (params.getOption() != null) { if (params.getOption() == 1) { andCriteria.add(Criteria.where("osdNameCorrect").is(1)); andCriteria.add(Criteria.where("osdTimeCorrect").is(1)); andCriteria.add(Criteria.where("osdProvinceCorrect").is(1)); andCriteria.add(Criteria.where("osdCityCorrect").is(1)); andCriteria.add(Criteria.where("osdPartCorrect").is(1)); Criteria and2 = new Criteria(); and2.andOperator(andCriteria); query = Query.query(and2); } else if (params.getOption() == -1) { // 使用$or条件连接多个字段检查，每个字段检查是否等于-1 Criteria c1 = Criteria.where("osdNameCorrect").is(-1); Criteria c2 = Criteria.where("osdTimeCorrect").is(-1); Criteria c3 = Criteria.where("osdProvinceCorrect").is(-1); Criteria c4 = Criteria.where("osdCityCorrect").is(-1); Criteria c5 = Criteria.where("osdPartCorrect").is(-1); Criteria orOperator = new Criteria().orOperator(c1, c2, c3, c4, c5); orOperator.andOperator(andCriteria); query = Query.query(orOperator); } else { Criteria c1 = Criteria.where("osdNameCorrect").is(0); Criteria c2 = Criteria.where("osdTimeCorrect").is(0); Criteria c3 = Criteria.where("osdProvinceCorrect").is(0); Criteria c4 = Criteria.where("osdCityCorrect").is(0); Criteria c5 = Criteria.where("osdPartCorrect").is(0); Criteria orOperator = new Criteria().orOperator(c1, c2, c3, c4, c5); orOperator.andOperator(andCriteria); query = Query.query(orOperator); } } long total = mongoTemplate.count(query, OsdCheckResult.class); MongoUtil.setPage(query, params, "checkTime"); List resultList = mongoTemplate.find(query, OsdCheckResult.class); for (OsdCheckResult osdCheckResult : resultList) { OsdCheckResult.getError(osdCheckResult); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("osd_check_result"); //总数 List dList = new ArrayList<>(2); dList.add(new Document("importantTag", Boolean.TRUE)); setTag(params, dList); Document osdFilter = new Document("$and", dList); //正常数 List dList1 = new ArrayList<>(2); dList1.add(new Document("importantTag", Boolean.TRUE)); dList1.add(new Document("osdNameCorrect", new Document("$eq", 1))); dList1.add(new Document("osdTimeCorrect", new Document("$eq", 1))); dList1.add(new Document("osdProvinceCorrect", new Document("$eq", 1))); dList1.add(new Document("osdCityCorrect", new Document("$eq", 1))); dList1.add(new Document("osdPartCorrect", new Document("$eq", 1))); setTag(params, dList1); Document osdCorrectFilter = new Document("$and", dList1); //异常数 List dList2 = new ArrayList<>(2); setTag(params, dList2); Document importantTagCondition = new Document("importantTag", Boolean.TRUE); dList2.add(importantTagCondition); List errorConditions = new ArrayList<>(); errorConditions.add(new Document("osdNameCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdTimeCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdProvinceCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdCityCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdPartCorrect", new Document("$eq", -1))); Document errorFilter = new Document("$or", errorConditions); dList2.add(errorFilter); Document osdErrorFilter = new Document("$and", dList2); //未知数 List dList3 = new ArrayList<>(2); setTag(params, dList3); dList3.add(importantTagCondition); List unknownConditions = new ArrayList<>(); unknownConditions.add(new Document("osdNameCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdTimeCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdProvinceCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdCityCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdPartCorrect", new Document("$eq", 0))); // 使用$or逻辑组合剩余的条件 Document unknownFilter = new Document("$or", unknownConditions); dList3.add(unknownFilter); Document osdUnknownFilter = new Document("$and", dList3); List lists = Arrays.asList(osdFilter, osdCorrectFilter, osdErrorFilter, osdUnknownFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceNo")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getKeyAnnotationAccuracy) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyAnnotationAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } @Override public void videoImportantPointLabelingAccuracyExport(HttpServletResponse response, DataCenterQuery params) { List likeFileds = Arrays.asList("deviceNo", "osdName"); List andCriteria = MongoUtil.getAndCriteria(params, "checkTime", likeFileds, null); Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); //下拉框标注正确查询条件 if (params.getOption() != null) { if (params.getOption() == 1) { andCriteria.add(Criteria.where("osdNameCorrect").is(1)); andCriteria.add(Criteria.where("osdTimeCorrect").is(1)); andCriteria.add(Criteria.where("osdProvinceCorrect").is(1)); andCriteria.add(Criteria.where("osdCityCorrect").is(1)); andCriteria.add(Criteria.where("osdPartCorrect").is(1)); Criteria and2 = new Criteria(); and2.andOperator(andCriteria); query = Query.query(and2); } else if (params.getOption() == -1) { // 使用$or条件连接多个字段检查，每个字段检查是否等于-1 Criteria c1 = Criteria.where("osdNameCorrect").is(-1); Criteria c2 = Criteria.where("osdTimeCorrect").is(-1); Criteria c3 = Criteria.where("osdProvinceCorrect").is(-1); Criteria c4 = Criteria.where("osdCityCorrect").is(-1); Criteria c5 = Criteria.where("osdPartCorrect").is(-1); Criteria orOperator = new Criteria().orOperator(c1, c2, c3, c4, c5); orOperator.andOperator(andCriteria); query = Query.query(orOperator); } else { Criteria c1 = Criteria.where("osdNameCorrect").is(0); Criteria c2 = Criteria.where("osdTimeCorrect").is(0); Criteria c3 = Criteria.where("osdProvinceCorrect").is(0); Criteria c4 = Criteria.where("osdCityCorrect").is(0); Criteria c5 = Criteria.where("osdPartCorrect").is(0); Criteria orOperator = new Criteria().orOperator(c1, c2, c3, c4, c5); orOperator.andOperator(andCriteria); query = Query.query(orOperator); } } List resultList = mongoTemplate.find(query, OsdCheckResult.class); for (OsdCheckResult osdCheckResult : resultList) { OsdCheckResult.getError(osdCheckResult); StringBuilder tag = new StringBuilder("" + (osdCheckResult.getProvinceTag() ? "省厅、" : "") + (osdCheckResult.getImportantTag() ? "重点点位、" : "") + (osdCheckResult.getImportantCommandImageTag() ? "重点指挥图像、" : "") + (osdCheckResult.getDeptTag() ? "部级、" : "")); // 删除字符串末尾的"、" if (tag.toString().endsWith("、")) { tag = new StringBuilder(tag.substring(0, tag.length() - 1)); } osdCheckResult.setTagStr(tag.toString()); } ExcelUtil util = new ExcelUtil<>(OsdCheckResult.class); String sheetName = "OSD标注"; util.exportExcel(response, resultList, sheetName); } /** * 视频：校时正确率(停用) * * @param params * @return */ @Override public Result videoCheckTimeAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("deviceId"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); long total = mongoTemplate.count(query, OneMachineFileResult.class); List resultList = mongoTemplate.find(query, OneMachineFileResult.class); // 统计数 long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OneMachineFileResult.class); long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OneMachineFileResult.class); long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OneMachineFileResult.class); long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OneMachineFileResult.class); long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OneMachineFileResult.class); HashMap map = new HashMap<>(); map.put("count", Arrays.asList(nonNetwork, network, video, car, face)); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 视频：重点点位校时正确率 * * @param params * @return */ @Override public Result videoImportantPointCheckTimeAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("deviceNo", "osdName"); Query query = MongoUtil.getQuery(params, "checkTime", likeFileds, null); //下拉框标注正确查询条件 if (params.getOption() != null) { if (params.getOption() == 1) { query.addCriteria(Criteria.where("osdTimeCorrect").is(1)); } else if (params.getOption() == -1) { query.addCriteria(Criteria.where("osdTimeCorrect").is(-1)); } else { query.addCriteria(Criteria.where("osdTimeCorrect").is(0)); } } long total = mongoTemplate.count(query, OsdCheckResult.class); MongoUtil.setPage(query, params, "checkTime"); List resultList = mongoTemplate.find(query, OsdCheckResult.class); for (OsdCheckResult osdCheckResult : resultList) { OsdCheckResult.getError(osdCheckResult); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("osd_check_result"); //总数 List dList = new ArrayList<>(2); dList.add(new Document("importantTag", Boolean.TRUE)); setTag(params, dList); Document osdFilter = new Document("$and", dList); //正常数 List dList1 = new ArrayList<>(2); dList1.add(new Document("importantTag", Boolean.TRUE)); dList1.add(new Document("osdNameCorrect", new Document("$eq", 1))); dList1.add(new Document("osdTimeCorrect", new Document("$eq", 1))); dList1.add(new Document("osdProvinceCorrect", new Document("$eq", 1))); dList1.add(new Document("osdCityCorrect", new Document("$eq", 1))); dList1.add(new Document("osdPartCorrect", new Document("$eq", 1))); setTag(params, dList1); Document osdCorrectFilter = new Document("$and", dList1); //异常数 List dList2 = new ArrayList<>(2); setTag(params, dList2); Document importantTagCondition = new Document("importantTag", Boolean.TRUE); dList2.add(importantTagCondition); List errorConditions = new ArrayList<>(); errorConditions.add(new Document("osdNameCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdTimeCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdProvinceCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdCityCorrect", new Document("$eq", -1))); errorConditions.add(new Document("osdPartCorrect", new Document("$eq", -1))); Document errorFilter = new Document("$or", errorConditions); dList2.add(errorFilter); Document osdErrorFilter = new Document("$and", dList2); //未知数 List dList3 = new ArrayList<>(2); setTag(params, dList3); dList3.add(importantTagCondition); List unknownConditions = new ArrayList<>(); unknownConditions.add(new Document("osdNameCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdTimeCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdProvinceCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdCityCorrect", new Document("$eq", 0))); unknownConditions.add(new Document("osdPartCorrect", new Document("$eq", 0))); // 使用$or逻辑组合剩余的条件 Document unknownFilter = new Document("$or", unknownConditions); dList3.add(unknownFilter); Document osdUnknownFilter = new Document("$and", dList3); List lists = Arrays.asList(osdFilter, osdCorrectFilter, osdErrorFilter, osdUnknownFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceNo")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) // .select(CheckIndexVideo::getKeyTimingAccuracy) // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyTimingAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：视图库对接稳定性 * * @param params * @return */ @Override public Result vehicleViewDockStable(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); //加DataType为车辆 query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_CAR)); if (params.getOption() != null) { if (ApiConstants.HK_SnapCount_ResultType_Normal.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Normal)); } else if (ApiConstants.HK_SnapCount_ResultType_Null.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Null)); } else if (ApiConstants.HK_SnapCount_ResultType_Descent.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Descent)); } else if (ApiConstants.HK_SnapCount_ResultType_Low.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Low)); } } long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); resultList.forEach(item -> item.setResultTypeText(item.getResultTypeText())); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_snapshot_data_monitor"); List dList2 = new ArrayList<>(2); dList2.add(new Document("resultType", new Document("$eq", 1))); dList2.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList2); List dList3 = new ArrayList<>(2); dList3.add(new Document("resultType", new Document("$eq", 2))); dList3.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList3); List dList4 = new ArrayList<>(2); dList4.add(new Document("resultType", new Document("$eq", 3))); dList4.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList4); List dList5 = new ArrayList<>(2); dList5.add(new Document("resultType", new Document("$eq", 4))); dList5.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList5); Document normalFilter = new Document("$and", dList2); Document noDataFilter = new Document("$and", dList3); Document downFilter = new Document("$and", dList4); Document lessFilter = new Document("$and", dList5); List lists = Arrays.asList(normalFilter, noDataFilter,downFilter,lessFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); matchConditions.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("dataCount", new Document("$sum", "$dataCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int dataCount = 0; for (Document doc : result) { dataCount = doc.getInteger("dataCount"); } rList.add(0, dataCount + ""); // List carList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getViewConnectStability) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(carList)) { // BigDecimal sum = carList.stream().map(CheckIndexCar::getViewConnectStability).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(carList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal normal = new BigDecimal(rList.get(1)); BigDecimal noData = new BigDecimal(rList.get(2)); BigDecimal down = new BigDecimal(rList.get(3)); BigDecimal less = new BigDecimal(rList.get(4)); BigDecimal totalCount = normal.add(noData).add(down).add(less); BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount.compareTo(BigDecimal.ZERO)>0) { onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：点位在线率 * * @param params * @return */ @Override public Result vehiclePointOnlineRate(DataCenterQuery params) { List 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); //分页数量 long total = mongoTemplate.count(query, TMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); //系统ping的结果 List resultList = mongoTemplate.find(query, TMonitorResult.class); params.setDeptTag(-1); params.setDeviceType(2); 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 offLineTime = item.getOffLineTimeStr(); if (!CollectionUtils.isEmpty(offLineTime)) { //后续可以改成配置的离线次数(提取前n次，n为配置的离线次数) if (offLineTime.size() > 1) { offLineTime = offLineTime.subList(0, 2); } item.setOffLineTimeStr(offLineTime); } }); // 统计设备数量 //卡片统计 int totalCount = 0; int onlineCount = 0; int offlineCount = 0; int unknownCount = 0; //构建条件 List criteriaList = new ArrayList<>(); // 添加固定条件 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Car + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } else if (params.getDataType() == 2) { criteriaList.add(Criteria.where("deptTag").is(Boolean.TRUE)); } // 构建match操作 MatchOperation match = Aggregation.match( new Criteria().andOperator(criteriaList.toArray(new Criteria[0])) ); GroupOperation group = Aggregation.group() .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Online)).then(1).otherwise(0)).as("onlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Offline)).then(1).otherwise(0)).as("offlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Unknown)).then(1).otherwise(0)).as("unknownCount"); // 将匹配阶段和分组阶段组合起来 Aggregation aggregation = Aggregation.newAggregation(match, group); // 执行聚合查询 AggregationResults results = mongoTemplate.aggregate(aggregation, "t_monitor_online", Map.class); // 替换为你的集合名称 for (Map result : results.getMappedResults()) { offlineCount = (Integer) result.getOrDefault("offlineCount", 0L); unknownCount = (Integer) result.getOrDefault("unknownCount", 0L); onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); totalCount = offlineCount + unknownCount + onlineCount; } // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getSiteOnline) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getSiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount!=0) { onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } HashMap map = new HashMap<>(); map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：互联网卡口设备目录一致性 * * @param params * @return */ @Override public Result vehicleNetDeviceDirectoryConsistency(DataCenterQuery params) { List likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue"); List andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); // 1/2/3 视频/车辆/人脸 Pattern pattern = Pattern.compile(".*2.*"); andCriteria.add(Criteria.where("sxjgnlx.value").regex(pattern)); Query query = new Query(); Criteria and = new Criteria(); if (params.getOption() != null) { if (params.getOption() == 1) { andCriteria.add(Criteria.where("newDevice").is(Boolean.TRUE)); } else if (params.getOption() == -1) { andCriteria.add(Criteria.where("newDevice").is(Boolean.FALSE)); } } and.andOperator(andCriteria); query = Query.query(and); long total = mongoTemplate.count(query, MonitorQualifyResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, MonitorQualifyResult.class); List resultVOS = new ArrayList<>(); for (MonitorQualifyResult result : resultList) { MonitorQualifyResultVO vo = MonitorQualifyResult.getVO(result); resultVOS.add(vo); } //统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_monitor_qualify"); //总数 List dList1 = new ArrayList<>(2); setTag(params, dList1); dList1.add(new Document("sxjgnlx.value", new Document("$regex", ".*2.*"))); Document totalFilter = new Document("$and", dList1); //新设备数 List dList2 = new ArrayList<>(2); setTag(params, dList2); dList2.add(new Document("sxjgnlx.value", new Document("$regex", ".*2.*"))); dList2.add(new Document("newDevice", Boolean.TRUE)); Document newFilter = new Document("$and", dList2); List lists = Arrays.asList(totalFilter, newFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$serialNumber.showValue")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getDeviceDirectoryConsistent) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getDeviceDirectoryConsistent).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultVOS); return Result.ok().data(map).total(total); } /** * 车辆：车辆卡口信息采集准确率 * * @param params * @return */ @Override public Result vehicleCollectionConsistency(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "crossName"); List andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); if (params.getOption() != null) { if (params.getOption() == 1) { query.addCriteria(Criteria.where("lalType").is(ApiConstants.HK_Info_LayType_Normal)); query.addCriteria(Criteria.where("gbCodeType").is(ApiConstants.HK_Info_GbCodeType_Normal)); } else if (params.getOption() == -1) { Criteria lalType = Criteria.where("lalType").ne(ApiConstants.HK_Info_LayType_Normal); Criteria gbCodeType = Criteria.where("gbCodeType").ne(ApiConstants.HK_Info_GbCodeType_Normal); Criteria orOperator = new Criteria().orOperator(lalType, gbCodeType); orOperator.andOperator(andCriteria); query = Query.query(orOperator); } } long total = mongoTemplate.count(query, CrossDetailResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, CrossDetailResult.class); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_cross_detail"); List dList1 = new ArrayList<>(2); setTag(params, dList1); List dList2 = new ArrayList<>(2); dList2.add(new Document("lalType", new Document("$eq", 1))); dList2.add(new Document("gbCodeType", new Document("$eq", 1))); setTag(params, dList2); List dList3 = new ArrayList<>(2); setTag(params, dList3); List errorConditions = new ArrayList<>(); errorConditions.add(new Document("lalType", new Document("$ne", 1))); errorConditions.add(new Document("gbCodeType", new Document("$ne", 1))); Document errorDoc = new Document("$or", errorConditions); dList3.add(errorDoc); Document totalFilter = new Document("$and", dList1); Document correctFilter = new Document("$and", dList2); Document errorFilter = new Document("$and", dList3); List lists = Arrays.asList(totalFilter, correctFilter, errorFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getVehicleInformationCollectionAccuracy) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleInformationCollectionAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：车辆卡口设备抓拍数据完整性 * * @param params * @return */ @Override public Result vehicleCollectionDataIntegrity(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { //主要属性不完整 if (params.getOption() == 1) { query.addCriteria(Criteria.where("noIntegrityCount").gt(0)); } else if (params.getOption() == -1) { //属性不完整 query.addCriteria(Criteria.where("mainNoIntegrityCount").gt(0)); } } long total = mongoTemplate.count(query, DataIntegrityMonitoringResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, DataIntegrityMonitoringResult.class); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_data_integrity_monitoring"); //抓拍量求和 // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("dataCount", new Document("$sum", "$dataCount")) .append("noIntegrityCount", new Document("$sum", "$noIntegrityCount")) .append("mainNoIntegrityCount", new Document("$sum", "$mainNoIntegrityCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int dataCount = 0; int noIntegrityCount = 0; int mainNoIntegrityCount = 0; for (Document doc : result) { dataCount = doc.getInteger("dataCount"); noIntegrityCount = doc.getInteger("noIntegrityCount"); mainNoIntegrityCount = doc.getInteger("mainNoIntegrityCount"); } // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getVehicleCaptureIntegrity) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleCaptureIntegrity).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } List countList = new ArrayList<>(); countList.add(dataCount + ""); countList.add(noIntegrityCount + ""); countList.add(mainNoIntegrityCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; if (dataCount!=0) { onlineRate = new BigDecimal(dataCount-noIntegrityCount).divide(new BigDecimal(dataCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } countList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", countList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：车辆卡口设备抓拍数据准确性 * * @param params * @return */ @Override public Result vehicleCollectionDataCaptured(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { //主要属性不一致 if (params.getOption() == 1) { query.addCriteria(Criteria.where("majorDiffCount").gt(0)); } else if (params.getOption() == -1) { //重要属性不一致 query.addCriteria(Criteria.where("importantDiffCount").gt(0)); } } long total = mongoTemplate.count(query, AttrRecognitionMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, AttrRecognitionMonitorResult.class); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_attr_recognition_monitor"); // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("sampleCount", new Document("$sum", "$sampleCount")) .append("majorDiffCount", new Document("$sum", "$majorDiffCount")) .append("importantDiffCount", new Document("$sum", "$importantDiffCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int sampleCount = 0; int majorDiffCount = 0; int importantDiffCount = 0; for (Document doc : result) { sampleCount = doc.getInteger("sampleCount"); majorDiffCount = doc.getInteger("majorDiffCount"); importantDiffCount = doc.getInteger("importantDiffCount"); } // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getVehicleCaptureAccuracy) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleCaptureAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } List countList = new ArrayList<>(); countList.add(sampleCount + ""); countList.add(majorDiffCount + ""); countList.add(importantDiffCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; if (sampleCount!=0) { onlineRate = new BigDecimal(sampleCount-majorDiffCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } countList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", countList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：车辆卡口设备时钟准确性 * * @param params * @return */ @Override public Result vehicleClockAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { //当日时钟异常 if (params.getOption() == 1) { query.addCriteria(Criteria.where("majorDiffCount").gt(0)); } else if (params.getOption() == -1) { //全部时钟异常 query.addCriteria(Criteria.where("importantDiffCount").gt(0)); } } long total = mongoTemplate.count(query, VehicleDeviceInspectionResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, VehicleDeviceInspectionResult.class); List resultVos = new ArrayList<>(); resultList.forEach(item -> { SnapClockVO vo = VehicleDeviceInspectionResult.getVO(item); resultVos.add(vo); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_vehicle_device_inspection"); List dList1 = new ArrayList<>(2); dList1.add(new Document("snapClock.todayClockResult", new Document("$eq", 1))); setTag(params, dList1); List dList2 = new ArrayList<>(2); dList2.add(new Document("snapClock.todayClockResult", new Document("$eq", 0))); setTag(params, dList2); List dList3 = new ArrayList<>(2); dList3.add(new Document("snapClock.allClockResult", new Document("$eq", 1))); setTag(params, dList3); List dList4 = new ArrayList<>(2); dList4.add(new Document("snapClock.allClockResult", new Document("$eq", 0))); setTag(params, dList4); Document todayFilter = new Document("$and", dList1); Document todayErrFilter = new Document("$and", dList2); Document allFilter = new Document("$and", dList3); Document allErrFilter = new Document("$and", dList4); List lists = Arrays.asList(todayFilter, todayErrFilter, allFilter, allErrFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getVehicleTimingAccuracy) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleTimingAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; BigDecimal normal = new BigDecimal(rList.get(0)); BigDecimal abnormal = new BigDecimal(rList.get(1)); BigDecimal totalCount = normal.add(abnormal); if (totalCount.compareTo(BigDecimal.ZERO)>0) { onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultVos); return Result.ok().data(map).total(total); } /** * 车辆：车辆卡口设备抓拍数据上传及时性 * * @param params * @return */ @Override public Result vehicleTimelyUploadAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_CAR)); if (params.getOption() != null) { //正常 if (params.getOption() == 1) { query.addCriteria(Criteria.where("delayCount").is(0)); } else if (params.getOption() == -1) { //延迟 query.addCriteria(Criteria.where("delayCount").gt(0)); } } long total = mongoTemplate.count(query, SnapshotDelayMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, SnapshotDelayMonitorResult.class); // 统计数 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_snapshop_delay_monitor"); List dList1 = new ArrayList<>(2); setTag(params, dList1); dList1.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); Document allFilter = new Document("$and", dList1); List dList2 = new ArrayList<>(2); dList2.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); dList2.add(new Document("delayCount", new Document("$gt", 0))); setTag(params, dList2); Document delayFilter = new Document("$and", dList2); List lists = Arrays.asList(allFilter, delayFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getVehicleUploadTimeliness) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleUploadTimeliness).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：车辆卡口设备url可用性 * * @param params * @return */ @Override public Result vehicleUrlAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { if (params.getOption() == 1) { query.addCriteria(Criteria.where("expCount").is(0)); } else if (params.getOption() == -1) { query.addCriteria(Criteria.where("expCount").gt(0)); } } long total = mongoTemplate.count(query, PicAccessResult.class); MongoUtil.setPage(query, params, TIME_FIELD); query.with(Sort.by(Sort.Order.desc("expCount"))); List resultList = mongoTemplate.find(query, PicAccessResult.class); // 统计数 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_pic_access"); // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("sampleCount", new Document("$sum", "$sampleCount")) .append("expCount", new Document("$sum", "$expCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int sampleCount = 0; int expCount = 0; for (Document doc : result) { sampleCount = doc.getInteger("sampleCount"); expCount = doc.getInteger("expCount"); } List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) .select(CheckIndexCar::getVehicleUrlAvailability) .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) .list(); BigDecimal onlineRate = BigDecimal.ZERO; if (CollectionUtils.isNotEmpty(videoList)) { BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleUrlAvailability).reduce(BigDecimal.ZERO, BigDecimal::add); BigDecimal count = BigDecimal.valueOf(videoList.size()); onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); } List rList = new ArrayList<>(); rList.add(sampleCount + ""); rList.add(expCount + ""); rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 车辆：车辆卡口设备抓拍数据大图可用性 * * @param params * @return */ @Override public Result vehicleBigImgAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { if (params.getOption() == 1) { query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").is(0)); } else if (params.getOption() == -1) { query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").gt(0)); } } long total = mongoTemplate.count(query, VehicleDeviceSamplingResult.class); MongoUtil.setPage(query, params, TIME_FIELD); query.with(Sort.by(Sort.Order.desc("bigUseful.bigPicExpCount"))); List resultList = mongoTemplate.find(query, VehicleDeviceSamplingResult.class); List voList = new ArrayList<>(); resultList.forEach(item -> { BigPicUsefulVO picVO = VehicleDeviceSamplingResult.getPicVO(item); voList.add(picVO); }); // 统计数 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_vehicle_device_sampling"); // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("sampleCount", new Document("$sum", "$bigUseful.sampleCount")) .append("expCount", new Document("$sum", "$bigUseful.bigPicExpCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int sampleCount = 0; int expCount = 0; for (Document doc : result) { sampleCount = doc.getInteger("sampleCount"); expCount = doc.getInteger("expCount"); } List countList = new ArrayList<>(); // List videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) // .select(CheckIndexCar::getVehiclePictureAvailability) // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehiclePictureAvailability).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } countList.add(sampleCount + ""); countList.add(expCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; if (sampleCount!=0) { onlineRate = new BigDecimal(sampleCount-expCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } countList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", countList); map.put("list", voList); return Result.ok().data(map).total(total); } /** * 人脸：视图库对接稳定性 * * @param params * @return */ @Override public Result faceViewDockStable(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); //加DataType为车辆 query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_FACE)); if (params.getOption() != null) { if (ApiConstants.HK_SnapCount_ResultType_Normal.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Normal)); } else if (ApiConstants.HK_SnapCount_ResultType_Null.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Null)); } else if (ApiConstants.HK_SnapCount_ResultType_Descent.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Descent)); } else if (ApiConstants.HK_SnapCount_ResultType_Low.equals(params.getOption())) { query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Low)); } } long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); resultList.forEach(item -> item.setResultTypeText(item.getResultTypeText())); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_snapshot_data_monitor"); List dList2 = new ArrayList<>(2); dList2.add(new Document("resultType", new Document("$eq", 1))); dList2.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList2); List dList3 = new ArrayList<>(2); dList3.add(new Document("resultType", new Document("$eq", 2))); dList3.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList3); List dList4 = new ArrayList<>(2); dList4.add(new Document("resultType", new Document("$eq", 3))); dList4.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList4); List dList5 = new ArrayList<>(2); dList5.add(new Document("resultType", new Document("$eq", 4))); dList5.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); setTag(params, dList5); Document normalFilter = new Document("$and", dList2); Document noDataFilter = new Document("$and", dList3); Document downFilter = new Document("$and", dList4); Document lessFilter = new Document("$and", dList5); List lists = Arrays.asList(normalFilter, noDataFilter,downFilter,lessFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); //抓拍量求和 // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); matchConditions.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_FACE))); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("dataCount", new Document("$sum", "$dataCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int dataCount = 0; for (Document doc : result) { dataCount = doc.getInteger("dataCount"); } rList.add(0, dataCount + ""); // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getViewConnectStability) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getViewConnectStability).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal normal = new BigDecimal(rList.get(1)); BigDecimal noData = new BigDecimal(rList.get(2)); BigDecimal down = new BigDecimal(rList.get(3)); BigDecimal less = new BigDecimal(rList.get(4)); BigDecimal totalCount = normal.add(noData).add(down).add(less); BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount.compareTo(BigDecimal.ZERO)>0) { onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 人脸：点位在线率 * * @param params * @return */ @Override public Result facePointOnlineRate(DataCenterQuery params) { List 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); //分页数量 long total = mongoTemplate.count(query, TMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List 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 offLineTime = item.getOffLineTimeStr(); if (!CollectionUtils.isEmpty(offLineTime)) { //后续可以改成配置的离线次数(提取前n次，n为配置的离线次数) if (offLineTime.size() > 1) { offLineTime = offLineTime.subList(0, 2); } item.setOffLineTimeStr(offLineTime); } }); params.setDeptTag(-1); params.setDeviceType(3); // 统计设备数量 //卡片统计 int totalCount = 0; int onlineCount = 0; int offlineCount = 0; int unknownCount = 0; //构建条件 List criteriaList = new ArrayList<>(); // 添加固定条件 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Face + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } else if (params.getDataType() == 2) { criteriaList.add(Criteria.where("deptTag").is(Boolean.TRUE)); } // 构建match操作 MatchOperation match = Aggregation.match( new Criteria().andOperator(criteriaList.toArray(new Criteria[0])) ); GroupOperation group = Aggregation.group() .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Online)).then(1).otherwise(0)).as("onlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Offline)).then(1).otherwise(0)).as("offlineCount") .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Unknown)).then(1).otherwise(0)).as("unknownCount"); // 将匹配阶段和分组阶段组合起来 Aggregation aggregation = Aggregation.newAggregation(match, group); // 执行聚合查询 AggregationResults results = mongoTemplate.aggregate(aggregation, "t_monitor_online", Map.class); // 替换为你的集合名称 for (Map result : results.getMappedResults()) { offlineCount = (Integer) result.getOrDefault("offlineCount", 0L); unknownCount = (Integer) result.getOrDefault("unknownCount", 0L); onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); totalCount = offlineCount + unknownCount + onlineCount; } // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getSiteOnline) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, params.getStartTime(), params.getEndTime()) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getSiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (totalCount!=0) { onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } HashMap map = new HashMap<>(); map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 人脸：目录一致率 * * @param params * @return */ @Override public Result faceDirectoryConsistency(DataCenterQuery params) { List likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue"); List andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); // 1/2/3 视频/车辆/人脸 Pattern pattern = Pattern.compile(".*3.*"); andCriteria.add(Criteria.where("sxjgnlx.value").regex(pattern)); Query query = new Query(); Criteria and = new Criteria(); if (params.getOption() != null) { if (params.getOption() == 1) { andCriteria.add(Criteria.where("newDevice").is(Boolean.TRUE)); } else if (params.getOption() == -1) { andCriteria.add(Criteria.where("newDevice").is(Boolean.FALSE)); } } and.andOperator(andCriteria); query = Query.query(and); long total = mongoTemplate.count(query, MonitorQualifyResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, MonitorQualifyResult.class); List resultVOS = new ArrayList<>(); for (MonitorQualifyResult result : resultList) { MonitorQualifyResultVO vo = MonitorQualifyResult.getVO(result); resultVOS.add(vo); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_monitor_qualify"); //总数 List dList1 = new ArrayList<>(2); setTag(params, dList1); dList1.add(new Document("sxjgnlx.value", new Document("$regex", ".*3.*"))); Document totalFilter = new Document("$and", dList1); //新设备数 List dList2 = new ArrayList<>(2); setTag(params, dList2); dList2.add(new Document("sxjgnlx.value", new Document("$regex", ".*3.*"))); dList2.add(new Document("newDevice", Boolean.TRUE)); Document newFilter = new Document("$and", dList2); List lists = Arrays.asList(totalFilter, newFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$serialNumber.showValue")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getDeviceDirectoryConsistent) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getDeviceDirectoryConsistent).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultVOS); return Result.ok().data(map).total(total); } /** * 人脸：人脸卡口信息采集准确率 * * @param params * @return */ @Override public Result faceCollectionConsistency(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "crossName"); List andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); if (params.getOption() != null) { if (params.getOption() == 1) { query.addCriteria(Criteria.where("lalType").is(ApiConstants.HK_Info_LayType_Normal)); query.addCriteria(Criteria.where("gbCodeType").is(ApiConstants.HK_Info_GbCodeType_Normal)); } else if (params.getOption() == -1) { Criteria lalType = Criteria.where("lalType").ne(ApiConstants.HK_Info_LayType_Normal); Criteria gbCodeType = Criteria.where("gbCodeType").ne(ApiConstants.HK_Info_GbCodeType_Normal); Criteria orOperator = new Criteria().orOperator(lalType, gbCodeType); orOperator.andOperator(andCriteria); query = Query.query(orOperator); } } long total = mongoTemplate.count(query, MonitoringDetailResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, MonitoringDetailResult.class); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_monitoring_detail"); List dList1 = new ArrayList<>(2); setTag(params, dList1); List dList2 = new ArrayList<>(2); dList2.add(new Document("lalType", new Document("$eq", 1))); dList2.add(new Document("gbCodeType", new Document("$eq", 1))); setTag(params, dList2); List dList3 = new ArrayList<>(2); setTag(params, dList3); List errorConditions = new ArrayList<>(); errorConditions.add(new Document("lalType", new Document("$ne", 1))); errorConditions.add(new Document("gbCodeType", new Document("$ne", 1))); Document errorDoc = new Document("$or", errorConditions); dList3.add(errorDoc); Document totalFilter = new Document("$and", dList1); Document correctFilter = new Document("$and", dList2); Document errorFilter = new Document("$and", dList3); List lists = Arrays.asList(totalFilter, correctFilter, errorFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getFaceInformationCollectionAccuracy) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getFaceInformationCollectionAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 人脸：设备抓拍图片合格性 * * @param params * @return */ @Override public Result faceImgQualification(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "cameraName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { if (params.getOption() == 1) { query.addCriteria(Criteria.where("faceEligibility.unfaceEligCount").is(0)); } else if (params.getOption() == -1) { query.addCriteria(Criteria.where("faceEligibility.unfaceEligCount").gt(0)); } } long total = mongoTemplate.count(query, FaceDeviceSamplingResult.class); query.with(Sort.by(Sort.Order.desc("faceEligibility.unfaceEligCount"))); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, FaceDeviceSamplingResult.class); List voList = new ArrayList<>(); resultList.forEach(item -> { BigPicUsefulVO picVO = FaceDeviceSamplingResult.getEligeVO(item); voList.add(picVO); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_face_device_sampling"); // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("sampleCount", new Document("$sum", "$faceEligibility.sampleCount")) .append("expCount", new Document("$sum", "$faceEligibility.unfaceEligCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int sampleCount = 0; int expCount = 0; for (Document doc : result) { sampleCount = doc.getInteger("sampleCount"); expCount = doc.getInteger("expCount"); } List countList = new ArrayList<>(); // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getFacePictureQualification) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getFacePictureQualification).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } countList.add(sampleCount + ""); countList.add(expCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; if (sampleCount!=0) { onlineRate = new BigDecimal(sampleCount-expCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } countList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", countList); map.put("list", voList); return Result.ok().data(map).total(total); } /** * 人脸：设备抓拍图片时钟准确性 * * @param params * @return */ @Override public Result faceCapturesImagesAccuracy(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { //当日时钟异常 if (params.getOption() == 1) { query.addCriteria(Criteria.where("majorDiffCount").gt(0)); } else if (params.getOption() == -1) { //全部时钟异常 query.addCriteria(Criteria.where("importantDiffCount").gt(0)); } } long total = mongoTemplate.count(query, FaceDeviceInspectionResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); List resultVos = new ArrayList<>(); resultList.forEach(item -> { SnapClockVO vo = FaceDeviceInspectionResult.getVO(item); resultVos.add(vo); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_face_device_inspection"); List dList1 = new ArrayList<>(2); dList1.add(new Document("snapClock.todayClockResult", new Document("$eq", 1))); setTag(params, dList1); List dList2 = new ArrayList<>(2); dList2.add(new Document("snapClock.todayClockResult", new Document("$eq", 0))); setTag(params, dList2); List dList3 = new ArrayList<>(2); dList3.add(new Document("snapClock.allClockResult", new Document("$eq", 1))); setTag(params, dList3); List dList4 = new ArrayList<>(2); dList4.add(new Document("snapClock.allClockResult", new Document("$eq", 0))); setTag(params, dList4); Document todayFilter = new Document("$and", dList1); Document todayErrFilter = new Document("$and", dList2); Document allFilter = new Document("$and", dList3); Document allErrFilter = new Document("$and", dList4); List lists = Arrays.asList(todayFilter, todayErrFilter, allFilter, allErrFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getFaceTimingAccuracy) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getFaceTimingAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; BigDecimal normal = new BigDecimal(rList.get(0)); BigDecimal abnormal = new BigDecimal(rList.get(1)); BigDecimal totalCount = normal.add(abnormal); if (totalCount.compareTo(BigDecimal.ZERO)>0) { onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultVos); return Result.ok().data(map).total(total); } /** * 人脸：抓拍人脸数据上传及时性 * * @param params * @return */ @Override public Result faceTimelyUpload(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_FACE)); if (params.getOption() != null) { //正常 if (params.getOption() == 1) { query.addCriteria(Criteria.where("delayCount").is(0)); } else if (params.getOption() == -1) { //延迟 query.addCriteria(Criteria.where("delayCount").gt(0)); } } long total = mongoTemplate.count(query, SnapshotDelayMonitorResult.class); MongoUtil.setPage(query, params, TIME_FIELD); List resultList = mongoTemplate.find(query, SnapshotDelayMonitorResult.class); // 统计数 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_snapshop_delay_monitor"); List dList1 = new ArrayList<>(2); setTag(params, dList1); dList1.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_FACE))); Document allFilter = new Document("$and", dList1); List dList2 = new ArrayList<>(2); dList2.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_FACE))); dList2.add(new Document("delayCount", new Document("$gt", 0))); setTag(params, dList2); Document delayFilter = new Document("$and", dList2); List lists = Arrays.asList(allFilter, delayFilter); List rList = lists.stream().map(filter -> { // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$externalIndexCode")), new Document("$count", "uniqueDeviceIds") ); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } return uniqueDeviceIdCount + ""; }).collect(Collectors.toList()); // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getFaceUploadTimeliness) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getFaceUploadTimeliness).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } BigDecimal onlineRate = BigDecimal.ZERO; if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } rList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", rList); map.put("list", resultList); return Result.ok().data(map).total(total); } /** * 人脸：人脸卡口设备抓拍数据大图可用性 * * @param params * @return */ @Override public Result faceAvailabilityOfLargeImg(DataCenterQuery params) { List likeFileds = Arrays.asList("externalIndexCode", "deviceName"); Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); if (params.getOption() != null) { if (params.getOption() == 1) { query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").is(0)); } else if (params.getOption() == -1) { query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").gt(0)); } } long total = mongoTemplate.count(query, FaceDeviceSamplingResult.class); MongoUtil.setPage(query, params, TIME_FIELD); query.with(Sort.by(Sort.Order.desc("bigUseful.bigPicExpCount"))); List resultList = mongoTemplate.find(query, FaceDeviceSamplingResult.class); List voList = new ArrayList<>(); resultList.forEach(item -> { BigPicUsefulVO picVO = FaceDeviceSamplingResult.getPicVO(item); voList.add(picVO); }); // 统计数 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_face_device_sampling"); // 构建基本的$match条件 List matchConditions = new ArrayList<>(); setTag(params, matchConditions); List pipeline = Arrays.asList( new Document("$match", new Document("$and", matchConditions)), new Document("$group", new Document("_id", "$mongoCreateTime") .append("sampleCount", new Document("$sum", "$bigUseful.sampleCount")) .append("expCount", new Document("$sum", "$bigUseful.bigPicExpCount")) )); // 执行聚合查询并获取结果 AggregateIterable result = collection.aggregate(pipeline); int sampleCount = 0; int expCount = 0; for (Document doc : result) { sampleCount = doc.getInteger("sampleCount"); expCount = doc.getInteger("expCount"); } List countList = new ArrayList<>(); // 统计数 // List videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) // .select(CheckIndexFace::getFacePictureAvailability) // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) // .list(); // BigDecimal onlineRate = BigDecimal.ZERO; // if (CollectionUtils.isNotEmpty(videoList)) { // BigDecimal sum = videoList.stream().map(CheckIndexFace::getFacePictureAvailability).reduce(BigDecimal.ZERO, BigDecimal::add); // BigDecimal count = BigDecimal.valueOf(videoList.size()); // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); // } countList.add(sampleCount + ""); countList.add(expCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; if (sampleCount!=0) { onlineRate = new BigDecimal(sampleCount-expCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } countList.add(this.remove0(onlineRate)); HashMap map = new HashMap<>(); map.put("count", countList); map.put("list", voList); return Result.ok().data(map).total(total); } /** * 视频：视频图像资源安全管理 * * @param query * @return */ @Override public Result videoImageResourceSecurity(DataCenterQuery query) { Page page = PageHelper.startPage(query.getPageNum(), query.getPageSize()); securityDetailMapper.selectImageResourceSecurityDetailList(query); // 统计数 HashMap map = new HashMap<>(); map.put("count", CollectionUtils.EMPTY_COLLECTION); map.put("list", page); return Result.ok().data(map).total(page.getTotal()); } /** * 删除尾部的0 * * @param rate * @return */ private String remove0(BigDecimal rate) { DF.setDecimalSeparatorAlwaysShown(false); return DF.format(rate) + "%"; } /** * 设置标签搜索条件 * * @param params * @param dList */ private void setTag(DataCenterQuery params, List dList) { if (params.getDataType().equals(1)) { dList.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE))); } else if (params.getDataType().equals(2)) { dList.add(new Document("deptTag", new Document("$eq", Boolean.TRUE))); } Document mongoCreateTimeRange = new Document(); if (params.getStartTime() != null) mongoCreateTimeRange.append("$gte", params.getStartTime()); if (params.getEndTime() != null) mongoCreateTimeRange.append("$lt", params.getEndTime()); dList.add(new Document("mongoCreateTime", mongoCreateTimeRange)); } }