Mercurial > lada > lada-server
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())