From 780d2a7b51a4f340ba3ce1b8b90628a82123d45d Mon Sep 17 00:00:00 2001
From: ludj <ldj_willow@163.com>
Date: Sat, 4 Feb 2023 13:18:52 +0800
Subject: [PATCH] =?UTF-8?q?=E8=AF=BB=E5=86=99=E6=AC=A1=E6=95=B0=E6=9B=B4?=
 =?UTF-8?q?=E6=96=B0?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/nl/acs/opc/DeviceOpcProtocolRunable.java  | 15 +++++++++++++--
 .../src/main/java/org/nl/acs/opc/OpcStartTag.java |  2 +-
 .../src/main/java/org/nl/acs/opc/OpcUtl.java      | 13 +++++++++++--
 3 files changed, 25 insertions(+), 5 deletions(-)

diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java b/acs/nladmin-system/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java
index 8f6c42fa0..15639f781 100644
--- a/acs/nladmin-system/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java
+++ b/acs/nladmin-system/src/main/java/org/nl/acs/opc/DeviceOpcProtocolRunable.java
@@ -118,8 +118,19 @@ public class DeviceOpcProtocolRunable implements Runnable {
         while (true) {
           //          System.out.println("label97");
           long begin = System.currentTimeMillis();
-          Map<Item, ItemState> itemStatus =
-              group.read(true, (Item[]) itemsMap.values().toArray(new Item[0]));
+          Map<Item, ItemState> itemStatus =null;
+
+             try{
+               itemStatus=group.read(true, (Item[]) itemsMap.values().toArray(new Item[0]));
+             }catch (Exception e){
+               try{
+                 itemStatus=group.read(true, (Item[]) itemsMap.values().toArray(new Item[0]));
+               }catch (Exception e2){
+                 itemStatus=group.read(true, (Item[]) itemsMap.values().toArray(new Item[0]));
+               }
+             }
+
+
           //TODO 读完释放server可行否?
 
           long end = System.currentTimeMillis();
diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcStartTag.java b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcStartTag.java
index c8ef74e07..0b1679af9 100644
--- a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcStartTag.java
+++ b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcStartTag.java
@@ -1,5 +1,5 @@
 package org.nl.acs.opc;
 
 public class OpcStartTag {
-    public static boolean is_run = true;
+    public static boolean is_run = false;
 }
diff --git a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java
index 154e5972a..35ef44b80 100644
--- a/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java
+++ b/acs/nladmin-system/src/main/java/org/nl/acs/opc/OpcUtl.java
@@ -33,7 +33,17 @@ public class OpcUtl {
 
     public static void writeValue(Group group, WriteRequest... requests) throws WDKException {
         try {
-            Map<Item, Integer> e = group.write(requests);
+            Map<Item, Integer> e=null;
+            try{
+                group.write(requests);
+            }catch (Exception e1){
+               try{
+                   e=  group.write(requests);
+               }catch (Exception e2){
+                 e=  group.write(requests);
+               }
+            }
+
             boolean is_success = true;
             StringBuilder message = new StringBuilder();
             Iterator arg4 = e.keySet().iterator();
@@ -58,7 +68,6 @@ public class OpcUtl {
                 System.out.println("下发信号失败："+message.toString());
                 log.info("下发信号失败："+message.toString());
                 throw new WDKException(message.toString());
-//                group.write(requests);
             }
         } catch (JIException arg7) {
             log.info("下发信号失败："+arg7.getMessage());