mongodb加索引注解

xiangpei

2024-08-02 9814046268f11b43fc674142db0fb3b690c3fbaf

mongodb加索引注解

 ycl-pojo/src/main/java/com/ycl/platform/domain/query/DataCenterQuery.java

New file
@@ -0,0 +1,26 @@
package com.ycl.platform.domain.query;

import com.ycl.platform.base.AbsQuery;
import lombok.Data;

import java.util.Date;

/**
 * 数据中心查询
 *
 * @author：xp
 * @date：2024/7/31 17:06
 */
@Data
public class DataCenterQuery extends AbsQuery {

    /** 开始时间 */
    private Date startTime;

    /** 结束时间 */
    private Date endTime;

    /** 关键词 */
    private String keyword;

}

 ycl-pojo/src/main/java/com/ycl/platform/domain/query/DateCenterQuery.java

File was deleted

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/AttrRecognitionMonitorResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -21,11 +22,13 @@
    /**
     * 设备或卡口国标编码
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 设备或卡口名称
     */
    @TextIndexed
    private String deviceName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CarDetectResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,11 +17,13 @@
    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织区域
     */
    @TextIndexed
    private String orgName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CodeByAreaResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,11 +17,13 @@
    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织名称
     */
    @TextIndexed
    private String orgName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CoordinateByAreaResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,11 +17,13 @@
    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织名称
     */
    @TextIndexed
    private String orgName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CrossDetailResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,21 +17,25 @@
    /**
     * 组织编号，用于查询该组织及其所有下级组织卡口异常情况。若不传，返回所有卡口异常详情。
     */
    @TextIndexed
    private String orgCode;

    /**
     * 采集设备内码，用于标识特定的采集设备。
     */
    @TextIndexed
    private String indexCode;

    /**
     * 国标编码（外码），用于标准化标识采集设备。
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 卡口名称，用于描述或标识卡口。
     */
    @TextIndexed
    private String crossName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/DataIntegrityMonitoringResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,21 +17,25 @@
    /**
     * 卡口内码或采集设备内码，dataType为1时表示卡口内码，dataType为11时表示采集设备内码
     */
    @TextIndexed
    private String indexCode;

     /**
     * 设备或卡口国标编码
     */
     @TextIndexed
    private String externalIndexCode;

    /**
     * 设备或卡口名称
     */
    @TextIndexed
    private String deviceName;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/FaceDetectResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,11 +17,13 @@
    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织区域
     */
    @TextIndexed
    private String orgName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/FaceDeviceInspectionResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,31 +17,37 @@
    /**
     * 设备名称
     */
    @TextIndexed
    private String deviceName;

    /**
     * 设备编号
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 卡口内码或采集设备内码，dataType为1时表示卡口内码，dataType为2或11时表示采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * IP地址
     */
    @TextIndexed
    private String networkAddr;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织名称
     */
    @TextIndexed
    private String orgName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/FaceDeviceSamplingResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,31 +17,37 @@
    /**
     * 设备名称
     */
    @TextIndexed
    private String deviceName;

    /**
     * 卡口内码或采集设备内码，dataType为1时表示卡口内码，dataType为2或11时表示采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * 设备或卡口国标编码
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * IP地址
     */
    @TextIndexed
    private String networkAddr;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织名称
     */
    @TextIndexed
    private String orgName;

    // 以下为嵌套对象的字段

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/MonitorResourceResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

import java.util.List;
@@ -29,11 +30,13 @@
        /**
         * 名称
         */
        @TextIndexed
        private String monitorName;

        /**
         * 编号
         */
        @TextIndexed
        private String monitorCode;

        /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/MonitoringDetailResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,21 +17,25 @@
    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * 国标编码（外码）
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 采集设备名称
     */
    @TextIndexed
    private String cameraName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/OrganizationTreeResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

import java.util.List;
@@ -30,11 +31,13 @@
        /**
         * 组织编号
         */
        @TextIndexed
        private String orgCode;

        /**
         * 组织名称
         */
        @TextIndexed
        private String orgName;

        /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/PicAccessResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,21 +17,25 @@
    /**
     * 数据类型为1时表示卡口内码，数据类型为2或11时表示人脸采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * 设备或卡口国标编码
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 设备或卡口名称
     */
    @TextIndexed
    private String deviceName;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/SnapshotDataMonitorResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -19,21 +20,25 @@
    /**
     * dataType为1：卡口内码   dataType为2或11：采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * 设备或卡口国标编码
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 设备或卡口名称
     */
    @TextIndexed
    private String deviceName;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/SnapshotDelayMonitorResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -12,25 +13,31 @@
