|
|
@@ -0,0 +1,660 @@
|
|
|
+
|
|
|
+// EasyGBD_DemoDlg.cpp: 实现文件
|
|
|
+//
|
|
|
+
|
|
|
+#include "pch.h"
|
|
|
+#include "framework.h"
|
|
|
+#include "EasyGBD_Demo.h"
|
|
|
+#include "EasyGBD_DemoDlg.h"
|
|
|
+#include "afxdialogex.h"
|
|
|
+
|
|
|
+#ifdef _DEBUG
|
|
|
+#define new DEBUG_NEW
|
|
|
+#endif
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+// 用于应用程序“关于”菜单项的 CAboutDlg 对话框
|
|
|
+
|
|
|
+class CAboutDlg : public CDialogEx
|
|
|
+{
|
|
|
+public:
|
|
|
+ CAboutDlg();
|
|
|
+
|
|
|
+// 对话框数据
|
|
|
+#ifdef AFX_DESIGN_TIME
|
|
|
+ enum { IDD = IDD_ABOUTBOX };
|
|
|
+#endif
|
|
|
+
|
|
|
+ protected:
|
|
|
+ virtual void DoDataExchange(CDataExchange* pDX); // DDX/DDV 支持
|
|
|
+
|
|
|
+// 实现
|
|
|
+protected:
|
|
|
+ DECLARE_MESSAGE_MAP()
|
|
|
+};
|
|
|
+
|
|
|
+CAboutDlg::CAboutDlg() : CDialogEx(IDD_ABOUTBOX)
|
|
|
+{
|
|
|
+}
|
|
|
+
|
|
|
+void CAboutDlg::DoDataExchange(CDataExchange* pDX)
|
|
|
+{
|
|
|
+ CDialogEx::DoDataExchange(pDX);
|
|
|
+}
|
|
|
+
|
|
|
+BEGIN_MESSAGE_MAP(CAboutDlg, CDialogEx)
|
|
|
+END_MESSAGE_MAP()
|
|
|
+
|
|
|
+
|
|
|
+// CEasyGBDDemoDlg 对话框
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+CEasyGBDDemoDlg::CEasyGBDDemoDlg(CWnd* pParent /*=nullptr*/)
|
|
|
+ : CDialogEx(IDD_EASYGBD_DEMO_DIALOG, pParent)
|
|
|
+{
|
|
|
+ m_hIcon = AfxGetApp()->LoadIcon(IDR_MAINFRAME);
|
|
|
+
|
|
|
+ InitMutex(&mLogMutex);
|
|
|
+ memset(&mGB28181Device, 0x00, sizeof(GB28181_DEVICE_T));
|
|
|
+}
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::DoDataExchange(CDataExchange* pDX)
|
|
|
+{
|
|
|
+ CDialogEx::DoDataExchange(pDX);
|
|
|
+}
|
|
|
+
|
|
|
+BEGIN_MESSAGE_MAP(CEasyGBDDemoDlg, CDialogEx)
|
|
|
+ ON_WM_SYSCOMMAND()
|
|
|
+ ON_WM_PAINT()
|
|
|
+ ON_WM_QUERYDRAGICON()
|
|
|
+ ON_BN_CLICKED(IDC_BUTTON_STARTUP, &CEasyGBDDemoDlg::OnBnClickedButtonStart)
|
|
|
+ ON_WM_DESTROY()
|
|
|
+ ON_BN_CLICKED(IDC_BUTTON_SHUTDOWN, &CEasyGBDDemoDlg::OnBnClickedButtonShutdown)
|
|
|
+ ON_BN_CLICKED(IDC_BUTTON_BROWSE, &CEasyGBDDemoDlg::OnBnClickedButtonBrowse)
|
|
|
+ ON_MESSAGE(WM_UPDATE_LOG, OnUpdateLog)
|
|
|
+END_MESSAGE_MAP()
|
|
|
+
|
|
|
+
|
|
|
+// CEasyGBDDemoDlg 消息处理程序
|
|
|
+
|
|
|
+BOOL CEasyGBDDemoDlg::OnInitDialog()
|
|
|
+{
|
|
|
+ CDialogEx::OnInitDialog();
|
|
|
+
|
|
|
+ // 将“关于...”菜单项添加到系统菜单中。
|
|
|
+
|
|
|
+ // IDM_ABOUTBOX 必须在系统命令范围内。
|
|
|
+ ASSERT((IDM_ABOUTBOX & 0xFFF0) == IDM_ABOUTBOX);
|
|
|
+ ASSERT(IDM_ABOUTBOX < 0xF000);
|
|
|
+
|
|
|
+ CMenu* pSysMenu = GetSystemMenu(FALSE);
|
|
|
+ if (pSysMenu != nullptr)
|
|
|
+ {
|
|
|
+ BOOL bNameValid;
|
|
|
+ CString strAboutMenu;
|
|
|
+ bNameValid = strAboutMenu.LoadString(IDS_ABOUTBOX);
|
|
|
+ ASSERT(bNameValid);
|
|
|
+ if (!strAboutMenu.IsEmpty())
|
|
|
+ {
|
|
|
+ pSysMenu->AppendMenu(MF_SEPARATOR);
|
|
|
+ pSysMenu->AppendMenu(MF_STRING, IDM_ABOUTBOX, strAboutMenu);
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ // 设置此对话框的图标。 当应用程序主窗口不是对话框时，框架将自动
|
|
|
+ // 执行此操作
|
|
|
+ SetIcon(m_hIcon, TRUE); // 设置大图标
|
|
|
+ SetIcon(m_hIcon, FALSE); // 设置小图标
|
|
|
+
|
|
|
+ // TODO: 在此添加额外的初始化代码
|
|
|
+
|
|
|
+ SetWindowText(TEXT("EasyGBD_Win（Powered by EasyDarwin）"));
|
|
|
+
|
|
|
+ pEdtServerSipID = (CEdit*)GetDlgItem(IDC_EDIT_SERVER_SIPID);
|
|
|
+ pEdtServerIP = (CEdit*)GetDlgItem(IDC_EDIT_SERVER_IP);
|
|
|
+ pEdtServerPort = (CEdit*)GetDlgItem(IDC_EDIT_SERVER_PORT);
|
|
|
+ pEdtRegExpire = (CEdit*)GetDlgItem(IDC_EDIT_REG_EXPIRE);
|
|
|
+ pEdtHeartbeatCount = (CEdit*)GetDlgItem(IDC_EDIT_HEARTBEAT_COUNT);
|
|
|
+ pEdtHeartbeatInterval = (CEdit*)GetDlgItem(IDC_EDIT_HEARTBEAT_INTERVAL);
|
|
|
+ pComboxProtocol = (CComboBox*)GetDlgItem(IDC_COMBO_PROTOCOL);
|
|
|
+ pEdtPassword = (CEdit*)GetDlgItem(IDC_EDIT_PASSWORD);
|
|
|
+ pEdtLocalSipID = (CEdit*)GetDlgItem(IDC_EDIT_LOCAL_SIPID);
|
|
|
+ pEdtLocalPort = (CEdit*)GetDlgItem(IDC_EDIT_LOCAL_PORT);
|
|
|
+ pEdtSourceURL = (CEdit*)GetDlgItem(IDC_EDIT_SOURCE_URL);
|
|
|
+
|
|
|
+ pBtnStartup = (CButton*)GetDlgItem(IDC_BUTTON_STARTUP);
|
|
|
+ pBtnShutdown = (CButton*)GetDlgItem(IDC_BUTTON_SHUTDOWN);
|
|
|
+ pRichEditLog = (CRichEditCtrl*)GetDlgItem(IDC_RICHEDIT2_LOG);
|
|
|
+
|
|
|
+
|
|
|
+ pEdtServerSipID->SetWindowTextW(TEXT("11010100032008000001"));
|
|
|
+ pEdtServerIP->SetWindowTextW(TEXT("192.168.0.106"));
|
|
|
+ pEdtServerPort->SetWindowTextW(TEXT("5060"));
|
|
|
+ pEdtRegExpire->SetWindowTextW(TEXT("3600"));
|
|
|
+ pEdtHeartbeatCount->SetWindowTextW(TEXT("3"));
|
|
|
+ pEdtHeartbeatInterval->SetWindowTextW(TEXT("60"));
|
|
|
+ pComboxProtocol->AddString(TEXT("UDP"));
|
|
|
+ pComboxProtocol->AddString(TEXT("TCP"));
|
|
|
+ pComboxProtocol->SetCurSel(0);
|
|
|
+ pEdtPassword->SetWindowTextW(TEXT("12345678"));
|
|
|
+ pEdtLocalSipID->SetWindowTextW(TEXT("34020000001320000911"));
|
|
|
+ pEdtLocalPort->SetWindowTextW(TEXT("15090"));
|
|
|
+ pEdtSourceURL->SetWindowTextW(TEXT("视频源或者文件URL,例如：\"rtsp://...\",\"D:\\video\\gb.mp4\",\"http://...\""));
|
|
|
+
|
|
|
+ OnBnClickedButtonShutdown();
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ return TRUE; // 除非将焦点设置到控件，否则返回 TRUE
|
|
|
+}
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::OnSysCommand(UINT nID, LPARAM lParam)
|
|
|
+{
|
|
|
+ if ((nID & 0xFFF0) == IDM_ABOUTBOX)
|
|
|
+ {
|
|
|
+ CAboutDlg dlgAbout;
|
|
|
+ dlgAbout.DoModal();
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ CDialogEx::OnSysCommand(nID, lParam);
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+// 如果向对话框添加最小化按钮，则需要下面的代码
|
|
|
+// 来绘制该图标。 对于使用文档/视图模型的 MFC 应用程序，
|
|
|
+// 这将由框架自动完成。
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::OnPaint()
|
|
|
+{
|
|
|
+ if (IsIconic())
|
|
|
+ {
|
|
|
+ CPaintDC dc(this); // 用于绘制的设备上下文
|
|
|
+
|
|
|
+ SendMessage(WM_ICONERASEBKGND, reinterpret_cast<WPARAM>(dc.GetSafeHdc()), 0);
|
|
|
+
|
|
|
+ // 使图标在工作区矩形中居中
|
|
|
+ int cxIcon = GetSystemMetrics(SM_CXICON);
|
|
|
+ int cyIcon = GetSystemMetrics(SM_CYICON);
|
|
|
+ CRect rect;
|
|
|
+ GetClientRect(&rect);
|
|
|
+ int x = (rect.Width() - cxIcon + 1) / 2;
|
|
|
+ int y = (rect.Height() - cyIcon + 1) / 2;
|
|
|
+
|
|
|
+ // 绘制图标
|
|
|
+ dc.DrawIcon(x, y, m_hIcon);
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ CDialogEx::OnPaint();
|
|
|
+ }
|
|
|
+}
|
|
|
+
|
|
|
+//当用户拖动最小化窗口时系统调用此函数取得光标
|
|
|
+//显示。
|
|
|
+HCURSOR CEasyGBDDemoDlg::OnQueryDragIcon()
|
|
|
+{
|
|
|
+ return static_cast<HCURSOR>(m_hIcon);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+bool MByteToWChar(LPCSTR lpcszStr, LPWSTR lpwszStr, DWORD dwSize)
|
|
|
+{
|
|
|
+ // Get the required size of the buffer that receives the Unicode
|
|
|
+ // string.
|
|
|
+ DWORD dwMinSize;
|
|
|
+ dwMinSize = MultiByteToWideChar(CP_ACP, 0, lpcszStr, -1, NULL, 0);
|
|
|
+
|
|
|
+ if (dwSize < dwMinSize)
|
|
|
+ {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+
|
|
|
+ // Convert headers from ASCII to Unicode.
|
|
|
+ MultiByteToWideChar(CP_ACP, 0, lpcszStr, -1, lpwszStr, dwMinSize);
|
|
|
+ return true;
|
|
|
+}
|
|
|
+bool WCharToMByte(LPCWSTR lpcwszStr, LPSTR lpszStr, DWORD dwSize)
|
|
|
+{
|
|
|
+ DWORD dwMinSize;
|
|
|
+ dwMinSize = WideCharToMultiByte(CP_UTF8, NULL, lpcwszStr, -1, NULL, 0, NULL, FALSE);
|
|
|
+ if (dwSize < dwMinSize)
|
|
|
+ {
|
|
|
+ return false;
|
|
|
+ }
|
|
|
+ WideCharToMultiByte(CP_UTF8, NULL, lpcwszStr, -1, lpszStr, dwSize, NULL, FALSE);
|
|
|
+ return true;
|
|
|
+}
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::OnBnClickedButtonStart()
|
|
|
+{
|
|
|
+ // TODO: 在此添加控件通知处理程序代码
|
|
|
+
|
|
|
+ wchar_t wszServerSipId[32] = { 0 };
|
|
|
+ char szServerSipId[32] = { 0 };
|
|
|
+ pEdtServerSipID->GetWindowTextW(wszServerSipId, sizeof(wszServerSipId));
|
|
|
+ WCharToMByte(wszServerSipId, szServerSipId, sizeof(szServerSipId) / sizeof(szServerSipId[0]));
|
|
|
+
|
|
|
+ wchar_t wszServerIP[32] = { 0 };
|
|
|
+ char szServerIP[32] = { 0 };
|
|
|
+ pEdtServerIP->GetWindowTextW(wszServerIP, sizeof(wszServerIP));
|
|
|
+ WCharToMByte(wszServerIP, szServerIP, sizeof(szServerIP) / sizeof(szServerIP[0]));
|
|
|
+
|
|
|
+ wchar_t wszServerPort[16] = { 0 };
|
|
|
+ char szServerPort[16] = { 0 };
|
|
|
+ pEdtServerPort->GetWindowTextW(wszServerPort, sizeof(wszServerPort));
|
|
|
+ WCharToMByte(wszServerPort, szServerPort, sizeof(szServerPort) / sizeof(szServerPort[0]));
|
|
|
+
|
|
|
+ wchar_t wszRegExpire[16] = { 0 };
|
|
|
+ char szRegExpire[16] = { 0 };
|
|
|
+ pEdtRegExpire->GetWindowTextW(wszRegExpire, sizeof(wszRegExpire));
|
|
|
+ WCharToMByte(wszRegExpire, szRegExpire, sizeof(szRegExpire) / sizeof(szRegExpire[0]));
|
|
|
+
|
|
|
+ wchar_t wszHeartbeatCount[16] = { 0 };
|
|
|
+ char szHeartbeatCount[16] = { 0 };
|
|
|
+ pEdtHeartbeatCount->GetWindowTextW(wszHeartbeatCount, sizeof(wszHeartbeatCount));
|
|
|
+ WCharToMByte(wszHeartbeatCount, szHeartbeatCount, sizeof(szHeartbeatCount) / sizeof(szHeartbeatCount[0]));
|
|
|
+
|
|
|
+ wchar_t wszHeartbeatInterval[16] = { 0 };
|
|
|
+ char szHeartbeatInterval[16] = { 0 };
|
|
|
+ pEdtHeartbeatInterval->GetWindowTextW(wszHeartbeatInterval, sizeof(wszHeartbeatInterval));
|
|
|
+ WCharToMByte(wszHeartbeatInterval, szHeartbeatInterval, sizeof(szHeartbeatInterval) / sizeof(szHeartbeatInterval[0]));
|
|
|
+
|
|
|
+ int protocol = pComboxProtocol->GetCurSel();
|
|
|
+
|
|
|
+ wchar_t wszPassword[32] = { 0 };
|
|
|
+ char szPassword[32] = { 0 };
|
|
|
+ pEdtPassword->GetWindowTextW(wszPassword, sizeof(wszPassword));
|
|
|
+ WCharToMByte(wszPassword, szPassword, sizeof(szPassword) / sizeof(szPassword[0]));
|
|
|
+
|
|
|
+ wchar_t wszLocalSipID[32] = { 0 };
|
|
|
+ char szLocalSipID[32] = { 0 };
|
|
|
+ pEdtLocalSipID->GetWindowTextW(wszLocalSipID, sizeof(wszLocalSipID));
|
|
|
+ WCharToMByte(wszLocalSipID, szLocalSipID, sizeof(szLocalSipID) / sizeof(szLocalSipID[0]));
|
|
|
+
|
|
|
+ wchar_t wszLocalPort[16] = { 0 };
|
|
|
+ char szLocalPort[16] = { 0 };
|
|
|
+ pEdtLocalPort->GetWindowTextW(wszLocalPort, sizeof(wszLocalPort));
|
|
|
+ WCharToMByte(wszLocalPort, szLocalPort, sizeof(szLocalPort) / sizeof(szLocalPort[0]));
|
|
|
+
|
|
|
+ wchar_t wszSourceURL[1024] = { 0 };
|
|
|
+ char szSourceURL[1024] = { 0 };
|
|
|
+ pEdtSourceURL->GetWindowTextW(wszSourceURL, sizeof(wszSourceURL));
|
|
|
+ WCharToMByte(wszSourceURL, szSourceURL, sizeof(szSourceURL) / sizeof(szSourceURL[0]));
|
|
|
+
|
|
|
+ Startup(szServerSipId, szServerIP, atoi(szServerPort), atoi(szRegExpire), atoi(szHeartbeatCount), atoi(szHeartbeatInterval),
|
|
|
+ protocol, szPassword, szLocalSipID, atoi(szLocalPort), szSourceURL);
|
|
|
+
|
|
|
+
|
|
|
+ pBtnStartup->EnableWindow(FALSE);
|
|
|
+ pBtnShutdown->EnableWindow(TRUE);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::OnBnClickedButtonShutdown()
|
|
|
+{
|
|
|
+ Shutdown();
|
|
|
+
|
|
|
+ pBtnStartup->EnableWindow(TRUE);
|
|
|
+ pBtnShutdown->EnableWindow(FALSE);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+int CEasyGBDDemoDlg::OutputLog(char* szFormat, ...)
|
|
|
+{
|
|
|
+ char pbuf[1024] = { 0 };
|
|
|
+
|
|
|
+ va_list args;
|
|
|
+ va_start(args, szFormat);
|
|
|
+ vsnprintf(pbuf, sizeof(pbuf) - 1, szFormat, args);
|
|
|
+ va_end(args);
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+ LockLogMutex();
|
|
|
+ mLogVector.push_back(pbuf);
|
|
|
+ UnlockLogMutex();
|
|
|
+
|
|
|
+ PostMessage(WM_UPDATE_LOG);
|
|
|
+
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+LRESULT CEasyGBDDemoDlg::OnUpdateLog(WPARAM, LPARAM)
|
|
|
+{
|
|
|
+
|
|
|
+ OutputLog2UI();
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::OutputLog2UI()
|
|
|
+{
|
|
|
+ LockLogMutex();
|
|
|
+ LOG_VECTOR::iterator it = mLogVector.begin();
|
|
|
+ while (it != mLogVector.end())
|
|
|
+ {
|
|
|
+ wchar_t wszBuf[1024] = { 0 };
|
|
|
+ MByteToWChar(it->data(), wszBuf, sizeof(wszBuf) / sizeof(wszBuf[0]));
|
|
|
+
|
|
|
+ pRichEditLog->SetSel(-1, -1);
|
|
|
+ pRichEditLog->ReplaceSel(wszBuf);
|
|
|
+
|
|
|
+ mLogVector.erase(it);
|
|
|
+ it = mLogVector.begin();
|
|
|
+ if (it == mLogVector.end()) break;
|
|
|
+ }
|
|
|
+ UnlockLogMutex();
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+int CALLBACK __GB28181DeviceCALLBACK(void* userPtr, int channelId, int eventType, char* eventParams, int paramLength)
|
|
|
+{
|
|
|
+ GB28181_DEVICE_T* pGB28181Device = (GB28181_DEVICE_T*)userPtr;
|
|
|
+ GB28181_CHANNEL_T* pChannel = &pGB28181Device->pChannel[channelId];
|
|
|
+
|
|
|
+ if (NULL == pChannel) return 0;
|
|
|
+
|
|
|
+ CEasyGBDDemoDlg* pThis = (CEasyGBDDemoDlg*)pChannel->userptr;
|
|
|
+
|
|
|
+ if (GB28181_DEVICE_EVENT_CONNECTING == eventType)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("GB/T28181服务连接中... %s\n", eventParams);
|
|
|
+
|
|
|
+ }
|
|
|
+ else if (GB28181_DEVICE_EVENT_REGISTER_ING == eventType)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("GB/T28181 注册中....\n");
|
|
|
+ }
|
|
|
+ if (GB28181_DEVICE_EVENT_REGISTER_OK == eventType)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("GB/T28181 注册成功.\n");
|
|
|
+ }
|
|
|
+ else if (GB28181_DEVICE_EVENT_REGISTER_AUTH_FAIL == eventType)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("GB/T28181 鉴权失败.\n");
|
|
|
+ }
|
|
|
+
|
|
|
+ else if (GB28181_DEVICE_EVENT_START_AUDIO_VIDEO == eventType)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("GB/T28181 请求视频. ID: %s\n", eventParams);
|
|
|
+ pChannel->sendStatus = 1;
|
|
|
+ }
|
|
|
+ else if (GB28181_DEVICE_EVENT_STOP_AUDIO_VIDEO == eventType)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("GB/T28181 停止视频. ID: %s\n", eventParams);
|
|
|
+ pChannel->sendStatus = 0;
|
|
|
+ }
|
|
|
+ else if (GB28181_DEVICE_EVENT_TALK_AUDIO_DATA == eventType)
|
|
|
+ {
|
|
|
+ //pThis->OutputLog("GB/T28181 音频对讲数据...\n");
|
|
|
+ }
|
|
|
+
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+int Easy_APICALL __EasyStreamClientCallBack(void* _channelPtr, int _frameType, void* pBuf, EASY_FRAME_INFO* _frameInfo)
|
|
|
+{
|
|
|
+ GB28181_CHANNEL_T* pChannel = (GB28181_CHANNEL_T*)_channelPtr;
|
|
|
+ CEasyGBDDemoDlg* pThis = (CEasyGBDDemoDlg*)pChannel->userptr;
|
|
|
+
|
|
|
+ if (_frameType == EASY_SDK_VIDEO_FRAME_FLAG)
|
|
|
+ {
|
|
|
+ if (pChannel->videoCodec < 1)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("设置视频编码格式: %s\n", _frameInfo->codec == EASY_SDK_VIDEO_CODEC_H264 ? "H264" : "H265");
|
|
|
+
|
|
|
+ libGB28181Device_SetVideoFormat(pChannel->id, _frameInfo->codec, 0, 0, 0);
|
|
|
+ libGB28181Device_SetAudioFormat(pChannel->id, EASY_SDK_AUDIO_CODEC_AAC, 8000, 1, 16);
|
|
|
+
|
|
|
+ pChannel->videoCodec = _frameInfo->codec;
|
|
|
+ }
|
|
|
+
|
|
|
+ if (pChannel->sendStatus == 1)
|
|
|
+ {
|
|
|
+ if (_frameInfo->type == 0x01)
|
|
|
+ {
|
|
|
+ char* buf = (char*)pBuf;
|
|
|
+ pThis->OutputLog("推送关键帧: %d Bytes: %02X %02X %02X %02X %02X %02X %02X %02X\n", _frameInfo->length,
|
|
|
+ (unsigned char)buf[0], (unsigned char)buf[1], (unsigned char)buf[2], (unsigned char)buf[3],
|
|
|
+ (unsigned char)buf[4], (unsigned char)buf[5], (unsigned char)buf[6], (unsigned char)buf[7]);
|
|
|
+ }
|
|
|
+
|
|
|
+ libGB28181Device_AddVideoData(pChannel->id, (char*)pBuf, _frameInfo->length, _frameInfo->type);
|
|
|
+ }
|
|
|
+ }
|
|
|
+ else if (_frameType == EASY_SDK_AUDIO_FRAME_FLAG)
|
|
|
+ {
|
|
|
+ if (pChannel->sendStatus == 1)
|
|
|
+ {
|
|
|
+ libGB28181Device_AddAudioData(pChannel->id, _frameInfo->codec, (char*)pBuf, _frameInfo->length, _frameInfo->length);
|
|
|
+ }
|
|
|
+
|
|
|
+ //if (pChannel->sendStatus == 1)
|
|
|
+ //{
|
|
|
+ // if (NULL == pChannel->atcHandle)
|
|
|
+ // {
|
|
|
+ // ATC_Init(&pChannel->atcHandle, pChannel->audioOutputFormat,//TRANSCODE_AUDIO_TYPE_AAC,
|
|
|
+ // //pChannel->srcAudioCodec, frameinfo->sample_rate, 1, frameinfo->bitsPerSample);
|
|
|
+ // pChannel->srcAudioCodec, _frameInfo->sample_rate, _frameInfo->channels, _frameInfo->bits_per_sample);
|
|
|
+ // }
|
|
|
+ // if (pChannel->atcHandle)
|
|
|
+ // {
|
|
|
+ // unsigned char* dstBuf = NULL;
|
|
|
+ // int dstBufSize = 0;
|
|
|
+ // if (0 == ATC_Transcode(pChannel->atcHandle, &dstBuf, &dstBufSize, (unsigned char*)pBuf, _frameInfo->length))
|
|
|
+ // {
|
|
|
+ // //printf("Audio frame length: %d --> %d\n", frameinfo->length, dstBufSize);
|
|
|
+
|
|
|
+ // //if (NULL != pChannel->pDSPlayer)
|
|
|
+ // //{
|
|
|
+ // // pChannel->pDSPlayer->Write((char*)dstBuf, dstBufSize);
|
|
|
+ // //}
|
|
|
+
|
|
|
+ // if (pChannel->sendStatus == 1)
|
|
|
+ // {
|
|
|
+ // libGB28181Device_AddAudioData(pChannel->id, pChannel->audioOutputFormat, (char*)dstBuf, dstBufSize, dstBufSize);// dstBufSize);
|
|
|
+ // //libGB28181Device_AddAudioData(7, (char*)dstBuf, dstBufSize, dstBufSize);// dstBufSize);
|
|
|
+ // }
|
|
|
+
|
|
|
+ // //if (NULL == pChannel->fDat)
|
|
|
+ // //{
|
|
|
+ // // //pGB28181Device->fDat = fopen("1.aac", "wb");
|
|
|
+ // // pChannel->fDat = fopen("1.711u", "wb");
|
|
|
+ // //}
|
|
|
+ // //if (NULL != pChannel->fDat)
|
|
|
+ // //{
|
|
|
+ // // fwrite(pBuf, 1, _frameInfo->length, pChannel->fDat);
|
|
|
+ // //}
|
|
|
+ // }
|
|
|
+ // }
|
|
|
+
|
|
|
+ // //libGB28181Device_AddAudioData(pChannel->id, _frameInfo->codec, (char*)pBuf, _frameInfo->length, _frameInfo->length);
|
|
|
+ //}
|
|
|
+ }
|
|
|
+ else if (_frameType == EASY_SDK_EVENT_FRAME_FLAG)
|
|
|
+ {
|
|
|
+ if (_frameInfo->codec == EASY_STREAM_CLIENT_STATE_DISCONNECTED)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("当前视频源已断开!\n");
|
|
|
+ }
|
|
|
+ else if (_frameInfo->codec == EASY_STREAM_CLIENT_STATE_CONNECTED)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("当前视频源连接成功!\n");
|
|
|
+ }
|
|
|
+ else if (_frameInfo->codec == EASY_STREAM_CLIENT_STATE_EXIT)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("当前视频源已正常断开连接!\n");
|
|
|
+ }
|
|
|
+ else if (_frameInfo->codec == EASY_STREAM_CLIENT_STATE_CONNECT_FAILED)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("当前视频源连接失败!\n");
|
|
|
+ }
|
|
|
+ else if (_frameInfo->codec == EASY_STREAM_CLIENT_STATE_CONNECTING)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("当前视频源连接中...\n");
|
|
|
+ }
|
|
|
+ else if (_frameInfo->codec == EASY_STREAM_CLIENT_STATE_CONNECTED)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("当前视频源连接成功.\n");
|
|
|
+ }
|
|
|
+ else if (_frameInfo->codec == EASY_STREAM_CLIENT_STATE_CONNECT_ABORT)
|
|
|
+ {
|
|
|
+ pThis->OutputLog("当前视频源连接异常中断.\n");
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ return 0;
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+int CEasyGBDDemoDlg::Startup(const char* serverSIPId, const char* serverIP, const int serverPort,
|
|
|
+ const int reg_expires, const int heartbeatCount, const int heartbeatInterval,
|
|
|
+ const int protocol, const char* password, const char* localSIPId, const int localPort, const char* sourceURL)
|
|
|
+{
|
|
|
+ int ret = 0;
|
|
|
+
|
|
|
+ if (NULL == mGB28181Device.pChannel)
|
|
|
+ {
|
|
|
+ OutputLog("启动中...\n");
|
|
|
+
|
|
|
+ mGB28181Device.pChannel = new GB28181_CHANNEL_T[MAX_GB28181_CHANNEL_NUM];
|
|
|
+ if (mGB28181Device.pChannel)
|
|
|
+ {
|
|
|
+ memset(mGB28181Device.pChannel, 0x00, sizeof(GB28181_CHANNEL_T) * MAX_GB28181_CHANNEL_NUM);
|
|
|
+ for (int i = 0; i < MAX_GB28181_CHANNEL_NUM; i++)
|
|
|
+ {
|
|
|
+ mGB28181Device.pChannel[i].id = i;
|
|
|
+ mGB28181Device.pChannel[i].userptr = this;
|
|
|
+ strcpy(mGB28181Device.pChannel[i].sourceURL, sourceURL);// "rtsp://admin:admin12345@192.168.6.41");
|
|
|
+ }
|
|
|
+
|
|
|
+ GB28181_DEVICE_INFO_T gb28181DeviceInfo;
|
|
|
+ memset(&gb28181DeviceInfo, 0x00, sizeof(GB28181_DEVICE_INFO_T));
|
|
|
+
|
|
|
+ strcpy(gb28181DeviceInfo.server_id, serverSIPId);
|
|
|
+ memcpy(gb28181DeviceInfo.server_domain, gb28181DeviceInfo.server_id, 10);
|
|
|
+ strcpy(gb28181DeviceInfo.server_ip, serverIP);
|
|
|
+ gb28181DeviceInfo.server_port = serverPort;
|
|
|
+ gb28181DeviceInfo.reg_expires = reg_expires;
|
|
|
+ gb28181DeviceInfo.heartbeat_count = heartbeatCount;
|
|
|
+ gb28181DeviceInfo.heartbeat_interval = heartbeatInterval;
|
|
|
+ gb28181DeviceInfo.protocol = protocol; //0 - udp; 1 - tcp
|
|
|
+ strcpy(gb28181DeviceInfo.password, password);
|
|
|
+ gb28181DeviceInfo.log_enable = 1; // log enable flag
|
|
|
+ gb28181DeviceInfo.log_level = 0; // log level(0:TRACE,1:DEBUG,2:INFO,3:WARNING,4:ERROR,5:FATAL)
|
|
|
+
|
|
|
+ strcpy(gb28181DeviceInfo.device_id, localSIPId);
|
|
|
+ gb28181DeviceInfo.localSipPort = localPort;
|
|
|
+
|
|
|
+ gb28181DeviceInfo.channel_nums = MAX_GB28181_CHANNEL_NUM;
|
|
|
+ for (int i = 0; i < gb28181DeviceInfo.channel_nums; i++)
|
|
|
+ {
|
|
|
+ sprintf(gb28181DeviceInfo.channel[i].id, "%s1310%06d", gb28181DeviceInfo.server_domain, i + 1);
|
|
|
+ sprintf(gb28181DeviceInfo.channel[i].name, "ch %02d", i + 1);
|
|
|
+ strcpy(gb28181DeviceInfo.channel[i].model, "IPCamera");
|
|
|
+ sprintf(gb28181DeviceInfo.channel[i].owner, "Owner %02d", i + 1);
|
|
|
+ strcpy(gb28181DeviceInfo.channel[i].manufacturer, "Easy");
|
|
|
+ gb28181DeviceInfo.channel[i].longitude = (double)i + 100;
|
|
|
+ gb28181DeviceInfo.channel[i].latitude = (double)i + 10;
|
|
|
+ }
|
|
|
+
|
|
|
+ libGB28181Device_Create(&gb28181DeviceInfo/*为NULL则表示从当前目录下读取config.xml*/, __GB28181DeviceCALLBACK, (void*)&mGB28181Device);
|
|
|
+
|
|
|
+ for (int i = 0; i < MAX_GB28181_CHANNEL_NUM; i++)
|
|
|
+ {
|
|
|
+ if (0 == strcmp(mGB28181Device.pChannel[i].sourceURL, "\0")) continue;
|
|
|
+
|
|
|
+
|
|
|
+ EasyStreamClient_Init(&mGB28181Device.pChannel[i].streamClientHandle, 0);
|
|
|
+ EasyStreamClient_SetCallback(mGB28181Device.pChannel[i].streamClientHandle, __EasyStreamClientCallBack);
|
|
|
+ EasyStreamClient_OpenStream(mGB28181Device.pChannel[i].streamClientHandle,
|
|
|
+ mGB28181Device.pChannel[i].sourceURL, EASY_RTP_OVER_TCP, &mGB28181Device.pChannel[i], 1, 5, 1);
|
|
|
+ EasyStreamClient_SetAudioEnable(mGB28181Device.pChannel[i].streamClientHandle, 1);
|
|
|
+
|
|
|
+ //mGB28181Device.pChannel[i].audioOutputFormat = TRANSCODE_AUDIO_TYPE_G711U;// TRANSCODE_AUDIO_TYPE_G711U;
|
|
|
+
|
|
|
+ //libGB28181Device_SetVideoFormat(i, EASY_SDK_VIDEO_CODEC_H265, 0, 0, 0);
|
|
|
+ //libGB28181Device_SetAudioFormat(i, EASY_SDK_AUDIO_CODEC_AAC, 8000, 1, 16);
|
|
|
+ }
|
|
|
+
|
|
|
+ OutputLog("已启动..\n");
|
|
|
+ }
|
|
|
+ else
|
|
|
+ {
|
|
|
+ OutputLog("启动失败...\n");
|
|
|
+ ret = -1000;
|
|
|
+ return ret;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+
|
|
|
+ return ret;
|
|
|
+}
|
|
|
+void CEasyGBDDemoDlg::Shutdown()
|
|
|
+{
|
|
|
+ if (NULL == mGB28181Device.pChannel) return;
|
|
|
+
|
|
|
+ OutputLog("停止中...\n");
|
|
|
+
|
|
|
+ for (int i = 0; i < MAX_GB28181_CHANNEL_NUM; i++)
|
|
|
+ {
|
|
|
+ if (0 == strcmp(mGB28181Device.pChannel[i].sourceURL, "\0")) continue;
|
|
|
+
|
|
|
+ mGB28181Device.pChannel[i].sendStatus = 0;
|
|
|
+
|
|
|
+ EasyStreamClient_Deinit(mGB28181Device.pChannel[i].streamClientHandle);
|
|
|
+ mGB28181Device.pChannel[i].streamClientHandle = NULL;
|
|
|
+
|
|
|
+ //ATC_Deinit(&mGB28181Device.pChannel[i].atcHandle);
|
|
|
+
|
|
|
+ if (NULL != mGB28181Device.pChannel[i].fDat)
|
|
|
+ {
|
|
|
+ fclose(mGB28181Device.pChannel[i].fDat);
|
|
|
+ mGB28181Device.pChannel[i].fDat = NULL;
|
|
|
+ }
|
|
|
+ }
|
|
|
+
|
|
|
+ delete[]mGB28181Device.pChannel;
|
|
|
+ mGB28181Device.pChannel = NULL;
|
|
|
+
|
|
|
+ libGB28181Device_Release();
|
|
|
+
|
|
|
+
|
|
|
+ OutputLog("已停止.\n");
|
|
|
+}
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::OnDestroy()
|
|
|
+{
|
|
|
+ CDialogEx::OnDestroy();
|
|
|
+
|
|
|
+ Shutdown();
|
|
|
+ DeinitMutex(&mLogMutex);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
|
|
+void CEasyGBDDemoDlg::OnBnClickedButtonBrowse()
|
|
|
+{
|
|
|
+ //wchar_t szDefaultOpenPath[MAX_PATH] = { 0 };
|
|
|
+ //MByteToWChar(globalRecordingPath, szDefaultOpenPath, sizeof(szDefaultOpenPath) / sizeof(szDefaultOpenPath[0]));
|
|
|
+
|
|
|
+ CFileDialog file(TRUE, NULL, NULL, OFN_HIDEREADONLY | OFN_OVERWRITEPROMPT, L"媒体文件(*.*)|*.*||");
|
|
|
+ //file.m_ofn.lpstrInitialDir = szDefaultOpenPath;
|
|
|
+ if (file.DoModal() != IDOK) return;
|
|
|
+
|
|
|
+ //获取文件名称
|
|
|
+ file.GetFileName();
|
|
|
+ //获取文件路径,此处只想说明下file.GetPathName()的返回值类型。
|
|
|
+ CString filePath = file.GetPathName();
|
|
|
+
|
|
|
+ pEdtSourceURL->SetWindowTextW(filePath);
|
|
|
+}
|
|
|
+
|
|
|
+
|
|
|
+
|
Babosa