| | |
| | | import com.ycl.system.page.PageUtil; |
| | | import com.ycl.utils.DateUtils; |
| | | import com.ycl.utils.MongoUtil; |
| | | import com.ycl.utils.StringUtils; |
| | | import com.ycl.utils.bean.BeanUtils; |
| | | import com.ycl.utils.poi.ExcelUtil; |
| | | import constant.ApiConstants; |
| | |
| | | item.setOnlineStr("未知"); |
| | | } |
| | | List<String> offLineTime = item.getOffLineTimeStr(); |
| | | if(!CollectionUtils.isEmpty(offLineTime)) { |
| | | //后续可以改成配置的离线次数(提取前n次,n为配置的离线次数) |
| | | if (!CollectionUtils.isEmpty(offLineTime)) { |
| | | if (offLineTime.size() > 1) { |
| | | offLineTime = offLineTime.subList(0, 2); |
| | | offLineTime = offLineTime.subList(offLineTime.size() - 2, offLineTime.size()); |
| | | } |
| | | item.setOffLineTimeStr(offLineTime); |
| | | } |
| | |
| | | onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); |
| | | totalCount = offlineCount + unknownCount + onlineCount; |
| | | } |
| | | /** 查询当天在线率 */ |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getSiteOnline) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | .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)); |
| | | if (totalCount!=0) { |
| | | onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | // /** 查询当天在线率 */ |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getSiteOnline) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | // .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)); |
| | | // } |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); |
| | | map.put("list", resultList); |
| | |
| | | onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); |
| | | totalCount = offlineCount + unknownCount + onlineCount; |
| | | } |
| | | |
| | | params.setDeptTag(1); |
| | | params.setDeviceType(1); |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getMinistrySiteOnline) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | .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)); |
| | | if (totalCount!=0) { |
| | | onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | // params.setDeptTag(1); |
| | | // params.setDeviceType(1); |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getMinistrySiteOnline) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | // .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)); |
| | | // } |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); |
| | | map.put("list", resultList); |
| | |
| | | onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); |
| | | totalCount = offlineCount + unknownCount + onlineCount; |
| | | } |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getKeySiteOnline) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | .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)); |
| | | if (totalCount!=0) { |
| | | onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getKeySiteOnline) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | // .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)); |
| | | // } |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); |
| | | map.put("list", resultList); |
| | |
| | | onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); |
| | | totalCount = offlineCount + unknownCount + onlineCount; |
| | | } |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getKeyCommandImageOnline) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | .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)); |
| | | if (totalCount!=0) { |
| | | onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getKeyCommandImageOnline) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | // .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)); |
| | | // } |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); |
| | | map.put("list", resultList); |
| | |
| | | List<Criteria> andCriteria = MongoUtil.getAndCriteria(params, TIME_FIELD, likeFileds, null); |
| | | Query query = new Query(); |
| | | Criteria and = new Criteria(); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption() ==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | andCriteria.add(Criteria.where("newDevice").is(Boolean.TRUE)); |
| | | }else if(params.getOption() ==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | andCriteria.add(Criteria.where("newDevice").is(Boolean.FALSE)); |
| | | } |
| | | } |
| | |
| | | //总数 |
| | | List<Document> dList1 = new ArrayList<>(2); |
| | | setTag(params, dList1); |
| | | Document totalFilter = new Document("$and",dList1); |
| | | Document totalFilter = new Document("$and", dList1); |
| | | //新设备数 |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | setTag(params, dList2); |
| | | dList2.add(new Document("newDevice",Boolean.TRUE)); |
| | | Document newFilter = new Document("$and",dList2); |
| | | dList2.add(new Document("newDevice", Boolean.TRUE)); |
| | | Document newFilter = new Document("$and", dList2); |
| | | |
| | | List<Document> lists = Arrays.asList(totalFilter, newFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getMonitorRegistration) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .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)); |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getMonitorRegistration) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | BigDecimal rate = BigDecimal.ZERO; |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | rate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | rList.add(this.remove0(rate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", rList); |
| | | map.put("list", resultVOS); |
| | |
| | | Criteria and = new Criteria(); |
| | | and.andOperator(andCriteria); |
| | | query = Query.query(and); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption() ==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | andCriteria.add(Criteria.where("serialNumber.error").is(Boolean.FALSE)); |
| | | andCriteria.add(Criteria.where("name.error").is(Boolean.FALSE)); |
| | | andCriteria.add(Criteria.where("civilCode.error").is(Boolean.FALSE)); |
| | |
| | | Criteria and2 = new Criteria(); |
| | | and2.andOperator(andCriteria); |
| | | query = Query.query(and2); |
| | | }else if(params.getOption() ==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | Criteria c1 = Criteria.where("serialNumber.error").is(Boolean.TRUE); |
| | | Criteria c2 = Criteria.where("name.error").is(Boolean.TRUE); |
| | | Criteria c3 = Criteria.where("civilCode.error").is(Boolean.TRUE); |
| | |
| | | //总数 |
| | | List<Document> dList1 = new ArrayList<>(2); |
| | | setTag(params, dList1); |
| | | Document totalFilter = new Document("$and",dList1); |
| | | Document totalFilter = new Document("$and", dList1); |
| | | //合格数 |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | dList2.add(new Document("serialNumber.error",Boolean.FALSE)); |
| | | dList2.add(new Document("name.error",Boolean.FALSE)); |
| | | dList2.add(new Document("civilCode.error",Boolean.FALSE)); |
| | | dList2.add(new Document("integrated_device.error",Boolean.FALSE)); |
| | | dList2.add(new Document("jkdwlx.error",Boolean.FALSE)); |
| | | dList2.add(new Document("latitude.error",Boolean.FALSE)); |
| | | dList2.add(new Document("longitude.error",Boolean.FALSE)); |
| | | dList2.add(new Document("macdz.error",Boolean.FALSE)); |
| | | dList2.add(new Document("name.error",Boolean.FALSE)); |
| | | dList2.add(new Document("sbzt.error",Boolean.FALSE)); |
| | | dList2.add(new Document("sxjcjqy.error",Boolean.FALSE)); |
| | | dList2.add(new Document("sxjgnlx.error",Boolean.FALSE)); |
| | | setTag(params,dList2); |
| | | Document qualifyFilter = new Document("$and",dList2); |
| | | dList2.add(new Document("serialNumber.error", Boolean.FALSE)); |
| | | dList2.add(new Document("name.error", Boolean.FALSE)); |
| | | dList2.add(new Document("civilCode.error", Boolean.FALSE)); |
| | | dList2.add(new Document("integrated_device.error", Boolean.FALSE)); |
| | | dList2.add(new Document("jkdwlx.error", Boolean.FALSE)); |
| | | dList2.add(new Document("latitude.error", Boolean.FALSE)); |
| | | dList2.add(new Document("longitude.error", Boolean.FALSE)); |
| | | dList2.add(new Document("macdz.error", Boolean.FALSE)); |
| | | dList2.add(new Document("name.error", Boolean.FALSE)); |
| | | dList2.add(new Document("sbzt.error", Boolean.FALSE)); |
| | | dList2.add(new Document("sxjcjqy.error", Boolean.FALSE)); |
| | | dList2.add(new Document("sxjgnlx.error", Boolean.FALSE)); |
| | | setTag(params, dList2); |
| | | Document qualifyFilter = new Document("$and", dList2); |
| | | //不合格数 |
| | | List<Document> dList3 = new ArrayList<>(2); |
| | | setTag(params,dList3); |
| | | List<Document> dList3 = new ArrayList<>(2); |
| | | setTag(params, dList3); |
| | | List<Document> errorConditions = new ArrayList<>(); |
| | | errorConditions.add(new Document("serialNumber.error", new Document("$eq", Boolean.TRUE))); |
| | | errorConditions.add(new Document("name.error", new Document("$eq", Boolean.TRUE))); |
| | |
| | | } |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getMonitorQualification) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getMonitorQualification) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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); |
| | |
| | | * 档案留存总量:mongo存的所有去重后的档案 |
| | | * 当日档案:当日的档案 |
| | | * 档案考核比 = 当日档案/档案留存总量 |
| | | * |
| | | * @param params |
| | | * @return1 |
| | | */ |
| | |
| | | //总数 |
| | | List<Document> dList1 = new ArrayList<>(2); |
| | | DataCenterQuery totalParams = new DataCenterQuery(); |
| | | BeanUtils.copyProperties(params,totalParams); |
| | | BeanUtils.copyProperties(params, totalParams); |
| | | totalParams.setStartTime(null); |
| | | setTag(totalParams, dList1); |
| | | Document totalFilter = new Document("$and",dList1); |
| | | Document totalFilter = new Document("$and", dList1); |
| | | //当日档案数 |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | setTag(params, dList2); |
| | | Document newFilter = new Document("$and",dList2); |
| | | Document newFilter = new Document("$and", dList2); |
| | | |
| | | List<Document> lists = Arrays.asList(totalFilter, newFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | |
| | | } |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getArchivesRate) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | BigDecimal onlineRate = BigDecimal.ZERO; |
| | | if (CollectionUtils.isNotEmpty(videoList)) { |
| | | BigDecimal sum = videoList.stream().map(CheckIndexVideo::getArchivesRate).reduce(BigDecimal.ZERO, BigDecimal::add); |
| | | BigDecimal count = BigDecimal.valueOf(videoList.size()); |
| | | onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getArchivesRate) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .list(); |
| | | // BigDecimal onlineRate = BigDecimal.ZERO; |
| | | // if (CollectionUtils.isNotEmpty(videoList)) { |
| | | // BigDecimal sum = videoList.stream().map(CheckIndexVideo::getArchivesRate).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); |
| | |
| | | MongoUtil.setPage(query, params, "createTime"); |
| | | List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); |
| | | //翻译行政区域 |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | String areaCode = item.getArealayername().substring(0, 6); |
| | | AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode); |
| | | if(areaDeptEnum!=null) item.setArealayername(areaDeptEnum.getName()); |
| | | if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName()); |
| | | }); |
| | | // 统计数量 |
| | | MongoDatabase database = mongoTemplate.getDb(); |
| | |
| | | } |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getVideoAvailable) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .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)); |
| | | } |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getVideoAvailable) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | //加一个总数 |
| | | int totalCount = 0; |
| | | for (String s : resultCount) { |
| | |
| | | } |
| | | resultCount.add(0, totalCount + ""); |
| | | |
| | | BigDecimal onlineRate = BigDecimal.ZERO; |
| | | if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) { |
| | | onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | resultCount.add(this.remove0(onlineRate)); |
| | | |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | MongoUtil.setPage(query, params, "createTime"); |
| | | List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); |
| | | //翻译行政区域 |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | String areaCode = item.getArealayername().substring(0, 6); |
| | | AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode); |
| | | if(areaDeptEnum!=null) item.setArealayername(areaDeptEnum.getName()); |
| | | if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName()); |
| | | }); |
| | | // 统计数量 |
| | | MongoDatabase database = mongoTemplate.getDb(); |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getMinistryVideoAvailable) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .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)); |
| | | } |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getMinistryVideoAvailable) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | //加一个总数 |
| | | int totalCount = 0; |
| | | for (String s : resultCount) { |
| | | totalCount += Integer.parseInt(s); |
| | | } |
| | | resultCount.add(0, totalCount + ""); |
| | | BigDecimal onlineRate = BigDecimal.ZERO; |
| | | if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) { |
| | | onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | resultCount.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", resultCount); |
| | |
| | | MongoUtil.setPage(query, params, "createTime"); |
| | | List<RecordMetaDSumResult> resultList = mongoTemplate.find(query, RecordMetaDSumResult.class); |
| | | //翻译行政区域 |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | String areaCode = item.getArealayername().substring(0, 6); |
| | | AreaDeptEnum areaDeptEnum = AreaDeptEnum.fromCode(areaCode); |
| | | if(areaDeptEnum!=null) item.setArealayername(areaDeptEnum.getName()); |
| | | if (areaDeptEnum != null) item.setArealayername(areaDeptEnum.getName()); |
| | | }); |
| | | // 统计数量 |
| | | MongoDatabase database = mongoTemplate.getDb(); |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getKeyVideoAvailable) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .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)); |
| | | } |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getKeyVideoAvailable) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | //加一个总数 |
| | | int totalCount = 0; |
| | | for (String s : resultCount) { |
| | | totalCount += Integer.parseInt(s); |
| | | } |
| | | resultCount.add(0, totalCount + ""); |
| | | BigDecimal onlineRate = BigDecimal.ZERO; |
| | | if (!StringUtils.isEmpty(resultCount.get(0)) && !"0".equals(resultCount.get(0))) { |
| | | onlineRate = new BigDecimal(resultCount.get(1)).divide(new BigDecimal(resultCount.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | resultCount.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", resultCount); |
| | |
| | | query = Query.query(and); |
| | | //下拉框标注正确查询条件 |
| | | if (params.getOption() != null) { |
| | | if(params.getOption()==1) { |
| | | if (params.getOption() == 1) { |
| | | andCriteria.add(Criteria.where("osdNameCorrect").is(1)); |
| | | andCriteria.add(Criteria.where("osdTimeCorrect").is(1)); |
| | | andCriteria.add(Criteria.where("osdProvinceCorrect").is(1)); |
| | |
| | | Criteria and2 = new Criteria(); |
| | | and2.andOperator(andCriteria); |
| | | query = Query.query(and2); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | // 使用$or条件连接多个字段检查,每个字段检查是否等于-1 |
| | | Criteria c1 = Criteria.where("osdNameCorrect").is(-1); |
| | | Criteria c2 = Criteria.where("osdTimeCorrect").is(-1); |
| | |
| | | Criteria orOperator = new Criteria().orOperator(c1, c2, c3, c4, c5); |
| | | orOperator.andOperator(andCriteria); |
| | | query = Query.query(orOperator); |
| | | }else { |
| | | } else { |
| | | Criteria c1 = Criteria.where("osdNameCorrect").is(0); |
| | | Criteria c2 = Criteria.where("osdTimeCorrect").is(0); |
| | | Criteria c3 = Criteria.where("osdProvinceCorrect").is(0); |
| | |
| | | Document osdCorrectFilter = new Document("$and", dList1); |
| | | //异常数 |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | setTag(params,dList2); |
| | | setTag(params, dList2); |
| | | Document importantTagCondition = new Document("importantTag", Boolean.TRUE); |
| | | dList2.add(importantTagCondition); |
| | | List<Document> errorConditions = new ArrayList<>(); |
| | |
| | | Document osdErrorFilter = new Document("$and", dList2); |
| | | //未知数 |
| | | List<Document> dList3 = new ArrayList<>(2); |
| | | setTag(params,dList3); |
| | | setTag(params, dList3); |
| | | dList3.add(importantTagCondition); |
| | | List<Document> unknownConditions = new ArrayList<>(); |
| | | unknownConditions.add(new Document("osdNameCorrect", new Document("$eq", 0))); |
| | |
| | | dList3.add(unknownFilter); |
| | | Document osdUnknownFilter = new Document("$and", dList3); |
| | | |
| | | List<Document> lists = Arrays.asList(osdFilter, osdCorrectFilter, osdErrorFilter,osdUnknownFilter); |
| | | List<Document> lists = Arrays.asList(osdFilter, osdCorrectFilter, osdErrorFilter, osdUnknownFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getKeyAnnotationAccuracy) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getKeyAnnotationAccuracy) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | query = Query.query(and); |
| | | //下拉框标注正确查询条件 |
| | | if (params.getOption() != null) { |
| | | if(params.getOption()==1) { |
| | | if (params.getOption() == 1) { |
| | | andCriteria.add(Criteria.where("osdNameCorrect").is(1)); |
| | | andCriteria.add(Criteria.where("osdTimeCorrect").is(1)); |
| | | andCriteria.add(Criteria.where("osdProvinceCorrect").is(1)); |
| | |
| | | Criteria and2 = new Criteria(); |
| | | and2.andOperator(andCriteria); |
| | | query = Query.query(and2); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | // 使用$or条件连接多个字段检查,每个字段检查是否等于-1 |
| | | Criteria c1 = Criteria.where("osdNameCorrect").is(-1); |
| | | Criteria c2 = Criteria.where("osdTimeCorrect").is(-1); |
| | |
| | | Criteria orOperator = new Criteria().orOperator(c1, c2, c3, c4, c5); |
| | | orOperator.andOperator(andCriteria); |
| | | query = Query.query(orOperator); |
| | | }else { |
| | | } else { |
| | | Criteria c1 = Criteria.where("osdNameCorrect").is(0); |
| | | Criteria c2 = Criteria.where("osdTimeCorrect").is(0); |
| | | Criteria c3 = Criteria.where("osdProvinceCorrect").is(0); |
| | |
| | | } |
| | | |
| | | /** |
| | | * 视频:校时正确率 |
| | | * 视频:校时正确率(停用) |
| | | * |
| | | * @param params |
| | | * @return |
| | |
| | | Query query = MongoUtil.getQuery(params, "checkTime", likeFileds, null); |
| | | //下拉框标注正确查询条件 |
| | | if (params.getOption() != null) { |
| | | if(params.getOption()==1) { |
| | | query.addCriteria(Criteria.where("osdTimeCorrect").is(1)); |
| | | }else if(params.getOption()==-1){ |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("osdTimeCorrect").is(1)); |
| | | } else if (params.getOption() == -1) { |
| | | query.addCriteria(Criteria.where("osdTimeCorrect").is(-1)); |
| | | }else { |
| | | } else { |
| | | query.addCriteria(Criteria.where("osdTimeCorrect").is(0)); |
| | | } |
| | | } |
| | |
| | | Document osdCorrectFilter = new Document("$and", dList1); |
| | | //异常数 |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | setTag(params,dList2); |
| | | setTag(params, dList2); |
| | | Document importantTagCondition = new Document("importantTag", Boolean.TRUE); |
| | | dList2.add(importantTagCondition); |
| | | List<Document> errorConditions = new ArrayList<>(); |
| | |
| | | Document osdErrorFilter = new Document("$and", dList2); |
| | | //未知数 |
| | | List<Document> dList3 = new ArrayList<>(2); |
| | | setTag(params,dList3); |
| | | setTag(params, dList3); |
| | | dList3.add(importantTagCondition); |
| | | List<Document> unknownConditions = new ArrayList<>(); |
| | | unknownConditions.add(new Document("osdNameCorrect", new Document("$eq", 0))); |
| | |
| | | dList3.add(unknownFilter); |
| | | Document osdUnknownFilter = new Document("$and", dList3); |
| | | |
| | | List<Document> lists = Arrays.asList(osdFilter, osdCorrectFilter, osdErrorFilter,osdUnknownFilter); |
| | | List<Document> lists = Arrays.asList(osdFilter, osdCorrectFilter, osdErrorFilter, osdUnknownFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | .select(CheckIndexVideo::getKeyTimingAccuracy) |
| | | .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexVideo> videoList = new LambdaQueryChainWrapper<>(checkIndexVideoService.getBaseMapper()) |
| | | // .select(CheckIndexVideo::getKeyTimingAccuracy) |
| | | // .eq(params.getDataType().equals(1), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexVideo::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexVideo::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | //加DataType为车辆 |
| | | query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_CAR)); |
| | | if(params.getOption()!=null){ |
| | | if(ApiConstants.HK_SnapCount_ResultType_Normal.equals(params.getOption())) { |
| | | if (params.getOption() != null) { |
| | | if (ApiConstants.HK_SnapCount_ResultType_Normal.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Normal)); |
| | | }else if(ApiConstants.HK_SnapCount_ResultType_Null.equals(params.getOption())){ |
| | | } else if (ApiConstants.HK_SnapCount_ResultType_Null.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Null)); |
| | | }else if(ApiConstants.HK_SnapCount_ResultType_Descent.equals(params.getOption())){ |
| | | } else if (ApiConstants.HK_SnapCount_ResultType_Descent.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Descent)); |
| | | }else if(ApiConstants.HK_SnapCount_ResultType_Low.equals(params.getOption())){ |
| | | } else if (ApiConstants.HK_SnapCount_ResultType_Low.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Low)); |
| | | } |
| | | } |
| | | long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); |
| | | MongoUtil.setPage(query, params, TIME_FIELD); |
| | | List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); |
| | | resultList.forEach(item ->item.setResultTypeText(item.getResultTypeText())); |
| | | resultList.forEach(item -> item.setResultTypeText(item.getResultTypeText())); |
| | | // 统计数量 |
| | | MongoDatabase database = mongoTemplate.getDb(); |
| | | MongoCollection<Document> collection = database.getCollection("hk_snapshot_data_monitor"); |
| | |
| | | dList3.add(new Document("resultType", new Document("$eq", 2))); |
| | | dList3.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | setTag(params, dList3); |
| | | |
| | | Document noDataFilter = new Document("$and", dList2); |
| | | Document trFilter = new Document("$and", dList3); |
| | | List<Document> lists = Arrays.asList(noDataFilter, trFilter); |
| | | List<Document> dList4 = new ArrayList<>(2); |
| | | dList4.add(new Document("resultType", new Document("$eq", 3))); |
| | | dList4.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | setTag(params, dList4); |
| | | List<Document> dList5 = new ArrayList<>(2); |
| | | dList5.add(new Document("resultType", new Document("$eq", 4))); |
| | | dList5.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | setTag(params, dList5); |
| | | Document normalFilter = new Document("$and", dList2); |
| | | Document noDataFilter = new Document("$and", dList3); |
| | | Document downFilter = new Document("$and", dList4); |
| | | Document lessFilter = new Document("$and", dList5); |
| | | List<Document> lists = Arrays.asList(normalFilter, noDataFilter,downFilter,lessFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | for (Document doc : result) { |
| | | dataCount = doc.getInteger("dataCount"); |
| | | } |
| | | rList.add(0,dataCount+""); |
| | | List<CheckIndexCar> carList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getViewConnectStability) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | rList.add(0, dataCount + ""); |
| | | // List<CheckIndexCar> carList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getViewConnectStability) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .list(); |
| | | // BigDecimal onlineRate = BigDecimal.ZERO; |
| | | // if (CollectionUtils.isNotEmpty(carList)) { |
| | | // BigDecimal sum = carList.stream().map(CheckIndexCar::getViewConnectStability).reduce(BigDecimal.ZERO, BigDecimal::add); |
| | | // BigDecimal count = BigDecimal.valueOf(carList.size()); |
| | | // onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); |
| | | // } |
| | | BigDecimal normal = new BigDecimal(rList.get(1)); |
| | | BigDecimal noData = new BigDecimal(rList.get(2)); |
| | | BigDecimal down = new BigDecimal(rList.get(3)); |
| | | BigDecimal less = new BigDecimal(rList.get(4)); |
| | | BigDecimal totalCount = normal.add(noData).add(down).add(less); |
| | | BigDecimal onlineRate = BigDecimal.ZERO; |
| | | if (CollectionUtils.isNotEmpty(carList)) { |
| | | BigDecimal sum = carList.stream().map(CheckIndexCar::getViewConnectStability).reduce(BigDecimal.ZERO, BigDecimal::add); |
| | | BigDecimal count = BigDecimal.valueOf(carList.size()); |
| | | onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); |
| | | if (totalCount.compareTo(BigDecimal.ZERO)>0) { |
| | | onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | item.setOnlineStr("未知"); |
| | | } |
| | | List<String> offLineTime = item.getOffLineTimeStr(); |
| | | if(!CollectionUtils.isEmpty(offLineTime)) { |
| | | if (!CollectionUtils.isEmpty(offLineTime)) { |
| | | //后续可以改成配置的离线次数(提取前n次,n为配置的离线次数) |
| | | if (offLineTime.size() > 1) { |
| | | offLineTime = offLineTime.subList(0, 2); |
| | |
| | | totalCount = offlineCount + unknownCount + onlineCount; |
| | | } |
| | | |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getSiteOnline) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getSiteOnline) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (totalCount!=0) { |
| | | onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); |
| | |
| | | andCriteria.add(Criteria.where("sxjgnlx.value").regex(pattern)); |
| | | Query query = new Query(); |
| | | Criteria and = new Criteria(); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption() ==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | andCriteria.add(Criteria.where("newDevice").is(Boolean.TRUE)); |
| | | }else if(params.getOption() ==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | andCriteria.add(Criteria.where("newDevice").is(Boolean.FALSE)); |
| | | } |
| | | } |
| | |
| | | List<Document> dList1 = new ArrayList<>(2); |
| | | setTag(params, dList1); |
| | | dList1.add(new Document("sxjgnlx.value", new Document("$regex", ".*2.*"))); |
| | | Document totalFilter = new Document("$and",dList1); |
| | | Document totalFilter = new Document("$and", dList1); |
| | | //新设备数 |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | setTag(params, dList2); |
| | | dList2.add(new Document("sxjgnlx.value", new Document("$regex", ".*2.*"))); |
| | | dList2.add(new Document("newDevice",Boolean.TRUE)); |
| | | Document newFilter = new Document("$and",dList2); |
| | | dList2.add(new Document("newDevice", Boolean.TRUE)); |
| | | Document newFilter = new Document("$and", dList2); |
| | | |
| | | List<Document> lists = Arrays.asList(totalFilter, newFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getDeviceDirectoryConsistent) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getDeviceDirectoryConsistent) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | Criteria and = new Criteria(); |
| | | and.andOperator(andCriteria); |
| | | query = Query.query(and); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption() ==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("lalType").is(ApiConstants.HK_Info_LayType_Normal)); |
| | | query.addCriteria(Criteria.where("gbCodeType").is(ApiConstants.HK_Info_GbCodeType_Normal)); |
| | | }else if(params.getOption() ==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | Criteria lalType = Criteria.where("lalType").ne(ApiConstants.HK_Info_LayType_Normal); |
| | | Criteria gbCodeType = Criteria.where("gbCodeType").ne(ApiConstants.HK_Info_GbCodeType_Normal); |
| | | Criteria orOperator = new Criteria().orOperator(lalType, gbCodeType); |
| | |
| | | List<Document> dList3 = new ArrayList<>(2); |
| | | setTag(params, dList3); |
| | | List<Document> errorConditions = new ArrayList<>(); |
| | | errorConditions.add(new Document("lalType",new Document("$ne",1))); |
| | | errorConditions.add(new Document("gbCodeType",new Document("$ne",1))); |
| | | Document errorDoc = new Document("$or",errorConditions); |
| | | errorConditions.add(new Document("lalType", new Document("$ne", 1))); |
| | | errorConditions.add(new Document("gbCodeType", new Document("$ne", 1))); |
| | | Document errorDoc = new Document("$or", errorConditions); |
| | | dList3.add(errorDoc); |
| | | Document totalFilter = new Document("$and", dList1); |
| | | Document correctFilter = new Document("$and", dList2); |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getVehicleInformationCollectionAccuracy) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getVehicleInformationCollectionAccuracy) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | public Result vehicleCollectionDataIntegrity(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if (params.getOption() != null) { |
| | | //主要属性不完整 |
| | | if(params.getOption()==1){ |
| | | query.addCriteria(Criteria.where("noIntegrityCount").gt(0)); |
| | | }else if(params.getOption()==-1){ |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("noIntegrityCount").gt(0)); |
| | | } else if (params.getOption() == -1) { |
| | | //属性不完整 |
| | | query.addCriteria(Criteria.where("mainNoIntegrityCount").gt(0)); |
| | | } |
| | |
| | | mainNoIntegrityCount = doc.getInteger("mainNoIntegrityCount"); |
| | | } |
| | | |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getVehicleCaptureIntegrity) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .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)); |
| | | } |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getVehicleCaptureIntegrity) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | List<String> countList = new ArrayList<>(); |
| | | countList.add(dataCount+""); |
| | | countList.add(noIntegrityCount+""); |
| | | countList.add(mainNoIntegrityCount+""); |
| | | countList.add(dataCount + ""); |
| | | countList.add(noIntegrityCount + ""); |
| | | countList.add(mainNoIntegrityCount + ""); |
| | | BigDecimal onlineRate = BigDecimal.ZERO; |
| | | if (dataCount!=0) { |
| | | onlineRate = new BigDecimal(dataCount-noIntegrityCount).divide(new BigDecimal(dataCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | countList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", countList); |
| | |
| | | public Result vehicleCollectionDataCaptured(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if (params.getOption() != null) { |
| | | //主要属性不一致 |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("majorDiffCount").gt(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | //重要属性不一致 |
| | | query.addCriteria(Criteria.where("importantDiffCount").gt(0)); |
| | | } |
| | |
| | | importantDiffCount = doc.getInteger("importantDiffCount"); |
| | | } |
| | | |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getVehicleCaptureAccuracy) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .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)); |
| | | } |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getVehicleCaptureAccuracy) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | |
| | | List<String> countList = new ArrayList<>(); |
| | | countList.add(sampleCount+""); |
| | | countList.add(majorDiffCount+""); |
| | | countList.add(importantDiffCount+""); |
| | | countList.add(sampleCount + ""); |
| | | countList.add(majorDiffCount + ""); |
| | | countList.add(importantDiffCount + ""); |
| | | BigDecimal onlineRate = BigDecimal.ZERO; |
| | | if (sampleCount!=0) { |
| | | onlineRate = new BigDecimal(sampleCount-majorDiffCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | countList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", countList); |
| | |
| | | public Result vehicleClockAccuracy(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if (params.getOption() != null) { |
| | | //当日时钟异常 |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("majorDiffCount").gt(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | //全部时钟异常 |
| | | query.addCriteria(Criteria.where("importantDiffCount").gt(0)); |
| | | } |
| | |
| | | MongoUtil.setPage(query, params, TIME_FIELD); |
| | | List<VehicleDeviceInspectionResult> resultList = mongoTemplate.find(query, VehicleDeviceInspectionResult.class); |
| | | List<SnapClockVO> resultVos = new ArrayList<>(); |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | SnapClockVO vo = VehicleDeviceInspectionResult.getVO(item); |
| | | resultVos.add(vo); |
| | | }); |
| | |
| | | Document allFilter = new Document("$and", dList3); |
| | | Document allErrFilter = new Document("$and", dList4); |
| | | |
| | | List<Document> lists = Arrays.asList(todayFilter, todayErrFilter, allFilter,allErrFilter); |
| | | List<Document> lists = Arrays.asList(todayFilter, todayErrFilter, allFilter, allErrFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getVehicleTimingAccuracy) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getVehicleTimingAccuracy) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | BigDecimal normal = new BigDecimal(rList.get(0)); |
| | | BigDecimal abnormal = new BigDecimal(rList.get(1)); |
| | | BigDecimal totalCount = normal.add(abnormal); |
| | | if (totalCount.compareTo(BigDecimal.ZERO)>0) { |
| | | onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_CAR)); |
| | | if(params.getOption()!=null){ |
| | | if (params.getOption() != null) { |
| | | //正常 |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("delayCount").is(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | //延迟 |
| | | query.addCriteria(Criteria.where("delayCount").gt(0)); |
| | | } |
| | |
| | | |
| | | List<Document> dList1 = new ArrayList<>(2); |
| | | setTag(params, dList1); |
| | | dList1.add(new Document("dataType" ,new Document("$eq",ApiConstants.HK_DataType_CAR))); |
| | | dList1.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | Document allFilter = new Document("$and", dList1); |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | dList2.add(new Document("dataType" ,new Document("$eq",ApiConstants.HK_DataType_CAR))); |
| | | dList2.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | dList2.add(new Document("delayCount", new Document("$gt", 0))); |
| | | setTag(params, dList2); |
| | | Document delayFilter = new Document("$and", dList2); |
| | | |
| | | List<Document> lists = Arrays.asList(allFilter,delayFilter); |
| | | List<Document> lists = Arrays.asList(allFilter, delayFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | }).collect(Collectors.toList()); |
| | | |
| | | |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getVehicleUploadTimeliness) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getVehicleUploadTimeliness) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | public Result vehicleUrlAccuracy(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("expCount").is(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | query.addCriteria(Criteria.where("expCount").gt(0)); |
| | | } |
| | | } |
| | |
| | | onlineRate = sum.divide(count, 4, RoundingMode.HALF_UP).multiply(BigDecimal.valueOf(100)); |
| | | } |
| | | List<String> rList = new ArrayList<>(); |
| | | rList.add(sampleCount+""); |
| | | rList.add(expCount+""); |
| | | rList.add(sampleCount + ""); |
| | | rList.add(expCount + ""); |
| | | rList.add(this.remove0(onlineRate)); |
| | | |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | public Result vehicleBigImgAccuracy(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").is(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").gt(0)); |
| | | } |
| | | } |
| | |
| | | query.with(Sort.by(Sort.Order.desc("bigUseful.bigPicExpCount"))); |
| | | List<VehicleDeviceSamplingResult> resultList = mongoTemplate.find(query, VehicleDeviceSamplingResult.class); |
| | | List<BigPicUsefulVO> voList = new ArrayList<>(); |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | BigPicUsefulVO picVO = VehicleDeviceSamplingResult.getPicVO(item); |
| | | voList.add(picVO); |
| | | }); |
| | |
| | | expCount = doc.getInteger("expCount"); |
| | | } |
| | | List<String> countList = new ArrayList<>(); |
| | | List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | .select(CheckIndexCar::getVehiclePictureAvailability) |
| | | .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexCar> videoList = new LambdaQueryChainWrapper<>(checkIndexCarService.getBaseMapper()) |
| | | // .select(CheckIndexCar::getVehiclePictureAvailability) |
| | | // .eq(params.getDataType().equals(1), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexCar::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexCar::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | countList.add(sampleCount + ""); |
| | | countList.add(expCount + ""); |
| | | 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)); |
| | | if (sampleCount!=0) { |
| | | onlineRate = new BigDecimal(sampleCount-expCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | countList.add(sampleCount+""); |
| | | countList.add(expCount+""); |
| | | countList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", countList); |
| | |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | //加DataType为车辆 |
| | | query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_FACE)); |
| | | if(params.getOption()!=null){ |
| | | if(ApiConstants.HK_SnapCount_ResultType_Normal.equals(params.getOption())) { |
| | | if (params.getOption() != null) { |
| | | if (ApiConstants.HK_SnapCount_ResultType_Normal.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Normal)); |
| | | }else if(ApiConstants.HK_SnapCount_ResultType_Null.equals(params.getOption())){ |
| | | } else if (ApiConstants.HK_SnapCount_ResultType_Null.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Null)); |
| | | }else if(ApiConstants.HK_SnapCount_ResultType_Descent.equals(params.getOption())){ |
| | | } else if (ApiConstants.HK_SnapCount_ResultType_Descent.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Descent)); |
| | | }else if(ApiConstants.HK_SnapCount_ResultType_Low.equals(params.getOption())){ |
| | | } else if (ApiConstants.HK_SnapCount_ResultType_Low.equals(params.getOption())) { |
| | | query.addCriteria(Criteria.where("resultType").is(ApiConstants.HK_SnapCount_ResultType_Low)); |
| | | } |
| | | } |
| | | long total = mongoTemplate.count(query, SnapshotDataMonitorResult.class); |
| | | MongoUtil.setPage(query, params, TIME_FIELD); |
| | | List<SnapshotDataMonitorResult> resultList = mongoTemplate.find(query, SnapshotDataMonitorResult.class); |
| | | resultList.forEach(item ->item.setResultTypeText(item.getResultTypeText())); |
| | | resultList.forEach(item -> item.setResultTypeText(item.getResultTypeText())); |
| | | // 统计数量 |
| | | MongoDatabase database = mongoTemplate.getDb(); |
| | | MongoCollection<Document> collection = database.getCollection("hk_snapshot_data_monitor"); |
| | |
| | | dList3.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | setTag(params, dList3); |
| | | |
| | | Document noDataFilter = new Document("$and", dList2); |
| | | Document trFilter = new Document("$and", dList3); |
| | | List<Document> lists = Arrays.asList(noDataFilter, trFilter); |
| | | List<Document> dList4 = new ArrayList<>(2); |
| | | dList4.add(new Document("resultType", new Document("$eq", 3))); |
| | | dList4.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | setTag(params, dList4); |
| | | List<Document> dList5 = new ArrayList<>(2); |
| | | dList5.add(new Document("resultType", new Document("$eq", 4))); |
| | | dList5.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_CAR))); |
| | | setTag(params, dList5); |
| | | Document normalFilter = new Document("$and", dList2); |
| | | Document noDataFilter = new Document("$and", dList3); |
| | | Document downFilter = new Document("$and", dList4); |
| | | Document lessFilter = new Document("$and", dList5); |
| | | List<Document> lists = Arrays.asList(normalFilter, noDataFilter,downFilter,lessFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | for (Document doc : result) { |
| | | dataCount = doc.getInteger("dataCount"); |
| | | } |
| | | rList.add(0,dataCount+""); |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getViewConnectStability) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | rList.add(0, dataCount + ""); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getViewConnectStability) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | BigDecimal normal = new BigDecimal(rList.get(1)); |
| | | BigDecimal noData = new BigDecimal(rList.get(2)); |
| | | BigDecimal down = new BigDecimal(rList.get(3)); |
| | | BigDecimal less = new BigDecimal(rList.get(4)); |
| | | BigDecimal totalCount = normal.add(noData).add(down).add(less); |
| | | 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)); |
| | | if (totalCount.compareTo(BigDecimal.ZERO)>0) { |
| | | onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | item.setOnlineStr("未知"); |
| | | } |
| | | List<String> offLineTime = item.getOffLineTimeStr(); |
| | | if(!CollectionUtils.isEmpty(offLineTime)) { |
| | | if (!CollectionUtils.isEmpty(offLineTime)) { |
| | | //后续可以改成配置的离线次数(提取前n次,n为配置的离线次数) |
| | | if (offLineTime.size() > 1) { |
| | | offLineTime = offLineTime.subList(0, 2); |
| | |
| | | onlineCount = (Integer) result.getOrDefault("onlineCount", 0L); |
| | | totalCount = offlineCount + unknownCount + onlineCount; |
| | | } |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getSiteOnline) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | .list(); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getSiteOnline) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, params.getStartTime(), params.getEndTime()) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (totalCount!=0) { |
| | | onlineRate = new BigDecimal(onlineCount).divide(new BigDecimal(totalCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", Arrays.asList(totalCount + "", onlineCount + "", offlineCount + "", unknownCount + "", this.remove0(onlineRate))); |
| | | map.put("list", resultList); |
| | |
| | | andCriteria.add(Criteria.where("sxjgnlx.value").regex(pattern)); |
| | | Query query = new Query(); |
| | | Criteria and = new Criteria(); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption() ==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | andCriteria.add(Criteria.where("newDevice").is(Boolean.TRUE)); |
| | | }else if(params.getOption() ==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | andCriteria.add(Criteria.where("newDevice").is(Boolean.FALSE)); |
| | | } |
| | | } |
| | |
| | | List<Document> dList1 = new ArrayList<>(2); |
| | | setTag(params, dList1); |
| | | dList1.add(new Document("sxjgnlx.value", new Document("$regex", ".*3.*"))); |
| | | Document totalFilter = new Document("$and",dList1); |
| | | Document totalFilter = new Document("$and", dList1); |
| | | //新设备数 |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | setTag(params, dList2); |
| | | dList2.add(new Document("sxjgnlx.value", new Document("$regex", ".*3.*"))); |
| | | dList2.add(new Document("newDevice",Boolean.TRUE)); |
| | | Document newFilter = new Document("$and",dList2); |
| | | dList2.add(new Document("newDevice", Boolean.TRUE)); |
| | | Document newFilter = new Document("$and", dList2); |
| | | |
| | | List<Document> lists = Arrays.asList(totalFilter, newFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getDeviceDirectoryConsistent) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getDeviceDirectoryConsistent) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | Criteria and = new Criteria(); |
| | | and.andOperator(andCriteria); |
| | | query = Query.query(and); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption() ==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("lalType").is(ApiConstants.HK_Info_LayType_Normal)); |
| | | query.addCriteria(Criteria.where("gbCodeType").is(ApiConstants.HK_Info_GbCodeType_Normal)); |
| | | }else if(params.getOption() ==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | Criteria lalType = Criteria.where("lalType").ne(ApiConstants.HK_Info_LayType_Normal); |
| | | Criteria gbCodeType = Criteria.where("gbCodeType").ne(ApiConstants.HK_Info_GbCodeType_Normal); |
| | | Criteria orOperator = new Criteria().orOperator(lalType, gbCodeType); |
| | |
| | | List<Document> dList3 = new ArrayList<>(2); |
| | | setTag(params, dList3); |
| | | List<Document> errorConditions = new ArrayList<>(); |
| | | errorConditions.add(new Document("lalType",new Document("$ne",1))); |
| | | errorConditions.add(new Document("gbCodeType",new Document("$ne",1))); |
| | | Document errorDoc = new Document("$or",errorConditions); |
| | | errorConditions.add(new Document("lalType", new Document("$ne", 1))); |
| | | errorConditions.add(new Document("gbCodeType", new Document("$ne", 1))); |
| | | Document errorDoc = new Document("$or", errorConditions); |
| | | dList3.add(errorDoc); |
| | | Document totalFilter = new Document("$and", dList1); |
| | | Document correctFilter = new Document("$and", dList2); |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getFaceInformationCollectionAccuracy) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getFaceInformationCollectionAccuracy) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(1)).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | public Result faceImgQualification(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "cameraName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("faceEligibility.unfaceEligCount").is(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | query.addCriteria(Criteria.where("faceEligibility.unfaceEligCount").gt(0)); |
| | | } |
| | | } |
| | |
| | | MongoUtil.setPage(query, params, TIME_FIELD); |
| | | List<FaceDeviceSamplingResult> resultList = mongoTemplate.find(query, FaceDeviceSamplingResult.class); |
| | | List<BigPicUsefulVO> voList = new ArrayList<>(); |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | BigPicUsefulVO picVO = FaceDeviceSamplingResult.getEligeVO(item); |
| | | voList.add(picVO); |
| | | }); |
| | |
| | | } |
| | | List<String> countList = new ArrayList<>(); |
| | | |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getFacePictureQualification) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getFacePictureQualification) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | countList.add(sampleCount + ""); |
| | | countList.add(expCount + ""); |
| | | 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)); |
| | | if (sampleCount!=0) { |
| | | onlineRate = new BigDecimal(sampleCount-expCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | countList.add(sampleCount+""); |
| | | countList.add(expCount+""); |
| | | countList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", countList); |
| | |
| | | public Result faceCapturesImagesAccuracy(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if (params.getOption() != null) { |
| | | //当日时钟异常 |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("majorDiffCount").gt(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | //全部时钟异常 |
| | | query.addCriteria(Criteria.where("importantDiffCount").gt(0)); |
| | | } |
| | |
| | | MongoUtil.setPage(query, params, TIME_FIELD); |
| | | List<FaceDeviceInspectionResult> resultList = mongoTemplate.find(query, FaceDeviceInspectionResult.class); |
| | | List<SnapClockVO> resultVos = new ArrayList<>(); |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | SnapClockVO vo = FaceDeviceInspectionResult.getVO(item); |
| | | resultVos.add(vo); |
| | | }); |
| | |
| | | Document allErrFilter = new Document("$and", dList4); |
| | | |
| | | |
| | | List<Document> lists = Arrays.asList(todayFilter, todayErrFilter, allFilter,allErrFilter); |
| | | List<Document> lists = Arrays.asList(todayFilter, todayErrFilter, allFilter, allErrFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | return uniqueDeviceIdCount + ""; |
| | | }).collect(Collectors.toList()); |
| | | |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getFaceTimingAccuracy) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getFaceTimingAccuracy) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | BigDecimal normal = new BigDecimal(rList.get(0)); |
| | | BigDecimal abnormal = new BigDecimal(rList.get(1)); |
| | | BigDecimal totalCount = normal.add(abnormal); |
| | | if (totalCount.compareTo(BigDecimal.ZERO)>0) { |
| | | onlineRate = normal.divide(totalCount, 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | query.addCriteria(Criteria.where("dataType").is(ApiConstants.HK_DataType_FACE)); |
| | | if(params.getOption()!=null){ |
| | | if (params.getOption() != null) { |
| | | //正常 |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("delayCount").is(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | //延迟 |
| | | query.addCriteria(Criteria.where("delayCount").gt(0)); |
| | | } |
| | |
| | | |
| | | List<Document> dList1 = new ArrayList<>(2); |
| | | setTag(params, dList1); |
| | | dList1.add(new Document("dataType" ,new Document("$eq",ApiConstants.HK_DataType_FACE))); |
| | | dList1.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_FACE))); |
| | | Document allFilter = new Document("$and", dList1); |
| | | List<Document> dList2 = new ArrayList<>(2); |
| | | dList2.add(new Document("dataType" ,new Document("$eq",ApiConstants.HK_DataType_FACE))); |
| | | dList2.add(new Document("dataType", new Document("$eq", ApiConstants.HK_DataType_FACE))); |
| | | dList2.add(new Document("delayCount", new Document("$gt", 0))); |
| | | setTag(params, dList2); |
| | | Document delayFilter = new Document("$and", dList2); |
| | | |
| | | List<Document> lists = Arrays.asList(allFilter,delayFilter); |
| | | List<Document> lists = Arrays.asList(allFilter, delayFilter); |
| | | List<String> rList = lists.stream().map(filter -> { |
| | | // 构建聚合管道 |
| | | List<Document> pipeline = Arrays.asList( |
| | |
| | | }).collect(Collectors.toList()); |
| | | |
| | | |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getFaceUploadTimeliness) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getFaceUploadTimeliness) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | 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)); |
| | | if (!StringUtils.isEmpty(rList.get(0)) && !"0".equals(rList.get(0))) { |
| | | onlineRate = new BigDecimal(rList.get(0)).subtract(new BigDecimal(rList.get(1))).divide(new BigDecimal(rList.get(0)), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | rList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | |
| | | public Result faceAvailabilityOfLargeImg(DataCenterQuery params) { |
| | | List<String> likeFileds = Arrays.asList("externalIndexCode", "deviceName"); |
| | | Query query = MongoUtil.getQuery(params, TIME_FIELD, likeFileds, null); |
| | | if(params.getOption()!=null){ |
| | | if(params.getOption()==1){ |
| | | if (params.getOption() != null) { |
| | | if (params.getOption() == 1) { |
| | | query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").is(0)); |
| | | }else if(params.getOption()==-1){ |
| | | } else if (params.getOption() == -1) { |
| | | query.addCriteria(Criteria.where("bigUseful.bigPicExpCount").gt(0)); |
| | | } |
| | | } |
| | |
| | | query.with(Sort.by(Sort.Order.desc("bigUseful.bigPicExpCount"))); |
| | | List<FaceDeviceSamplingResult> resultList = mongoTemplate.find(query, FaceDeviceSamplingResult.class); |
| | | List<BigPicUsefulVO> voList = new ArrayList<>(); |
| | | resultList.forEach(item->{ |
| | | resultList.forEach(item -> { |
| | | BigPicUsefulVO picVO = FaceDeviceSamplingResult.getPicVO(item); |
| | | voList.add(picVO); |
| | | }); |
| | |
| | | List<String> countList = new ArrayList<>(); |
| | | |
| | | // 统计数 |
| | | List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | .select(CheckIndexFace::getFacePictureAvailability) |
| | | .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | .list(); |
| | | // List<CheckIndexFace> videoList = new LambdaQueryChainWrapper<>(checkIndexFaceService.getBaseMapper()) |
| | | // .select(CheckIndexFace::getFacePictureAvailability) |
| | | // .eq(params.getDataType().equals(1), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Province) |
| | | // .eq(params.getDataType().equals(2), CheckIndexFace::getExamineTag, CheckConstants.Examine_Tag_Dept) |
| | | // .between(CheckIndexFace::getCreateTime, DateUtils.getDayStart(params.getStartTime()), DateUtils.getDayEnd(params.getEndTime())) |
| | | // .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)); |
| | | // } |
| | | countList.add(sampleCount + ""); |
| | | countList.add(expCount + ""); |
| | | 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)); |
| | | if (sampleCount!=0) { |
| | | onlineRate = new BigDecimal(sampleCount-expCount).divide(new BigDecimal(sampleCount), 3,RoundingMode.DOWN).multiply(new BigDecimal("100")); |
| | | } |
| | | countList.add(sampleCount+""); |
| | | countList.add(expCount+""); |
| | | countList.add(this.remove0(onlineRate)); |
| | | HashMap<String, Object> map = new HashMap<>(); |
| | | map.put("count", countList); |
| | |
| | | dList.add(new Document("deptTag", new Document("$eq", Boolean.TRUE))); |
| | | } |
| | | Document mongoCreateTimeRange = new Document(); |
| | | if (params.getStartTime()!=null) mongoCreateTimeRange.append("$gte", params.getStartTime()); |
| | | if (params.getEndTime()!=null) mongoCreateTimeRange .append("$lt", params.getEndTime()); |
| | | if (params.getStartTime() != null) mongoCreateTimeRange.append("$gte", params.getStartTime()); |
| | | if (params.getEndTime() != null) mongoCreateTimeRange.append("$lt", params.getEndTime()); |
| | | dList.add(new Document("mongoCreateTime", mongoCreateTimeRange)); |
| | | } |
| | | } |