// ======================================================================== // 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; using Csla.Validation; namespace VEPROMS.CSLA.Library { /// /// Transition Generated by MyGeneration using the CSLA Object Mapping template /// [Serializable()] [TypeConverter(typeof(TransitionConverter))] public partial class Transition : BusinessBase, IDisposable, IVEHasBrokenRules { #region Log4Net private static readonly log4net.ILog _MyLog = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); #endregion #region Refresh private List _RefreshTransitions = new List(); private void AddToRefreshList(List refreshTransitions) { if (IsDirty) refreshTransitions.Add(this); } private void ClearRefreshList() => _RefreshTransitions = new List(); private void BuildRefreshList() { ClearRefreshList(); AddToRefreshList(_RefreshTransitions); } private void ProcessRefreshList() { foreach (Transition tmp in _RefreshTransitions) { TransitionInfo.Refresh(tmp); if (tmp._MyContent != null) ContentInfo.Refresh(tmp._MyContent); if (tmp._MyItemRangeID != null) ItemInfo.Refresh(tmp._MyItemRangeID); if (tmp._MyItemToID != null) ItemInfo.Refresh(tmp._MyItemToID); } ClearRefreshList(); } #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(Transition transition) { if (!_CacheList.Contains(transition)) _CacheList.Add(transition); // In AddToCache } protected static void RemoveFromCache(Transition transition) { while (_CacheList.Contains(transition)) _CacheList.Remove(transition); // 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 Transition(s) from temporary _CacheList to _CacheByPrimaryKey { Transition tmp = _CacheList[0]; // Get the first Transition string pKey = tmp.TransitionID.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 Transition } } protected static Transition GetCachedByPrimaryKey(int transitionID) { ConvertListToDictionary(); string key = transitionID.ToString(); if (_CacheByPrimaryKey.ContainsKey(key)) return _CacheByPrimaryKey[key][0]; return null; } #endregion #region Business Methods private string _ErrorMessage = string.Empty; public string ErrorMessage => _ErrorMessage; private static int _nextTransitionID = -1; public static int NextTransitionID => _nextTransitionID--; private int _TransitionID; [System.ComponentModel.DataObjectField(true, true)] public int TransitionID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _TransitionID; } } private int _FromID; public int FromID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyContent != null) _FromID = _MyContent.ContentID; return _FromID; } } private Content _MyContent; public Content MyContent { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyContent == null && _FromID != 0) _MyContent = Content.Get(_FromID); return _MyContent; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_MyContent != value) { _MyContent = value; _FromID = value.ContentID;// Update underlying data field PropertyHasChanged(); } } } private int _ToID; /// /// StructureID /// public int ToID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyItemToID != null) _ToID = _MyItemToID.ItemID; return _ToID; } } private Item _MyItemToID; public Item MyItemToID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyItemToID == null && _ToID != 0) _MyItemToID = Item.Get(_ToID); return _MyItemToID; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_MyItemToID != value) { _MyItemToID = value; _ToID = value.ItemID;// Update underlying data field PropertyHasChanged(); } } } private int _RangeID; public int RangeID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyItemRangeID != null) _RangeID = _MyItemRangeID.ItemID; return _RangeID; } } private Item _MyItemRangeID; public Item MyItemRangeID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyItemRangeID == null && _RangeID != 0) _MyItemRangeID = Item.Get(_RangeID); return _MyItemRangeID; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_MyItemRangeID != value) { _MyItemRangeID = value; _RangeID = value.ItemID;// Update underlying data field PropertyHasChanged(); } } } private int _IsRange; /// /// 0 - Not a Range Transition, 1 - Range Transition, 2 - Range Transition - Extends to last Sibling /// public int IsRange { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _IsRange; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_IsRange != value) { _IsRange = value; PropertyHasChanged(); } } } private int _TranType; public int TranType { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _TranType; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_TranType != value) { _TranType = value; PropertyHasChanged(); } } } private string _Config = string.Empty; public string Config { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _Config; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (value == null) value = string.Empty; if (_Config != value) { _Config = value; PropertyHasChanged(); } } } private DateTime _DTS = new DateTime(); public DateTime DTS { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _DTS; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_DTS != value) { _DTS = value; PropertyHasChanged(); } } } private string _UserID = string.Empty; public string UserID { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _UserID; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (value == null) value = string.Empty; if (_UserID != value) { _UserID = value; PropertyHasChanged(); } } } private byte[] _LastChanged = new byte[8];//timestamp private int _TransitionZTransitionCount = 0; /// /// Count of TransitionZTransitions for this Transition /// public int TransitionZTransitionCount { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _TransitionZTransitionCount; } } private ZTransition _MyZTransition = null; /// /// Related Field /// [TypeConverter(typeof(ZTransitionConverter))] public ZTransition MyZTransition { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyZTransition == null) _MyZTransition = ZTransition.New(this); return _MyZTransition; } } public override bool IsDirty { get { if (base.IsDirty) return true; return IsDirtyList(new List()); } } public bool IsDirtyList(List list) { if (base.IsDirty || list.Contains(this)) return base.IsDirty; list.Add(this); return base.IsDirty || (_MyZTransition != null && _MyZTransition.IsDirtyList(list)) || (_MyContent != null && _MyContent.IsDirtyList(list)) || (_MyItemRangeID != null && _MyItemRangeID.IsDirtyList(list)) || (_MyItemToID != null && _MyItemToID.IsDirtyList(list)); } public override bool IsValid => IsValidList(new List()); public bool IsValidList(List list) { if (list.Contains(this)) return (IsNew && !IsDirty) || base.IsValid; list.Add(this); return ((IsNew && !IsDirty) || base.IsValid) && (_MyZTransition == null || _MyZTransition.IsValidList(list)) && (_MyContent == null || _MyContent.IsValidList(list)) && (_MyItemRangeID == null || _MyItemRangeID.IsValidList(list)) && (_MyItemToID == null || _MyItemToID.IsValidList(list)); } // CSLATODO: Check Transition.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 Transition protected override object GetIdValue() => MyTransitionUnique; // Absolutely Unique ID #endregion #region ValidationRules [NonSerialized] private bool _CheckingBrokenRules = false; public IVEHasBrokenRules HasBrokenRules { get { if (_CheckingBrokenRules) return null; if ((IsDirty || !IsNew) && BrokenRulesCollection.Count > 0) return this; try { _CheckingBrokenRules = true; IVEHasBrokenRules hasBrokenRules = null; if (_MyZTransition != null && (hasBrokenRules = _MyZTransition.HasBrokenRules) != null) return hasBrokenRules; if (_MyContent != null && (hasBrokenRules = _MyContent.HasBrokenRules) != null) return hasBrokenRules; if (_MyItemToID != null && (hasBrokenRules = _MyItemToID.HasBrokenRules) != null) return hasBrokenRules; if (_MyItemRangeID != null && (hasBrokenRules = _MyItemRangeID.HasBrokenRules) != null) return hasBrokenRules; return hasBrokenRules; } finally { _CheckingBrokenRules = false; } } } public BrokenRulesCollection BrokenRules { get { IVEHasBrokenRules hasBrokenRules = HasBrokenRules; if (Equals(hasBrokenRules)) return BrokenRulesCollection; return hasBrokenRules?.BrokenRules; } } protected override void AddBusinessRules() { ValidationRules.AddRule(MyContentRequired, "MyContent"); ValidationRules.AddRule(MyItemToIDRequired, "MyItemToID"); ValidationRules.AddRule(MyItemRangeIDRequired, "MyItemRangeID"); ValidationRules.AddRule( Csla.Validation.CommonRules.StringMaxLength, new Csla.Validation.CommonRules.MaxLengthRuleArgs("Config", 1073741823)); ValidationRules.AddRule( Csla.Validation.CommonRules.StringRequired, "UserID"); ValidationRules.AddRule( Csla.Validation.CommonRules.StringMaxLength, new Csla.Validation.CommonRules.MaxLengthRuleArgs("UserID", 100)); //ValidationRules.AddDependantProperty("x", "y"); _TransitionExtension.AddValidationRules(ValidationRules); // CSLATODO: Add other validation rules } protected override void AddInstanceBusinessRules() { _TransitionExtension.AddInstanceValidationRules(ValidationRules); // CSLATODO: Add other validation rules } private static bool MyContentRequired(Transition target, Csla.Validation.RuleArgs e) { if (target._FromID == 0 && target._MyContent == null) // Required field missing { e.Description = "Required"; return false; } return true; } private static bool MyItemToIDRequired(Transition target, Csla.Validation.RuleArgs e) { if (target._ToID == 0 && target._MyItemToID == null) // Required field missing { e.Description = "Required"; return false; } return true; } private static bool MyItemRangeIDRequired(Transition target, Csla.Validation.RuleArgs e) { if (target._RangeID == 0 && target._MyItemRangeID == null) // Required field missing { e.Description = "Required"; return false; } return true; } #endregion #region Authorization Rules protected override void AddAuthorizationRules() { //CSLATODO: Who can read/write which fields _TransitionExtension.AddAuthorizationRules(AuthorizationRules); } protected override void AddInstanceAuthorizationRules() { //CSLATODO: Who can read/write which fields _TransitionExtension.AddInstanceAuthorizationRules(AuthorizationRules); } #endregion #region Factory Methods public int CurrentEditLevel => EditLevel; private static int _TransitionUnique = 0; protected static int TransitionUnique => ++_TransitionUnique; private readonly int _MyTransitionUnique = TransitionUnique; // Absolutely Unique ID - Editable public int MyTransitionUnique => _MyTransitionUnique; protected Transition() {/* 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; ~Transition() { _CountFinalized++; } public void Dispose() { if (_Disposed) return; _CountDisposed++; _Disposed = true; RemoveFromDictionaries(); if (_MyZTransition != null) { _MyZTransition.Dispose(); _MyZTransition = null; } if (_MyContent != null) _MyContent = null; } private void RemoveFromDictionaries() { RemoveFromCache(this); if (_CacheByPrimaryKey.ContainsKey(TransitionID.ToString())) { List listTransition = _CacheByPrimaryKey[TransitionID.ToString()]; // Get the list of items while (listTransition.Contains(this)) listTransition.Remove(this); // Remove the item from the list if (listTransition.Count == 0) //If there are no items left in the list _CacheByPrimaryKey.Remove(TransitionID.ToString()); // remove the list } } public static Transition New() { try { return DataPortal.Create(); } catch (Exception ex) { throw new DbCslaException("Error on Transition.New", ex); } } public static Transition New(Content myContent, Item myItemToID, Item myItemRangeID) { Transition tmp = Transition.New(); tmp.MyContent = myContent; tmp.MyItemToID = myItemToID; tmp.MyItemRangeID = myItemRangeID; return tmp; } public static Transition New(Content myContent, Item myItemToID, Item myItemRangeID, int isRange, int tranType, string config, DateTime dts, string userID) { Transition tmp = Transition.New(); tmp.MyContent = myContent; tmp.MyItemToID = myItemToID; tmp.MyItemRangeID = myItemRangeID; tmp.IsRange = isRange; tmp.TranType = tranType; tmp.Config = config; tmp.DTS = dts; tmp.UserID = userID; return tmp; } public static Transition MakeTransition(Content myContent, Item myItemToID, Item myItemRangeID, int isRange, int tranType, string config, DateTime dts, string userID) { Transition tmp = Transition.New(myContent, myItemToID, myItemRangeID, isRange, tranType, config, dts, userID); if (tmp.IsSavable) tmp = tmp.Save(); else { Csla.Validation.BrokenRulesCollection brc = tmp.ValidationRules.GetBrokenRules(); tmp._ErrorMessage = "Failed Validation:"; foreach (Csla.Validation.BrokenRule br in brc) { tmp._ErrorMessage += "\r\n\tFailure: " + br.RuleName; } } return tmp; } public static Transition New(Content myContent, Item myItemToID, Item myItemRangeID, string config) { Transition tmp = Transition.New(); tmp.MyContent = myContent; tmp.MyItemToID = myItemToID; tmp.MyItemRangeID = myItemRangeID; tmp.Config = config; return tmp; } public static Transition MakeTransition(Content myContent, Item myItemToID, Item myItemRangeID, string config) { Transition tmp = Transition.New(myContent, myItemToID, myItemRangeID, config); if (tmp.IsSavable) tmp = tmp.Save(); else { Csla.Validation.BrokenRulesCollection brc = tmp.ValidationRules.GetBrokenRules(); tmp._ErrorMessage = "Failed Validation:"; foreach (Csla.Validation.BrokenRule br in brc) { tmp._ErrorMessage += "\r\n\tFailure: " + br.RuleName; } } return tmp; } public static Transition Get(int transitionID) { try { Transition tmp = GetCachedByPrimaryKey(transitionID); if (tmp == null) { tmp = DataPortal.Fetch(new PKCriteria(transitionID)); AddToCache(tmp); } if (tmp.ErrorMessage == "No Record Found") { tmp.Dispose(); // Clean-up Transition tmp = null; } return tmp; } catch (Exception ex) { throw new DbCslaException("Error on Transition.Get", ex); } } public static Transition Get(SafeDataReader dr) { if (dr.Read()) return new Transition(dr); return null; } internal Transition(SafeDataReader dr) => ReadData(dr); public static void Delete(int transitionID) { try { DataPortal.Delete(new PKCriteria(transitionID)); } catch (Exception ex) { throw new DbCslaException("Error on Transition.Delete", ex); } } public override Transition Save() { try { BuildRefreshList(); Transition transition = base.Save(); RemoveFromDictionaries(); // if save is successful remove the previous Folder from the cache AddToCache(transition);//Refresh the item in AllList ProcessRefreshList(); return transition; } catch (Exception ex) { throw new DbCslaException("Error on CSLA Save", ex); } } #endregion #region Data Access Portal [Serializable()] protected class PKCriteria { private readonly int _TransitionID; public int TransitionID => _TransitionID; public PKCriteria(int transitionID) => _TransitionID = transitionID; } // CSLATODO: If Create needs to access DB - It should not be marked RunLocal [RunLocal()] private new void DataPortal_Create() { _TransitionID = NextTransitionID; // Database Defaults _IsRange = _TransitionExtension.DefaultIsRange; _TranType = _TransitionExtension.DefaultTranType; _DTS = _TransitionExtension.DefaultDTS; _UserID = _TransitionExtension.DefaultUserID; // CSLATODO: Add any defaults that are necessary ValidationRules.CheckRules(); } private void ReadData(SafeDataReader dr) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.ReadData", GetHashCode()); try { _TransitionID = dr.GetInt32("TransitionID"); _FromID = dr.GetInt32("FromID"); _ToID = dr.GetInt32("ToID"); _RangeID = dr.GetInt32("RangeID"); _IsRange = dr.GetInt32("IsRange"); _TranType = dr.GetInt32("TranType"); _Config = dr.GetString("Config"); _DTS = dr.GetDateTime("DTS"); _UserID = dr.GetString("UserID"); dr.GetBytes("LastChanged", 0, _LastChanged, 0, 8); _TransitionZTransitionCount = dr.GetInt32("ZTransitionCount"); MarkOld(); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.ReadData", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Transition.ReadData", ex); } } private void DataPortal_Fetch(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.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 = "getTransition"; cm.Parameters.AddWithValue("@TransitionID", criteria.TransitionID); cm.CommandTimeout = Database.DefaultTimeout; using (SafeDataReader dr = new SafeDataReader(cm.ExecuteReader())) { if (!dr.Read()) { _ErrorMessage = "No Record Found"; return; } ReadData(dr); // load child objects dr.NextResult(); _MyZTransition = ZTransition.Get(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("Transition.DataPortal_Fetch", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Transition.DataPortal_Fetch", ex); } } [Transactional(TransactionalTypes.TransactionScope)] protected override void DataPortal_Insert() { try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { ApplicationContext.LocalContext["cn"] = cn; SQLInsert(); // 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("Transition.DataPortal_Insert", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Transition.DataPortal_Insert", ex); } finally { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.DataPortal_Insert", GetHashCode()); } } [Transactional(TransactionalTypes.TransactionScope)] internal void SQLInsert() { if (!IsDirty) return; try { _MyContent?.Update(); _MyItemRangeID?.Update(); _MyItemToID?.Update(); using (SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]) { if (cn.State == System.Data.ConnectionState.Closed) cn.Open(); using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "addTransition"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@FromID", FromID); cm.Parameters.AddWithValue("@ToID", ToID); cm.Parameters.AddWithValue("@RangeID", RangeID); cm.Parameters.AddWithValue("@IsRange", _IsRange); cm.Parameters.AddWithValue("@TranType", _TranType); cm.Parameters.AddWithValue("@Config", _Config); if (_DTS.Year >= 1753 && _DTS.Year <= 9999) cm.Parameters.AddWithValue("@DTS", _DTS); cm.Parameters.AddWithValue("@UserID", _UserID); // Output Calculated Columns SqlParameter param_TransitionID = new SqlParameter("@newTransitionID", SqlDbType.Int) { Direction = ParameterDirection.Output }; cm.Parameters.Add(param_TransitionID); SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp) { Direction = ParameterDirection.Output }; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure _TransitionID = (int)cm.Parameters["@newTransitionID"].Value; _LastChanged = (byte[])cm.Parameters["@newLastChanged"].Value; } } MarkOld(); // update child objects _MyZTransition?.Update(this); if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.SQLInsert", GetHashCode()); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.SQLInsert", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Transition.SQLInsert", ex); } } [Transactional(TransactionalTypes.TransactionScope)] public static byte[] Add(SqlConnection cn, ref int transitionID, Content myContent, Item myItemToID, Item myItemRangeID, int isRange, int tranType, string config, DateTime dts, string userID) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.Add", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "addTransition"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@FromID", myContent.ContentID); cm.Parameters.AddWithValue("@ToID", myItemToID.ItemID); cm.Parameters.AddWithValue("@RangeID", myItemRangeID.ItemID); cm.Parameters.AddWithValue("@IsRange", isRange); cm.Parameters.AddWithValue("@TranType", tranType); cm.Parameters.AddWithValue("@Config", config); if (dts.Year >= 1753 && dts.Year <= 9999) cm.Parameters.AddWithValue("@DTS", dts); cm.Parameters.AddWithValue("@UserID", userID); // Output Calculated Columns SqlParameter param_TransitionID = new SqlParameter("@newTransitionID", SqlDbType.Int) { Direction = ParameterDirection.Output }; cm.Parameters.Add(param_TransitionID); SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp) { Direction = ParameterDirection.Output }; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure transitionID = (int)cm.Parameters["@newTransitionID"].Value; return (byte[])cm.Parameters["@newLastChanged"].Value; } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.Add", ex); throw new DbCslaException("Transition.Add", ex); } } [Transactional(TransactionalTypes.TransactionScope)] protected override void DataPortal_Update() { if (!IsDirty) return; // If not dirty - nothing to do if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.DataPortal_Update", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { ApplicationContext.LocalContext["cn"] = cn; SQLUpdate(); // 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("Transition.DataPortal_Update", ex); _ErrorMessage = ex.Message; if (!ex.Message.EndsWith("has been edited by another user.")) throw ex; } } [Transactional(TransactionalTypes.TransactionScope)] internal void SQLUpdate() { if (!IsDirty) return; // If not dirty - nothing to do if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.SQLUpdate", GetHashCode()); try { _MyContent?.Update(); _MyItemRangeID?.Update(); _MyItemToID?.Update(); using (SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]) { if (cn.State == System.Data.ConnectionState.Closed) cn.Open(); if (base.IsDirty) { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "updateTransition"; // All Fields including Calculated Fields cm.Parameters.AddWithValue("@TransitionID", _TransitionID); cm.Parameters.AddWithValue("@FromID", FromID); cm.Parameters.AddWithValue("@ToID", ToID); cm.Parameters.AddWithValue("@RangeID", RangeID); cm.Parameters.AddWithValue("@IsRange", _IsRange); cm.Parameters.AddWithValue("@TranType", _TranType); cm.Parameters.AddWithValue("@Config", _Config); if (_DTS.Year >= 1753 && _DTS.Year <= 9999) cm.Parameters.AddWithValue("@DTS", _DTS); cm.Parameters.AddWithValue("@UserID", _UserID); cm.Parameters.AddWithValue("@LastChanged", _LastChanged); // Output Calculated Columns SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp) { Direction = ParameterDirection.Output }; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure _LastChanged = (byte[])cm.Parameters["@newLastChanged"].Value; } } } MarkOld(); // use the open connection to update child objects _MyZTransition?.Update(this); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.SQLUpdate", ex); _ErrorMessage = ex.Message; if (!ex.Message.EndsWith("has been edited by another user.")) throw ex; } } internal void Update() { if (!IsDirty) return; if (base.IsDirty) { using (SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]) { if (cn.State == System.Data.ConnectionState.Closed) cn.Open(); if (IsNew) _LastChanged = Transition.Add(cn, ref _TransitionID, _MyContent, _MyItemToID, _MyItemRangeID, _IsRange, _TranType, _Config, _DTS, _UserID); else _LastChanged = Transition.Update(cn, ref _TransitionID, _FromID, _ToID, _RangeID, _IsRange, _TranType, _Config, _DTS, _UserID, ref _LastChanged); } MarkOld(); } _MyZTransition?.Update(this); } [Transactional(TransactionalTypes.TransactionScope)] public static byte[] Update(SqlConnection cn, ref int transitionID, int fromID, int toID, int rangeID, int isRange, int tranType, string config, DateTime dts, string userID, ref byte[] lastChanged) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.Update", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "updateTransition"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@TransitionID", transitionID); cm.Parameters.AddWithValue("@FromID", fromID); cm.Parameters.AddWithValue("@ToID", toID); cm.Parameters.AddWithValue("@RangeID", rangeID); cm.Parameters.AddWithValue("@IsRange", isRange); cm.Parameters.AddWithValue("@TranType", tranType); cm.Parameters.AddWithValue("@Config", config); if (dts.Year >= 1753 && dts.Year <= 9999) cm.Parameters.AddWithValue("@DTS", dts); cm.Parameters.AddWithValue("@UserID", userID); cm.Parameters.AddWithValue("@LastChanged", lastChanged); // Output Calculated Columns SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp) { Direction = ParameterDirection.Output }; cm.Parameters.Add(param_LastChanged); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure return (byte[])cm.Parameters["@newLastChanged"].Value; } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.Update", ex); throw new DbCslaException("Transition.Update", ex); } } [Transactional(TransactionalTypes.TransactionScope)] protected override void DataPortal_DeleteSelf() { DataPortal_Delete(new PKCriteria(_TransitionID)); } [Transactional(TransactionalTypes.TransactionScope)] private void DataPortal_Delete(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.DataPortal_Delete", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "deleteTransition"; cm.Parameters.AddWithValue("@TransitionID", criteria.TransitionID); cm.ExecuteNonQuery(); } } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.DataPortal_Delete", ex); _ErrorMessage = ex.Message; throw new DbCslaException("Transition.DataPortal_Delete", ex); } } [Transactional(TransactionalTypes.TransactionScope)] public static void Remove(SqlConnection cn, int transitionID) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.Remove", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "deleteTransition"; // Input PK Fields cm.Parameters.AddWithValue("@TransitionID", transitionID); // CSLATODO: Define any additional output parameters cm.ExecuteNonQuery(); } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.Remove", ex); throw new DbCslaException("Transition.Remove", ex); } } #endregion #region Exists public static bool Exists(int transitionID) { ExistsCommand result; try { result = DataPortal.Execute(new ExistsCommand(transitionID)); return result.Exists; } catch (Exception ex) { throw new DbCslaException("Error on Transition.Exists", ex); } } [Serializable()] private class ExistsCommand : CommandBase { private readonly int _TransitionID; private bool _exists; public bool Exists => _exists; public ExistsCommand(int transitionID) => _TransitionID = transitionID; protected override void DataPortal_Execute() { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] Transition.DataPortal_Execute", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { if (cn.State == System.Data.ConnectionState.Closed) cn.Open(); using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandTimeout = Database.SQLTimeout; cm.CommandText = "existsTransition"; cm.Parameters.AddWithValue("@TransitionID", _TransitionID); int count = (int)cm.ExecuteScalar(); _exists = count > 0; } } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("Transition.DataPortal_Execute", ex); throw new DbCslaException("Transition.DataPortal_Execute", ex); } } } #endregion // Standard Default Code #region extension readonly TransitionExtension _TransitionExtension = new TransitionExtension(); [Serializable()] partial class TransitionExtension : extensionBase { } [Serializable()] class extensionBase { // Default Values public virtual int DefaultIsRange => 0; public virtual int DefaultTranType => 0; public virtual DateTime DefaultDTS => DateTime.Now; public virtual string DefaultUserID => Volian.Base.Library.VlnSettings.UserID; // Authorization Rules public virtual void AddAuthorizationRules(Csla.Security.AuthorizationRules rules) { // Needs to be overriden to add new authorization rules } // Instance Authorization Rules public virtual void AddInstanceAuthorizationRules(Csla.Security.AuthorizationRules rules) { // Needs to be overriden to add new authorization rules } // Validation Rules public virtual void AddValidationRules(Csla.Validation.ValidationRules rules) { // Needs to be overriden to add new validation rules } // InstanceValidation Rules public virtual void AddInstanceValidationRules(Csla.Validation.ValidationRules rules) { // Needs to be overriden to add new validation rules } } #endregion } // Class #region Converter internal class TransitionConverter : ExpandableObjectConverter { public override object ConvertTo(ITypeDescriptorContext context, System.Globalization.CultureInfo culture, object value, Type destType) { if (destType == typeof(string) && value is Transition transs) { // Return the ToString value return transs.ToString(); } return base.ConvertTo(context, culture, value, destType); } } #endregion } // Namespace