From 3d5198eca9b5a6b7114f48936b0e46068236be80 Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期三, 04 九月 2024 01:36:53 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java | 805 +++++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 638 insertions(+), 167 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 b9c0a83..1693bed 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,17 +1,30 @@ 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.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.RecordMetaDSumResult; -import com.ycl.platform.domain.vo.TMonitorVO; +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.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.*; /** * 鏁版嵁涓績鎺ュ彛 @@ -24,352 +37,810 @@ public class DataCenterServiceImpl implements DataCenterService { private final MongoTemplate mongoTemplate; + private final ImageResourceSecurityDetailMapper securityDetailMapper; + private final YwPointMapper pointMapper; + + + private final static String TIME_FIELD = "mongoCreateTime"; /** * 瑙嗛锛氱偣浣嶅湪绾跨巼 * - * @param query + * @param params * @return */ @Override - public List<TMonitorVO> videoPointOnlineRate(DataCenterQuery query) { + public Result videoPointOnlineRate(DataCenterQuery params) { + // 鐢熸垚鏌ヨ + Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, null); - return null; + // 鍏堟煡鎬绘暟鍐嶅垎椤� + long total = mongoTemplate.count(query, VideoOnlineResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<VideoOnlineResult> resultList = mongoTemplate.find(query, VideoOnlineResult.class); + + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(total)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** - * 瑙嗛锛氫竴鏈轰竴妗f敞鍐岀巼 + * 瑙嗛锛氶儴绾х偣浣嶅湪绾跨巼 * - * @param query + * @param params * @return */ @Override - public List<TMonitorVO> videoOneMachineDocumentRegister(DataCenterQuery query) { - return null; - } + public Result deptVideoPointOnlineRate(DataCenterQuery params) { + // 鍏堟煡鍑洪儴绾х偣浣嶇殑鍥芥爣 + List<String> deptGBList = pointMapper.getDeptPointGB(0); - /** - * 瑙嗛锛氫竴鏈轰竴妗e悎鏍肩巼 - * - * @param query - * @return - */ - @Override - public List<TMonitorVO> videoOneMachineDocumentQualified(DataCenterQuery query) { - return null; - } + // 鐢熸垚鏌ヨ + Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, deptGBList); - /** - * 瑙嗛锛氭。妗堣�冩牳姣� - * - * @param query - * @return - */ - @Override - public List<TMonitorVO> videoAssessmentFileRatio(DataCenterQuery query) { - return null; - } + // 鍏堟煡鎬绘暟鍐嶅垎椤� + long total = mongoTemplate.count(query, VideoOnlineResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<VideoOnlineResult> resultList = mongoTemplate.find(query, VideoOnlineResult.class); - /** - * 瑙嗛锛氬綍鍍忓彲鐢ㄧ巼 - * - * @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; + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(total)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 瑙嗛锛氶噸鐐圭偣浣嶅湪绾跨巼 * - * @param query + * @param params * @return */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 @Override - public List<TMonitorVO> videoImportantPointOnlineRate(DataCenterQuery query) { - return null; + 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); + // 缁熻鏁� + 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(nonNetwork, network, video, car, face)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 瑙嗛锛氶噸鐐规寚鎸ュ浘鍍忓湪绾跨巼 * - * @param query + * @param params * @return */ - // TODO 杩斿洖鏁版嵁瀵硅薄鏇存崲 @Override - public List<TMonitorVO> videoImportantPointImageOnlineRate(DataCenterQuery query) { - return null; + 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); + // 缁熻鏁� + 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(nonNetwork, network, video, car, face)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } + /** + * 瑙嗛锛氫竴鏈轰竴妗f敞鍐岀巼 + * + * @param params + * @return + */ + @Override + public Result videoOneMachineDocumentRegister(DataCenterQuery params) { + 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); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), MonitorQualifyResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), MonitorQualifyResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), MonitorQualifyResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), MonitorQualifyResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), MonitorQualifyResult.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); + } + + /** + * 瑙嗛锛氫竴鏈轰竴妗e悎鏍肩巼 + * + * @param params + * @return + */ + @Override + public Result videoOneMachineDocumentQualified(DataCenterQuery params) { + + 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); + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + + /** + * 瑙嗛锛氭。妗堣�冩牳姣� + * + * @param params + * @return + */ + @Override + public Result videoAssessmentFileRatio(DataCenterQuery params) { + // 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); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), MonitorQualifyResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), MonitorQualifyResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), MonitorQualifyResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), MonitorQualifyResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), MonitorQualifyResult.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); + } + + /** + * 瑙嗛锛氬綍鍍忓彲鐢ㄧ巼 + * + * @param params + * @return + */ + @Override + public Result videoAvailabilityRate(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "deviceId", "createTime", null); + + long total = mongoTemplate.count(query, RecordMetaDSumResult.class); + MongoUtil.setPage(query, params, "createTime"); + List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("1")), RecordMetaDSumResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("2")), RecordMetaDSumResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("-1")), RecordMetaDSumResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three)); + 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); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("1")), RecordMetaDSumResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("2")), RecordMetaDSumResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("-1")), RecordMetaDSumResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three)); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + + /** + * 瑙嗛锛氶噸鐐圭偣浣嶅綍鍍忓彲鐢ㄧ巼 + * + * @param params + * @return + */ + @Override + public Result videoImportantPointAvailabilityRate(DataCenterQuery params) { + + List<String> deptGBList = pointMapper.getDeptPointGB(1); + + 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); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("1")), OneMachineFileResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("2")), OneMachineFileResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("recordStatus").is("-1")), OneMachineFileResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three)); + map.put("list", resultList); + return Result.ok().data(map).total(total); + } + + /** + * 瑙嗛锛氭爣娉ㄦ纭巼 + * + * @param params + * @return + */ + @Override + public Result videoLabelingAccuracy(DataCenterQuery params) { + + 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); + } + + /** + * 瑙嗛锛氶噸鐐圭偣浣嶆爣娉ㄦ纭巼 + * + * @param params + * @return + */ + @Override + public Result videoImportantPointLabelingAccuracy(DataCenterQuery params) { + + 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); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OsdCheckResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OsdCheckResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OsdCheckResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OsdCheckResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OsdCheckResult.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); + } + + /** + * 瑙嗛锛氭牎鏃舵纭巼 + * + * @param params + * @return + */ + @Override + public Result videoCheckTimeAccuracy(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "deviceId", "", new ArrayList<>()); + + long total = mongoTemplate.count(query, OneMachineFileResult.class); + 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); + } + + /** + * 瑙嗛锛氶噸鐐圭偣浣嶆牎鏃舵纭巼 + * + * @param params + * @return + */ + @Override + public Result videoImportantPointCheckTimeAccuracy(DataCenterQuery params) { + + List<String> deptGBList = pointMapper.getDeptPointGB(1); + + Query query = MongoUtil.getQuery(params, "deviceId", "checkTime", deptGBList); + + long total = mongoTemplate.count(query, OsdCheckResult.class); + MongoUtil.setPage(query, params, "checkTime"); + List<OsdCheckResult> resultList = mongoTemplate.find(query, OsdCheckResult.class); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), OsdCheckResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), OsdCheckResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), OsdCheckResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), OsdCheckResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), OsdCheckResult.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); + } /** * 杞﹁締锛氳鍥惧簱瀵规帴绋冲畾鎬� * - * @param query + * @param params * @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); + public Result vehicleViewDockStable(DataCenterQuery params) { - return null; + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("1")), SnapshotDataMonitorResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("2")), SnapshotDataMonitorResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("3")), SnapshotDataMonitorResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("4")), SnapshotDataMonitorResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 杞﹁締锛氱偣浣嶅湪绾跨巼 * - * @param query + * @param params * @return */ @Override - public List<SnapshotDataMonitorResult> vehiclePointOnlineRate(DataCenterQuery query) { - return null; + public Result vehiclePointOnlineRate(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("1")), SnapshotDataMonitorResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("2")), SnapshotDataMonitorResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("3")), SnapshotDataMonitorResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("4")), SnapshotDataMonitorResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 杞﹁締锛氫簰鑱旂綉鍗″彛璁惧鐩綍涓�鑷存�� * - * @param query + * @param params * @return */ @Override - public List<TMonitorVO> vehicleNetDeviceDirectoryConsistency(DataCenterQuery query) { - return null; + public Result vehicleNetDeviceDirectoryConsistency(DataCenterQuery params) { + + 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); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), MonitorQualifyResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), MonitorQualifyResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), MonitorQualifyResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), MonitorQualifyResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), MonitorQualifyResult.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); } /** * 杞﹁締锛氳溅杈嗗崱鍙d俊鎭噰闆嗗噯纭巼 * - * @param query + * @param params * @return */ @Override - public List<CrossDetailResult> vehicleCollectionConsistency(DataCenterQuery query) { - return null; + public Result vehicleCollectionConsistency(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, CrossDetailResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("1")), CrossDetailResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("2")), CrossDetailResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("3")), CrossDetailResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("4")), CrossDetailResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 杞﹁締锛氳溅杈嗗崱鍙h澶囨姄鎷嶆暟鎹畬鏁存�� * - * @param query + * @param params * @return */ @Override - public List<DataIntegrityMonitoringResult> vehicleCollectionDataIntegrity(DataCenterQuery query) { - return null; + public Result vehicleCollectionDataIntegrity(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, DataIntegrityMonitoringResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<DataIntegrityMonitoringResult> resultList = mongoTemplate.find(query, DataIntegrityMonitoringResult.class); + // 缁熻鏁� + HashMap<String, Object> map = new HashMap<>(); + map.put("count", CollectionUtils.EMPTY_COLLECTION); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 杞﹁締锛氳溅杈嗗崱鍙h澶囨姄鎷嶆暟鎹噯纭�� * - * @param query + * @param params * @return */ @Override - public List<AttrRecognitionMonitorResult> vehicleCollectionDataCaptured(DataCenterQuery query) { - return null; + public Result vehicleCollectionDataCaptured(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, AttrRecognitionMonitorResult.class); + 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); } /** * 杞﹁締锛氳溅杈嗗崱鍙h澶囨椂閽熷噯纭�� * - * @param query + * @param params * @return */ @Override - public List<VehicleDeviceInspectionResult> vehicleClockAccuracy(DataCenterQuery query) { - return null; + public Result vehicleClockAccuracy(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, VehicleDeviceInspectionResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<VehicleDeviceInspectionResult> resultList = mongoTemplate.find(query, VehicleDeviceInspectionResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("1")), VehicleDeviceInspectionResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("2")), VehicleDeviceInspectionResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("4")), VehicleDeviceInspectionResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 杞﹁締锛氳溅杈嗗崱鍙h澶囨姄鎷嶆暟鎹笂浼犲強鏃舵�� * - * @param query + * @param params * @return */ @Override - public List<SnapshotDelayMonitorResult> vehicleTimelyUploadAccuracy(DataCenterQuery query) { - return null; + public Result vehicleTimelyUploadAccuracy(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, SnapshotDelayMonitorResult.class); + 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); } /** * 杞﹁締锛氳溅杈嗗崱鍙h澶噓rl鍙敤鎬� * - * @param query + * @param params * @return */ @Override - public List<PicAccessResult> vehicleUrlAccuracy(DataCenterQuery query) { - return null; + public Result vehicleUrlAccuracy(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, PicAccessResult.class); + 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); } /** * 杞﹁締锛氳溅杈嗗崱鍙h澶囨姄鎷嶆暟鎹ぇ鍥惧彲鐢ㄦ�� * - * @param query + * @param params * @return */ @Override - public List<VehicleDeviceSamplingResult> vehicleBigImgAccuracy(DataCenterQuery query) { - return null; + public Result vehicleBigImgAccuracy(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, new ArrayList<>()); + + long total = mongoTemplate.count(query, VehicleDeviceSamplingResult.class); + 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); } /** * 浜鸿劯锛氳鍥惧簱瀵规帴绋冲畾鎬� * - * @param query + * @param params * @return */ @Override - public List<SnapshotDataMonitorResult> faceViewDockStable(DataCenterQuery query) { - return null; + public Result faceViewDockStable(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("1")), SnapshotDataMonitorResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("2")), SnapshotDataMonitorResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("3")), SnapshotDataMonitorResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("4")), SnapshotDataMonitorResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 浜鸿劯锛氱偣浣嶅湪绾跨巼 * - * @param query + * @param params * @return */ - // TODO 鏇存崲鍝嶅簲缁撴灉 @Override - public List<TMonitorVO> facePointOnlineRate(DataCenterQuery query) { - return null; + public Result facePointOnlineRate(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("1")), SnapshotDataMonitorResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("2")), SnapshotDataMonitorResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("3")), SnapshotDataMonitorResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("resultType").is("4")), SnapshotDataMonitorResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 浜鸿劯锛氱洰褰曚竴鑷寸巼 * - * @param query + * @param params * @return */ @Override - public List<TMonitorVO> faceDirectoryConsistency(DataCenterQuery query) { - return null; + public Result faceDirectoryConsistency(DataCenterQuery params) { + + 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); + // 缁熻鏁� + long nonNetwork = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("0")), MonitorQualifyResult.class); + long network = mongoTemplate.count(new Query().addCriteria(Criteria.where("LWSX").is("1")), MonitorQualifyResult.class); + long video = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*1.*")), MonitorQualifyResult.class); + long car = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*2.*")), MonitorQualifyResult.class); + long face = mongoTemplate.count(new Query().addCriteria(Criteria.where("SXJGNLX").regex(".*3.*")), MonitorQualifyResult.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); } /** * 浜鸿劯锛氫汉鑴稿崱鍙d俊鎭噰闆嗗噯纭巼 * - * @param query + * @param params * @return */ @Override - public List<CrossDetailResult> faceCollectionConsistency(DataCenterQuery query) { - return null; + public Result faceCollectionConsistency(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, CrossDetailResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("1")), CrossDetailResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("2")), CrossDetailResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("3")), CrossDetailResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("4")), CrossDetailResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 浜鸿劯锛氳澶囨姄鎷嶅浘鐗囧悎鏍兼�� * - * @param query + * @param params * @return */ @Override - public List<MonitoringDetailResult> faceImgQualification(DataCenterQuery query) { - return null; + public Result faceImgQualification(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "deviceId", TIME_FIELD, null); + + long total = mongoTemplate.count(query, MonitoringDetailResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<MonitoringDetailResult> resultList = mongoTemplate.find(query, MonitoringDetailResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("1")), MonitoringDetailResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("2")), MonitoringDetailResult.class); + long three = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("3")), MonitoringDetailResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("lalType").is("4")), MonitoringDetailResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, three, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 浜鸿劯锛氳澶囨姄鎷嶅浘鐗囨椂閽熷噯纭�� * - * @param query + * @param params * @return */ @Override - public List<FaceDeviceInspectionResult> faceCapturesImagesAccuracy(DataCenterQuery query) { - return null; + public Result faceCapturesImagesAccuracy(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, FaceDeviceInspectionResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("1")), FaceDeviceInspectionResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("2")), FaceDeviceInspectionResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("4")), FaceDeviceInspectionResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 浜鸿劯锛氭姄鎷嶄汉鑴告暟鎹笂浼犲強鏃舵�� * - * @param query + * @param params * @return */ @Override - public List<FaceDeviceInspectionResult> faceTimelyUpload(DataCenterQuery query) { - return null; + public Result faceTimelyUpload(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, FaceDeviceInspectionResult.class); + MongoUtil.setPage(query, params, TIME_FIELD); + List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); + // 缁熻鏁� + long one = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("1")), FaceDeviceInspectionResult.class); + long two = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("2")), FaceDeviceInspectionResult.class); + long four = mongoTemplate.count(new Query().addCriteria(Criteria.where("snapResult").is("4")), FaceDeviceInspectionResult.class); + HashMap<String, Object> map = new HashMap<>(); + map.put("count", Arrays.asList(one, two, four)); + map.put("list", resultList); + return Result.ok().data(map).total(total); } /** * 浜鸿劯锛氫汉鑴稿崱鍙h澶囨姄鎷嶆暟鎹ぇ鍥惧彲鐢ㄦ�� * + * @param params + * @return + */ + @Override + public Result faceAvailabilityOfLargeImg(DataCenterQuery params) { + + Query query = MongoUtil.getQuery(params, "externalIndexCode", TIME_FIELD, null); + + long total = mongoTemplate.count(query, FaceDeviceSamplingResult.class); + 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 List<FaceDeviceSamplingResult> faceAvailabilityOfLargeImg(DataCenterQuery query) { - return null; + 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