modify:http error code use protocol common hdr file

xengine-qyt · xengine-qyt · commit b1914adaff5c · 2025-03-11T14:03:40.000+08:00
diff --git a/XEngine_Source/XEngine_MQServiceApp/MQService_HttpTask.cpp b/XEngine_Source/XEngine_MQServiceApp/MQService_HttpTask.cpp
@@ -66,7 +66,7 @@ bool MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
 		HttpProtocol_ServerHelp_GetParament(pSt_HTTPParam->tszHttpUri, &ppSt_ListUrl, &nUrlCount);
 		if (nUrlCount < 1)
 		{
-			ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, 400, "url parament is incorrent");
+			ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, ERROR_XENGINE_MESSAGE_HTTP_PARAMENT, "url parament is incorrent");
 			XEngine_MQXService_Send(lpszClientAddr, tszPKTBuffer, nPKTLen, XENGINE_MQAPP_NETTYPE_HTTP);
 			return false;
 		}
@@ -93,7 +93,7 @@ bool MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST
 				//获取在线用户 http://127.0.0.1:5202/api?function=get&method=online&type=0
 				if (3 != nUrlCount)
 				{
-					ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, 400, "url parament is incorrent");
+					ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, ERROR_XENGINE_MESSAGE_HTTP_PARAMENT, "url parament is incorrent");
 					XEngine_MQXService_Send(lpszClientAddr, tszPKTBuffer, nPKTLen, XENGINE_MQAPP_NETTYPE_HTTP);
 					return false;
 				}
diff --git a/XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp b/XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp
@@ -692,7 +692,7 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
 				{
 					if (pSt_ProtocolHdr->byIsReply)
 					{
-						pSt_ProtocolHdr->wReserve = ERROR_XENGINE_MESSAGE_XMQ_CREATEKEY;
+						pSt_ProtocolHdr->wReserve = ERROR_XENGINE_MESSAGE_XMQ_EXISTED;
 						ProtocolModule_Packet_Common(nNetType, pSt_ProtocolHdr, &st_MQProtocol, tszSDBuffer, &nSDLen);
 						XEngine_MQXService_Send(lpszClientAddr, tszSDBuffer, nSDLen, nNetType);
 					}
diff --git a/XEngine_Source/XQueue_ProtocolHdr.h b/XEngine_Source/XQueue_ProtocolHdr.h
@@ -81,6 +81,8 @@
 #define ERROR_XENGINE_MESSAGE_XMQ_QUERYOWNER 0x2015                        //查询所有者失败
 #define ERROR_XENGINE_MESSAGE_XMQ_MODIFYTOPIC 0x2016                       //修改主题失败
 #define ERROR_XENGINE_MESSAGE_XMQ_MODIFYMSG 0x2017                         //修改消息失败
+
+#define ERROR_XENGINE_MESSAGE_HTTP_PARAMENT 0x3001                         //HTTP请求参数错误
 ///////////////////////////////////////////////////////////////////////////
 //                          导出的数据结构
 ///////////////////////////////////////////////////////////////////////////

Original file line number	Diff line number	Diff line change
`@@ -66,7 +66,7 @@ bool MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST`
`66`	`66`	`HttpProtocol_ServerHelp_GetParament(pSt_HTTPParam->tszHttpUri, &ppSt_ListUrl, &nUrlCount);`
`67`	`67`	`if (nUrlCount < 1)`
`68`	`68`	`{`
`69`		`- ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, 400, "url parament is incorrent");`
	`69`	`+ ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, ERROR_XENGINE_MESSAGE_HTTP_PARAMENT, "url parament is incorrent");`
`70`	`70`	`XEngine_MQXService_Send(lpszClientAddr, tszPKTBuffer, nPKTLen, XENGINE_MQAPP_NETTYPE_HTTP);`
`71`	`71`	`return false;`
`72`	`72`	`}`
`@@ -93,7 +93,7 @@ bool MessageQueue_Http_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam, LPCXST`
`93`	`93`	`//获取在线用户 http://127.0.0.1:5202/api?function=get&method=online&type=0`
`94`	`94`	`if (3 != nUrlCount)`
`95`	`95`	`{`
`96`		`- ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, 400, "url parament is incorrent");`
	`96`	`+ ProtocolModule_Packet_Http(tszPKTBuffer, &nPKTLen, ERROR_XENGINE_MESSAGE_HTTP_PARAMENT, "url parament is incorrent");`
`97`	`97`	`XEngine_MQXService_Send(lpszClientAddr, tszPKTBuffer, nPKTLen, XENGINE_MQAPP_NETTYPE_HTTP);`
`98`	`98`	`return false;`
`99`	`99`	`}`
Original file line number	Diff line number	Diff line change
`@@ -692,7 +692,7 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC`
`692`	`692`	`{`
`693`	`693`	`if (pSt_ProtocolHdr->byIsReply)`
`694`	`694`	`{`
`695`		`- pSt_ProtocolHdr->wReserve = ERROR_XENGINE_MESSAGE_XMQ_CREATEKEY;`
	`695`	`+ pSt_ProtocolHdr->wReserve = ERROR_XENGINE_MESSAGE_XMQ_EXISTED;`
`696`	`696`	`ProtocolModule_Packet_Common(nNetType, pSt_ProtocolHdr, &st_MQProtocol, tszSDBuffer, &nSDLen);`
`697`	`697`	`XEngine_MQXService_Send(lpszClientAddr, tszSDBuffer, nSDLen, nNetType);`
`698`	`698`	`}`