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


@@ -20,6 +20,7 @@


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;


@@ -66,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;


@@ -631,6 +631,8 @@






    }








    /**


     * 视频：点位在线率


@@ -1370,6 +1372,7 @@




        return recordingMinTime;


    }


    private final TMonitorMapper tMonitorMapper;




    /**


     * 视频：录像可用率


@@ -1379,15 +1382,20 @@


     */


    @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查询


@@ -1403,12 +1411,15 @@




        });


        // 统计数量




        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);


            // 构建聚合管道


@@ -1435,8 +1446,9 @@


        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("recordDuration",new Document("$gte", finalRecordingMinTime));


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


        documentList.add(recording);




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


@@ -1448,25 +1460,14 @@


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


        );


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






        Integer uniqueDeviceIdCount = 0;


        for (Document doc : result) {


            uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds");


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


        }


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


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


//                .select(CheckIndexVideo::getVideoAvailable)


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


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


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


//                .list();


//        BigDecimal onlineRate = BigDecimal.ZERO;


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


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


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


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


//        }


        //加一个总数


        int totalCount = 0;


        for (String s : resultCount) {


            totalCount += Integer.parseInt(s);


@@ -1474,8 +1475,6 @@


        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字段的总数


@@ -1548,7 +1547,7 @@


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


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


        setTag(params, documentList);


        Document recording = new Document("recordDuration",new Document("$gte", finalRecordingMinTime));


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


        documentList.add(recording);


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


        // 构建聚合管道


@@ -1655,7 +1654,7 @@


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


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


        setTag(params, documentList);


        Document recording = new Document("recordDuration",new Document("$gte", finalRecordingMinTime));


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


        documentList.add(recording);


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


        // 构建聚合管道