EICP3.0_69/SCADA_DAQ/SystemControl.cs

using DBModel;
using DBNames;
using log4net;
using SCADA.CommonLib;
using SCADA.CommonLib.Helper;
using SCADA.CommonLib.License;
using SCADA_DAQ.Plugin.Core;
using SCADA_DAQ.Plugin.Core.License;
using SCADA_DAQ.Plugin.CoreUI;
using System;
using System.Collections.Generic;
using System.Diagnostics;
using System.IO;
using System.Linq;
using System.Reflection;
using System.Threading;
using System.Threading.Tasks;
using System.Windows;

namespace SCADA_DAQ
{
    internal class SystemControl
    {
        /// <summary>
        /// 
        /// </summary>
        bool isShutDown = false;
        ILog Log { get; set; } = null;

        private EventWaitHandle evh;
        public App App { get; private set; }
        private static SystemControl systemControl;

        private static readonly object syncObj = new object();

        private readonly List<AdvanceTimer> Timers = new List<AdvanceTimer>();
        private readonly Task initTask;
        private readonly Task initServer;
        private ServiceHost host = null;
        public string UidVersion { get; }

        private string SoftWareId { get; set; }

        private SystemControl(App app)
        {
            App = app;
            PowerOnTime = DateTime.Now;
            SoftWareId = MD5Helper.GetFileMD5(GetType().Assembly.Location);
            UidVersion = $"{ApplicationHelper.GetAppVersion()}.{Convert.ToUInt16(SoftWareId.Substring(0, 3), 16):D4}";
            app.RuntimeInfo.UidVersion = UidVersion;
            initTask = Task.Factory.StartNew(() =>
            {
                bool createdNew = true;
                if (app.SystemConfig.SingleModel == true)
                {
                    evh = new EventWaitHandle(false, EventResetMode.AutoReset, App.RuntimeInfo.ProductId, out createdNew);
                    var currentProcess = Process.GetCurrentProcess();
                    var ps = Process.GetProcessesByName(
                        Path.GetFileNameWithoutExtension(Assembly.GetEntryAssembly().ManifestModule.Name))
                    .Where(t => t.Id != currentProcess.Id);

                    if (createdNew)       //信号锁创建成功，且是单例模式
                    {
                        foreach (Process p in ps)
                        {
                            p.Kill();
                        }
                    }
                    else
                    {
                        if (ps.Count() == 1 && ps.First().MainWindowHandle != IntPtr.Zero)
                        {
                            evh?.Set();
                            app.Dispatcher.Invoke(new Action(() =>
                            {
                                isShutDown = true;
                                App.Shutdown(1);
                            }));
                            return;
                        }
                        else
                        {
                            foreach (Process p in ps)   //单例模式下如果主界面没有出现，或者有多个进程，直接全部kill掉
                            {
                                p.Kill();
                            }
                        }
                    }
                }

                Console.WriteLine($"开始获取电脑ID  {DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}");
                LicenseManage.GenerateID(App.RuntimeInfo.ProductId, out var str);
                Console.WriteLine($"检查释放系统组件  {DateTime.Now:yyyy-MM-dd HH:mm:ss.fff}");
                ReleaseRunTime();
                try
                {
                    var dtClass = DataTableHelper.DtToList<App_Classes>(Env.DAL.App_Classes.GetData($"{T_Col_Name.App_Classes.ClassType_Int}=2"));
                    if (dtClass != null)
                    {
                        Env.Schedual.Classes.Clear();
                        foreach (var appClassese in dtClass)
                        {
                            var startTime = TimeSpan.Parse(appClassese.StartTime_Str);
                            var endTime = TimeSpan.Parse(appClassese.EndTime_Str);
                            Env.Schedual.Classes.Add(new WorkShift(startTime,
                                endTime, appClassese.ClassesName_Str));
                        }
                    }
                }
                catch (Exception)
                {
                    Env.Schedual.Classes.Add(new WorkShift(new TimeSpan(7, 30, 0), new TimeSpan(19, 30, 0), "白班"));
                    Env.Schedual.Classes.Add(new WorkShift(new TimeSpan(19, 30, 0), new TimeSpan(7, 30, 0), "夜班"));
                }
                CreateBackGroundTask(ReportOnLine, 10 * 1000 * 60, 10 * 1000, true, "ReportAppInfo");
                var systemStatics = Plugin.CoreUI.SystemApp.SystemStatictics.Create();
                systemStatics.AppRuntime = App;
                systemStatics.Start();
            });

            initServer = Task.Factory.StartNew(() =>
            {


            });
        }


