提交 f7bf036f 编写于 作者: xengine-qyt's avatar xengine-qyt

modify:The http task now distinguishes between post and get

上级 6aebe225
......@@ -10,7 +10,7 @@
// Purpose: HTTP任务处理代码
// History:
*********************************************************************/
XHTHREAD CALLBACK XEngine_HTTPTask_Thread(XPVOID lParam)
XHTHREAD CALLBACK HTTPTask_TastPost_Thread(XPVOID lParam)
{
//任务池是编号1开始的.
int nThreadPos = *(int*)lParam;
......@@ -42,7 +42,7 @@ XHTHREAD CALLBACK XEngine_HTTPTask_Thread(XPVOID lParam)
if (HttpProtocol_Server_GetMemoryEx(xhHTTPPacket, ppSst_ListAddr[i]->tszClientAddr, &ptszMsgBuffer, &nMsgLen, &st_HTTPReqparam))
{
//在另外一个函数里面处理数据
XEngine_HTTPTask_Handle(&st_HTTPReqparam, ppSst_ListAddr[i]->tszClientAddr, ptszMsgBuffer, nMsgLen);
HTTPTask_TastPost_Handle(&st_HTTPReqparam, ppSst_ListAddr[i]->tszClientAddr, ptszMsgBuffer, nMsgLen);
//释放内存
BaseLib_OperatorMemory_FreeCStyle((VOID**)&ptszMsgBuffer);
}
......@@ -52,7 +52,7 @@ XHTHREAD CALLBACK XEngine_HTTPTask_Thread(XPVOID lParam)
}
return 0;
}
XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXSTR lpszClientAddr, LPCXSTR lpszRVBuffer, int nRVLen)
XBOOL HTTPTask_TastPost_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXSTR lpszClientAddr, LPCXSTR lpszRVBuffer, int nRVLen)
{
int nMsgLen = 4096;
LPCXSTR lpszMethodPost = _T("POST");
......@@ -149,7 +149,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_P2PClient(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
HTTPTask_TastPost_P2PClient(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
}
else if (0 == _tcsnicmp(lpszParamZIPCode, tszValue, _tcslen(lpszParamZIPCode)))
{
......@@ -166,7 +166,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_PostCode(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
HTTPTask_TastPost_PostCode(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
}
else if (0 == _tcsnicmp(lpszParamXLog, tszValue, _tcslen(lpszParamXLog)))
{
......@@ -183,7 +183,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_LogInfo(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
HTTPTask_TastPost_LogInfo(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
}
else if (0 == _tcsnicmp(lpszParamQRCode, tszValue, _tcslen(lpszParamQRCode)))
{
......@@ -200,7 +200,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_QRCode(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
HTTPTask_TaskPost_QRCode(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
}
else if (0 == _tcsnicmp(lpszParamSocket, tszValue, _tcslen(lpszParamSocket)))
{
......@@ -217,7 +217,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_SocketTest(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
HTTPTask_TastPost_SocketTest(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
}
else if (0 == _tcsnicmp(lpszParamDTest, tszValue, _tcslen(lpszParamDTest)))
{
......@@ -234,7 +234,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_DTest(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
HTTPTask_TastPost_DTest(lpszClientAddr, lpszRVBuffer, nRVLen, _ttoi(tszValue));
}
else
{
......@@ -249,7 +249,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
if (0 == _tcsnicmp(lpszParamOPtions, tszValue, _tcslen(lpszParamOPtions)))
{
//HTTP能力查询
XEngine_HTTPTask_OPTions(lpszClientAddr);
HTTPTask_TaskGet_OPTions(lpszClientAddr);
}
else if (0 == _tcsnicmp(lpszParamIDCard, tszValue, _tcslen(lpszParamIDCard)))
{
......@@ -266,7 +266,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_IDCard(lpszClientAddr, tszValue);
HTTPTask_TaskGet_IDCard(lpszClientAddr, tszValue);
}
else if (0 == _tcsnicmp(lpszParamBank, tszValue, _tcslen(lpszParamBank)))
{
......@@ -283,7 +283,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("HTTP客户端:%s,发送的URL请求参数不正确:%s"), lpszClientAddr, pSt_HTTPParam->tszHttpUri);
return FALSE;
}
XEngine_HTTPTask_BankInfo(lpszClientAddr, tszValue);
HTTPTask_TaskGet_BankInfo(lpszClientAddr, tszValue);
}
else if (0 == _tcsnicmp(lpszParamLanguage, tszValue, _tcslen(lpszParamLanguage)))
{
......@@ -307,7 +307,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
memset(tszKey, '\0', sizeof(tszKey));
BaseLib_OperatorString_GetKeyValue(pptszList[2], "=", tszKey, tszCvtType);
XEngine_HTTPTask_Language(lpszClientAddr, tszValue, _ttoi(tszCvtType));
HTTPTask_TaskGet_Language(lpszClientAddr, tszValue, _ttoi(tszCvtType));
}
else if (0 == _tcsnicmp(lpszParamTranslation, tszValue, _tcslen(lpszParamTranslation)))
{
......@@ -331,7 +331,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
memset(tszKey, '\0', sizeof(tszKey));
BaseLib_OperatorString_GetKeyValue(pptszList[2], "=", tszKey, tszCvtType);
XEngine_HTTPTask_Translation(lpszClientAddr, tszValue, _ttoi(tszCvtType));
HTTPTask_TaskGet_Translation(lpszClientAddr, tszValue, _ttoi(tszCvtType));
}
else if (0 == _tcsnicmp(lpszParamLocker, tszValue, _tcslen(lpszParamLocker)))
{
......@@ -345,7 +345,7 @@ XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
BaseLib_OperatorString_GetKeyValue(pptszList[1], "=", tszKey, tszLockToken);
BaseLib_OperatorString_GetKeyValue(pptszList[2], "=", tszKey, tszLockType);
XEngine_HTTPTask_Locker(lpszClientAddr, _ttoi64(tszLockToken), (ENUM_XENGINE_APISERVICE_LOCKER_TYPE)_ttoi(tszLockType));
HTTPTask_TaskGet_Locker(lpszClientAddr, _ttoi64(tszLockToken), (ENUM_XENGINE_APISERVICE_LOCKER_TYPE)_ttoi(tszLockType));
}
else
{
......
......@@ -11,6 +11,6 @@
// History:
*********************************************************************/
//任务处理池,用来获取一个完整包
XHTHREAD CALLBACK XEngine_HTTPTask_Thread(XPVOID lParam);
XHTHREAD CALLBACK HTTPTask_TastPost_Thread(XPVOID lParam);
//任务处理相关函数,处理包的内容
XBOOL XEngine_HTTPTask_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXSTR lpszClientAddr, LPCXSTR lpszRVBuffer, int nRVLen);
\ No newline at end of file
XBOOL HTTPTask_TastPost_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXSTR lpszClientAddr, LPCXSTR lpszRVBuffer, int nRVLen);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_BankInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszBankNumber);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_DTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_IDCard(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_Language(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_Locker(LPCXSTR lpszClientAddr,__int64x nToken, ENUM_XENGINE_APISERVICE_LOCKER_TYPE enLockType);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_LogInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_OPTions(LPCXSTR lpszClientAddr);
\ No newline at end of file
#pragma once
void CALLBACK XEngine_HTTPTask_P2PCallback(XENGINE_P2XPPEER_PROTOCOL* pSt_P2PProtocol, XPVOID lParam);
XBOOL XEngine_HTTPTask_P2PClient(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int unOperatorCode);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_PostCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_QRCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#pragma once
void CALLBACK XEngine_HTTPTask_CBSocketTest(XNETHANDLE xhToken, LPCSTR lpszAddr, int nPort, __int64x nNumber, __int64x nFailed, __int64x nSuccess, int nStatus, XPVOID lParam);
XBOOL XEngine_HTTPTask_SocketTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#pragma once
XBOOL XEngine_HTTPTask_Translation(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType);
\ No newline at end of file
......@@ -58,18 +58,20 @@ using namespace std;
#include "XEngine_Network.h"
#include "XEngine_HTTPTask.h"
#include "XEngine_PluginTask.h"
#include "XEngine_HTTPTask/HTTPTask_IDCard.h"
#include "XEngine_HTTPTask/HTTPTask_Bank.h"
#include "XEngine_HTTPTask/HTTPTask_Language.h"
#include "XEngine_HTTPTask/HTTPTask_Translation.h"
#include "XEngine_HTTPTask/HTTPTask_Locker.h"
#include "XEngine_HTTPTask/HTTPTask_OPtions.h"
#include "XEngine_HTTPTask/HTTPTask_P2PClient.h"
#include "XEngine_HTTPTask/HTTPTask_PostCode.h"
#include "XEngine_HTTPTask/HTTPTask_Log.h"
#include "XEngine_HTTPTask/HTTPTask_QRCode.h"
#include "XEngine_HTTPTask/HTTPTask_SocketTest.h"
#include "XEngine_HTTPTask/HTTPTask_DTest.h"
//post
#include "XEngine_TaskPost/TaskPost_DTest.h"
#include "XEngine_TaskPost/TaskPost_Log.h"
#include "XEngine_TaskPost/TaskPost_P2PClient.h"
#include "XEngine_TaskPost/TaskPost_PostCode.h"
#include "XEngine_TaskPost/TaskPost_SocketTest.h"
#include "XEngine_TaskPost/TaskPost_QRCode.h"
//get
#include "XEngine_TaskGet/TaskGet_IDCard.h"
#include "XEngine_TaskGet/TaskGet_Bank.h"
#include "XEngine_TaskGet/TaskGet_Language.h"
#include "XEngine_TaskGet/TaskGet_Translation.h"
#include "XEngine_TaskGet/TaskGet_Locker.h"
#include "XEngine_TaskGet/TaskGet_OPtions.h"
/********************************************************************
// Created: 2022/01/20 14:42:06
// File Name: D:\XEngine_ServiceApp\XEngine_Source\XEngine_ServiceApp\XEngine_HttpApp\XEngine_Hdr.h
......
......@@ -234,7 +234,7 @@ int main(int argc, char** argv)
*pInt_Pos = i;
ppSt_ListHTTPParam[i]->lParam = pInt_Pos;
ppSt_ListHTTPParam[i]->fpCall_ThreadsTask = XEngine_HTTPTask_Thread;
ppSt_ListHTTPParam[i]->fpCall_ThreadsTask = HTTPTask_TastPost_Thread;
}
xhHTTPPool = ManagePool_Thread_NQCreate(&ppSt_ListHTTPParam, st_ServiceConfig.st_XMax.nHTTPThread);
if (NULL == xhHTTPPool)
......@@ -249,7 +249,7 @@ int main(int argc, char** argv)
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_WARN, _T("启动服务中,HTTP消息服务没有被启用"));
}
//初始化P2P
if (!ModuleHelp_P2PClient_Init(st_ServiceConfig.st_XTime.nP2PTimeOut, XEngine_HTTPTask_P2PCallback))
if (!ModuleHelp_P2PClient_Init(st_ServiceConfig.st_XTime.nP2PTimeOut, HTTPTask_TastPost_P2PCallback))
{
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _T("启动服务中,启动P2P客户端管理器失败,错误:%lX"), ModuleHelp_GetLastError());
goto XENGINE_SERVICEAPP_EXIT;
......
......@@ -156,39 +156,39 @@
<ClCompile Include="XEngine_Configure.cpp" />
<ClCompile Include="XEngine_HttpApp.cpp" />
<ClCompile Include="XEngine_HTTPTask.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Bank.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_DTest.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_IDCard.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Language.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Locker.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Log.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_OPtions.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_P2PClient.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_PostCode.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_QRCode.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_SocketTest.cpp" />
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Translation.cpp" />
<ClCompile Include="XEngine_Network.cpp" />
<ClCompile Include="XEngine_PluginTask.cpp" />
<ClCompile Include="XEngine_TaskGet\TaskGet_Bank.cpp" />
<ClCompile Include="XEngine_TaskGet\TaskGet_IDCard.cpp" />
<ClCompile Include="XEngine_TaskGet\TaskGet_Language.cpp" />
<ClCompile Include="XEngine_TaskGet\TaskGet_Locker.cpp" />
<ClCompile Include="XEngine_TaskGet\TaskGet_OPtions.cpp" />
<ClCompile Include="XEngine_TaskGet\TaskGet_Translation.cpp" />
<ClCompile Include="XEngine_TaskPost\TaskPost_DTest.cpp" />
<ClCompile Include="XEngine_TaskPost\TaskPost_Log.cpp" />
<ClCompile Include="XEngine_TaskPost\TaskPost_P2PClient.cpp" />
<ClCompile Include="XEngine_TaskPost\TaskPost_PostCode.cpp" />
<ClCompile Include="XEngine_TaskPost\TaskPost_QRCode.cpp" />
<ClCompile Include="XEngine_TaskPost\TaskPost_SocketTest.cpp" />
</ItemGroup>
<ItemGroup>
<ClInclude Include="XEngine_Configure.h" />
<ClInclude Include="XEngine_Hdr.h" />
<ClInclude Include="XEngine_HTTPTask.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Bank.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_DTest.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_IDCard.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Language.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Locker.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Log.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_OPtions.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_P2PClient.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_PostCode.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_QRCode.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_SocketTest.h" />
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Translation.h" />
<ClInclude Include="XEngine_Network.h" />
<ClInclude Include="XEngine_PluginTask.h" />
<ClInclude Include="XEngine_TaskGet\TaskGet_Bank.h" />
<ClInclude Include="XEngine_TaskGet\TaskGet_IDCard.h" />
<ClInclude Include="XEngine_TaskGet\TaskGet_Language.h" />
<ClInclude Include="XEngine_TaskGet\TaskGet_Locker.h" />
<ClInclude Include="XEngine_TaskGet\TaskGet_OPtions.h" />
<ClInclude Include="XEngine_TaskGet\TaskGet_Translation.h" />
<ClInclude Include="XEngine_TaskPost\TaskPost_DTest.h" />
<ClInclude Include="XEngine_TaskPost\TaskPost_Log.h" />
<ClInclude Include="XEngine_TaskPost\TaskPost_P2PClient.h" />
<ClInclude Include="XEngine_TaskPost\TaskPost_PostCode.h" />
<ClInclude Include="XEngine_TaskPost\TaskPost_QRCode.h" />
<ClInclude Include="XEngine_TaskPost\TaskPost_SocketTest.h" />
</ItemGroup>
<Import Project="$(VCTargetsPath)\Microsoft.Cpp.targets" />
<ImportGroup Label="ExtensionTargets">
......
......@@ -9,16 +9,22 @@
<UniqueIdentifier>{67DA6AB6-F800-4c08-8B7A-83BB121AAD01}</UniqueIdentifier>
<Extensions>rc;ico;cur;bmp;dlg;rc2;rct;bin;rgs;gif;jpg;jpeg;jpe;resx;tiff;tif;png;wav;mfcribbon-ms</Extensions>
</Filter>
<Filter Include="头文件\XEngine_HTTPTask">
<UniqueIdentifier>{9bf2e74a-551b-4d8d-ad34-ccd13e64e985}</UniqueIdentifier>
</Filter>
<Filter Include="源文件">
<UniqueIdentifier>{4FC737F1-C7A5-4376-A066-2A32D752A2FF}</UniqueIdentifier>
<Extensions>cpp;c;cc;cxx;c++;cppm;ixx;def;odl;idl;hpj;bat;asm;asmx</Extensions>
</Filter>
<Filter Include="源文件\XEngine_HTTPTask">
<Filter Include="头文件\XEngine_TaskGet">
<UniqueIdentifier>{9bf2e74a-551b-4d8d-ad34-ccd13e64e985}</UniqueIdentifier>
</Filter>
<Filter Include="源文件\XEngine_TaskGet">
<UniqueIdentifier>{a205153f-6995-49dc-ae5f-cd2bc0d31549}</UniqueIdentifier>
</Filter>
<Filter Include="头文件\XEngine_TaskPost">
<UniqueIdentifier>{3d1f325b-4812-45f1-b04b-0056a7b2ce72}</UniqueIdentifier>
</Filter>
<Filter Include="源文件\XEngine_TaskPost">
<UniqueIdentifier>{a904cf8f-7387-403f-8686-0f5c35c6b72c}</UniqueIdentifier>
</Filter>
</ItemGroup>
<ItemGroup>
<ClCompile Include="XEngine_HttpApp.cpp">
......@@ -33,44 +39,44 @@
<ClCompile Include="XEngine_Network.cpp">
<Filter>源文件</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_IDCard.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_PluginTask.cpp">
<Filter>源文件</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Bank.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskPost\TaskPost_DTest.cpp">
<Filter>源文件\XEngine_TaskPost</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Language.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskPost\TaskPost_Log.cpp">
<Filter>源文件\XEngine_TaskPost</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Translation.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskPost\TaskPost_P2PClient.cpp">
<Filter>源文件\XEngine_TaskPost</Filter>
</ClCompile>
<ClCompile Include="XEngine_PluginTask.cpp">
<Filter>源文件</Filter>
<ClCompile Include="XEngine_TaskPost\TaskPost_PostCode.cpp">
<Filter>源文件\XEngine_TaskPost</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_P2PClient.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskPost\TaskPost_SocketTest.cpp">
<Filter>源文件\XEngine_TaskPost</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_OPtions.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskGet\TaskGet_Bank.cpp">
<Filter>源文件\XEngine_TaskGet</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Locker.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskGet\TaskGet_IDCard.cpp">
<Filter>源文件\XEngine_TaskGet</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_PostCode.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskGet\TaskGet_Language.cpp">
<Filter>源文件\XEngine_TaskGet</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_Log.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskGet\TaskGet_Locker.cpp">
<Filter>源文件\XEngine_TaskGet</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_QRCode.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskGet\TaskGet_OPtions.cpp">
<Filter>源文件\XEngine_TaskGet</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_SocketTest.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskGet\TaskGet_Translation.cpp">
<Filter>源文件\XEngine_TaskGet</Filter>
</ClCompile>
<ClCompile Include="XEngine_HTTPTask\HTTPTask_DTest.cpp">
<Filter>源文件\XEngine_HTTPTask</Filter>
<ClCompile Include="XEngine_TaskPost\TaskPost_QRCode.cpp">
<Filter>源文件\XEngine_TaskPost</Filter>
</ClCompile>
</ItemGroup>
<ItemGroup>
......@@ -86,44 +92,44 @@
<ClInclude Include="XEngine_Network.h">
<Filter>头文件</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_IDCard.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_PluginTask.h">
<Filter>头文件</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Bank.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskPost\TaskPost_DTest.h">
<Filter>头文件\XEngine_TaskPost</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Language.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskPost\TaskPost_Log.h">
<Filter>头文件\XEngine_TaskPost</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Translation.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskPost\TaskPost_P2PClient.h">
<Filter>头文件\XEngine_TaskPost</Filter>
</ClInclude>
<ClInclude Include="XEngine_PluginTask.h">
<Filter>头文件</Filter>
<ClInclude Include="XEngine_TaskPost\TaskPost_PostCode.h">
<Filter>头文件\XEngine_TaskPost</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_P2PClient.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskPost\TaskPost_SocketTest.h">
<Filter>头文件\XEngine_TaskPost</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_OPtions.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskGet\TaskGet_Bank.h">
<Filter>头文件\XEngine_TaskGet</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Locker.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskGet\TaskGet_IDCard.h">
<Filter>头文件\XEngine_TaskGet</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_PostCode.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskGet\TaskGet_Language.h">
<Filter>头文件\XEngine_TaskGet</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_Log.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskGet\TaskGet_Locker.h">
<Filter>头文件\XEngine_TaskGet</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_QRCode.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskGet\TaskGet_OPtions.h">
<Filter>头文件\XEngine_TaskGet</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_SocketTest.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskGet\TaskGet_Translation.h">
<Filter>头文件\XEngine_TaskGet</Filter>
</ClInclude>
<ClInclude Include="XEngine_HTTPTask\HTTPTask_DTest.h">
<Filter>头文件\XEngine_HTTPTask</Filter>
<ClInclude Include="XEngine_TaskPost\TaskPost_QRCode.h">
<Filter>头文件\XEngine_TaskPost</Filter>
</ClInclude>
</ItemGroup>
</Project>
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_BankInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszBankNumber)
XBOOL HTTPTask_TaskGet_BankInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszBankNumber)
{
int nMsgLen = 4096;
int nPktLen = 4096;
......
#pragma once
XBOOL HTTPTask_TaskGet_BankInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszBankNumber);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_IDCard(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer)
XBOOL HTTPTask_TaskGet_IDCard(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer)
{
int nMsgLen = 4096;
int nPktLen = 4096;
......
#pragma once
XBOOL HTTPTask_TaskGet_IDCard(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_Language(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType)
XBOOL HTTPTask_TaskGet_Language(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType)
{
int nMsgLen = 4096;
int nPktLen = 4096;
......
#pragma once
XBOOL HTTPTask_TaskGet_Language(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_Locker(LPCXSTR lpszClientAddr, __int64x xhToken, ENUM_XENGINE_APISERVICE_LOCKER_TYPE enLockType)
XBOOL HTTPTask_TaskGet_Locker(LPCXSTR lpszClientAddr, __int64x xhToken, ENUM_XENGINE_APISERVICE_LOCKER_TYPE enLockType)
{
int nSDLen = 4096;
int nRVLen = 4096;
......
#pragma once
XBOOL HTTPTask_TaskGet_Locker(LPCXSTR lpszClientAddr,__int64x nToken, ENUM_XENGINE_APISERVICE_LOCKER_TYPE enLockType);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_OPTions(LPCXSTR lpszClientAddr)
XBOOL HTTPTask_TaskGet_OPTions(LPCXSTR lpszClientAddr)
{
int nMsgLen = 4096;
int nPktLen = 4096;
......
#pragma once
XBOOL HTTPTask_TaskGet_OPTions(LPCXSTR lpszClientAddr);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_Translation(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType)
XBOOL HTTPTask_TaskGet_Translation(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType)
{
int nMsgLen = 4096;
int nPktLen = 4096;
......
#pragma once
XBOOL HTTPTask_TaskGet_Translation(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nConvertType);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_DTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
XBOOL HTTPTask_TastPost_DTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
{
int nSDLen = 0;
XCHAR tszSDBuffer[4096];
......
#pragma once
XBOOL HTTPTask_TastPost_DTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_LogInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
XBOOL HTTPTask_TastPost_LogInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
{
int nSDLen = 0;
int nRVLen = 0;
......
#pragma once
XBOOL HTTPTask_TastPost_LogInfo(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#include "../XEngine_Hdr.h"
void CALLBACK XEngine_HTTPTask_P2PCallback(XENGINE_P2XPPEER_PROTOCOL* pSt_P2PProtocol, XPVOID lParam)
void CALLBACK HTTPTask_TastPost_P2PCallback(XENGINE_P2XPPEER_PROTOCOL* pSt_P2PProtocol, XPVOID lParam)
{
XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_WARN, _T("HTTP客户端:公网:%s,私网:%s,连接:%s P2P离开"), pSt_P2PProtocol->tszPublicAddr, pSt_P2PProtocol->tszPrivateAddr, pSt_P2PProtocol->tszConnectAddr);
}
XBOOL XEngine_HTTPTask_P2PClient(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int unOperatorCode)
XBOOL HTTPTask_TastPost_P2PClient(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int unOperatorCode)
{
int nSDLen = 4096;
int nRVLen = 4096;
......
#pragma once
void CALLBACK HTTPTask_TastPost_P2PCallback(XENGINE_P2XPPEER_PROTOCOL* pSt_P2PProtocol, XPVOID lParam);
XBOOL HTTPTask_TastPost_P2PClient(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int unOperatorCode);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_PostCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
XBOOL HTTPTask_TastPost_PostCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
{
int nSDLen = 4096;
int nRVLen = 4096;
......
#pragma once
XBOOL HTTPTask_TastPost_PostCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#include "../XEngine_Hdr.h"
XBOOL XEngine_HTTPTask_QRCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
XBOOL HTTPTask_TaskPost_QRCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
{
int nSDLen = 0;
int nRVLen = 0;
......
#pragma once
XBOOL HTTPTask_TaskPost_QRCode(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
#include "../XEngine_Hdr.h"
void CALLBACK XEngine_HTTPTask_CBSocketTest(XNETHANDLE xhToken, LPCSTR lpszAddr, int nPort, __int64x nNumber, __int64x nFailed, __int64x nSuccess, int nStatus, XPVOID lParam)
void CALLBACK HTTPTask_TastPost_CBSocketTest(XNETHANDLE xhToken, LPCSTR lpszAddr, int nPort, __int64x nNumber, __int64x nFailed, __int64x nSuccess, int nStatus, XPVOID lParam)
{
XENGINE_SOCKETTEST* pSt_SocketTest = (XENGINE_SOCKETTEST*)lParam;
int nMsgLen = 0;
......@@ -47,7 +47,7 @@ void CALLBACK XEngine_HTTPTask_CBSocketTest(XNETHANDLE xhToken, LPCSTR lpszAddr,
}
}
}
XBOOL XEngine_HTTPTask_SocketTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
XBOOL HTTPTask_TastPost_SocketTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType)
{
int nSDLen = 0;
int nRVLen = 0;
......@@ -70,12 +70,12 @@ XBOOL XEngine_HTTPTask_SocketTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer,
{
if (pSt_SocketTest->bConn)
{
ModuleHelp_SocketTest_StartConnect(&pSt_SocketTest->xhToken, &pSt_SocketTest->st_SocketConn, XEngine_HTTPTask_CBSocketTest, pSt_SocketTest);
ModuleHelp_SocketTest_StartConnect(&pSt_SocketTest->xhToken, &pSt_SocketTest->st_SocketConn, HTTPTask_TastPost_CBSocketTest, pSt_SocketTest);
}
else
{
memcpy(&pSt_SocketTest->st_SocketData.st_REConnect, &pSt_SocketTest->st_SocketConn, sizeof(MODULEHELP_SOCKETTEST_RECONNECT));
ModuleHelp_SocketTest_StartDatas(&pSt_SocketTest->xhToken, &pSt_SocketTest->st_SocketData, XEngine_HTTPTask_CBSocketTest, pSt_SocketTest->bTCP, pSt_SocketTest);
ModuleHelp_SocketTest_StartDatas(&pSt_SocketTest->xhToken, &pSt_SocketTest->st_SocketData, HTTPTask_TastPost_CBSocketTest, pSt_SocketTest->bTCP, pSt_SocketTest);
}
ModuleProtocol_Packet_TestReply(tszRVBuffer, &nRVLen, pSt_SocketTest->xhToken);
HttpProtocol_Server_SendMsgEx(xhHTTPPacket, tszSDBuffer, &nSDLen, &st_HDRParam, tszRVBuffer, nRVLen);
......
#pragma once
void CALLBACK HTTPTask_TastPost_CBSocketTest(XNETHANDLE xhToken, LPCSTR lpszAddr, int nPort, __int64x nNumber, __int64x nFailed, __int64x nSuccess, int nStatus, XPVOID lParam);
XBOOL HTTPTask_TastPost_SocketTest(LPCXSTR lpszClientAddr, LPCXSTR lpszMsgBuffer, int nMsgLen, int nType);
\ No newline at end of file
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册