modify:time release code

Author: xengine-qyt

XEngine_Source/XEngine_MQServiceApp/MQService_Hdr.h

@@ -70,6 +70,7 @@ extern XHANDLE xhHttpPool;
 extern XHANDLE xhWSPool;
 
 extern XENGINE_SERVERCONFIG st_ServiceCfg;
+extern MESSAGEQUEUE_DBCONFIG st_DBConfig;
 
 #include "MQService_Config.h"
 #include "MQService_Net.h"

XEngine_Source/XEngine_MQServiceApp/MQService_Task.cpp

@@ -51,7 +51,16 @@ void CALLBACK MessageQueue_CBTask_TimePublish(LPCXSTR lpszQueueName, __int64x nI
 		XEngine_MQXService_Send(tszUserAddr, tszMsgBuffer, nMsgLen, nNetType);
 	}
 	BaseLib_OperatorMemory_Free((XPPPMEM)&ppSt_ListUser, nListCount);
-	//移除这条消息
-	DBModule_MQUser_TimeDelete(&st_DBTime);
+	
+	if (st_DBConfig.st_MQUser.st_UserTime.bPubClear)
+	{
+		//移除这条消息
+		DBModule_MQUser_TimeDelete(&st_DBTime);
+	}
+	else
+	{
+		//更新
+		DBModule_MQUser_TimeUPDate(&st_DBTime);
+	}
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("定时任务,消息主题:%s,序列:%lld,定时任务分发成功,客户端个数:%d"), lpszQueueName, nIDMsg, nListCount);
 }

XEngine_Source/XEngine_MQServiceApp/XEngine_MQServiceApp.cpp

@@ -15,6 +15,7 @@ XHANDLE xhHttpPool = NULL;
 XHANDLE xhWSPool = NULL;
 
 XENGINE_SERVERCONFIG st_ServiceCfg;
+MESSAGEQUEUE_DBCONFIG st_DBConfig;
 
 void ServiceApp_Stop(int signo)
 {
@@ -88,6 +89,8 @@ int main(int argc, char** argv)
 	LPCXSTR lpszHTTPMime = _X("./XEngine_Config/HttpMime.types");
 	LPCXSTR lpszHTTPCode = _X("./XEngine_Config/HttpCode.types");
 	LPCXSTR lpszLogFile = _X("./XEngine_Log/XEngine_MQServiceApp.Log");
+	LPCXSTR lpszDBConfig = _X("./XEngine_Config/XEngine_DBConfig.json");
+
 	XCHAR tszStringMsg[2048];
 	HELPCOMPONENTS_XLOG_CONFIGURE st_XLogConfig;
 	THREADPOOL_PARAMENT** ppSt_ListTCPParam;
@@ -117,9 +120,15 @@ int main(int argc, char** argv)
 		goto NETSERVICEEXIT;
 	}
 	HelpComponents_XLog_SetLogPriority(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO);
-
 	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("启动服务中，初始化日志系统成功"));
 
+	if (!Config_Json_DBFile(lpszDBConfig, &st_DBConfig))
+	{
+		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_ERROR, _X("启动服务中，初始化数据库配置失败，错误：%lX"), Config_GetLastError());
+		goto NETSERVICEEXIT;
+	}
+	XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("启动服务中，初始化数据库配置成功"));
+
 	if (st_ServiceCfg.bDeamon)
 	{
 		XLOG_PRINT(xhLog, XENGINE_HELPCOMPONENTS_XLOG_IN_LOGLEVEL_INFO, _X("初始化守护进程..."));