blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
zxl
2025-05-29 71f61d13531b3e2a0099ba5afe3f268c99c5bacf 
 ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java


@@ -20,9 +20,11 @@


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.service.ISysConfigService;


import com.ycl.utils.DateUtils;


import com.ycl.utils.MongoUtil;


import com.ycl.utils.StringUtils;


@@ -65,7 +67,6 @@


    private final MongoTemplate mongoTemplate;


    private final ImageResourceSecurityDetailMapper securityDetailMapper;


    private final YwPointMapper pointMapper;


    private final ICheckIndexVideoService checkIndexVideoService;


    private final ICheckIndexCarService checkIndexCarService;


    private final ICheckIndexFaceService checkIndexFaceService;


    private final DynamicColumnMapper dynamicColumnMapper;


@@ -76,14 +77,35 @@




    private static DecimalFormat DF = new DecimalFormat("#.####");








    public Map<String,List<DynamicColumnVO>> getDynamicByConditions(DataCenterQuery params,List<DynamicColumnVO> list){


        //获得到对应id，且包含传入字符串 动态列集合


        List<DynamicColumnVO> likeFieldDynamicColumnVOList = list.stream()


                .filter(dynamicColumnVO ->


                    dynamicColumnVO.getLabelId().equals(params.getDyId()) &&


                            dynamicColumnVO.getColumnValue().contains(params.getDyValue())


        ).collect(Collectors.toList());


        //获得满足条件的id集合


        List<String> ids = likeFieldDynamicColumnVOList.stream().map(DynamicColumnVO::getRefStringId).toList();


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = list.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));


        Set<String> removeSet = new HashSet<>(ids);


        //移除掉不符合条件的key


        groupByRefStringIdMap.keySet().retainAll(removeSet);




        return groupByRefStringIdMap;


    }




    @Override


    public void recordingAvailabilityExport(HttpServletResponse response,DataCenterQuery params) throws IOException {




        List<String> likeFileds = Arrays.asList("deviceId", "deviceName");


        Query query = MongoUtil.getQuery(params, "createTime", likeFileds, null);


        //下拉框录像情况查询条件


        if (params.getOption() != null) {


            query.addCriteria(Criteria.where("recordStatus").is(params.getOption()));


        }


        MongoUtil.setNoPage(query, params, TIME_FIELD);


        List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class);


        //翻译行政区域


        resultList.forEach(item -> {


@@ -91,8 +113,19 @@


            AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode);


            if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName());


        });


        //获得动态列数据


        List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_VIDEO);


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));




        //判断是否有查询条件


        boolean conditions = false;


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>();


        if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){


            conditions = true;


            //获得动态列集合中包含了的字符串值的集合 区分大小写


            groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList);


        }else{


            groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));


        }


        //固定表头


        LinkedHashSet<String> headers = new LinkedHashSet<>();


        headers.add(RecordingAvailabilityHeaders.arealayername);


@@ -114,21 +147,28 @@


            headersList.addAll(dynamicsHeaders);


            headers.addAll(headersList);


        }


        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");


        SimpleDateFormat dateFormat2 = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");




//        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd");


        //查询到有动态列查询条件


        //获得对应动态列中ref的对象id 与 查询结果id过滤


        if (conditions){


            Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap;


            resultList = resultList.stream()


                    .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getId()))


                    .collect(Collectors.toList());


        }


        SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


        List<List<Object>> data = new ArrayList<>();


        for (RecordMetaDSumResult result : resultList){


            List<Object> row = new ArrayList<>();


            row.add(result.getArealayername());


            row.add(result.getArealayerno());


            row.add(dateFormat2.format(result.getCreateTime()));


            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(dateFormat2.format(result.getCreateTime()));


            row.add(dateFormat.format(result.getCreateTime()));


            //添加动态列数据


            for (String header : headersList){


                boolean flag = false;


@@ -200,8 +240,23 @@


                item.setOffLineTimeStr(offLineTime);


            }


        });








        List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_FACE_POINT);


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));






        //判断是否有查询条件


        boolean conditions = false;


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>();


        if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){


            conditions = true;


            //获得动态列集合中包含了的字符串值的集合 区分大小写


            groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList);


        }else{


            groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));


        }




        //固定表头


        LinkedHashSet<String> headers = new LinkedHashSet<>();


        headers.add(PointOnlineHeaders.no);


