Russian Qt Forum

#ifndef MYTHREAD_H
#define MYTHREAD_H

#include <QThread>
#include <QNetworkAccessManager>
#include <QNetworkReply>
#include <QTimer>
#include <QNetworkConfigurationManager>
#include <Parser>
#include <Serializer>
#include <QObjectHelper>
#include <QTime>
#include "macroconfig.h"

class MyThread : public QThread
{
    Q_OBJECT
public:
    enum Status{
        PointsPay,
        FullInfo
    };
    explicit MyThread(QObject *parent = 0);
    void getPointsPay(int);
    QString getPlatform() ;
    void setServerTime(QString);
protected:
    void run();
private:
    QString m_skey;
    QNetworkAccessManager *m_manager;
    QNetworkReply *m_reply;
    QNetworkConfigurationManager m_config;
    Status m_flag;
    QTimer m_timer;
    QTimer m_TimerWating;
    QTime m_lastTimeInfo;
    QTime m_lastTimePay;
    QString m_serverTime;
    QString m_os;
    QMap<int,QVariantMap> m_pointsPay;
    
signals:
    QVariantMap succes(QVariantMap);
    QMap<int,QVariantMap> succes(QMap<int,QVariantMap>);
    QString Error(QString);
    
public slots:
        void getFullInfo();
        void finish(QNetworkReply*);
        void Error(QNetworkReply::NetworkError);
        void isOnlain();
        void setParamAndStart(QString skey);
    
};

#endif // MYTHREAD_H

#include "mythread.h"
#include <QDebug>

MyThread::MyThread(QObject *parent) :
    QThread(parent)
{
    //moveToThread(this);   если раскоментировать то функция run вообще не вызывается....
    m_manager = new QNetworkAccessManager();
    m_manager->moveToThread(this);
    connect(m_manager,SIGNAL(finished(QNetworkReply*)),this,SLOT(finish(QNetworkReply*)));
    connect(&m_TimerWating,SIGNAL(timeout()),this,SLOT(isOnlain()));
    m_lastTimeInfo.addSecs(-60);
    m_lastTimePay.addSecs(-60);
    m_os = this->getPlatform();
    m_timer.setInterval(60000);
}

void MyThread::setParamAndStart(QString skey){  // устанавливаем ключ и запускаем поток
    if (!skey.isEmpty()) {
        m_skey = skey;
        start();   // запускаем поток. Пробовала и из main.cpp но ничего не изменилось
    }
}

void MyThread::run(){
    qDebug()<<"run";
    getPointsPay(1);
    //getFullInfo();
    m_timer.start();
    exec();             // использовать собственную очередь событий
}

void MyThread::getPointsPay(int type){  // поработать с объектом QTime
   qDebug()<<__FUNCTION__<<type;
    m_flag = PointsPay;
    //if (m_lastTimePay.addSecs(30) <= QTime::currentTime()){
        QString Responce = "/?r=client/paymentplacesinfo&place_type_id=%1";
        Responce = HOST + Responce.arg(QString::number(type));
        if (m_config.isOnline()){
            m_lastTimePay = QTime::currentTime();
            m_reply = m_manager->get(QNetworkRequest(Responce));
            m_reply->moveToThread(this);
            m_reply->ignoreSslErrors();
            connect(m_reply,SIGNAL(error(QNetworkReply::NetworkError)),this,SLOT(Error(QNetworkReply::NetworkError)));
        }
        else  m_TimerWating.start(30000);
   // }

}

void MyThread::getFullInfo(){
  m_flag = FullInfo;
  if (m_lastTimePay.addSecs(30) <= QTime::currentTime()){   // проверяем как давно мы запрашивали эту информацию
        QString param = "/?r=client/getfullInfo&skey=%1&platform=%2&date=%3";
        param = HOST+param.arg(m_skey,m_os,m_serverTime);
        if (m_config.isOnline()){
            m_lastTimeInfo = QTime::currentTime();
            m_reply = m_manager->get(QNetworkRequest(param));
            connect(m_reply,SIGNAL(error(QNetworkReply::NetworkError)),this,SLOT(Error(QNetworkReply::NetworkError)));
            m_reply->ignoreSslErrors();
        }
        else  m_TimerWating.start(30000);

   }

}

