MainViewModel.cs 28 KB

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