From 334b16b4abb4cbe3d1d4e4f211efd6f4468ae09f Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期五, 19 九月 2025 15:12:52 +0800
Subject: [PATCH] 1.ControlJob和ProcessJob的中断操作,强制结批增加字符串描述原因,方便生产跟踪。

---
 SourceCode/Bond/Servo/SECSRuntimeManager.cpp |   38 ++++++++++++++++++++++++++++++++++++++
 1 files changed, 38 insertions(+), 0 deletions(-)

diff --git a/SourceCode/Bond/Servo/SECSRuntimeManager.cpp b/SourceCode/Bond/Servo/SECSRuntimeManager.cpp
index 708dcf1..ccbcf77 100644
--- a/SourceCode/Bond/Servo/SECSRuntimeManager.cpp
+++ b/SourceCode/Bond/Servo/SECSRuntimeManager.cpp
@@ -1420,6 +1420,44 @@
     }
 }
 
+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) {

--
Gitblit v1.9.3