MainForm.cs 19 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498
  1. using DevExpress.XtraBars;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.ComponentModel;
  5. using System.Data;
  6. using System.Drawing;
  7. using System.Linq;
  8. using System.Text;
  9. using System.Threading.Tasks;
  10. using System.Windows.Forms;
  11. using DevExpress.XtraBars.Docking2010.Views;
  12. using DW5S.App.UserControl;
  13. using DevExpress.XtraBars.Ribbon;
  14. using System.Threading;
  15. using DevExpress.XtraEditors;
  16. using ExtensionsDev;
  17. using DevExpress.XtraBars.Forms;
  18. using DW5S.App.CorTools;
  19. using System.IO;
  20. using DW5S.DTO;
  21. using DW5S.Entity;
  22. using DW5S.Repostory;
  23. using DW5S.KxcApi;
  24. using System.Net.Http;
  25. using DW5S.App.Properties;
  26. using System.Windows.Documents;
  27. using DW5S.App;
  28. using System.Diagnostics;
  29. using DevExpress.Utils.Extensions;
  30. using System.Net;
  31. using DW5S.WebApi;
  32. using DW5S.DataEmulation;
  33. using DxHelper;
  34. using System.Runtime.InteropServices;
  35. using System.Runtime.InteropServices.ComTypes;
  36. using DevExpress.LookAndFeel.Design;
  37. using System.Configuration;
  38. using Microsoft.Extensions.Logging;
  39. using DW5S.Service;
  40. namespace DW5S
  41. {
  42. public partial class MainForm : DevExpress.XtraBars.Ribbon.RibbonForm
  43. {
  44. [Autowired]
  45. private readonly ILogger logger;
  46. [Autowired]
  47. private readonly UnitOfWork unitOfWork;
  48. Dictionary<string, Type> ctrlTypes = new Dictionary<string, Type>();
  49. public MainForm()
  50. {
  51. InitializeComponent();
  52. ribbon.UseDefault();
  53. tabbedView1.UseDefault();
  54. ctrlTypes.Add("任务管理", typeof(CtrlHome));
  55. ctrlTypes.Add("参估结果", typeof(CtrlCgRes));
  56. ctrlTypes.Add("绘图管理", typeof(CtrlDraw));
  57. ctrlTypes.Add("星历管理", typeof(CtrlXl));
  58. ctrlTypes.Add("卫星管理", typeof(CtrlSat));
  59. ctrlTypes.Add("接收站管理", typeof(CtrlTx));
  60. ctrlTypes.Add("参考站管理", typeof(CtrlTx));
  61. ctrlTypes.Add("超短波管理", typeof(CtrlTx));
  62. ctrlTypes.Add("测向站管理", typeof(CtrlTx));
  63. ctrlTypes.Add("固定站管理", typeof(CtrlFixedStation));
  64. ctrlTypes.Add("信号管理", typeof(CtrlSignal));
  65. ctrlTypes.Add("目标管理", typeof(CtrlTarget));
  66. ctrlTypes.Add("系统设置", typeof(CtrlSysSettings));
  67. ctrlTypes.Add("变采样", typeof(ResampleForm));
  68. ctrlTypes.Add("GPU参估", typeof(GpuCalcForm));
  69. ctrlTypes.Add("检测参估", typeof(DetectToolForm));
  70. ctrlTypes.Add("星历推算", typeof(XlCalculateForm));
  71. ctrlTypes.Add("信号仿真", typeof(SignalEmulation));
  72. ctrlTypes.Add("服务状态", typeof(CtrlSvrs));
  73. ctrlTypes.Add("服务日志", typeof(CtrlSvrLog));
  74. DxHelper.WaitHelper.UpdateSplashMessage("正在检查数据库环境...");
  75. }
  76. private string text;
  77. private async void MainForm_Load(object sender, EventArgs e)
  78. {
  79. this.text = this.Text;
  80. this.HtmlText = $"<size=12>{this.text}";
  81. var repsSys = unitOfWork.Reps<SysSetings>();
  82. var settings = await repsSys.FirstOrDefaultAsync();
  83. btn_ItemClick(null, null);
  84. ServerContext.Instance.Init();
  85. this.HtmlText = $"<size=12>{text}(<size=9>{settings.TimeZoneDisplayName}</size>)";
  86. Messenger.Defalut.Sub<SysSetings>("时区改变", settings =>
  87. {
  88. this.HtmlText = $"<size=12>{text}(<size=9>{settings.TimeZoneDisplayName}</size>)";
  89. });
  90. StartProcess();
  91. _ = XlScan();
  92. _ = XlClear();
  93. _ = ClearLocalFile();
  94. _ = ClearLog();
  95. _ = MonitorCpuAndMemory();
  96. await XlLonCalc();
  97. }
  98. private Task MonitorCpuAndMemory()
  99. {
  100. if (!AppConfigHelper.Get("UseGatherDevState", true)) return Task.CompletedTask;
  101. return Task.Run(() =>
  102. {
  103. try
  104. {
  105. int interval = 30000;
  106. CpuMonitor sys = new CpuMonitor();
  107. const int GB_DIV = 1024 * 1024 * 1024;
  108. while (true)
  109. {
  110. //第二章方法获取系统CPU和内存使用情况
  111. logger.LogInformation($"设备CPU:{sys.CpuLoad:f1}%,设备内存:{(sys.PhysicalMemory - sys.MemoryAvailable) / GB_DIV:f2}GB/{sys.PhysicalMemory / (double)GB_DIV:f2}GB,平台内存:{sys.ProcessMemory() / (double)GB_DIV:f2}GB,平台线程:{sys.ProcessThread()}");
  112. Thread.Sleep(interval);
  113. }
  114. }
  115. catch
  116. { }
  117. });
  118. }
  119. //自动导入Tle
  120. private async Task XlScan()
  121. {
  122. while (true)
  123. {
  124. await Task.Delay(10000);
  125. var repsSys = unitOfWork.Reps<SysSetings>();
  126. var settings = await repsSys.FirstOrDefaultAsync();
  127. if (settings == null
  128. || string.IsNullOrWhiteSpace(settings.XLDirectory)
  129. || !Directory.Exists(settings.XLDirectory))
  130. {
  131. continue;
  132. }
  133. DirectoryInfo dir = new DirectoryInfo(settings.XLDirectory);
  134. var backupSucceed = Path.Combine(dir.FullName, "Backup", "Succeed");
  135. var backupFailed = Path.Combine(dir.FullName, "Backup", "Failed");
  136. Directory.CreateDirectory(backupSucceed);
  137. Directory.CreateDirectory(backupFailed);
  138. var files = Directory.EnumerateFiles(settings.XLDirectory, "*", SearchOption.TopDirectoryOnly);
  139. foreach (string file in files)
  140. {
  141. bool succeed = false;
  142. try
  143. {
  144. var fileName = await HttpHelper.UploadFileAsync(file, SysConfig.GetBaseUrl());
  145. XlImportDto dto = new XlImportDto() { File = fileName };
  146. var res = await HttpHelper.PostRequestAsync<RecordRes>(SysConfig.GetUrl("Xl/ImportTleAsync"), dto);
  147. if (res.code == 200)
  148. {
  149. logger.LogInformation($"星历文件[{file}]自动导入成功!");
  150. try
  151. {
  152. //导入完成的文件放在备份目录
  153. var newFile = Path.Combine(backupSucceed, Path.GetFileName(file));
  154. if (File.Exists(newFile))
  155. File.Delete(newFile);
  156. File.Move(file, newFile);
  157. }
  158. catch
  159. {
  160. }
  161. }
  162. else
  163. {
  164. logger.LogError($"星历文件[{file}]自动导入失败.{res.msg}");
  165. try
  166. {
  167. //导入完成的文件放在备份目录
  168. var newFile = Path.Combine(backupFailed, Path.GetFileName(file));
  169. if (File.Exists(newFile))
  170. File.Delete(newFile);
  171. File.Move(file, newFile);
  172. }
  173. catch
  174. {
  175. }
  176. }
  177. }
  178. catch (Exception ex)
  179. {
  180. logger.LogError(ex, $"星历文件[{file}]自动导入失败");
  181. try
  182. {
  183. //导入完成的文件放在备份目录
  184. var newFile = Path.Combine(backupFailed, Path.GetFileName(file));
  185. if (File.Exists(newFile))
  186. File.Delete(newFile);
  187. File.Move(file, newFile);
  188. }
  189. catch
  190. {
  191. }
  192. await Task.Delay(5000);
  193. }
  194. finally
  195. {
  196. await Task.Delay(2000);
  197. }
  198. }
  199. }
  200. }
  201. //清理1年之前导入的星历
  202. private async Task XlClear()
  203. {
  204. while (true)
  205. {
  206. try
  207. {
  208. var repsXl = unitOfWork.Reps<XlInfo>();
  209. DateTime dt = DateTime.Now.AddYears(-1);
  210. await repsXl.DeleteAsync(p => p.UpdateTime < dt);
  211. await unitOfWork.SaveAsync();
  212. await Task.Delay(60 * 1000);
  213. }
  214. catch (Exception ex)
  215. {
  216. await LogUI.Error("清理过期星历异常", ex);
  217. }
  218. finally
  219. {
  220. await Task.Delay(2000);
  221. }
  222. }
  223. }
  224. //计算星历的轨道经度
  225. private async Task XlLonCalc()
  226. {
  227. while (true)
  228. {
  229. try
  230. {
  231. List<XlInfo> calcItems = null;
  232. List<SatInfo> satInfo = null;
  233. using (RHDWContext db = new RHDWContext())
  234. {
  235. calcItems = await db.XlInfos.Where(p => p.Lon == null).OrderByDescending(p => p.SatCode).Take(100).ToListAsync();
  236. satInfo = await db.SatInfos.ToListAsync();
  237. }
  238. if (calcItems != null && calcItems.Any())
  239. {
  240. var firstUpdateItems = calcItems.Where(p => satInfo.Any(t => t.SatCode == p.SatCode)).ToList();
  241. await Task.Run(() =>
  242. {
  243. List<XlInfo> Level1 = new List<XlInfo>();
  244. foreach (var item in firstUpdateItems)
  245. {
  246. try
  247. {
  248. var eph = EphHelper.Calc(item.TwoLine, item.TimeUTC);
  249. item.Lon = Math.Round(PhysicsHelper.EcefToGeo((eph.X, eph.Y, eph.Z)).lon, 1);
  250. Level1.Add(item);
  251. calcItems.Remove(item);
  252. }
  253. catch (Exception ex)
  254. {
  255. item.Lon = -999;
  256. LogUI.Error($"[{item.TwoLine}]推算XYZ星历出错!", ex).Wait(5000);
  257. }
  258. }
  259. if (Level1.Any())
  260. {
  261. using (RHDWContext db = new RHDWContext())
  262. {
  263. db.XlInfos.AddOrUpdate(Level1.ToArray());
  264. db.SaveChanges();
  265. }
  266. }
  267. List<XlInfo> Level2 = new List<XlInfo>();
  268. foreach (var item in calcItems)
  269. {
  270. try
  271. {
  272. var eph = EphHelper.Calc(item.TwoLine, item.TimeUTC);
  273. item.Lon = Math.Round(PhysicsHelper.EcefToGeo((eph.X, eph.Y, eph.Z)).lon, 1);
  274. Level2.Add(item);
  275. }
  276. catch (Exception ex)
  277. {
  278. item.Lon = -999;
  279. LogUI.Error($"[{item.TwoLine}]推算XYZ星历出错!", ex).Wait(5000);
  280. }
  281. }
  282. if (Level2.Any())
  283. {
  284. using (RHDWContext db = new RHDWContext())
  285. {
  286. db.XlInfos.AddOrUpdate(Level2.ToArray());
  287. db.SaveChanges();
  288. }
  289. }
  290. });
  291. }
  292. else
  293. {
  294. await Task.Delay(60 * 1000);
  295. }
  296. }
  297. catch (Exception ex)
  298. {
  299. LogUI.Error($"推算XYZ星历出错!", ex).Wait(5000);
  300. }
  301. finally
  302. {
  303. await Task.Delay(5000);
  304. }
  305. }
  306. }
  307. //清理10分钟之前的文件
  308. private async Task ClearLocalFile()
  309. {
  310. while (true)
  311. {
  312. try
  313. {
  314. var uploadFolder = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot");
  315. var files = Directory.EnumerateFiles(uploadFolder);
  316. foreach (var file in files)
  317. {
  318. FileInfo info = new FileInfo(file);
  319. if (info.CreationTime < DateTime.Now.AddMinutes(-10))
  320. {
  321. try
  322. {
  323. info.Delete();
  324. }
  325. catch
  326. {
  327. }
  328. }
  329. }
  330. }
  331. catch (Exception ex)
  332. {
  333. await LogUI.Error("清理wwwroot历史文件异常", ex);
  334. }
  335. await Task.Delay(60 * 1000);
  336. }
  337. }
  338. private async Task ClearLog()
  339. {
  340. while (true)
  341. {
  342. using (RHDWLogContext db = new RHDWLogContext())
  343. {
  344. try
  345. {
  346. var time1 = DateTime.Today.AddDays(-7);
  347. var time2 = DateTime.Today.AddDays(-30);
  348. var delItems = await db.LogRes.Where(p => p.LogTime < time1 && p.LogType != Entity.EnumLogType.Error).Take(500).ToListAsync();
  349. db.LogRes.RemoveRange(delItems);
  350. var delItems2 = await db.LogRes.Where(p => p.LogTime < time2 && p.LogType == Entity.EnumLogType.Error).Take(500).ToListAsync();
  351. db.LogRes.RemoveRange(delItems2);
  352. await db.SaveChangesAsync();
  353. if (!delItems.Any() && !delItems2.Any())
  354. {
  355. break;
  356. }
  357. }
  358. catch (Exception ex)
  359. {
  360. await LogUI.Error("清理日志信息异常", ex);
  361. await Task.Delay(10000);
  362. }
  363. finally
  364. {
  365. await Task.Delay(5000);
  366. }
  367. }
  368. }
  369. }
  370. private void btn_ItemClick(object sender, ItemClickEventArgs e)
  371. {
  372. var btnTxt = e?.Item?.Caption?.Trim() ?? "任务管理";
  373. BaseDocument doc = null;
  374. doc = tabbedView1.Documents.Find(p => p.Control.GetType() == ctrlTypes[btnTxt]).FirstOrDefault();
  375. if (doc == null)
  376. {
  377. doc = tabbedView1.AddDocument((Control)Activator.CreateInstance(ctrlTypes[btnTxt]), btnTxt);
  378. if (doc.Control is Form form)
  379. {
  380. form.Text = "";
  381. doc.Caption = btnTxt;
  382. }
  383. if (btnTxt == "任务管理")
  384. doc.Properties.AllowClose = DevExpress.Utils.DefaultBoolean.False;
  385. else
  386. doc.Properties.AllowClose = DevExpress.Utils.DefaultBoolean.True;
  387. }
  388. tabbedView1.ActivateDocument(doc.Control);
  389. }
  390. protected override void OnFormClosing(FormClosingEventArgs e)
  391. {
  392. if (e.CloseReason == CloseReason.UserClosing)
  393. {
  394. if (!DxHelper.MsgBoxHelper.ShowConfirm("确定要退出当前系统吗?"))
  395. {
  396. e.Cancel = true;
  397. return;
  398. }
  399. }
  400. KillProcess();
  401. Application.Exit();
  402. }
  403. private void btnOpenApi_ItemClick(object sender, ItemClickEventArgs e)
  404. {
  405. using (RHDWContext db = new RHDWContext())
  406. {
  407. if (SysConfig.Config == null)
  408. {
  409. DxHelper.MsgBoxHelper.ShowWarning($"请在系统设置中配置基础信息");
  410. return;
  411. }
  412. string addr = $"http://{IpHelper.GetLocalIp()}:{SysConfig.Config.HttpPort}/swagger";
  413. try
  414. {
  415. System.Diagnostics.Process.Start(addr);
  416. }
  417. catch
  418. {
  419. db.Dispose();
  420. DxHelper.MsgBoxHelper.ShowError($"无法打开默认浏览器,请手动打开浏览器查看接口文档.地址{addr}");
  421. }
  422. }
  423. }
  424. private void StartProcess()
  425. {
  426. Task.Run(() =>
  427. {
  428. KillProcess();
  429. Process pro = new Process();
  430. var servicesDir = Directory.GetDirectories(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Service\\"), "*", SearchOption.TopDirectoryOnly);
  431. foreach (var item in servicesDir)
  432. {
  433. try
  434. {
  435. string exeName = Path.GetFileNameWithoutExtension(item);
  436. string exeFile = $"{item}\\{exeName}.exe";
  437. pro.StartInfo.FileName = exeFile;
  438. pro.StartInfo.WindowStyle = ProcessWindowStyle.Hidden;
  439. pro.StartInfo.Arguments = $"http://127.0.0.1:{SysConfig.Config.HttpPort}";
  440. pro.Start();
  441. }
  442. catch (Exception ex)
  443. {
  444. DW5S.Framework.LogHelper.Error($"启动【{item}】中的服务异常", ex);
  445. DxHelper.MsgBoxHelper.ShowError($"启动【{item}】中的服务异常");
  446. }
  447. }
  448. });
  449. }
  450. private void KillProcess()
  451. {
  452. try
  453. {
  454. List<Process> list = new List<Process>();
  455. var servicesDir = Directory.GetDirectories(Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "Service\\"), "*", SearchOption.TopDirectoryOnly);
  456. foreach (var item in servicesDir)
  457. {
  458. string exeName = Path.GetFileNameWithoutExtension(item);
  459. list.AddRange(Process.GetProcessesByName(exeName));
  460. }
  461. foreach (var item in list)
  462. {
  463. try
  464. {
  465. item.Kill();
  466. }
  467. catch
  468. {
  469. }
  470. }
  471. }
  472. catch
  473. { }
  474. }
  475. }
  476. }