// ======================================================================== // 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.Configuration; using System.IO; using System.ComponentModel; using System.Collections.Generic; namespace VEPROMS.CSLA.Library { public delegate void ROFstInfoEvent(object sender); /// /// ROFstInfo Generated by MyGeneration using the CSLA Object Mapping template /// [Serializable()] [TypeConverter(typeof(ROFstInfoConverter))] public partial class ROFstInfo : ReadOnlyBase, IDisposable { public event ROFstInfoEvent Changed; private void OnChange() { if (Changed != null) Changed(this); } #region Log4Net private static readonly log4net.ILog _MyLog = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); #endregion #region Collection private static List _CacheList = new List(); protected static void AddToCache(ROFstInfo rOFstInfo) { if (!_CacheList.Contains(rOFstInfo)) { rOFstInfo.ClearROLookupBytes(); // B2022-026 RO Memory reduction _CacheList.Add(rOFstInfo); // In AddToCache } } protected static void RemoveFromCache(ROFstInfo rOFstInfo) { while (_CacheList.Contains(rOFstInfo)) _CacheList.Remove(rOFstInfo); // In RemoveFromCache } private static Dictionary> _CacheByPrimaryKey = new Dictionary>(); private static void ConvertListToDictionary() { while (_CacheList.Count > 0) // Move ROFstInfo(s) from temporary _CacheList to _CacheByPrimaryKey { ROFstInfo tmp = _CacheList[0]; // Get the first ROFstInfo string pKey = tmp.ROFstID.ToString(); if (!_CacheByPrimaryKey.ContainsKey(pKey)) { _CacheByPrimaryKey[pKey] = new List(); // Add new list for PrimaryKey } tmp.ClearROLookupBytes(); // B2022-026 RO Memory reduction _CacheByPrimaryKey[pKey].Add(tmp); // Add to Primary Key list _CacheList.RemoveAt(0); // Remove the first ROFstInfo } } internal static void AddList(ROFstInfoList lst) { foreach (ROFstInfo item in lst) AddToCache(item); } protected static ROFstInfo GetCachedByPrimaryKey(int rOFstID) { ConvertListToDictionary(); string key = rOFstID.ToString(); if (_CacheByPrimaryKey.ContainsKey(key)) return _CacheByPrimaryKey[key][0]; return null; } #endregion #region Business Methods private string _ErrorMessage = string.Empty; public string ErrorMessage { get { return _ErrorMessage; } } protected ROFst _Editable; private IVEHasBrokenRules HasBrokenRules { get { IVEHasBrokenRules hasBrokenRules = null; if (_Editable != null) hasBrokenRules = _Editable.HasBrokenRules; return hasBrokenRules; } } private int _ROFstID; [System.ComponentModel.DataObjectField(true, true)] public int ROFstID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _ROFstID; } } private int _RODbID; public int RODbID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyRODb != null) _RODbID = _MyRODb.RODbID; return _RODbID; } } private RODbInfo _MyRODb; public RODbInfo MyRODb { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyRODb == null && _RODbID != 0) _MyRODb = RODbInfo.GetJustRODB(_RODbID); return _MyRODb; } } private byte[] _ROLookup; public byte[] ROLookup { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { // B2022-026 RO Memory reduction return null; } } private string _Config = string.Empty; public string Config { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _Config; } } private DateTime _DTS = new DateTime(); public DateTime DTS { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _DTS; } } private string _UserID = string.Empty; public string UserID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _UserID; } } private int _ROFstAssociationCount = 0; /// /// Count of ROFstAssociations for this ROFst /// public int ROFstAssociationCount { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_ROFstAssociationCount < 0) _ROFstAssociationCount = ROFstAssociations.Count; return _ROFstAssociationCount; } } private AssociationInfoList _ROFstAssociations = null; [TypeConverter(typeof(AssociationInfoListConverter))] public AssociationInfoList ROFstAssociations { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_ROFstAssociationCount < 0 || (_ROFstAssociationCount > 0 && _ROFstAssociations == null)) _ROFstAssociations = AssociationInfoList.GetByROFstID(_ROFstID); if (_ROFstAssociationCount < 0) _ROFstAssociationCount = _ROFstAssociations.Count; return _ROFstAssociations; } } public void RefreshROFstAssociations() { _ROFstAssociationCount = -1; ConvertListToDictionary(); if (_CacheByPrimaryKey.ContainsKey(_ROFstID.ToString())) foreach (ROFstInfo tmp in _CacheByPrimaryKey[_ROFstID.ToString()]) tmp._ROFstAssociationCount = -1; // This will cause the data to be requeried } private int _ROFstFigureCount = 0; /// /// Count of ROFstFigures for this ROFst /// public int ROFstFigureCount { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_ROFstFigureCount < 0) _ROFstFigureCount = ROFstFigures.Count; return _ROFstFigureCount; } } private FigureInfoList _ROFstFigures = null; [TypeConverter(typeof(FigureInfoListConverter))] public FigureInfoList ROFstFigures { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_ROFstFigureCount < 0 || (_ROFstFigureCount > 0 && _ROFstFigures == null)) _ROFstFigures = FigureInfoList.GetByROFstID(_ROFstID); if (_ROFstFigureCount < 0) _ROFstFigureCount = _ROFstFigures.Count; return _ROFstFigures; } } public void RefreshROFstFigures() { _ROFstFigureCount = -1; ConvertListToDictionary(); if (_CacheByPrimaryKey.ContainsKey(_ROFstID.ToString())) foreach (ROFstInfo tmp in _CacheByPrimaryKey[_ROFstID.ToString()]) tmp._ROFstFigureCount = -1; // This will cause the data to be requeried } /// /// Overrides Base GetIdValue - Used internally by CSLA to determine equality /// /// A Unique ID for the current ROFstInfo protected override object GetIdValue() { return MyROFstInfoUnique; // Absolutely Unique ID } #endregion #region Factory Methods private static int _ROFstInfoUnique = 0; private static int ROFstInfoUnique { get { return ++_ROFstInfoUnique; } } private int _MyROFstInfoUnique = ROFstInfoUnique; public int MyROFstInfoUnique // Absolutely Unique ID - Info { get { return _MyROFstInfoUnique; } } protected ROFstInfo() {/* 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 { get { return ++_CountCreated; } } private int _CountWhenCreated = IncrementCountCreated; public static int CountCreated { get { return _CountCreated; } } public static int CountNotDisposed { get { return _CountCreated - _CountDisposed; } } public static int CountNotFinalized { get { return _CountCreated - _CountFinalized; } } ~ROFstInfo() { _CountFinalized++; } public void Dispose() { if (_Disposed) return; _CountDisposed++; _Disposed = true; RemoveFromCache(this); if (!_CacheByPrimaryKey.ContainsKey(ROFstID.ToString())) return; List listROFstInfo = _CacheByPrimaryKey[ROFstID.ToString()]; // Get the list of items while (listROFstInfo.Contains(this)) listROFstInfo.Remove(this); // Remove the item from the list if (listROFstInfo.Count == 0) // If there are no items left in the list _CacheByPrimaryKey.Remove(ROFstID.ToString()); // remove the list } public virtual ROFst Get() { return _Editable = ROFst.Get(_ROFstID); } public static void Refresh(ROFst tmp) { string key = tmp.ROFstID.ToString(); ConvertListToDictionary(); if (_CacheByPrimaryKey.ContainsKey(key)) foreach (ROFstInfo tmpInfo in _CacheByPrimaryKey[key]) tmpInfo.RefreshFields(tmp); } // B2022-026 RO Memory reduction public void ClearROLookupBytes() { _ROLookup = null; } protected virtual void RefreshFields(ROFst tmp) { if (_RODbID != tmp.RODbID) { if (MyRODb != null) MyRODb.RefreshRODbROFsts(); // Update List for old value _RODbID = tmp.RODbID; // Update the value } _MyRODb = null; // Reset list so that the next line gets a new list if (MyRODb != null) MyRODb.RefreshRODbROFsts(); // Update List for new value //_ROLookup = tmp.ROLookup; _ROLookup = null; // B2022-026 RO Memory reduction _Config = tmp.Config; _DTS = tmp.DTS; _UserID = tmp.UserID; _ROFstInfoExtension.Refresh(this); OnChange();// raise an event } public static void Refresh(RODbROFst tmp) { string key = tmp.ROFstID.ToString(); ConvertListToDictionary(); if (_CacheByPrimaryKey.ContainsKey(key)) foreach (ROFstInfo tmpInfo in _CacheByPrimaryKey[key]) tmpInfo.RefreshFields(tmp); } protected virtual void RefreshFields(RODbROFst tmp) { //_ROLookup = tmp.ROLookup; _ROLookup = null; // B2022-026 RO Memory reduction _Config = tmp.Config; _DTS = tmp.DTS; _UserID = tmp.UserID; _ROFstInfoExtension.Refresh(this); OnChange();// raise an event } public static ROFstInfo Get(int rOFstID) { try { ROFstInfo tmp = GetCachedByPrimaryKey(rOFstID); if (tmp == null) { tmp = DataPortal.Fetch(new PKCriteria(rOFstID)); AddToCache(tmp); } if (tmp.ErrorMessage == "No Record Found") { tmp.Dispose(); // Clean-up ROFstInfo tmp = null; } if (tmp != null) { tmp.ClearROLookupBytes(); // B2022-026 RO Memory reduction } return tmp; } catch (Exception ex) { throw new DbCslaException("Error on ROFstInfo.Get", ex); } } #endregion #region Data Access Portal internal ROFstInfo(SafeDataReader dr) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFstInfo.Constructor", GetHashCode()); try { ReadData(dr); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFstInfo.Constructor", ex); throw new DbCslaException("ROFstInfo.Constructor", ex); } } [Serializable()] protected class PKCriteria { private int _ROFstID; public int ROFstID { get { return _ROFstID; } } public PKCriteria(int rOFstID) { _ROFstID = rOFstID; } } private void ReadData(SafeDataReader dr) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFstInfo.ReadData", GetHashCode()); try { _ROFstID = dr.GetInt32("ROFstID"); _RODbID = dr.GetInt32("RODbID"); //_ROLookup = (byte[])dr.GetValue("ROLookup"); _ROLookup = null; // B2022-026 RO Memory reduction _Config = dr.GetString("Config"); _DTS = dr.GetDateTime("DTS"); _UserID = dr.GetString("UserID"); _ROFstAssociationCount = dr.GetInt32("AssociationCount"); _ROFstFigureCount = dr.GetInt32("FigureCount"); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFstInfo.ReadData", ex); _ErrorMessage = ex.Message; throw new DbCslaException("ROFstInfo.ReadData", ex); } } private void DataPortal_Fetch(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFstInfo.DataPortal_Fetch", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { ApplicationContext.LocalContext["cn"] = cn; using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "getROFst"; cm.Parameters.AddWithValue("@ROFstID", criteria.ROFstID); cm.CommandTimeout = Database.DefaultTimeout; 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("ROFstInfo.DataPortal_Fetch", ex); _ErrorMessage = ex.Message; throw new DbCslaException("ROFstInfo.DataPortal_Fetch", ex); } } #endregion // Standard Refresh #region extension ROFstInfoExtension _ROFstInfoExtension = new ROFstInfoExtension(); [Serializable()] partial class ROFstInfoExtension : extensionBase { } [Serializable()] class extensionBase { // Default Refresh public virtual void Refresh(ROFstInfo tmp) { } } #endregion } // Class #region Converter internal class ROFstInfoConverter : ExpandableObjectConverter { public override object ConvertTo(ITypeDescriptorContext context, System.Globalization.CultureInfo culture, object value, Type destType) { if (destType == typeof(string) && value is ROFstInfo) { // Return the ToString value return ((ROFstInfo)value).ToString(); } return base.ConvertTo(context, culture, value, destType); } } #endregion } // Namespace