@@ -222,6 +277,13 @@


            //使用链表保证后续补充数据时获取数据顺序一致


            headersList.addAll(dynamicsHeaders);


            headers.addAll(headersList);


        }




        if (conditions){


            Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap;


            resultList = resultList.stream()


                    .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo()))


                    .collect(Collectors.toList());


        }




        List<List<Object>> data = new ArrayList<>();


@@ -312,7 +374,16 @@


            }


        });


        List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_VIDEO_POINT);


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));


        //判断是否有查询条件


        boolean conditions = false;


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>();


        if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){


            conditions = true;


            //获得动态列集合中包含了的字符串值的集合 区分大小写


            groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList);


        }else{


            groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));


        }


        //固定表头


        LinkedHashSet<String> headers = new LinkedHashSet<>();


        headers.add(PointOnlineHeaders.no);


@@ -333,6 +404,14 @@


            //使用链表保证后续补充数据时获取数据顺序一致


            headersList.addAll(dynamicsHeaders);


            headers.addAll(headersList);


        }






        if (conditions){


            Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap;


            resultList = resultList.stream()


                    .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo()))


                    .collect(Collectors.toList());


        }




        List<List<Object>> data = new ArrayList<>();


@@ -427,7 +506,16 @@


            }


        });


        List<DynamicColumnVO> dynamicColumnVOList = dynamicColumnMapper.getDynamicColumnByTableName(TableNameConstants.COLUMN_NAME_CAR_POINT);


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));


        //判断是否有查询条件


        boolean conditions = false;


        Map<String,List<DynamicColumnVO>> groupByRefStringIdMap = new HashMap<>();


        if (params.getDyId() != null && StringUtils.isNotEmpty(params.getDyValue())){


            conditions = true;


            //获得动态列集合中包含了的字符串值的集合 区分大小写


            groupByRefStringIdMap = getDynamicByConditions(params,dynamicColumnVOList);


        }else{


            groupByRefStringIdMap = dynamicColumnVOList.stream().collect(Collectors.groupingBy(DynamicColumnVO::getRefStringId));


        }


        //固定表头


        LinkedHashSet<String> headers = new LinkedHashSet<>();


        headers.add(PointOnlineHeaders.no);


@@ -448,6 +536,14 @@


            //使用链表保证后续补充数据时获取数据顺序一致


            headersList.addAll(dynamicsHeaders);


            headers.addAll(headersList);


        }






        if (conditions){


            Map<String, List<DynamicColumnVO>> finalGroupByRefStringIdMap = groupByRefStringIdMap;


            resultList = resultList.stream()


                    .filter(obj -> finalGroupByRefStringIdMap.containsKey(obj.getNo()))


                    .collect(Collectors.toList());


        }




        List<List<Object>> data = new ArrayList<>();


