From cf86c1392cafe0ef5844cba235da5a0a716a95ee Mon Sep 17 00:00:00 2001 From: weidong Date: Mon, 9 Sep 2024 21:01:33 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BC=98=E5=8C=96=E9=AB=98=E7=A8=8B=E8=B7=9F?= =?UTF-8?q?=E8=B8=AA=E7=AE=97=E6=B3=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../sideslope/task/AbnormalDeviceProcessor.java | 13 ++++++++++--- 1 file changed, 10 insertions(+), 3 deletions(-) diff --git a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/task/AbnormalDeviceProcessor.java b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/task/AbnormalDeviceProcessor.java index 91520dd0..5b9b53ba 100644 --- a/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/task/AbnormalDeviceProcessor.java +++ b/sec-beidou-rtcm/src/main/java/com/imdroid/sideslope/task/AbnormalDeviceProcessor.java @@ -104,7 +104,6 @@ public class AbnormalDeviceProcessor{ } void insertData(String noDataDeviceId,double refGnssData1[],double refGnssData2[]){ - logger.debug("{} abnormal process"); if(refGnssData1!=null && refGnssData2!=null){ logger.debug("{} delta: {},{},{}",noDataDeviceId, (refGnssData1[0]+refGnssData2[0])/2, @@ -150,7 +149,7 @@ public class AbnormalDeviceProcessor{ queryWrapper.eq("deviceid",deviceId); queryWrapper.eq("enabled",true); queryWrapper.isNotNull("rpose"); - queryWrapper.ge("createtime",now.minusHours(24)); + queryWrapper.ge("createtime",now.minusHours(2)); queryWrapper.orderByDesc("createtime"); queryWrapper.last("limit 2"); @@ -158,9 +157,17 @@ public class AbnormalDeviceProcessor{ } void checkNotGoodDevice(String deviceId, String refDeviceId1){ + LocalDateTime validTime = LocalDateTime.now().minusMinutes(10); + // 待修改的点 List calcDataList = getLastTwo(deviceId); + if(calcDataList.size() == 2){ + if(calcDataList.get(0).getCreatetime().isBefore(validTime)) return; + } + else return; + // 参考点 List calcDataList1 = getLastTwo(refDeviceId1); - if(calcDataList.size() == 2 && calcDataList1.size()==2){ + if(calcDataList1.size()==2){ + if(calcDataList1.get(0).getCreatetime().isBefore(validTime)) return; double deltaU = calcDataList1.get(0).getRposd() - calcDataList1.get(1).getRposd(); GnssCalcData calcData = calcDataList.get(0); calcData.setRposd(calcDataList.get(1).getRposd()+deltaU);