ECS / ECS_EquipmentMangaSystem_BingChengTaiGuang · Files

using HHECS.Infrastructure.Json;
using HHECS.WebCommon.Json;
using System;
using System.Collections.Generic;
using System.Data.SqlClient;
using System.IO;
using System.Text;

namespace HHECS.WebCommon.Config
{
    /// <summary>
    ///  配置读取 ,公共变量 支持内存缓存 
    /// </summary>
    public class ConfigRead
    {
        #region 属性
        private static volatile ConfigRead _configRead = null;
        private readonly AppsettingsHelp _appsettingsHelp;

        /// <summary>
        /// ConnectionStrings
        /// </summary>
        private ConnectionStrings  AppsetConnection { get; set; }  
        
        private Dictionary<string, string> OperType { get; set; }

        /// <summary>
        /// Gets the instance.
        /// </summary>
        public static ConfigRead GetInstance
        {
            get
            {
                if (_configRead == null)
                {
                    lock (typeof(ConfigRead))
                    {
                        if (_configRead == null)
                        {
                            _configRead = new ConfigRead();
                        }
                    }
                }
                return _configRead;
            }
        }

        /// <summary>
        /// BaseInfoCache.json  sql
        /// </summary>
        private Dictionary<string, string> BaseSql { get; set; }
        #endregion

        private ConfigRead()
        {
            _appsettingsHelp = new AppsettingsHelp();
        }

        #region method


        /// <summary>
        /// ConnectionStrings 密码已解密
        /// </summary>
        /// <returns></returns>
        public ConnectionStrings GetAppsetConnection()
        {
            try
            {
                if (AppsetConnection == null)
                {
                    AppsetConnection = _appsettingsHelp.GetAppsettings<ConnectionStrings>("ConnectionStrings");
                    var  stringBuilder = new SqlConnectionStringBuilder(AppsetConnection.BaseDBContext);
                    stringBuilder.Password = Encryption.Decrypt(stringBuilder.Password);
                    AppsetConnection.BaseDBContext= stringBuilder.ConnectionString;
                    if (!string.IsNullOrEmpty(AppsetConnection.AopAllowed))
                    {
                        var temp = AppsetConnection.AopAllowed.Split(',', StringSplitOptions.RemoveEmptyEntries);
                        AppsetConnection.Allowed = temp;
                    }
                }
            }
            catch
            {
                throw new Exception("ConfigRead 类 ，GetAppsetConnection 方法读取数据库连接失败");
            }
            return AppsetConnection;
        }



        /// <summary>
        /// OperLogFilter  OperType
        /// </summary>
        /// <returns></returns>
        public Dictionary<string, string> GetOperType()
        {
            if (OperType == null)
            {
                OperType = new Dictionary<string, string>
                {
                    {"Index", "查看"},
                    {"Ins", "增加"},
                    {"Upd", "更新"},
                    {"DelByIds", "删除"},
                    {"InsDesc", "增加"},
                    {"UpdDesc", "更新"},
                    {"DelByIdsDesc", "删除"},
                };
            }
            return OperType;
        }


        #region  BaseInfoCache
        /// <summary>
        /// GetBaseInfoSql
        /// </summary>
        /// <returns></returns>
        public Dictionary<string, string> GetBaseInfoSql()
        {
            if (BaseSql == null || BaseSql.Count == 0)
            {
                BaseSql = new Dictionary<string, string>();
                string filePath = Path.Combine(AppContext.BaseDirectory, "BaseInfoCache.json");
                string content = ReadFileString(filePath);
                var tempData = JsonHelper.JsonConvertObject<BaseInfoCls>(content);
                for (int i = 0; i < tempData.BaseInfo.Count; i++)
                {
                    BaseSql.Add(tempData.BaseInfo[i].Key, tempData.BaseInfo[i].Sql);
                }
            }
            return BaseSql;
        }


        /// <summary>
        /// 读取文件 返回string
        /// </summary>
        protected string ReadFileString(string filePath)
        {
            string content = "";
            using (StreamReader sr = new(filePath, Encoding.Default))
            {
                content = sr.ReadToEnd();
            }
            return content;
        } 
        #endregion


        #endregion
    }

    /// <summary>
    /// appsettings.json  ConnectionStrings 节点类
    /// </summary>
    public class ConnectionStrings
    {
        public string BaseDBContext { get; set; }

        public string InterfaceDBContext { get; set; }

        public string RedisIp { get; set; }

        public int RedisDb { get; set; }

        public int HttpWebPort { get; set; }

        public int HttpsWebPort { get; set; }

        public string LoginTitle { get; set; }

        public string FaceBaseUrl { get; set; }


        public string EmailUser { get; set; }
        public string EmailPassword { get; set; }
        public string EmailServer { get; set; }
        public string FileUrl { get; set; }

        public string SendEmailTime { get; set; }
        public string CerPwd { get; set; }

        public string CerPath { get; set; }

        /// <summary>
        /// AOP 不拦截
        /// </summary>
        public string AopAllowed { get; set; }

        public string[] Allowed { get; set; }
    }

    #region BaseInfoCache.json 缓存类
    internal class BaseInfoCls
    {
        /// <summary>
        /// 
        /// </summary>
        public List<BaseInfoItem> BaseInfo { get; set; }
    }

    internal class BaseInfoItem
    {
        /// <summary>
        /// 
        /// </summary>
        public string Key { get; set; }
        /// <summary>
        /// 
        /// </summary>
        public string Sql { get; set; }
    } 
    #endregion
}