From cacea2da59a3acd73f3161d819a10e0060762616 Mon Sep 17 00:00:00 2001
From: mrDarker <mr.darker@163.com>
Date: 星期二, 06 五月 2025 14:54:13 +0800
Subject: [PATCH] Merge branch 'clh' into liuyang

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

diff --git a/SourceCode/Bond/Servo/CRecipesManager.cpp b/SourceCode/Bond/Servo/CRecipesManager.cpp
new file mode 100644
index 0000000..e858b42
--- /dev/null
+++ b/SourceCode/Bond/Servo/CRecipesManager.cpp
@@ -0,0 +1,187 @@
+#include "stdafx.h"
+#include "CRecipesManager.h"
+#include "ToolUnits.h"
+#include "Common.h"
+
+
+namespace SERVO {
+	unsigned __stdcall TimeoutCheckWorkThreadFunction(LPVOID lpParam)
+	{
+		CRecipesManager* pRecipesManager = (CRecipesManager*)lpParam;
+		return pRecipesManager->TimeoutCheckWorkingProc();
+	}
+
+	CRecipesManager::CRecipesManager()
+	{
+		m_nSyncStatus = SS_NONE;
+		m_nTotalMasterRecipeCount = 0;
+		m_nWordThreadAddr = 0;
+		m_hWorkStop = nullptr;
+		m_hWorkThreadHandle = nullptr;
+		m_nTimeoutCount = 0;
+		::InitializeCriticalSection(&m_cs);
+	}
+
+	CRecipesManager::~CRecipesManager()
+	{
+		// 等待超时检测线程退出
+		if (m_hWorkStop != nullptr) {
+			SetEvent(m_hWorkStop);
+			if (m_hWorkThreadHandle != NULL) {
+				WaitForSingleObject(m_hWorkThreadHandle, INFINITE);
+				CloseHandle(m_hWorkThreadHandle);
+				m_hWorkThreadHandle = NULL;
+			}
+			CloseHandle(m_hWorkStop);
+			m_hWorkStop = NULL;
+		}
+
+
+		// 清理数据
+		lock();
+		for (auto item : m_mapRecipes) {
+			delete item.second;
+		}
+		for (auto item : m_mapRecipesTemp) {
+			delete item.second;
+		}
+		unlock();
+		::DeleteCriticalSection(&m_cs);
+	}
+
+	int CRecipesManager::syncing()
+	{
+		lock();
+		if (m_nSyncStatus == SS_SYNCING) {
+			unlock();
+			return -1;
+		}
+
+		m_nSyncStatus = SS_SYNCING;
+		m_nTimeoutCount = 0;
+		unlock();
+
+
+		if (m_hWorkStop == nullptr) {
+			m_hWorkStop = ::CreateEvent(NULL, TRUE, FALSE, NULL);
+			m_hWorkThreadHandle = (HANDLE)_beginthreadex(NULL, 0, SERVO::TimeoutCheckWorkThreadFunction, this,
+				0, &m_nWordThreadAddr);
+		}
+
+		return 0;
+	}
+
+	void CRecipesManager::syncFailed()
+	{
+		lock();
+		m_nSyncStatus = SS_FAILED;
+		m_nTimeoutCount = 0;
+		unlock();
+	}
+
+	short CRecipesManager::decodeRecipeListReport(const char* pszData, size_t size)
+	{
+		int index = 0;
+		int unitNo, reportType, totalMasterRecipeCount;
+		int toatlGroupCount, currentGroupCount;
+		const char* pszIdsData;
+
+		unitNo = CToolUnits::toInt16(&pszData[index]);
+		index += 2;
+
+		pszIdsData = &pszData[index];
+		index += (250 * 2);
+
+		reportType = CToolUnits::toInt16(&pszData[index]);
+		index += 2;
+
+		totalMasterRecipeCount = CToolUnits::toInt16(&pszData[index]);
+		index += 2;
+
+		toatlGroupCount = CToolUnits::toInt16(&pszData[index]);
+		index += 2;
+
+		lock();
+		if (m_nTotalMasterRecipeCount == 0) m_nTotalMasterRecipeCount = toatlGroupCount;
+		if (m_nTotalMasterRecipeCount != toatlGroupCount) {
+			return MRLRC_MASTER_RECIPE_LIST_COUNT_NG;
+		}
+		m_nTimeoutCount = 0;
+		unlock();
+
+		currentGroupCount = CToolUnits::toInt16(&pszData[index]);
+		index += 2;
+
+
+		// 找到对应CRecipeList, 找不到则新建
+		lock();
+		CRecipeList* pRecipeList = getRecipeListFromTemp(unitNo);
+		if (pRecipeList == nullptr) {
+			pRecipeList = new CRecipeList(unitNo);
+			m_mapRecipesTemp[unitNo] = pRecipeList;
+		}
+		unlock();
+		ASSERT(pRecipeList);
+
+
+		// 这里暂时只处理reportType=4，即Request from EAS
+		if (reportType == 4) {
+			int nRet = pRecipeList->addRecipePacket(toatlGroupCount, currentGroupCount, pszIdsData, 250 * 2);
+			if (MRLRC_CURRENT_RECIPE_COMPLETE == nRet) {
+				lock();
+				if (m_nTotalMasterRecipeCount == m_mapRecipesTemp.size()) {
+					for (auto item : m_mapRecipes) {
+						delete item.second;
+					}
+					m_mapRecipes = m_mapRecipesTemp;
+					m_mapRecipesTemp.clear();
+					m_nSyncStatus = SS_COMPLETE;
+					unlock();
+					return MRLRC_OK;
+				}
+				unlock();
+			}
+			else if (MRLRC_CONTINUE == nRet) {
+				return MRLRC_CONTINUE;
+			}
+		}
+
+
+		return MRLRC_OK;
+	}
+
+	CRecipeList* CRecipesManager::getRecipeListFromTemp(int unitNo)
+	{
+		auto iter = m_mapRecipesTemp.find(unitNo);
+		if (iter == m_mapRecipesTemp.end()) return nullptr;
+		return iter->second;
+	}
+
+	unsigned CRecipesManager::TimeoutCheckWorkingProc()
+	{
+		while (1) {
+			int nRet = WaitForSingleObject(m_hWorkStop, 1000);
+			if (nRet == WAIT_OBJECT_0) {
+				ResetEvent(m_hWorkStop);
+				break;
+			}
+
+			lock();
+			if (m_nSyncStatus == SS_SYNCING) {
+				m_nTimeoutCount++;
+				if (m_nTimeoutCount > 10) {
+					m_nSyncStatus = SS_TIMEOUT;
+					unlock();
+					TRACE("CRecipesManager::TimeoutCheckWorkingProc 超时退出\n");
+				}
+			}
+
+			unlock();
+		}
+
+		// _endthreadex(0);
+		TRACE("CRecipesManager::TimeoutCheckWorkingProc 线程退出\n");
+		return 0;
+	}
+
+}

--
Gitblit v1.9.3