From e42e8364112e97d89eeaecd13f043dff42179949 Mon Sep 17 00:00:00 2001
From: LAPTOP-SNT8I5JK\Boounion <Chenluhua@qq.com>
Date: 星期二, 27 五月 2025 17:19:02 +0800
Subject: [PATCH] 1.enum修改为enum class, 理顺CLoadPort各成员变量在调度中的判定作用；

---
 SourceCode/Bond/Servo/HsmsPassive.cpp |  710 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 703 insertions(+), 7 deletions(-)

diff --git a/SourceCode/Bond/Servo/HsmsPassive.cpp b/SourceCode/Bond/Servo/HsmsPassive.cpp
index 22d340d..094f4fd 100644
--- a/SourceCode/Bond/Servo/HsmsPassive.cpp
+++ b/SourceCode/Bond/Servo/HsmsPassive.cpp
@@ -3,6 +3,11 @@
 #include "Log.h"
 #include "Model.h"
 #include "Common.h"
+#include <time.h>
+#include <iostream>  
+#include <time.h>  
+#include <stdlib.h>  
+#include <string.h>  
 
 
 unsigned __stdcall CimWorkThreadFunction(LPVOID lpParam)
@@ -26,11 +31,18 @@
 	m_pModel = nullptr;
 	m_nActionTimeout = 6;
 	m_nSystemByte = 0;
+	m_strEquipmentModelType = "2860";
 	m_strSoftRev = _T("1.0.1");
 	m_hCimWorkThreadHandle = NULL;
 	m_nCimWorkThrdaddr = 0;
 	m_bCimWorking = FALSE;
 	m_hCimWorkEvent = ::CreateEvent(NULL, TRUE, FALSE, NULL);
+	m_nSessionId = 1;
+	m_listener.onEQOffLine = nullptr;
+	m_listener.onEQOnLine = nullptr;
+	m_listener.onCommand = nullptr;
+	m_listener.onEQConstantRequest = nullptr;
+	m_listener.onEQConstantSend = nullptr;
 	InitializeCriticalSection(&m_criticalSection);
 }
 
@@ -54,9 +66,92 @@
 	DeleteCriticalSection(&m_criticalSection);
 }
 
+void CHsmsPassive::setListener(SECSListener listener)
+{
+	m_listener.onEQOffLine = listener.onEQOffLine;
+	m_listener.onEQOnLine = listener.onEQOnLine;
+	m_listener.onCommand = listener.onCommand;
+	m_listener.onEQConstantRequest = listener.onEQConstantRequest;
+	m_listener.onEQConstantSend = listener.onEQConstantSend;
+}
+
 void CHsmsPassive::setActionTimeout(int nSecond)
 {
 	m_nActionTimeout = max(3, nSecond);
+}
+
+void CHsmsPassive::setEquipmentModelType(const char* pszMode)
+{
+	m_strEquipmentModelType = pszMode;
+	if (m_strEquipmentModelType.length() > 20) {
+		m_strEquipmentModelType = m_strEquipmentModelType.substr(0, 20);
+	}
+}
+
+void CHsmsPassive::setSoftRev(const char* pszRev)
+{
+	m_strSoftRev = pszRev;
+	if (m_strSoftRev.length() > 20) {
+		m_strSoftRev = m_strSoftRev.substr(0, 20);
+	}
+
+}
+
+void CHsmsPassive::addReport(unsigned int id, const char* pszName)
+{
+	Lock();
+	REPORT report;
+	report.id = id;
+	strcpy_s(report.szName, REPORT_NAME_MAX, pszName);
+	m_mapReport[id] = report;
+	Unlock();
+}
+
+void CHsmsPassive::linkEventReport(unsigned int RPTID, unsigned int CEID)
+{
+	m_mapReportIdToCEID[RPTID] = CEID;
+}
+
+void CHsmsPassive::unlinkEventReport(unsigned int CEID)
+{
+	for (auto it = m_mapReportIdToCEID.begin(); it != m_mapReportIdToCEID.end(); ) {
+		if (it->second == CEID) {
+			m_mapReportIdToCEID.erase(it++);  // 更新迭代器
+		}
+		else {
+			++it;
+		}
+	}
+
+}
+
+unsigned int CHsmsPassive::getCEID(int RPTID)
+{
+	auto iter = m_mapReportIdToCEID.find(RPTID);
+	if (iter != m_mapReportIdToCEID.end()) return iter->second;
+	return 0;
+}
+
+void CHsmsPassive::deleteReport(unsigned int RPTID)
+{
+	for (auto it = m_mapValueIdToPRTID.begin(); it != m_mapValueIdToPRTID.end(); ) {
+		if (it->second == RPTID) {
+			m_mapValueIdToPRTID.erase(it++);  // 更新迭代器
+		}
+		else {
+			++it;
+		}
+	}
+}
+
+void CHsmsPassive::deleteAllReport()
+{
+	m_mapValueIdToPRTID.clear();
+}
+
+void CHsmsPassive::defineReport(unsigned int VID, unsigned int RPTID)
+{
+	m_mapValueIdToPRTID[VID] = RPTID;
 }
 
 void CHsmsPassive::OnTimer(UINT nTimerid)
