AdresZoekServlet

package nl.mineleni.cbsviewer.servlet.gazetteer;

import static nl.mineleni.cbsviewer.util.StringConstants.OPENLS_REQ_PARAM_REQUEST;
import static nl.mineleni.cbsviewer.util.StringConstants.OPENLS_REQ_PARAM_SEARCH;
import static nl.mineleni.cbsviewer.util.StringConstants.OPENLS_REQ_VALUE_GEOCODE;
import static nl.mineleni.cbsviewer.util.StringConstants.REQ_PARAM_GEVONDEN;
import static nl.mineleni.cbsviewer.util.StringConstants.REQ_PARAM_STRAAL;
import static nl.mineleni.cbsviewer.util.StringConstants.REQ_PARAM_XCOORD;
import static nl.mineleni.cbsviewer.util.StringConstants.REQ_PARAM_YCOORD;

import java.io.IOException;
import java.text.DecimalFormat;
import java.text.ParseException;
import java.util.List;
import java.util.Map;
import java.util.TreeMap;

import javax.servlet.ServletConfig;
import javax.servlet.ServletException;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;

import nl.mineleni.cbsviewer.servlet.AbstractWxSServlet;
import nl.mineleni.cbsviewer.servlet.gazetteer.lusclient.OpenLSClient;
import nl.mineleni.cbsviewer.servlet.gazetteer.lusclient.OpenLSClientAddress;
import nl.mineleni.cbsviewer.servlet.gazetteer.lusclient.OpenLSClientUtil;
import nl.mineleni.cbsviewer.util.LabelsBundle;
import nl.mineleni.openls.databinding.openls.GeocodeResponse;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import flexjson.JSONSerializer;
import flexjson.transformer.NumberTransformer;

/**
 * Servlet implementation class AdresZoekServlet.
 *
 * @author mprins
 */
public class AdresZoekServlet extends AbstractWxSServlet {
	/** logger. */
	private static final Logger LOGGER = LoggerFactory
			.getLogger(AbstractWxSServlet.class);

	/** serialization id. */
	private static final long serialVersionUID = 1L;

	/**
	 * gazetteer service max. aantal terug te geven resultaten config parameter.
	 * * {@value} .
	 */
	private static final String SERVLETCONFIG_OPENLS_MAX_RESULTS = "openlsmaxresults";

	/** gazetteer service url config parameter. {@value} . */
	private static final String SERVLETCONFIG_OPENLS_SERVER_URL = "openlsserverurl";

	/** De read-only, resourcebundel voor de applicatie. */
	private static final LabelsBundle LABELS = new LabelsBundle();

	/** De open ls client die het echte werk doet. */
	private transient OpenLSClient openLSClient;

	/** maximum aantal terug te geven adressen. */
	private transient int openLSmaxResults;

	/** de Open LS server url. */
	private transient String openLSServerUrl;

	/**
	 * zorgt ervoor dat eventuele doubles als integer worden gerenderd. Als het
	 * niet lukt wordt de oorspronkelijke waarde teruggeven.
	 *
	 * @param coord
	 *            een coordinaat waarde
	 * @return de waarde in integer formaat
	 */
	private String formatCoord(final String coord) {
		/** coordinaten formatter. */
		final DecimalFormat fmt = new DecimalFormat("###");
		try {
			// formatting als int
			return fmt.parse(coord).toString();
		} catch (final ParseException e) {
			LOGGER.warn("Fout tijden parsen van coordinaat: " + coord, e);
			return coord;
		} catch (final NullPointerException e) {
			LOGGER.warn("Fout tijden parsen van coordinaat: " + coord, e);
			return coord;
		}
	}

	/*
	 * @see Servlet#init(ServletConfig)
	 */
	@Override
	public void init(final ServletConfig config) throws ServletException {
		super.init(config);
		this.openLSClient = new OpenLSClient();
		// init params inlezen en controleren
		this.openLSServerUrl = config
				.getInitParameter(SERVLETCONFIG_OPENLS_SERVER_URL);
		if (this.openLSServerUrl == null) {
			LOGGER.error("config param " + SERVLETCONFIG_OPENLS_SERVER_URL
					+ " is null.");
			throw new ServletException("config param "
					+ SERVLETCONFIG_OPENLS_SERVER_URL + " is null.");
		}
		this.openLSmaxResults = config
				.getInitParameter(SERVLETCONFIG_OPENLS_MAX_RESULTS) == null ? null
				: Integer.parseInt(config
						.getInitParameter(SERVLETCONFIG_OPENLS_MAX_RESULTS));
	}

