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

namespace BLL.DAL
{
    public class DAL_ConveyorInfo
    {
        public IList<GetWCSConveyorInfo> GetList(AjaxConveyorInfoList Json, ref PageInfo pageInfo)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();
                strSql.Append("select a.*,b.userName as CreateUserName,c.userName as UpdateUserName from WCSConveyorInfo a left join UserInfo b on a.CreateUser = b.Id left join UserInfo c on a.UpdateUser = c.Id where a.IsDel = '0' ");

                if (string.IsNullOrWhiteSpace(Json.SkuType) && string.IsNullOrWhiteSpace(Json.Conveyor) && string.IsNullOrWhiteSpace(Json.LotNo) && string.IsNullOrWhiteSpace(Json.IsEndLot) && string.IsNullOrWhiteSpace(Json.Status))
                {
                    strSql.Append(" and IsEndLot = '0'");
                }

                if (!string.IsNullOrWhiteSpace(Json.SkuType))
                {
                    strSql.Append(" and SkuType = '" + Json.SkuType + "'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.Conveyor))
                {
                    strSql.Append(" and Conveyor = '" + Json.Conveyor + "'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.LotNo))
                {
                    strSql.Append(" and LotNo like '%" + Json.LotNo + "%'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.IsEndLot))
                {
                    strSql.Append(" and IsEndLot = '" + Json.IsEndLot + "'  ");
                }
                if (!string.IsNullOrWhiteSpace(Json.Status))
                {
                    strSql.Append(" and Status = '" + Json.Status + "'  ");
                }
                if (Json.BeginTime != null && Json.BeginTime != DateTime.MinValue && Json.BeginTime != DateTime.MaxValue)
                {
                    strSql.Append($"and LoginTime >= '{Convert.ToDateTime(Json.BeginTime).ToShortDateString()}' ");
                }
                if (Json.BeginTime != null && Json.EndTime != DateTime.MinValue && Json.EndTime != DateTime.MaxValue)
                {
                    strSql.Append($"and LoginTime <= '{Convert.ToDateTime(Json.EndTime).ToShortDateString() + " 23:59:59.999"}' ");

                }

                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), null, "CreateTime", "Desc", ref pageInfo);
                return ModelConvertHelper<GetWCSConveyorInfo>.DataTableToModel(dt);
            }
            catch
            {
                throw new NotImplementedException();
            }
        }

        public GetWCSConveyorInfo GetConveyorInfo(string Id)
        {
            GetWCSConveyorInfo getWCS = new GetWCSConveyorInfo();

            StringBuilder strSql = new StringBuilder();
            strSql.Append($"select * from WCSConveyorInfo where Id = @id");

            //DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(strSql);

            SqlParam[] para = new SqlParam[]
                {
                    new SqlParam("@id", Id),
                };

            IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, para);
            getWCS = ModelConvertHelper<GetWCSConveyorInfo>.ReaderToModel(dt);

            return getWCS;
        }

        /// <summary>
        /// 添加物料输送信息
        /// </summary>
        /// <param name="model"></param>
        /// <param name="loginUser"></param>
        /// <returns></returns>
        public bool Add(WCSConveyorInfo model, string loginUser)
        {
            bool result = false;
            try
            {
                //转换user信息 user Code变成id

                UserInfo us = null;
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");

                IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);

                us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
                if (us == null)
                {
                    return false;
                }
                Hashtable ht = new Hashtable();

                ht["SkuType"] = "'" + model.SkuType + "'";
                ht["Conveyor"] = "'" + model.Conveyor + "'";
                ht["LotNo"] = "'" + model.LotNo.Trim() + "'";
                ht["SupplierLot"] = "'" + model.SupplierLot + "'";
                ht["ManuFactureDate"] = "'" + model.ManuFactureDate + "'";
                ht["IsEndLot"] = "0";
                ht["Status"] = "0";

                ht["IsDel"] = "0";
                ht["CreateUser"] = "" + us.ID + "";
                ht["CreateTime"] = "GetDate()";

                var ret = DataFactory.SqlDataBase().InsertByHashtableNullParam("WCSConveyorInfo", ht);

                if (ret == 1) result = true;

                return result;

            }
            catch
            {
                return result;
            }
        }

