DynamicDataGrid.cs 28 KB

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