6.定时轮询比特位，修改为只轮询EFEM, Bonder1, Bonder2, BakeCooling, VacuuumBake, Measurent...

LAPTOP-SNT8I5JK\Boounion

2025-06-26 b54cb6d1d8742e94bd79623d4f410b3ff5abde86

 SourceCode/Bond/Servo/SECSRuntimeManager.cpp

@@ -104,8 +104,8 @@
        return 1;
    }

    // 构建删除所有数据的 SQL 语句
    std::string deleteSQL = "DELETE FROM " + tableName + ";";
    // 构建删除所有数据的 SQL 语句, 重置自增 ID
    std::string deleteSQL = "TRUNCATE TABLE " + tableName + ";";
    if (!m_pDB->executeQuery(deleteSQL)) {
        return 2;
    }
@@ -789,6 +789,157 @@
    }
}

// 添加 SystemEC 数据
int SECSRuntimeManager::addSystemEC(int nID, const std::string& sName, const std::string& sDataType, int nMinValue, int nMaxValue, int nDefaultVal, const std::string& sUnit, const std::string& sRemark, int nSystemID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1; // 数据库未连接
    }

    if (isIDDuplicate(nID)) {
        return 2; // ID 重复
    }

    if (isNameDuplicate(sName)) {
        return 3; // Name 重复
    }

    // 构建插入 SQL 语句
    std::string insertSQL = "INSERT INTO SystemEC (ID, Name, DataType, MinValue, MaxValue, DefaultVal, Unit, Remark, SystemID) VALUES ("
        + std::to_string(nID) + ", '" + sName + "', '" + sDataType + "', "
        + (nMinValue >= 0 ? std::to_string(nMinValue) : "NULL") + ", "
        + (nMaxValue >= 0 ? std::to_string(nMaxValue) : "NULL") + ", "
        + (nDefaultVal >= 0 ? std::to_string(nDefaultVal) : "NULL") + ", "
        + ((sUnit == "NULL" || sUnit.empty()) ? "NULL" : "'" + sUnit + "'") + ", '"
        + sRemark + "', " + std::to_string(nSystemID) + ");";

    if (!m_pDB->executeQuery(insertSQL)) {
        return 4; // 插入失败
    }

    return 0; // 插入成功
}

// 查询指定 ID 的 SystemEC 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getSystemECByID(int nID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM SystemEC WHERE ID = " + std::to_string(nID) + ";";
    return m_pDB->fetchResults(querySQL);
}

// 查询所有 SystemEC 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getAllSystemEC() {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM SystemEC;";
    return m_pDB->fetchResults(querySQL);
}

// 更新指定 ID 的 SystemEC 数据
int SECSRuntimeManager::updateSystemEC(int nID, int nNewID, const std::string& sName, const std::string& sDataType, int nMinValue, int nMaxValue, int nDefaultVal, const std::string& sUnit, const std::string& sRemark, int nSystemID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1;
    }

    // 检查是否存在该 ID
    if (!isIDDuplicate(nID)) {
        return 2;
    }

    // 检查新的 ID 是否已存在
    if (isIDDuplicate(nNewID) && nNewID != nID) {
        return 3;
    }

    // 构建更新 SQL 语句
    std::string updateSQL = "UPDATE SystemEC SET ";

    bool firstField = true;

    if (nNewID > 0 && nNewID != nID) {
        updateSQL += "ID = " + std::to_string(nNewID);
        firstField = false;
    }

    if (!sName.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Name = '" + sName + "'";
        firstField = false;
    }

    if (!sDataType.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "DataType = '" + sDataType + "'";
        firstField = false;
    }

    if (nMinValue >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "MinValue = " + std::to_string(nMinValue);
        firstField = false;
    }

    if (nMaxValue >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "MaxValue = " + std::to_string(nMaxValue);
        firstField = false;
    }

    if (nDefaultVal >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "DefaultVal = " + std::to_string(nDefaultVal);
        firstField = false;
    }

    if (sUnit != "NULL" && !sUnit.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Unit = '" + sUnit + "'";
        firstField = false;
    }
    else if (sUnit == "NULL") {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Unit = NULL";
        firstField = false;
    }

    if (!sRemark.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Remark = '" + sRemark + "'";
        firstField = false;
    }

    if (nSystemID > 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "SystemID = " + std::to_string(nSystemID);
    }

    updateSQL += " WHERE ID = " + std::to_string(nID) + ";";

    if (!m_pDB->executeQuery(updateSQL)) {
        return 4;
    }

    return 0;
}

