IEnumerableExtensions.cs 53 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554
  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, CancellationToken cancellationToken = default)
  724. {
  725. var results = new List<TResult>();
  726. var tasks = new List<Task<TResult>>();
  727. foreach (var item in source)
  728. {
  729. if (cancellationToken.IsCancellationRequested)
  730. {
  731. break;
  732. }
  733. var task = selector(item);
  734. tasks.Add(task);
  735. if (tasks.Count >= maxParallelCount)
  736. {
  737. await Task.WhenAny(tasks);
  738. var completedTasks = tasks.Where(t => t.IsCompleted).ToArray();
  739. results.AddRange(completedTasks.Select(t => t.Result));
  740. tasks.RemoveWhere(t => completedTasks.Contains(t));
  741. }
  742. }
  743. results.AddRange(await Task.WhenAll(tasks));
  744. return results;
  745. }
  746. /// <summary>
  747. /// 异步Select
  748. /// </summary>
  749. /// <typeparam name="T"></typeparam>
  750. /// <typeparam name="TResult"></typeparam>
  751. /// <param name="source"></param>
  752. /// <param name="selector"></param>
  753. /// <param name="maxParallelCount">最大并行数</param>
  754. /// <returns></returns>
  755. public static async Task<List<TResult>> SelectAsync<T, TResult>(this IEnumerable<T> source, Func<T, int, Task<TResult>> selector, int maxParallelCount, CancellationToken cancellationToken = default)
  756. {
  757. var results = new List<TResult>();
  758. var tasks = new List<Task<TResult>>();
  759. int index = 0;
  760. foreach (var item in source)
  761. {
  762. if (cancellationToken.IsCancellationRequested)
  763. {
  764. break;
  765. }
  766. var task = selector(item, index);
  767. tasks.Add(task);
  768. Interlocked.Add(ref index, 1);
  769. if (tasks.Count >= maxParallelCount)
  770. {
  771. await Task.WhenAny(tasks);
  772. var completedTasks = tasks.Where(t => t.IsCompleted).ToArray();
  773. results.AddRange(completedTasks.Select(t => t.Result));
  774. tasks.RemoveWhere(t => completedTasks.Contains(t));
  775. }
  776. }
  777. results.AddRange(await Task.WhenAll(tasks));
  778. return results;
  779. }
  780. /// <summary>
  781. /// 异步For
  782. /// </summary>
  783. /// <typeparam name="T"></typeparam>
  784. /// <param name="source"></param>
  785. /// <param name="selector"></param>
  786. /// <param name="maxParallelCount">最大并行数</param>
  787. /// <param name="cancellationToken">取消口令</param>
  788. /// <returns></returns>
  789. public static async Task ForAsync<T>(this IEnumerable<T> source, Func<T, int, Task> selector, int maxParallelCount, CancellationToken cancellationToken = default)
  790. {
  791. int index = 0;
  792. if (Debugger.IsAttached)
  793. {
  794. foreach (var item in source)
  795. {
  796. await selector(item, index);
  797. index++;
  798. }
  799. return;
  800. }
  801. var list = new List<Task>();
  802. foreach (var item in source)
  803. {
  804. if (cancellationToken.IsCancellationRequested)
  805. {
  806. return;
  807. }
  808. list.Add(selector(item, index));
  809. Interlocked.Add(ref index, 1);
  810. if (list.Count >= maxParallelCount)
  811. {
  812. await Task.WhenAny(list);
  813. list.RemoveAll(t => t.IsCompleted);
  814. }
  815. }
  816. await Task.WhenAll(list);
  817. }
  818. /// <summary>
  819. /// 异步For
  820. /// </summary>
  821. /// <typeparam name="T"></typeparam>
  822. /// <param name="source"></param>
  823. /// <param name="selector"></param>
  824. /// <param name="cancellationToken">取消口令</param>
  825. /// <returns></returns>
  826. public static Task ForAsync<T>(this IEnumerable<T> source, Func<T, int, Task> selector, CancellationToken cancellationToken = default)
  827. {
  828. if (source is ICollection<T> collection)
  829. {
  830. return ForAsync(collection, selector, collection.Count, cancellationToken);
  831. }
  832. var list = source.ToList();
  833. return ForAsync(list, selector, list.Count, cancellationToken);
  834. }
  835. /// <summary>
  836. /// 取最大值
  837. /// </summary>
  838. /// <typeparam name="TSource"></typeparam>
  839. /// <typeparam name="TResult"></typeparam>
  840. /// <param name="source"></param>
  841. /// <param name="selector"></param>
  842. /// <returns></returns>
  843. public static TResult MaxOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector) => source.Select(selector).DefaultIfEmpty().Max();
  844. /// <summary>
  845. /// 取最大值
  846. /// </summary>
  847. /// <typeparam name="TSource"></typeparam>
  848. /// <typeparam name="TResult"></typeparam>
  849. /// <param name="source"></param>
  850. /// <param name="selector"></param>
  851. /// <param name="defaultValue"></param>
  852. /// <returns></returns>
  853. public static TResult MaxOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Max();
  854. /// <summary>
  855. /// 取最大值
  856. /// </summary>
  857. /// <typeparam name="TSource"></typeparam>
  858. /// <param name="source"></param>
  859. /// <returns></returns>
  860. public static TSource MaxOrDefault<TSource>(this IQueryable<TSource> source) => source.DefaultIfEmpty().Max();
  861. /// <summary>
  862. /// 取最大值
  863. /// </summary>
  864. /// <typeparam name="TSource"></typeparam>
  865. /// <param name="source"></param>
  866. /// <param name="defaultValue"></param>
  867. /// <returns></returns>
  868. public static TSource MaxOrDefault<TSource>(this IQueryable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Max();
  869. /// <summary>
  870. /// 取最大值
  871. /// </summary>
  872. /// <typeparam name="TSource"></typeparam>
  873. /// <typeparam name="TResult"></typeparam>
  874. /// <param name="source"></param>
  875. /// <param name="selector"></param>
  876. /// <param name="defaultValue"></param>
  877. /// <returns></returns>
  878. public static TResult MaxOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Max();
  879. /// <summary>
  880. /// 取最大值
  881. /// </summary>
  882. /// <typeparam name="TSource"></typeparam>
  883. /// <typeparam name="TResult"></typeparam>
  884. /// <param name="source"></param>
  885. /// <param name="selector"></param>
  886. /// <returns></returns>
  887. public static TResult MaxOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector) => source.Select(selector).DefaultIfEmpty().Max();
  888. /// <summary>
  889. /// 取最大值
  890. /// </summary>
  891. /// <typeparam name="TSource"></typeparam>
  892. /// <param name="source"></param>
  893. /// <returns></returns>
  894. public static TSource MaxOrDefault<TSource>(this IEnumerable<TSource> source) => source.DefaultIfEmpty().Max();
  895. /// <summary>
  896. /// 取最大值
  897. /// </summary>
  898. /// <typeparam name="TSource"></typeparam>
  899. /// <param name="source"></param>
  900. /// <param name="defaultValue"></param>
  901. /// <returns></returns>
  902. public static TSource MaxOrDefault<TSource>(this IEnumerable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Max();
  903. /// <summary>
  904. /// 取最小值
  905. /// </summary>
  906. /// <typeparam name="TSource"></typeparam>
  907. /// <typeparam name="TResult"></typeparam>
  908. /// <param name="source"></param>
  909. /// <param name="selector"></param>
  910. /// <returns></returns>
  911. public static TResult MinOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector) => source.Select(selector).DefaultIfEmpty().Min();
  912. /// <summary>
  913. /// 取最小值
  914. /// </summary>
  915. /// <typeparam name="TSource"></typeparam>
  916. /// <typeparam name="TResult"></typeparam>
  917. /// <param name="source"></param>
  918. /// <param name="selector"></param>
  919. /// <param name="defaultValue"></param>
  920. /// <returns></returns>
  921. public static TResult MinOrDefault<TSource, TResult>(this IQueryable<TSource> source, Expression<Func<TSource, TResult>> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Min();
  922. /// <summary>
  923. /// 取最小值
  924. /// </summary>
  925. /// <typeparam name="TSource"></typeparam>
  926. /// <param name="source"></param>
  927. /// <returns></returns>
  928. public static TSource MinOrDefault<TSource>(this IQueryable<TSource> source) => source.DefaultIfEmpty().Min();
  929. /// <summary>
  930. /// 取最小值
  931. /// </summary>
  932. /// <typeparam name="TSource"></typeparam>
  933. /// <param name="source"></param>
  934. /// <param name="defaultValue"></param>
  935. /// <returns></returns>
  936. public static TSource MinOrDefault<TSource>(this IQueryable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Min();
  937. /// <summary>
  938. /// 取最小值
  939. /// </summary>
  940. /// <typeparam name="TSource"></typeparam>
  941. /// <typeparam name="TResult"></typeparam>
  942. /// <param name="source"></param>
  943. /// <param name="selector"></param>
  944. /// <returns></returns>
  945. public static TResult MinOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector) => source.Select(selector).DefaultIfEmpty().Min();
  946. /// <summary>
  947. /// 取最小值
  948. /// </summary>
  949. /// <typeparam name="TSource"></typeparam>
  950. /// <typeparam name="TResult"></typeparam>
  951. /// <param name="source"></param>
  952. /// <param name="selector"></param>
  953. /// <param name="defaultValue"></param>
  954. /// <returns></returns>
  955. public static TResult MinOrDefault<TSource, TResult>(this IEnumerable<TSource> source, Func<TSource, TResult> selector, TResult defaultValue) => source.Select(selector).DefaultIfEmpty(defaultValue).Min();
  956. /// <summary>
  957. /// 取最小值
  958. /// </summary>
  959. /// <typeparam name="TSource"></typeparam>
  960. /// <param name="source"></param>
  961. /// <returns></returns>
  962. public static TSource MinOrDefault<TSource>(this IEnumerable<TSource> source) => source.DefaultIfEmpty().Min();
  963. /// <summary>
  964. /// 取最小值
  965. /// </summary>
  966. /// <typeparam name="TSource"></typeparam>
  967. /// <param name="source"></param>
  968. /// <param name="defaultValue"></param>
  969. /// <returns></returns>
  970. public static TSource MinOrDefault<TSource>(this IEnumerable<TSource> source, TSource defaultValue) => source.DefaultIfEmpty(defaultValue).Min();
  971. /// <summary>
  972. /// 标准差
  973. /// </summary>
  974. /// <typeparam name="T"></typeparam>
  975. /// <typeparam name="TResult"></typeparam>
  976. /// <param name="source"></param>
  977. /// <param name="selector"></param>
  978. /// <returns></returns>
  979. public static TResult StandardDeviation<T, TResult>(this IEnumerable<T> source, Func<T, TResult> selector) where TResult : IConvertible
  980. {
  981. return StandardDeviation(source.Select(t => selector(t).ConvertTo<double>())).ConvertTo<TResult>();
  982. }
  983. /// <summary>
  984. /// 标准差
  985. /// </summary>
  986. /// <typeparam name="T"></typeparam>
  987. /// <param name="source"></param>
  988. /// <returns></returns>
  989. public static T StandardDeviation<T>(this IEnumerable<T> source) where T : IConvertible
  990. {
  991. return StandardDeviation(source.Select(t => t.ConvertTo<double>())).ConvertTo<T>();
  992. }
  993. /// <summary>
  994. /// 标准差
  995. /// </summary>
  996. /// <param name="source"></param>
  997. /// <returns></returns>
  998. public static double StandardDeviation(this IEnumerable<double> source)
  999. {
  1000. double result = 0;
  1001. var list = source as ICollection<double> ?? source.ToList();
  1002. int count = list.Count;
  1003. if (count > 1)
  1004. {
  1005. var avg = list.Average();
  1006. var sum = list.Sum(d => (d - avg) * (d - avg));
  1007. result = Math.Sqrt(sum / count);
  1008. }
  1009. return result;
  1010. }
  1011. /// <summary>
  1012. /// 随机排序
  1013. /// </summary>
  1014. /// <typeparam name="T"></typeparam>
  1015. /// <param name="source"></param>
  1016. /// <returns></returns>
  1017. public static IOrderedEnumerable<T> OrderByRandom<T>(this IEnumerable<T> source)
  1018. {
  1019. return source.OrderBy(_ => Guid.NewGuid());
  1020. }
  1021. /// <summary>
  1022. /// 序列相等
  1023. /// </summary>
  1024. /// <typeparam name="T"></typeparam>
  1025. /// <param name="first"></param>
  1026. /// <param name="second"></param>
  1027. /// <param name="condition"></param>
  1028. /// <returns></returns>
  1029. public static bool SequenceEqual<T>(this IEnumerable<T> first, IEnumerable<T> second, Func<T, T, bool> condition)
  1030. {
  1031. if (first is ICollection<T> source1 && second is ICollection<T> source2)
  1032. {
  1033. if (source1.Count != source2.Count)
  1034. {
  1035. return false;
  1036. }
  1037. if (source1 is IList<T> list1 && source2 is IList<T> list2)
  1038. {
  1039. int count = source1.Count;
  1040. for (int index = 0; index < count; ++index)
  1041. {
  1042. if (!condition(list1[index], list2[index]))
  1043. {
  1044. return false;
  1045. }
  1046. }
  1047. return true;
  1048. }
  1049. }
  1050. using IEnumerator<T> enumerator1 = first.GetEnumerator();
  1051. using IEnumerator<T> enumerator2 = second.GetEnumerator();
  1052. while (enumerator1.MoveNext())
  1053. {
  1054. if (!enumerator2.MoveNext() || !condition(enumerator1.Current, enumerator2.Current))
  1055. {
  1056. return false;
  1057. }
  1058. }
  1059. return !enumerator2.MoveNext();
  1060. }
  1061. /// <summary>
  1062. /// 序列相等
  1063. /// </summary>
  1064. /// <typeparam name="T1"></typeparam>
  1065. /// <typeparam name="T2"></typeparam>
  1066. /// <param name="first"></param>
  1067. /// <param name="second"></param>
  1068. /// <param name="condition"></param>
  1069. /// <returns></returns>
  1070. public static bool SequenceEqual<T1, T2>(this IEnumerable<T1> first, IEnumerable<T2> second, Func<T1, T2, bool> condition)
  1071. {
  1072. if (first is ICollection<T1> source1 && second is ICollection<T2> source2)
  1073. {
  1074. if (source1.Count != source2.Count)
  1075. {
  1076. return false;
  1077. }
  1078. if (source1 is IList<T1> list1 && source2 is IList<T2> list2)
  1079. {
  1080. int count = source1.Count;
  1081. for (int index = 0; index < count; ++index)
  1082. {
  1083. if (!condition(list1[index], list2[index]))
  1084. {
  1085. return false;
  1086. }
  1087. }
  1088. return true;
  1089. }
  1090. }
  1091. using IEnumerator<T1> enumerator1 = first.GetEnumerator();
  1092. using IEnumerator<T2> enumerator2 = second.GetEnumerator();
  1093. while (enumerator1.MoveNext())
  1094. {
  1095. if (!enumerator2.MoveNext() || !condition(enumerator1.Current, enumerator2.Current))
  1096. {
  1097. return false;
  1098. }
  1099. }
  1100. return !enumerator2.MoveNext();
  1101. }
  1102. /// <summary>
  1103. /// 对比两个集合哪些是新增的、删除的、修改的
  1104. /// </summary>
  1105. /// <param name="first">新集合</param>
  1106. /// <param name="second">旧集合</param>
  1107. /// <returns></returns>
  1108. public static (List<T> adds, List<T> remove, List<T> updates) CompareChanges<T>(this IEnumerable<T> first, IEnumerable<T> second)
  1109. {
  1110. first ??= new List<T>();
  1111. second ??= new List<T>();
  1112. var firstSource = first as ICollection<T> ?? first.ToList();
  1113. var secondSource = second as ICollection<T> ?? second.ToList();
  1114. var add = firstSource.Except(secondSource).ToList();
  1115. var remove = secondSource.Except(firstSource).ToList();
  1116. var update = firstSource.Intersect(secondSource).ToList();
  1117. return (add, remove, update);
  1118. }
  1119. /// <summary>
  1120. /// 对比两个集合哪些是新增的、删除的、修改的
  1121. /// </summary>
  1122. /// <typeparam name="TKey">对比因素</typeparam>
  1123. /// <param name="first">新集合</param>
  1124. /// <param name="second">旧集合</param>
  1125. /// <param name="keySelector">对比因素(可唯一确定元素的字段)</param>
  1126. /// <returns></returns>
  1127. 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)
  1128. {
  1129. return CompareChanges(first, second, keySelector, keySelector);
  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. [Obsolete("大数据集时性能不佳,请考虑使用其他重载")]
  1141. 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)
  1142. {
  1143. if (first == null) throw new ArgumentNullException(nameof(first));
  1144. if (second == null) throw new ArgumentNullException(nameof(second));
  1145. if (condition == null) throw new ArgumentNullException(nameof(condition));
  1146. var adds = new List<T1>();
  1147. var removes = new List<T2>();
  1148. var updates = new List<T1>();
  1149. var secondSet = new HashSet<T2>(second);
  1150. foreach (var item in first)
  1151. {
  1152. var match = secondSet.FirstOrDefault(s => condition(item, s));
  1153. if (match != null)
  1154. {
  1155. updates.Add(item);
  1156. secondSet.Remove(match);
  1157. }
  1158. else
  1159. {
  1160. adds.Add(item);
  1161. }
  1162. }
  1163. removes.AddRange(secondSet);
  1164. return (adds, removes, updates);
  1165. }
  1166. /// <summary>
  1167. /// 对比两个集合哪些是新增的、删除的、修改的
  1168. /// </summary>
  1169. /// <typeparam name="T1">集合1</typeparam>
  1170. /// <typeparam name="T2">集合2</typeparam>
  1171. /// <typeparam name="TKey">对比因素</typeparam>
  1172. /// <param name="first">新集合</param>
  1173. /// <param name="second">旧集合</param>
  1174. /// <param name="firstKeySelector">集合1的对比因素(可唯一确定元素的字段)</param>
  1175. /// <param name="secondKeySelector">集合2的对比因素(可唯一确定元素的字段)</param>
  1176. /// <returns></returns>
  1177. 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)
  1178. {
  1179. first ??= new List<T1>();
  1180. second ??= new List<T2>();
  1181. var firstLookup = first.ToLookup(firstKeySelector);
  1182. var secondLookup = second.ToLookup(secondKeySelector);
  1183. var adds = new List<T1>();
  1184. var removes = new List<T2>();
  1185. var updates = new List<T1>();
  1186. foreach (var kvp in firstLookup)
  1187. {
  1188. if (secondLookup.Contains(kvp.Key))
  1189. {
  1190. updates.AddRange(kvp);
  1191. }
  1192. else
  1193. {
  1194. adds.AddRange(kvp);
  1195. }
  1196. }
  1197. foreach (var kvp in secondLookup.Where(kvp => !firstLookup.Contains(kvp.Key)))
  1198. {
  1199. removes.AddRange(kvp);
  1200. }
  1201. return (adds, removes, updates);
  1202. }
  1203. /// <summary>
  1204. /// 对比两个集合哪些是新增的、删除的、修改的
  1205. /// </summary>
  1206. /// <param name="first">新集合</param>
  1207. /// <param name="second">旧集合</param>
  1208. /// <returns></returns>
  1209. public static (List<T> adds, List<T> remove, List<(T first, T second)> updates) CompareChangesPlus<T>(this IEnumerable<T> first, IEnumerable<T> second)
  1210. {
  1211. first ??= new List<T>();
  1212. second ??= new List<T>();
  1213. var firstSource = first as ICollection<T> ?? first.ToList();
  1214. var secondSource = second as ICollection<T> ?? second.ToList();
  1215. var add = firstSource.Except(secondSource).ToList();
  1216. var remove = secondSource.Except(firstSource).ToList();
  1217. var updates = firstSource.Intersect(secondSource).Select(t1 => (t1, secondSource.FirstOrDefault(t2 => t1.Equals(t2)))).ToList();
  1218. return (add, remove, updates);
  1219. }
  1220. /// <summary>
  1221. /// 对比两个集合哪些是新增的、删除的、修改的
  1222. /// </summary>
  1223. /// <param name="first">新集合</param>
  1224. /// <param name="second">旧集合</param>
  1225. /// <param name="keySelector">对比因素</param>
  1226. /// <returns></returns>
  1227. 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)
  1228. {
  1229. return CompareChangesPlus(first, second, keySelector, keySelector);
  1230. }
  1231. /// <summary>
  1232. /// 对比两个集合哪些是新增的、删除的、修改的(大数据集时性能不佳,请考虑使用其他重载)
  1233. /// </summary>
  1234. /// <typeparam name="T1"></typeparam>
  1235. /// <typeparam name="T2"></typeparam>
  1236. /// <param name="first">新集合</param>
  1237. /// <param name="second">旧集合</param>
  1238. /// <param name="condition">对比因素条件</param>
  1239. /// <returns></returns>
  1240. [Obsolete("大数据集时性能不佳,请考虑使用其他重载")]
  1241. public static (List<T1> adds, List<T2> remove, List<(T1 first, T2 second)> updates) CompareChangesPlus<T1, T2>(
  1242. this IEnumerable<T1> first,
  1243. IEnumerable<T2> second,
  1244. Func<T1, T2, bool> condition)
  1245. {
  1246. if (first == null) throw new ArgumentNullException(nameof(first));
  1247. if (second == null) throw new ArgumentNullException(nameof(second));
  1248. if (condition == null) throw new ArgumentNullException(nameof(condition));
  1249. var adds = new List<T1>();
  1250. var removes = new List<T2>();
  1251. var updates = new List<(T1 first, T2 second)>();
  1252. var secondSet = new HashSet<T2>(second);
  1253. foreach (var item in first)
  1254. {
  1255. var match = secondSet.FirstOrDefault(s => condition(item, s));
  1256. if (match != null)
  1257. {
  1258. updates.Add((item, match));
  1259. secondSet.Remove(match);
  1260. }
  1261. else
  1262. {
  1263. adds.Add(item);
  1264. }
  1265. }
  1266. removes.AddRange(secondSet);
  1267. return (adds, removes, updates);
  1268. }
  1269. /// <summary>
  1270. /// 对比两个集合哪些是新增的、删除的、修改的
  1271. /// </summary>
  1272. /// <typeparam name="T1"></typeparam>
  1273. /// <typeparam name="T2"></typeparam>
  1274. /// <param name="first">新集合</param>
  1275. /// <param name="second">旧集合</param>
  1276. /// <param name="firstKeySelector">集合1的对比因素(可唯一确定元素的字段)</param>
  1277. /// <param name="secondKeySelector">集合2的对比因素(可唯一确定元素的字段)</param>
  1278. /// <returns></returns>
  1279. 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)
  1280. {
  1281. first ??= new List<T1>();
  1282. second ??= new List<T2>();
  1283. var lookup1 = first.ToLookup(firstKeySelector);
  1284. var lookup2 = second.ToLookup(secondKeySelector);
  1285. var add = new List<T1>();
  1286. var remove = new List<T2>();
  1287. var updates = new List<(T1 first, T2 second)>();
  1288. foreach (var x in lookup1)
  1289. {
  1290. if (lookup2.Contains(x.Key))
  1291. {
  1292. updates.Add((x.First(), lookup2[x.Key].First()));
  1293. }
  1294. else
  1295. {
  1296. add.AddRange(x);
  1297. }
  1298. }
  1299. foreach (var x in lookup2.Where(x => !lookup1.Contains(x.Key)))
  1300. {
  1301. remove.AddRange(x);
  1302. }
  1303. return (add, remove, updates);
  1304. }
  1305. /// <summary>
  1306. /// 将集合声明为非null集合
  1307. /// </summary>
  1308. /// <typeparam name="T"></typeparam>
  1309. /// <param name="list"></param>
  1310. /// <returns></returns>
  1311. public static List<T> AsNotNull<T>(this List<T> list)
  1312. {
  1313. return list ?? new List<T>();
  1314. }
  1315. /// <summary>
  1316. /// 将集合声明为非null集合
  1317. /// </summary>
  1318. /// <typeparam name="T"></typeparam>
  1319. /// <param name="list"></param>
  1320. /// <returns></returns>
  1321. public static IEnumerable<T> AsNotNull<T>(this IEnumerable<T> list)
  1322. {
  1323. return list ?? new List<T>();
  1324. }
  1325. /// <summary>
  1326. /// 满足条件时执行筛选条件
  1327. /// </summary>
  1328. /// <typeparam name="T"></typeparam>
  1329. /// <param name="source"></param>
  1330. /// <param name="condition"></param>
  1331. /// <param name="where"></param>
  1332. /// <returns></returns>
  1333. public static IEnumerable<T> WhereIf<T>(this IEnumerable<T> source, bool condition, Func<T, bool> where)
  1334. {
  1335. return condition ? source.Where(where) : source;
  1336. }
  1337. /// <summary>
  1338. /// 满足条件时执行筛选条件
  1339. /// </summary>
  1340. /// <typeparam name="T"></typeparam>
  1341. /// <param name="source"></param>
  1342. /// <param name="condition"></param>
  1343. /// <param name="where"></param>
  1344. /// <returns></returns>
  1345. public static IEnumerable<T> WhereIf<T>(this IEnumerable<T> source, Func<bool> condition, Func<T, bool> where)
  1346. {
  1347. return condition() ? source.Where(where) : source;
  1348. }
  1349. /// <summary>
  1350. /// 满足条件时执行筛选条件
  1351. /// </summary>
  1352. /// <typeparam name="T"></typeparam>
  1353. /// <param name="source"></param>
  1354. /// <param name="condition"></param>
  1355. /// <param name="where"></param>
  1356. /// <returns></returns>
  1357. public static IQueryable<T> WhereIf<T>(this IQueryable<T> source, bool condition, Expression<Func<T, bool>> where)
  1358. {
  1359. return condition ? source.Where(where) : source;
  1360. }
  1361. /// <summary>
  1362. /// 满足条件时执行筛选条件
  1363. /// </summary>
  1364. /// <typeparam name="T"></typeparam>
  1365. /// <param name="source"></param>
  1366. /// <param name="condition"></param>
  1367. /// <param name="where"></param>
  1368. /// <returns></returns>
  1369. public static IQueryable<T> WhereIf<T>(this IQueryable<T> source, Func<bool> condition, Expression<Func<T, bool>> where)
  1370. {
  1371. return condition() ? source.Where(where) : source;
  1372. }
  1373. /// <summary>
  1374. /// 改变元素的索引位置
  1375. /// </summary>
  1376. /// <typeparam name="T"></typeparam>
  1377. /// <param name="list">集合</param>
  1378. /// <param name="item">元素</param>
  1379. /// <param name="index">索引值</param>
  1380. /// <exception cref="ArgumentNullException"></exception>
  1381. public static IList<T> ChangeIndex<T>(this IList<T> list, T item, int index)
  1382. {
  1383. if (item is null)
  1384. {
  1385. throw new ArgumentNullException(nameof(item));
  1386. }
  1387. ChangeIndexInternal(list, item, index);
  1388. return list;
  1389. }
  1390. /// <summary>
  1391. /// 改变元素的索引位置
  1392. /// </summary>
  1393. /// <typeparam name="T"></typeparam>
  1394. /// <param name="list">集合</param>
  1395. /// <param name="condition">元素定位条件</param>
  1396. /// <param name="index">索引值</param>
  1397. public static IList<T> ChangeIndex<T>(this IList<T> list, Func<T, bool> condition, int index)
  1398. {
  1399. var item = list.FirstOrDefault(condition);
  1400. if (item != null)
  1401. {
  1402. ChangeIndexInternal(list, item, index);
  1403. }
  1404. return list;
  1405. }
  1406. private static void ChangeIndexInternal<T>(IList<T> list, T item, int index)
  1407. {
  1408. index = Math.Max(0, index);
  1409. index = Math.Min(list.Count - 1, index);
  1410. list.Remove(item);
  1411. list.Insert(index, item);
  1412. }
  1413. }