diff --git a/src/Infrastructure/Repository/IRepositoryBase.cs b/src/Infrastructure/Repository/IRepositoryBase.cs
new file mode 100644
index 0000000..78f47f6
--- /dev/null
+++ b/src/Infrastructure/Repository/IRepositoryBase.cs
@@ -0,0 +1,30 @@
+using System.Linq.Expressions;
+using SqlSugar;
+
+namespace Infrastructure.Repository;
+
+public interface IRepositoryBase<T> where T : class, new()
+{
+    ISqlSugarClient DbContext { get; }
+
+    Task<T?> GetByIdAsync(long id);
+
+    Task<List<T?>> GetAllAsync();
+
+    Task<T?> GetFirstByExpressionAsync(Expression<Func<T, bool>> expression);
+
+    Task<long> AddSnowflakeAsync(T entity);
+
+    Task<IList<long>> AddSnowflakesAsync(IList<T> entities);
+
+    Task<PageData<T?>> QueryPageAsync(Expression<Func<T, bool>>? whereExpression, int pageIndex = 1, int pageSize = 20,
+        Expression<Func<T, object>>? orderExpression = null, OrderByType orderByType = OrderByType.Asc);
+
+    Task<bool> UpdateColumnsAsync(T entity, Expression<Func<T, object>> expression);
+
+    Task<bool> DeleteByIdAsync(long id);
+
+    Task<bool> DeleteAsync(T entity);
+
+    Task<bool> DeletedByExpressionAsync(Expression<Func<T, bool>> expression);
+}
\ No newline at end of file
diff --git a/src/Infrastructure/Repository/RepositoryBase.cs b/src/Infrastructure/Repository/RepositoryBase.cs
new file mode 100644
index 0000000..38a1b86
--- /dev/null
+++ b/src/Infrastructure/Repository/RepositoryBase.cs
@@ -0,0 +1,68 @@
+using System.Linq.Expressions;
+using SqlSugar;
+using SqlSugar.Extensions;
+
+namespace Infrastructure.Repository;
+
+public class RepositoryBase<T>(ISqlSugarClient context) : IRepositoryBase<T> where T : class, new()
+{
+    public ISqlSugarClient DbContext => context;
+
+    public async Task<T?> GetByIdAsync(long id)
+    {
+        return await context.Queryable<T>().InSingleAsync(id);
+    }
+
+    public async Task<long> AddSnowflakeAsync(T entity)
+    {
+        return await context.Insertable<T>(entity).ExecuteReturnSnowflakeIdAsync();
+    }
+
+    public async Task<IList<long>> AddSnowflakesAsync(IList<T> entities)
+    {
+        return await context.Insertable<T>(entities).ExecuteReturnSnowflakeIdListAsync();
+    }
+
+    public async Task<PageData<T?>> QueryPageAsync(Expression<Func<T, bool>>? whereExpression, int pageIndex = 1,
+        int pageSize = 20,
+        Expression<Func<T, object>>? orderExpression = null, OrderByType orderByType = OrderByType.Asc)
+    {
+        RefAsync<int> totalCount = 0;
+        var list = await context.Queryable<T>()
+            .OrderByIF(orderExpression != null, orderExpression, orderByType)
+            .WhereIF(whereExpression != null, whereExpression)
+            .ToPageListAsync(pageIndex, pageSize, totalCount);
+        var pageCount = Math.Ceiling(totalCount.ObjToDecimal() / pageSize.ObjToDecimal()).ObjToInt();
+        return new PageData<T?>(pageIndex, pageCount, totalCount, pageSize, list);
+    }
+
+    public async Task<List<T?>> GetAllAsync()
+    {
+        return await context.Queryable<T?>().ToListAsync();
+    }
+
+    public async Task<T?> GetFirstByExpressionAsync(Expression<Func<T, bool>> expression)
+    {
+        return await context.Queryable<T>().Where(expression).FirstAsync();
+    }
+
+    public async Task<bool> UpdateColumnsAsync(T entity, Expression<Func<T, object>> expression)
+    {
+        return await context.Updateable(entity).UpdateColumns(expression).ExecuteCommandHasChangeAsync();
+    }
+
+    public async Task<bool> DeleteByIdAsync(long id)
+    {
+        return await context.Deleteable<T>().In(id).ExecuteCommandHasChangeAsync();
+    }
+
+    public async Task<bool> DeleteAsync(T entity)
+    {
+        return await context.Deleteable(entity).ExecuteCommandHasChangeAsync();
+    }
+
+    public async Task<bool> DeletedByExpressionAsync(Expression<Func<T, bool>> expression)
+    {
+        return await context.Deleteable<T>().Where(expression).ExecuteCommandHasChangeAsync();
+    }
+}
\ No newline at end of file