| | |
|---|
| | | for (int i = 0; i < pBody->getSubItemSize(); i++) { |
|---|
| | | ISECS2Item* pStreamItem = pBody->getSubItem(i); |
|---|
| | | ASSERT(pStreamItem); |
|---|
| | | unsigned char STRID; |
|---|
| | | unsigned char STRID, FCNID; |
|---|
| | | pStreamItem->getSubItemU1(0, STRID); |
|---|
| | | ISECS2Item* pFcnItem = pStreamItem->getSubItem(1); |
|---|
| | | for (int j = 0; j < pFcnItem->getSubItemSize(); j++) { |
|---|
| | | |
|---|
| | | ISECS2Item* pFcnItemList = pStreamItem->getSubItem(1); |
|---|
| | | if (pFcnItemList->getSubItemSize() == 0) { |
|---|
| | | m_spoolingConfig[STRID].clear(); |
|---|
| | | } |
|---|
| | | else { |
|---|
| | | for (int j = 0; j < pFcnItemList->getSubItemSize(); j++) { |
|---|
| | | pFcnItemList->getSubItemU1(j, FCNID); |
|---|
| | | m_spoolingConfig[STRID].insert(FCNID); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | |
|---|
| | | 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); |
|---|
| | | // 打印验证结果 |
|---|
| | | for (auto s : m_spoolingConfig) { |
|---|
| | | LOGI("====> stream:%d", s.first); |
|---|
| | | for (auto f : s.second) { |
|---|
| | | LOGI("function:%d", f); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | 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; |
|---|
