using System;
using System.Data;
using System.Text;
using System.Collections.Generic;
using System.Data.SqlClient;
using ApServerProvider;
using DbCommon;
using System.Collections;

namespace Estsh.Core.Repositories
{

    /****************************************************************
     * 
     * 看板产线关系
     * 
     * NOAH
     * 
     ****************************************************************/
    public class ViewBoardPdlineDefineDal : BaseApp
	{
        public ViewBoardPdlineDefineDal(RemotingProxy remotingProxy)
            : base(remotingProxy)
        { 
        }
		#region  成员方法
		/// <summary>
		/// 获得菜单列表数据
		/// </summary>
		public DataTable getList(string strWhere,string filedOrder)
		{
            lock (_remotingProxy)
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append("SELECT  a.view_board_id ,a.pdline_id,a.enabled,c.view_board_name , b.pdline_name,b.pdline_desc,a.guid FROM dbo.g_view_board_pdline a LEFT JOIN dbo.sys_pdline b ON a.pdline_id = b.pdline_id LEFT JOIN dbo.g_view_board c ON a.view_board_id = c.view_board_id ");
                if (!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 DataTable getListByPage(int PageSize, int PageIndex, string strWhere, string OrderBy)
        {
            lock (_remotingProxy)
            {
                if (strWhere.Trim() != "")
                {
                    strWhere = strWhere.Remove(0, 6);//因为存储过程中已经有where，这里需要把之前加入的where去掉，这里截除前六个字符
                }
                if (OrderBy.Trim() != "")
                {
                    OrderBy = " " + OrderBy;  //排序
                }
                Hashtable Params = new Hashtable(6);

                Params.Add("@TotalCount", 100);
                Params.Add("@TotalPage", 100);
                Params.Add("@GroupColumn", "");
                Params.Add("@Table", "dbo.g_view_board_pdline a LEFT JOIN dbo.sys_pdline b ON a.pdline_id = b.pdline_id LEFT JOIN dbo.g_view_board c ON a.view_board_id = c.view_board_id");
                Params.Add("@Column", "a.view_board_id ,a.pdline_id,a.enabled,c.view_board_name ,b.pdline_name,b.pdline_desc,a.guid");
                Params.Add("@PageSize", PageSize);
                Params.Add("@CurrentPage", PageIndex);
                Params.Add("@Condition", strWhere);
                Params.Add("@OrderColumn", OrderBy);
                Params.Add("@Group", 0);

                String strProcedure = "EXEC Com_Pagination @TotalCount, @TotalPage, @Table, @Column,@OrderColumn,@GroupColumn,@PageSize, @CurrentPage,@Group,@Condition";
                return _remotingProxy.GetDataTable(strProcedure, Params);
            }
        }

        /// <summary>
        /// 获取分页记录总数
        /// </summary>
        public int getCountWhere(string strWhere)
        {
            lock (_remotingProxy)
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append("select count(*) as Total FROM dbo.g_view_board_pdline a LEFT JOIN dbo.sys_pdline b ON a.pdline_id = b.pdline_id LEFT JOIN dbo.g_view_board c ON a.view_board_id = c.view_board_id");
                if (strWhere.Trim() != "")
                {
                    strSql.Append(" " + strWhere);
                }
                int i = 0;
                DataTable dt = _remotingProxy.GetDataTable(strSql.ToString());
                if (dt.Rows.Count > 0)
                {
                    if (dt.Rows[0]["Total"].ToString() != "")
                    {
                        i = int.Parse(dt.Rows[0]["Total"].ToString());
                    }
                }
                return i;
            }
        }

        /// <summary>
        /// 插入菜单数据
        /// </summary>
        /// <param name="htParams"></param>
        /// <returns></returns>
        public int saveViewBoardPdline(Hashtable htParams)
        {
            lock (_remotingProxy)
            {
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("INSERT INTO dbo.g_view_board_pdline(view_board_id,pdline_id,enabled,create_ymd,create_hms) values");
                SqlStringBuilder.Append("(@view_board_id,@pdline_id,@enabled,Convert(varchar(10),getdate(),23),Convert(varchar(10),getdate(),108))");

                return _remotingProxy.ExecuteNonQuery(SqlStringBuilder.ToString(), htParams);
            }
        }

        /// <summary>
        /// 更新菜单数据
        /// </summary>
        /// <param name="htParams"></param>
        /// <returns></returns>
        public int updateViewBoardPdline(Hashtable htParams)
        {
            lock (_remotingProxy)
            {
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("UPDATE g_view_board_pdline SET  ");
                SqlStringBuilder.Append(" pdline_id=@pdline_id, view_board_id=@view_board_id,enabled=@enabled,update_ymd=Convert(varchar(10),getdate(),23),update_hms=Convert(varchar(10),getdate(),108) ");
                SqlStringBuilder.Append(" WHERE guid=@guid ");

                return _remotingProxy.ExecuteNonQuery(SqlStringBuilder.ToString(), htParams);
            }
        }

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

		#endregion  成员方法






        /// <summary>
        /// 获取 看板 信息
        /// BY NOAH
        /// </summary>
        /// <returns></returns>
        public DataTable getBoardName()
        {
            lock (_remotingProxy)
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append("SELECT DISTINCT view_board_id as [value],view_board_name as [key] from g_view_board WHERE enabled = 'Y'");
                return _remotingProxy.GetDataTable(strSql.ToString());
            }
        }
        /// <summary>
        /// 获取 产线 信息
        /// BY NOAH
        /// </summary>
        /// <returns></returns>
        public DataTable getPdlineName()
        {
            lock (_remotingProxy)
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append("SELECT DISTINCT pdline_id as [value],pdline_name as [key] from sys_pdline WHERE enabled = 'Y'");
                return _remotingProxy.GetDataTable(strSql.ToString());
            }
        }
        /// <summary>
        /// 判断用户输入的零件号是否存在
        /// BY NOAH
        /// </summary>
        /// <param name="part_no"></param>
        /// <returns></returns>
        public String isExsitPart_no(String part_no)
        {
            lock (_remotingProxy)
            {
                string part_id = null;
                string SqlString = "select top 1 part_id from sys_part where enabled='Y' and part_no=@part_no";
                Hashtable Params = new Hashtable(1);
                Params.Add("@part_no", part_no);
                DataTable dt = _remotingProxy.GetDataTable(SqlString, Params);
                if (dt.Rows.Count < 1)
                {
                    return part_id;
                }
                else
                {
                    part_id = dt.Rows[0][0].ToString();
                    return part_id;
                }
            }
        }
	}
}