#1019: SystemSanityCheckJob.kt

Codestruktur

Klassen: SystemSanityCheckJob

Obertyp(en): AbstractJob

Funktionen (2): executeJob, asString

Eigenschaften (7): taskDao, tasks, taskMap, rootTask, abandonedTasks, ancestor, rootTaskFound

Importe: 5 Pakete

Paket: org.projectforge.business.jobs

Quellcode (gekürzt)

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("Systemintegritätsprüfung") {
    override fun executeJob() {
        jobExecutionContext.addMessage("Aufgabenintegrität (verwaiste Aufgaben)")
        val tasks: List<TaskDO> = taskDao.selectAll(false)
        jobExecutionContext.addMessage("${tasks.size} Aufgaben gefunden.")
        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("Weitere Root-Aufgabe gefunden: ${asString(task)}")
                } else {
                    jobExecutionContext.addMessage("Root-Aufgabe gefunden: ${asString(task)}")
                    rootTask = true
                }
            } else {
                var ancestor = taskMap[task.parentTaskId]
                var rootTaskFound = false
                for (i in 0..49) { // Max. Tiefe 50, sonst zyklische Aufgabe!
                    if (ancestor == null) {
                        break
                    }
                    if (ancestor.parentTaskId == null) {
                        // Root-Aufgabe gefunden, OK.
                        rootTaskFound = true
                        break
                    }
                    ancestor = taskMap[ancestor.parentTaskId]
                }
                if (!rootTaskFound) {
                    jobExecutionContext.addError("Verwaiste Aufgabe gefunden (zyklische Aufgaben ohne Pfad zur Wurzel): ${asString(task)}")
                    abandonedTasks = true
                }
            }
            taskMap[task.id] = task
        }
        if (!abandonedTasks) {
            jobExecutionContext.addMessage("Test OK, keine verwaisten Aufgaben erkannt.")
        } else {
            jobExecutionContext.addError("Test FEHLGESCHLAGEN, verwaiste Aufgaben erkannt.")
        }
    }

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

Git-Verlauf

868d6abb7 2025 -> 2026
034eebd5d HTML-Handling und Job-Handling.
63081666f Quellcode-Dateiköpfe: 2024 -> 2025.
619985f48 Release 8.1 Snapshot (#247)