|
|
@@ -1,660 +0,0 @@
|
|
|
-
|
|
|
-// 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