/************************************************************************
|
* Copyright 2009-2011 Hikvision Digital Technology Co., Ltd.
|
* FileName : audiotransfer.cpp
|
* Description : audio transfer
|
* Modification History : none
|
* Version : V1.0
|
* Time : 2009-11,12
|
* Author : wanggongpu
|
* Descrp :
|
*************************************************************************/
|
#include "audiotransfer.h"
|
#include <QFileDialog>
|
#include <QDir>
|
#include <QMessageBox>
|
#include "DemoPublic.h"
|
|
#include "qtclientdemo.h"
|
extern QtClientDemo* gqtclinetdemo;
|
|
#ifndef _WIN32
|
extern unsigned int seg_isram;
|
#endif
|
/*****************************************************************************
|
*
|
* Routines to determine byte order (of this machine) and swap bytes
|
*
|
*****************************************************************************/
|
|
|
|
|
|
enum byte_order { order_unknown, order_bigEndian, order_littleEndian };
|
|
static enum byte_order DetermineByteOrder (void)
|
{
|
char s[sizeof (long) + 1];
|
union
|
{
|
long longval;
|
char charval[sizeof (long)];
|
} probe;
|
probe.longval = 0x41424344L; /* ABCD in ASCII */
|
strncpy (s, probe.charval, sizeof (long));
|
s[sizeof (long)] = '\0';
|
/* fprintf( stderr, "byte order is %s\n", s ); */
|
|
if (strcmp (s, "ABCD") == 0)
|
return order_bigEndian;
|
else if (strcmp (s, "DCBA") == 0)
|
return order_littleEndian;
|
else
|
return order_unknown;
|
}
|
|
static void SwapBytesInWords (short *loc, int words)
|
{
|
int i;
|
short thisval;
|
char *dst, *src;
|
src = (char *) &thisval;
|
for (i = 0; i < words; i++)
|
{
|
thisval = *loc;
|
dst = (char *) loc++;
|
dst[0] = src[1];
|
dst[1] = src[0];
|
}
|
}
|
|
|
|
|
/*****************************************************************************
|
*
|
* Read in specified number of samples
|
*
|
*****************************************************************************/
|
|
int wave_get_samples (wave_info_t *wave_info, short int pcm[], int numSamples)
|
{
|
int samples_read;
|
FILE *file = wave_info->soundfile;
|
|
samples_read = fread (pcm, sizeof(short int), numSamples, file);
|
|
/*if(samples_read < numSamples)
|
{
|
fseek(file, 0, SEEK_SET);
|
samples_read = fread (pcm, sizeof(short int), numSamples, file);
|
}*/
|
|
if (wave_info->byteswap)
|
{
|
SwapBytesInWords (pcm, samples_read);
|
}
|
|
return (samples_read/wave_info->channels);
|
}
|
|
|
|
|
/*****************************************************************************
|
*
|
* parse the wave header.
|
* returns NULL if not open failed
|
* returns a wave_info_t * if wave header successfully parsed.
|
* needs to fill in : samplerate + channels
|
*
|
* POST: wave_info->soundfile is set to be at the start of the
|
* PCM audio data
|
*
|
*****************************************************************************/
|
|
wave_info_t *wave_init (char *inPath, WaveFileHeader *waveheader)
|
{
|
unsigned char wave_header_buffer[40]; //HH fixed
|
int wave_header_read = 0;
|
int wave_header_stereo = -1;
|
int wave_header_16bit = -1;
|
unsigned long samplerate;
|
enum byte_order NativeByteOrder = order_unknown;
|
|
|
wave_info_t *wave_info = NULL;
|
FILE *file;
|
|
if ( (file = fopen(inPath, "rb"))==NULL)
|
{
|
DebugPrint("WAV: cannot open input file: %s\n", inPath);
|
return(NULL);
|
}
|
|
|
/************** WAVE ************************/
|
/* Nick Burch <The_Leveller@newmail.net> */
|
/********************************************/
|
/* Wave File Headers: (Dec) */
|
/* 8-11 = "WAVE" */
|
/* 22 = Stereo / Mono */
|
/* 01 = mono, 02 = stereo */
|
/* 24 = Sampling Frequency */
|
/* 32 = Data Rate */
|
/* 01 = x1 (8bit Mono) */
|
/* 02 = x2 (8bit Stereo or */
|
/* 16bit Mono) */
|
/* 04 = x4 (16bit Stereo) */
|
/********************************************/
|
fread(waveheader,1 , sizeof(WaveFileHeader),file);
|
fseek (file, 0, SEEK_SET);
|
fread (wave_header_buffer, 1, 40, file);
|
|
if (wave_header_buffer[8] == 'W' && wave_header_buffer[9] == 'A'
|
&& wave_header_buffer[10] == 'V' && wave_header_buffer[11] == 'E')
|
{
|
DebugPrint("Parsing Wave File Header\n");
|
if (NativeByteOrder == order_unknown)
|
{
|
NativeByteOrder = DetermineByteOrder ();
|
if (NativeByteOrder == order_unknown)
|
{
|
DebugPrint ("byte order not determined\n");
|
fclose(file); return(NULL);
|
}
|
}
|
|
if (NativeByteOrder == order_littleEndian)
|
{
|
#ifdef _WIN32
|
samplerate = *(unsigned long *) (&wave_header_buffer[24]);
|
#else
|
samplerate = *(unsigned int *) (&wave_header_buffer[24]);
|
#endif
|
}
|
else
|
{
|
samplerate = wave_header_buffer[27] +
|
(wave_header_buffer[26] << 8) +
|
(wave_header_buffer[25] << 16) + (wave_header_buffer[24] << 24);
|
}
|
|
/* Wave File */
|
wave_header_read = 1;
|
switch (samplerate)
|
{
|
case 44100:
|
case 48000:
|
case 32000:
|
case 24000:
|
case 22050:
|
case 16000:
|
DebugPrint (">>> %ld Hz sampling freq selected\n", samplerate);
|
break;
|
default:
|
/* Unknown Unsupported Frequency */
|
DebugPrint (">>> Unknown samp freq %ld Hz in Wave Header\n",
|
samplerate);
|
DebugPrint (">>> Default 44.1 kHz samp freq selected\n");
|
samplerate = 44100;
|
break;
|
}
|
|
if ((long) wave_header_buffer[22] == 1)
|
{
|
DebugPrint (">>> Input Wave File is Mono\n");
|
wave_header_stereo = 0;
|
}
|
if ((long) wave_header_buffer[22] == 2)
|
{
|
DebugPrint (">>> Input Wave File is Stereo\n");
|
wave_header_stereo = 1;
|
}
|
|
if ((long) wave_header_buffer[32] == 1)
|
{
|
DebugPrint (">>> Input Wave File is 8 Bit\n");
|
wave_header_16bit = 0;
|
DebugPrint("Input File must be 16 Bit! Please Re-sample");
|
fclose(file); return(NULL);
|
}
|
if ((long) wave_header_buffer[32] == 2)
|
{
|
if (wave_header_stereo == 1)
|
{
|
DebugPrint(">>> Input Wave File is 8 Bit\n");
|
wave_header_16bit = 0;
|
DebugPrint("Input File must be 16 Bit! Please Re-sample");
|
fclose(file); return(NULL);
|
}
|
else
|
{
|
fprintf(stderr, ">>> Input Wave File is 16 Bit\n" );
|
wave_header_16bit = 1;
|
}
|
}
|
|
if ((long) wave_header_buffer[32] == 4)
|
{
|
/* fprintf(stderr, ">>> Input Wave File is 16 Bit\n" ); */
|
wave_header_16bit = 1;
|
}
|
|
/* should probably use the wave header to determine size here FIXME MFC Feb 2003 */
|
if (fseek (file, 44, SEEK_SET) != 0)
|
{
|
/* there's a way of calculating the size of the
|
wave header. i'll just jump 44 to start with */
|
DebugPrint( "Could not seek to PCM sound data in \"%s\".\n", inPath);
|
fclose(file); return(NULL);
|
}
|
|
// Successfully processed the wave header
|
wave_info = (wave_info_t *)calloc(1, sizeof(wave_info_t));
|
wave_info->soundfile = file;
|
if (wave_header_stereo == 1)
|
wave_info->channels = 2;
|
else
|
wave_info->channels = 1;
|
|
wave_info->samplerate = samplerate;
|
|
// UNKNOWN. But we really should be able to work
|
// it out. FIX THIS. MFC May03.
|
wave_info->num_samples = -1;
|
|
// Enable byte swap for big endian machines
|
if (NativeByteOrder == order_bigEndian)
|
wave_info->byteswap = 1;
|
else wave_info->byteswap = 0;
|
|
return(wave_info);
|
}
|
|
// not a wave file
|
fclose(file);
|
return(NULL);
|
}
|
|
|
/************************************************************************
|
* Function : AudioTransfer
|
* Description : instructor
|
* Input : none
|
* Output : none
|
* Return : none
|
*************************************************************************/
|
AudioTransfer::AudioTransfer(QList<DeviceData> * tree,QDialog *parent)
|
: QDialog(parent)
|
{
|
ui.setupUi(this);
|
m_qlistdevicetree =tree;
|
|
for (int j=0;j<256;j++)
|
{
|
m_atuserid[j]=-1;
|
}
|
QList<DeviceData>::iterator it;
|
int i=0;
|
for ( it = (*m_qlistdevicetree).begin(); it != (*m_qlistdevicetree).end(); ++it)
|
{
|
if ((*it).getUsrID()>=0)
|
{
|
m_atuserid[i]=(*it).getUsrID();//iºÍindexÒ»Ò»¶ÔÓ¦
|
i++;
|
items.append(new QTreeWidgetItem((QTreeWidget*)0,
|
QStringList((*it).getDeviceName())));
|
}
|
}
|
ui.treeWidget->insertTopLevelItems(0, items);
|
|
connect(ui.treeWidget,SIGNAL(itemClicked(QTreeWidgetItem *,
|
int)),this,SLOT(audioTransferDevice(QTreeWidgetItem *, int)));
|
m_atindex = 0;
|
m_talkmrhandle = -1;
|
m_encodehandle = NULL;
|
|
}
|
|
|
|
/************************************************************************
|
* Function : ~AudioTransfer
|
* Description : destructor
|
* Input : none
|
* Output : none
|
* Return : none
|
*************************************************************************/
|
AudioTransfer::~AudioTransfer()
|
{
|
|
}
|
|
void AudioTransfer::audioTransferDevice(QTreeWidgetItem * item, int column)
|
{
|
QList<DeviceData>::iterator it;
|
int i=0;
|
for ( it = (*m_qlistdevicetree).begin(),i=0; it != (*m_qlistdevicetree).end();
|
++it)
|
{
|
|
if ((*it).getDeviceName()==item->text(column))
|
{
|
m_atindex =i;
|
break;
|
}
|
if ((*it).getUsrID()>=0)
|
{
|
i++;
|
}
|
|
}
|
|
}
|
|
void AudioTransfer::on_pushButton_browse_clicked()
|
{
|
QString directory = QFileDialog::getOpenFileName(this,\
|
tr("Find Update Files DIR and Filename"), QDir::currentPath());
|
if (!directory.isEmpty())
|
{
|
ui.lineEdit_sendfilepath->insert(directory);
|
}
|
return;
|
|
}
|
|
/*******************************************************************
|
Function: fVoiceDataCallBack
|
Description: ÓïÒôת·¢»Øµ÷º¯Êý£¬ÓÃÓÚ»ñÈ¡É豸µÄÓïÒôÊý¾Ý
|
Parameter: (IN) int lVoiceComHandle
|
(IN) char *pRecvDataBuffer
|
(IN) unsigned int dwBufSize
|
(IN) unsigned char byAudioFlag
|
(IN) void *pUser
|
Return: HPR_OK--³É¹¦£¬HPR_ERROR--ʧ°Ü¡£ HPR_OK--³É¹¦£¬HPR_ERROR--ʧ°Ü¡£
|
**********************************************************************/
|
void __stdcall fVoiceDataCallBack(LONG lVoiceComHandle, char *pRecvDataBuffer, DWORD dwBufSize, BYTE byAudioFlag, void *pUser)
|
{
|
//´æÈë±í¸ñ
|
QString currentdatetime = QDateTime::currentDateTime().toString(" yyyy-MM-dd hh:mm:ss");
|
QString datastring = QString(QLatin1String(pRecvDataBuffer));
|
QString handle = QString::number(lVoiceComHandle);
|
QString totalsize = QString::number(dwBufSize);
|
QString audioflag = QString::number(int(byAudioFlag));
|
QString userinfo = QString((char *)pUser);
|
|
if (gqtclinetdemo->m_audiotransfer!=NULL)
|
{
|
QTableWidgetItem *currnettime = new QTableWidgetItem(currentdatetime);
|
QTableWidgetItem *handleitem = new QTableWidgetItem(handle);
|
QTableWidgetItem *sizeitem = new QTableWidgetItem(totalsize);
|
QTableWidgetItem *flagitem = new QTableWidgetItem(audioflag);
|
QTableWidgetItem *usrinfoitem = new QTableWidgetItem(userinfo);
|
int row = gqtclinetdemo->m_audiotransfer->ui.tableWidget->rowCount();
|
gqtclinetdemo->m_audiotransfer->ui.tableWidget->insertRow(row);
|
gqtclinetdemo->m_audiotransfer->ui.tableWidget->setItem(row, 0, currnettime);
|
gqtclinetdemo->m_audiotransfer->ui.tableWidget->setItem(row, 1, handleitem);
|
gqtclinetdemo->m_audiotransfer->ui.tableWidget->setItem(row, 2, sizeitem);
|
gqtclinetdemo->m_audiotransfer->ui.tableWidget->setItem(row, 3, flagitem);
|
gqtclinetdemo->m_audiotransfer->ui.tableWidget->setItem(row, 4, usrinfoitem);
|
}
|
|
//Send data to device after getting data.
|
char pSendData[80];
|
memset(pSendData, 0, 80);
|
NET_DVR_VoiceComSendData(lVoiceComHandle, pSendData, 80);
|
}
|
|
/*******************************************************************
|
Function: AudioTransfer::on_pushButton_startmr_clicked
|
Description: ¿ªÊ¼ÓïÒôת·¢btn
|
Parameter: (IN) ÎÞ²ÎÊý
|
Return: ÎÞ
|
**********************************************************************/
|
void AudioTransfer::on_pushButton_startmr_clicked()
|
{
|
m_talkmrhandle = NET_DVR_StartVoiceCom_MR_V30(m_atuserid[m_atindex],1,fVoiceDataCallBack,0);
|
|
if (m_talkmrhandle < 0)
|
{
|
QMessageBox::information(this,tr("NET_DVR_StartVoiceCom_MR_V30 error"),
|
tr("m_atindex=%1 m_atuserid[m_atindex]=%2").arg(m_atindex).arg(m_atuserid[m_atindex]));
|
|
}
|
else
|
{
|
QMessageBox::information(this,tr("NET_DVR_StartVoiceCom_MR_V30 SUCC"),
|
tr("NET_DVR_StartVoiceCom_MR_V30 SUCC"));
|
ui.pushButton_startmr->setDisabled(1);
|
ui.pushButton_stopmr->setDisabled(0);
|
}
|
|
}
|
void AudioTransfer::on_pushButton_stopmr_clicked()
|
{
|
if (!NET_DVR_StopVoiceCom(m_talkmrhandle))
|
{
|
QMessageBox::information(this,tr("NET_DVR_StopVoiceCom error"),
|
tr("lasterror=%1").arg(NET_DVR_GetLastError()));
|
}
|
else
|
{
|
QMessageBox::information(this,tr("NET_DVR_StopVoiceCom SUCC"),
|
tr("NET_DVR_StopVoiceCom SUCC"));
|
ui.pushButton_stopmr->setDisabled(1);
|
ui.pushButton_startmr->setDisabled(0);
|
}
|
|
}
|
|
void AudioTransfer::on_pushButton_talkmrsend_clicked()
|
{
|
m_encodehandle = NET_DVR_InitG722Encoder();
|
|
if (m_encodehandle == (void*)-1)
|
{
|
QMessageBox::information(this,tr("NET_DVR_InitG722Encoder error"),
|
tr("LAST_ERROR=%1").arg(NET_DVR_GetLastError()));
|
|
}
|
else
|
{
|
QMessageBox::information(this,tr("NET_DVR_InitG722Encoder SUCC"),
|
tr("NET_DVR_InitG722Encoder SUCC"));
|
}
|
|
wave_info_t* para = (wave_info_t*)malloc(sizeof(wave_info_t));
|
WaveFileHeader header;
|
short int pcmdata[640];
|
int i;
|
para = wave_init(ui.lineEdit_sendfilepath->text().toLatin1().data(), &header);
|
|
if ((para->channels!=1)&&(para->samplesize!=16)&&(para->samplerate!=16000))
|
{
|
printf("the file is not correct for its parameters!\n");
|
QMessageBox::information(this,tr("ÒôƵÎļþ´íÎó"),
|
tr("ÒôƵÎļþ²ÎÊý´íÎó"));
|
return ;
|
}
|
unsigned char sendcontent[80]={0};
|
|
//int time =header.length/1280;
|
//while (time>0)
|
//{
|
i=wave_get_samples(para,pcmdata,640);
|
//printf("time=%d\n",time);
|
|
if (!NET_DVR_EncodeG722Frame(m_encodehandle, (unsigned char*)pcmdata, sendcontent))
|
{
|
QMessageBox::information(this,tr("NET_DVR_EncodeG722Frame error"),
|
tr("lasterror=%1").arg(NET_DVR_GetLastError()));
|
}
|
else
|
{
|
QMessageBox::information(this,tr("NET_DVR_EncodeG722Frame SUCC"),
|
tr("NET_DVR_EncodeG722Frame SUCC"));
|
}
|
|
|
if (!NET_DVR_VoiceComSendData(m_talkmrhandle,(char*)sendcontent,80))
|
{
|
QMessageBox::information(this,tr("NET_DVR_VoiceComSendData error"),
|
tr("lasterror=%1").arg(NET_DVR_GetLastError()));
|
}
|
else
|
{
|
|
}
|
//usleep(40000);
|
//time -- ;
|
//}
|
NET_DVR_ReleaseG722Encoder(m_encodehandle);
|
QMessageBox::information(this,tr("NET_DVR_VoiceComSendData SUCC"),
|
tr("NET_DVR_VoiceComSendData SUCC"));
|
}
|
|
|
|
/************************************************************************
|
* Function : on_pushButton_exit_clicked
|
* Description : Í˳ö½çÃæ
|
* Input : none
|
* Output : none
|
* Return : none
|
*************************************************************************/
|
void AudioTransfer::on_pushButton_exit_clicked()
|
{
|
close();
|
}
|
|
