added:center protocol and add file with manage interface

xengine-qyt · xengine-qyt · commit 6af41f7e7e3a · 2021-07-30T10:00:03.000+08:00
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_Center.cpp b/XEngine_Source/XEngine_StorageApp/StorageApp_Center.cpp
@@ -111,6 +111,10 @@ BOOL XEngine_Task_HttpCenter(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int
 		{
 			XEngine_Task_Event(tszAPIName, lpszClientAddr, lpszMsgBuffer, nMsgLen, pSt_HTTPParam, pptszListHdr, nHdrCount);
 		}
+		else if (0 == _tcsnicmp(XENGINE_STORAGE_APP_TASK_MANAGE, tszAPIMethod, _tcslen(XENGINE_STORAGE_APP_TASK_MANAGE)))
+		{
+			XEngine_Task_Manage(tszAPIName, lpszClientAddr, lpszMsgBuffer, nMsgLen, pSt_HTTPParam, pptszListHdr, nHdrCount);
+		}
 	}
 	else if (0 == _tcsnicmp(lpszMethodGet, pSt_HTTPParam->tszHttpMethod, _tcslen(lpszMethodGet)))
 	{
@@ -122,7 +126,7 @@ BOOL XEngine_Task_HttpCenter(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int
 		{
 			st_HDRParam.bAuth = TRUE;
 		}
-		XEngine_Task_P2p(pSt_HTTPParam->tszHttpUri + 1, lpszClientAddr, pSt_HTTPParam);
+		XEngine_Task_P2PGet(pSt_HTTPParam->tszHttpUri + 1, lpszClientAddr, pSt_HTTPParam);
 	}
 	else
 	{
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_Center.h b/XEngine_Source/XEngine_StorageApp/StorageApp_Center.h
@@ -3,11 +3,14 @@
 #define XENGINE_STORAGE_APP_TASK_EVENT  _T("Event")
 #define XENGINE_STORAGE_APP_TASK_QUERY  _T("Query")
 #define XENGINE_STORAGE_APP_TASK_PASS  _T("Pass")
+#define XENGINE_STORAGE_APP_TASK_MANAGE  _T("Manage")
 
 #define XENGINE_STORAGE_APP_METHOD_CONFIG  _T("Config")
 #define XENGINE_STORAGE_APP_METHOD_UPFILE  _T("UPFile")
 #define XENGINE_STORAGE_APP_METHOD_DLFILE  _T("DLFile")
 #define XENGINE_STORAGE_APP_METHOD_FILE  _T("File")
+#define XENGINE_STORAGE_APP_METHOD_ADD  _T("Add")
+#define XENGINE_STORAGE_APP_METHOD_DEL  _T("Del")
 
 XHTHREAD CALLBACK XEngine_Center_HTTPThread(LPVOID lParam);
 BOOL XEngine_Task_HttpCenter_APIList(LPCTSTR lpszUrlName, TCHAR* ptszAPIVersion, TCHAR* ptszAPIMethod, TCHAR* ptszAPIName);
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_Download.cpp b/XEngine_Source/XEngine_StorageApp/StorageApp_Download.cpp
@@ -86,32 +86,6 @@ XHTHREAD CALLBACK XEngine_Download_SendThread(LPVOID lParam)
 					APIHelp_HttpRequest_Post(st_ServiceCfg.st_XProxy.st_XProxyPass.tszDLPass, tszProxyStr, &nHttpCode);
 					XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_NOTICE, _T("下载客户端:%s,请求完成通知返回值:%d,文件:%s,地址:%s"), tszClientAddr, nHttpCode, st_StorageInfo.tszFileDir, st_ServiceCfg.st_XProxy.st_XProxyPass.tszDLPass);
 				}