// 删除指定 ID 的 SystemEC 数据
int SECSRuntimeManager::deleteSystemECByID(int nID) {
    return deleteDataByID("SystemEC", nID);
}

// 删除所有 SystemEC 数据
int SECSRuntimeManager::deleteAllSystemEC() {
    return deleteAllDataFromTable("SystemEC");
}

// 初始化 EqpEC 表
void SECSRuntimeManager::initEqpECTable() {
    std::lock_guard<std::mutex> lock(m_mutex);
@@ -816,6 +967,168 @@
    }
}

// 添加 EqpEC 数据
int SECSRuntimeManager::addEqpEC(int nID, const std::string& sName, const std::string& sDataType, int nMinValue, int nMaxValue, int nDefaultValue, const std::string& sUnit, const std::string& sRemark, int nSeqNo, int nLength, int bCanUpdateByHost) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1; // 数据库未连接
    }

    if (isIDDuplicate(nID)) {
        return 2; // ID 重复
    }

    if (isNameDuplicate(sName)) {
        return 3; // Name 重复
    }

    // 构建插入 SQL 语句
    std::string insertSQL = "INSERT INTO EqpEC (ID, Name, DataType, MinValue, MaxValue, DefaultValue, Unit, Remark, SeqNo, Length, CanUpdateByHost) VALUES ("
        + std::to_string(nID) + ", '" + sName + "', '" + sDataType + "', "
        + (nMinValue >= 0 ? std::to_string(nMinValue) : "NULL") + ", "
        + (nMaxValue >= 0 ? std::to_string(nMaxValue) : "NULL") + ", "
        + (nDefaultValue >= 0 ? std::to_string(nDefaultValue) : "NULL") + ", "
        + ((sUnit == "NULL" || sUnit.empty()) ? "NULL" : "'" + sUnit + "'") + ", '"
        + sRemark + "', " + std::to_string(nSeqNo) + ", "
        + std::to_string(nLength) + ", " + std::to_string(bCanUpdateByHost) + ");";

    if (!m_pDB->executeQuery(insertSQL)) {
        return 4; // 插入失败
    }

    return 0; // 插入成功
}

// 查询指定 ID 的 EqpEC 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getEqpECByID(int nID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM EqpEC WHERE ID = " + std::to_string(nID) + ";";
    return m_pDB->fetchResults(querySQL);
}

// 查询所有 EqpEC 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getAllEqpEC() {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM EqpEC;";
    return m_pDB->fetchResults(querySQL);
}

// 更新指定 ID 的 EqpEC 数据
int SECSRuntimeManager::updateEqpEC(int nID, int nNewID, const std::string& sName, const std::string& sDataType, int nMinValue, int nMaxValue, int nDefaultValue, const std::string& sUnit, const std::string& sRemark, int nSeqNo, int nLength, int bCanUpdateByHost) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1;
    }

    // 检查是否存在该 ID
    if (!isIDDuplicate(nID)) {
        return 2;
    }

    // 检查新的 ID 是否已存在
    if (isIDDuplicate(nNewID) && nNewID != nID) {
        return 3;
    }

    // 构建更新 SQL 语句
    std::string updateSQL = "UPDATE EqpEC SET ";

    bool firstField = true;

    if (nNewID > 0 && nNewID != nID) {
        updateSQL += "ID = " + std::to_string(nNewID);
        firstField = false;
    }

    if (!sName.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Name = '" + sName + "'";
        firstField = false;
    }

    if (!sDataType.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "DataType = '" + sDataType + "'";
        firstField = false;
    }

    if (nMinValue >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "MinValue = " + std::to_string(nMinValue);
        firstField = false;
    }

    if (nMaxValue >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "MaxValue = " + std::to_string(nMaxValue);
        firstField = false;
    }

    if (nDefaultValue >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "DefaultValue = " + std::to_string(nDefaultValue);
        firstField = false;
    }

    if (sUnit != "NULL" && !sUnit.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Unit = '" + sUnit + "'";
        firstField = false;
    }
    else if (sUnit == "NULL") {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Unit = NULL";
        firstField = false;
    }

    if (!sRemark.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Remark = '" + sRemark + "'";
        firstField = false;
    }

    if (nSeqNo > 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "SeqNo = " + std::to_string(nSeqNo);
    }

    if (nLength > 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Length = " + std::to_string(nLength);
    }

    if (bCanUpdateByHost >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "CanUpdateByHost = " + std::to_string(bCanUpdateByHost);
    }

    updateSQL += " WHERE ID = " + std::to_string(nID) + ";";

    if (!m_pDB->executeQuery(updateSQL)) {
        return 4;
    }

    return 0;
}

