RyXéo » ryxeo-WebPhotoAlbum

/** Classe tools: regroupe ce qui est mutualisable entre assistant et appli

  * @see https://redmine.ryxeo.com/projects/

  * @author 2012 Eric Seigne <eric.seigne@ryxeo.com>

  * @see The GNU Public License (GNU/GPL) v3

  *

  *

  * This program is free software; you can redistribute it and/or modify

  * it under the terms of the GNU General Public License as published by

  * the Free Software Foundation; either version 3 of the License, or

  * (at your option) any later version.

  *

  * This program is distributed in the hope that it will be useful, but

  * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY

  * or FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License

  * for more details.

  *

  * You should have received a copy of the GNU General Public License along

  * with this program. If not, see <http://www.gnu.org/licenses/>.

  */

#include "tools.h"

class AbulEduSleeperThread : public QThread

{

public:

    static void msleep(unsigned long msecs) {QThread::msleep(msecs);}

};

tools::tools(QDir basedir, QObject *parent) :

    QObject(parent)

{

    m_baseDir = basedir;

    m_web = new QWebView();

    connect(m_web,SIGNAL(loadFinished(bool)),this,SLOT(unzipFinished(bool)));

}

void tools::ftpConnect(QString serveur, QString login, QString passwd)

{

    qDebug() << "tools::ftpConnect (0)";

    m_currentFTPFileUpload = -1;

    m_ftp = new QFtp(this);

    connect(m_ftp, SIGNAL(commandFinished(int,bool)),

            this, SLOT(ftpCommandFinished(int,bool)));

    connect(m_ftp, SIGNAL(done(bool)),

            this, SLOT(ftpDone(bool)));

    connect(m_ftp, SIGNAL(stateChanged(int)),

            this, SLOT(ftpStateChanged(int)));

    connect(m_ftp, SIGNAL(listInfo(QUrlInfo)),

            this, SLOT(addToList(QUrlInfo)));

    connect(m_ftp, SIGNAL(dataTransferProgress(qint64,qint64)),

            this, SLOT(updateDataTransferProgress(qint64,qint64)));

    m_ftp->connectToHost(serveur, 21);

    m_ftp->setTransferMode(QFtp::Passive);

    m_ftp->login(login, passwd);

    qDebug() << "tools::ftpConnect (1)";

}

void tools::ftpCommandFinished(int commandId, bool error)

{

    qDebug() << "======================= BEGIN FTP INFO ======================= ";

    qDebug() << "  Numero de commande : " << commandId;

    if (m_ftp->currentCommand() == QFtp::ConnectToHost) {

        qDebug() << "  Command: Connect to host";

    }

    if (m_ftp->currentCommand() == QFtp::Login) {

        qDebug() << "  Command: Login";

    }

    if (m_ftp->currentCommand() == QFtp::Put) {

        QFile *file = static_cast<QFile*>(m_ftp->currentDevice());

        if(file) {

            file->deleteLater();

        }

        qDebug() << "  Command: Put";

    }

    if (m_ftp->currentCommand() == QFtp::Get) {

        qDebug() << "  Command: Get";

    }

    if (m_ftp->currentCommand() == QFtp::List) {

        qDebug() << "  Command: List";

    }

    if(error) {

        qDebug() << "  Description de l'erreur " << m_ftp->errorString().trimmed();

        qDebug() << "  Abort command and clear pending commands !";

        //grosse ruse pour remettre un peu a zero les erreurs de QFTP qui est quand meme

        //bien capricieux !

        m_ftp->cd("/");

        m_ftp->list("/");

        m_ftp->clearPendingCommands();

        AbulEduSleeperThread::msleep(800);

    }

    qDebug() << "======================= END FTP INFO ======================= ";

    //    if(m_currentFTPFileUpload >= 0 && m_fileListToUploadIndex.count() > 0) {

    //        if(m_typeUploadRecursif == "PHP")

    //            uploadRecursifPHP(m_destDirBase);

    //        else

    //            uploadRecursifGallery(m_destDirBase);

    //    }

    //    else {

    //        qDebug() << "Tout a ete expedie ";

    //    }

}

void tools::ftpDone(bool error)

{

    //    qDebug() << "tools::ftpDone : " << error;

    //    if(error)

    //        qDebug() << "   " << m_ftp->errorString();

    //on passe a la commande FTP suivante et on nettoie au passage

    //    m_ftp->clearPendingCommands();

    ftpNextCommand();

}

void tools::ftpStateChanged(int state)

{

    qDebug() << "tools::ftpStateChanged : code " << state;

    if(state == QFtp::Closing) {

        m_ftpCommands.clear();

    }

}

void tools::updateDataTransferProgress(qint64 readBytes, qint64 totalBytes)

{

    //    qDebug() << "Transfert: " << readBytes << " sur " << totalBytes;

    emit signalUploadData(totalBytes, readBytes);

}

void tools::clear()

{

    m_fileListToUpload.clear();

    m_fileListToUploadIndex.clear();

    m_currentFTPFileUpload = 0;

}

int tools::nbTotalUpload()

{

    return m_fileListToUpload.count()+2;

}

int tools::nbResteUpload()

{

    return m_fileListToUploadIndex.count();

}

void tools::ftpNextCommand()

