EICP3.0_69/SCADA_DAQ.Service/Env.cs

using DIL;
using SCADA.CommonLib;
using SCADA.CommonLib.Data.DIL;
using SCADA.CommonLib.Helper;
using SysManage.User;
using System;
using System.Collections.ObjectModel;
using System.IO;
using System.Linq;
using System.Reflection;

namespace SCADA_DAQ
{
    class Env
    {
        public static DILDB DAL = null;

        public static User NewUser;

        public static Schedual Schedual { get; internal set; } = Schedual.Instance;

        //public static readonly ConcurrentDictionary<string, BaseComm> CommResource = new ConcurrentDictionary<string, BaseComm>();

        public static DateTime StartTime { get; set; }

        public static int StartTick { get; internal set; }

        public static AutoSaveParameterItem<string> ProductName;

        public static AutoSaveParameterItem<string> CompanyName;

        public static AutoSaveParameterItem<string> MainDllName;

        public static AutoSaveParameterItem<string> DefaultUserName;

        public static AutoSaveParameterItem<string> WebServerAddress = AutoSaveParameterItem.Create("App.WebServer", "www.skdscada.com");

        public static AutoSaveParameterItem<bool> DataBaseNeedRest { get; set; } = AutoSaveParameterItem.Create("App.DatabaseNeedRest", false);

        public static AutoSaveParameterItem<string> ComputerTag;

        public static AutoSaveParameterItem<int> RESTfulPort;

        public static AutoSaveParameterItem<int> RPCPort;

        public static AutoSaveParameterItem<bool> SingleModel;

        public static AutoSaveParameterItem<SCADA.CommonLib.LoggerHelper.LogLevel> LogLevel;

        public static DataBaseConfig CurrentDbConfig { get; set; }

        public static AutoSaveParameterItem<DatabaseSelector> CurrentDataBase { get; set; }

        public static DataBaseConfig SysDBConfig { get; set; }

        public static AutoSaveParameterItem<DatabaseSelector> SysDataBase { get; set; }

        public static DataBaseConfig AlarmDBConfig { get; set; }

        public static AutoSaveParameterItem<DatabaseSelector> AlarmDataBase { get; set; }

        public static AutoSaveParameterItem<ObservableCollection<DataBaseConfig>> DataBaseResource { get; set; }

        /// <summary>
        /// 设备配置文件
        /// </summary>
        public static AutoSaveParameterItem<string> DeviceConfigFilePath;

        public static void ParameterInit()
        {
            ProductName = AutoSaveParameterItem.Create("App.ProductName", "", true);
            ProductName.DisplayName = "产品名称";


            CompanyName = AutoSaveParameterItem.Create("App.ProductName", "", true);
            CompanyName.DisplayName = "公司名称";


            MainDllName = AutoSaveParameterItem.Create("App.MainDllname", "", true);
            {
                MainDllName.DisplayName = "主dll名称";
            };

            DefaultUserName = AutoSaveParameterItem.Create("App.DefualtUserName", "", true);
            DefaultUserName.DisplayName = "默认用户";


            ComputerTag = AutoSaveParameterItem.Create("App.ComputerTag", "", true);
            ComputerTag.DisplayName = "电脑标签";
            ComputerTag.IsReadOnly = true;


            RESTfulPort = AutoSaveParameterItem.Create("App.RESTfulPort", 7888);
            RESTfulPort.DisplayName = "网页端口";

            RPCPort = AutoSaveParameterItem.Create("App.RPCPort", 7880);
            RPCPort.DisplayName = "本地RPC端口";


            SingleModel = AutoSaveParameterItem.Create("App.SingleModel", true);
            SingleModel.DisplayName = "单例模式";

            LogLevel = AutoSaveParameterItem.Create("App.LogLevel", SCADA.CommonLib.LoggerHelper.LogLevel.All);
            LogLevel.DisplayName = "日志级别";

            DeviceConfigFilePath = AutoSaveParameterItem.Create("DeviceConfigFilePath", "DeviceCfg.Json");
            DeviceConfigFilePath.DisplayName = "设备配置文件";

            CurrentDataBase = AutoSaveParameterItem.Create("App.DataBaseConfig", new DatabaseSelector()
            { CurrentDataBaseConfig = "Default" });

            SysDataBase = AutoSaveParameterItem.Create("App.DataBaseConfig.System", new DatabaseSelector()
            { CurrentDataBaseConfig = "SysDB" });

            AlarmDataBase = AutoSaveParameterItem.Create("App.DataBaseConfig.Alarm", new DatabaseSelector()
            { CurrentDataBaseConfig = "AlarmDB" });
            DataBaseResource = AutoSaveParameterItem.Create("App.DataBaseResource",
                        new ObservableCollection<DataBaseConfig>()
                        {
                            new DataBaseConfig()
                            {
                                ResourceName="Default",
                                DBType = DatabaseType.Sqlite,
                                FilePath = @"Data\QwPlatform.db"
                            },
                            new DataBaseConfig()
                            {
                                ResourceName="AlarmDB",
                                DBType = DatabaseType.Sqlite,
                                FilePath = @"Data\QwPlatform.db"
                            },
                            new DataBaseConfig()
                            {
                                ResourceName="SysDB",
                                DBType = DatabaseType.Sqlite,
                                FilePath = @"Data\LocalApp.db"
                            },
                        }, true);

            dataBaseConfigInit(DataBaseResource, CurrentDataBase.Value, out var currentconfig);
            dataBaseConfigInit(DataBaseResource, SysDataBase.Value, out var sysConfig);
            dataBaseConfigInit(DataBaseResource, AlarmDataBase.Value, out var alarmConfig);
            CurrentDbConfig = currentconfig;
            AlarmDBConfig = alarmConfig;
            SysDBConfig = sysConfig;
            void dataBaseConfigInit(ObservableCollection<DataBaseConfig> srouce, DatabaseSelector selector, out DataBaseConfig config)
            {
                config = DataBaseResource.Value.FirstOrDefault(t => t.ResourceName == selector?.CurrentDataBaseConfig);
                selector.DataBaseConfigResource = DataBaseResource.Value;
                if (config == null)
                {
                    config = DataBaseResource.Value.FirstOrDefault();
                    selector.CurrentDataBaseConfig = config.ResourceName;
                }
                selector.DataBaseConfig = config;
            }
            bool neeRestDatabase = DataBaseNeedRest.Value;

            void dbInit(DataBaseConfig dataBaseConfig, Type dbType, out BaseDB dilDb)
            {
                if (dataBaseConfig.DBType == DatabaseType.Sqlite)   //如果是sqlite数据库就检查数据库的状态
                {
                    string dbInfo = Path.Combine(AppDomain.CurrentDomain.BaseDirectory, dataBaseConfig.FilePath);
                    //string dbInfo = Path.GetFullPath(dataBaseConfig.FilePath);
                    dilDb = (BaseDB)Activator.CreateInstance(dbType, Path.GetDirectoryName(dbInfo), Path.GetFileName(dataBaseConfig.FilePath),
                        dataBaseConfig.UserName,
                        dataBaseConfig.Password);
                    CheckDataBase(dilDb, Path.Combine(dilDb.ServerName, dilDb.DatabaseInfo), dataBaseConfig.NeedReset || DataBaseNeedRest.Value);
                    dataBaseConfig.NeedReset = false;
                }
                else
                {
                    dilDb = (BaseDB)Activator.CreateInstance(dbType, dataBaseConfig.DatabaseServer, dataBaseConfig.DataBaseName, dataBaseConfig.UserName, dataBaseConfig.Password);
                }
            }
            dbInit(CurrentDbConfig, typeof(DILDB), out BaseDB currentDB);
            dbInit(SysDBConfig, typeof(LocalDB.DIL.DILDB), out BaseDB sysDB);
            dbInit(AlarmDBConfig, typeof(DILDB), out BaseDB alarmDB);

            DAL = (DILDB)currentDB;
            GlobalEnv.Instance.GlobalDB = currentDB;
            GlobalEnv.Instance.AlarmDB = alarmDB;
            GlobalEnv.Instance.LocalAppDB = sysDB;
            NewUser = new User(DAL)
            {
                UserName = "Admin",
            };
        }
        static Env()
        {
            //XmlUserConfig.Create();
            //ParameterInit();
        }