// 删除指定 ID 的 EqpEC 数据
int SECSRuntimeManager::deleteEqpECByID(int nID) {
    return deleteDataByID("EqpEC", nID);
}

// 删除所有 EqpEC 数据
int SECSRuntimeManager::deleteAllEqpEC() {
    return deleteAllDataFromTable("EqpEC");
}

// 初始化 SystemEvent 表
void SECSRuntimeManager::initSystemEventTable() {
    std::lock_guard<std::mutex> lock(m_mutex);
@@ -836,6 +1149,110 @@
    }
}

// 添加 SystemEvent 数据
int SECSRuntimeManager::addSystemEvent(int nCEID, const std::string& sName, const std::string& sRemark, int nSystemID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1; // 数据库未连接
    }

    // 构建 SQL 插入语句
    std::string insertSQL = "INSERT INTO SystemEvent (CEID, Name, Remark, SystemID) VALUES ("
        + std::to_string(nCEID) + ", '" + sName + "', '" + sRemark + "', " + std::to_string(nSystemID) + ");";

    if (!m_pDB->executeQuery(insertSQL)) {
        return 2; // 插入失败
    }

    return 0; // 插入成功
}

// 查询指定 CEID 的 SystemEvent 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getSystemEventByID(int nCEID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM SystemEvent WHERE CEID = " + std::to_string(nCEID) + ";";
    return m_pDB->fetchResults(querySQL);
}

// 查询所有 SystemEvent 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getAllSystemEvents() {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM SystemEvent;";
    return m_pDB->fetchResults(querySQL);
}

// 更新指定 CEID 的 SystemEvent 数据
int SECSRuntimeManager::updateSystemEvent(int nCEID, int nNewCEID, const std::string& sName, const std::string& sRemark, int nSystemID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1;
    }

    // 构建更新 SQL 语句
    std::string updateSQL = "UPDATE SystemEvent SET ";

    bool firstField = true;

    if (nNewCEID > 0 && nNewCEID != nCEID) {
        updateSQL += "CEID = " + std::to_string(nNewCEID);
        firstField = false;
    }

    if (!sName.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Name = '" + sName + "'";
        firstField = false;
    }

    if (!sRemark.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Remark = '" + sRemark + "'";
        firstField = false;
    }

    if (nSystemID > 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "SystemID = " + std::to_string(nSystemID);
    }

    updateSQL += " WHERE CEID = " + std::to_string(nCEID) + ";";

    if (!m_pDB->executeQuery(updateSQL)) {
        return 2;
    }

    return 0;
}

// 删除指定 CEID 的 SystemEvent 数据
int SECSRuntimeManager::deleteSystemEventByID(int nCEID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1; // 数据库未连接，返回 1
    }

    // 构建删除 SQL 语句
    std::string deleteSQL = "DELETE FROM SystemEvent WHERE CEID = " + std::to_string(nCEID) + ";";
    if (!m_pDB->executeQuery(deleteSQL)) {
        return 2; // 删除失败，返回 2
    }

    return 0; // 删除成功，返回 0
}

// 删除所有 SystemEvent 数据
int SECSRuntimeManager::deleteAllSystemEvents() {
    return deleteAllDataFromTable("SystemEvent");
}

