using DevExpress.XtraEditors;
using DxHelper;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Configuration;
using System.Data;
using System.Drawing;
using System.Linq;
using System.Security.Policy;
using System.Text;
using System.Threading.Tasks;
using System.Windows.Forms;
using XdCxRhDW.Dto;
using XdCxRhDW.TaskServer.Controllers;
using XdCxRhDW.WebApi;

namespace XdCxRhDW.TaskServer
{
    public partial class MainForm : DevExpress.XtraEditors.XtraForm
    {
        List<LogInfo> list = new List<LogInfo>();
        public MainForm()
        {
            InitializeComponent();
            gridLog.Init<LogInfo>().UseExportCsv().UseFilter()
                .AddMenu("清除", SvgHelper.CreateClear(), () =>
                {
                    list.Clear();
                    gridView1.RefreshData();
                }).DataSource = list;
            gridView1.Columns[0].MaxWidth = 150;
            gridView1.Columns[1].MaxWidth = 120;
            LogHelper.Logger = info =>
            {
                list.Insert(0, info);
                gridView1.RefreshData();
            };
        }

        private async void MainForm_LoadAsync(object sender, EventArgs e)
        {

           // HistoryTaskProcessingController historyTask = new HistoryTaskProcessingController();
            //historyTask.Run(new HistoryTaskProcessingDto());
            var port = Convert.ToInt32(ConfigurationManager.AppSettings["LocalHttpPort"].Trim());
            var svrID = ConfigurationManager.AppSettings["SvrID"].Trim();
            var posPlatformAddr = ConfigurationManager.AppSettings["PosPlatformAddr"].Trim();
            this.Text = EnumSvrType.HistoryTask.GetEnumDisplayName() + "-" + svrID;
            var localIp = IpHelper.GetLocalIp();
            Startup.Start(port, "XdCxRhDW.TaskServer.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";
            while (true)
            {
                try
                {
                    var res = await HttpHelper.PostRequestAsync<object>(url, new SvrStateReportDto()
                    {
                        SvrType = EnumSvrType.HistoryTask,
                        SvrID = svrID,
                        ReportType = 0,
                        BaseHttpAddr = $"http://{localIp}:{port}",
                        SwaggerAddr = $"http://{localIp}:{port}/Swagger",
                    });
                    if (res.code != 200)
                    {
                        LogHelper.Error($"状态上报异常.{res.msg}");
                    }
                    else
                    {
                        LogHelper.Info("状态上报成功!");
                    }
                }
                catch (Exception ex)
                {
                    LogHelper.Error("状态上报异常", ex);
                }
                await Task.Delay(10000);
            }
        }

        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.HistoryTask,
                    ReportType = 1,
                    BaseHttpAddr = $"http://{localIp}:{port}",
                });

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