Testaa organisaatioiden linkitys

src/test/scala/fi/oph/koski/raportointikanta/RaportointikantaSpec.scala

@@ -8,7 +8,7 @@ import fi.oph.koski.henkilo.{KoskiSpecificMockOppijat, LaajatOppijaHenkilöTiedo
 import fi.oph.koski.henkilo.KoskiSpecificMockOppijat.{master, masterEiKoskessa}
 import fi.oph.koski.json.{JsonFiles, JsonSerializer}
 import fi.oph.koski.koskiuser.MockUsers
-import fi.oph.koski.organisaatio.MockOrganisaatiot
+import fi.oph.koski.organisaatio.{MockOrganisaatiot, Organisaatiotyyppi}
 import fi.oph.koski.schema.KoskiSchema.strictDeserialization
 import fi.oph.koski.schema._
 import fi.oph.koski.util.Wait
@@ -187,6 +187,33 @@ class RaportointikantaSpec
 
       verifioiYtrOpiskeluoikeudet()
     }
+    "Organisaatiot ovat linkitetty oikein" in {
+      def verifyOrg(parentOid: Option[String], childOid: String) = {
+        parentOid match {
+          case Some(oid) =>
+            KoskiApplicationForTests.organisaatioRepository
+              .getChildOids(oid)
+              .getOrElse(Set.empty) should contain(childOid)
+          case None =>
+            throw new AssertionError("parentOid ei voi olla None")
+        }
+      }
+
+      mainRaportointiDb.runDbSync(mainRaportointiDb.ROrganisaatiot.result)
+        .foreach { row: ROrganisaatioRow =>
+          val tyypit = row.organisaatiotyypit.split(',')
+          if (tyypit.contains(Organisaatiotyyppi.TOIMIPISTE)) {
+            verifyOrg(row.toimipisteenOppilaitos, row.organisaatioOid)
+            row.oppilaitoksenKoulutustoimija should equal(None)
+          } else if (tyypit.contains(Organisaatiotyyppi.OPPILAITOS)) {
+            row.toimipisteenOppilaitos should equal(None)
+            verifyOrg(row.oppilaitoksenKoulutustoimija, row.organisaatioOid)
+          } else {
+            row.toimipisteenOppilaitos should equal(None)
+            row.oppilaitoksenKoulutustoimija should equal(None)
+          }
+        }
+    }
 
     def verifioiYtrOpiskeluoikeudet() = {
       val ytrOotRaportointikannassa = mainRaportointiDb.runDbSync(