| 12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142 |
- using AutoMapper.QueryableExtensions;
- using EFSecondLevelCache.Core;
- using Masuit.MyBlogs.Core.Infrastructure.Repository.Interface;
- using Masuit.MyBlogs.Core.Infrastructure.Services.Interface;
- using NinjaNye.SearchExtensions;
- using System;
- using System.Collections.Generic;
- using System.Data.SqlClient;
- using System.Linq;
- using System.Linq.Expressions;
- using System.Threading.Tasks;
- namespace Masuit.MyBlogs.Core.Infrastructure.Services
- {
- /// <summary>
- /// 业务层基类
- /// </summary>
- /// <typeparam name="T"></typeparam>
- public class BaseService<T> : IBaseService<T> where T : class, new()
- {
- public virtual IBaseRepository<T> BaseDal { get; set; }
- public BaseService(IBaseRepository<T> repository)
- {
- BaseDal = repository;
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<T> GetAll()
- {
- return BaseDal.GetAll();
- }
- /// <summary>
- /// 获取所有实体(不跟踪)
- /// </summary>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<T> GetAllNoTracking()
- {
- return BaseDal.GetAllNoTracking();
- }
- /// <summary>
- /// 从二级缓存获取所有实体
- /// </summary>
- /// <returns>还未执行的SQL语句</returns>
- public virtual EFCachedDbSet<T> GetAllFromL2Cache()
- {
- return BaseDal.GetAllFromL2Cache();
- }
- /// <summary>
- /// 从二级缓存获取所有实体
- /// </summary>
- /// <returns>还未执行的SQL语句</returns>
- public virtual EFCachedQueryable<T> GetAllFromL2CacheNoTracking()
- {
- return BaseDal.GetAllFromL2CacheNoTracking();
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TDto">映射实体</typeparam>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<TDto> GetAll<TDto>() where TDto : class
- {
- return BaseDal.GetAll<TDto>();
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TDto">映射实体</typeparam>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<TDto> GetAllFromL2Cache<TDto>() where TDto : class
- {
- return BaseDal.GetAllFromL2Cache<TDto>();
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IOrderedQueryable<T> GetAll<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.GetAll(orderby, isAsc);
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IOrderedQueryable<T> GetAllNoTracking<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.GetAllNoTracking(orderby, isAsc);
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<T> GetAllFromL2Cache<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.GetAllFromL2Cache(orderby, isAsc);
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<T> GetAllFromL2CacheNoTracking<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.GetAllFromL2CacheNoTracking(orderby, isAsc);
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <typeparam name="TDto">映射实体</typeparam>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<TDto> GetAll<TS, TDto>(Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
- {
- return BaseDal.GetAll<TS, TDto>(orderby, isAsc);
- }
- /// <summary>
- /// 获取所有实体
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <typeparam name="TDto">映射实体</typeparam>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<TDto> GetAllFromL2Cache<TS, TDto>(Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
- {
- return BaseDal.GetAllFromL2Cache<TS, TDto>(orderby, isAsc);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<T> LoadEntities(Expression<Func<T, bool>> @where)
- {
- return BaseDal.LoadEntities(where);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- IOrderedQueryable<T> IBaseService<T>.LoadEntities<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc)
- {
- return null;
- }
- /// <summary>
- /// 基本查询方法,获取一个被AutoMapper映射后的集合
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<TDto> LoadEntities<TDto>(Expression<Func<T, bool>> @where) where TDto : class
- {
- return BaseDal.LoadEntities<TDto>(where);
- }
- /// <summary>
- /// 基本查询方法,获取一个被AutoMapper映射后的集合
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <typeparam name="TDto">输出类型</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- /// <returns></returns>
- public virtual IQueryable<TDto> LoadEntities<TS, TDto>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
- {
- return BaseDal.LoadEntities<TS, TDto>(where, orderby, isAsc);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合,优先从二级缓存读取
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<T> LoadEntitiesFromL2Cache(Expression<Func<T, bool>> @where)
- {
- return BaseDal.LoadEntitiesFromL2Cache(where);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合,优先从二级缓存读取
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序方式</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<T> LoadEntitiesFromL2Cache<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.LoadEntitiesFromL2Cache(where, orderby, isAsc);
- }
- /// <summary>
- /// 基本查询方法,获取一个被AutoMapper映射后的集合,优先从二级缓存读取
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<TDto> LoadEntitiesFromL2Cache<TDto>(Expression<Func<T, bool>> @where) where TDto : class
- {
- return BaseDal.LoadEntitiesFromL2Cache<TDto>(where);
- }
- /// <summary>
- /// 基本查询方法,获取一个被AutoMapper映射后的集合,优先从二级缓存读取
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <typeparam name="TDto">输出类型</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序方式</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<TDto> LoadEntitiesFromL2Cache<TS, TDto>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
- {
- return BaseDal.LoadEntitiesFromL2Cache<TS, TDto>(where, orderby, isAsc);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合(不跟踪实体)
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<T> LoadEntitiesNoTracking(Expression<Func<T, bool>> @where)
- {
- return BaseDal.LoadEntitiesNoTracking(where);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合(不跟踪实体)
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序方式</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IOrderedQueryable<T> LoadEntitiesNoTracking<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.LoadEntitiesNoTracking(where, orderby, isAsc);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合,优先从二级缓存读取(不跟踪实体)
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>实体集合</returns>
- public virtual IEnumerable<T> LoadEntitiesFromL2CacheNoTracking(Expression<Func<T, bool>> @where)
- {
- return BaseDal.LoadEntitiesFromL2CacheNoTracking(where);
- }
- /// <summary>
- /// 基本查询方法,获取一个集合,优先从二级缓存读取(不跟踪实体)
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序方式</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<T> LoadEntitiesFromL2CacheNoTracking<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.LoadEntitiesFromL2CacheNoTracking(where, orderby, isAsc);
- }
- /// <summary>
- /// 获取第一条数据
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>实体</returns>
- public virtual T GetFirstEntity(Expression<Func<T, bool>> @where)
- {
- return BaseDal.GetFirstEntity(where);
- }
- /// <summary>
- /// 获取第一条数据
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>实体</returns>
- public virtual T GetFirstEntity<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.GetFirstEntity(where, orderby, isAsc);
- }
- /// <summary>
- /// 获取第一条被AutoMapper映射后的数据
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>实体</returns>
- public virtual TDto GetFirstEntity<TDto>(Expression<Func<T, bool>> @where) where TDto : class
- {
- return BaseDal.GetFirstEntity<TDto>(where);
- }
- /// <summary>
- /// 获取第一条被AutoMapper映射后的数据
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <typeparam name="TDto">映射实体</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>映射实体</returns>
- public virtual TDto GetFirstEntity<TS, TDto>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
- {
- return BaseDal.GetFirstEntity<TS, TDto>(where, orderby, isAsc);
- }
- /// <summary>
- /// 获取第一条数据
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>实体</returns>
- public virtual async Task<T> GetFirstEntityAsync<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return await BaseDal.GetFirstEntityAsync(where, orderby, isAsc);
- }
- /// <summary>
- /// 获取第一条数据,优先从缓存读取
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>实体</returns>
- public virtual async Task<T> GetFirstEntityAsync(Expression<Func<T, bool>> @where)
- {
- return await BaseDal.GetFirstEntityAsync(where);
- }
- /// <summary>
- /// 获取第一条数据(不跟踪实体)
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>实体</returns>
- public virtual T GetFirstEntityNoTracking(Expression<Func<T, bool>> @where)
- {
- return BaseDal.GetFirstEntityNoTracking(where);
- }
- /// <summary>
- /// 获取第一条数据(不跟踪实体)
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>实体</returns>
- public virtual T GetFirstEntityNoTracking<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.GetFirstEntityNoTracking(where, orderby, isAsc);
- }
- /// <summary>
- /// 获取第一条数据(异步,不跟踪实体)
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>实体</returns>
- public virtual async Task<T> GetFirstEntityNoTrackingAsync(Expression<Func<T, bool>> @where)
- {
- return await BaseDal.GetFirstEntityNoTrackingAsync(where);
- }
- /// <summary>
- /// 获取第一条数据(异步,不跟踪实体)
- /// </summary>
- /// <typeparam name="TS">排序</typeparam>
- /// <param name="where">查询条件</param>
- /// <param name="orderby">排序字段</param>
- /// <param name="isAsc">是否升序</param>
- /// <returns>实体</returns>
- public virtual async Task<T> GetFirstEntityNoTrackingAsync<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return await BaseDal.GetFirstEntityNoTrackingAsync(where, orderby, isAsc);
- }
- /// <summary>
- /// 根据ID找实体
- /// </summary>
- /// <param name="id">实体id</param>
- /// <returns>实体</returns>
- public virtual T GetById(object id)
- {
- return BaseDal.GetById(id);
- }
- /// <summary>
- /// 根据ID找实体(异步)
- /// </summary>
- /// <param name="id">实体id</param>
- /// <returns>实体</returns>
- public virtual async Task<T> GetByIdAsync(object id)
- {
- return await BaseDal.GetByIdAsync(id);
- }
- /// <summary>
- /// 高效分页查询方法
- /// </summary>
- /// <typeparam name="TS"></typeparam>
- /// <param name="pageIndex">第几页</param>
- /// <param name="pageSize">每页大小</param>
- /// <param name="totalCount">数据总数</param>
- /// <param name="where">where Lambda条件表达式</param>
- /// <param name="orderby">orderby Lambda条件表达式</param>
- /// <param name="isAsc">升序降序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<T> LoadPageEntities<TS>(int pageIndex, int pageSize, out int totalCount, Expression<Func<T, bool>> where, Expression<Func<T, TS>> orderby,
- bool isAsc = true)
- {
- return BaseDal.LoadPageEntities(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
- }
- /// <summary>
- /// 高效分页查询方法,取出被AutoMapper映射后的数据集合
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <typeparam name="TDto">映射实体</typeparam>
- /// <param name="pageIndex">第几页</param>
- /// <param name="pageSize">每页大小</param>
- /// <param name="totalCount">数据总数</param>
- /// <param name="where">where Lambda条件表达式</param>
- /// <param name="orderby">orderby Lambda条件表达式</param>
- /// <param name="isAsc">升序降序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<TDto> LoadPageEntities<TS, TDto>(int pageIndex, int pageSize, out int totalCount, Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc) where TDto : class
- {
- return BaseDal.LoadPageEntities<TS, TDto>(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
- }
- /// <summary>
- /// 高效分页查询方法,优先从二级缓存读取
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <param name="pageIndex">第几页</param>
- /// <param name="pageSize">每页大小</param>
- /// <param name="totalCount">数据总数</param>
- /// <param name="where">where Lambda条件表达式</param>
- /// <param name="orderby">orderby Lambda条件表达式</param>
- /// <param name="isAsc">升序降序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<T> LoadPageEntitiesFromL2Cache<TS>(int pageIndex, int pageSize, out int totalCount, Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.LoadPageEntitiesFromL2Cache(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
- }
- /// <summary>
- /// 高效分页查询方法,优先从二级缓存读取,取出被AutoMapper映射后的数据集合
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <typeparam name="TDto">映射实体</typeparam>
- /// <param name="pageIndex">第几页</param>
- /// <param name="pageSize">每页大小</param>
- /// <param name="totalCount">数据总数</param>
- /// <param name="where">where Lambda条件表达式</param>
- /// <param name="orderby">orderby Lambda条件表达式</param>
- /// <param name="isAsc">升序降序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<TDto> LoadPageEntitiesFromL2Cache<TS, TDto>(int pageIndex, int pageSize, out int totalCount, Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc) where TDto : class
- {
- return BaseDal.LoadPageEntitiesFromL2Cache<TS, TDto>(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
- }
- /// <summary>
- /// 高效分页查询方法(不跟踪实体)
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <param name="pageIndex">第几页</param>
- /// <param name="pageSize">每页大小</param>
- /// <param name="totalCount">数据总数</param>
- /// <param name="where">where Lambda条件表达式</param>
- /// <param name="orderby">orderby Lambda条件表达式</param>
- /// <param name="isAsc">升序降序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IQueryable<T> LoadPageEntitiesNoTracking<TS>(int pageIndex, int pageSize, out int totalCount, Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.LoadPageEntitiesNoTracking(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
- }
- /// <summary>
- /// 高效分页查询方法,优先从缓存读取(不跟踪实体)
- /// </summary>
- /// <typeparam name="TS">排序字段</typeparam>
- /// <param name="pageIndex">第几页</param>
- /// <param name="pageSize">每页大小</param>
- /// <param name="totalCount">数据总数</param>
- /// <param name="where">where Lambda条件表达式</param>
- /// <param name="orderby">orderby Lambda条件表达式</param>
- /// <param name="isAsc">升序降序</param>
- /// <returns>还未执行的SQL语句</returns>
- public virtual IEnumerable<T> LoadPageEntitiesFromL2CacheNoTracking<TS>(int pageIndex, int pageSize, out int totalCount, Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
- {
- return BaseDal.LoadPageEntitiesFromL2CacheNoTracking(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <typeparam name="TDto"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<TDto> SearchPage<TOrder, TDto>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = GetAllNoTracking().Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <typeparam name="TDto"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="where">其他条件</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<TDto> SearchPage<TOrder, TDto>(int page, int size, out int total, string[] keywords, Expression<Func<T, bool>> @where, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = LoadEntities(where).Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPage<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = GetAll().Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="where">其他条件</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPage<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, bool>> @where, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = LoadEntities(where).Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPageNotracking<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = GetAllNoTracking().Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="where">其他条件</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPageNotracking<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, bool>> @where, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = LoadEntitiesNoTracking(where).Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <typeparam name="TDto"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<TDto> SearchPageFromCache<TOrder, TDto>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = GetAllNoTracking().Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().Cacheable().ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <typeparam name="TDto"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="where">其他条件</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<TDto> SearchPageFromCache<TOrder, TDto>(int page, int size, out int total, string[] keywords, Expression<Func<T, bool>> @where, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = LoadEntities(where).Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().Cacheable().ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPageFromCache<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = GetAll().Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="where">其他条件</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPageFromCache<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, bool>> @where, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = LoadEntities(where).Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPageFromCacheNotracking<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = GetAllNoTracking().Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
- }
- /// <summary>
- /// 搜索
- /// </summary>
- /// <typeparam name="TOrder"></typeparam>
- /// <param name="page">第几页</param>
- /// <param name="size">页大小</param>
- /// <param name="total">总条数</param>
- /// <param name="keywords">关键词</param>
- /// <param name="where">其他条件</param>
- /// <param name="orderBy">排序字段</param>
- /// <param name="isAsc">升序排列?</param>
- /// <returns></returns>
- public List<T> SearchPageFromCacheNotracking<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, bool>> @where, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
- {
- var query = LoadEntitiesNoTracking(where).Search().Containing(keywords);
- total = query.Count();
- IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
- return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
- }
- /// <summary>
- /// 根据ID删除实体
- /// </summary>
- /// <param name="id">实体id</param>
- /// <returns>删除成功</returns>
- public virtual bool DeleteById(object id)
- {
- return BaseDal.DeleteById(id);
- }
- /// <summary>
- /// 根据ID删除实体并保存
- /// </summary>
- /// <param name="id">实体id</param>
- /// <returns>删除成功</returns>
- public virtual bool DeleteByIdSaved(object id)
- {
- BaseDal.DeleteById(id);
- return SaveChanges() > 0;
- }
- /// <summary>
- /// 根据ID删除实体并保存(异步)
- /// </summary>
- /// <param name="id">实体id</param>
- /// <returns>删除成功</returns>
- public virtual async Task<int> DeleteByIdSavedAsync(object id)
- {
- BaseDal.DeleteById(id);
- return await SaveChangesAsync();
- }
- /// <summary>
- /// 删除实体并保存
- /// </summary>
- /// <param name="t">需要删除的实体</param>
- /// <returns>删除成功</returns>
- public virtual bool DeleteEntity(T t)
- {
- return BaseDal.DeleteEntity(t);
- }
- /// <summary>
- /// 根据条件删除实体
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>删除成功</returns>
- public virtual int DeleteEntity(Expression<Func<T, bool>> @where)
- {
- return BaseDal.DeleteEntity(where);
- }
- /// <summary>
- /// 根据条件删除实体
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>删除成功</returns>
- public virtual int DeleteEntitySaved(Expression<Func<T, bool>> @where)
- {
- BaseDal.DeleteEntity(where);
- return SaveChanges();
- }
- /// <summary>
- /// 根据条件删除实体
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>删除成功</returns>
- public virtual async Task<int> DeleteEntitySavedAsync(Expression<Func<T, bool>> @where)
- {
- BaseDal.DeleteEntity(where);
- return await SaveChangesAsync();
- }
- /// <summary>
- /// 根据条件删除实体(异步)
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>删除成功</returns>
- public virtual async Task<int> DeleteEntityAsync(Expression<Func<T, bool>> @where)
- {
- return await BaseDal.DeleteEntityAsync(where);
- }
- /// <summary>
- /// 删除实体并保存
- /// </summary>
- /// <param name="t">需要删除的实体</param>
- /// <returns>删除成功</returns>
- public virtual bool DeleteEntitySaved(T t)
- {
- BaseDal.DeleteEntity(t);
- return SaveChanges() > 0;
- }
- /// <summary>
- /// 删除实体并保存(异步)
- /// </summary>
- /// <param name="t">需要删除的实体</param>
- /// <returns>删除成功</returns>
- public virtual async Task<int> DeleteEntitySavedAsync(T t)
- {
- BaseDal.DeleteEntity(t);
- return await SaveChangesAsync();
- }
- /// <summary>
- /// 更新实体
- /// </summary>
- /// <param name="t">更新后的实体</param>
- /// <returns>更新成功</returns>
- public virtual bool UpdateEntity(T t)
- {
- return BaseDal.UpdateEntity(t);
- }
- /// <summary>
- /// 更新实体并保存
- /// </summary>
- /// <param name="t">更新后的实体</param>
- /// <returns>更新成功</returns>
- public virtual bool UpdateEntitySaved(T t)
- {
- BaseDal.UpdateEntity(t);
- return SaveChanges() > 0;
- }
- /// <summary>
- /// 更新实体并保存(异步)
- /// </summary>
- /// <param name="t">更新后的实体</param>
- /// <returns>更新成功</returns>
- public virtual async Task<int> UpdateEntitySavedAsync(T t)
- {
- BaseDal.UpdateEntity(t);
- return await SaveChangesAsync();
- }
- /// <summary>
- /// 根据条件更新实体
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <param name="t">更新后的实体</param>
- /// <returns>更新成功</returns>
- public virtual int UpdateEntity(Expression<Func<T, bool>> @where, T t)
- {
- return BaseDal.UpdateEntity(where, t);
- }
- /// <summary>
- /// 根据条件更新实体(异步)
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <param name="t">更新后的实体</param>
- /// <returns>更新成功</returns>
- public virtual async Task<int> UpdateEntityAsync(Expression<Func<T, bool>> @where, T t)
- {
- return await BaseDal.UpdateEntityAsync(where, t);
- }
- /// <summary>
- /// 添加实体
- /// </summary>
- /// <param name="t">需要添加的实体</param>
- /// <returns>添加成功</returns>
- public virtual T AddEntity(T t)
- {
- return BaseDal.AddEntity(t);
- }
- /// <summary>
- /// 添加实体并保存
- /// </summary>
- /// <param name="t">需要添加的实体</param>
- /// <returns>添加成功</returns>
- public virtual T AddEntitySaved(T t)
- {
- T entity = BaseDal.AddEntity(t);
- bool b = SaveChanges() > 0;
- return b ? entity : null;
- }
- /// <summary>
- /// 添加实体并保存(异步)
- /// </summary>
- /// <param name="t">需要添加的实体</param>
- /// <returns>添加成功</returns>
- public virtual async Task<int> AddEntitySavedAsync(T t)
- {
- BaseDal.AddEntity(t);
- return await SaveChangesAsync();
- }
- /// <summary>
- /// 统一保存的方法
- /// </summary>
- /// <returns>受影响的行数</returns>
- public virtual int SaveChanges()
- {
- return BaseDal.SaveChanges();
- }
- /// <summary>
- /// 统一保存数据
- /// </summary>
- /// <returns>受影响的行数</returns>
- public virtual async Task<int> SaveChangesAsync()
- {
- return await BaseDal.SaveChangesAsync();
- }
- /// <summary>
- /// 判断实体是否在数据库中存在
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns>是否存在</returns>
- public virtual bool Any(Expression<Func<T, bool>> @where)
- {
- return BaseDal.Any(where);
- }
- /// <summary>
- /// 统计符合条件的个数
- /// </summary>
- /// <param name="where">查询条件</param>
- /// <returns></returns>
- public int Count(Expression<Func<T, bool>> @where)
- {
- return BaseDal.Count(where);
- }
- /// <summary>
- /// 删除多个实体
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>删除成功</returns>
- public virtual bool DeleteEntities(IEnumerable<T> list)
- {
- return BaseDal.DeleteEntities(list);
- }
- /// <summary>
- /// 删除多个实体并保存
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>删除成功</returns>
- public virtual bool DeleteEntitiesSaved(IEnumerable<T> list)
- {
- BaseDal.DeleteEntities(list);
- return SaveChanges() > 0;
- }
- /// <summary>
- /// 删除多个实体并保存(异步)
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>删除成功</returns>
- public virtual async Task<int> DeleteEntitiesSavedAsync(IEnumerable<T> list)
- {
- BaseDal.DeleteEntities(list);
- return await SaveChangesAsync();
- }
- /// <summary>
- /// 更新多个实体
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>更新成功</returns>
- public virtual bool UpdateEntities(IEnumerable<T> list)
- {
- return BaseDal.UpdateEntities(list);
- }
- /// <summary>
- /// 更新多个实体并保存
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>更新成功</returns>
- public virtual bool UpdateEntitiesSaved(IEnumerable<T> list)
- {
- BaseDal.UpdateEntities(list);
- return SaveChanges() > 0;
- }
- /// <summary>
- /// 更新多个实体并保存(异步)
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>更新成功</returns>
- public virtual async Task<int> UpdateEntitiesSavedAsync(IEnumerable<T> list)
- {
- BaseDal.UpdateEntities(list);
- return await SaveChangesAsync();
- }
- /// <summary>
- /// 添加多个实体并保存
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>添加成功</returns>
- public virtual IEnumerable<T> AddEntities(IList<T> list)
- {
- IEnumerable<T> entities = BaseDal.AddEntities(list);
- SaveChanges();
- return entities;
- }
- /// <summary>
- /// 添加多个实体并保存(异步)
- /// </summary>
- /// <param name="list">实体集合</param>
- /// <returns>添加成功</returns>
- public virtual async Task<IEnumerable<T>> AddEntitiesAsync(IList<T> list)
- {
- IEnumerable<T> entities = BaseDal.AddEntities(list);
- await SaveChangesAsync();
- return entities;
- }
- /// <summary>
- /// 执行查询语句
- /// </summary>
- /// <typeparam name="T"></typeparam>
- /// <param name="sql"></param>
- /// <param name="parameters">参数</param>
- /// <returns>泛型集合</returns>
- public virtual IQueryable<T> SqlQuery(string sql, params SqlParameter[] parameters)
- {
- return BaseDal.SqlQuery(sql, parameters);
- }
- /// <summary>
- /// 执行查询语句
- /// </summary>
- /// <typeparam name="TS"></typeparam>
- /// <param name="sql"></param>
- /// <param name="parameters">参数</param>
- /// <returns>泛型集合</returns>
- public virtual IEnumerable<TS> SqlQuery<TS>(string sql, object parameters = null)
- {
- return BaseDal.SqlQuery<TS>(sql, parameters);
- }
- /// <summary>
- /// 执行DML语句
- /// </summary>
- /// <param name="sql"></param>
- /// <param name="parameters"></param>
- public virtual void ExecuteSql(string sql, params SqlParameter[] parameters)
- {
- BaseDal.ExecuteSql(sql, parameters);
- }
- /// <summary>
- /// 批量添加实体
- /// </summary>
- /// <param name="list">需要添加的实体</param>
- public virtual void BulkInsert(IEnumerable<T> list)
- {
- BaseDal.BulkInsert(list);
- }
- /// <summary>
- /// 统一批量保存数据
- /// </summary>
- public virtual void BulkSaveChanges()
- {
- BaseDal.BulkSaveChanges();
- }
- }
- }
|