From 1c06f123c3d29ec4d7f778dcd5de2aed05faef3d Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期三, 04 九月 2024 05:49:34 +0800 Subject: [PATCH] 视频安全资源优化 --- ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java | 1486 +++++++++++++++++++++++++++++++++++++++++------------------ 1 files changed, 1,028 insertions(+), 458 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java b/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java index 7e35095..0f70896 100644 --- a/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java +++ b/ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java @@ -1,23 +1,35 @@ package com.ycl.platform.service.impl; +import com.baomidou.mybatisplus.core.metadata.IPage; +import com.github.pagehelper.Page; +import com.github.pagehelper.PageHelper; +import com.mongodb.client.AggregateIterable; +import com.mongodb.client.MongoCollection; +import com.mongodb.client.MongoDatabase; +import com.ycl.platform.domain.entity.ImageResourceSecurityDetail; +import com.ycl.platform.domain.entity.YwPoint; import com.ycl.platform.domain.query.DataCenterQuery; import com.ycl.platform.domain.result.HK.*; -import com.ycl.platform.domain.result.UY.MonitorQualifyResult; -import com.ycl.platform.domain.result.UY.OneMachineFileResult; -import com.ycl.platform.domain.result.UY.RecordMetaDSumResult; -import com.ycl.platform.domain.result.UY.VideoOnlineResult; +import com.ycl.platform.domain.result.UY.*; +import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper; +import com.ycl.platform.mapper.YwPointMapper; import com.ycl.platform.service.DataCenterService; +import com.ycl.platform.service.YwPointService; import com.ycl.system.Result; +import com.ycl.system.page.PageUtil; import com.ycl.utils.MongoUtil; import lombok.RequiredArgsConstructor; +import org.apache.commons.collections.CollectionUtils; +import org.bson.Document; import org.springframework.data.domain.Sort; 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.data.mongodb.core.query.TextCriteria; import org.springframework.stereotype.Service; -import java.util.List; -import java.util.Objects; +import java.util.*; +import java.util.stream.Collectors; /** * 鏁版嵁涓績鎺ュ彛 @@ -30,6 +42,9 @@ public class DataCenterServiceImpl implements DataCenterService { private final MongoTemplate mongoTemplate; + private final ImageResourceSecurityDetailMapper securityDetailMapper; + private final YwPointMapper pointMapper; + private final static String TIME_FIELD = "mongoCreateTime"; @@ -41,21 +56,163 @@ */ @Override public Result videoPointOnlineRate(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<VideoOnlineResult> resultList = mongoTemplate.find(query, VideoOnlineResult.class); + // 鐢熸垚鏌ヨ + Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, null); + + // 鍏堟煡鎬绘暟鍐嶅垎椤� long total = mongoTemplate.count(query, VideoOnlineResult.class); - return Result.ok().data(resultList).total(total); + 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"); + long distinctCount = collection.distinct("deviceId", String.class).into(new ArrayList<>()).size(); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(distinctCount)); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + + /** + * 瑙嗛锛氶儴绾х偣浣嶅湪绾跨巼 + * + * @param params + * @return + */ + @Override + public Result deptVideoPointOnlineRate(DataCenterQuery params) { + // 鍏堟煡鍑洪儴绾х偣浣嶇殑鍥芥爣 + List<String> deptGBList = pointMapper.getDeptPointGB(0); + + // 鐢熸垚鏌ヨ + Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, deptGBList); + + // 鍏堟煡鎬绘暟鍐嶅垎椤� + 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("deviceId", new Document("$in", deptGBList)); + // 鏋勫缓鑱氬悎绠¢亾 + 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 鍙細浜х敓涓�涓粨鏋� + } + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(uniqueDeviceIdCount)); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + + /** + * 瑙嗛锛氶噸鐐圭偣浣嶅湪绾跨巼 + * + * @param params + * @return + */ + @Override + public Result videoImportantPointOnlineRate(DataCenterQuery params) { + // 鍏堟煡鍑洪噸鐐圭偣浣嶇殑鍥芥爣 + List<String> deptGBList = pointMapper.getDeptPointGB(1); + + Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, deptGBList); + + 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("deviceId", new Document("$in", deptGBList)); + // 鏋勫缓鑱氬悎绠¢亾 + 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 鍙細浜х敓涓�涓粨鏋� + } + +// long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), VideoOnlineResult.class); +// long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), VideoOnlineResult.class); +// long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), VideoOnlineResult.class); +// long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), VideoOnlineResult.class); +// long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), VideoOnlineResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(uniqueDeviceIdCount)); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + + /** + * 瑙嗛锛氶噸鐐规寚鎸ュ浘鍍忓湪绾跨巼 + * + * @param params + * @return + */ + @Override + public Result videoImportantPointImageOnlineRate(DataCenterQuery params) { + // 鍏堟煡鍑洪噸鐐规寚鎸ュ浘鍍忕偣浣嶇殑鍥芥爣 + List<String> deptGBList = pointMapper.getDeptPointGB(2); + + Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, deptGBList); + + 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("deviceId", new Document("$in", deptGBList)); + // 鏋勫缓鑱氬悎绠¢亾 + 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 鍙細浜х敓涓�涓粨鏋� + } + +// // 缁熻鏁� +// long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), VideoOnlineResult.class); +// long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), VideoOnlineResult.class); +// long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), VideoOnlineResult.class); +// long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), VideoOnlineResult.class); +// long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), VideoOnlineResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(uniqueDeviceIdCount)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -66,21 +223,45 @@ */ @Override public Result videoOneMachineDocumentRegister(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) + + Query query = MongoUtil.getQuery(params, "serialNumber.showValue", TIME_FIELD, null); + + long total = mongoTemplate.count(query, MonitorQualifyResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> rList = lists.stream().map(filter -> { + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$serialNumber.showValue")), + new Document("$count", "uniqueDeviceIds") ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -91,21 +272,45 @@ */ @Override public Result videoOneMachineDocumentQualified(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class); + + Query query = MongoUtil.getQuery(params, "serialNumber.showValue", TIME_FIELD, null); + long total = mongoTemplate.count(query, MonitorQualifyResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> rList = lists.stream().map(filter -> { + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$serialNumber.showValue")), + 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -116,21 +321,45 @@ */ @Override public Result videoAssessmentFileRatio(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) + // TODO 鏂板涓�寮犺〃璁板綍姣忔鐨勬。妗堣�冩牳 + Query query = MongoUtil.getQuery(params, "serialNumber.showValue", TIME_FIELD, null); + + long total = mongoTemplate.count(query, MonitorQualifyResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> rList = lists.stream().map(filter -> { + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$serialNumber.showValue")), + new Document("$count", "uniqueDeviceIds") ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -141,21 +370,91 @@ */ @Override public Result videoAvailabilityRate(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + + Query query = MongoUtil.getQuery(params, "deviceId", "createTime", null); + long total = mongoTemplate.count(query, RecordMetaDSumResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, "createTime"); + List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + + // 缁熻鏁伴噺 + MongoDatabase database = mongoTemplate.getDb(); + MongoCollection<Document> collection = database.getCollection("uy_record_meta_d_sum"); + List<Integer> status = Arrays.asList(1, 0, -1); + List<Integer> resultCount = status.stream().map(item -> { + Document filter = new Document("recordStatus", item); + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceId")), + new Document("$count", "uniqueDeviceIds") + ); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", resultCount); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + + /** + * 瑙嗛锛氶儴绾у綍鍍忓彲鐢ㄧ巼 + * + * @param params + * @return + */ + @Override + public Result deptVideoAvailabilityRate(DataCenterQuery params) { + + List<String> deptGBList = pointMapper.getDeptPointGB(0); + + Query query = MongoUtil.getQuery(params, "deviceId", "createTime", deptGBList); + + long total = mongoTemplate.count(query, RecordMetaDSumResult.class); + MongoUtil.setPage(query, params, "createTime"); + List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + + // 缁熻鏁伴噺 + MongoDatabase database = mongoTemplate.getDb(); + MongoCollection<Document> collection = database.getCollection("uy_record_meta_d_sum"); + List<Integer> status = Arrays.asList(1, 0, -1); + List<Integer> resultCount = status.stream().map(item -> { + Document filter = new Document("$and", Arrays.asList( + new Document("deviceId", new Document("$in", deptGBList)), // $in 鏉′欢 + new Document("recordStatus", item) + )); + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceId")), + new Document("$count", "uniqueDeviceIds") + ); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", resultCount); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -166,21 +465,45 @@ */ @Override public Result videoImportantPointAvailabilityRate(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + + List<String> deptGBList = pointMapper.getDeptPointGB(1); + + Query query = MongoUtil.getQuery(params, "deviceId", "createTime", deptGBList); + long total = mongoTemplate.count(query, RecordMetaDSumResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, "createTime"); + List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + + // 缁熻鏁伴噺 + MongoDatabase database = mongoTemplate.getDb(); + MongoCollection<Document> collection = database.getCollection("uy_record_meta_d_sum"); + List<Integer> status = Arrays.asList(1, 0, -1); + List<Integer> resultCount = status.stream().map(item -> { + Document filter = new Document("$and", Arrays.asList( + new Document("deviceId", new Document("$in", deptGBList)), // $in 鏉′欢 + new Document("recordStatus", item) + )); + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceId")), + new Document("$count", "uniqueDeviceIds") + ); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", resultCount); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -189,24 +512,23 @@ * @param params * @return */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 @Override public Result videoLabelingAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + + Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>()); + + long total = mongoTemplate.count(query, RecordMetaDSumResult.class); + List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), RecordMetaDSumResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), RecordMetaDSumResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), RecordMetaDSumResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), RecordMetaDSumResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), RecordMetaDSumResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(nonNetwork, network, video, car, face)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -215,24 +537,48 @@ * @param params * @return */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 @Override public Result videoImportantPointLabelingAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) + + List<String> deptGBList = pointMapper.getDeptPointGB(1); + Query query = MongoUtil.getQuery(params, "deviceNo", "checkTime", deptGBList); + + long total = mongoTemplate.count(query, OsdCheckResult.class); + MongoUtil.setPage(query, params, "checkTime"); + List<OsdCheckResult> resultList = mongoTemplate.find(query, OsdCheckResult.class); + + // 缁熻鏁伴噺 + MongoDatabase database = mongoTemplate.getDb(); + MongoCollection<Document> collection = database.getCollection("osd_check_result"); + + Document osdNameFilter = new Document("osdNameCorrect", 1); + Document osdNameErrFilter = new Document("osdNameCorrect", -1); + Document osdTimeFilter = new Document("osdTimeCorrect", 1); + Document osdTimeErrFilter = new Document("osdTimeCorrect", -1); + List<Document> lists = Arrays.asList(osdNameFilter, osdNameErrFilter, osdTimeFilter, osdTimeErrFilter); + List<Integer> rList = lists.stream().map(filter -> { + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceNo")), + new Document("$count", "uniqueDeviceIds") ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -241,24 +587,23 @@ * @param params * @return */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 @Override public Result videoCheckTimeAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); + + Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>()); + long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OneMachineFileResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OneMachineFileResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OneMachineFileResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OneMachineFileResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OneMachineFileResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(nonNetwork, network, video, car, face)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -267,79 +612,47 @@ * @param params * @return */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 @Override public Result videoImportantPointCheckTimeAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) + + List<String> deptGBList = pointMapper.getDeptPointGB(1); + + Query query = MongoUtil.getQuery(params, "deviceNo", "checkTime", deptGBList); + + long total = mongoTemplate.count(query, OsdCheckResult.class); + MongoUtil.setPage(query, params, "checkTime"); + List<OsdCheckResult> resultList = mongoTemplate.find(query, OsdCheckResult.class); + + // 缁熻鏁伴噺 + MongoDatabase database = mongoTemplate.getDb(); + MongoCollection<Document> collection = database.getCollection("osd_check_result"); + + Document osdTimeFilter = new Document("osdTimeCorrect", 1); + Document osdTimeErrFilter = new Document("osdTimeCorrect", -1); + List<Document> lists = Arrays.asList(osdTimeFilter, osdTimeErrFilter); + List<Integer> rList = lists.stream().map(filter -> { + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$deviceNo")), + new Document("$count", "uniqueDeviceIds") ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } - - /** - * 瑙嗛锛氶噸鐐圭偣浣嶅湪绾跨巼 - * - * @param params - * @return - */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 - @Override - public Result videoImportantPointOnlineRate(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); - } - - /** - * 瑙嗛锛氶噸鐐规寚鎸ュ浘鍍忓湪绾跨巼 - * - * @param params - * @return - */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 - @Override - public Result videoImportantPointImageOnlineRate(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); - } - - /** @@ -350,21 +663,44 @@ */ @Override public Result vehicleViewDockStable(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); - return Result.ok().data(resultList).total(total); + 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<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -375,21 +711,22 @@ */ @Override public Result vehiclePointOnlineRate(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); - return Result.ok().data(resultList).total(total); + 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(); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(distinctCount)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -400,21 +737,45 @@ */ @Override public Result vehicleNetDeviceDirectoryConsistency(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, MonitorQualifyResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> rList = lists.stream().map(filter -> { + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$serialNumber.showValue")), + new Document("$count", "uniqueDeviceIds") ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -425,21 +786,45 @@ */ @Override public Result vehicleCollectionConsistency(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, CrossDetailResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -450,21 +835,21 @@ */ @Override public Result vehicleCollectionDataIntegrity(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<DataIntegrityMonitoringResult> resultList = mongoTemplate.find(query, DataIntegrityMonitoringResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, DataIntegrityMonitoringResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<DataIntegrityMonitoringResult> resultList = mongoTemplate.find(query, DataIntegrityMonitoringResult.class); + + // 缁熻鏁伴噺 + MongoDatabase database = mongoTemplate.getDb(); + MongoCollection<Document> collection = database.getCollection("hk_data_integrity_monitoring"); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -475,21 +860,17 @@ */ @Override public Result vehicleCollectionDataCaptured(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<AttrRecognitionMonitorResult> resultList = mongoTemplate.find(query, AttrRecognitionMonitorResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, AttrRecognitionMonitorResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<AttrRecognitionMonitorResult> resultList = mongoTemplate.find(query, AttrRecognitionMonitorResult.class); + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -500,21 +881,45 @@ */ @Override public Result vehicleClockAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<VehicleDeviceInspectionResult> resultList = mongoTemplate.find(query, VehicleDeviceInspectionResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, VehicleDeviceInspectionResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<VehicleDeviceInspectionResult> resultList = mongoTemplate.find(query, VehicleDeviceInspectionResult.class); + + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter); + List<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -525,21 +930,17 @@ */ @Override public Result vehicleTimelyUploadAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<SnapshotDelayMonitorResult> resultList = mongoTemplate.find(query, SnapshotDelayMonitorResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, SnapshotDelayMonitorResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<SnapshotDelayMonitorResult> resultList = mongoTemplate.find(query, SnapshotDelayMonitorResult.class); + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -550,21 +951,17 @@ */ @Override public Result vehicleUrlAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<PicAccessResult> resultList = mongoTemplate.find(query, PicAccessResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, PicAccessResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<PicAccessResult> resultList = mongoTemplate.find(query, PicAccessResult.class); + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -575,21 +972,17 @@ */ @Override public Result vehicleBigImgAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<VehicleDeviceSamplingResult> resultList = mongoTemplate.find(query, VehicleDeviceSamplingResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, new ArrayList<>()); + long total = mongoTemplate.count(query, VehicleDeviceSamplingResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<VehicleDeviceSamplingResult> resultList = mongoTemplate.find(query, VehicleDeviceSamplingResult.class); + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -600,21 +993,44 @@ */ @Override public Result faceViewDockStable(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); - return Result.ok().data(resultList).total(total); + 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<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -623,24 +1039,46 @@ * @param params * @return */ - // TODO 鏇存崲鍝嶅簲缁撴灉 @Override public Result facePointOnlineRate(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); - return Result.ok().data(resultList).total(total); + 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<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -651,21 +1089,45 @@ */ @Override public Result faceDirectoryConsistency(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) + + Query query = MongoUtil.getQuery(params, "serialNumber.showValue", TIME_FIELD, null); + + long total = mongoTemplate.count(query, MonitorQualifyResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<MonitorQualifyResult> resultList = mongoTemplate.find(query, MonitorQualifyResult.class); + +// 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> rList = lists.stream().map(filter -> { + // 鏋勫缓鑱氬悎绠¢亾 + List<Document> pipeline = Arrays.asList( + new Document("$match", filter), + // $group 鍘婚噸 + new Document("$group", new Document("_id", "$serialNumber.showValue")), + new Document("$count", "uniqueDeviceIds") ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<OneMachineFileResult> resultList = mongoTemplate.find(query, OneMachineFileResult.class); - long total = mongoTemplate.count(query, OneMachineFileResult.class); - return Result.ok().data(resultList).total(total); + // 鎵ц鑱氬悎鏌ヨ骞惰幏鍙栫粨鏋� + AggregateIterable<Document> result = collection.aggregate(pipeline); + Integer uniqueDeviceIdCount = 0; + for (Document doc : result) { + uniqueDeviceIdCount = doc.getInteger("uniqueDeviceIds"); + break; // 涓嶉渶瑕佺户缁亶鍘嗭紝鍥犱负 $count 鍙細浜х敓涓�涓粨鏋� + } + return uniqueDeviceIdCount; + }).collect(Collectors.toList()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -676,21 +1138,45 @@ */ @Override public Result faceCollectionConsistency(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, CrossDetailResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -701,21 +1187,45 @@ */ @Override public Result faceImgQualification(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<MonitoringDetailResult> resultList = mongoTemplate.find(query, MonitoringDetailResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, MonitoringDetailResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<MonitoringDetailResult> resultList = mongoTemplate.find(query, MonitoringDetailResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter); + List<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -726,21 +1236,44 @@ */ @Override public Result faceCapturesImagesAccuracy(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, FaceDeviceInspectionResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter); + List<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -751,21 +1284,44 @@ */ @Override public Result faceTimelyUpload(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, FaceDeviceInspectionResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); + + // 缁熻鏁伴噺 + 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> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter); + List<Integer> 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()); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", rList); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** @@ -776,20 +1332,34 @@ */ @Override public Result faceAvailabilityOfLargeImg(DataCenterQuery params) { - Query query = new Query(); - // 鍏ㄦ枃绱㈠紩鏌ヨ - MongoUtil.fullText(query, params.getKeyword()); - Criteria criteria = new Criteria(); - // 鏅�氭煡璇� - if (Objects.nonNull(params.getStartTime()) && Objects.nonNull(params.getEndTime())) { - criteria.andOperator( - Criteria.where(TIME_FIELD).gte(params.getStartTime()).lte(params.getEndTime()) - ); - } - query.addCriteria(criteria); - query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize())); - List<FaceDeviceSamplingResult> resultList = mongoTemplate.find(query, FaceDeviceSamplingResult.class); + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + long total = mongoTemplate.count(query, FaceDeviceSamplingResult.class); - return Result.ok().data(resultList).total(total); + MongoUtil.setPage(query, params, TIME_FIELD); + List<FaceDeviceSamplingResult> resultList = mongoTemplate.find(query, FaceDeviceSamplingResult.class); + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + /** + * 瑙嗛锛氳棰戝浘鍍忚祫婧愬畨鍏ㄧ鐞� + * + * @param query + * @return + */ + @Override + public Result videoImageResourceSecurity(DataCenterQuery query) { + Page<ImageResourceSecurityDetail> page = PageHelper.startPage(query.getPageNum(), query.getPageSize()); + securityDetailMapper.selectImageResourceSecurityDetailList(query); + + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", page); + return Result.ok().data(map).total(page.getTotal()); + } } -- Gitblit v1.8.0