@Data
@Document(collection = "hk_snapshop_delay_monitor")
public class SnapshotDelayMonitorResult extends BaseResult {

    private Integer dataType;

    /**
     * dataType为1：卡口内码   dataType为2或11：采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * 设备或卡口国标编码
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 设备或卡口名称
     */
    @TextIndexed
    private String deviceName;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/VehicleDeviceInspectionResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,27 +17,32 @@
    /**
     * 设备编号，dataType为1时表示卡口内码，dataType为11时表示采集设备内码
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 设备名称
     */
    @TextIndexed
    private String deviceName;


    /**
     * 卡口内码或采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织名称
     */
    @TextIndexed
    private String orgName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/VehicleDeviceSamplingResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -16,26 +17,31 @@
    /**
     * 卡口内码或采集设备内码，dataType为1时表示卡口内码，dataType为11时表示采集设备内码
     */
    @TextIndexed
    private String indexCode;

    /**
     * 设备或卡口国标编码
     */
    @TextIndexed
    private String externalIndexCode;

    /**
     * 设备或卡口名称
     */
    @TextIndexed
    private String deviceName;

    /**
     * 组织编号
     */
    @TextIndexed
    private String orgCode;

    /**
     * 组织名称
     */
    @TextIndexed
    private String orgName;

    // 以下为嵌套对象的字段

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OneMachineFileResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

import java.util.Date;
@@ -19,16 +20,19 @@
    /**
     * 设备编码，20位：中心编码、行业编码、设备类型、网络标识、设备序号，与联网平台/共享平台国标编码一致。
     */
    @TextIndexed
    private String SBBM;

    /**
     * 设备名称，标识设备的基本名称。命名方式参照《GAT751-2008视频图像文字标注规范》。
     */
    @TextIndexed
    private String SBMC;

    /**
     * 摄像机采集区域（参考文档解析）
     */
    @TextIndexed
    private String SXJCJQY;

    /**
@@ -40,6 +44,7 @@
    /**
     * IPV4地址，摄像机IP地址。
     */
    @TextIndexed
    private String IP;

    /**
@@ -65,6 +70,7 @@
    /**
     * MAC地址，摄像机MAC地址。
     */
    @TextIndexed
    private String MACDZ;

    /**
@@ -77,6 +83,7 @@
    /**
     * 设备厂商，编码1-海康威视；2-大华；3-天地伟业；4-科达；5-安讯士；6-博世；7-亚安；8-英飞拓；9-宇视；10-海信；11-中星电子；12-明景；13-联想；14-中兴；99-其他。
     */
    @TextIndexed
    private String SBCS;

    /**
@@ -92,6 +99,7 @@
    /**
     * 点位俗称，监控点位附近如有标志性建筑、场所或监控点位处于公众约定俗成的地点，可以填写标志性建设名称和地点俗称。
     */
    @TextIndexed
    private String DWSC;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OnlineResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -22,6 +23,7 @@
    /**
     * 行政区划名称
     */
    @TextIndexed
    private String arealayernoName;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OsdMonitorResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

import java.util.List;
@@ -19,11 +20,13 @@
    /**
     * 区域路径信息
     */
    @TextIndexed
    private String arealayerPath;

    /**
     * 区域名称
     */
    @TextIndexed
    private String arealayername;

    /**
@@ -34,11 +37,13 @@
    /**
     * 设备 ID
     */
    @TextIndexed
    private String deviceId;

    /**
     * 设备名称
     */
    @TextIndexed
    private String deviceName;

    /**
@@ -54,6 +59,7 @@
    /**
     * IP 地址
     */
    @TextIndexed
    private String ip;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/QueryVqdResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -21,6 +22,7 @@
    /**
     * 行政区划名称
     */
    @TextIndexed
    private String arealayernoName;
    /**
     *
@@ -61,10 +63,12 @@
    /**
     * 设备 IP
     */
    @TextIndexed
    private String deviceIp;
    /**
     * 设备名称
     */
    @TextIndexed
    private String deviceName;
    /**
     *

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/RecordMetaDSumResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

import java.util.Date;
@@ -18,6 +19,7 @@
    /**
     * 行政区域名称
     */
    @TextIndexed
    private String arealayername;

