ntminer 6 years ago
parent
commit
24332517f3
32 changed files with 222 additions and 222 deletions
  1. 6 6
      src/AppModels/AppContext.partials.CoinGroupViewModels.cs
  2. 8 8
      src/AppModels/AppContext.partials.CoinKernelViewModels.cs
  3. 10 10
      src/AppModels/AppContext.partials.CoinViewModels.cs
  4. 7 7
      src/AppModels/AppContext.partials.ColumnsShowViewModels.cs
  5. 7 7
      src/AppModels/AppContext.partials.FileWriterViewModels.cs
  6. 7 7
      src/AppModels/AppContext.partials.FragmentWriterViewModels.cs
  7. 10 10
      src/AppModels/AppContext.partials.GpuProfileViewModels.cs
  8. 15 15
      src/AppModels/AppContext.partials.GpuSpeedViewModels.cs
  9. 26 26
      src/AppModels/AppContext.partials.GpuViewModels.cs
  10. 7 7
      src/AppModels/AppContext.partials.GroupViewModels.cs
  11. 8 8
      src/AppModels/AppContext.partials.KernelInputViewModels.cs
  12. 5 5
      src/AppModels/AppContext.partials.KernelOutputKeywordViewModels.cs
  13. 15 15
      src/AppModels/AppContext.partials.KernelOutputTranslaterViewModels.cs
  14. 7 7
      src/AppModels/AppContext.partials.KernelOutputViewModels.cs
  15. 6 6
      src/AppModels/AppContext.partials.KernelViewModels.cs
  16. 6 6
      src/AppModels/AppContext.partials.MineWorkViewModels.cs
  17. 4 4
      src/AppModels/AppContext.partials.MinerGroupViewModels.cs
  18. 6 6
      src/AppModels/AppContext.partials.NTMinerWalletViewModels.cs
  19. 6 6
      src/AppModels/AppContext.partials.OverClockDataViewModels.cs
  20. 4 4
      src/AppModels/AppContext.partials.PackageViewModels.cs
  21. 8 8
      src/AppModels/AppContext.partials.PoolKernelViewModels.cs
  22. 5 5
      src/AppModels/AppContext.partials.PoolViewModels.cs
  23. 2 2
      src/AppModels/AppContext.partials.ShareViewModels.cs
  24. 8 8
      src/AppModels/AppContext.partials.SysDicItemViewModels.cs
  25. 10 10
      src/AppModels/AppContext.partials.SysDicViewModels.cs
  26. 5 5
      src/AppModels/AppContext.partials.UserViewModels.cs
  27. 5 5
      src/AppModels/AppContext.partials.WalletViewModels.cs
  28. 1 1
      src/AppModels/Vms/LocalMessagesViewModel.cs
  29. 1 1
      src/AppViews0/Ucs/SpeedCharts.xaml.cs
  30. 2 2
      src/NTMinerBus/Bus/DomainEvent`1.cs
  31. 1 1
      src/NTMinerClient/Core/Gpus/Impl/TempGruarder.cs
  32. 4 4
      src/NTMinerClient/Core/Kernels/Impl/CoinKernelSet.cs

+ 6 - 6
src/AppModels/AppContext.partials.CoinGroupViewModels.cs

@@ -23,9 +23,9 @@ namespace NTMiner {
                     });
                 BuildEventPath<CoinGroupAddedEvent>("添加了币组后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            CoinGroupViewModel coinGroupVm = new CoinGroupViewModel(message.Source);
-                            _dicById.Add(message.Source.GetId(), coinGroupVm);
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            CoinGroupViewModel coinGroupVm = new CoinGroupViewModel(message.Target);
+                            _dicById.Add(message.Target.GetId(), coinGroupVm);
                             if (!_listByGroupId.ContainsKey(coinGroupVm.GroupId)) {
                                 _listByGroupId.Add(coinGroupVm.GroupId, new List<CoinGroupViewModel>());
                             }
@@ -35,9 +35,9 @@ namespace NTMiner {
                     });
                 BuildEventPath<CoinGroupRemovedEvent>("删除了币组后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            var entity = _dicById[message.Source.GetId()];
-                            _dicById.Remove(message.Source.GetId());
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            var entity = _dicById[message.Target.GetId()];
+                            _dicById.Remove(message.Target.GetId());
                             if (_listByGroupId.ContainsKey(entity.GroupId)) {
                                 _listByGroupId[entity.GroupId].Remove(entity);
                             }

+ 8 - 8
src/AppModels/AppContext.partials.CoinKernelViewModels.cs

@@ -25,10 +25,10 @@ namespace NTMiner {
                     });
                 BuildEventPath<CoinKernelAddedEvent>("添加了币种内核后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        var coinKernelVm = new CoinKernelViewModel(message.Source);
-                        _dicById.Add(message.Source.GetId(), coinKernelVm);
+                        var coinKernelVm = new CoinKernelViewModel(message.Target);
+                        _dicById.Add(message.Target.GetId(), coinKernelVm);
                         OnPropertyChanged(nameof(AllCoinKernels));
-                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Source.CoinId, out CoinViewModel coinVm)) {
+                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Target.CoinId, out CoinViewModel coinVm)) {
                             coinVm.OnPropertyChanged(nameof(CoinViewModel.CoinKernel));
                             coinVm.OnPropertyChanged(nameof(CoinViewModel.CoinKernels));
                             coinVm.OnPropertyChanged(nameof(NTMiner.Vms.CoinViewModel.IsSupported));
@@ -43,10 +43,10 @@ namespace NTMiner {
                     });
                 BuildEventPath<CoinKernelUpdatedEvent>("更新了币种内核后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        CoinKernelViewModel entity = _dicById[message.Source.GetId()];
+                        CoinKernelViewModel entity = _dicById[message.Target.GetId()];
                         var supportedGpu = entity.SupportedGpu;
                         Guid dualCoinGroupId = entity.DualCoinGroupId;
-                        entity.Update(message.Source);
+                        entity.Update(message.Target);
                         if (supportedGpu != entity.SupportedGpu) {
                             var coinKernels = AllCoinKernels.Where(a => a.KernelId == entity.Id);
                             foreach (var coinKernel in coinKernels) {
@@ -61,10 +61,10 @@ namespace NTMiner {
                     });
                 BuildEventPath<CoinKernelRemovedEvent>("移除了币种内核后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.TryGetValue(message.Source.GetId(), out CoinKernelViewModel coinKernelVm)) {
-                            _dicById.Remove(message.Source.GetId());
+                        if (_dicById.TryGetValue(message.Target.GetId(), out CoinKernelViewModel coinKernelVm)) {
+                            _dicById.Remove(message.Target.GetId());
                             OnPropertyChanged(nameof(AllCoinKernels));
-                            if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Source.CoinId, out CoinViewModel coinVm)) {
+                            if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Target.CoinId, out CoinViewModel coinVm)) {
                                 coinVm.OnPropertyChanged(nameof(CoinViewModel.CoinKernel));
                                 coinVm.OnPropertyChanged(nameof(CoinViewModel.CoinKernels));
                                 coinVm.OnPropertyChanged(nameof(NTMiner.Vms.CoinViewModel.IsSupported));

+ 10 - 10
src/AppModels/AppContext.partials.CoinViewModels.cs

@@ -30,31 +30,31 @@ namespace NTMiner {
                     });
                 BuildEventPath<CoinAddedEvent>("添加了币种后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Add(message.Source.GetId(), new CoinViewModel(message.Source));
+                        _dicById.Add(message.Target.GetId(), new CoinViewModel(message.Target));
                         AppContext.Instance.MinerProfileVm.OnPropertyChanged(nameof(NTMiner.AppContext.Instance.MinerProfileVm.CoinVm));
                         AllPropertyChanged();
                     });
                 BuildEventPath<CoinRemovedEvent>("移除了币种后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         AppContext.Instance.MinerProfileVm.OnPropertyChanged(nameof(NTMiner.AppContext.Instance.MinerProfileVm.CoinVm));
                         AllPropertyChanged();
                     });
                 BuildEventPath<CoinUpdatedEvent>("更新了币种后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        CoinViewModel coinVm = _dicById[message.Source.GetId()];
+                        CoinViewModel coinVm = _dicById[message.Target.GetId()];
                         bool justAsDualCoin = coinVm.JustAsDualCoin;
-                        coinVm.Update(message.Source);
-                        coinVm.TestWalletVm.Address = message.Source.TestWallet;
+                        coinVm.Update(message.Target);
+                        coinVm.TestWalletVm.Address = message.Target.TestWallet;
                         coinVm.OnPropertyChanged(nameof(coinVm.Wallets));
                         coinVm.OnPropertyChanged(nameof(coinVm.WalletItems));
-                        if (AppContext.Instance.MinerProfileVm.CoinId == message.Source.GetId()) {
+                        if (AppContext.Instance.MinerProfileVm.CoinId == message.Target.GetId()) {
                             AppContext.Instance.MinerProfileVm.OnPropertyChanged(nameof(NTMiner.AppContext.Instance.MinerProfileVm.CoinVm));
                         }
                         CoinKernelViewModel coinKernelVm = AppContext.Instance.MinerProfileVm.CoinVm.CoinKernel;
                         if (coinKernelVm != null
                             && coinKernelVm.CoinKernelProfile.SelectedDualCoin != null
-                            && coinKernelVm.CoinKernelProfile.SelectedDualCoin.GetId() == message.Source.GetId()) {
+                            && coinKernelVm.CoinKernelProfile.SelectedDualCoin.GetId() == message.Target.GetId()) {
                             coinKernelVm.CoinKernelProfile.OnPropertyChanged(nameof(coinKernelVm.CoinKernelProfile.SelectedDualCoin));
                         }
                         if (justAsDualCoin != coinVm.JustAsDualCoin) {
@@ -64,14 +64,14 @@ namespace NTMiner {
                 BuildEventPath<CoinIconDownloadedEvent>("下载了币种图标后", LogEnum.DevConsole,
                     action: message => {
                         try {
-                            if (string.IsNullOrEmpty(message.Source.Icon)) {
+                            if (string.IsNullOrEmpty(message.Target.Icon)) {
                                 return;
                             }
-                            string iconFileFullName = SpecialPath.GetIconFileFullName(message.Source);
+                            string iconFileFullName = SpecialPath.GetIconFileFullName(message.Target);
                             if (string.IsNullOrEmpty(iconFileFullName) || !File.Exists(iconFileFullName)) {
                                 return;
                             }
-                            if (_dicById.TryGetValue(message.Source.GetId(), out CoinViewModel coinVm)) {
+                            if (_dicById.TryGetValue(message.Target.GetId(), out CoinViewModel coinVm)) {
                                 try {
                                     coinVm.IconImageSource = new Uri(iconFileFullName, UriKind.Absolute).ToString();
                                 }

+ 7 - 7
src/AppModels/AppContext.partials.ColumnsShowViewModels.cs

@@ -23,24 +23,24 @@ namespace NTMiner {
                 });
                 BuildEventPath<ColumnsShowAddedEvent>("添加了列显后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            ColumnsShowViewModel vm = new ColumnsShowViewModel(message.Source);
-                            _dicById.Add(message.Source.GetId(), vm);
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            ColumnsShowViewModel vm = new ColumnsShowViewModel(message.Target);
+                            _dicById.Add(message.Target.GetId(), vm);
                             OnPropertyChanged(nameof(List));
                             AppContext.Instance.MinerClientsWindowVm.ColumnsShow = vm;
                         }
                     });
                 BuildEventPath<ColumnsShowUpdatedEvent>("更新了列显后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            ColumnsShowViewModel entity = _dicById[message.Source.GetId()];
-                            entity.Update(message.Source);
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            ColumnsShowViewModel entity = _dicById[message.Target.GetId()];
+                            entity.Update(message.Target);
                         }
                     });
                 BuildEventPath<ColumnsShowRemovedEvent>("移除了列显后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
                         AppContext.Instance.MinerClientsWindowVm.ColumnsShow = _dicById.Values.FirstOrDefault();
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChanged(nameof(List));
                     });
                 foreach (var item in NTMinerRoot.Instance.ColumnsShowSet.AsEnumerable()) {

+ 7 - 7
src/AppModels/AppContext.partials.FileWriterViewModels.cs

@@ -29,22 +29,22 @@ namespace NTMiner {
                     });
                 BuildEventPath<FileWriterAddedEvent>("添加了文件书写器后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            FileWriterViewModel groupVm = new FileWriterViewModel(message.Source);
-                            _dicById.Add(message.Source.GetId(), groupVm);
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            FileWriterViewModel groupVm = new FileWriterViewModel(message.Target);
+                            _dicById.Add(message.Target.GetId(), groupVm);
                             OnPropertyChangeds();
                         }
                     });
                 BuildEventPath<FileWriterUpdatedEvent>("更新了文件书写器后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            FileWriterViewModel entity = _dicById[message.Source.GetId()];
-                            entity.Update(message.Source);
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            FileWriterViewModel entity = _dicById[message.Target.GetId()];
+                            entity.Update(message.Target);
                         }
                     });
                 BuildEventPath<FileWriterRemovedEvent>("删除了文件书写器后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChangeds();
                     });
                 Init();

+ 7 - 7
src/AppModels/AppContext.partials.FragmentWriterViewModels.cs

@@ -29,22 +29,22 @@ namespace NTMiner {
                     });
                 BuildEventPath<FragmentWriterAddedEvent>("添加了命令行片段书写器后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            FragmentWriterViewModel groupVm = new FragmentWriterViewModel(message.Source);
-                            _dicById.Add(message.Source.GetId(), groupVm);
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            FragmentWriterViewModel groupVm = new FragmentWriterViewModel(message.Target);
+                            _dicById.Add(message.Target.GetId(), groupVm);
                             OnPropertyChangeds();
                         }
                     });
                 BuildEventPath<FragmentWriterUpdatedEvent>("更新了命令行片段书写器后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            FragmentWriterViewModel entity = _dicById[message.Source.GetId()];
-                            entity.Update(message.Source);
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            FragmentWriterViewModel entity = _dicById[message.Target.GetId()];
+                            entity.Update(message.Target);
                         }
                     });
                 BuildEventPath<FragmentWriterRemovedEvent>("删除了命令行片段书写器后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChangeds();
                     });
                 Init();

+ 10 - 10
src/AppModels/AppContext.partials.GpuProfileViewModels.cs

@@ -32,33 +32,33 @@ namespace NTMiner {
                 BuildEventPath<GpuProfileAddedOrUpdatedEvent>("添加或更新了Gpu超频数据后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
                         lock (_locker) {
-                            if (_listByCoinId.TryGetValue(message.Source.CoinId, out List<GpuProfileViewModel> list)) {
-                                var vm = list.FirstOrDefault(a => a.Index == message.Source.Index);
+                            if (_listByCoinId.TryGetValue(message.Target.CoinId, out List<GpuProfileViewModel> list)) {
+                                var vm = list.FirstOrDefault(a => a.Index == message.Target.Index);
                                 if (vm != null) {
-                                    vm.Update(message.Source);
+                                    vm.Update(message.Target);
                                 }
                                 else {
-                                    if (AppContext.Instance.GpuVms.TryGetGpuVm(message.Source.Index, out GpuViewModel gpuVm)) {
-                                        var item = new GpuProfileViewModel(message.Source, gpuVm);
+                                    if (AppContext.Instance.GpuVms.TryGetGpuVm(message.Target.Index, out GpuViewModel gpuVm)) {
+                                        var item = new GpuProfileViewModel(message.Target, gpuVm);
                                         list.Add(item);
                                         list.Sort(new CompareByGpuIndex());
                                         if (item.Index == NTMinerRoot.GpuAllId) {
-                                            _gpuAllVmDicByCoinId.Add(message.Source.CoinId, item);
+                                            _gpuAllVmDicByCoinId.Add(message.Target.CoinId, item);
                                         }
                                     }
                                 }
                             }
                             else {
                                 list = new List<GpuProfileViewModel>();
-                                if (AppContext.Instance.GpuVms.TryGetGpuVm(message.Source.Index, out GpuViewModel gpuVm)) {
-                                    var item = new GpuProfileViewModel(message.Source, gpuVm);
+                                if (AppContext.Instance.GpuVms.TryGetGpuVm(message.Target.Index, out GpuViewModel gpuVm)) {
+                                    var item = new GpuProfileViewModel(message.Target, gpuVm);
                                     list.Add(item);
                                     list.Sort(new CompareByGpuIndex());
                                     if (item.Index == NTMinerRoot.GpuAllId) {
-                                        _gpuAllVmDicByCoinId.Add(message.Source.CoinId, item);
+                                        _gpuAllVmDicByCoinId.Add(message.Target.CoinId, item);
                                     }
                                 }
-                                _listByCoinId.Add(message.Source.CoinId, list);
+                                _listByCoinId.Add(message.Target.CoinId, list);
                             }
                         }
                     });

+ 15 - 15
src/AppModels/AppContext.partials.GpuSpeedViewModels.cs

@@ -54,62 +54,62 @@ namespace NTMiner {
                 BuildEventPath<GpuShareChangedEvent>("显卡份额变更后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
                         ResetIfMainCoinSwitched();
-                        int index = message.Source.Gpu.Index;
+                        int index = message.Target.Gpu.Index;
                         GpuSpeedViewModel gpuSpeedVm = _list.FirstOrDefault(a => a.GpuVm.Index == index);
                         if (gpuSpeedVm != null) {
-                            gpuSpeedVm.MainCoinSpeed.FoundShare = message.Source.MainCoinSpeed.FoundShare;
-                            gpuSpeedVm.MainCoinSpeed.AcceptShare = message.Source.MainCoinSpeed.AcceptShare;
-                            gpuSpeedVm.MainCoinSpeed.RejectShare = message.Source.MainCoinSpeed.RejectShare;
+                            gpuSpeedVm.MainCoinSpeed.FoundShare = message.Target.MainCoinSpeed.FoundShare;
+                            gpuSpeedVm.MainCoinSpeed.AcceptShare = message.Target.MainCoinSpeed.AcceptShare;
+                            gpuSpeedVm.MainCoinSpeed.RejectShare = message.Target.MainCoinSpeed.RejectShare;
                         }
                     });
                 BuildEventPath<FoundShareIncreasedEvent>("找到一个份额后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
                         ResetIfMainCoinSwitched();
-                        int index = message.Source.Gpu.Index;
+                        int index = message.Target.Gpu.Index;
                         GpuSpeedViewModel gpuSpeedVm = _list.FirstOrDefault(a => a.GpuVm.Index == index);
                         if (gpuSpeedVm != null) {
-                            gpuSpeedVm.MainCoinSpeed.FoundShare = message.Source.MainCoinSpeed.FoundShare;
+                            gpuSpeedVm.MainCoinSpeed.FoundShare = message.Target.MainCoinSpeed.FoundShare;
                         }
                     });
                 BuildEventPath<AcceptShareIncreasedEvent>("接受一个份额后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
                         ResetIfMainCoinSwitched();
-                        int index = message.Source.Gpu.Index;
+                        int index = message.Target.Gpu.Index;
                         GpuSpeedViewModel gpuSpeedVm = _list.FirstOrDefault(a => a.GpuVm.Index == index);
                         if (gpuSpeedVm != null) {
-                            gpuSpeedVm.MainCoinSpeed.AcceptShare = message.Source.MainCoinSpeed.AcceptShare;
+                            gpuSpeedVm.MainCoinSpeed.AcceptShare = message.Target.MainCoinSpeed.AcceptShare;
                         }
                     });
                 BuildEventPath<RejectShareIncreasedEvent>("拒绝一个份额后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
                         ResetIfMainCoinSwitched();
-                        int index = message.Source.Gpu.Index;
+                        int index = message.Target.Gpu.Index;
                         GpuSpeedViewModel gpuSpeedVm = _list.FirstOrDefault(a => a.GpuVm.Index == index);
                         if (gpuSpeedVm != null) {
-                            gpuSpeedVm.MainCoinSpeed.RejectShare = message.Source.MainCoinSpeed.RejectShare;
+                            gpuSpeedVm.MainCoinSpeed.RejectShare = message.Target.MainCoinSpeed.RejectShare;
                         }
                     });
                 BuildEventPath<IncorrectShareIncreasedEvent>("产生一个错误份额后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
                         ResetIfMainCoinSwitched();
-                        int index = message.Source.Gpu.Index;
+                        int index = message.Target.Gpu.Index;
                         GpuSpeedViewModel gpuSpeedVm = _list.FirstOrDefault(a => a.GpuVm.Index == index);
                         if (gpuSpeedVm != null) {
-                            gpuSpeedVm.MainCoinSpeed.IncorrectShare = message.Source.MainCoinSpeed.IncorrectShare;
+                            gpuSpeedVm.MainCoinSpeed.IncorrectShare = message.Target.MainCoinSpeed.IncorrectShare;
                         }
                     });
                 BuildEventPath<GpuSpeedChangedEvent>("显卡算力变更后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
                         ResetIfMainCoinSwitched();
-                        int index = message.Source.Gpu.Index;
+                        int index = message.Target.Gpu.Index;
                         GpuSpeedViewModel gpuSpeedVm = _list.FirstOrDefault(a => a.GpuVm.Index == index);
                         if (gpuSpeedVm != null) {
                             if (message.IsDual) {
-                                gpuSpeedVm.DualCoinSpeed.UpdateSpeed(message.Source.DualCoinSpeed.Value, message.Source.DualCoinSpeed.SpeedOn);
+                                gpuSpeedVm.DualCoinSpeed.UpdateSpeed(message.Target.DualCoinSpeed.Value, message.Target.DualCoinSpeed.SpeedOn);
                                 gpuSpeedVm.OnPropertyChanged(nameof(gpuSpeedVm.AverageDualCoinSpeedText));
                             }
                             else {
-                                gpuSpeedVm.MainCoinSpeed.UpdateSpeed(message.Source.MainCoinSpeed.Value, message.Source.MainCoinSpeed.SpeedOn);
+                                gpuSpeedVm.MainCoinSpeed.UpdateSpeed(message.Target.MainCoinSpeed.Value, message.Target.MainCoinSpeed.SpeedOn);
                                 gpuSpeedVm.OnPropertyChanged(nameof(gpuSpeedVm.AverageMainCoinSpeedText));
                             }
                         }

+ 26 - 26
src/AppModels/AppContext.partials.GpuViewModels.cs

@@ -53,32 +53,32 @@ namespace NTMiner {
                     });
                 BuildEventPath<GpuStateChangedEvent>("显卡状态变更后刷新VM内存", LogEnum.None,
                     action: message => {
-                        if (_gpuVms.ContainsKey(message.Source.Index)) {
-                            GpuViewModel vm = _gpuVms[message.Source.Index];
-                            vm.Temperature = message.Source.Temperature;
-                            vm.FanSpeed = message.Source.FanSpeed;
-                            vm.PowerUsage = message.Source.PowerUsage;
-                            vm.CoreClockDelta = message.Source.CoreClockDelta;
-                            vm.MemoryClockDelta = message.Source.MemoryClockDelta;
-                            vm.CoreClockDeltaMin = message.Source.CoreClockDeltaMin;
-                            vm.CoreClockDeltaMax = message.Source.CoreClockDeltaMax;
-                            vm.MemoryClockDeltaMin = message.Source.MemoryClockDeltaMin;
-                            vm.MemoryClockDeltaMax = message.Source.MemoryClockDeltaMax;
-                            vm.Cool = message.Source.Cool;
-                            vm.CoolMin = message.Source.CoolMin;
-                            vm.CoolMax = message.Source.CoolMax;
-                            vm.PowerCapacity = message.Source.PowerCapacity;
-                            vm.PowerMin = message.Source.PowerMin;
-                            vm.PowerMax = message.Source.PowerMax;
-                            vm.TempLimit = message.Source.TempLimit;
-                            vm.TempLimitDefault = message.Source.TempLimitDefault;
-                            vm.TempLimitMax = message.Source.TempLimitMax;
-                            vm.TempLimitMin = message.Source.TempLimitMin;
-                            vm.CoreVoltage = message.Source.CoreVoltage;
-                            vm.MemoryVoltage = message.Source.MemoryVoltage;
-                            vm.VoltMin = message.Source.VoltMin;
-                            vm.VoltMax = message.Source.VoltMax;
-                            vm.VoltDefault = message.Source.VoltDefault;
+                        if (_gpuVms.ContainsKey(message.Target.Index)) {
+                            GpuViewModel vm = _gpuVms[message.Target.Index];
+                            vm.Temperature = message.Target.Temperature;
+                            vm.FanSpeed = message.Target.FanSpeed;
+                            vm.PowerUsage = message.Target.PowerUsage;
+                            vm.CoreClockDelta = message.Target.CoreClockDelta;
+                            vm.MemoryClockDelta = message.Target.MemoryClockDelta;
+                            vm.CoreClockDeltaMin = message.Target.CoreClockDeltaMin;
+                            vm.CoreClockDeltaMax = message.Target.CoreClockDeltaMax;
+                            vm.MemoryClockDeltaMin = message.Target.MemoryClockDeltaMin;
+                            vm.MemoryClockDeltaMax = message.Target.MemoryClockDeltaMax;
+                            vm.Cool = message.Target.Cool;
+                            vm.CoolMin = message.Target.CoolMin;
+                            vm.CoolMax = message.Target.CoolMax;
+                            vm.PowerCapacity = message.Target.PowerCapacity;
+                            vm.PowerMin = message.Target.PowerMin;
+                            vm.PowerMax = message.Target.PowerMax;
+                            vm.TempLimit = message.Target.TempLimit;
+                            vm.TempLimitDefault = message.Target.TempLimitDefault;
+                            vm.TempLimitMax = message.Target.TempLimitMax;
+                            vm.TempLimitMin = message.Target.TempLimitMin;
+                            vm.CoreVoltage = message.Target.CoreVoltage;
+                            vm.MemoryVoltage = message.Target.MemoryVoltage;
+                            vm.VoltMin = message.Target.VoltMin;
+                            vm.VoltMax = message.Target.VoltMax;
+                            vm.VoltDefault = message.Target.VoltDefault;
                             if (_gpuAllVm != null) {
                                 _gpuAllVm.OnPropertyChanged(nameof(_gpuAllVm.TemperatureText));
                                 _gpuAllVm.OnPropertyChanged(nameof(_gpuAllVm.FanSpeedText));

+ 7 - 7
src/AppModels/AppContext.partials.GroupViewModels.cs

@@ -31,18 +31,18 @@ namespace NTMiner {
                     });
                 BuildEventPath<GroupAddedEvent>("添加了组后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            GroupViewModel groupVm = new GroupViewModel(message.Source);
-                            _dicById.Add(message.Source.GetId(), groupVm);
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            GroupViewModel groupVm = new GroupViewModel(message.Target);
+                            _dicById.Add(message.Target.GetId(), groupVm);
                             OnPropertyChangeds();
                         }
                     });
                 BuildEventPath<GroupUpdatedEvent>("更新了组后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            GroupViewModel entity = _dicById[message.Source.GetId()];
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            GroupViewModel entity = _dicById[message.Target.GetId()];
                             int sortNumber = entity.SortNumber;
-                            entity.Update(message.Source);
+                            entity.Update(message.Target);
                             if (sortNumber != entity.SortNumber) {
                                 this.OnPropertyChanged(nameof(List));
                                 OnPropertyChanged(nameof(SelectionOptions));
@@ -51,7 +51,7 @@ namespace NTMiner {
                     });
                 BuildEventPath<GroupRemovedEvent>("删除了组后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChangeds();
                     });
                 Init();

+ 8 - 8
src/AppModels/AppContext.partials.KernelInputViewModels.cs

@@ -25,18 +25,18 @@ namespace NTMiner {
                     });
                 BuildEventPath<KernelInputAddedEvent>("添加了内核输入后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        var vm = new KernelInputViewModel(message.Source);
-                        _dicById.Add(message.Source.GetId(), vm);
+                        var vm = new KernelInputViewModel(message.Target);
+                        _dicById.Add(message.Target.GetId(), vm);
                         OnPropertyChangeds();
                     });
                 BuildEventPath<KernelInputUpdatedEvent>("更新了内核输入后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            var item = _dicById[message.Source.GetId()];
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            var item = _dicById[message.Target.GetId()];
                             if (item != null) {
                                 bool isSupportDualMine = item.IsSupportDualMine;
                                 string args = item.Args;
-                                item.Update(message.Source);
+                                item.Update(message.Target);
                                 if (args != item.Args) {
                                     CoinViewModel coinVm = AppContext.Instance.MinerProfileVm.CoinVm;
                                     if (coinVm != null && coinVm.CoinKernel != null && coinVm.CoinKernel.Kernel.KernelInputId == item.Id) {
@@ -44,7 +44,7 @@ namespace NTMiner {
                                     }
                                 }
                                 if (isSupportDualMine != item.IsSupportDualMine) {
-                                    foreach (var coinKernelVm in AppContext.Instance.CoinKernelVms.AllCoinKernels.Where(a => a.KernelId == message.Source.GetId())) {
+                                    foreach (var coinKernelVm in AppContext.Instance.CoinKernelVms.AllCoinKernels.Where(a => a.KernelId == message.Target.GetId())) {
                                         coinKernelVm.OnPropertyChanged(nameof(coinKernelVm.IsSupportDualMine));
                                     }
                                 }
@@ -53,8 +53,8 @@ namespace NTMiner {
                     });
                 BuildEventPath<KernelInputRemovedEvent>("移除了内核输入后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Remove(message.Source.GetId());
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Remove(message.Target.GetId());
                             OnPropertyChangeds();
                         }
                     });

+ 5 - 5
src/AppModels/AppContext.partials.KernelOutputKeywordViewModels.cs

@@ -45,8 +45,8 @@ namespace NTMiner {
                     });
                 BuildEventPath<UserKernelOutputKeywordAddedEvent>("添加了内核输出过滤器后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            KernelOutputKeywordViewModel vm = new KernelOutputKeywordViewModel(message.Source);
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            KernelOutputKeywordViewModel vm = new KernelOutputKeywordViewModel(message.Target);
                             _dicById.Add(vm.Id, vm);
                             if (AppContext.Instance.KernelOutputVms.TryGetKernelOutputVm(vm.KernelOutputId, out KernelOutputViewModel kernelOutputVm)) {
                                 if (!_dicByKernelOutputId.ContainsKey(vm.KernelOutputId)) {
@@ -59,13 +59,13 @@ namespace NTMiner {
                     });
                 BuildEventPath<UserKernelOutputKeywordUpdatedEvent>("更新了内核输出过滤器后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicById.TryGetValue(message.Source.GetId(), out KernelOutputKeywordViewModel vm)) {
-                            vm.Update(message.Source);
+                        if (_dicById.TryGetValue(message.Target.GetId(), out KernelOutputKeywordViewModel vm)) {
+                            vm.Update(message.Target);
                         }
                     });
                 BuildEventPath<UserKernelOutputKeywordRemovedEvent>("删除了内核输出过滤器后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicById.TryGetValue(message.Source.GetId(), out KernelOutputKeywordViewModel vm)) {
+                        if (_dicById.TryGetValue(message.Target.GetId(), out KernelOutputKeywordViewModel vm)) {
                             _dicById.Remove(vm.Id);
                             _dicByKernelOutputId[vm.KernelOutputId].Remove(vm);
                             if (AppContext.Instance.KernelOutputVms.TryGetKernelOutputVm(vm.KernelOutputId, out KernelOutputViewModel kernelOutputVm)) {

+ 15 - 15
src/AppModels/AppContext.partials.KernelOutputTranslaterViewModels.cs

@@ -27,37 +27,37 @@ namespace NTMiner {
                     });
                 BuildEventPath<KernelOutputTranslaterAddedEvent>("添加了内核输出翻译器后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (AppContext.Instance.KernelOutputVms.TryGetKernelOutputVm(message.Source.KernelOutputId, out KernelOutputViewModel kernelOutputVm)) {
-                            if (!_dicByKernelOutputId.ContainsKey(message.Source.KernelOutputId)) {
-                                _dicByKernelOutputId.Add(message.Source.KernelOutputId, new List<KernelOutputTranslaterViewModel>());
+                        if (AppContext.Instance.KernelOutputVms.TryGetKernelOutputVm(message.Target.KernelOutputId, out KernelOutputViewModel kernelOutputVm)) {
+                            if (!_dicByKernelOutputId.ContainsKey(message.Target.KernelOutputId)) {
+                                _dicByKernelOutputId.Add(message.Target.KernelOutputId, new List<KernelOutputTranslaterViewModel>());
                             }
-                            var vm = new KernelOutputTranslaterViewModel(message.Source);
-                            _dicByKernelOutputId[message.Source.KernelOutputId].Add(vm);
-                            _dicById.Add(message.Source.GetId(), vm);
+                            var vm = new KernelOutputTranslaterViewModel(message.Target);
+                            _dicByKernelOutputId[message.Target.KernelOutputId].Add(vm);
+                            _dicById.Add(message.Target.GetId(), vm);
                             kernelOutputVm.OnPropertyChanged(nameof(kernelOutputVm.KernelOutputTranslaters));
                         }
                     });
                 BuildEventPath<KernelOutputTranslaterUpdatedEvent>("更新了内核输出翻译器后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicByKernelOutputId.ContainsKey(message.Source.KernelOutputId)) {
-                            var item = _dicByKernelOutputId[message.Source.KernelOutputId].FirstOrDefault(a => a.Id == message.Source.GetId());
+                        if (_dicByKernelOutputId.ContainsKey(message.Target.KernelOutputId)) {
+                            var item = _dicByKernelOutputId[message.Target.KernelOutputId].FirstOrDefault(a => a.Id == message.Target.GetId());
                             if (item != null) {
-                                item.Update(message.Source);
+                                item.Update(message.Target);
                             }
                         }
                     });
                 BuildEventPath<KernelOutputTranslaterRemovedEvent>("移除了内核输出翻译器后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicByKernelOutputId.ContainsKey(message.Source.KernelOutputId)) {
-                            var item = _dicByKernelOutputId[message.Source.KernelOutputId].FirstOrDefault(a => a.Id == message.Source.GetId());
+                        if (_dicByKernelOutputId.ContainsKey(message.Target.KernelOutputId)) {
+                            var item = _dicByKernelOutputId[message.Target.KernelOutputId].FirstOrDefault(a => a.Id == message.Target.GetId());
                             if (item != null) {
-                                _dicByKernelOutputId[message.Source.KernelOutputId].Remove(item);
+                                _dicByKernelOutputId[message.Target.KernelOutputId].Remove(item);
                             }
                         }
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Remove(message.Source.GetId());
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Remove(message.Target.GetId());
                         }
-                        if (AppContext.Instance.KernelOutputVms.TryGetKernelOutputVm(message.Source.KernelOutputId, out KernelOutputViewModel kernelOutputVm)) {
+                        if (AppContext.Instance.KernelOutputVms.TryGetKernelOutputVm(message.Target.KernelOutputId, out KernelOutputViewModel kernelOutputVm)) {
                             kernelOutputVm.OnPropertyChanged(nameof(kernelOutputVm.KernelOutputTranslaters));
                         }
                     });

+ 7 - 7
src/AppModels/AppContext.partials.KernelOutputViewModels.cs

@@ -25,24 +25,24 @@ namespace NTMiner {
                     });
                 BuildEventPath<KernelOutputAddedEvent>("添加了内核输出组后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        var vm = new KernelOutputViewModel(message.Source);
-                        _dicById.Add(message.Source.GetId(), vm);
+                        var vm = new KernelOutputViewModel(message.Target);
+                        _dicById.Add(message.Target.GetId(), vm);
                         OnPropertyChanged(nameof(AllKernelOutputVms));
                         OnPropertyChanged(nameof(PleaseSelectVms));
                     });
                 BuildEventPath<KernelOutputUpdatedEvent>("更新了内核输出组后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            var item = _dicById[message.Source.GetId()];
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            var item = _dicById[message.Target.GetId()];
                             if (item != null) {
-                                item.Update(message.Source);
+                                item.Update(message.Target);
                             }
                         }
                     });
                 BuildEventPath<KernelOutputRemovedEvent>("移除了内核输出组后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Remove(message.Source.GetId());
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Remove(message.Target.GetId());
                             OnPropertyChanged(nameof(AllKernelOutputVms));
                             OnPropertyChanged(nameof(PleaseSelectVms));
                         }

+ 6 - 6
src/AppModels/AppContext.partials.KernelViewModels.cs

@@ -30,26 +30,26 @@ namespace NTMiner {
                     });
                 BuildEventPath<KernelAddedEvent>("添加了内核后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Add(message.Source.GetId(), new KernelViewModel(message.Source));
+                        _dicById.Add(message.Target.GetId(), new KernelViewModel(message.Target));
                         OnPropertyChanged(nameof(AllKernels));
-                        foreach (var coinKernelVm in AppContext.Instance.CoinKernelVms.AllCoinKernels.Where(a => a.KernelId == message.Source.GetId())) {
+                        foreach (var coinKernelVm in AppContext.Instance.CoinKernelVms.AllCoinKernels.Where(a => a.KernelId == message.Target.GetId())) {
                             coinKernelVm.OnPropertyChanged(nameof(coinKernelVm.IsSupportDualMine));
                         }
                     });
                 BuildEventPath<KernelRemovedEvent>("删除了内核后调整VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChanged(nameof(AllKernels));
-                        foreach (var coinKernelVm in AppContext.Instance.CoinKernelVms.AllCoinKernels.Where(a => a.KernelId == message.Source.GetId())) {
+                        foreach (var coinKernelVm in AppContext.Instance.CoinKernelVms.AllCoinKernels.Where(a => a.KernelId == message.Target.GetId())) {
                             coinKernelVm.OnPropertyChanged(nameof(coinKernelVm.IsSupportDualMine));
                         }
                     });
                 BuildEventPath<KernelUpdatedEvent>("更新了内核后调整VM内存", LogEnum.DevConsole,
                     action: message => {
-                        var entity = _dicById[message.Source.GetId()];
+                        var entity = _dicById[message.Target.GetId()];
                         PublishStatus publishStatus = entity.PublishState;
                         Guid kernelInputId = entity.KernelInputId;
-                        entity.Update(message.Source);
+                        entity.Update(message.Target);
                         if (publishStatus != entity.PublishState) {
                             foreach (var coinKernelVm in AppContext.Instance.CoinKernelVms.AllCoinKernels.Where(a => a.KernelId == entity.Id)) {
                                 foreach (var coinVm in AppContext.Instance.CoinVms.AllCoins.Where(a => a.Id == coinKernelVm.CoinId)) {

+ 6 - 6
src/AppModels/AppContext.partials.MineWorkViewModels.cs

@@ -27,25 +27,25 @@ namespace NTMiner {
                 });
                 BuildEventPath<MineWorkAddedEvent>("添加作业后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Add(message.Source.GetId(), new MineWorkViewModel(message.Source));
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Add(message.Target.GetId(), new MineWorkViewModel(message.Target));
                             OnPropertyChanged(nameof(List));
                             OnPropertyChanged(nameof(MineWorkVmItems));
-                            if (message.Source.GetId() == AppContext.Instance.MinerClientsWindowVm.SelectedMineWork.GetId()) {
+                            if (message.Target.GetId() == AppContext.Instance.MinerClientsWindowVm.SelectedMineWork.GetId()) {
                                 AppContext.Instance.MinerClientsWindowVm.SelectedMineWork = MineWorkViewModel.PleaseSelect;
                             }
                         }
                     });
                 BuildEventPath<MineWorkUpdatedEvent>("更新作业后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById[message.Source.GetId()].Update(message.Source);
+                        _dicById[message.Target.GetId()].Update(message.Target);
                     });
                 BuildEventPath<MineWorkRemovedEvent>("删除作业后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChanged(nameof(List));
                         OnPropertyChanged(nameof(MineWorkVmItems));
-                        if (message.Source.GetId() == AppContext.Instance.MinerClientsWindowVm.SelectedMineWork.GetId()) {
+                        if (message.Target.GetId() == AppContext.Instance.MinerClientsWindowVm.SelectedMineWork.GetId()) {
                             AppContext.Instance.MinerClientsWindowVm.SelectedMineWork = MineWorkViewModel.PleaseSelect;
                         }
                     });

+ 4 - 4
src/AppModels/AppContext.partials.MinerGroupViewModels.cs

@@ -28,8 +28,8 @@ namespace NTMiner {
                 });
                 BuildEventPath<MinerGroupAddedEvent>("添加矿机分组后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Add(message.Source.GetId(), new MinerGroupViewModel(message.Source));
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Add(message.Target.GetId(), new MinerGroupViewModel(message.Target));
                             OnPropertyChanged(nameof(List));
                             OnPropertyChanged(nameof(MinerGroupItems));
                             AppContext.Instance.MinerClientsWindowVm.OnPropertyChanged(nameof(MinerClientsWindowViewModel.SelectedMinerGroup));
@@ -37,11 +37,11 @@ namespace NTMiner {
                     });
                 BuildEventPath<MinerGroupUpdatedEvent>("更新矿机分组后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById[message.Source.GetId()].Update(message.Source);
+                        _dicById[message.Target.GetId()].Update(message.Target);
                     });
                 BuildEventPath<MinerGroupRemovedEvent>("删除矿机分组后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChanged(nameof(List));
                         OnPropertyChanged(nameof(MinerGroupItems));
                         AppContext.Instance.MinerClientsWindowVm.OnPropertyChanged(nameof(MinerClientsWindowViewModel.SelectedMinerGroup));

+ 6 - 6
src/AppModels/AppContext.partials.NTMinerWalletViewModels.cs

@@ -29,21 +29,21 @@ namespace NTMiner {
                 });
                 BuildEventPath<NTMinerWalletAddedEvent>("添加NTMiner钱包后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Add(message.Source.GetId(), new NTMinerWalletViewModel(message.Source));
-                            if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Source.CoinId, out CoinViewModel coinVm)) {
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Add(message.Target.GetId(), new NTMinerWalletViewModel(message.Target));
+                            if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Target.CoinId, out CoinViewModel coinVm)) {
                                 coinVm.OnPropertyChanged(nameof(coinVm.NTMinerWallets));
                             }
                         }
                     });
                 BuildEventPath<NTMinerWalletUpdatedEvent>("更新NTMiner钱包后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById[message.Source.GetId()].Update(message.Source);
+                        _dicById[message.Target.GetId()].Update(message.Target);
                     });
                 BuildEventPath<NTMinerWalletRemovedEvent>("删除NTMiner钱包后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById.Remove(message.Source.GetId());
-                        if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Source.CoinId, out CoinViewModel coinVm)) {
+                        _dicById.Remove(message.Target.GetId());
+                        if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Target.CoinId, out CoinViewModel coinVm)) {
                             coinVm.OnPropertyChanged(nameof(coinVm.NTMinerWallets));
                         }
                     });

+ 6 - 6
src/AppModels/AppContext.partials.OverClockDataViewModels.cs

@@ -23,21 +23,21 @@ namespace NTMiner {
                     });
                 BuildEventPath<OverClockDataAddedEvent>("添加超频建议后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Add(message.Source.GetId(), new OverClockDataViewModel(message.Source));
-                            if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Source.CoinId, out CoinViewModel coinVm)) {
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Add(message.Target.GetId(), new OverClockDataViewModel(message.Target));
+                            if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Target.CoinId, out CoinViewModel coinVm)) {
                                 coinVm.OnPropertyChanged(nameof(coinVm.OverClockDatas));
                             }
                         }
                     });
                 BuildEventPath<OverClockDataUpdatedEvent>("更新超频建议后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById[message.Source.GetId()].Update(message.Source);
+                        _dicById[message.Target.GetId()].Update(message.Target);
                     });
                 BuildEventPath<OverClockDataRemovedEvent>("删除超频建议后刷新VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById.Remove(message.Source.GetId());
-                        if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Source.CoinId, out CoinViewModel coinVm)) {
+                        _dicById.Remove(message.Target.GetId());
+                        if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Target.CoinId, out CoinViewModel coinVm)) {
                             coinVm.OnPropertyChanged(nameof(coinVm.OverClockDatas));
                         }
                     });

+ 4 - 4
src/AppModels/AppContext.partials.PackageViewModels.cs

@@ -25,7 +25,7 @@ namespace NTMiner {
                     });
                 BuildEventPath<PackageAddedEvent>("添加了包后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Add(message.Source.GetId(), new PackageViewModel(message.Source));
+                        _dicById.Add(message.Target.GetId(), new PackageViewModel(message.Target));
                         OnPropertyChanged(nameof(AllPackages));
                         foreach (var item in AppContext.Instance.KernelVms.AllKernels) {
                             item.OnPropertyChanged(nameof(item.IsPackageValid));
@@ -33,7 +33,7 @@ namespace NTMiner {
                     });
                 BuildEventPath<PackageRemovedEvent>("删除了包后调整VM内存", LogEnum.DevConsole,
                     action: message => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChanged(nameof(AllPackages));
                         foreach (var item in AppContext.Instance.KernelVms.AllKernels) {
                             item.OnPropertyChanged(nameof(item.IsPackageValid));
@@ -41,8 +41,8 @@ namespace NTMiner {
                     });
                 BuildEventPath<PackageUpdatedEvent>("更新了包后调整VM内存", LogEnum.DevConsole,
                     action: message => {
-                        var entity = _dicById[message.Source.GetId()];
-                        entity.Update(message.Source);
+                        var entity = _dicById[message.Target.GetId()];
+                        entity.Update(message.Target);
                         foreach (var item in AppContext.Instance.KernelVms.AllKernels) {
                             item.OnPropertyChanged(nameof(item.IsPackageValid));
                         }

+ 8 - 8
src/AppModels/AppContext.partials.PoolKernelViewModels.cs

@@ -16,19 +16,19 @@ namespace NTMiner {
 #endif
                 BuildEventPath<PoolKernelAddedEvent>("新添了矿池内核后刷新矿池内核VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
                             PoolViewModel poolVm;
-                            if (AppContext.Instance.PoolVms.TryGetPoolVm(message.Source.PoolId, out poolVm)) {
-                                _dicById.Add(message.Source.GetId(), new PoolKernelViewModel(message.Source));
+                            if (AppContext.Instance.PoolVms.TryGetPoolVm(message.Target.PoolId, out poolVm)) {
+                                _dicById.Add(message.Target.GetId(), new PoolKernelViewModel(message.Target));
                                 poolVm.OnPropertyChanged(nameof(poolVm.PoolKernels));
                             }
                         }
                     });
                 BuildEventPath<PoolKernelRemovedEvent>("移除了币种内核后刷新矿池内核VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            var vm = _dicById[message.Source.GetId()];
-                            _dicById.Remove(message.Source.GetId());
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            var vm = _dicById[message.Target.GetId()];
+                            _dicById.Remove(message.Target.GetId());
                             PoolViewModel poolVm;
                             if (AppContext.Instance.PoolVms.TryGetPoolVm(vm.PoolId, out poolVm)) {
                                 poolVm.OnPropertyChanged(nameof(poolVm.PoolKernels));
@@ -37,8 +37,8 @@ namespace NTMiner {
                     });
                 BuildEventPath<PoolKernelUpdatedEvent>("更新了矿池内核后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById[message.Source.GetId()].Update(message.Source);
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById[message.Target.GetId()].Update(message.Target);
                         }
                     });
                 Init();

+ 5 - 5
src/AppModels/AppContext.partials.PoolViewModels.cs

@@ -24,9 +24,9 @@ namespace NTMiner {
                     });
                 BuildEventPath<PoolAddedEvent>("添加矿池后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Add(message.Source.GetId(), new PoolViewModel(message.Source));
+                        _dicById.Add(message.Target.GetId(), new PoolViewModel(message.Target));
                         OnPropertyChanged(nameof(AllPools));
-                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Source.CoinId, out CoinViewModel coinVm)) {
+                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Target.CoinId, out CoinViewModel coinVm)) {
                             coinVm.CoinProfile.OnPropertyChanged(nameof(CoinProfileViewModel.MainCoinPool));
                             coinVm.CoinProfile.OnPropertyChanged(nameof(CoinProfileViewModel.DualCoinPool));
                             coinVm.OnPropertyChanged(nameof(CoinViewModel.Pools));
@@ -35,9 +35,9 @@ namespace NTMiner {
                     });
                 BuildEventPath<PoolRemovedEvent>("删除矿池后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChanged(nameof(AllPools));
-                        if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Source.CoinId, out CoinViewModel coinVm)) {
+                        if (AppContext.Instance.CoinVms.TryGetCoinVm(message.Target.CoinId, out CoinViewModel coinVm)) {
                             coinVm.CoinProfile.OnPropertyChanged(nameof(CoinProfileViewModel.MainCoinPool));
                             coinVm.CoinProfile.OnPropertyChanged(nameof(CoinProfileViewModel.DualCoinPool));
                             coinVm.OnPropertyChanged(nameof(CoinViewModel.Pools));
@@ -46,7 +46,7 @@ namespace NTMiner {
                     });
                 BuildEventPath<PoolUpdatedEvent>("更新矿池后刷新VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById[message.Source.GetId()].Update(message.Source);
+                        _dicById[message.Target.GetId()].Update(message.Target);
                     });
                 Init();
 #if DEBUG

+ 2 - 2
src/AppModels/AppContext.partials.ShareViewModels.cs

@@ -15,8 +15,8 @@ namespace NTMiner {
 #endif
                 BuildEventPath<ShareChangedEvent>("收益变更后调整VM内存", LogEnum.DevConsole,
                     action: message => {
-                        if (_dicByCoinId.TryGetValue(message.Source.CoinId, out ShareViewModel shareVm)) {
-                            shareVm.Update(message.Source);
+                        if (_dicByCoinId.TryGetValue(message.Target.CoinId, out ShareViewModel shareVm)) {
+                            shareVm.Update(message.Target);
                         }
                     });
 #if DEBUG

+ 8 - 8
src/AppModels/AppContext.partials.SysDicItemViewModels.cs

@@ -25,10 +25,10 @@ namespace NTMiner {
                     });
                 BuildEventPath<SysDicItemAddedEvent>("添加了系统字典项后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            _dicById.Add(message.Source.GetId(), new SysDicItemViewModel(message.Source));
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            _dicById.Add(message.Target.GetId(), new SysDicItemViewModel(message.Target));
                             OnPropertyChangeds();
-                            if (AppContext.Instance.SysDicVms.TryGetSysDicVm(message.Source.DicId, out SysDicViewModel sysDicVm)) {
+                            if (AppContext.Instance.SysDicVms.TryGetSysDicVm(message.Target.DicId, out SysDicViewModel sysDicVm)) {
                                 sysDicVm.OnPropertyChanged(nameof(sysDicVm.SysDicItems));
                                 sysDicVm.OnPropertyChanged(nameof(sysDicVm.SysDicItemsSelect));
                             }
@@ -36,10 +36,10 @@ namespace NTMiner {
                     });
                 BuildEventPath<SysDicItemUpdatedEvent>("更新了系统字典项后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            SysDicItemViewModel entity = _dicById[message.Source.GetId()];
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            SysDicItemViewModel entity = _dicById[message.Target.GetId()];
                             int sortNumber = entity.SortNumber;
-                            entity.Update(message.Source);
+                            entity.Update(message.Target);
                             if (sortNumber != entity.SortNumber) {
                                 if (AppContext.Instance.SysDicVms.TryGetSysDicVm(entity.DicId, out SysDicViewModel sysDicVm)) {
                                     sysDicVm.OnPropertyChanged(nameof(sysDicVm.SysDicItems));
@@ -50,9 +50,9 @@ namespace NTMiner {
                     });
                 BuildEventPath<SysDicItemRemovedEvent>("删除了系统字典项后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChangeds();
-                        if (AppContext.Instance.SysDicVms.TryGetSysDicVm(message.Source.DicId, out SysDicViewModel sysDicVm)) {
+                        if (AppContext.Instance.SysDicVms.TryGetSysDicVm(message.Target.DicId, out SysDicViewModel sysDicVm)) {
                             sysDicVm.OnPropertyChanged(nameof(sysDicVm.SysDicItems));
                             sysDicVm.OnPropertyChanged(nameof(sysDicVm.SysDicItemsSelect));
                         }

+ 10 - 10
src/AppModels/AppContext.partials.SysDicViewModels.cs

@@ -32,21 +32,21 @@ namespace NTMiner {
                 });
                 BuildEventPath<SysDicAddedEvent>("添加了系统字典后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (!_dicById.ContainsKey(message.Source.GetId())) {
-                            SysDicViewModel sysDicVm = new SysDicViewModel(message.Source);
-                            _dicById.Add(message.Source.GetId(), sysDicVm);
-                            if (!_dicByCode.ContainsKey(message.Source.Code)) {
-                                _dicByCode.Add(message.Source.Code, sysDicVm);
+                        if (!_dicById.ContainsKey(message.Target.GetId())) {
+                            SysDicViewModel sysDicVm = new SysDicViewModel(message.Target);
+                            _dicById.Add(message.Target.GetId(), sysDicVm);
+                            if (!_dicByCode.ContainsKey(message.Target.Code)) {
+                                _dicByCode.Add(message.Target.Code, sysDicVm);
                             }
                             OnPropertyChangeds();
                         }
                     });
                 BuildEventPath<SysDicUpdatedEvent>("更新了系统字典后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        if (_dicById.ContainsKey(message.Source.GetId())) {
-                            SysDicViewModel entity = _dicById[message.Source.GetId()];
+                        if (_dicById.ContainsKey(message.Target.GetId())) {
+                            SysDicViewModel entity = _dicById[message.Target.GetId()];
                             int sortNumber = entity.SortNumber;
-                            entity.Update(message.Source);
+                            entity.Update(message.Target);
                             if (sortNumber != entity.SortNumber) {
                                 this.OnPropertyChanged(nameof(List));
                             }
@@ -54,8 +54,8 @@ namespace NTMiner {
                     });
                 BuildEventPath<SysDicRemovedEvent>("删除了系统字典后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Remove(message.Source.GetId());
-                        _dicByCode.Remove(message.Source.Code);
+                        _dicById.Remove(message.Target.GetId());
+                        _dicByCode.Remove(message.Target.Code);
                         OnPropertyChangeds();
                     });
                 Init();

+ 5 - 5
src/AppModels/AppContext.partials.UserViewModels.cs

@@ -27,21 +27,21 @@ namespace NTMiner {
                 });
                 BuildEventPath<UserAddedEvent>("添加了用户后", LogEnum.DevConsole,
                     action: message => {
-                        if (!_dicByLoginName.ContainsKey(message.Source.LoginName)) {
-                            _dicByLoginName.Add(message.Source.LoginName, new UserViewModel(message.Source));
+                        if (!_dicByLoginName.ContainsKey(message.Target.LoginName)) {
+                            _dicByLoginName.Add(message.Target.LoginName, new UserViewModel(message.Target));
                             OnPropertyChanged(nameof(List));
                         }
                     });
                 BuildEventPath<UserUpdatedEvent>("更新了用户后", LogEnum.DevConsole,
                     action: message => {
                         UserViewModel vm;
-                        if (_dicByLoginName.TryGetValue(message.Source.LoginName, out vm)) {
-                            vm.Update(message.Source);
+                        if (_dicByLoginName.TryGetValue(message.Target.LoginName, out vm)) {
+                            vm.Update(message.Target);
                         }
                     });
                 BuildEventPath<UserRemovedEvent>("移除了用户后", LogEnum.DevConsole,
                     action: message => {
-                        _dicByLoginName.Remove(message.Source.LoginName);
+                        _dicByLoginName.Remove(message.Target.LoginName);
                         OnPropertyChanged(nameof(List));
                     });
                 foreach (var item in NTMinerRoot.Instance.UserSet.AsEnumerable()) {

+ 5 - 5
src/AppModels/AppContext.partials.WalletViewModels.cs

@@ -20,10 +20,10 @@ namespace NTMiner {
                     });
                 BuildEventPath<WalletAddedEvent>("添加了钱包后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Add(message.Source.GetId(), new WalletViewModel(message.Source));
+                        _dicById.Add(message.Target.GetId(), new WalletViewModel(message.Target));
                         OnPropertyChanged(nameof(WalletList));
                         CoinViewModel coin;
-                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Source.CoinId, out coin)) {
+                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Target.CoinId, out coin)) {
                             coin.OnPropertyChanged(nameof(CoinViewModel.Wallets));
                             coin.OnPropertyChanged(nameof(CoinViewModel.WalletItems));
                             coin.CoinKernel?.CoinKernelProfile?.SelectedDualCoin?.OnPropertyChanged(nameof(CoinViewModel.Wallets));
@@ -31,10 +31,10 @@ namespace NTMiner {
                     });
                 BuildEventPath<WalletRemovedEvent>("删除了钱包后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById.Remove(message.Source.GetId());
+                        _dicById.Remove(message.Target.GetId());
                         OnPropertyChanged(nameof(WalletList));
                         CoinViewModel coin;
-                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Source.CoinId, out coin)) {
+                        if (AppContext.Instance.CoinVms.TryGetCoinVm((Guid)message.Target.CoinId, out coin)) {
                             coin.OnPropertyChanged(nameof(CoinViewModel.Wallets));
                             coin.OnPropertyChanged(nameof(CoinViewModel.WalletItems));
                             coin.CoinProfile?.OnPropertyChanged(nameof(CoinProfileViewModel.SelectedWallet));
@@ -43,7 +43,7 @@ namespace NTMiner {
                     });
                 BuildEventPath<WalletUpdatedEvent>("更新了钱包后调整VM内存", LogEnum.DevConsole,
                     action: (message) => {
-                        _dicById[message.Source.GetId()].Update(message.Source);
+                        _dicById[message.Target.GetId()].Update(message.Target);
                     });
                 Init();
 #if DEBUG

+ 1 - 1
src/AppModels/Vms/LocalMessagesViewModel.cs

@@ -79,7 +79,7 @@
             VirtualRoot.BuildEventPath<LocalMessageAddedEvent>("发生了挖矿事件后刷新Vm内存", LogEnum.DevConsole,
                 action: message => {
                     UIThread.Execute(() => {
-                        var vm = new LocalMessageViewModel(message.Source);
+                        var vm = new LocalMessageViewModel(message.Target);
                         _localMessageVms.Insert(0, vm);
                         if (IsSatisfyQuery(vm)) {
                             _queyResults.Insert(0, vm);

+ 1 - 1
src/AppViews0/Ucs/SpeedCharts.xaml.cs

@@ -63,7 +63,7 @@ namespace NTMiner.Views.Ucs {
                                     }
                                 }
                             }
-                            IGpuSpeed gpuSpeed = message.Source;
+                            IGpuSpeed gpuSpeed = message.Target;
                             int index = gpuSpeed.Gpu.Index;
                             if (Vm.SpeedChartVms.ContainsKey(index)) {
                                 SpeedChartViewModel speedChartVm = Vm.SpeedChartVms[index];

+ 2 - 2
src/NTMinerBus/Bus/DomainEvent`1.cs

