From dc4f12f66685260ac357997680e5f3fe723c3c4a Mon Sep 17 00:00:00 2001 From: feiyu02 <risaku@163.com> Date: 星期五, 12 九月 2025 17:22:40 +0800 Subject: [PATCH] 2025.9.12 1. 新增监测设备和巡查场景信息的匹配功能 --- src/main/kotlin/cn/flightfeather/supervision/common/executor/BgTask.kt | 15 +++++++++------ 1 files changed, 9 insertions(+), 6 deletions(-) diff --git a/src/main/kotlin/cn/flightfeather/supervision/common/executor/BgTask.kt b/src/main/kotlin/cn/flightfeather/supervision/common/executor/BgTask.kt index 2ed156b..3a0b2b1 100644 --- a/src/main/kotlin/cn/flightfeather/supervision/common/executor/BgTask.kt +++ b/src/main/kotlin/cn/flightfeather/supervision/common/executor/BgTask.kt @@ -17,8 +17,8 @@ var future: Future<*>? = null fun ready() { - taskStatus.status = TaskStatus.RUNNING taskStatus.startTime = LocalDateTime.now() + setStatus(TaskStatus.RUNNING) } fun execute() { @@ -32,26 +32,29 @@ } fun success() { - taskStatus.status = TaskStatus.SUCCESS complete() - onStatusChange(taskStatus) + setStatus(TaskStatus.SUCCESS) } fun fail() { - taskStatus.status = TaskStatus.FAIL complete() - onStatusChange(taskStatus) + setStatus(TaskStatus.FAIL) } fun shutdown() { if (future?.isCancelled == false && !future!!.isDone) { future!!.cancel(true) } - taskStatus.status = TaskStatus.SHUTDOWN complete() + setStatus(TaskStatus.SHUTDOWN) } fun complete() { taskStatus.endTime = LocalDateTime.now() } + + fun setStatus(status: TaskStatus) { + taskStatus.status = status + onStatusChange(taskStatus) + } } \ No newline at end of file -- Gitblit v1.9.3