    /**
@@ -38,6 +40,7 @@
    /**
     * 摄像机名称
     */
    @TextIndexed
    private String deviceName;

    /**
@@ -53,6 +56,7 @@
    /**
     * 国标平台ID
     */
    @TextIndexed
    private String platId;

    /**

 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/VideoQualityResult.java

@@ -2,6 +2,7 @@

import com.ycl.platform.domain.result.BaseResult;
import lombok.Data;
import org.springframework.data.mongodb.core.index.TextIndexed;
import org.springframework.data.mongodb.core.mapping.Document;

/**
@@ -10,60 +11,91 @@
@Data
@Document(collection = "uy_video_quality")
public class VideoQualityResult extends BaseResult {

    /** 行政区划编码 */
    private String arealayernoCode;

    /** 行政区划名称 */
    @TextIndexed
    private String arealayernoName;

    /** 模糊 */
    private Integer blur;

    /** 模糊原始分值 */
    private Integer blurRaw;

    /** 颜色 */
    private Integer color;

    /** 颜色原始分值 */
    private Integer colorRaw;

    /** 摄像机-国标id */
    private String deviceId;

    /** 摄像机ip */
    @TextIndexed
    private String deviceIp;

    /** 摄像机设备名称 */
    @TextIndexed
    private String deviceName;

    /** 统计纬度 */
    private String dim;

    /** 图像是否正常 -1：异常，1正常，0：未诊断*/
    private Integer isImgAbnormal;

    /** 信号是否丢失 -1：异常，1正常，0：未诊断*/
    private Integer isSignalMiss;

    /** 亮度 */
    private Integer light;

    /** 亮度原始分值 */
    private Integer lightRaw;

    /** 遮挡 */
    private Integer shade;

    /** 遮挡原始分值 */
    private Integer shadeRaw;

    /** 抖动 */
    private Integer shake;

    /** 抖动原始分值 */
    private Integer shakeRaw;

    /** 无信号 */
    private Integer signal;

    /** 无信号原始分值 */
    private Integer signalRaw;

    /** 雪花 */
    private Integer snow;

    /** 雪花原始分值 */
    private Integer snowRaw;

    /** 排序属性 */
    private String sortFiled;

    /** 诊断状态编码 -1：异常，1：正常，0：未诊断 */
    private String status;

    /** 诊断状态名称 */
    private String statusName;

    /** 条纹 */
    private Integer stripe;

    /** 条纹原始分值 */
    private Integer stripeRaw;

    /** 诊断时间 */
    private String vqdTime;
}

 ycl-server/src/main/java/com/ycl/config/MongoInit.java

New file
@@ -0,0 +1,59 @@
//package com.ycl.config;
//
//import com.mongodb.client.ListIndexesIterable;
//import com.mongodb.client.MongoCollection;
//import org.bson.Document;
//import org.springframework.boot.context.event.ApplicationReadyEvent;
//import org.springframework.context.event.EventListener;
//import org.springframework.data.mongodb.core.MongoTemplate;
//import org.springframework.stereotype.Component;
//
//import java.util.concurrent.atomic.AtomicReference;
//
///**
// * @author：xp
// * @date：2024/8/2 13:54
// */
//@Component
//public class MongoInit {
//
//    /**
//     * springboot启动时创建mongo的索引
//     *
//     * @param testEvent
//     */
//    @EventListener(classes = {ApplicationReadyEvent.class})
//    public void createIndex(ApplicationReadyEvent testEvent) {
//        MongoTemplate mongo = testEvent.getApplicationContext().getBean(MongoTemplate.class);
//        MongoCollection<Document> coll = mongo.getCollection("aa");
//
//
//    }
//
//    /**
//     * 检查没有索引就创建
//     *
//     * @param mongo mongodb实例
//     * @param collectionName mongodb集合名称
//     */
//    private void exitAndCreate(MongoTemplate mongo, String collectionName) {
//        // 获取集合
//        MongoCollection<Document> collection = mongo.getCollection("yourCollectionName");
//
//        // 创建一个全文索引，这里索引所有字符串字段
//        Document createIndex = new Document("$**", "text");
//        // 设置语言
//        createIndex.append("default_language", "chinese");
//        ListIndexesIterable<Document> indexes = collection.listIndexes();
//        AtomicReference<Boolean> exit = new AtomicReference<>(Boolean.FALSE);
//        indexes.forEach(index -> {
//            if (createIndex.equals(index)) {
//                exit.set(Boolean.TRUE);
//            }
//        });
//        if (! exit.get()) {
//            collection.createIndex(createIndex);
//        }
//    }
//
//}

 ycl-server/src/main/java/com/ycl/platform/service/DataCenterService.java

