qgsmaphittest.cpp

Go to the documentation of this file.

/***************************************************************************
    qgsmaphittest.cpp
    ---------------------
    begin                : September 2014
    copyright            : (C) 2014 by Martin Dobias
    email                : wonder dot sk at gmail dot com
 ***************************************************************************
 *                                                                         *
 *   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 2 of the License, or     *
 *   (at your option) any later version.                                   *
 *                                                                         *
 ***************************************************************************/
 
#include "qgsmaphittest.h"
 
#include "qgsexpressioncontextutils.h"
#include "qgsfeatureiterator.h"
#include "qgsgeometry.h"
#include "qgsgeometryengine.h"
#include "qgsmaplayerstyle.h"
#include "qgsrasterlayer.h"
#include "qgsrasterlayerutils.h"
#include "qgsrasterrenderer.h"
#include "qgsrendercontext.h"
#include "qgsrenderer.h"
#include "qgssymbollayerutils.h"
#include "qgsvectorlayer.h"
#include "qgsvectorlayerfeatureiterator.h"
 
#include "moc_qgsmaphittest.cpp"
 
QgsMapHitTest::QgsMapHitTest( const QgsMapSettings &settings, const QgsGeometry &polygon, const LayerFilterExpression &layerFilterExpression )
  : mSettings( QgsLayerTreeFilterSettings( settings ) )
{
  mSettings.setLayerFilterExpressions( layerFilterExpression );
  mSettings.setFilterPolygon( polygon );
}
 
QgsMapHitTest::QgsMapHitTest( const QgsMapSettings &settings, const LayerFilterExpression &layerFilterExpression )
  : mSettings( QgsLayerTreeFilterSettings( settings ) )
{
  mSettings.setLayerFilterExpressions( layerFilterExpression );
  mSettings.setFlags( Qgis::LayerTreeFilterFlag::SkipVisibilityCheck );
}
 
QgsMapHitTest::QgsMapHitTest( const QgsLayerTreeFilterSettings &settings )
  : mSettings( settings )
{
 
}
 
void QgsMapHitTest::run()
{
  const QgsMapSettings &mapSettings = mSettings.mapSettings();
 
  // TODO: do we need this temp image?
  QImage tmpImage( mapSettings.outputSize(), mapSettings.outputImageFormat() );
  tmpImage.setDotsPerMeterX( static_cast< int >( std::round( mapSettings.outputDpi() * 25.4 ) ) );
  tmpImage.setDotsPerMeterY( static_cast< int >( std::round( mapSettings.outputDpi() * 25.4 ) ) );
  QPainter painter( &tmpImage );
 
  QgsRenderContext context = QgsRenderContext::fromMapSettings( mapSettings );
  context.setPainter( &painter ); // we are not going to draw anything, but we still need a working painter
 
  const QList< QgsMapLayer * > layers = mSettings.layers();
  for ( QgsMapLayer *layer : layers )
  {
 
    QgsGeometry extent;
    if ( !( mSettings.flags() & Qgis::LayerTreeFilterFlag::SkipVisibilityCheck ) )
    {
      if ( !layer->isInScaleRange( mapSettings.scale() ) )
      {
        continue;
      }
 
      extent = mSettings.combinedVisibleExtentForLayer( layer );
 
      context.setCoordinateTransform( mapSettings.layerTransform( layer ) );
      context.setExtent( extent.boundingBox() );
    }
 
    if ( QgsVectorLayer *vl = qobject_cast<QgsVectorLayer *>( layer ) )
    {
      if ( !vl->renderer() )
        continue;
 
      context.expressionContext() << QgsExpressionContextUtils::layerScope( vl );
      SymbolSet &usedSymbols = mHitTest[vl->id()];
      SymbolSet &usedSymbolsRuleKey = mHitTestRuleKey[vl->id()];
 
      QgsMapLayerStyleOverride styleOverride( vl );
      if ( mapSettings.layerStyleOverrides().contains( vl->id() ) )
        styleOverride.setOverrideStyle( mapSettings.layerStyleOverrides().value( vl->id() ) );
 
      auto source = std::make_unique< QgsVectorLayerFeatureSource >( vl );
      runHitTestFeatureSource( source.get(),
                               vl->id(), vl->fields(), vl->renderer(),
                               usedSymbols, usedSymbolsRuleKey, context,
                               nullptr, extent );
    }
    else if ( QgsRasterLayer *rl = qobject_cast<QgsRasterLayer *>( layer ) )
    {
      if ( !rl->renderer() || !rl->dataProvider() )
        continue;
 
      QgsRasterMinMaxOrigin minMaxOrigin = rl->renderer()->minMaxOrigin();
 
      runHitTestRasterSource( rl->dataProvider(), rl->id(), rl->renderer()->inputBand(), minMaxOrigin, minMaxOrigin.limits(),
                              context, nullptr, extent );
    }
    else if ( QgsMeshLayer *ml = qobject_cast<QgsMeshLayer *>( layer ) )
    {
      QgsMeshDatasetIndex datasetIndex = ml->activeScalarDatasetIndex( context );
      QgsMeshRendererScalarSettings scalarSettings = ml->rendererSettings().scalarSettings( datasetIndex.dataset() );
 
      runHitTestMeshSource( ml, ml->id(), datasetIndex, context, nullptr, extent );
    }
  }
 
  painter.end();
}
 
