fixed:unread protocol memory leak

fixed:unread protocol serial handle is incorrent

Author: xengine-qyt

XEngine_Source/MQCore_DBModule/DBModule_MQData/DBModule_MQData.cpp

@@ -304,7 +304,7 @@ bool CDBModule_MQData::DBModule_MQData_List(LPCXSTR lpszQueueName, __int64x nSer
 	XCHAR tszSQLStatement[1024];
 	memset(tszSQLStatement, '\0', sizeof(tszSQLStatement));
 	//名称为,消息名为必填
-	_xstprintf(tszSQLStatement, _X("SELECT * FROM `%s` WHERE nQueueSerial > %lld"), lpszQueueName, nSerial);
+	_xstprintf(tszSQLStatement, _X("SELECT * FROM `%s` WHERE nQueueSerial >= %lld"), lpszQueueName, nSerial);
 	if (!DataBase_MySQL_ExecuteQuery(xhDBSQL, &xhTable, tszSQLStatement, &nllLine, &nllRow))
 	{
 		DBModule_IsErrorOccur = true;

XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp

@@ -854,14 +854,16 @@ bool MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCXSTR lpszC
 				if (nDBCount > 0)
 				{
 					//更新用户KEY
-					st_UserKey.nKeySerial = ppSt_UserKey[i]->nKeySerial + nDBCount + 1;
+					st_UserKey.nKeySerial = ppSt_UserKey[i]->nKeySerial + nDBCount;
 					_tcsxcpy(st_UserKey.tszUserName, tszUserName);
 					_tcsxcpy(st_UserKey.tszKeyName, ppSt_UserKey[i]->tszKeyName);
 					DBModule_MQUser_KeyUPDate(&st_UserKey);
 					ProtocolModule_Packet_UNReadInsert(xhUNRead, &ppSt_DBMessage, nDBCount);
+					BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_DBMessage, nDBCount);
 				}
 			}
 			ProtocolModule_Packet_UNReadDelete(xhUNRead, tszSDBuffer, &nSDLen);
+			BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_UserKey, nListCount);
 			XEngine_MQXService_Send(lpszClientAddr, tszSDBuffer, nSDLen, nNetType);
 			XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("%s消息端:%s,请求未读消息成功,用户名:%s,发送未读消息成功,发送的主题个数:%d"), lpszClientType, lpszClientAddr, tszUserName, nListCount);
 		}

XEngine_Source/XQueue_ProtocolHdr.h

@@ -56,7 +56,7 @@
 typedef struct
 {
 	XBYTE byAttrAll : 1;                                                 //通知所有
-	XBYTE byAttrDisk : 1;                                                //消息存储标记
+	XBYTE byAttrSelf : 1;                                                //自己也能接受
 	XBYTE byAttrResver2 : 1;
 	XBYTE byAttrResver3 : 1;
 	XBYTE byAttrResver4 : 1;