自启全量同步进度展示

dev2.0
陈伟 2025-07-04 15:18:41 +08:00
parent 750d04a9d5
commit b4583dd811
1 changed files with 14 additions and 2 deletions

View File

@ -13,6 +13,7 @@ using HeBianGu.Systems.Setting;
using HeBianGu.Window.Link; using HeBianGu.Window.Link;
using Hopetry.Provider; using Hopetry.Provider;
using Hopetry.Services; using Hopetry.Services;
using Hopetry.ViewModel.Sync;
using SqlSugar; using SqlSugar;
using SystemSetting = FileUploader.Models.SystemSetting; using SystemSetting = FileUploader.Models.SystemSetting;
@ -182,14 +183,25 @@ namespace HeBianGu.App.Disk
xmlSerializerService.Save("./settings.xml", setting); xmlSerializerService.Save("./settings.xml", setting);
setting.SyncDir = setting1.SyncDir; setting.SyncDir = setting1.SyncDir;
} }
if (temp.IsOn && notRun) if (temp.IsOn && notRun)
{ {
// 异步启动服务 // 异步启动服务
Console.WriteLine("启动同步:"); Console.WriteLine("启动同步:");
try try
{ {
minioService.MirrorAsync(bucketName, setting.SyncDir, (total, count, fileName) => { }, var syncModel = services.GetService<SyncViewModel>();
setting.TaskCount); Task.Run(async () =>
{
await minioService.MirrorAsync(bucketName, setting.SyncDir, (total, count, fileName) =>
{
//添加同步信息
syncModel.SyncProgressText = $"同步中: {count}/{total} {fileName}";
},
setting.TaskCount);
syncModel.SyncProgressText = "同步完成";
});
minioService.RealTimeListen(bucketName, setting.SyncDir, minioService.RealTimeListen(bucketName, setting.SyncDir,
cancellationToken: cancelToken.Token); cancellationToken: cancelToken.Token);
notRun = false; notRun = false;