QMap<QString, QSet<QString> > QgsMapHitTest::results() const
{
  return mHitTestRuleKey;
}

QMap<QString, QList<QString> > QgsMapHitTest::resultsPy() const
{
  QMap<QString, QList<QString> > res;
  for ( auto it = mHitTestRuleKey.begin(); it != mHitTestRuleKey.end(); ++it )
  {
    res.insert( it.key(), qgis::setToList( it.value() ) );
  }
  return res;
}
 
bool QgsMapHitTest::symbolVisible( QgsSymbol *symbol, QgsVectorLayer *layer ) const
{
  if ( !symbol || !layer )
    return false;
 
  auto it = mHitTest.constFind( layer->id() );
  if ( it == mHitTest.constEnd() )
    return false;
 
  return it->contains( QgsSymbolLayerUtils::symbolProperties( symbol ) );
}
 
bool QgsMapHitTest::legendKeyVisible( const QString &ruleKey, QgsVectorLayer *layer ) const
{
  if ( !layer )
    return false;
 
  auto it = mHitTestRuleKey.constFind( layer->id() );
  if ( it == mHitTestRuleKey.constEnd() )
    return false;
 
  return it->contains( ruleKey );
}
 
void QgsMapHitTest::runHitTestFeatureSource( QgsAbstractFeatureSource *source,
    const QString &layerId,
    const QgsFields &fields,
    const QgsFeatureRenderer *renderer,
    SymbolSet &usedSymbols,
    SymbolSet &usedSymbolsRuleKey,
    QgsRenderContext &context,
    QgsFeedback *feedback,
    const QgsGeometry &visibleExtent )
{
  std::unique_ptr< QgsFeatureRenderer > r( renderer->clone() );
  const bool moreSymbolsPerFeature = r->capabilities() & QgsFeatureRenderer::MoreSymbolsPerFeature;
  r->startRender( context, fields );
 
  // shortcut early if we know that there's nothing visible
  if ( r->canSkipRender() )
  {
    r->stopRender( context );
    return;
  }
 
  // if there's no legend items for this layer, shortcut out early
  QSet< QString > remainingKeysToFind = r->legendKeys();
  if ( remainingKeysToFind.empty() )
  {
    r->stopRender( context );
    return;
  }
 
  QgsFeatureRequest request;
  if ( feedback )
    request.setFeedback( feedback );
 
  const QString rendererFilterExpression = r->filter( fields );
  if ( !rendererFilterExpression.isEmpty() )
  {
    request.setFilterExpression( rendererFilterExpression );
  }
 
  request.setExpressionContext( context.expressionContext() );
 
  QSet<QString> requiredAttributes = r->usedAttributes( context );
 
  QgsGeometry transformedPolygon = visibleExtent;
  if ( transformedPolygon.type() != Qgis::GeometryType::Polygon )
  {
    transformedPolygon = QgsGeometry();
  }
 
  if ( feedback && feedback->isCanceled() )
  {
    r->stopRender( context );
    return;
  }
 
  const QMap<QString, QString> layerFilterExpressions = mSettings.layerFilterExpressions();
  if ( auto it = layerFilterExpressions.constFind( layerId ); it != layerFilterExpressions.constEnd() )
  {
    const QString expression = *it;
    QgsExpression expr( expression );
    expr.prepare( &context.expressionContext() );
 
    requiredAttributes.unite( expr.referencedColumns() );
    request.combineFilterExpression( expression );
  }
 
  request.setSubsetOfAttributes( requiredAttributes, fields );
 
  std::unique_ptr< QgsGeometryEngine > polygonEngine;
  if ( !( mSettings.flags() & Qgis::LayerTreeFilterFlag::SkipVisibilityCheck ) )
  {
    if ( transformedPolygon.isNull() )
    {
      request.setFilterRect( context.extent() );
      request.setFlags( Qgis::FeatureRequestFlag::ExactIntersect );
    }
    else
    {
      request.setFilterRect( transformedPolygon.boundingBox() );
      polygonEngine.reset( QgsGeometry::createGeometryEngine( transformedPolygon.constGet() ) );
      polygonEngine->prepareGeometry();
    }
  }
 
  if ( feedback && feedback->isCanceled() )
  {
    r->stopRender( context );
    return;
  }
 
  QgsFeatureIterator fi = source->getFeatures( request );
 
  usedSymbols.clear();
  usedSymbolsRuleKey.clear();
 
  QgsFeature f;
  while ( fi.nextFeature( f ) )
  {
    if ( feedback && feedback->isCanceled() )
      break;
 
    // filter out elements outside of the polygon
    if ( f.hasGeometry() && polygonEngine )
    {
      if ( !polygonEngine->intersects( f.geometry().constGet() ) )
      {
        continue;
      }
    }
 
    context.expressionContext().setFeature( f );
 
    //make sure we store string representation of symbol, not pointer
    //otherwise layer style override changes will delete original symbols and leave hanging pointers
    const QSet< QString > legendKeysForFeature = r->legendKeysForFeature( f, context );
    for ( const QString &legendKey : legendKeysForFeature )
    {
      usedSymbolsRuleKey.insert( legendKey );
      remainingKeysToFind.remove( legendKey );
    }
 
    if ( moreSymbolsPerFeature )
    {
      const QgsSymbolList originalSymbolsForFeature = r->originalSymbolsForFeature( f, context );
      for ( QgsSymbol *s : originalSymbolsForFeature )
      {
        if ( s )
          usedSymbols.insert( QgsSymbolLayerUtils::symbolProperties( s ) );
      }
    }
    else
    {
      QgsSymbol *s = r->originalSymbolForFeature( f, context );
      if ( s )
        usedSymbols.insert( QgsSymbolLayerUtils::symbolProperties( s ) );
    }
 
    if ( remainingKeysToFind.empty() )
    {
      // already found features for all legend items, no need to keep searching
      break;
    }
  }
  r->stopRender( context );
}
 