        private DateTime PowerOnTime { get; set; }

        public static SystemControl Create(App app)
        {
            lock (syncObj)
            {
                if (systemControl == null)
                {
                    systemControl = new SystemControl(app);
                }
            }
            return systemControl;
        }
        public static SystemControl GetInstance()
        {
            return systemControl;
        }

        public void SystemInit()
        {
            App.DispatcherUnhandledException += Application_DispatcherUnhandledException;
            AppDomain.CurrentDomain.UnhandledException += CurrentDomain_UnhandledException;
            TaskScheduler.UnobservedTaskException += TaskScheduler_UnobservedTaskException;
            Task.Factory.StartNew(() =>
            {
                Task.WaitAll(initTask);
                if (isShutDown) return;
                var st = new Stopwatch();
                st.Start();
                EicpCoreManage.AppRuntime = App;
                host = ServiceHost.Instance;
                (App as IApp).ServiceHost = host;
                host.Start(App);
                try
                {
                    App.RuntimeInfo.StartTime = DateTime.Now;
                    Log = SCADA.CommonLib.LoggerHelper.Logger.CreateLogger(typeof(App));
                    Dictionary<SCADA.CommonLib.LoggerHelper.LogLevel, log4net.Core.Level> logLevel =
                    new Dictionary<SCADA.CommonLib.LoggerHelper.LogLevel, log4net.Core.Level>()
                    {
                        { SCADA.CommonLib.LoggerHelper.LogLevel.All,log4net.Core.Level.All},
                        { SCADA.CommonLib.LoggerHelper.LogLevel.Debug,log4net.Core.Level.Debug},
                        { SCADA.CommonLib.LoggerHelper.LogLevel.Info,log4net.Core.Level.Info},
                        { SCADA.CommonLib.LoggerHelper.LogLevel.Warn,log4net.Core.Level.Warn},
                        { SCADA.CommonLib.LoggerHelper.LogLevel.Error,log4net.Core.Level.Error},
                        { SCADA.CommonLib.LoggerHelper.LogLevel.Fatal,log4net.Core.Level.Fatal},
                        { SCADA.CommonLib.LoggerHelper.LogLevel.None,log4net.Core.Level.Off},
                    };
                    LogManager.GetRepository().Threshold = logLevel[App.SystemConfig.LogLevel];
                    Log.Info($"App {App.RuntimeInfo.ProductId} ({UidVersion}) is starting ……");
                    Task.WaitAll(initServer);
                    Console.WriteLine($"系统初始化完成 {DateTime.Now:yyyy-MM-dd HH:mm:ss,fff}");
                    Func<bool> action = null;
                    LoadLicense();
                    //App.Dispatcher.Invoke(new Action(() =>
                    //{
                    //    if (App.MainWindow is MainWindow window)
                    //    {
                    //        action = window.GetLicense;
                    //    }
                    //}));
                    //if (!LicenseManage.CheckID(App as IApp, out var str, action))
                    //{
                    //    App.Dispatcher.Invoke(new Action(() =>
                    //    {
                    //        isShutDown = true;
                    //        App.Shutdown(100);
                    //    }));
                    //    return;
                    //}
                    //else
                    //{
                    //    App.RuntimeInfo.LicenseInfo = LicenseManage.GetLicenseInfo(App.RuntimeInfo.ProductId);
                    //}
                    App.RuntimeInfo.ComputerId = App.RuntimeInfo.LicenseInfo.Computer.ComputerId;
                    App.RuntimeInfo.LicenseInfo.LicenseType = LicenseType.Permanentlicense;

                    App.Dispatcher.Invoke(new Action(() =>
                    {
                        if (App.MainWindow is MainWindow window)
                        {
                            window.LicenseInfo = App.RuntimeInfo.LicenseInfo;
                            Log.Debug($"系统初始化完成,即将开启");
                            Env.SetLanguage();
                            window.SystemInited();
                            Env.SetTheme();
                            Env.SetFont();
                        }
                    }));
                }
                catch (Exception ex)
                {
                    FalatReport(ex);
                    Log.Error(ex);
                }


                new Thread(() =>
                {
                    while (!isShutDown && evh != null)
                    {
                        if (evh.WaitOne(-1))
                        {
                            if (isShutDown)
                            {
                                return;
                            }
                            App.Dispatcher.Invoke(new Action(() =>
                            {
                                App.MainWindow.Topmost = true;
                                App.MainWindow.WindowState = WindowState.Maximized;
                                App.MainWindow.Topmost = false;
                            }));
                        }
                    }
                }).Start();
            });
        }