@@ -534,6 +630,50 @@








    }




    //zxl


    @Override


    public BigDecimal videoPointOnlineRateCount(DataCenterQuery params){


        //卡片统计


        int totalCount = 0;


        int onlineCount = 0;


        int offlineCount = 0;


        int unknownCount = 0;


        //构建条件


        List<Criteria> criteriaList = new ArrayList<>();


        // 添加固定条件


        criteriaList.add(Criteria.where("monitorType").regex(".*" + CheckConstants.Rule_Category_Video + ".*"));


        criteriaList.add(Criteria.where("mongoCreateTime").gte(params.getStartTime()).lte(params.getEndTime()));


        // 根据dataType动态添加条件


        if (params.getDataType() == 1) {


            criteriaList.add(Criteria.where("provinceTag").is(Boolean.TRUE));


        } else if (params.getDataType() == 2) {


            criteriaList.add(Criteria.where("deptTag").is(Boolean.TRUE));


        }


        // 构建match操作


        MatchOperation match = Aggregation.match(


                new Criteria().andOperator(criteriaList.toArray(new Criteria[0]))


        );


        GroupOperation group = Aggregation.group()


                .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Online)).then(1).otherwise(0)).as("onlineCount")


                .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Offline)).then(1).otherwise(0)).as("offlineCount")


                .sum(ConditionalOperators.when(Criteria.where("online").is(ApiConstants.UY_OnlineSite_Unknown)).then(1).otherwise(0)).as("unknownCount");


        // 将匹配阶段和分组阶段组合起来


        Aggregation aggregation = Aggregation.newAggregation(match, group);


        // 执行聚合查询


        AggregationResults<Map> results = mongoTemplate.aggregate(aggregation, "t_monitor_online", Map.class); // 替换为你的集合名称


        for (Map<String, Object> 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"));


        }


        return onlineRate;


    }




    /**


@@ -1259,44 +1399,38 @@


        return Result.ok().data(map).total(total);


    }




    /**


     * 视频：录像可用率


     *


     * @param params


     * @return


     */


    @Override


    private final ISysConfigService configService;




    public Result videoAvailabilityRate(DataCenterQuery params) {


        List<String> likeFileds = Arrays.asList("deviceId", "deviceName");


        Query query = MongoUtil.getQuery(params, "createTime", likeFileds, null);


        //下拉框录像情况查询条件


        if (params.getOption() != null) {


            query.addCriteria(Criteria.where("recordStatus").is(params.getOption()));


    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 小时（以小时为单位）


        }


        long total = mongoTemplate.count(query, RecordMetaDSumResult.class);


        MongoUtil.setPage(query, params, "createTime");


        List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class);


        //查询动态列数据


        //查询动态列数据更具id查询


//        List<DynamicColumnVO> dynamicColumnNames = dynamicColumnMapper.getDynamicColumnByTableName("uy_record_meta_d_sum");


        //翻译行政区域


        resultList.forEach(item -> {


            String areaCode = item.getArealayername().substring(0, 6);


            AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode);


            if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName());




            List<DynamicColumnVO> list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_VIDEO,item.getId());


            item.setDynamicColumnList(list);


        return recordingMinTime;


    }


    private final TMonitorMapper tMonitorMapper;




        });


    //zxl


    @Override


    public BigDecimal videoAvailabilityRateCount(DataCenterQuery params){


        System.out.println("------------------------------------------------------------------------------------");


        System.out.println(params);


        // 统计数量


        List<String> noString = tMonitorMapper.getIdListVideo();


        MongoDatabase database = mongoTemplate.getDb();


        MongoCollection<Document> collection = database.getCollection("uy_record_meta_d_sum");


        List<Integer> status = Arrays.asList(1, 0, -1);


        List<String> resultCount = status.stream().map(item -> {


            List<Document> dList = new ArrayList<>(2);




            dList.add(new Document("recordStatus", new Document("$eq", item)));


            dList.add(new Document("no", new Document("$in", noString)));


            setTag(params, dList);


            Document filter = new Document("$and", dList);


            // 构建聚合管道


@@ -1315,19 +1449,35 @@


            }


            return uniqueDeviceIdCount + "";


        }).collect(Collectors.toList());


//        List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())


//                .select(CheckIndexVideo::getVideoAvailable)


//                .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)


//                .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept)


//                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime()))


//                .list();


//        BigDecimal onlineRate = BigDecimal.ZERO;


//        if (CollectionUtils.isNotEmpty(videoList)) {


//            BigDecimal sum = videoList.stream().map(CheckIndexVideo::getVideoAvailable).reduce(BigDecimal.ZERO, BigDecimal::add);


//            BigDecimal count = BigDecimal.valueOf(videoList.size());


//            onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));