@@ -1,6 +1,6 @@
package com.ycl.platform.service;

import com.ycl.platform.domain.query.DateCenterQuery;
import com.ycl.platform.domain.query.DataCenterQuery;
import com.ycl.platform.domain.result.HK.*;
import com.ycl.platform.domain.result.UY.RecordMetaDSumResult;
import com.ycl.platform.domain.vo.TMonitorVO;
@@ -8,6 +8,8 @@
import java.util.List;

/**
 * 数据中心接口
 *
 * @author：xp
 * @date：2024/8/1 16:42
 */
@@ -20,7 +22,7 @@
     * @return
     */
    // TODO 返回数据对象更换
    List<TMonitorVO> videoPointOnlineRate(DateCenterQuery query);
    List<TMonitorVO> videoPointOnlineRate(DataCenterQuery query);

    /**
     * 视频：一机一档注册率
@@ -28,7 +30,7 @@
     * @param query
     * @return
     */
    List<TMonitorVO> videoOneMachineDocumentRegister(DateCenterQuery query);
    List<TMonitorVO> videoOneMachineDocumentRegister(DataCenterQuery query);

    /**
     * 视频：一机一档合格率
@@ -36,7 +38,7 @@
     * @param query
     * @return
     */
    List<TMonitorVO> videoOneMachineDocumentQualified(DateCenterQuery query);
    List<TMonitorVO> videoOneMachineDocumentQualified(DataCenterQuery query);

    /**
     * 视频：档案考核比
@@ -44,7 +46,7 @@
     * @param query
     * @return
     */
    List<TMonitorVO> videoAssessmentFileRatio(DateCenterQuery query);
    List<TMonitorVO> videoAssessmentFileRatio(DataCenterQuery query);

    /**
     * 视频：录像可用率
@@ -52,7 +54,7 @@
     * @param query
     * @return
     */
    List<RecordMetaDSumResult> videoAvailabilityRate(DateCenterQuery query);
    List<RecordMetaDSumResult> videoAvailabilityRate(DataCenterQuery query);

    /**
     * 视频：重点点位录像可用率
@@ -60,7 +62,7 @@
     * @param query
     * @return
     */
    List<RecordMetaDSumResult> videoImportantPointAvailabilityRate(DateCenterQuery query);
    List<RecordMetaDSumResult> videoImportantPointAvailabilityRate(DataCenterQuery query);

    /**
     * 视频：标注正确率
@@ -69,7 +71,7 @@
     * @return
     */
    // TODO 返回数据对象更换
    List<TMonitorVO> videoLabelingAccuracy(DateCenterQuery query);
    List<TMonitorVO> videoLabelingAccuracy(DataCenterQuery query);

    /**
     * 视频：重点点位标注正确率
@@ -78,7 +80,7 @@
     * @return
     */
    // TODO 返回数据对象更换
    List<TMonitorVO> videoImportantPointLabelingAccuracy(DateCenterQuery query);
    List<TMonitorVO> videoImportantPointLabelingAccuracy(DataCenterQuery query);

    /**
     * 视频：校时正确率
@@ -87,7 +89,7 @@
     * @return
     */
    // TODO 返回数据对象更换
    List<TMonitorVO> videoCheckTimeAccuracy(DateCenterQuery query);
    List<TMonitorVO> videoCheckTimeAccuracy(DataCenterQuery query);

    /**
     * 视频：重点点位校时正确率
@@ -96,7 +98,7 @@
     * @return
     */
    // TODO 返回数据对象更换
    List<TMonitorVO> videoImportantPointCheckTimeAccuracy(DateCenterQuery query);
    List<TMonitorVO> videoImportantPointCheckTimeAccuracy(DataCenterQuery query);

    /**
     * 视频：重点点位在线率
@@ -105,7 +107,7 @@
     * @return
     */
    // TODO 返回数据对象更换
    List<TMonitorVO> videoImportantPointOnlineRate(DateCenterQuery query);
    List<TMonitorVO> videoImportantPointOnlineRate(DataCenterQuery query);

    /**
     * 视频：重点指挥图像在线率
@@ -114,7 +116,7 @@
     * @return
     */
    // TODO 返回数据对象更换
    List<TMonitorVO> videoImportantPointImageOnlineRate(DateCenterQuery query);
    List<TMonitorVO> videoImportantPointImageOnlineRate(DataCenterQuery query);