void QgsMapHitTest::runHitTestRasterSource( QgsRasterDataProvider *provider,
    const QString &layerId,
    const int band,
    const QgsRasterMinMaxOrigin minMaxOrigin,
    const Qgis::RasterRangeLimit rangeLimit,
    const QgsRenderContext &context,
    QgsFeedback *feedback,
    const QgsGeometry &visibleExtent )
{
  if ( feedback && feedback->isCanceled() )
    return;
 
  QgsRectangle transformedExtent;
  if ( visibleExtent.type() != Qgis::GeometryType::Polygon )
  {
    transformedExtent = context.extent();
  }
  else
  {
    transformedExtent = visibleExtent.boundingBox();
  }
 
  double min = std::numeric_limits<double>::quiet_NaN();
  double max = std::numeric_limits<double>::quiet_NaN();
  bool found = false;
 
  switch ( minMaxOrigin.extent() )
  {
    case Qgis::RasterRangeExtent::UpdatedCanvas:
    {
      if ( provider->extent().intersects( transformedExtent ) )
      {
        QgsRasterLayerUtils::computeMinMax( provider, band, minMaxOrigin, rangeLimit,
                                            transformedExtent, static_cast<int>( QgsRasterLayer::SAMPLE_SIZE ), min, max );
        found = true;
      }
      break;
    }
    case Qgis::RasterRangeExtent::WholeRaster:
    case Qgis::RasterRangeExtent::FixedCanvas:
      break;
  }
 
  if ( found )
  {
    mHitTestRenderersUpdatedCanvas.insert( layerId, std::pair<double, double>( min, max ) );
  }
}
 
