BaseService.cs 46 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142
  1. using AutoMapper.QueryableExtensions;
  2. using EFSecondLevelCache.Core;
  3. using Masuit.MyBlogs.Core.Infrastructure.Repository.Interface;
  4. using Masuit.MyBlogs.Core.Infrastructure.Services.Interface;
  5. using NinjaNye.SearchExtensions;
  6. using System;
  7. using System.Collections.Generic;
  8. using System.Data.SqlClient;
  9. using System.Linq;
  10. using System.Linq.Expressions;
  11. using System.Threading.Tasks;
  12. namespace Masuit.MyBlogs.Core.Infrastructure.Services
  13. {
  14. /// <summary>
  15. /// 业务层基类
  16. /// </summary>
  17. /// <typeparam name="T"></typeparam>
  18. public class BaseService<T> : IBaseService<T> where T : class, new()
  19. {
  20. public virtual IBaseRepository<T> BaseDal { get; set; }
  21. public BaseService(IBaseRepository<T> repository)
  22. {
  23. BaseDal = repository;
  24. }
  25. /// <summary>
  26. /// 获取所有实体
  27. /// </summary>
  28. /// <returns>还未执行的SQL语句</returns>
  29. public virtual IQueryable<T> GetAll()
  30. {
  31. return BaseDal.GetAll();
  32. }
  33. /// <summary>
  34. /// 获取所有实体(不跟踪)
  35. /// </summary>
  36. /// <returns>还未执行的SQL语句</returns>
  37. public virtual IQueryable<T> GetAllNoTracking()
  38. {
  39. return BaseDal.GetAllNoTracking();
  40. }
  41. /// <summary>
  42. /// 从二级缓存获取所有实体
  43. /// </summary>
  44. /// <returns>还未执行的SQL语句</returns>
  45. public virtual EFCachedDbSet<T> GetAllFromL2Cache()
  46. {
  47. return BaseDal.GetAllFromL2Cache();
  48. }
  49. /// <summary>
  50. /// 从二级缓存获取所有实体
  51. /// </summary>
  52. /// <returns>还未执行的SQL语句</returns>
  53. public virtual EFCachedQueryable<T> GetAllFromL2CacheNoTracking()
  54. {
  55. return BaseDal.GetAllFromL2CacheNoTracking();
  56. }
  57. /// <summary>
  58. /// 获取所有实体
  59. /// </summary>
  60. /// <typeparam name="TDto">映射实体</typeparam>
  61. /// <returns>还未执行的SQL语句</returns>
  62. public virtual IQueryable<TDto> GetAll<TDto>() where TDto : class
  63. {
  64. return BaseDal.GetAll<TDto>();
  65. }
  66. /// <summary>
  67. /// 获取所有实体
  68. /// </summary>
  69. /// <typeparam name="TDto">映射实体</typeparam>
  70. /// <returns>还未执行的SQL语句</returns>
  71. public virtual IEnumerable<TDto> GetAllFromL2Cache<TDto>() where TDto : class
  72. {
  73. return BaseDal.GetAllFromL2Cache<TDto>();
  74. }
  75. /// <summary>
  76. /// 获取所有实体
  77. /// </summary>
  78. /// <typeparam name="TS">排序</typeparam>
  79. /// <param name="orderby">排序字段</param>
  80. /// <param name="isAsc">是否升序</param>
  81. /// <returns>还未执行的SQL语句</returns>
  82. public virtual IOrderedQueryable<T> GetAll<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
  83. {
  84. return BaseDal.GetAll(orderby, isAsc);
  85. }
  86. /// <summary>
  87. /// 获取所有实体
  88. /// </summary>
  89. /// <typeparam name="TS">排序</typeparam>
  90. /// <param name="orderby">排序字段</param>
  91. /// <param name="isAsc">是否升序</param>
  92. /// <returns>还未执行的SQL语句</returns>
  93. public virtual IOrderedQueryable<T> GetAllNoTracking<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
  94. {
  95. return BaseDal.GetAllNoTracking(orderby, isAsc);
  96. }
  97. /// <summary>
  98. /// 获取所有实体
  99. /// </summary>
  100. /// <typeparam name="TS">排序</typeparam>
  101. /// <param name="orderby">排序字段</param>
  102. /// <param name="isAsc">是否升序</param>
  103. /// <returns>还未执行的SQL语句</returns>
  104. public virtual IEnumerable<T> GetAllFromL2Cache<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
  105. {
  106. return BaseDal.GetAllFromL2Cache(orderby, isAsc);
  107. }
  108. /// <summary>
  109. /// 获取所有实体
  110. /// </summary>
  111. /// <typeparam name="TS">排序</typeparam>
  112. /// <param name="orderby">排序字段</param>
  113. /// <param name="isAsc">是否升序</param>
  114. /// <returns>还未执行的SQL语句</returns>
  115. public virtual IEnumerable<T> GetAllFromL2CacheNoTracking<TS>(Expression<Func<T, TS>> @orderby, bool isAsc = true)
  116. {
  117. return BaseDal.GetAllFromL2CacheNoTracking(orderby, isAsc);
  118. }
  119. /// <summary>
  120. /// 获取所有实体
  121. /// </summary>
  122. /// <typeparam name="TS">排序</typeparam>
  123. /// <typeparam name="TDto">映射实体</typeparam>
  124. /// <param name="orderby">排序字段</param>
  125. /// <param name="isAsc">是否升序</param>
  126. /// <returns>还未执行的SQL语句</returns>
  127. public virtual IQueryable<TDto> GetAll<TS, TDto>(Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
  128. {
  129. return BaseDal.GetAll<TS, TDto>(orderby, isAsc);
  130. }
  131. /// <summary>
  132. /// 获取所有实体
  133. /// </summary>
  134. /// <typeparam name="TS">排序</typeparam>
  135. /// <typeparam name="TDto">映射实体</typeparam>
  136. /// <param name="orderby">排序字段</param>
  137. /// <param name="isAsc">是否升序</param>
  138. /// <returns>还未执行的SQL语句</returns>
  139. public virtual IEnumerable<TDto> GetAllFromL2Cache<TS, TDto>(Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
  140. {
  141. return BaseDal.GetAllFromL2Cache<TS, TDto>(orderby, isAsc);
  142. }
  143. /// <summary>
  144. /// 基本查询方法,获取一个集合
  145. /// </summary>
  146. /// <param name="where">查询条件</param>
  147. /// <returns>还未执行的SQL语句</returns>
  148. public virtual IQueryable<T> LoadEntities(Expression<Func<T, bool>> @where)
  149. {
  150. return BaseDal.LoadEntities(where);
  151. }
  152. /// <summary>
  153. /// 基本查询方法,获取一个集合
  154. /// </summary>
  155. /// <typeparam name="TS">排序</typeparam>
  156. /// <param name="where">查询条件</param>
  157. /// <param name="orderby">排序字段</param>
  158. /// <param name="isAsc">是否升序</param>
  159. /// <returns>还未执行的SQL语句</returns>
  160. IOrderedQueryable<T> IBaseService<T>.LoadEntities<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc)
  161. {
  162. return null;
  163. }
  164. /// <summary>
  165. /// 基本查询方法,获取一个被AutoMapper映射后的集合
  166. /// </summary>
  167. /// <param name="where">查询条件</param>
  168. /// <returns>还未执行的SQL语句</returns>
  169. public virtual IQueryable<TDto> LoadEntities<TDto>(Expression<Func<T, bool>> @where) where TDto : class
  170. {
  171. return BaseDal.LoadEntities<TDto>(where);
  172. }
  173. /// <summary>
  174. /// 基本查询方法,获取一个被AutoMapper映射后的集合
  175. /// </summary>
  176. /// <typeparam name="TS">排序字段</typeparam>
  177. /// <typeparam name="TDto">输出类型</typeparam>
  178. /// <param name="where">查询条件</param>
  179. /// <param name="orderby">排序字段</param>
  180. /// <param name="isAsc">是否升序</param>
  181. /// <returns>还未执行的SQL语句</returns>
  182. /// <returns></returns>
  183. public virtual IQueryable<TDto> LoadEntities<TS, TDto>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
  184. {
  185. return BaseDal.LoadEntities<TS, TDto>(where, orderby, isAsc);
  186. }
  187. /// <summary>
  188. /// 基本查询方法,获取一个集合,优先从二级缓存读取
  189. /// </summary>
  190. /// <param name="where">查询条件</param>
  191. /// <returns>还未执行的SQL语句</returns>
  192. public virtual IEnumerable<T> LoadEntitiesFromL2Cache(Expression<Func<T, bool>> @where)
  193. {
  194. return BaseDal.LoadEntitiesFromL2Cache(where);
  195. }
  196. /// <summary>
  197. /// 基本查询方法,获取一个集合,优先从二级缓存读取
  198. /// </summary>
  199. /// <typeparam name="TS">排序字段</typeparam>
  200. /// <param name="where">查询条件</param>
  201. /// <param name="orderby">排序方式</param>
  202. /// <param name="isAsc">是否升序</param>
  203. /// <returns>还未执行的SQL语句</returns>
  204. public virtual IEnumerable<T> LoadEntitiesFromL2Cache<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
  205. {
  206. return BaseDal.LoadEntitiesFromL2Cache(where, orderby, isAsc);
  207. }
  208. /// <summary>
  209. /// 基本查询方法,获取一个被AutoMapper映射后的集合,优先从二级缓存读取
  210. /// </summary>
  211. /// <param name="where">查询条件</param>
  212. /// <returns>还未执行的SQL语句</returns>
  213. public virtual IEnumerable<TDto> LoadEntitiesFromL2Cache<TDto>(Expression<Func<T, bool>> @where) where TDto : class
  214. {
  215. return BaseDal.LoadEntitiesFromL2Cache<TDto>(where);
  216. }
  217. /// <summary>
  218. /// 基本查询方法,获取一个被AutoMapper映射后的集合,优先从二级缓存读取
  219. /// </summary>
  220. /// <typeparam name="TS">排序字段</typeparam>
  221. /// <typeparam name="TDto">输出类型</typeparam>
  222. /// <param name="where">查询条件</param>
  223. /// <param name="orderby">排序方式</param>
  224. /// <param name="isAsc">是否升序</param>
  225. /// <returns>还未执行的SQL语句</returns>
  226. public virtual IEnumerable<TDto> LoadEntitiesFromL2Cache<TS, TDto>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
  227. {
  228. return BaseDal.LoadEntitiesFromL2Cache<TS, TDto>(where, orderby, isAsc);
  229. }
  230. /// <summary>
  231. /// 基本查询方法,获取一个集合(不跟踪实体)
  232. /// </summary>
  233. /// <param name="where">查询条件</param>
  234. /// <returns>还未执行的SQL语句</returns>
  235. public virtual IQueryable<T> LoadEntitiesNoTracking(Expression<Func<T, bool>> @where)
  236. {
  237. return BaseDal.LoadEntitiesNoTracking(where);
  238. }
  239. /// <summary>
  240. /// 基本查询方法,获取一个集合(不跟踪实体)
  241. /// </summary>
  242. /// <typeparam name="TS">排序字段</typeparam>
  243. /// <param name="where">查询条件</param>
  244. /// <param name="orderby">排序方式</param>
  245. /// <param name="isAsc">是否升序</param>
  246. /// <returns>还未执行的SQL语句</returns>
  247. public virtual IOrderedQueryable<T> LoadEntitiesNoTracking<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
  248. {
  249. return BaseDal.LoadEntitiesNoTracking(where, orderby, isAsc);
  250. }
  251. /// <summary>
  252. /// 基本查询方法,获取一个集合,优先从二级缓存读取(不跟踪实体)
  253. /// </summary>
  254. /// <param name="where">查询条件</param>
  255. /// <returns>实体集合</returns>
  256. public virtual IEnumerable<T> LoadEntitiesFromL2CacheNoTracking(Expression<Func<T, bool>> @where)
  257. {
  258. return BaseDal.LoadEntitiesFromL2CacheNoTracking(where);
  259. }
  260. /// <summary>
  261. /// 基本查询方法,获取一个集合,优先从二级缓存读取(不跟踪实体)
  262. /// </summary>
  263. /// <typeparam name="TS">排序字段</typeparam>
  264. /// <param name="where">查询条件</param>
  265. /// <param name="orderby">排序方式</param>
  266. /// <param name="isAsc">是否升序</param>
  267. /// <returns>还未执行的SQL语句</returns>
  268. public virtual IEnumerable<T> LoadEntitiesFromL2CacheNoTracking<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
  269. {
  270. return BaseDal.LoadEntitiesFromL2CacheNoTracking(where, orderby, isAsc);
  271. }
  272. /// <summary>
  273. /// 获取第一条数据
  274. /// </summary>
  275. /// <param name="where">查询条件</param>
  276. /// <returns>实体</returns>
  277. public virtual T GetFirstEntity(Expression<Func<T, bool>> @where)
  278. {
  279. return BaseDal.GetFirstEntity(where);
  280. }
  281. /// <summary>
  282. /// 获取第一条数据
  283. /// </summary>
  284. /// <typeparam name="TS">排序</typeparam>
  285. /// <param name="where">查询条件</param>
  286. /// <param name="orderby">排序字段</param>
  287. /// <param name="isAsc">是否升序</param>
  288. /// <returns>实体</returns>
  289. public virtual T GetFirstEntity<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
  290. {
  291. return BaseDal.GetFirstEntity(where, orderby, isAsc);
  292. }
  293. /// <summary>
  294. /// 获取第一条被AutoMapper映射后的数据
  295. /// </summary>
  296. /// <param name="where">查询条件</param>
  297. /// <returns>实体</returns>
  298. public virtual TDto GetFirstEntity<TDto>(Expression<Func<T, bool>> @where) where TDto : class
  299. {
  300. return BaseDal.GetFirstEntity<TDto>(where);
  301. }
  302. /// <summary>
  303. /// 获取第一条被AutoMapper映射后的数据
  304. /// </summary>
  305. /// <typeparam name="TS">排序</typeparam>
  306. /// <typeparam name="TDto">映射实体</typeparam>
  307. /// <param name="where">查询条件</param>
  308. /// <param name="orderby">排序字段</param>
  309. /// <param name="isAsc">是否升序</param>
  310. /// <returns>映射实体</returns>
  311. public virtual TDto GetFirstEntity<TS, TDto>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true) where TDto : class
  312. {
  313. return BaseDal.GetFirstEntity<TS, TDto>(where, orderby, isAsc);
  314. }
  315. /// <summary>
  316. /// 获取第一条数据
  317. /// </summary>
  318. /// <typeparam name="TS">排序</typeparam>
  319. /// <param name="where">查询条件</param>
  320. /// <param name="orderby">排序字段</param>
  321. /// <param name="isAsc">是否升序</param>
  322. /// <returns>实体</returns>
  323. public virtual async Task<T> GetFirstEntityAsync<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
  324. {
  325. return await BaseDal.GetFirstEntityAsync(where, orderby, isAsc);
  326. }
  327. /// <summary>
  328. /// 获取第一条数据,优先从缓存读取
  329. /// </summary>
  330. /// <param name="where">查询条件</param>
  331. /// <returns>实体</returns>
  332. public virtual async Task<T> GetFirstEntityAsync(Expression<Func<T, bool>> @where)
  333. {
  334. return await BaseDal.GetFirstEntityAsync(where);
  335. }
  336. /// <summary>
  337. /// 获取第一条数据(不跟踪实体)
  338. /// </summary>
  339. /// <param name="where">查询条件</param>
  340. /// <returns>实体</returns>
  341. public virtual T GetFirstEntityNoTracking(Expression<Func<T, bool>> @where)
  342. {
  343. return BaseDal.GetFirstEntityNoTracking(where);
  344. }
  345. /// <summary>
  346. /// 获取第一条数据(不跟踪实体)
  347. /// </summary>
  348. /// <typeparam name="TS">排序</typeparam>
  349. /// <param name="where">查询条件</param>
  350. /// <param name="orderby">排序字段</param>
  351. /// <param name="isAsc">是否升序</param>
  352. /// <returns>实体</returns>
  353. public virtual T GetFirstEntityNoTracking<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
  354. {
  355. return BaseDal.GetFirstEntityNoTracking(where, orderby, isAsc);
  356. }
  357. /// <summary>
  358. /// 获取第一条数据(异步,不跟踪实体)
  359. /// </summary>
  360. /// <param name="where">查询条件</param>
  361. /// <returns>实体</returns>
  362. public virtual async Task<T> GetFirstEntityNoTrackingAsync(Expression<Func<T, bool>> @where)
  363. {
  364. return await BaseDal.GetFirstEntityNoTrackingAsync(where);
  365. }
  366. /// <summary>
  367. /// 获取第一条数据(异步,不跟踪实体)
  368. /// </summary>
  369. /// <typeparam name="TS">排序</typeparam>
  370. /// <param name="where">查询条件</param>
  371. /// <param name="orderby">排序字段</param>
  372. /// <param name="isAsc">是否升序</param>
  373. /// <returns>实体</returns>
  374. public virtual async Task<T> GetFirstEntityNoTrackingAsync<TS>(Expression<Func<T, bool>> @where, Expression<Func<T, TS>> @orderby, bool isAsc = true)
  375. {
  376. return await BaseDal.GetFirstEntityNoTrackingAsync(where, orderby, isAsc);
  377. }
  378. /// <summary>
  379. /// 根据ID找实体
  380. /// </summary>
  381. /// <param name="id">实体id</param>
  382. /// <returns>实体</returns>
  383. public virtual T GetById(object id)
  384. {
  385. return BaseDal.GetById(id);
  386. }
  387. /// <summary>
  388. /// 根据ID找实体(异步)
  389. /// </summary>
  390. /// <param name="id">实体id</param>
  391. /// <returns>实体</returns>
  392. public virtual async Task<T> GetByIdAsync(object id)
  393. {
  394. return await BaseDal.GetByIdAsync(id);
  395. }
  396. /// <summary>
  397. /// 高效分页查询方法
  398. /// </summary>
  399. /// <typeparam name="TS"></typeparam>
  400. /// <param name="pageIndex">第几页</param>
  401. /// <param name="pageSize">每页大小</param>
  402. /// <param name="totalCount">数据总数</param>
  403. /// <param name="where">where Lambda条件表达式</param>
  404. /// <param name="orderby">orderby Lambda条件表达式</param>
  405. /// <param name="isAsc">升序降序</param>
  406. /// <returns>还未执行的SQL语句</returns>
  407. public virtual IQueryable<T> LoadPageEntities<TS>(int pageIndex, int pageSize, out int totalCount, Expression<Func<T, bool>> where, Expression<Func<T, TS>> orderby,
  408. bool isAsc = true)
  409. {
  410. return BaseDal.LoadPageEntities(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
  411. }
  412. /// <summary>
  413. /// 高效分页查询方法,取出被AutoMapper映射后的数据集合
  414. /// </summary>
  415. /// <typeparam name="TS">排序字段</typeparam>
  416. /// <typeparam name="TDto">映射实体</typeparam>
  417. /// <param name="pageIndex">第几页</param>
  418. /// <param name="pageSize">每页大小</param>
  419. /// <param name="totalCount">数据总数</param>
  420. /// <param name="where">where Lambda条件表达式</param>
  421. /// <param name="orderby">orderby Lambda条件表达式</param>
  422. /// <param name="isAsc">升序降序</param>
  423. /// <returns>还未执行的SQL语句</returns>
  424. 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
  425. {
  426. return BaseDal.LoadPageEntities<TS, TDto>(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
  427. }
  428. /// <summary>
  429. /// 高效分页查询方法,优先从二级缓存读取
  430. /// </summary>
  431. /// <typeparam name="TS">排序字段</typeparam>
  432. /// <param name="pageIndex">第几页</param>
  433. /// <param name="pageSize">每页大小</param>
  434. /// <param name="totalCount">数据总数</param>
  435. /// <param name="where">where Lambda条件表达式</param>
  436. /// <param name="orderby">orderby Lambda条件表达式</param>
  437. /// <param name="isAsc">升序降序</param>
  438. /// <returns>还未执行的SQL语句</returns>
  439. 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)
  440. {
  441. return BaseDal.LoadPageEntitiesFromL2Cache(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
  442. }
  443. /// <summary>
  444. /// 高效分页查询方法,优先从二级缓存读取,取出被AutoMapper映射后的数据集合
  445. /// </summary>
  446. /// <typeparam name="TS">排序字段</typeparam>
  447. /// <typeparam name="TDto">映射实体</typeparam>
  448. /// <param name="pageIndex">第几页</param>
  449. /// <param name="pageSize">每页大小</param>
  450. /// <param name="totalCount">数据总数</param>
  451. /// <param name="where">where Lambda条件表达式</param>
  452. /// <param name="orderby">orderby Lambda条件表达式</param>
  453. /// <param name="isAsc">升序降序</param>
  454. /// <returns>还未执行的SQL语句</returns>
  455. 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
  456. {
  457. return BaseDal.LoadPageEntitiesFromL2Cache<TS, TDto>(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
  458. }
  459. /// <summary>
  460. /// 高效分页查询方法(不跟踪实体)
  461. /// </summary>
  462. /// <typeparam name="TS">排序字段</typeparam>
  463. /// <param name="pageIndex">第几页</param>
  464. /// <param name="pageSize">每页大小</param>
  465. /// <param name="totalCount">数据总数</param>
  466. /// <param name="where">where Lambda条件表达式</param>
  467. /// <param name="orderby">orderby Lambda条件表达式</param>
  468. /// <param name="isAsc">升序降序</param>
  469. /// <returns>还未执行的SQL语句</returns>
  470. 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)
  471. {
  472. return BaseDal.LoadPageEntitiesNoTracking(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
  473. }
  474. /// <summary>
  475. /// 高效分页查询方法,优先从缓存读取(不跟踪实体)
  476. /// </summary>
  477. /// <typeparam name="TS">排序字段</typeparam>
  478. /// <param name="pageIndex">第几页</param>
  479. /// <param name="pageSize">每页大小</param>
  480. /// <param name="totalCount">数据总数</param>
  481. /// <param name="where">where Lambda条件表达式</param>
  482. /// <param name="orderby">orderby Lambda条件表达式</param>
  483. /// <param name="isAsc">升序降序</param>
  484. /// <returns>还未执行的SQL语句</returns>
  485. 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)
  486. {
  487. return BaseDal.LoadPageEntitiesFromL2CacheNoTracking(pageIndex, pageSize, out totalCount, where, orderby, isAsc);
  488. }
  489. /// <summary>
  490. /// 搜索
  491. /// </summary>
  492. /// <typeparam name="TOrder"></typeparam>
  493. /// <typeparam name="TDto"></typeparam>
  494. /// <param name="page">第几页</param>
  495. /// <param name="size">页大小</param>
  496. /// <param name="total">总条数</param>
  497. /// <param name="keywords">关键词</param>
  498. /// <param name="orderBy">排序字段</param>
  499. /// <param name="isAsc">升序排列?</param>
  500. /// <returns></returns>
  501. public List<TDto> SearchPage<TOrder, TDto>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
  502. {
  503. var query = GetAllNoTracking().Search().Containing(keywords);
  504. total = query.Count();
  505. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  506. return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().ToList();
  507. }
  508. /// <summary>
  509. /// 搜索
  510. /// </summary>
  511. /// <typeparam name="TOrder"></typeparam>
  512. /// <typeparam name="TDto"></typeparam>
  513. /// <param name="page">第几页</param>
  514. /// <param name="size">页大小</param>
  515. /// <param name="total">总条数</param>
  516. /// <param name="keywords">关键词</param>
  517. /// <param name="where">其他条件</param>
  518. /// <param name="orderBy">排序字段</param>
  519. /// <param name="isAsc">升序排列?</param>
  520. /// <returns></returns>
  521. 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)
  522. {
  523. var query = LoadEntities(where).Search().Containing(keywords);
  524. total = query.Count();
  525. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  526. return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().ToList();
  527. }
  528. /// <summary>
  529. /// 搜索
  530. /// </summary>
  531. /// <typeparam name="TOrder"></typeparam>
  532. /// <param name="page">第几页</param>
  533. /// <param name="size">页大小</param>
  534. /// <param name="total">总条数</param>
  535. /// <param name="keywords">关键词</param>
  536. /// <param name="orderBy">排序字段</param>
  537. /// <param name="isAsc">升序排列?</param>
  538. /// <returns></returns>
  539. public List<T> SearchPage<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
  540. {
  541. var query = GetAll().Search().Containing(keywords);
  542. total = query.Count();
  543. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  544. return order.Skip((page - 1) * size).Take(size).ToList();
  545. }
  546. /// <summary>
  547. /// 搜索
  548. /// </summary>
  549. /// <typeparam name="TOrder"></typeparam>
  550. /// <param name="page">第几页</param>
  551. /// <param name="size">页大小</param>
  552. /// <param name="total">总条数</param>
  553. /// <param name="keywords">关键词</param>
  554. /// <param name="where">其他条件</param>
  555. /// <param name="orderBy">排序字段</param>
  556. /// <param name="isAsc">升序排列?</param>
  557. /// <returns></returns>
  558. 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)
  559. {
  560. var query = LoadEntities(where).Search().Containing(keywords);
  561. total = query.Count();
  562. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  563. return order.Skip((page - 1) * size).Take(size).ToList();
  564. }
  565. /// <summary>
  566. /// 搜索
  567. /// </summary>
  568. /// <typeparam name="TOrder"></typeparam>
  569. /// <param name="page">第几页</param>
  570. /// <param name="size">页大小</param>
  571. /// <param name="total">总条数</param>
  572. /// <param name="keywords">关键词</param>
  573. /// <param name="orderBy">排序字段</param>
  574. /// <param name="isAsc">升序排列?</param>
  575. /// <returns></returns>
  576. public List<T> SearchPageNotracking<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
  577. {
  578. var query = GetAllNoTracking().Search().Containing(keywords);
  579. total = query.Count();
  580. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  581. return order.Skip((page - 1) * size).Take(size).ToList();
  582. }
  583. /// <summary>
  584. /// 搜索
  585. /// </summary>
  586. /// <typeparam name="TOrder"></typeparam>
  587. /// <param name="page">第几页</param>
  588. /// <param name="size">页大小</param>
  589. /// <param name="total">总条数</param>
  590. /// <param name="keywords">关键词</param>
  591. /// <param name="where">其他条件</param>
  592. /// <param name="orderBy">排序字段</param>
  593. /// <param name="isAsc">升序排列?</param>
  594. /// <returns></returns>
  595. 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)
  596. {
  597. var query = LoadEntitiesNoTracking(where).Search().Containing(keywords);
  598. total = query.Count();
  599. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  600. return order.Skip((page - 1) * size).Take(size).ToList();
  601. }
  602. /// <summary>
  603. /// 搜索
  604. /// </summary>
  605. /// <typeparam name="TOrder"></typeparam>
  606. /// <typeparam name="TDto"></typeparam>
  607. /// <param name="page">第几页</param>
  608. /// <param name="size">页大小</param>
  609. /// <param name="total">总条数</param>
  610. /// <param name="keywords">关键词</param>
  611. /// <param name="orderBy">排序字段</param>
  612. /// <param name="isAsc">升序排列?</param>
  613. /// <returns></returns>
  614. public List<TDto> SearchPageFromCache<TOrder, TDto>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
  615. {
  616. var query = GetAllNoTracking().Search().Containing(keywords);
  617. total = query.Count();
  618. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  619. return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().Cacheable().ToList();
  620. }
  621. /// <summary>
  622. /// 搜索
  623. /// </summary>
  624. /// <typeparam name="TOrder"></typeparam>
  625. /// <typeparam name="TDto"></typeparam>
  626. /// <param name="page">第几页</param>
  627. /// <param name="size">页大小</param>
  628. /// <param name="total">总条数</param>
  629. /// <param name="keywords">关键词</param>
  630. /// <param name="where">其他条件</param>
  631. /// <param name="orderBy">排序字段</param>
  632. /// <param name="isAsc">升序排列?</param>
  633. /// <returns></returns>
  634. 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)
  635. {
  636. var query = LoadEntities(where).Search().Containing(keywords);
  637. total = query.Count();
  638. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  639. return order.Skip((page - 1) * size).Take(size).ProjectTo<TDto>().Cacheable().ToList();
  640. }
  641. /// <summary>
  642. /// 搜索
  643. /// </summary>
  644. /// <typeparam name="TOrder"></typeparam>
  645. /// <param name="page">第几页</param>
  646. /// <param name="size">页大小</param>
  647. /// <param name="total">总条数</param>
  648. /// <param name="keywords">关键词</param>
  649. /// <param name="orderBy">排序字段</param>
  650. /// <param name="isAsc">升序排列?</param>
  651. /// <returns></returns>
  652. public List<T> SearchPageFromCache<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
  653. {
  654. var query = GetAll().Search().Containing(keywords);
  655. total = query.Count();
  656. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  657. return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
  658. }
  659. /// <summary>
  660. /// 搜索
  661. /// </summary>
  662. /// <typeparam name="TOrder"></typeparam>
  663. /// <param name="page">第几页</param>
  664. /// <param name="size">页大小</param>
  665. /// <param name="total">总条数</param>
  666. /// <param name="keywords">关键词</param>
  667. /// <param name="where">其他条件</param>
  668. /// <param name="orderBy">排序字段</param>
  669. /// <param name="isAsc">升序排列?</param>
  670. /// <returns></returns>
  671. 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)
  672. {
  673. var query = LoadEntities(where).Search().Containing(keywords);
  674. total = query.Count();
  675. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  676. return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
  677. }
  678. /// <summary>
  679. /// 搜索
  680. /// </summary>
  681. /// <typeparam name="TOrder"></typeparam>
  682. /// <param name="page">第几页</param>
  683. /// <param name="size">页大小</param>
  684. /// <param name="total">总条数</param>
  685. /// <param name="keywords">关键词</param>
  686. /// <param name="orderBy">排序字段</param>
  687. /// <param name="isAsc">升序排列?</param>
  688. /// <returns></returns>
  689. public List<T> SearchPageFromCacheNotracking<TOrder>(int page, int size, out int total, string[] keywords, Expression<Func<T, TOrder>> orderBy, bool isAsc = true)
  690. {
  691. var query = GetAllNoTracking().Search().Containing(keywords);
  692. total = query.Count();
  693. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  694. return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
  695. }
  696. /// <summary>
  697. /// 搜索
  698. /// </summary>
  699. /// <typeparam name="TOrder"></typeparam>
  700. /// <param name="page">第几页</param>
  701. /// <param name="size">页大小</param>
  702. /// <param name="total">总条数</param>
  703. /// <param name="keywords">关键词</param>
  704. /// <param name="where">其他条件</param>
  705. /// <param name="orderBy">排序字段</param>
  706. /// <param name="isAsc">升序排列?</param>
  707. /// <returns></returns>
  708. 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)
  709. {
  710. var query = LoadEntitiesNoTracking(where).Search().Containing(keywords);
  711. total = query.Count();
  712. IOrderedQueryable<T> order = isAsc ? query.OrderBy(orderBy) : query.OrderByDescending(orderBy);
  713. return order.Skip((page - 1) * size).Take(size).Cacheable().ToList();
  714. }
  715. /// <summary>
  716. /// 根据ID删除实体
  717. /// </summary>
  718. /// <param name="id">实体id</param>
  719. /// <returns>删除成功</returns>
  720. public virtual bool DeleteById(object id)
  721. {
  722. return BaseDal.DeleteById(id);
  723. }
  724. /// <summary>
  725. /// 根据ID删除实体并保存
  726. /// </summary>
  727. /// <param name="id">实体id</param>
  728. /// <returns>删除成功</returns>
  729. public virtual bool DeleteByIdSaved(object id)
  730. {
  731. BaseDal.DeleteById(id);
  732. return SaveChanges() > 0;
  733. }
  734. /// <summary>
  735. /// 根据ID删除实体并保存(异步)
  736. /// </summary>
  737. /// <param name="id">实体id</param>
  738. /// <returns>删除成功</returns>
  739. public virtual async Task<int> DeleteByIdSavedAsync(object id)
  740. {
  741. BaseDal.DeleteById(id);
  742. return await SaveChangesAsync();
  743. }
  744. /// <summary>
  745. /// 删除实体并保存
  746. /// </summary>
  747. /// <param name="t">需要删除的实体</param>
  748. /// <returns>删除成功</returns>
  749. public virtual bool DeleteEntity(T t)
  750. {
  751. return BaseDal.DeleteEntity(t);
  752. }
  753. /// <summary>
  754. /// 根据条件删除实体
  755. /// </summary>
  756. /// <param name="where">查询条件</param>
  757. /// <returns>删除成功</returns>
  758. public virtual int DeleteEntity(Expression<Func<T, bool>> @where)
  759. {
  760. return BaseDal.DeleteEntity(where);
  761. }
  762. /// <summary>
  763. /// 根据条件删除实体
  764. /// </summary>
  765. /// <param name="where">查询条件</param>
  766. /// <returns>删除成功</returns>
  767. public virtual int DeleteEntitySaved(Expression<Func<T, bool>> @where)
  768. {
  769. BaseDal.DeleteEntity(where);
  770. return SaveChanges();
  771. }
  772. /// <summary>
  773. /// 根据条件删除实体
  774. /// </summary>
  775. /// <param name="where">查询条件</param>
  776. /// <returns>删除成功</returns>
  777. public virtual async Task<int> DeleteEntitySavedAsync(Expression<Func<T, bool>> @where)
  778. {
  779. BaseDal.DeleteEntity(where);
  780. return await SaveChangesAsync();
  781. }
  782. /// <summary>
  783. /// 根据条件删除实体(异步)
  784. /// </summary>
  785. /// <param name="where">查询条件</param>
  786. /// <returns>删除成功</returns>
  787. public virtual async Task<int> DeleteEntityAsync(Expression<Func<T, bool>> @where)
  788. {
  789. return await BaseDal.DeleteEntityAsync(where);
  790. }
  791. /// <summary>
  792. /// 删除实体并保存
  793. /// </summary>
  794. /// <param name="t">需要删除的实体</param>
  795. /// <returns>删除成功</returns>
  796. public virtual bool DeleteEntitySaved(T t)
  797. {
  798. BaseDal.DeleteEntity(t);
  799. return SaveChanges() > 0;
  800. }
  801. /// <summary>
  802. /// 删除实体并保存(异步)
  803. /// </summary>
  804. /// <param name="t">需要删除的实体</param>
  805. /// <returns>删除成功</returns>
  806. public virtual async Task<int> DeleteEntitySavedAsync(T t)
  807. {
  808. BaseDal.DeleteEntity(t);
  809. return await SaveChangesAsync();
  810. }
  811. /// <summary>
  812. /// 更新实体
  813. /// </summary>
  814. /// <param name="t">更新后的实体</param>
  815. /// <returns>更新成功</returns>
  816. public virtual bool UpdateEntity(T t)
  817. {
  818. return BaseDal.UpdateEntity(t);
  819. }
  820. /// <summary>
  821. /// 更新实体并保存
  822. /// </summary>
  823. /// <param name="t">更新后的实体</param>
  824. /// <returns>更新成功</returns>
  825. public virtual bool UpdateEntitySaved(T t)
  826. {
  827. BaseDal.UpdateEntity(t);
  828. return SaveChanges() > 0;
  829. }
  830. /// <summary>
  831. /// 更新实体并保存(异步)
  832. /// </summary>
  833. /// <param name="t">更新后的实体</param>
  834. /// <returns>更新成功</returns>
  835. public virtual async Task<int> UpdateEntitySavedAsync(T t)
  836. {
  837. BaseDal.UpdateEntity(t);
  838. return await SaveChangesAsync();
  839. }
  840. /// <summary>
  841. /// 根据条件更新实体
  842. /// </summary>
  843. /// <param name="where">查询条件</param>
  844. /// <param name="t">更新后的实体</param>
  845. /// <returns>更新成功</returns>
  846. public virtual int UpdateEntity(Expression<Func<T, bool>> @where, T t)
  847. {
  848. return BaseDal.UpdateEntity(where, t);
  849. }
  850. /// <summary>
  851. /// 根据条件更新实体(异步)
  852. /// </summary>
  853. /// <param name="where">查询条件</param>
  854. /// <param name="t">更新后的实体</param>
  855. /// <returns>更新成功</returns>
  856. public virtual async Task<int> UpdateEntityAsync(Expression<Func<T, bool>> @where, T t)
  857. {
  858. return await BaseDal.UpdateEntityAsync(where, t);
  859. }
  860. /// <summary>
  861. /// 添加实体
  862. /// </summary>
  863. /// <param name="t">需要添加的实体</param>
  864. /// <returns>添加成功</returns>
  865. public virtual T AddEntity(T t)
  866. {
  867. return BaseDal.AddEntity(t);
  868. }
  869. /// <summary>
  870. /// 添加实体并保存
  871. /// </summary>
  872. /// <param name="t">需要添加的实体</param>
  873. /// <returns>添加成功</returns>
  874. public virtual T AddEntitySaved(T t)
  875. {
  876. T entity = BaseDal.AddEntity(t);
  877. bool b = SaveChanges() > 0;
  878. return b ? entity : null;
  879. }
  880. /// <summary>
  881. /// 添加实体并保存(异步)
  882. /// </summary>
  883. /// <param name="t">需要添加的实体</param>
  884. /// <returns>添加成功</returns>
  885. public virtual async Task<int> AddEntitySavedAsync(T t)
  886. {
  887. BaseDal.AddEntity(t);
  888. return await SaveChangesAsync();
  889. }
  890. /// <summary>
  891. /// 统一保存的方法
  892. /// </summary>
  893. /// <returns>受影响的行数</returns>
  894. public virtual int SaveChanges()
  895. {
  896. return BaseDal.SaveChanges();
  897. }
  898. /// <summary>
  899. /// 统一保存数据
  900. /// </summary>
  901. /// <returns>受影响的行数</returns>
  902. public virtual async Task<int> SaveChangesAsync()
  903. {
  904. return await BaseDal.SaveChangesAsync();
  905. }
  906. /// <summary>
  907. /// 判断实体是否在数据库中存在
  908. /// </summary>
  909. /// <param name="where">查询条件</param>
  910. /// <returns>是否存在</returns>
  911. public virtual bool Any(Expression<Func<T, bool>> @where)
  912. {
  913. return BaseDal.Any(where);
  914. }
  915. /// <summary>
  916. /// 统计符合条件的个数
  917. /// </summary>
  918. /// <param name="where">查询条件</param>
  919. /// <returns></returns>
  920. public int Count(Expression<Func<T, bool>> @where)
  921. {
  922. return BaseDal.Count(where);
  923. }
  924. /// <summary>
  925. /// 删除多个实体
  926. /// </summary>
  927. /// <param name="list">实体集合</param>
  928. /// <returns>删除成功</returns>
  929. public virtual bool DeleteEntities(IEnumerable<T> list)
  930. {
  931. return BaseDal.DeleteEntities(list);
  932. }
  933. /// <summary>
  934. /// 删除多个实体并保存
  935. /// </summary>
  936. /// <param name="list">实体集合</param>
  937. /// <returns>删除成功</returns>
  938. public virtual bool DeleteEntitiesSaved(IEnumerable<T> list)
  939. {
  940. BaseDal.DeleteEntities(list);
  941. return SaveChanges() > 0;
  942. }
  943. /// <summary>
  944. /// 删除多个实体并保存(异步)
  945. /// </summary>
  946. /// <param name="list">实体集合</param>
  947. /// <returns>删除成功</returns>
  948. public virtual async Task<int> DeleteEntitiesSavedAsync(IEnumerable<T> list)
  949. {
  950. BaseDal.DeleteEntities(list);
  951. return await SaveChangesAsync();
  952. }
  953. /// <summary>
  954. /// 更新多个实体
  955. /// </summary>
  956. /// <param name="list">实体集合</param>
  957. /// <returns>更新成功</returns>
  958. public virtual bool UpdateEntities(IEnumerable<T> list)
  959. {
  960. return BaseDal.UpdateEntities(list);
  961. }
  962. /// <summary>
  963. /// 更新多个实体并保存
  964. /// </summary>
  965. /// <param name="list">实体集合</param>
  966. /// <returns>更新成功</returns>
  967. public virtual bool UpdateEntitiesSaved(IEnumerable<T> list)
  968. {
  969. BaseDal.UpdateEntities(list);
  970. return SaveChanges() > 0;
  971. }
  972. /// <summary>
  973. /// 更新多个实体并保存(异步)
  974. /// </summary>
  975. /// <param name="list">实体集合</param>
  976. /// <returns>更新成功</returns>
  977. public virtual async Task<int> UpdateEntitiesSavedAsync(IEnumerable<T> list)
  978. {
  979. BaseDal.UpdateEntities(list);
  980. return await SaveChangesAsync();
  981. }
  982. /// <summary>
  983. /// 添加多个实体并保存
  984. /// </summary>
  985. /// <param name="list">实体集合</param>
  986. /// <returns>添加成功</returns>
  987. public virtual IEnumerable<T> AddEntities(IList<T> list)
  988. {
  989. IEnumerable<T> entities = BaseDal.AddEntities(list);
  990. SaveChanges();
  991. return entities;
  992. }
  993. /// <summary>
  994. /// 添加多个实体并保存(异步)
  995. /// </summary>
  996. /// <param name="list">实体集合</param>
  997. /// <returns>添加成功</returns>
  998. public virtual async Task<IEnumerable<T>> AddEntitiesAsync(IList<T> list)
  999. {
  1000. IEnumerable<T> entities = BaseDal.AddEntities(list);
  1001. await SaveChangesAsync();
  1002. return entities;
  1003. }
  1004. /// <summary>
  1005. /// 执行查询语句
  1006. /// </summary>
  1007. /// <typeparam name="T"></typeparam>
  1008. /// <param name="sql"></param>
  1009. /// <param name="parameters">参数</param>
  1010. /// <returns>泛型集合</returns>
  1011. public virtual IQueryable<T> SqlQuery(string sql, params SqlParameter[] parameters)
  1012. {
  1013. return BaseDal.SqlQuery(sql, parameters);
  1014. }
  1015. /// <summary>
  1016. /// 执行查询语句
  1017. /// </summary>
  1018. /// <typeparam name="TS"></typeparam>
  1019. /// <param name="sql"></param>
  1020. /// <param name="parameters">参数</param>
  1021. /// <returns>泛型集合</returns>
  1022. public virtual IEnumerable<TS> SqlQuery<TS>(string sql, object parameters = null)
  1023. {
  1024. return BaseDal.SqlQuery<TS>(sql, parameters);
  1025. }
  1026. /// <summary>
  1027. /// 执行DML语句
  1028. /// </summary>
  1029. /// <param name="sql"></param>
  1030. /// <param name="parameters"></param>
  1031. public virtual void ExecuteSql(string sql, params SqlParameter[] parameters)
  1032. {
  1033. BaseDal.ExecuteSql(sql, parameters);
  1034. }
  1035. /// <summary>
  1036. /// 批量添加实体
  1037. /// </summary>
  1038. /// <param name="list">需要添加的实体</param>
  1039. public virtual void BulkInsert(IEnumerable<T> list)
  1040. {
  1041. BaseDal.BulkInsert(list);
  1042. }
  1043. /// <summary>
  1044. /// 统一批量保存数据
  1045. /// </summary>
  1046. public virtual void BulkSaveChanges()
  1047. {
  1048. BaseDal.BulkSaveChanges();
  1049. }
  1050. }
  1051. }