resource.cpp

#include "resource.h"

#include "tcpclient.h"
#include "OpeWidget.h"
#include <QVBoxLayout>
#include <QInputDialog>
#include <QMessageBox>
#include <QListWidgetItem>
#include <QFileDialog>

Resource::Resource(QWidget *parent)
    : QWidget{parent}
{
    m_pPathLb = new QLabel;
    m_pResListW = new QListWidget;
    m_pReturnPB = new QPushButton("返回");
    m_pCreateDirPB = new QPushButton("创建文件夹");
    // m_pDelDirPB = new QPushButton("删除文件夹");
    m_pRenamePB = new QPushButton("重命名文件");
    m_pFlushFilePB = new QPushButton("刷新文件");

    QVBoxLayout *pDirVBL = new QVBoxLayout;
    pDirVBL->addWidget(m_pReturnPB);
    pDirVBL->addWidget(m_pCreateDirPB);
    // pDirVBL->addWidget(m_pDelDirPB);
    pDirVBL->addWidget(m_pRenamePB);
    pDirVBL->addWidget(m_pFlushFilePB);

    m_pUploadPB = new QPushButton("上传文件");
    m_pDownLoadPB = new QPushButton("下载文件");
    m_pDelFilePB = new QPushButton("删除文件");
    m_pShareFilePB = new QPushButton("共享文件");

    QVBoxLayout *pFileVBL = new QVBoxLayout;
    pFileVBL->addWidget(m_pUploadPB);
    pFileVBL->addWidget(m_pDownLoadPB);
    pFileVBL->addWidget(m_pDelFilePB);
    pFileVBL->addWidget(m_pShareFilePB);

    QVBoxLayout *pPath = new QVBoxLayout;
    pPath->addWidget(m_pPathLb);
    pPath->addWidget(m_pResListW);

    QHBoxLayout *pMain = new QHBoxLayout;
    pMain->addLayout(pPath);
    pMain->addLayout(pDirVBL);
    pMain->addLayout(pFileVBL);

    m_pthread = new MyThread(this);


    setLayout(pMain);
    connect(m_pCreateDirPB, SIGNAL(clicked())
            , this, SLOT(createDir()));
    connect(m_pFlushFilePB, SIGNAL(clicked())
            , this, SLOT(flushFile()));
    connect(m_pDelFilePB, SIGNAL(clicked())
            , this, SLOT(deleteFlie()));
    connect(TcpClient::getInstance(), SIGNAL(showFlie())
            , this, SLOT(flushFile()));
    connect(TcpClient::getInstance(), SIGNAL(upLoadFile())
            , this, SLOT(upLoadFileData()));
    connect(m_pRenamePB, SIGNAL(clicked())
            , this, SLOT(renNameFlie()));
    connect(m_pResListW, SIGNAL(itemDoubleClicked(QListWidgetItem*))
            , this, SLOT(enterDir(QListWidgetItem *)));
    connect(m_pReturnPB, SIGNAL(clicked())
            , this, SLOT(returnSuperior()));
    connect(m_pUploadPB, SIGNAL(clicked())
            , this, SLOT(uploadFlie()));
    connect(m_pthread, SIGNAL(sigShowMsg())
            , this ,SLOT(showErr()));
    connect(m_pthread, SIGNAL(senderPDU(PDU*))
            , this ,SLOT(senderPDU(PDU*)));
    // QMessageBox::warning(this, "上传文件", "上传失败，读文件失败");



}

void Resource::showFlie(PDU *pdu)
{
    if (NULL == pdu) {
        return;
    }
    m_pResListW->clear();
    FLIE *flie = NULL;
    for (int i = 0; i < pdu->uiMsgLen/sizeof(FLIE); ++i) {
        flie = (FLIE *)(pdu->caMsg)+i;
        QListWidgetItem *item = new QListWidgetItem;
        item->setText(QString("%1").arg(flie->flieName));
        if (flie->isDir) {
            item->setIcon(QIcon(QPixmap(":/resource/dir.png")));
        }else{
            item->setIcon(QIcon(QPixmap(":/resource/flie.png")));
        }
        item->setToolTip(QString("%1KB").arg(flie->flieSize));
        m_pResListW->addItem(item);
    }
}

