// ======================================================================== // 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; using Csla.Validation; namespace VEPROMS.CSLA.Library { /// /// ROFst Generated by MyGeneration using the CSLA Object Mapping template /// [Serializable()] [TypeConverter(typeof(ROFstConverter))] public partial class ROFst : BusinessBase, IDisposable, IVEHasBrokenRules { #region Log4Net private static readonly log4net.ILog _MyLog = log4net.LogManager.GetLogger(System.Reflection.MethodBase.GetCurrentMethod().DeclaringType); #endregion #region Refresh private List _RefreshROFsts = new List(); private List _RefreshROFstDocVersionROFsts = new List(); private List _RefreshROFstROFstImages = new List(); private void AddToRefreshList(List refreshROFsts, List refreshROFstDocVersionROFsts, List refreshROFstROFstImages) { if (IsDirty) refreshROFsts.Add(this); if (_ROFstDocVersionROFsts != null && _ROFstDocVersionROFsts.IsDirty) { foreach (ROFstDocVersionROFst tmp in _ROFstDocVersionROFsts) { if (tmp.IsDirty) refreshROFstDocVersionROFsts.Add(tmp); } } if (_ROFstROFstImages != null && _ROFstROFstImages.IsDirty) { foreach (ROFstROFstImage tmp in _ROFstROFstImages) { if (tmp.IsDirty) refreshROFstROFstImages.Add(tmp); } } } private void BuildRefreshList() { _RefreshROFsts = new List(); _RefreshROFstDocVersionROFsts = new List(); _RefreshROFstROFstImages = new List(); AddToRefreshList(_RefreshROFsts, _RefreshROFstDocVersionROFsts, _RefreshROFstROFstImages); } private void ProcessRefreshList() { foreach (ROFst tmp in _RefreshROFsts) { ROFstInfo.Refresh(tmp); if (tmp._MyRODb != null) RODbInfo.Refresh(tmp._MyRODb); } foreach (ROFstDocVersionROFst tmp in _RefreshROFstDocVersionROFsts) { DocVersionROFstInfo.Refresh(this, tmp); } foreach (ROFstROFstImage tmp in _RefreshROFstROFstImages) { ROFstImageInfo.Refresh(this, tmp); } } #endregion #region Collection private static List _CacheList = new List(); protected static void AddToCache(ROFst rOFst) { if (!_CacheList.Contains(rOFst)) _CacheList.Add(rOFst); // In AddToCache } protected static void RemoveFromCache(ROFst rOFst) { while (_CacheList.Contains(rOFst)) _CacheList.Remove(rOFst); // In RemoveFromCache } private static Dictionary> _CacheByPrimaryKey = new Dictionary>(); private static void ConvertListToDictionary() { List remove = new List(); foreach (ROFst tmp in _CacheList) { if (!_CacheByPrimaryKey.ContainsKey(tmp.ROFstID.ToString())) { _CacheByPrimaryKey[tmp.ROFstID.ToString()] = new List(); // Add new list for PrimaryKey } _CacheByPrimaryKey[tmp.ROFstID.ToString()].Add(tmp); // Add to Primary Key list remove.Add(tmp); } foreach (ROFst tmp in remove) RemoveFromCache(tmp); } protected static ROFst 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; } } private static int _nextROFstID = -1; public static int NextROFstID { get { return _nextROFstID--; } } 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 RODb _MyRODb; public RODb MyRODb { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_MyRODb == null && _RODbID != 0) _MyRODb = RODb.Get(_RODbID); return _MyRODb; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_MyRODb != value) { _MyRODb = value; PropertyHasChanged(); } } } private byte[] _ROFST; public byte[] ROFST { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _ROFST; } [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] set { if (_ROFST != value) { _ROFST = 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 _ROFstDocVersionROFstCount = 0; /// /// Count of ROFstDocVersionROFsts for this ROFst /// public int ROFstDocVersionROFstCount { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _ROFstDocVersionROFstCount; } } private ROFstDocVersionROFsts _ROFstDocVersionROFsts = null; /// /// Related Field /// [TypeConverter(typeof(ROFstDocVersionROFstsConverter))] public ROFstDocVersionROFsts ROFstDocVersionROFsts { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { // TODO: See if this fixed after docversion changes. // if (_ROFstDocVersionROFstCount > 0 && _ROFstDocVersionROFsts == null) _ROFstDocVersionROFsts = ROFstDocVersionROFsts.GetByROFstID(ROFstID); // TODO: This should be uncommented after docversion changes: //else if (_ROFstDocVersionROFsts == null) // _ROFstDocVersionROFsts = ROFstDocVersionROFsts.New(); return _ROFstDocVersionROFsts; } } private int _ROFstROFstImageCount = 0; /// /// Count of ROFstROFstImages for this ROFst /// public int ROFstROFstImageCount { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { return _ROFstROFstImageCount; } } private ROFstROFstImages _ROFstROFstImages = null; /// /// Related Field /// [TypeConverter(typeof(ROFstROFstImagesConverter))] public ROFstROFstImages ROFstROFstImages { [System.Runtime.CompilerServices.MethodImpl(System.Runtime.CompilerServices.MethodImplOptions.NoInlining)] get { if (_ROFstROFstImageCount > 0 && _ROFstROFstImages == null) _ROFstROFstImages = ROFstROFstImages.GetByROFstID(ROFstID); else if (_ROFstROFstImages == null) _ROFstROFstImages = ROFstROFstImages.New(); return _ROFstROFstImages; } } public override bool IsDirty { get { return base.IsDirty || (_ROFstDocVersionROFsts == null ? false : _ROFstDocVersionROFsts.IsDirty) || (_ROFstROFstImages == null ? false : _ROFstROFstImages.IsDirty) || (_MyRODb == null ? false : _MyRODb.IsDirty); } } public override bool IsValid { get { return (IsNew && !IsDirty ? true : base.IsValid) && (_ROFstDocVersionROFsts == null ? true : _ROFstDocVersionROFsts.IsValid) && (_ROFstROFstImages == null ? true : _ROFstROFstImages.IsValid) && (_MyRODb == null ? true : _MyRODb.IsValid); } } // TODO: Replace base ROFst.ToString function as necessary /// /// Overrides Base ToString /// /// A string representation of current ROFst //public override string ToString() //{ // return base.ToString(); //} // TODO: Check ROFst.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 ROFst protected override object GetIdValue() { return _ROFstID; } #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 (_ROFstDocVersionROFsts != null && (hasBrokenRules = _ROFstDocVersionROFsts.HasBrokenRules) != null) return hasBrokenRules; if (_ROFstROFstImages != null && (hasBrokenRules = _ROFstROFstImages.HasBrokenRules) != null) return hasBrokenRules; if (_MyRODb != null && (hasBrokenRules = _MyRODb.HasBrokenRules) != null) return hasBrokenRules; return hasBrokenRules; } finally { _CheckingBrokenRules = false; } } } public BrokenRulesCollection BrokenRules { get { IVEHasBrokenRules hasBrokenRules = HasBrokenRules; if (this.Equals(hasBrokenRules)) return BrokenRulesCollection; return (hasBrokenRules != null ? hasBrokenRules.BrokenRules : null); } } protected override void AddBusinessRules() { ValidationRules.AddRule(MyRODbRequired, "MyRODb"); ValidationRules.AddRule( Csla.Validation.CommonRules.StringRequired, "UserID"); ValidationRules.AddRule( Csla.Validation.CommonRules.StringMaxLength, new Csla.Validation.CommonRules.MaxLengthRuleArgs("UserID", 100)); //ValidationRules.AddDependantProperty("x", "y"); _ROFstExtension.AddValidationRules(ValidationRules); // TODO: Add other validation rules } protected override void AddInstanceBusinessRules() { _ROFstExtension.AddInstanceValidationRules(ValidationRules); // TODO: Add other validation rules } private static bool MyRODbRequired(ROFst target, Csla.Validation.RuleArgs e) { if (target._RODbID == 0 && target._MyRODb == null) // Required field missing { e.Description = "Required"; return false; } return true; } // Sample data comparison validation rule //private bool StartDateGTEndDate(object target, Csla.Validation.RuleArgs e) //{ // if (_started > _ended) // { // e.Description = "Start date can't be after end date"; // return false; // } // else // return true; //} #endregion #region Authorization Rules protected override void AddAuthorizationRules() { //TODO: Who can read/write which fields //AuthorizationRules.AllowRead(ROFstID, ""); //AuthorizationRules.AllowRead(RODbID, ""); //AuthorizationRules.AllowRead(ROFST, ""); //AuthorizationRules.AllowRead(DTS, ""); //AuthorizationRules.AllowRead(UserID, ""); //AuthorizationRules.AllowWrite(RODbID, ""); //AuthorizationRules.AllowWrite(ROFST, ""); //AuthorizationRules.AllowWrite(DTS, ""); //AuthorizationRules.AllowWrite(UserID, ""); _ROFstExtension.AddAuthorizationRules(AuthorizationRules); } protected override void AddInstanceAuthorizationRules() { //TODO: Who can read/write which fields _ROFstExtension.AddInstanceAuthorizationRules(AuthorizationRules); } public static bool CanAddObject() { // TODO: Can Add Authorization //return Csla.ApplicationContext.User.IsInRole("ProjectManager"); return true; } public static bool CanGetObject() { // TODO: CanGet Authorization return true; } public static bool CanDeleteObject() { // TODO: CanDelete Authorization //bool result = false; //if (Csla.ApplicationContext.User.IsInRole("ProjectManager"))result = true; //if (Csla.ApplicationContext.User.IsInRole("Administrator"))result = true; //return result; return true; } /// /// determines if related records (Foreign Keys) will keep this Item from being deleted /// public bool CanDelete { get { // Check to make sure that there are not any related records int usedByCount = 0; usedByCount += _ROFstDocVersionROFstCount; usedByCount += _ROFstROFstImageCount; return (usedByCount == 0); } } public static bool CanEditObject() { // TODO: CanEdit Authorization //return Csla.ApplicationContext.User.IsInRole("ProjectManager"); return true; } #endregion #region Factory Methods public int CurrentEditLevel { get { return EditLevel; } } private static int _ROFstUnique = 0; protected static int ROFstUnique { get { return ++_ROFstUnique; } } private int _MyROFstUnique = ROFstUnique; public int MyROFstUnique { get { return _MyROFstUnique; } } protected ROFst() {/* require use of factory methods */ AddToCache(this); } public void Dispose() { RemoveFromDictionaries(); } private void RemoveFromDictionaries() { RemoveFromCache(this); if (_CacheByPrimaryKey.ContainsKey(ROFstID.ToString())) { List listROFst = _CacheByPrimaryKey[ROFstID.ToString()]; // Get the list of items while (listROFst.Contains(this)) listROFst.Remove(this); // Remove the item from the list if (listROFst.Count == 0) //If there are no items left in the list _CacheByPrimaryKey.Remove(ROFstID.ToString()); // remove the list } } public static ROFst New() { if (!CanAddObject()) throw new System.Security.SecurityException("User not authorized to add a ROFst"); try { return DataPortal.Create(); } catch (Exception ex) { throw new DbCslaException("Error on ROFst.New", ex); } } public static ROFst New(RODb myRODb, byte[] rofst) { ROFst tmp = ROFst.New(); tmp.MyRODb = myRODb; tmp.ROFST = rofst; return tmp; } public static ROFst MakeROFst(RODb myRODb, byte[] rofst) { ROFst tmp = ROFst.New(myRODb, rofst); if (tmp.IsSavable) { ROFst tmp2 = tmp; tmp = tmp2.Save(); tmp2.Dispose(); } 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 ROFst New(RODb myRODb, byte[] rofst, DateTime dts, string userID) { ROFst tmp = ROFst.New(); tmp.MyRODb = myRODb; tmp.ROFST = rofst; tmp.DTS = dts; tmp.UserID = userID; return tmp; } public static ROFst MakeROFst(RODb myRODb, byte[] rofst, DateTime dts, string userID) { ROFst tmp = ROFst.New(myRODb, rofst, dts, userID); if (tmp.IsSavable) { ROFst tmp2 = tmp; tmp = tmp2.Save(); tmp2.Dispose(); } 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 ROFst Get(int rOFstID) { if (!CanGetObject()) throw new System.Security.SecurityException("User not authorized to view a ROFst"); try { ROFst tmp = GetCachedByPrimaryKey(rOFstID); if (tmp == null) { tmp = DataPortal.Fetch(new PKCriteria(rOFstID)); AddToCache(tmp); } if (tmp.ErrorMessage == "No Record Found") { tmp.Dispose(); // Clean-up ROFst tmp = null; } return tmp; } catch (Exception ex) { throw new DbCslaException("Error on ROFst.Get", ex); } } public static ROFst Get(SafeDataReader dr) { if (dr.Read()) return new ROFst(dr); return null; } internal ROFst(SafeDataReader dr) { ReadData(dr); } public static void Delete(int rOFstID) { if (!CanDeleteObject()) throw new System.Security.SecurityException("User not authorized to remove a ROFst"); try { DataPortal.Delete(new PKCriteria(rOFstID)); } catch (Exception ex) { throw new DbCslaException("Error on ROFst.Delete", ex); } } public override ROFst Save() { if (IsDeleted && !CanDeleteObject()) throw new System.Security.SecurityException("User not authorized to remove a ROFst"); else if (IsNew && !CanAddObject()) throw new System.Security.SecurityException("User not authorized to add a ROFst"); else if (!CanEditObject()) throw new System.Security.SecurityException("User not authorized to update a ROFst"); try { BuildRefreshList(); ROFst rOFst = base.Save(); RemoveFromDictionaries(); // if save is successful remove the previous Folder from the cache AddToCache(rOFst);//Refresh the item in AllList ProcessRefreshList(); return rOFst; } catch (Exception ex) { throw new DbCslaException("Error on CSLA Save", ex); } } #endregion #region Data Access Portal [Serializable()] protected class PKCriteria { private int _ROFstID; public int ROFstID { get { return _ROFstID; } } public PKCriteria(int rOFstID) { _ROFstID = rOFstID; } } // TODO: If Create needs to access DB - It should not be marked RunLocal [RunLocal()] private new void DataPortal_Create() { _ROFstID = NextROFstID; // Database Defaults _DTS = _ROFstExtension.DefaultDTS; _UserID = _ROFstExtension.DefaultUserID; // TODO: Add any defaults that are necessary ValidationRules.CheckRules(); } private void ReadData(SafeDataReader dr) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.ReadData", GetHashCode()); try { _ROFstID = dr.GetInt32("ROFstID"); _RODbID = dr.GetInt32("RODbID"); _ROFST = (byte[])dr.GetValue("ROFST"); _DTS = dr.GetDateTime("DTS"); _UserID = dr.GetString("UserID"); dr.GetBytes("LastChanged", 0, _LastChanged, 0, 8); _ROFstDocVersionROFstCount = dr.GetInt32("DocVersionROFstCount"); _ROFstROFstImageCount = dr.GetInt32("ROFstImageCount"); MarkOld(); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFst.ReadData", ex); _ErrorMessage = ex.Message; throw new DbCslaException("ROFst.ReadData", ex); } } private void DataPortal_Fetch(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.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); using (SafeDataReader dr = new SafeDataReader(cm.ExecuteReader())) { if (!dr.Read()) { _ErrorMessage = "No Record Found"; return; } ReadData(dr); // load child objects dr.NextResult(); _ROFstDocVersionROFsts = ROFstDocVersionROFsts.Get(dr); // load child objects dr.NextResult(); _ROFstROFstImages = ROFstROFstImages.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("ROFst.DataPortal_Fetch", ex); _ErrorMessage = ex.Message; throw new DbCslaException("ROFst.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("ROFst.DataPortal_Insert", ex); _ErrorMessage = ex.Message; throw new DbCslaException("ROFst.DataPortal_Insert", ex); } finally { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.DataPortal_Insert", GetHashCode()); } } [Transactional(TransactionalTypes.TransactionScope)] internal void SQLInsert() { if (!this.IsDirty) return; try { if (_MyRODb != null) _MyRODb.Update(); SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]; using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "addROFst"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@RODbID", RODbID); cm.Parameters.AddWithValue("@ROFST", _ROFST); if (_DTS.Year >= 1753 && _DTS.Year <= 9999) cm.Parameters.AddWithValue("@DTS", _DTS); cm.Parameters.AddWithValue("@UserID", _UserID); // Output Calculated Columns SqlParameter param_ROFstID = new SqlParameter("@newROFstID", SqlDbType.Int); param_ROFstID.Direction = ParameterDirection.Output; cm.Parameters.Add(param_ROFstID); SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // TODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure _ROFstID = (int)cm.Parameters["@newROFstID"].Value; _LastChanged = (byte[])cm.Parameters["@newLastChanged"].Value; } MarkOld(); // update child objects if (_ROFstDocVersionROFsts != null) _ROFstDocVersionROFsts.Update(this); if (_ROFstROFstImages != null) _ROFstROFstImages.Update(this); if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.SQLInsert", GetHashCode()); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFst.SQLInsert", ex); _ErrorMessage = ex.Message; throw new DbCslaException("ROFst.SQLInsert", ex); } } [Transactional(TransactionalTypes.TransactionScope)] public static byte[] Add(SqlConnection cn, ref int rOFstID, RODb myRODb, byte[] rofst, DateTime dts, string userID) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.Add", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "addROFst"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@RODbID", myRODb.RODbID); cm.Parameters.AddWithValue("@ROFST", rofst); if (dts.Year >= 1753 && dts.Year <= 9999) cm.Parameters.AddWithValue("@DTS", dts); cm.Parameters.AddWithValue("@UserID", userID); // Output Calculated Columns SqlParameter param_ROFstID = new SqlParameter("@newROFstID", SqlDbType.Int); param_ROFstID.Direction = ParameterDirection.Output; cm.Parameters.Add(param_ROFstID); SqlParameter param_LastChanged = new SqlParameter("@newLastChanged", SqlDbType.Timestamp); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // TODO: Define any additional output parameters cm.ExecuteNonQuery(); // Save all values being returned from the Procedure rOFstID = (int)cm.Parameters["@newROFstID"].Value; return (byte[])cm.Parameters["@newLastChanged"].Value; } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFst.Add", ex); throw new DbCslaException("ROFst.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}] ROFst.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("ROFst.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}] ROFst.SQLUpdate", GetHashCode()); try { if (_MyRODb != null) _MyRODb.Update(); SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]; if (base.IsDirty) { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "updateROFst"; // All Fields including Calculated Fields cm.Parameters.AddWithValue("@ROFstID", _ROFstID); cm.Parameters.AddWithValue("@RODbID", RODbID); cm.Parameters.AddWithValue("@ROFST", _ROFST); 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); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // TODO: 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 if (_ROFstDocVersionROFsts != null) _ROFstDocVersionROFsts.Update(this); if (_ROFstROFstImages != null) _ROFstROFstImages.Update(this); } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFst.SQLUpdate", ex); _ErrorMessage = ex.Message; if (!ex.Message.EndsWith("has been edited by another user.")) throw ex; } } internal void Update() { if (!this.IsDirty) return; if (base.IsDirty) { SqlConnection cn = (SqlConnection)ApplicationContext.LocalContext["cn"]; if (IsNew) _LastChanged = ROFst.Add(cn, ref _ROFstID, _MyRODb, _ROFST, _DTS, _UserID); else _LastChanged = ROFst.Update(cn, ref _ROFstID, _MyRODb, _ROFST, _DTS, _UserID, ref _LastChanged); MarkOld(); } if (_ROFstDocVersionROFsts != null) _ROFstDocVersionROFsts.Update(this); if (_ROFstROFstImages != null) _ROFstROFstImages.Update(this); } [Transactional(TransactionalTypes.TransactionScope)] public static byte[] Update(SqlConnection cn, ref int rOFstID, RODb myRODb, byte[] rofst, DateTime dts, string userID, ref byte[] lastChanged) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.Update", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "updateROFst"; // Input All Fields - Except Calculated Columns cm.Parameters.AddWithValue("@ROFstID", rOFstID); cm.Parameters.AddWithValue("@RODbID", myRODb.RODbID); cm.Parameters.AddWithValue("@ROFST", rofst); 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); param_LastChanged.Direction = ParameterDirection.Output; cm.Parameters.Add(param_LastChanged); // TODO: 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("ROFst.Update", ex); throw new DbCslaException("ROFst.Update", ex); } } [Transactional(TransactionalTypes.TransactionScope)] protected override void DataPortal_DeleteSelf() { DataPortal_Delete(new PKCriteria(_ROFstID)); } [Transactional(TransactionalTypes.TransactionScope)] private void DataPortal_Delete(PKCriteria criteria) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.DataPortal_Delete", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "deleteROFst"; cm.Parameters.AddWithValue("@ROFstID", criteria.ROFstID); cm.ExecuteNonQuery(); } } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFst.DataPortal_Delete", ex); _ErrorMessage = ex.Message; throw new DbCslaException("ROFst.DataPortal_Delete", ex); } } [Transactional(TransactionalTypes.TransactionScope)] public static void Remove(SqlConnection cn, int rOFstID) { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.Remove", 0); try { using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "deleteROFst"; // Input PK Fields cm.Parameters.AddWithValue("@ROFstID", rOFstID); // TODO: Define any additional output parameters cm.ExecuteNonQuery(); } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFst.Remove", ex); throw new DbCslaException("ROFst.Remove", ex); } } #endregion #region Exists public static bool Exists(int rOFstID) { ExistsCommand result; try { result = DataPortal.Execute(new ExistsCommand(rOFstID)); return result.Exists; } catch (Exception ex) { throw new DbCslaException("Error on ROFst.Exists", ex); } } [Serializable()] private class ExistsCommand : CommandBase { private int _ROFstID; private bool _exists; public bool Exists { get { return _exists; } } public ExistsCommand(int rOFstID) { _ROFstID = rOFstID; } protected override void DataPortal_Execute() { if (_MyLog.IsDebugEnabled) _MyLog.DebugFormat("[{0}] ROFst.DataPortal_Execute", GetHashCode()); try { using (SqlConnection cn = Database.VEPROMS_SqlConnection) { cn.Open(); using (SqlCommand cm = cn.CreateCommand()) { cm.CommandType = CommandType.StoredProcedure; cm.CommandText = "existsROFst"; cm.Parameters.AddWithValue("@ROFstID", _ROFstID); int count = (int)cm.ExecuteScalar(); _exists = (count > 0); } } } catch (Exception ex) { if (_MyLog.IsErrorEnabled) _MyLog.Error("ROFst.DataPortal_Execute", ex); throw new DbCslaException("ROFst.DataPortal_Execute", ex); } } } #endregion // Standard Default Code #region extension ROFstExtension _ROFstExtension = new ROFstExtension(); [Serializable()] partial class ROFstExtension : extensionBase { } [Serializable()] class extensionBase { // Default Values public virtual DateTime DefaultDTS { get { return DateTime.Now; } } public virtual string DefaultUserID { get { return Environment.UserName.ToUpper(); } } // 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 ROFstConverter : ExpandableObjectConverter { public override object ConvertTo(ITypeDescriptorContext context, System.Globalization.CultureInfo culture, object value, Type destType) { if (destType == typeof(string) && value is ROFst) { // Return the ToString value return ((ROFst)value).ToString(); } return base.ConvertTo(context, culture, value, destType); } } #endregion } // Namespace //// The following is a sample Extension File. You can use it to create ROFstExt.cs //using System; //using System.Collections.Generic; //using System.Text; //using Csla; //namespace VEPROMS.CSLA.Library //{ // public partial class ROFst // { // partial class ROFstExtension : extensionBase // { // // TODO: Override automatic defaults // public virtual DateTime DefaultDTS // { // get { return DateTime.Now; } // } // public virtual string DefaultUserID // { // get { return Environment.UserName.ToUpper(); } // } // public new void AddAuthorizationRules(Csla.Security.AuthorizationRules rules) // { // //rules.AllowRead(Dbid, ""); // } // public new void AddInstanceAuthorizationRules(Csla.Security.AuthorizationRules rules) // { // //rules.AllowInstanceRead(Dbid, ""); // } // public new void AddValidationRules(Csla.Validation.ValidationRules rules) // { // rules.AddRule( // Csla.Validation.CommonRules.StringMaxLength, // new Csla.Validation.CommonRules.MaxLengthRuleArgs("Name", 100)); // } // public new void AddInstanceValidationRules(Csla.Validation.ValidationRules rules) // { // rules.AddInstanceRule(/* Instance Validation Rule */); // } // } // } //}