@@ -78,6 +173,7 @@
 
 int CHsmsPassive::onRecvMsg(IMessage* pMessage)
 {
+	LOGI("onRecvMsg:%s", pMessage->toString());
 	Lock();
 	CHsmsAction* pAction = nullptr;
 	for (auto iter = m_listActionSent.begin(); iter != m_listActionSent.end(); iter++) {
@@ -109,7 +205,9 @@
 	auto onStatusChanged = [&](void* pFrom, STATE state) -> void {
 		m_pModel->notifyInt(RX_CODE_PASSIVE_STATUS_CHANGED, (int)state);
 
-		// 连上之后发S1F1, 
+		// 连上之后发S1F1
+		// 修改为不主动发送，而是响应
+		/*
 		if (STATE::SELECTED == state) {
 			m_bAreYouThereRequest = FALSE;
 			if (!m_bAreYouThereRequest) {
@@ -117,17 +215,20 @@
 				secsAreYouThereRequest();
 			}
 		}
+		*/
 	};
 	auto onRecvSysMessage = [&](void* pFrom, IMessage* pMessage) -> void {
 		LOGI("<HSMS>onRecvSysMessage:sessionId:%d, sType:%d systemBytes:%d",
 			pMessage->getHeader()->sessionId, pMessage->getHeader()->sType, pMessage->getHeader()->systemBytes);
 		onRecvMsg(pMessage);
 		if (MSG_LINKTEST_REQ == pMessage->getHeader()->sType) {
+			/*
 			Sleep(10);
 			if (!m_bAreYouThereRequest) {
 				m_bAreYouThereRequest = TRUE;
-				secsAreYouThereRequest();
+				requestYouThere();
 			}
+			*/
 		}
 	};
 
@@ -147,7 +248,46 @@
 		LOGI("<HSMS>收到消息 S%dF%d", nStream, pHeader->function);
 		if (nStream == 1 && pHeader->function == 1) {
 			// S1F1
-			secsAreYouThereReply(pHeader->sessionId, pHeader->systemBytes);
+			replyAreYouThere(pMessage);
+		}
+		else if (nStream == 1 && pHeader->function == 13) {
+			replyEstablishCommunications(pMessage);
+		}
+		else if (nStream == 1 && pHeader->function == 15) {
+			replyOffLine(pMessage);
+		}
+		else if (nStream == 1 && pHeader->function == 17) {
+			replyOnLine(pMessage);
+		}
+		else if (nStream == 2 && pHeader->function == 13) {
+			replyEquipmentConstantRequest(pMessage);
+		}
+		else if (nStream == 2 && pHeader->function == 15) {
+			replyEquipmentConstantSend(pMessage);
+		}
+		else if (nStream == 2 && pHeader->function == 31) {
+			replyDatetime(pMessage);
+		}
+		else if (nStream == 2 && pHeader->function == 33) {
+			replyDefineReport(pMessage);
+		}
+		else if (nStream == 2 && pHeader->function == 35) {
+			replyLinkEventReport(pMessage);
+		}
+		else if (nStream == 2 && pHeader->function == 37) {
+			replyEanbleDisableEventReport(pMessage);
+		}
+		else if (nStream == 2 && pHeader->function == 41) {
+			replyCommand(pMessage);
+		}
+		else if (nStream == 5 && pHeader->function == 3) {
+			replyEanbleDisableAlarmReport(pMessage);
+		}
+		else if (nStream == 7 && pHeader->function == 19) {
+			replyQueryPPIDList(pMessage);
+		}
+		else if (nStream == 10 && pHeader->function == 3) {
+			replyTerminalDisplay(pMessage);
 		}
 	};
 
@@ -250,8 +390,21 @@
 	return 0;
 }
 
