IEnumerableExtensions.cs 52 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502
  1. using System;
  2. using System.Collections;
  3. using System.Collections.Concurrent;
  4. using System.Collections.Generic;
  5. using System.Diagnostics;
  6. using System.Linq;
  7. using System.Linq.Expressions;
  8. using System.Threading;
  9. using System.Threading.Tasks;
  10. namespace Masuit.Tools;
  11. /// <summary>
  12. ///
  13. /// </summary>
  14. public static class IEnumerableExtensions
  15. {
  16. #if NETFRAMEWORK
  17. public static IEnumerable<T> Append<T>(this IEnumerable<T> source, T item)
  18. {
  19. return source.Concat([item]);
  20. }
  21. #endif
  22. /// <summary>
  23. /// 按字段属性判等取交集
  24. /// </summary>
  25. /// <typeparam name="TFirst"></typeparam>
  26. /// <typeparam name="TSecond"></typeparam>
  27. /// <param name="second"></param>
  28. /// <param name="condition"></param>
  29. /// <param name="first"></param>
  30. /// <returns></returns>
  31. public static IEnumerable<TFirst> IntersectBy<TFirst, TSecond>(this IEnumerable<TFirst> first, IEnumerable<TSecond> second, Func<TFirst, TSecond, bool> condition)
  32. {
  33. return first.Where(f => second.Any(s => condition(f, s)));
  34. }
  35. /// <summary>
  36. /// 按字段属性判等取交集
  37. /// </summary>
  38. /// <typeparam name="TSource"></typeparam>
  39. /// <typeparam name="TKey"></typeparam>
  40. /// <param name="first"></param>
  41. /// <param name="second"></param>
  42. /// <param name="keySelector"></param>
  43. /// <returns></returns>
  44. public static IEnumerable<TSource> IntersectBy<TSource, TKey>(this IEnumerable<TSource> first, IEnumerable<TSource> second, Func<TSource, TKey> keySelector)
  45. {
  46. return first.IntersectBy(second, keySelector, null);
  47. }
  48. /// <summary>
  49. /// 按字段属性判等取交集
  50. /// </summary>
  51. /// <typeparam name="TSource"></typeparam>
  52. /// <typeparam name="TKey"></typeparam>
  53. /// <param name="first"></param>
  54. /// <param name="second"></param>
  55. /// <param name="keySelector"></param>
  56. /// <param name="comparer"></param>
  57. /// <returns></returns>
  58. public static IEnumerable<TSource> IntersectBy<TSource, TKey>(this IEnumerable<TSource> first, IEnumerable<TSource> second, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
  59. {
  60. if (first == null)
  61. throw new ArgumentNullException(nameof(first));
  62. if (second == null)
  63. throw new ArgumentNullException(nameof(second));
  64. if (keySelector == null)
  65. throw new ArgumentNullException(nameof(keySelector));
  66. return IntersectByIterator(first, second, keySelector, comparer);
  67. }
  68. private static IEnumerable<TSource> IntersectByIterator<TSource, TKey>(IEnumerable<TSource> first, IEnumerable<TSource> second, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
  69. {
  70. var set = new HashSet<TKey>(second.Select(keySelector), comparer);
  71. foreach (var item in first.Where(source => set.Remove(keySelector(source))))
  72. {
  73. yield return item;
  74. }
  75. }
  76. /// <summary>
  77. /// 多个集合取交集元素
  78. /// </summary>
  79. /// <typeparam name="T"></typeparam>
  80. /// <param name="source"></param>
  81. /// <returns></returns>
  82. public static IEnumerable<T> IntersectAll<T>(this IEnumerable<IEnumerable<T>> source)
  83. {
  84. return source.Aggregate((current, item) => current.Intersect(item));
  85. }
  86. /// <summary>
  87. /// 多个集合取交集元素
  88. /// </summary>
  89. /// <typeparam name="TSource"></typeparam>
  90. /// <typeparam name="TKey"></typeparam>
  91. /// <param name="source"></param>
  92. /// <param name="keySelector"></param>
  93. /// <returns></returns>
  94. public static IEnumerable<TSource> IntersectAll<TSource, TKey>(this IEnumerable<IEnumerable<TSource>> source, Func<TSource, TKey> keySelector)
  95. {
  96. return source.Aggregate((current, item) => current.IntersectBy(item, keySelector));
  97. }
  98. /// <summary>
  99. /// 多个集合取交集元素
  100. /// </summary>
  101. /// <typeparam name="TSource"></typeparam>
  102. /// <typeparam name="TKey"></typeparam>
  103. /// <param name="source"></param>
  104. /// <param name="keySelector"></param>
  105. /// <param name="comparer"></param>
  106. /// <returns></returns>
  107. public static IEnumerable<TSource> IntersectAll<TSource, TKey>(this IEnumerable<IEnumerable<TSource>> source, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
  108. {
  109. return source.Aggregate((current, item) => current.IntersectBy(item, keySelector, comparer));
  110. }
  111. /// <summary>
  112. /// 多个集合取交集元素
  113. /// </summary>
  114. /// <typeparam name="T"></typeparam>
  115. /// <param name="source"></param>
  116. /// <param name="comparer"></param>
  117. /// <returns></returns>
  118. public static IEnumerable<T> IntersectAll<T>(this IEnumerable<IEnumerable<T>> source, IEqualityComparer<T> comparer)
  119. {
  120. return source.Aggregate((current, item) => current.Intersect(item, comparer));
  121. }
  122. /// <summary>
  123. /// 按字段属性判等取差集
  124. /// </summary>
  125. /// <typeparam name="TFirst"></typeparam>
  126. /// <typeparam name="TSecond"></typeparam>
  127. /// <param name="second"></param>
  128. /// <param name="condition"></param>
  129. /// <param name="first"></param>
  130. /// <returns></returns>
  131. public static IEnumerable<TFirst> ExceptBy<TFirst, TSecond>(this IEnumerable<TFirst> first, IEnumerable<TSecond> second, Func<TFirst, TSecond, bool> condition)
  132. {
  133. return first.Where(f => !second.Any(s => condition(f, s)));
  134. }
  135. /// <summary>
  136. /// 按字段属性判等取差集
  137. /// </summary>
  138. /// <param name="second"></param>
  139. /// <param name="first"></param>
  140. /// <param name="keySelector"></param>
  141. /// <returns></returns>
  142. public static IEnumerable<T> ExceptBy<T, TKey>(this IEnumerable<T> first, IEnumerable<T> second, Func<T, TKey> keySelector)
  143. {
  144. var firstLookup = first.ToLookup(keySelector);
  145. var secondLookup = second.ToLookup(keySelector);
  146. return firstLookup.Where(kvp => !secondLookup.Contains(kvp.Key)).SelectMany(kvp => kvp).ToList();
  147. }
  148. #if NET6_0_OR_GREATER
  149. #else
  150. /// <summary>
  151. /// 按字段去重
  152. /// </summary>
  153. /// <typeparam name="TSource"></typeparam>
  154. /// <typeparam name="TKey"></typeparam>
  155. /// <param name="source"></param>
  156. /// <param name="keySelector"></param>
  157. /// <returns></returns>
  158. public static IEnumerable<TSource> DistinctBy<TSource, TKey>(this IEnumerable<TSource> source, Func<TSource, TKey> keySelector)
  159. {
  160. if (source == null) throw new ArgumentNullException(nameof(source));
  161. if (keySelector == null) throw new ArgumentNullException(nameof(keySelector));
  162. var set = new HashSet<TKey>();
  163. return source.Where(item => set.Add(keySelector(item)));
  164. }
  165. /// <summary>
  166. /// 按字段属性判等取交集
  167. /// </summary>
  168. /// <typeparam name="TSource"></typeparam>
  169. /// <typeparam name="TKey"></typeparam>
  170. /// <param name="first"></param>
  171. /// <param name="second"></param>
  172. /// <param name="keySelector"></param>
  173. /// <returns></returns>
  174. public static IEnumerable<TSource> IntersectBy<TSource, TKey>(this IEnumerable<TSource> first, IEnumerable<TKey> second, Func<TSource, TKey> keySelector)
  175. {
  176. return first.IntersectBy(second, keySelector, null);
  177. }
  178. /// <summary>
  179. /// 按字段属性判等取交集
  180. /// </summary>
  181. /// <typeparam name="TSource"></typeparam>
  182. /// <typeparam name="TKey"></typeparam>
  183. /// <param name="first"></param>
  184. /// <param name="second"></param>
  185. /// <param name="keySelector"></param>
  186. /// <param name="comparer"></param>
  187. /// <returns></returns>
  188. public static IEnumerable<TSource> IntersectBy<TSource, TKey>(this IEnumerable<TSource> first, IEnumerable<TKey> second, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
  189. {
  190. if (first == null) throw new ArgumentNullException(nameof(first));
  191. if (second == null) throw new ArgumentNullException(nameof(second));
  192. if (keySelector == null) throw new ArgumentNullException(nameof(keySelector));
  193. return IntersectByIterator(first, second, keySelector, comparer);
  194. }
  195. private static IEnumerable<TSource> IntersectByIterator<TSource, TKey>(IEnumerable<TSource> first, IEnumerable<TKey> second, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
  196. {
  197. var set = new HashSet<TKey>(second, comparer);
  198. return first.Where(source => set.Remove(keySelector(source)));
  199. }
  200. /// <summary>
  201. /// 按字段属性判等取差集
  202. /// </summary>
  203. /// <typeparam name="TSource"></typeparam>
  204. /// <typeparam name="TKey"></typeparam>
  205. /// <param name="first"></param>
  206. /// <param name="second"></param>
  207. /// <param name="keySelector"></param>
  208. /// <returns></returns>
  209. public static IEnumerable<TSource> ExceptBy<TSource, TKey>(this IEnumerable<TSource> first, IEnumerable<TKey> second, Func<TSource, TKey> keySelector)
  210. {
  211. return first.ExceptBy(second, keySelector, null);
  212. }
  213. /// <summary>
  214. /// 按字段属性判等取差集
  215. /// </summary>
  216. /// <typeparam name="TSource"></typeparam>
  217. /// <typeparam name="TKey"></typeparam>
  218. /// <param name="first"></param>
  219. /// <param name="second"></param>
  220. /// <param name="keySelector"></param>
  221. /// <param name="comparer"></param>
  222. /// <returns></returns>
  223. /// <exception cref="ArgumentNullException"></exception>
  224. public static IEnumerable<TSource> ExceptBy<TSource, TKey>(this IEnumerable<TSource> first, IEnumerable<TKey> second, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
  225. {
  226. if (first == null) throw new ArgumentNullException(nameof(first));
  227. if (second == null) throw new ArgumentNullException(nameof(second));
  228. if (keySelector == null) throw new ArgumentNullException(nameof(keySelector));
  229. return ExceptByIterator(first, second, keySelector, comparer);
  230. }
  231. private static IEnumerable<TSource> ExceptByIterator<TSource, TKey>(IEnumerable<TSource> first, IEnumerable<TKey> second, Func<TSource, TKey> keySelector, IEqualityComparer<TKey> comparer)
  232. {
  233. var set = new HashSet<TKey>(second, comparer);
  234. return first.Where(source => set.Add(keySelector(source)));
  235. }
  236. #endif
  237. /// <summary>
  238. /// 添加多个元素
  239. /// </summary>
  240. /// <typeparam name="T"></typeparam>
  241. /// <param name="this"></param>
  242. /// <param name="values"></param>
  243. public static void AddRange<T>(this ICollection<T> @this, params T[] values)
  244. {
  245. foreach (var obj in values)
  246. {
  247. @this.Add(obj);
  248. }
  249. }
  250. /// <summary>
  251. /// 添加多个元素
  252. /// </summary>
  253. /// <typeparam name="T"></typeparam>
  254. /// <param name="this"></param>
  255. /// <param name="values"></param>
  256. public static void AddRange<T>(this ICollection<T> @this, IEnumerable<T> values)
  257. {
  258. foreach (var obj in values)
  259. {
  260. @this.Add(obj);
  261. }
  262. }
  263. /// <summary>
  264. /// 添加多个元素
  265. /// </summary>
  266. /// <typeparam name="T"></typeparam>
  267. /// <param name="this"></param>
  268. /// <param name="values"></param>
  269. public static void AddRange<T>(this ConcurrentBag<T> @this, params T[] values)
  270. {
  271. foreach (var obj in values)
  272. {
  273. @this.Add(obj);
  274. }
  275. }
  276. /// <summary>
  277. /// 添加多个元素
  278. /// </summary>
  279. /// <typeparam name="T"></typeparam>
  280. /// <param name="this"></param>
  281. /// <param name="values"></param>
  282. public static void AddRange<T>(this ConcurrentQueue<T> @this, params T[] values)
  283. {
  284. foreach (var obj in values)
  285. {
  286. @this.Enqueue(obj);
  287. }
  288. }
  289. /// <summary>
  290. /// 添加符合条件的多个元素
  291. /// </summary>
  292. /// <typeparam name="T"></typeparam>
  293. /// <param name="this"></param>
  294. /// <param name="predicate"></param>
  295. /// <param name="values"></param>
  296. public static void AddRangeIf<T>(this ICollection<T> @this, Func<T, bool> predicate, params T[] values)
  297. {
  298. foreach (var obj in values.Where(predicate))
  299. {
  300. @this.Add(obj);
  301. }
  302. }
  303. /// <summary>
  304. /// 添加符合条件的多个元素
  305. /// </summary>
  306. /// <typeparam name="T"></typeparam>
  307. /// <param name="this"></param>
  308. /// <param name="predicate"></param>
  309. /// <param name="values"></param>
  310. public static void AddRangeIf<T>(this ConcurrentBag<T> @this, Func<T, bool> predicate, params T[] values)
  311. {
  312. foreach (var obj in values.Where(predicate))
  313. {
  314. @this.Add(obj);
  315. }
  316. }
  317. /// <summary>
  318. /// 添加符合条件的多个元素
  319. /// </summary>
  320. /// <typeparam name="T"></typeparam>
  321. /// <param name="this"></param>
  322. /// <param name="predicate"></param>
  323. /// <param name="values"></param>
  324. public static void AddRangeIf<T>(this ConcurrentQueue<T> @this, Func<T, bool> predicate, params T[] values)
  325. {
  326. foreach (var obj in values.Where(predicate))
  327. {
  328. @this.Enqueue(obj);
  329. }
  330. }
  331. /// <summary>
  332. /// 符合条件则添加元素
  333. /// </summary>
  334. /// <typeparam name="T"></typeparam>
  335. /// <param name="this"></param>
  336. /// <param name="predicate"></param>
  337. /// <param name="values"></param>
  338. public static ICollection<T> AddRangeIf<T>(this ICollection<T> @this, Func<bool> predicate, IEnumerable<T> values)
  339. {
  340. if (predicate())
  341. {
  342. foreach (var value in values)
  343. {
  344. @this.Add(value);
  345. }
  346. }
  347. return @this;
  348. }
  349. /// <summary>
  350. /// 符合条件则添加元素
  351. /// </summary>
  352. /// <typeparam name="T"></typeparam>
  353. /// <param name="this"></param>
  354. /// <param name="predicate"></param>
  355. /// <param name="values"></param>
  356. public static ICollection<T> AddRangeIf<T>(this ICollection<T> @this, bool predicate, IEnumerable<T> values)
  357. {
  358. if (predicate)
  359. {
  360. foreach (var value in values)
  361. {
  362. @this.Add(value);
  363. }
  364. }
  365. return @this;
  366. }
  367. /// <summary>
  368. /// 符合条件则添加元素
  369. /// </summary>
  370. /// <typeparam name="T"></typeparam>
  371. /// <param name="this"></param>
  372. /// <param name="predicate"></param>
  373. /// <param name="values"></param>
  374. public static ConcurrentBag<T> AddRangeIf<T>(this ConcurrentBag<T> @this, Func<bool> predicate, IEnumerable<T> values)
  375. {
  376. if (predicate())
  377. {
  378. foreach (var value in values)
  379. {
  380. @this.Add(value);
  381. }
  382. }
  383. return @this;
  384. }
  385. /// <summary>
  386. /// 符合条件则添加元素
  387. /// </summary>
  388. /// <typeparam name="T"></typeparam>
  389. /// <param name="this"></param>
  390. /// <param name="predicate"></param>
  391. /// <param name="values"></param>
  392. public static ConcurrentBag<T> AddRangeIf<T>(this ConcurrentBag<T> @this, bool predicate, IEnumerable<T> values)
  393. {
  394. if (predicate)
  395. {
  396. foreach (var value in values)
  397. {
  398. @this.Add(value);
  399. }
  400. }
  401. return @this;
  402. }
  403. /// <summary>
  404. /// 符合条件则添加元素
  405. /// </summary>
  406. /// <typeparam name="T"></typeparam>
  407. /// <param name="this"></param>
  408. /// <param name="predicate"></param>
  409. /// <param name="values"></param>
  410. public static ConcurrentQueue<T> AddRangeIf<T>(this ConcurrentQueue<T> @this, Func<bool> predicate, IEnumerable<T> values)
  411. {
  412. if (predicate())
  413. {
  414. foreach (var value in values)
  415. {
  416. @this.Enqueue(value);
  417. }
  418. }
  419. return @this;
  420. }
  421. /// <summary>
  422. /// 符合条件则添加元素
  423. /// </summary>
  424. /// <typeparam name="T"></typeparam>
  425. /// <param name="this"></param>
  426. /// <param name="predicate"></param>
  427. /// <param name="values"></param>
  428. public static ConcurrentQueue<T> AddRangeIf<T>(this ConcurrentQueue<T> @this, bool predicate, IEnumerable<T> values)
  429. {
  430. if (predicate)
  431. {
  432. foreach (var value in values)
  433. {
  434. @this.Enqueue(value);
  435. }
  436. }
  437. return @this;
  438. }
  439. /// <summary>
  440. /// 添加不重复的元素
  441. /// </summary>
  442. /// <typeparam name="T"></typeparam>
  443. /// <param name="this"></param>
  444. /// <param name="values"></param>
  445. public static void AddRangeIfNotContains<T>(this ICollection<T> @this, params T[] values)
  446. {
  447. foreach (T obj in values)
  448. {
  449. if ([email protected](obj))
  450. {
  451. @this.Add(obj);
  452. }
  453. }
  454. }
  455. /// <summary>
  456. /// 符合条件则添加一个元素
  457. /// </summary>
  458. /// <typeparam name="T"></typeparam>
  459. /// <param name="this"></param>
  460. /// <param name="predicate"></param>
  461. /// <param name="value"></param>
  462. public static ICollection<T> AppendIf<T>(this ICollection<T> @this, Func<bool> predicate, T value)
  463. {
  464. if (predicate())
  465. {
  466. @this.Add(value);
  467. }
  468. return @this;
  469. }
  470. /// <summary>
  471. /// 符合条件则添加一个元素
  472. /// </summary>
  473. /// <typeparam name="T"></typeparam>
  474. /// <param name="this"></param>
  475. /// <param name="predicate"></param>
  476. /// <param name="value"></param>
  477. public static ICollection<T> AppendIf<T>(this ICollection<T> @this, bool predicate, T value)
  478. {
  479. if (predicate)
  480. {
  481. @this.Add(value);
  482. }
  483. return @this;
  484. }
  485. /// <summary>
  486. /// 符合条件则添加一个元素
  487. /// </summary>
  488. /// <typeparam name="T"></typeparam>
  489. /// <param name="this"></param>
  490. /// <param name="predicate"></param>
  491. /// <param name="value"></param>
  492. public static IEnumerable<T> AppendIf<T>(this IEnumerable<T> @this, Func<bool> predicate, T value)
  493. {
  494. return predicate() ? @this.Append(value) : @this;
  495. }
  496. /// <summary>
  497. /// 符合条件则添加一个元素
  498. /// </summary>
  499. /// <typeparam name="T"></typeparam>
  500. /// <param name="this"></param>
  501. /// <param name="predicate"></param>
  502. /// <param name="value"></param>
  503. public static IEnumerable<T> AppendIf<T>(this IEnumerable<T> @this, bool predicate, T value)
  504. {
  505. return predicate ? @this.Append(value) : @this;
  506. }
  507. /// <summary>
  508. /// 移除符合条件的元素
  509. /// </summary>
  510. /// <typeparam name="T"></typeparam>
  511. /// <param name="this"></param>
  512. /// <param name="where"></param>
  513. public static void RemoveWhere<T>(this ICollection<T> @this, Func<T, bool> @where)
  514. {
  515. foreach (var obj in @this.Where(where).ToList())
  516. {
  517. @this.Remove(obj);
  518. }
  519. }
  520. /// <summary>
  521. /// 在元素之后添加元素
  522. /// </summary>
  523. /// <typeparam name="T"></typeparam>
  524. /// <param name="list"></param>
  525. /// <param name="condition">条件</param>
  526. /// <param name="value">值</param>
  527. public static void InsertAfter<T>(this IList<T> list, Func<T, bool> condition, T value)
  528. {
  529. foreach (var index in list.Select((item, index) => new
  530. {
  531. item,
  532. index
  533. }).Where(p => condition(p.item)).OrderByDescending(p => p.index).Select(t => t.index))
  534. {
  535. if (index + 1 == list.Count)
  536. {
  537. list.Add(value);
  538. }
  539. else
  540. {
  541. list.Insert(index + 1, value);
  542. }
  543. }
  544. }
  545. /// <summary>
  546. /// 在元素之后添加元素
  547. /// </summary>
  548. /// <typeparam name="T"></typeparam>
  549. /// <param name="list"></param>
  550. /// <param name="index">索引位置</param>
  551. /// <param name="value">值</param>
  552. public static void InsertAfter<T>(this IList<T> list, int index, T value)
  553. {
  554. foreach (var i in list.Select((v, i) => new
  555. {
  556. Value = v,
  557. Index = i
  558. }).Where(p => p.Index == index).OrderByDescending(p => p.Index).Select(t => t.Index))
  559. {
  560. if (i + 1 == list.Count)
  561. {
  562. list.Add(value);
  563. }
  564. else
  565. {
  566. list.Insert(i + 1, value);
  567. }
  568. }
  569. }
  570. /// <summary>
  571. /// 转HashSet
  572. /// </summary>
  573. /// <typeparam name="T"></typeparam>
  574. /// <typeparam name="TResult"></typeparam>
  575. /// <param name="source"></param>
  576. /// <param name="selector"></param>
  577. /// <returns></returns>
  578. public static HashSet<TResult> ToHashSet<T, TResult>(this IEnumerable<T> source, Func<T, TResult> selector)
  579. {
  580. return new HashSet<TResult>(source.Select(selector));
  581. }
  582. /// <summary>
  583. /// 转SortedSet
  584. /// </summary>
  585. /// <typeparam name="T"></typeparam>
  586. /// <param name="source"></param>
  587. /// <returns></returns>
  588. public static SortedSet<T> ToSortedSet<T>(this IEnumerable<T> source, IComparer<T> comparer = null)
  589. {
  590. return comparer == null ? [.. source] : new SortedSet<T>(source, comparer);
  591. }
  592. /// <summary>
  593. /// 转SortedSet
  594. /// </summary>
  595. /// <typeparam name="T"></typeparam>
  596. /// <typeparam name="TResult"></typeparam>
  597. /// <param name="source"></param>
  598. /// <param name="selector"></param>
  599. /// <returns></returns>
  600. public static SortedSet<TResult> ToSortedSet<T, TResult>(this IEnumerable<T> source, Func<T, TResult> selector, IComparer<TResult> comparer = null)
  601. {
  602. return comparer == null ? [.. source.Select(selector)] : new SortedSet<TResult>(source.Select(selector), comparer);
  603. }
  604. /// <summary>
  605. /// 转Queue
  606. /// </summary>
  607. /// <typeparam name="T"></typeparam>
  608. /// <param name="source"></param>
  609. /// <returns></returns>
  610. public static Queue<T> ToQueue<T>(this IEnumerable<T> source)
  611. {
  612. return new Queue<T>(source);
  613. }
  614. /// <summary>
  615. /// 转Queue
  616. /// </summary>
  617. /// <typeparam name="T"></typeparam>
  618. /// <typeparam name="TResult"></typeparam>
  619. /// <param name="source"></param>
  620. /// <param name="selector"></param>
  621. /// <returns></returns>
  622. public static Queue<TResult> ToQueue<T, TResult>(this IEnumerable<T> source, Func<T, TResult> selector)
  623. {
  624. return new Queue<TResult>(source.Select(selector));
  625. }
  626. /// <summary>
  627. /// 遍历IEnumerable
  628. /// </summary>
  629. /// <param name="objs"></param>
  630. /// <param name="action">回调方法</param>
  631. /// <typeparam name="T"></typeparam>
  632. public static void ForEach<T>(this IEnumerable<T> objs, Action<T> action)
  633. {
  634. foreach (var o in objs)
  635. {
  636. action(o);
  637. }
  638. }
  639. /// <summary>
  640. /// 异步foreach
  641. /// </summary>
  642. /// <typeparam name="T"></typeparam>
  643. /// <param name="source"></param>
  644. /// <param name="maxParallelCount">最大并行数</param>
  645. /// <param name="action"></param>
  646. /// <param name="cancellationToken"></param>
  647. /// <returns></returns>
  648. public static async Task ForeachAsync<T>(this IEnumerable<T> source, Func<T, Task> action, int maxParallelCount, CancellationToken cancellationToken = default)
  649. {
  650. if (Debugger.IsAttached)
  651. {
  652. foreach (var item in source)
  653. {
  654. await action(item);
  655. }
  656. return;
  657. }
  658. var list = new List<Task>();
  659. foreach (var item in source)
  660. {
  661. if (cancellationToken.IsCancellationRequested)
  662. {
  663. return;
  664. }
  665. list.Add(action(item));
  666. if (list.Count(t => !t.IsCompleted) >= maxParallelCount)
  667. {
  668. await Task.WhenAny(list);
  669. list.RemoveAll(t => t.IsCompleted);
  670. }
  671. }
  672. await Task.WhenAll(list);
  673. }
  674. /// <summary>
  675. /// 异步foreach
  676. /// </summary>
  677. /// <typeparam name="T"></typeparam>
  678. /// <param name="source"></param>
  679. /// <param name="action"></param>
  680. /// <param name="cancellationToken"></param>
  681. /// <returns></returns>
  682. public static Task ForeachAsync<T>(this IEnumerable<T> source, Func<T, Task> action, CancellationToken cancellationToken = default)
  683. {
  684. if (source is ICollection<T> collection)
  685. {
  686. return ForeachAsync(collection, action, collection.Count, cancellationToken);
  687. }
  688. var list = source.ToList();
  689. return ForeachAsync(list, action, list.Count, cancellationToken);
  690. }
  691. /// <summary>
  692. /// 异步Select
  693. /// </summary>
  694. /// <typeparam name="T"></typeparam>
  695. /// <typeparam name="TResult"></typeparam>
  696. /// <param name="source"></param>
  697. /// <param name="selector"></param>
  698. /// <returns></returns>
  699. public static Task<TResult[]> SelectAsync<T, TResult>(this IEnumerable<T> source, Func<T, Task<TResult>> selector)
  700. {
  701. return Task.WhenAll(source.Select(selector));
  702. }
  703. /// <summary>
  704. /// 异步Select
  705. /// </summary>
  706. /// <typeparam name="T"></typeparam>
  707. /// <typeparam name="TResult"></typeparam>
  708. /// <param name="source"></param>
  709. /// <param name="selector"></param>
  710. /// <returns></returns>
  711. public static Task<TResult[]> SelectAsync<T, TResult>(this IEnumerable<T> source, Func<T, int, Task<TResult>> selector)
  712. {
  713. return Task.WhenAll(source.Select(selector));
  714. }
  715. /// <summary>
  716. /// 异步Select
  717. /// </summary>
  718. /// <typeparam name="T"></typeparam>
  719. /// <typeparam name="TResult"></typeparam>
  720. /// <param name="source"></param>
  721. /// <param name="selector"></param>
  722. /// <param name="maxParallelCount">最大并行数</param>
  723. /// <returns></returns>
  724. public static async Task<List<TResult>> SelectAsync<T, TResult>(this IEnumerable<T> source, Func<T, Task<TResult>> selector, int maxParallelCount)
  725. {
  726. var results = new List<TResult>();
  727. var tasks = new List<Task<TResult>>();
  728. foreach (var item in source)
  729. {
  730. var task = selector(item);
  731. tasks.Add(task);
  732. if (tasks.Count >= maxParallelCount)
  733. {
  734. await Task.WhenAny(tasks);
  735. var completedTasks = tasks.Where(t => t.IsCompleted).ToArray();
  736. results.AddRange(completedTasks.Select(t => t.Result));
  737. tasks.RemoveWhere(t => completedTasks.Contains(t));
  738. }
  739. }
  740. results.AddRange(await Task.WhenAll(tasks));
  741. return results;
  742. }
  743. /// <summary>
  744. /// 异步Select
  745. /// </summary>
  746. /// <typeparam name="T"></typeparam>
  747. /// <typeparam name="TResult"></typeparam>
  748. /// <param name="source"></param>
  749. /// <param name="selector"></param>
  750. /// <param name="maxParallelCount">最大并行数</param>
  751. /// <returns></returns>
  752. public static async Task<List<TResult>> SelectAsync<T, TResult>(this IEnumerable<T> source, Func<T, int, Task<TResult>> selector, int maxParallelCount)
  753. {
  754. var results = new List<TResult>();
  755. var tasks = new List<Task<TResult>>();
  756. int index = 0;
  757. foreach (var item in source)
  758. {
  759. var task = selector(item, index);
  760. tasks.Add(task);
  761. Interlocked.Add(ref index, 1);
  762. if (tasks.Count >= maxParallelCount)
  763. {
  764. await Task.WhenAny(tasks);
  765. var completedTasks = tasks.Where(t => t.IsCompleted).ToArray();
  766. results.AddRange(completedTasks.Select(t => t.Result));
  767. tasks.RemoveWhere(t => completedTasks.Contains(t));
  768. }
  769. }
  770. results.AddRange(await Task.WhenAll(tasks));
  771. return results;
  772. }
  773. /// <summary>
  774. /// 异步For
  775. /// </summary>
  776. /// <typeparam name="T"></typeparam>
  777. /// <param name="source"></param>
  778. /// <param name="selector"></param>
  779. /// <param name="maxParallelCount">最大并行数</param>
  780. /// <param name="cancellationToken">取消口令</param>
  781. /// <returns></returns>
  782. public static async Task ForAsync<T>(this IEnumerable<T> source, Func<T, int, Task> selector, int maxParallelCount, CancellationToken cancellationToken = default)
  783. {
  784. int index = 0;
  785. if (Debugger.IsAttached)
  786. {
  787. foreach (var item in source)
  788. {
  789. await selector(item, index);
  790. index++;
  791. }
  792. return;
  793. }
  794. var list = new List<Task>();
  795. foreach (var item in source)
  796. {
  797. if (cancellationToken.IsCancellationRequested)
  798. {
  799. return;
  800. }
  801. list.Add(selector(item, index));
  802. Interlocked.Add(ref index, 1);
  803. if (list.Count >= maxParallelCount)
  804. {
  805. await Task.WhenAny(list);
  806. list.RemoveAll(t => t.IsCompleted);
  807. }
  808. }
  809. await Task.WhenAll(list);
  810. }
  811. /// <summary>
  812. /// 异步For
  813. /// </summary>
  814. /// <typeparam name="T"></typeparam>
  815. /// <param name="source"></param>
  816. /// <param name="selector"></param>
  817. /// <param name="cancellationToken">取消口令</param>
  818. /// <returns></returns>
  819. public static Task ForAsync<T>(this IEnumerable<T> source, Func<T, int, Task> selector, CancellationToken cancellationToken = default)
  820. {
  821. if (source is ICollection<T> collection)
  822. {
  823. return ForAsync(collection, selector, collection.Count, cancellationToken);
  824. }
  825. var list = source.ToList();
  826. return ForAsync(list, selector, list.Count, cancellationToken);
  827. }
  828. /// <summary>
  829. /// 取最大值
  830. /// </summary>
  831. /// <typeparam name="TSource"></typeparam>
  832. /// <typeparam name="TResult"></typeparam>
  833. /// <param name="source"></param>
  834. /// <param name="selector"></param>
  835. /// <returns></returns>
  836. public static TResult MaxOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector) => source.Select(selector).DefaultIfEmpty().Max();
  837. /// <summary>
  838. /// 取最大值
  839. /// </summary>
  840. /// <typeparam name="TSource"></typeparam>
  841. /// <typeparam name="TResult"></typeparam>
  842. /// <param name="source"></param>
  843. /// <param name="selector"></param>
  844. /// <param name="defaultValue"></param>
  845. /// <returns></returns>
  846. public static TResult MaxOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Max();
  847. /// <summary>
  848. /// 取最大值
  849. /// </summary>
  850. /// <typeparam name="TSource"></typeparam>
  851. /// <param name="source"></param>
  852. /// <returns></returns>
  853. public static TSource MaxOrDefault<TSource>(this IQueryable<TSource> source) => source.DefaultIfEmpty().Max();
  854. /// <summary>
  855. /// 取最大值
  856. /// </summary>
  857. /// <typeparam name="TSource"></typeparam>
  858. /// <param name="source"></param>
  859. /// <param name="defaultValue"></param>
  860. /// <returns></returns>
  861. public static TSource MaxOrDefault<TSource>(this IQueryable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Max();
  862. /// <summary>
  863. /// 取最大值
  864. /// </summary>
  865. /// <typeparam name="TSource"></typeparam>
  866. /// <typeparam name="TResult"></typeparam>
  867. /// <param name="source"></param>
  868. /// <param name="selector"></param>
  869. /// <param name="defaultValue"></param>
  870. /// <returns></returns>
  871. public static TResult MaxOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Max();
  872. /// <summary>
  873. /// 取最大值
  874. /// </summary>
  875. /// <typeparam name="TSource"></typeparam>
  876. /// <typeparam name="TResult"></typeparam>
  877. /// <param name="source"></param>
  878. /// <param name="selector"></param>
  879. /// <returns></returns>
  880. public static TResult MaxOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector) => source.Select(selector).DefaultIfEmpty().Max();
  881. /// <summary>
  882. /// 取最大值
  883. /// </summary>
  884. /// <typeparam name="TSource"></typeparam>
  885. /// <param name="source"></param>
  886. /// <returns></returns>
  887. public static TSource MaxOrDefault<TSource>(this IEnumerable<TSource> source) => source.DefaultIfEmpty().Max();
  888. /// <summary>
  889. /// 取最大值
  890. /// </summary>
  891. /// <typeparam name="TSource"></typeparam>
  892. /// <param name="source"></param>
  893. /// <param name="defaultValue"></param>
  894. /// <returns></returns>
  895. public static TSource MaxOrDefault<TSource>(this IEnumerable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Max();
  896. /// <summary>
  897. /// 取最小值
  898. /// </summary>
  899. /// <typeparam name="TSource"></typeparam>
  900. /// <typeparam name="TResult"></typeparam>
  901. /// <param name="source"></param>
  902. /// <param name="selector"></param>
  903. /// <returns></returns>
  904. public static TResult MinOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector) => source.Select(selector).DefaultIfEmpty().Min();
  905. /// <summary>
  906. /// 取最小值
  907. /// </summary>
  908. /// <typeparam name="TSource"></typeparam>
  909. /// <typeparam name="TResult"></typeparam>
  910. /// <param name="source"></param>
  911. /// <param name="selector"></param>
  912. /// <param name="defaultValue"></param>
  913. /// <returns></returns>
  914. public static TResult MinOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Min();
  915. /// <summary>
  916. /// 取最小值
  917. /// </summary>
  918. /// <typeparam name="TSource"></typeparam>
  919. /// <param name="source"></param>
  920. /// <returns></returns>
  921. public static TSource MinOrDefault<TSource>(this IQueryable<TSource> source) => source.DefaultIfEmpty().Min();
  922. /// <summary>
  923. /// 取最小值
  924. /// </summary>
  925. /// <typeparam name="TSource"></typeparam>
  926. /// <param name="source"></param>
  927. /// <param name="defaultValue"></param>
  928. /// <returns></returns>
  929. public static TSource MinOrDefault<TSource>(this IQueryable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Min();
  930. /// <summary>
  931. /// 取最小值
  932. /// </summary>
  933. /// <typeparam name="TSource"></typeparam>
  934. /// <typeparam name="TResult"></typeparam>
  935. /// <param name="source"></param>
  936. /// <param name="selector"></param>
  937. /// <returns></returns>
  938. public static TResult MinOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector) => source.Select(selector).DefaultIfEmpty().Min();
  939. /// <summary>
  940. /// 取最小值
  941. /// </summary>
  942. /// <typeparam name="TSource"></typeparam>
  943. /// <typeparam name="TResult"></typeparam>
  944. /// <param name="source"></param>
  945. /// <param name="selector"></param>
  946. /// <param name="defaultValue"></param>
  947. /// <returns></returns>
  948. public static TResult MinOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Min();
  949. /// <summary>
  950. /// 取最小值
  951. /// </summary>
  952. /// <typeparam name="TSource"></typeparam>
  953. /// <param name="source"></param>
  954. /// <returns></returns>
  955. public static TSource MinOrDefault<TSource>(this IEnumerable<TSource> source) => source.DefaultIfEmpty().Min();
  956. /// <summary>
  957. /// 取最小值
  958. /// </summary>
  959. /// <typeparam name="TSource"></typeparam>
  960. /// <param name="source"></param>
  961. /// <param name="defaultValue"></param>
  962. /// <returns></returns>
  963. public static TSource MinOrDefault<TSource>(this IEnumerable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Min();
  964. /// <summary>
  965. /// 标准差
  966. /// </summary>
  967. /// <typeparam name="T"></typeparam>
  968. /// <typeparam name="TResult"></typeparam>
  969. /// <param name="source"></param>
  970. /// <param name="selector"></param>
  971. /// <returns></returns>
  972. public static TResult StandardDeviation<T, TResult>(this IEnumerable<T> source, Func<T, TResult> selector) where TResult : IConvertible
  973. {
  974. return StandardDeviation(source.Select(t => selector(t).ConvertTo<double>())).ConvertTo<TResult>();
  975. }
  976. /// <summary>
  977. /// 标准差
  978. /// </summary>
  979. /// <typeparam name="T"></typeparam>
  980. /// <param name="source"></param>
  981. /// <returns></returns>
  982. public static T StandardDeviation<T>(this IEnumerable<T> source) where T : IConvertible
  983. {
  984. return StandardDeviation(source.Select(t => t.ConvertTo<double>())).ConvertTo<T>();
  985. }
  986. /// <summary>
  987. /// 标准差
  988. /// </summary>
  989. /// <param name="source"></param>
  990. /// <returns></returns>
  991. public static double StandardDeviation(this IEnumerable<double> source)
  992. {
  993. double result = 0;
  994. var list = source as ICollection<double> ?? source.ToList();
  995. int count = list.Count;
  996. if (count > 1)
  997. {
  998. var avg = list.Average();
  999. var sum = list.Sum(d => (d - avg) * (d - avg));
  1000. result = Math.Sqrt(sum / count);
  1001. }
  1002. return result;
  1003. }
  1004. /// <summary>
  1005. /// 随机排序
  1006. /// </summary>
  1007. /// <typeparam name="T"></typeparam>
  1008. /// <param name="source"></param>
  1009. /// <returns></returns>
  1010. public static IOrderedEnumerable<T> OrderByRandom<T>(this IEnumerable<T> source)
  1011. {
  1012. return source.OrderBy(_ => Guid.NewGuid());
  1013. }
  1014. /// <summary>
  1015. /// 序列相等
  1016. /// </summary>
  1017. /// <typeparam name="T"></typeparam>
  1018. /// <param name="first"></param>
  1019. /// <param name="second"></param>
  1020. /// <param name="condition"></param>
  1021. /// <returns></returns>
  1022. public static bool SequenceEqual<T>(this IEnumerable<T> first, IEnumerable<T> second, Func<T, T, bool> condition)
  1023. {
  1024. if (first is ICollection<T> source1 && second is ICollection<T> source2)
  1025. {
  1026. if (source1.Count != source2.Count)
  1027. {
  1028. return false;
  1029. }
  1030. if (source1 is IList<T> list1 && source2 is IList<T> list2)
  1031. {
  1032. int count = source1.Count;
  1033. for (int index = 0; index < count; ++index)
  1034. {
  1035. if (!condition(list1[index], list2[index]))
  1036. {
  1037. return false;
  1038. }
  1039. }
  1040. return true;
  1041. }
  1042. }
  1043. using IEnumerator<T> enumerator1 = first.GetEnumerator();
  1044. using IEnumerator<T> enumerator2 = second.GetEnumerator();
  1045. while (enumerator1.MoveNext())
  1046. {
  1047. if (!enumerator2.MoveNext() || !condition(enumerator1.Current, enumerator2.Current))
  1048. {
  1049. return false;
  1050. }
  1051. }
  1052. return !enumerator2.MoveNext();
  1053. }
  1054. /// <summary>
  1055. /// 序列相等
  1056. /// </summary>
  1057. /// <typeparam name="T1"></typeparam>
  1058. /// <typeparam name="T2"></typeparam>
  1059. /// <param name="first"></param>
  1060. /// <param name="second"></param>
  1061. /// <param name="condition"></param>
  1062. /// <returns></returns>
  1063. public static bool SequenceEqual<T1, T2>(this IEnumerable<T1> first, IEnumerable<T2> second, Func<T1, T2, bool> condition)
  1064. {
  1065. if (first is ICollection<T1> source1 && second is ICollection<T2> source2)
  1066. {
  1067. if (source1.Count != source2.Count)
  1068. {
  1069. return false;
  1070. }
  1071. if (source1 is IList<T1> list1 && source2 is IList<T2> list2)
  1072. {
  1073. int count = source1.Count;
  1074. for (int index = 0; index < count; ++index)
  1075. {
  1076. if (!condition(list1[index], list2[index]))
  1077. {
  1078. return false;
  1079. }
  1080. }
  1081. return true;
  1082. }
  1083. }
  1084. using IEnumerator<T1> enumerator1 = first.GetEnumerator();
  1085. using IEnumerator<T2> enumerator2 = second.GetEnumerator();
  1086. while (enumerator1.MoveNext())
  1087. {
  1088. if (!enumerator2.MoveNext() || !condition(enumerator1.Current, enumerator2.Current))
  1089. {
  1090. return false;
  1091. }
  1092. }
  1093. return !enumerator2.MoveNext();
  1094. }
  1095. /// <summary>
  1096. /// 对比两个集合哪些是新增的、删除的、修改的
  1097. /// </summary>
  1098. /// <param name="first">新集合</param>
  1099. /// <param name="second">旧集合</param>
  1100. /// <returns></returns>
  1101. public static (List<T> adds, List<T> remove, List<T> updates) CompareChanges<T>(this IEnumerable<T> first, IEnumerable<T> second)
  1102. {
  1103. first ??= new List<T>();
  1104. second ??= new List<T>();
  1105. var firstSource = first as ICollection<T> ?? first.ToList();
  1106. var secondSource = second as ICollection<T> ?? second.ToList();
  1107. var add = firstSource.Except(secondSource).ToList();
  1108. var remove = secondSource.Except(firstSource).ToList();
  1109. var update = firstSource.Intersect(secondSource).ToList();
  1110. return (add, remove, update);
  1111. }
  1112. /// <summary>
  1113. /// 对比两个集合哪些是新增的、删除的、修改的
  1114. /// </summary>
  1115. /// <typeparam name="TKey">对比因素</typeparam>
  1116. /// <param name="first">新集合</param>
  1117. /// <param name="second">旧集合</param>
  1118. /// <param name="keySelector">对比因素(可唯一确定元素的字段)</param>
  1119. /// <returns></returns>
  1120. public static (List<T> adds, List<T> remove, List<T> updates) CompareChanges<T, TKey>(this IEnumerable<T> first, IEnumerable<T> second, Func<T, TKey> keySelector)
  1121. {
  1122. first ??= new List<T>();
  1123. second ??= new List<T>();
  1124. var firstSource = first as ICollection<T> ?? first.ToList();
  1125. var secondSource = second as ICollection<T> ?? second.ToList();
  1126. var add = firstSource.ExceptBy(secondSource, keySelector).ToList();
  1127. var remove = secondSource.ExceptBy(firstSource, keySelector).ToList();
  1128. var update = firstSource.IntersectBy(secondSource, keySelector).ToList();
  1129. return (add, remove, update);
  1130. }
  1131. /// <summary>
  1132. /// 对比两个集合哪些是新增的、删除的、修改的
  1133. /// </summary>
  1134. /// <typeparam name="T1"></typeparam>
  1135. /// <typeparam name="T2"></typeparam>
  1136. /// <param name="first">新集合</param>
  1137. /// <param name="second">旧集合</param>
  1138. /// <param name="condition">对比因素条件</param>
  1139. /// <returns></returns>
  1140. public static (List<T1> adds, List<T2> remove, List<T1> updates) CompareChanges<T1, T2>(this IEnumerable<T1> first, IEnumerable<T2> second, Func<T1, T2, bool> condition)
  1141. {
  1142. first ??= new List<T1>();
  1143. second ??= new List<T2>();
  1144. var firstSource = first as ICollection<T1> ?? first.ToList();
  1145. var secondSource = second as ICollection<T2> ?? second.ToList();
  1146. var add = firstSource.ExceptBy(secondSource, condition).ToList();
  1147. var remove = secondSource.ExceptBy(firstSource, (s, f) => condition(f, s)).ToList();
  1148. var update = firstSource.IntersectBy(secondSource, condition).ToList();
  1149. return (add, remove, update);
  1150. }
  1151. /// <summary>
  1152. /// 对比两个集合哪些是新增的、删除的、修改的
  1153. /// </summary>
  1154. /// <typeparam name="T1">集合1</typeparam>
  1155. /// <typeparam name="T2">集合2</typeparam>
  1156. /// <typeparam name="TKey">对比因素</typeparam>
  1157. /// <param name="first">新集合</param>
  1158. /// <param name="second">旧集合</param>
  1159. /// <param name="firstKeySelector">集合1的对比因素(可唯一确定元素的字段)</param>
  1160. /// <param name="secondKeySelector">集合2的对比因素(可唯一确定元素的字段)</param>
  1161. /// <returns></returns>
  1162. public static (List<T1> adds, List<T2> remove, List<T1> updates) CompareChanges<T1, T2, TKey>(this IEnumerable<T1> first, IEnumerable<T2> second, Func<T1, TKey> firstKeySelector, Func<T2, TKey> secondKeySelector)
  1163. {
  1164. first ??= new List<T1>();
  1165. second ??= new List<T2>();
  1166. var firstLookup = first.ToLookup(firstKeySelector);
  1167. var secondLookup = second.ToLookup(secondKeySelector);
  1168. var adds = firstLookup.Where(kvp => !secondLookup.Contains(kvp.Key)).SelectMany(kvp => kvp).ToList();
  1169. var removes = secondLookup.Where(kvp => !firstLookup.Contains(kvp.Key)).SelectMany(kvp => kvp).ToList();
  1170. var updates = firstLookup.Where(kvp => secondLookup.Contains(kvp.Key)).SelectMany(kvp => kvp).ToList();
  1171. return (adds, removes, updates);
  1172. }
  1173. /// <summary>
  1174. /// 对比两个集合哪些是新增的、删除的、修改的
  1175. /// </summary>
  1176. /// <param name="first">新集合</param>
  1177. /// <param name="second">旧集合</param>
  1178. /// <returns></returns>
  1179. public static (List<T> adds, List<T> remove, List<(T first, T second)> updates) CompareChangesPlus<T>(this IEnumerable<T> first, IEnumerable<T> second)
  1180. {
  1181. first ??= new List<T>();
  1182. second ??= new List<T>();
  1183. var firstSource = first as ICollection<T> ?? first.ToList();
  1184. var secondSource = second as ICollection<T> ?? second.ToList();
  1185. var add = firstSource.Except(secondSource).ToList();
  1186. var remove = secondSource.Except(firstSource).ToList();
  1187. var updates = firstSource.Intersect(secondSource).Select(t1 => (t1, secondSource.FirstOrDefault(t2 => t1.Equals(t2)))).ToList();
  1188. return (add, remove, updates);
  1189. }
  1190. /// <summary>
  1191. /// 对比两个集合哪些是新增的、删除的、修改的
  1192. /// </summary>
  1193. /// <param name="first">新集合</param>
  1194. /// <param name="second">旧集合</param>
  1195. /// <param name="keySelector">对比因素</param>
  1196. /// <returns></returns>
  1197. public static (List<T> adds, List<T> remove, List<(T first, T second)> updates) CompareChangesPlus<T, TKey>(this IEnumerable<T> first, IEnumerable<T> second, Func<T, TKey> keySelector)
  1198. {
  1199. first ??= new List<T>();
  1200. second ??= new List<T>();
  1201. var firstSource = first as ICollection<T> ?? first.ToList();
  1202. var secondSource = second as ICollection<T> ?? second.ToList();
  1203. var add = firstSource.ExceptBy(secondSource, keySelector).ToList();
  1204. var remove = secondSource.ExceptBy(firstSource, keySelector).ToList();
  1205. var updates = firstSource.IntersectBy(secondSource, keySelector).Select(t1 => (t1, secondSource.FirstOrDefault(t2 => keySelector(t1).Equals(keySelector(t2))))).ToList();
  1206. return (add, remove, updates);
  1207. }
  1208. /// <summary>
  1209. /// 对比两个集合哪些是新增的、删除的、修改的
  1210. /// </summary>
  1211. /// <typeparam name="T1"></typeparam>
  1212. /// <typeparam name="T2"></typeparam>
  1213. /// <param name="first">新集合</param>
  1214. /// <param name="second">旧集合</param>
  1215. /// <param name="condition">对比因素条件</param>
  1216. /// <returns></returns>
  1217. public static (List<T1> adds, List<T2> remove, List<(T1 first, T2 second)> updates) CompareChangesPlus<T1, T2>(this IEnumerable<T1> first, IEnumerable<T2> second, Func<T1, T2, bool> condition)
  1218. {
  1219. first ??= new List<T1>();
  1220. second ??= new List<T2>();
  1221. var firstSource = first as ICollection<T1> ?? first.ToList();
  1222. var secondSource = second as ICollection<T2> ?? second.ToList();
  1223. var add = firstSource.ExceptBy(secondSource, condition).ToList();
  1224. var remove = secondSource.ExceptBy(firstSource, (s, f) => condition(f, s)).ToList();
  1225. var updates = firstSource.IntersectBy(secondSource, condition).Select(t1 => (t1, secondSource.FirstOrDefault(t2 => condition(t1, t2)))).ToList();
  1226. return (add, remove, updates);
  1227. }
  1228. /// <summary>
  1229. /// 对比两个集合哪些是新增的、删除的、修改的
  1230. /// </summary>
  1231. /// <typeparam name="T1"></typeparam>
  1232. /// <typeparam name="T2"></typeparam>
  1233. /// <param name="first">新集合</param>
  1234. /// <param name="second">旧集合</param>
  1235. /// <param name="firstKeySelector">集合1的对比因素(可唯一确定元素的字段)</param>
  1236. /// <param name="secondKeySelector">集合2的对比因素(可唯一确定元素的字段)</param>
  1237. /// <returns></returns>
  1238. public static (List<T1> adds, List<T2> remove, List<(T1 first, T2 second)> updates) CompareChangesPlus<T1, T2, TKey>(this IEnumerable<T1> first, IEnumerable<T2> second, Func<T1, TKey> firstKeySelector, Func<T2, TKey> secondKeySelector)
  1239. {
  1240. first ??= new List<T1>();
  1241. second ??= new List<T2>();
  1242. var firstDict = first.ToLookup(firstKeySelector);
  1243. var secondDict = second.ToLookup(secondKeySelector);
  1244. var add = new List<T1>();
  1245. var remove = new List<T2>();
  1246. var updates = new List<(T1 first, T2 second)>();
  1247. foreach (var x in firstDict)
  1248. {
  1249. if (secondDict.Contains(x.Key))
  1250. {
  1251. updates.Add((x.First(), secondDict[x.Key].First()));
  1252. }
  1253. else
  1254. {
  1255. add.AddRange(x);
  1256. }
  1257. }
  1258. foreach (var x in secondDict.Where(x => !firstDict.Contains(x.Key)))
  1259. {
  1260. remove.AddRange(x);
  1261. }
  1262. return (add, remove, updates);
  1263. }
  1264. /// <summary>
  1265. /// 将集合声明为非null集合
  1266. /// </summary>
  1267. /// <typeparam name="T"></typeparam>
  1268. /// <param name="list"></param>
  1269. /// <returns></returns>
  1270. public static List<T> AsNotNull<T>(this List<T> list)
  1271. {
  1272. return list ?? new List<T>();
  1273. }
  1274. /// <summary>
  1275. /// 将集合声明为非null集合
  1276. /// </summary>
  1277. /// <typeparam name="T"></typeparam>
  1278. /// <param name="list"></param>
  1279. /// <returns></returns>
  1280. public static IEnumerable<T> AsNotNull<T>(this IEnumerable<T> list)
  1281. {
  1282. return list ?? new List<T>();
  1283. }
  1284. /// <summary>
  1285. /// 满足条件时执行筛选条件
  1286. /// </summary>
  1287. /// <typeparam name="T"></typeparam>
  1288. /// <param name="source"></param>
  1289. /// <param name="condition"></param>
  1290. /// <param name="where"></param>
  1291. /// <returns></returns>
  1292. public static IEnumerable<T> WhereIf<T>(this IEnumerable<T> source, bool condition, Func<T, bool> where)
  1293. {
  1294. return condition ? source.Where(where) : source;
  1295. }
  1296. /// <summary>
  1297. /// 满足条件时执行筛选条件
  1298. /// </summary>
  1299. /// <typeparam name="T"></typeparam>
  1300. /// <param name="source"></param>
  1301. /// <param name="condition"></param>
  1302. /// <param name="where"></param>
  1303. /// <returns></returns>
  1304. public static IEnumerable<T> WhereIf<T>(this IEnumerable<T> source, Func<bool> condition, Func<T, bool> where)
  1305. {
  1306. return condition() ? source.Where(where) : source;
  1307. }
  1308. /// <summary>
  1309. /// 满足条件时执行筛选条件
  1310. /// </summary>
  1311. /// <typeparam name="T"></typeparam>
  1312. /// <param name="source"></param>
  1313. /// <param name="condition"></param>
  1314. /// <param name="where"></param>
  1315. /// <returns></returns>
  1316. public static IQueryable<T> WhereIf<T>(this IQueryable<T> source, bool condition, Expression<Func<T, bool>> where)
  1317. {
  1318. return condition ? source.Where(where) : source;
  1319. }
  1320. /// <summary>
  1321. /// 满足条件时执行筛选条件
  1322. /// </summary>
  1323. /// <typeparam name="T"></typeparam>
  1324. /// <param name="source"></param>
  1325. /// <param name="condition"></param>
  1326. /// <param name="where"></param>
  1327. /// <returns></returns>
  1328. public static IQueryable<T> WhereIf<T>(this IQueryable<T> source, Func<bool> condition, Expression<Func<T, bool>> where)
  1329. {
  1330. return condition() ? source.Where(where) : source;
  1331. }
  1332. /// <summary>
  1333. /// 改变元素的索引位置
  1334. /// </summary>
  1335. /// <typeparam name="T"></typeparam>
  1336. /// <param name="list">集合</param>
  1337. /// <param name="item">元素</param>
  1338. /// <param name="index">索引值</param>
  1339. /// <exception cref="ArgumentNullException"></exception>
  1340. public static IList<T> ChangeIndex<T>(this IList<T> list, T item, int index)
  1341. {
  1342. if (item is null)
  1343. {
  1344. throw new ArgumentNullException(nameof(item));
  1345. }
  1346. ChangeIndexInternal(list, item, index);
  1347. return list;
  1348. }
  1349. /// <summary>
  1350. /// 改变元素的索引位置
  1351. /// </summary>
  1352. /// <typeparam name="T"></typeparam>
  1353. /// <param name="list">集合</param>
  1354. /// <param name="condition">元素定位条件</param>
  1355. /// <param name="index">索引值</param>
  1356. public static IList<T> ChangeIndex<T>(this IList<T> list, Func<T, bool> condition, int index)
  1357. {
  1358. var item = list.FirstOrDefault(condition);
  1359. if (item != null)
  1360. {
  1361. ChangeIndexInternal(list, item, index);
  1362. }
  1363. return list;
  1364. }
  1365. private static void ChangeIndexInternal<T>(IList<T> list, T item, int index)
  1366. {
  1367. index = Math.Max(0, index);
  1368. index = Math.Min(list.Count - 1, index);
  1369. list.Remove(item);
  1370. list.Insert(index, item);
  1371. }
  1372. }