XdCxRhDW/Service/X2D1TaskServer/MainForm.cs

using System;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Threading.Tasks;
using System.Windows.Forms;
using XdCxRhDW.Dto;
using XdCxRhDW.Framework;
using XdCxRhDW.WebApi;

namespace X2D1TaskServer
{
    public partial class MainForm : Form
    {
        private EnumSvrType svrType = EnumSvrType.X2D1NoRefTask;
        public MainForm()
        {
            InitializeComponent();
            LogHelper.Logger = info =>
            {
                try
                {
                    this.Invoke(new Action(() =>
                    {
                        this.listBox1.Items.Insert(0, $"{info.LogTime:yyyyMMddHHmmss.fff}--{info.Msg}");
                        if (this.listBox1.Items.Count > 1000)
                            this.listBox1.Items.RemoveAt(this.listBox1.Items.Count - 1);
                    }));
                }
                catch
                { }
            };
        }

        private async void MainForm_LoadAsync(object sender, EventArgs e)
        {
            if (Debugger.IsAttached)//结束已启动的进程,方便调试
            {
                var pros = Process.GetProcessesByName(Assembly.GetExecutingAssembly().GetName().Name).OrderBy(p => p.StartTime).ToList();
                pros.RemoveAt(pros.Count - 1);
                foreach (var item in pros)
                {
                    try
                    {
                        item.Kill();
                    }
                    catch
                    { }
                }
            }
            var port = AppConfigHelper.Get<int>("LocalHttpPort");
            var svrID = AppConfigHelper.Get("SvrID");
            var posPlatformAddr = AppConfigHelper.Get("PosPlatformAddr").AppendUrlSuffix("api/");
            LogHelper.BaseUrl = posPlatformAddr;
            this.Text = svrType.GetEnumDisplayName() + "-" + svrID;
            string localIp;
            string getIpUrl = posPlatformAddr.AppendUrlSuffix("task/getclientip");
            while (true)
            {
                try
                {
                    var rsp = await HttpHelper.GetRequestAsync<string>(getIpUrl, 10);
                    if (rsp.code == 0)
                    {
                        await LogHelper.Error(rsp.msg);
                        return;
                    }
                    else
                    {
                        localIp = rsp.data;
                    }
                    break;
                }
                catch (Exception ex)
                {
                    await LogHelper.Error($"无法连接到平台{getIpUrl},请检测地址是否正确并确保平台防火墙允许端口通过", ex);
                    await Task.Delay(5000);
                }
            }
            await LogHelper.Info($"本机IP={localIp}");
            Startup.Start(port, $"{System.Reflection.Assembly.GetExecutingAssembly().GetName().Name}.xml", "XdCxRhDW.Dto.xml");
            await LogHelper.Info($"服务启动成功.接口地址http://{localIp}:{port}/swagger");

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

        private void MainForm_FormClosed(object sender, FormClosedEventArgs e)
        {
            try
            {
                var port = AppConfigHelper.Get<int>("LocalHttpPort");
                var svrID = AppConfigHelper.Get("SvrID");
                var posPlatformAddr = AppConfigHelper.Get("PosPlatformAddr").AppendUrlSuffix("api/");
                string url = posPlatformAddr.AppendUrlSuffix("SvrReport/Report");
                var localIp = IpHelper.GetLocalIp();
                _ = HttpHelper.PostRequestAsync<object>(url, new SvrStateReportDto()
                {
                    SvrID = svrID,
                    SvrType = svrType,
                    ReportType = 1,
                    BaseHttpAddr = $"http://{localIp}:{port}",
                });

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

        //清理10分钟之前的文件
        private async Task ClearLocalFile()
        {
            while (true)
            {
                try
                {
                    var uploadFolder = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, "wwwroot");
                    var files = Directory.EnumerateFiles(uploadFolder);
                    foreach (var file in files)
                    {
                        FileInfo info = new FileInfo(file);
                        if (info.CreationTime < DateTime.Now.AddMinutes(-10))
                        {
                            try
                            {
                                info.Delete();
                            }
                            catch
                            {
                            }
                        }
                    }
                }
                catch (Exception ex)
                {
                    await LogHelper.Error("清理wwwroot历史文件异常", ex);
                }
                await Task.Delay(60 * 1000);
            }
        }
    }
}