RuoVea.ExSugar 6.0.10

RuoVea.ExSqlSugar

/* 打印sql语句*/ "PrintSql": true,

    private void SqlSugarConfigure(IServiceCollection services)
    {
        #region 配置sqlsuagr
        List<ConnectionConfig> connectConfigList = new List<ConnectionConfig>();
        //数据库序号从0开始,默认数据库为0
        var config= App.GetConfig<ConnectionDb>("ConnectionStrings");
        //默认数据库
        connectConfigList.Add(new ConnectionConfig
        {
            ConnectionString = config.DefaultDbString,
            DbType = (DbType)Convert.ToInt32(Enum.Parse(typeof(DbType), config.DefaultDbType)),
            IsAutoCloseConnection = true,
            ConfigId = config.DefaultDbNumber,
            InitKeyType = InitKeyType.Attribute
        });
        //业务数据库集合
        foreach (var item in config.DbConfigs)
		{
            connectConfigList.Add(new ConnectionConfig
            {
                ConnectionString = item.DbString,
                DbType = (DbType)Convert.ToInt32(Enum.Parse(typeof(DbType), item.DbType)),
                IsAutoCloseConnection = true,
                ConfigId = item.DbNumber,
                InitKeyType = InitKeyType.Attribute
            });
        }
        services.AddSqlSugar(connectConfigList.ToArray()
            , db =>
            {
                db.Aop.OnLogExecuting = (sql, pars) =>
                {
                    if (sql.StartsWith("SELECT"))
                    {
                        Console.ForegroundColor = ConsoleColor.Green;
                    }
                    if (sql.StartsWith("UPDATE") || sql.StartsWith("INSERT"))
                    {
                        Console.ForegroundColor = ConsoleColor.White;
                    }
                    if (sql.StartsWith("DELETE"))
                    {
                        Console.ForegroundColor = ConsoleColor.Blue;
                    }
                    //App.PrintToMiniProfiler("SqlSugar", "Info", sql + "\r\n" + db.Utilities.SerializeObject(pars.ToDictionary(it => it.ParameterName, it => it.Value)));
                    Console.WriteLine(sql + "\r\n\r\n" + SqlProfiler.ParameterFormat(sql, pars));
                    App.PrintToMiniProfiler("SqlSugar", "Info", SqlProfiler.ParameterFormat(sql, pars));
                };
                //执行超时时间
                db.Ado.CommandTimeOut = 30;
                //配置多租户全局过滤器
                db.QueryFilter.Add(new TableFilterItem<SysUser>(FilterExpression<SysUser>()));
                db.QueryFilter.Add(new TableFilterItem<SysOrg>(FilterExpression<SysOrg>()));
                db.QueryFilter.Add(new TableFilterItem<SysPos>(FilterExpression<SysPos>()));
                db.QueryFilter.Add(new TableFilterItem<SysRole>(FilterExpression<SysRole>()));
                db.QueryFilter.Add(new TableFilterItem<OnlineUser>(FilterExpression()));

                // 配置加删除全局过滤器
                db.QueryFilter.Add(new TableFilterItem<SysApp>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysCodeGen>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysCodeGenConfig>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysDictData>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysDictType>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysFile>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysMenu>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysNotice>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysOauthUser>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysOrg>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysPos>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysRole>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysTimer>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysUser>(it => it.IsDeleted == false));
                db.QueryFilter.Add(new TableFilterItem<SysTenant>(it => it.IsDeleted == false));
            });
        #endregion
    }

    /// <summary>
    /// 获取当前租户id
    /// </summary>
    /// <returns></returns>
    private object GetTenantId()
    {
        if (App.User == null) return null;
        return App.User.FindFirst(ClaimConst.TENANT_ID)?.Value;
    }

    /// <summary>
    /// 判断是不是超级管理员
    /// </summary>
    /// <returns></returns>
    private bool IsSuperAdmin()
    {
        if (App.User == null) return false;
        return App.User.FindFirst(ClaimConst.CLAINM_SUPERADMIN)?.Value == AdminType.SuperAdmin.GetHashCode().ToString();
    }

    /// <summary>
    /// 非超级管理员默认添加租户过滤
    /// </summary>
    /// <returns></returns>
    private Expression<Func<T, bool>> FilterExpression<T>() where T : DBEntityTenant
    {
        var superAdminViewAllData = Convert.ToBoolean(App.Configuration["SystemSettings:SuperAdminViewAllData"]);
        if (IsSuperAdmin() && superAdminViewAllData) return m => true;
        return m => m.TenantId == long.Parse(GetTenantId().ToString());
    }

    /// <summary>
    /// 非超级管理员默认添加租户过滤
    /// 在线用户比较特殊，数据库表格设计问题
    /// </summary>
    /// <returns></returns>
    private Expression<Func<OnlineUser, bool>> FilterExpression()
    {
        var superAdminViewAllData = Convert.ToBoolean(App.Configuration["SystemSettings:SuperAdminViewAllData"]);
        if (IsSuperAdmin() && superAdminViewAllData) return m => true;
        return m => m.TenantId == long.Parse(GetTenantId().ToString());
    }