@@ -126,7 +128,7 @@
     * @param query
     * @return
     */
    List<SnapshotDataMonitorResult> vehicleViewDockStable(DateCenterQuery query);
    List<SnapshotDataMonitorResult> vehicleViewDockStable(DataCenterQuery query);

    /**
     * 车辆：点位在线率
@@ -134,7 +136,7 @@
     * @param query
     * @return
     */
    List<SnapshotDataMonitorResult> vehiclePointOnlineRate(DateCenterQuery query);
    List<SnapshotDataMonitorResult> vehiclePointOnlineRate(DataCenterQuery query);

    /**
     * 车辆：互联网卡口设备目录一致性
@@ -142,7 +144,7 @@
     * @param query
     * @return
     */
    List<TMonitorVO> vehicleNetDeviceDirectoryConsistency(DateCenterQuery query);
    List<TMonitorVO> vehicleNetDeviceDirectoryConsistency(DataCenterQuery query);

    /**
     * 车辆：车辆卡口信息采集准确率
@@ -150,7 +152,7 @@
     * @param query
     * @return
     */
    List<CrossDetailResult> vehicleCollectionConsistency(DateCenterQuery query);
    List<CrossDetailResult> vehicleCollectionConsistency(DataCenterQuery query);

    /**
     * 车辆：车辆卡口设备抓拍数据完整性
@@ -158,7 +160,7 @@
     * @param query
     * @return
     */
    List<DataIntegrityMonitoringResult> vehicleCollectionDataIntegrity(DateCenterQuery query);
    List<DataIntegrityMonitoringResult> vehicleCollectionDataIntegrity(DataCenterQuery query);

    /**
     * 车辆：车辆卡口设备抓拍数据准确性
@@ -166,7 +168,7 @@
     * @param query
     * @return
     */
    List<AttrRecognitionMonitorResult> vehicleCollectionDataCaptured(DateCenterQuery query);
    List<AttrRecognitionMonitorResult> vehicleCollectionDataCaptured(DataCenterQuery query);

    /**
     * 车辆：车辆卡口设备时钟准确性
@@ -174,7 +176,7 @@
     * @param query
     * @return
     */
    List<VehicleDeviceInspectionResult> vehicleClockAccuracy(DateCenterQuery query);
    List<VehicleDeviceInspectionResult> vehicleClockAccuracy(DataCenterQuery query);

    /**
     * 车辆：车辆卡口设备抓拍数据上传及时性
@@ -182,7 +184,7 @@
     * @param query
     * @return
     */
    List<SnapshotDelayMonitorResult> vehicleTimelyUploadAccuracy(DateCenterQuery query);
    List<SnapshotDelayMonitorResult> vehicleTimelyUploadAccuracy(DataCenterQuery query);

    /**
     * 车辆：车辆卡口设备url可用性
@@ -190,7 +192,7 @@
     * @param query
     * @return
     */
    List<PicAccessResult> vehicleUrlAccuracy(DateCenterQuery query);
    List<PicAccessResult> vehicleUrlAccuracy(DataCenterQuery query);

    /**
     * 车辆：车辆卡口设备抓拍数据大图可用性
@@ -198,7 +200,7 @@
     * @param query
     * @return
     */
    List<VehicleDeviceSamplingResult> vehicleBigImgAccuracy(DateCenterQuery query);
    List<VehicleDeviceSamplingResult> vehicleBigImgAccuracy(DataCenterQuery query);



