fix: mapping av arbeidtype fra arbeidsforhold rest tjeneste. Fjernet de aller fleste kodeliste instansene (#466)

Author: frode-carlsen

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/AktivitetsAvtale.java

@@ -38,7 +38,7 @@ public class AktivitetsAvtale extends BaseEntitet implements IndexKey {
 
     @ManyToOne(optional = false)
     @JoinColumn(name = "yrkesaktivitet_id", nullable = false, updatable = false, unique = true)
-    private YrkesaktivitetEntitet yrkesaktivitet;
+    private Yrkesaktivitet yrkesaktivitet;
 
     /**
      * TODO (FC): Se om vi kan bli kvitt antallTimer. Brukes bare til å sjekke om det finnes verdi i {@link #erAnsettelsesPeriode()}.
@@ -221,7 +221,7 @@ void setBeskrivelse(String beskrivelse) {
         this.beskrivelse = beskrivelse;
     }
 
-    void setYrkesaktivitet(YrkesaktivitetEntitet yrkesaktivitet) {
+    void setYrkesaktivitet(Yrkesaktivitet yrkesaktivitet) {
         this.yrkesaktivitet = yrkesaktivitet;
     }
 

domenetjenester/iay/src/main/java/no/nav/foreldrepenger/abakus/domene/iay/AktørArbeid.java

@@ -1,20 +1,184 @@
 package no.nav.foreldrepenger.abakus.domene.iay;
 
 import java.util.Collection;
+import java.util.LinkedHashSet;
+import java.util.Objects;
+import java.util.Optional;
+import java.util.Set;
+import java.util.stream.Collectors;
 
+import javax.persistence.AttributeOverride;
+import javax.persistence.AttributeOverrides;
+import javax.persistence.Column;
+import javax.persistence.Embedded;
+import javax.persistence.Entity;
+import javax.persistence.GeneratedValue;
+import javax.persistence.GenerationType;
+import javax.persistence.Id;
+import javax.persistence.JoinColumn;
+import javax.persistence.ManyToOne;
+import javax.persistence.OneToMany;
+import javax.persistence.Table;
+import javax.persistence.Version;
+
+import no.nav.abakus.iaygrunnlag.kodeverk.ArbeidType;
+import no.nav.abakus.iaygrunnlag.kodeverk.IndexKey;
+import no.nav.foreldrepenger.abakus.felles.diff.ChangeTracked;
+import no.nav.foreldrepenger.abakus.felles.diff.IndexKeyComposer;
+import no.nav.foreldrepenger.abakus.felles.jpa.BaseEntitet;
 import no.nav.foreldrepenger.abakus.typer.AktørId;
 
-public interface AktørArbeid {
+@Table(name = "IAY_AKTOER_ARBEID")
+@Entity(name = "AktørArbeid")
+public class AktørArbeid extends BaseEntitet implements IndexKey {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.SEQUENCE, generator = "SEQ_AKTOER_ARBEID")
+    private Long id;
+
+    @Embedded
+    @AttributeOverrides(@AttributeOverride(name = "aktørId", column = @Column(name = "aktoer_id", nullable = false)))
+    private AktørId aktørId;
+
+    @ManyToOne(optional = false)
+    @JoinColumn(name = "inntekt_arbeid_ytelser_id", nullable = false, updatable = false)
+    private InntektArbeidYtelseAggregat inntektArbeidYtelser;
+
+    @OneToMany(mappedBy = "aktørArbeid")
+    @ChangeTracked
+    private Set<Yrkesaktivitet> yrkesaktiviter = new LinkedHashSet<>();
+
+    @Version
+    @Column(name = "versjon", nullable = false)
+    private long versjon;
+
+    AktørArbeid() {
+        // hibernate
+    }
+
+    /**
+     * Deep copy ctor
+     */
+    AktørArbeid(AktørArbeid aktørArbeid) {
+        final AktørArbeid aktørArbeid1 = aktørArbeid; // NOSONAR
+        this.aktørId = aktørArbeid1.getAktørId();
+
+        this.yrkesaktiviter = aktørArbeid1.yrkesaktiviter.stream().map(yrkesaktivitet -> {
+            yrkesaktivitet.setAktørArbeid(this);
+            return yrkesaktivitet;
+        }).collect(Collectors.toCollection(LinkedHashSet::new));
+    }
+
+    @Override
+    public String getIndexKey() {
+        Object[] keyParts = { getAktørId() };
+        return IndexKeyComposer.createKey(keyParts);
+    }
 
     /**
      * Aktøren som avtalene gjelder for
      *
      * @return aktørId
      */
-    AktørId getAktørId();
+    public AktørId getAktørId() {
+        return aktørId;
+    }
+
+    void setAktørId(AktørId aktørId) {
+        this.aktørId = aktørId;
+    }
 
     /** 
      * Alle yrkesaktiviteter (ufiltret ifht skjæringstidspunkt vurdering. )
      */
-    Collection<Yrkesaktivitet> hentAlleYrkesaktiviteter();
+    public Collection<Yrkesaktivitet> hentAlleYrkesaktiviteter() {
+        return Set.copyOf(yrkesaktiviter);
+    }
+
+    void setYrkesaktiviter() {
+        this.yrkesaktiviter = new LinkedHashSet<>();
+    }
+
+    void setInntektArbeidYtelser(InntektArbeidYtelseAggregat inntektArbeidYtelser) {
+        this.inntektArbeidYtelser = inntektArbeidYtelser;
+    }
+
+    boolean hasValues() {
+        return aktørId != null || yrkesaktiviter != null;
+    }
+
+    YrkesaktivitetBuilder getYrkesaktivitetBuilderForNøkkel(Opptjeningsnøkkel identifikator, ArbeidType arbeidType) {
+        Optional<Yrkesaktivitet> yrkesaktivitet = yrkesaktiviter.stream()
+            .filter(ya -> ya.getArbeidType().equals(arbeidType) && new Opptjeningsnøkkel(ya).equals(identifikator))
+            .findFirst();
+        final YrkesaktivitetBuilder oppdatere = YrkesaktivitetBuilder.oppdatere(yrkesaktivitet);
+        oppdatere.medArbeidType(arbeidType);
+        return oppdatere;
+    }
+
+    YrkesaktivitetBuilder getYrkesaktivitetBuilderForNøkkel(Opptjeningsnøkkel identifikator, Set<ArbeidType> arbeidTyper) {
+        Optional<Yrkesaktivitet> yrkesaktivitet = yrkesaktiviter.stream()
+            .filter(ya -> arbeidTyper.contains(ya.getArbeidType()) && new Opptjeningsnøkkel(ya).equals(identifikator))
+            .findFirst();
+        final YrkesaktivitetBuilder oppdatere = YrkesaktivitetBuilder.oppdatere(yrkesaktivitet);
+        if (!oppdatere.getErOppdatering()) {
+            // Defaulter til ordinert arbeidsforhold hvis saksbehandler har lagt til fra GUI
+            oppdatere.medArbeidType(ArbeidType.ORDINÆRT_ARBEIDSFORHOLD);
+        }
+        return oppdatere;
+    }
+
+    void fjernYrkesaktivitetForBuilder(YrkesaktivitetBuilder builder) {
+        Yrkesaktivitet yrkesaktivitetKladd = builder.getKladd();
+        ArbeidType arbeidType = yrkesaktivitetKladd.getArbeidType();
+        if (arbeidType.erAnnenOpptjening() || ArbeidType.SELVSTENDIG_NÆRINGSDRIVENDE.equals(arbeidType)) {
+            yrkesaktiviter.removeIf(ya -> ya.getArbeidType().equals(arbeidType));
+        } else {
+            Opptjeningsnøkkel nøkkel = new Opptjeningsnøkkel(yrkesaktivitetKladd);
+            yrkesaktiviter.removeIf(ya -> ya.getArbeidType().equals(arbeidType)
+                && new Opptjeningsnøkkel(ya).matcher(nøkkel));
+        }
+    }
+
+    YrkesaktivitetBuilder getYrkesaktivitetBuilderForType(ArbeidType type) {
+        Optional<Yrkesaktivitet> yrkesaktivitet = yrkesaktiviter.stream()
+            .filter(ya -> ya.getArbeidType().equals(type))
+            .findFirst();
+        final YrkesaktivitetBuilder oppdatere = YrkesaktivitetBuilder.oppdatere(yrkesaktivitet);
+        oppdatere.medArbeidType(type);
+        return oppdatere;
+    }
+
+    void leggTilYrkesaktivitet(Yrkesaktivitet yrkesaktivitet) {
+        this.yrkesaktiviter.add(yrkesaktivitet);
+        yrkesaktivitet.setAktørArbeid(this);
+    }
+
+    @Override
+    public boolean equals(Object obj) {
+        if (obj == this) {
+            return true;
+        } else if (!(obj instanceof AktørArbeid)) {
+            return false;
+        }
+        AktørArbeid other = (AktørArbeid) obj;
+        return Objects.equals(this.getAktørId(), other.getAktørId());
+    }
+
+    @Override
+    public int hashCode() {
+        return Objects.hash(aktørId);
+    }
+
+    @Override
+    public String toString() {
+        return getClass().getSimpleName() + "<" +
+            "aktørId=" + aktørId +
+            ", yrkesaktiviteter=" + yrkesaktiviter +
+            '>';
+    }
+
+    void tilbakestillYrkesaktiviteter() {
+        this.yrkesaktiviter.clear();
+    }
 }