//package org.jeecg.modules.dry.common;
//
//import lombok.extern.slf4j.Slf4j;
//import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
//import org.eclipse.milo.opcua.sdk.client.api.identity.AnonymousProvider;
//import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaSubscription;
//import org.eclipse.milo.opcua.sdk.client.api.subscriptions.UaSubscriptionManager;
//import org.eclipse.milo.opcua.sdk.client.nodes.UaNode;
//import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedDataItem;
//import org.eclipse.milo.opcua.sdk.client.subscriptions.ManagedSubscription;
//import org.eclipse.milo.opcua.stack.core.AttributeId;
//import org.eclipse.milo.opcua.stack.core.Identifiers;
//import org.eclipse.milo.opcua.stack.core.UaException;
//import org.eclipse.milo.opcua.stack.core.security.SecurityPolicy;
//import org.eclipse.milo.opcua.stack.core.types.builtin.*;
//import org.eclipse.milo.opcua.stack.core.types.builtin.unsigned.UInteger;
//import org.eclipse.milo.opcua.stack.core.types.enumerated.MonitoringMode;
//import org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn;
//import org.eclipse.milo.opcua.stack.core.types.structured.MonitoredItemCreateRequest;
//import org.eclipse.milo.opcua.stack.core.types.structured.MonitoringParameters;
//import org.eclipse.milo.opcua.stack.core.types.structured.ReadValueId;
//
//import java.nio.file.Files;
//import java.nio.file.Path;
//import java.nio.file.Paths;
//import java.util.ArrayList;
//import java.util.List;
//import java.util.Objects;
//import java.util.concurrent.CountDownLatch;
//import java.util.concurrent.atomic.AtomicInteger;
//
//
//@Slf4j
//public class OPCUA {
//
//    private static AtomicInteger atomic = new AtomicInteger(1);
//    // 定义服务端地址
//    private final static String endPointUrl = "opc.tcp://127.0.0.1:49320";
//
//
//    /**
//     * 创建OPC UA客户端
//     * @return
//     * @throws Exception
//     */
//    public static OpcUaClient createClient() throws Exception {
//
//        Path securityTempDir = Paths.get(System.getProperty("java.io.tmpdir"), "security");
//        Files.createDirectories(securityTempDir);
//        if (!Files.exists(securityTempDir)) {
//            throw new Exception("unable to create security dir: " + securityTempDir);
//        }
//        return OpcUaClient.create(endPointUrl,
//            endpoints ->
//                endpoints.stream()
//                    .filter(e -> e.getSecurityPolicyUri().equals(SecurityPolicy.None.getUri()))
//                    .findFirst(),
//            configBuilder ->
//                configBuilder
//                    .setApplicationName(LocalizedText.english("eclipse milo opc-ua client"))
//                    .setApplicationUri("urn:eclipse:milo:examples:client")
//                    //访问方式
//                    .setIdentityProvider(new AnonymousProvider())
//                    .setRequestTimeout(UInteger.valueOf(5000))
//                    .build()
//        );
//    }
//
//    /**
//     * 遍历树形节点
//     *
//     * @param client OPC UA客户端
//     * @param uaNode 节点
//     * @throws Exception
//     */
//    public static void browseNode(OpcUaClient client, UaNode uaNode) throws Exception {
//        List<? extends UaNode> nodes;
//        if (uaNode == null) {
//            nodes = client.getAddressSpace().browseNodes(Identifiers.ObjectsFolder);
//        } else {
//            nodes = client.getAddressSpace().browseNodes(uaNode);
//        }
//        for (UaNode nd : nodes) {
//            //排除系统行性节点，这些系统性节点名称一般都是以"_"开头
//            if (Objects.requireNonNull(nd.getBrowseName().getName()).contains("_")) {
//                continue;
//            }
//            System.out.println("Node= " + nd.getBrowseName().getName());
//            browseNode(client, nd);
//        }
//    }
//
//
//    /**
//     * 读取节点数据
//     *
//     * @param client OPC UA客户端
//     * @throws Exception
//     */
//    public static void readNode(OpcUaClient client) throws Exception {
//        int namespaceIndex = 2;
//        String identifier = "TD-01.SB-01.AG-01";
//        //节点
//        NodeId nodeId = new NodeId(namespaceIndex, identifier);
//        //读取节点数据
//        DataValue value = client.readValue(0.0, TimestampsToReturn.Neither, nodeId).get();
//
//        System.out.println(identifier + ": " + String.valueOf(value.getValue().getValue()));
//    }
//
//
//    /**
//     * 写入节点数据
//     *
//     * @param client
//     * @throws Exception
//     */
//    public static void writeNodeValue(OpcUaClient client) throws Exception {
//        //节点
//        NodeId nodeId = new NodeId(2, "TD-01.SB-01.AG-01");
//        short i = 3;
//        //创建数据对象,此处的数据对象一定要定义类型，不然会出现类型错误，导致无法写入
//        DataValue nowValue = new DataValue(new Variant(i), null, null);
//        //写入节点数据
//        StatusCode statusCode = client.writeValue(nodeId, nowValue).join();
//        System.out.println("结果：" + statusCode.isGood());
//    }
//
//
//    /**
//     * 订阅(单个)
//     *
//     * @param client
//     * @throws Exception
//     */
//    public static void subscribe(OpcUaClient client) throws Exception {
//        //创建发布间隔1000ms的订阅对象
//        client
//            .getSubscriptionManager()
//            .createSubscription(1000.0)
//            .thenAccept(t -> {
//                //节点
//                NodeId nodeId = new NodeId(2, "TD-01.SB-01.AG-01");
//                ReadValueId readValueId = new ReadValueId(nodeId, AttributeId.Value.uid(), null, null);
//                //创建监控的参数
//                MonitoringParameters parameters = new MonitoringParameters(UInteger.valueOf(atomic.getAndIncrement()), 1000.0, null, UInteger.valueOf(10), true);
//                //创建监控项请求
//                //该请求最后用于创建订阅。
//                MonitoredItemCreateRequest request = new MonitoredItemCreateRequest(readValueId, MonitoringMode.Reporting, parameters);
//                List<MonitoredItemCreateRequest> requests = new ArrayList<>();
//                requests.add(request);
//                //创建监控项，并且注册变量值改变时候的回调函数。
//                t.createMonitoredItems(
//                    TimestampsToReturn.Both,
//                    requests,
//                    (item, id) -> item.setValueConsumer((it, val) -> {
//                        System.out.println("nodeid :" + it.getReadValueId().getNodeId());
//                        System.out.println("value :" + val.getValue().getValue());
//                    })
//                );
//            }).get();
//
//        //持续订阅
//        Thread.sleep(Long.MAX_VALUE);
//    }
//
//
//    /**
//     * 批量订阅
//     *
//     * @param client
//     * @throws Exception
//     */
////    private static void managedSubscriptionEvent(OpcUaClient client) throws Exception {
////        final CountDownLatch eventLatch = new CountDownLatch(1);
////
////        //处理订阅业务
////        handlerNode(client);
////
////        //持续监听
////        eventLatch.await();
////    }
//
//    /**
//     * 处理订阅业务
//     *
//     * @param client OPC UA客户端
//     */
//    public static void handlerNode(OpcUaClient client) {
//        try {
//            //创建订阅
//            ManagedSubscription subscription = ManagedSubscription.create(client);
//
//            //你所需要订阅的key
//            List<String> key = new ArrayList<>();
//            key.add("通道 1.设备 1.标记 1");
//            key.add("通道 1.设备 1.标记 2");
//
//            List<NodeId> nodeIdList = new ArrayList<>();
//            for (String s : key) {
//                nodeIdList.add(new NodeId(2, s));
//            }
//
//            //监听
//            List<ManagedDataItem> dataItemList = subscription.createDataItems(nodeIdList);
//            for (ManagedDataItem managedDataItem : dataItemList) {
//                managedDataItem.addDataValueListener((t) -> {
//                    System.out.println(managedDataItem.getNodeId().getIdentifier().toString() + ":" + t.getValue().getValue().toString());
//                });
//            }
//        } catch (Exception e) {
//            e.printStackTrace();
//        }
//    }
//
//    /**
//     * 自定义订阅监听
//     */
//    public static class CustomSubscriptionListener implements UaSubscriptionManager.SubscriptionListener {
//
//        private OpcUaClient client;
//
//        CustomSubscriptionListener(OpcUaClient client) {
//            this.client = client;
//        }
//
//        public void onKeepAlive(UaSubscription subscription, DateTime publishTime) {
//            log.debug("onKeepAlive");
//        }
//
//        public void onStatusChanged(UaSubscription subscription, StatusCode status) {
//            log.debug("onStatusChanged");
//        }
//
//        public void onPublishFailure(UaException exception) {
//            log.debug("onPublishFailure");
//        }
//
//        public void onNotificationDataLost(UaSubscription subscription) {
//            log.debug("onNotificationDataLost");
//        }
//
//        /**
//         * 重连时 尝试恢复之前的订阅失败时 会调用此方法
//         * @param uaSubscription 订阅
//         * @param statusCode 状态
//         */
//        public void onSubscriptionTransferFailed(UaSubscription uaSubscription, StatusCode statusCode) {
//            log.debug("恢复订阅失败 需要重新订阅");
//            //在回调方法中重新订阅
//            handlerNode(client);
//        }
//    }
//
//    /**
//     * 批量订阅
//     *
//     * @param client
//     * @throws Exception
//     */
//    public static void managedSubscriptionEvent(OpcUaClient client) throws Exception {
//        final CountDownLatch eventLatch = new CountDownLatch(1);
//
//        //添加订阅监听器，用于处理断线重连后的订阅问题
//        client.getSubscriptionManager().addSubscriptionListener(new CustomSubscriptionListener(client));
//
//        //处理订阅业务
//        handlerNode(client);
//
//        //持续监听
//        eventLatch.await();
//    }
//}