dengjunjie
2025-03-12 f43b7df8400f4fcffc9f19dca0888d61e2b33d5f
ÏîÄ¿´úÂë/WMS/WIDESEA_WMSServer/WIDESEA_Core/BaseRepository/IRepository.cs
@@ -7,6 +7,7 @@
using System.Linq.Expressions;
using System.Text;
using System.Threading.Tasks;
using WIDESEA_Core.Enums;
namespace WIDESEA_Core.BaseRepository
{
@@ -23,12 +24,16 @@
        /// <returns>查询结果</returns>
        TEntity QureyDataById(object id);
        Task<TEntity> QureyDataByIdAsync(object id);
        /// <summary>
        /// é€šè¿‡ä¸»é”®æ•°ç»„查询数据
        /// </summary>
        /// <param name="lstIds">主键数组</param>
        /// <returns>查询结果集合</returns>
        List<TEntity> QureyDataByIds(object[] lstIds);
        Task<List<TEntity>> QureyDataByIdsAsync(object[] lstIds);
        /// <summary>
        /// é€šè¿‡ä¸»é”®é›†åˆæŸ¥è¯¢æ•°æ®
@@ -37,12 +42,16 @@
        /// <returns>查询结果集合</returns>
        List<TEntity> QureyDataByIds(List<object> lstIds);
        Task<List<TEntity>> QureyDataByIdsAsync(List<object> lstIds);
        /// <summary>
        /// æ·»åŠ å•æ¡æ•°æ®
        /// </summary>
        /// <param name="entity"></param>
        /// <returns>影响行数</returns>
        int AddData(TEntity entity);
        Task<int> AddDataAsync(TEntity entity);
        /// <summary>
        /// æ·»åŠ å¤šæ¡æ•°æ®
@@ -51,12 +60,20 @@
        /// <returns>影响行数</returns>
        int AddData(List<TEntity> listEntity);
        Task<int> AddDataAsync(List<TEntity> listEntity);
        /// <summary>
        /// é€šè¿‡ä¸»é”®åˆ é™¤æ•°æ®
        /// </summary>
        /// <param name="id">主键</param>
        /// <returns>删除结果</returns>
        bool DeleteDataById(object id);
        Task<bool> DeleteDataByIdAsync(object id);
        bool DeleteAndMoveIntoHty(TEntity entity, OperateType operateType);
        bool DeleteAndMoveIntoHty(List<TEntity> entities, OperateType operateType);
        /// <summary>
        /// é€šè¿‡ä¸»é”®æ•°æ®åˆ é™¤å¤šæ¡æ•°æ®
@@ -65,12 +82,16 @@
        /// <returns>删除结果</returns>
        bool DeleteDataByIds(object[] ids);
        Task<bool> DeleteDataByIdsAsync(object[] ids);
        /// <summary>
        /// é€šè¿‡å®žä½“数据删除数据
        /// </summary>
        /// <param name="ids">主键数组</param>
        /// <returns>删除结果</returns>
        bool DeleteData(TEntity entity);
        Task<bool> DeleteDataAsync(TEntity entity);
        /// <summary>
        /// é€šè¿‡å®žä½“集合数据删除数据
@@ -79,12 +100,16 @@
        /// <returns>删除结果</returns>
        bool DeleteData(List<TEntity> listEntity);
        Task<bool> DeleteDataAsync(List<TEntity> listEntity);
        /// <summary>
        /// æ›´æ–°å•条数据
        /// </summary>
        /// <param name="entity"></param>
        /// <returns></returns>
        bool UpdateData(TEntity entity);
        Task<bool> UpdateDataAsync(TEntity entity);
        /// <summary>
        /// æ›´æ–°å¤šæ¡æ•°æ®
@@ -93,6 +118,8 @@
        /// <returns></returns>
        bool UpdateData(List<TEntity> listEntity);
        Task<bool> UpdateDataAsync(List<TEntity> listEntity);
        /// <summary>
        /// æŒ‡å®šåˆ—更新数据
        /// </summary>
@@ -100,13 +127,17 @@
        /// <param name="lstColumns"></param>
        /// <param name="lstIgnoreColumns"></param>
        /// <returns></returns>
        bool UpdateData(TEntity entity, List<string> lstColumns, List<string> lstIgnoreColumns = null);
        bool UpdateData(TEntity entity, List<string> lstColumns, List<string>? lstIgnoreColumns = null);
        Task<bool> UpdateDataAsync(TEntity entity, List<string> lstColumns, List<string>? lstIgnoreColumns = null);
        /// <summary>
        /// æŸ¥è¯¢æ‰€æœ‰æ•°æ®
        /// </summary>
        /// <returns></returns>
        List<TEntity> QueryData();
        Task<List<TEntity>> QueryDataAsync();
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æ•°æ®
@@ -115,6 +146,8 @@
        /// <returns></returns>
        List<TEntity> QueryData(string where);
        Task<List<TEntity>> QueryDataAsync(string where);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æ•°æ®
        /// </summary>
@@ -122,9 +155,23 @@
        /// <returns></returns>
        List<TEntity> QueryData(Expression<Func<TEntity, bool>> whereExpression);
        Task<List<TEntity>> QueryDataAsync(Expression<Func<TEntity, bool>> whereExpression);
        TEntity QueryFirst(Expression<Func<TEntity, bool>> whereExpression);
        Task<TEntity> QueryFirstAsync(Expression<Func<TEntity, bool>> whereExpression);
        TResult QueryFirst<TResult>(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, TResult>> expression);
        Task<TResult> QueryFirstAsync<TResult>(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, TResult>> expression);
        TResult QueryFirst<TResult>(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, TResult>> expression, Dictionary<string, OrderByType> orderBy);
        Task<TResult> QueryFirstAsync<TResult>(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, TResult>> expression, Dictionary<string, OrderByType> orderBy);
        TEntity QueryFirst(Expression<Func<TEntity, bool>> whereExpression, Dictionary<string, OrderByType> orderBy);
        Task<TEntity> QueryFirstAsync(Expression<Func<TEntity, bool>> whereExpression, Dictionary<string, OrderByType> orderBy);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æ•°æ®å¹¶æŽ’序
@@ -132,7 +179,9 @@
        /// <param name="whereExpression"></param>
        /// <param name="orderByFields"></param>
        /// <returns></returns>
        List<TEntity> QueryData(Expression<Func<TEntity, bool>> whereExpression, string orderByFields);
        List<TEntity> QueryData(Expression<Func<TEntity, bool>> whereExpression, Dictionary<string, OrderByType> orderBy);
        Task<List<TEntity>> QueryDataAsync(Expression<Func<TEntity, bool>> whereExpression, string orderByFields);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æ•°æ®å¹¶æŽ’序
@@ -142,6 +191,8 @@
        /// <returns></returns>
        List<TEntity> QueryData(string where, Dictionary<string, OrderByType> orderBy);
        Task<List<TEntity>> QueryDataAsync(string where, Dictionary<string, OrderByType> orderBy);
        /// <summary>
        /// æŸ¥è¯¢æŒ‡å®šæ•°æ®å¯¹è±¡
        /// </summary>
@@ -149,6 +200,8 @@
        /// <param name="expression"></param>
        /// <returns></returns>
        List<TResult> QueryData<TResult>(Expression<Func<TEntity, TResult>> expression);
        Task<List<TResult>> QueryDataAsync<TResult>(Expression<Func<TEntity, TResult>> expression);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æŒ‡å®šæ•°æ®å¯¹è±¡
@@ -158,7 +211,9 @@
        /// <param name="whereExpression"></param>
        /// <param name="orderByFields"></param>
        /// <returns></returns>
        List<TResult> QueryData<TResult>(Expression<Func<TEntity, TResult>> expression, Expression<Func<TEntity, bool>> whereExpression, string orderByFields);
        List<TResult> QueryData<TResult>(Expression<Func<TEntity, TResult>> expression, Expression<Func<TEntity, bool>> whereExpression, string orderByFields = "");
        Task<List<TResult>> QueryDataAsync<TResult>(Expression<Func<TEntity, TResult>> expression, Expression<Func<TEntity, bool>> whereExpression, string orderByFields);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æ•°æ®å¹¶æŽ’序
@@ -169,6 +224,8 @@
        /// <returns></returns>
        List<TEntity> QueryData(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, object>> orderByExpression, bool isAsc = true);
        Task<List<TEntity>> QueryDataAsync(Expression<Func<TEntity, bool>> whereExpression, Expression<Func<TEntity, object>> orderByExpression, bool isAsc = true);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æ•°æ®å¹¶æŽ’序
        /// </summary>
@@ -177,13 +234,7 @@
        /// <returns></returns>
        List<TEntity> QueryData(string where, string orderByFields);
        /// <summary>
        /// åŽŸç”ŸSql语句查询数据
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        List<TEntity> QueryDataBySql(string sql, SugarParameter[] parameters = null);
        Task<List<TEntity>> QueryDataAsync(string where, string orderByFields);
        /// <summary>
        /// åŽŸç”ŸSql语句查询数据
@@ -191,9 +242,23 @@
        /// <param name="sql"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        List<dynamic> QueryDynamicDataBySql(string sql, SugarParameter[] parameters = null);
        List<TEntity> QueryDataBySql(string sql, SugarParameter[]? parameters = null);
        List<object> QueryObjectDataBySql(string sql, SugarParameter[] parameters = null);
        Task<List<TEntity>> QueryDataBySqlAsync(string sql, SugarParameter[]? parameters = null);
        /// <summary>
        /// åŽŸç”ŸSql语句查询数据
        /// </summary>
        /// <param name="sql"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        List<dynamic> QueryDynamicDataBySql(string sql, SugarParameter[]? parameters = null);
        Task<List<dynamic>> QueryDynamicDataBySqlAsync(string sql, SugarParameter[]? parameters = null);
        List<object> QueryObjectDataBySql(string sql, SugarParameter[]? parameters = null);
        Task<List<object>> QueryObjectDataBySqlAsync(string sql, SugarParameter[]? parameters = null);
        /// <summary>
        /// åŽŸç”ŸSql语句执行操作
@@ -201,7 +266,9 @@
        /// <param name="sql"></param>
        /// <param name="sqlParameters"></param>
        /// <returns></returns>
        public int ExecuteSqlCommand(string sql, params SqlParameter[] sqlParameters);
        int ExecuteSqlCommand(string sql, params SqlParameter[] sqlParameters);
        Task<int> ExecuteSqlCommandAsync(string sql, params SqlParameter[] sqlParameters);
        /// <summary>
        /// åŽŸç”ŸSql语句查询数据
@@ -209,7 +276,9 @@
        /// <param name="sql"></param>
        /// <param name="parameters"></param>
        /// <returns></returns>
        DataTable QueryTable(string sql, SugarParameter[] parameters = null);
        DataTable QueryTable(string sql, SugarParameter[]? parameters = null);
        Task<DataTable> QueryTableAsync(string sql, SugarParameter[]? parameters = null);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æ•°æ®æŒ‡å®šæ•°é‡çš„行
@@ -220,6 +289,8 @@
        /// <returns></returns>
        List<TEntity> QueryData(Expression<Func<TEntity, bool>> whereExpression, int top, string orderByFields);
        Task<List<TEntity>> QueryDataAsync(Expression<Func<TEntity, bool>> whereExpression, int top, string orderByFields);
        /// <summary>
        /// æ¡ä»¶æŸ¥è¯¢æŒ‡å®šæ•°é‡çš„行
        /// </summary>
@@ -228,6 +299,8 @@
        /// <param name="orderByFields"></param>
        /// <returns></returns>
        List<TEntity> QueryData(string where, int top, string orderByFields);
        Task<List<TEntity>> QueryDataAsync(string where, int top, string orderByFields);
        /// <summary>
        /// åˆ†é¡µæŸ¥è¯¢
@@ -239,6 +312,8 @@
        /// <returns></returns>
        List<TEntity> QueryData(Expression<Func<TEntity, bool>> whereExpression, int pageIndex, int pageSize, string orderByFields);
        Task<List<TEntity>> QueryDataAsync(Expression<Func<TEntity, bool>> whereExpression, int pageIndex, int pageSize, string orderByFields);
        /// <summary>
        /// åˆ†é¡µæŸ¥è¯¢
        /// </summary>
@@ -249,6 +324,8 @@
        /// <returns></returns>
        List<TEntity> QueryData(string where, int pageIndex, int pageSize, string orderByFields);
        Task<List<TEntity>> QueryDataAsync(string where, int pageIndex, int pageSize, string orderByFields);
        /// <summary>
        /// åˆ†é¡µæŸ¥è¯¢
        /// </summary>
@@ -257,7 +334,7 @@
        /// <param name="pageSize"></param>
        /// <param name="orderByFields"></param>
        /// <returns></returns>
        PageGridData<TEntity> QueryPage(Expression<Func<TEntity, bool>> whereExpression, int pageIndex, int pageSize, string orderByFields = null);
        PageGridData<TEntity> QueryPage(Expression<Func<TEntity, bool>> whereExpression, int pageIndex, int pageSize, string? orderByFields = null);
        /// <summary>
        /// åˆ†é¡µæŸ¥è¯¢
@@ -284,6 +361,20 @@
        List<TResult> QueryTabs<T, T2, TResult>(
            Expression<Func<T, T2, object[]>> joinExpression,
            Expression<Func<T, T2, TResult>> selectExpression,
           Expression<Func<T, T2, bool>> whereExpressionT1,
            Expression<Func<TResult, bool>> whereExpression);
        List<TResult> QueryTabs<T, T2, TResult>(
         Expression<Func<T, T2, bool>> joinExpression,
         Expression<Func<T, T2, TResult>> selectExpression,
         Expression<Func<T, bool>> whereExpressionT1,
         Expression<Func<T2, bool>> whereExpressionT2,
         Expression<Func<TResult, bool>> whereExpression);
        Task<List<TResult>> QueryTabsAsync<T, T2, TResult>(
            Expression<Func<T, T2, object[]>> joinExpression,
            Expression<Func<T, T2, TResult>> selectExpression,
            Expression<Func<TResult, bool>> whereExpression);
        /// <summary>
@@ -305,7 +396,7 @@
            Expression<Func<TResult, bool>> whereExpression,
            int pageIndex = 1,
            int pageSize = 20,
            string orderByFields = null);
            string? orderByFields = null);
        /// <summary>
        /// ä¸¤è¡¨è”合查询-分页-分组
@@ -328,7 +419,7 @@
            Expression<Func<T, object>> groupExpression,
            int pageIndex = 1,
            int pageSize = 20,
            string orderByFields = null);
            string? orderByFields = null);
        //List<TResult> QueryMuch<T, T2, T3, TResult>(
        //    Expression<Func<T, T2, T3, object[]>> joinExpression,
@@ -336,4 +427,4 @@
        //    Expression<Func<T, T2, T3, bool>> whereLambda = null) where T : class, new();
        //Task<PageModel<TEntity>> QueryPage(PaginationModel pagination);
    }
}
}