package org.gcube.portlets.user.geoportaldataentry.server;

import java.util.ArrayList;
import java.util.Collections;
import java.util.Comparator;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.gcube.application.geoportal.common.model.legacy.Concessione;
import org.gcube.application.geoportal.common.model.legacy.Concessione.Paths;
import org.gcube.application.geoportal.common.model.legacy.LayerConcessione;
import org.gcube.application.geoportal.common.model.legacy.RelazioneScavo;
import org.gcube.application.geoportal.common.model.legacy.UploadedImage;
import org.gcube.application.geoportal.common.model.legacy.report.ValidationReport;
import org.gcube.application.geoportal.common.model.rest.AddSectionToConcessioneRequest;
import org.gcube.application.geoportal.common.rest.MongoConcessioni;
import org.gcube.application.geoportal.common.rest.TempFile;
import org.gcube.application.geoportalcommon.ConvertToDataViewModel;
import org.gcube.application.geoportalcommon.GeoportalCommon;
import org.gcube.application.geoportalcommon.shared.GeoNaDataViewerProfile;
import org.gcube.application.geoportalcommon.shared.GeoNaItemRef;
import org.gcube.application.geoportalcommon.shared.products.ConcessioneDV;
import org.gcube.application.geoportalcommon.shared.products.model.ValidationReportDV;
import org.gcube.portlets.user.geoportaldataentry.client.ConcessioniFormCardTitle;
import org.gcube.portlets.user.geoportaldataentry.client.ConstantsGeoPortalDataEntryApp.RECORD_FIELD;
import org.gcube.portlets.user.geoportaldataentry.client.ConstantsGeoPortalDataEntryApp.RECORD_TYPE;
import org.gcube.portlets.user.geoportaldataentry.client.GeoportalDataEntryService;
import org.gcube.portlets.user.geoportaldataentry.server.MongoServiceUtil.ConcessioneValidationReportStatusComparator;
import org.gcube.portlets.user.geoportaldataentry.shared.CommitReport;
import org.gcube.portlets.user.geoportaldataentry.shared.GeoNaFormDataObject;
import org.gcube.portlets.user.geoportaldataentry.shared.GeonaISConfig;
import org.gcube.portlets.user.geoportaldataentry.shared.ResultSetPaginatedData;
import org.gcube.portlets.user.geoportaldataentry.shared.SortFilter;
import org.gcube.portlets.user.geoportaldataentry.shared.SortFilter.ORDER;
import org.gcube.portlets.widgets.mpformbuilder.shared.GenericDatasetBean;
import org.gcube.portlets.widgets.mpformbuilder.shared.upload.FileUploaded;
import org.gcube.vomanagement.usermanagement.model.GCubeUser;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import com.google.gwt.user.server.rpc.RemoteServiceServlet;

/**
 * The server side implementation of the RPC service.
 *
 * @author Francesco Mangiacrapa at ISTI-CNR (francesco.mangiacrapa@isti.cnr.it)
 * 
 *         Dec 1, 2020
 */
@SuppressWarnings("serial")
public class GeoportalDataEntryServiceImpl extends RemoteServiceServlet implements GeoportalDataEntryService {

	public static final String GEONA_GENERIC_RESOURCE_SECONDARY_TYPE = "GEONA_GENERIC_RESOURCE_SECONDARY_TYPE";
	private static final Logger LOG = LoggerFactory.getLogger(GeoportalDataEntryServiceImpl.class);