void Resource::createDir()
{
    QString strNewDir = QInputDialog::getText(this, "创建文件夹", "文件夹名");
    if (strNewDir.isEmpty()) {
        QMessageBox::warning(this, "创建文件夹", "文件夹名不能为空");
        return ;
    }
    if (strNewDir.size()>32) {
        QMessageBox::warning(this, "创建文件夹", "文件夹名过长");
        return ;
    }
    PDU *pdu = mkPDU(TcpClient::getInstance()->m_strCurPuath.size()+1);
    pdu->uiMsgType = ENUM_MSG_TYPE_CREAT_DIR_REQUEST;
    memcpy(pdu->caData, TcpClient::getInstance()->m_strName.toStdString().c_str()
           , TcpClient::getInstance()->m_strName.size());
    memcpy(pdu->caData+32, strNewDir.toStdString().c_str()
           , strNewDir.size());
    memcpy(pdu->caMsg, TcpClient::getInstance()->m_strCurPuath.toStdString().c_str()
           , TcpClient::getInstance()->m_strCurPuath.size());
    TcpClient::getInstance()->getTcpSocket()->write((char *)pdu, pdu->uiPDULen);
    free(pdu);
    pdu = NULL;

}

void Resource::flushFile()
{
    m_pPathLb->setText(TcpClient::getInstance()->m_strCurPuath);
    PDU *pdu = mkPDU(TcpClient::getInstance()->m_strCurPuath.size()+1);
    pdu->uiMsgType = ENUM_MSG_TYPE_SHOW_FLIE_REQUEST;
    memcpy(pdu->caMsg, TcpClient::getInstance()->m_strCurPuath.toStdString().c_str()
           , TcpClient::getInstance()->m_strCurPuath.size());
    TcpClient::getInstance()->getTcpSocket()->write((char *)pdu, pdu->uiPDULen);
    free(pdu);
    pdu = NULL;
}

void Resource::deleteFlie()
{
    if (m_pResListW->currentItem()==NULL) {
        QMessageBox::warning(this, "删除文件", "选择要删除文件");
        return;
    }
    QString flieName = m_pResListW->currentItem()->text();
    QMessageBox::StandardButton btn;
    btn = QMessageBox::question(this, "删除文件", "确定要删除文件"+flieName+"吗?(其包含文件将一并删除)"
                                , QMessageBox::Yes|QMessageBox::No);
    if (btn == QMessageBox::No) {
        return;
    }
    PDU *pdu = mkPDU(TcpClient::getInstance()->m_strCurPuath.size()+1);
    pdu->uiMsgType = ENUM_MSG_TYPE_DELETE_FLIE_REQUEST;
    strcpy((char *)pdu->caMsg, TcpClient::getInstance()->m_strCurPuath.toStdString().c_str());
    strcpy(pdu->caData, flieName.toStdString().c_str());
    TcpClient::getInstance()->getTcpSocket()->write((char *)pdu, pdu->uiPDULen);
    free(pdu);
    pdu = NULL;
}

void Resource::renNameFlie()
{
    if (m_pResListW->currentItem()==NULL) {
        QMessageBox::warning(this, "重命名文件", "选择要重命名文件");
        return;
    }
    QString strOldNameFlie = m_pResListW->currentItem()->text();
    QString strNewNameFlie = QInputDialog::getText(this, "重命名文件 "+strOldNameFlie, "新文件名");
    if (strNewNameFlie.isEmpty()) {
        QMessageBox::warning(this, "重命名文件", "新文件名不能为空");
        return ;
    }
    if (strNewNameFlie.size()>32) {
        QMessageBox::warning(this, "重命名文件", "新文件名过长");
        return ;
    }
    PDU *pdu = mkPDU(TcpClient::getInstance()->m_strCurPuath.size()+1);
    pdu->uiMsgType = ENUM_MSG_TYPE_RENNAME_FLIE_REQUEST;
    memcpy(pdu->caData, strOldNameFlie.toStdString().c_str()
           , 32);
    memcpy(pdu->caData+32, strNewNameFlie.toStdString().c_str()
           , 32);
    strcpy((char *)pdu->caMsg, TcpClient::getInstance()->m_strCurPuath.toStdString().c_str());
    TcpClient::getInstance()->getTcpSocket()->write((char *)pdu, pdu->uiPDULen);
    free(pdu);
    pdu = NULL;
}

