Entity.cs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463
  1. using System;
  2. using System.Collections.Generic;
  3. using System.Collections.ObjectModel;
  4. using System.Linq;
  5. using System.Linq.Expressions;
  6. using System.Reflection;
  7. using InABox.Clients;
  8. using InABox.Core;
  9. namespace InABox.Core
  10. {
  11. public class Credentials
  12. {
  13. public virtual string UserID { get; set; }
  14. public virtual string Password { get; set; }
  15. }
  16. public interface IEntity
  17. {
  18. Guid ID { get; set; }
  19. Guid Deleted { get; set; }
  20. bool IsChanged();
  21. void CommitChanges();
  22. void CancelChanges();
  23. }
  24. public interface ITaxable
  25. {
  26. double ExTax { get; set; }
  27. double TaxRate { get; set; }
  28. double Tax { get; set; }
  29. double IncTax { get; set; }
  30. }
  31. public interface IIssues
  32. {
  33. string Issues { get; set; }
  34. }
  35. public interface IExportable
  36. {
  37. }
  38. public interface IImportable
  39. {
  40. }
  41. public interface IMergeable
  42. {
  43. }
  44. public interface ISecure { }
  45. public interface IDuplicatable
  46. {
  47. IEntityDuplicator GetDuplicator();
  48. }
  49. public interface IEntityDuplicator
  50. {
  51. //void Duplicate(IFilter filter);
  52. void Duplicate(IEnumerable<BaseObject> entities);
  53. }
  54. public class EntityDuplicator<TEntity> : IEntityDuplicator where TEntity : Entity, IRemotable, IPersistent
  55. {
  56. private readonly List<Tuple<Type, Type, Expression>> _relationships = new List<Tuple<Type, Type, Expression>>();
  57. public void Duplicate(IEnumerable<TEntity> entites) =>
  58. Duplicate(typeof(TEntity),
  59. new Filter<TEntity>(x => x.ID).InList(entites.Select(x => x.ID).ToArray()));
  60. public void Duplicate(IFilter filter)
  61. {
  62. Duplicate(typeof(TEntity), filter);
  63. }
  64. private void Duplicate(Type parent, IFilter filter)
  65. {
  66. var table = ClientFactory.CreateClient(parent).Query(filter);
  67. foreach (var row in table.Rows)
  68. {
  69. var update = (row.ToObject(parent) as Entity)!;
  70. var id = update.ID;
  71. update.ID = Guid.Empty;
  72. update.CommitChanges();
  73. ClientFactory.CreateClient(parent).Save(update, "Duplicated Record");
  74. foreach (var relationship in _relationships.Where(x => x.Item1 == parent))
  75. {
  76. var filtertype = typeof(Filter<>).MakeGenericType(relationship.Item2);
  77. var newfilter = Activator.CreateInstance(filtertype) as IFilter;
  78. filter.Expression = relationship.Item3;
  79. filter.Operator = Operator.IsEqualTo;
  80. filter.Value = id;
  81. Duplicate(relationship.Item2, filter);
  82. }
  83. }
  84. }
  85. public void AddChild<TParent, TChild>(Expression<Func<TChild, IEntityLink<TParent>>> childkey) where TParent : Entity where TChild : Entity
  86. {
  87. _relationships.Add(new Tuple<Type, Type, Expression>(typeof(TParent), typeof(TChild), childkey));
  88. }
  89. void IEntityDuplicator.Duplicate(IEnumerable<BaseObject> entities) => Duplicate(entities.Cast<TEntity>());
  90. }
  91. /// <summary>
  92. /// An <see cref="IProperty"/> is required if it has the <see cref="RequiredColumnAttribute"/> defined on it.<br/>
  93. /// If it is part of an <see cref="IEntityLink"/> (or <see cref="IEnclosedEntity"/>), then it is only required
  94. /// if the <see cref="IEntityLink"/> property on the parent class also has <see cref="RequiredColumnAttribute"/>.
  95. /// </summary>
  96. public class RequiredColumnAttribute : Attribute { }
  97. public abstract class Entity : BaseObject, IEntity
  98. {
  99. private bool bTaxing;
  100. //public String Name { get; set; }
  101. [TimestampEditor(Visible = Visible.Optional, Editable = Editable.Hidden)]
  102. [RequiredColumn]
  103. public virtual DateTime LastUpdate { get; set; }
  104. [CodeEditor(Visible = Visible.Optional, Editable = Editable.Hidden)]
  105. [RequiredColumn]
  106. public string LastUpdateBy { get; set; }
  107. [NullEditor]
  108. [RequiredColumn]
  109. public virtual DateTime Created { get; set; }
  110. [NullEditor]
  111. [RequiredColumn]
  112. public virtual string CreatedBy { get; set; }
  113. [NullEditor]
  114. [RequiredColumn]
  115. public Guid ID { get; set; }
  116. /// <summary>
  117. /// If the entity is deleted, holds the ID of the Deletion. Otherwise, it holds Guid.Empty
  118. /// </summary>
  119. [NullEditor]
  120. [DoNotSerialize]
  121. public Guid Deleted { get; set; }
  122. public static Type ClassVersion(Type t)
  123. {
  124. //Type t = MethodBase.GetCurrentMethod().DeclaringType;
  125. var ti = t.GetTypeInfo();
  126. var interfaces = ti.GetInterfaces();
  127. if (ti.GetInterfaces().Contains(typeof(IPersistent)))
  128. {
  129. if (ti.BaseType != null)
  130. throw new Exception(t.Name + " hase no Base Type");
  131. if (ti.BaseType.Equals(typeof(Entity)))
  132. throw new Exception(t.Name + " may not derive directly from TEntity");
  133. var props = t.GetTypeInfo().GetProperties(BindingFlags.DeclaredOnly | BindingFlags.Public | BindingFlags.Instance);
  134. if (props.Count() > 0)
  135. throw new Exception(t.Name + "may not declare properties");
  136. }
  137. return t.GetTypeInfo().BaseType;
  138. }
  139. //[NullEditor]
  140. //public List<EntityHistory> History { get; set; }
  141. protected override void Init()
  142. {
  143. base.Init();
  144. ID = Guid.Empty;
  145. Deleted = Guid.Empty;
  146. Created = DateTime.Now;
  147. CreatedBy = ClientFactory.UserID;
  148. LastUpdate = DateTime.Now;
  149. LastUpdateBy = ClientFactory.UserID;
  150. //History = new List<EntityHistory>();
  151. CheckSequence();
  152. }
  153. //public Entity() : base()
  154. //{
  155. // CommitChanges();
  156. //}
  157. //public Entity(Guid id) : base()
  158. //{
  159. // ID = id;
  160. // History = new List<EntityHistory>();
  161. // UserProperties = new Dictionary<string, Object>();
  162. // DataModel.InitializeEntity(this);
  163. // CheckSequence();
  164. // CommitChanges();
  165. //}
  166. public static bool IsEntityLinkValid<T, U>(Expression<Func<T, U>> expression, CoreRow arg) where U : IEntityLink
  167. {
  168. return arg.IsEntityLinkValid(expression);
  169. }
  170. /// <summary>
  171. /// Gets the ID of an entity link of an entity, doing a validity check (see <see cref="IsEntityLinkValid{T, U}(Expression{Func{T, U}}, CoreRow)"/>)
  172. /// </summary>
  173. /// <typeparam name="T">The entity type</typeparam>
  174. /// <typeparam name="U">The entity link type</typeparam>
  175. /// <param name="expression">An expression to the entity link of type <typeparamref name="U"/></param>
  176. /// <param name="arg">The row representing the entity of type <typeparamref name="T"/></param>
  177. /// <returns>The ID on the entity link, or <c>null</c> if the entity link is invalid</returns>
  178. public static Guid? EntityLinkID<T, U>(Expression<Func<T, U>> expression, CoreRow arg) where U : IEntityLink
  179. {
  180. var col = CoreUtils.GetFullPropertyName(expression, ".");
  181. var id = arg.Get<Guid>(col + ".ID");
  182. if (id != Guid.Empty && arg.Get<Guid>(col + ".Deleted") == Guid.Empty)
  183. return id;
  184. return null;
  185. }
  186. private void CheckSequence()
  187. {
  188. if (this is ISequenceable seq && seq.Sequence <= 0)
  189. {
  190. seq.Sequence = CoreUtils.GenerateSequence();
  191. }
  192. }
  193. protected override void SetChanged(string name, object? before, object? after)
  194. {
  195. base.SetChanged(name, before, after);
  196. CheckTax(name, before, after);
  197. }
  198. private void CheckTax(string name, object? before, object? after)
  199. {
  200. if (this is ITaxable)
  201. {
  202. if (bTaxing)
  203. return;
  204. bTaxing = true;
  205. try
  206. {
  207. var taxable = this as ITaxable;
  208. if (name.Equals("ExTax"))
  209. {
  210. taxable.Tax = (double)after * (taxable.TaxRate / 100.0F);
  211. taxable.IncTax = (double)after + taxable.Tax;
  212. }
  213. else if (name.Equals("TaxRate"))
  214. {
  215. taxable.Tax = taxable.ExTax * ((double)after / 100.0F);
  216. taxable.IncTax = taxable.ExTax + taxable.Tax;
  217. }
  218. else if (name.Equals("Tax"))
  219. {
  220. taxable.IncTax = (double)after + taxable.Tax;
  221. }
  222. else if (name.Equals("IncTax"))
  223. {
  224. taxable.ExTax = (double)after / ((100.0F + taxable.TaxRate) / 100.0F);
  225. taxable.Tax = (double)after - taxable.ExTax;
  226. }
  227. }
  228. catch (Exception e)
  229. {
  230. Logger.Send(LogType.Error, "", String.Join("\n",e.Message,e.StackTrace));
  231. }
  232. bTaxing = false;
  233. }
  234. }
  235. protected override void DoPropertyChanged(string name, object? before, object? after)
  236. {
  237. if (!IsObserving())
  238. return;
  239. //CheckSequence();
  240. if (!name.Equals("LastUpdate"))
  241. LastUpdate = DateTime.Now;
  242. LastUpdateBy = ClientFactory.UserID;
  243. // This doesn;t work - keeps being updated to current date
  244. // Created => null ::Set ID = guid.empty -> now :: any other change -> unchanged!
  245. // Moved to Create(), should not simply be overwritten on deserialise from json
  246. //if (Created.Equals(DateTime.MinValue))
  247. //{
  248. // Created = DateTime.Now;
  249. // CreatedBy = ClientFactory.UserID;
  250. //}
  251. }
  252. }
  253. public interface ILicense<TLicenseToken> where TLicenseToken : LicenseToken
  254. {
  255. }
  256. public interface IPersistent
  257. {
  258. }
  259. public interface IRemotable
  260. {
  261. }
  262. //public interface IRemoteQuery
  263. //{
  264. //}
  265. //public interface IRemoteUpdate
  266. //{
  267. //}
  268. //public interface IRemoteDelete
  269. //{
  270. //}
  271. public interface ISequenceable
  272. {
  273. long Sequence { get; set; }
  274. }
  275. public interface IAutoIncrement<T, TType>
  276. {
  277. Expression<Func<T, TType>> AutoIncrementField();
  278. Filter<T> AutoIncrementFilter();
  279. }
  280. public interface INumericAutoIncrement<T> : IAutoIncrement<T, int>
  281. {
  282. }
  283. public interface IStringAutoIncrement
  284. {
  285. string AutoIncrementPrefix();
  286. string AutoIncrementFormat();
  287. }
  288. public interface IStringAutoIncrement<T> : IAutoIncrement<T, string>, IStringAutoIncrement
  289. {
  290. }
  291. /// <summary>
  292. /// Used to flag an entity as exhibiting the properties of a ManyToMany relationship, allowing PRS to auto-generate things like grids and datamodels based on
  293. /// entity relationships.
  294. /// </summary>
  295. /// <remarks>
  296. /// This will cause a ManyToMany grid of <typeparamref name="TRight"/> to appear on all <typeparamref name="TLeft"/> editors.
  297. /// Hence, if one wishes to cause both grids to appear (that is, for <typeparamref name="TLeft"/> to appear for <typeparamref name="TRight"/> <i>and</i>
  298. /// vice versa, one must flag the entity with both <c>IManyToMany&lt;<typeparamref name="TLeft"/>, <typeparamref name="TRight"/>&gt;</c> and
  299. /// <c>IManyToMany&lt;<typeparamref name="TRight"/>, <typeparamref name="TLeft"/>&gt;</c>.
  300. /// </remarks>
  301. /// <typeparam name="TLeft"></typeparam>
  302. /// <typeparam name="TRight"></typeparam>
  303. public interface IManyToMany<TLeft, TRight> where TLeft : Entity where TRight : Entity
  304. {
  305. }
  306. public interface IOneToMany<TOne> where TOne : Entity
  307. {
  308. }
  309. public static class EntityFactory
  310. {
  311. public delegate object ObjectActivator(params object[] args);
  312. private static readonly Dictionary<Type, ObjectActivator> _cache = new Dictionary<Type, ObjectActivator>();
  313. public static ObjectActivator GetActivator<T>(ConstructorInfo ctor)
  314. {
  315. var type = ctor.DeclaringType;
  316. var paramsInfo = ctor.GetParameters();
  317. //create a single param of type object[]
  318. var param =
  319. Expression.Parameter(typeof(object[]), "args");
  320. var argsExp =
  321. new Expression[paramsInfo.Length];
  322. //pick each arg from the params array
  323. //and create a typed expression of them
  324. for (var i = 0; i < paramsInfo.Length; i++)
  325. {
  326. Expression index = Expression.Constant(i);
  327. var paramType = paramsInfo[i].ParameterType;
  328. Expression paramAccessorExp =
  329. Expression.ArrayIndex(param, index);
  330. Expression paramCastExp =
  331. Expression.Convert(paramAccessorExp, paramType);
  332. argsExp[i] = paramCastExp;
  333. }
  334. //make a NewExpression that calls the
  335. //ctor with the args we just created
  336. var newExp = Expression.New(ctor, argsExp);
  337. //create a lambda with the New
  338. //Expression as body and our param object[] as arg
  339. var lambda =
  340. Expression.Lambda(typeof(ObjectActivator), newExp, param);
  341. //compile it
  342. var compiled = (ObjectActivator)lambda.Compile();
  343. return compiled;
  344. }
  345. public static T CreateEntity<T>() where T : BaseObject
  346. {
  347. if (!_cache.ContainsKey(typeof(T)))
  348. {
  349. var ctor = typeof(T).GetConstructors().First();
  350. var activator = typeof(EntityFactory).GetMethod("GetActivator").MakeGenericMethod(typeof(T));
  351. _cache[typeof(T)] = GetActivator<T>(ctor);
  352. }
  353. var createdActivator = _cache[typeof(T)];
  354. return (T)createdActivator();
  355. }
  356. public static object CreateEntity(Type type)
  357. {
  358. if (!_cache.ContainsKey(type))
  359. {
  360. var ctor = type.GetConstructors().First();
  361. var activator = typeof(EntityFactory).GetMethod("GetActivator").MakeGenericMethod(type);
  362. _cache[type] = (ObjectActivator)activator.Invoke(null, new object[] { ctor });
  363. }
  364. var createdActivator = _cache[type];
  365. return createdActivator();
  366. }
  367. }
  368. }