ImportImagesWorkOrder.cpp

Go to the documentation of this file.

 
#include "ImportImagesWorkOrder.h"
 
#include <QDebug>
#include <QFileDialog>
#include <QMessageBox>
#include <QtConcurrentMap>
 
#include "Camera.h"
#include "Cube.h"
#include "CubeAttribute.h"
#include "FileName.h"
#include "Project.h"
#include "ProjectItem.h"
#include "ProjectItemModel.h"
#include "SaveProjectWorkOrder.h"
#include "Target.h"
#include "TextFile.h"
 
namespace Isis {
 
  ImportImagesWorkOrder::ImportImagesWorkOrder(Project *project) :
      WorkOrder(project) {
    // This is an asynchronous work order
    m_isSynchronous = false;
    m_newImages = NULL;
    m_list = NULL;
 
    QAction::setText(tr("Import &Images..."));
    QUndoCommand::setText(tr("Import Images"));
    setModifiesDiskState(true);
  }
 
 
  ImportImagesWorkOrder::ImportImagesWorkOrder(const ImportImagesWorkOrder &other) :
      WorkOrder(other) {
    m_newImages = NULL;
    m_list = other.m_list;
  }
 
 
  ImportImagesWorkOrder::~ImportImagesWorkOrder() {
    delete m_newImages;
    m_newImages = NULL;
 
    m_list = NULL;
  }
 
 
  ImportImagesWorkOrder *ImportImagesWorkOrder::clone() const {
    return new ImportImagesWorkOrder(*this);
  }
 
 
  bool ImportImagesWorkOrder::isExecutable(ProjectItem *item) {
 
      if (item) {
        return (item->text() == "Images");
      }
 
     return false;
  }
 
 
  bool ImportImagesWorkOrder::setupExecution() {
    try {
      WorkOrder::setupExecution();
 
      QStringList fileNames = QFileDialog::getOpenFileNames(
          qobject_cast<QWidget *>(parent()),
          tr("Import Images"), "",
          tr("Isis cubes and list files (*.cub *.lis);;All Files (*)"));
 
      QStringList* stateToSave = new QStringList();
 
      if (!fileNames.isEmpty()) {
        foreach (FileName fileName, fileNames) {
          if (fileName.extension() == "lis") {
            TextFile listFile(fileName.expanded());
            QString path = fileName.path();
            QString lineOfListFile;
 
            while (listFile.GetLine(lineOfListFile)) {
              FileName relFileName(path + "/" + lineOfListFile);
              if (relFileName.fileExists() ) {
                stateToSave->append(path + "/" + lineOfListFile);
              }
              else {
                FileName absFileName(lineOfListFile);
                if ( absFileName.fileExists() && lineOfListFile.startsWith("/") ) {
                  stateToSave->append(lineOfListFile);
                }
 
                else {
                  project()->warn("File " + lineOfListFile + " not found");
                }
              }
            }
          }
          else {
            stateToSave->append(fileName.original());
          }
        }
 
        QMessageBox::StandardButton saveProjectAnswer = QMessageBox::No;
        if (stateToSave->count() >= 100 && project()->isTemporaryProject()) {
          saveProjectAnswer = QMessageBox::question(qobject_cast<QWidget *>(parent()),
                   tr("Save Project Before Importing Images"),
                   tr("Would you like to save your project <b>before</b> importing images? It can be "
                      "slow to save your project after these images have been loaded if you do not "
                      "save now. <br><br>IMPORTANT: WHEN IMPORTING LARGE DATA SETS, SAVING YOUR "
                      "PROJECT BEFORE IMPORTING IS HIGHLY RECOMMENDED."),
                   QMessageBox::Yes | QMessageBox::No | QMessageBox::Cancel,
                   QMessageBox::Yes);
        }
 
        if (saveProjectAnswer == QMessageBox::Yes) {
          SaveProjectWorkOrder saveWorkOrder(project());
          saveWorkOrder.trigger();
        }
 
        QMessageBox::StandardButton copyImagesAnswer = QMessageBox::No;
        if (!stateToSave->isEmpty() && saveProjectAnswer != QMessageBox::Cancel) {
          copyImagesAnswer = QMessageBox::question(qobject_cast<QWidget *>(parent()),
                   tr("Copy Images into Project"),
                   tr("Should images (DN data) be copied into project?"),
                   QMessageBox::Yes | QMessageBox::No | QMessageBox::Cancel,
                   QMessageBox::No);
        }
 
        bool copyDnData = (copyImagesAnswer == QMessageBox::Yes);
 
        stateToSave->prepend(copyDnData? "copy" : "nocopy");
 
        if (fileNames.count() > 1) {
          QUndoCommand::setText(tr("Import %1 Images").arg(stateToSave->count() - 1));
        }
        else if (fileNames.count() == 1 && stateToSave->count() > 2) {
          QUndoCommand::setText(tr("Import %1 Images from %2").arg(
                        QString::number(stateToSave->count() - 1), fileNames.first()));
        }
        else {
          QUndoCommand::setText(tr("Import %1").arg(fileNames.first()));
        }
 
        // The internal data will look like: [ copy|nocopy, img1, img2, ... ]
        setInternalData(*stateToSave);
 
        bool doImport = stateToSave->count() > 1 && saveProjectAnswer != QMessageBox::Cancel &&
                        copyImagesAnswer != QMessageBox::Cancel;
 
        return doImport;
      }
 
    }
    catch (IException &e) {
      QMessageBox::critical(NULL, tr("Error"), tr(e.what()));
    }
    return false;
 
  }
 
 
  void ImportImagesWorkOrder::undoExecution() {
    if (m_list && project()->images().size() > 0 ) {
      project()->waitForImageReaderFinished();
      // Remove the images from disk.
      m_list->deleteFromDisk( project() );
      // Remove the images from the model, which updates the tree view.
      ProjectItem *currentItem =
          project()->directory()->model()->findItemData( QVariant::fromValue(m_list) );
      project()->directory()->model()->removeItem(currentItem);
    }
  }
 
 
  void ImportImagesWorkOrder::postUndoExecution() {
    if (m_list && project()->images().size() > 0 ) {
      foreach (Image *image, *m_list) {
        delete image;
      }
      delete m_list;
    }
  }
 
 
  void ImportImagesWorkOrder::execute() {
    try {
      QObject tmpObj;
      if (internalData().count() > 0) {
        // Recall in setupExecution() that first element in internal data is copy|nocopy,
        // and rest of elements are the expanded names of images to import.
        importConfirmedImages(internalData().mid(1), (internalData()[0] == "copy"));
        project()->setClean(false);
      }
    }
    catch (IException &e) {
        QMessageBox::critical(NULL, tr("Error"), tr(e.what()));
    }
  }
 
 
  void ImportImagesWorkOrder::postExecution() {
    try {
      if (!m_newImages->isEmpty()) {
        project()->addImages(*m_newImages);
        m_list = project()->images().last();
 
        delete m_newImages;
        m_newImages = NULL;
      }
    }
    catch (IException &e) {
      m_status = WorkOrderFinished;
      m_warning.append(e.what());
    }
    if (m_warning != "") {
      project()->warn(m_warning);
    }
  }
 
 
  ImportImagesWorkOrder::OriginalFileToProjectCubeFunctor::OriginalFileToProjectCubeFunctor(
      QThread *guiThread, QDir destinationFolder, bool copyDnData) : m_errors(new IException),
      m_numErrors(new int(0)) {
    m_destinationFolder = destinationFolder;
    m_copyDnData = copyDnData;
    m_guiThread = guiThread;
  }
 
 
  ImportImagesWorkOrder::OriginalFileToProjectCubeFunctor::OriginalFileToProjectCubeFunctor(
      const OriginalFileToProjectCubeFunctor &other) : m_errors(other.m_errors),
      m_numErrors(other.m_numErrors) {
    m_destinationFolder = other.m_destinationFolder;
    m_copyDnData = other.m_copyDnData;
    m_guiThread = other.m_guiThread;
  }
 
 
  ImportImagesWorkOrder::OriginalFileToProjectCubeFunctor::~OriginalFileToProjectCubeFunctor() {
    m_destinationFolder = QDir();
    m_copyDnData = false;
    m_guiThread = NULL;
  }
 
 
  Cube *ImportImagesWorkOrder::OriginalFileToProjectCubeFunctor::operator()(
      const FileName &original) {
    Cube *result = NULL;
 
    // As long as we haven't encountered 20 errors related to importing images, we can continue
    // to import images.
    if (*m_numErrors < 20) {
      try {
        QString destination = QFileInfo(m_destinationFolder, original.name())
                                .absoluteFilePath();
        Cube *input = new Cube(original, "r");
 
        if (m_copyDnData) {
          Cube *copiedCube = input->copy(destination, CubeAttributeOutput());
          delete input;
          input = copiedCube;
        }
 
        FileName externalLabelFile(destination);
        externalLabelFile = externalLabelFile.setExtension("ecub");
 
        Cube *projectImage = input->copy(externalLabelFile, CubeAttributeOutput("+External"));
 
        if (m_copyDnData) {
          // Make sure the external label has a fully relative path to the DN data
          projectImage->relocateDnData(FileName(destination).name());
        }
 
        //  Set new ecub to readOnly.  When closing cube, the labels were being re-written because
        // the cube was read/write. This caused a segfault when imported large number of images
        // because of a label template file being opened too many times.
        projectImage->reopen();
 
        delete input;
 
        result = projectImage;
      }
      // When we encounter an exception, update the m_errors and m_numErrors to with the exception
      // that occurred.
      catch (IException &e) {
        m_errorsLock.lock();
 
        m_errors->append(e);
        (*m_numErrors)++;
 
        m_errorsLock.unlock();
      }
    }
 
    return result;
  }
 
 
  IException ImportImagesWorkOrder::OriginalFileToProjectCubeFunctor::errors() const {
    IException result;
 
    result.append(*m_errors);
 
    if (*m_numErrors >= 20) {
      result.append(
          IException(IException::Unknown,
                     tr("Aborted import images due to a high number of errors"),
                     _FILEINFO_));
    }
    return result;
  }
 
 
  void ImportImagesWorkOrder::importConfirmedImages(QStringList confirmedImages, bool copyDnData) {
    try {
      if (!confirmedImages.isEmpty()) {
        QDir folder = project()->addImageFolder("import");
 
        setProgressRange(0, confirmedImages.count());
 
        // We are creating a new QObject within an asynchronous execute(), which means that this
        // variable, m_newImages, has thread affinity with a thread in the gloabal thread pool
        // (i.e. m_newImages lives in a thread in the global thread pool).
        // see WorkOrder::redo().
        m_newImages = new ImageList;
        m_newImages->reserve(confirmedImages.count());
 
        QStringList confirmedImagesFileNames;
        QStringList confirmedImagesIds;
 
        foreach (QString confirmedImage, confirmedImages) {
          QStringList fileNameAndId = confirmedImage.split(",");
          confirmedImagesFileNames.append(fileNameAndId.first());
 
          // Determine if there was already a unique id provided for the file.
          if (fileNameAndId.count() == 2) {
            confirmedImagesIds.append(fileNameAndId.last());
          }
          else {
            confirmedImagesIds.append(QString());
          }
        }
 
        OriginalFileToProjectCubeFunctor functor(thread(), folder, copyDnData);
        // Start concurrently copying the images to import.
        QFuture<Cube *> future = QtConcurrent::mapped(confirmedImagesFileNames, functor);
 
        // The new internal data will store the copied files as well as their associated unique id's.
        QStringList newInternalData;
        newInternalData.append(internalData().first());
 
        // By releasing a thread from the global thread pool, we are effectively temporarily
        // increasing the max number of available threads. This is useful when a thread goes to sleep
        // waiting for more work, so we can allow other threads to continue.
        // See Qt's QThreadPool::releaseThread() documentation.
        QThreadPool::globalInstance()->releaseThread();
        for (int i = 0; i < confirmedImages.count(); i++) {
          setProgressValue(i);
 
          // This will wait for the result at i to finish (the functor invocation finishes) and
          // get the cube.
          Cube *cube = future.resultAt(i);
 
          if (cube) {
 
            // Confirm that the target body and the gui camera do not exist before creating and 
            // and adding them for each image. Since a target may be covered by many cameras and a 
            // camera may cover many targets, have to get tricky with the checking.
            QString instrumentId = cube->label()->findGroup("Instrument", 
                              PvlObject::FindOptions::Traverse).findKeyword("InstrumentId")[0];
            QString targetName = cube->label()->findGroup("Instrument", 
                              PvlObject::FindOptions::Traverse).findKeyword("TargetName")[0];
            if (!project()->hasTarget(targetName)) {
              Camera *camera = cube->camera();
              Target *target = camera->target();
              project()->addTarget(target);
              
              if (!project()->hasCamera(instrumentId)) {
                project()->addCamera(camera);
              }
            }
            else if (!project()->hasCamera(instrumentId)) {
              Camera *camera = cube->camera();
              project()->addCamera(camera);
            }
 
            // Create a new image from the result in the thread spawned in WorkOrder::redo().
            Image *newImage = new Image(cube);
            newImage->closeCube();
            // Memory for cube is deleted in Image::closeCube()
            cube = NULL;
 
            // Either use a unique id that was already provided or create one for the new image.
            if (confirmedImagesIds[i].isEmpty()) {
              confirmedImagesIds[i] = newImage->id();
            }
            else {
              newImage->setId(confirmedImagesIds[i]);
            }
 
            QStringList imageInternalData;
            imageInternalData.append(confirmedImagesFileNames[i]);
            imageInternalData.append(confirmedImagesIds[i]);
 
            newInternalData.append(imageInternalData.join(","));
 
            m_newImages->append(newImage);
 
            // Move the new image back and its display properities to the GUI thread.
            // Note: thread() returns the GUI thread because this ImportImagesWorkOrder lives
            // (was created) in the GUI thread.
            newImage->moveToThread(thread());
            newImage->displayProperties()->moveToThread(thread());
          }
        }
        // Since we temporarily increased the max thread count (by releasing a thread), make sure
        // to re-reserve the thread for the global thread pool's accounting.
        // See Qt's QThreadPool::reserveThread().
        QThreadPool::globalInstance()->reserveThread();
 
        m_warning = functor.errors().toString();
 
        // Recall that m_newImages has thread affinity with a thread in the global thread pool.
        // Move it to the GUI-thread because these threads in the pool do not run in an event loop,
        // so they cannot process events.
        // See https://doc.qt.io/qt-5/threads-qobject.html#per-thread-event-loop
        // See http://doc.qt.io/qt-5/threads-technologies.html#comparison-of-solutions
        m_newImages->moveToThread(thread());
 
        if (m_newImages->isEmpty()) {
          folder.removeRecursively();
        }
 
        setInternalData(newInternalData);
      }
    }
    catch (IException &e) {
        QMessageBox::critical(NULL, tr("Error"), tr(e.what()));
    }
  }
}