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

根据配置，软件启动时，启动一次全量同步，并开启实时监听同步

dev
陈伟 2025-03-24 14:44:54 +08:00
parent f55764b09c
commit eac93572ea
2 changed files with 18 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
App.xaml.cs
View File

@ -1,4 +1,5 @@
using System.Windows; using System.IO;
using System.Windows;
using System.Windows.Media; using System.Windows.Media;
using HeBianGu.Base.WpfBase; using HeBianGu.Base.WpfBase;
using HeBianGu.Control.Guide; using HeBianGu.Control.Guide;
@ -9,6 +10,7 @@ using HeBianGu.Systems.About;
using HeBianGu.Systems.Identity; using HeBianGu.Systems.Identity;
using HeBianGu.Systems.Setting; using HeBianGu.Systems.Setting;
using Hopetry.Services; using Hopetry.Services;
using SystemSetting = FileUploader.Models.SystemSetting;
namespace HeBianGu.App.Disk namespace HeBianGu.App.Disk
{ {
@ -31,8 +33,13 @@ namespace HeBianGu.App.Disk
services.AddSingleton<MinioService, MinioService>(); services.AddSingleton<MinioService, MinioService>();
var minioService = services.GetService<MinioService>(); var minioService = services.GetService<MinioService>();
var bucketName = minioService._bucketName; var bucketName = minioService._bucketName;
//minioService.MirrorAsync1(bucketName, "d:/test"); var xmlSerializerService = services.GetService<ISerializerService>();
//minioService.RealTimeListen(bucketName, "d:/test"); if (File.Exists("./settings.xml"))
{
var setting = xmlSerializerService.Load<SystemSetting>("./settings.xml");
minioService.MirrorAsync1(bucketName, setting.SyncDir, setting.TaskCount);
minioService.RealTimeListen(bucketName, setting.SyncDir);
}
services.AddStart(x => services.AddStart(x =>
{ {
x.ProductFontSize = 90; x.ProductFontSize = 90;

15
ViewModel/Sync/SyncViewModel.cs
View File

@ -33,12 +33,14 @@ public class SyncViewModel : MvcViewModelBase
_serializerService = serializerService; _serializerService = serializerService;
if (File.Exists("./settings.xml")) if (File.Exists("./settings.xml"))
{ {
var setting = _serializerService.Load<SystemSetting>("./settings.xml"); _setting = _serializerService.Load<SystemSetting>("./settings.xml");
_setting.TaskCount = setting.TaskCount; // 同步字段
_setting.SyncDir = setting.SyncDir; SyncDir = _setting.SyncDir;
SyncDir = setting.SyncDir; TaskCount = _setting.TaskCount;
_taskCount = setting.TaskCount; }
// MessageBox.Show("abc"); else
{
_setting = new SystemSetting();
} }
OpenDirCommand = new RelayCommand(async () => await ButtonBase_OnClick()); OpenDirCommand = new RelayCommand(async () => await ButtonBase_OnClick());
@ -80,7 +82,6 @@ public class SyncViewModel : MvcViewModelBase
RaisePropertyChanged(); RaisePropertyChanged();
} }
} }
public RelayCommand SyncData { get; set; } public RelayCommand SyncData { get; set; }