DynamicDataGrid.cs 27 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Diagnostics.CodeAnalysis;
  4. using System.Drawing;
  5. using System.Linq;
  6. using System.Linq.Expressions;
  7. using System.Reflection;
  8. using System.Threading;
  9. using System.Threading.Tasks;
  10. using System.Windows;
  11. using System.Windows.Controls;
  12. using InABox.Clients;
  13. using InABox.Configuration;
  14. using InABox.Core;
  15. using InABox.Wpf;
  16. using InABox.WPF;
  17. using Expression = System.Linq.Expressions.Expression;
  18. namespace InABox.DynamicGrid;
  19. public interface IDynamicDataGrid : IDynamicGrid
  20. {
  21. /// <summary>
  22. /// The tag the the DynamicGridColumns are stored against. If set to <see langword="null"/>,
  23. /// the name of <typeparamref name="TEntity"/> is used as a default.
  24. /// </summary>
  25. string? ColumnsTag { get; set; }
  26. IColumns LoadEditorColumns();
  27. Type DataType { get; }
  28. }
  29. public class DynamicDataGrid<TEntity> : DynamicGrid<TEntity>, IDynamicDataGrid where TEntity : Entity, IRemotable, IPersistent, new()
  30. {
  31. public delegate void OnReloadEventHandler(object sender, Filters<TEntity> criteria, Columns<TEntity> columns, ref SortOrder<TEntity>? sortby);
  32. private readonly int ChunkSize = 500;
  33. private Button MergeBtn = null!; //Late-initialised
  34. public DynamicGridFilterButtonComponent<TEntity> FilterComponent;
  35. protected DynamicGridCustomColumnsComponent<TEntity> ColumnsComponent;
  36. private Column<TEntity>[] FilterColumns;
  37. public Type DataType => typeof(TEntity);
  38. public DynamicDataGrid() : base()
  39. {
  40. var fields = DatabaseSchema.Properties(typeof(TEntity));
  41. foreach (var field in fields)
  42. if (!MasterColumns.Any(x => x.ColumnName == field.Name))
  43. MasterColumns.Add(new DynamicGridColumn { ColumnName = field.Name });
  44. var cols = LookupFactory.DefineColumns<TEntity>();
  45. // Minimum Columns for Lookup values
  46. foreach (var col in cols)
  47. HiddenColumns.Add(CoreUtils.CreateLambdaExpression<TEntity>(col.Property));
  48. // Minimum Columns for Successful Saving
  49. // This should be cross-checked with the relevant Store<>
  50. // so that clients will (usually) provide sufficient columns for saving
  51. foreach (var col in LookupFactory.RequiredColumns<TEntity>())
  52. HiddenColumns.Add(CoreUtils.CreateLambdaExpression<TEntity>(col.Property));
  53. //HiddenColumns.Add(x => x.ID);
  54. if (typeof(TEntity).GetInterfaces().Contains(typeof(IIssues)))
  55. {
  56. HiddenColumns.Add(x => (x as IIssues)!.Issues);
  57. var coltype = typeof(DynamicIssuesColumn<>).MakeGenericType(typeof(TEntity));
  58. ActionColumns.Add((Activator.CreateInstance(coltype, this) as DynamicActionColumn)!);
  59. }
  60. SetupFilterColumns();
  61. }
  62. protected override void Init()
  63. {
  64. FilterComponent = new(this,
  65. new GlobalConfiguration<CoreFilterDefinitions>(GetTag()),
  66. new UserConfiguration<CoreFilterDefinitions>(GetTag()));
  67. FilterComponent.OnFilterRefresh += () => Refresh(false, true);
  68. ColumnsComponent = new DynamicGridCustomColumnsComponent<TEntity>(this, GetTag());
  69. MergeBtn = AddButton("Merge", Wpf.Resources.merge.AsBitmapImage(Color.White), MergeClick);
  70. }
  71. protected override void DoReconfigure(DynamicGridOptions options)
  72. {
  73. if (Security.CanEdit<TEntity>())
  74. {
  75. options.AddRows = true;
  76. options.EditRows = true;
  77. }
  78. if (Security.CanDelete<TEntity>())
  79. options.DeleteRows = true;
  80. if (Security.CanImport<TEntity>() && typeof(TEntity).HasInterface<IImportable>())
  81. options.ImportData = true;
  82. if (Security.CanExport<TEntity>() && typeof(TEntity).HasInterface<IExportable>())
  83. options.ExportData = true;
  84. if (Security.CanMerge<TEntity>())
  85. options.MultiSelect = true;
  86. }
  87. [MemberNotNull(nameof(FilterColumns))]
  88. private void SetupFilterColumns()
  89. {
  90. if (typeof(TEntity).GetCustomAttribute<AutoEntity>() is AutoEntity auto)
  91. {
  92. if (auto.Generator is not null)
  93. {
  94. var columns = auto.Generator.IDColumns;
  95. FilterColumns = columns.Select(x => new Column<TEntity>(x.Property)).ToArray();
  96. }
  97. else
  98. {
  99. FilterColumns = Array.Empty<Column<TEntity>>();
  100. }
  101. }
  102. else
  103. {
  104. FilterColumns = new[] { new Column<TEntity>(x => x.ID) };
  105. }
  106. foreach (var column in FilterColumns)
  107. {
  108. AddHiddenColumn(column.Property);
  109. }
  110. }
  111. protected override void BeforeLoad(IDynamicEditorForm form, TEntity[] items)
  112. {
  113. form.ReadOnly = form.ReadOnly || !Security.CanEdit<TEntity>();
  114. base.BeforeLoad(form, items);
  115. }
  116. private string? _columnsTag;
  117. public string? ColumnsTag
  118. {
  119. get => _columnsTag;
  120. set
  121. {
  122. _columnsTag = value;
  123. ColumnsComponent.Tag = GetTag();
  124. }
  125. }
  126. protected override void OptionsChanged()
  127. {
  128. base.OptionsChanged();
  129. if (MergeBtn != null)
  130. MergeBtn.Visibility = Visibility.Collapsed;
  131. FilterComponent.ShowFilterList = Options.FilterRows && !Options.HideDatabaseFilters;
  132. }
  133. protected override void SelectItems(CoreRow[]? rows)
  134. {
  135. base.SelectItems(rows);
  136. MergeBtn.Visibility = Options.MultiSelect && typeof(TEntity).IsAssignableTo(typeof(IMergeable)) && Security.CanMerge<TEntity>() && rows != null && rows.Length > 1
  137. ? Visibility.Visible
  138. : Visibility.Collapsed;
  139. }
  140. public event OnReloadEventHandler? OnReload;
  141. protected bool IsPaging { get; private set; } = false;
  142. protected override string FormatRecordCount(int count)
  143. {
  144. return IsPaging
  145. ? $"{base.FormatRecordCount(count)} (loading..)"
  146. : base.FormatRecordCount(count);
  147. }
  148. protected override void Reload(
  149. Filters<TEntity> criteria, Columns<TEntity> columns, ref SortOrder<TEntity>? sort,
  150. CancellationToken token, Action<CoreTable?, Exception?> action)
  151. {
  152. criteria.Add(FilterComponent.GetFilter());
  153. OnReload?.Invoke(this, criteria, columns, ref sort);
  154. if(Options.PageSize > 0)
  155. {
  156. var inSort = sort;
  157. Task.Run(() =>
  158. {
  159. var page = CoreRange.Database(Options.PageSize);
  160. var filter = criteria.Combine();
  161. IsPaging = true;
  162. while (!token.IsCancellationRequested)
  163. {
  164. try
  165. {
  166. var data = Client.Query(filter, columns, inSort, page);
  167. data.Offset = page.Offset;
  168. IsPaging = data.Rows.Count == page.Limit;
  169. if (token.IsCancellationRequested)
  170. {
  171. break;
  172. }
  173. action(data, null);
  174. if (!IsPaging)
  175. break;
  176. // Proposal - Let's slow it down a bit to enhance UI responsiveness?
  177. Thread.Sleep(100);
  178. page.Next();
  179. }
  180. catch (Exception e)
  181. {
  182. action(null, e);
  183. break;
  184. }
  185. }
  186. }, token);
  187. }
  188. else
  189. {
  190. Client.Query(criteria.Combine(), columns, sort, action);
  191. }
  192. }
  193. private CoreRow[]? SelectedBeforeRefresh;
  194. protected override void OnAfterRefresh()
  195. {
  196. base.OnAfterRefresh();
  197. if (SelectedBeforeRefresh is not null)
  198. {
  199. var selectedValues = SelectedBeforeRefresh
  200. .Select(x => FilterColumns.Select(c => x[c.Property]).ToList())
  201. .ToList();
  202. SelectedBeforeRefresh = null;
  203. var selectedRows = Data.Rows.Where(r =>
  204. {
  205. return selectedValues.Any(v =>
  206. {
  207. for (int i = 0; i < v.Count; ++i)
  208. {
  209. if (v[i]?.Equals(r[FilterColumns[i].Property]) != true)
  210. return false;
  211. }
  212. return true;
  213. });
  214. }).ToArray();
  215. SelectedRows = selectedRows;
  216. SelectItems(selectedRows);
  217. }
  218. }
  219. public override void Refresh(bool reloadcolumns, bool reloaddata)
  220. {
  221. SelectedBeforeRefresh = SelectedRows;
  222. base.Refresh(reloadcolumns, reloaddata);
  223. }
  224. IColumns IDynamicDataGrid.LoadEditorColumns() => LoadEditorColumns();
  225. public Columns<TEntity> LoadEditorColumns()
  226. {
  227. return DynamicGridUtils.LoadEditorColumns(DataColumns());
  228. }
  229. private Filter<TEntity>? GetRowFilter(CoreRow row)
  230. {
  231. var newFilters = new Filters<TEntity>();
  232. foreach (var column in FilterColumns)
  233. {
  234. newFilters.Add(new Filter<TEntity>(column.Property).IsEqualTo(row[column.Property]));
  235. }
  236. return newFilters.Combine();
  237. }
  238. public override TEntity[] LoadItems(CoreRow[] rows)
  239. {
  240. Filter<TEntity>? filter = null;
  241. var results = new List<TEntity>();
  242. for (var i = 0; i < rows.Length; i += ChunkSize)
  243. {
  244. var chunk = rows.Skip(i).Take(ChunkSize);
  245. foreach (var row in chunk)
  246. {
  247. var newFilter = GetRowFilter(row);
  248. if (newFilter is not null)
  249. {
  250. //var id = row.Get<TEntity, Guid>(x => x.ID);
  251. if (filter is null)
  252. filter = newFilter;//new Filter<TEntity>(x => x.ID).IsEqualTo(id);
  253. else
  254. filter = filter.Or(newFilter);//.Or(x => x.ID).IsEqualTo(id);
  255. }
  256. }
  257. var columns = LoadEditorColumns(); // new Columns<TEntity>().Default(ColumnType.IncludeOptional, ColumnType.IncludeForeignKeys, ColumnType.IncludeUserProperties);
  258. var data = Client.Query(filter, columns);
  259. results.AddRange(data.ToObjects<TEntity>());
  260. }
  261. return results.ToArray();
  262. }
  263. public override TEntity LoadItem(CoreRow row)
  264. {
  265. var id = row.Get<TEntity, Guid>(x => x.ID);
  266. var filter = GetRowFilter(row);//new Filter<TEntity>(x => x.ID).IsEqualTo(id);
  267. return Client.Query(filter, LoadEditorColumns()).ToObjects<TEntity>().FirstOrDefault()
  268. ?? throw new Exception($"No {typeof(TEntity).Name} with ID {id}");
  269. }
  270. public override void SaveItem(TEntity item)
  271. {
  272. Client.Save(item, "Edited by User");
  273. }
  274. public override void SaveItems(TEntity[] items)
  275. {
  276. Client.Save(items, "Edited by User");
  277. }
  278. public override void DeleteItems(params CoreRow[] rows)
  279. {
  280. var deletes = new List<TEntity>();
  281. foreach (var row in rows)
  282. {
  283. var delete = new TEntity();
  284. foreach (var column in FilterColumns)
  285. {
  286. CoreUtils.SetPropertyValue(delete, column.Property, row[column.Property]);
  287. }
  288. //var delete = /* row.ToObject<TEntity>(); */
  289. deletes.Add(delete);
  290. }
  291. Client.Delete(deletes, "Deleted on User Request");
  292. }
  293. private object GetPropertyValue(Expression member, object obj)
  294. {
  295. var objectMember = Expression.Convert(member, typeof(object));
  296. var getterLambda = Expression.Lambda<Func<object>>(objectMember);
  297. var getter = getterLambda.Compile();
  298. return getter();
  299. }
  300. protected override void ObjectToRow(TEntity obj, CoreRow row)
  301. {
  302. foreach (var column in Data.Columns)
  303. {
  304. var prop = DatabaseSchema.Property(obj.GetType(), column.ColumnName);
  305. if (prop is StandardProperty)
  306. row.Set(column.ColumnName, CoreUtils.GetPropertyValue(obj, prop.Name));
  307. else if (prop is CustomProperty)
  308. row.Set(column.ColumnName, obj.UserProperties[column.ColumnName]);
  309. }
  310. //base.ObjectToRow(obj, row);
  311. }
  312. //private void Auditgrid_OnReload(object sender, Dictionary<string, object> criteria, ref String sort)
  313. //{
  314. // criteria["DocumentType"] = typeof(TEntity).EntityName();
  315. // criteria["DocumentID"] = (sender as FrameworkElement).Tag;
  316. // sort = "TimeStamp";
  317. //}
  318. public override void LoadEditorButtons(TEntity item, DynamicEditorButtons buttons)
  319. {
  320. base.LoadEditorButtons(item, buttons);
  321. if (ClientFactory.IsSupported<AuditTrail>())
  322. buttons.Add("Audit Trail", Wpf.Resources.view.AsBitmapImage(), item, AuditTrailClick);
  323. }
  324. private void AuditTrailClick(object sender, object item)
  325. {
  326. var entity = (TEntity)item;
  327. var window = new AuditWindow(entity.ID);
  328. window.ShowDialog();
  329. }
  330. protected override DynamicGridColumns LoadColumns()
  331. {
  332. return ColumnsComponent.LoadColumns();
  333. }
  334. protected override void SaveColumns(DynamicGridColumns columns)
  335. {
  336. ColumnsComponent.SaveColumns(columns);
  337. }
  338. protected override void LoadColumnsMenu(ContextMenu menu)
  339. {
  340. base.LoadColumnsMenu(menu);
  341. ColumnsComponent.LoadColumnsMenu(menu);
  342. }
  343. public string GetTag()
  344. {
  345. var tag = typeof(TEntity).Name;
  346. if (!string.IsNullOrWhiteSpace(ColumnsTag))
  347. tag = string.Format("{0}.{1}", tag, ColumnsTag);
  348. return tag;
  349. }
  350. protected override DynamicGridSettings LoadSettings()
  351. {
  352. var tag = GetTag();
  353. var user = Task.Run(() => new UserConfiguration<DynamicGridSettings>(tag).Load());
  354. user.Wait();
  355. //var global = Task.Run(() => new GlobalConfiguration<DynamicGridSettings>(tag).Load());
  356. //global.Wait();
  357. //Task.WaitAll(user, global);
  358. //var columns = user.Result.Any() ? user.Result : global.Result;
  359. return user.Result;
  360. }
  361. protected override void SaveSettings(DynamicGridSettings settings)
  362. {
  363. var tag = GetTag();
  364. new UserConfiguration<DynamicGridSettings>(tag).Save(settings);
  365. }
  366. protected override BaseEditor? GetEditor(object item, DynamicGridColumn column)
  367. {
  368. var prop = DatabaseSchema.Properties(typeof(TEntity)).FirstOrDefault(x => x.Name == column.ColumnName);
  369. if (prop != null)
  370. return prop.Editor;
  371. return base.GetEditor(item, column);
  372. }
  373. protected override object? GetEditorValue(object item, string name)
  374. {
  375. if (item is TEntity entity)
  376. {
  377. var prop = DatabaseSchema.Properties(typeof(TEntity)).FirstOrDefault(x => x.Name == name);
  378. if (prop is CustomProperty)
  379. {
  380. if (entity.UserProperties.ContainsKey(name))
  381. return entity.UserProperties[name];
  382. return null;
  383. }
  384. }
  385. return base.GetEditorValue(item, name);
  386. }
  387. protected override void SetEditorValue(object item, string name, object value)
  388. {
  389. var prop = DatabaseSchema.Properties(typeof(TEntity)).FirstOrDefault(x => x.Name == name);
  390. if (prop is CustomProperty && item is TEntity entity)
  391. {
  392. entity.UserProperties[name] = value;
  393. }
  394. else
  395. {
  396. base.SetEditorValue(item, name, value);
  397. }
  398. }
  399. protected bool Duplicate(
  400. CoreRow row,
  401. Expression<Func<TEntity, object?>> codefield,
  402. Type[] childtypes)
  403. {
  404. var id = row.Get<TEntity, Guid>(x => x.ID);
  405. var code = row.Get(codefield) as string;
  406. var tasks = new List<Task>();
  407. var itemtask = Task.Run(() =>
  408. {
  409. var filter = new Filter<TEntity>(x => x.ID).IsEqualTo(id);
  410. var result = new Client<TEntity>().Load(filter).FirstOrDefault()
  411. ?? throw new Exception("Entity does not exist!");
  412. return result;
  413. });
  414. tasks.Add(itemtask);
  415. //itemtask.Wait();
  416. Task<List<string?>>? codetask = null;
  417. if (!string.IsNullOrWhiteSpace(code))
  418. {
  419. codetask = Task.Run(() =>
  420. {
  421. var columns = Columns.None<TEntity>().Add(codefield);
  422. //columns.Add<String>(codefield);
  423. var filter = new Filter<TEntity>(codefield).BeginsWith(code);
  424. var table = new Client<TEntity>().Query(filter, columns);
  425. var result = table.Rows.Select(x => x.Get(codefield) as string).ToList();
  426. return result;
  427. });
  428. tasks.Add(codetask);
  429. }
  430. //codetask.Wait();
  431. var children = new Dictionary<Type, CoreTable>();
  432. foreach (var childtype in childtypes)
  433. {
  434. var childtask = Task.Run(() =>
  435. {
  436. var prop = childtype.GetProperties().FirstOrDefault(x =>
  437. x.PropertyType.GetInterfaces().Contains(typeof(IEntityLink)) &&
  438. x.PropertyType.GetInheritedGenericTypeArguments().FirstOrDefault() == typeof(TEntity));
  439. if (prop is not null)
  440. {
  441. var filter = Core.Filter.Create(childtype);
  442. filter.Expression = CoreUtils.GetMemberExpression(childtype, prop.Name + ".ID");
  443. filter.Operator = Operator.IsEqualTo;
  444. filter.Value = id;
  445. var sort = LookupFactory.DefineSort(childtype);
  446. var client = ClientFactory.CreateClient(childtype);
  447. var table = client.Query(filter, null, sort);
  448. foreach (var r in table.Rows)
  449. {
  450. r["ID"] = Guid.Empty;
  451. r[prop.Name + ".ID"] = Guid.Empty;
  452. }
  453. children[childtype] = table;
  454. }
  455. else
  456. {
  457. Logger.Send(LogType.Error, "", $"DynamicDataGrid<{typeof(TEntity)}>.Duplicate(): No parent property found for child type {childtype}");
  458. }
  459. });
  460. tasks.Add(childtask);
  461. //childtask.Wait();
  462. }
  463. //var manytomanys = CoreUtils.TypeList(
  464. // AppDomain.CurrentDomain.GetAssemblies(),
  465. // x => x.GetInterfaces().Any(intf => intf.IsGenericType && intf.GetGenericTypeDefinition() == typeof(IManyToMany<,>) && intf.GenericTypeArguments.Contains(typeof(T)))
  466. //);
  467. //Task<CoreTable> childtask = Task.Run(() =>
  468. //{
  469. // var result = new CoreTable();
  470. // result.LoadColumns(typeof(TChild));
  471. // var children = new Client<TChild>().Load(new Filter<TChild>(x => linkfield).IsEqualTo(id));
  472. // foreach (var child in children)
  473. // {
  474. // child.ID = Guid.Empty;
  475. // String linkprop = CoreUtils.GetFullPropertyName<TChild, Guid>(linkfield, ".");
  476. // CoreUtils.SetPropertyValue(child, linkprop, Guid.Empty);
  477. // var newrow = result.NewRow();
  478. // result.LoadRow(newrow, child);
  479. // result.Rows.Add(newrow);
  480. // }
  481. // return result;
  482. //});
  483. //tasks.Add(childtask);
  484. Task.WaitAll(tasks.ToArray());
  485. var item = itemtask.Result;
  486. item.ID = Guid.Empty;
  487. if (codetask != null)
  488. {
  489. var codes = codetask.Result;
  490. var i = 1;
  491. while (codes.Contains(string.Format("{0} ({1})", code, i)))
  492. i++;
  493. var codeprop = CoreUtils.GetFullPropertyName(codefield, ".");
  494. CoreUtils.SetPropertyValue(item, codeprop, string.Format("{0} ({1})", code, i));
  495. }
  496. var grid = new DynamicDataGrid<TEntity>();
  497. return grid.EditItems(new[] { item }, t => children.ContainsKey(t) ? children[t] : null, true);
  498. }
  499. private bool MergeClick(Button arg1, CoreRow[] rows)
  500. {
  501. if (rows == null || rows.Length <= 1)
  502. return false;
  503. return DoMerge(rows);
  504. }
  505. protected virtual bool DoMerge(CoreRow[] rows)
  506. {
  507. var targetid = rows.Last().Get<TEntity, Guid>(x => x.ID);
  508. var target = rows.Last().ToObject<TEntity>().ToString();
  509. var otherids = rows.Select(r => r.Get<TEntity, Guid>(x => x.ID)).Where(x => x != targetid).ToArray();
  510. string[] others = rows.Where(r => otherids.Contains(r.Get<Guid>("ID"))).Select(x => x.ToObject<TEntity>().ToString()!).ToArray();
  511. var nRows = rows.Length;
  512. if (!MessageWindow.ShowYesNo(
  513. $"This will merge the following items:\n\n" +
  514. $"- {string.Join("\n- ", others)}\n\n" +
  515. $" into:\n\n" +
  516. $"- {target}\n\n" +
  517. $"After this, the items will be permanently removed.\n" +
  518. $"Are you sure you wish to do this?",
  519. "Merge Items Warning"))
  520. return false;
  521. using (new WaitCursor())
  522. {
  523. var types = CoreUtils.Entities.Where(
  524. x =>
  525. !x.IsGenericType
  526. && x.IsSubclassOf(typeof(Entity))
  527. && !x.Equals(typeof(AuditTrail))
  528. && !x.Equals(typeof(TEntity))
  529. && x.GetCustomAttribute<AutoEntity>() == null
  530. && x.HasInterface<IRemotable>()
  531. && x.HasInterface<IPersistent>()
  532. ).ToArray();
  533. foreach (var type in types)
  534. {
  535. var props = CoreUtils.PropertyList(
  536. type,
  537. x =>
  538. x.PropertyType.GetInterfaces().Contains(typeof(IEntityLink))
  539. && x.PropertyType.GetInheritedGenericTypeArguments().Contains(typeof(TEntity))
  540. );
  541. foreach (var prop in DatabaseSchema.LocalProperties(type))
  542. {
  543. if(prop.Parent is null
  544. || prop.Parent.PropertyType.GetInterfaceDefinition(typeof(IEntityLink<>)) is not Type intDef
  545. || intDef.GenericTypeArguments[0] != typeof(TEntity))
  546. {
  547. continue;
  548. }
  549. var filter = Filter.Create(type, prop.Name).InList(otherids);
  550. var columns = Columns.None(type).Add("ID").Add(prop.Name);
  551. var updates = ClientFactory.CreateClient(type).Query(filter, columns).Rows.ToArray(r => r.ToObject(type));
  552. if (updates.Length != 0)
  553. {
  554. foreach (var update in updates)
  555. prop.Setter()(update, targetid);
  556. ClientFactory.CreateClient(type).Save(updates, $"Merged {typeof(TEntity).Name} Records");
  557. }
  558. }
  559. }
  560. var histories = new Client<AuditTrail>()
  561. .Query(
  562. new Filter<AuditTrail>(x => x.EntityID).InList(otherids),
  563. Columns.None<AuditTrail>()
  564. .Add(x => x.ID).Add(x => x.EntityID))
  565. .ToArray<AuditTrail>();
  566. foreach (var history in histories)
  567. history.EntityID = targetid;
  568. if (histories.Length != 0)
  569. new Client<AuditTrail>().Save(histories, "");
  570. var deletes = new List<object>();
  571. foreach (var otherid in otherids)
  572. {
  573. var delete = new TEntity();
  574. CoreUtils.SetPropertyValue(delete, "ID", otherid);
  575. deletes.Add(delete);
  576. }
  577. ClientFactory.CreateClient(typeof(TEntity))
  578. .Delete(deletes, string.Format("Merged {0} Records", typeof(TEntity).EntityName().Split('.').Last()));
  579. return true;
  580. }
  581. }
  582. protected override IEnumerable<TEntity> LoadDuplicatorItems(CoreRow[] rows)
  583. {
  584. return rows.Select(x => x.ToObject<TEntity>());
  585. }
  586. protected override bool BeforePaste(IEnumerable<TEntity> items, ClipAction action)
  587. {
  588. if (action == ClipAction.Copy)
  589. {
  590. foreach (var item in items)
  591. item.ID = Guid.Empty;
  592. return true;
  593. }
  594. return base.BeforePaste(items, action);
  595. }
  596. protected override void CustomiseExportFilters(Filters<TEntity> filters, CoreRow[] visiblerows)
  597. {
  598. base.CustomiseExportFilters(filters, visiblerows);
  599. /*if (IsEntity)
  600. {
  601. var ids = visiblerows.Select(r => r.Get<TEntity, Guid>(c => c.ID)).ToArray();
  602. filters.Add(new Filter<TEntity>(x => x.ID).InList(ids));
  603. }
  604. else
  605. {
  606. Filter<TEntity>? filter = null;
  607. foreach (var row in visiblerows)
  608. {
  609. var rowFilter = GetRowFilter(row);
  610. if(rowFilter is not null)
  611. {
  612. if (filter is null)
  613. {
  614. filter = rowFilter;
  615. }
  616. else
  617. {
  618. filter.Or(rowFilter);
  619. }
  620. }
  621. }
  622. filters.Add(filter);
  623. }*/
  624. }
  625. protected override IEnumerable<Tuple<Type?, CoreTable>> LoadExportTables(Filters<TEntity> filter, IEnumerable<Tuple<Type, IColumns>> tableColumns)
  626. {
  627. var queries = new Dictionary<string, IQueryDef>();
  628. var columns = tableColumns.ToList();
  629. foreach (var table in columns)
  630. {
  631. var tableType = table.Item1;
  632. PropertyInfo? property = null;
  633. var m2m = CoreUtils.GetManyToMany(tableType, typeof(TEntity));
  634. IFilter? queryFilter = null;
  635. if (m2m != null)
  636. {
  637. property = CoreUtils.GetManyToManyThisProperty(tableType, typeof(TEntity));
  638. }
  639. else
  640. {
  641. var o2m = CoreUtils.GetOneToMany(tableType, typeof(TEntity));
  642. if (o2m != null)
  643. {
  644. property = CoreUtils.GetOneToManyProperty(tableType, typeof(TEntity));
  645. }
  646. }
  647. if (property != null)
  648. {
  649. var subQuery = new SubQuery<TEntity>();
  650. subQuery.Filter = filter.Combine();
  651. subQuery.Column = new Column<TEntity>(x => x.ID);
  652. queryFilter = (Activator.CreateInstance(typeof(Filter<>).MakeGenericType(tableType)) as IFilter)!;
  653. queryFilter.Expression = CoreUtils.GetMemberExpression(tableType, property.Name + ".ID");
  654. queryFilter.InQuery(subQuery);
  655. queries[tableType.Name] = new QueryDef(tableType)
  656. {
  657. Filter = queryFilter,
  658. Columns = table.Item2
  659. };
  660. }
  661. }
  662. var results = Client.QueryMultiple(queries);
  663. return columns.Select(x => new Tuple<Type?, CoreTable>(x.Item1, results[x.Item1.Name]));
  664. }
  665. protected override CoreTable LoadImportKeys(String[] fields)
  666. {
  667. return Client.Query(null, Columns.None<TEntity>().Add(fields));
  668. }
  669. }