DW5S/DW5S.App/UserControl/CtrlSvrs.cs

using DevExpress.Mvvm.Native;
using DevExpress.Utils.Html;
using DevExpress.XtraEditors;
using System;
using System.Collections.Generic;
using System.ComponentModel;
using System.Data;

using System.Drawing;
using System.Linq;
using System.Text;
using System.Threading;
using System.Threading.Tasks;
using System.Windows.Controls;
using System.Windows.Documents;
using System.Windows.Forms;
using DW5S.App.EditForms;
using DW5S.DTO;
using DW5S.Repostory;
using DW5S.Service;
using DW5S.Entity;
using Serilog;
using DW5S.ViewModel;
using DevExpress.XtraReports.Wizards;

namespace DW5S.App.UserControl
{
    public partial class CtrlSvrs : DevExpress.XtraEditors.XtraUserControl
    {
        
        

        
        

        List<SvrViewModel> list = new List<SvrViewModel>();
        public CtrlSvrs()
        {
            InitializeComponent();
        }


        private async void CtrlSvrs_Load(object sender, EventArgs e)
        {
            gridSvrs.UseDefault(list).UseGroup().UseRowNumber();
            gridSvrs.UseEdit();
            var linkEdit = new DevExpress.XtraEditors.Repository.RepositoryItemHyperLinkEdit();
            this.gridSvrs.RepositoryItems.Add(linkEdit);
            if (gridView1.Columns.Count > 0)
            {
                gridView1.Columns[nameof(SvrViewModel.SwaggerAddr)].ColumnEdit = linkEdit;
                gridView1.Columns[nameof(SvrViewModel.SwaggerAddr)].OptionsColumn.AllowEdit = true;
            }
            #region 模拟服务
            List<SvrViewModel> svrList = new List<SvrViewModel>();
                SvrViewModel svr1 = new SvrViewModel(EnumSvrType.AdCgSvr,"10001","http://192.168.1.1:8091", "http://192.168.1.1:8091/swagger/index.html", DateTime.Now);
                SvrViewModel svr2 = new SvrViewModel(EnumSvrType.CpuCgSvr, "10002", "http://192.168.1.2:8091", "http://192.168.1.2:8091/swagger/index.html", DateTime.Now);
                SvrViewModel svr3 = new SvrViewModel(EnumSvrType.GpuCgSvr, "10003", "http://192.168.1.3:8091", "http://192.168.1.3:8091/swagger/index.html", DateTime.Now);
                SvrViewModel svr4 = new SvrViewModel(EnumSvrType.CheckSvr, "10004", "http://192.168.1.4:8091", "http://192.168.1.4:8091/swagger/index.html", DateTime.Now);
                SvrViewModel svr5 = new SvrViewModel(EnumSvrType.X2D1NoRefTask, "10005", "http://192.168.1.5:8091", "http://192.168.1.5:8091/swagger/index.html", DateTime.Now);
                SvrViewModel svr6 = new SvrViewModel(EnumSvrType.X2D1RefTask, "10006", "http://192.168.1.6:8091", "http://192.168.1.6:8091/swagger/index.html", DateTime.Now);
                SvrViewModel svr7 = new SvrViewModel(EnumSvrType.X1D1CxTask, "10007", "http://192.168.1.7:8091", "http://192.168.1.7:8091/swagger/index.html", DateTime.Now);
                svrList.Add(svr1);
                svrList.Add(svr2);
                svrList.Add(svr3);
                svrList.Add(svr4);
                svrList.Add(svr5);
                svrList.Add(svr6);
                svrList.Add(svr7);
            this.list.AddRange(svrList);
            #endregion

            //this.list.AddRange(ServerContext.Instance.GetAll().To<List<SvrViewModel>>());
            gridView1.RefreshData();
            Messenger.Defalut.Sub<List<SvrViewModel>>("服务集合改变", RefreshSvr);
            var unitOfWork = IocContainer.UnitOfWork;
            var repsSys = unitOfWork.Of<SysSetings>();
            var settings = await repsSys.FirstOrDefaultAsync();
            if (settings != null)
                this.simpleLabelItem2.Text = $"如果服务无法注册到平台需要到平台所在设备允许防火墙通过平台端口{settings.HttpPort}";

        }
        private void RefreshSvr(List<SvrViewModel> items)
        {
            if (!this.IsHandleCreated || this.Disposing || this.IsDisposed) return;
            try
            {
                var listCopy = list.Skip(0).ToList();
                foreach (var item in listCopy)
                {
                    var find = items.Find(p => p.BaseHttpAddr == item.BaseHttpAddr);
                    if (find == null)
                    {
                        list.Remove(item);
                    }
                }
                foreach (var item in items)
                {
                    var find = list.Find(p => p.BaseHttpAddr == item.BaseHttpAddr);
                    if (find == null)
                    {
                        list.Add(new SvrViewModel(item.SvrType, item.SvrID, item.BaseHttpAddr, item.SwaggerAddr, item.ReportTime));
                    }
                    else
                    {
                        find.BaseHttpAddr = item.BaseHttpAddr;
                        find.SwaggerAddr = item.SwaggerAddr;
                        find.SvrType = item.SvrType;
                        find.SvrID = item.SvrID;
                        find.ReportTime = item.ReportTime;
                    }
                }
                this.BeginInvoke(new Action(() =>
                {
                    gridView1.RefreshData();
                }));
            }
            catch (Exception ex)
            {
                IocContainer.Logger.Error(ex,"处理服务状态上报异常");
            }
        }

        protected override void Dispose(bool disposing)
        {
            Messenger.Defalut.UnSub<List<SvrViewModel>>("服务集合改变", RefreshSvr);
            if (disposing && (components != null))
            {
                components.Dispose();
            }
            base.Dispose(disposing);
        }
    }
}