//        }


        //加一个总数




        //计算录像可用率


        MongoDatabase databaes2 = mongoTemplate.getDb();


        MongoCollection<Document> collection2 = databaes2.getCollection("uy_record_meta_d_sum");




        double finalRecordingMinTime = getSySMinTime();




        List<Document> documentList = new ArrayList<>(2);


        documentList.add(new Document("no", new Document("$in", noString)));


        setTag(params, documentList);


        Document recording = new Document("missDuration",new Document("$lte", finalRecordingMinTime));


        documentList.add(recording);




        Document filter = new Document("$and", documentList);


        // 构建聚合管道


        List<Document> pipeline = Arrays.asList(


                new Document("$match", filter),


                // $group 去重


                new Document("$group", new Document("_id", "$deviceId")),


                new Document("$count", "uniqueDeviceIds")


        );


        AggregateIterable<Document> result = collection2.aggregate(pipeline);






        Integer uniqueDeviceIdCount = 0;


        for (Document doc : result) {


            uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds");


            break; // 不需要继续遍历，因为 $count 只会产生一个结果


        }


        int totalCount = 0;


        for (String s : resultCount) {


            totalCount += Integer.parseInt(s);


@@ -1337,13 +1487,126 @@


        BigDecimal onlineRate = BigDecimal.ZERO;


//        1：完整 0：间歇 -1：异常 |


        if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) {


            //resultCount.get(0)


            onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100"));


            //resultCount.get(0)是总数 uniqueDeviceIdCount是更具系统参数查询到mongodb中大于等于 recordDuration字段的总数


            onlineRate = new BigDecimal(uniqueDeviceIdCount).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100"));


        }


        System.out.println(resultCount);


        System.out.println(onlineRate);


        return onlineRate;


    }










    /**


     * 视频：录像可用率


     *


     * @param params


     * @return


     */


    @Override


    public Result videoAvailabilityRate(DataCenterQuery params) {


        List<String> noString = tMonitorMapper.getIdListVideo();




        List<String> likeFileds = Arrays.asList("deviceId", "deviceName");


        Query 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<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class);


        //查询动态列数据


        //查询动态列数据更具id查询


//        List<DynamicColumnVO> dynamicColumnNames = dynamicColumnMapper.getDynamicColumnByTableName("uy_record_meta_d_sum");


        //翻译行政区域


        resultList.forEach(item -> {


            String areaCode = item.getArealayername().substring(0, 6);


            AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode);


            if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName());




            List<DynamicColumnVO> list = dynamicColumnMapper.getDynamicColumnByTable(TableNameConstants.COLUMN_NAME_VIDEO,item.getId());


            item.setDynamicColumnList(list);




        });


        // 统计数量




        MongoDatabase database = mongoTemplate.getDb();


        MongoCollection<Document> collection = database.getCollection("uy_record_meta_d_sum");


        List<Integer> status = Arrays.asList(1, 0, -1);


        List<String> resultCount = status.stream().map(item -> {


            List<Document> dList = new ArrayList<>(2);




            dList.add(new Document("recordStatus", new Document("$eq", item)));


            dList.add(new Document("no", new Document("$in", noString)));


            setTag(params, dList);


            Document filter = new Document("$and", dList);


            // 构建聚合管道


            List<Document> pipeline = Arrays.asList(


                    new Document("$match", filter),


                    // $group 去重


                    new Document("$group", new Document("_id", "$deviceId")),


                    new Document("$count", "uniqueDeviceIds")


            );


            // 执行聚合查询并获取结果


            AggregateIterable<Document> 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<Document> collection2 = databaes2.getCollection("uy_record_meta_d_sum");




        double finalRecordingMinTime = getSySMinTime();




        List<Document> documentList = new ArrayList<>(2);


        documentList.add(new Document("no", new Document("$in", noString)));


        setTag(params, documentList);


        Document recording = new Document("missDuration",new Document("$lte", finalRecordingMinTime));


        documentList.add(recording);




        Document filter = new Document("$and", documentList);


        // 构建聚合管道


        List<Document> pipeline = Arrays.asList(


                new Document("$match", filter),


                // $group 去重


                new Document("$group", new Document("_id", "$deviceId")),


                new Document("$count", "uniqueDeviceIds")


        );


        AggregateIterable<Document> result = collection2.aggregate(pipeline);






        Integer uniqueDeviceIdCount = 0;


        for (Document doc : result) {


            uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds");


            break; // 不需要继续遍历，因为 $count 只会产生一个结果


        }


        log.error("录像可用率打印：{}",uniqueDeviceIdCount);


        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<String, Object> map = new HashMap<>();


        log.error("resultCount:{}",resultCount.get(3));


        map.put("count", resultCount);


        map.put("list", resultList);


        return Result.ok().data(map).total(total);


@@ -1399,6 +1662,35 @@


            return uniqueDeviceIdCount + "";


        }).collect(Collectors.toList());






        //计算部级录像可用率


        MongoDatabase database2 = mongoTemplate.getDb();


        MongoCollection<Document> collection2 = database2.getCollection("uy_record_meta_d_sum");


        double finalRecordingMinTime = getSySMinTime();




        List<Document> documentList = new ArrayList<>(4);


        documentList.add(new Document("deptTag", new Document("$eq", Boolean.TRUE)));


        setTag(params, documentList);


        Document recording = new Document("missDuration",new Document("$lte", finalRecordingMinTime));


        documentList.add(recording);


        Document filter = new Document("$and", documentList);


        // 构建聚合管道


        List<Document> pipeline = Arrays.asList(


                new Document("$match", filter),


                // $group 去重


                new Document("$group", new Document("_id", "$deviceId")),


                new Document("$count", "uniqueDeviceIds")


        );


        AggregateIterable<Document> result = collection2.aggregate(pipeline);


        Integer uniqueDeviceIdCount = 0;


        for (Document doc : result) {


            uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds");


            break; // 不需要继续遍历，因为 $count 只会产生一个结果


        }


        log.error("部级录像可用率{}:",uniqueDeviceIdCount);








