IEnumerableExtensions.cs 52 KB

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