blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
fuliqi
2024-09-25 8febea78af8515def606491b3373c16db7d54941 
 ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java


@@ -11,6 +11,7 @@


import com.ycl.platform.domain.query.DataCenterQuery;


import com.ycl.platform.domain.result.HK.*;


import com.ycl.platform.domain.result.UY.*;


import com.ycl.platform.domain.vo.PointDetailVO;


import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper;


import com.ycl.platform.mapper.YwPointMapper;


import com.ycl.platform.service.*;


@@ -18,6 +19,7 @@


import com.ycl.system.page.PageUtil;


import com.ycl.utils.DateUtils;


import com.ycl.utils.MongoUtil;


import constant.CheckConstants;


import lombok.RequiredArgsConstructor;


import org.apache.commons.collections.CollectionUtils;


import org.bson.Document;


@@ -30,6 +32,7 @@




import java.math.BigDecimal;


import java.math.RoundingMode;


import java.text.DecimalFormat;


import java.util.*;


import java.util.stream.Collectors;




@@ -53,6 +56,8 @@




    private final static String TIME_FIELD = "mongoCreateTime";




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




    /**


     * 视频：点位在线率


     *


@@ -61,19 +66,14 @@


     */


    @Override


    public Result videoPointOnlineRate(DataCenterQuery params) {


        // 生成查询


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


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


        params.setDeptTag(-1);


        params.setDeviceType(1);


        IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);


        pointMapper.dataCenterPage(page, params);




        // 先查总数再分页


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


        MongoUtil.setPage(query, params, TIME_FIELD);


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


        // 统计设备数量


        Integer distinctCount = pointMapper.distinctCount(params);




        // 统计数量


        MongoDatabase database = mongoTemplate.getDb();


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


        long distinctCount = collection.distinct("deviceId", String.class).into(new ArrayList<>()).size();


        Date now = new Date();


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


                .select(CheckIndexVideo::getSiteOnline)


