115 lines
3.8 KiB
C++
115 lines
3.8 KiB
C++
#ifndef OPCUAMANAGER_H
|
||
#define OPCUAMANAGER_H
|
||
|
||
#include <QObject>
|
||
#include <QOpcUaClient>
|
||
#include <QOpcUaNode>
|
||
#include <QOpcUaEndpointDescription>
|
||
#include <QVector>
|
||
#include <QUrl>
|
||
#include <QTimer>
|
||
#include <QMutex> // 新增：线程安全锁
|
||
#include <QEventLoop>
|
||
#include <QThread>
|
||
struct WriteWaiter : QObject {
|
||
Q_OBJECT
|
||
public:
|
||
bool ok = false;
|
||
QEventLoop loop;
|
||
public slots:
|
||
void done(bool success, const QString &) { ok = success; loop.quit(); }
|
||
};
|
||
|
||
class OpcUaManager : public QObject
|
||
{
|
||
Q_OBJECT
|
||
public:
|
||
static OpcUaManager* instance(QObject* parent = nullptr); // 全局唯一获取方式
|
||
// 禁止拷贝和赋值（避免创建多个实例）
|
||
OpcUaManager(const OpcUaManager&) = delete;
|
||
OpcUaManager& operator=(const OpcUaManager&) = delete;
|
||
~OpcUaManager();
|
||
|
||
// 连接服务器
|
||
bool connectToServer(const QString &url, const QString &username, const QString &password);
|
||
// 断开连接
|
||
void disconnectFromServer();
|
||
// 读取节点值
|
||
bool readNodeValue(const QString &nodeId);
|
||
// 写入节点值
|
||
bool writeNodeValue(const QString &nodeId, const QVariant &value);
|
||
// 获取连接状态
|
||
QOpcUaClient::ClientState connectionState() const;
|
||
|
||
QOpcUaClient* getClient() const; // 添加这个方法
|
||
|
||
bool writeNodeValue(const QString &nodeId,
|
||
const QVariant &value,
|
||
int maxRetry /* = 3 */,
|
||
int retryIntervalMs /* = 200 */);
|
||
signals:
|
||
// 状态变化信号
|
||
void stateChanged(QOpcUaClient::ClientState state);
|
||
// 读取完成信号（返回值和节点ID）
|
||
void readCompleted(const QVariant &value, const QString &nodeId);
|
||
// 写入完成信号（返回是否成功和节点ID）
|
||
void writeCompleted(bool success, const QString &nodeId);
|
||
// 错误信号（返回错误信息）
|
||
void errorOccurred(const QString &errorString);
|
||
void reconnected(); // 新增：重连成功后广播
|
||
private slots:
|
||
// 端点请求完成处理
|
||
void onEndpointsRequestFinished(QVector<QOpcUaEndpointDescription> endpoints,
|
||
QOpcUa::UaStatusCode statusCode,
|
||
QUrl requestedUrl);
|
||
// 客户端状态变化处理
|
||
void onClientStateChanged(QOpcUaClient::ClientState state);
|
||
// 属性读取完成处理（用于普通读取）
|
||
void onAttributeRead(QOpcUa::NodeAttributes attrs);
|
||
// 属性写入完成处理
|
||
void onAttributeWritten(QOpcUa::NodeAttribute attribute, QOpcUa::UaStatusCode statusCode);
|
||
// 写入前读取值类型（用于动态类型适配）
|
||
void onPreWriteValueTypeRead(QOpcUa::NodeAttributes attrs);
|
||
|
||
void tryReconnect(); // 新增：真正执行重连
|
||
private:
|
||
explicit OpcUaManager(QObject *parent = nullptr); // 私有构造函数（仅允许 instance() 创建）
|
||
static OpcUaManager* m_instance; // 静态单例实例
|
||
static QMutex m_mutex; // 线程安全锁（避免多线程冲突）
|
||
|
||
// 创建客户端实例
|
||
void createClient();
|
||
|
||
/** @brief OPC UA客户端实例 */
|
||
QOpcUaClient *mClient;
|
||
|
||
/** @brief 当前操作的节点 */
|
||
QOpcUaNode *mCurrentNode;
|
||
|
||
/** @brief 当前节点ID */
|
||
QString mCurrentNodeId;
|
||
|
||
/** @brief 服务器地址 */
|
||
QUrl mServerUrl;
|
||
|
||
/** @brief 登录用户名 */
|
||
QString mUserName;
|
||
|
||
/** @brief 登录密码 */
|
||
QString mPassword;
|
||
|
||
/** @brief 节点数据类型（备用） */
|
||
int mNodeDataType;
|
||
|
||
/** @brief 待写入的值（临时存储） */
|
||
QVariant mPendingWriteValue;
|
||
|
||
/** @brief 重连定时器 */
|
||
QTimer *mReconnectTimer = nullptr;
|
||
|
||
/** @brief 每次重连的时间间隔 */
|
||
const int RECONNECT_INTERVAL = 3000; //
|
||
};
|
||
|
||
#endif // OPCUAMANAGER_H
|