void QgsMapHitTest::runHitTestMeshSource( QgsMeshLayer *layer,
    const QString &layerId,
    const QgsMeshDatasetIndex datasetIndex,
    const QgsRenderContext &context,
    QgsFeedback *feedback,
    const QgsGeometry &visibleExtent )
{
  if ( feedback && feedback->isCanceled() )
    return;
 
  QgsRectangle transformedExtent;
  if ( visibleExtent.type() != Qgis::GeometryType::Polygon )
  {
    transformedExtent = context.extent();
  }
  else
  {
    transformedExtent = visibleExtent.boundingBox();
  }
 
  Qgis::MeshRangeExtent rangeExtent = layer->rendererSettings().scalarSettings( datasetIndex.group() ).extent();
  Qgis::MeshRangeLimit rangeLimit = layer->rendererSettings().scalarSettings( datasetIndex.group() ).limits();
 
  double min = std::numeric_limits<double>::quiet_NaN();
  double max = std::numeric_limits<double>::quiet_NaN();
  bool found = false;
 
  if ( datasetIndex.isValid() )
  {
    switch ( rangeExtent )
    {
      case Qgis::MeshRangeExtent::UpdatedCanvas:
      {
        switch ( rangeLimit )
        {
          case Qgis::MeshRangeLimit::MinimumMaximum:
          {
            found  = layer->minimumMaximumActiveScalarDataset( transformedExtent, datasetIndex, min, max );
            break;
          }
          case Qgis::MeshRangeLimit::NotSet:
            break;
        }
        break;
      }
      case Qgis::MeshRangeExtent::WholeMesh:
      case Qgis::MeshRangeExtent::FixedCanvas:
        break;
    }
  }
 
  if ( found )
  {
    mHitTestRenderersUpdatedCanvas.insert( layerId, std::pair<double, double>( min, max ) );
  }
}
 
//
// QgsMapHitTestTask
//
 
QgsMapHitTestTask::QgsMapHitTestTask( const QgsLayerTreeFilterSettings &settings )
  : QgsTask( tr( "Updating Legend" ), QgsTask::Flag::CanCancel | QgsTask::Flag::CancelWithoutPrompt | QgsTask::Flag::Silent )
  , mSettings( settings )
{
  prepare();
}
 
QMap<QString, QSet<QString> > QgsMapHitTestTask::results() const
{
  return mResults;
}

QMap<QString, QList<QString> > QgsMapHitTestTask::resultsPy() const
{
  QMap<QString, QList<QString> > res;
  for ( auto it = mResults.begin(); it != mResults.end(); ++it )
  {
    res.insert( it.key(), qgis::setToList( it.value() ) );
  }
  return res;
}
 