        /// <summary>
        /// 添加物料输送信息
        /// </summary>
        /// <param name="model"></param>
        /// <param name="loginUser"></param>
        /// <returns></returns>
        public bool Upt(WCSConveyorInfo model, string loginUser)
        {
            bool result = false;
            try
            {
                UserInfo us = null;
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");

                IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);

                us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
                if (us == null)
                {
                    return false;
                }

                

                StringBuilder sql = new StringBuilder();
                if (model.Conveyor == "1")
                {
                    model.Conveyor = "A";
                }
                else if (model.Conveyor == "2")
                {
                    model.Conveyor = "B";
                }
                else if (model.Conveyor == "3")
                {
                    model.Conveyor = "C";
                }
                else if (model.Conveyor == "4")
                {
                    model.Conveyor = "C1";
                }
                else if (model.Conveyor == "5")
                {
                    model.Conveyor = "D";
                }

                sql.Append($"update WcsConveyorInfo set SkuType = '{model.SkuType}',Conveyor = '{model.Conveyor}',LotNo = '{model.LotNo}',SupplierLot = '{model.SupplierLot}',ManuFactureDate = '{model.ManuFactureDate}',UpdateTime = getdate(),UpdateUser = '{us.ID}' Where Id = {model.Id}");

                int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                if (_ret > 0) result = true;
                return result;
            }
            catch
            {
                return result;
            }
        }

        public bool Delete(string[] infoIds, string loginUser)
        {
            bool result = false;
            try
            {
                UserInfo us = null;
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");

                IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);

                us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
                if (us == null)
                {
                    return false;
                }
                var dt2 = DataFactory.SqlDataBase().IsExist("WcsConveyorInfo", "Id", infoIds);
                if (dt2 >= infoIds.Length)
                {
                    StringBuilder sql = new StringBuilder();
                    foreach (string code in infoIds)
                    {
                        sql.Append("update WcsConveyorInfo set IsDel=1,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id='" + code + "';");
                    }

                    int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                    if (_ret > infoIds.Length) result = true;
                }
                return result;

            }
            catch
            {
                return result;
            }
        }

        public bool Run(string[] infoIds, string loginUser)
        {
            bool result = false;
            try
            {
                UserInfo us = null;
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");

                IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);

                us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
                if (us == null)
                {
                    return false;
                }
                var dt2 = DataFactory.SqlDataBase().IsExist("WCSConveyorInfo", "Id", infoIds);
                if (dt2 >= infoIds.Length)
                {
                    StringBuilder sql = new StringBuilder();
                    foreach (string code in infoIds)
                    {
                        StringBuilder sql2 = new StringBuilder();
                        sql2.Append($"select * from WCSConveyorInfo where IsDel = 0 and Id = '{code}' ");

                        IDataReader dt3 = DataFactory.SqlDataBase().GetDataReaderBySQL(sql2, null);

                        var info = ModelConvertHelper<WCSConveyorInfo>.ReaderToModel(dt3);

                        sql.Append("update WcsConveyorInfo set Status=1,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id='" + code + "';");
                        sql.Append("update WcsConveyorInfo set Status=0,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id !='" + code + "' and IsDel = '0' and Conveyor = '"+ info.Conveyor + "';");
                    }

                    int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                    if (_ret > infoIds.Length) result = true;
                }
                return result;

            }
            catch
            {
                return result;
            }
        }

        public bool JiePi(string[] infoIds, string loginUser)
        {
            bool result = false;
            try
            {
                UserInfo us = null;
                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select * from UserInfo where IsDel = 0 and UserCode = '{loginUser}' ");

                IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql, null);

                us = ModelConvertHelper<UserInfo>.ReaderToModel(dt);
                if (us == null)
                {
                    return false;
                }
                var dt2 = DataFactory.SqlDataBase().IsExist("WCSConveyorInfo", "Id", infoIds);
                if (dt2 >= infoIds.Length)
                {
                    StringBuilder sql = new StringBuilder();
                    foreach (string code in infoIds)
                    {
                        sql.Append("update WcsConveyorInfo set IsEndLot=1,Status =0,UpdateTime = getdate(),UpdateUser = '" + us.ID + "' where Id='" + code + "';");

                    }

                    int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                    if (_ret > infoIds.Length) result = true;
                }
                return result;

            }
            catch
            {
                return result;
            }
        }
    }
}