批量数据采集方法更新

yyt

2024-02-21 a9406b6b18ee5a8e29cad3248f46320a36ac9749

 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>中查找元素
@@ -168,8 +168,13 @@
      try {
         Class<?> clazz = Class.forName("com.jcdm.main.da.opcuaconfig.cert.MethodName");
         Method method = clazz.getMethod(daOpcuaConfig.getrFunction(), new Class[] { String.class, String.class });
         if (value.isNull()){
            method.invoke(clazz.newInstance(),new Object[] {
                  new String(id.getIdentifier().toString()), new String("") });
         }else{
         method.invoke(clazz.newInstance(),new Object[] {
               new String(id.getIdentifier().toString()), new String(value.getValue().toString()) });
         }
      } catch (ClassNotFoundException | NoSuchMethodException | IllegalAccessException | InstantiationException |
             InvocationTargetException e) {
         e.printStackTrace();
@@ -257,11 +262,14 @@
      log.info("Value={}", value);

      Variant variant = value.getValue();
      log.info("Variant={}", variant.getValue());

      log.info("BackingClass={}", BuiltinDataType.getBackingClass(variant.getDataType().get()));
      if(null == variant.getValue())
      {
         return null;
      }else{
         return variant.getValue().toString();
      }

      return variant.getValue().toString();
   }