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 itemStatus = - group.read(true, (Item[]) itemsMap.values().toArray(new Item[0])); + Map 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 e = group.write(requests); + Map 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());