using Common;
using Model;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace BLL.DAL
{
   public class DALPicking
    {
        public IList<Picking> GetList(AjaxErpOutList Json, ref PageInfo page)
        {
            try
            {
                IList<Picking> list = new List<Picking>();
                StringBuilder strSql = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();
                strSql.Append("Select * from Picking where 1 = 1");
                if (!string.IsNullOrEmpty(Json.OrdNo))
                {
                    strSql.Append(" and OrdNo like '%' + @OrdNo + '%'");
                    para.Add(new SqlParam("@OrdNo",Json.OrdNo));
                }
                if (!string.IsNullOrEmpty(Json.Statu))
                {
                    strSql.Append(" and IsDel = @Statu");
                    para.Add(new SqlParam("@Statu",Json.Statu));
                }
                else
                {
                    strSql.Append(" and IsDel = 0");
                }
                //if (Json.BeginTime != DateTime.MinValue && Json.BeginTime != null && Json.BeginTime != DateTime.MaxValue)
                //{
                //    strSql.Append(" and ");
                //    strSql.Append("CreateTime >= @CreateTime1 ");
                //    para.Add(new SqlParam("@CreateTime1", Convert.ToDateTime(Json.BeginTime)));
                //}

                //if (Json.EndTime != DateTime.MinValue && Json.EndTime != null && Json.EndTime != DateTime.MaxValue)
                //{
                //    strSql.Append(" and ");
                //    strSql.Append("CreateTime <= @CreateTime2 ");
                //    para.Add(new SqlParam("@CreateTime2", Convert.ToDateTime(Json.EndTime)));
                //}

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

                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), param, "ID", "asc", ref page);
                list = ModelConvertHelper<Picking>.DataTableToModel(dt);

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

        }
        /// <summary>
        /// 回库逻辑判断下发指令
        /// </summary>
        /// <param name="json"></param>
        /// <returns></returns>
        public bool Out(string[] json, string CreateUser)
        {
            bool result = false;
            try
            {
                StringBuilder strSql = new StringBuilder();
                //获取单号下货位
                strSql.Append("Select OrdNo,Addre,Palno from Picking where ID ='" + json[0] + "' and IsDel=0 ");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);

                for (int i = 0; i < dt.Rows.Count; i++)
                {

                    //判断货位是里层还是外层
                    if (dt.Rows[i]["Addre"].ToString().IndexOf("-001") >= 0 || dt.Rows[i]["Addre"].ToString().IndexOf("-004") >= 0)
                    {
                        string pai1 = "";
                        string pai2 = "";
                        //是里层判断外层是否是空货位，不是则先移库
                        if (dt.Rows[i]["Addre"].ToString().IndexOf("-001") >= 0)
                        {
                            pai1 = "-001";
                            pai2 = "-002";
                        }
                        else
                        {
                            pai1 = "-004";
                            pai2 = "-003";
                        }
                        StringBuilder seladdre = new StringBuilder();
                        seladdre.Append("Select Addre,Palno,DepotsLocation.Height from log_Store ");
                        seladdre.Append("left join DepotsLocation on log_Store.Addre = DepotsLocation.LocationCode ");
                        seladdre.Append("where Addre = '" + dt.Rows[i]["Addre"].ToString().Replace(pai1, pai2) + "' and DepotsLocation.TurnoverDemand in ('02') ");
                        seladdre.Append("group by Addre,Palno,DepotsLocation.Height;");

                        //seladdre.Append("Select Addre,Palno from log_Store where Addre ='" + dt.Rows[i]["Addre"].ToString().Replace(pai1, pai2) + "'");
                        DataTable dd = DataFactory.SqlDataBase().GetDataTableBySQL(seladdre);
                        if (dd.Rows.Count > 0)
                        {
                            if (dd.Rows.Count > 1) 
                            {
                                return false;
                            }

                            string moveaddre = "";
                            string oriPos = dt.Rows[0]["Addre"].ToString().Replace(pai1, pai2);
                            int height = int.Parse(dt.Rows[0]["Height"].ToString());
                            DAL_Pub pub = new DAL_Pub();
                            int move = pub.GetEmptyPos(ref moveaddre, height, oriPos);
                            //外层有托盘则先移库再回库
                            if (moveaddre.IndexOf("-001") >= 0 || moveaddre.IndexOf("-004") >= 0)
                            {
                                string ad1 = "";
                                string ad2 = "";
                                if (moveaddre.IndexOf("-001") >= 0)
                                {
                                    ad1 = "-001";
                                    ad2 = "-002";
                                }
                                else
                                {
                                    ad1 = "-004";
                                    ad2 = "-003";
                                }
                                //判断空货位外层是否是空位，是直接移库，不是外层托盘移向里层再移库
                                StringBuilder sql = new StringBuilder();
                                sql.Append("Select LocationCode,log_Store.Palno from DepotsLocation Select LocationCode,log_Store.Palno from DepotsLocation  left join log_Store on DepotsLocation.LocationCode = log_Store.Addre where LocationCode ='" + moveaddre.Replace(ad1, ad2) + "' and TurnoveDemand='01' ");

                                DataTable ad = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                                if (ad.Rows.Count > 0)
                                {
                                    Hashtable ht = new Hashtable();
                                    ht["CMDType"] = "'move'";
                                    ht["Palno"] = "'" + ad.Rows[0]["Palno"].ToString() + "'";
                                    ht["OldAddre"] = "'" + ad.Rows[0]["Addre"].ToString() + "'";
                                    ht["NowAddre"] = "'"+moveaddre+"'";
                                    ht["CMDStatu"] = "0";
                                    ht["CreateUser"] = "'" + CreateUser + "'";
                                    int moveadd = DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);

                                    Hashtable ht1 = new Hashtable();
                                    ht1["CMDType"] = "'move'";
                                    ht1["Palno"] = "'" + dd.Rows[0]["Palno"].ToString() + "'";
                                    ht1["OldAddre"] = "'" + dd.Rows[0]["Addre"].ToString() + "'";
                                    ht1["NowAddre"] = "'" + ad.Rows[0]["LocationCode"].ToString() + "'";
                                    ht1["CMDStatu"] = "0";
                                    ht1["CreateUser"] = "'" + CreateUser + "'";
                                    int moveadd1 = DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht1);
                                }
                                else
                                {
                                    Hashtable ht = new Hashtable();
                                    ht["CMDType"] = "'move'";
                                    ht["Palno"] = "'" + dd.Rows[0]["Palno"].ToString() + "'";
                                    ht["OldAddre"] = "'" + dd.Rows[0]["Addre"].ToString() + "'";
                                    ht["NowAddre"] = "'"+moveaddre+"'";
                                    ht["CMDStatu"] = "0";
                                    ht["CreateUser"] = "'" + CreateUser + "'";
                                    int moveadd = DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
                                }
                            }
                            else
                            {
                                Hashtable ht = new Hashtable();
                                ht["CMDType"] = "'move'";
                                ht["Palno"] = "'" + dt.Rows[i]["Palno"].ToString() + "'";
                                ht["OldAddre"] = "'" + dt.Rows[i]["Addre"].ToString() + "'";
                                ht["NowAddre"] = "'"+moveaddre+"'";
                                ht["CMDStatu"] = "0";
                                ht["CreateUser"] = "'" + CreateUser + "'";
                                int moveadd = DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
                            }
                            Hashtable hy = new Hashtable();
                            hy["TaskID"] = "'"+dt.Rows[i]["OrdNo"].ToString()+"'";
                            hy["CMDType"] = "'to'";
                            hy["Palno"] = "'" + dt.Rows[i]["Palno"].ToString() + "'";
                            hy["CMDStatu"] = "0";
                            hy["CreateUser"] = "'" + CreateUser + "'";
                            int outadd = DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", hy);

                        }
                        else
                        {
                            //外层没有托盘直接回库
                            Hashtable ht = new Hashtable();
                            ht["TaskID"] = "'" + dt.Rows[i]["OrdNo"].ToString() + "'";
                            ht["CMDType"] = "'to'";
                            ht["Palno"] = "'" + dt.Rows[i]["Palno"].ToString() + "'";
                            ht["OldAddre"] = "'" + dt.Rows[i]["Addre"].ToString() + "'";
                            ht["CMDStatu"] = "0";
                            ht["CreateUser"] = "'" + CreateUser + "'";
                            int outadd = DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);

                        }

                    }//是外层则直接出库下发指令
                    else
                    {
                        Hashtable ht = new Hashtable();
                        ht["TaskID"] = "'" + dt.Rows[i]["OrdNo"].ToString() + "'";
                        ht["CMDType"] = "'to'";
                        ht["Palno"] = "'" + dt.Rows[i]["Palno"].ToString() + "'";
                        ht["OldAddre"] = "'" + dt.Rows[i]["Addre"].ToString() + "'";
                        ht["CMDStatu"] = "0";
                        ht["CreateUser"] = "'"+CreateUser+"'";
                        int dd = DataFactory.SqlDataBase().InsertByHashtableNullParam("WH_CMD", ht);
                    }

                    //下发完指令更改单号状态为正在执行
                    Hashtable htup = new Hashtable();
                    htup["IsDel"] = 1;

                    string ID = "'" + json[0] + "'";

                    int _ret = DataFactory.SqlDataBase().UpdateByHashtable("Picking", nameof(ID), ID, htup);
                }
                return true;
            }
            catch
            {
                return result;
            }
        }
    }
}