SpeedNumCube/sncprojects/lib/SNCNumCheck/autouploadfile.cpp

#include "autouploadfile.h"
#include "sncdatabase.h"
#include "wsnumchk.h"
#include "respsubminpnum.h"
#include "resppackmerge.h"
#include "respchkuserfeestatus.h"
#include "resppacktran.h"
#include "fileprepare.h"
#include "filesplitter.h"
AutoUploadFile::AutoUploadFile()
{
    m_stop = false;
    m_skip = false;
    m_moduleID = "bzjc";
    m_numchk = new WSNumChk();
}
AutoUploadFile::~AutoUploadFile()
{
    m_numchk->abort();
    delete m_numchk;
    qDebug()<<QDateTime::currentDateTime().toString("yyyy-MM-dd HH:mm:ss")\
           <<"FormNumChk.AutoUpload Destroyed.";
}
void AutoUploadFile::abort()
{
    m_stop = true;
    m_numchk->abort();
}
void AutoUploadFile::setSkip(bool skip)
{

    m_skip = skip;
}
void AutoUploadFile::setClientID(QString clientID)
{
    m_clientID = clientID;
}

void AutoUploadFile::setHost(QString host, QString port)
{
    m_host = host;
    m_port = port;
    m_numchk->setHost(m_host,m_port);
}

void AutoUploadFile::setAccountInfo(QMap<QString, QString> accountInfo)
{
    m_account = accountInfo;
}
void AutoUploadFile::run()
{
    if(m_skip)
        return;
    m_stop = false;
    QString userCode = m_account.value("usercode");
    QString userHash = m_account.value("userhash");
    if(userHash.isEmpty()||userCode.isEmpty()||m_clientID.isEmpty())
        return ;
    QMultiMap<QString,QString> list = SNCDataBase::getAllUpload(m_moduleID,m_clientID,userCode);
    int cols = list.uniqueKeys().size();
    int rows = 0;
    if(cols!=0)
        rows = list.size()/cols;
    for(int i=0;i<rows;i++)
    {
        if(m_stop)
            break;

        int fileid = list.values("fileid").at(i).toInt();
        QString filepath = list.values("filepath").at(i);
        QString filetype = list.values("filetype").at(i);
        QString memo = list.values("memo").at(i);
        int state = list.values("uploadstate").at(i).toInt();
        QString tasktype = list.values("tasktype").at(i);
        if(state==0 || state == 2)
        {
            m_errCode = 0;
            m_errMsg = "";
            m_errDetail = "";
            SNCDataBase::updateFileUploadState(fileid,1,m_errMsg,m_errDetail);
            int ret = upload(fileid,filepath,filetype,tasktype,memo);
            switch(ret)
            {
                case 0:
                    SNCDataBase::updateFileUploadState(fileid,2,m_errMsg,m_errDetail);
                    break;
                case 1:
                    SNCDataBase::updateFileUploadState(fileid,3,m_errMsg,m_errDetail);
                    emit uploadSucceed();
                    break;
                case -1:
                    SNCDataBase::updateFileUploadState(fileid,m_errCode,m_errMsg,m_errDetail);
                    emit uploadFailed();
                    break;
            }
        }

    }
}
int AutoUploadFile::upload(int fileid,QString filePath, QString fileType,QString taskType, QString memo)
{

    bool multi;
    if(taskType=="1")
        multi = false;
    else
        multi = true;
    FilePrepare filePrepare(filePath,fileType,multi,this->m_moduleID,this->m_clientID);
    if(!filePrepare.prepare())
    {
        m_errCode = -1;
        m_errMsg = filePrepare.getRtnMsg();
        return -1;
    }
    if(m_stop)
    {
        return 0;
    }
    QString userHash = m_account.value("userhash");
    QString json = m_numchk->chkUserFeeStatus(QString("%1").arg(filePrepare.getCount()),userHash);
    RespChkUserFeeStatus    response(json);
    if(response.getRtnCode()<=0)
    {
        m_errMsg = response.getRtnMemo();
        m_errCode = -4;
        if(response.getRtnCode()==RTNCODE_NETWORK_ABORT)
        {
            return 0;
        }
        else if(response.getRtnCode()==RTNCODE_NETWORK_NOTAVAILABLE)
        {
            m_errCode = -2;
            return -1;
        }
    }
    FileSplitter splitter(filePrepare.getLastUploadFileName(),QString::number(fileid));
    QStringList list = splitter.getSplitResult();

    bool allupload = true;
    QString packName;
    for(int i=0;i<list.size();i++)
    {
        if(m_stop)
        {
            return 0;
        }
        packName = list.at(i);
        QString json = m_numchk->PackTran(packName,userHash);
        RespPackTran response(json);
        if(response.getRtnCode()==1)
        {
            QFile::remove(packName);
        }
        else
        {
            m_errMsg = response.getRtnMemo();
            m_errCode = -4;
            if(response.getRtnCode()==RTNCODE_NETWORK_ABORT)
            {
                return 0;
            }
            else if(response.getRtnCode()==RTNCODE_NETWORK_NOTAVAILABLE)
            {
                m_errCode = -2;
                return -1;
            }
            allupload = false;
            break;
        }
        SNCDataBase::updateFileUploadPercent(fileid,(i+1)*100.0/list.size());
        emit uploadProgressUpdated();
    }

    if(allupload)
    {
        splitter.cleanup();
        QString json = m_numchk->PackMerge(packName,userHash);
        RespPackMerge response(json);
        if(response.getRtnCode()==1)
        {
            json = m_numchk->submitPnumFile(filePrepare.getLastUploadFileName(),response.getFileHash(),fileType,taskType,memo,userHash);
            RespSubminPNum response(json);
            if(response.getRtnCode()==2)
            {
                m_errCode = 1;
                m_errMsg = "上传成功，号码全部接收。";
                m_errDetail = response.getRtnMemo();
                SNCDataBase::updateFileUploadSrvInfo(fileid,response.getBatchID(),response.getSubmitTime());
            }
            else if(response.getRtnCode()==1)
            {
                m_errCode = 1;
                m_errMsg = "上传成功，文件中含有部分非法数据。";
                m_errDetail = response.getRtnMemo();
                SNCDataBase::updateFileUploadSrvInfo(fileid,response.getBatchID(),response.getSubmitTime());
            }
            else
            {
                m_errMsg = response.getRtnMemo();
                m_errCode = -4;
                if(response.getRtnCode()==RTNCODE_NETWORK_ABORT)
                {
                    return 0;
                }
                else if(response.getRtnCode()==RTNCODE_NETWORK_NOTAVAILABLE)
                {
                    m_errCode = -2;
                    return -1;
                }
            }

        }
        else
        {
            m_errMsg = response.getRtnMemo();
            m_errCode = -4;
            if(response.getRtnCode()==RTNCODE_NETWORK_ABORT)
            {
                return 0;
            }
            else if(response.getRtnCode()==RTNCODE_NETWORK_NOTAVAILABLE)
            {
                m_errCode = -2;
                return -1;
            }
        }
    }
    if(m_errCode<0)
        return -1;
    else
        return 1;
}