// ======================================================================== // Copyright 2007 - Volian Enterprises, Inc. All rights reserved. // Volian Enterprises - Proprietary Information - DO NOT COPY OR DISTRIBUTE // ------------------------------------------------------------------------ // $Workfile: $ $Revision: $ // $Author: $ $Date: $ // // $History: $ // ======================================================================== using System; using System.Data; using System.Data.SqlClient; using Csla; using Csla.Data; using System.ComponentModel; using System.Collections.Generic; namespace VEPROMS.CSLA.Library { public delegate void OwnerInfoEvent(object sender); /// /// OwnerInfo Generated by MyGeneration using the CSLA Object Mapping template /// [Serializable()] [TypeConverter(typeof(OwnerInfoConverter))] public partial class OwnerInfo : ReadOnlyBase, IDisposable { public event OwnerInfoEvent Changed; private void OnChange() => Changed?.Invoke(this); #region Log4Net private static readonly log4net.ILog _MyLog = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); #endregion #region Collection [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0044:Add readonly modifier", Justification = "Keeping Collections Not ReadOnly")] private static List _CacheList = new List(); protected static void AddToCache(OwnerInfo ownerInfo) { if (!_CacheList.Contains(ownerInfo)) _CacheList.Add(ownerInfo); // In AddToCache } protected static void RemoveFromCache(OwnerInfo ownerInfo) { while (_CacheList.Contains(ownerInfo)) _CacheList.Remove(ownerInfo); // In RemoveFromCache } [System.Diagnostics.CodeAnalysis.SuppressMessage("Style", "IDE0044:Add readonly modifier", Justification = "Keeping Collections Not ReadOnly")] private static Dictionary> _CacheByPrimaryKey = new Dictionary>(); private static void ConvertListToDictionary() { while (_CacheList.Count > 0) // Move OwnerInfo(s) from temporary _CacheList to _CacheByPrimaryKey { OwnerInfo tmp = _CacheList[0]; // Get the first OwnerInfo string pKey = tmp.OwnerID.ToString(); if (!_CacheByPrimaryKey.ContainsKey(pKey)) { _CacheByPrimaryKey[pKey] = new List(); // Add new list for PrimaryKey } _CacheByPrimaryKey[pKey].Add(tmp); // Add to Primary Key list _CacheList.RemoveAt(0); // Remove the first OwnerInfo } } internal static void AddList(OwnerInfoList lst) { foreach (OwnerInfo item in lst) AddToCache(item); } protected static OwnerInfo GetCachedByPrimaryKey(int ownerID) { ConvertListToDictionary(); string key = ownerID.ToString(); if (_CacheByPrimaryKey.ContainsKey(key)) return _CacheByPrimaryKey[key][0]; return null; } #endregion #region Business Methods private string _ErrorMessage = string.Empty; public string ErrorMessage => _ErrorMessage; protected Owner _Editable; private int _OwnerID; [System.ComponentModel.DataObjectField(true, true)] public int OwnerID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _OwnerID; } } private int _SessionID; public int SessionID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _SessionID; } } private byte _OwnerType; public byte OwnerType { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _OwnerType; } } private int _OwnerItemID; public int OwnerItemID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _OwnerItemID; } } private DateTime _DTSStart = new DateTime(); public DateTime DTSStart { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _DTSStart; } } // CSLATODO: Check OwnerInfo.GetIdValue to assure that the ID returned is unique /// /// Overrides Base GetIdValue - Used internally by CSLA to determine equality /// /// A Unique ID for the current OwnerInfo protected override object GetIdValue() => MyOwnerInfoUnique; // Absolutely Unique ID #endregion #region Factory Methods private static int _OwnerInfoUnique = 0; private static int OwnerInfoUnique => ++_OwnerInfoUnique; private readonly int _MyOwnerInfoUnique = OwnerInfoUnique; // Absolutely Unique ID - Info public int MyOwnerInfoUnique => _MyOwnerInfoUnique; protected OwnerInfo() {/* require use of factory methods */ AddToCache(this); } private bool _Disposed = false; private static int _CountCreated = 0; private static int _CountDisposed = 0; private static int _CountFinalized = 0; private static int IncrementCountCreated => ++_CountCreated; private readonly int _CountWhenCreated = IncrementCountCreated; public static int CountCreated => _CountCreated; public static int CountNotDisposed => _CountCreated - _CountDisposed; public static int CountNotFinalized => _CountCreated - _CountFinalized; ~OwnerInfo() { _CountFinalized++; } public void Dispose() { if (_Disposed) return; _CountDisposed++; _Disposed = true; RemoveFromCache(this); if (!_CacheByPrimaryKey.ContainsKey(OwnerID.ToString())) return; List listOwnerInfo = _CacheByPrimaryKey[OwnerID.ToString()]; // Get the list of items while (listOwnerInfo.Contains(this)) listOwnerInfo.Remove(this); // Remove the item from the list if (listOwnerInfo.Count == 0) // If there are no items left in the list _CacheByPrimaryKey.Remove(OwnerID.ToString()); // remove the list } public virtual Owner Get() => _Editable = Owner.Get(_OwnerID); public static void Refresh(Owner tmp) { string key = tmp.OwnerID.ToString(); ConvertListToDictionary(); if (_CacheByPrimaryKey.ContainsKey(key)) foreach (OwnerInfo tmpInfo in _CacheByPrimaryKey[key]) tmpInfo.RefreshFields(tmp); } protected virtual void RefreshFields(Owner tmp) { _SessionID = tmp.SessionID; _OwnerType = tmp.OwnerType; _OwnerItemID = tmp.OwnerItemID; _DTSStart = tmp.DTSStart; _OwnerInfoExtension.Refresh(this); OnChange();// raise an event } public static OwnerInfo Get(int ownerID) { try { OwnerInfo tmp = GetCachedByPrimaryKey(ownerID); if (tmp == null) { tmp = DataPortal.Fetch(new PKCriteria(ownerID)); AddToCache(tmp); } if (tmp.ErrorMessage == "No Record Found") { tmp.Dispose(); // Clean-up OwnerInfo tmp = null; } return tmp; } catch (Exception ex) { throw new DbCslaException("Error on OwnerInfo.Get", ex); } } #endregion #region Data Access Portal internal OwnerInfo(SafeDataReader dr) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] OwnerInfo.Constructor", GetHashCode()); try { ReadData(dr); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("OwnerInfo.Constructor", ex); throw new DbCslaException("OwnerInfo.Constructor", ex); } } [Serializable()] protected class PKCriteria { private readonly int _OwnerID; public int OwnerID => _OwnerID; public PKCriteria(int ownerID) => _OwnerID = ownerID; } private void ReadData(SafeDataReader dr) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] OwnerInfo.ReadData", GetHashCode()); try { _OwnerID = dr.GetInt32("OwnerID"); _SessionID = dr.GetInt32("SessionID"); _OwnerType = dr.GetByte("OwnerType"); _OwnerItemID = dr.GetInt32("OwnerItemID"); _DTSStart = dr.GetDateTime("DTSStart"); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("OwnerInfo.ReadData", ex); _ErrorMessage = ex.Message; throw new DbCslaException("OwnerInfo.ReadData", ex); } } private void DataPortal_Fetch(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] OwnerInfo.DataPortal_Fetch", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { ApplicationContext.LocalContext["cn"] = cn; using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "getOwner"; cm.Parameters.AddWithValue("@OwnerID", criteria.OwnerID); using (SafeDataReader dr = new SafeDataReader(cm.ExecuteReader())) { if (!dr.Read()) { _ErrorMessage = "No Record Found"; return; } ReadData(dr); } } // removing of item only needed for local data portal if (ApplicationContext.ExecutionLocation == ApplicationContext.ExecutionLocations.Client) ApplicationContext.LocalContext.Remove("cn"); } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("OwnerInfo.DataPortal_Fetch", ex); _ErrorMessage = ex.Message; throw new DbCslaException("OwnerInfo.DataPortal_Fetch", ex); } } #endregion // Standard Refresh #region extension readonly OwnerInfoExtension _OwnerInfoExtension = new OwnerInfoExtension(); [Serializable()] partial class OwnerInfoExtension : extensionBase { } [Serializable()] class extensionBase { // Default Refresh public virtual void Refresh(OwnerInfo tmp) { } } #endregion } // Class #region Converter internal class OwnerInfoConverter : ExpandableObjectConverter { public override object ConvertTo(ITypeDescriptorContext context, System.Globalization.CultureInfo culture, object value, Type destType) { if (destType == typeof(string) && value is OwnerInfo info) { // Return the ToString value return info.ToString(); } return base.ConvertTo(context, culture, value, destType); } } #endregion } // Namespace