void QgsMapHitTestTask::prepare()
{
  const QgsMapSettings &mapSettings = mSettings.mapSettings();
 
  const QList< QgsMapLayer * > layers = mSettings.layers();
 
  QgsRenderContext context = QgsRenderContext::fromMapSettings( mapSettings );
 
  for ( QgsMapLayer *layer : layers )
  {
    QgsGeometry extent;
    if ( !( mSettings.flags() & Qgis::LayerTreeFilterFlag::SkipVisibilityCheck ) )
    {
      if ( !layer->isInScaleRange( mapSettings.scale() ) )
      {
        continue;
      }
 
      extent = mSettings.combinedVisibleExtentForLayer( layer );
    }
 
    if ( QgsVectorLayer *vl = qobject_cast<QgsVectorLayer *>( layer ) )
    {
      if ( !vl->renderer() )
        continue;
 
      QgsMapLayerStyleOverride styleOverride( vl );
      if ( mapSettings.layerStyleOverrides().contains( vl->id() ) )
        styleOverride.setOverrideStyle( mapSettings.layerStyleOverrides().value( vl->id() ) );
 
      PreparedLayerData layerData;
      layerData.source = std::make_unique< QgsVectorLayerFeatureSource >( vl );
      layerData.layerId = vl->id();
      layerData.fields = vl->fields();
      layerData.renderer.reset( vl->renderer()->clone() );
      layerData.transform = mapSettings.layerTransform( vl );
      layerData.extent = extent;
      layerData.layerScope.reset( QgsExpressionContextUtils::layerScope( vl ) );
 
      mPreparedData.emplace_back( std::move( layerData ) );
    }
    else if ( QgsRasterLayer *rl = qobject_cast<QgsRasterLayer *>( layer ) )
    {
      if ( !rl->dataProvider() || !rl->renderer() )
        continue;
 
      QgsRasterMinMaxOrigin minMaxOrigin = rl->renderer()->minMaxOrigin();
 
      PreparedRasterData rasterData;
      rasterData.provider = std::unique_ptr< QgsRasterDataProvider >( rl->dataProvider()->clone() );
      rasterData.provider->moveToThread( nullptr );
 
      rasterData.layerId = rl->id();
      rasterData.band = rl->renderer()->inputBand();
      rasterData.minMaxOrigin = minMaxOrigin;
      rasterData.rangeLimit = minMaxOrigin.limits();
      rasterData.transform = mapSettings.layerTransform( rl );
      rasterData.extent = extent;
 
      mPreparedRasterData.emplace_back( std::move( rasterData ) );
    }
    else if ( QgsMeshLayer *ml = qobject_cast<QgsMeshLayer *>( layer ) )
    {
      PreparedMeshData meshData;
      meshData.layer = std::unique_ptr< QgsMeshLayer >( ml->clone() );
      meshData.layer->moveToThread( nullptr );
 
      meshData.layerId = ml->id();
      meshData.datasetIndex = ml->activeScalarDatasetIndex( context );
      meshData.transform = mapSettings.layerTransform( ml );
      meshData.extent = extent;
 
      mPreparedMeshData.emplace_back( std::move( meshData ) );
    }
  }
}
 
void QgsMapHitTestTask::cancel()
{
  if ( mFeedback )
    mFeedback->cancel();
 
  QgsTask::cancel();
}
 
