From a415a410bf34071b9f6a3c0ef0087864acb4481c Mon Sep 17 00:00:00 2001 From: chendaofei <857448963@qq.com> Date: Fri, 10 Jan 2025 09:08:23 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../gather/detection/handler/SocketDevResponseService.java | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java b/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java index d1b3a065..f6fdc939 100644 --- a/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java +++ b/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java @@ -875,6 +875,11 @@ public class SocketDevResponseService { //FormalTestManager.devXiNumDataMap.put(devData.getId(),) + if(SocketManager.clockMap.containsKey(sourceIssue.getIndex())){ + SocketManager.clockMap.put(sourceIssue.getIndex(),0L); + } + + if (successComm.size() == FormalTestManager.monitorIdListComm.size()) { //TODO 理论上遇到返回code10200的数量与监测点数量一致则认为数据返回结束,但是会存在缺失数据情况,例如有部分装置是没有暂降功能的 System.out.println(sourceIssue.getType() + splitTag + sourceIssue.getIndex() + "当前测试小项读取数据已经全部结束。。。。。。。。。");