MainForm.cs 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109
  1. using DxHelper;
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Configuration;
  5. using System.Windows.Forms;
  6. using XdCxRhDW.Dto;
  7. using XdCxRhDW.WebApi;
  8. namespace XdCxRhDW.TaskServer
  9. {
  10. public partial class MainForm : DevExpress.XtraEditors.XtraForm
  11. {
  12. List<LogInfo> list = new List<LogInfo>();
  13. public MainForm()
  14. {
  15. InitializeComponent();
  16. gridLog.Init<LogInfo>().UseExportCsv().UseFilter()
  17. .AddMenu("清除", SvgHelper.CreateClear(), () =>
  18. {
  19. list.Clear();
  20. gridView1.RefreshData();
  21. }).DataSource = list;
  22. gridView1.Columns[0].MaxWidth = 150;
  23. gridView1.Columns[1].MaxWidth = 120;
  24. LogHelper.Logger = info =>
  25. {
  26. list.Insert(0, info);
  27. gridView1.RefreshData();
  28. };
  29. }
  30. private async void MainForm_LoadAsync(object sender, EventArgs e)
  31. {
  32. // HistoryTaskProcessingController historyTask = new HistoryTaskProcessingController();
  33. //historyTask.Run(new HistoryTaskProcessingDto());
  34. var port = Convert.ToInt32(ConfigurationManager.AppSettings["LocalHttpPort"].Trim());
  35. var svrID = ConfigurationManager.AppSettings["SvrID"].Trim();
  36. var posPlatformAddr = ConfigurationManager.AppSettings["PosPlatformAddr"].Trim();
  37. this.Text = EnumSvrType.HistoryTask.GetEnumDisplayName() + "-" + svrID;
  38. var localIp = IpHelper.GetLocalIp();
  39. Startup.Start(port, "XdCxRhDW.TaskServer.Xml", "XdCxRhDW.Dto.xml");
  40. LogHelper.Info($"服务启动成功.接口地址http://{localIp}:{port}/swagger");
  41. string url;
  42. if (posPlatformAddr.EndsWith("/"))
  43. url = posPlatformAddr + "api/SvrReport/Report";
  44. else
  45. url = posPlatformAddr + "/api/SvrReport/Report";
  46. while (true)
  47. {
  48. try
  49. {
  50. var res = await HttpHelper.PostRequestAsync<object>(url, new SvrStateReportDto()
  51. {
  52. SvrType = EnumSvrType.HistoryTask,
  53. SvrID = svrID,
  54. ReportType = 0,
  55. BaseHttpAddr = $"http://{localIp}:{port}",
  56. SwaggerAddr = $"http://{localIp}:{port}/Swagger",
  57. });
  58. if (res.code != 200)
  59. {
  60. LogHelper.Error($"状态上报异常.{res.msg}");
  61. }
  62. else
  63. {
  64. LogHelper.Info("状态上报成功!");
  65. }
  66. }
  67. catch (Exception ex)
  68. {
  69. LogHelper.Error("状态上报异常", ex);
  70. }
  71. await System.Threading.Tasks.Task.Delay(10000);
  72. }
  73. }
  74. private void MainForm_FormClosed(object sender, FormClosedEventArgs e)
  75. {
  76. try
  77. {
  78. var port = Convert.ToInt32(ConfigurationManager.AppSettings["LocalHttpPort"].Trim());
  79. var svrID = ConfigurationManager.AppSettings["SvrID"].Trim();
  80. var posPlatformAddr = ConfigurationManager.AppSettings["PosPlatformAddr"].Trim();
  81. string url;
  82. if (posPlatformAddr.EndsWith("/"))
  83. url = posPlatformAddr + "api/SvrReport/Report";
  84. else
  85. url = posPlatformAddr + "/api/SvrReport/Report";
  86. var localIp = IpHelper.GetLocalIp();
  87. _ = HttpHelper.PostRequestAsync<object>(url, new SvrStateReportDto()
  88. {
  89. SvrID = svrID,
  90. SvrType = EnumSvrType.HistoryTask,
  91. ReportType = 1,
  92. BaseHttpAddr = $"http://{localIp}:{port}",
  93. });
  94. }
  95. catch (Exception ex)
  96. {
  97. LogHelper.Error("状态上报异常", ex);
  98. }
  99. }
  100. }
  101. }