XdCxRhDW54/Service/Leo2SatTaskServer54/MainForm.cs

using DevExpress.Utils;
using DxHelper;
using System;
using System.Collections.Generic;
using System.Configuration;
using System.IO;
using System.Threading.Tasks;
using System.Windows.Forms;
using XdCxRhDW.Dto;
using XdCxRhDW.WebApi;

namespace X2LeoTaskServer54
{
    public partial class MainForm : DevExpress.XtraEditors.XtraForm
    {
        List<LogInfo> list = new List<LogInfo>();
        public MainForm()
        {
            InitializeComponent();
            gridLog.UseDefault(list).UseExportCsv().UseClear<LogInfo>().SetLogImageColumn(nameof(LogInfo.LogType), typeof(EnumLogType));
            gridView1.Columns[nameof(LogInfo.LogType)].MaxWidth = 100;
            gridView1.Columns[nameof(LogInfo.LogTime)].MaxWidth = 160;
            gridView1.Columns[nameof(LogInfo.Msg)].AppearanceCell.TextOptions.HAlignment = HorzAlignment.Near;
            this.IconOptions.SvgImage = DxHelper.SvgHelper.LoadFromFile("Service.svg");
            LogHelper.Logger = info =>
            {
                try
                {
                    list.Insert(0, info);
                    this.Invoke(new Action(() => gridView1.RefreshData()));
                }
                catch
                { }
            };
        }

        private async void MainForm_LoadAsync(object sender, EventArgs e)
        {
            try
            {
                if (Directory.Exists("tmp"))
                    Directory.Delete("tmp");
            }
            catch
            { }
            var port = Convert.ToInt32(ConfigurationManager.AppSettings["LocalHttpPort"].Trim());
            var svrID = ConfigurationManager.AppSettings["SvrID"].Trim();
            var posPlatformAddr = ConfigurationManager.AppSettings["PosPlatformAddr"].Trim();
            LogHelper.BaseUrl = posPlatformAddr + "/api/";
            this.Text = EnumSvrType.LeoX2Task54.GetEnumDisplayName() + "-" + svrID;
            string localIp;
            string getIpUrl = $"{posPlatformAddr}/api/task/getclientip";
            while (true)
            {
                try
                {
                    var rsp = await HttpHelper.GetRequestAsync<string>(getIpUrl, 10);
                    if (rsp.code == 0)
                    {
                        LogHelper.Error(rsp.msg);
                        return;
                    }
                    else
                    {
                        localIp = rsp.data;
                    }
                    break;
                }
                catch (Exception ex)
                {
                    LogHelper.Error($"无法连接到平台{getIpUrl},请检测地址是否正确并确保平台防火墙允许端口通过", ex);
                    await Task.Delay(5000);
                }
            }
            LogHelper.Info($"本机IP={localIp}");
            Startup.Start(port, $"{System.Reflection.Assembly.GetExecutingAssembly().GetName().Name}.xml", "XdCxRhDW.Dto.xml");
            LogHelper.Info($"服务启动成功.接口地址http://{localIp}:{port}/swagger");

            string url;
            if (posPlatformAddr.EndsWith("/"))
                url = posPlatformAddr + "api/SvrReport/Report";
            else
                url = posPlatformAddr + "/api/SvrReport/Report";
            bool preSucceed = false;
            while (!this.Disposing)
            {
                try
                {
                    var res = await HttpHelper.PostRequestAsync<object>(url, new SvrStateReportDto()
                    {
                        SvrType = EnumSvrType.LeoX2Task54,
                        SvrID = svrID,
                        ReportType = 0,
                        BaseHttpAddr = $"http://{localIp}:{port}",
                        SwaggerAddr = $"http://{localIp}:{port}/Swagger",
                    });
                    if (res.code != 200)
                    {
                        LogHelper.Error($"状态上报异常[url={url}].{res.msg}");
                        preSucceed = false;
                    }
                    else
                    {
                        if (!preSucceed)
                            LogHelper.Info($"状态上报成功![url={url}]");
                        preSucceed = true;
                    }
                }
                catch (Exception ex)
                {
                    LogHelper.Error($"状态上报异常[url={url}]", ex);
                    preSucceed = false;
                }
                await System.Threading.Tasks.Task.Delay(6000);
            }
        }

        private void MainForm_FormClosed(object sender, FormClosedEventArgs e)
        {
            try
            {
                var port = Convert.ToInt32(ConfigurationManager.AppSettings["LocalHttpPort"].Trim());
                var svrID = ConfigurationManager.AppSettings["SvrID"].Trim();
                var posPlatformAddr = ConfigurationManager.AppSettings["PosPlatformAddr"].Trim();
                string url;
                if (posPlatformAddr.EndsWith("/"))
                    url = posPlatformAddr + "api/SvrReport/Report";
                else
                    url = posPlatformAddr + "/api/SvrReport/Report";
                var localIp = IpHelper.GetLocalIp();


                _ = HttpHelper.PostRequestAsync<object>(url, new SvrStateReportDto()
                {
                    SvrID = svrID,
                    SvrType = EnumSvrType.LeoX2Task54,
                    ReportType = 1,
                    BaseHttpAddr = $"http://{localIp}:{port}",
                });

            }
            catch (Exception ex)
            {
                LogHelper.Error("状态上报异常", ex);
            }
        }
    }
}