更新OPCUA

yyt

2024-02-17 386e107222d673a1ea2781a03a7b1b1d28212f58

 jcdm-main/src/main/java/com/jcdm/main/da/opcuaconfig/client/ClientHandler.java

@@ -157,7 +157,7 @@
   public void handle(NodeId id, Variant value){
      if (b == null || 0 > b.size()) {
         DaOpcuaConfig opcuaConfParam=new DaOpcuaConfig();
          opcuaConfParam.setSubscribe(1L);
          opcuaConfParam.setSubscribe("Y");
          b=daOpcuaConfigService.selectDaOpcuaConfigList(opcuaConfParam);
      }
      //使用Stream API在List<T>中查找元素
@@ -166,7 +166,7 @@
            .findAny()
            .orElse(null);
      try {
         Class<?> clazz = Class.forName(daOpcuaConfig.getrModule());
         Class<?> clazz = Class.forName("com.jcdm.main.da.opcuaconfig.cert.MethodName");
         Method method = clazz.getMethod(daOpcuaConfig.getrFunction(), new Class[] { String.class, String.class });
         method.invoke(clazz.newInstance(),new Object[] {
               new String(id.getIdentifier().toString()), new String(value.getValue().toString()) });
@@ -219,29 +219,6 @@

      return statusCode.isGood();
   }

   /**
    * 方法描述: 读取多个点位的值
    *
    * @param keys 点位集合
    * @return {@link List<DataValue>}
    * @throws
    */
//   public static List<DataValue> readValues2(Set<String> keys){
//      List<NodeId> nodeIdList=new ArrayList<>(500);
//      keys.forEach(e->{
//         NodeId nodeId = new NodeId(2, e);
//         nodeIdList.add(nodeId);
//      });
//      try {
//         List<DataValue> dataValues=client.readValues(0.0, TimestampsToReturn.Both,nodeIdList).get();
//         return dataValues;
//      } catch (InterruptedException | ExecutionException e) {
//         e.printStackTrace();
//      }
//      return null;
//   }


   /**
    * 方法描述: 读取多个点位的值