annotate src/main/java/de/intevation/lada/rest/LProbeService.java @ 325:30883ab746a5

Extracted LAF import service to its own service class.
author Raimund Renkert <rrenkert@intevation.de>
date Fri, 23 Aug 2013 12:56:19 +0200
parents 5844d7457dde
children b199946e9654
rev   line source
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
1 package de.intevation.lada.rest;
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
2
321
5844d7457dde Completed importer for LAF format. Ort objects still need some attention.
Raimund Renkert <rrenkert@intevation.de>
parents: 305
diff changeset
3 import java.io.IOException;
5844d7457dde Completed importer for LAF format. Ort objects still need some attention.
Raimund Renkert <rrenkert@intevation.de>
parents: 305
diff changeset
4 import java.io.InputStream;
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
5 import java.util.ArrayList;
321
5844d7457dde Completed importer for LAF format. Ort objects still need some attention.
Raimund Renkert <rrenkert@intevation.de>
parents: 305
diff changeset
6 import java.util.HashMap;
5844d7457dde Completed importer for LAF format. Ort objects still need some attention.
Raimund Renkert <rrenkert@intevation.de>
parents: 305
diff changeset
7 import java.util.LinkedList;
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
8 import java.util.List;
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
9 import java.util.Map;
17
4ed66a87c0c4 Added missing import.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 15
diff changeset
10 import java.util.logging.Logger;
15
624611a29348 Provide GET method to load a list of proben.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 8
diff changeset
11
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
12 import javax.enterprise.context.RequestScoped;
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
13 import javax.inject.Inject;
131
4e181a4aaab0 Refactored the entity repositories.
Raimund Renkert <rrenkert@intevation.de>
parents: 107
diff changeset
14 import javax.inject.Named;
66
54ff6ded05b2 New service to create a LProbe.
Raimund Renkert <rrenkert@intevation.de>
parents: 62
diff changeset
15 import javax.ws.rs.Consumes;
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
16 import javax.ws.rs.GET;
66
54ff6ded05b2 New service to create a LProbe.
Raimund Renkert <rrenkert@intevation.de>
parents: 62
diff changeset
17 import javax.ws.rs.POST;
73
354deea8e738 Fixed generating return value for Create and Update.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 70
diff changeset
18 import javax.ws.rs.PUT;
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
19 import javax.ws.rs.Path;
35
f425150ea2b5 New filter option in LProbe GET request.
Raimund Renkert <rrenkert@intevation.de>
parents: 29
diff changeset
20 import javax.ws.rs.PathParam;
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
21 import javax.ws.rs.Produces;
35
f425150ea2b5 New filter option in LProbe GET request.
Raimund Renkert <rrenkert@intevation.de>
parents: 29
diff changeset
22 import javax.ws.rs.core.Context;
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
23 import javax.ws.rs.core.HttpHeaders;
35
f425150ea2b5 New filter option in LProbe GET request.
Raimund Renkert <rrenkert@intevation.de>
parents: 29
diff changeset
24 import javax.ws.rs.core.MultivaluedMap;
f425150ea2b5 New filter option in LProbe GET request.
Raimund Renkert <rrenkert@intevation.de>
parents: 29
diff changeset
25 import javax.ws.rs.core.UriInfo;
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
26
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
27 import org.apache.commons.io.IOUtils;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
28 import org.jboss.resteasy.plugins.providers.multipart.InputPart;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
29 import org.jboss.resteasy.plugins.providers.multipart.MultipartFormDataInput;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
30 import org.json.JSONArray;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
31 import org.json.JSONException;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
32 import org.json.JSONObject;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
33
232
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
34 import de.intevation.lada.auth.Authentication;
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
35 import de.intevation.lada.auth.AuthenticationException;
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
36 import de.intevation.lada.auth.AuthenticationResponse;
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
37 import de.intevation.lada.auth.Authorization;
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
38 import de.intevation.lada.data.LProbeRepository;
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
39 import de.intevation.lada.data.QueryBuilder;
131
4e181a4aaab0 Refactored the entity repositories.
Raimund Renkert <rrenkert@intevation.de>
parents: 107
diff changeset
40 import de.intevation.lada.data.Repository;
321
5844d7457dde Completed importer for LAF format. Ort objects still need some attention.
Raimund Renkert <rrenkert@intevation.de>
parents: 305
diff changeset
41 import de.intevation.lada.data.importer.Importer;
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
42 import de.intevation.lada.model.LProbe;
139
fda177c59d1f Updated service and repository to use the extended LProbeInfo object.
Raimund Renkert <rrenkert@intevation.de>
parents: 131
diff changeset
43 import de.intevation.lada.model.LProbeInfo;
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
44 import de.intevation.lada.utils.QueryTools;
289
f4701a64e8a3 Added upload function to the ProbenService. Must be implemented.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 263
diff changeset
45
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
46 /**
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
47 * This class produces a RESTful service to read, write and update
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
48 * LProbe objects.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
49 *
77
8af2a920f974 Formatting.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 75
diff changeset
50 * @author <a href="mailto:rrenkert@intevation.de">Raimund Renkert</a>
8af2a920f974 Formatting.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 75
diff changeset
51 */
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
52 @Path("/proben")
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
53 @RequestScoped
45
a5ee8d69c0b4 Renamed existing rest services and make use of the generic repository.
Raimund Renkert <rrenkert@intevation.de>
parents: 39
diff changeset
54 public class LProbeService {
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
55
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
56 /**
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
57 * The Repository for LProbe.
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
58 */
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
59 @Inject
131
4e181a4aaab0 Refactored the entity repositories.
Raimund Renkert <rrenkert@intevation.de>
parents: 107
diff changeset
60 @Named("lproberepository")
4e181a4aaab0 Refactored the entity repositories.
Raimund Renkert <rrenkert@intevation.de>
parents: 107
diff changeset
61 private Repository repository;
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
62
223
d9d1a46af55d Moved isReadOnly for LProbe from authentication to service.
Raimund Renkert <rrenkert@intevation.de>
parents: 210
diff changeset
63 @Inject
d9d1a46af55d Moved isReadOnly for LProbe from authentication to service.
Raimund Renkert <rrenkert@intevation.de>
parents: 210
diff changeset
64 @Named("lmessungrepository")
d9d1a46af55d Moved isReadOnly for LProbe from authentication to service.
Raimund Renkert <rrenkert@intevation.de>
parents: 210
diff changeset
65 private Repository messungRepository;
d9d1a46af55d Moved isReadOnly for LProbe from authentication to service.
Raimund Renkert <rrenkert@intevation.de>
parents: 210
diff changeset
66
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
67 /**
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
68 * The authorization module.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
69 */
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
70 @Inject
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
71 @Named("ldapauth")
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
72 private Authentication authentication;
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
73
232
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
74 @Inject
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
75 @Named("dataauthorization")
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
76 private Authorization authorization;
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
77
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
78 /**
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
79 * The logger for this class.
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
80 */
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
81 @Inject
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
82 private Logger log;
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
83
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
84 /**
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
85 * Request a LProbe via its id.
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
86 *
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
87 * @param id The LProbe id
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
88 * @param header THe HTTP header containing authorization information.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
89 * @return Response object.
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
90 */
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
91 @GET
36
8155d2ed5cb8 Use String for lprobe id.
Raimund Renkert <rrenkert@intevation.de>
parents: 35
diff changeset
92 @Path("/{id}")
8155d2ed5cb8 Use String for lprobe id.
Raimund Renkert <rrenkert@intevation.de>
parents: 35
diff changeset
93 @Produces("text/json")
188
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
94 public Response findById(
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
95 @PathParam("id") String id,
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
96 @Context HttpHeaders header
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
97 ) {
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
98 try {
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
99 AuthenticationResponse auth =
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
100 authentication.authorizedGroups(header);
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
101 Response response =
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
102 repository.findById(LProbeInfo.class, id);
232
d8a3d188046f Renamed package authentication to auth.
Raimund Renkert <rrenkert@intevation.de>
parents: 231
diff changeset
103 @SuppressWarnings("unchecked")
188
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
104 List<LProbeInfo> probe = (List<LProbeInfo>)response.getData();
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
105 if (probe.isEmpty()) {
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
106 return new Response(false, 601, new ArrayList<LProbeInfo>());
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
107 }
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
108 String nbId = probe.get(0).getNetzbetreiberId();
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
109 String mstId = probe.get(0).getMstId();
234
0d545e6d1885 Return LProbe objects with "fertig" flag = true.
Raimund Renkert <rrenkert@intevation.de>
parents: 233
diff changeset
110 if (auth.getNetzbetreiber().contains(nbId) ||
0d545e6d1885 Return LProbe objects with "fertig" flag = true.
Raimund Renkert <rrenkert@intevation.de>
parents: 233
diff changeset
111 probe.get(0).getFertig()) {
188
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
112 if (auth.getMst().contains(mstId)) {
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
113 return response;
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
114 }
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
115 return response;
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
116 }
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
117 return new Response(false, 698, new ArrayList<LProbe>());
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
118 }
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
119 catch(AuthenticationException ae) {
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
120 return new Response(false, 699, new ArrayList<LProbe>());
bc8e6d6f5eb1 Use authentication in lprobe 'findById'.
Raimund Renkert <rrenkert@intevation.de>
parents: 182
diff changeset
121 }
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
122 }
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
123
80
75d42f8063f8 Formatting
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 77
diff changeset
124 /**
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
125 * Request LProbe via a filter.
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
126 *
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
127 * Query parameters are used for the filter in form of key-value pairs.
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
128 * This filter can take the three parameters
263
2098db2e8fbd Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 234
diff changeset
129 * mstId=$MSTID (String)
2098db2e8fbd Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 234
diff changeset
130 * umwId=$UWBID (String)
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
131 * begin=$PROBEENTNAHMEBEGIN (Timestamp)
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
132 *
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
133 * @param info The URL query parameters.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
134 * @param header The HTTP header containing authorization information.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
135 * @return Response object.
39
e0a5477f657e Documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 38
diff changeset
136 */
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
137 @GET
35
f425150ea2b5 New filter option in LProbe GET request.
Raimund Renkert <rrenkert@intevation.de>
parents: 29
diff changeset
138 @Produces("text/json")
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
139 public Response filter(
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
140 @Context UriInfo info,
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
141 @Context HttpHeaders header
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
142 ) {
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
143 try {
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
144 AuthenticationResponse auth =
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
145 authentication.authorizedGroups(header);
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
146 QueryBuilder<LProbeInfo> builder =
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
147 new QueryBuilder<LProbeInfo>(
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
148 repository.getEntityManager(),
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
149 LProbeInfo.class);
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
150
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
151 MultivaluedMap<String, String> params = info.getQueryParameters();
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
152 if (params.isEmpty() || !params.containsKey("qid")) {
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
153 return repository.filter(builder.getQuery());
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
154 }
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
155 String qid = params.getFirst("qid");
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
156 JSONObject query = QueryTools.getQueryById(qid);
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
157 List<String> filters = new ArrayList<String>();
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
158 List<String> results = new ArrayList<String>();
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
159 String sql = "";
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
160 try {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
161 sql = query.getString("sql");
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
162 JSONArray jFilters = query.getJSONArray("filters");
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
163 for (int i = 0; i < jFilters.length(); i++) {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
164 JSONObject jFilter = jFilters.getJSONObject(i);
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
165 filters.add(jFilter.getString("dataIndex"));
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
166 }
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
167 JSONArray jResults = query.getJSONArray("result");
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
168 for (int i = 0; i < jResults.length(); i++) {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
169 JSONObject jResult = jResults.getJSONObject(i);
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
170 results.add(jResult.getString("dataIndex"));
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
171 }
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
172 }
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
173 catch (JSONException e) {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
174 return new Response(false, 603, new ArrayList<LProbeInfo>());
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
175 }
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
176
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
177 if (sql == null || sql.length() == 0) {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
178 return new Response(false, 603, new ArrayList<LProbeInfo>());
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
179 }
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
180 LProbeRepository lpr = (LProbeRepository)repository;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
181 String subselect = "(select * from l_probe_info where ";
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
182 List<String> netzbetreiberIds = auth.getNetzbetreiber();
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
183 boolean first = true;
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
184 for (String netzbetreiberId: netzbetreiberIds) {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
185 if (first) {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
186 subselect += "netzbetreiber_id = '" + netzbetreiberId + "' ";
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
187 first = false;
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
188 }
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
189 else {
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
190 subselect += "or netzbetreiber_id = '" + netzbetreiberId + "' ";
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
191 }
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
192 }
305
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
193 subselect += "or fertig = true) as lp";
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
194 sql = sql.replace("l_probe", subselect);
f0e1caad6027 Use sql queries from config to get proben.
Raimund Renkert <rrenkert@intevation.de>
parents: 289
diff changeset
195 return lpr.filterFree(sql, filters, results, params);
35
f425150ea2b5 New filter option in LProbe GET request.
Raimund Renkert <rrenkert@intevation.de>
parents: 29
diff changeset
196 }
182
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
197 catch(AuthenticationException ae) {
a2e04ab2cd44 Use the new filter and query builder and have authentication for LProbeInfo objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 169
diff changeset
198 return new Response(false, 699, new ArrayList<LProbe>());
35
f425150ea2b5 New filter option in LProbe GET request.
Raimund Renkert <rrenkert@intevation.de>
parents: 29
diff changeset
199 }
29
c5930d01e0ab Package renaming and code cosmetics.
Raimund Renkert <rrenkert@intevation.de>
parents: 24
diff changeset
200 }
62
0b3f58cbbd75 Added comment on expected return values.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 55
diff changeset
201
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
202 /**
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
203 * Update a LProbe object.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
204 *
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
205 * @param probe A LProbeInfo object wrapping the LProbe object.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
206 * @param header The HTTP header containing authorization information.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
207 * @return Response object.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
208 */
73
354deea8e738 Fixed generating return value for Create and Update.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 70
diff changeset
209 @PUT
354deea8e738 Fixed generating return value for Create and Update.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 70
diff changeset
210 @Path("/{id}")
354deea8e738 Fixed generating return value for Create and Update.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 70
diff changeset
211 @Produces("text/json")
354deea8e738 Fixed generating return value for Create and Update.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 70
diff changeset
212 @Consumes("application/json")
207
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
213 public Response update(LProbeInfo probe, @Context HttpHeaders header) {
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
214 try {
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
215 if(authentication.hasAccess(header, probe.getProbeId())) {
233
b619f6552f55 Fixed update of LProbe objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 232
diff changeset
216 LProbe p = probe.toLProbe();
b619f6552f55 Fixed update of LProbe objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 232
diff changeset
217 p.setProbeId(probe.getProbeId());
b619f6552f55 Fixed update of LProbe objects.
Raimund Renkert <rrenkert@intevation.de>
parents: 232
diff changeset
218 return repository.update(p);
207
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
219 }
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
220 return new Response(false, 698, new ArrayList<LProbeInfo>());
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
221 }
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
222 catch(AuthenticationException ae) {
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
223 return new Response(false, 699, new ArrayList<LProbeInfo>());
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
224 }
73
354deea8e738 Fixed generating return value for Create and Update.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 70
diff changeset
225 }
354deea8e738 Fixed generating return value for Create and Update.
Torsten Irländer <torsten.irlaender@intevation.de>
parents: 70
diff changeset
226
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
227 /**
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
228 * Create a new LProbe object.
263
2098db2e8fbd Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 234
diff changeset
229 *
210
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
230 * @param probe A LProbeInfo object wrapping the LProbe object.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
231 * @param header The HTTP header containing authorization information.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
232 * @return Response object.
a305412206a3 Code documentation.
Raimund Renkert <rrenkert@intevation.de>
parents: 207
diff changeset
233 */
66
54ff6ded05b2 New service to create a LProbe.
Raimund Renkert <rrenkert@intevation.de>
parents: 62
diff changeset
234 @POST
54ff6ded05b2 New service to create a LProbe.
Raimund Renkert <rrenkert@intevation.de>
parents: 62
diff changeset
235 @Produces("text/json")
54ff6ded05b2 New service to create a LProbe.
Raimund Renkert <rrenkert@intevation.de>
parents: 62
diff changeset
236 @Consumes("application/json")
207
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
237 public Response create(LProbeInfo probe, @Context HttpHeaders header) {
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
238 try {
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
239 AuthenticationResponse auth =
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
240 authentication.authorizedGroups(header);
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
241 if (auth.getNetzbetreiber().contains(probe.getNetzbetreiberId()) &&
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
242 auth.getMst().contains(probe.getMstId())) {
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
243 LProbe p = probe.toLProbe();
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
244 return repository.create(p);
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
245 }
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
246 return new Response(false, 698, new ArrayList<LProbeInfo>());
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
247 }
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
248 catch(AuthenticationException ae) {
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
249 return new Response(false, 699, new ArrayList<LProbeInfo>());
fe05c016cdb6 Added authorization to create and update in lprobe service.
Raimund Renkert <rrenkert@intevation.de>
parents: 189
diff changeset
250 }
66
54ff6ded05b2 New service to create a LProbe.
Raimund Renkert <rrenkert@intevation.de>
parents: 62
diff changeset
251 }
8
1016bcc08bb3 Added stub for REST service for Proben
Torsten Irländer <torsten.irlaender@intevation.de>
parents:
diff changeset
252 }
This site is hosted by Intevation GmbH (Datenschutzerklärung und Impressum | Privacy Policy and Imprint)