+// 通用的reply ack函数
+void CHsmsPassive::replyAck(int s, int f, unsigned int systemBytes, BYTE ack, const char* pszAckName)
+{
+	IMessage* pMessage = NULL;
+	HSMS_Create1Message(pMessage, m_nSessionId, s, f, systemBytes);
+	ASSERT(pMessage);
+	ISECS2Item* pItem = pMessage->getBody();
+	pItem->setBinary((const char*)&ack, 1, pszAckName);
+	m_pPassive->sendMessage(pMessage);
+	LOGI("<HSMS>[SECS Msg SEND]S%dF%d (SysByte=%u)", s, f, systemBytes);
+	HSMS_Destroy1Message(pMessage);
+}
+
 // S1F1
-int CHsmsPassive::secsAreYouThereRequest()
+int CHsmsPassive::requestAreYouThere()
 {
 	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
 		return ER_NOTSELECT;
@@ -261,7 +414,7 @@
 	CHsmsAction* pAction = new CHsmsAction(ACTION_HELLO, FALSE, m_nActionTimeout);
 	m_listAction.push_back(pAction);
 	IMessage* pMessage = NULL;
-	HSMS_Create1Message(pMessage, 0xffff, 1 | REPLY, 1, ++m_nSystemByte);
+	HSMS_Create1Message(pMessage, m_nSessionId, 1 | REPLY, 1, ++m_nSystemByte);
 	ASSERT(pMessage);
 	pAction->setSendMessage(pMessage);
 
@@ -272,14 +425,14 @@
 }
 
 // S1F2
-int CHsmsPassive::secsAreYouThereReply(unsigned int sessionId, unsigned int systemBytes)
+int CHsmsPassive::replyAreYouThere(IMessage* pRecv)
 {
 	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
 		return ER_NOTSELECT;
 	}
 
 	IMessage* pMessage = NULL;
-	HSMS_Create1Message(pMessage, sessionId, 1, 2, systemBytes);
+	HSMS_Create1Message(pMessage, m_nSessionId, 1, 2, pRecv->getHeader()->systemBytes);
 	ASSERT(pMessage);
 
 	ISECS2Item* pItem = pMessage->getBody();
@@ -291,3 +444,546 @@
 
 	return 0;
 }