	/**
	 * Save geona data forms.
	 *
	 * @param listGeonaFormObjects the list geona form objects
	 * @return the commit report
	 * @throws Exception the exception
	 */
	@Override
	public CommitReport saveGeonaDataForms(List<GeoNaFormDataObject> listGeonaFormObjects) throws Exception {
		LOG.info("saveGeonaDataForms called");

		HashMap<ConcessioniFormCardTitle, List<GeoNaFormDataObject>> toMap = new HashMap<ConcessioniFormCardTitle, List<GeoNaFormDataObject>>();

		for (GeoNaFormDataObject geoNaFormDataObject : listGeonaFormObjects) {

			ConcessioniFormCardTitle theType = geoNaFormDataObject.getTheType();
			List<GeoNaFormDataObject> listForm = toMap.get(theType);
			if (listForm == null) {
				listForm = new ArrayList<GeoNaFormDataObject>();
			}

			listForm.add(geoNaFormDataObject);
			toMap.put(theType, listForm);
		}
		if (LOG.isDebugEnabled())
			prettyPrintClientDataEntryMap(toMap);

		LOG.debug("Built map with form data: " + toMap);
		GCubeUser user = SessionUtil.getCurrentUser(this.getThreadLocalRequest());

		Concessione concessioneNew;
		String mongoId = null;
		MongoServiceUtil serviceUtil = new MongoServiceUtil();
		MongoConcessioni clientMongo = null;

		try {

			SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
			clientMongo = serviceUtil.getInstanceMongoConcessioni();

			// Saving Data
			// Informazioni di Progetto
			List<GeoNaFormDataObject> list = toMap.get(ConcessioniFormCardTitle.INFORMAZIONI_DI_PROGETTO);
			if (list == null || list.isEmpty() || list.get(0) == null || list.get(0).getListGDB() == null)
				throw new Exception(
						"Error: no data found for " + ConcessioniFormCardTitle.INFORMAZIONI_DI_PROGETTO.getTitle());

			List<GenericDatasetBean> listGDB = list.get(0).getListGDB();
			GenericDatasetBean idp = listGDB.get(0);
			LOG.debug("\n\n");
			LOG.debug(ConcessioniFormCardTitle.INFORMAZIONI_DI_PROGETTO + " building with client obj: " + idp);
			Concessione concessione = ConvertToServiceModel.toConcessione(idp, user);
			LOG.debug("Built " + ConcessioniFormCardTitle.INFORMAZIONI_DI_PROGETTO + " as server obj: " + concessione);

			// Register New Concessione
			concessioneNew = clientMongo.createNew(concessione);

			// ABSTRACT_RELAZIONE_DI_SCAVO
			list = toMap.get(ConcessioniFormCardTitle.ABSTRACT_RELAZIONE_DI_SCAVO);
			if (list == null || list.isEmpty() || list.get(0) == null || list.get(0).getListGDB() == null)
				throw new Exception(
						"Error: no data found for " + ConcessioniFormCardTitle.ABSTRACT_RELAZIONE_DI_SCAVO.getTitle());

			listGDB = list.get(0).getListGDB();
			GenericDatasetBean ards = listGDB.get(0);
			LOG.debug("\n\n");
			LOG.debug(ConcessioniFormCardTitle.ABSTRACT_RELAZIONE_DI_SCAVO + " building with client obj: " + ards);
			RelazioneScavo abstractRelazioneDiScavo = ConvertToServiceModel.toAbstractRelazioneScavo(ards);

			// RELAZIONE_DI_SCAVO
			list = toMap.get(ConcessioniFormCardTitle.RELAZIONE_DI_SCAVO);
			if (list == null || list.isEmpty() || list.get(0) == null || list.get(0).getListGDB() == null)
				throw new Exception(
						"Error: no data found for " + ConcessioniFormCardTitle.RELAZIONE_DI_SCAVO.getTitle());

			listGDB = list.get(0).getListGDB();
			GenericDatasetBean rds = listGDB.get(0);
			LOG.debug("\n\n");
			LOG.debug(ConcessioniFormCardTitle.RELAZIONE_DI_SCAVO + " building with client obj: " + rds);
			RelazioneScavo relazioneDiScavo = ConvertToServiceModel.toRelazioneScavo(abstractRelazioneDiScavo, rds);
			LOG.debug("Built " + ConcessioniFormCardTitle.RELAZIONE_DI_SCAVO + " as server obj: " + relazioneDiScavo);

			// Setting Relazione
			concessioneNew.setRelazioneScavo(relazioneDiScavo);

			// IMMAGINI_RAPPRESENTATIVE
			list = toMap.get(ConcessioniFormCardTitle.IMMAGINI_RAPPRESENTATIVE);
			if (list == null || list.isEmpty() || list.get(0) == null || list.get(0).getListGDB() == null)
				throw new Exception(
						"Error: no data found for " + ConcessioniFormCardTitle.IMMAGINI_RAPPRESENTATIVE.getTitle());

			List<GenericDatasetBean> imgRaprsLst = list.get(0).getListGDB();
			List<UploadedImage> immaginiRappresentativeService = null;
			if (imgRaprsLst.size() > 0) {
				immaginiRappresentativeService = new ArrayList<UploadedImage>(imgRaprsLst.size());
				for (GenericDatasetBean imgRapr : imgRaprsLst) {
					LOG.debug("\n\n");
					LOG.debug(ConcessioniFormCardTitle.IMMAGINI_RAPPRESENTATIVE + " building with client obj: "
							+ imgRapr);
					UploadedImage img = ConvertToServiceModel.toImmaginiRappresentative(imgRapr);
					LOG.debug("Built " + ConcessioniFormCardTitle.IMMAGINI_RAPPRESENTATIVE + " as server obj: " + img);
					immaginiRappresentativeService.add(img);
				}
			}

			// Setting Immagini Rappresentative
			if (immaginiRappresentativeService != null) {
				concessioneNew.setImmaginiRappresentative(immaginiRappresentativeService);
			}

			// POSIZIONAMENTO_DELL_AREA_DI_INDAGINE
			list = toMap.get(ConcessioniFormCardTitle.POSIZIONAMENTO_DELL_AREA_DI_INDAGINE);
			if (list == null || list.isEmpty() || list.get(0) == null || list.get(0).getListGDB() == null)
				throw new Exception("Error: no data found for "
						+ ConcessioniFormCardTitle.POSIZIONAMENTO_DELL_AREA_DI_INDAGINE.getTitle());

			listGDB = list.get(0).getListGDB();
			GenericDatasetBean pad = listGDB.get(0);
			LayerConcessione layerPad = null;
			if (pad != null) {
				LOG.debug("\n\n");
				LOG.debug(ConcessioniFormCardTitle.POSIZIONAMENTO_DELL_AREA_DI_INDAGINE + " building with client obj: "
						+ pad);
				layerPad = ConvertToServiceModel.toLayerConcessione(pad);
				LOG.debug("Built " + ConcessioniFormCardTitle.POSIZIONAMENTO_DELL_AREA_DI_INDAGINE + " as server obj: "
						+ layerPad);
			}

			// Setting Posizionamento Di Scavo
			if (layerPad != null) {
				concessioneNew.setPosizionamentoScavo(layerPad);
			}

			// PIANTA_DI_FINE_SCAVO
			list = toMap.get(ConcessioniFormCardTitle.PIANTA_DI_FINE_SCAVO);
			if (list == null || list.isEmpty() || list.get(0) == null || list.get(0).getListGDB() == null)
				throw new Exception(
						"Error: no data found for " + ConcessioniFormCardTitle.PIANTA_DI_FINE_SCAVO.getTitle());

			listGDB = list.get(0).getListGDB();
			List<GenericDatasetBean> listPfs = listGDB;
			// Managing N:N
			List<LayerConcessione> pianteFineScavo = null;
			if (listPfs.size() > 0) {
				pianteFineScavo = new ArrayList<LayerConcessione>(listPfs.size());
				for (GenericDatasetBean pfs : listPfs) {
					LOG.debug("\n\n");
					LOG.debug(ConcessioniFormCardTitle.PIANTA_DI_FINE_SCAVO + " building with client obj: " + pfs);
					LayerConcessione layerPfs = ConvertToServiceModel.toLayerConcessione(pfs);
					LOG.debug("Built " + ConcessioniFormCardTitle.PIANTA_DI_FINE_SCAVO + " as server obj: " + layerPfs);
					pianteFineScavo.add(layerPfs);

				}
			}

			// Setting Piante fine Scavo
			if (pianteFineScavo != null) {
				concessioneNew.setPianteFineScavo(pianteFineScavo);
			}

			// Registering Meta
			clientMongo.replace(concessioneNew);
			mongoId = concessioneNew.getMongo_id();
			LOG.info("Registered the meta. Called mongo.replace for: " + concessioneNew);

			// UPLOADING FILES
			LOG.info("Now uploading the files...");
			// Building TempFile for ABSTRACT DELLA RELAZIONE DI SCAVO
			SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
			List<TempFile> ardsFiles = serviceUtil.toTemFiles(ards.getFilesUploaded());
			// TODO DEVE ESSERE PASSATO CON PATH RELAZIONE OPPURE BISOGNA PREVEDERE UN
			// ABSTRACT_RELAZIONE???
			if (ardsFiles != null && ardsFiles.size() > 0) {
				// saving into back-end
				AddSectionToConcessioneRequest request = new AddSectionToConcessioneRequest(Paths.RELAZIONE, ardsFiles);
				clientMongo.registerFileSet(mongoId, request);
				LOG.info("Registered the mongoId " + mongoId + " request " + Paths.RELAZIONE + "with "
						+ ardsFiles.size() + " file/s");
			}

			// Building TempFile for RELAZIONE DI SCAVO
			SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
			List<TempFile> files = serviceUtil.toTemFiles(rds.getFilesUploaded());
			// Upload file to Concessione. Should be one file.
			if (files != null && files.size() > 0) {
				// saving into back-end
				AddSectionToConcessioneRequest request = new AddSectionToConcessioneRequest(Paths.RELAZIONE, files);
				clientMongo.registerFileSet(mongoId, request);
				LOG.info("Registered the mongoId " + mongoId + " request " + Paths.RELAZIONE + "with " + files.size()
						+ " file/s");
			}

			// IMMAGINI RAPPRESENTATIVE
			for (int i = 0; i < imgRaprsLst.size(); i++) {
				LOG.debug("\n\n");
				GenericDatasetBean imgRapr = imgRaprsLst.get(i);
				// Building TempFile for Immagini
				SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
				files = serviceUtil.toTemFiles(imgRapr.getFilesUploaded());
				// Upload file to Concessione. The size is always 1 so it is consistent with the
				// 'for' index
				if (files != null && files.size() > 0) {
					// saving into back-end
					AddSectionToConcessioneRequest request = new AddSectionToConcessioneRequest(Paths.imgByIndex(i),
							files);
					clientMongo.registerFileSet(mongoId, request);
					LOG.info("Registered the mongoId " + mongoId + " request " + Paths.IMMAGINI + "with " + files.size()
							+ " file/s");
				}

			}

			// POSIZIONAMENTO
			// Building TempFile for POSIZIONAMENTO
			SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
			files = serviceUtil.toTemFiles(pad.getFilesUploaded());
			// Upload file to Concessione
			if (files != null && files.size() > 0) {
				// saving into back-end
				AddSectionToConcessioneRequest request = new AddSectionToConcessioneRequest(Paths.POSIZIONAMENTO,
						files);
				clientMongo.registerFileSet(mongoId, request);
				LOG.info("Registered the mongoId " + mongoId + " request " + Paths.POSIZIONAMENTO + "with "
						+ files.size() + " file/s");
			}

			// PIANTE FINE SCAVO
			if (listPfs.size() > 0) {
				for (int i = 0; i < listPfs.size(); i++) {
					// Building TempFile for PIANTA_DI_FINE_SCAVO
					GenericDatasetBean pfs = listPfs.get(i);
					SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
					files = serviceUtil.toTemFiles(pfs.getFilesUploaded());
					// Upload file to Concessione Section by Path 'Relazione'
					if (files != null && files.size() > 0) {
						// saving into back-end
						AddSectionToConcessioneRequest request = new AddSectionToConcessioneRequest(
								Paths.piantaByIndex(i), files);
						clientMongo.registerFileSet(mongoId, request);
						LOG.info("Registered the mongoId " + mongoId + " request " + Paths.PIANTE + "with "
								+ files.size() + " file/s");
					}

				}
			}

		} catch (Exception e) {
			LOG.error("Error on converting form data: ", e);
			throw new Exception(
					"Error occurred on saving data, try again or contact the support. Error: " + e.getMessage());
		}

		try {

			Concessione concessione;
			if (clientMongo != null && mongoId != null) {
				SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
				concessione = clientMongo.publish(mongoId);
				// server report
				ValidationReport report = concessione.getReport();
				LOG.info("ValidationReport: " + report);

				// to client
				CommitReport cRep = new CommitReport();
				// cRep.setRecordId(concessione.getId());
				cRep.setMongoId(concessione.getMongo_id());
				ValidationReportDV vr = ConvertToDataViewModel.toValidationReport(report);
				cRep.setValidationReportDV(vr);
//				switch (report.getStatus()) {
//				case PASSED:
//					if (cRep.getMongoId() == null) {
//						LOG.error("The mongo id is null!!!");
//						throw new Exception("Invalid identifier (mongoId is null) for the concessione");
//					}
//					cRep.setMsg("OK");
//					break;
//				case WARNING:
//					cRep.setMsg(report.getWarningMessages().toString());
//					break;
//				case ERROR:
//					cRep.setMsg(report.getErrorMessages().toString());
//					break;
//
//				default:
//					break;
//				}

				return cRep;
			} else
				throw new Exception("MongoId or Client not found");

		} catch (Exception e) {
			LOG.error("Error on commiting data: ", e);
			throw new Exception("Error occurred on saving data. Error: " + e.getMessage());
		} finally {
//			if(manager!=null) {
//				try {
//					manager.shutdown();
//				}catch (Exception e) {
//					//silent
//				}
//				
//			}
		}

	}

