DemandNotificationRestService.java
/*
* Copyright (c) 2002-2023, Mairie de 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.grusupply.web.rs;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;
import java.util.Optional;
import javax.ws.rs.GET;
import javax.ws.rs.Path;
import javax.ws.rs.Produces;
import javax.ws.rs.QueryParam;
import javax.ws.rs.core.MediaType;
import javax.ws.rs.core.Response;
import org.apache.commons.lang3.StringUtils;
import fr.paris.lutece.plugins.grubusiness.business.demand.Demand;
import fr.paris.lutece.plugins.grubusiness.business.notification.EnumNotificationType;
import fr.paris.lutece.plugins.grubusiness.business.notification.Notification;
import fr.paris.lutece.plugins.grubusiness.business.web.rs.DemandDisplay;
import fr.paris.lutece.plugins.grubusiness.business.web.rs.DemandResult;
import fr.paris.lutece.plugins.grubusiness.business.web.rs.EnumGenericStatus;
import fr.paris.lutece.plugins.grubusiness.business.web.rs.NotificationResult;
import fr.paris.lutece.plugins.grubusiness.business.web.rs.SearchResult;
import fr.paris.lutece.plugins.grustoragedb.business.DemandHome;
import fr.paris.lutece.plugins.grustoragedb.business.NotificationHome;
import fr.paris.lutece.plugins.grustoragedb.business.Status;
import fr.paris.lutece.plugins.grustoragedb.business.StatusHome;
import fr.paris.lutece.plugins.grustoragedb.business.DemandType;
import fr.paris.lutece.plugins.grustoragedb.business.DemandTypeHome;
import fr.paris.lutece.plugins.grusupply.constant.GruSupplyConstants;
import fr.paris.lutece.plugins.grusupply.utils.GrusupplyUtils;
import fr.paris.lutece.plugins.rest.service.RestConstants;
import fr.paris.lutece.portal.service.i18n.I18nService;
import fr.paris.lutece.portal.service.util.AppPropertiesService;
import fr.paris.lutece.portal.web.l10n.LocaleService;
import fr.paris.lutece.util.html.Paginator;
/**
*
* Service Rest DemandNotificationRestService
*
*/
@Path( RestConstants.BASE_PATH + GruSupplyConstants.PLUGIN_NAME + GruSupplyConstants.PATH_DEMAND )
public class DemandNotificationRestService
{
/**
* Return list of demand
*
* @param strDemandType
* @param strPage
*/
@GET
@Path( GruSupplyConstants.PATH_DEMAND_LIST )
@Produces( MediaType.APPLICATION_JSON )
public Response getListDemand( @QueryParam( GruSupplyConstants.QUERY_PARAM_ID_DEMAND_TYPE ) String strIdDemandType,
@QueryParam( GruSupplyConstants.QUERY_PARAM_INDEX ) String strIndex,
@QueryParam( GruSupplyConstants.QUERY_PARAM_CUSTOMER_ID ) String strCustomerId,
@QueryParam( GruSupplyConstants.QUERY_PARAM_NOTIFICATION_TYPE ) String strNotificationType )
{
int nIndex = StringUtils.isEmpty( strIndex ) ? 1 : Integer.parseInt( strIndex );
int nDefaultItemsPerPage = AppPropertiesService.getPropertyInt( GruSupplyConstants.LIMIT_DEMAND_API_REST, 10 );
DemandResult result = new DemandResult( );
if( StringUtils.isEmpty( strCustomerId ) )
{
result.setStatus( SearchResult.ERROR_FIELD_MANDATORY );
result.setErrorMessage( GruSupplyConstants.MESSAGE_ERROR_DEMAND );
return Response.status( Response.Status.BAD_REQUEST ).entity( GrusupplyUtils.convertToJsonString( result ) ).build( );
}
List<Integer> listIds = DemandHome.getIdsByCustomerIdAndDemandTypeId( strCustomerId, strNotificationType, strIdDemandType );
return getResponse( result, nIndex, nDefaultItemsPerPage, listIds );
}
/**
* Get list by status
*
* @param strIdDemandType
* @param strIndex
* @param strCustomerId
* @return list of active demand
*/
@GET
@Path( GruSupplyConstants.PATH_DEMAND_STATUS )
@Produces( MediaType.APPLICATION_JSON )
public Response getListOfDemandByStatus( @QueryParam( GruSupplyConstants.QUERY_PARAM_ID_DEMAND_TYPE ) String strIdDemandType,
@QueryParam( GruSupplyConstants.QUERY_PARAM_INDEX ) String strIndex,
@QueryParam( GruSupplyConstants.QUERY_PARAM_CUSTOMER_ID ) String strCustomerId,
@QueryParam( GruSupplyConstants.QUERY_PARAM_LIST_STATUS ) String strListStatus,
@QueryParam( GruSupplyConstants.QUERY_PARAM_NOTIFICATION_TYPE ) String strNotificationType )
{
int nIndex = StringUtils.isEmpty( strIndex ) ? 1 : Integer.parseInt( strIndex );
int nDefaultItemsPerPage = AppPropertiesService.getPropertyInt( GruSupplyConstants.LIMIT_DEMAND_API_REST, 10 );
DemandResult result = new DemandResult( );
if( StringUtils.isEmpty( strCustomerId ) || StringUtils.isEmpty( strListStatus ) )
{
result.setStatus( SearchResult.ERROR_FIELD_MANDATORY );
result.setErrorMessage( GruSupplyConstants.MESSAGE_ERROR_STATUS );
return Response.status( Response.Status.BAD_REQUEST ).entity( GrusupplyUtils.convertToJsonString( result ) ).build( );
}
List<String> listStatus = Arrays.asList( strListStatus.split( "," ) );
List<Integer> listIds = DemandHome.getIdsByStatus( strCustomerId, listStatus, strNotificationType, strIdDemandType );
return getResponse( result, nIndex, nDefaultItemsPerPage, listIds );
}
/**
* Get response
* @param result
* @param nIndex
* @param nDefaultItemsPerPage
* @param listIds
* @return
*/
private Response getResponse( DemandResult result, int nIndex, int nDefaultItemsPerPage, List<Integer> listIds )
{
if ( !listIds.isEmpty( ) )
{
Paginator<Integer> paginator = new Paginator<>( listIds, nDefaultItemsPerPage, StringUtils.EMPTY, StringUtils.EMPTY, String.valueOf( nIndex ) );
result.setListDemandDisplay( getListDemandDisplay( paginator.getPageItems( ) ) );
result.setIndex( String.valueOf( nIndex ) );
result.setPaginator( nIndex + "/" + paginator.getPagesCount( ) );
result.setStatus( Response.Status.OK.name( ) );
result.setNumberResult( listIds.size( ) );
}
return Response.status( Response.Status.OK ).entity( GrusupplyUtils.convertToJsonString( result ) ).build( );
}
/**
*
* @param listIds
* @return list of demand display
*/
private List<DemandDisplay> getListDemandDisplay( List<Integer> listIds )
{
List<DemandDisplay> listDemandDisplay = new ArrayList<>( );
List<Demand> listDemand = DemandHome.getByIds( listIds );
for( Demand demand : listDemand )
{
DemandDisplay demandDisplay = new DemandDisplay( );
demandDisplay.setDemand( demand );
demandDisplay.setStatus( getLabelStatus( demand ) );
listDemandDisplay.add( demandDisplay );
}
Collections.reverse(listDemandDisplay);
return listDemandDisplay;
}
/**
* Get status label
* @param demand
* @return status
*/
private String getLabelStatus( Demand demand )
{
Notification notification = NotificationHome.getLastNotifByDemandIdAndDemandTypeId( String.valueOf( demand.getDemandId( ) ), String.valueOf( demand.getTypeId( ) ) ) ;
if( notification.getMyDashboardNotification( ) != null )
{
EnumGenericStatus enumGenericStatus = EnumGenericStatus.getByStatusId( notification.getMyDashboardNotification( ).getStatusId( ) );
if( enumGenericStatus != null )
{
return I18nService.getLocalizedString( enumGenericStatus.getLabel( ), LocaleService.getDefault( ) );
}
else
{
Optional<Status> status = StatusHome.findByStatus( notification.getMyDashboardNotification( ).getStatusText( ) );
if( status.isPresent( ) )
{
enumGenericStatus = EnumGenericStatus.valueOf( status.get( ).getCodeStatus( ) );
if( enumGenericStatus != null )
{
return I18nService.getLocalizedString( enumGenericStatus.getLabel( ), LocaleService.getDefault( ) );
}
}
}
return notification.getMyDashboardNotification( ).getStatusText( );
}
return StringUtils.EMPTY;
}
/**
* Gets list of notification
*
* @param strIdDemand
*/
@GET
@Path( GruSupplyConstants.PATH_NOTIFICATION_LIST )
@Produces( MediaType.APPLICATION_JSON )
public Response getListNotification( @QueryParam( GruSupplyConstants.QUERY_PARAM_ID_DEMAND ) String strIdDemand,
@QueryParam( GruSupplyConstants.QUERY_PARAM_ID_DEMAND_TYPE ) String strIdDemandType,
@QueryParam( GruSupplyConstants.QUERY_PARAM_CUSTOMER_ID ) String strCustomerId )
{
NotificationResult result = new NotificationResult( );
if ( StringUtils.isNotEmpty( strIdDemand ) && StringUtils.isNotEmpty( strIdDemandType )
&& StringUtils.isNotEmpty( strCustomerId ) )
{
List<Notification> notifications = NotificationHome.getByDemandIdTypeIdCustomerId( strIdDemand, strIdDemandType, strCustomerId );
result.setNotifications( notifications );
result.setStatus( Response.Status.OK.name( ) );
result.setNumberResult( notifications.size( ) );
return Response.status( Response.Status.OK ).entity( GrusupplyUtils.convertToJsonString( result ) ).build( );
}
else
{
result.setStatus( SearchResult.ERROR_FIELD_MANDATORY );
result.setErrorMessage( GruSupplyConstants.MESSAGE_ERROR_NOTIF);
return Response.status( Response.Status.BAD_REQUEST ).entity( GrusupplyUtils.convertToJsonString( result ) ).build( );
}
}
/**
* Gets list of demand types
*
* @return list of demand types
*/
@GET
@Path( GruSupplyConstants.PATH_TYPE_DEMAND )
@Produces( MediaType.APPLICATION_JSON )
public Response getDemandTypes( )
{
List<DemandType> listDemandTypes = DemandTypeHome.getDemandTypesList( );
String strResult = GrusupplyUtils.convertToJsonString( listDemandTypes );
return Response.ok( strResult ).build( );
}
/**
* Gets list of notification types
*
* @return list of demand types
*/
@GET
@Path( GruSupplyConstants.PATH_TYPE_NOTIFICATION )
@Produces( MediaType.APPLICATION_JSON )
public Response getNotificationTypes( )
{
String strResult = GrusupplyUtils.convertToJsonString( EnumNotificationType.values( ) );
return Response.ok( strResult ).build( );
}
}