Estsh-Yiri/Estsh.Core.Services/Repositories/ViewBoardDefineDal.cs

using System;
using System.Data;
using System.Text;
using System.Collections.Generic;
using System.Data.SqlClient;
using ApServerProvider;
using DbCommon;
using System.Collections;
using Estsh.Web.Util;

/****************************************************************************************************************************************
 * 
 * 创建人：唐慰
 * 创建时间：2013.03.23
 * 描述：看板模块DAL类
 * 变更记录：
 * 130401 唐慰 + 所有方法改为首字母大写
 * 130407 唐慰 + Insert方法添加create_userid、create_ymd、create_hms、guid
 * 130407 唐慰 + Update方法添加update_userid、update_ymd、update_hms、enabled
 * 
 ****************************************************************************************************************************************/

namespace Estsh.Core.Repositories
{
	/// <summary>
	/// 处理菜单模块的业务数据
	/// </summary>
	public class ViewBoardDefineDal : BaseApp
	{
        public ViewBoardDefineDal(RemotingProxy remotingProxy)
            : base(remotingProxy)
        { 
        }
		#region  成员方法

		/// <summary>
		/// 根据传入条件获得菜单列表数据
		/// </summary>
		public DataTable GetList(string strWhere,string filedOrder)
		{
            lock (_remotingProxy)
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append(" select * from dbo.g_view_board ");
                if (strWhere != null && !strWhere.Trim().Equals(""))
                {
                    strSql.Append(" where " + strWhere);
                }
                if (filedOrder != null && !filedOrder.Trim().Equals(""))
                {
                    strSql.Append(" order by " + filedOrder);
                }
                return this._remotingProxy.GetDataTable(strSql.ToString());
            }
		}

        /// <summary>
        /// 根据分页条件获取分页数据列表
        /// </summary>
        public Hashtable GetListByPage(int PageSize, int PageIndex, string strWhere, string OrderBy)
        {
            lock (_remotingProxy)
            {
                Hashtable result = new Hashtable();

                List<StoreProcedureParameter> parameters = new List<StoreProcedureParameter>();

                parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Output, "@TotalCount", 100));
                parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Output, "@TotalPage", 100));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Table", "g_view_board"));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Column", "*"));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@OrderColumn", OrderBy));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@GroupColumn", ""));
                parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Input, "@PageSize", PageSize));
                parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Input, "@CurrentPage", PageIndex));
                parameters.Add(new StoreProcedureParameter(DbType.Int32, ParameterDirection.Input, "@Group", 0));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Condition", strWhere));

                Hashtable values = new Hashtable(2);

                DataTable dt = new DataTable();
                dt = _remotingProxy.ExecuteSotreProcedure("Com_Pagination", parameters, ref values);
                ArrayList dataList = DataTypeConvert.NewObject.DataTableToArrayList(dt);
                result.Add("dataList", dataList);
                result.Add("totalCount", values["@TotalCount"].ToString());

                return result;
            }
        }

        /// <summary>
        /// 获取下拉框菜单数据
        /// </summary>
        /// <returns></returns>
        public DataTable GetSelect()
        {
            lock (_remotingProxy)
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append("select part_type as [value],part_type as [key] from sys_part where len(part_type)>0 group by part_type ");
                return _remotingProxy.GetDataTable(strSql.ToString());
            }
        }

        /// <summary>
        /// 插入菜单数据
        /// </summary>
        /// <param name="htParams"></param>
        /// <returns></returns>
        public int Insert(Hashtable htParams)
        {
            lock (_remotingProxy)
            {
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("INSERT INTO g_view_board(view_board_name  ");
                SqlStringBuilder.Append("						, view_type ");
                SqlStringBuilder.Append("						, view_part_type ");
                SqlStringBuilder.Append("						,create_userid ");
                SqlStringBuilder.Append("						,create_ymd ");
                SqlStringBuilder.Append("						,create_hms ");
                SqlStringBuilder.Append("						,guid) ");
                SqlStringBuilder.Append("		            VALUES(@view_board_name ");
                SqlStringBuilder.Append("						, @view_type ");
                SqlStringBuilder.Append("						, @view_part_type ");
                SqlStringBuilder.Append("						, @create_userid ");
                SqlStringBuilder.Append("						, CONVERT(VARCHAR(10),GETDATE(),23) ");
                SqlStringBuilder.Append("						, CONVERT(VARCHAR(10),GETDATE(),108) ");
                SqlStringBuilder.Append("						, NEWID()) ");
                return _remotingProxy.ExecuteNonQuery(SqlStringBuilder.ToString(), htParams);
            }
        }

        /// <summary>
        /// 更新菜单数据
        /// </summary>
        /// <param name="htParams"></param>
        /// <returns></returns>
        public int Update(Hashtable htParams)
        {
            lock (_remotingProxy)
            {
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("update g_view_board  ");
                SqlStringBuilder.Append("SET view_board_name=@view_board_name ");
                SqlStringBuilder.Append("	, view_type=@view_type ");
                SqlStringBuilder.Append("	, view_part_type=@view_part_type ");
                SqlStringBuilder.Append("	, enabled=@enabled ");
                SqlStringBuilder.Append("	,update_userid=@update_userid ");
                SqlStringBuilder.Append("	,update_ymd=CONVERT(VARCHAR(10),GETDATE(),23) ");
                SqlStringBuilder.Append("	,update_hms=CONVERT(VARCHAR(10),GETDATE(),108) ");
                SqlStringBuilder.Append("WHERE view_board_id=@view_board_id	 ");
                return _remotingProxy.ExecuteNonQuery(SqlStringBuilder.ToString(), htParams);
            }
        }

        /// <summary>
        /// 删除菜单数据
        /// </summary>
        /// <param name="ruid"></param>
        /// <returns></returns>
        public int Delete(String view_board_id)
        {
            lock (_remotingProxy)
            {
                String delStr = "DELETE FROM g_view_board WHERE view_board_id = @view_board_id";
                Hashtable htparams = new Hashtable();
                htparams.Add("@view_board_id", view_board_id);
                return _remotingProxy.ExecuteNonQuery(delStr, htparams);
            }
        }

		#endregion  成员方法
	}
}