// 初始化 EqpEvent 表
void SECSRuntimeManager::initEqpEventTable() {
    std::lock_guard<std::mutex> lock(m_mutex);
@@ -854,6 +1271,105 @@
    if (!m_pDB->executeQuery(createTableSQL)) {
        throw std::runtime_error("Failed to create EqpEvent table.");
    }
}

// 添加 EqpEvent 数据
int SECSRuntimeManager::addEqpEvent(const std::string& sName, const std::string& sRemark, int nBitNo) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1; // 数据库未连接
    }

    // 构建 SQL 插入语句
    std::string insertSQL = "INSERT INTO EqpEvent (Name, Remark, BitNo) VALUES ('"
        + sName + "', '" + sRemark + "', " + std::to_string(nBitNo) + ");";

    if (!m_pDB->executeQuery(insertSQL)) {
        return 2; // 插入失败
    }

    return 0; // 插入成功
}

// 查询指定 CEID 的 EqpEvent 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getEqpEventByID(int nCEID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM EqpEvent WHERE CEID = " + std::to_string(nCEID) + ";";
    return m_pDB->fetchResults(querySQL);
}

// 查询所有 EqpEvent 数据
std::vector<std::vector<std::string>> SECSRuntimeManager::getAllEqpEvents() {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return {};
    }

    std::string querySQL = "SELECT * FROM EqpEvent;";
    return m_pDB->fetchResults(querySQL);
}

// 更新指定 CEID 的 EqpEvent 数据
int SECSRuntimeManager::updateEqpEvent(int nCEID, const std::string& sName, const std::string& sRemark, int nBitNo) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1;
    }

    // 构建更新 SQL 语句
    std::string updateSQL = "UPDATE EqpEvent SET ";

    bool firstField = true;

    if (!sName.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Name = '" + sName + "'";
        firstField = false;
    }

    if (!sRemark.empty()) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "Remark = '" + sRemark + "'";
        firstField = false;
    }

    if (nBitNo >= 0) {
        if (!firstField) updateSQL += ", ";
        updateSQL += "BitNo = " + std::to_string(nBitNo);
    }

    updateSQL += " WHERE CEID = " + std::to_string(nCEID) + ";";

    if (!m_pDB->executeQuery(updateSQL)) {
        return 2;
    }

    return 0;
}

// 删除指定 CEID 的 EqpEvent 数据
int SECSRuntimeManager::deleteEqpEventByID(int nCEID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return 1; // 数据库未连接，返回 1
    }

    // 构建删除 SQL 语句
    std::string deleteSQL = "DELETE FROM EqpEvent WHERE CEID = " + std::to_string(nCEID) + ";";
    if (!m_pDB->executeQuery(deleteSQL)) {
        return 2; // 删除失败，返回 2
    }

    return 0; // 删除成功，返回 0
}

// 删除所有 EqpEvent 数据
int SECSRuntimeManager::deleteAllEqpEvents() {
    return deleteAllDataFromTable("EqpEvent");
}

// 初始化 EventLink 表
@@ -885,8 +1401,8 @@
    // 创建 EqpPPID 表
    std::string createTableSQL =
        "CREATE TABLE IF NOT EXISTS EqpPPID ("
        "BitNo INTEGER PRIMARY KEY AUTOINCREMENT, "
        "PPID INTEGER NULL);";
        "RecipeNo INTEGER PRIMARY KEY, "
        "PPID TEXT NULL);";
    if (!m_pDB->executeQuery(createTableSQL)) {
        throw std::runtime_error("Failed to create EqpPPID table.");
    }
@@ -896,7 +1412,7 @@
    if (nCount == 0) {
        // 插入初始数据（512 行）
        for (int nBitNo = 0; nBitNo < 512; ++nBitNo) {
            std::string insertSQL = "INSERT INTO EqpPPID (BitNo) VALUES (" + std::to_string(nBitNo) + ");";
            std::string insertSQL = "INSERT INTO EqpPPID (RecipeNo) VALUES (" + std::to_string(nBitNo) + ");";
            if (!m_pDB->executeQuery(insertSQL)) {
                throw std::runtime_error("Failed to insert data into EqpPPID table.");
            }
@@ -904,6 +1420,112 @@
    }
}

