BudgetSolrAddon.java
/*
* Copyright (c) 2002-2020, City of Paris
* All rights reserved.
*
* Redistribution and use in source and binary forms, with or without
* modification, are permitted provided that the following conditions
* are met:
*
* 1. Redistributions of source code must retain the above copyright notice
* and the following disclaimer.
*
* 2. Redistributions in binary form must reproduce the above copyright notice
* and the following disclaimer in the documentation and/or other materials
* provided with the distribution.
*
* 3. Neither the name of 'Mairie de Paris' nor 'Lutece' nor the names of its
* contributors may be used to endorse or promote products derived from
* this software without specific prior written permission.
*
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT HOLDERS OR CONTRIBUTORS BE
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
* POSSIBILITY OF SUCH DAMAGE.
*
* License 1.0
*/
package fr.paris.lutece.plugins.participatorybudget.service;
import java.io.IOException;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.servlet.http.HttpServletRequest;
import fr.paris.lutece.plugins.leaflet.business.GeolocItem;
import fr.paris.lutece.plugins.leaflet.service.IconService;
import fr.paris.lutece.plugins.participatorybudget.service.campaign.CampaignService;
import fr.paris.lutece.plugins.participatorybudget.service.vote.MyVoteService;
import fr.paris.lutece.plugins.participatorybudget.util.BudgetUtils;
import fr.paris.lutece.plugins.search.solr.business.SolrSearchEngine;
import fr.paris.lutece.plugins.search.solr.business.SolrSearchResult;
import fr.paris.lutece.plugins.search.solr.indexer.SolrItem;
import fr.paris.lutece.plugins.search.solr.service.ISolrSearchAppAddOn;
import fr.paris.lutece.portal.service.security.LuteceUser;
import fr.paris.lutece.portal.service.security.SecurityService;
import fr.paris.lutece.portal.service.spring.SpringContextService;
import fr.paris.lutece.portal.service.util.AppLogService;
import fr.paris.lutece.portal.service.util.AppPropertiesService;
public class BudgetSolrAddon implements ISolrSearchAppAddOn
{
// Parameters copied from SolrSearchApp
private static final String SOLRSEARCHAPP_PARAMETER_CONF = "conf";
private static final String SOLRSEARCHAPP_MARK_POINTS_GEOJSON = "geojson";
private static final String SOLRSEARCHAPP_MARK_POINTS_ID = "id";
private static final String SOLRSEARCHAPP_MARK_POINTS_FIELDCODE = "code";
private static final String SOLRSEARCHAPP_MARK_POINTS_TYPE = "type";
private static final String SOLRSEARCHAPP_PROPERTY_SOLR_RESPONSE_MAX = "solr.reponse.max";
private static final int SOLRSEARCHAPP_SOLR_RESPONSE_MAX = Integer
.parseInt( AppPropertiesService.getProperty( SOLRSEARCHAPP_PROPERTY_SOLR_RESPONSE_MAX, "50" ) );
private static final String PARAMETER_CONF_MAP_PROJETS = "projects_submitted_map"; // Vue des projets soumis au vote
private static final String SOLR_QUERY_ALL = "*:*";
private static final String PROPERTY_OLDPROJECTS_FQ = "participatorybudget.oldprojects.fq";
private static final String [ ] SOLR_FQ_OLDPROJECTS = {
AppPropertiesService.getProperty( PROPERTY_OLDPROJECTS_FQ, "(statut_project_text:GAGNANT' OR statut_project_text:'gagnant') AND type:'PB Project" )
};
private static final String MARK_OLDPROJECTS_POINTS = "oldprojects_points";
private static final String MARK_ARRONDISSEMENT_VOTE_USER = "arrondissementVote";
private static final String PARAMETER_REMOVE_ARR_FILTER = "remove_arr";
private static final String MARK_REMOVE_ARR_FILTER = "remove_arr";
/**
* Ajoute les projets des années précédentes.
*/
public void buildPageAddOn( Map<String, Object> model, HttpServletRequest request )
{
if ( PARAMETER_CONF_MAP_PROJETS.equals( request.getParameter( SOLRSEARCHAPP_PARAMETER_CONF ) ) )
{
SolrSearchEngine engine = SolrSearchEngine.getInstance( );
List<SolrSearchResult> listResultsGeoloc = engine.getGeolocSearchResults( SOLR_QUERY_ALL, SOLR_FQ_OLDPROJECTS, SOLRSEARCHAPP_SOLR_RESPONSE_MAX );
List<HashMap<String, Object>> points = getGeolocModel( listResultsGeoloc );
model.put( MARK_OLDPROJECTS_POINTS, points );
}
MyVoteService _myVoteService = SpringContextService.getBean( MyVoteService.BEAN_NAME );
String arrondissement = null;
boolean isValidated = false;
LuteceUser user = SecurityService.getInstance( ).getRegisteredUser( request );
if ( user != null )
{
arrondissement = BudgetUtils.getArrondissementDisplay( user );
isValidated = _myVoteService.isUserVoteValidated( user.getName( ) );
}
if ( arrondissement != null )
{
model.put( MARK_ARRONDISSEMENT_VOTE_USER, arrondissement );
}
else
{
model.put( MARK_ARRONDISSEMENT_VOTE_USER, "notConnected" );
}
model.put( BudgetUtils.MARK_VOTE_VALIDATED, isValidated );
model.put( MARK_REMOVE_ARR_FILTER, request.getParameter( PARAMETER_REMOVE_ARR_FILTER ) );
model.put( BudgetUtils.MARK_CAMPAIGN_SERVICE, CampaignService.getInstance( ) );
}
/**
* CopyPasted from SolrSearchApp to have the same freemarkers as if it was a search
*/
private static List<HashMap<String, Object>> getGeolocModel( List<SolrSearchResult> listResultsGeoloc )
{
List<HashMap<String, Object>> points = new ArrayList<HashMap<String, Object>>( listResultsGeoloc.size( ) );
HashMap<String, String> iconKeysCache = new HashMap<String, String>( );
for ( SolrSearchResult result : listResultsGeoloc )
{
Map<String, Object> dynamicFields = result.getDynamicFields( );
for ( String key : dynamicFields.keySet( ) )
{
if ( key.endsWith( SolrItem.DYNAMIC_GEOJSON_FIELD_SUFFIX ) )
{
HashMap<String, Object> h = new HashMap<String, Object>( );
String strJson = (String) dynamicFields.get( key );
GeolocItem geolocItem = null;
try
{
geolocItem = GeolocItem.fromJSON( strJson );
}
catch( IOException e )
{
AppLogService.error( "SolrSearchApp: error parsing geoloc JSON: " + strJson + ", exception " + e );
}
if ( geolocItem != null )
{
String strType = result.getId( ).substring( result.getId( ).lastIndexOf( "_" ) + 1 );
String strIcon;
if ( iconKeysCache.containsKey( geolocItem.getIcon( ) ) )
{
strIcon = iconKeysCache.get( geolocItem.getIcon( ) );
}
else
{
strIcon = IconService.getIcon( strType, geolocItem.getIcon( ) );
iconKeysCache.put( geolocItem.getIcon( ), strIcon );
}
geolocItem.setIcon( strIcon );
h.put( SOLRSEARCHAPP_MARK_POINTS_GEOJSON, geolocItem.toJSON( ) );
h.put( SOLRSEARCHAPP_MARK_POINTS_ID,
result.getId( ).substring( result.getId( ).indexOf( "_" ) + 1, result.getId( ).lastIndexOf( "_" ) ) );
h.put( SOLRSEARCHAPP_MARK_POINTS_FIELDCODE, key.substring( 0, key.lastIndexOf( "_" ) ) );
if ( strType.equals( "doc" ) )
{
h.put( SOLRSEARCHAPP_MARK_POINTS_TYPE, "gagnant" );
}
points.add( h );
}
}
}
}
return points;
}
}