bool QgsMapHitTestTask::run()
{
  mFeedback = std::make_unique< QgsFeedback >();
  connect( mFeedback.get(), &QgsFeedback::progressChanged, this, &QgsTask::progressChanged );
 
  auto hitTest = std::make_unique< QgsMapHitTest >( mSettings );
 
  // TODO: do we need this temp image?
  const QgsMapSettings &mapSettings = mSettings.mapSettings();
 
  QImage tmpImage( mapSettings.outputSize(), mapSettings.outputImageFormat() );
  tmpImage.setDotsPerMeterX( static_cast< int >( std::round( mapSettings.outputDpi() * 25.4 ) ) );
  tmpImage.setDotsPerMeterY( static_cast< int >( std::round( mapSettings.outputDpi() * 25.4 ) ) );
  QPainter painter( &tmpImage );
 
  QgsRenderContext context = QgsRenderContext::fromMapSettings( mapSettings );
 
  context.setPainter( &painter ); // we are not going to draw anything, but we still need a working painter
 
  std::size_t layerIdx = 0;
  const std::size_t totalCount = mPreparedData.size() + mPreparedRasterData.size() + mPreparedMeshData.size();
 
  for ( auto &layerData : mPreparedData )
  {
    mFeedback->setProgress( static_cast< double >( layerIdx ) / static_cast< double >( totalCount ) * 100.0 );
    if ( mFeedback->isCanceled() )
      break;
 
    QgsMapHitTest::SymbolSet &usedSymbols = hitTest->mHitTest[layerData.layerId];
    QgsMapHitTest::SymbolSet &usedSymbolsRuleKey = hitTest->mHitTestRuleKey[layerData.layerId];
 
    context.setCoordinateTransform( layerData.transform );
    context.setExtent( layerData.extent.boundingBox() );
 
    QgsExpressionContextScope *layerScope = layerData.layerScope.release();
    QgsExpressionContextScopePopper scopePopper( context.expressionContext(), layerScope );
 
    hitTest->runHitTestFeatureSource( layerData.source.get(),
                                      layerData.layerId,
                                      layerData.fields,
                                      layerData.renderer.get(),
                                      usedSymbols,
                                      usedSymbolsRuleKey,
                                      context,
                                      mFeedback.get(),
                                      layerData.extent );
    layerIdx++;
  }
 
  layerIdx = 0;
  for ( PreparedRasterData &rasterData : mPreparedRasterData )
  {
    rasterData.provider->moveToThread( QThread:: currentThread() );
 
    mFeedback->setProgress( ( static_cast<double>( mPreparedData.size() ) + static_cast< double >( layerIdx ) ) / static_cast< double >( totalCount ) * 100.0 );
    if ( mFeedback->isCanceled() )
      break;
 
    context.setCoordinateTransform( rasterData.transform );
    context.setExtent( rasterData.extent.boundingBox() );
 
    hitTest->runHitTestRasterSource( rasterData.provider.get(),
                                     rasterData.layerId,
                                     rasterData.band,
                                     rasterData.minMaxOrigin,
                                     rasterData.rangeLimit,
                                     context,
                                     mFeedback.get(),
                                     rasterData.extent );
    layerIdx++;
  }
 
  layerIdx = 0;
  for ( PreparedMeshData &meshData : mPreparedMeshData )
  {
    mFeedback->setProgress( ( static_cast<double>( mPreparedData.size() ) + static_cast<double>( mPreparedRasterData.size() ) + static_cast< double >( layerIdx ) ) / static_cast< double >( totalCount ) * 100.0 );
    if ( mFeedback->isCanceled() )
      break;
 
    context.setCoordinateTransform( meshData.transform );
    context.setExtent( meshData.extent.boundingBox() );
 
    meshData.layer->moveToThread( QThread:: currentThread() );
    meshData.layer->updateTriangularMesh();
 
    hitTest->runHitTestMeshSource( meshData.layer.get(),
                                   meshData.layerId,
                                   meshData.datasetIndex,
                                   context,
                                   mFeedback.get(),
                                   meshData.extent );
    layerIdx++;
  }
 
  mResults = hitTest->mHitTestRuleKey;
 
  mResultsRenderersUpdatedCanvas = hitTest->mHitTestRenderersUpdatedCanvas;
 
  mFeedback.reset();
 
  // data moved to the task thread above need to explicitly emptied here
  // otherwise destructors run in the main thread may comply
  // raster data
  mPreparedRasterData.clear();
  //mesh data
  mPreparedMeshData.clear();
 
  return true;
}