clients/FilterProcess/sfilterprocess.cpp

#include <QString>
#include <iostream>
#include "sfilteralgorithm.h"
#include "sfilterprocess.h"
#include "shttpsender.h"
#include "../Json/sjson.h"
#include <QDebug>
#include <QSqlDatabase>
using namespace std;

bool SFilterProcess::init(QString _strFilterProcessGroupID, QString _strFilterProcessGroupName)
{
    if (!m_SInitializer.init(_strFilterProcessGroupID, _strFilterProcessGroupName))
    {
        cout << "initializer init error" << endl;
        return false;
    }

    m_SDatagroup.setInitializer(m_SInitializer);
    m_SConsumer.setInitiaizer(m_SInitializer);
    m_SInfluencer.setInitiaizer(m_SInitializer);
    m_SSpammer.setInitiaizer(m_SInitializer);
    m_SPowercafe.setInitiaizer(m_SInitializer);
    m_SConsumerMarketer.setInitiaizer(m_SInitializer);
    m_SConsumerCheckList.setInitiaizer(m_SInitializer);
    m_SInitializer.closeConnection(SDBManager::E_DATABASE_WEB);
    return true;
}

bool SFilterProcess::init(QString _strFilterProcessGroupID, QString _strFilterProcessGroupName, QString _strInfluencerLimit)
{
    if (!m_SInitializer.init(_strFilterProcessGroupID, _strFilterProcessGroupName, _strInfluencerLimit))
    {
        cout << "initializer init error" << endl;
        return false;
    }

    m_SDatagroup.setInitializer(m_SInitializer);
    m_SConsumer.setInitiaizer(m_SInitializer);
    m_SInfluencer.setInitiaizer(m_SInitializer);
    m_SSpammer.setInitiaizer(m_SInitializer);
    m_SPowercafe.setInitiaizer(m_SInitializer);
    m_SConsumerMarketer.setInitiaizer(m_SInitializer);
    m_SConsumerCheckList.setInitiaizer(m_SInitializer);
    m_SInitializer.closeConnection(SDBManager::E_DATABASE_WEB);
    return true;
}

bool SFilterProcess::run()
{
    m_SInitializer.insertLog("New Filter start");
    QList<SInitializer::stFilterProcess> listFilterProcess = m_SInitializer.getFilterProcess();
    foreach (SInitializer::stFilterProcess process, listFilterProcess)
    {
        switch(process.m_nFilterProcessType)
        {
        case E_PROCSS_TYPE_LOAD:
        {
            m_SDatagroup.loadData(process.m_nDatagroupID);
            break;
        }
        case E_PROCSS_TYPE_CATEGORY_MAKE:
        {
            m_SInitializer.insertDebugLog("FilterGroupName: " + process.m_strFilterGroupName);
            switch(process.m_nServiceNum)
            {
            case E_SERVICE_INFLUENCER:
            {
                qDebug() << "Influencer:" << process.m_nCategoryNum;
                m_SInfluencer.makeCategory(m_SDatagroup, process.m_nCategoryNum, m_SInitializer.getFilterGroup(process.m_nFilterGroupID));
                break;
            }
            case E_SERVICE_CONSUMER:
            {
                qDebug() << "Consumer:" << process.m_nCategoryNum;
                m_SConsumer.makeCategory(m_SDatagroup, process.m_nCategoryNum, m_SInitializer.getFilterGroup(process.m_nFilterGroupID));
                break;
            }
            case E_SERVICE_SPAMMER:
            {
                qDebug() << "Spammer:" << process.m_nCategoryNum;
                m_SSpammer.makeCategory(m_SDatagroup, process.m_nCategoryNum, m_SInitializer.getFilterGroup(process.m_nFilterGroupID));
                break;
            }
            case E_SERVICE_POWERCAFE:
            {
                qDebug() << "Powercafe:" << process.m_nCategoryNum;
                m_SPowercafe.makeCategory(m_SDatagroup, process.m_nCategoryNum, m_SInitializer.getFilterGroup(process.m_nFilterGroupID));
                break;
            }
            }

            break;
        }
        case E_PROCSS_TYPE_SEND:
        {
            m_SConsumerMarketer.makeTable(m_SDatagroup);
            m_SConsumerCheckList.makeTable(m_SDatagroup);
            m_SDatagroup.makeTable();

            m_SConsumer.makeTable(m_SDatagroup);
            m_SInfluencer.makeTable(m_SDatagroup);
            m_SSpammer.makeTable(m_SDatagroup);
            m_SPowercafe.makeTable(m_SDatagroup);

            if (m_SInitializer.isUpload())
            {
                m_SInitializer.openConnection(SDBManager::E_DATABASE_WEB);
                m_SDatagroup.uploadData(process.m_nCompanyNum);
                m_SConsumer.uploadData(process.m_nCompanyNum);
                m_SInfluencer.uploadData(process.m_nCompanyNum);
                m_SSpammer.uploadData(process.m_nCompanyNum);
                m_SPowercafe.uploadData(process.m_nCompanyNum);

                m_SDatagroup.changeTable(process.m_nCompanyNum);
                m_SConsumer.changeTable(process.m_nCompanyNum);
                m_SInfluencer.changeTable(process.m_nCompanyNum);
                m_SSpammer.changeTable(process.m_nCompanyNum);
                m_SPowercafe.changeTable(process.m_nCompanyNum);

                m_SInitializer.updateWebDBInfoComplete(m_SInitializer.getDatabase(SDBManager::E_DATABASE_WEB), m_SDatagroup.getstDate()->m_strMindate,
                                                       m_SDatagroup.getstDate()->m_strMaxdate, m_SDatagroup.getstDate()->m_strLastupdate,
                                                       m_SDatagroup.getCounts()->m_nFilterBodyCount, m_SDatagroup.getCounts()->m_nFilterReplyCount,
                                                       process.m_nCompanyNum);
                m_SInitializer.insertLog("Upload Done");
                m_nCompany = process.m_nCompanyNum;
            }
            else
            {
                m_nCompany = -100;
                m_SInitializer.insertLog("No Upload");
            }

            m_SConsumer.SaveDataFile(process.m_nCompanyNum);
            m_SInfluencer.SaveDataFile(process.m_nCompanyNum);

            break;
        }
        }
    }

    m_SInitializer.insertLog("New Filter END.");
    return true;
}

int SFilterProcess::getCompanyNum()
{
    return m_nCompany;
}