11
This commit is contained in:
1 parent
c4806fbaf2
commit
d1cb2273d6
17 files changed
+450
-238
No files matched your search
@@ -34,6 +34,9 @@ class SyncCheckTool {
|
||||
/// 最近一次终端日志上传统计,供设置页展示扫描、跳过、成功和失败数量。
|
||||
final terminalLogSummary = const TerminalLogUploadSummary().obs;
|
||||
|
||||
/// 人脸同步任务执行中的最新进度快照,任务结束后清空;仅驱动界面展示。
|
||||
final departmentFaceSyncProgress = Rxn<FaceSyncProgress>();
|
||||
|
||||
/// 当前进程内 Cron 调度器;任务全部停止后置空并关闭其内部计时资源。
|
||||
Cron? _cron;
|
||||
|
||||
@@ -728,6 +731,9 @@ class SyncCheckTool {
|
||||
}
|
||||
} finally {
|
||||
if (heavy) SyncIdleTool.instance.endHeavyTask();
|
||||
if (type == ScheduledTaskType.departmentFaceSync) {
|
||||
departmentFaceSyncProgress.value = null;
|
||||
}
|
||||
runningTasks.remove(type);
|
||||
final nextRequest = _pendingRequests[type];
|
||||
if (nextRequest != null) {
|
||||
@@ -835,6 +841,12 @@ class SyncCheckTool {
|
||||
final summary = await SyncFaceTool.sync(
|
||||
mode: mode,
|
||||
userIds: request.faceUserIds,
|
||||
onProgress: (processed, total) {
|
||||
departmentFaceSyncProgress.value = FaceSyncProgress(
|
||||
processed: processed,
|
||||
total: total,
|
||||
);
|
||||
},
|
||||
);
|
||||
if (summary.changed > 0 &&
|
||||
request.triggerType == ScheduledTaskTriggerType.mqtt &&
|
||||
|
||||
Reference in new issue
Block a user