IEnumerableExtensions.cs 52 KB

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