From d49b037cd6d42cff6e8a15b3590a3edac2c4568b Mon Sep 17 00:00:00 2001
From: xiangpei <xiangpei@timesnew.cn>
Date: 星期五, 06 九月 2024 16:38:55 +0800
Subject: [PATCH] 点位在线监测
---
ycl-server/src/main/java/com/ycl/platform/service/impl/DataCenterServiceImpl.java | 2144 +++++++++++++++++++++++++++++++++++++++++++++--------------
1 files changed, 1,634 insertions(+), 510 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 394332d..7d463d4 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,31 +1,40 @@
package com.ycl.platform.service.impl;
+import com.baomidou.mybatisplus.core.metadata.IPage;
+import com.baomidou.mybatisplus.extension.conditions.query.LambdaQueryChainWrapper;
import com.github.pagehelper.Page;
import com.github.pagehelper.PageHelper;
-import com.github.pagehelper.PageInfo;
-import com.ycl.platform.domain.entity.ImageResourceSecurityDetail;
+import com.mongodb.client.AggregateIterable;
+import com.mongodb.client.MongoCollection;
+import com.mongodb.client.MongoDatabase;
+import com.ycl.platform.domain.entity.*;
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.domain.vo.PointDetailVO;
import com.ycl.platform.mapper.ImageResourceSecurityDetailMapper;
-import com.ycl.platform.mapper.ImageResourceSecurityMapper;
-import com.ycl.platform.service.DataCenterService;
+import com.ycl.platform.mapper.YwPointMapper;
+import com.ycl.platform.service.*;
import com.ycl.system.Result;
-import com.ycl.system.page.TableDataInfo;
+import com.ycl.system.page.PageUtil;
+import com.ycl.utils.DateUtils;
import com.ycl.utils.MongoUtil;
-import constant.HttpStatus;
+import constant.CheckConstants;
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.math.BigDecimal;
+import java.math.RoundingMode;
+import java.text.DecimalFormat;
+import java.util.*;
+import java.util.stream.Collectors;
/**
* 鏁版嵁涓績鎺ュ彛
@@ -38,9 +47,16 @@
public class DataCenterServiceImpl implements DataCenterService {
private final MongoTemplate mongoTemplate;
- private final ImageResourceSecurityMapper securityMapper;
private final ImageResourceSecurityDetailMapper securityDetailMapper;
+ private final YwPointMapper pointMapper;
+ private final ICheckIndexVideoService checkIndexVideoService;
+ private final ICheckIndexCarService checkIndexCarService;
+ private final ICheckIndexFaceService checkIndexFaceService;
+
+
private final static String TIME_FIELD = "mongoCreateTime";
+
+ private static DecimalFormat DF = new DecimalFormat("#.####");
/**
* 瑙嗛锛氱偣浣嶅湪绾跨巼
@@ -50,246 +66,63 @@
*/
@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())
- );
+ params.setDeptTag(-1);
+ params.setDeviceType(1);
+ IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);
+ pointMapper.dataCenterPage(page, params);
+
+ // 缁熻璁惧鏁伴噺
+ Integer distinctCount = pointMapper.distinctCount(params);
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getSiteOnline)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getSiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, VideoOnlineResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(distinctCount + "",this.remove0(onlineRate)));
+ map.put("list", page.getRecords());
+ return Result.ok().data(map).total(page.getTotal());
}
/**
- * 瑙嗛锛氫竴鏈轰竴妗ｆ敞鍐岀巼
+ * 瑙嗛锛氶儴绾х偣浣嶅湪绾跨巼
*
* @param params
* @return
*/
@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.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
+ public Result deptVideoPointOnlineRate(DataCenterQuery params) {
+ params.setDeptTag(1);
+ params.setDeviceType(1);
+ IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);
+ pointMapper.dataCenterPage(page, params);
- /**
- * 瑙嗛锛氫竴鏈轰竴妗ｅ悎鏍肩巼
- *
- * @param params
- * @return
- */
- @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);
- long total = mongoTemplate.count(query, MonitorQualifyResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
+ // 缁熻璁惧鏁伴噺
+ Integer distinctCount = pointMapper.distinctCount(params);
- /**
- * 瑙嗛锛氭。妗堣�冩牳姣�
- *
- * @param params
- * @return
- */
- @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())
- );
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getMinistrySiteOnline)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMinistrySiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
-
- /**
- * 瑙嗛锛氬綍鍍忓彲鐢ㄧ巼
- *
- * @param params
- * @return
- */
- @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);
- long total = mongoTemplate.count(query, RecordMetaDSumResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
-
- /**
- * 瑙嗛锛氶噸鐐圭偣浣嶅綍鍍忓彲鐢ㄧ巼
- *
- * @param params
- * @return
- */
- @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);
- long total = mongoTemplate.count(query, RecordMetaDSumResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
-
- /**
- * 瑙嗛锛氭爣娉ㄦ纭巼
- *
- * @param params
- * @return
- */
- @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);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
-
- /**
- * 瑙嗛锛氶噸鐐圭偣浣嶆爣娉ㄦ纭巼
- *
- * @param params
- * @return
- */
- @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())
- );
- }
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
-
- /**
- * 瑙嗛锛氭牎鏃舵纭巼
- *
- * @param params
- * @return
- */
- @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);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
- }
-
- /**
- * 瑙嗛锛氶噸鐐圭偣浣嶆牎鏃舵纭巼
- *
- * @param params
- * @return
- */
- @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())
- );
- }
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));
+ map.put("list", page.getRecords());
+ return Result.ok().data(map).total(page.getTotal());
}
/**
@@ -300,21 +133,30 @@
*/
@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())
- );
+ params.setDeptTag(3);
+ params.setDeviceType(1);
+ IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);
+ pointMapper.dataCenterPage(page, params);
+
+ // 缁熻璁惧鏁伴噺
+ Integer distinctCount = pointMapper.distinctCount(params);
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getKeySiteOnline)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeySiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));
+ map.put("list", page.getRecords());
+ return Result.ok().data(map).total(page.getTotal());
}
/**
@@ -325,24 +167,662 @@
*/
@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())
- );
+ params.setDeptTag(4);
+ params.setDeviceType(1);
+ IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);
+ pointMapper.dataCenterPage(page, params);
+
+ // 缁熻璁惧鏁伴噺
+ Integer distinctCount = pointMapper.distinctCount(params);
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getKeyCommandImageOnline)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyCommandImageOnline).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));
+ map.put("list", page.getRecords());
+ return Result.ok().data(map).total(page.getTotal());
}
+ /**
+ * 瑙嗛锛氫竴鏈轰竴妗ｆ敞鍐岀巼
+ *
+ * @param params
+ * @return
+ */
+ @Override
+ public Result videoOneMachineDocumentRegister(DataCenterQuery params) {
+ List<String> likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, 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");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getMonitorRegistration)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMonitorRegistration).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
+ }
+
+ /**
+ * 瑙嗛锛氫竴鏈轰竴妗ｅ悎鏍肩巼
+ *
+ * @param params
+ * @return
+ */
+ @Override
+ public Result videoOneMachineDocumentQualified(DataCenterQuery params) {
+ List<String> likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, 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");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getMonitorQualification)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMonitorQualification).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
+ }
+
+ /**
+ * 瑙嗛锛氭。妗堣�冩牳姣�
+ *
+ * @param params
+ * @return
+ */
+ @Override
+ public Result videoAssessmentFileRatio(DataCenterQuery params) {
+ // TODO 鏂板涓�寮犺〃璁板綍姣忔鐨勬。妗堣�冩牳
+ List<String> likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
+ 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");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ rList.add("0%");
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
+ }
+
+ /**
+ * 瑙嗛锛氬綍鍍忓彲鐢ㄧ巼
+ *
+ * @param params
+ * @return
+ */
+ @Override
+ public Result videoAvailabilityRate(DataCenterQuery params) {
+ List<String> likeFileds = Arrays.asList("deviceId", "deviceName");
+ Query query = MongoUtil.getQuery(params,"createTime", likeFileds, null);
+
+ 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<String> resultCount = status.stream().map(item -> {
+ List<Document> dList = new ArrayList<>(2);
+ dList.add(new Document("recordStatus", new Document("$eq", item)));
+ if (params.getDataType().equals(1)) {
+ dList.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document filter = new Document("$and", dList);
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getVideoAvailable)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getVideoAvailable).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ resultCount.add(this.remove0(onlineRate));
+ 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> likeFileds = Arrays.asList("deviceId", "deviceName");
+ Query query = MongoUtil.getQuery(params,"createTime", likeFileds, 1);
+
+ 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<String> resultCount = status.stream().map(item -> {
+ List<Document> dList = new ArrayList<>(4);
+ dList.add(new Document("deptTag", new Document("$eq", Boolean.TRUE)));
+ dList.add(new Document("recordStatus", new Document("$eq", item)));
+ if (params.getDataType().equals(1)) {
+ dList.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document filter = new Document("$and", dList);
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getMinistryVideoAvailable)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getMinistryVideoAvailable).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ resultCount.add(this.remove0(onlineRate));
+ 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 videoImportantPointAvailabilityRate(DataCenterQuery params) {
+ List<String> likeFileds = Arrays.asList("deviceId", "deviceName");
+ Query query = MongoUtil.getQuery(params,"createTime", likeFileds, 3);
+
+ 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<String> resultCount = status.stream().map(item -> {
+ List<Document> dList = new ArrayList<>(4);
+ dList.add(new Document("importantTag", new Document("$eq", Boolean.TRUE)));
+ dList.add(new Document("recordStatus", new Document("$eq", item)));
+ if (params.getDataType().equals(1)) {
+ dList.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document filter = new Document("$and", dList);
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getKeyVideoAvailable)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyVideoAvailable).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ resultCount.add(this.remove0(onlineRate));
+ 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 videoLabelingAccuracy(DataCenterQuery params) {
+ List<String> likeFileds = Arrays.asList("deviceId", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
+ 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> likeFileds = Arrays.asList("deviceNo", "osdName");
+ Query query = MongoUtil.getQuery(params,"checkTime", likeFileds, 3);
+
+ 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");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("importantTag", Boolean.TRUE));
+ dList1.add(new Document("osdNameCorrect", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("importantTag", Boolean.TRUE));
+ dList2.add(new Document("osdNameCorrect", new Document("$eq", -1)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("importantTag", Boolean.TRUE));
+ dList3.add(new Document("osdTimeCorrect", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("importantTag", Boolean.TRUE));
+ dList4.add(new Document("osdTimeCorrect", new Document("$eq", -1)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document osdNameFilter = new Document("$and", dList1);
+ Document osdNameErrFilter = new Document("$and", dList2);
+ Document osdTimeFilter = new Document("$and", dList3);
+ Document osdTimeErrFilter = new Document("$and", dList4);
+ List<Document> lists = Arrays.asList(osdNameFilter, osdNameErrFilter, osdTimeFilter, osdTimeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ List<Document> pipeline = Arrays.asList(
+ new Document("$match", filter),
+ // $group 鍘婚噸
+ new Document("$group", new Document("_id", "$deviceNo")),
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getKeyAnnotationAccuracy)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyAnnotationAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
+ }
+
+ /**
+ * 瑙嗛锛氭牎鏃舵纭巼
+ *
+ * @param params
+ * @return
+ */
+ @Override
+ public Result videoCheckTimeAccuracy(DataCenterQuery params) {
+
+ List<String> likeFileds = Arrays.asList("deviceId");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
+ 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> likeFileds = Arrays.asList("deviceNo", "osdName");
+ Query query = MongoUtil.getQuery(params,"checkTime", likeFileds, 3);
+
+ 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");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("importantTag", Boolean.TRUE));
+ dList1.add(new Document("osdTimeCorrect", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("importantTag", Boolean.TRUE));
+ dList2.add(new Document("osdTimeCorrect", new Document("$eq", -1)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document osdTimeFilter = new Document("$and", dList1);
+ Document osdTimeErrFilter = new Document("$and", dList2);
+ List<Document> lists = Arrays.asList(osdTimeFilter, osdTimeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ List<Document> pipeline = Arrays.asList(
+ new Document("$match", filter),
+ // $group 鍘婚噸
+ new Document("$group", new Document("_id", "$deviceNo")),
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper())
+ .select(CheckIndexVideo::getKeyTimingAccuracy)
+ .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexVideo::getKeyTimingAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
+ }
/**
@@ -353,21 +833,81 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_snapshot_data_monitor");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("importantTag", Boolean.TRUE));
+ dList1.add(new Document("resultType", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("importantTag", Boolean.TRUE));
+ dList2.add(new Document("resultType", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("importantTag", Boolean.TRUE));
+ dList3.add(new Document("resultType", new Document("$eq", 3)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("importantTag", Boolean.TRUE));
+ dList4.add(new Document("resultType", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document normalFilter = new Document("$and", dList1);
+ Document noDataFilter = new Document("$and", dList2);
+ Document trFilter = new Document("$and", dList3);
+ Document littleFilter = new Document("$and", dList4);
+ List<Document> lists = Arrays.asList(normalFilter, noDataFilter, trFilter, littleFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getViewConnectStability)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getViewConnectStability).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -378,21 +918,30 @@
*/
@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())
- );
+ params.setDeptTag(-1);
+ params.setDeviceType(2);
+ IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);
+ pointMapper.dataCenterPage(page, params);
+
+ // 缁熻璁惧鏁伴噺
+ Integer distinctCount = pointMapper.distinctCount(params);
+
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getSiteOnline)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getSiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(distinctCount + "", this.remove0(onlineRate)));
+ map.put("list", page.getRecords());
+ return Result.ok().data(map).total(page.getTotal());
}
/**
@@ -403,21 +952,77 @@
*/
@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())
- );
+ List<String> likeFileds = Arrays.asList("ip.showValue", "name.showValue", "serialNumber.showValue");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, 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");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getDeviceDirectoryConsistent)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getDeviceDirectoryConsistent).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -428,21 +1033,78 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "crossName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, CrossDetailResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_cross_detail");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("lalType", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("lalType", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("lalType", new Document("$eq", 3)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("lalType", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getVehicleInformationCollectionAccuracy)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleInformationCollectionAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -453,21 +1115,34 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, DataIntegrityMonitoringResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<DataIntegrityMonitoringResult> resultList = mongoTemplate.find(query, DataIntegrityMonitoringResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_data_integrity_monitoring");
+
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getVehicleCaptureIntegrity)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleCaptureIntegrity).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(this.remove0(onlineRate)));
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -478,21 +1153,29 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, AttrRecognitionMonitorResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<AttrRecognitionMonitorResult> resultList = mongoTemplate.find(query, AttrRecognitionMonitorResult.class);
- return Result.ok().data(resultList).total(total);
+
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getVehicleCaptureAccuracy)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleCaptureAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(this.remove0(onlineRate)));
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -503,21 +1186,73 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, VehicleDeviceInspectionResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<VehicleDeviceInspectionResult> resultList = mongoTemplate.find(query, VehicleDeviceInspectionResult.class);
- return Result.ok().data(resultList).total(total);
+
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_vehicle_device_inspection");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("snapResult", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("snapResult", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("snapResult", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document longitudeErrFilter = new Document("$and", dList3);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getVehicleTimingAccuracy)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleTimingAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -528,21 +1263,30 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, SnapshotDelayMonitorResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<SnapshotDelayMonitorResult> resultList = mongoTemplate.find(query, SnapshotDelayMonitorResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁�
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getVehicleUploadTimeliness)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleUploadTimeliness).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(this.remove0(onlineRate)));
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -553,21 +1297,30 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, PicAccessResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<PicAccessResult> resultList = mongoTemplate.find(query, PicAccessResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁�
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getVehicleUrlAvailability)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehicleUrlAvailability).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(this.remove0(onlineRate)));
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -578,21 +1331,30 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, VehicleDeviceSamplingResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<VehicleDeviceSamplingResult> resultList = mongoTemplate.find(query, VehicleDeviceSamplingResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁�
+ Date now = new Date();
+ List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper())
+ .select(CheckIndexCar::getVehiclePictureAvailability)
+ .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexCar::getVehiclePictureAvailability).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(this.remove0(onlineRate)));
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -603,21 +1365,77 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_snapshot_data_monitor");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("resultType", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("resultType", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("resultType", new Document("$eq", 3)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("resultType", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document normalFilter = new Document("$and", dList1);
+ Document noDataFilter = new Document("$and", dList2);
+ Document trFilter = new Document("$and", dList3);
+ Document littleFilter = new Document("$and", dList4);
+ List<Document> lists = Arrays.asList(normalFilter, noDataFilter, trFilter, littleFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getViewConnectStability)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getViewConnectStability).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -628,21 +1446,33 @@
*/
@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())
- );
+ params.setDeptTag(-1);
+ params.setDeviceType(3);
+ IPage<PointDetailVO> page = PageUtil.getPage(params, PointDetailVO.class);
+ pointMapper.dataCenterPage(page, params);
+
+ // 缁熻璁惧鏁伴噺
+ Integer distinctCount = pointMapper.distinctCount(params);
+
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getSiteOnline)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getSiteOnline).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ List<String> rList = new ArrayList<>(2);
+ rList.add(distinctCount + "");
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", page.getRecords());
+ return Result.ok().data(map).total(page.getTotal());
}
/**
@@ -653,21 +1483,77 @@
*/
@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())
- );
+ List<String> likeFileds = Arrays.asList("serialNumber.showValue", "ip.showValue", "name.showValue");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, 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");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("ip.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
}
- query.addCriteria(criteria);
- long total = mongoTemplate.count(query, OneMachineFileResult.class);
- 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);
- return Result.ok().data(resultList).total(total);
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("macdz.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("latitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("longitude.error", new Document("$eq", Boolean.TRUE)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getDeviceDirectoryConsistent)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getDeviceDirectoryConsistent).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -678,21 +1564,77 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "crossName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, CrossDetailResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<CrossDetailResult> resultList = mongoTemplate.find(query, CrossDetailResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_cross_detail");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("lalType", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("lalType", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("lalType", new Document("$eq", 3)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("lalType", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getFaceInformationCollectionAccuracy)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getFaceInformationCollectionAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -703,21 +1645,78 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "cameraName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, MonitoringDetailResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<MonitoringDetailResult> resultList = mongoTemplate.find(query, MonitoringDetailResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_monitoring_detail");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("lalType", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("lalType", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("lalType", new Document("$eq", 3)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList4 = new ArrayList<>(2);
+ dList4.add(new Document("lalType", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList4.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document latitudeErrFilter = new Document("$and", dList3);
+ Document longitudeErrFilter = new Document("$and", dList4);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, latitudeErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getFacePictureQualification)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getFacePictureQualification).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -728,21 +1727,72 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, FaceDeviceInspectionResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_vehicle_device_inspection");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("snapResult", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("snapResult", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("snapResult", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document longitudeErrFilter = new Document("$and", dList3);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getFaceTimingAccuracy)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getFaceTimingAccuracy).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -753,21 +1803,72 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, FaceDeviceInspectionResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁伴噺
+ MongoDatabase database = mongoTemplate.getDb();
+ MongoCollection<Document> collection = database.getCollection("hk_vehicle_device_inspection");
+
+ List<Document> dList1 = new ArrayList<>(2);
+ dList1.add(new Document("snapResult", new Document("$eq", 1)));
+ if (params.getDataType().equals(1)) {
+ dList1.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList2 = new ArrayList<>(2);
+ dList2.add(new Document("snapResult", new Document("$eq", 2)));
+ if (params.getDataType().equals(1)) {
+ dList2.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ List<Document> dList3 = new ArrayList<>(2);
+ dList3.add(new Document("snapResult", new Document("$eq", 4)));
+ if (params.getDataType().equals(1)) {
+ dList3.add(new Document("provinceTag", new Document("$eq", Boolean.TRUE)));
+ }
+ Document ipErrFilter = new Document("$and", dList1);
+ Document macdzErrFilter = new Document("$and", dList2);
+ Document longitudeErrFilter = new Document("$and", dList3);
+
+ List<Document> lists = Arrays.asList(ipErrFilter, macdzErrFilter, longitudeErrFilter);
+ List<String> rList = lists.stream().map(filter -> {
+ // 鏋勫缓鑱氬悎绠￠亾
+ 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());
+
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getFaceUploadTimeliness)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getFaceUploadTimeliness).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+ rList.add(this.remove0(onlineRate));
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", rList);
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
@@ -778,21 +1879,31 @@
*/
@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);
+ List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName");
+ Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null);
+
long total = mongoTemplate.count(query, FaceDeviceSamplingResult.class);
- query.with(Sort.by(Sort.Order.asc(TIME_FIELD))).skip(params.getSkipNum()).limit(Math.toIntExact(params.getPageSize()));
+ MongoUtil.setPage(query, params, TIME_FIELD);
List<FaceDeviceSamplingResult> resultList = mongoTemplate.find(query, FaceDeviceSamplingResult.class);
- return Result.ok().data(resultList).total(total);
+
+ // 缁熻鏁�
+ Date now = new Date();
+ List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper())
+ .select(CheckIndexFace::getFacePictureAvailability)
+ .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province)
+ .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(now), DateUtils.getDayEnd(now))
+ .list();
+ BigDecimal onlineRate = BigDecimal.ZERO;
+ if (CollectionUtils.isNotEmpty(videoList)) {
+ BigDecimal sum = videoList.stream().map(CheckIndexFace::getFacePictureAvailability).reduce(BigDecimal.ZERO, BigDecimal::add);
+ BigDecimal count = BigDecimal.valueOf(videoList.size());
+ onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100));
+ }
+
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", Arrays.asList(this.remove0(onlineRate)));
+ map.put("list", resultList);
+ return Result.ok().data(map).total(total);
}
/**
* 瑙嗛锛氳棰戝浘鍍忚祫婧愬畨鍏ㄧ鐞�
@@ -802,11 +1913,24 @@
*/
@Override
public Result videoImageResourceSecurity(DataCenterQuery query) {
- ImageResourceSecurityDetail imageResourceSecurityDetail = new ImageResourceSecurityDetail();
Page<ImageResourceSecurityDetail> page = PageHelper.startPage(query.getPageNum(), query.getPageSize());
- securityDetailMapper.selectImageResourceSecurityDetailList(imageResourceSecurityDetail);
+ securityDetailMapper.selectImageResourceSecurityDetailList(query);
- return Result.ok().data(page.getResult()).total(page.getTotal());
+ // 缁熻鏁�
+ HashMap<String, Object> map = new HashMap<>();
+ map.put("count", CollectionUtils.EMPTY_COLLECTION);
+ map.put("list", page);
+ return Result.ok().data(map).total(page.getTotal());
}
+
+ /**
+ * 鍒犻櫎灏鹃儴鐨�0
+ * @param rate
+ * @return
+ */
+ private String remove0(BigDecimal rate) {
+ DF.setDecimalSeparatorAlwaysShown(false);
+ return DF.format(rate) + "%";
+ }
}
--
Gitblit v1.8.0