OO#159_adding new state in Arbeitsangebote

OpenOlitor · May 21, 2024 · 99d9ef4 · 99d9ef4
1 parent dea53f8
commit 99d9ef4
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 11 deletions.
diff --git a/...n/scala/ch/openolitor/arbeitseinsatz/batch/calculations/ArbeitseinsatzStatusUpdater.scala b/...n/scala/ch/openolitor/arbeitseinsatz/batch/calculations/ArbeitseinsatzStatusUpdater.scala
@@ -47,12 +47,12 @@ class ArbeitseinsatzStatusUpdater(override val sysConfig: SystemConfig, override
 
   override def process(): Unit = {
     DB autoCommit { implicit session =>
-      val archived = getArbeitsangebotArchivedQuery()
+      val completed = getArbeitsangebotCompletedQuery()
 
-      logger.debug(s"Found ${archived.size} archived Arbeitsangebote for ${sysConfig.mandantConfiguration.name}")
+      logger.debug(s"Found ${completed.size} completedArbeitsangebote for ${sysConfig.mandantConfiguration.name}")
 
-      archived foreach { arbeitsangebot =>
-        entityStore ! ArbeitseinsatzCommandHandler.ArbeitsangebotArchivedCommand(arbeitsangebot.id)
+      completed foreach { arbeitsangebot =>
+        entityStore ! ArbeitseinsatzCommandHandler.ArbeitsangebotCompletedCommand(arbeitsangebot.id)
       }
     }
   }

diff --git a/src/main/scala/ch/openolitor/arbeitseinsatz/models/Arbeitseinsatz.scala b/src/main/scala/ch/openolitor/arbeitseinsatz/models/Arbeitseinsatz.scala
@@ -31,14 +31,15 @@ sealed trait ArbeitseinsatzStatus extends Product
 
 object ArbeitseinsatzStatus {
   def apply(value: String): ArbeitseinsatzStatus = {
-    Vector(InVorbereitung, Bereit, Abgesagt, Archiviert) find (_.toString == value) getOrElse (Bereit)
+    Vector(InVorbereitung, Bereit, Abgesagt, Archiviert, Beendet) find (_.toString == value) getOrElse (Bereit)
   }
 }
 
 case object InVorbereitung extends ArbeitseinsatzStatus
 case object Bereit extends ArbeitseinsatzStatus
 case object Abgesagt extends ArbeitseinsatzStatus
 case object Archiviert extends ArbeitseinsatzStatus
+case object Beendet extends ArbeitseinsatzStatus
 
 case class ArbeitskategorieId(id: Long) extends BaseId
 case class ArbeitskategorieBez(id: String) extends BaseStringId

diff --git a/...ain/scala/ch/openolitor/arbeitseinsatz/repositories/ArbeitseinsatzRepositoryQueries.scala b/...ain/scala/ch/openolitor/arbeitseinsatz/repositories/ArbeitseinsatzRepositoryQueries.scala
@@ -216,7 +216,7 @@ trait ArbeitseinsatzRepositoryQueries extends LazyLogging with ArbeitseinsatzDBM
       }.list
   }
 
-  protected def getArbeitsangebotArchivedQuery = {
+  protected def getArbeitsangebotCompletedQuery = {
     withSQL {
       select
         .from(arbeitsangebotMapping as arbeitsangebot)

diff --git a/src/main/scala/ch/openolitor/kundenportal/repositories/KundenportalRepositoryQueries.scala b/src/main/scala/ch/openolitor/kundenportal/repositories/KundenportalRepositoryQueries.scala
@@ -384,11 +384,12 @@ trait KundenportalRepositoryQueries extends LazyLogging with StammdatenDBMapping
         .join(projektMapping as projekt)
         .join(arbeitsangebotMapping as arbeitsangebot).on(arbeitseinsatz.arbeitsangebotId, arbeitsangebot.id)
         .where.append(UriQueryParamToSQLSyntaxBuilder.build[Arbeitseinsatz](gjFilter, arbeitseinsatz, "zeitVon"))
-        .and.withRoundBracket { _.eq(arbeitseinsatz.personId, owner.personId).or.withRoundBracket {
-          _.in(arbeitseinsatz.arbeitsangebotId, select(arbeitseinsatz.arbeitsangebotId)
-            .from(arbeitseinsatzMapping as arbeitseinsatz)
-            .where.eq(arbeitseinsatz.personId, owner.personId))
-            .and.eq(arbeitseinsatz.contactPermission, True)
+        .and.withRoundBracket {
+          _.eq(arbeitseinsatz.personId, owner.personId).or.withRoundBracket {
+            _.in(arbeitseinsatz.arbeitsangebotId, select(arbeitseinsatz.arbeitsangebotId)
+              .from(arbeitseinsatzMapping as arbeitseinsatz)
+              .where.eq(arbeitseinsatz.personId, owner.personId))
+              .and.eq(arbeitseinsatz.contactPermission, True)
           }
         }.orderBy(arbeitseinsatz.zeitVon)
     }.one(arbeitseinsatzMapping(arbeitseinsatz))