package com.mes.milo.runner;
|
|
import com.mes.milo.model.WriteEntity;
|
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 java.util.LinkedList;
|
import java.util.List;
|
|
/**
|
* @author mes
|
* @version 0.0.1
|
* @since 2020/4/14
|
*/
|
@Slf4j
|
public class WriteValuesRunner {
|
private final List<WriteEntity> entities;
|
|
public WriteValuesRunner(List<WriteEntity> entities) {
|
this.entities = entities;
|
}
|
|
public void run(OpcUaClient opcUaClient) {
|
try {
|
if (!entities.isEmpty()) {
|
List<NodeId> nodeIds = new LinkedList<>();
|
List<DataValue> dataValues = new LinkedList<>();
|
for (WriteEntity entity : entities) {
|
nodeIds.add(CustomUtil.parseNodeId(entity.getIdentifier()));
|
dataValues.add(new DataValue(entity.getVariant(), null, null));
|
}
|
|
List<StatusCode> statusCodeList = opcUaClient.writeValues(nodeIds, dataValues).join();
|
for (int i = 0; i < statusCodeList.size(); i++) {
|
if (statusCodeList.get(i).isGood()) {
|
log.info("将值 '{}' 写入到点位：{} 成功", dataValues.get(i).getValue(), nodeIds.get(i));
|
} else {
|
log.error("点位：{} 写入时出现了异常：{}", nodeIds.get(i), statusCodeList.get(i));
|
}
|
}
|
}
|
} catch (Exception e) {
|
log.error("批量写值出现异常出现了异常：{}", e.getMessage(), e);
|
}
|
}
|
}
|