@@ -214,7 +216,7 @@
     * @param query
     * @return
     */
    List<SnapshotDataMonitorResult> faceViewDockStable(DateCenterQuery query);
    List<SnapshotDataMonitorResult> faceViewDockStable(DataCenterQuery query);

    /**
     * 人脸：点位在线率
@@ -223,7 +225,7 @@
     * @return
     */
    // TODO 更换响应结果
    List<TMonitorVO> facePointOnlineRate(DateCenterQuery query);
    List<TMonitorVO> facePointOnlineRate(DataCenterQuery query);

    /**
     * 人脸：目录一致率
@@ -231,7 +233,7 @@
     * @param query
     * @return
     */
    List<TMonitorVO> faceDirectoryConsistency(DateCenterQuery query);
    List<TMonitorVO> faceDirectoryConsistency(DataCenterQuery query);

    /**
     * 人脸：人脸卡口信息采集准确率
@@ -239,7 +241,7 @@
     * @param query
     * @return
     */
    List<CrossDetailResult> faceCollectionConsistency(DateCenterQuery query);
    List<CrossDetailResult> faceCollectionConsistency(DataCenterQuery query);

    /**
     * 人脸：设备抓拍图片合格性
@@ -247,7 +249,7 @@
     * @param query
     * @return
     */
    List<MonitoringDetailResult> faceImgQualification(DateCenterQuery query);
    List<MonitoringDetailResult> faceImgQualification(DataCenterQuery query);

    /**
     * 人脸：设备抓拍图片时钟准确性
@@ -255,7 +257,7 @@
     * @param query
     * @return
     */
    List<FaceDeviceInspectionResult> faceCapturesImagesAccuracy(DateCenterQuery query);
    List<FaceDeviceInspectionResult> faceCapturesImagesAccuracy(DataCenterQuery query);

    /**
     * 人脸：抓拍人脸数据上传及时性
@@ -263,7 +265,7 @@
     * @param query
     * @return
     */
    List<FaceDeviceInspectionResult> faceTimelyUpload(DateCenterQuery query);
    List<FaceDeviceInspectionResult> faceTimelyUpload(DataCenterQuery query);

    /**
     * 人脸：人脸卡口设备抓拍数据大图可用性
@@ -271,5 +273,5 @@
     * @param query
     * @return
     */
    List<FaceDeviceSamplingResult> faceAvailabilityOfLargeImg(DateCenterQuery query);
    List<FaceDeviceSamplingResult> faceAvailabilityOfLargeImg(DataCenterQuery query);
}

 ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java

New file
@@ -0,0 +1,375 @@
package com.ycl.platform.service.impl;

import com.ycl.platform.domain.query.DataCenterQuery;
import com.ycl.platform.domain.result.HK.*;
import com.ycl.platform.domain.result.UY.RecordMetaDSumResult;
import com.ycl.platform.domain.vo.TMonitorVO;
import com.ycl.platform.service.DataCenterService;
import lombok.RequiredArgsConstructor;
import org.springframework.data.mongodb.core.MongoTemplate;
import org.springframework.data.mongodb.core.query.Criteria;
import org.springframework.data.mongodb.core.query.Query;
import org.springframework.stereotype.Service;

import java.util.List;

/**
 * 数据中心接口
 *
 * @author：xp
 * @date：2024/8/2 11:07
 */
@Service
@RequiredArgsConstructor
public class DataCenterServiceImpl implements DataCenterService {

    private final MongoTemplate mongoTemplate;

    /**
     * 视频：点位在线率
     *
     * @param query
     * @return
     */
    @Override
    public List<TMonitorVO> videoPointOnlineRate(DataCenterQuery query) {

        return null;
    }

