From 2524b13661d714e15ecb0ccf72c7e8c3f4d2458b Mon Sep 17 00:00:00 2001 From: hzj <826100833@qq.com> Date: Tue, 11 Nov 2025 11:00:04 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9A=82=E6=80=81=E4=BA=8B=E4=BB=B6=E5=90=8C?= =?UTF-8?q?=E6=AD=A5=E6=8E=92=E9=99=A4=E4=BB=A5=E5=90=8C=E6=AD=A5=E7=9A=84?= =?UTF-8?q?=E4=BA=8B=E4=BB=B6?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../product/event/dataTransmit/DataSynchronization.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java b/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java index 624d836..3a98656 100644 --- a/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java +++ b/event_smart/src/main/java/com/njcn/product/event/dataTransmit/DataSynchronization.java @@ -215,12 +215,12 @@ public class DataSynchronization { String exportDirName = String.format("%s/%s/%s.json","/event", filePath,"bz_"+fileName); // 查询失败的暂降事件 LambdaQueryWrapper statusPOLambdaQueryWrapper = new LambdaQueryWrapper<>(); - statusPOLambdaQueryWrapper.between(PqsEventDetailStatusPO::getEventTime,start,end); + statusPOLambdaQueryWrapper.between(PqsEventDetailStatusPO::getSyncTime,start,end); List hasList = pqsEventDetailStatusService.list(statusPOLambdaQueryWrapper); Map pqsEventDetailStatusPOMap = hasList.stream().collect(Collectors.toMap(PqsEventDetailStatusPO::getEventDetailId, Function.identity())); // 查询事件 LambdaQueryWrapper pqsEventdetailLambdaQueryWrapper = new LambdaQueryWrapper<>(); - pqsEventdetailLambdaQueryWrapper.between(PqsEventdetail::getCreateTime,start,end); + pqsEventdetailLambdaQueryWrapper.between(PqsEventdetail::getCreateTime,start.minusMinutes(3*10),end); List unsyncedEvents = pqsEventdetailMapper.selectList(pqsEventdetailLambdaQueryWrapper); List tempEvetIds = unsyncedEvents.stream().map(PqsEventdetail::getEventdetailIndex).collect(Collectors.toList()); //查询日志 @@ -259,7 +259,7 @@ public class DataSynchronization { List pqLinedetails = pqLinedetailMapper.selectList(null); Map lineDetailMap = pqLinedetails.stream().collect(Collectors.toMap(PqLinedetail::getLineIndex, Function.identity())); - unSyncIds.forEach(temp->{ + eventIds.forEach(temp->{ PqsEventdetail pqsEventdetail = pqsEventdetailMap.get(temp); if(pqsEventDetailStatusPOMap.containsKey(temp)){