	/**
	 * Gets the geona init config.
	 *
	 * @return the geona init config
	 */
	@Override
	public GeonaISConfig getGeonaInitConfig() {
		LOG.info("getConfig called");

		String scope = SessionUtil.getCurrentContext(this.getThreadLocalRequest(), false);
		String theSecondaryType;
		try {
			theSecondaryType = this.getServletContext().getInitParameter(GEONA_GENERIC_RESOURCE_SECONDARY_TYPE);
		} catch (Exception e) {
			LOG.error("I cannot read the init parameter for: " + GEONA_GENERIC_RESOURCE_SECONDARY_TYPE, e);
			theSecondaryType = "GeoNaMetadata";
		}

//		LOG.warn("\n\n\nHARD-CABLING THE SCOPE, PLEASE REMOTE IT!!!!\n\n\n");
//		scope = "/gcube/devsec/devVRE";

		GeonaISConfig configs = new GeonaISConfig(theSecondaryType, scope);
		LOG.info("returning config: " + configs);
		return configs;
	}

	/**
	 * Gets the links for.
	 *
	 * @param itemId     the item id is the mongoId
	 * @param recordType the record type
	 * @return the links for
	 * @throws Exception the exception
	 */
	@Override
	public GeoNaItemRef getLinksFor(String itemId, RECORD_TYPE recordType) throws Exception {
		LOG.info("getLinksFor called");

		SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
		GeoNaDataViewerProfile grViewerProfile = SessionUtil.getGeportalViewerResourceProfile(getThreadLocalRequest());
		GeoportalCommon gc = new GeoportalCommon(grViewerProfile);
		GeoNaItemRef item = new GeoNaItemRef(itemId, recordType.toString().toLowerCase());
		item = gc.getPublicLinksFor(item, false);
		LOG.info("Returning: " + item);
		return item;
	}

