Работа с сетью, работа с БД и парсинг информации. Разделение потоков

@~~MDK_17R~~ · 24.04.2014, 20:25. **Показов** 630. **Ответов** 0

Author24 — интернет-сервис помощи студентам

Возникла проблема разграничения потоков. То есть в конечном файле реализованы алгоритмы: работа с сетью, работа с БД и парсинг информации. Преподаватель сказал, что категорически запрещается, чтобы всё это работало в одном потоке. Необходимо сделать в разных. Помогите, пожалуйста кто чем сможет, очень срочно, до субботы(26.04) нужно сделать.
Это код главного файла MainWindow:

C++ (Qt)

#include "mainwindow.h"
 
MainWindow::MainWindow(QWidget *parent) :
    QWidget(parent)
{
    search = new QLineEdit;
 
    reload = new QPushButton(this->style()->standardIcon(QStyle::SP_BrowserReload),"");
    reload->setFixedSize(50,50);
 
    results = new QListWidget;
    results->setVerticalScrollMode(QAbstractItemView::ScrollPerPixel);
    results->verticalScrollBar()->setStyleSheet("QScrollBar:vertical{"
                                                "width: 40px; "
                                                "} "
                                                );
 
    add = new additionaly;
 
    tabs = new QTabWidget;
    QTabBar* tabBar = tabs->findChild<QTabBar*>();
    tabBar->hide();
    tabs->addTab(results,"Main");
    tabs->addTab(add,"Add");
 
    manager = new QNetworkAccessManager;
 
    QHBoxLayout* hlayo = new QHBoxLayout;
    hlayo->setMargin(0);
    hlayo->setSpacing(5);
    hlayo->addWidget(search);
    hlayo->addWidget(reload);
 
    QVBoxLayout* vlayo = new QVBoxLayout;
    vlayo->setMargin(5);
    vlayo->setSpacing(5);
    vlayo->addLayout(hlayo);
    vlayo->addWidget(tabs);
 
    this->setLayout(vlayo);
 
    connect(reload,SIGNAL(clicked()),this,SLOT(updateBase()));
    connect(search,SIGNAL(textChanged(QString)),this,SLOT(parseBase(QString)));
    connect(add,SIGNAL(back()),this,SLOT(toBack()));
 
    createConnection();
    createStationTables();
    parseBase("");
 
    dialog = new QLabel("<h3>Обновление базы!</h3>");
    dialog->setFixedSize(800,480);
}
 
bool MainWindow::createConnection()
{
    QSqlDatabase db = QSqlDatabase::addDatabase("QSQLITE"); // Используется БД SQLite
    db.setDatabaseName("BusStation");
 
    db.setUserName("Anonymous");
    db.setHostName("localhost");
    db.setPassword("Anonymous");
 
    if(!db.open())
    {
        qDebug() << db.lastError();
        return false;
    }
 
    query = new QSqlQueryModel;
    add->table->setModel(query);
 
    return true;
}
 
bool MainWindow::createStationTables()
{
    query->setQuery("CREATE TABLE IF NOT EXISTS stations (" // Таблица основных данных
                    "id INTEGER PRIMARY KEY ASC, "
                    "number INTEGER UNSIGNED, "
                    "time VARCHAR(80), "
                    "title VARCHAR(45));");
    if(!logError(query)) return false;
    query->setQuery("CREATE TABLE IF NOT EXISTS output (" // Таблица дополнительных данных
                    "id INTEGER PRIMARY KEY ASC, "
                    "context VARCHAR(100), "
                    "title VARCHAR(45), "
                    "time VARCHAR(45), "
                    "id_station INTEGER, "
                    "FOREIGN KEY (id_station) "
                    "REFERENCES stations(id) "
                    "ON DELETE CASCADE "
                    "ON UPDATE CASCADE);");
    logError(query);
    if(!logError(query)) return false;
    return true;
}
 
bool MainWindow::logError(QSqlQueryModel* query)
{
    if(query->lastError().isValid())
    {
        qDebug() << query->lastError(); // Вывод в консоль отладки
        return false;
    }
    return true;
}
 
void MainWindow::updateBase()
{
    dialog->show();
    tabs->setCurrentIndex(0);
    QNetworkReply* reply = manager->get(QNetworkRequest(QUrl("http://avtovokzal.tomsk.ru"))); // получение содержания сайта
    connect(reply,SIGNAL(finished()),this,SLOT(mainReply()));
    connect(reply,SIGNAL(error(QNetworkReply::NetworkError)),this,SLOT(error(QNetworkReply::NetworkError)));
}
 
void MainWindow::error(QNetworkReply::NetworkError)
{
    qDebug() << ((QNetworkReply*)sender())->errorString();
    dialog->hide();
}
 
