#include "numberprocessor.h"
#include "numberreg.h"

NumberProcessor::NumberProcessor(QList<QString> *bufferSegments, QList<QStringList> *bufferNumbers,
                                 QSemaphore *free, QSemaphore *used, QMutex *mutex,
                                 NumberProcessType processType)
{
    this->bufferSegments = bufferSegments;
    this->bufferNumbers = bufferNumbers;
    this->free = free;
    this->used = used;
    this->mutex = mutex;
    this->processType = processType;
    this->stop = false;
}
void NumberProcessor::abort()
{
    this->stop = true;
}
NumberProcessor::~NumberProcessor()
{
    qDebug()<<"NumberProcessor dead";
}
void NumberProcessor::setBlackSegments(QStringList blackSegments)
{
    this->blackSegments = blackSegments;
}
void NumberProcessor::setBlackNumbers(QList<QStringList> blackNumbers)
{
    this->blackNumbers = blackNumbers;
}
void NumberProcessor::run()
{
    switch(processType)
    {
        case NumberSort:
            sort();
            break;
        case NumberRemoveDuplicate:
            removeDuplicate();
            break;
        case NumberRemoveBlackList:
            removeBlackList();
            break;
        case NumberRemoveNotPhone:
            removeNotPhoneNumber();
            break;
        default:
            break;
    }
}
void NumberProcessor::sort()
{
    while(true)
    {
        //used->acquire();
        if(stop)
        {
            break;
        }
        mutex->lock();
        QString segment;
        QStringList numbers;
        if(bufferSegments->size()>0)
        {
            segment = bufferSegments->takeLast();
            numbers = bufferNumbers->takeLast();
        }
        mutex->unlock();
        //free->release();
        if(!segment.isEmpty())
        {
            numbers.sort();
            emit childTaskFinished(segment,numbers);
        }
    }
    emit threadDestroy();
}
void NumberProcessor::removeDuplicate()
{
    while(true)
    {

        //used->acquire();
        if(stop)
        {
            break;
        }
        mutex->lock();
        QString segment;
        QStringList numbers;
        if(bufferSegments->size()>0)
        {
            segment = bufferSegments->takeLast();
            numbers = bufferNumbers->takeLast();
        }
        mutex->unlock();
        //free->release();
        if(!segment.isEmpty())
        {
            numbers.sort();
            QStringList list;
            QString tmp;
            for(int j=0;j<numbers.size();j++)
            {
                if (tmp != numbers[j])
                {
                    tmp = numbers[j];
                    list.append(tmp);
                }
            }
            numbers = list;
            emit childTaskFinished(segment,numbers);
        }
    }
    emit threadDestroy();
}
void NumberProcessor::removeBlackList()
{
    while(true)
    {        

        //used->acquire();
        if(stop)
        {
            break;
        }
        mutex->lock();
        QString segment;
        QStringList numbers;
        if(bufferSegments->size()>0)
        {
            segment = bufferSegments->takeLast();
            numbers = bufferNumbers->takeLast();
        }
        mutex->unlock();
        //free->release();
        if(!segment.isEmpty())
        {
            for(int j=0;j<blackSegments.size();j++)
            {
                if(segment==blackSegments.at(j))
                {
                    for(int k=0;k<numbers.size();k++)
                    {
                        for(int l=0;l<blackNumbers.at(j).size();l++)
                        {
                            if(numbers.at(k)==blackNumbers.at(j).at(l))
                            {
                                numbers.removeAt(k);
                                k--;
                                break;
                            }
                        }
                    }
                    break;
                }
            }
            if(numbers.size()==0)
            {
                segment = "";
            }
            emit childTaskFinished(segment,numbers);
        }
    }
    emit threadDestroy();
}
void NumberProcessor::removeNotPhoneNumber()
{
    while(true)
    {

        //used->acquire();
        if(stop)
        {
            break;
        }
        mutex->lock();
        QString segment;
        QStringList numbers;
        if(bufferSegments->size()>0)
        {
            segment = bufferSegments->takeLast();
            numbers = bufferNumbers->takeLast();
        }
        mutex->unlock();
        //free->release();
        if(!segment.isEmpty())
        {
            if(!NumberReg::getSegmentReg().exactMatch(segment))
            {
                segment = "";
            }
            else
            {
                for(int i=0;i<numbers.size();i++)
                {
                    if (!NumberReg::getLastFour().exactMatch(numbers[i]))
                    {
                        numbers.removeAt(i);
                        i++;
                    }
                }
                if(numbers.size()==0)
                {
                    segment = "";
                }
            }
            emit childTaskFinished(segment,numbers);
        }
    }
    emit threadDestroy();
}