	/**
	 * Gets the list concessioni.
	 *
	 * @param start             the start
	 * @param limit             the limit
	 * @param filter            the filter
	 * @param reloadFromService the reload from service
	 * @return the list concessioni
	 * @throws Exception the exception
	 */
	@Override
	public ResultSetPaginatedData getListConcessioni(Integer start, Integer limit, SortFilter filter,
			boolean reloadFromService) throws Exception {
		LOG.info("getListConcessioni called wit start: " + start + ", limit: " + limit + ", filter: " + filter);

		try {
			List<Concessione> listOfConcessioni = SessionUtil.getListOfConcessioni(getThreadLocalRequest(),
					reloadFromService);
			int listConcessioniSize = listOfConcessioni.size();

			List<Concessione> toReturn = new ArrayList<Concessione>();
			int startIndex;
			int limitIndex = 0;
			if (start == null && limit == null) {
				startIndex = 0;
				limitIndex = listConcessioniSize;
			} else {
				startIndex = start;
				limitIndex = start + limit;
				if (limitIndex > listConcessioniSize) {
					limitIndex = listConcessioniSize;
				}
			}

			ResultSetPaginatedData searchedData = new ResultSetPaginatedData(start, limit, startIndex, false);
			searchedData.setTotalItems(listConcessioniSize);

			RECORD_FIELD orderBy = null;
			ORDER order = null;
			ConcessioneValidationReportStatusComparator statusComparator = null;

			if (filter == null) {
				// unsorted list of records
				toReturn = listOfConcessioni.subList(startIndex, limitIndex);
			} else {

				orderBy = filter.getOrderByField();
				order = filter.getOrder();

				if (orderBy == null)
					orderBy = RECORD_FIELD.NAME;

				if (order == null)
					order = ORDER.ASC;

				// CASE INSENSITIVE COMPARATOR
				Comparator<Concessione> comparator = null;

				switch (orderBy) {
				case NAME:
					if (order.equals(ORDER.ASC)) {
						comparator = Comparator.comparing(Concessione::getNome,
								Comparator.nullsLast(String.CASE_INSENSITIVE_ORDER));
					} else {
						comparator = Comparator
								.comparing(Concessione::getNome, Comparator.nullsLast(String.CASE_INSENSITIVE_ORDER))
								.reversed();
					}

					break;
				case CREATED:
					if (order.equals(ORDER.ASC)) {
						comparator = Comparator.comparing(Concessione::getCreationTime,
								Comparator.nullsLast(Comparator.naturalOrder()));
					} else {
						comparator = Comparator.comparing(Concessione::getCreationTime,
								Comparator.nullsLast(Comparator.naturalOrder())).reversed();
					}
					break;

				case CREATED_BY:
					if (order.equals(ORDER.ASC)) {
						comparator = Comparator.comparing(Concessione::getCreationUser,
								Comparator.nullsLast(String.CASE_INSENSITIVE_ORDER));
					} else {
						comparator = Comparator.comparing(Concessione::getCreationUser,
								Comparator.nullsLast(String.CASE_INSENSITIVE_ORDER)).reversed();
					}
					break;

				// TODO is buggy must be performed by service
				case PROJECT_START_END_DATE:
					if (order.equals(ORDER.ASC)) {
						comparator = Comparator.comparing(Concessione::getDataInizioProgetto,
								Comparator.nullsLast(Comparator.naturalOrder()));
					} else {
						comparator = Comparator.comparing(Concessione::getDataInizioProgetto,
								Comparator.nullsLast(Comparator.naturalOrder())).reversed();
					}
					break;

				case RECORD_STATUS:
					statusComparator = new ConcessioneValidationReportStatusComparator();
				default:
					break;
				}

				// sorting with nullsLast
				if (comparator != null)
					listOfConcessioni.sort(Comparator.nullsLast(comparator));

				// solution quick&dirty
				try {
					if (statusComparator != null) {
						if (order.equals(ORDER.ASC)) {
							listOfConcessioni.sort(Comparator.nullsLast(statusComparator));
						} else {
							Collections.sort(listOfConcessioni, Comparator.nullsLast(
									Collections.reverseOrder(new ConcessioneValidationReportStatusComparator())));
						}
					}
				} catch (Exception e) {
					LOG.warn("comparator Exception: " + e.getMessage());
				}

				LOG.debug("sorted list: " + listOfConcessioni);
				// pagination
				toReturn = listOfConcessioni.subList(startIndex, limitIndex);
			}

			List<ConcessioneDV> toReturnList = new ArrayList<ConcessioneDV>(toReturn.size());

			for (Concessione concessione : toReturn) {
				ConcessioneDV concessioneDV = ConvertToDataViewModel.toMetadataConcessione(concessione, true);
				toReturnList.add(concessioneDV);
			}

			searchedData.setData(toReturnList);

			if (listConcessioniSize == limit || listConcessioniSize == 0) {
				LOG.debug("Page completed returning " + listConcessioniSize + " items");
				int newOffset = startIndex + start;
				searchedData.setServerSearchFinished(newOffset > listConcessioniSize || listConcessioniSize == 0);
				LOG.debug("is Search finished: " + searchedData.isServerSearchFinished());
				return searchedData;
			}

			LOG.debug("Returning: " + toReturnList);
			LOG.info("Returning list of concessioni with size: " + toReturnList.size());
			return searchedData;
		} catch (Exception e) {
			LOG.error("Error on loading list of concessioni: ", e);
			throw new Exception("Error occurred on loading list of Concessioni. Error: " + e.getMessage());
		}

	}

