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

namespace Estsh.Core.Repositories
{
    public class PdlineOffineQueryDal : BaseApp
    {
        public PdlineOffineQueryDal(RemotingProxy remotingProxy)
            : base(remotingProxy)
        { }

        public ArrayList GetPdline()
        {
            lock (_remotingProxy)
            {
                StringBuilder SqlStringBuilder = new StringBuilder(1024);
                SqlStringBuilder.Append("select pdline_id as [value],pdline_desc as [key] from dbo.sys_pdline where enabled='Y' ");

                DataTable dt = _remotingProxy.GetDataTable(SqlStringBuilder.ToString());
                return DataTypeConvert.NewObject.DataTableToArrayList(dt);
            }
        }
        /// <summary>
        /// 客户产线集合
        /// </summary>
        /// <returns>数据集</returns>
        //public ArrayList GetCustPDLineName()
        //{
        //    lock (_remotingProxy)
        //    {
        //        StringBuilder SqlStringBuilder = new StringBuilder(1024);
        //        SqlStringBuilder.Append("select cust_pdline_name as [value],cust_pdline_name as [key] from sys_cust_pdline where enabled='Y' ");

        //        DataTable dt = _remotingProxy.GetDataTable(SqlStringBuilder.ToString());
        //        return DataTypeConvert.NewObject.DataTableToArrayList(dt);
        //    }
        //}

        // <summary>
        /// 根据分页条件获取分页数据列表
        /// </summary>
        public DataTable getShippingListByPage( String txtStartTime, String txtEndTime, string cbPdline)
        //public Hashtable getShippingListByPage(String cust_pdline_name, int PageSize, int PageIndex, string strWhere, string OrderBy)
        {
            lock (_remotingProxy)
            {
                Hashtable Params = new Hashtable();
                Params.Add("@StartTime", txtStartTime);
                Params.Add("@EndTime", txtEndTime);
                Params.Add("@type", cbPdline);


                String strProcedure = "EXEC get_offline_production @type,@StartTime,@EndTime";
                return _remotingProxy.GetDataTable(strProcedure, Params);
               
            }
        }

        /// <summary>
        /// 根据分页条件获取分页数据列表(导出时使用)
        /// </summary>
        public DataTable getShippingExport(int PageSize, int PageIndex, string strWhere)
        {
            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", " dbo.g_sn_status a LEFT JOIN sys_part b ON a.part_id = b.part_id  LEFT JOIN dbo.sys_pdline c ON a.pdline_id = c.pdline_id LEFT JOIN sys_model d ON d.model_id = a.model_id LEFT JOIN dbo.sys_model_type e ON e.type_id = d.model_type_id"));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Column", "a.ruid ,c.pdline_desc ,e.type_name ,d.model_name ,a.serial_number ,b.part_spec ,CONVERT(varchar(100),a.in_pdline_time,120) as in_pdline_time,CONVERT(varchar(100),a.out_pdline_time,120) as out_pdline_time "));
                //parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@OrderColumn", OrderBy.Replace("desc", "")));
                //parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@OrderColumn", OrderBy.Replace("desc", "")));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@OrderColumn", @"a.serial_number"));
                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);
                return dt;
            }
        }

        //public bool getSnStatus(string sn)
        //{
        //    lock (_remotingProxy)
        //    {
        //        StringBuilder SqlStringBuilder = new StringBuilder(1024);
        //        SqlStringBuilder.Append("SELECT TOP 100 * FROM dbo.i_hx_testdata WHERE 条码 = '" + sn + "' ");

        //        object obj = _remotingProxy.GetScalar(SqlStringBuilder.ToString());
        //        return obj == null ? false : true;
        //    }
        //}

        //public string getVinStatus(string input)
        //{
        //    lock (_remotingProxy)
        //    {
        //        StringBuilder SqlStringBuilder = new StringBuilder(1024);
        //        SqlStringBuilder.Append("SELECT  a.vin ");
        //        SqlStringBuilder.Append("FROM    dbo.g_order a ");
        //        SqlStringBuilder.Append("        LEFT JOIN g_order_items b ON a.order_id = b.order_id ");
        //        SqlStringBuilder.Append("WHERE   b.shipping_sn ='" + input + "' ");

        //        object obj = _remotingProxy.GetScalar(SqlStringBuilder.ToString());
        //        return obj == null ? null : obj.ToString();
        //    }
        //}


    }
}