Method on_queryMessageVersion_finished

src/share/WizGroupMessage.cpp:153–204

}

void WizGroupMessage::on_queryMessageVersion_finished()
{
    QNetworkReply* reply = qobject_cast<QNetworkReply *>(sender());

    if (reply->error()) {
        reply->deleteLater();
        syncEnd();
        return;
    }

    // return: "{"result": version,"return_code":200,"return_message":"success"}"
    QString strReply = reply->readAll();
    reply->deleteLater();

    qDebug() << "[Message Sync]query version finished, reply: " << strReply;

    rapidjson::Document document;
    document.Parse<0>(strReply.toUtf8().constData());

    if (!document.IsObject()) {
        TOLOG("Error occured when try to parse json of message version");
        syncEnd();
        return;
    }

    QString nCode;
    if (document["return_code"].IsString()) {
        nCode = document["return_code"].getString();
    } else {
        nCode = QString::number(document["return_code"].getInt());
    }

    QString strMsg = document["return_message"].getString();
    if (nCode != WIZAPI_RETURN_SUCCESS) {
        TOLOG2("Error occured when get message version, code: %1, message: %2",
               nCode, strMsg);
        syncEnd();
        return;
    }

    qint64 nVersionRemote = document["result"].getInt64();
    qint64 nVersionLocal = m_db.getObjectVersion(WIZMESSAGEDATA::objectName());

    qDebug() << "[Message Sync]local message version: " << nVersionLocal;

    // 3. compare version, determine fetch needed or not
    if (nVersionLocal < nVersionRemote) {
        callGetMessages(nVersionLocal);
    } else {
        syncEnd();
    }
}

void WizGroupMessage::onGetMessages(const CWizMessageDataArray& messages)
{