	/**
	 * Pretty print client data entry map.
	 *
	 * @param toMap the to map
	 */
	private void prettyPrintClientDataEntryMap(HashMap<ConcessioniFormCardTitle, List<GeoNaFormDataObject>> toMap) {

		for (ConcessioniFormCardTitle theType : toMap.keySet()) {
			LOG.debug("\n\n");
			LOG.debug(theType.toString());
			List<GeoNaFormDataObject> list = toMap.get(theType);
			for (GeoNaFormDataObject geoNaFormDataObject : list) {
				LOG.debug("\t has " + geoNaFormDataObject.getListGDB().size() + " data bean/s");
				int i = 0;
				for (GenericDatasetBean gbd : geoNaFormDataObject.getListGDB()) {
					LOG.debug("\t " + ++i + ") " + GenericDatasetBean.class.getSimpleName() + " entries:");
					Map<String, List<String>> map = gbd.getFormDataEntryFields();
					for (String keyEntry : map.keySet()) {
						LOG.debug("\t " + keyEntry + ": " + map.get(keyEntry));
					}
					for (FileUploaded fup : gbd.getFilesUploaded()) {
						LOG.debug("\t " + fup);
					}
				}
			}
		}
	}

	/**
	 * Delete record.
	 *
	 * @param itemId     the item id
	 * @param recordType the record type
	 * @return true, if successful
	 * @throws Exception the exception
	 */
	@Override
	public boolean deleteRecord(String itemId, RECORD_TYPE recordType) throws Exception {
		LOG.info("deleteRecord called with itemId: " + itemId + ", recordType: " + recordType);
		try {

			if (itemId == null)
				throw new Exception("Item id is null");

			if (recordType.equals(RECORD_TYPE.CONCESSIONE)) {
				SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
				MongoServiceUtil serviceUtil = new MongoServiceUtil();
				MongoConcessioni clientMongo = serviceUtil.getInstanceMongoConcessioni();
				clientMongo.deleteById(itemId);
				return true;
			}

			return false;

		} catch (Exception e) {
			LOG.error("Error on deleting the project with item id: " + itemId, e);
			throw new Exception(
					"Error occurred on deleting the project with id: " + itemId + ". Error: " + e.getMessage());
		}
	}

