diff src/main/java/de/intevation/lada/factory/ProbeFactory.java @ 1028:1c41c7b8f7c2 schema-update

Updated server application to new database model. THIS IS STILL WIP!!!
author Raimund Renkert <raimund.renkert@intevation.de>
date Fri, 08 Jul 2016 15:32:36 +0200
parents 84f17f460969
children 1868bd3565bf
line wrap: on
line diff
--- a/src/main/java/de/intevation/lada/factory/ProbeFactory.java	Mon Jul 04 14:31:18 2016 +0200
+++ b/src/main/java/de/intevation/lada/factory/ProbeFactory.java	Fri Jul 08 15:32:36 2016 +0200
@@ -17,19 +17,17 @@
 
 import org.apache.log4j.Logger;
 
-import de.intevation.lada.model.land.LKommentarP;
-import de.intevation.lada.model.land.LMessung;
-import de.intevation.lada.model.land.LMesswert;
-import de.intevation.lada.model.land.LOrtszuordnung;
-import de.intevation.lada.model.land.LProbe;
-import de.intevation.lada.model.land.LStatusProtokoll;
+import de.intevation.lada.model.land.KommentarP;
 import de.intevation.lada.model.land.Messprogramm;
 import de.intevation.lada.model.land.MessprogrammMmt;
-import de.intevation.lada.model.land.MessungTranslation;
-import de.intevation.lada.model.land.ProbeTranslation;
-import de.intevation.lada.model.stamm.DeskriptorUmwelt;
-import de.intevation.lada.model.stamm.Deskriptoren;
-import de.intevation.lada.model.stamm.Ort;
+import de.intevation.lada.model.land.Probe;
+import de.intevation.lada.model.land.Messung;
+import de.intevation.lada.model.land.Messwert;
+import de.intevation.lada.model.land.Ortszuordnung;
+import de.intevation.lada.model.land.StatusProtokoll;
+import de.intevation.lada.model.stammdaten.DeskriptorUmwelt;
+import de.intevation.lada.model.stammdaten.Deskriptoren;
+import de.intevation.lada.model.stammdaten.Ort;
 import de.intevation.lada.util.annotation.RepositoryConfig;
 import de.intevation.lada.util.data.QueryBuilder;
 import de.intevation.lada.util.data.Repository;
@@ -62,7 +60,7 @@
      *
      * @return List of probe objects.
      */
