//---------------------------------------------------------------------------
#include <vcl.h>
#include <stdio.h>
#include <stdlib.h>
#pragma hdrstop

#include "WavePlayerForm.h"
#include "Wave.h"
//---------------------------------------------------------------------------
#pragma package(smart_init)
#pragma resource "*.dfm"
TWaveForm *WaveForm;
//---------------------------------------------------------------------------
void CALLBACK   RecordCallbackProc(HWAVEIN hwi,         //In 버퍼가 꽉 찼을 경우 처리..
                        UINT uMsg,
                        DWORD dwInstance,
                        DWORD dwParam1,
                        DWORD dwParam2);

void CALLBACK   TimeProc(UINT uID,
                        UINT uMsg,
                        DWORD dwUser,
                        DWORD dw1,
                        DWORD dw2);
//---------------------------------------------------------------------------
__fastcall TWaveForm::TWaveForm(TComponent* Owner)
    : TForm(Owner)
{
    m_BufferCount = 0;
    m_DSBufferCount = 0;
    m_playCount = 0;
}
//---------------------------------------------------------------------------
void TWaveForm::InitPriamy(HWND hwnd)
{
    HRESULT hr;
    hr = DirectSoundCreate(NULL, &m_pDSound, NULL);
    if(FAILED(hr))
    {
        ShowMessage("별거 아닌 다이랙트 사운드 실패 ㅡㅡ;");
        return;
    }

    if(FAILED(hr = m_pDSound->SetCooperativeLevel(hwnd, DSSCL_NORMAL)))
    {
        ShowMessage("협력 래벨 설정...");
        return ;
    }

    ZeroMemory(&m_desdPrimary, sizeof(DSBUFFERDESC));
    m_desdPrimary.dwSize = sizeof(DSBUFFERDESC);
    m_desdPrimary.dwFlags = DSBCAPS_PRIMARYBUFFER;

    if(FAILED(hr = m_pDSound->CreateSoundBuffer(&m_desdPrimary, &m_pDSBPrimary, NULL)))
    {
        ShowMessage("첫번째 버퍼 를 만들다 실패");
        return;
    }
}
//---------------------------------------------------------------------------
void TWaveForm::InitSecond()
{
    WAVEFORMATEX wf;                                            //웨이브 파일 재생을 위한 포맷
    PVOID pMem;
    DWORD dwSize;

    wf.wFormatTag = WAVE_FORMAT_PCM;
    wf.nChannels  = 1L;
    wf.wBitsPerSample	= 16;
    wf.nSamplesPerSec = 8000L;
    wf.nAvgBytesPerSec = 16000L;
    wf.nBlockAlign = 2L;

    //2번째 버퍼를 만들기위해 DSBUFFERDESC 샛팅
    m_desdSecond.dwSize = sizeof(DSBUFFERDESC);
    m_desdSecond.dwFlags = DSBCAPS_CTRLPOSITIONNOTIFY           //포지션 통보방식 사용
                        | DSBCAPS_GETCURRENTPOSITION2;          //스트리밍 버퍼 사용

	m_desdSecond.dwBufferBytes = MAXNUMOFBUFFER*BUFFER_SIZE;    //버퍼 사이즈
    m_desdSecond.lpwfxFormat = (tWAVEFORMATEX*)&wf;
    if(FAILED(m_pDSound->CreateSoundBuffer(&m_desdSecond, &m_pDSBSecond, NULL)))
    {
        ShowMessage("두번째꺼 만들기 실패...");
        return;
    }
    //데이터를 읽어 들이기 위해서
    for(int i = 0 ; i < 2 ; i++)
    {
        if(FAILED(m_pDSBSecond->Lock(BUFFER_SIZE*i, BUFFER_SIZE, &pMem, &dwSize, 0, 0, 0)))
        {
            ShowMessage("락이 안걸림");
            return;
        }

        m_DSBufferCount++;
        memcpy(pMem, PlayBuf.Data[m_playCount++], BUFFER_SIZE);

        if(m_playCount == MAXNUMOFBUFFER)
            m_playCount = 0;

        if(m_DSBufferCount == MAXNUMOFBUFFER)
            m_DSBufferCount = 0;

        if(FAILED(m_pDSBSecond->Unlock( pMem, dwSize, 0, 0)))
        {
            ShowMessage("락 해제안된다.. ㅜ.ㅜ");
            return;
        }
    }
}
//---------------------------------------------------------------------------
void TWaveForm::PlaySound()
{
    m_pDSBPrimary->Play(PlayBuf.Data[0][0], 0, SND_ASYNC);
//    m_pDSBPrimary->Play(0, 0, DSBPLAY_LOOPING);
//    m_pDSBSecond->Play(0, 0, DSBPLAY_LOOPING);
    //ShowMessage("ff");
}
//---------------------------------------------------------------------------
void CALLBACK   TimeProc(UINT uID,
                        UINT uMsg,
                        DWORD dwUser,
                        DWORD dw1,
                        DWORD dw2)
{
    PVOID pMem;
    DWORD dwSize;

    if(WaveForm->m_DSBufferCount == MAXNUMOFBUFFER)
        WaveForm->m_DSBufferCount = 0;

    if(WaveForm->m_playCount == MAXNUMOFBUFFER)
        WaveForm->m_playCount = 0;

    if(FAILED(WaveForm->m_pDSBSecond->Lock(BUFFER_SIZE* WaveForm->m_DSBufferCount,
                                            BUFFER_SIZE, &pMem, &dwSize, 0, 0, 0)))
    {
        ShowMessage("타이머 락이 안걸림");
        return;
    }

    WaveForm->m_DSBufferCount++;
    memcpy(pMem, WaveForm->PlayBuf.Data[WaveForm->m_playCount++], BUFFER_SIZE);

    if(FAILED(WaveForm->m_pDSBSecond->Unlock( pMem, dwSize, 0, 0)))
    {
        ShowMessage("타이머 락 해제안된다.. ㅜ.ㅜ");
        return;
    }
}
//---------------------------------------------------------------------------
void TWaveForm::SocketPlaySound(BYTE* pWaveIn)
{
   memset( PlayBuf.Data[PlayBuf.Count], 0x00, BUFFER_SIZE );
   memcpy(PlayBuf.Data[PlayBuf.Count++], pWaveIn , BUFFER_SIZE);

   if(PlayBuf.Count == MAXNUMOFBUFFER) PlayBuf.Count = 0;

   if(PlayBuf.Count == 2 && WaveForm->m_StartFlag == false)
   {
      WaveForm->m_StartFlag = true;
      InitPriamy(WavePlayerMainForm->Handle);
      InitSecond();
      PlaySound();
   }
}
//---------------------------------------------------------------------------
void TWaveForm::SocketPlayStop()
{
    m_pDSBSecond->Stop();
    m_pDSBSecond->Release();
    m_pDSBPrimary->Release();
    m_pDSound->Release();
    m_DSBufferCount = 0;
    m_playCount = 0;
    m_StartFlag = true;
    PlayBuf.Count = 0;
}
//---------------------------------------------------------------------------
/*
   ARS Demo System 구축
   JCT 보드
   엔진 : SL-2
   스택스 011-595-7577 김태식 이사
   5/3 오전 10:30에 미팅 기간 10일
*/
//대전시 유성구 구성동 21번지 금강환경관리청내 중부권 관제 관리팀(환경관리공단)
//신문호