added:get session str for rtsp client

Author: xengine-qyt

XEngine_Source/XEngine_ModuleHelp/ModuleHelp_Define.h

@@ -290,6 +290,25 @@ extern "C" bool ModuleHelp_Rtsp_GetClient(LPCXSTR lpszClientID, int* pInt_RTPPor
 *********************************************************************/
 extern "C" bool ModuleHelp_Rtsp_SetSession(LPCXSTR lpszClientID, LPCXSTR lpszSessionStr);
 /********************************************************************
+函数名称：ModuleHelp_Rtsp_GetSession
+函数功能：获取一个会话ID
+ 参数.一：lpszClientID
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要处理的客户端ID
+ 参数.二：ptszSessionStr
+  In/Out：Out
+  类型：字符指针
+  可空：N
+  意思：输出获取到的会话ID
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+extern "C" bool ModuleHelp_Rtsp_GetSession(LPCXSTR lpszClientID, XCHAR* ptszSessionStr);
+/********************************************************************
 函数名称：ModuleHelp_Rtsp_SetSsrc
 函数功能：设置一个RTSP的RTP关联的SSRC
  参数.一：lpszClientID

XEngine_Source/XEngine_ModuleHelp/ModuleHelp_Rtsp/ModuleHelp_Rtsp.cpp

@@ -243,6 +243,38 @@ bool CModuleHelp_Rtsp::ModuleHelp_Rtsp_SetSession(LPCXSTR lpszClientID, LPCXSTR
 	return true;
 }
 /********************************************************************
+函数名称：ModuleHelp_Rtsp_GetSession
+函数功能：获取一个会话ID
+ 参数.一：lpszClientID
+  In/Out：In
+  类型：常量字符指针
+  可空：N
+  意思：输入要处理的客户端ID
+ 参数.二：ptszSessionStr
+  In/Out：Out
+  类型：字符指针
+  可空：N
+  意思：输出获取到的会话ID
+返回值
+  类型：逻辑型
+  意思：是否成功
+备注：
+*********************************************************************/
+bool CModuleHelp_Rtsp::ModuleHelp_Rtsp_GetSession(LPCXSTR lpszClientID, XCHAR* ptszSessionStr)
+{
+	ModuleHelp_IsErrorOccur = false;
+
+	unordered_map<string, RTSPPROTOCOL_CLIENTINFO>::iterator stl_MapIterator = stl_MapRTSPClient.find(lpszClientID);
+	if (stl_MapIterator == stl_MapRTSPClient.end())
+	{
+		ModuleHelp_IsErrorOccur = true;
+		ModuleHelp_dwErrorCode = ERROR_MODULE_HELP_RTSP_NOTFOUND;
+		return false;
+	}
+	_tcsxcpy(ptszSessionStr, stl_MapIterator->second.tszSession);
+	return true;
+}
+/********************************************************************
 函数名称：ModuleHelp_Rtsp_SetSsrc
 函数功能：设置一个RTSP的RTP关联的SSRC
  参数.一：lpszClientID

XEngine_Source/XEngine_ModuleHelp/ModuleHelp_Rtsp/ModuleHelp_Rtsp.h

@@ -36,6 +36,7 @@ class CModuleHelp_Rtsp
 	bool ModuleHelp_Rtsp_SetClient(LPCXSTR lpszClientID, int nRTPPort, int nRTCPPort, int nTrackID);
 	bool ModuleHelp_Rtsp_GetClient(LPCXSTR lpszClientID, int* pInt_RTPPort, int* pInt_RTCPPort, bool bVideo = true);
 	bool ModuleHelp_Rtsp_SetSession(LPCXSTR lpszClientID, LPCXSTR lpszSessionStr);
+	bool ModuleHelp_Rtsp_GetSession(LPCXSTR lpszClientID, XCHAR *ptszSessionStr);
 	bool ModuleHelp_Rtsp_SetSsrc(LPCXSTR lpszClientID, LPCXSTR lpszSsrcStr, bool bVideo = true);
 protected:
 private:

XEngine_Source/XEngine_ModuleHelp/XEngine_ModuleHelp.def

@@ -19,4 +19,5 @@ EXPORTS
 	ModuleHelp_Rtsp_SetClient
 	ModuleHelp_Rtsp_GetClient
 	ModuleHelp_Rtsp_SetSession
+	ModuleHelp_Rtsp_GetSession
 	ModuleHelp_Rtsp_SetSsrc

XEngine_Source/XEngine_ModuleHelp/pch.cpp

@@ -95,6 +95,10 @@ extern "C" bool ModuleHelp_Rtsp_SetSession(LPCXSTR lpszClientID, LPCXSTR lpszSes
 {
 	return m_HelpRtsp.ModuleHelp_Rtsp_SetSession(lpszClientID, lpszSessionStr);
 }
+extern "C" bool ModuleHelp_Rtsp_GetSession(LPCXSTR lpszClientID, XCHAR * ptszSessionStr)
+{
+	return m_HelpRtsp.ModuleHelp_Rtsp_GetSession(lpszClientID, ptszSessionStr);
+}
 extern "C" bool ModuleHelp_Rtsp_SetSsrc(LPCXSTR lpszClientID, LPCXSTR lpszSsrcStr, bool bVideo)
 {
 	return m_HelpRtsp.ModuleHelp_Rtsp_SetSsrc(lpszClientID, lpszSsrcStr, bVideo);

XEngine_Source/XEngine_ServiceApp/XEngine_StreamMediaApp/StreamMedia_PullStream/PullStream_ClientMethod.cpp

@@ -151,10 +151,9 @@ bool PullStream_ClientMethod_Handle(RFCCOMPONENTS_HTTP_REQPARAM* pSt_HTTPParam,
 	}
 	else if (ENUM_RTSPPROTOCOL_METHOD_TYPE_SETUP == st_RTSPRequest.enMethod)
 	{
+		ModuleHelp_Rtsp_GetSession(lpszClientAddr, st_RTSPResponse.tszSession);
 		ModuleHelp_Rtsp_SetClient(lpszClientAddr, st_RTSPRequest.st_TransportInfo.st_ClientPorts.nRTPPort, st_RTSPRequest.st_TransportInfo.st_ClientPorts.nRTCPPort, st_RTSPRequest.st_ChannelInfo.nChannelNumber);
 
-		
-
 		st_RTSPResponse.st_TransportInfo.st_TransFlags.bAVP = true;
 		st_RTSPResponse.st_TransportInfo.st_TransFlags.bRTP = true;
 		st_RTSPResponse.st_TransportInfo.st_TransFlags.bUDP = true;