void MyThread::finish(QNetworkReply* reply){
    QByteArray json = reply->readAll();
    QJson::Parser parser;
    bool ok;
    QVariantMap buffer = parser.parse (json, &ok).toMap();
    if (ok){
        if (m_flag == PointsPay){
            m_pointsPay[buffer["current"].toInt()] = buffer;
            if (buffer["current"].toInt()!=3)
                this->getPointsPay(buffer["current"].toInt()+1); // запрашиваем следующую точку оплаты
            else this->getFullInfo(); // получаем пользовательскую информацию
        }
       else {
            emit succes(buffer);  // возвращаем пользовательскую информацию
            QVariantMap news = buffer["news"].toMap();
            QList<QVariant> created = news.value("created").toList();
            QList<QVariant> modified = news.value("modified").toList();
            QList<QVariant> deleted = news.value("deleted").toList();
            if (created.isEmpty() || modified.isEmpty() || deleted.isEmpty()){
                this->getPointsPay(1);
            }
            m_timer.start();
        }
    }

}

void MyThread::Error(QNetworkReply::NetworkError error){
    switch(error)
       {

       case QNetworkReply::ConnectionRefusedError:{
           emit Error(QString::fromLocal8Bit("Сервер перегружен."));
           break;
       }

       case QNetworkReply::ContentNotFoundError:{
               emit Error(QString::fromLocal8Bit("Ошибка сервера 404."));
               break;
           }
       case QNetworkReply::HostNotFoundError:{
               emit Error( QString::fromLocal8Bit("Не найден удаленный сервер."));
               break;
           }

       default: {
               emit Error(m_reply->errorString());
               break;
           }
       }
    m_TimerWating.start(60000); // спустя минуту попытаемся вновь соедениться с сервером
}

void MyThread::isOnlain(){
    if (m_config.isOnline()){
        m_TimerWating.stop();
        if (m_flag == PointsPay)
            this->getPointsPay(m_pointsPay.count());
        else this->getFullInfo();
    }
}

void MyThread::setServerTime(QString time){
    this->m_serverTime = time;
}

QString MyThread::getPlatform() {
#if defined(Q_OS_WIN)
    return "winxp";
#elif defined(Q_OS_LINUX)
    return "linux";
#elif defined(Q_OS_MACOSX)
    return "macos";
#endif
}

class MyClass : public QObject
{
   Q_OBJECT
signals:
   //Сигнал о завершении работы "void process()"
   void finished();

public:
   //Обращаем внимание, что в конструкторе не указываем родителя,
   //но при этом можем внести какие-либо другие параметры.
   MyClass() : QObject() {}

   virtual ~MyClass() {}

public slots:
   void process() {
      //Здесь наш код, который должен выполниться в отдельном потоке.
      ...

      //Отсылаем сигнал о завершении выполнения.
      emit finished();
   }

private:
   //Здесь указываем наши приватные объекты и переменные.

};

QThread *thread = new QThread;
MyClass *myclass = new MyClass();
myclass->moveToThread(thread);
connect(thread, SIGNAL(started()), myclass, SLOT(process()));
connect(myclass, SIGNAL(finished()), thread, SLOT(quit()));
connect(myclass, SIGNAL(finished()), myclass, SLOT(deleteLater()));
connect(thread, SIGNAL(finished()), thread, SLOT(deleteLater()));
thread->start();

QThread *thread = new QThread(this); //Сам QThread может иметь parent'а
thread->start();
...
MyClass *myclass = new MyClass();
myclass->moveToThread(thread);
connect(this, SIGNAL(my_signal()), myclass, SLOT(process()));
connect(myclass, SIGNAL(finished()), this, SLOT(my_slot()));

void MyClass::process() {
   //Здесь наш код, который должен выполниться в отдельном потоке.
   ...

   //Перемещаем объект обратно в главный поток.
   moveToThread(QCoreApplication::instance()->thread());

   //Отсылаем сигнал о завершении выполнения.
   emit finished();
}