OA系统

开发平台：
C#

worksumupDAL.cs：源码内容
							// =================================================================== 
// 产品(COM.OA.SqlServerDAL)项目
//====================================================================
// wangyp @Copy Right 2006-2008
// 文件：worksumupDAL.cs
// 项目名称：工程项目管理
// 创建时间：2008-9-23
// 负责人：wangyp
// 先创建SqlHelper.cs文件,引用System.Configuration程序集和实体(COM.OA.Entity)、产品规则(COM.OA.IDAL)项目、引用业务逻辑(COM.OA.BLL)项目
// ===================================================================
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Data.SqlClient;
using System.Text;
using COM.OA.Entity;
using COM.OA.IDAL;
using COM.OA.BLL;
namespace COM.OA.SqlServerDAL
{
    /// <summary>
    /// 数据访问层dbo.worksumup
    /// </summary>
    public partial class worksumupDAL : IworksumupDAL
    {
        #region 构造函数
        /// <summary>
        /// 数据层实例化
        /// </summary>
        public worksumupDAL()
        {
        }
        #endregion
        #region -----------实例化接口函数-----------
        #region 添加
        /// <summary>
        /// 向数据库中插入一条新记录
        /// </summary>
        /// <param name="worksumup">worksumup实体对象</param>
        /// <returns></returns>
        public int Insert(worksumup worksumup)
        {
            string sqlCommand = "worksumupInsert";
            int res;
            SqlParameter[] param ={
			new SqlParameter("@ws_id",SqlDbType.Int),
			new SqlParameter("@ws_st_id",SqlDbType.Int),
			new SqlParameter("@ws_year",SqlDbType.VarChar),
			new SqlParameter("@ws_month",SqlDbType.VarChar),
			new SqlParameter("@ws_generalwork",SqlDbType.VarChar),
			new SqlParameter("@ws_nextplan",SqlDbType.VarChar),
			new SqlParameter("@ws_advice",SqlDbType.VarChar),
			new SqlParameter("@ws_time",SqlDbType.DateTime),
			new SqlParameter("@ws_state",SqlDbType.Int),
			new SqlParameter("@ws_u_id",SqlDbType.Int)
			};
            param[0].Direction = ParameterDirection.Output;
            param[1].Value = worksumup.ws_st_id;
            param[2].Value = worksumup.ws_year;
            param[3].Value = worksumup.ws_month;
            param[4].Value = worksumup.ws_generalwork;
            param[5].Value = worksumup.ws_nextplan;
            param[6].Value = worksumup.ws_advice;
            param[7].Value = worksumup.ws_time;
            param[8].Value = worksumup.ws_state;
            param[9].Value = worksumup.ws_u_id;
            res = SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
            worksumup.ws_id = ((param[0].Value) == DBNull.Value) ? 0 : Convert.ToInt32(param[0].Value);
            return res;
        }
        /// <summary>
        /// 向数据库中插入一条新记录。带事务
        /// </summary>
        /// <param name="sp">事务对象</param>
        /// <param name="worksumup">worksumup实体对象</param>
        /// <returns></returns>
        public int Insert(SqlTransaction sp, worksumup worksumup)
        {
            string sqlCommand = "worksumupInsert";
            int res;
            SqlParameter[] param ={
			new SqlParameter("@ws_id",SqlDbType.Int),
			new SqlParameter("@ws_st_id",SqlDbType.Int),
			new SqlParameter("@ws_year",SqlDbType.VarChar),
			new SqlParameter("@ws_month",SqlDbType.VarChar),
			new SqlParameter("@ws_generalwork",SqlDbType.VarChar),
			new SqlParameter("@ws_nextplan",SqlDbType.VarChar),
			new SqlParameter("@ws_advice",SqlDbType.VarChar),
			new SqlParameter("@ws_time",SqlDbType.DateTime),
			new SqlParameter("@ws_state",SqlDbType.Int),
			new SqlParameter("@ws_u_id",SqlDbType.Int)
			};
            param[0].Direction = ParameterDirection.Output;
            param[1].Value = worksumup.ws_st_id;
            param[2].Value = worksumup.ws_year;
            param[3].Value = worksumup.ws_month;
            param[4].Value = worksumup.ws_generalwork;
            param[5].Value = worksumup.ws_nextplan;
            param[6].Value = worksumup.ws_advice;
            param[7].Value = worksumup.ws_time;
            param[8].Value = worksumup.ws_state;
            param[9].Value = worksumup.ws_u_id;
            res = SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
            worksumup.ws_id = ((param[0].Value) == DBNull.Value) ? 0 : Convert.ToInt32(param[0].Value);
            return res;
        }
        #endregion
        #region 更新
        /// <summary>
        /// 向数据表worksumup更新一条记录
        /// </summary>
        /// <param name="worksumup">worksumup实体对象</param>
        /// <returns></returns>
        public int Update(worksumup worksumup)
        {
            string sqlCommand = "worksumupUpdate";
            SqlParameter[] param ={
				new SqlParameter("@ws_id",SqlDbType.Int),
				new SqlParameter("@ws_st_id",SqlDbType.Int),
				new SqlParameter("@ws_year",SqlDbType.VarChar),
				new SqlParameter("@ws_month",SqlDbType.VarChar),
				new SqlParameter("@ws_generalwork",SqlDbType.VarChar),
				new SqlParameter("@ws_nextplan",SqlDbType.VarChar),
				new SqlParameter("@ws_advice",SqlDbType.VarChar),
				new SqlParameter("@ws_time",SqlDbType.DateTime),
				new SqlParameter("@ws_state",SqlDbType.Int),
				new SqlParameter("@ws_u_id",SqlDbType.Int)
				};
            param[0].Value = worksumup.ws_id;
            param[1].Value = worksumup.ws_st_id;
            param[2].Value = worksumup.ws_year;
            param[3].Value = worksumup.ws_month;
            param[4].Value = worksumup.ws_generalwork;
            param[5].Value = worksumup.ws_nextplan;
            param[6].Value = worksumup.ws_advice;
            param[7].Value = worksumup.ws_time;
            param[8].Value = worksumup.ws_state;
            param[9].Value = worksumup.ws_u_id;
            return SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
        }
        /// <summary>
        /// 向数据表worksumup更新一条记录。带事务
        /// </summary>
        /// <param name="sp">事务对象</param>
        /// <param name="worksumup">worksumup实体对象</param>
        /// <returns></returns>
        public int Update(SqlTransaction sp, worksumup worksumup)
        {
            string sqlCommand = "worksumupUpdate";
            SqlParameter[] param ={
				new SqlParameter("@ws_id",SqlDbType.Int),
				new SqlParameter("@ws_st_id",SqlDbType.Int),
				new SqlParameter("@ws_year",SqlDbType.VarChar),
				new SqlParameter("@ws_month",SqlDbType.VarChar),
				new SqlParameter("@ws_generalwork",SqlDbType.VarChar),
				new SqlParameter("@ws_nextplan",SqlDbType.VarChar),
				new SqlParameter("@ws_advice",SqlDbType.VarChar),
				new SqlParameter("@ws_time",SqlDbType.DateTime),
				new SqlParameter("@ws_state",SqlDbType.Int),
				new SqlParameter("@ws_u_id",SqlDbType.Int)
				};
            param[0].Value = worksumup.ws_id;
            param[1].Value = worksumup.ws_st_id;
            param[2].Value = worksumup.ws_year;
            param[3].Value = worksumup.ws_month;
            param[4].Value = worksumup.ws_generalwork;
            param[5].Value = worksumup.ws_nextplan;
            param[6].Value = worksumup.ws_advice;
            param[7].Value = worksumup.ws_time;
            param[8].Value = worksumup.ws_state;
            param[9].Value = worksumup.ws_u_id;
            return SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
        }
        #endregion
        #region 删除
        /// <summary>
        /// 删除数据表worksumup中的一条记录
        /// </summary>
        /// <param name="ws_id">ws_id</param>
        /// <returns></returns>
        public int Delete(int ws_id)
        {
            string sqlCommand = "worksumupDelete";
            SqlParameter[] param ={
				new SqlParameter("@ws_id",SqlDbType.Int)
			};
            param[0].Value = ws_id;
            return SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
        }
        /// <summary>
        /// 删除数据表worksumup中的一条记录
        /// </summary>
        /// <param name="worksumup">worksumup实体对象</param>
        /// <returns></returns>
        public int Delete(worksumup worksumup)
        {
            string sqlCommand = "worksumupDelete";
            SqlParameter[] param ={
				new SqlParameter("@ws_id",SqlDbType.Int)
			};
            param[0].Value = worksumup.ws_id;
            return SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
        }
        /// <summary>
        /// 删除数据表worksumup中的一条记录,带事务
        /// </summary>
        /// <param name="sp">事务对象</param>
        /// <param name="ws_id">ws_id</param>
        /// <returns></returns>
        public int Delete(SqlTransaction sp, int ws_id)
        {
            string sqlCommand = "worksumupDelete";
            SqlParameter[] param ={
				new SqlParameter("@ws_id",SqlDbType.Int)
			};
            param[0].Value = ws_id;
            return SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
        }
        /// <summary>
        /// 删除数据表worksumup中的一条记录,带事务
        /// </summary>
        /// <param name="sp">事务对象</param>
        /// <param name="worksumup">worksumup实体对象</param>
        /// <returns></returns>
        public int Delete(SqlTransaction sp, worksumup worksumup)
        {
            string sqlCommand = "worksumupDelete";
            SqlParameter[] param ={
				new SqlParameter("@ws_id",SqlDbType.Int)
			};
            param[0].Value = worksumup.ws_id;
            return SqlHelper.ExecuteNonQuery(sp, CommandType.StoredProcedure, sqlCommand, param);
        }
        #endregion
        #region 实体对象
        /// <summary>
        /// 得到worksumup实体对象
        /// </summary>
        /// <param name="row">row</param>
        /// <returns>worksumup实体对象</returns>
        public worksumup Select(DataRow row)
        {
            worksumup obj = new worksumup();
            if (row != null)
            {
                obj.ws_id = ((row["ws_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["ws_id"]);
                obj.ws_st_id = ((row["ws_st_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["ws_st_id"]);
                obj.ws_year = row["ws_year"].ToString();
                obj.ws_month = row["ws_month"].ToString();
                obj.ws_generalwork = row["ws_generalwork"].ToString();
                obj.ws_nextplan = row["ws_nextplan"].ToString();
                obj.ws_advice = row["ws_advice"].ToString();
                obj.ws_time = ((row["ws_time"]) == DBNull.Value) ? DateTime.MinValue : Convert.ToDateTime(row["ws_time"]);
                obj.ws_state = ((row["ws_state"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["ws_state"]);
                obj.ws_u_id = ((row["ws_u_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(row["ws_u_id"]);
            }
            else
            {
                return null;
            }
            return obj;
        }
        /// <summary>
        /// 得到worksumup实体对象
        /// </summary>
        /// <param name="dr">dr</param>
        /// <returns>worksumup实体对象</returns>
        public worksumup Select(IDataReader dr)
        {
            worksumup obj = new worksumup();
            obj.ws_id = ((dr["ws_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["ws_id"]);
            obj.ws_st_id = ((dr["ws_st_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["ws_st_id"]);
            obj.ws_year = dr["ws_year"].ToString();
            obj.ws_month = dr["ws_month"].ToString();
            obj.ws_generalwork = dr["ws_generalwork"].ToString();
            obj.ws_nextplan = dr["ws_nextplan"].ToString();
            obj.ws_advice = dr["ws_advice"].ToString();
            obj.ws_time = ((dr["ws_time"]) == DBNull.Value) ? DateTime.MinValue : Convert.ToDateTime(dr["ws_time"]);
            obj.ws_state = ((dr["ws_state"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["ws_state"]);
            obj.ws_u_id = ((dr["ws_u_id"]) == DBNull.Value) ? 0 : Convert.ToInt32(dr["ws_u_id"]);
            return obj;
        }
        /// <summary>
        /// 根据ID,返回一个worksumup实体对象
        /// </summary>
        /// <param name="ws_id">ws_id</param>
        /// <returns>worksumup实体对象</returns>
        public worksumup Select(int ws_id)
        {
            return this.Select(ws_id, false, false);
        }
        /// <summary>
        /// 根据ID,返回一个worksumup实体对象
        /// </summary>
        /// <param name="ws_id">ws_id</param>
        /// <param name="bParentTable">将worksumup对象设置与父表关联</param>
        /// <param name="bChildrenTable">将worksumup对象设置与子表关联</param>
        /// <returns>worksumup实体对象</returns>
        public worksumup Select(int ws_id, bool bParentTable, bool bChildrenTable)
        {
            worksumup obj = null;
            SqlParameter[] param ={
			new SqlParameter("@ws_id",SqlDbType.Int)
			};
            param[0].Value = ws_id;
            string sqlCommand = "worksumupSelect";
            using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param))
            {
                while (dr.Read())
                {
                    obj = this.Select(dr);
                }
            }
            this.Select(obj, bParentTable, bChildrenTable);
            return obj;
        }
        /// <summary>
        /// 将worksumup实体对象设置与父表和子表关联
        /// </summary>
        /// <param name="obj">worksumup实体对象</param>
        /// <param name="bParentTable">是/否设置与父表对象关联</param>
        /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
        public void Select(worksumup obj, bool bParentTable, bool bChildrenTable)
        {
            //关联的主表
            if (bParentTable)
            {
                obj.users = usersBLL.Select(obj.ws_u_id);
                obj.sumuptype = sumuptypeBLL.Select(obj.ws_st_id);
            }
            //关联的子表集合
            if (bChildrenTable)
            {
            }
        }
        #endregion
        #region 父表
        /// <summary>
        /// 设置实体对象(worksumup)的父表对象
        /// </summary>
        /// <param name="worksumup">实体对象</param>
        public void users(worksumup worksumup)
        {
            worksumup.users = usersBLL.Select(worksumup.ws_u_id);
        }
        /// <summary>
        /// 设置实体对象(worksumup)的父表对象
        /// </summary>
        /// <param name="worksumup">实体对象</param>
        public void sumuptype(worksumup worksumup)
        {
            worksumup.sumuptype = sumuptypeBLL.Select(worksumup.ws_st_id);
        }
        #endregion
        #region 子表
        #endregion
        #region 查询
        /// <summary>
        /// 得到数据表worksumup所有记录
        /// </summary>
        /// <returns>结果集</returns>
        public IList<worksumup> Select()
        {
            return this.Select(false, false);
        }
        /// <summary>
        /// 得到数据表worksumup所有记录
        /// </summary>
        /// <param name="bParentTable">是/否设置与父表对象关联</param>
        /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(bool bParentTable, bool bChildrenTable)
        {
            IList<worksumup> list = new List<worksumup>();
            string sqlCommand = "worksumupSelectAll";
            using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand))
            {
                while (dr.Read())
                {
                    list.Add(this.Select(dr));
                }
            }
            foreach (worksumup obj in list)
            {
                this.Select(obj, bParentTable, bChildrenTable);
            }
            return list;
        }
        /// <summary>
        /// 得到数据表worksumup满足查询条件的记录
        /// </summary>
        /// <param name="where">查询条件</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(string where)
        {
            return this.Select(where, false, false);
        }
        /// <summary>
        /// 得到数据表worksumup满足查询条件的记录
        /// </summary>
        /// <param name="where">查询条件</param>
        /// <param name="bParentTable">是/否设置与父表对象关联</param>
        /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(string where, bool bParentTable, bool bChildrenTable)
        {
            IList<worksumup> list = new List<worksumup>();
            SqlParameter[] param ={
			new SqlParameter("@where",SqlDbType.VarChar,8000)
			};
            param[0].Value = where;
            string sqlCommand = "worksumupSelectByParams";
            using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param))
            {
                while (dr.Read())
                {
                    list.Add(this.Select(dr));
                }
            }
            foreach (worksumup obj in list)
            {
                this.Select(obj, bParentTable, bChildrenTable);
            }
            return list;
        }
        /// <summary>
        /// 得到数据表ArticalInfo满足外键字段查询条件的记录
        /// </summary>
        /// <param name="foreignFieldName">外键字段名称</param>
        /// <param name="foreignFieldValue">外键字段值</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(string foreignFieldName, int foreignFieldValue)
        {
            return this.Select(foreignFieldName, foreignFieldValue, false, false);
        }
        /// <summary>
        /// 得到数据表ArticalInfo满足外键字段查询条件的记录
        /// </summary>
        /// <param name="foreignFieldName">外键字段名称</param>
        /// <param name="foreignFieldValue">外键字段值</param>
        /// <param name="bParentTable">是/否设置与父表对象关联</param>
        /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(string foreignFieldName, int foreignFieldValue, bool bParentTable, bool bChildrenTable)
        {
            return this.Select(string.Format("{0}='{1}'", foreignFieldName, foreignFieldValue), bParentTable, bChildrenTable);
        }
        /// <summary>
        /// 得到数据表worksumup满足查询条件的记录数
        /// </summary>
        /// <param name="where">查询条件</param>
        /// <param name="recordCount">记录数</param>
        public void Select(string where, out int recordCount)
        {
            string sqlCommand = "worksumupCountByWhere";
            SqlParameter[] param ={
			new SqlParameter("@where",SqlDbType.VarChar,8000),
			new SqlParameter("@recordCount",SqlDbType.Int)
			};
            param[0].Value = where;
            param[1].Direction = ParameterDirection.Output;
            SqlHelper.ExecuteNonQuery(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param);
            recordCount = Convert.ToInt32(param[1].Value);
        }
        /// <summary>
        /// 得到数据表worksumup满足查询条件的分页记录
        /// </summary>
        /// <param name="pageSize">每页显示记录数</param>
        /// <param name="pageIndex">当前显示第几页</param>
        /// <param name="where">查询条件</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(int pageSize, int pageIndex, string where)
        {
            return this.Select(pageSize, pageIndex, where, false, false);
        }
        /// <summary>
        /// 得到数据表worksumup满足查询条件的分页记录
        /// </summary>
        /// <param name="pageSize">每页显示记录数</param>
        /// <param name="pageIndex">当前显示第几页</param>
        /// <param name="where">查询条件</param>
        /// <param name="bParentTable">是/否设置与父表对象关联</param>
        /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(int pageSize, int pageIndex, string where, bool bParentTable, bool bChildrenTable)
        {
            IList<worksumup> list = new List<worksumup>();
            string sqlCommand = "worksumupSelectByPagerParams";
            SqlParameter[] param ={
			new SqlParameter("@pageSize",SqlDbType.Int),
			new SqlParameter("@pageIndex",SqlDbType.Int),
			new SqlParameter("@where",SqlDbType.VarChar,8000)
			};
            param[0].Value = pageSize;
            param[1].Value = pageIndex;
            param[2].Value = where;
            using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param))
            {
                while (dr.Read())
                {
                    list.Add(this.Select(dr));
                }
            }
            foreach (worksumup obj in list)
            {
                this.Select(obj, bParentTable, bChildrenTable);
            }
            return list;
        }
        /// <summary>
        /// 得到数据表worksumup满足查询条件记录
        /// </summary>
        /// <param name="commandType">命令类型</param>
        /// <param name="sqlCommand">SQL命令</param>
        /// <param name="SqlParameter[]">命令参数数组</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(CommandType commandType, string sqlCommand, params SqlParameter[] param)
        {
            return this.Select(false, false, commandType, sqlCommand, param);
        }
        /// <summary>
        /// 得到数据表worksumup满足查询条件记录
        /// </summary>
        /// <param name="bParentTable">是/否设置与父表对象关联</param>
        /// <param name="bChildrenTable">是/否设置与子表对象关联</param>
        /// <param name="commandType">命令类型</param>
        /// <param name="sqlCommand">SQL命令</param>
        /// <param name="SqlParameter[]">命令参数数组</param>
        /// <returns>结果集</returns>
        public IList<worksumup> Select(bool bParentTable, bool bChildrenTable, CommandType commandType, string sqlCommand, params SqlParameter[] param)
        {
            IList<worksumup> list = new List<worksumup>();
            using (SqlDataReader dr = SqlHelper.ExecuteReader(Conn.SqlConn, commandType, sqlCommand, param))
            {
                while (dr.Read())
                {
                    list.Add(this.Select(dr));
                }
            }
            foreach (worksumup obj in list)
            {
                this.Select(obj, bParentTable, bChildrenTable);
            }
            return list;
        }
        /// <summary>
        /// 根据主键检测是否存在该条记录
        /// </summary>
        /// <param name="ws_id">ws_id</param>
        /// <returns>存在/不存在</returns>
        public bool Exists(int ws_id)
        {
            SqlParameter[] param ={
                                 new SqlParameter("@ws_id",SqlDbType.Int)
                                 };
            param[0].Value = ws_id;
            string sqlCommand = "worksumupIsExist";
            int a = Convert.ToInt32(SqlHelper.ExecuteScalar(Conn.SqlConn, CommandType.StoredProcedure, sqlCommand, param));
            if (a > 0)
            {
                return true;
            }
            else
            {
                return false;
            }
        }
        #endregion
        #endregion
    }
}

						