（部级录像可用率，重点录像可用率，录像可用率）计算可用率

zxl

2025-05-12 fdcdd41fba7874c045766e3dea54d56d70df73ef

 ycl-server/src/main/java/com/ycl/task/UYTask.java

@@ -194,6 +194,8 @@
        } else {
            log.error("请配置离线次数，此次设置为默认值2");
        }


        // 先查出设备IP集合,剔除掉在线情况是未知的,并且只检测正在考核的设备避免多余工单
        List<TMonitorResult> monitorList = monitorMapper.getDistinctIP();
        //补充错误时间点
@@ -230,6 +232,7 @@
        CompletableFuture<Void> allOf = CompletableFuture.allOf(
                futureList.toArray(new CompletableFuture[0])
        );

        try {
            allOf.get(60, TimeUnit.SECONDS); // 给予额外的5秒来收集结果
        } catch (TimeoutException e) {
@@ -243,9 +246,11 @@
                .filter(Objects::nonNull)
                .collect(Collectors.toList());


        Date now = new Date();
        List<String> offLineList = new ArrayList<>();
        List<String> onLineList = new ArrayList<>();
        List<String> unKnownList = new ArrayList<>();
        //查出数据库纯车辆或纯人脸设备
//        List<String> serialNumbers = monitorMapper.selectCarOrFace().stream().map(TMonitor::getSerialNumber).collect(Collectors.toList());
        dataList.forEach(item->{
@@ -254,12 +259,17 @@
            } else if(!item.getPingOnline()) {
                //筛选出ping离线的设备，更改数据库为离线
                offLineList.add(item.getIp());
            }else {
                unKnownList.add(item.getIp());
            }
        });
        log.error("unKnownList:{}",unKnownList);
        if(!CollectionUtils.isEmpty(offLineList)) {
            log.error("修改离线的点位集合:{}",offLineList);
            monitorMapper.batchUpdateOnline(offLineList, now, ApiConstants.UY_OnlineSite_Offline);
        }
        if(!CollectionUtils.isEmpty(onLineList)) {
            log.error("修改在线的点位集合:{}",onLineList);
            monitorMapper.batchUpdateOnline(onLineList, now, ApiConstants.UY_OnlineSite_Online);
        }
        //存放到mongo
@@ -289,6 +299,8 @@
            Query query = new Query(Criteria.where("mongoCreateTime").gte(DateUtils.getDayStart(new Date())).lt(DateUtils.getDayEnd(new Date())));
            DeleteResult result = mongoTemplate.remove(query, TMonitorResult.class);
            //存放在mongo中

            log.error("存入同步在线mongo数据{}" , mongoList );
            mongoTemplate.insertAll(mongoList);
        }
        //工单（同一IP只生成一个工单）
@@ -306,6 +318,7 @@
                .map(TMonitorResult::getWorkOrder)
                .collect(Collectors.toList());
        if (!CollectionUtils.isEmpty(workOrderList)) {
            log.error("pointOnline获得插入工单:{}",workOrderList);
            workOrderService.innerAddWorkOrder(workOrderList);
        }
        log.info("点位在线监测完成");