MainViewModel.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625
  1. using Avalonia;
  2. using Avalonia.Collections;
  3. using Avalonia.Controls;
  4. using Avalonia.Controls.ApplicationLifetimes;
  5. using Avalonia.Controls.Documents;
  6. using Avalonia.Media;
  7. using Avalonia.Threading;
  8. using CommunityToolkit.Mvvm.ComponentModel;
  9. using CommunityToolkit.Mvvm.Input;
  10. using FxpConvert.Common;
  11. using Shaker.Models;
  12. using ShakerApp.Tools;
  13. using ShakerApp.ViewModels;
  14. using SukiUI.Dialogs;
  15. using SukiUI.Toasts;
  16. using System;
  17. using System.Collections.Generic;
  18. using System.Linq;
  19. using System.Reflection;
  20. using System.Runtime.CompilerServices;
  21. using System.Windows.Input;
  22. namespace ShakerApp.ViewModels;
  23. public class MainViewModel : DisplayViewModelBase<IModel>
  24. {
  25. public ICalc Calc { get; } = new SIMDFxpConvert.SIMDCalc();
  26. private AvaloniaDictionary<string, Window?> OpenedWindows = new AvaloniaDictionary<string, Window?>();
  27. private bool canDebug = false;
  28. private MainViewModel()
  29. {
  30. #if DEBUG
  31. CanDebug = true;
  32. #else
  33. CanDebug = false;
  34. #endif
  35. GetEvent(ShakerSettingViewModel.LANGUAGECHANGEDEVENT).Subscrip((_, _) =>
  36. {
  37. OnPropertyChanged(nameof(Title));
  38. });
  39. GetEvent(Topic.DisConnect).Subscrip((_, _) =>
  40. {
  41. OnPropertyChanged(nameof(Title));
  42. OnPropertyChanged(nameof(TitleColor));
  43. });
  44. MainPageViewModel.Instance.PropertyChanged += (sender, args) =>
  45. {
  46. switch(args.PropertyName)
  47. {
  48. case nameof(MainPageViewModel.MainPageType):
  49. OnPropertyChanged(nameof(Title));
  50. break;
  51. }
  52. };
  53. GetEvent(Topic.DisConnect).Subscrip((sender, args) =>
  54. {
  55. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.DisConnect)?.Publish(this);
  56. });
  57. this.GetType().Assembly.GetTypes()
  58. .Where(x => x.IsAnsiClass && !x.IsAbstract && x.IsAssignableTo(typeof(ObservableObject)))
  59. .ToList()
  60. .ForEach(x =>
  61. {
  62. var val = x.GetProperties(System.Reflection.BindingFlags.Static | System.Reflection.BindingFlags.Public)
  63. .FirstOrDefault(y => y.PropertyType == x);
  64. val?.GetValue(null);
  65. });
  66. List<(MethodInfo Method, string Key)> infos = this.GetType().GetMethods(BindingFlags.Instance | BindingFlags.Public | BindingFlags.NonPublic)
  67. .Where(x => x.GetCustomAttribute<MenuClickAttribute>() != null)
  68. .Select(x =>
  69. {
  70. var att = x.GetCustomAttribute<MenuClickAttribute>();
  71. return (x, att!.Key);
  72. }).ToList();
  73. MenuViewModel.Instance.MenuClick += (menu) =>
  74. {
  75. if (menu == null) return;
  76. infos.FirstOrDefault(x => x.Key == menu.Header).Method?.Invoke(Default, new[] { menu.Header });
  77. };
  78. }
  79. static MainViewModel()
  80. {
  81. }
  82. public Avalonia.Media.IBrush TitleColor => CommunicationViewModel.Instance.LocalIsConnect ? Brushes.Black : Brushes.Red;
  83. public ICommand ExitCommand => new RelayCommand(()=>Exit(""));
  84. [MenuClick("MenuExit")]
  85. private void Exit(string? p)
  86. {
  87. ShowAsk(App.Current?.FindResource("PromptExitMsg")+"",()=>
  88. {
  89. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STOP)?.Publish(this, null);
  90. Environment.Exit(0);
  91. });
  92. }
  93. private string GetTitle()
  94. {
  95. string s = string.Empty;
  96. if(ViewModels.CommunicationViewModel.Instance.LocalIsConnect)
  97. {
  98. if(MainPageViewModel.Instance.MainPageType == MainPageType.StartPage)
  99. {
  100. s = $"{App.Current?.FindResource("Title")}-{ViewModels.DeviceMangerViewModel.Instance.CurrentDevice!.Name}[{CommunicationViewModel.Instance.LocalCommunication.IP}:{CommunicationViewModel.Instance.LocalCommunication.Port}]";
  101. }
  102. else
  103. {
  104. s = $"{App.Current?.FindResource("Title")}-{ViewModels.DeviceMangerViewModel.Instance.CurrentDevice!.Name}-[{App.Current?.FindResource(MainPageViewModel.Instance.MainPageType.Description())}]";
  105. }
  106. }
  107. else
  108. {
  109. s = App.Current?.FindResource("Title") + "-" + App.Current?.FindResource("Offline");
  110. }
  111. return s;
  112. }
  113. public ICommand ConnectCommand => new RelayCommand(Connect);
  114. private void Connect()
  115. {
  116. CommunicationViewModel.Instance.Connect(ViewModels.ShakerSettingViewModel.Instance.RemoteIP, ViewModels.ShakerSettingViewModel.Instance.RemotePort);
  117. }
  118. public override string Title => GetTitle();
  119. public bool CanDebug
  120. {
  121. get => canDebug;
  122. set
  123. {
  124. SetProperty(ref canDebug, value);
  125. MenuViewModel.Instance["CanDebug"]!.IsVisible = value;
  126. MenuViewModel.Instance["MenuDebug"]!.IsVisible = value;
  127. }
  128. }
  129. public ICommand SettingCommand => new RelayCommand<string?>(Setting);
  130. private async void Setting(string? p)
  131. {
  132. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  133. {
  134. ShakerSettingViewModel.Instance.InitData();
  135. ShakerSettingViewModel.Instance.Title = p;
  136. BaseDialogWindow window = new BaseDialogWindow();
  137. window.DataContext = ShakerSettingViewModel.Instance;
  138. await window.ShowDialog(desktop.MainWindow!);
  139. }
  140. }
  141. public ICommand DeviceMangerCommand => new RelayCommand<string?>(DeviceManger);
  142. private async void DeviceManger(string? p)
  143. {
  144. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  145. {
  146. DeviceMangerViewModel.Instance.InitData();
  147. DeviceMangerViewModel.Instance.Title = p;
  148. BaseDialogWindow window = new BaseDialogWindow();
  149. window.DataContext = DeviceMangerViewModel.Instance;
  150. DeviceMangerViewModel.Instance.CloseWindowAction = () => window?.Close();
  151. await window.ShowDialog(desktop.MainWindow!);
  152. }
  153. }
  154. public ICommand SelectTestTypeCommand => new RelayCommand<MainPageType>(SelectTestType);
  155. private void SelectTestType(MainPageType type)
  156. {
  157. MainPageViewModel.Instance.MainPageType = type;
  158. }
  159. public ICommand SaveConfigCommand => new RelayCommand<string?>(SaveConfig);
  160. [MenuClick("MenuSaveConfig")]
  161. private async void SaveConfig(string? p)
  162. {
  163. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  164. {
  165. SaveConfigViewModel.Instance.InitData();
  166. SaveConfigViewModel.Instance.Title = p;
  167. BaseDialogWindow window = new BaseDialogWindow();
  168. window.DataContext = SaveConfigViewModel.Instance;
  169. DeviceMangerViewModel.Instance.CloseWindowAction = () => window?.Close();
  170. await window.ShowDialog(desktop.MainWindow!);
  171. }
  172. }
  173. public ICommand SignalPreviewCommand=> new RelayCommand<string?>(SignalPreview);
  174. private void SignalPreview(string? p)
  175. {
  176. if (string.IsNullOrEmpty(p)) return;
  177. if (OpenedWindows.TryGetValue(p, out var w))
  178. {
  179. if (w != null && w.IsLoaded)
  180. {
  181. w.Activate();
  182. return;
  183. }
  184. }
  185. SignalPreviewViewModel.Instance.InitData();
  186. SignalPreviewViewModel.Instance.Title = p;
  187. BaseDialogWindow window = new BaseDialogWindow();
  188. window.DataContext = SignalPreviewViewModel.Instance;
  189. OpenedWindows[p] = window;
  190. SignalPreviewViewModel.Instance.CloseWindowAction = () =>
  191. {
  192. window?.Close();
  193. OpenedWindows[p] = null;
  194. };
  195. window.Show();
  196. }
  197. public ICommand LoadConfigCommand => new RelayCommand<string?>(LoadConfig);
  198. [MenuClick("MenuLoadConfig")]
  199. private async void LoadConfig(string? p)
  200. {
  201. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  202. {
  203. LoadConfigViewModel.Instance.InitData();
  204. LoadConfigViewModel.Instance.Title = p;
  205. BaseDialogWindow window = new BaseDialogWindow();
  206. window.DataContext = LoadConfigViewModel.Instance;
  207. DeviceMangerViewModel.Instance.CloseWindowAction = () => window?.Close();
  208. await window.ShowDialog(desktop.MainWindow!);
  209. }
  210. }
  211. public ICommand ShakerConfigCommand => new RelayCommand<string?>(ShakerConfig);
  212. private async void ShakerConfig(string? p)
  213. {
  214. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  215. {
  216. ShakerConfigViewModel.Instance.InitData();
  217. ShakerConfigViewModel.Instance.Title = p;
  218. BaseDialogWindow window = new BaseDialogWindow();
  219. window.DataContext = ShakerConfigViewModel.Instance;
  220. ShakerConfigViewModel.Instance.CloseWindowAction = () => window?.Close();
  221. await window.ShowDialog(desktop.MainWindow!);
  222. }
  223. }
  224. public ICommand OilControlCommand => new RelayCommand<string?>(OilControl);
  225. private void OilControl(string? p)
  226. {
  227. if (string.IsNullOrEmpty(p)) return;
  228. if(OpenedWindows.TryGetValue(p,out var w))
  229. {
  230. if(w!=null && w.IsLoaded)
  231. {
  232. w.Activate();
  233. return;
  234. }
  235. }
  236. OilSourceStatusViewModel.Instance.InitData();
  237. OilSourceStatusViewModel.Instance.Title = p;
  238. BaseDialogWindow window = new BaseDialogWindow();
  239. window.DataContext = OilSourceStatusViewModel.Instance;
  240. OpenedWindows[p] = window;
  241. OilSourceStatusViewModel.Instance.CloseWindowAction = () =>
  242. {
  243. window?.Close();
  244. OpenedWindows[p] = null;
  245. };
  246. window.Show();
  247. }
  248. public ICommand CloseCommand => new RelayCommand(Close);
  249. private void Close()
  250. {
  251. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STOP)?.Publish(this, null);
  252. Environment.Exit(0);
  253. }
  254. public ICommand DebugCommand => new RelayCommand<string?>(Debug);
  255. public async void Debug(string? p)
  256. {
  257. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  258. {
  259. InputPassWordViewModel.Instance.InitData();
  260. BaseDialogWindow window = new BaseDialogWindow();
  261. window.DataContext = InputPassWordViewModel.Instance;
  262. InputPassWordViewModel.Instance.CloseWindowAction = () => window?.Close();
  263. InputPassWordViewModel.Instance.InputAction = (pass) =>
  264. {
  265. window?.Close();
  266. if(pass != "123456")
  267. {
  268. ToastManager.CreateSimpleInfoToast().WithTitle(App.Current?.FindResource("PromptTitle")+"").WithContent(App.Current?.FindResource("PassWordError") + "").Queue();
  269. return;
  270. }
  271. ShowDebug(p);
  272. };
  273. await window.ShowDialog(desktop.MainWindow!);
  274. }
  275. }
  276. private async void ShowDebug(string? p)
  277. {
  278. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  279. {
  280. ShakerControlViewModel.Instance.InitData();
  281. ShakerControlViewModel.Instance.Title = p;
  282. ShakerControlViewModel.Instance.Content = typeof(Views.DebugView);
  283. BaseDialogWindow window = new BaseDialogWindow();
  284. window.DataContext = ShakerControlViewModel.Instance;
  285. ShakerControlViewModel.Instance.CloseWindowAction = () =>
  286. {
  287. window?.Close();
  288. };
  289. await window.ShowDialog(desktop.MainWindow!);
  290. }
  291. }
  292. public ICommand UpbitfileCommand => new RelayCommand<string?>(Upbitfile);
  293. private void Upbitfile(string? p)
  294. {
  295. }
  296. public ICommand SweepConfigCommand => new RelayCommand<string?>(SweepConfig);
  297. private async void SweepConfig(string? p)
  298. {
  299. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  300. {
  301. SweepConfigViewModel.Instance.InitData();
  302. SweepConfigViewModel.Instance.Title = p;
  303. BaseDialogWindow window = new BaseDialogWindow();
  304. window.DataContext = SweepConfigViewModel.Instance;
  305. await window.ShowDialog(desktop.MainWindow!);
  306. }
  307. }
  308. public void InitServiceMsg()
  309. {
  310. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<string>(Topic.SERVICERESULT)?.Subscrip((_, _) => Topic.SERVICERESULT);
  311. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<Shaker.Models.AllConfig>(Shaker.Models.Topic.SYNCCONFIG)?.Subscrip((_, _) =>
  312. {
  313. return new AllConfig()
  314. {
  315. OilSource = OilSourceStatusViewModel.Instance.Model,
  316. RandomConfig = RandomConfigViewModel.Instance.Model,
  317. ShakerConfig = ShakerConfigViewModel.Instance.Model,
  318. ShakerControl = ShakerControlViewModel.Instance.Model,
  319. ShakerStatus = ShakerStatusViewModel.Instance.Model,
  320. SweepConfig = SweepConfigViewModel.Instance.Model,
  321. };
  322. });
  323. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<ShakerConfigModel>()?.Subscrip((sender, args) =>
  324. {
  325. ShakerConfigViewModel.Instance.ReceiveServiceModel(args.Data);
  326. });
  327. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<ShakerControlModel>()?.Subscrip((sender, args) =>
  328. {
  329. ShakerControlViewModel.Instance.ReceiveServiceModel(args.Data);
  330. });
  331. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<SweepConfigModel>()?.Subscrip((sender, args) =>
  332. {
  333. SweepConfigViewModel.Instance.ReceiveServiceModel(args.Data);
  334. });
  335. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<RandomConfigModel>()?.Subscrip((sender, args) =>
  336. {
  337. RandomConfigViewModel.Instance.ReceiveServiceModel(args.Data);
  338. });
  339. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<DeviceInfoModel?>()?.Publish(this, ViewModels.DeviceMangerViewModel.Instance.CurrentDevice?.Model);
  340. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<RandomTestStep>()?.Subscrip((sender, args) =>
  341. {
  342. CommunicationViewModel.Instance.LocalCommunication?.GetEvent<RandomTestStep>()?.Publish(this, args.Data);
  343. });
  344. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<MainPageType>()?.Subscrip((sender, args) =>
  345. {
  346. MainPageViewModel.Instance.MainPageType = args.Data;
  347. CommunicationViewModel.Instance.LocalCommunication?.GetEvent<MainPageType>()?.Publish(this, args.Data);
  348. });
  349. CommunicationViewModel.Instance.LocalCommunication?.GetEvent<MainPageType>()?.Subscrip((sender, args) =>
  350. {
  351. MainPageViewModel.Instance.MainPageType = args.Data;
  352. });
  353. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Shaker.Models.Topic.START)?.Subscrip((_, _) =>
  354. {
  355. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.START)?.Publish(this);
  356. });
  357. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.STARTRANDOMTEST)?.Subscrip((_, _) =>
  358. {
  359. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STARTRANDOMTEST)?.Publish(this);
  360. });
  361. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.STOP)?.Subscrip((_, _) =>
  362. {
  363. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STOP)?.Publish(this);
  364. });
  365. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.RISETABLE)?.Subscrip((_, _) =>
  366. {
  367. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.RISETABLE)?.Publish(this);
  368. });
  369. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.ZEROCHANGE)?.Subscrip((_, e) =>
  370. {
  371. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.ZEROCHANGE)?.Publish(this, null, e.Data[0]);
  372. });
  373. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.DROPTABLE)?.Subscrip((_, _) =>
  374. {
  375. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.DROPTABLE)?.Publish(this);
  376. });
  377. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.STOPSIGNALGEN)?.Subscrip((_, _) =>
  378. {
  379. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STOPSIGNALGEN)?.Publish(this);
  380. });
  381. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.VALVEPOWER)?.Subscrip((_, e) =>
  382. {
  383. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STOPSIGNALGEN)?.Publish(this, null, e.Data[0]);
  384. });
  385. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.STARTSIGNALGEN)?.Subscrip((_, _) =>
  386. {
  387. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STARTSIGNALGEN)?.Publish(this);
  388. });
  389. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.RESETERROR)?.Subscrip((_, _) =>
  390. {
  391. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.RESETERROR)?.Publish(this);
  392. });
  393. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.CircuitPressure)?.Subscrip((sender, args) =>
  394. {
  395. if (args.Data.Length >= 2 && args.Data[0] is int index && args.Data[1] is float pressure)
  396. {
  397. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.CircuitPressure)?.Publish(this, null, index, pressure);
  398. }
  399. });
  400. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.CircuitStart)?.Subscrip((sender, args) =>
  401. {
  402. if (args.Data.Length >= 2 && args.Data[0] is int index && args.Data[1] is bool state)
  403. {
  404. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.CircuitStart)?.Publish(this, null, index, state);
  405. }
  406. });
  407. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.CircuitLoad)?.Subscrip((sender, args) =>
  408. {
  409. if (args.Data.Length >= 2 && args.Data[0] is int index && args.Data[1] is bool state)
  410. {
  411. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.CircuitLoad)?.Publish(this, null, index, state);
  412. }
  413. });
  414. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.ForerunnerPressure)?.Subscrip((sender, args) =>
  415. {
  416. if (args.Data.Length >= 1 && args.Data[0] is float pressure)
  417. {
  418. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.ForerunnerPressure)?.Publish(this, null, pressure);
  419. }
  420. });
  421. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.ForerunnerStart)?.Subscrip((sender, args) =>
  422. {
  423. if (args.Data.Length >= 1 && args.Data[0] is bool state)
  424. {
  425. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.ForerunnerStart)?.Publish(this, null, state);
  426. }
  427. });
  428. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.ForerunnerLoad)?.Subscrip((sender, args) =>
  429. {
  430. if (args.Data.Length >= 1 && args.Data[0] is bool state)
  431. {
  432. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.ForerunnerLoad)?.Publish(this, null, state);
  433. }
  434. });
  435. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.AssistantPressure)?.Subscrip((sender, args) =>
  436. {
  437. if (args.Data.Length >= 1 && args.Data[0] is float pressure)
  438. {
  439. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.AssistantPressure)?.Publish(this, null, pressure);
  440. }
  441. });
  442. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.AssistantStart)?.Subscrip((sender, args) =>
  443. {
  444. if (args.Data.Length >= 1 && args.Data[0] is bool state)
  445. {
  446. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.AssistantStart)?.Publish(this, null, state);
  447. }
  448. });
  449. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.AssistantLoad)?.Subscrip((sender, args) =>
  450. {
  451. if (args.Data.Length >= 1 && args.Data[0] is bool state)
  452. {
  453. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.AssistantLoad)?.Publish(this, null, state);
  454. }
  455. });
  456. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.CirculatePressure)?.Subscrip((sender, args) =>
  457. {
  458. if (args.Data.Length >= 1 && args.Data[0] is float pressure)
  459. {
  460. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.CirculatePressure)?.Publish(this, null, pressure);
  461. }
  462. });
  463. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.CirculateStart)?.Subscrip((sender, args) =>
  464. {
  465. if (args.Data.Length >= 1 && args.Data[0] is bool state)
  466. {
  467. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.CirculateStart)?.Publish(this, null, state);
  468. }
  469. });
  470. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.CirculateLoad)?.Subscrip((sender, args) =>
  471. {
  472. if (args.Data.Length >= 1 && args.Data[0] is bool state)
  473. {
  474. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.CirculateLoad)?.Publish(this, null, state);
  475. }
  476. });
  477. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.OilEmergencyStop)?.Subscrip((sender, args) =>
  478. {
  479. if (args.Data.Length >= 1 && args.Data[0] is bool state)
  480. {
  481. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.OilEmergencyStop)?.Publish(this, null, state);
  482. }
  483. });
  484. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent(Topic.RANDOMNEXTLEVEL)?.Subscrip((_, _) =>
  485. {
  486. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.RANDOMNEXTLEVEL)?.Publish(this);
  487. });
  488. }
  489. public ICommand RandomConfigCommand => new RelayCommand<string?>(RandomConfig);
  490. private async void RandomConfig(string? p)
  491. {
  492. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  493. {
  494. RandomConfigViewModel.Instance.InitData();
  495. RandomConfigViewModel.Instance.Title = p;
  496. BaseDialogWindow window = new BaseDialogWindow();
  497. window.DataContext = RandomConfigViewModel.Instance;
  498. await window.ShowDialog(desktop.MainWindow!);
  499. }
  500. }
  501. public ICommand AboutCommand => new RelayCommand<string?>(About);
  502. private async void About(string? p)
  503. {
  504. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  505. {
  506. AboutViewModel.Instance.InitData();
  507. AboutViewModel.Instance.Title = p;
  508. BaseDialogWindow window = new BaseDialogWindow();
  509. window.DataContext = AboutViewModel.Instance;
  510. await window.ShowDialog(desktop.MainWindow!);
  511. }
  512. }
  513. public ICommand DisConnectCommand => new RelayCommand(DisConnect);
  514. private void DisConnect()
  515. {
  516. ShowAsk(App.Current?.FindResource("AskDisconnect") + "", () =>
  517. {
  518. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.STOP)?.Publish(this, null);
  519. CommunicationViewModel.Instance.DisConnect();
  520. });
  521. }
  522. public ICommand ShakerControlCommand => new RelayCommand<string?>(ShakerControl);
  523. private void ShakerControl(string? p)
  524. {
  525. if (string.IsNullOrEmpty(p)) return;
  526. if (OpenedWindows.TryGetValue(p, out var w))
  527. {
  528. if (w != null && w.IsLoaded)
  529. {
  530. w.Activate();
  531. return;
  532. }
  533. }
  534. ShakerStatusViewModel.Instance.InitData();
  535. ShakerStatusViewModel.Instance.Title = p;
  536. BaseDialogWindow window = new BaseDialogWindow();
  537. window.DataContext = ShakerStatusViewModel.Instance;
  538. OpenedWindows[p] = window;
  539. ShakerStatusViewModel.Instance.CloseWindowAction = () =>
  540. {
  541. window?.Close();
  542. OpenedWindows[p] = null;
  543. };
  544. window.Show();
  545. }
  546. public ICommand LogCommand =>new RelayCommand<string?>(Log);
  547. private async void Log(string? p)
  548. {
  549. if (Application.Current?.ApplicationLifetime is IClassicDesktopStyleApplicationLifetime desktop && !string.IsNullOrEmpty(p))
  550. {
  551. LogViewModel.Instance.InitData();
  552. LogViewModel.Instance.Title = p;
  553. BaseDialogWindow window = new BaseDialogWindow();
  554. window.DataContext = LogViewModel.Instance;
  555. await window.ShowDialog(desktop.MainWindow!);
  556. }
  557. }
  558. public void SyncConfig()
  559. {
  560. LogViewModel.Instance.AddLog($"同步控制器设置参数");
  561. CommunicationViewModel.Instance.LocalCommunication?.GetEvent<DeviceInfoModel?>()?.Subscrip((sender, args) =>
  562. {
  563. if (args.Data == null)
  564. {
  565. DeviceMangerViewModel.Instance.CurrentDevice = null;
  566. }
  567. else
  568. {
  569. if (DeviceMangerViewModel.Instance.CurrentDevice == null) DeviceMangerViewModel.Instance.CurrentDevice = new DeviceInfoViewModel();
  570. DeviceMangerViewModel.Instance.CurrentDevice.UpDateModel(args.Data);
  571. }
  572. });
  573. var config= CommunicationViewModel.Instance.LocalCommunication?.GetEvent<Shaker.Models.AllConfig>(Shaker.Models.Topic.SYNCCONFIG)?.Publish(this);
  574. if(config ==null)
  575. {
  576. LogViewModel.Instance.AddLog($"同步控制器设置参数失败", LogType.Error);
  577. base.ToastManager.CreateSimpleInfoToast()
  578. .WithTitle(App.Current?.FindResource("PromptTitle") + "")
  579. .WithContent(App.Current?.FindResource("GetConfigError")+"")
  580. .Queue();
  581. CommunicationViewModel.Instance.LocalCommunication?.Close();
  582. return;
  583. }
  584. LogViewModel.Instance.AddLog($"同步控制器设置参数成功");
  585. GetEvent<AllConfig>().Publish(this, config);
  586. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<AllConfig>(Topic.SYNCCONFIG)?.Publish(this,null, config);
  587. CommunicationViewModel.Instance.LocalCommunication?.GetEvent(Topic.START)?.Publish(this);
  588. OnPropertyChanged(nameof(Title));
  589. OnPropertyChanged(nameof(TitleColor));
  590. CommunicationViewModel.Instance.ServiceCommunication?.GetEvent<DeviceInfoModel?>()?.Publish(this, DeviceMangerViewModel.Instance.CurrentDevice?.Model);
  591. foreach (var item in MainPageViewModel.Instance.MainPageViewModels)
  592. {
  593. item.UpdataColnumInfo();
  594. }
  595. }
  596. public static MainViewModel Default { get; } = new MainViewModel();
  597. }