| | |
| | | package cn.stylefeng.guns.opcua.client; |
| | | |
| | | import cn.stylefeng.guns.base.pojo.page.LayuiPageFactory; |
| | | import cn.stylefeng.guns.base.pojo.page.LayuiPageInfo; |
| | | import cn.stylefeng.guns.opcua.controller.OpcuaConfController; |
| | | import cn.stylefeng.guns.opcua.entity.OpcuaConf; |
| | | import cn.stylefeng.guns.opcua.mapper.OpcuaConfMapper; |
| | | import cn.stylefeng.guns.opcua.model.params.OpcuaConfParam; |
| | | import cn.stylefeng.guns.opcua.model.result.OpcuaConfResult; |
| | | import cn.stylefeng.guns.opcua.service.OpcuaConfService; |
| | | import cn.stylefeng.roses.kernel.model.response.ResponseData; |
| | | import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; |
| | | import com.google.common.collect.ImmutableList; |
| | | import cn.stylefeng.guns.opcua.entity.NodeEntity; |
| | | import lombok.extern.slf4j.Slf4j; |
| | | import org.apache.poi.ss.formula.functions.T; |
| | | import org.eclipse.milo.opcua.sdk.client.OpcUaClient; |
| | | import org.eclipse.milo.opcua.sdk.client.api.nodes.VariableNode; |
| | | import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaSubscription; |
| | |
| | | import org.springframework.beans.factory.annotation.Autowired; |
| | | import org.springframework.stereotype.Service; |
| | | import org.springframework.util.CollectionUtils; |
| | | import cn.stylefeng.guns.base.enums.MicroTimestamp; |
| | | |
| | | import java.lang.reflect.InvocationTargetException; |
| | | import java.lang.reflect.Method; |
| | |
| | | public class ClientHandler { |
| | | |
| | | // 客户端实例 |
| | | private OpcUaClient client = null; |
| | | public static OpcUaClient client = null; |
| | | |
| | | public List<OpcuaConfResult> b = null; |
| | | |
| | | @Autowired |
| | | private ClientRunner clientRunner; |
| | |
| | | return "找不到客户端,操作失败"; |
| | | } |
| | | |
| | | // List<Node> ns = client.getAddressSpace().browse(new NodeId(2, "模拟通道一.模拟设备一")).get(); |
| | | |
| | | // 查询订阅对象,没有则创建 |
| | | UaSubscription subscription = null; |
| | | ImmutableList<UaSubscription> subscriptionList = client.getSubscriptionManager().getSubscriptions(); |
| | |
| | | // 创建监控项,并且注册变量值改变时候的回调函数 |
| | | subscription.createMonitoredItems(TimestampsToReturn.Both, requests, (item, id) -> { |
| | | item.setValueConsumer((i, v) -> { |
| | | handle(i.getReadValueId().getNodeId(), v.getValue()); |
| | | handle2(i.getReadValueId().getNodeId(), v.getValue()); |
| | | }); |
| | | }).get(); |
| | | |
| | |
| | | * @CreateTime 2023年10月13日 |
| | | */ |
| | | |
| | | public void handle(NodeId id, Variant value){ |
| | | /*public void handle(NodeId id, Variant value){ |
| | | long startTime = System.currentTimeMillis(); |
| | | |
| | | OpcuaConfParam opcuaConfParam=new OpcuaConfParam(); |
| | | opcuaConfParam.setNode(id.getIdentifier().toString()); |
| | | List<OpcuaConfResult> a=opcuaConfController.mylist(opcuaConfParam); |
| | | |
| | | log.info("数据库访问代码执行时间:" + (System.currentTimeMillis() - startTime) + "毫秒"); |
| | | String str1 = id.getIdentifier().toString()+":"+value.getValue().toString(); |
| | | try { |
| | | Class<?> clazz = Class.forName(a.get(0).getRModule()); |
| | |
| | | e.printStackTrace(); |
| | | } |
| | | log.info("代码执行时间:" + (System.currentTimeMillis() - startTime) + "毫秒"); |
| | | }*/ |
| | | public void handle2(NodeId id, Variant value){ |
| | | |
| | | MicroTimestamp t = null; |
| | | String sTime=t.INSTANCE.get(); |
| | | |
| | | |
| | | if (b == null || 0 > b.size()) { |
| | | OpcuaConfParam opcuaConfParam=new OpcuaConfParam(); |
| | | opcuaConfParam.setSubscribe(1); |
| | | b=opcuaConfController.mylist(opcuaConfParam); |
| | | } |
| | | //使用Stream API在List<T>中查找元素 |
| | | OpcuaConfResult opcuaConfResult = b.stream() |
| | | .filter(customer ->id.getIdentifier().toString().equals(customer.getNode())) |
| | | .findAny() |
| | | .orElse(null); |
| | | try { |
| | | Class<?> clazz = Class.forName(opcuaConfResult.getRModule()); |
| | | Method method = clazz.getMethod(opcuaConfResult.getRFunction(), new Class[] { String.class, |
| | | String.class }); |
| | | 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(); |
| | | } |
| | | log.info("代码执行开始时间为:"+ sTime +",结束时间为:"+t.INSTANCE.get()+"."); |
| | | } |
| | | |
| | | |
| | | /** |
| | | * @MethodName: write |
| | |
| | | case "boolean": |
| | | value = new Variant(Boolean.parseBoolean(node.getValue().toString())); |
| | | break; |
| | | case "long": |
| | | value = new Variant(Long.parseLong(node.getValue().toString())); |
| | | break; |
| | | } |
| | | DataValue dataValue = new DataValue(value, null, null); |
| | | |