        /// <summary>
        /// 重新加载授权文件
        /// </summary>
        internal void LoadLicense()
        {
            App.RuntimeInfo.LicenseInfo = LicenseManage.GetLicenseInfo(App.RuntimeInfo.ProductId);
            if (isShutDown || App.RuntimeInfo.LicenseInfo == null) return;
            if (!App.Dispatcher.HasShutdownStarted)
            {
                App.Dispatcher.Invoke(new Action(() =>
                {
                    if (App.MainWindow is MainWindow window)
                    {
                        window.MainWindowViewModel.CopyRightInfo = $"{App.SystemConfig.AuthorInfo}({App.RuntimeInfo.LicenseInfo.LicenseType})";
                    }
                }));
                ReportAppInfo(true);
            }
        }


        private DateTime lastReportSuccessTime = DateTime.MinValue;

        private void ReportOnLine()
        {
            if ((DateTime.Now - lastReportSuccessTime).TotalSeconds > 590)
            {
                ReportAppInfo(true);
            }
        }

        private void ReportAppInfo(bool isOnline = true)
        {
            if (App.RuntimeInfo.LicenseInfo != null && (App.RuntimeInfo.LicenseInfo.LicenseType == LicenseType.TempLicense || App.RuntimeInfo.LicenseInfo.LicenseType == LicenseType.Permanentlicense))
            {
                var reportInfo = new
                {
                    SessionID = App.RuntimeInfo.SessionId,
                    AppName = App.RuntimeInfo.LicenseInfo?.AppName,
                    Version = UidVersion,
                    CustomerTag = App.SystemConfig.ComputerTag,
                    ComputerId = App.RuntimeInfo.LicenseInfo?.Computer.ComputerId,
                    LicenseId = App.RuntimeInfo.LicenseInfo?.LicenseId,
                    LicenseType = App.RuntimeInfo.LicenseInfo?.LicenseType.ToString(),
                    ActiveTime = App.RuntimeInfo.LicenseInfo?.ActiveTime,
                    ExpireDate = App.RuntimeInfo.LicenseInfo?.ActiveTime.AddDays(App.RuntimeInfo.LicenseInfo.ExpireDays),
                    TotalOutputPcs = Env.TotalOutputPcs.Value,
                    TotalOutputQty = Env.TotalOutputQty.Value,
                    IsOnline = isOnline
                };
                if (EicpCoreManage.ReportAppInfo(reportInfo, out var appName))
                {
                    lastReportSuccessTime = DateTime.Now;
                    App.SystemConfig.ComputerTag = appName;
                }
            }
        }

        private void FalatReport(Exception exception)
        {
            if (isShutDown) return;
            if (App.RuntimeInfo.LicenseInfo != null &&
                (App.RuntimeInfo.LicenseInfo.LicenseType == LicenseType.TempLicense ||
                App.RuntimeInfo.LicenseInfo.LicenseType == LicenseType.Permanentlicense))
            {
                try
                {
                    EicpCoreManage.FalatReport(new
                    {
                        SessionID = App.RuntimeInfo.SessionId,
                        AppName = App.RuntimeInfo.LicenseInfo?.AppName,
                        Version = UidVersion,
                        ComputerId = App.RuntimeInfo.LicenseInfo?.Computer?.ComputerId,
                        SoftwareID = SoftWareId,
                        Customer = System.Windows.Forms.Application.CompanyName,
                        Message = exception.Message,
                        PowerOnTime = PowerOnTime,
                        RunTime = DateTime.Now - PowerOnTime,
                        Exception = exception?.ToString()
                    });
                }
                catch (Exception ex)
                {
                    Log?.Error(ex);
                }
            }
        }
        public bool RestartHost()
        {
            return host.Restart();
        }

