lada/lada-server: src/main/java/de/intevation/lada/rest/LProbeService.java comparison

comparison src/main/java/de/intevation/lada/rest/LProbeService.java @ 305:f0e1caad6027

Use sql queries from config to get proben.

author	Raimund Renkert <rrenkert@intevation.de>
date	Fri, 16 Aug 2013 14:41:40 +0200
parents	f4701a64e8a3
children	5844d7457dde

comparison

equal deleted inserted replaced

-:2d3f293899e8
+:f0e1caad6027
 package de.intevation.lada.rest;
 import java.util.ArrayList;
 import java.util.List;
+import java.util.Map;
 import java.util.logging.Logger;
 import javax.enterprise.context.RequestScoped;
 import javax.inject.Inject;
 import javax.inject.Named;
 import javax.ws.rs.core.Context;
 import javax.ws.rs.core.HttpHeaders;
 import javax.ws.rs.core.MultivaluedMap;
 import javax.ws.rs.core.UriInfo;
+import org.apache.commons.io.IOUtils;
+import org.jboss.resteasy.plugins.providers.multipart.InputPart;
+import org.jboss.resteasy.plugins.providers.multipart.MultipartFormDataInput;
+import org.json.JSONArray;
+import org.json.JSONException;
+import org.json.JSONObject;
 import de.intevation.lada.auth.Authentication;
 import de.intevation.lada.auth.AuthenticationException;
 import de.intevation.lada.auth.AuthenticationResponse;
 import de.intevation.lada.auth.Authorization;
+import de.intevation.lada.data.LProbeRepository;
 import de.intevation.lada.data.QueryBuilder;
 import de.intevation.lada.data.Repository;
 import de.intevation.lada.model.LProbe;
 import de.intevation.lada.model.LProbeInfo;
+import de.intevation.lada.utils.QueryTools;
-import org.jboss.resteasy.plugins.providers.multipart.MultipartFormDataInput;
 /**
 * This class produces a RESTful service to read, write and update
 * LProbe objects.
 *
 authentication.authorizedGroups(header);
 QueryBuilder<LProbeInfo> builder =
 new QueryBuilder<LProbeInfo>(
 repository.getEntityManager(),
 LProbeInfo.class);
-builder.or("netzbetreiberId", auth.getNetzbetreiber());
-builder.or("fertig", Boolean.TRUE);
 MultivaluedMap<String, String> params = info.getQueryParameters();
-if (params.isEmpty()) {
+if (params.isEmpty() || !params.containsKey("qid")) {
 return repository.filter(builder.getQuery());
 }
-QueryBuilder<LProbeInfo> mstBuilder = builder.getEmptyBuilder();
+String qid = params.getFirst("qid");
-if (params.keySet().contains("mstId")) {
+JSONObject query = QueryTools.getQueryById(qid);
-String[] paramValues = params.getFirst("mstId").split(",");
+List<String> filters = new ArrayList<String>();
-for (String pv: paramValues) {
+List<String> results = new ArrayList<String>();
-mstBuilder.or("mstId", pv);
+String sql = "";
-}
+try {
-builder.and(mstBuilder);
+sql = query.getString("sql");
-}
+JSONArray jFilters = query.getJSONArray("filters");
-QueryBuilder<LProbeInfo> umwBuilder = builder.getEmptyBuilder();
+for (int i = 0; i < jFilters.length(); i++) {
-if (params.keySet().contains("umwId")) {
+JSONObject jFilter = jFilters.getJSONObject(i);
-String[] paramValues = params.getFirst("umwId").split(",");
+filters.add(jFilter.getString("dataIndex"));
-for (String pv: paramValues) {
+}
-umwBuilder.or("umwId", pv);
+JSONArray jResults = query.getJSONArray("result");
-}
+for (int i = 0; i < jResults.length(); i++) {
-builder.and(umwBuilder);
+JSONObject jResult = jResults.getJSONObject(i);
-}
+results.add(jResult.getString("dataIndex"));
-QueryBuilder<LProbeInfo> beginBuilder = builder.getEmptyBuilder();
+}
-if (params.keySet().contains("bedin")) {
+}
-String[] paramValues = params.getFirst("begin").split(",");
+catch (JSONException e) {
-for (String pv: paramValues) {
+return new Response(false, 603, new ArrayList<LProbeInfo>());
-beginBuilder.or("probeentnahmeBegin", pv);
+}
-}
-builder.and(beginBuilder);
+if (sql == null || sql.length() == 0) {
-}
+return new Response(false, 603, new ArrayList<LProbeInfo>());
-builder.distinct();
+}
-return repository.filter(builder.getQuery());
+LProbeRepository lpr = (LProbeRepository)repository;
+String subselect = "(select * from l_probe_info where ";
+List<String> netzbetreiberIds = auth.getNetzbetreiber();
+boolean first = true;
+for (String netzbetreiberId: netzbetreiberIds) {
+if (first) {
+subselect += "netzbetreiber_id = '" + netzbetreiberId + "' ";
+first = false;
+}
+else {
+subselect += "or netzbetreiber_id = '" + netzbetreiberId + "' ";
+}
+}
+subselect += "or fertig = true) as lp";
+sql = sql.replace("l_probe", subselect);
+return lpr.filterFree(sql, filters, results, params);
 }
 catch(AuthenticationException ae) {
 return new Response(false, 699, new ArrayList<LProbe>());
 }
 }

Mercurial > lada > lada-server

comparison src/main/java/de/intevation/lada/rest/LProbeService.java @ 305:f0e1caad6027