+
+// S1F15
+int CHsmsPassive::replyOffLine(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+
+	// 交由上层应用来获取机器常量值
+	if (m_listener.onEQOffLine != nullptr) {
+		m_listener.onEQOffLine(this);
+	}
+
+
+	// 回复
+	replyAck(1, 16, pRecv->getHeader()->systemBytes, BYTE(0), "OFLACK");
+	return 0;
+}
+
+// S1F17
+int CHsmsPassive::replyOnLine(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+
+	// 交由上层应用来获取机器常量值
+	if (m_listener.onEQOnLine != nullptr) {
+		m_listener.onEQOnLine(this);
+	}
+
+
+	// 回复
+	replyAck(1, 18, pRecv->getHeader()->systemBytes, BYTE(0), "ONLACK");
+	return 0;
+}
+
+int CHsmsPassive::replyEstablishCommunications(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+	IMessage* pMessage = NULL;
+	HSMS_Create1Message(pMessage, m_nSessionId, 1, 14, pRecv->getHeader()->systemBytes);
+	ASSERT(pMessage);
+
+	ISECS2Item* pItem = pMessage->getBody();
+	pItem->addBinaryItem(BYTE(0), "COMMACK");
+	ISECS2Item* pList = pItem->addItem();
+	pList->addItem(m_strEquipmentModelType.c_str(), "MDLN");
+	pList->addItem(m_strSoftRev.c_str(), "SOFTREV");
+	m_pPassive->sendMessage(pMessage);
+	LOGI("<HSMS>[SECS Msg SEND]S1F14 (SysByte=%u)", pMessage->getHeader()->systemBytes);
+	HSMS_Destroy1Message(pMessage);
+
+	return 0;
+}
+
+// S2F13
+int CHsmsPassive::replyEquipmentConstantRequest(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+
+	// 要获取的常量表表
+	BOOL bCheckData = FALSE;
+	std::vector<EQConstant> eqcs;
+	{
+		ISECS2Item* pItem = pRecv->getBody();
+		int ecidSize = pItem->getSubItemSize();
+		for (int i = 0; i < ecidSize; i++) {
+			EQConstant eqc;
+			unsigned short id;
+			if (pItem->getSubItemU2(i, id)) {
+				eqc.id = id;
+				eqcs.push_back(eqc);
+			}
+		}
+	}
+
+
+	// 交由上层应用来获取机器常量值
+	if (m_listener.onEQConstantRequest != nullptr) {
+		m_listener.onEQConstantRequest(this, eqcs);
+	}
+
+
+	// 回复
+	IMessage* pMessage = NULL;
+	HSMS_Create1Message(pMessage, m_nSessionId, 1, 14, pRecv->getHeader()->systemBytes);
+	ASSERT(pMessage);
+	ISECS2Item* pItem = pMessage->getBody();
+	for (auto& item : eqcs) {
+		pItem->addItem(item.szValue, "ECV");
+	}
+
+	m_pPassive->sendMessage(pMessage);
+	LOGI("<HSMS>[SECS Msg SEND]S2F14 (SysByte=%u)", pMessage->getHeader()->systemBytes);
+	HSMS_Destroy1Message(pMessage);
+
+	return 0;
+}
+
+// S2F15
+int CHsmsPassive::replyEquipmentConstantSend(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+
+	// 要设置的常量表表
+	BOOL bCheckData = FALSE;
+	std::vector<EQConstant> eqcs;
+	{
+		ISECS2Item* pItem = pRecv->getBody();
+		int ecidSize = pItem->getSubItemSize();
+		for (int i = 0; i < ecidSize; i++) {
+			ISECS2Item* pItemEqc = pItem->getSubItem(i);
+			if (pItemEqc != nullptr) {
+				EQConstant eqc;
+				unsigned short eqcid;
+				const char* pszValue;
+				if (pItemEqc->getSubItemU2(0, eqcid)
+					&& pItemEqc->getSubItemString(1, pszValue)) {
+					eqc.id = eqcid;
+					strcpy_s(eqc.szValue, EQCONSTANT_VALUE_MAX, pszValue);
+					eqcs.push_back(eqc);
+				}
+			}
+		}
+	}
+
+
+	// 交由上层应用来保存和设置机器常量值
+	std::vector<unsigned int> ecvs;
+	if (m_listener.onEQConstantSend != nullptr) {
+		m_listener.onEQConstantSend(this, eqcs);
+	}
+
+
+	// 回复
+	replyAck(2, 16, pRecv->getHeader()->systemBytes, BYTE(0), "EACK");
+	return 0;
+}
+
+// S2F31
+int CHsmsPassive::replyDatetime(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+	ISECS2Item* pBody =	pRecv->getBody();
+	if (pBody == nullptr || pBody->getType() != SITYPE::A) ER_PARAM_ERROR;
+	const char* pszMessage;
+	if (pBody->getString(pszMessage)) {
+		// 更新时间
+		SYSTEMTIME time;
+		char szBuffer[20];
+		memcpy(szBuffer, pszMessage, 16);
+		szBuffer[14] = '\0';
+		time.wSecond = atoi(&szBuffer[12]);
+		szBuffer[12] = '\0';
+		time.wMinute = atoi(&szBuffer[10]);
+		szBuffer[10] = '\0';
+		time.wHour = atoi(&szBuffer[8]);
+		szBuffer[8] = '\0';
+		time.wDay = atoi(&szBuffer[6]);
+		szBuffer[6] = '\0';
+		time.wMonth = atoi(&szBuffer[4]);
+		szBuffer[4] = '\0';
+		time.wYear = atoi(&szBuffer[0]);
+		time.wMilliseconds = 0;
+		SetLocalTime(&time);
+	}
+
+	replyAck(2, 32, pRecv->getHeader()->systemBytes, BYTE(0), "TIACK");
+	return 0;
+}
+
+// S2F33
+int CHsmsPassive::replyDefineReport(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+
+	ISECS2Item* pBody = pRecv->getBody();
+	ISECS2Item* defineItem, *rptListItem, * vidListItem;
+	unsigned int dataId, rptid, vid;
+	if (!pBody->getSubItemU4(0, dataId)) goto MYREPLY;
+	rptListItem = pBody->getSubItem(1);
+	if (rptListItem == nullptr) goto MYREPLY;
+	if (rptListItem->getSubItemSize() == 0) {
+		deleteAllReport();
+		goto MYREPLY;
+	}
+	for (int i = 0; i < rptListItem->getSubItemSize(); i++) {
+		defineItem = rptListItem->getSubItem(i);
+		if (defineItem == nullptr) continue;
+		vidListItem = defineItem->getSubItem(1);
+		if (defineItem->getSubItemU4(0, rptid)
+			&& vidListItem != nullptr) {
+			int vidCount = vidListItem->getSubItemSize();
+			if (vidCount == 0) {
+				deleteReport(rptid);
+			}
+			else {
+				for (int k = 0; k < vidCount; k++) {
+					if (vidListItem->getSubItemU4(k, vid)) {
+						defineReport(vid, rptid);
+					}
+				}
+			}
+		}
+	}
+
+
+MYREPLY:
+	// 检验结果是否正确
+	for (auto item : m_mapValueIdToPRTID) {
+		LOGE("=== vid:%d, prtid:%d", item.first, item.second);
+	}
+
+	replyAck(2, 34, pRecv->getHeader()->systemBytes, BYTE(0), "DRACK");
+	return 0;
+}
+
+// S2F35
+int CHsmsPassive::replyLinkEventReport(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+
+	ISECS2Item* pBody = pRecv->getBody();
+	ISECS2Item* linkItem, *ceidListItem, *rptListItem;
+	unsigned int dataId, ceid, rptid;
+	if (!pBody->getSubItemU4(0, dataId)) goto MYREPLY;
+	ceidListItem = pBody->getSubItem(1);
+	if (ceidListItem == nullptr) goto MYREPLY;
+	for (int i = 0; i < ceidListItem->getSubItemSize(); i++) {
+		linkItem = ceidListItem->getSubItem(i);
+		if (linkItem == nullptr) continue;
+		rptListItem = linkItem->getSubItem(1);
+		if (linkItem->getSubItemU4(0, ceid)
+			&& rptListItem != nullptr) {
+			int prtCount = rptListItem->getSubItemSize();
+			if (prtCount == 0) {
+				unlinkEventReport(ceid);
+			}
+			else {
+				for (int k = 0; k < prtCount; k++) {
+					if (rptListItem->getSubItemU4(k, rptid)) {
+						linkEventReport(rptid, ceid);
+					}
+				}
+			}
+		}
+	}
+
+
+	// 检验结果是否正确
+	for (auto item : m_mapReportIdToCEID) {
+		LOGE("=== prtid:%d, ceid:%d", item.first, item.second);
+	}
+
+MYREPLY:
+	replyAck(2, 36, pRecv->getHeader()->systemBytes, BYTE(0), "LRACK");
+	return 0;
+}
+
+// S2F37
+int CHsmsPassive::replyEanbleDisableEventReport(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+	ISECS2Item* pBody = pRecv->getBody();
+	if (pBody == nullptr || pBody->getType() != SITYPE::A) ER_PARAM_ERROR;
+
+
+
+	BOOL bCheckData = FALSE;
+	bool bEnable;
+	std::vector<unsigned int> ids;
+	{
+		ISECS2Item* pItemIds;
+		ISECS2Item* pItem = pRecv->getBody();
+		if (pItem->getSubItemSize() < 2) goto MYREPLY;
+		if (!pItem->getSubItemBool(0, bEnable)) goto MYREPLY;
+		pItemIds = pItem->getSubItem(1);
+		if (pItemIds == nullptr || pItemIds->getType() != SITYPE::L) goto MYREPLY;
+		for (int i = 0; i < pItemIds->getSubItemSize(); i++) {
+			unsigned int id;
+			if (pItemIds->getSubItemU4(i, id)) {
+				ids.push_back(id);
+			}
+		}
+		bCheckData = TRUE;
+		LOGI("EanbleDisableAlarm bEnable:%s", bEnable ? _T("YES") : _T("NO"));
+		for (auto item : ids) {
+			LOGI("ID:%u", item);
+		}
+	}
+
+
+MYREPLY:
+	replyAck(2, 38, pRecv->getHeader()->systemBytes, BYTE(0), "ERACK");
+	return 0;
+}
+
+// S2F41
+int CHsmsPassive::replyCommand(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+	ISECS2Item* pBody = pRecv->getBody();
+	if (pBody == nullptr || pBody->getType() != SITYPE::A) ER_PARAM_ERROR;
+
+
+
+	BOOL bCheckData = FALSE;
+	const char* pszCmdName;
+	std::vector<CommandParameter> params;
+	{
+		ISECS2Item* pItemParams, *pItemParam;
+		ISECS2Item* pItem = pRecv->getBody();
+		if (pItem->getSubItemSize() < 2) goto MYREPLY;
+		if (!pItem->getSubItemString(0, pszCmdName)) goto MYREPLY;
+		pItemParams = pItem->getSubItem(1);
+		if (pItemParams == nullptr || pItemParams->getType() != SITYPE::L) goto MYREPLY;
+		for (int i = 0; i < pItemParams->getSubItemSize(); i++) {
+			const char* pszParamName, * pszParamValue;
+			pItemParam = pItemParams->getSubItem(i);
+			if (pItemParam != nullptr 
+				&& pItemParam->getSubItemString(0, pszParamName)
+				&& pItemParam->getSubItemString(1, pszParamValue)) {
+				CommandParameter cp;
+				strcpy_s(cp.szName, COMMAND_NAME_MAX, pszParamName);
+				strcpy_s(cp.szValue, COMMAND_VALUE_MAX, pszParamValue);
+				params.push_back(cp);
+			}
+		}
+		bCheckData = TRUE;
+	}
+
+
+	// 回调到应用层
+	if (bCheckData) {
+		if (m_listener.onCommand != nullptr) {
+			m_listener.onCommand(this, pszCmdName, params);
+		}
+	}
+
+MYREPLY:
+	replyAck(2, 42, pRecv->getHeader()->systemBytes, BYTE(0), "ERACK");
+	return 0;
+}
+
+// S5F3
+int CHsmsPassive::replyEanbleDisableAlarmReport(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+	ISECS2Item* pBody = pRecv->getBody();
+	if (pBody == nullptr || pBody->getType() != SITYPE::A) ER_PARAM_ERROR;
+
+
+
+	BOOL bCheckData = FALSE;
+	const char* ALED;
+	unsigned int ALID;
+	unsigned int ALEDLEN;
+	{
+		ISECS2Item* pItem = pRecv->getBody();
+		if (pItem->getSubItemSize() < 2) goto MYREPLY;
+		if (!pItem->getSubItemBinary(0, ALED, ALEDLEN)) goto MYREPLY;
+		if (!pItem->getSubItemU4(1, ALID)) goto MYREPLY;
+		bCheckData = TRUE;
+		LOGI("EanbleDisableAlarmReport ALED:0x%02x, ALID:%d", ALED[0], ALID);
+
+		double d;
+		float f;
+		pItem->getSubItemF4(2, f);
+		pItem->getSubItemF8(3, d);
+		LOGI("EanbleDisableAlarmReport d:%lf, f:%f",
+			d, f);
+		/*
+		unsigned long long n1;
+		unsigned int n2;
+		unsigned short n3;
+		unsigned char n4;
+		long long sn1;
+		int sn2;
+		short sn3;
+		char sn4;
+		pItem->getSubItemU8(2, n1);
+		pItem->getSubItemU4(3, n2);
+		pItem->getSubItemU2(4, n3);
+		pItem->getSubItemU1(5, n4);
+		pItem->getSubItemI8(6, sn1);
+		pItem->getSubItemI4(7, sn2);
+		pItem->getSubItemI2(8, sn3);
+		pItem->getSubItemI1(9, sn4);
+
+		LOGI("EanbleDisableAlarmReport n1:%llu, n2:%u, n3:%hu, n4:%hhu", 
+			n1, n2, n3, n4);
+		LOGI("EanbleDisableAlarmReport sn1:%lld, sn2:%d, sn3:%hd, sn4:%hhd",
+			sn1, sn2, sn3, sn4);
+			*/
+	}
+
+
+MYREPLY:
+	replyAck(5, 4, pRecv->getHeader()->systemBytes, BYTE(0), "ACKC5");
+	return 0;
+}
+
+// S7F19
+int CHsmsPassive::replyQueryPPIDList(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+
+	IMessage* pMessage = NULL;
+	HSMS_Create1Message(pMessage, m_nSessionId, 7, 20, pRecv->getHeader()->systemBytes);
+	ASSERT(pMessage);
+
+	ISECS2Item* pItem = pMessage->getBody();
+	pItem->addItem("banana1", "PPID1");
+	pItem->addItem("banana2", "PPID2");
+	pItem->addF8Item(-123.45, "PPID2");
+	pItem->addF4Item(-568.99f, "PPID2");
+	pItem->addF8Item(456.456, "PPID2");
+	pItem->addF4Item(123.123f, "PPID2");
+	m_pPassive->sendMessage(pMessage);
+	LOGI("<HSMS>[SECS Msg SEND]S7F20 (SysByte=%u)", pMessage->getHeader()->systemBytes);
+	HSMS_Destroy1Message(pMessage);
+
+	return 0;
+}
+
+// S10F3
+int CHsmsPassive::replyTerminalDisplay(IMessage* pRecv)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+	ISECS2Item* pBody = pRecv->getBody();
+	if (pBody == nullptr || pBody->getType() != SITYPE::A) ER_PARAM_ERROR;
+
+
+
+	BOOL bCheckData = FALSE;
+	const char* tid;
+	unsigned int tidlen;
+	const char* pszText = nullptr;;
+	{
+		ISECS2Item* pItem = pRecv->getBody();
+		if (pItem->getSubItemSize() < 2) goto MYREPLY;
+		if (!pItem->getSubItemBinary(0, tid, tidlen)) goto MYREPLY;
+		if (!pItem->getSubItemString(1, pszText)) goto MYREPLY;
+		bCheckData = TRUE;
+		LOGI("TerminalDisplay tid:0x%02x, pszText:%s", tid[0], pszText);
+		m_pModel->notifyText(RX_HSMS_TERMINAL_TEXT, pszText);
+	}
+
+
+MYREPLY:
+	replyAck(10, 4, pRecv->getHeader()->systemBytes, BYTE(0), "ACKC10");
+	return 0;
+}
+
+// S5F1
+int CHsmsPassive::requestAlarmReport(int ALCD, int ALID, const char* ALTX)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+	Lock();
+	CHsmsAction* pAction = new CHsmsAction(ACTION_ALARM_REPORT, TRUE, m_nActionTimeout);
+	m_listAction.push_back(pAction);
+	IMessage* pMessage = NULL;
+	HSMS_Create1Message(pMessage, m_nSessionId, 5 | REPLY, 1, ++m_nSystemByte);
+	ASSERT(pMessage);
+	ISECS2Item* pItem = pMessage->getBody();
+	pItem->addBinaryItem(BYTE(ALCD & 0xff), "ALCD");
+	pItem->addU4Item(ALID, "ALID");
+	pItem->addItem(ALTX, "ALTX");
+	pAction->setSendMessage(pMessage);
+
+	SetEvent(m_hCimWorkEvent);
+	Unlock();
+
+	return ER_NOERROR;
+}
+
+// S6F11
+int CHsmsPassive::requestEventReportSend(unsigned int DATAID, unsigned int RPTID, const std::vector<std::string>& values)
+{
+	if (m_pPassive == NULL || STATE::SELECTED != m_pPassive->getState()) {
+		return ER_NOTSELECT;
+	}
+
+	Lock();
+	CHsmsAction* pAction = new CHsmsAction(ACTION_EVENT_REPORT, TRUE, m_nActionTimeout);
+	m_listAction.push_back(pAction);
+	IMessage* pMessage = NULL;
+	HSMS_Create1Message(pMessage, m_nSessionId, 6 | REPLY, 11, ++m_nSystemByte);
+	ASSERT(pMessage);
+	ISECS2Item* pItem = pMessage->getBody();
+	pItem->addU4Item(DATAID, "DATAID");
+	pItem->addU4Item(getCEID(RPTID), "CEID");
+	ISECS2Item* pItemList1 = pItem->addItem();
+	ISECS2Item* pItemList2 = pItemList1->addItem();
+	pItemList2->addU4Item(RPTID, "RPTID");
+	ISECS2Item* pItemList3 = pItemList2->addItem();
+	for (auto item : values) {
+		pItemList3->addItem(item.c_str(), "V");
+	}
+	pAction->setSendMessage(pMessage);
+
+	SetEvent(m_hCimWorkEvent);
+	Unlock();
+	
+	return ER_NOERROR;
+}
+
+
+

--
Gitblit v1.9.3