DynamicDataGrid.cs 26 KB

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