void MainWindow::mainReply()
{
    query->setQuery("DELETE FROM stations;");
    query->setQuery("DELETE FROM output;");
 
    QNetworkReply* reply = (QNetworkReply*)sender(); // результат полученного сайта
    QString str = reply->readAll();
    if(str=="")
    {
        dialog->hide();
        return;
    }
    // Убираем лишнее в в контексте и получаем таблицу
    QString table_f = "<div id=\"main_content\">";
    str = str.mid(str.indexOf(table_f)+table_f.count());
    table_f = "</table>";
    QString table = str.left(str.indexOf(table_f));
    table = table.replace(" class=\'white\'","");
    table = table.replace(" class=\'blue\'","");
    table = table.replace(" class=\'head\'","");
    table = table.replace(" class=\'c1\'","");
    table = table.replace(" class=\'c2\'","");
    table = table.replace(" class=\'c3\'","");
    table = table.replace(" class=\'c4\'","");
    table = table.replace(" class=\'c5\'","");
 
    int n = 0;
    // парсинг кадой строки за исключением заголовка
    while(table.count()>0)
    {
        QString tr_f = "<tr>";
        QString tr = table.mid(table.indexOf(tr_f)+tr_f.count());
        tr_f = "</tr>";
        tr = tr.left(tr.indexOf(tr_f));
 
        table = table.mid(table.indexOf(tr_f)+tr_f.count());
 
        if(n==0)
        {
            ++n;
            continue;
        }
 
        QString number = "";
        QString title = "";
        // парсинг колонок строки
        for(int i=0;i<5;++i)
        {
            QString td_f = "<td>";
            QString td = tr.mid(tr.indexOf(td_f)+td_f.count());
            td_f = "</td>";
            td = td.left(td.indexOf(td_f));
 
            if(i==0)
            {
                number = td;
            }
 
            if(i==1)
            {
                QString h3_f = "</h3>";
                td = td.mid(td.indexOf(h3_f)+h3_f.count());
                title = td;
            }
 
            if(i==2)
            {
                QString div_f = "<div>";
                td = td.left(td.indexOf(div_f));
                QString temp = "";
                while(td.indexOf("\'>")!=-1)
                {
                    temp+=td.mid(td.indexOf("\'>")+2,5);
                    td=td.mid(td.indexOf("a>")+2);
                    if(td!="") temp+=", ";
                }
 
                query->setQuery("INSERT INTO stations (number, time, title) VALUES (\'"+number+"\', \'"+temp+"\', \'"+title+"\');");
 
                //-----------
 
                query->setQuery("SELECT id FROM stations ORDER BY id DESC LIMIT 1;");
 
                QString id_number = query->data(query->index(0,0)).toString();
 
                toDoBase(title,number);
                query->setQuery("UPDATE output SET id_station=\'"+id_number+"\' WHERE id_station=\'-1\';");
            }
 
            tr = tr.mid(tr.indexOf(td_f)+td_f.count());
        }
        QApplication::processEvents();
        ++n;
    }
    dialog->hide();
    parseBase("");
}
 
void MainWindow::otherReply()
{
    QNetworkReply* reply = (QNetworkReply*)sender();
    QString str = reply->readAll();
 
    QString div_f = "<div class=\"Ttrip\">";
    QString div = str.mid(str.indexOf(div_f)+div_f.count()+1);
    div_f = "<table class=\'vtl\'>";
    div = div.left(div.indexOf(div_f));
    div = div.replace("<div >","");
    div = div.replace("</div>","|");
 
    QString table_f = "<table class=\"vtl\">";
    str = str.mid(str.indexOf(table_f)+table_f.count());
    table_f = "</table>";
    QString table = str.left(str.indexOf(table_f));
    table = table.replace(" class=\'white\'","");
    table = table.replace(" class=\'blue\'","");
    table = table.replace(" class=\'head\'","");
    table = table.replace(" class=\'c1\'","");
    table = table.replace(" class=\'c2\'","");
    table = table.replace(" class=\'c3\'","");
    table = table.replace(" class=\'c4\'","");
    table = table.replace(" class=\'c5\'","");
 
    int n = 0;
    while(table.count()>0)
    {
        QString tr_f = "<tr>";
        QString tr = table.mid(table.indexOf(tr_f)+tr_f.count());
        tr_f = "</tr>";
        tr = tr.left(tr.indexOf(tr_f));
 
        table = table.mid(table.indexOf(tr_f)+tr_f.count());
 
        if(n==0)
        {
            ++n;
            continue;
        }
 
        QString time = "";
        QString title = "";
        for(int i=0;i<3;++i)
        {
            QString td_f = "<td>";
            QString td = tr.mid(tr.indexOf(td_f)+td_f.count());
            td_f = "</td>";
            td = td.left(td.indexOf(td_f));
 
            if(i==0)
            {
                title = td;
            }
 
            if(i==1)
            {
                time = td;
                query->setQuery("INSERT INTO output (context, title, time, id_station) VALUES (\'"+div+"\', \'"+title+"\', \'"+time+"\', \'-1\');");
            }
 
            tr = tr.mid(tr.indexOf(td_f)+td_f.count());
        }
 
        ++n;
    }
}
 
