modify:release time task does not to notify user

Author: xengine-qyt

XEngine_Source/XEngine_MQServiceApp/MQService_TCPTask.cpp

@@ -400,31 +400,36 @@ BOOL MessageQueue_TCP_Handle(XENGINE_PROTOCOLHDR* pSt_ProtocolHdr, LPCTSTR lpszC
 			}
 			//是否需要通知
 			int nListCount = 0;
-			XENGINE_DBUSERKEY** ppSt_ListUser;
-			if (DBModule_MQUser_KeyList(NULL, st_MQProtocol.tszMQKey, &ppSt_ListUser, &nListCount))
+			if (0 == st_MQProtocol.nPubTime)
 			{
-				int nTCPLen = 0;
-				TCHAR tszTCPBuffer[4096];
-				memset(tszTCPBuffer, '\0', sizeof(tszTCPBuffer));
-
-				pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;
-				ProtocolModule_Packet_Common(nNetType, pSt_ProtocolHdr, &st_MQProtocol, tszTCPBuffer, &nTCPLen, lpszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ), nMsgLen - sizeof(XENGINE_PROTOCOL_XMQ));
-				for (int i = 0; i < nListCount; i++)
+				//定时任务不通知
+				XENGINE_DBUSERKEY** ppSt_ListUser;
+				if (DBModule_MQUser_KeyList(NULL, st_MQProtocol.tszMQKey, &ppSt_ListUser, &nListCount))
 				{
-					//跳过自己
-					if (0 == _tcsncmp(tszUserName, ppSt_ListUser[i]->tszUserName, _tcslen(tszUserName)))
+					int nTCPLen = 0;
+					TCHAR tszTCPBuffer[4096];
+					memset(tszTCPBuffer, '\0', sizeof(tszTCPBuffer));
+
+					pSt_ProtocolHdr->unOperatorCode = XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_MSGNOTIFY;
+					ProtocolModule_Packet_Common(nNetType, pSt_ProtocolHdr, &st_MQProtocol, tszTCPBuffer, &nTCPLen, lpszMsgBuffer + sizeof(XENGINE_PROTOCOL_XMQ), nMsgLen - sizeof(XENGINE_PROTOCOL_XMQ));
+					for (int i = 0; i < nListCount; i++)
 					{
-						continue;
+						//跳过自己
+						if (0 == _tcsncmp(tszUserName, ppSt_ListUser[i]->tszUserName, _tcslen(tszUserName)))
+						{
+							continue;
+						}
+						TCHAR tszUserAddr[128];
+						memset(tszUserAddr, '\0', sizeof(tszUserAddr));
+
+						SessionModule_Client_GetAddr(ppSt_ListUser[i]->tszUserName, tszUserAddr);
+						XEngine_MQXService_Send(tszUserAddr, tszTCPBuffer, nTCPLen, nNetType);
 					}
-					TCHAR tszUserAddr[128];
-					memset(tszUserAddr, '\0', sizeof(tszUserAddr));
-
-					SessionModule_Client_GetAddr(ppSt_ListUser[i]->tszUserName, tszUserAddr);
-					XEngine_MQXService_Send(tszUserAddr, tszTCPBuffer, nTCPLen, nNetType);
+					BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_ListUser, nListCount);
 				}
-				BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_ListUser, nListCount);
 			}
 			XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _T("%s消息端:%s,主题:%s,序列:%lld,投递数据到消息队列成功,通知客户端个数:%d"), lpszClientType, lpszClientAddr, st_DBQueue.tszQueueName, st_DBQueue.nQueueSerial, nListCount);
+			
 		}
 		else if (XENGINE_COMMUNICATION_PROTOCOL_OPERATOR_CODE_MQ_REQGET == pSt_ProtocolHdr->unOperatorCode)
 		{