std::vector<std::string> SECSRuntimeManager::getAllPPID() {
   std::lock_guard<std::mutex> lock(m_mutex);
   if (m_pDB == nullptr) {
      return {};
   }

   std::string querySQL = "SELECT PPID FROM EqpPPID;";
   auto rows = m_pDB->fetchResults(querySQL);

   std::vector<std::string> vecResult;
   for (const auto& row : rows) {
        vecResult.push_back(row[0]);
   }
   return vecResult;
}

void SECSRuntimeManager::setAllPPID(const std::vector<std::string>& vecPPIDList) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) return;

    // 开启事务
    m_pDB->executeQuery("BEGIN TRANSACTION;");

    for (size_t i = 0; i < vecPPIDList.size(); ++i) {
        std::string safePPID = vecPPIDList[i];
        size_t pos = 0;
        while ((pos = safePPID.find('\'', pos)) != std::string::npos) {
            safePPID.insert(pos, 1, '\'');
            pos += 2;
        }
        std::string sql = "UPDATE EqpPPID SET PPID = '" + safePPID + "' WHERE RecipeNo = " + std::to_string(i) + ";";
        m_pDB->executeQuery(sql);
    }

    // 提交事务
    m_pDB->executeQuery("COMMIT;");
}

bool SECSRuntimeManager::updatePPIDForRecipe(int nRecipeNo, const std::string& strPPID) {
    std::lock_guard<std::mutex> lock(m_mutex);
    if (m_pDB == nullptr) {
        return false;
    }

    // 转义单引号，防止 SQL 注入
    std::string safePPID = strPPID;
    size_t pos = 0;
    while ((pos = safePPID.find('\'', pos)) != std::string::npos) {
        safePPID.insert(pos, 1, '\'');
        pos += 2;
    }

    std::string updateSQL = "UPDATE EqpPPID SET PPID = '" + safePPID + "' WHERE RecipeNo = " + std::to_string(nRecipeNo) + ";";
    return m_pDB->executeQuery(updateSQL);
}

std::string SECSRuntimeManager::getPPIDForRecipe(int nRecipeNo) {
   std::lock_guard<std::mutex> lock(m_mutex);
   if (m_pDB == nullptr) {
      return "";
   }

   std::string querySQL = "SELECT PPID FROM EqpPPID WHERE RecipeNo = " + std::to_string(nRecipeNo) + ";";
   std::vector<std::vector<std::string>> results = m_pDB->fetchResults(querySQL);
   if (!results.empty() && !results[0].empty()) {
      return results[0][0];
   }

   return "";
}

int SECSRuntimeManager::getRecipeForPPID(std::string strPPID) {
   std::lock_guard<std::mutex> lock(m_mutex);
   if (m_pDB == nullptr) {
      return -1;
   }

   std::string querySQL = "SELECT RecipeNo FROM EqpPPID WHERE PPID = '" + strPPID + "';";
   std::vector<std::vector<std::string>> results = m_pDB->fetchResults(querySQL);
   if (!results.empty() && !results[0].empty()) {
      return std::stoi(results[0][0]);
   }

   return -1;
}

bool SECSRuntimeManager::deletePPIDForRecipe(int nRecipeNo) {
   std::lock_guard<std::mutex> lock(m_mutex);
   if (m_pDB == nullptr) {
      return false;
   }

   std::string deleteSQL = "UPDATE EqpPPID SET PPID = NULL WHERE RecipeNo = " + std::to_string(nRecipeNo) + ";";
   return m_pDB->executeQuery(deleteSQL);
}

bool SECSRuntimeManager::deletePPIDForAllRecipes() {
   std::lock_guard<std::mutex> lock(m_mutex);
   if (m_pDB == nullptr) {
      return false;
   }

   std::string deleteSQL = "UPDATE EqpPPID SET PPID = NULL WHERE RecipeNo BETWEEN 0 AND 511;";
   return m_pDB->executeQuery(deleteSQL);
}

// 初始化 RPTID 表
void SECSRuntimeManager::initRPTIDTable() {
    std::lock_guard<std::mutex> lock(m_mutex);