package com.mes.milo.runner;

import com.mes.milo.model.ReadWriteEntity;
import com.mes.milo.utils.CustomUtil;
import lombok.extern.slf4j.Slf4j;
import org.eclipse.milo.opcua.sdk.client.OpcUaClient;
import org.eclipse.milo.opcua.stack.core.types.builtin.DataValue;
import org.eclipse.milo.opcua.stack.core.types.builtin.NodeId;
import org.eclipse.milo.opcua.stack.core.types.builtin.StatusCode;
import org.eclipse.milo.opcua.stack.core.types.enumerated.TimestampsToReturn;

import java.util.ArrayList;
import java.util.List;

/**
 * @author mes
 * @version 0.0.1
 * @desc
 * @since 2020/4/14
 */
@Slf4j
public class ReadValuesRunner {
    /**
     * 要读的点位list
     */
    private final List<String> identifiers;

    public ReadValuesRunner(List<String> identifiers) {
        this.identifiers = identifiers;
    }

    public List<ReadWriteEntity> run(OpcUaClient opcUaClient) {
        List<ReadWriteEntity> entityList = new ArrayList<>();
        try {
            List<NodeId> nodeIds = new ArrayList<>();
            identifiers.forEach(identifier -> nodeIds.add(CustomUtil.parseNodeId(identifier)));
            // 读取指定点位的值，10s超时
            List<DataValue> dataValues = opcUaClient.readValues(10000, TimestampsToReturn.Both, nodeIds).get();
            if (dataValues.size() == identifiers.size()) {
                for (int i = 0; i < identifiers.size(); i++) {
                    String id = identifiers.get(i);
                    Object value = dataValues.get(i).getValue().getValue();
                    StatusCode status = dataValues.get(i).getStatusCode();
                    assert status != null;
                    if (status.isGood()) {
                        log.info("读取点位 '{}' 的值为 {}", id, value);
                    }
                    entityList.add(ReadWriteEntity.builder()
                            .identifier(id)
                            .value(value)
                            .dataValue(dataValues.get(i))
                            .build());
                }
            }
        } catch (Exception e) {
            log.error("读值时出现了异常：{}", e.getMessage(), e);
        }
        return entityList;
    }
}