csla.net 框架的实例应用三（集合多条记录的演示）续

继上页

单条业务类代码：

using System;
using System.Collections.Generic;
using System.Text;
using Csla;
using Csla.Data;
using System.Data.SqlClient;
using System.Data;

namespace dllcsla
{
    [Serializable]
    public class Tcoupon : BusinessBase<Tcoupon>
    {

        #region Class Level Private Variables
        private int _pkey = -1;        //**PK
        private string _memberIdno = "";
        private int _couponValue = 0;
        private DateTime _genDate = DateTime.Today;
        private DateTime _deadline = DateTime.Today.AddMonths(12);
        private bool _isUsed = false;
        private DateTime _useDate = DateTime.MinValue;
        private string _remark = "";
        private int _issueHotelKey = -1; //Hostel key
        #endregion

        #region Constructors
        private Tcoupon()
        {
            MarkAsChild();
        }
        #endregion

        #region Business Properties and Methods
        public int pkey
        {
            get { return _pkey; }
        }
        public string CouponNum { get { return "C" + _pkey.ToString(); } }
        public string CouponCombo { get { return "C" + _pkey.ToString() + " : " + _remark + " : " + _couponValue.ToString(); } }

        public string MemberIdNo
        {
            get { return _memberIdno; }
            set
            {
                if (value != _memberIdno)
                {
                    _memberIdno = value;
                    MarkDirty();
                }
            }
        }
        public int CouponValue
        {
            get { return _couponValue; }
            set
            {
                if (value != _couponValue)
                {
                    _couponValue = value;
                    MarkDirty();
                }
            }
        }
        public DateTime GenDate
        {
            get { return _genDate; }
            set
            {
                if (value != _genDate)
                {
                    _genDate = value;
                    MarkDirty();
                }
            }
        }
        public DateTime Deadline
        {
            get { return _deadline; }
            set
            {
                if (value != _deadline)
                {
                    _deadline = value;
                    MarkDirty();
                }
            }
        }
        public bool IsUsed
        {
            get { return _isUsed; }
            set
            {
                if (value != _isUsed)
                {
                    _isUsed = value;
                    MarkDirty();
                }
            }
        }
        public DateTime UseDate
        {
            get { return _useDate; }
            set
            {
                if (value != _useDate)
                {
                    _useDate = value;
                    MarkDirty();
                }
            }
        }
        public string UseDateStr { get { return _useDate == DateTime.MinValue ? "" : _useDate.ToShortDateString(); } }
        public string Remark
        {
            get { return _remark; }
            set
            {
                if (value != _remark)
                {
                    _remark = value;
                    MarkDirty();
                }
            }
        }
        public int IssueHotelKey
        {
            get { return _issueHotelKey; }
            set
            {
                if (value != _issueHotelKey)
                {
                    _issueHotelKey = value;
                    MarkDirty();
                }
            }
        }

        #endregion //Business Properties and Methods

        #region System.Object Overrides

        protected override object GetIdValue()
        {
            return _pkey;
        }
        #endregion //System.Object Overrides

        #region Static Methods
        public static Tcoupon NewCoupon()
        {
            return new Tcoupon();
        }

        public static Tcoupon GetCoupon(SafeDataReader dr )
        {
            return new Tcoupon(dr);
        }

        internal Tcoupon(SafeDataReader dr)
        {
            FetchObject(dr);
            MarkAsChild();
        }

        #endregion

        private void FetchObject(SafeDataReader dr)
        {
            _pkey = dr.GetInt32("pkey");
            _couponValue = dr.GetInt32("Value");
            _deadline = dr.GetDateTime("Deadline");
            _genDate = dr.GetDateTime("GenDate");
            _isUsed = dr.GetBoolean("IsUsed");
            _memberIdno = dr.GetString("MemberIdno");
            _remark = dr.GetString("Remark");
            _useDate = dr.GetDateTime("UseDate");
            _issueHotelKey = dr.GetInt32("issueHotelKey");
            MarkOld();
        }

        [Transactional(TransactionalTypes.TransactionScope)]
        protected override void DataPortal_Insert()
        {
            SqlConnection cn = new SqlConnection("Data Source=.;User ID=sa;Password=123456;Initial Catalog=tblcustom;");
            cn.Open();

            try
            {
                if (this.IsNew)
                {
                    using (SqlCommand cm = cn.CreateCommand())
                    {
                        cm.CommandType = CommandType.StoredProcedure;
                        cm.CommandText = "dd_prod_insertcoupon";
                        AddInsertUpdateParams(cm);
                        cm.ExecuteNonQuery();
                        MarkOld();
                    }
                }
            }
            finally
            {
                cn.Close();
            }
        }

        private void AddInsertUpdateParams(SqlCommand cm)
        {
            cm.Parameters.AddWithValue("@MemberIdno", _memberIdno);
            cm.Parameters.AddWithValue("@Value", _couponValue);
            cm.Parameters.AddWithValue("@GenDate", _genDate);
            cm.Parameters.AddWithValue("@Deadline", _deadline);
            cm.Parameters.AddWithValue("@isUsed", _isUsed);
            if (!this.IsNew)
            {
                if (_useDate == DateTime.MinValue)
                    cm.Parameters.AddWithValue("@UseDate", DBNull.Value);
                else
                    cm.Parameters.AddWithValue("@UseDate", _useDate);
            }
            cm.Parameters.AddWithValue("@Remark", _remark);
            cm.Parameters.AddWithValue("@issueHotelKey", _issueHotelKey);
        }