@@ -86,9 +86,9 @@


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


        }


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


        map.put("count", Arrays.asList(distinctCount + "",onlineRate + "%"));


        map.put("list", resultList);


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


        map.put("count", Arrays.asList(distinctCount + "",this.remove0(onlineRate)));


        map.put("list", page.getRecords());


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


    }




    /**


@@ -99,38 +99,18 @@


     */


    @Override


    public Result deptVideoPointOnlineRate(DataCenterQuery params) {


        params.setDeptTag(1);


        params.setDeviceType(1);


        IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);


        pointMapper.dataCenterPage(page, params);




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


        // 生成查询


        Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, 1);


        // 统计设备数量


        Integer distinctCount = pointMapper.distinctCount(params);




        // 先查总数再分页


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


        MongoUtil.setPage(query, params, TIME_FIELD);


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




        // 统计数量


        MongoDatabase database = mongoTemplate.getDb();


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


        Document filter = new Document("deptTag", new Document("$eq", Boolean.TRUE));


        // 构建聚合管道


        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 只会产生一个结果


        }


        Date now = new Date();


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


                .select(CheckIndexVideo::getMinistrySiteOnline)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -140,9 +120,9 @@


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


        }


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


        map.put("count", Arrays.asList(uniqueDeviceIdCount + "", onlineRate + "%"));


        map.put("list", resultList);


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


        map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));


        map.put("list", page.getRecords());


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


    }




    /**


@@ -153,35 +133,18 @@


     */


    @Override


    public Result videoImportantPointOnlineRate(DataCenterQuery params) {


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


        Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, 3);


        params.setDeptTag(3);


        params.setDeviceType(1);


        IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);


        pointMapper.dataCenterPage(page, params);




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


        MongoUtil.setPage(query, params, TIME_FIELD);


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




        // 统计数量


        MongoDatabase database = mongoTemplate.getDb();


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


        Document filter = new Document("importantTag", new Document("$eq", Boolean.TRUE));


        // 构建聚合管道


        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 只会产生一个结果


        }


        // 统计设备数量


        Integer distinctCount = pointMapper.distinctCount(params);




        Date now = new Date();


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


                .select(CheckIndexVideo::getKeySiteOnline)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -191,9 +154,9 @@


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


        }


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


        map.put("count", Arrays.asList(uniqueDeviceIdCount + "", onlineRate + "%"));


        map.put("list", resultList);


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


        map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));


        map.put("list", page.getRecords());


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


    }




    /**


@@ -204,35 +167,18 @@


     */


    @Override


    public Result videoImportantPointImageOnlineRate(DataCenterQuery params) {


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


        Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, 4);


        params.setDeptTag(4);


        params.setDeviceType(1);


        IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);


        pointMapper.dataCenterPage(page, params);




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


        MongoUtil.setPage(query, params, TIME_FIELD);


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




        // 统计数量


        MongoDatabase database = mongoTemplate.getDb();


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


        Document filter = new Document("importantCommandImageTag", new Document("$eq", Boolean.TRUE));


        // 构建聚合管道


        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 只会产生一个结果


        }


        // 统计设备数量


        Integer distinctCount = pointMapper.distinctCount(params);




        Date now = new Date();


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


                .select(CheckIndexVideo::getKeyCommandImageOnline)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -242,9 +188,9 @@


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


        }


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


        map.put("count", Arrays.asList(uniqueDeviceIdCount + "", onlineRate + "%"));


        map.put("list", resultList);


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


        map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));


        map.put("list", page.getRecords());


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


    }




    /**


@@ -266,10 +212,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("ip.error", true);


        Document macdzErrFilter = new Document("macdz.error", true);


        Document latitudeErrFilter = new Document("latitude.error", true);


        Document longitudeErrFilter = new Document("longitude.error", true);


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


        dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList1);


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


        dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList2);


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


        dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList3);


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


        dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -293,6 +251,7 @@


        Date now = new Date();


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


                .select(CheckIndexVideo::getMonitorRegistration)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -301,7 +260,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -327,10 +286,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("ip.error", true);


        Document macdzErrFilter = new Document("macdz.error", true);


        Document latitudeErrFilter = new Document("latitude.error", true);


        Document longitudeErrFilter = new Document("longitude.error", true);


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


        dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList1);


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


        dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList2);


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


        dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList3);


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


        dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -354,6 +325,7 @@


        Date now = new Date();


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


                .select(CheckIndexVideo::getMonitorQualification)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -362,7 +334,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -377,7 +349,6 @@


     */


    @Override


    public Result videoAssessmentFileRatio(DataCenterQuery params) {


        // TODO 新增一张表记录每次的档案考核


        List<String> likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue");


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




@@ -389,10 +360,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("ip.error", true);


        Document macdzErrFilter = new Document("macdz.error", true);


        Document latitudeErrFilter = new Document("latitude.error", true);


        Document longitudeErrFilter = new Document("longitude.error", true);


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


        dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList1);


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


        dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList2);


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


        dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList3);


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


        dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -440,7 +423,10 @@


        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 -> {


            Document filter = new Document("recordStatus", item);


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


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


            setTag(params, dList);


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


            // 构建聚合管道


            List<Document> pipeline = Arrays.asList(


                    new Document("$match", filter),


@@ -461,6 +447,7 @@


        Date now = new Date();


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


                .select(CheckIndexVideo::getVideoAvailable)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -469,7 +456,7 @@


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


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


        }


        resultCount.add(onlineRate + "%");


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


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


        map.put("count", resultCount);


        map.put("list", resultList);


@@ -496,10 +483,11 @@


        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 -> {


            Document filter = new Document("$and", Arrays.asList(


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


                    new Document("recordStatus", item)


            ));


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


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


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


            setTag(params,dList);


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


            // 构建聚合管道


            List<Document> pipeline = Arrays.asList(


                    new Document("$match", filter),


@@ -520,6 +508,7 @@


        Date now = new Date();


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


                .select(CheckIndexVideo::getMinistryVideoAvailable)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -528,7 +517,7 @@


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


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


        }


        resultCount.add(onlineRate + "%");


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


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


        map.put("count", resultCount);


        map.put("list", resultList);


@@ -555,10 +544,11 @@


        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 -> {


            Document filter = new Document("$and", Arrays.asList(


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


                    new Document("recordStatus", item)


            ));


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


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


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


            setTag(params,dList);


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


            // 构建聚合管道


            List<Document> pipeline = Arrays.asList(


                    new Document("$match", filter),


@@ -573,12 +563,13 @@


                uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds");


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


            }


            return uniqueDeviceIdCount + "%";


            return uniqueDeviceIdCount + "";


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




        Date now = new Date();


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


                .select(CheckIndexVideo::getKeyVideoAvailable)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -587,7 +578,7 @@


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


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


        }


        resultCount.add(onlineRate + "%");


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


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


        map.put("count", resultCount);


        map.put("list", resultList);


@@ -638,11 +629,26 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document importantTag = new Document("importantTag", Boolean.TRUE);


        Document osdNameFilter = new Document("$and", Arrays.asList(new Document("osdNameCorrect", 1), importantTag));


        Document osdNameErrFilter = new Document("$and", Arrays.asList(new Document("osdNameCorrect", -1), importantTag));


        Document osdTimeFilter = new Document("$and", Arrays.asList(new Document("osdTimeCorrect", 1), importantTag));


        Document osdTimeErrFilter = new Document("$and", Arrays.asList(new Document("osdTimeCorrect", -1), importantTag));


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


        dList1.add(new Document("importantTag", Boolean.TRUE));


        dList1.add(new Document("osdNameCorrect", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("importantTag", Boolean.TRUE));


        dList2.add(new Document("osdNameCorrect", new Document("$eq", -1)));


        setTag(params,dList2);


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


        dList3.add(new Document("importantTag", Boolean.TRUE));


        dList3.add(new Document("osdTimeCorrect", new Document("$eq", 1)));


        setTag(params,dList3);


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


        dList4.add(new Document("importantTag", Boolean.TRUE));


        dList4.add(new Document("osdTimeCorrect", new Document("$eq", -1)));


        setTag(params,dList4);


        Document osdNameFilter = new Document("$and", dList1);


        Document osdNameErrFilter = new Document("$and", dList2);


        Document osdTimeFilter = new Document("$and", dList3);


        Document osdTimeErrFilter = new Document("$and", dList4);


        List<Document> lists = Arrays.asList(osdNameFilter, osdNameErrFilter, osdTimeFilter, osdTimeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


@@ -665,6 +671,7 @@


        Date now = new Date();


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


                .select(CheckIndexVideo::getKeyAnnotationAccuracy)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -673,7 +680,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -726,9 +733,16 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document importantTag = new Document("importantTag", Boolean.TRUE);


        Document osdTimeFilter = new Document("$and", Arrays.asList(new Document("osdTimeCorrect", 1), importantTag));


        Document osdTimeErrFilter = new Document("$and", Arrays.asList(new Document("osdTimeCorrect", -1), importantTag));


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


        dList1.add(new Document("importantTag", Boolean.TRUE));


        dList1.add(new Document("osdTimeCorrect", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("importantTag", Boolean.TRUE));


        dList2.add(new Document("osdTimeCorrect", new Document("$eq", -1)));


        setTag(params,dList2);


        Document osdTimeFilter = new Document("$and", dList1);


        Document osdTimeErrFilter = new Document("$and", dList2);


        List<Document> lists = Arrays.asList(osdTimeFilter, osdTimeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


@@ -751,6 +765,7 @@


        Date now = new Date();


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


                .select(CheckIndexVideo::getKeyTimingAccuracy)


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


                .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -759,7 +774,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -786,10 +801,26 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document normalFilter = new Document("resultType", 1);


        Document noDataFilter = new Document("resultType", 2);


        Document trFilter = new Document("resultType", 3);


        Document littleFilter = new Document("resultType", 4);


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


        dList1.add(new Document("importantTag", Boolean.TRUE));


        dList1.add(new Document("resultType", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("importantTag", Boolean.TRUE));


        dList2.add(new Document("resultType", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("importantTag", Boolean.TRUE));


        dList3.add(new Document("resultType", new Document("$eq", 3)));


        setTag(params,dList3);


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


        dList4.add(new Document("importantTag", Boolean.TRUE));


        dList4.add(new Document("resultType", new Document("$eq", 4)));


        setTag(params,dList4);


        Document normalFilter = new Document("$and", dList1);


        Document noDataFilter = new Document("$and", dList2);


        Document trFilter = new Document("$and", dList3);


        Document littleFilter = new Document("$and", dList4);


        List<Document> lists = Arrays.asList(normalFilter, noDataFilter, trFilter, littleFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


@@ -812,6 +843,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getViewConnectStability)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -820,7 +852,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -835,21 +867,18 @@


     */


    @Override


    public Result vehiclePointOnlineRate(DataCenterQuery params) {


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


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


        params.setDeptTag(-1);


        params.setDeviceType(2);


        IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);


        pointMapper.dataCenterPage(page, params);




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


        MongoUtil.setPage(query, params, TIME_FIELD);


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




        // 统计数量


        MongoDatabase database = mongoTemplate.getDb();


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


        long distinctCount = collection.distinct("externalIndexCode", String.class).into(new ArrayList<>()).size();


        // 统计设备数量


        Integer distinctCount = pointMapper.distinctCount(params);




        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getSiteOnline)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -859,9 +888,9 @@


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


        }


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


        map.put("count", Arrays.asList(distinctCount + "%", onlineRate + "%"));


        map.put("list", resultList);


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


        map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));


        map.put("list", page.getRecords());


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


    }




    /**


@@ -883,11 +912,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("ip.error", true);


        Document macdzErrFilter = new Document("macdz.error", true);


        Document latitudeErrFilter = new Document("latitude.error", true);


        Document longitudeErrFilter = new Document("longitude.error", true);




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


        dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList1);


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


        dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList2);


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


        dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList3);


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


        dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);


        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


@@ -904,12 +944,13 @@


                uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds");


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


            }


            return uniqueDeviceIdCount + "%";


            return uniqueDeviceIdCount + "";


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




        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getDeviceDirectoryConsistent)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -918,7 +959,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -944,10 +985,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("lalType", 1);


        Document macdzErrFilter = new Document("lalType", 2);


        Document latitudeErrFilter = new Document("lalType", 3);


        Document longitudeErrFilter = new Document("lalType", 4);


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


        dList1.add(new Document("lalType", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("lalType", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("lalType", new Document("$eq", 3)));


        setTag(params,dList3);


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


        dList4.add(new Document("lalType", new Document("$eq", 4)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -971,6 +1024,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getVehicleInformationCollectionAccuracy)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -979,7 +1033,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1008,6 +1062,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getVehicleCaptureIntegrity)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1018,7 +1073,7 @@


        }




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


        map.put("count", Arrays.asList(onlineRate + "%"));


        map.put("count", Arrays.asList(this.remove0(onlineRate)));


        map.put("list", resultList);


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


    }


@@ -1041,6 +1096,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getVehicleCaptureAccuracy)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1050,7 +1106,7 @@


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


        }


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


        map.put("count", Arrays.asList(onlineRate + "%"));


        map.put("count", Arrays.asList(this.remove0(onlineRate)));


        map.put("list", resultList);


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


    }


@@ -1075,9 +1131,18 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("snapResult", 1);


        Document macdzErrFilter = new Document("snapResult", 2);


        Document longitudeErrFilter = new Document("snapResult", 4);


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


        dList1.add(new Document("snapResult", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("snapResult", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("snapResult", new Document("$eq", 4)));


        setTag(params,dList3);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document longitudeErrFilter = new Document("$and", dList3);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -1101,6 +1166,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getVehicleTimingAccuracy)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1109,7 +1175,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1135,6 +1201,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getVehicleUploadTimeliness)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1144,7 +1211,7 @@


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


        }


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


        map.put("count", Arrays.asList(onlineRate + "%"));


        map.put("count", Arrays.asList(this.remove0(onlineRate)));


        map.put("list", resultList);


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


    }


@@ -1168,6 +1235,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getVehicleUrlAvailability)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1177,7 +1245,7 @@


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


        }


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


        map.put("count", Arrays.asList(onlineRate + "%"));


        map.put("count", Arrays.asList(this.remove0(onlineRate)));


        map.put("list", resultList);


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


    }


@@ -1201,6 +1269,7 @@


        Date now = new Date();


        List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())


                .select(CheckIndexCar::getVehiclePictureAvailability)


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


                .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1210,7 +1279,7 @@


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


        }


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


        map.put("count", Arrays.asList(onlineRate + "%"));


        map.put("count", Arrays.asList(this.remove0(onlineRate)));


        map.put("list", resultList);


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


    }


@@ -1234,10 +1303,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document normalFilter = new Document("resultType", 1);


        Document noDataFilter = new Document("resultType", 2);


        Document trFilter = new Document("resultType", 3);


        Document littleFilter = new Document("resultType", 4);


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


        dList1.add(new Document("resultType", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("resultType", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("resultType", new Document("$eq", 3)));


        setTag(params,dList3);


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


        dList4.add(new Document("resultType", new Document("$eq", 4)));


        setTag(params,dList4);


        Document normalFilter = new Document("$and", dList1);


        Document noDataFilter = new Document("$and", dList2);


        Document trFilter = new Document("$and", dList3);


        Document littleFilter = new Document("$and", dList4);


        List<Document> lists = Arrays.asList(normalFilter, noDataFilter, trFilter, littleFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


@@ -1260,6 +1341,7 @@


        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getViewConnectStability)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1268,7 +1350,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1283,43 +1365,18 @@


     */


    @Override


    public Result facePointOnlineRate(DataCenterQuery params) {


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


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


        params.setDeptTag(-1);


        params.setDeviceType(3);


        IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);


        pointMapper.dataCenterPage(page, params);




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


        MongoUtil.setPage(query, params, TIME_FIELD);


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




        // 统计数量


        MongoDatabase database = mongoTemplate.getDb();


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




        Document normalFilter = new Document("resultType", 1);


        Document noDataFilter = new Document("resultType", 2);


        Document trFilter = new Document("resultType", 3);


        Document littleFilter = new Document("resultType", 4);


        List<Document> lists = Arrays.asList(normalFilter, noDataFilter, trFilter, littleFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


            List<Document> pipeline = Arrays.asList(


                    new Document("$match", filter),


                    // $group 去重


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


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


        // 统计设备数量


        Integer distinctCount = pointMapper.distinctCount(params);




        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getSiteOnline)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1328,11 +1385,13 @@


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


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


        }


        rList.add(onlineRate + "%");


        List<String> rList = new ArrayList<>(2);


        rList.add(distinctCount + "");


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


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


        map.put("count", rList);


        map.put("list", resultList);


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


        map.put("list", page.getRecords());


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


    }




    /**


@@ -1354,11 +1413,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("ip.error", true);


        Document macdzErrFilter = new Document("macdz.error", true);


        Document latitudeErrFilter = new Document("latitude.error", true);


        Document longitudeErrFilter = new Document("longitude.error", true);




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


        dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList1);


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


        dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList2);


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


        dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList3);


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


        dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);


        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


@@ -1381,6 +1451,7 @@


        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getDeviceDirectoryConsistent)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1389,7 +1460,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1415,11 +1486,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("lalType", 1);


        Document macdzErrFilter = new Document("lalType", 2);


        Document latitudeErrFilter = new Document("lalType", 3);


        Document longitudeErrFilter = new Document("lalType", 4);




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


        dList1.add(new Document("lalType", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("lalType", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("lalType", new Document("$eq", 3)));


        setTag(params,dList3);


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


        dList4.add(new Document("lalType", new Document("$eq", 4)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);


        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


            // 构建聚合管道


@@ -1442,6 +1524,7 @@


        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getFaceInformationCollectionAccuracy)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1450,7 +1533,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1476,10 +1559,22 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("lalType", 1);


        Document macdzErrFilter = new Document("lalType", 2);


        Document latitudeErrFilter = new Document("lalType", 3);


        Document longitudeErrFilter = new Document("lalType", 4);


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


        dList1.add(new Document("lalType", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("lalType", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("lalType", new Document("$eq", 3)));


        setTag(params,dList3);


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


        dList4.add(new Document("lalType", new Document("$eq", 4)));


        setTag(params,dList4);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document latitudeErrFilter = new Document("$and", dList3);


        Document longitudeErrFilter = new Document("$and", dList4);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -1503,6 +1598,7 @@


        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getFacePictureQualification)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1511,7 +1607,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1537,9 +1633,18 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("snapResult", 1);


        Document macdzErrFilter = new Document("snapResult", 2);


        Document longitudeErrFilter = new Document("snapResult", 4);


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


        dList1.add(new Document("snapResult", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("snapResult", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("snapResult", new Document("$eq", 4)));


        setTag(params,dList3);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document longitudeErrFilter = new Document("$and", dList3);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -1563,6 +1668,7 @@


        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getFaceTimingAccuracy)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1571,7 +1677,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1597,9 +1703,18 @@


        MongoDatabase database = mongoTemplate.getDb();


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




        Document ipErrFilter = new Document("snapResult", 1);


        Document macdzErrFilter = new Document("snapResult", 2);


        Document longitudeErrFilter = new Document("snapResult", 4);


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


        dList1.add(new Document("snapResult", new Document("$eq", 1)));


        setTag(params,dList1);


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


        dList2.add(new Document("snapResult", new Document("$eq", 2)));


        setTag(params,dList2);


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


        dList3.add(new Document("snapResult", new Document("$eq", 4)));


        setTag(params,dList3);


        Document ipErrFilter = new Document("$and", dList1);


        Document macdzErrFilter = new Document("$and", dList2);


        Document longitudeErrFilter = new Document("$and", dList3);




        List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter);


        List<String> rList = lists.stream().map(filter -> {


@@ -1623,6 +1738,7 @@


        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getFaceUploadTimeliness)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1631,7 +1747,7 @@


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


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


        }


        rList.add(onlineRate + "%");


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


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


        map.put("count", rList);


        map.put("list", resultList);


@@ -1657,6 +1773,7 @@


        Date now = new Date();


        List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())


                .select(CheckIndexFace::getFacePictureAvailability)


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


                .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))


                .list();


        BigDecimal onlineRate = BigDecimal.ZERO;


@@ -1665,8 +1782,9 @@


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


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


        }




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


        map.put("count", Arrays.asList(onlineRate + "%"));


        map.put("count", Arrays.asList(this.remove0(onlineRate)));


        map.put("list", resultList);


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


    }


@@ -1688,4 +1806,27 @@


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


        }


    }


}