@@ -5,13 +5,13 @@ namespace NTMiner.Bus {
         protected DomainEvent(Guid bornPathId, TEntity source) {
             this.Id = Guid.NewGuid();
             this.BornPathId = bornPathId;
-            this.Source = source;
+            this.Target = source;
             this.Timestamp = DateTime.Now;
         }
 
         public Guid Id { get; private set; }
         public Guid BornPathId { get; private set; }
         public DateTime Timestamp { get; private set; }
-        public TEntity Source { get; private set; }
+        public TEntity Target { get; private set; }
     }
 }

+ 1 - 1
src/NTMinerClient/Core/Gpus/Impl/TempGruarder.cs

@@ -23,7 +23,7 @@ namespace NTMiner.Core.Gpus.Impl {
             _isInited = true;
             VirtualRoot.BuildEventPath<GpuStateChangedEvent>("当显卡温度变更时守卫温度防线", LogEnum.None,
                 action: message => {
-                    IGpu gpu = message.Source;
+                    IGpu gpu = message.Target;
                     if (gpu.Index == NTMinerRoot.GpuAllId || root.MinerProfile.CoinId == Guid.Empty) {
                         return;
                     }

+ 4 - 4
src/NTMinerClient/Core/Kernels/Impl/CoinKernelSet.cs

@@ -96,9 +96,9 @@ namespace NTMiner.Core.Kernels.Impl {
             context.BuildEventPath<FileWriterRemovedEvent>("移除文件书写器后移除引用关系", LogEnum.DevConsole,
                 action: message => {
                     var repository = NTMinerRoot.CreateServerRepository<CoinKernelData>();
-                    var entities = _dicById.Values.Where(a => a.FileWriterIds.Contains(message.Source.GetId())).ToArray();
+                    var entities = _dicById.Values.Where(a => a.FileWriterIds.Contains(message.Target.GetId())).ToArray();
                     foreach (var entity in entities) {
-                        entity.FileWriterIds = new List<Guid>(entity.FileWriterIds.Where(a => a != message.Source.GetId()));
+                        entity.FileWriterIds = new List<Guid>(entity.FileWriterIds.Where(a => a != message.Target.GetId()));
                         repository.Update(entity);
                         VirtualRoot.RaiseEvent(new CoinKernelUpdatedEvent(message.Id, entity));
                     }
@@ -106,9 +106,9 @@ namespace NTMiner.Core.Kernels.Impl {
             context.BuildEventPath<FragmentWriterRemovedEvent>("移除命令行片段书写器后移除引用关系", LogEnum.DevConsole,
                 action: message => {
                     var repository = NTMinerRoot.CreateServerRepository<CoinKernelData>();
-                    var entities = _dicById.Values.Where(a => a.FragmentWriterIds.Contains(message.Source.GetId())).ToArray();
+                    var entities = _dicById.Values.Where(a => a.FragmentWriterIds.Contains(message.Target.GetId())).ToArray();
                     foreach (var entity in entities) {
-                        entity.FragmentWriterIds = new List<Guid>(entity.FragmentWriterIds.Where(a => a != message.Source.GetId()));
+                        entity.FragmentWriterIds = new List<Guid>(entity.FragmentWriterIds.Where(a => a != message.Target.GetId()));
                         repository.Update(entity);
                         VirtualRoot.RaiseEvent(new CoinKernelUpdatedEvent(message.Id, entity));
                     }