    /**
     * 视频：一机一档注册率
     *
     * @param query
     * @return
     */
    @Override
    public List<TMonitorVO> videoOneMachineDocumentRegister(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：一机一档合格率
     *
     * @param query
     * @return
     */
    @Override
    public List<TMonitorVO> videoOneMachineDocumentQualified(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：档案考核比
     *
     * @param query
     * @return
     */
    @Override
    public List<TMonitorVO> videoAssessmentFileRatio(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：录像可用率
     *
     * @param query
     * @return
     */
    @Override
    public List<RecordMetaDSumResult> videoAvailabilityRate(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：重点点位录像可用率
     *
     * @param query
     * @return
     */
    @Override
    public List<RecordMetaDSumResult> videoImportantPointAvailabilityRate(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：标注正确率
     *
     * @param query
     * @return
     */
    // TODO 返回数据对象更换
    @Override
    public List<TMonitorVO> videoLabelingAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：重点点位标注正确率
     *
     * @param query
     * @return
     */
    // TODO 返回数据对象更换
    @Override
    public List<TMonitorVO> videoImportantPointLabelingAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：校时正确率
     *
     * @param query
     * @return
     */
    // TODO 返回数据对象更换
    @Override
    public List<TMonitorVO> videoCheckTimeAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：重点点位校时正确率
     *
     * @param query
     * @return
     */
    // TODO 返回数据对象更换
    @Override
    public List<TMonitorVO> videoImportantPointCheckTimeAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：重点点位在线率
     *
     * @param query
     * @return
     */
    // TODO 返回数据对象更换
    @Override
    public List<TMonitorVO> videoImportantPointOnlineRate(DataCenterQuery query) {
        return null;
    }

    /**
     * 视频：重点指挥图像在线率
     *
     * @param query
     * @return
     */
    // TODO 返回数据对象更换
    @Override
    public List<TMonitorVO> videoImportantPointImageOnlineRate(DataCenterQuery query) {
        return null;
    }




    /**
     * 车辆：视图库对接稳定性
     *
     * @param query
     * @return
     */
    @Override
    public List<SnapshotDataMonitorResult> vehicleViewDockStable(DataCenterQuery query) {
        //
        Criteria criteria = new Criteria().andOperator(
                Criteria.where("name").is("xp"),
                Criteria.where("age").lte(50)
        );
        List<SnapshotDataMonitorResult> ts = mongoTemplate.find(Query.query(criteria), SnapshotDataMonitorResult.class);

        return null;
    }

    /**
     * 车辆：点位在线率
     *
     * @param query
     * @return
     */
    @Override
    public List<SnapshotDataMonitorResult> vehiclePointOnlineRate(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：互联网卡口设备目录一致性
     *
     * @param query
     * @return
     */
    @Override
    public List<TMonitorVO> vehicleNetDeviceDirectoryConsistency(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：车辆卡口信息采集准确率
     *
     * @param query
     * @return
     */
    @Override
    public List<CrossDetailResult> vehicleCollectionConsistency(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：车辆卡口设备抓拍数据完整性
     *
     * @param query
     * @return
     */
    @Override
    public List<DataIntegrityMonitoringResult> vehicleCollectionDataIntegrity(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：车辆卡口设备抓拍数据准确性
     *
     * @param query
     * @return
     */
    @Override
    public List<AttrRecognitionMonitorResult> vehicleCollectionDataCaptured(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：车辆卡口设备时钟准确性
     *
     * @param query
     * @return
     */
    @Override
    public List<VehicleDeviceInspectionResult> vehicleClockAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：车辆卡口设备抓拍数据上传及时性
     *
     * @param query
     * @return
     */
    @Override
    public List<SnapshotDelayMonitorResult> vehicleTimelyUploadAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：车辆卡口设备url可用性
     *
     * @param query
     * @return
     */
    @Override
    public List<PicAccessResult> vehicleUrlAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 车辆：车辆卡口设备抓拍数据大图可用性
     *
     * @param query
     * @return
     */
    @Override
    public List<VehicleDeviceSamplingResult> vehicleBigImgAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：视图库对接稳定性
     *
     * @param query
     * @return
     */
    @Override
    public List<SnapshotDataMonitorResult> faceViewDockStable(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：点位在线率
     *
     * @param query
     * @return
     */
    // TODO 更换响应结果
    @Override
    public List<TMonitorVO> facePointOnlineRate(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：目录一致率
     *
     * @param query
     * @return
     */
    @Override
    public List<TMonitorVO> faceDirectoryConsistency(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：人脸卡口信息采集准确率
     *
     * @param query
     * @return
     */
    @Override
    public List<CrossDetailResult> faceCollectionConsistency(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：设备抓拍图片合格性
     *
     * @param query
     * @return
     */
    @Override
    public List<MonitoringDetailResult> faceImgQualification(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：设备抓拍图片时钟准确性
     *
     * @param query
     * @return
     */
    @Override
    public List<FaceDeviceInspectionResult> faceCapturesImagesAccuracy(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：抓拍人脸数据上传及时性
     *
     * @param query
     * @return
     */
    @Override
    public List<FaceDeviceInspectionResult> faceTimelyUpload(DataCenterQuery query) {
        return null;
    }

    /**
     * 人脸：人脸卡口设备抓拍数据大图可用性
     *
     * @param query
     * @return
     */
    @Override
    public List<FaceDeviceSamplingResult> faceAvailabilityOfLargeImg(DataCenterQuery query) {
        return null;
    }
}