modify:clear timed release list when program start

Author: xengine-qyt

XEngine_Source/MQCore_DBModule/DBModule_Define.h

@@ -217,6 +217,20 @@ extern "C" BOOL DBModule_MQData_TimeQuery(XENGINE_DBTIMERELEASE*** pppSt_DBInfo,
 备注：
 *********************************************************************/
 extern "C" BOOL DBModule_MQData_TimeDelete(XENGINE_DBTIMERELEASE* pSt_DBInfo);
+/********************************************************************
+函数名称：DMBodule_MQData_TimeClaer
+函数功能：清理超时通知
+ 参数.一：nTime
+  In/Out：In
+  类型：整数型
+  可空：Y
+  意思：输入要清理的日期
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+extern "C" BOOL DMBodule_MQData_TimeClaer(time_t nTime = 0);
 /*************************************************************************
 						消息用户导出函数
 **************************************************************************/

XEngine_Source/MQCore_DBModule/DBModule_MQData/DBModule_MQData.cpp

@@ -68,6 +68,8 @@ BOOL CDBModule_MQData::DBModule_MQData_Init(DATABASE_MYSQL_CONNECTINFO* pSt_DBCo
         DBModule_dwErrorCode = DataBase_GetLastError();
         return FALSE;
     }
+	DMBodule_MQData_TimeClaer();
+
 	bIsRun = TRUE;
 	m_lParam = lParam;
 	lpCall_TimePublish = fpCall_TimePublish;
@@ -607,6 +609,44 @@ BOOL CDBModule_MQData::DBModule_MQData_TimeDelete(XENGINE_DBTIMERELEASE* pSt_DBI
 	}
 	return TRUE;
 }
+/********************************************************************
+函数名称：DMBodule_MQData_TimeClaer
+函数功能：清理超时通知
+ 参数.一：nTime
+  In/Out：In
+  类型：整数型
+  可空：Y
+  意思：输入要清理的日期
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+BOOL CDBModule_MQData::DMBodule_MQData_TimeClaer(time_t nTime /* = 0 */)
+{
+	DBModule_IsErrorOccur = FALSE;
+
+	TCHAR tszSQLQuery[2048];
+	memset(tszSQLQuery, '\0', sizeof(tszSQLQuery));
+
+	if (0 == nTime)
+	{
+		nTime = time(NULL);
+	}
+#ifdef _MSC_BUILD
+	_stprintf(tszSQLQuery, _T("DELETE FROM `XEngine_TimeRelease` WHERE nIDTime <= %lld"), nTime);
+#else
+	_stprintf(tszSQLQuery, _T("DELETE FROM `XEngine_TimeRelease` WHERE nIDTime <= %ld"), nTime);
+#endif
+
+	if (!DataBase_MySQL_Execute(xhDBSQL, tszSQLQuery))
+	{
+		DBModule_IsErrorOccur = TRUE;
+		DBModule_dwErrorCode = DataBase_GetLastError();
+		return FALSE;
+	}
+	return TRUE;
+}
 //////////////////////////////////////////////////////////////////////////
 //                         线程函数
 //////////////////////////////////////////////////////////////////////////

XEngine_Source/MQCore_DBModule/DBModule_MQData/DBModule_MQData.h

@@ -28,6 +28,7 @@ class CDBModule_MQData
 	BOOL DBModule_MQData_TimeInsert(XENGINE_DBTIMERELEASE* pSt_DBInfo);
 	BOOL DBModule_MQData_TimeQuery(XENGINE_DBTIMERELEASE*** pppSt_DBInfo, int* pInt_ListCount);
 	BOOL DBModule_MQData_TimeDelete(XENGINE_DBTIMERELEASE* pSt_DBInfo);
+	BOOL DMBodule_MQData_TimeClaer(time_t nTime = 0);
 protected:
 	static XHTHREAD CALLBACK DBModule_MQData_TimeThread(LPVOID lParam);
 private:

XEngine_Source/MQCore_DBModule/MQCore_DBModule.def

@@ -14,6 +14,7 @@ EXPORTS
 	DBModule_MQData_TimeInsert
 	DBModule_MQData_TimeQuery
 	DBModule_MQData_TimeDelete
+	DMBodule_MQData_TimeClaer
 
 	DBModule_MQUser_Init
 	DBModule_MQUser_Destory

XEngine_Source/MQCore_DBModule/pch.cpp

@@ -71,6 +71,10 @@ extern "C" BOOL DBModule_MQData_TimeDelete(XENGINE_DBTIMERELEASE * pSt_DBInfo)
 {
 	return m_DBData.DBModule_MQData_TimeDelete(pSt_DBInfo);
 }
+extern "C" BOOL DMBodule_MQData_TimeClaer(time_t nTime)
+{
+	return m_DBData.DMBodule_MQData_TimeClaer(nTime);
+}
 /*************************************************************************
 						消息用户导出函数
 **************************************************************************/

XEngine_Source/XEngine_MQServiceApp/MQService_Hdr.h

@@ -37,6 +37,8 @@ using namespace std;
 #include <XEngine_Include/XEngine_RfcComponents/HttpServer_Error.h>
 #include <XEngine_Include/XEngine_RfcComponents/WSProtocol_Define.h>
 #include <XEngine_Include/XEngine_RfcComponents/WSProtocol_Error.h>
+#include <XEngine_Include/XEngine_NetHelp/APIHelp_Define.h>
+#include <XEngine_Include/XEngine_NetHelp/APIHelp_Error.h>
 
 #ifdef _UNICODE
 typedef std::wstring tstring;
@@ -84,6 +86,7 @@ extern XENGINE_SERVERCONFIG st_ServiceCfg;
 #pragma comment(lib,"XEngine_HelpComponents/HelpComponents_Packets.lib")
 #pragma comment(lib,"XEngine_RfcComponents/RfcComponents_HttpServer.lib")
 #pragma comment(lib,"XEngine_RfcComponents/RfcComponents_WSProtocol.lib")
+#pragma comment(lib,"XEngine_NetHelp/NetHelp_APIHelp.lib")
 #pragma comment(lib,"Ws2_32.lib")
 #ifdef _DEBUG
 #ifdef _WIN64