        internal void Update(SqlConnection cn)
        {
            using (SqlCommand cm = cn.CreateCommand())
            {
                if (this.IsNew)
                {
                    cm.CommandType = CommandType.StoredProcedure;
                    cm.CommandText = "dd_prod_insertcoupon";
                    AddInsertUpdateParams(cm);
                    cm.ExecuteNonQuery();
                    
                }
                else if (this.IsDirty)
                {
                    cm.CommandType = CommandType.Text;
                    cm.CommandText = "update table_Coupon set MemberIdno=@MemberIdno, Value=@Value, GenDate=@GenDate, " +
                        "Deadline=@Deadline, isUsed=@isUsed, UseDate=@UseDate, Remark=@Remark, issueHotelKey=@issueHotelKey where pkey=@pkey";
                    cm.Parameters.AddWithValue("@pkey", _pkey);
                    AddInsertUpdateParams(cm);
                    cm.ExecuteNonQuery();
                }
                MarkOld();
            }
        }

        [Transactional(TransactionalTypes.TransactionScope)]
        protected override void DataPortal_Update()
        {
            SqlConnection cn = new SqlConnection("Data Source=.;User ID=sa;Password=123456;Initial Catalog=tblcustom;");
            cn.Open();
            try
            {
                try
                {
                    if (!this.IsNew)
                        Update(cn);
                }
                catch (Exception ex)
                {
                    throw (ex);
                }
            }
            finally
            {
                cn.Close();
            }
        }

        [Transactional(TransactionalTypes.TransactionScope)]
        protected override void DataPortal_DeleteSelf()
        {
            DeleteSelf();
        }

        public void DeleteSelf()
        {

            SqlHelper.ExecuteSql("delete from table_Coupon where pkey=" + _pkey.ToString());
        }

        /// <summary>
        /// 获得单条对像的数据
        /// </summary>
        /// <param name="where"></param>
        /// <returns></returns>
        internal Tcoupon couponRecord(string where)
        {
            Tcoupon couponClass = new Tcoupon();
            SqlDataReader sqlReader = null;
            string sql = "select top 1 * from table_Coupon where 1=1 " + where;
            sqlReader = SqlHelper.ExecuteReader(sql);
            if (sqlReader.Read())
            {
                couponClass._pkey = Convert.ToInt32(sqlReader["pkey"]);
                couponClass._memberIdno = sqlReader["MemberIdno"].ToString();
                couponClass._couponValue = Convert.ToInt32(sqlReader["Value"]);
                couponClass._deadline = Convert.ToDateTime(sqlReader["Deadline"]);
                couponClass._genDate = Convert.ToDateTime(sqlReader["GenDate"]);
                couponClass._isUsed = Convert.ToBoolean(sqlReader["IsUsed"]);
                couponClass._memberIdno = sqlReader["MemberIdno"].ToString();
                couponClass._remark = sqlReader["Remark"].ToString();
                if (sqlReader["UseDate"].ToString() != string.Empty)
                {
                    couponClass._useDate = Convert.ToDateTime(sqlReader["UseDate"]);
                }
                couponClass._issueHotelKey = Convert.ToInt32(sqlReader["issueHotelKey"]);
            }
            sqlReader.Close();
            MarkOld();

            return couponClass;
        }

        public DataSet getall()
        {
            return SqlHelper.Query(" select * from table_Coupon ");
        }

        /// <summary>
        /// 获得多条对像的数据
        /// </summary>
        /// <param name="where"></param>
        /// <returns></returns>
        public void couponRecorddlist(string where)
        {
            Tcoupon couponClass;

            SqlDataReader sqlReader = null;
            string sql = "select * from table_Coupon where 1=1 " + where;
            sqlReader = SqlHelper.ExecuteReader(sql);
            while (sqlReader.Read())
            {
                couponClass = new Tcoupon();
                couponClass._pkey = Convert.ToInt32(sqlReader["pkey"]);
                couponClass._memberIdno = sqlReader["MemberIdno"].ToString();
                couponClass._couponValue = Convert.ToInt32(sqlReader["Value"]);
                couponClass._deadline = Convert.ToDateTime(sqlReader["Deadline"]);
                couponClass._genDate = Convert.ToDateTime(sqlReader["GenDate"]);
                couponClass._isUsed = Convert.ToBoolean(sqlReader["IsUsed"]);
                couponClass._memberIdno = sqlReader["MemberIdno"].ToString();
                couponClass._remark = sqlReader["Remark"].ToString();
                if (sqlReader["UseDate"].ToString() != string.Empty)
                {
                    couponClass._useDate = Convert.ToDateTime(sqlReader["UseDate"]);
                }
                couponClass._issueHotelKey = Convert.ToInt32(sqlReader["issueHotelKey"]);
            }
            sqlReader.Close();
        }

    }

}