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

zxl

2025-05-12 fdcdd41fba7874c045766e3dea54d56d70df73ef

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

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

        // 现在需要查出状态为未知的设备

        // 先查出设备IP集合,剔除掉在线情况是未知的,并且只检测正在考核的设备避免多余工单
        List<TMonitorResult> monitorList = monitorMapper.getDistinctIP();
@@ -247,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->{
@@ -258,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
@@ -294,7 +300,7 @@
            DeleteResult result = mongoTemplate.remove(query, TMonitorResult.class);
            //存放在mongo中

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