-    public List<LProbe> create(String id, Long from, Long to) {
+    public List<Probe> create(String id, Long from, Long to) {
         QueryBuilder<Messprogramm> builder =
             new QueryBuilder<Messprogramm>(
                     repository.entityManager("land"),
@@ -80,7 +78,7 @@
         start.setTime(new Date(from));
         Calendar end = Calendar.getInstance();
         end.setTime(new Date (to));
-        List<LProbe> proben = new ArrayList<LProbe>();
+        List<Probe> proben = new ArrayList<Probe>();
 
 
         if ("M".equals(messprogramm.getProbenintervall())) {
@@ -105,7 +103,7 @@
     }
 
     /**
-     * Create LProbe objects using the interval and messprogramm details.
+     * Create Probe objects using the interval and messprogramm details.
      *
      * @param   interval        The time interval for probe objects.
      * @param   messprogramm    The messprogramm containing details.
@@ -116,7 +114,7 @@
     private void createProben(
         Date[] interval,
         Messprogramm messprogramm,
-        List<LProbe> proben
+        List<Probe> proben
     ) {
         Calendar start = Calendar.getInstance();
         start.setTime(interval[0]);
@@ -148,7 +146,7 @@
             Date startDate = start.getTime();
             end.add(Calendar.DATE, messprogramm.getTeilintervallBis() - endDay + messprogramm.getIntervallOffset());
             Date endDate = end.getTime();
-            LProbe probe = createObjects(messprogramm, startDate, endDate);
+            Probe probe = createObjects(messprogramm, startDate, endDate);
             if (probe != null) {
                 proben.add(probe);
             }
@@ -156,7 +154,7 @@
         }
     }
 
-    private List<LProbe> generateMonth(
+    private List<Probe> generateMonth(
         Messprogramm messprogramm,
         Calendar start,
         Calendar end,
@@ -170,7 +168,7 @@
             0 : messprogramm.getTeilintervallBis();
         int manualDuration = teilBis - teilVon;
 
-        List<LProbe> proben = new ArrayList<LProbe>();
+        List<Probe> proben = new ArrayList<Probe>();
 
         int currentLength = getDurationMonth(start);
         if (manualDuration > 0) {
@@ -184,7 +182,7 @@
         for (;monthStart.before(end);) {
             if (monthStart.get(Calendar.DAY_OF_YEAR) > messprogramm.getGueltigVon() &&
                 monthStart.get(Calendar.DAY_OF_YEAR) < messprogramm.getGueltigBis()) {
-                LProbe probe = createObjects(messprogramm, monthStart.getTime(), monthEnd.getTime());
+                Probe probe = createObjects(messprogramm, monthStart.getTime(), monthEnd.getTime());
                 if (probe != null) {
                     proben.add(probe);
                 }
@@ -202,7 +200,7 @@
         return proben;
     }
 
-    private List<LProbe> generateQuarter(
+    private List<Probe> generateQuarter(
         Messprogramm messprogramm,
         Calendar start,
         Calendar end,
@@ -216,7 +214,7 @@
             0 : messprogramm.getTeilintervallBis();
         int manualDuration = teilBis - teilVon;
 
-        List<LProbe> proben = new ArrayList<LProbe>();
+        List<Probe> proben = new ArrayList<Probe>();
 
         int currentLength = getDurationQuarter(start);
         if (manualDuration > 0) {
@@ -230,7 +228,7 @@
         for (;quarterStart.before(end);) {
             if (quarterStart.get(Calendar.DAY_OF_YEAR) > messprogramm.getGueltigVon() &&
                 quarterStart.get(Calendar.DAY_OF_YEAR) < messprogramm.getGueltigBis()) {
-                LProbe probe = createObjects(messprogramm, quarterStart.getTime(), quarterEnd.getTime());
+                Probe probe = createObjects(messprogramm, quarterStart.getTime(), quarterEnd.getTime());
                 if (probe != null) {
                     proben.add(probe);
                 }
@@ -248,7 +246,7 @@
         return proben;
     }
 
-    private List<LProbe> generateHalf(
+    private List<Probe> generateHalf(
         Messprogramm messprogramm,
         Calendar start,
         Calendar end,
@@ -262,7 +260,7 @@
             0 : messprogramm.getTeilintervallBis();
         int manualDuration = teilBis - teilVon;
 
-        List<LProbe> proben = new ArrayList<LProbe>();
+        List<Probe> proben = new ArrayList<Probe>();
 
         int currentLength = getDurationHalf(start);
         if (manualDuration > 0) {
@@ -276,7 +274,7 @@
         for (;halfStart.before(end);) {
             if (halfStart.get(Calendar.DAY_OF_YEAR) > messprogramm.getGueltigVon() &&
                 halfStart.get(Calendar.DAY_OF_YEAR) < messprogramm.getGueltigBis()) {
-                LProbe probe = createObjects(messprogramm, halfStart.getTime(), halfEnd.getTime());
+                Probe probe = createObjects(messprogramm, halfStart.getTime(), halfEnd.getTime());
                 if (probe != null) {
                     proben.add(probe);
                 }
@@ -294,7 +292,7 @@
         return proben;
     }
 
-    private List<LProbe> generate(
+    private List<Probe> generate(
         Messprogramm messprogramm,
         Calendar start,
         Calendar end,
@@ -309,7 +307,7 @@
 
         //int teilStart = messprogramm.getTeilintervallVon() + startDay;
         //int teilEnd = messprogramm.getTeilintervallBis() + startDay;
-        List<LProbe> proben = new ArrayList<LProbe>();
+        List<Probe> proben = new ArrayList<Probe>();
         int duration = messprogramm.getTeilintervallBis() -
             messprogramm.getTeilintervallVon();
 
@@ -321,7 +319,7 @@
             end.set(Calendar.DAY_OF_YEAR, startDay + duration);
             logger.debug("from: " + start.getTime() + " to " + end.getTime());
             startDay += days;
-            LProbe probe = createObjects(messprogramm, start.getTime(), end.getTime());
+            Probe probe = createObjects(messprogramm, start.getTime(), end.getTime());
             if (probe != null) {
                 proben.add(probe);
             }
@@ -437,32 +435,31 @@
      *
      * @return The new probe object.
      */
-    private LProbe createObjects(
+    private Probe createObjects(
         Messprogramm messprogramm,
         Date startDate,
         Date endDate
     ) {
-        QueryBuilder<LProbe> builderProbe =
-            new QueryBuilder<LProbe>(
+        QueryBuilder<Probe> builderProbe =
+            new QueryBuilder<Probe>(
                 repository.entityManager("land"),
-                LProbe.class);
+                Probe.class);
         builderProbe.and("mprId", messprogramm.getId());
         builderProbe.and("solldatumBeginn", startDate);
         builderProbe.and("solldatumEnde", endDate);
 
-        List<LProbe> proben =
+        List<Probe> proben =
             repository.filterPlain(builderProbe.getQuery(), "land");
 
         if (!proben.isEmpty()) {
             return null;
         }
-        LProbe probe = new LProbe();
+        Probe probe = new Probe();
         probe.setBaId(messprogramm.getBaId());
         probe.setDatenbasisId(messprogramm.getDatenbasisId());
         probe.setMediaDesk(messprogramm.getMediaDesk());
         probe.setMstId(messprogramm.getMstId());
         probe.setLaborMstId(messprogramm.getLaborMstId());
-        probe.setNetzbetreiberId(messprogramm.getNetzbetreiberId());
         probe.setProbenartId(messprogramm.getProbenartId());
         probe.setProbeNehmerId(messprogramm.getProbeNehmerId());
         probe.setSolldatumBeginn(new Timestamp(startDate.getTime()));
@@ -471,17 +468,14 @@
         probe.setUmwId(messprogramm.getUmwId());
         probe.setMprId(messprogramm.getId());
         repository.create(probe, "land");
-        ProbeTranslation translation = new ProbeTranslation();
-        translation.setProbeId(probe);
-        repository.create(translation, "land");
 
         if (messprogramm.getProbeKommentar() != null &&
             !messprogramm.getProbeKommentar().equals("")) {
-            LKommentarP kommentar = new LKommentarP();
+            KommentarP kommentar = new KommentarP();
             kommentar.setDatum(new Timestamp(new Date().getTime()));
             kommentar.setProbeId(probe.getId());
             kommentar.setText(messprogramm.getProbeKommentar());
-            kommentar.setErzeuger(messprogramm.getMstId());
+            kommentar.setMstId(messprogramm.getMstId());
 
             repository.create(kommentar, "land");
         }
@@ -495,30 +489,26 @@
         @SuppressWarnings("unchecked")
         List<MessprogrammMmt> mmts = (List<MessprogrammMmt>)response.getData();
         for (MessprogrammMmt mmt : mmts) {
-            LMessung messung = new LMessung();
+            Messung messung = new Messung();
             messung.setFertig(false);
             messung.setGeplant(true);
             messung.setMmtId(mmt.getMmtId());
             messung.setNebenprobenNr(
-                messprogramm.getNetzbetreiberId() + mmt.getMmtId());
+                messprogramm.getMstId() + mmt.getMmtId());
             messung.setProbeId(probe.getId());
             repository.create(messung, "land");
-            MessungTranslation mTranslation = new MessungTranslation();
-            mTranslation.setMessungsId(messung);
-            repository.create(mTranslation, "land");
 
-            LStatusProtokoll status = new LStatusProtokoll();
+            StatusProtokoll status = new StatusProtokoll();
             status.setDatum(new Timestamp(new Date().getTime()));
             status.setMessungsId(messung.getId());
-            status.setErzeuger(probe.getMstId());
-            status.setStatusStufe(1);
-            status.setStatusWert(0);
+            status.setMstId(probe.getMstId());
+            status.setStatusKombi(1);
             repository.create(status, "land");
             messung.setStatus(status.getId());
             repository.update(messung, "land");
 
             for (int mw : mmt.getMessgroessen()) {
-                LMesswert wert = new LMesswert();
+                Messwert wert = new Messwert();
                 wert.setMessgroesseId(mw);
                 wert.setMessungsId(messung.getId());
                 wert.setMesswert(0d);
@@ -528,7 +518,7 @@
         }
         if (messprogramm.getOrtId() != null &&
             !messprogramm.getOrtId().equals("")) {
-            LOrtszuordnung ort = new LOrtszuordnung();
+            Ortszuordnung ort = new Ortszuordnung();
             ort.setOrtszuordnungTyp("E");
             ort.setProbeId(probe.getId());
             QueryBuilder<Ort> ortBuilder = new QueryBuilder<Ort>(
@@ -544,7 +534,7 @@
         }
         // Reolad the probe to have the old id
         probe =
-            (LProbe)repository.getById(LProbe.class, probe.getId(), "land").getData();
+            (Probe)repository.getById(Probe.class, probe.getId(), "land").getData();
         return probe;
     }
 
@@ -649,7 +639,7 @@
      *
      * @return The updated probe object.
      */
-    public LProbe findUmweltId(LProbe probe) {
+    public Probe findUmweltId(Probe probe) {
         String[] mediaDesk = probe.getMediaDesk().split(" ");
         if (mediaDesk.length <= 1) {
             return probe;
@@ -665,7 +655,7 @@
      *
      * @return The updated probe object.
      */
-    public LProbe findMediaDesk(LProbe probe) {
+    public Probe findMediaDesk(Probe probe) {
         Object result = repository.queryFromString(
                 "SELECT get_media_from_media_desk( :mediaDesk );", "stamm")
             .setParameter("mediaDesk", probe.getMediaDesk())
This site is hosted by Intevation GmbH (Datenschutzerklärung und Impressum | Privacy Policy and Imprint)