/// <summary> /// SqlSugar 启动服务 /// </summary> public static class SqlsugarSetup { public static void AddSqlsugarServer(this IServiceCollection services) { if (services == null) throw new ArgumentNullException(nameof(services)); ConnectionDb config = (ConnectionDb)Appsettings.GetSection("ConnectionStrings").Get(typeof(ConnectionDb)); SqlSugarScope sqlSugar = new SqlSugarScope( SugarUtil.ConnectBuilder(config), db ⇒ { db.Aop.OnLogExecuting = (sql, pars) ⇒ SugarUtil.OnLogExecuting(sql, pars); //执行超时时间 db.Ado.CommandTimeOut = config.CommandTimeOut;

            //SQL执行完回调函数
            db.Aop.OnLogExecuted = (sql, pars) =>
            {
                //执行完可以输出SQL执行时间
                Console.Write($"SQL:{sql},\r\nTimeSpan:{db.Ado.SqlExecutionTime.TotalMilliseconds}ms\r\n");
            };
        });
        services.AddSingleton<ISqlSugarClient>(sqlSugar);//这边是SqlSugarScope用AddSingleton
    }

    /// <summary>
    /// SqlSugar.IOC注入
    /// </summary>
    /// <param name="services"></param>
    /// <param name="configuration"></param>
    public static void AddSqlsugarIocSetup(this IServiceCollection services)
    {
        if (services == null) throw new ArgumentNullException(nameof(services));

        var listConfig = new List<IocConfig>();
        ConnectionDb config = (ConnectionDb)Appsettings.GetSection("ConnectionStrings").Get(typeof(ConnectionDb));

        listConfig.Add(new IocConfig()
        {
            DbType = (IocDbType)Convert.ToInt32(Enum.Parse(typeof(IocDbType), config.DefaultDbType)),
            ConnectionString = config.DefaultDbString,
            IsAutoCloseConnection = true,
            ConfigId = config.DefaultDbNumber,
        });

        if (config.DbConfigs != null && config.DbConfigs.Count() > 0)
        {
            foreach (var item in config.DbConfigs)
            {
                listConfig.Add(new IocConfig()
                {
                    DbType = (IocDbType)Convert.ToInt32(Enum.Parse(typeof(IocDbType), item.DbType)),
                    ConnectionString = item.DbString,
                    IsAutoCloseConnection = true,
                    ConfigId = item.DbNumber,
                });
            }
        }
        services.AddSqlSugar(listConfig);

        //配置参数
        services.ConfigurationSugar(db =>
        {
            db.Aop.OnLogExecuting = (sql, pars) => SugarUtil.OnLogExecuting(sql, pars);

            if (config.DbConfigs != null && config.DbConfigs.Count() > 0)
            {
                foreach (var item in config.DbConfigs)
                {
                    db.GetConnection(item.DbNumber).Aop.OnLogExecuting = (sql, pars) => SugarUtil.OnLogExecuting(sql, pars);
                }
            }
        });
    }

}