// Admin.NET 项目的版æƒã€å•†æ ‡ã€ä¸“利和其他相关æƒåˆ©å‡å—ç›¸åº”æ³•å¾‹æ³•è§„çš„ä¿æŠ¤ã€‚ä½¿ç”¨æœ¬é¡¹ç›®åº”éµå®ˆç›¸å…³æ³•律法规和许å¯è¯çš„è¦æ±‚。 // // 本项目主è¦éµå¾ª MIT 许å¯è¯å’Œ Apache 许å¯è¯ï¼ˆç‰ˆæœ¬ 2.0)进行分å‘和使用。许å¯è¯ä½äºŽæºä»£ç æ ‘æ ¹ç›®å½•ä¸çš„ LICENSE-MIT å’Œ LICENSE-APACHE 文件。 // // ä¸å¾—利用本项目从事å±å®³å›½å®¶å®‰å…¨ã€æ‰°ä¹±ç¤¾ä¼šç§©åºã€ä¾µçŠ¯ä»–äººåˆæ³•æƒç›Šç‰æ³•å¾‹æ³•è§„ç¦æ¢çš„æ´»åЍï¼ä»»ä½•基于本项目二次开å‘è€Œäº§ç”Ÿçš„ä¸€åˆ‡æ³•å¾‹çº çº·å’Œè´£ä»»ï¼Œæˆ‘ä»¬ä¸æ‰¿æ‹…ä»»ä½•è´£ä»»ï¼ using MapsterMapper; namespace Admin.NET.Core; public static class RepositoryExtension { /// <summary> /// 实体å‡åˆ 除 _rep.FakeDelete(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <returns></returns> public static int FakeDelete<T>(this ISugarRepository repository, T entity) where T : EntityBase, new() { return repository.Context.FakeDelete(entity); } /// <summary> /// 实体å‡åˆ 除 db.FakeDelete(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <returns></returns> public static int FakeDelete<T>(this ISqlSugarClient db, T entity) where T : EntityBase, new() { return db.Updateable(entity).AS().ReSetValue(x => { x.IsDelete = true; }) .IgnoreColumns(ignoreAllNullColumns: true) .EnableDiffLogEvent() // 记录差异日志 .UpdateColumns(x => new { x.IsDelete, x.UpdateTime, x.UpdateUserId }) // å…è®¸æ›´æ–°çš„å—æ®µ-AOP拦截自动设置UpdateTimeã€UpdateUserId .ExecuteCommand(); } /// <summary> /// å®žä½“é›†åˆæ‰¹é‡å‡åˆ 除 _rep.FakeDelete(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <returns></returns> public static int FakeDelete<T>(this ISugarRepository repository, List<T> entity) where T : EntityBase, new() { return repository.Context.FakeDelete(entity); } /// <summary> /// å®žä½“é›†åˆæ‰¹é‡å‡åˆ 除 db.FakeDelete(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <returns></returns> public static int FakeDelete<T>(this ISqlSugarClient db, List<T> entity) where T : EntityBase, new() { return db.Updateable(entity).AS().ReSetValue(x => { x.IsDelete = true; }) .IgnoreColumns(ignoreAllNullColumns: true) .EnableDiffLogEvent() // 记录差异日志 .UpdateColumns(x => new { x.IsDelete, x.UpdateTime, x.UpdateUserId }) // å…è®¸æ›´æ–°çš„å—æ®µ-AOP拦截自动设置UpdateTimeã€UpdateUserId .ExecuteCommand(); } /// <summary> /// 实体å‡åˆ é™¤å¼‚æ¥ _rep.FakeDeleteAsync(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <returns></returns> public static Task<int> FakeDeleteAsync<T>(this ISugarRepository repository, T entity) where T : EntityBase, new() { return repository.Context.FakeDeleteAsync(entity); } /// <summary> /// 实体å‡åˆ 除 db.FakeDelete(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <returns></returns> public static Task<int> FakeDeleteAsync<T>(this ISqlSugarClient db, T entity) where T : EntityBase, new() { return db.Updateable(entity).AS().ReSetValue(x => { x.IsDelete = true; }) .IgnoreColumns(ignoreAllNullColumns: true) .EnableDiffLogEvent() // 记录差异日志 .UpdateColumns(x => new { x.IsDelete, x.UpdateTime, x.UpdateUserId }) // å…è®¸æ›´æ–°çš„å—æ®µ-AOP拦截自动设置UpdateTimeã€UpdateUserId .ExecuteCommandAsync(); } /// <summary> /// å®žä½“é›†åˆæ‰¹é‡å‡åˆ é™¤å¼‚æ¥ _rep.FakeDeleteAsync(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <returns></returns> public static Task<int> FakeDeleteAsync<T>(this ISugarRepository repository, List<T> entity) where T : EntityBase, new() { return repository.Context.FakeDeleteAsync(entity); } /// <summary> /// å®žä½“é›†åˆæ‰¹é‡å‡åˆ 除 db.FakeDelete(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <returns></returns> public static Task<int> FakeDeleteAsync<T>(this ISqlSugarClient db, List<T> entity) where T : EntityBase, new() { return db.Updateable(entity).AS().ReSetValue(x => { x.IsDelete = true; }) .IgnoreColumns(ignoreAllNullColumns: true) .EnableDiffLogEvent() // 记录差异日志 .UpdateColumns(x => new { x.IsDelete, x.UpdateTime, x.UpdateUserId }) // å…è®¸æ›´æ–°çš„å—æ®µ-AOP拦截自动设置UpdateTimeã€UpdateUserId .ExecuteCommandAsync(); } /// <summary> /// æŽ’åºæ–¹å¼(默认é™åº) /// </summary> /// <param name="queryable"></param> /// <param name="pageInput"> </param> /// <param name="prefix"> </param> /// <param name="defaultSortField"> 默认排åºå—段 </param> /// <param name="descSort"> 是å¦é™åº </param> /// <returns> </returns> public static ISugarQueryable<T> OrderBuilder<T>(this ISugarQueryable<T> queryable, BasePageInput pageInput, string prefix = "", string defaultSortField = "Id", bool descSort = true) { // 约定默认æ¯å¼ 表都有IdæŽ’åº var orderStr = string.IsNullOrWhiteSpace(defaultSortField) ? "" : $"{prefix}{defaultSortField}" + (descSort ? " Desc" : " Asc"); TypeAdapterConfig typeAdapterConfig = new(); typeAdapterConfig.ForType<T, BasePageInput>().IgnoreNullValues(true); Mapper mapper = new(typeAdapterConfig); // 务必将mapper设为å•实例 var nowPagerInput = mapper.Map<BasePageInput>(pageInput); // æŽ’åºæ˜¯å¦å¯ç”¨-排åºå—段和排åºé¡ºåºéƒ½ä¸ºéžç©ºæ‰å¯ç”¨æŽ’åº if (!string.IsNullOrEmpty(nowPagerInput.Field) && !string.IsNullOrEmpty(nowPagerInput.Order)) { var col = queryable.Context.EntityMaintenance.GetEntityInfo<T>().Columns.FirstOrDefault(u => u.PropertyName.Equals(nowPagerInput.Field, StringComparison.CurrentCultureIgnoreCase)); orderStr = col != null ? $"{prefix}{col.DbColumnName} {(nowPagerInput.Order == nowPagerInput.DescStr ? "Desc" : "Asc")}" : $"{prefix}{nowPagerInput.Field} {(nowPagerInput.Order == nowPagerInput.DescStr ? "Desc" : "Asc")}"; } return queryable.OrderByIF(!string.IsNullOrWhiteSpace(orderStr), orderStr); } /// <summary> /// 更新实体并记录差异日志 _rep.UpdateWithDiffLog(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <param name="ignoreAllNullColumns"></param> /// <returns></returns> public static int UpdateWithDiffLog<T>(this ISugarRepository repository, T entity, bool ignoreAllNullColumns = true) where T : EntityBase, new() { return repository.Context.UpdateWithDiffLog(entity, ignoreAllNullColumns); } /// <summary> /// 更新实体并记录差异日志 _rep.UpdateWithDiffLog(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <param name="ignoreAllNullColumns"></param> /// <returns></returns> public static int UpdateWithDiffLog<T>(this ISqlSugarClient db, T entity, bool ignoreAllNullColumns = true) where T : EntityBase, new() { return db.Updateable(entity).AS() .IgnoreColumns(ignoreAllNullColumns: ignoreAllNullColumns) .EnableDiffLogEvent() .ExecuteCommand(); } /// <summary> /// 更新实体并记录差异日志 _rep.UpdateWithDiffLogAsync(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <param name="ignoreAllNullColumns"></param> /// <returns></returns> public static Task<int> UpdateWithDiffLogAsync<T>(this ISugarRepository repository, T entity, bool ignoreAllNullColumns = true) where T : EntityBase, new() { return repository.Context.UpdateWithDiffLogAsync(entity, ignoreAllNullColumns); } /// <summary> /// 更新实体并记录差异日志 _rep.UpdateWithDiffLogAsync(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <param name="ignoreAllNullColumns"></param> /// <returns></returns> public static Task<int> UpdateWithDiffLogAsync<T>(this ISqlSugarClient db, T entity, bool ignoreAllNullColumns = true) where T : EntityBase, new() { return db.Updateable(entity) .IgnoreColumns(ignoreAllNullColumns: ignoreAllNullColumns) .EnableDiffLogEvent() .ExecuteCommandAsync(); } /// <summary> /// 新增实体并记录差异日志 _rep.InsertWithDiffLog(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <returns></returns> public static int InsertWithDiffLog<T>(this ISugarRepository repository, T entity) where T : EntityBase, new() { return repository.Context.InsertWithDiffLog(entity); } /// <summary> /// 新增实体并记录差异日志 _rep.InsertWithDiffLog(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <returns></returns> public static int InsertWithDiffLog<T>(this ISqlSugarClient db, T entity) where T : EntityBase, new() { return db.Insertable(entity).AS().EnableDiffLogEvent().ExecuteCommand(); } /// <summary> /// 新增实体并记录差异日志 _rep.InsertWithDiffLogAsync(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="repository"></param> /// <param name="entity"></param> /// <returns></returns> public static Task<int> InsertWithDiffLogAsync<T>(this ISugarRepository repository, T entity) where T : EntityBase, new() { return repository.Context.InsertWithDiffLogAsync(entity); } /// <summary> /// 新增实体并记录差异日志 _rep.InsertWithDiffLog(entity) /// </summary> /// <typeparam name="T"></typeparam> /// <param name="db"></param> /// <param name="entity"></param> /// <returns></returns> public static Task<int> InsertWithDiffLogAsync<T>(this ISqlSugarClient db, T entity) where T : EntityBase, new() { return db.Insertable(entity).AS().EnableDiffLogEvent().ExecuteCommandAsync(); } /// <summary> /// 多库查询 /// </summary> /// <param name="queryable"></param> /// <returns> </returns> public static ISugarQueryable<T> AS<T>(this ISugarQueryable<T> queryable) { var info = GetTableInfo<T>(); return queryable.AS<T>($"{info.Item1}.{info.Item2}"); } /// <summary> /// 多库查询 /// </summary> /// <typeparam name="T"></typeparam> /// <typeparam name="T2"></typeparam> /// <param name="queryable"></param> /// <returns></returns> public static ISugarQueryable<T, T2> AS<T, T2>(this ISugarQueryable<T, T2> queryable) { var info = GetTableInfo<T2>(); return queryable.AS<T2>($"{info.Item1}.{info.Item2}"); } /// <summary> /// 多库更新 /// </summary> /// <param name="updateable"></param> /// <returns> </returns> public static IUpdateable<T> AS<T>(this IUpdateable<T> updateable) where T : EntityBase, new() { var info = GetTableInfo<T>(); return updateable.AS($"{info.Item1}.{info.Item2}"); } /// <summary> /// 多库新增 /// </summary> /// <param name="insertable"></param> /// <returns> </returns> public static IInsertable<T> AS<T>(this IInsertable<T> insertable) where T : EntityBase, new() { var info = GetTableInfo<T>(); return insertable.AS($"{info.Item1}.{info.Item2}"); } /// <summary> /// å¤šåº“åˆ é™¤ /// </summary> /// <param name="deleteable"></param> /// <returns> </returns> public static IDeleteable<T> AS<T>(this IDeleteable<T> deleteable) where T : EntityBase, new() { var info = GetTableInfo<T>(); return deleteable.AS($"{info.Item1}.{info.Item2}"); } /// <summary> /// æ ¹æ®å®žä½“类型获å–è¡¨ä¿¡æ¯ /// </summary> /// <typeparam name="T"></typeparam> /// <returns></returns> private static Tuple<string, string> GetTableInfo<T>() { var entityType = typeof(T); var attr = entityType.GetCustomAttribute<TenantAttribute>(); var configId = attr == null ? SqlSugarConst.MainConfigId : attr.configId.ToString(); var tableName = entityType.GetCustomAttribute<SugarTable>().TableName; return new Tuple<string, string>(configId, tableName); } /// <summary> /// ç¦ç”¨è¿‡æ»¤å™¨-é€‚ç”¨äºŽæ›´æ–°å’Œåˆ é™¤æ“作(åªå¯¹å½“å‰è¯·æ±‚æœ‰æ•ˆï¼Œç¦æ¢ä½¿ç”¨å¼‚æ¥ï¼‰ /// </summary> /// <param name="repository"></param> /// <param name="action">ç¦æ¢å¼‚æ¥</param> /// <returns></returns> public static void RunWithoutFilter(this ISugarRepository repository, Action action) { repository.Context.QueryFilter.ClearAndBackup(); // 清空并备份过滤器 action.Invoke(); repository.Context.QueryFilter.Restore(); // 还原过滤器 // 用例 //_rep.RunWithoutFilter(() => //{ // æ‰§è¡Œæ›´æ–°æˆ–è€…åˆ é™¤ // ç¦æ¢ä½¿ç”¨å¼‚æ¥å‡½æ•° //}); } /// <summary> /// 忽略租户 /// </summary> /// <param name="queryable"></param> /// <param name="ignore">是å¦å¿½ç•¥ 默认true</param> /// <returns> </returns> public static ISugarQueryable<T> IgnoreTenant<T>(this ISugarQueryable<T> queryable, bool ignore = true) { return ignore ? queryable.ClearFilter<ITenantIdFilter>() : queryable; } /// <summary> /// 导航+å表过滤 创建一个扩展函数,默认是Class䏿”¯æŒWhere /// </summary> /// <typeparam name="T"></typeparam> /// <param name="thisValue"></param> /// <param name="whereExpression"></param> /// <returns></returns> public static List<T> Where<T>(this T thisValue, Func<T, bool> whereExpression) where T : class, new() { return new List<T>() { thisValue }; } /// <summary> /// 导航+å表过滤 创建一个扩展函数,默认是Class䏿”¯æŒWhereIF /// </summary> /// <typeparam name="T"></typeparam> /// <param name="thisValue"></param> /// <param name="isWhere"></param> /// <param name="whereExpression"></param> /// <returns></returns> public static List<T> WhereIF<T>(this T thisValue, bool isWhere, Func<T, bool> whereExpression) where T : class, new() { return new List<T>() { thisValue }; } /// <summary> /// åªæ›´æ–°æŸäº›åˆ— /// </summary> /// <typeparam name="T"></typeparam> /// <typeparam name="R"></typeparam> /// <param name="updateable"></param> /// <returns></returns> public static IUpdateable<T> OnlyUpdateColumn<T, R>(this IUpdateable<T> updateable) where T : EntityBase, new() where R : class, new() { if (updateable.UpdateBuilder.UpdateColumns == null) updateable.UpdateBuilder.UpdateColumns = new List<string>(); foreach (PropertyInfo info in typeof(R).GetProperties()) { // åˆ¤æ–æ˜¯å¦æ˜¯ç›¸åŒå±žæ€§ if (typeof(T).GetProperty(info.Name) != null) updateable.UpdateBuilder.UpdateColumns.Add(info.Name); } return updateable; } }