	/**
	 * Return json van adreszoek resultaten.
	 *
	 * @param addrl
	 *            Een {@code List} met adressen, de lijst mag leeg zijn
	 * @return een javascript array met geserialiseerde
	 *         {@link nl.mineleni.cbsviewer.servlet.gazetteer.lusclient.OpenLSClientAddress}
	 *         objecten
	 */
	private String returnJson(final List<OpenLSClientAddress> addrl) {
		if (addrl.size() < 1) {
			return "[]";
		} else {
			final String json = new JSONSerializer()
					.exclude("class", "validClientAddress", "municipality")
					.exclude("countrySubdivision", "municipalitySubdivision")
					.exclude("streetName", "streetNumber", "postalCode")
					.transform(new NumberTransformer(), "xCoord", "yCoord")
					.prettyPrint(LOGGER.isDebugEnabled()).serialize(addrl);
			if (LOGGER.isDebugEnabled()) {
				LOGGER.debug("json: " + json);
			}
			return json;
		}
	}

	/*
	 * (non-Javadoc)
	 *
	 * @see
	 * javax.servlet.http.HttpServlet#service(javax.servlet.http.HttpServletRequest
	 * , javax.servlet.http.HttpServletResponse)
	 */
	@Override
	protected void service(final HttpServletRequest request,
			final HttpServletResponse response) throws ServletException,
			IOException {

		final boolean forwardResponse = this.parseForward(request);

		final String zoekTerm = request.getParameter("adres");
		if (LOGGER.isDebugEnabled()) {
			LOGGER.debug("Zoeken naar: " + zoekTerm);
		}
		if (zoekTerm.length() < 1) {
			request.setAttribute(REQ_PARAM_GEVONDEN.code,
					LABELS.getString("KEY_ZOEKEN_NIETS_INGEVULD"));
			if (forwardResponse) {
				request.getRequestDispatcher("/index.jsp").forward(request,
						response);
			}
		} else {
			final Map<String, String> openLSParams = new TreeMap<>();
			openLSParams.put(OPENLS_REQ_PARAM_REQUEST.code,
					OPENLS_REQ_VALUE_GEOCODE.code);
			openLSParams.put(OPENLS_REQ_PARAM_SEARCH.code, zoekTerm);
			final GeocodeResponse gcr = this.openLSClient.doGetOpenLSRequest(
					this.openLSServerUrl, openLSParams);
			final List<OpenLSClientAddress> addrl = OpenLSClientUtil
					.getOpenLSClientAddressList(gcr, this.openLSmaxResults);

			if (forwardResponse) {
				if (addrl.isEmpty()) {
					// niets gevonden
					if (LOGGER.isDebugEnabled()) {
						LOGGER.debug(LABELS.getString("KEY_ZOEKEN_GEEN_ADRES")
								+ zoekTerm);
					}
					request.setAttribute(REQ_PARAM_GEVONDEN.code,
							LABELS.getString("KEY_ZOEKEN_GEEN_ADRES"));
				} else if (addrl.size() == 1) {
					// 1 adres gevonden
					if (LOGGER.isDebugEnabled()) {
						LOGGER.debug("Er is 1 match gevonden voor: " + zoekTerm);
					}
					final OpenLSClientAddress addr = addrl.get(0);

					request.setAttribute(REQ_PARAM_XCOORD.code,
							this.formatCoord(addr.getxCoord()));
					request.setAttribute(REQ_PARAM_YCOORD.code,
							this.formatCoord(addr.getyCoord()));
					request.setAttribute(REQ_PARAM_STRAAL.code,
							addr.getRadius());
					request.setAttribute(REQ_PARAM_GEVONDEN.code,
							LABELS.getString("KEY_ZOEKEN_EEN_ADRES") + " "
									+ addr.getAddressString());
				} else {
					// meer dan 1 adressen gevonden
					if (LOGGER.isDebugEnabled()) {
						LOGGER.debug("Er is meer dan 1 match gevonden voor: "
								+ zoekTerm);
					}
					request.setAttribute("adreslijst", addrl);
					request.setAttribute(REQ_PARAM_GEVONDEN.code,
							LABELS.getString("KEY_ZOEKEN_MEER_ADRES"));
				}
				request.getRequestDispatcher("/index.jsp").forward(request,
						response);
			} else {
				// in geval van directe aanroep voor bijv. ajax
				final String format = request.getParameter("format");
				if ((format != null) && format.equalsIgnoreCase("json")) {
					// geeft zoekresultaat als json
					final String json = this.returnJson(addrl);
					response.setCharacterEncoding("UTF-8");
					response.setContentType("application/json");
					response.setContentLength(json.length());
					response.getWriter().print(json);
					response.flushBuffer();
				}
			}
		}
	}
}