chenwei
/
FieldWorkClient
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

添加实时同步提示

dev2.0
陈伟 2025-07-04 15:33:22 +08:00
parent b4583dd811
commit 7de18bd1ad
2 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
App.xaml.cs
View File

@ -201,9 +201,16 @@ namespace HeBianGu.App.Disk
setting.TaskCount);
syncModel.SyncProgressText = "同步完成";
});
minioService.RealTimeListen(bucketName, setting.SyncDir,
cancellationToken: cancelToken.Token);
Task.Run(async () =>
{
await minioService.RealTimeListen(bucketName, setting.SyncDir, ( fileName) =>
{
//添加同步信息
syncModel.SyncProgressText = $"实时同步中: {fileName}";
},
cancellationToken: cancelToken.Token);
syncModel.SyncProgressText = $"实时同步完成";
});
notRun = false;
}
catch (OperationCanceledException)

3
Services/MinioService.cs
View File

@ -347,7 +347,7 @@ namespace Hopetry.Services
}
// 实时监听方法
public async Task RealTimeListen(string bucketName, string localDir, string prefix = "", string suffix = "",
public async Task RealTimeListen(string bucketName, string localDir,Action<string> action, string prefix = "", string suffix = "",
CancellationToken cancellationToken = default)
{
Console.WriteLine("开启实时监听");
@ -373,6 +373,7 @@ namespace Hopetry.Services
},
async (item, _) =>
{
action(item.objectKey);
await DownLoadObject(item.bucketName, item.objectKey, item.localDir, item.objectETag);
});
});