void MainWindow::toDoBase(QString title, QString number)
{
    // выполнение php скрипта найденного в исходниках JavaScript сайта
    QNetworkReply* reply = manager->get(QNetworkRequest(QUrl("http://avtovokzal.tomsk.ru/ajax/tripinfo.php?name="+title+"&number="+number)));
 
    connect(reply,SIGNAL(finished()),this,SLOT(otherReply()));
    connect(reply,SIGNAL(error(QNetworkReply::NetworkError)),this,SLOT(error(QNetworkReply::NetworkError)));
 
    while(!reply->isFinished())
    {
        QApplication::processEvents();
    }
}
 
void MainWindow::parseBase(QString str)
{
    tabs->setCurrentIndex(0);
    // отображение маршрутов по названию или номеру маршрута
    query->setQuery("SELECT * FROM stations WHERE (UPPER(number) LIKE \'%"+str.toUpper()+"%\') OR (UPPER(title) LIKE \'%"+str.toUpper()+"%\');");
 
    results->clear();
 
    // генерирование результата
    for(int i=0;i<query->rowCount();++i)
    {
        QListWidgetItem* item = new QListWidgetItem;
        item->setSizeHint(QSize(0,80));
        header* widget = new header;
        connect(widget,SIGNAL(showAdd(QString,QString,QString)),this,SLOT(toAdd(QString,QString,QString)));
        connect(results,SIGNAL(clicked(QModelIndex)),this,SLOT(clickWidget(QModelIndex)));
        widget->number->setText(query->data(query->index(i,1)).toString());
        widget->time->setText(query->data(query->index(i,2)).toString());
        widget->title->setText(query->data(query->index(i,3)).toString());
        widget->id = query->data(query->index(i,0)).toString();
        results->addItem(item);
        results->setItemWidget(item,widget);
    }
}
 
void MainWindow::toAdd(QString id, QString title, QString number)
{
    add->head->setText("<h3>Маршрут №"+number+"\nТомск - "+title+"</h3>");
    query->setQuery("SELECT context FROM output WHERE id_station=\'"+id+"\' LIMIT 1;");
    for(int i=0;i<query->rowCount();++i)
    {
        QString str = query->data(query->index(0,0)).toString().replace("|","\n");
        add->title->setText(str);
    }
    query->setQuery("SELECT id as `№`, title AS `Маршрут`, time AS `Время в пути` FROM output WHERE id_station=\'"+id+"\';");
    add->table->resizeColumnsToContents();
    add->table->hideColumn(0);
    tabs->setCurrentIndex(1);
}
 
void MainWindow::toBack()
{
    tabs->setCurrentIndex(0);
    search->setVisible(true);
    reload->setVisible(true);
}
 
void MainWindow::clickWidget(QModelIndex index)
{
    header* hed = (header*)results->itemWidget(results->item(index.row()));
    hed->onClick();
    search->setVisible(false);
    reload->setVisible(false);
}

заголовочный файл mainwindow.h:

C++ (Qt)

#ifndef MAINWINDOW_H
#define MAINWINDOW_H
 
#include "header.h"
#include <QtNetwork>
#include <QtSql>
 
class MainWindow : public QWidget // виджет главного окна
{
    Q_OBJECT
public:
    explicit MainWindow(QWidget *parent = 0);
 
    QLineEdit* search; // строка отображения
 
    QPushButton* reload; // кнопка обновления базы
 
    QListWidget* results; // виджет отображения результатов
 
    QTabWidget* tabs; // виджет управления окнами
 
    additionaly* add; // виджет дополнительного содержания
 
    QLabel* dialog; // информация об обновлении
 
    //---------------------------
 
    QNetworkAccessManager* manager; // сетевой менеджер для парсинга сайта
 
    QSqlQueryModel* query; // модель доступа к БД
 
    bool createConnection(); // функция подключения к БД
    bool createStationTables(); // функция создания таблиц БД
    bool logError(QSqlQueryModel* query); // функция логирования ошибок
signals:
 
public slots:
    void updateBase(); // метод обновления базы данных
    void toDoBase(QString title, QString number); // метод парсинга дополнительных ссылок
    void mainReply(); // парсинг основной ссылки
    void otherReply(); // парсинг дополнительный ссылок
    void error(QNetworkReply::NetworkError); // обработка ошибок
    void parseBase(QString str); // метод отображения элементов списка БД
    void toAdd(QString id, QString title, QString number); // метод отображения дополнительной информации
    void toBack(); // метод отображения главного окна
    void clickWidget(QModelIndex index); // метод обработки выбора элемента списка для отобрадения дополнительной информации
 
};
 
#endif // MAINWINDOW_H

Если потребуется код из остальных файлов или полная реализация, сообщите, залью.

	24.04.2014, 20:25