        private void Application_DispatcherUnhandledException(object sender, System.Windows.Threading.DispatcherUnhandledExceptionEventArgs e)
        {
            Log?.Error(e.Exception);
            e.Handled = true;
            if (!isShutDown)
            {
                FalatReport(e.Exception);
            }

        }

        private void CurrentDomain_UnhandledException(object sender, UnhandledExceptionEventArgs e)
        {
            FalatReport(e.ExceptionObject as Exception);
            Log?.Fatal(e.ExceptionObject);
            LogManager.Flush(10);
            ExitHandler(e.ExceptionObject.ToString());
            App?.Dispatcher.BeginInvoke(new Action(() =>
            {
                MessageBox.Show(e.ExceptionObject.ToString());
            }));
        }


        /// <summary>
        /// 释放运行时压缩包
        /// </summary>
        private void ReleaseRunTime()
        {
            var runTimeLibDic = new Dictionary<string, string>()
            {
                {"Content.zip","Content" },
                {"EicpWeb.zip","Content" },
                {"EicpCustomer.zip","Content" },
                {"HCNETSDKLib.zip",null },
                {"RunTime.zip",null },
                {"SyntecLib_v4.zip",null},
                {"FocasLib.zip",AppDomain.CurrentDomain.BaseDirectory },
                {"DeviceCfg.zip",null},
                {"x86_x64.zip",null },
            };
            foreach (var item in runTimeLibDic)
            {
                try
                {
                    if (System.IO.File.Exists(item.Key))
                    {
                        ZipHelper.UnZip(item.Key, item.Value);
                        FileHelper.DeleteFile(item.Key);
                    }
                }
                catch (Exception ex)
                {
                    Log.Error(ex);
                }
            }
        }
        private void TaskScheduler_UnobservedTaskException(object sender, UnobservedTaskExceptionEventArgs e)
        {
            Log?.Fatal(e.Exception);
            FalatReport(e.Exception);
            ExitHandler(e.Exception.Message);
        }

        private void ExitHandler(string exitMsg)
        {
            Plugin.CoreUI.SystemApp.SystemStatictics.Create().AppExit(exitMsg);
            ReportAppInfo(false);
        }

        public void ApplicationExit(int exitCode)
        {
            isShutDown = true;
            evh?.Set();
            evh?.Dispose();
        }

        public void ApplicationDispose(int exitCode)
        {
            isShutDown = true;
            if (host != null) host.Stop();
            foreach (var item in Timers)
            {
                item.Dispose();
            }
            var exitReason = "";
            if (ExitCode.ContainsKey(exitCode))
            {
                exitReason = ExitCode[exitCode];
            }
            ExitHandler(exitReason);
            if (Log != null)
            {
                Log.Info($"{App.RuntimeInfo.ProductId}({UidVersion}) is shutdown by {exitReason}");
                SCADA.CommonLib.LoggerHelper.Logger.Dispose();
            }
        }

        public void ApplicationSessionEnding(object sender, SessionEndingCancelEventArgs e)
        {
            Log.Error($"计算机已注销或关闭,原因:{e.ReasonSessionEnding}");
        }



        /// <summary>
        /// 创建一个后台任务
        /// </summary>
        /// <param name="task"></param>
        /// <param name="cycleTime">重复执行间隔 毫秒</param>
        /// <param name="delayTime">延迟时间</param>
        /// <param name="backgroundContinue">当转到后台时继续执行</param>
        /// <param name="taskName"></param>
        public void CreateBackGroundTask(ThreadStart task, int cycleTime, int delayTime = 0, bool backgroundContinue = false, string taskName = null)
        {
            Timers.Add(new AdvanceTimer(task, taskName, cycleTime, delayTime)
            {
                IsBackground = backgroundContinue,
                IsActived = true,
                TimerName = taskName
            });
        }

        private readonly Dictionary<int, string> ExitCode = new Dictionary<int, string>()
        {
            {0,"User Exit"},
            {100,"invalid license"},
        };
    }
}