using System;
using System.Collections.Generic;
using System.Text;
using Model;
using Common;
using System.Data;

namespace BLL
{
    public class DALErpInDetail : IDALErpInDetail
    {
        public IList<ErpDetails> GetList(AjaxErpInList models)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append("select * from View_ErpInDetail where Ordno ='" + models.OrdNo);
                strSql.Append("' and DepartGuid = '" + models.DepartGuid + "' ");
                strSql.Append("order by [dbo].PadLeft(PageNo,'0',3) asc ");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);

                return ModelConvertHelper<ErpDetails>.DataTableToModel(dt);
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }


        public IList<ErpMat> GetList(string OrdNo)
        {
            try
            {
                IList<ErpMat> ls = new List<ErpMat>();
                List<SqlParam> para = new List<SqlParam>();
                StringBuilder strSql = new StringBuilder();
                strSql.Append("Select * from View_ErpInDetail ");


                if (!string.IsNullOrEmpty(OrdNo))
                {
                    if (para.Count < 1) strSql.Append("where "); else strSql.Append(" and ");
                    strSql.Append("OrdNo = @OrdNo ");
                    para.Add(new SqlParam("@OrdNo", OrdNo));
                }


                SqlParam[] param = null;
                if (para != null)
                    param = para.ToArray();

                IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, param);
                ls = ModelConvertHelper<ErpMat>.DataReaderToModel(dt);

                return ls;
            }
            catch
            {
                throw new NotImplementedException();
            }
        }

        public IList<ErpDetails> GetList(AjaxErpInList models, ref PageInfo pageInfo)
        {
            try
            {
                IList<ErpDetails> ls = new List<ErpDetails>();
                List<SqlParam> para = new List<SqlParam>();
                StringBuilder strSql = new StringBuilder();
                strSql.Append("Select * from View_ErpInDetail where ");
                strSql.Append("OrdNo = @OrdNo and DepartGuid = @DepartGuid ");
                para.Add(new SqlParam("@OrdNo", models.OrdNo));
                para.Add(new SqlParam("@DepartGuid", models.DepartGuid));

                SqlParam[] param = para.ToArray();
                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(),param, "[dbo].PadLeft(PageNo,'0',3)", "asc" ,ref pageInfo);
                ls = ModelConvertHelper<ErpDetails>.DataTableToModel(dt);

                return ls;
            }
            catch (Exception ex)
            {
                throw ex;
            }
        }

        public IList<ErpMat> Getposition(string ordNo, string matNo)
        {
            try
            {
                IList<ErpMat> ls = new List<ErpMat>();
               
                StringBuilder strSql = new StringBuilder();
                strSql.Append("Select * from ErpInPosition where OrdNo='"+ordNo+ "' and MatNo='"+matNo+"'");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);
                ls = ModelConvertHelper<ErpMat>.DataTableToModel(dt);

                return ls;
            }
            catch
            {
                throw new NotImplementedException();
            }
        }
        public bool IsExist(string name, string value)
        {
            bool result = false;
            try
            {
                string[] para = new string[] { value };
                int dt = DataFactory.SqlDataBase().IsExist("Roles", name, para);
                if (dt > 0) result = true;
                return result;
            }
            catch
            {
                return result;
            }

        }

        public DataTable GetDataTable(string[] strWhere)
        {
            DataTable dt = null;
            try
            {
                int index = 0;
                string str = "@RoleNum" + index;
                SqlParam[] param = new SqlParam[strWhere.Length];
                StringBuilder sql = new StringBuilder();
                sql.Append("Select RoleNum as 角色编号, RoleName as 角色名,CreatUser as 创建人,CreatTime as 创建时间,UpdateUser as 更新人,UpdateTime as 更新时间,Demo as 备注 FROM View_GetRoles where RoleNum in (");

                for (int i = 0; i < param.Length - 1; i++)
                {
                    string obj2 = strWhere[i];
                    str = "@RoleNum" + index;
                    sql.Append(str).Append(",");
                    param[index] = new SqlParam(str, obj2);
                    index++;
                }
                str = "@RoleNum" + index;
                sql.Append(str);
                param[index] = new SqlParam(str, strWhere[index]);
                sql.Append(")");

                dt = DataFactory.SqlDataBase().GetDataTableBySQL(sql, param, "");

                return dt;

            }
            catch
            {
                throw new NotImplementedException();
            }

        }

        public bool Delete(List<ErpMat> EMats)
        {
            bool result = false;
            try
            {
                foreach (ErpMat tm in EMats)
                {
                    int n = DataFactory.SqlDataBase().DeleteData("ErpInDetail", "OrdNo", tm.OrdNo);
                    if (n >= 0)
                        result = true;
                }
                //foreach (ErpMat tm in EMats)
                //{
                //    List<SqlParam> para = new List<SqlParam>();
                //    StringBuilder strSql = new StringBuilder();
                //    StringBuilder sp1 = new StringBuilder();
                //    StringBuilder sp2 = new StringBuilder();

                //    strSql.Append(" DELETE FROM ErpInDetail where OrdNo = @OrdNo");

                //    SqlParam[] param = new SqlParam[] {

                //        new SqlParam("@OrdNo", tm.OrdNo)
                //    };
                    
                //    int n = DataFactory.SqlDataBase().ExecuteBySql(strSql, param);
                //    if (n < 0)
                //        return false;
                //}
                    //try
                    //{
                    ////向库存明细表插入更新数据
                    //for (int j = 0; j < EMats.Count; j++)
                    //{
                    //    int sum = 0;
                    //    StringBuilder mql = new StringBuilder();
                    //    mql.Append("select CurQuant from ErpInDetail where OrdNo='"+EMats[j].OrdNo+"' and MatNo='" + EMats[j].MatNo + "' and addreNo='" + EMats[j].addreNo + "' and PalNo='" + EMats[j].Palno + "'");
                    //    DataTable dl = DataFactory.SqlDataBase().GetDataTableBySQL(mql);
                    //    if (dl.Rows.Count > 0)
                    //    {
                    //        try
                    //        {
                    //            sum = int.Parse(EMats[j].CurQuant.ToString()) - int.Parse(dl.Rows[0]["CurQuant"].ToString());
                    //        }
                    //        catch (Exception)
                    //        {

                    //            sum = 0;
                    //        }
                            
                    //    }
                    //    else
                    //    {
                    //        sum = int.Parse(EMats[j].CurQuant.ToString());
                    //    }
                    //    StringBuilder select1 = new StringBuilder();
                    //    select1.Append("select Quant from log_Store where  MatNo='" + EMats[j].MatNo + "' and Palno='" + EMats[j].Palno + "'and Addre='" + EMats[j].addreNo + "' ");
                    //    DataTable slstock = DataFactory.SqlDataBase().GetDataTableBySQL(select1);
                    //    if (slstock.Rows.Count > 0)
                    //    {
                    //        StringBuilder select2 = new StringBuilder();
                    //        sum = int.Parse(slstock.Rows[0]["Quant"].ToString()) + sum;
                    //        select2.Append(" update log_Store set Quant='" + sum + "' where Addre='" + EMats[j].addreNo + "' and MatNo='" + EMats[j].MatNo + "' and Palno='" + EMats[j].Palno + "'  ");
                    //        DataFactory.SqlDataBase().ExecuteBySql(select2);
                    //    }
                    //    else
                    //    {
                    //        StringBuilder select2 = new StringBuilder();
                    //        select2.Append("insert into log_Store (Addre,Palno,MatNo,Quant)values('" + EMats[j].addreNo + "','" + EMats[j].Palno + "','" + EMats[j].MatNo + "','" + EMats[j].CurQuant + "')");
                    //       int ad = DataFactory.SqlDataBase().ExecuteBySql(select2);
                    //    }
                    //}
                    ////向库存总表插入更新数据
                    //for (int j = 0; j < EMats.Count; j++)
                    //{
                    //    int sum = 0;
                    //    StringBuilder mql = new StringBuilder();
                    //    mql.Append("select CurQuant from ErpInDetail where OrdNo='" + EMats[j].OrdNo + "' and MatNo='" + EMats[j].MatNo + "' and addreNo='" + EMats[j].addreNo + "' and PalNo='" + EMats[j].Palno + "'");
                    //    DataTable dl = DataFactory.SqlDataBase().GetDataTableBySQL(mql);
                    //    if (dl.Rows.Count > 0)
                    //    {
                    //        try
                    //        {
                    //            sum = int.Parse(EMats[j].CurQuant.ToString()) - int.Parse(dl.Rows[0]["CurQuant"].ToString());
                    //        }
                    //        catch (Exception)
                    //        {

                    //            sum = 0;
                    //        }
                            
                    //    }
                    //    else
                    //    {
                    //        sum = int.Parse(EMats[j].CurQuant.ToString());
                    //    }
                    //    StringBuilder hql = new StringBuilder();
                    //    hql.Append("select * from Log_Stroe_Mat where MatNo='" + EMats[j].MatNo + "'");
                    //    DataTable dd = DataFactory.SqlDataBase().GetDataTableBySQL(hql);
                    //    if (dd.Rows.Count > 0)
                    //    {
                    //        StringBuilder hql2 = new StringBuilder();
                    //        int quant = int.Parse(dd.Rows[0]["Quant"].ToString()) + sum;
                    //        hql2.Append("Update Log_Stroe_Mat set Quant='" + quant + "' where MatNo='" + EMats[j].MatNo + "'");
                    //        DataFactory.SqlDataBase().ExecuteBySql(hql2);
                    //    }
                    //    else
                    //    {
                    //        StringBuilder hql2 = new StringBuilder();
                    //        hql2.Append("insert into Log_Stroe_Mat (MatNo,Quant)values('" + EMats[j].MatNo + "','" + EMats[j].CurQuant + "')");
                    //        DataFactory.SqlDataBase().ExecuteBySql(hql2);
                    //    }

                    //}
                    //int dt = DataFactory.SqlDataBase().ExecuteBySql(strSql, param);
                    //    result = true;
                    //}
                    //catch
                    //{
                    //    result = false;
                    //}
                   
                
                return result;
            }
            catch
            {
                return result;
            }
        }

        public DataTable GetPrintData(string OrdNo)
        {
            DataTable ds = null;
            try
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append(" Select * from View_ErpInDetail where ");
                strSql.Append("OrdNo = @OrdNo ");

                SqlParam[] para = new SqlParam[]
                {
                    new SqlParam("@OrdNo", OrdNo),
                };
                strSql.Append(" order by [dbo].PadLeft(PageNo,'0',3) asc;");

                ds = DataFactory.SqlDataBase().GetDataTableBySQL(strSql, para, "table2");

                return ds;
            }
            catch
            {
                return ds;
            }
        }
    }
}