package com.ycl.platform.service.impl; import com.alibaba.excel.EasyExcel; import com.alibaba.excel.write.style.column.LongestMatchColumnWidthStyleStrategy; import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper; import com.github.pagehelper.Page; import com.github.pagehelper.PageHelper; 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.form.UpdateDynamicValueForm; 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.DynamicColumnVO; import com.ycl.platform.mapper.DynamicColumnMapper; import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper; import com.ycl.platform.mapper.TMonitorMapper; import com.ycl.platform.mapper.YwPointMapper; import com.ycl.platform.service.*; import com.ycl.system.Result; import com.ycl.system.entity.SysDept; import com.ycl.system.model.LoginUser; import com.ycl.system.service.ISysConfigService; import com.ycl.system.service.ISysDeptService; import com.ycl.utils.DateUtils; import com.ycl.utils.MongoUtil; import com.ycl.utils.SecurityUtils; import com.ycl.utils.StringUtils; import com.ycl.utils.bean.BeanUtils; import com.ycl.utils.poi.ExcelUtil; import constant.*; import enumeration.general.AreaDeptEnum; import jakarta.servlet.http.HttpServletResponse; import lombok.RequiredArgsConstructor; import lombok.extern.slf4j.Slf4j; import org.apache.commons.collections.CollectionUtils; import org.bson.Document; import org.springframework.data.domain.Sort; 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.stereotype.Service; import java.io.IOException; 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 @Slf4j public class DataCenterServiceImpl implements DataCenterService { private final MongoTemplate mongoTemplate; private final ImageResourceSecurityDetailMapper securityDetailMapper; private final YwPointMapper pointMapper; private final ICheckIndexCarService checkIndexCarService; private final ICheckIndexFaceService checkIndexFaceService; private final DynamicColumnMapper dynamicColumnMapper; private final static String TIME_FIELD = "mongoCreateTime"; private static DecimalFormat DF = new DecimalFormat("#.####"); public Map> getDynamicByConditions(DataCenterQuery params,List list){ //TODO 该位置没有过滤账号的部门对应的设备信息，而是更具条件查询的全部 //获得到对应id，且包含传入字符串 动态列集合 List likeFieldDynamicColumnVOList = list.stream() .filter(dynamicColumnVO -> dynamicColumnVO.getLabelId().equals(params.getDyId()) && dynamicColumnVO.getColumnValue().contains(params.getDyValue()) ).collect(Collectors.toList()); //获得满足条件的id集合 List ids = likeFieldDynamicColumnVOList.stream().map(DynamicColumnVO::getRefStringId).toList(); Map> groupByRefStringIdMap = list.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); Set removeSet = new HashSet<>(ids); //移除掉不符合条件的key groupByRefStringIdMap.keySet().retainAll(removeSet); return groupByRefStringIdMap; } //录像可用 @Override public void recordingAvailabilityExport(HttpServletResponse response,DataCenterQuery params) throws IOException { 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())); } SysDept sysDept = getSysDeptByLoginUser(); if (sysDept !=null){ AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query.addCriteria(Criteria.where("no").regex("^" +areaDeptEnum.getCode())); } } MongoUtil.setNoPage(query, params, TIME_FIELD); 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()); }); //获得动态列数据 List dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_VIDEO); //判断是否有查询条件 boolean conditions = false; Map> groupByRefStringIdMap = new HashMap<>(); if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ conditions = true; //获得动态列集合中包含了的字符串值的集合 区分大小写 groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); }else{ groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); } //固定表头 LinkedHashSet headers = new LinkedHashSet<>(); headers.add(RecordingAvailabilityHeaders.arealayername); headers.add(RecordingAvailabilityHeaders.arealayerno); headers.add(RecordingAvailabilityHeaders.createTime); headers.add(RecordingAvailabilityHeaders.deviceId); headers.add(RecordingAvailabilityHeaders.missDuration); headers.add(RecordingAvailabilityHeaders.platId); headers.add(RecordingAvailabilityHeaders.recordDuration); headers.add(RecordingAvailabilityHeaders.recordStatusText); headers.add(RecordingAvailabilityHeaders.statTime); List headersList = new LinkedList<>(); List dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_VIDEO); //添加动态表头 if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { //使用链表保证后续补充数据时获取数据顺序一致 headersList.addAll(dynamicsHeaders); headers.addAll(headersList); } // SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd"); //查询到有动态列查询条件 //获得对应动态列中ref的对象id 与 查询结果id过滤 if (conditions){ Map> finalGroupByRefStringIdMap = groupByRefStringIdMap; resultList = resultList.stream() .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getId())) .collect(Collectors.toList()); } SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); List> data = new ArrayList<>(); for (RecordMetaDSumResult result : resultList){ List row = new ArrayList<>(); row.add(result.getArealayername()); row.add(result.getArealayerno()); row.add(dateFormat.format(result.getCreateTime())); row.add(result.getDeviceId()); row.add(result.getMissDuration()); row.add(result.getPlatId()); row.add(result.getRecordDuration()); row.add(result.getRecordStatusText()); row.add(dateFormat.format(result.getCreateTime())); //添加动态列数据 for (String header : headersList){ boolean flag = false; List columnVOS = groupByRefStringIdMap.get(result.getId()); if (!CollectionUtils.isEmpty(columnVOS)) { for (DynamicColumnVO columnVO : columnVOS) { if (header.equals(columnVO.getLabelValue())) { row.add(columnVO.getColumnValue()); flag = true; } } } //没找到用空串占位 if (!flag) row.add(""); } data.add(row); } List> headList = new ArrayList<>(); for (String header : headers) { headList.add(Collections.singletonList(header)); } EasyExcel.write(response.getOutputStream()) .head(headList) // 设置表头 .sheet("录像可用率") // 设置sheet名称 .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .doWrite(data); // 写入数据 } //点位在线 @Override public void pointOnlineFaceExport(HttpServletResponse response, DataCenterQuery params) throws IOException { List likeFileds = Arrays.asList("name", "no", "ip"); Query query = null; SysDept sysDept = getSysDeptByLoginUser(); if (sysDept !=null){ AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); } }else { query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } //查人脸设备 query.addCriteria(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Face + ".*")); //下拉框在线情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("online").is(params.getOption())); } Sort sort = Sort.by( Sort.Order.asc("pingOnline"), // 首先按照 pingOnline 升序排序 Sort.Order.desc("offLineCount") // 首先按照 pingOnline 升序排序 ); // 通过pingOnline字段排序，为false的排在前面 query.with(sort); MongoUtil.setNoPage(query, params, TIME_FIELD); //分页数量 List 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); } }); List dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_FACE_POINT); //判断是否有查询条件 boolean conditions = false; Map> groupByRefStringIdMap = new HashMap<>(); if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ conditions = true; //获得动态列集合中包含了的字符串值的集合 区分大小写 groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); }else{ groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); } //固定表头 LinkedHashSet headers = new LinkedHashSet<>(); headers.add(PointOnlineHeaders.no); headers.add(PointOnlineHeaders.name); headers.add(PointOnlineHeaders.ip); headers.add(PointOnlineHeaders.onlineStr); headers.add(PointOnlineHeaders.pingOnlineStr); headers.add(PointOnlineHeaders.checkCount); headers.add(PointOnlineHeaders.offLineCount); headers.add(PointOnlineHeaders.offLineTimeStr); headers.add(PointOnlineHeaders.mongoCreateTime); List headersList = new LinkedList<>(); List dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_FACE_POINT); //添加动态表头 if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { //使用链表保证后续补充数据时获取数据顺序一致 headersList.addAll(dynamicsHeaders); headers.addAll(headersList); } if (conditions){ Map> finalGroupByRefStringIdMap = groupByRefStringIdMap; resultList = resultList.stream() .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo())) .collect(Collectors.toList()); } List> data = new ArrayList<>(); for (TMonitorResult result : resultList){ List row = new ArrayList<>(); row.add(result.getNo()); row.add(result.getName()); row.add(result.getIp()); row.add(result.getOnlineStr()); row.add(result.getPingOnlineStr()); row.add(result.getCheckCount()); row.add(result.getOffLineCount()); if (CollectionUtils.isEmpty(result.getOffLineTimeStr())){ row.add(null); }else { row.add(result.getOffLineTimeStr().toString()); } row.add(result.getMongoCreateTime()); //添加动态列数据 for (String header : headersList){ boolean flag = false; List columnVOS = groupByRefStringIdMap.get(result.getNo()); if (!CollectionUtils.isEmpty(columnVOS)) { for (DynamicColumnVO columnVO : columnVOS) { if (header.equals(columnVO.getLabelValue())) { row.add(columnVO.getColumnValue()); flag = true; } } } //没找到用空串占位 if (!flag) row.add(""); } data.add(row); } List> headList = new ArrayList<>(); for (String header : headers) { headList.add(Collections.singletonList(header)); } EasyExcel.write(response.getOutputStream()) .head(headList) // 设置表头 .sheet("人脸点位在线率") // 设置sheet名称 .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .doWrite(data); // 写入数据 } private final ISysDeptService deptService; public SysDept getSysDeptByLoginUser(){ LoginUser loginUser = SecurityUtils.getLoginUser(); SysDept sysDept = null; Long deptId =null; if (loginUser.getDeptId() != null){ deptId = loginUser.getDeptId(); sysDept = deptService.selectDeptById(deptId); } return sysDept; } //视频单位在线 @Override public void pointOnlineVideoExport(HttpServletResponse response, DataCenterQuery params) throws IOException { List likeFileds = Arrays.asList("name", "no", "ip"); Query query = null; SysDept sysDept = getSysDeptByLoginUser(); if (sysDept !=null){ AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); } }else { query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } //查视频设备 query.addCriteria(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); //下拉框在线情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("online").is(params.getOption())); } Sort sort = Sort.by( Sort.Order.asc("pingOnline"), // 首先按照 pingOnline 升序排序 Sort.Order.desc("offLineCount") // 首先按照 pingOnline 升序排序 ); // 通过pingOnline字段排序，为false的排在前面 query.with(sort); MongoUtil.setNoPage(query, params, TIME_FIELD); List 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); } }); List dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_VIDEO_POINT); //判断是否有查询条件 boolean conditions = false; Map> groupByRefStringIdMap = new HashMap<>(); if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ conditions = true; //获得动态列集合中包含了的字符串值的集合 区分大小写 groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); }else{ groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); } //固定表头 LinkedHashSet headers = new LinkedHashSet<>(); headers.add(PointOnlineHeaders.no); headers.add(PointOnlineHeaders.name); headers.add(PointOnlineHeaders.ip); headers.add(PointOnlineHeaders.onlineStr); headers.add(PointOnlineHeaders.pingOnlineStr); headers.add(PointOnlineHeaders.checkCount); headers.add(PointOnlineHeaders.offLineCount); headers.add(PointOnlineHeaders.offLineTimeStr); headers.add(PointOnlineHeaders.mongoCreateTime); List headersList = new LinkedList<>(); List dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_VIDEO_POINT); //添加动态表头 if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { //使用链表保证后续补充数据时获取数据顺序一致 headersList.addAll(dynamicsHeaders); headers.addAll(headersList); } if (conditions){ Map> finalGroupByRefStringIdMap = groupByRefStringIdMap; resultList = resultList.stream() .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo())) .collect(Collectors.toList()); } List> data = new ArrayList<>(); for (TMonitorResult result : resultList){ List row = new ArrayList<>(); row.add(result.getNo()); row.add(result.getName()); row.add(result.getIp()); row.add(result.getOnlineStr()); row.add(result.getPingOnlineStr()); row.add(result.getCheckCount()); row.add(result.getOffLineCount()); if (CollectionUtils.isEmpty(result.getOffLineTimeStr())){ row.add(null); }else { row.add(result.getOffLineTimeStr().toString()); } row.add(result.getMongoCreateTime()); //添加动态列数据 for (String header : headersList){ boolean flag = false; List columnVOS = groupByRefStringIdMap.get(result.getNo()); if (!CollectionUtils.isEmpty(columnVOS)) { for (DynamicColumnVO columnVO : columnVOS) { if (header.equals(columnVO.getLabelValue())) { row.add(columnVO.getColumnValue()); flag = true; } } } //没找到用空串占位 if (!flag) row.add(""); } data.add(row); } List> headList = new ArrayList<>(); for (String header : headers) { headList.add(Collections.singletonList(header)); } EasyExcel.write(response.getOutputStream()) .head(headList) // 设置表头 .sheet("视频点位在线率") // 设置sheet名称 .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .doWrite(data); // 写入数据 } //车辆点位在线 @Override public void pointOnlineCarExport(HttpServletResponse response, DataCenterQuery params) throws IOException { List likeFileds = Arrays.asList("name", "no", "ip"); Query query = null; SysDept sysDept = getSysDeptByLoginUser(); if (sysDept !=null){ AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); } }else { query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } //查车辆设备 query.addCriteria(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Car + ".*")); //下拉框在线情况查询条件 if (params.getOption() != null) { query.addCriteria(Criteria.where("online").is(params.getOption())); } Sort sort = Sort.by( Sort.Order.asc("pingOnline"), // 首先按照 pingOnline 升序排序 Sort.Order.desc("offLineCount") // 首先按照 pingOnline 升序排序 ); // 通过pingOnline字段排序，为false的排在前面 query.with(sort); //分页数量 //系统ping的结果 List 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); } }); List dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_CAR_POINT); //判断是否有查询条件 boolean conditions = false; Map> groupByRefStringIdMap = new HashMap<>(); if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){ conditions = true; //获得动态列集合中包含了的字符串值的集合 区分大小写 groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList); }else{ groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId)); } //固定表头 LinkedHashSet headers = new LinkedHashSet<>(); headers.add(PointOnlineHeaders.no); headers.add(PointOnlineHeaders.name); headers.add(PointOnlineHeaders.ip); headers.add(PointOnlineHeaders.onlineStr); headers.add(PointOnlineHeaders.pingOnlineStr); headers.add(PointOnlineHeaders.checkCount); headers.add(PointOnlineHeaders.offLineCount); headers.add(PointOnlineHeaders.offLineTimeStr); headers.add(PointOnlineHeaders.mongoCreateTime); List headersList = new LinkedList<>(); List dynamicsHeaders = dynamicColumnMapper.getHeader(TableNameConstants.COLUMN_NAME_CAR_POINT); //添加动态表头 if (!org.springframework.util.CollectionUtils.isEmpty(dynamicsHeaders)) { //使用链表保证后续补充数据时获取数据顺序一致 headersList.addAll(dynamicsHeaders); headers.addAll(headersList); } if (conditions){ Map> finalGroupByRefStringIdMap = groupByRefStringIdMap; resultList = resultList.stream() .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo())) .collect(Collectors.toList()); } List> data = new ArrayList<>(); for (TMonitorResult result : resultList){ List row = new ArrayList<>(); row.add(result.getNo()); row.add(result.getName()); row.add(result.getIp()); row.add(result.getOnlineStr()); row.add(result.getPingOnlineStr()); row.add(result.getCheckCount()); row.add(result.getOffLineCount()); if (CollectionUtils.isEmpty(result.getOffLineTimeStr())){ row.add(null); }else { row.add(result.getOffLineTimeStr().toString()); } row.add(result.getMongoCreateTime()); //添加动态列数据 for (String header : headersList){ boolean flag = false; List columnVOS = groupByRefStringIdMap.get(result.getNo()); if (!CollectionUtils.isEmpty(columnVOS)) { for (DynamicColumnVO columnVO : columnVOS) { if (header.equals(columnVO.getLabelValue())) { row.add(columnVO.getColumnValue()); flag = true; } } } //没找到用空串占位 if (!flag) row.add(""); } data.add(row); } List> headList = new ArrayList<>(); for (String header : headers) { headList.add(Collections.singletonList(header)); } EasyExcel.write(response.getOutputStream()) .head(headList) // 设置表头 .sheet("车辆点位在线率") // 设置sheet名称 .registerWriteHandler(new LongestMatchColumnWidthStyleStrategy()) .doWrite(data); // 写入数据 } @Override public Result updateDynamicValue(UpdateDynamicValueForm form) { List list = form.getDynamicColumnVOList(); if (CollectionUtils.isEmpty(list) || StringUtils.isEmpty(form.getId())) { throw new RuntimeException("修改自定义列的传入值为null或传入id为null"); } List updateList = new ArrayList<>(); List addList = new ArrayList<>(); for (DynamicColumnVO dynamicColumnVO : list){ if(dynamicColumnVO.getColumnValue() == null){ continue; } DynamicColumnValue dynamicColumnValue = new DynamicColumnValue(); dynamicColumnValue.setColumnValue(dynamicColumnVO.getColumnValue()); dynamicColumnValue.setDynamicColumnId(dynamicColumnVO.getId()); dynamicColumnValue.setRefStringId(form.getId()); dynamicColumnValue.setRefId(0); if(dynamicColumnVO.getValueId() == null){ addList.add(dynamicColumnValue); }else { dynamicColumnValue.setId(dynamicColumnVO.getValueId()); updateList.add(dynamicColumnValue); } } log.error("addList:{}",addList); log.error("updateList:{}",updateList); if (CollectionUtils.isNotEmpty(addList)){ dynamicColumnMapper.saveBatch(addList); } if (CollectionUtils.isNotEmpty(updateList)) { dynamicColumnMapper.updateBatch(updateList); } return Result.ok("修改成功"); } /** * 视频：点位在线率 * * @param params * @return */ @Override public Result videoPointOnlineRate(DataCenterQuery params) { List likeFileds = Arrays.asList("name", "no", "ip"); //此处新增了根据用户权限查询的情况 Query query = null; SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } }else { 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); } //添加动态数据 List list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_VIDEO_POINT,item.getNo()); item.setDynamicColumnList(list); }); 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())); //此处新增了根据用户权限查询的情况 if (areaDeptEnum != null){ criteriaList.add(Criteria.where("no").regex("^" +areaDeptEnum.getCode())); } // 根据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 = null; SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } }else { 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<>(); //此处新增了根据用户权限查询的情况 if (areaDeptEnum != null){ criteriaList.add(Criteria.where("no").regex("^" +areaDeptEnum.getCode())); } // 添加固定条件 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 = null; SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } }else { 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<>(); //此处新增了根据用户权限查询的情况 if (areaDeptEnum != null){ criteriaList.add(Criteria.where("no").regex("^" +areaDeptEnum.getCode())); } // 添加固定条件 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); criteriaList.add(Criteria.where("importantTag").is(Boolean.TRUE)); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } 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 = null; SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } }else { 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<>(); //此处新增了根据用户权限查询的情况 if (areaDeptEnum != null){ criteriaList.add(Criteria.where("no").regex("^" +areaDeptEnum.getCode())); } // 添加固定条件 criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*")); criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime())); criteriaList.add(Criteria.where("importantCommandImageTag").is(Boolean.TRUE)); // 根据dataType动态添加条件 if (params.getDataType() == 1) { criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE)); } 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"); SysDept sysDept = getSysDeptByLoginUser(); List andCriteria; AreaDeptEnum areaDeptEnum = null; if (sysDept != null) { areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null) { andCriteria = MongoUtil.getAndCriteriaDateCenter(areaDeptEnum.getCode(),params, TIME_FIELD, likeFileds, null); }else { andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); } }else { 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"); Document areDocument = null; if (areaDeptEnum != null) { String areaCodePrefix = areaDeptEnum.getCode(); areDocument = new Document("deviceNo", new Document("$regex", "^" + areaCodePrefix)); } //总数 List dList1 = new ArrayList<>(2); if(areDocument != null){ dList1.add(areDocument); } setTag(params, dList1); Document totalFilter = new Document("$and", dList1); //新设备数 List dList2 = new ArrayList<>(2); if(areDocument != null){ dList1.add(areDocument); } 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"); SysDept sysDept = getSysDeptByLoginUser(); List andCriteria; AreaDeptEnum areaDeptEnum = null; if (sysDept != null) { areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null) { andCriteria = MongoUtil.getAndCriteriaDateCenter(areaDeptEnum.getCode(),params, TIME_FIELD, likeFileds, null); }else { andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); } }else { 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"); Document areDocument = null; if (areaDeptEnum != null) { String areaCodePrefix = areaDeptEnum.getCode(); areDocument = new Document("deviceNo", new Document("$regex", "^" + areaCodePrefix)); } //总数 List dList1 = new ArrayList<>(2); if (areDocument != null){ dList1.add(areDocument); } setTag(params, dList1); Document totalFilter = new Document("$and", dList1); //list1 //合格数 List dList2 = new ArrayList<>(2); if (areDocument != null){ dList2.add(areDocument); } 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); if (areDocument != null){ dList3.add(areDocument); } 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); } private final ISysConfigService configService; public double getSySMinTime(){ //获取系统参数 String dictLabel = configService.selectConfigByKey("recording_min_time"); double recordingMinTime; try { recordingMinTime = Double.parseDouble(dictLabel) / 60; // 如果 dictLabel 是以小时为单位，则无需除以 60 } catch (Exception e) { log.error("配置的删除时间范围格式不正确: {}", dictLabel, e); return 12.0; // 默认 12 小时（以小时为单位） } return recordingMinTime; } private final TMonitorMapper tMonitorMapper; /** * 视频：录像可用率 * * @param params * @return */ @Override public Result videoAvailabilityRate(DataCenterQuery params) { List noString = tMonitorMapper.getIdListVideo(); List likeFileds = Arrays.asList("deviceId", "deviceName"); SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; Query query = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,"createTime",likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, "createTime", likeFileds, null); } }else { query = MongoUtil.getQuery(params, "createTime", likeFileds, null); } if (CollectionUtils.isNotEmpty(noString)) { // 防止空集合异常 query.addCriteria(Criteria.where("no").in(noString)); } //下拉框录像情况查询条件 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); //查询动态列数据 //查询动态列数据更具id查询 // List dynamicColumnNames = dynamicColumnMapper.getDynamicColumnByTableName("uy_record_meta_d_sum"); //翻译行政区域 resultList.forEach(item -> { String areaCode = item.getArealayername().substring(0, 6); AreaDeptEnum areaDeptEnumInfo = AreaDeptEnum.fromCode(areaCode); if (areaDeptEnumInfo != null) item.setArealayername(areaDeptEnumInfo.getName()); List list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_VIDEO,item.getId()); item.setDynamicColumnList(list); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_record_meta_d_sum"); List status = Arrays.asList(1, 0, -1); AreaDeptEnum finalAreaDeptEnum = areaDeptEnum; List resultCount = status.stream().map(item -> { List dList = new ArrayList<>(2); dList.add(new Document("recordStatus", new Document("$eq", item))); if(finalAreaDeptEnum != null){ dList.add(new Document("$and", Arrays.asList( new Document("no", new Document("$in", noString)), new Document("no", new Document("$regex", "^" + finalAreaDeptEnum.getCode())) ))); }else { dList.add(new Document("no", new Document("$in", noString))); } 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()); //计算录像可用率 MongoDatabase databaes2 = mongoTemplate.getDb(); MongoCollection collection2 = databaes2.getCollection("uy_record_meta_d_sum"); double finalRecordingMinTime = getSySMinTime(); List documentList = new ArrayList<>(2); if(finalAreaDeptEnum != null){ documentList.add(new Document("$and", Arrays.asList( new Document("no", new Document("$in", noString)), new Document("no", new Document("$regex", "^" + finalAreaDeptEnum.getCode())) ))); }else { documentList.add(new Document("no", new Document("$in", noString))); } // documentList.add(new Document("$and", Arrays.asList( // new Document("no", new Document("$in", noString)), // new Document("no", new Document("$regex", "^" + finalAreaDeptEnum.getCode())) // ))); setTag(params, documentList); Document recording = new Document("missDuration",new Document("$lte", finalRecordingMinTime)); documentList.add(recording); Document filter = new Document("$and", documentList); // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceId")), new Document("$count", "uniqueDeviceIds") ); AggregateIterable result = collection2.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } log.error("录像可用率打印：{}",uniqueDeviceIdCount); int totalCount = 0; for (String s : resultCount) { totalCount += Integer.parseInt(s); } resultCount.add(0, totalCount + ""); BigDecimal onlineRate = BigDecimal.ZERO; // 1：完整 0：间歇 -1：异常 | if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) { //resultCount.get(0)是总数 uniqueDeviceIdCount是更具系统参数查询到mongodb中大于等于 recordDuration字段的总数 onlineRate = new BigDecimal(uniqueDeviceIdCount).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); } resultCount.add(this.remove0(onlineRate)); 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"); SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; Query query = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,"createTime",likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, "createTime", likeFileds, null); } }else { 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 areaDeptEnumInfo = AreaDeptEnum.fromCode(areaCode); if (areaDeptEnumInfo != null) item.setArealayername(areaDeptEnumInfo.getName()); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_record_meta_d_sum"); List status = Arrays.asList(1, 0, -1); AreaDeptEnum finalAreaDeptEnum = areaDeptEnum; 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); if (finalAreaDeptEnum != null){ dList.add(new Document("$and", Arrays.asList( // new Document("no", new Document("$in", noString)), new Document("no", new Document("$regex", "^" + finalAreaDeptEnum.getCode())) ))); } 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()); //计算部级录像可用率 MongoDatabase database2 = mongoTemplate.getDb(); MongoCollection collection2 = database2.getCollection("uy_record_meta_d_sum"); double finalRecordingMinTime = getSySMinTime(); List documentList = new ArrayList<>(4); documentList.add(new Document("deptTag", new Document("$eq", Boolean.TRUE))); setTag(params, documentList); Document recording = new Document("missDuration",new Document("$lte", finalRecordingMinTime)); documentList.add(recording); if (finalAreaDeptEnum != null){ documentList.add(new Document("$and", Arrays.asList( // new Document("no", new Document("$in", noString)), new Document("no", new Document("$regex", "^" + finalAreaDeptEnum.getCode())) ))); } Document filter = new Document("$and", documentList); // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceId")), new Document("$count", "uniqueDeviceIds") ); AggregateIterable result = collection2.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } log.error("部级录像可用率{}:",uniqueDeviceIdCount); // 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(uniqueDeviceIdCount).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"); SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; Query query = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,"createTime",likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, "createTime", likeFileds, null); } }else { query = MongoUtil.getQuery(params, "createTime", likeFileds, null); } query.addCriteria(Criteria.where("importantTag").is(Boolean.TRUE)); //下拉框录像情况查询条件 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 areaDeptEnumInfo = AreaDeptEnum.fromCode(areaCode); if (areaDeptEnumInfo != null) item.setArealayername(areaDeptEnumInfo.getName()); }); // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("uy_record_meta_d_sum"); List status = Arrays.asList(1, 0, -1); AreaDeptEnum finalAreaDeptEnum = areaDeptEnum; 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); if (finalAreaDeptEnum != null){ dList.add(new Document("$and", Arrays.asList( // new Document("no", new Document("$in", noString)), new Document("no", new Document("$regex", "^" + finalAreaDeptEnum.getCode())) ))); } 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()); //计算重点点位录像可用率 MongoDatabase database2 = mongoTemplate.getDb(); MongoCollection collection2 = database2.getCollection("uy_record_meta_d_sum"); double finalRecordingMinTime = getSySMinTime(); List documentList = new ArrayList<>(4); documentList.add(new Document("importantTag", new Document("$eq", Boolean.TRUE))); setTag(params, documentList); Document recording = new Document("missDuration",new Document("$lte", finalRecordingMinTime)); documentList.add(recording); if (finalAreaDeptEnum != null){ documentList.add(new Document("$and", Arrays.asList( // new Document("no", new Document("$in", noString)), new Document("no", new Document("$regex", "^" + finalAreaDeptEnum.getCode())) ))); } Document filter = new Document("$and", documentList); // 构建聚合管道 List pipeline = Arrays.asList( new Document("$match", filter), // $group 去重 new Document("$group", new Document("_id", "$deviceId")), new Document("$count", "uniqueDeviceIds") ); AggregateIterable result = collection2.aggregate(pipeline); Integer uniqueDeviceIdCount = 0; for (Document doc : result) { uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); break; // 不需要继续遍历，因为 $count 只会产生一个结果 } log.error("重点点位录像可用率{}:",uniqueDeviceIdCount); // 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(uniqueDeviceIdCount).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); Query nonNetworkQuery; Query networkQuery; Query videoQuery; Query carQuery; Query faceQuery; // if (areaDeptEnum == null){ nonNetworkQuery = new Query().addCriteria(Criteria.where("LWSX").is("0")); networkQuery = new Query().addCriteria(Criteria.where("LWSX").is("1")); videoQuery = new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")); carQuery = new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")); faceQuery = new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")); // } // else { // nonNetworkQuery = new Query().addCriteria(Criteria.where("LWSX").is("0")).addCriteria(Criteria.where("no").regex("^" + Pattern.quote(areaDeptEnum.getCode()))); // networkQuery = new Query().addCriteria(Criteria.where("LWSX").is("1")).addCriteria(Criteria.where("no").regex("^" + Pattern.quote(areaDeptEnum.getCode()))); // videoQuery = new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")).addCriteria(Criteria.where("no").regex("^" + Pattern.quote(areaDeptEnum.getCode()))); // carQuery = new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")).addCriteria(Criteria.where("no").regex("^" + Pattern.quote(areaDeptEnum.getCode()))); // faceQuery = new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")).addCriteria(Criteria.where("no").regex("^" + Pattern.quote(areaDeptEnum.getCode()))); // } // 统计数 long nonNetwork = mongoTemplate.count(nonNetworkQuery, RecordMetaDSumResult.class); long network = mongoTemplate.count(networkQuery, RecordMetaDSumResult.class); long video = mongoTemplate.count(videoQuery, RecordMetaDSumResult.class); long car = mongoTemplate.count(carQuery, RecordMetaDSumResult.class); long face = mongoTemplate.count(faceQuery, 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"); SysDept sysDept = getSysDeptByLoginUser(); List andCriteria; AreaDeptEnum areaDeptEnum = null; if (sysDept != null) { areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null) { andCriteria = MongoUtil.getAndCriteriaDateCenter(areaDeptEnum.getCode(),params, "checkTime", likeFileds, null); }else { andCriteria = MongoUtil.getAndCriteria(params, "checkTime", likeFileds, null); } }else { andCriteria = MongoUtil.getAndCriteria(params, "checkTime", likeFileds, null); } Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); query.addCriteria(Criteria.where("importantTag").is(Boolean.TRUE)); // 下拉框标注正确查询条件 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"); // 确保在统计查询中也应用相同的过滤条件 Document areDocument = null; if (areaDeptEnum != null) { String areaCodePrefix = areaDeptEnum.getCode(); areDocument = new Document("deviceNo", new Document("$regex", "^" + areaCodePrefix)); } // 总数 List dList = new ArrayList<>(2); if (areDocument != null){ dList.add(areDocument); } dList.add(new Document("importantTag", Boolean.TRUE)); setTag(params, dList); Document osdFilter = new Document("$and", dList); // 正常数 List dList1 = new ArrayList<>(2); if (areDocument != null){ dList1.add(areDocument); } 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); if (areDocument != null){ dList2.add(areDocument); } 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); if (areDocument != null){ dList3.add(areDocument); } 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))); 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()); 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"); SysDept sysDept = getSysDeptByLoginUser(); List andCriteria; AreaDeptEnum areaDeptEnum = null; if (sysDept != null) { areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null) { andCriteria = MongoUtil.getAndCriteriaDateCenter(areaDeptEnum.getCode(),params, "checkTime", likeFileds, null); }else { andCriteria = MongoUtil.getAndCriteria(params, "checkTime", likeFileds, null); } }else { andCriteria = MongoUtil.getAndCriteria(params, "checkTime", likeFileds, null); } Query query = new Query(); Criteria and = new Criteria(); and.andOperator(andCriteria); query = Query.query(and); query.addCriteria(Criteria.where("importantTag").is(Boolean.TRUE)); //下拉框标注正确查询条件 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); Document areDocument = null; if (areaDeptEnum != null) { String areaCodePrefix = areaDeptEnum.getCode(); areDocument = new Document("deviceNo", new Document("$regex", "^" + areaCodePrefix)); } for (OsdCheckResult osdCheckResult : resultList) { OsdCheckResult.getError(osdCheckResult); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("osd_check_result"); //总数 List dList = new ArrayList<>(3); if (areDocument != null){ dList.add(areDocument); } 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))); if (areDocument != null){ dList1.add(areDocument); } setTag(params, dList1); Document osdCorrectFilter = new Document("$and", dList1); //异常数 List dList2 = new ArrayList<>(2); if (areDocument != null){ dList2.add(areDocument); } 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); if (areDocument != null){ dList3.add(areDocument); } 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 = null; SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } }else { 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())); Document areDocument = null; if (areaDeptEnum != null) { String areaCodePrefix = areaDeptEnum.getCode(); areDocument = new Document("deviceNo", new Document("$regex", "^" + areaCodePrefix)); } // 统计数量 MongoDatabase database = mongoTemplate.getDb(); MongoCollection collection = database.getCollection("hk_snapshot_data_monitor"); List dList2 = new ArrayList<>(2); if (areDocument != null){ dList2.add(areDocument); } 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); if (areDocument != null){ dList3.add(areDocument); } 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); if (areDocument != null){ dList4.add(areDocument); } 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); if (areDocument != null){ dList5.add(areDocument); } 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); } public Query buildQuery(DataCenterQuery params,List likeFileds,String fileName){ Query query = null; SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } }else { query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } return query; } /** * 车辆：点位在线率 * * @param params * @return */ @Override public Result vehiclePointOnlineRate(DataCenterQuery params) { List likeFileds = Arrays.asList("name", "no", "ip"); Query query = null; SysDept sysDept = getSysDeptByLoginUser(); AreaDeptEnum areaDeptEnum = null; if (sysDept !=null){ areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null){ query = MongoUtil.getQueryDataCenter(areaDeptEnum.getCode(),params,TIME_FIELD,likeFileds,null,"no"); }else{ query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); } }else { 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); } //添加动态数据 List list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_CAR_POINT,item.getNo()); item.setDynamicColumnList(list); }); // 统计设备数量 //卡片统计 int totalCount = 0; int onlineCount = 0; int offlineCount = 0; int unknownCount = 0; //构建条件 List criteriaList = new ArrayList<>(); if (areaDeptEnum != null){ criteriaList.add(Criteria.where("no").regex("^" +areaDeptEnum.getCode())); } // 添加固定条件 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"); SysDept sysDept = getSysDeptByLoginUser(); List andCriteria; AreaDeptEnum areaDeptEnum = null; if (sysDept != null) { areaDeptEnum = AreaDeptEnum.fromDept(Math.toIntExact(sysDept.getDeptId())); if (areaDeptEnum != null) { andCriteria = MongoUtil.getAndCriteriaDateCenter(areaDeptEnum.getCode(),params, "checkTime", likeFileds, null); }else { andCriteria = MongoUtil.getAndCriteria(params, "checkTime", likeFileds, null); } }else { andCriteria = MongoUtil.getAndCriteria(params, "checkTime", 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"); Document areDocument = null; if (areaDeptEnum != null) { String areaCodePrefix = areaDeptEnum.getCode(); areDocument = new Document("no", new Document("$regex", "^" + areaCodePrefix)); } //总数 List dList1 = new ArrayList<>(2); if (areDocument != null){ dList1.add(areDocument); } setTag(params, dList1); dList1.add(new Document("sxjgnlx.value", new Document("$regex", ".*2.*"))); Document totalFilter = new Document("$and", dList1); //新设备数 List dList2 = new ArrayList<>(2); if (areDocument != null){ dList2.add(areDocument); } 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); } //添加动态数据 List list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_FACE_POINT,item.getNo()); item.setDynamicColumnList(list); }); 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)); } }