{

    if(!m_ftpCommands.isEmpty()) {

        QStringList cmd(m_ftpCommands.takeFirst().split(";"));

        QString fileName;

        //Commande speciale pour extraire un fichier ZIP sur le serveur

        //exemple: http://webopenphoto.free.fr/sagc/extract.php?src=galleries/Cala-Montjoi-2012_Christophe/zip/mq.zip

        if(cmd.at(0) == "unzip") {

            QUrl u(m_urlSite + "/extract.php?src=" + cmd.at(1));

            m_web->load(u);

            qDebug() << "Ouverture de " << u;

            fileName = "Unzip " + cmd.at(1);

        }

        if(cmd.at(0) == "mkdir") {

            m_ftp->mkdir(cmd.at(1));

            fileName = cmd.at(1);

        }

        if(cmd.at(0) == "put") {

            QFile *fic = new QFile(cmd.at(1));

            if(fic->open(QIODevice::ReadOnly)) {

                qDebug() << "       Upload : " << cmd.at(1) << " -> " << cmd.at(2);

                m_ftp->put(fic,cmd.at(2));

                fileName = cmd.at(2);

            }

            else {

                //erreur

            }

        }

        m_currentFTPFileUpload++;

        emit signalUpload(nbTotalUpload(), m_currentFTPFileUpload, fileName);

    }

    else {

        emit signalUploadEnd();

    }

}

void tools::unzipFinished(bool status)

{

    ftpNextCommand();

}

void tools::ftpUnzip(QString zipUrl)

{

    qDebug() << "tools::ftpUnzip " << zipUrl;

    m_ftpCommands << "unzip;" + zipUrl;

}

void tools::ftpMkdir(QString rep)

{

    //Avant de faire un mkdir il faut verifier si le repertoire n'existe pas deja

    //sinon la pile des commandes FTP est remise a zero !!!

    m_ftpCommands << "mkdir;" + rep;

}

void tools::ftpPut(QString source, QString ladest)

{

    m_ftpCommands << "put;" + source + ";" + ladest;

}

void tools::parcoursRecursif(QString rep, QString repertoireServeur)

{

    qDebug() << "parcoursRecursif : " << rep;

    QDir dir(rep);

    dir.setFilter(QDir::Hidden | QDir::Files | QDir::Dirs | QDir::NoSymLinks | QDir::NoDotAndDotDot);

    QFileInfoList list = dir.entryInfoList();

    for(int i = 0; i < list.count(); i++) {

        qDebug() << " Ajout de " << list.at(i).absoluteFilePath() << " rep serveur : " << repertoireServeur;

        m_fileListToUpload.insert(list.at(i).absoluteFilePath(), repertoireServeur);

        m_fileListToUploadIndex << list.at(i).absoluteFilePath();

        if(list.at(i).isDir()) {

            if(list.at(i).fileName() == "hq" || list.at(i).fileName() == "mq" || list.at(i).fileName() == "lq" || list.at(i).fileName() == "thumbs") {

                qDebug() << " On ne parcours pas " << list.at(i).absoluteFilePath();

            }

            else {

                parcoursRecursif(list.at(i).absoluteFilePath(), list.at(i).absoluteFilePath().remove(m_baseDir.absolutePath()).remove("/data/www"));

            }

        }

    }

}

void tools::uploadRecursifGallery(QString destDirBase, QString urlSite)

{

    qDebug() << " ** uploadRecursifGallery : " << m_fileListToUploadIndex.count() ;

    m_urlSite = urlSite;

    m_destDirBase = destDirBase;

    m_typeUploadRecursif = "Gallery";

    while(m_fileListToUploadIndex.count()>0) {

        QString s(m_fileListToUploadIndex.takeFirst());

        qDebug() << "     -> " << s;

        QFileInfo fi(s);

        if(fi.isDir()) {

            QString ladest = m_destDirBase + "/galleries" + fi.absoluteFilePath().remove(m_baseDir.absolutePath());

            qDebug() << "       mkdir : " << ladest;

            ftpMkdir(ladest);

        }

        else {

            QString ladest = m_destDirBase + "/galleries/" + m_fileListToUpload.value(fi.absoluteFilePath()) + "/" + fi.fileName();

            ftpPut(fi.absoluteFilePath(),ladest);

            if(fi.absoluteFilePath().endsWith(".zip")) {

                ftpUnzip("galleries/" + m_fileListToUpload.value(fi.absoluteFilePath()) + "/" + fi.fileName());

            }

        }

    }

}

void tools::uploadRecursifPHP(QString destDirBase)

{

    qDebug() << "uploadRecursifPHP : " << m_fileListToUploadIndex.count() ;

    m_destDirBase = destDirBase;

    m_typeUploadRecursif = "PHP";

    while(m_fileListToUploadIndex.count()>0) {

        QString s(m_fileListToUploadIndex.takeFirst());

        qDebug() << "     -> " << s;

        QFileInfo fi(s);

        if(fi.isDir()) {

            QString ladest = m_destDirBase + fi.absoluteFilePath().remove(m_baseDir.absolutePath()).remove("/data/www");

            qDebug() << "mkdir : " << ladest;

            ftpMkdir(ladest);

        }

        else {

            QString ladest = m_destDirBase + m_fileListToUpload.value(fi.absoluteFilePath()) + "/" + fi.fileName();

            ftpPut(fi.absoluteFilePath(),ladest);

        }

    }

}

void tools::addToList(const QUrlInfo &urlInfo)

{

    qDebug() << "tools::addToList";

    qDebug() << urlInfo.name();

}