#include <logger.h>
#include "TeleWrapper.h"

extern "C" {
#include "serial.h"
}

bool TeleWrapper::start()
{
    LOG_INFO << "TeleWrapper::start" << LOG_ENDL;

    fd = serialOpen(PORT, BAUD);

    running = true;
    pthread_mutex_init(&mutex, NULL); // 初始化互斥对象,动态加锁
    cond = PTHREAD_COND_INITIALIZER;
    int ret = pthread_create(&tel_thid, NULL, TeleWrapper::tel_thd, this);

    if(ret != 0)
    {
        LOGP(ERROR, "pthread_create: %s/n", strerror(ret));
        running = false;
        return false;
    }

    return true;

}

void TeleWrapper::stop()
{
    LOG_INFO << "TeleWrapper::stop" << LOG_ENDL;

    if (!running)
        return;

    running = false;
    pthread_join(tel_thid, NULL);//阻塞线程，等待线程
    pthread_mutex_destroy(&mutex);

    serialClose(fd);
}





void TeleWrapper::popTask()
{

    TeleTask curTask = telQueue.front();
    telQueue.pop();
    switch(curTask.command)
    {
        case TeleTask::CALL: //打电话
            callNum(curTask.param);
            break;
        case TeleTask::HANGUP:
            //  挂机
            hang();
            break;
    }
}
void TeleWrapper::pushTask(TeleTask task)
{
    telQueue.push(task);
    pthread_mutex_unlock(&mutex);
    //pthread_cond_signal(&cond);
    //pthread_mutex_lock(&mutex);
    //thread_resume(); //唤醒线程
}

void * TeleWrapper::tel_thd(void *arg)  //线程函数
{
    LOG_INFO << "TeleWrapper::tel_thd start" << LOG_ENDL;

    TeleWrapper& teleWrapper = *(TeleWrapper*)arg;
    while(teleWrapper.running)
    {
        if(teleWrapper.telQueue.empty())
            pthread_mutex_lock(&teleWrapper.mutex);

        if(teleWrapper.telQueue.empty())
            continue;

        teleWrapper.popTask();
    }

    pthread_mutex_unlock(&teleWrapper.mutex);
    LOG_INFO << "TeleWrapper::tel_thd stop" << LOG_ENDL;
}

void TeleWrapper::callNum(char phone)
{
    switch (phone)
    {
        case '1':
            serialWriteString(fd, "DA");//1
            break;
        case '2':
            serialWriteString(fd, "DB");//2
            break;
        case '3':
            serialWriteString(fd, "DC");//3
            break;
        case '4':
            serialWriteString(fd, "DD");//4
            break;
        case '5':
            serialWriteString(fd, "DE");//5
            break;
        case '6':
            serialWriteString(fd, "DF");//6
            break;
        case '7':
            serialWriteString(fd, "DG");//7
            break;
        case '8':
            serialWriteString(fd, "DH");//8
            break;
        case '9':
            serialWriteString(fd, "DI");//9
            break;
        case '0':
            serialWriteString(fd, "DJ");//0
            break;
    }
}

void TeleWrapper::callNum(const std::string phone)
{

    serialWriteString(fd, "BA");
    serialWriteString(fd, "AA");//摘机
    sleep(1);
    const char* _phone = phone.c_str();
    while (*_phone)
    {
        sleep(1);
        callNum(*(_phone++));
    }
}

void TeleWrapper::hang()
{
    sleep(40);
    serialWriteString(fd, "BA");
}