	/**
	 * Update record.
	 *
	 * @param itemId     the item id
	 * @param jsonUpdate the json update
	 * @param recordType the record type
	 * @return the updated JSON string representing the itemId 
	 * @throws Exception the exception
	 */
	@Override
	public String updateRecord(String itemId, String jsonUpdate, RECORD_TYPE recordType) throws Exception {
		LOG.info("updateRecord called with itemId: " + itemId + ", recordType: " + recordType);
		try {

			if (itemId == null)
				throw new Exception("Item id is null");

			LOG.debug("jsonUpdate is: " + jsonUpdate);
			if (recordType.equals(RECORD_TYPE.CONCESSIONE)) {
				SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
				MongoServiceUtil serviceUtil = new MongoServiceUtil();
				MongoConcessioni clientMongo = serviceUtil.getInstanceMongoConcessioni();
				Concessione concessione = clientMongo.update(itemId, jsonUpdate);
				return serviceUtil.toJSON(concessione);
			}

			return null;

		} catch (Exception e) {
			LOG.error("Error on updating the project with item id: " + itemId, e);
			throw new Exception(
					"Error occurred on updating the project with id: " + itemId + ". Error: " + e.getMessage());
		}
	}

	/**
	 * Gets the JSON record.
	 *
	 * @param itemId     the item id
	 * @param recordType the record type
	 * @return the JSON record representing the itemId 
	 * @throws Exception the exception
	 */
	@Override
	public String getJSONRecord(String itemId, RECORD_TYPE recordType) throws Exception {
		LOG.info("getJSONRecord called with itemId: " + itemId + ", recordType: " + recordType);
		try {

			if (itemId == null)
				throw new Exception("Item id is null");

			if (recordType.equals(RECORD_TYPE.CONCESSIONE)) {
				SessionUtil.getCurrentContext(this.getThreadLocalRequest(), true);
				MongoServiceUtil serviceUtil = new MongoServiceUtil();
				MongoConcessioni clientMongo = serviceUtil.getInstanceMongoConcessioni();
				Concessione concessione = clientMongo.getById(itemId);
				return serviceUtil.toJSON(concessione);
			}

			return null;

		} catch (Exception e) {
			LOG.error("Error on reading the JSON project with item id: " + itemId, e);
			throw new Exception(
					"Error occurred on reading the JSON project with id: " + itemId + ". Error: " + e.getMessage());
		}
	}
}