        private static void CheckDataBase(BaseDB db, string databasepath, bool dataBaseNeedRest)
        {
            if (dataBaseNeedRest)   //用户设置了重置数据库
            {
                System.Diagnostics.Trace.TraceInformation($"用户请求重置数据库,数据库开始重置");
                if (ReleseDatabase())
                {
                    DataBaseNeedRest.Value = false;   //数据库重置成功
                }
            }
            else
            {
                if (File.Exists(databasepath))
                {
                    object dt = db.ExecuteScalar("PRAGMA integrity_check");
                    if ($"{dt}".ToUpper() == "OK")
                    {
                        System.Diagnostics.Debug.WriteLine($"{databasepath} 数据库检测正常");
                    }
                    else
                    {
                        System.Diagnostics.Trace.TraceWarning($"检测到本地数据库已损坏,开始重置数据库");
                        _ = ReleseDatabase();
                    }
                }
                else
                {
                    ReleseDatabase();
                }
            }


            bool ReleseDatabase()
            {
                try
                {
                    if (File.Exists(databasepath))
                    {
                        File.Move(databasepath, $"{databasepath}.{DateTime.Now:yyyyMMddHHmmss}");
                    }
                    var assembly = Assembly.GetEntryAssembly();
                    Stream res = null;
                    if (Path.GetFileName(databasepath).ToUpper() == "LOCALAPP.DB")
                    {
                        res = new MemoryStream(LocalResource.LocalApp);
                    }
                    else if (Path.GetFileName(databasepath).ToUpper() == "QWPLATFORM.DB")
                    {
                        res = new MemoryStream(LocalResource.QwPlatform);
                    }
                    if (res == null) return true;
                    using (res)
                    {
                        FileHelper.EnsureDirectoryExist(databasepath);
                        byte[] save = ZipHelper.UnZip(res)[0];
                        using (FileStream fsObj = new FileStream(databasepath, FileMode.Create))
                        {
                            fsObj.Write(save, 0, save.Length);
                            fsObj.Close();
                        }
                    }
                    System.Diagnostics.Debug.WriteLine($"{databasepath} 数据库修复成功");
                    return true;
                }
                catch (Exception ex)
                {
                    System.Diagnostics.Trace.Fail($"{databasepath} 数据库修复失败,{ex}");
                    //_ = MessageBox.Show(Application.Current?.MainWindow, ex.ToString(), LanguageHelper.GetStringByKey("SysCfg_DatabaseRepairFail"));
                }
                return false;
            }
        }
    }
}