Mercurial > lada > lada-server
diff src/main/java/de/intevation/lada/factory/ProbeFactory.java @ 1097:186d602e031a
Merged branch schema-update into default.
author | Tom Gottfried <tom@intevation.de> |
---|---|
date | Fri, 14 Oct 2016 18:17:42 +0200 |
parents | 99c6c644773b |
children | 1ef08710aaeb |
line wrap: on
line diff
--- a/src/main/java/de/intevation/lada/factory/ProbeFactory.java Fri Oct 14 16:11:22 2016 +0200 +++ b/src/main/java/de/intevation/lada/factory/ProbeFactory.java Fri Oct 14 18:17:42 2016 +0200 @@ -18,19 +18,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; @@ -232,7 +230,7 @@ * * @return List of probe objects. */ - public List<LProbe> create(Messprogramm messprogramm, Long from, Long to) { + public List<Probe> create(Messprogramm messprogramm, Long from, Long to) { Calendar start = Calendar.getInstance(); start.setTimeInMillis(from); @@ -247,7 +245,7 @@ int gueltigVon = messprogramm.getGueltigVon(); int gueltigBis = messprogramm.getGueltigBis(); - List<LProbe> proben = new ArrayList<LProbe>(); + List<Probe> proben = new ArrayList<Probe>(); for (Intervall intervall = new Intervall(messprogramm, start); intervall.getFrom().before(end.getTime()); @@ -282,7 +280,7 @@ || solldatumBeginnDOY <= actualGueltigBis) ) ) { - LProbe probe = createObjects( + Probe probe = createObjects( messprogramm, intervall.getFrom(), intervall.getTo() @@ -305,32 +303,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())); @@ -339,17 +336,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"); } @@ -363,30 +357,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); @@ -396,7 +386,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>( @@ -412,8 +402,8 @@ repository.create(ort, "land"); } // Reolad the probe to have the old id - probe = (LProbe)repository.getById( - LProbe.class, probe.getId(), "land").getData(); + probe = (Probe)repository.getById( + Probe.class, probe.getId(), "land").getData(); return probe; } @@ -424,7 +414,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; @@ -440,7 +430,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()) @@ -591,9 +581,6 @@ case 11: if (media.get(11).equals(data.get(i).getS11())) matches += 1; break; - case 12: if (media.get(12).equals(data.get(i).getS12())) - matches += 1; - break; } if (matches > lastMatch) { lastMatch = matches;