-				//如果启用了数据库并且启用了P2P存储网络
-				if ((0 != st_ServiceCfg.st_XSql.nSQLType) && (st_ServiceCfg.st_P2xp.nMode > 0))
-				{
-					UCHAR tszHashKey[MAX_PATH];
-					XSTORAGECORE_DBFILE st_DBFile;
-					SESSION_STORAGEINFO st_StorageInfo;
-
-					memset(tszHashKey, '\0', MAX_PATH);
-					memset(&st_DBFile, '\0', sizeof(XSTORAGECORE_DBFILE));
-					memset(&st_StorageInfo, '\0', sizeof(SESSION_STORAGEINFO));
-
-					Session_DLStroage_GetInfo(nThreadPos, i, &st_StorageInfo);
-
-					st_DBFile.st_ProtocolFile.nFileSize = st_StorageInfo.ullCount;
-					OPenSsl_Api_Digest(st_StorageInfo.tszFileDir, tszHashKey, NULL, TRUE, st_ServiceCfg.st_XStorage.nHashMode);
-					BaseLib_OperatorString_StrToHex((char*)tszHashKey, 20, st_DBFile.st_ProtocolFile.tszFileHash);
-					BaseLib_OperatorString_GetFileAndPath(st_StorageInfo.tszFileDir, st_DBFile.st_ProtocolFile.tszFilePath, st_DBFile.st_ProtocolFile.tszFileName);
-					if (1 == st_ServiceCfg.st_XSql.nSQLType)
-					{
-						XStorageSQL_File_FileInsert(&st_DBFile);
-					}
-					else
-					{
-						XStorage_SQLite_FileInsert(&st_DBFile);
-					}
-				}
 				Session_DLStroage_Delete(tszClientAddr);
 				XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_NOTICE, _T("下载客户端:%s,文件已经发送完毕,用户已经被移除发送列表"), tszClientAddr);
 				continue;
diff --git a/XEngine_Source/XEngine_StorageApp/StorageApp_Hdr.h b/XEngine_Source/XEngine_StorageApp/StorageApp_Hdr.h
@@ -105,6 +105,7 @@ extern XENGINE_LBCONFIG st_LoadbalanceCfg;
 #include "Storage_APPTask/Storage_TaskPass.h"
 #include "Storage_APPTask/Storage_TaskQuery.h"
 #include "Storage_APPTask/Storage_TaskP2p.h"
+#include "Storage_APPTask/Storage_TaskManage.h"
 #include "Storage_APPHelp/Storage_APPHelp.h"
 
 #ifdef _WINDOWS
diff --git a/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskManage.cpp b/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskManage.cpp
@@ -0,0 +1,35 @@
+﻿#include "../StorageApp_Hdr.h"
+
+
+BOOL XEngine_Task_Manage(LPCTSTR lpszAPIName, LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, TCHAR** pptszListHdr, int nHdrCount)
+{
+	int nSDLen = 2048;
+	TCHAR tszSDBuffer[2048];
+	RFCCOMPONENTS_HTTP_HDRPARAM st_HDRParam;
+
+	memset(tszSDBuffer, '\0', sizeof(tszSDBuffer));
+	memset(&st_HDRParam, '\0', sizeof(RFCCOMPONENTS_HTTP_HDRPARAM));
+
+	//文件存储成功的事件上传
+	if (0 == _tcsnicmp(XENGINE_STORAGE_APP_METHOD_ADD, lpszAPIName, _tcslen(XENGINE_STORAGE_APP_METHOD_ADD)))
+	{
+		int nListCount = 0;
+		XSTORAGECORE_DBFILE** ppSt_DBFile;
+
+		XStorageProtocol_Core_ReportFileParse(lpszMsgBuffer, nMsgLen, &ppSt_DBFile, &nListCount);
+		for (int i = 0; i < nListCount; i++)
+		{
+			if (0 == ppSt_DBFile[i]->st_ProtocolFile.nFileSize)
+			{
+				TCHAR tszFileDir[MAX_PATH];
+				_stprintf(tszFileDir, _T("%s %s"), ppSt_DBFile[i]->st_ProtocolFile.tszFilePath, ppSt_DBFile[i]->st_ProtocolFile.tszFileName);
+				XStorageSQL_File_FileInsert(ppSt_DBFile[i]);
+			}
+		}
+		st_HDRParam.nHttpCode = 200;
+		RfcComponents_HttpServer_SendMsgEx(xhUPHttp, tszSDBuffer, &nSDLen, &st_HDRParam);
+		XEngine_Net_SendMsg(lpszClientAddr, tszSDBuffer, nSDLen, STORAGE_NETTYPE_HTTPCENTER);
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("业务客户端:%s"), lpszClientAddr);
+	}
+	return TRUE;
+}
diff --git a/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskManage.h b/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskManage.h
@@ -0,0 +1,3 @@
+﻿#pragma once
+
+BOOL XEngine_Task_Manage(LPCTSTR lpszAPIName, LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, TCHAR** pptszListHdr, int nHdrCount);
diff --git a/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskP2p.cpp b/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskP2p.cpp
@@ -55,7 +55,7 @@ XHTHREAD XEngine_Task_P2PThread()
 	}
 	return 0;
 }
