EN · DE · RU · FR · ES

#1019: SystemSanityCheckJob.kt

projectforge-business/src/main/kotlin/org/projectforge/business/jobs/SystemSanityCheckJob.kt Type : Kotlin · Rôle : Composant · Source : projectforge-business/src/main/kotlin/org/projectforge/business/jobs/SystemSanityCheckJob.kt 82 lignes · 55 code · 23 commentaires · 4 vides
Tâche planifiée/système pour SystemSanityCheck. Implémente la logique de maintenance périodique ou de vérification de cohérence exécutée par le planificateur de tâches PF.

Structure du code

Classes : SystemSanityCheckJob

Supertype(s) : AbstractJob

Fonctions (2) : executeJob, asString

Propriétés (7) : taskDao, tasks, taskMap, rootTask, abandonedTasks, ancestor, rootTaskFound

Importations : 5 paquetages

Paquetage : org.projectforge.business.jobs

Code source (abrégé)

package org.projectforge.business.jobs

import org.projectforge.business.task.TaskDO
import org.projectforge.business.task.TaskDao
import org.projectforge.business.task.TaskNode
import org.projectforge.jobs.AbstractJob
import org.projectforge.jobs.JobExecutionContext

class SystemSanityCheckJob(val taskDao: TaskDao) : AbstractJob("Vérification d'intégrité du système") {
    override fun executeJob() {
        jobExecutionContext.addMessage("Intégrité des tâches (tâches abandonnées)")
        val tasks: List<TaskDO> = taskDao.selectAll(false)
        jobExecutionContext.addMessage("${tasks.size} tâches trouvées.")
        val taskMap: MutableMap<Long?, TaskDO> = HashMap()
        for (task in tasks) {
            taskMap[task.id] = task
        }
        var rootTask = false
        var abandonedTasks = false
        for (task in tasks) {
            if (task.parentTask == null) {
                if (rootTask) {
                    jobExecutionContext.addError("Autre tâche racine trouvée : ${asString(task)}")
                } else {
                    jobExecutionContext.addMessage("Tâche racine trouvée : ${asString(task)}")
                    rootTask = true
                }
            } else {
                var ancestor = taskMap[task.parentTaskId]
                var rootTaskFound = false
                for (i in 0..49) { // Profondeur max. de 50, sinon tâche cyclique !
                    if (ancestor == null) {
                        break
                    }
                    if (ancestor.parentTaskId == null) {
                        // Tâche racine trouvée, OK.
                        rootTaskFound = true
                        break
                    }
                    ancestor = taskMap[ancestor.parentTaskId]
                }
                if (!rootTaskFound) {
                    jobExecutionContext.addError("Tâche abandonnée trouvée (tâches cycliques sans chemin vers la racine) : ${asString(task)}")
                    abandonedTasks = true
                }
            }
            taskMap[task.id] = task
        }
        if (!abandonedTasks) {
            jobExecutionContext.addMessage("Test OK, aucune tâche abandonnée détectée.")
        } else {
            jobExecutionContext.addError("Test ÉCHOUÉ, des tâches abandonnées ont été détectées.")
        }
    }

    private fun asString(task: TaskDO): String {
        return "TaskNode[id=[${task.id}], created=[${task.created}] title=[${task.title}]]"
    }
}

Historique Git

868d6abb7 2025 -> 2026
034eebd5d Gestion du HTML et gestion des tâches.
63081666f En-têtes des fichiers source : 2024 -> 2025.
619985f48 Version 8.1 snapshot (#247)