void Resource::enterDir(QListWidgetItem *item)
{
    QString strDir = m_pResListW->currentItem()->text();
    // qDebug()<<strDir;
    PDU *pdu = mkPDU(TcpClient::getInstance()->m_strCurPuath.size()+1);
    pdu->uiMsgType = ENUM_MSG_TYPE_ENTER_DIR_REQUEST;
    memcpy(pdu->caData, strDir.toStdString().c_str()
           , 32);
    strcpy((char *)pdu->caMsg, TcpClient::getInstance()->m_strCurPuath.toStdString().c_str());
    TcpClient::getInstance()->getTcpSocket()->write((char *)pdu, pdu->uiPDULen);
    free(pdu);
    pdu = NULL;
}

void Resource::returnSuperior()
{
    if(strcmp(TcpClient::getInstance()->m_strCurPuath.toStdString().c_str(),
               QString("./%1").arg(TcpClient::getInstance()->m_strName).toStdString().c_str()) == 0){
        QMessageBox::warning(this, "返回上级", "已处于上级");
        return;
    }
    int index = TcpClient::getInstance()->m_strCurPuath.lastIndexOf('/');
    TcpClient::getInstance()->m_strCurPuath.remove(index
                                                   ,TcpClient::getInstance()->m_strCurPuath.size()-index);
    flushFile();
}

void Resource::uploadFlie()
{
    if (!m_strUploadFliePath.isEmpty()) {
        QMessageBox::warning(this, "上传文件", m_strUploadFliePath+" 正在上传");
        return;
    }
    m_strUploadFliePath = QFileDialog::getOpenFileName();
    if (m_strUploadFliePath.isEmpty()) {
        QMessageBox::warning(this, "上传文件","上传文件名不能为空");
        return;
    }
    int index = m_strUploadFliePath.lastIndexOf('/');
    QString strFileName = m_strUploadFliePath.right(m_strUploadFliePath.size()-index-1);
    qDebug()<<strFileName;
    QFile file(m_strUploadFliePath);
    qint64 fileSize = file.size();
    file.close();
    PDU *pdu = mkPDU(TcpClient::getInstance()->m_strCurPuath.size()+1);
    memcpy(pdu->caMsg ,TcpClient::getInstance()->m_strCurPuath.toStdString().c_str(), TcpClient::getInstance()->m_strCurPuath.size());
    sprintf(pdu->caData, "%s %lld", strFileName.toStdString().c_str(), fileSize);
    pdu->uiMsgType = ENUM_MSG_TYPE_UPLOAD_FILE_REQUEST;
    TcpClient::getInstance()->getTcpSocket()->write((char *)pdu, pdu->uiPDULen);
    free(pdu);
    pdu = NULL;
}

void Resource::upLoadFileData()
{
    QMessageBox::warning(this, "上传文件", " 正在上传");
    m_pthread->m_strUploadFliePath = OpeWidget::getInstance().pResource()->m_strUploadFliePath;
    m_pthread->start();
}

void Resource::showErr()
{
    QMessageBox::warning(this, "上传文件", "上传失败，读文件失败");
}

void Resource::senderPDU(PDU *pdu)
{
    qDebug()<<"数据发送";
    TcpClient::getInstance()->getTcpSocket()->write((char *)pdu, pdu->uiPDULen);
}
MyThread::MyThread(QObject *parent)
{

}

void MyThread::run()
{
    QFile file(m_strUploadFliePath);
    file.open(QIODevice::ReadOnly);
    qint64 fileSize = file.size();
    char *pBuffer = new char[4096];
    qint64 ret = 0;
    while (true) {
        ret = file.read(pBuffer, 4096);
        if (ret<=4096 && ret>0) {

            PDU *pdu = mkPDU(ret);
            pdu->uiMsgType = ENUM_MSG_TYPE_UPLOAD_DATA_REQUEST;
            strcpy((char *)pdu->caMsg, pBuffer);
            int index = OpeWidget::getInstance().pResource()->m_strUploadFliePath.lastIndexOf('/');
            QString strFileName = OpeWidget::getInstance().pResource()->m_strUploadFliePath
                                      .right(OpeWidget::getInstance().pResource()->m_strUploadFliePath.size()-index-1);
            sprintf(pdu->caData, "%s %lld", strFileName.toStdString().c_str(), fileSize);
            emit senderPDU(pdu);
            msleep(5);
            qDebug()<<strFileName<<ret;
            free(pdu);
            pdu = NULL;
        }else if(ret == 0){
            qDebug()<<"文件发送完成";
            break;
        }else{
            emit sigShowMsg();
            break;
        }
    }
    file.close();
    delete []pBuffer;
    pBuffer = NULL;
    OpeWidget::getInstance().pResource()->m_strUploadFliePath=NULL;
    quit();
}