//        List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())


//                .select(CheckIndexVideo::getMinistryVideoAvailable)


//                .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)


@@ -1419,7 +1711,7 @@


        resultCount.add(0, totalCount + "");


        BigDecimal onlineRate = BigDecimal.ZERO;


        if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) {


            onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100"));


            onlineRate = new BigDecimal(uniqueDeviceIdCount).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100"));


        }


        resultCount.add(this.remove0(onlineRate));


        HashMap<String, Object> map = new HashMap<>();


@@ -1478,6 +1770,32 @@


            return uniqueDeviceIdCount + "";


        }).collect(Collectors.toList());




        //计算重点点位录像可用率


        MongoDatabase database2 = mongoTemplate.getDb();


        MongoCollection<Document> collection2 = database2.getCollection("uy_record_meta_d_sum");


        double finalRecordingMinTime = getSySMinTime();




        List<Document> documentList = new ArrayList<>(4);


        documentList.add(new Document("importantTag", new Document("$eq", Boolean.TRUE)));


        setTag(params, documentList);


        Document recording = new Document("missDuration",new Document("$lte", finalRecordingMinTime));


        documentList.add(recording);


        Document filter = new Document("$and", documentList);


        // 构建聚合管道


        List<Document> pipeline = Arrays.asList(


                new Document("$match", filter),


                // $group 去重


                new Document("$group", new Document("_id", "$deviceId")),


                new Document("$count", "uniqueDeviceIds")


        );


        AggregateIterable<Document> result = collection2.aggregate(pipeline);


        Integer uniqueDeviceIdCount = 0;


        for (Document doc : result) {


            uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds");


            break; // 不需要继续遍历，因为 $count 只会产生一个结果


        }


        log.error("重点点位录像可用率{}:",uniqueDeviceIdCount);




//        List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())


//                .select(CheckIndexVideo::getKeyVideoAvailable)


//                .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)


@@ -1498,7 +1816,7 @@


        resultCount.add(0, totalCount + "");


        BigDecimal onlineRate = BigDecimal.ZERO;


        if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) {


            onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100"));


            onlineRate = new BigDecimal(uniqueDeviceIdCount).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100"));


        }


        resultCount.add(this.remove0(onlineRate));


        HashMap<String, Object> map = new HashMap<>();