[Lada-commits] [PATCH 3 of 3] Added zusatzwert services
Wald Commits
scm-commit at wald.intevation.org
Wed Feb 18 14:42:02 CET 2015
# HG changeset patch
# User Raimund Renkert <raimund.renkert at intevation.de>
# Date 1424266974 -3600
# Node ID 6fdbda6c5448e06c1baf295d4f48e9e577a5447a
# Parent d6b9ba0fc2c7b8d82faed38640236610302954af
Added zusatzwert services.
diff -r d6b9ba0fc2c7 -r 6fdbda6c5448 src/main/java/de/intevation/lada/rest/ZusatzwertService.java
--- /dev/null Thu Jan 01 00:00:00 1970 +0000
+++ b/src/main/java/de/intevation/lada/rest/ZusatzwertService.java Wed Feb 18 14:42:54 2015 +0100
@@ -0,0 +1,171 @@
+/* Copyright (C) 2013 by Bundesamt fuer Strahlenschutz
+ * Software engineering by Intevation GmbH
+ *
+ * This file is Free Software under the GNU GPL (v>=3)
+ * and comes with ABSOLUTELY NO WARRANTY! Check out
+ * the documentation coming with IMIS-Labordaten-Application for details.
+ */
+package de.intevation.lada.rest;
+
+import javax.enterprise.context.RequestScoped;
+import javax.inject.Inject;
+import javax.ws.rs.DELETE;
+import javax.ws.rs.GET;
+import javax.ws.rs.POST;
+import javax.ws.rs.PUT;
+import javax.ws.rs.Path;
+import javax.ws.rs.PathParam;
+import javax.ws.rs.Produces;
+import javax.ws.rs.core.Context;
+import javax.ws.rs.core.HttpHeaders;
+import javax.ws.rs.core.MediaType;
+import javax.ws.rs.core.MultivaluedMap;
+import javax.ws.rs.core.UriInfo;
+
+import org.apache.log4j.Logger;
+
+import de.intevation.lada.model.land.LZusatzWert;
+import de.intevation.lada.util.annotation.AuthenticationConfig;
+import de.intevation.lada.util.annotation.AuthorizationConfig;
+import de.intevation.lada.util.annotation.RepositoryConfig;
+import de.intevation.lada.util.auth.Authentication;
+import de.intevation.lada.util.auth.AuthenticationType;
+import de.intevation.lada.util.auth.Authorization;
+import de.intevation.lada.util.auth.AuthorizationType;
+import de.intevation.lada.util.data.QueryBuilder;
+import de.intevation.lada.util.data.Repository;
+import de.intevation.lada.util.data.RepositoryType;
+import de.intevation.lada.util.rest.Response;
+
+ at Path("zusatzwert")
+ at RequestScoped
+public class ZusatzwertService {
+
+ /* The logger used in this class.*/
+ @Inject
+ private Logger logger;
+
+ /* The data repository granting read/write access.*/
+ @Inject
+ @RepositoryConfig(type=RepositoryType.RW)
+ private Repository defaultRepo;
+
+ /* The authentication module.*/
+ @Inject
+ @AuthenticationConfig(type=AuthenticationType.NONE)
+ private Authentication authentication;
+
+ /* The authorization module.*/
+ @Inject
+ @AuthorizationConfig(type=AuthorizationType.NONE)
+ private Authorization authorization;
+
+ /**
+ * Get all objects.
+ *
+ * @return Response object containing all messung objects.
+ */
+ @GET
+ @Path("/")
+ @Produces(MediaType.APPLICATION_JSON)
+ public Response get(
+ @Context HttpHeaders headers,
+ @Context UriInfo info
+ ) {
+ if (!authentication.isAuthenticated(headers)) {
+ logger.debug("User is not authenticated!");
+ return new Response(false, 699, null);
+ }
+ MultivaluedMap<String, String> params = info.getQueryParameters();
+ if (params.isEmpty() || !params.containsKey("probeId")) {
+ return defaultRepo.getAll(LZusatzWert.class, "land");
+ }
+ String probeId = params.getFirst("probeId");
+ QueryBuilder<LZusatzWert> builder =
+ new QueryBuilder<LZusatzWert>(
+ defaultRepo.entityManager("land"),
+ LZusatzWert.class);
+ builder.and("probeId", probeId);
+ return defaultRepo.filter(builder.getQuery(), "land");
+ }
+
+ /**
+ * Get an object by id.
+ *
+ * @return Response object containing a single messung.
+ */
+ @GET
+ @Path("/{id}")
+ @Produces(MediaType.APPLICATION_JSON)
+ public Response getById(
+ @Context HttpHeaders headers,
+ @PathParam("id") String id
+ ) {
+ if (!authentication.isAuthenticated(headers)) {
+ logger.debug("User is not authenticated!");
+ return new Response(false, 699, null);
+ }
+ return defaultRepo.getById(LZusatzWert.class, Integer.valueOf(id), "land");
+ }
+
+ @POST
+ @Path("/")
+ @Produces(MediaType.APPLICATION_JSON)
+ public Response create(
+ @Context HttpHeaders headers,
+ LZusatzWert zusatzwert
+ ) {
+ if (!authentication.isAuthenticated(headers)) {
+ return new Response(false, 699, null);
+ }
+ /* Persist the new object*/
+ return defaultRepo.create(zusatzwert, "land");
+ }
+
+ /**
+ * Update an existing object.
+ *
+ * @return Response object containing the updated probe object.
+ */
+ @PUT
+ @Path("/")
+ @Produces(MediaType.APPLICATION_JSON)
+ public Response update(
+ @Context HttpHeaders headers,
+ LZusatzWert zusatzwert
+ ) {
+ if (!authentication.isAuthenticated(headers)) {
+ logger.debug("User is not authenticated!");
+ return new Response(false, 699, null);
+ }
+ Response response = defaultRepo.update(zusatzwert, "land");
+ Response updated = defaultRepo.getById(
+ LZusatzWert.class,
+ ((LZusatzWert)response.getData()).getId(), "land");
+ return updated;
+ }
+
+ /**
+ * Delete an existing object by id.
+ *
+ * @return Response object.
+ */
+ @DELETE
+ @Path("/{id}")
+ @Produces(MediaType.APPLICATION_JSON)
+ public Response delete(
+ @Context HttpHeaders headers,
+ @PathParam("id") String id
+ ) {
+ if (!authentication.isAuthenticated(headers)) {
+ logger.debug("User is not authenticated!");
+ return new Response(false, 699, null);
+ }
+ /* Get the object by id*/
+ Response object =
+ defaultRepo.getById(LZusatzWert.class, Integer.valueOf(id), "land");
+ LZusatzWert obj = (LZusatzWert)object.getData();
+ /* Delete the object*/
+ return defaultRepo.delete(obj, "land");
+ }
+}
More information about the Lada-commits
mailing list