#ifndef SECS_RUNTIME_MANAGER_H #define SECS_RUNTIME_MANAGER_H #include #include #include #include "Database.h" class SECSRuntimeManager { public: /** * 获取单例实例 * @return SECSRuntimeManager实例的引用 */ static SECSRuntimeManager& getInstance(); /** * 设置数据库连接 * @param db 数据库连接的指针 */ void setDatabase(BL::Database* db); /** * 初始化SECS运行设置管理库 * @return 成功返回true,失败返回false */ bool initRuntimeSetting(); /** * 销毁SECS运行设置管理库 */ void termRuntimeSetting(); /** * 初始化SystemSV表 */ void initSystemSVTable(); /** * 添加 SystemSV 数据 * @param nID: 需要添加的 SystemSV 的 ID,必须是唯一的。 * @param sName: 需要添加的 SystemSV 的名称,必须是唯一的。 * @param sDataType: 数据类型,表示该系统值的类型,例如 "ASCII"、"UINT_1" 等。 * @param nLength: 系统值的数据长度,通常为一个正整数,用于表示该数据的长度。 * @param sUnit: 系统值的单位。如果为空或者为 "NULL",则插入数据库中的 NULL 值。 * @param sRemark: 备注信息,描述该系统值的其他信息,可用于说明该字段的用途或特性。 * @param nSystemID: 该数据所属的系统 ID,用于与其他表进行关联。 * @return 1: 数据库未连接。 * @return 2: ID 重复,无法插入数据。 * @return 3: Name 重复,无法插入数据。 * @return 4: 插入数据失败。 * @return 0: 插入成功,数据已添加到 SystemSV 表中。 * * 此函数用于将一条新的数据插入到 SystemSV 表中。它首先会检查传入的 `ID` 和 `Name` 是否已存在于表中, * 如果存在则返回相应的错误代码。如果 `Unit` 参数为 "NULL" 或者为空,函数会将其转换为数据库中的 NULL 值。 * 然后,构造一个 SQL 插入语句并执行插入操作。如果插入失败,则抛出异常。 * 如果一切顺利,返回 0 表示数据成功插入。 */ int addSystemSV(int nID, const std::string& sName, const std::string& sDataType, int nLength, const std::string& sUnit, const std::string& sRemark, int nSystemID); /** * 获取指定 ID 的 SystemSV 数据 * @param nID: 需要查找的 SystemSV 的 ID。 * @return std::vector>: 返回一个二维字符串向量,表示查询结果。每行代表一条记录,每列代表该记录的一个字段值。 * 如果指定的 ID 存在,则返回该 ID 对应的记录;如果不存在,则返回空的二维向量。 * * 此函数用于通过指定的 `ID` 从 SystemSV 表中查找对应的数据。首先根据传入的 `ID` 构造查询 SQL 语句, * 然后执行查询操作,返回查询结果。查询结果是一个二维字符串向量,表示查询到的记录。每行是一个 * 字符串向量,每个元素是该行中的一列数据。如果找不到对应的数据,函数将返回一个空的二维向量。 */ std::vector> getSystemSVByID(int nID); /** * 获取所有 SystemSV 数据 * @return std::vector>: 返回一个二维字符串向量,表示查询结果。每行代表一条记录,每列代表该记录的一个字段值。 * 如果表中有数据,则返回所有记录;如果表为空,则返回空的二维向量。 * * 此函数用于从 SystemSV 表中获取所有的数据。通过构造 SQL 查询语句来选择所有记录,并执行查询操作。 * 返回的结果是一个二维字符串向量,表示表中的所有记录。每行数据是一个字符串向量,其中包含该记录的各个字段。 * 如果表中没有数据,函数将返回一个空的二维向量。 */ std::vector> getAllSystemSV(); /** * 更新指定 ID 的 SystemSV 数据 * @param nID: 需要更新的 SystemSV 的当前 ID。 * @param sNewID: 要更新为的新 ID。 * @return 1: 数据库未连接。 * @return 2: 未找到指定的 ID。 * @return 3: 新的 ID 已经存在,无法更新。 * @return 4: 更新操作失败。 * @return 0: 更新成功。 * * 此函数用于更新 `SystemSV` 表中指定 `nID` 的记录,将其 `ID` 字段更新为 `sNewID`。 * 在执行更新前,函数会检查: * 1. 当前的 `nID` 是否存在于表中。 * 2. 新的 `sNewID` 是否已经存在于表中,如果存在,则无法进行更新。 * * 如果 `nID` 不存在,则返回错误代码 2。如果 `sNewID` 已经存在,则返回错误代码 3。 * 如果数据库更新失败,则返回错误代码 4。成功时,返回 0 表示操作成功。 */ int updateIDSystemSV(int nID, int sNewID); /** * 更新所有 SystemSV 数据 * @param nID: 需要更新的 SystemSV 的当前 ID。 * @param sNewID: 要更新为的新 ID,如果为空或为 -1,则不更新 ID。 * @param sName: 新的名称,如果为空,则不更新。 * @param sDataType: 新的数据类型,如果为空,则不更新。 * @param nLength: 新的数据长度,如果为负值或零,则不更新。 * @param sUnit: 新的单位,如果为空或 "NULL",则不更新。 * @param sRemark: 新的备注,如果为空,则不更新。 * @param nSystemID: 新的系统 ID,如果为负值,则不更新。 * @return 1: 数据库未连接。 * @return 2: 没有找到该 ID 对应的记录。 * @return 3: 新的 ID 已经存在,无法更新。 * @return 4: 更新操作失败。 * @return 0: 更新成功。 * * 此函数用于更新指定 `ID` 的 `SystemSV` 数据。如果某个字段为空,则跳过该字段的更新。 * 如果给定的 `ID` 不存在,则返回错误代码 2。如果新的 `ID` 已经存在,则返回错误代码 3。 * * 如果字段为空,跳过该字段的更新。 */ int updateAllSystemSV(int nID, int sNewID, const std::string& sName, const std::string& sDataType, int nLength, const std::string& sUnit, const std::string& sRemark, int nSystemID); /** * 删除指定 ID 的 SystemSV 数据 * @param nID: 需要删除的 SystemSV 的 ID。 * @return 1: 数据库未连接。 * @return 2: 未找到指定的 ID 对应的记录。 * @return 3: 删除操作失败。 * @return 0: 删除成功。 * * 此函数用于删除 `SystemSV` 表中指定 `nID` 的记录。如果给定的 `nID` 不存在,则返回错误代码 2。 * 删除操作成功后,返回 0 表示删除成功。 */ int deleteSystemSVByID(int nID); /** * 删除所有 SystemSV 数据 * @return 1: 数据库未连接。 * @return 2: 删除操作失败。 * @return 0: 删除成功。 * * 此函数用于删除 `SystemSV` 表中的所有记录。如果数据库未连接,则返回错误代码 1。 * 如果删除操作失败,则返回错误代码 2。删除成功后,返回 0 表示删除成功。 */ int deleteAllSystemSV(); /** * 初始化 EqpSV 表 */ void initEqpSVTable(); /** * 添加 EqpSV 数据 * @param nID: 需要添加的 EqpSV 的 ID,必须是唯一的。 * @param sName: 需要添加的 EqpSV 的名称,必须是唯一的。 * @param sDataType: 数据类型,表示该设备值的类型,例如 "ASCII"、"UINT_1" 等。 * @param nLength: 设备值的数据长度,通常为一个正整数,用于表示该数据的长度。 * @param sUnit: 设备值的单位。如果为空或者为 "NULL",则插入数据库中的 NULL 值。 * @param sRemark: 备注信息,描述该设备值的其他信息,可用于说明该字段的用途或特性。 * @param nSeqNo: 该数据的序号,用于排序。 * @return 1: 数据库未连接。 * @return 2: ID 重复,无法插入数据。 * @return 3: Name 重复,无法插入数据。 * @return 4: 插入数据失败。 * @return 0: 插入成功,数据已添加到 EqpSV 表中。 * * 此函数用于将一条新的数据插入到 EqpSV 表中。它首先会检查传入的 `ID` 和 `Name` 是否已存在于表中, * 如果存在则返回相应的错误代码。如果 `Unit` 参数为 "NULL" 或者为空,函数会将其转换为数据库中的 NULL 值。 * 然后,构造一个 SQL 插入语句并执行插入操作。如果插入失败,则抛出异常。 * 如果一切顺利,返回 0 表示数据成功插入。 */ int addEqpSV(int nID, const std::string& sName, const std::string& sDataType, int nLength, const std::string& sUnit, const std::string& sRemark, int nSeqNo); /** * 获取指定 ID 的 EqpSV 数据 * @param nID: 需要查找的 EqpSV 的 ID。 * @return std::vector>: 返回一个二维字符串向量,表示查询结果。每行代表一条记录,每列代表该记录的一个字段值。 * 如果指定的 ID 存在,则返回该 ID 对应的记录;如果不存在,则返回空的二维向量。 * * 此函数用于通过指定的 `ID` 从 EqpSV 表中查找对应的数据。首先根据传入的 `ID` 构造查询 SQL 语句, * 然后执行查询操作,返回查询结果。查询结果是一个二维字符串向量,表示查询到的记录。每行是一个 * 字符串向量,每个元素是该行中的一列数据。如果找不到对应的数据,函数将返回一个空的二维向量。 */ std::vector> SECSRuntimeManager::getEqpSVByID(int nID); /** * 获取所有 EqpSV 数据 * @return std::vector>: 返回一个二维字符串向量,表示查询结果。每行代表一条记录,每列代表该记录的一个字段值。 * 如果表中有数据,则返回所有记录;如果表为空,则返回空的二维向量。 * * 此函数用于从 EqpSV 表中获取所有的数据。通过构造 SQL 查询语句来选择所有记录,并执行查询操作。 * 返回的结果是一个二维字符串向量,表示表中的所有记录。每行数据是一个字符串向量,其中包含该记录的各个字段。 * 如果表中没有数据,函数将返回一个空的二维向量。 */ std::vector> SECSRuntimeManager::getAllEqpSV(); /** * 更新指定 ID 的 EqpSV 数据 * @param nID: 需要更新的 EqpSV 的 ID,必须是已存在的 ID。 * @param nNewID: 更新后的 ID,必须是唯一的。 * @param sName: 更新后的 EqpSV 名称,必须是唯一的。 * @param sDataType: 更新后的数据类型,表示该设备值的类型,例如 "ASCII"、"UINT_1" 等。 * @param nLength: 更新后的设备值的数据长度,通常为一个正整数,用于表示该数据的长度。 * @param sUnit: 更新后的设备值的单位。如果为空或者为 "NULL",则插入数据库中的 NULL 值。 * @param sRemark: 更新后的备注信息,描述该设备值的其他信息,可用于说明该字段的用途或特性。 * @param nSeqNo: 更新后的该数据的序号,用于排序。 * @return 1: 数据库未连接。 * @return 2: ID 不存在,无法更新数据。 * @return 3: 新 ID 重复,无法更新数据。 * @return 4: 更新数据失败。 * @return 0: 更新成功,数据已更新到 EqpSV 表中。 * * 此函数用于更新指定 ID 的 EqpSV 数据。首先检查 `ID` 是否存在,如果不存在则返回错误代码 2。 * 然后检查新的 `ID` 是否已存在,如果已存在则返回错误代码 3。接下来,构造更新 SQL 语句,包含 * 需要更新的字段,并执行更新操作。如果更新失败,则返回错误代码 4。如果一切顺利,返回 0 表示 * 数据成功更新。 */ int updateEqpSV(int nID, int nNewID, const std::string& sName, const std::string& sDataType, int nLength, const std::string& sUnit, const std::string& sRemark, int nSeqNo); /** * 更新指定 ID 的 EqpSV 数据 * @param nID: 需要更新的 EqpSV 的当前 ID。 * @param sNewID: 要更新为的新 ID。 * @return 1: 数据库未连接。 * @return 2: 未找到指定的 ID。 * @return 3: 新的 ID 已经存在,无法更新。 * @return 4: 更新操作失败。 * @return 0: 更新成功。 * * 此函数用于更新 `EqpSV` 表中指定 `nID` 的记录,将其 `ID` 字段更新为 `sNewID`。 * 在执行更新前,函数会检查: * 1. 当前的 `nID` 是否存在于表中。 * 2. 新的 `sNewID` 是否已经存在于表中,如果存在,则无法进行更新。 * * 如果 `nID` 不存在,则返回错误代码 2。如果 `sNewID` 已经存在,则返回错误代码 3。 * 如果数据库更新失败,则返回错误代码 4。成功时,返回 0 表示操作成功。 */ int deleteEqpSVByID(int nID); /** * 删除所有 EqpSV 数据 * @return 1: 数据库未连接。 * @return 2: 删除操作失败。 * @return 0: 删除成功。 * * 此函数用于删除 `EqpSV` 表中的所有记录。如果数据库未连接,则返回错误代码 1。 * 如果删除操作失败,则返回错误代码 2。删除成功后,返回 0 表示删除成功。 */ int deleteAllEqpSV(); /** * 初始化 SystemDV 表 */ void initSystemDVTable(); /** * 初始化 EqpDV 表 */ void initEqpDVTable(); /** * 初始化 SystemEC 表 */ void initSystemECTable(); /** * 初始化 EqpEC 表 */ void initEqpECTable(); /** * 初始化 SystemEvent 表 */ void initSystemEventTable(); /** * 初始化 EqpEvent 表 */ void initEqpEventTable(); /** * 初始化 EventLink 表 */ void initEventLinkTable(); /** * 初始化 PPID 表 */ void initPPIDTable(); /** * 初始化 RPTID 表 */ void initRPTIDTable(); private: SECSRuntimeManager(); ~SECSRuntimeManager(); // 禁止拷贝和赋值 SECSRuntimeManager(const SECSRuntimeManager&) = delete; SECSRuntimeManager& operator=(const SECSRuntimeManager&) = delete; // 从数据库中获取整数 int getIntFromDB(const std::string& query); // 判断VID是否重复 bool isIDDuplicate(int nID); // 判断名称是否重复 bool isNameDuplicate(const std::string& sName); BL::Database* m_pDB; static std::mutex m_mutex; }; #endif // SECS_RUNTIME_MANAGER_H