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

namespace Estsh.Core.Repositories
{
    public class ExceptionHandling:BaseApp
    {
        public ExceptionHandling(RemotingProxy remotingProxy)
            : base(remotingProxy)
        { }
        /// <summary>
        /// 获取分页数据列表
        /// </summary>
        /// <param name="PageSize">一页显示多少条数据</param>
        /// <param name="PageIndex">当前第几页</param>
        /// <param name="strWhere">条件</param>
        /// <param name="OrderBy">排序字段</param>
        /// <returns></returns>
        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", "dbo.g_vw_order AS a LEFT JOIN sys_part AS b ON a.model_part_id = b.part_id  LEFT JOIN dbo.sys_model AS d ON b.model_id=d.model_id  LEFT JOIN dbo.sys_model_type AS c ON c.type_id = d.model_type_id "));
                parameters.Add(new StoreProcedureParameter(DbType.String, ParameterDirection.Input, "@Column", "row_number() OVER ( ORDER BY factory_id ASC ) AS number ,d.model_type ,c.type_name ,d.model_name ,(CASE status WHEN '-2' THEN 'N' WHEN '-1' THEN 'N' WHEN '0' THEN 'N' WHEN '1' THEN 'N' WHEN '2' THEN 'N' WHEN '3' THEN 'Y'  END) AS isempty, a.order_id,a.factory_id,a.file_name,a.cur_time,a.model_part_id,a.cust_knr,a.order_seq,a.cust_pdline,a.status,a.error_message,a.car_no,a.vin,a.update_ymd,a.update_hms,a.update_userid,a.create_userid,a.create_ymd,a.create_hms,a.guid,b.part_id,b.part_no,b.part_spec,b.part_spec2,b.part_location,b.part_type,b.part_class,b.model_id,b.vendor_id,d.model_code,d.model_desc,d.model_alias,c.type_id,c.type_alias,c.type_code,c.type_desc,a.enabled"));
                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>
        /// <param name="parames"></param>
        /// <returns></returns>
        public int EditOrder(Hashtable parames)
        {
            lock (_remotingProxy)
            {
                StringBuilder sql = new StringBuilder(1024);
                sql.Append("update g_vw_order set status=@status,error_message=@error_message, update_ymd=convert(varchar(10),getdate(),23),update_hms=CONVERT(varchar(10),GETDATE(),108),update_userid=@update_userid where order_id=@order_id");
                return _remotingProxy.ExecuteNonQuery(sql.ToString(), parames);
            }
        } 
        /// <summary>
        ///  查询系统列表
        /// </summary>
        /// <param name="strWhere"></param>
        /// <returns></returns>
        public DataTable getOrderList(string strWhere)
        {
            lock (_remotingProxy)
            {
                string sql = "select * from g_vw_order where 0=0 " + strWhere;
                return _remotingProxy.GetDataTable(sql);
            }
        }

        /// <summary>
        /// 获取客户产线
        /// </summary>
        /// <returns></returns>
        public DataTable Getcust_pdline()
        {
            lock (_remotingProxy)
            {
                string sql = "SELECt cust_pdline_name as [value],cust_pdline_name as [key] FROM dbo.sys_cust_pdline where enabled='Y'";
                DataTable dt = _remotingProxy.GetDataTable(sql);
                return dt;
            }
        }
        /// <summary>
        /// 获取车型
        /// </summary>
        /// <param name="value"></param>
        /// <returns></returns>
        public DataTable GetCarType(string value)
        {
            lock (_remotingProxy)
            {
                string sql = "select type_id as [value],type_name+':'+type_desc as [key] from sys_model_type where 0=0 " + value;
                DataTable dt = _remotingProxy.GetDataTable(sql);
                return dt;
            }
        }
        public DataTable GetModelType(string value)
        {
            lock (_remotingProxy)
            {
                string sql = "SELECT part_id as [value],part_no as [key] FROM dbo.sys_part WHERE model_id IN(select model_id from dbo.sys_model WHERE 0=0 " + value + ") AND part_type=2";
                DataTable dt = _remotingProxy.GetDataTable(sql);
                return dt;
            }
        }
    }
}