-BOOL XEngine_Task_P2p(LPCTSTR lpszFileHash, LPCTSTR lpszClientAddr, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam)
+BOOL XEngine_Task_P2PGet(LPCTSTR lpszFileHash, LPCTSTR lpszClientAddr, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam)
 {
 	int nSDLen = 2048;
 	int nRVLen = 2048;
diff --git a/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskP2p.h b/XEngine_Source/XEngine_StorageApp/Storage_APPTask/Storage_TaskP2p.h
@@ -1,4 +1,4 @@
 ﻿#pragma once
 
 XHTHREAD XEngine_Task_P2PThread();
-BOOL XEngine_Task_P2p(LPCTSTR lpszFileHash, LPCTSTR lpszClientAddr, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam);
+BOOL XEngine_Task_P2PGet(LPCTSTR lpszFileHash, LPCTSTR lpszClientAddr, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam);
diff --git a/XEngine_Source/XEngine_StorageApp/XEngine_StorageApp.vcxproj b/XEngine_Source/XEngine_StorageApp/XEngine_StorageApp.vcxproj
@@ -157,6 +157,7 @@
     <ClCompile Include="StorageApp_UPLoader.cpp" />
     <ClCompile Include="Storage_APPHelp\Storage_APPHelp.cpp" />
     <ClCompile Include="Storage_APPTask\Storage_TaskEvent.cpp" />
+    <ClCompile Include="Storage_APPTask\Storage_TaskManage.cpp" />
     <ClCompile Include="Storage_APPTask\Storage_TaskP2p.cpp" />
     <ClCompile Include="Storage_APPTask\Storage_TaskPass.cpp" />
     <ClCompile Include="Storage_APPTask\Storage_TaskQuery.cpp" />
@@ -173,6 +174,7 @@
     <ClInclude Include="StorageApp_UPLoader.h" />
     <ClInclude Include="Storage_APPHelp\Storage_APPHelp.h" />
     <ClInclude Include="Storage_APPTask\Storage_TaskEvent.h" />
+    <ClInclude Include="Storage_APPTask\Storage_TaskManage.h" />
     <ClInclude Include="Storage_APPTask\Storage_TaskP2p.h" />
     <ClInclude Include="Storage_APPTask\Storage_TaskPass.h" />
     <ClInclude Include="Storage_APPTask\Storage_TaskQuery.h" />
diff --git a/XEngine_Source/XEngine_StorageApp/XEngine_StorageApp.vcxproj.filters b/XEngine_Source/XEngine_StorageApp/XEngine_StorageApp.vcxproj.filters
@@ -63,6 +63,9 @@
     <ClCompile Include="Storage_APPTask\Storage_TaskP2p.cpp">
       <Filter>源文件\Storage_APPTask</Filter>
     </ClCompile>
+    <ClCompile Include="Storage_APPTask\Storage_TaskManage.cpp">
+      <Filter>源文件\Storage_APPTask</Filter>
+    </ClCompile>
   </ItemGroup>
   <ItemGroup>
     <ClInclude Include="StorageApp_Config.h">
@@ -101,5 +104,8 @@
     <ClInclude Include="Storage_APPTask\Storage_TaskP2p.h">
       <Filter>头文件\Storage_APPTask</Filter>
     </ClInclude>
+    <ClInclude Include="Storage_APPTask\Storage_TaskManage.h">
+      <Filter>头文件\Storage_APPTask</Filter>
+    </ClInclude>
   </ItemGroup>
 </Project>
diff --git a/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorageProtocol_Core/XStorageProtocol_Core.cpp b/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorageProtocol_Core/XStorageProtocol_Core.cpp
@@ -195,6 +195,92 @@ BOOL CXStorageProtocol_Core::XStorageProtocol_Core_REPQueryFile(TCHAR* ptszMsgBu
     return TRUE;
 }
 /********************************************************************
+函数名称：XStorageProtocol_Core_ReportFileParse
+函数功能：解析文件报告协议
+ 参数.一：lpszMsgBuffer
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要解析的内容
+ 参数.二：nMsgLen
+  In/Out：In
+  类型：整数型
+  可空：N
+  意思：输入要解析的内容大小
+ 参数.三：pppSt_DBFile
+  In/Out：Out
+  类型：三级指针
+  可空：N
+  意思：输出解析到的文件列表
+ 参数.四：pInt_ListCount
+  In/Out：In
+  类型：整数型指针
+  可空：N
+  意思：输出列表个数
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+BOOL CXStorageProtocol_Core::XStorageProtocol_Core_ReportFileParse(LPCTSTR lpszMsgBuffer, int nMsgLen, XSTORAGECORE_DBFILE*** pppSt_DBFile, int *pInt_ListCount)
+{
+    XStorage_IsErrorOccur = 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))
+	{
+		XStorage_IsErrorOccur = TRUE;
+		XStorage_dwErrorCode = ERROR_XENGINE_XSTROGE_PROTOCOL_PARSE;
+		return FALSE;
+	}
+	delete pSt_JsonReader;
+	pSt_JsonReader = NULL;
+
+    int nCount = st_JsonRoot["Count"].asInt();
+    Json::Value st_JsonArray = st_JsonRoot["List"];
+
+    BaseLib_OperatorMemory_Malloc((XPPPMEM)pppSt_DBFile, nCount, sizeof(XSTORAGECORE_DBFILE));
+    for (int i = 0; i < nCount; i++)
+    {
+        if (st_JsonArray[i]["nFileSize"].isNull())
+        {
+            (*pppSt_DBFile)[i]->st_ProtocolFile.nFileSize = 0;
+        }
+        else
+        {
+            (*pppSt_DBFile)[i]->st_ProtocolFile.nFileSize = st_JsonArray[i]["nFileSize"].asInt64();
+        }
+
+        if (!st_JsonArray[i]["tszFileName"].isNull())
+        {
+            _tcscpy((*pppSt_DBFile)[i]->st_ProtocolFile.tszFileName, st_JsonArray[i]["tszFileName"].asCString());
+        }
+        if (!st_JsonArray[i]["tszFilePath"].isNull())
+        {
+            _tcscpy((*pppSt_DBFile)[i]->st_ProtocolFile.tszFilePath, st_JsonArray[i]["tszFilePath"].asCString());
+        }
+        if (!st_JsonArray[i]["tszFileHash"].isNull())
+        {
+            _tcscpy((*pppSt_DBFile)[i]->st_ProtocolFile.tszFileHash, st_JsonArray[i]["tszFileHash"].asCString());
+        }
+        if (!st_JsonArray[i]["tszFileTime"].isNull())
+        {
+            _tcscpy((*pppSt_DBFile)[i]->st_ProtocolFile.tszFileTime, st_JsonArray[i]["tszFileTime"].asCString());
+        }
+        if (!st_JsonArray[i]["tszFileUser"].isNull())
+        {
+            _tcscpy((*pppSt_DBFile)[i]->st_ProtocolFile.tszFileUser, st_JsonArray[i]["tszFileUser"].asCString());
+        }
+    }
+    *pInt_ListCount = nCount;
+    return TRUE;
+}
+/********************************************************************
 函数名称：XStorageProtocol_Core_REQDirOperator
 函数功能：文件夹操作协议
  参数.一：lpszMsgBuffer
diff --git a/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorageProtocol_Core/XStorageProtocol_Core.h b/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorageProtocol_Core/XStorageProtocol_Core.h
@@ -19,6 +19,7 @@ class CXStorageProtocol_Core
 public:
     BOOL XStorageProtocol_Core_REQQueryFile(LPCTSTR lpszMsgBuffer, TCHAR *ptszTimeStart, TCHAR *ptszTimeEnd, TCHAR *ptszFileName = NULL, TCHAR * ptszFileHash = NULL);
     BOOL XStorageProtocol_Core_REPQueryFile(TCHAR *ptszMsgBuffer, int *pInt_MsgLen, XSTORAGECORE_DBFILE*** pppSt_DBFile, int nListCount, LPCTSTR lpszTimeStart = NULL, LPCTSTR lpszTimeEnd = NULL);
+    BOOL XStorageProtocol_Core_ReportFileParse(LPCTSTR lpszMsgBuffer, int nMsgLen, XSTORAGECORE_DBFILE*** pppSt_DBFile, int* pInt_ListCount);
 public:
 	BOOL XStorageProtocol_Core_REQDirOperator(LPCTSTR lpszMsgBuffer, TCHAR* ptszUserDir, int* pInt_Operator);
 	BOOL XStorageProtocol_Core_REPDirOperator(TCHAR* ptszMsgBuffer, int* pInt_MsgLen, TCHAR*** pppszListEnum, int nListCount);
diff --git a/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorageProtocol_Define.h b/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorageProtocol_Define.h
@@ -306,6 +306,35 @@ extern "C" BOOL XStorageProtocol_Core_REQQueryFile(LPCSTR lpszMsgBuffer, CHAR *p
 *********************************************************************/
 extern "C" BOOL XStorageProtocol_Core_REPQueryFile(CHAR *ptszMsgBuffer, int *pInt_MsgLen, XSTORAGECORE_DBFILE * **pppSt_DBFile, int nListCount, LPCSTR lpszTimeStart = NULL, LPCSTR lpszTimeEnd = NULL);
 /********************************************************************
+函数名称：XStorageProtocol_Core_ReportFileParse
+函数功能：解析文件报告协议
+ 参数.一：lpszMsgBuffer
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要解析的内容
+ 参数.二：nMsgLen
+  In/Out：In
+  类型：整数型
+  可空：N
+  意思：输入要解析的内容大小
+ 参数.三：pppSt_DBFile
+  In/Out：Out
+  类型：三级指针
+  可空：N
+  意思：输出解析到的文件列表
+ 参数.四：pInt_ListCount
+  In/Out：In
+  类型：整数型指针
+  可空：N
+  意思：输出列表个数
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+extern "C" BOOL XStorageProtocol_Core_ReportFileParse(LPCTSTR lpszMsgBuffer, int nMsgLen, XSTORAGECORE_DBFILE*** pppSt_DBFile, int* pInt_ListCount);
+/********************************************************************
 函数名称：XStorageProtocol_Core_REQDirOperator
 函数功能：文件夹操作协议
  参数.一：lpszMsgBuffer
diff --git a/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorage_Protocol.def b/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/XStorage_Protocol.def
@@ -13,6 +13,7 @@ EXPORTS
 
 	XStorageProtocol_Core_REQQueryFile
 	XStorageProtocol_Core_REPQueryFile
+	XStorageProtocol_Core_ReportFileParse
 	XStorageProtocol_Core_REQDirOperator
 	XStorageProtocol_Core_REPDirOperator
 	XStorageProtocol_Core_REQUPEvent
diff --git a/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/pch.cpp b/XEngine_Source/XEngine_StorageComponents/XStorage_Protocol/pch.cpp
@@ -71,6 +71,10 @@ extern "C" BOOL XStorageProtocol_Core_REPQueryFile(TCHAR * ptszMsgBuffer, int* p
 {
 	return m_ProtocolCore.XStorageProtocol_Core_REPQueryFile(ptszMsgBuffer, pInt_MsgLen, pppSt_DBFile, nListCount, lpszTimeStart, lpszTimeEnd);
 }
+extern "C" BOOL XStorageProtocol_Core_ReportFileParse(LPCTSTR lpszMsgBuffer, int nMsgLen, XSTORAGECORE_DBFILE * **pppSt_DBFile, int* pInt_ListCount)
+{
+	return m_ProtocolCore.XStorageProtocol_Core_ReportFileParse(lpszMsgBuffer, nMsgLen, pppSt_DBFile, pInt_ListCount);
+}
 extern "C" BOOL XStorageProtocol_Core_REQDirOperator(LPCTSTR lpszMsgBuffer, TCHAR * ptszUserDir, int* pInt_Operator)
 {
 	return m_ProtocolCore.XStorageProtocol_Core_REQDirOperator(lpszMsgBuffer, ptszUserDir, pInt_Operator);

Original file line number	Diff line number	Diff line change
`@@ -111,6 +111,10 @@ BOOL XEngine_Task_HttpCenter(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int`
`111`	`111`	`{`
`112`	`112`	`XEngine_Task_Event(tszAPIName, lpszClientAddr, lpszMsgBuffer, nMsgLen, pSt_HTTPParam, pptszListHdr, nHdrCount);`
`113`	`113`	`}`
	`114`	`+ else if (0 == _tcsnicmp(XENGINE_STORAGE_APP_TASK_MANAGE, tszAPIMethod, _tcslen(XENGINE_STORAGE_APP_TASK_MANAGE)))`
	`115`	`+ {`
	`116`	`+ XEngine_Task_Manage(tszAPIName, lpszClientAddr, lpszMsgBuffer, nMsgLen, pSt_HTTPParam, pptszListHdr, nHdrCount);`
	`117`	`+ }`
`114`	`118`	`}`
`115`	`119`	`else if (0 == _tcsnicmp(lpszMethodGet, pSt_HTTPParam->tszHttpMethod, _tcslen(lpszMethodGet)))`
`116`	`120`	`{`
`@@ -122,7 +126,7 @@ BOOL XEngine_Task_HttpCenter(LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int`
`122`	`126`	`{`
`123`	`127`	`st_HDRParam.bAuth = TRUE;`
`124`	`128`	`}`
`125`		`- XEngine_Task_P2p(pSt_HTTPParam->tszHttpUri + 1, lpszClientAddr, pSt_HTTPParam);`
	`129`	`+ XEngine_Task_P2PGet(pSt_HTTPParam->tszHttpUri + 1, lpszClientAddr, pSt_HTTPParam);`
`126`	`130`	`}`
`127`	`131`	`else`
`128`	`132`	`{`
Original file line number	Diff line number	Diff line change
`@@ -0,0 +1,3 @@`
	`1`	`+#pragma once`
	`2`	`+`
	`3`	`+BOOL XEngine_Task_Manage(LPCTSTR lpszAPIName, LPCTSTR lpszClientAddr, LPCTSTR lpszMsgBuffer, int nMsgLen, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, TCHAR** pptszListHdr, int nHdrCount);`
Original file line number	Diff line number	Diff line change
`@@ -55,7 +55,7 @@ XHTHREAD XEngine_Task_P2PThread()`
`55`	`55`	`}`
`56`	`56`	`return 0;`
`57`	`57`	`}`
`58`		`-BOOL XEngine_Task_P2p(LPCTSTR lpszFileHash, LPCTSTR lpszClientAddr, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam)`
	`58`	`+BOOL XEngine_Task_P2PGet(LPCTSTR lpszFileHash, LPCTSTR lpszClientAddr, RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam)`
`59`	`59`	`{`
`60`	`60`	`int nSDLen = 2048;`
`61`	`61`	`int nRVLen = 2048;`