IEnumerableExtensions.cs 52 KB

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