ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/QueryVqdParam.java
New file @@ -0,0 +1,136 @@ package com.ycl.platform.domain.param.UY; import lombok.Data; import lombok.experimental.Accessors; /** * 图像检测诊断结果 */ @Data @Accessors(chain = true) public class QueryVqdParam { /** * 租户id */ private String tenantId; /** * 行政区域编码 */ private String arealayerno; /** * 模糊 1:正常 0：未知 -1：异常 */ private String blur; /** * 颜色 1:正常 0：未知 -1：异常 */ private String color; /** * 摄像机国标ID */ private String deviceId; /** * 摄像机名称 */ private String deviceName; /** * 排序方式 可选值为 desc：倒序排序 asc：正序排序 默认倒序排序 */ private String direction; /** * 0：实时码流诊断 1：历史码流诊断 */ private Integer groupFlag; /** * 诊断分组ID */ private String groupId; /** * 图像质量状态 1:正常 0：未知 -1：异常 */ private String imgStatus; /** * 亮度 1:正常 0：未知 -1：异常 */ private String light; /** * 在线状态 1:在线 0：未知 -1：离线 */ private String onlineStatus; /** * 分页页码,默认从1开始 */ private Integer pageNum; /** * 分页大小,默认1000 */ private Integer pageSize; /** * 国标平台ID */ private String platId; /** * 遮挡 1:正常 0：未知 -1：异常 */ private String shade; /** * 抖动 1:正常 0：未知 -1：异常 */ private String shake; /** * 无信号 1:有信号 0：未知 -1：无信号 */ private String signal; /** * 信号状态 1:有信号 0：未知 -1：无信号 */ private String signalStatus; /** * 雪花 1:正常 0：未知 -1：异常 */ private String snow; /** * 排序的字段 按指定字段排序 默认按拉码流时间排序 */ private String sortedField; /** * 条纹 1:正常 0：未知 -1：异常 */ private String stripe; /** * 诊断任务创建时间 */ private String taskCreateTime; /** * 诊断任务复核时间 */ private String taskRecheckTime; /** * 视频诊断状态 */ private String videoDiagStatus; /** * 视频流诊断开始时间 */ private String videoDiagTimeBegin; /** * 视频流诊断结束时间 */ private String videoDiagTimeEnd; /** * 获取视频流状态 */ private String videoGetStatus; /** * 视频流获取时间开始时间 */ private String videoGetTimeBegin; /** * 视频流获取时间结束时间 */ private String videoGetTimeEnd; /** * 是否需要分页返回结果，当为true时pageSize和pageNum参数失效 */ private Boolean withOutPaging; } ycl-pojo/src/main/java/com/ycl/platform/domain/param/UY/VideoQualityParam.java
New file @@ -0,0 +1,31 @@ package com.ycl.platform.domain.param.UY; import lombok.Data; import lombok.experimental.Accessors; /** * 视频图像质量 */ @Data @Accessors(chain = true) public class VideoQualityParam { /** 区域编码 */ private String arealayerno; private Object[] dbConditionItems; /** 设备 ID */ private String deviceId; /** 设备名称 */ private String deviceName; /** 动态条件 */ private String dynamicConditionJson; /** 排序字段 */ private String field; /** 排序方式，desc: 降序, asc: 升序 */ private String order; /** 分页页码 */ private Integer pageNum; /** 分页大小 */ private Integer pageSize; /** 状态 */ private Integer status; } ycl-pojo/src/main/java/com/ycl/platform/domain/result/BaseResult.java
File was renamed from ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/BaseResult.java @@ -1,4 +1,4 @@ package com.ycl.platform.domain.result.HK; package com.ycl.platform.domain.result; import lombok.Data; import org.bson.types.ObjectId; ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/AttrRecognitionMonitorResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "attr_recognition_monitor") public class AttrRecognitionMonitorResult extends BaseResult{ public class AttrRecognitionMonitorResult extends BaseResult { /** * 卡口内码或采集设备内码，dataType为1时表示卡口内码，dataType为11时表示采集设备内码 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CarDetectResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "car_detect") public class CarDetectResult extends BaseResult{ public class CarDetectResult extends BaseResult { /** * 组织编号 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CodeByAreaResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "code_by_area") public class CodeByAreaResult extends BaseResult{ public class CodeByAreaResult extends BaseResult { /** * 组织编号 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CoordinateByAreaResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "coordinate_by_area") public class CoordinateByAreaResult extends BaseResult{ public class CoordinateByAreaResult extends BaseResult { /** * 组织编号 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CriteriaResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "criteria") public class CriteriaResult extends BaseResult{ public class CriteriaResult extends BaseResult { /** * 人脸评分低标准，例如：0.4 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/CrossDetailResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "cross_detail") public class CrossDetailResult extends BaseResult{ public class CrossDetailResult extends BaseResult { /** * 组织编号，用于查询该组织及其所有下级组织卡口异常情况。若不传，返回所有卡口异常详情。 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/DataIntegrityMonitoringResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "data_integrity_monitoring") public class DataIntegrityMonitoringResult extends BaseResult{ public class DataIntegrityMonitoringResult extends BaseResult { /** * 卡口内码或采集设备内码，dataType为1时表示卡口内码，dataType为11时表示采集设备内码 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/FaceDetectResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "face_detect") public class FaceDetectResult extends BaseResult{ public class FaceDetectResult extends BaseResult { /** * 组织编号 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/FaceDeviceInspectionResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "face_device_inspection") public class FaceDeviceInspectionResult extends BaseResult{ public class FaceDeviceInspectionResult extends BaseResult { /** * 设备名称 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/FaceDeviceSamplingResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "face_device_sampling") public class FaceDeviceSamplingResult extends BaseResult{ public class FaceDeviceSamplingResult extends BaseResult { /** * 设备名称 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/MonitorResourceResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -11,7 +12,7 @@ */ @Data @Document(collection = "monitor_resource") public class MonitorResourceResult extends BaseResult{ public class MonitorResourceResult extends BaseResult { /** * 关注资源列表 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/MonitoringDetailResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "monitoring_detail") public class MonitoringDetailResult extends BaseResult{ public class MonitoringDetailResult extends BaseResult { /** * 组织编号 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/OrganizationTreeResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -12,7 +13,7 @@ */ @Data @Document(collection = "organization_tree") public class OrganizationTreeResult extends BaseResult{ public class OrganizationTreeResult extends BaseResult { /** * 组织列表 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/PicAccessResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "pic_access") public class PicAccessResult extends BaseResult{ public class PicAccessResult extends BaseResult { /** * 数据类型为1时表示卡口内码，数据类型为2或11时表示人脸采集设备内码 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/SnapshotDataMonitorResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "snapshot_data_monitor") public class SnapshotDataMonitorResult extends BaseResult{ public class SnapshotDataMonitorResult extends BaseResult { /** * 数据类型 */ ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/SnapshotDelayMonitorResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "snapshop_delay_monitor") public class SnapshotDelayMonitorResult extends BaseResult{ public class SnapshotDelayMonitorResult extends BaseResult { private Integer dataType; /** * dataType为1：卡口内码 dataType为2或11：采集设备内码 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/VehicleDeviceInspectionResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "vehicle_device_inspection") public class VehicleDeviceInspectionResult extends BaseResult{ public class VehicleDeviceInspectionResult extends BaseResult { /** * 设备编号，dataType为1时表示卡口内码，dataType为11时表示采集设备内码 ycl-pojo/src/main/java/com/ycl/platform/domain/result/HK/VehicleDeviceSamplingResult.java
@@ -1,5 +1,6 @@ package com.ycl.platform.domain.result.HK; import com.ycl.platform.domain.result.BaseResult; import lombok.Data; import org.springframework.data.mongodb.core.mapping.Document; @@ -10,7 +11,7 @@ */ @Data @Document(collection = "vehicle_device_sampling") public class VehicleDeviceSamplingResult extends BaseResult{ public class VehicleDeviceSamplingResult extends BaseResult { /** * 卡口内码或采集设备内码，dataType为1时表示卡口内码，dataType为11时表示采集设备内码 ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/CameraResult.java
@@ -1,6 +1,5 @@ package com.ycl.platform.domain.result.UY; import com.ycl.platform.domain.result.HK.BaseResult; import lombok.Data; import java.util.Date; ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OnlineResult.java
@@ -1,6 +1,5 @@ package com.ycl.platform.domain.result.UY; import com.ycl.platform.domain.result.HK.BaseResult; import lombok.Data; /** ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/OsdMonitorResult.java
@@ -1,6 +1,5 @@ package com.ycl.platform.domain.result.UY; import com.ycl.platform.domain.result.HK.BaseResult; import lombok.Data; import java.util.List; ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/QueryVqdResult.java
New file @@ -0,0 +1,246 @@ package com.ycl.platform.domain.result.UY; import lombok.Data; /** * 图像监测诊断结果 */ @Data public class QueryVqdResult { /** * */ private String arealayerPath; /** * 行政区划编码 */ private String arealayernoCode; /** * 行政区划名称 */ private String arealayernoName; /** * */ private String binaryTenantId; /** * 模糊 */ private Integer blur; /** * 模糊原始分值 */ private Integer blurRaw; /** * 模糊阈值 */ private Integer blurThreshold; /** * 颜色 */ private Integer color; /** * 颜色原始分值 */ private Integer colorRaw; /** * 颜色阈值 */ private Integer colorThreshold; /** * */ private String decodeInfo; /** * 设备 ID */ private String deviceId; /** * 设备 IP */ private String deviceIp; /** * 设备名称 */ private String deviceName; /** * */ private String extJson; /** * */ private String frameLostRate; /** * */ private String groupId; /** * */ private String id; /** * */ private Integer ifmDelay; /** * 图像地址 */ private String imagePath; /** * 图像质量状态 1:正常 0：未知 -1：异常 */ private Integer imgStatus; /** * */ private Boolean inTime; /** * 维度 */ private String latitude; /** * 亮度 */ private Integer light; /** * 亮度原始分值 */ private Integer lightRaw; /** * 亮度阈值 */ private Integer lightThreshold; /** * 经度 */ private String longitude; /** * 在线状态 1:在线 0：未知 -1：离线 */ private Integer onlineStatus; /** * */ private String originalPlatId; /** * */ private String payloadType; /** * */ private String pixelInfo; /** * 国标平台ID */ private String platId; /** * 遮挡 */ private Integer shade; /** * 遮挡原始分值 */ private Integer shadeRaw; /** * 遮挡阈值 */ private Integer shadeThreshold; /** * 抖动 */ private Integer shake; /** * 抖动原始分值 */ private Integer shakeRaw; /** * 抖动阈值 */ private Integer shakeThreshold; /** * 信号 */ private Integer signal; /** * 信号原始分值 */ private Integer signalRaw; /** * 信号状态 无信号 1:有信号 0：未知 -1：无信号 */ private Integer signalStatus; /** * 信号阈值 */ private Integer signalThreshold; /** * */ private Integer sipDelay; /** * 雪花 */ private Integer snow; /** * 雪花原始分值 */ private Integer snowRaw; /** * 雪花阈值 */ private Integer snowThreshold; /** * 条纹 */ private Integer stripe; /** * 条纹原始分值 */ private Integer stripeRaw; /** * 条纹阈值 */ private Integer stripeThreshold; /** * */ private String tags; /** * */ private String taskCreateTime; /** * */ private String taskRecheckTime; /** * */ private String tenantId; /** * */ private Integer videoDelay; /** * */ private Integer videoDiagStatus; /** * */ private String videoDiagTime; /** * */ private Integer videoGetStatus; /** * */ private String videoGetTime; /** * */ private Integer vqdAtNight; } ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/RecordMetaDSumResult.java
@@ -1,6 +1,5 @@ package com.ycl.platform.domain.result.UY; import com.ycl.platform.domain.result.HK.BaseResult; import lombok.Data; import java.util.Date; ycl-pojo/src/main/java/com/ycl/platform/domain/result/UY/VideoQualityResult.java
New file @@ -0,0 +1,66 @@ package com.ycl.platform.domain.result.UY; import lombok.Data; /** * 视频图像质量 */ @Data public class VideoQualityResult { /** 行政区划编码 */ private String arealayernoCode; /** 行政区划名称 */ private String arealayernoName; /** 模糊 */ private Integer blur; /** 模糊原始分值 */ private Integer blurRaw; /** 颜色 */ private Integer color; /** 颜色原始分值 */ private Integer colorRaw; /** 摄像机-国标id */ private String deviceId; /** 摄像机ip */ private String deviceIp; /** 摄像机设备名称 */ 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/calculate/CarSiteOnlineCalculation.java
@@ -143,6 +143,4 @@ checkIndexCar.setViewConnectStability(viewConnectStability); return checkIndexCar; } } ycl-server/src/main/java/com/ycl/feign/UYClient.java
@@ -1,10 +1,9 @@ package com.ycl.feign; import com.alibaba.fastjson2.JSONObject; import com.ycl.platform.domain.param.UY.CameraParam; import com.ycl.platform.domain.param.UY.OnlineParam; import com.ycl.platform.domain.param.UY.RecordMetaDSumParam; import com.ycl.platform.domain.param.UY.*; import org.springframework.cloud.openfeign.FeignClient; import org.springframework.cloud.openfeign.SpringQueryMap; import org.springframework.stereotype.Component; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.PostMapping; @@ -27,7 +26,7 @@ * @return 查询摄像机清单集合 */ @GetMapping("/VIID/Cameras") JSONObject cameraList(@RequestParam CameraParam cameraParam); JSONObject cameraList(@SpringQueryMap CameraParam cameraParam); /** * 点位在线 @@ -36,7 +35,7 @@ * @return 查询在线统计列表 */ @GetMapping("/openapi/v1/report/online/list") JSONObject onlineList(@RequestParam OnlineParam onlineParam); JSONObject onlineList(@SpringQueryMap OnlineParam onlineParam); /** * 录像可用 @@ -50,4 +49,21 @@ @GetMapping("/api/v1/app/osdMonitor/list") JSONObject osdMonitorList(); /** * 图像检测诊断结果 * * @param param * @return */ @GetMapping("/openapi/v1/vqdMonitor/queryVqdResult") JSONObject queryVqdResult(@SpringQueryMap QueryVqdParam param); /** * 视频图像质量 * * @param param * @return */ @GetMapping("/api/v1/app/report/vqd/detail/list") JSONObject queryVqdResult(@SpringQueryMap VideoQualityParam param); } ycl-server/src/main/java/com/ycl/task/HKTask.java
@@ -2,9 +2,8 @@ import com.alibaba.fastjson2.JSONObject; import com.mongodb.client.result.DeleteResult; import com.ycl.calculate.CalculationStrategy; import com.ycl.factory.IndexCalculationFactory; import com.ycl.platform.domain.param.HK.*; import com.ycl.platform.domain.result.BaseResult; import com.ycl.platform.domain.result.HK.*; import com.ycl.platform.service.ICheckIndexCarService; import com.ycl.platform.service.ICheckIndexFaceService; @@ -20,9 +19,7 @@ import org.springframework.data.mongodb.core.query.Query; import org.springframework.stereotype.Component; import org.springframework.util.CollectionUtils; import org.springframework.util.unit.DataUnit; import java.text.SimpleDateFormat; import java.util.Date; import java.util.List;
@@ -1,5 +1,6 @@ package com.ycl.task; import com.ycl.platform.domain.param.UY.OnlineParam; import com.ycl.platform.service.IYwThresholdService; import com.ycl.feign.UYClient; import lombok.extern.slf4j.Slf4j; @@ -49,8 +50,12 @@ } //图像监测诊断结果 public void task2() { public void queryVqdResultTask() { //点位在线率 log.info("开始执行图像监测诊断结果数据同步"); log.info("结束执行图像监测诊断结果数据同步"); } //录像可用 @@ -58,10 +63,5 @@ //录像可用率 } private String getToday() { Date date = new Date(); SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd"); String today = sdf.format(date); return today; } }
