From 36a00aa8bee92f62470fc1031c8c07f3de35910d Mon Sep 17 00:00:00 2001 From: fuliqi <fuliqi@qq.com> Date: 星期三, 15 一月 2025 17:53:25 +0800 Subject: [PATCH] osd不做筛选,检测全量 --- ycl-server/src/main/java/com/ycl/task/HKTask.java | 48 ++++++++++++++++++++++++------------------------ 1 files changed, 24 insertions(+), 24 deletions(-) diff --git a/ycl-server/src/main/java/com/ycl/task/HKTask.java b/ycl-server/src/main/java/com/ycl/task/HKTask.java index 759cf0e..91b9159 100644 --- a/ycl-server/src/main/java/com/ycl/task/HKTask.java +++ b/ycl-server/src/main/java/com/ycl/task/HKTask.java @@ -204,23 +204,24 @@ TMonitor monitor = map.get(item.getExternalIndexCode()); item.setIp(monitor.getIp()); }); - List<UpdateOnlineVO> willUpdateList = totalResult.stream().map(item -> { - UpdateOnlineVO vo = new UpdateOnlineVO(); - vo.setOnline(item.getDataCount() > 0 ? 1 : -1); - vo.setIp(map.get(item.getExternalIndexCode()).getIp()); - vo.setUpdateTime(now); - return vo; - }).collect(Collectors.toList()); - monitorMapper.updateOnlineFromUyOrHk(willUpdateList); - //绂荤嚎鐢熸垚宸ュ崟,涓�涓猧p鍙敓鎴愪竴涓伐鍗� - List<SnapshotDataMonitorResult> workOrders = new ArrayList<>(totalResult.stream() - .filter(item -> ApiConstants.UY_OnlineSite_Offline.equals(item.getDataCount() > 0 ? 1 : -1)) - .collect(Collectors.toMap( - SnapshotDataMonitorResult::getIp, - Function.identity(), - (existing, replacement) -> existing // 濡傛灉閬囧埌鐩稿悓鐨� IP锛屼繚鐣欑涓�涓紙existing锛� - )).values()); - uyErrorTypeCheckService.hkOnlineCheck(workOrders); + //娴峰悍涓嶅仛鍦ㄧ嚎鐩戞祴 +// List<UpdateOnlineVO> willUpdateList = totalResult.stream().map(item -> { +// UpdateOnlineVO vo = new UpdateOnlineVO(); +// vo.setOnline(item.getDataCount() > 0 ? 1 : -1); +// vo.setIp(map.get(item.getExternalIndexCode()).getIp()); +// vo.setUpdateTime(now); +// return vo; +// }).collect(Collectors.toList()); +// monitorMapper.updateOnlineFromUyOrHk(willUpdateList); +// //绂荤嚎鐢熸垚宸ュ崟,涓�涓猧p鍙敓鎴愪竴涓伐鍗� +// List<SnapshotDataMonitorResult> workOrders = new ArrayList<>(totalResult.stream() +// .filter(item -> ApiConstants.UY_OnlineSite_Offline.equals(item.getDataCount() > 0 ? 1 : -1)) +// .collect(Collectors.toMap( +// SnapshotDataMonitorResult::getIp, +// Function.identity(), +// (existing, replacement) -> existing // 濡傛灉閬囧埌鐩稿悓鐨� IP锛屼繚鐣欑涓�涓紙existing锛� +// )).values()); +// uyErrorTypeCheckService.hkOnlineCheck(workOrders); } log.info("缁撴潫鎶撴媿鏁版嵁閲忔娴嬬粨鏋滄暟鎹悓姝�"); } @@ -581,24 +582,23 @@ car.setViewConnectStability(new BigDecimal(score.getDownCarDataUploadScoreString() == null ? "1" : score.getDownCarDataUploadScoreString())); car.setSiteOnline(new BigDecimal(score.getDownCrossQualityCarScoreString() == null ? "1" : score.getDownCrossQualityCarScoreString())); car.setDeviceDirectoryConsistent(new BigDecimal(score.getDownCrossNumPushCarScoreString() == null ? "1" : score.getDownCrossNumPushCarScoreString())); - //TODO:寰呭畬鍠� + //TODO:娌℃壘鍒拌�冩牳椤� car.setVehicleInformationCollectionAccuracy(new BigDecimal("1")); - //TODO:寰呭畬鍠� 閲嶇偣鎬庝箞鍔犺繘鍘� car.setVehicleCaptureIntegrity(new BigDecimal(score.getDownCrossAllCarDataIntegrityScoreString() == null ? "1" : score.getDownCrossAllCarDataIntegrityScoreString())); - //TODO:寰呭畬鍠� 涓や釜椤瑰悎鎴愪竴涓� + //娴峰悍鏄涓�1鐨勶紝浣嗘槸鎺ュ彛鎺ㄧ殑鍘熷鏁版嵁 car.setVehicleCaptureAccuracy(new BigDecimal("1")); car.setVehicleTimingAccuracy(new BigDecimal(score.getDownCrossCarInvertScoreString() == null ? "1" : score.getDownCrossCarInvertScoreString())); car.setVehicleUploadTimeliness(new BigDecimal(score.getDownCrossAllCarDelayScoreString() == null ? "1" : score.getDownCrossAllCarDelayScoreString())); - //TODO:寰呭畬鍠� + //TODO:娌℃壘鍒拌�冩牳椤� car.setVehicleUrlAvailability(new BigDecimal("1")); car.setVehiclePictureAvailability(new BigDecimal(score.getDownCrossPictureQualityCarScoreString() == null ? "1" : score.getDownCrossPictureQualityCarScoreString())); face.setViewConnectStability(new BigDecimal(score.getDownFaceDataUploadScoreString() == null ? "1" : score.getDownFaceDataUploadScoreString())); face.setSiteOnline(new BigDecimal(score.getDownFaceDataUploadScoreString() == null ? "1" : score.getDownFaceDataUploadScoreString())); - face.setDeviceDirectoryConsistent(new BigDecimal(score.getDownCrossNumPushCarScoreString() == null ? "1" : score.getDownCrossNumPushCarScoreString())); - //TODO:寰呭畬鍠� + face.setDeviceDirectoryConsistent(new BigDecimal(score.getDownCrossNumPushFaceScoreString() == null ? "1" : score.getDownCrossNumPushFaceScoreString())); + //TODO:娌℃壘鍒拌�冩牳椤� face.setFaceInformationCollectionAccuracy(new BigDecimal("1")); - //TODO:寰呭畬鍠� + //TODO:娌℃壘鍒拌�冩牳椤� face.setFacePictureQualification(new BigDecimal("1")); face.setFaceTimingAccuracy(new BigDecimal(score.getDownCrossFaceInvertScoreString() == null ? "1" : score.getDownCrossFaceInvertScoreString())); face.setFaceUploadTimeliness(new BigDecimal(score.getDownCrossAllFaceDelayScoreString() == null ? "1" : score.getDownCrossAllFaceDelayScoreString())); -- Gitblit v1.8.0