added:queryfile parse

Author: xengine-qyt

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/P2XPProtocol_Define.h

@@ -118,6 +118,30 @@ extern "C" BOOL P2XPProtocol_Parse_User(LPCTSTR lpszMsgBuffer, int nMsgLen, TCHA
 备注：
 *********************************************************************/
 extern "C" BOOL P2XPProtocol_Parse_Connect(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_P2XPIO_PROTOCOL* pSt_IOProtocol);
+/********************************************************************
+函数名称：P2XPProtocol_Parse_QueryFile
+函数功能：查询文件
+ 参数.一：lpszMsgBuffer
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要解析的缓冲区
+ 参数.二：nMsgLen
+  In/Out：In
+  类型：整数型
+  可空：N
+  意思：输入缓冲区大小
+ 参数.三：pSt_ProtocolFile
+  In/Out：Out
+  类型：数据结构指针
+  可空：N
+  意思：输出解析的文件信息
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+extern "C" BOOL P2XPProtocol_Parse_QueryFile(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_PROTOCOL_FILE* pSt_ProtocolFile);
 /************************************************************************/
 /*                        打包协议导出                                  */
 /************************************************************************/

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/P2XPProtocol_Parse/P2XPProtocol_Parse.cpp

@@ -278,4 +278,78 @@ BOOL CP2XPProtocol_Parse::P2XPProtocol_Parse_Connect(LPCTSTR lpszMsgBuffer, int
 		pSt_IOProtocol->bIsTcp = st_JsonRoot["bIsTcp"].asInt();
 	}
 	return TRUE;
+}
+/********************************************************************
+函数名称：P2XPProtocol_Parse_QueryFile
+函数功能：查询文件
+ 参数.一：lpszMsgBuffer
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要解析的缓冲区
+ 参数.二：nMsgLen
+  In/Out：In
+  类型：整数型
+  可空：N
+  意思：输入缓冲区大小
+ 参数.三：pSt_ProtocolFile
+  In/Out：Out
+  类型：数据结构指针
+  可空：N
+  意思：输出解析的文件信息
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+BOOL CP2XPProtocol_Parse::P2XPProtocol_Parse_QueryFile(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_PROTOCOL_FILE* pSt_ProtocolFile)
+{
+	P2XPProtocol_IsErrorOccur = FALSE;
+
+	if ((NULL == lpszMsgBuffer) || (NULL == pSt_ProtocolFile))
+	{
+		P2XPProtocol_IsErrorOccur = TRUE;
+		P2XPProtocol_dwErrorCode = ERROR_XENGINE_P2XP_PROTOCOL_PARAMENT;
+		return FALSE;
+	}
+	Json::Value st_JsonRoot;
+	Json::CharReaderBuilder st_JsonBuild;
+	Json::CharReader* pSt_JsonReader(st_JsonBuild.newCharReader());
+
+	JSONCPP_STRING st_JsonError;
+	//解析JSON
+	if (!pSt_JsonReader->parse(lpszMsgBuffer, lpszMsgBuffer + nMsgLen, &st_JsonRoot, &st_JsonError))
+	{
+		P2XPProtocol_IsErrorOccur = TRUE;
+		P2XPProtocol_dwErrorCode = ERROR_XENGINE_P2XP_PROTOCOL_PARSE;
+		return FALSE;
+	}
+	delete pSt_JsonReader;
+	pSt_JsonReader = NULL;
+
+	if (!st_JsonRoot["tszFileName"].isNull())
+	{
+		_tcscpy(pSt_ProtocolFile->tszFileName, st_JsonRoot["tszFileName"].asCString());
+	}
+	if (!st_JsonRoot["tszFilePath"].isNull())
+	{
+		_tcscpy(pSt_ProtocolFile->tszFilePath, st_JsonRoot["tszFilePath"].asCString());
+	}
+	if (!st_JsonRoot["tszFileHash"].isNull())
+	{
+		_tcscpy(pSt_ProtocolFile->tszFileHash, st_JsonRoot["tszFileHash"].asCString());
+	}
+	if (!st_JsonRoot["tszFileTime"].isNull())
+	{
+		_tcscpy(pSt_ProtocolFile->tszFileTime, st_JsonRoot["tszFileTime"].asCString());
+	}
+	if (!st_JsonRoot["tszFileUser"].isNull())
+	{
+		_tcscpy(pSt_ProtocolFile->tszFileUser, st_JsonRoot["tszFileUser"].asCString());
+	}
+	if (!st_JsonRoot["nFileSize"].isNull())
+	{
+		pSt_ProtocolFile->nFileSize = st_JsonRoot["nFileSize"].asInt();
+	}
+	return TRUE;
 }

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/P2XPProtocol_Parse/P2XPProtocol_Parse.h

@@ -21,6 +21,7 @@ class CP2XPProtocol_Parse
     BOOL P2XPProtocol_Parse_List(LPCTSTR lpszMsgBuffer, int nMsgLen, TCHAR* ptszPubAddr, TCHAR* ptszPriAddr);
     BOOL P2XPProtocol_Parse_User(LPCTSTR lpszMsgBuffer, int nMsgLen, TCHAR* ptszUserName);
     BOOL P2XPProtocol_Parse_Connect(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_P2XPIO_PROTOCOL* pSt_IOProtocol);
+    BOOL P2XPProtocol_Parse_QueryFile(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_PROTOCOL_FILE* pSt_ProtocolFile);
 protected:
 private:
 };

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/XEngine_P2XPProtocol.def

@@ -8,6 +8,7 @@ EXPORTS
 	P2XPProtocol_Parse_List
 	P2XPProtocol_Parse_User
 	P2XPProtocol_Parse_Connect
+	P2XPProtocol_Parse_QueryFile
 
 	P2XPProtocol_Packet_Common
 	P2XPProtocol_Packet_Lan

XEngine_Source/XEngine_P2XPComponents/XEngine_P2XPProtocol/pch.cpp

@@ -45,6 +45,10 @@ extern "C" BOOL P2XPProtocol_Parse_Connect(LPCTSTR lpszMsgBuffer, int nMsgLen, X
 {
 	return m_P2XPParse.P2XPProtocol_Parse_Connect(lpszMsgBuffer, nMsgLen, pSt_IOProtocol);
 }
+extern "C" BOOL P2XPProtocol_Parse_QueryFile(LPCTSTR lpszMsgBuffer, int nMsgLen, XENGINE_PROTOCOL_FILE * pSt_ProtocolFile)
+{
+	return m_P2XPParse.P2XPProtocol_Parse_QueryFile(lpszMsgBuffer, nMsgLen, pSt_ProtocolFile);
+}
 /************************************************************************/
 /*                        打包协议导出                                  */
 /************************************************************************/