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

namespace BLL.DAL
{
    public class DAL_IpPlcInfo
    {
        #region WCSIP

        /// <summary>
        /// 获取WCSIP信息
        /// </summary>
        /// <param name="json"></param>
        /// <param name="pageInfo"></param>
        /// <returns></returns>
        public IList<WCSIP> GetList(AjaxGetIpList json, ref PageInfo pageInfo)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();

                // 0 未下发 1 已下发 2 ？ 3已完成
                strSql.Append("select Id,IP, Type,WareHouseNo,Text,IsDel,CreateTime,CreateUser from WCSIP where IsDel = '0'");
                

                if (!string.IsNullOrWhiteSpace(json.Ip))
                {
                    strSql.Append(" and IP like '%" + json.Ip + "%' ");
                }
                if (!string.IsNullOrWhiteSpace(json.Type))
                {
                    strSql.Append(" and Type = '" + json.Type + "' ");
                }

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

                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), param, "Id", "asc", ref pageInfo);
                return ModelConvertHelper<WCSIP>.DataTableToModel(dt);
            }
            catch(Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 获取WCSIP单条信息
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public WCSIP GetOneIp(string id)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();

                strSql.Append($"select Id,IP, Type,WareHouseNo,Text,IsDel,CreateTime,CreateUser from WCSIP where Id = {id} ");
                
                var dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
                return ModelConvertHelper<WCSIP>.ReaderToModel(dt);
            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 获取设备类型
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public string GetDicTypeHtml(string type = "")
        {
            try
            {
                StringBuilder sb = new StringBuilder();
                string resMenuTemplate = "<option value='{0}' {1}>{2}</option>";
                sb.AppendFormat(resMenuTemplate, "", "", "选择");
                
                var list = new List<DicOption>();
                list.Add(new DicOption()
                {
                    Val="0",
                    Text = "跺机"
                });
                list.Add(new DicOption()
                {
                    Val = "1",
                    Text = "托盘输送线"
                });
                list.Add(new DicOption()
                {
                    Val = "2",
                    Text = "件箱输送线"
                });

                foreach (var row in list)
                {
                    sb.AppendFormat(resMenuTemplate, row.Val, row.Val == type ? "selected='selected'" :
                        string.Empty, row.Text);
                }

                return sb.ToString();
            }
            catch
            {
                return "";
            }
        }
        /// <summary>
        /// 添加IP信息
        /// </summary>
        /// <param name="models"></param>
        /// <returns></returns>
        public bool IpAdd(AjasWCSIP models)
        {
            bool result = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                // 验证任务是否已存在
                //sqlString.Append($"select count(Id) from WCSIP where PalletNo = '{models.PalletNo}';");
                //DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                //if (dt.Rows[0][0].ToString() != "0")
                //{
                //    throw new Exception("托盘号:" + models.PalletNo + ";已存在!");
                //}

                // 新增任务
                sqlString.Clear();
                var str = $"insert into WCSIP (IP ,Type ,WareHouseNo ,Text ,IsDel ,CreateTime ,CreateUser) VALUES('{models.IP}','{models.Type}','{models.WareHouseNo}','{models.Text}','0',GETDATE(),'{models.CreateUser}' ); ";

                sqlString.Append(str);
                 
                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                if (num == 1) result = true;

                return result;

            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }
        /// <summary>
        /// 修改IP信息
        /// </summary>
        /// <param name="models"></param>
        /// <returns></returns>
        public bool IpUpdate(AjasWCSIP models)
        {
            bool result = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                // 验证任务是否已存在
                //sqlString.Append($"select count(Id) from WCSIP where PalletNo = '{models.PalletNo}';");
                //DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                //if (dt.Rows[0][0].ToString() != "0")
                //{
                //    throw new Exception("托盘号:" + models.PalletNo + ";已存在!");
                //}

                // 新增任务
                sqlString.Clear();
                var str = $"update WCSIP set IP = '{models.IP}',Type = '{models.Type}',WareHouseNo = '{models.WareHouseNo}', Text = '{models.Text}' where Id = {models.Id} ; ";

                sqlString.Append(str);

                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                if (num == 1) result = true;

                return result;

            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }
        /// <summary>
        /// 删除IP信息
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public bool IpDel(string[] Id)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("WCSIP", "Id", Id);
                if (dt >= Id.Length)
                {
                    int i = 0;
                    while (i < Id.Length)
                    {

                        StringBuilder sql = new StringBuilder();
                        // 验证任务是否已存在
                        sql.Append($"select count(Id) from WCSPlcInfo where PlcIP = {Id[i]};");
                        DataTable dt2 = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (dt2.Rows[0][0].ToString() != "0")
                        {
                            throw new Exception($"当前IP下存有工位设备信息，请先移除!");
                        }
                        // 获取当前IP信息
                        sql.Clear();
                        sql.Append($"select * from WCSIP where Id = '{Id[i]}';");
                        DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (monitorDt != null && monitorDt.Rows.Count > 0)
                        {
                            if (monitorDt.Rows[0]["IsDel"].ToString() == "1")
                            {
                                i++;
                                continue;
                            } 
                            sql.Clear();
                            // 修改任务状态
                            sql.Append($"update WCSIP set IsDel = '1' where Id = {Id[i]} ;");
                            int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                            if (_ret >= 1) result = true;
                        }
                        i++;
                    }

                }
                return result;

            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        #endregion


        #region WCSPlcInfo 

        /// <summary>
        /// 获取WCSPlcInfo信息
        /// </summary>
        /// <param name="json"></param>
        /// <param name="pageInfo"></param>
        /// <returns></returns>
        public IList<WCSPlcInfo> GetPlcInfoList(AjaxGetIpList json, ref PageInfo pageInfo)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();

                // 0 未下发 1 已下发 2 ？ 3已完成
                strSql.Append("select Id ,PlcIP ,LedIP ,DbNumber ,Level ,StationNum ,PlcPos ,WcsPos ,PosType ,Text ,IsDel ,CreateTime ,CreateUser from WCSPlcInfo where IsDel = '0' ");

                if (!string.IsNullOrWhiteSpace(json.Ip))
                {
                    strSql.Append(" and PlcIP = '" + json.Ip + "' ");
                }

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

                DataTable dt = DataFactory.SqlDataBase().GetPageList(strSql.ToString(), param, "Id", "asc", ref pageInfo);
                return ModelConvertHelper<WCSPlcInfo>.DataTableToModel(dt);
            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 获取 WCSPlcInfo 单条信息
        /// </summary>
        /// <param name="id"></param>
        /// <returns></returns>
        public WCSPlcInfo GetOnePlc(string id)
        {
            try
            {
                StringBuilder strSql = new StringBuilder();

                strSql.Append($"select * from WCSPlcInfo where Id = {id} ");

                var dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
                return ModelConvertHelper<WCSPlcInfo>.ReaderToModel(dt);
            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 获取设备级别
        /// </summary>
        /// <param name="type"></param>
        /// <returns></returns>
        public string GetDicLevelHtml(string type = "")
        {
            try
            {
                StringBuilder sb = new StringBuilder();
                string resMenuTemplate = "<option value='{0}' {1}>{2}</option>";
                sb.AppendFormat(resMenuTemplate, "", "", "选择");

                var list = new List<DicOption>();
                list.Add(new DicOption()
                {
                    Val = "1",
                    Text = "DB区域级别"
                });
                list.Add(new DicOption()
                {
                    Val = "2",
                    Text = "工位级别"
                });

                foreach (var row in list)
                {
                    sb.AppendFormat(resMenuTemplate, row.Val, row.Val == type ? "selected='selected'" :
                        string.Empty, row.Text);
                }

                return sb.ToString();
            }
            catch
            {
                return "";
            }
        }
        /// <summary>
        /// 获取设备级别
        /// </summary>
        /// <param name="code"></param>
        /// <returns></returns>
        public string GetDicPlcIpHtml(string code = "")
        {
            try
            {
                StringBuilder sb = new StringBuilder();
                string resMenuTemplate = "<option value='{0}' {1}>{2}</option>";
                sb.AppendFormat(resMenuTemplate, "", "", "选择");

                StringBuilder sql = new StringBuilder();
                sql.Append("select * from WCSIP where IsDel = 0;");

                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                 
                foreach (DataRow row in dt.Rows)
                {
                    sb.AppendFormat(resMenuTemplate, row["Id"].ToString(), row["Id"].ToString() == code ? "selected='selected'" :
                        string.Empty, row["Text"].ToString());
                }

                return sb.ToString();
            }
            catch
            {
                return "";
            }
        }

        /// <summary>
        /// 添加PlcInfo信息
        /// </summary>
        /// <param name="models"></param>
        /// <returns></returns>
        public bool PlcAdd(AjasWCSPlcInfo models)
        {
            bool result = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                // 验证任务是否已存在
                //sqlString.Append($"select count(Id) from WCSIP where PalletNo = '{models.PalletNo}';");
                //DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                //if (dt.Rows[0][0].ToString() != "0")
                //{
                //    throw new Exception("托盘号:" + models.PalletNo + ";已存在!");
                //}

                // 新增任务
                sqlString.Clear();
                var str = $"insert into WCSPlcInfo (PlcIP ,LedIP ,DbNumber ,Level,StationNum ,PlcPos ,WcsPos ,PosType ,Text ,IsDel ,CreateTime,CreateUser) VALUES('{models.PlcIP}','{models.LedIP}','{models.DbNumber}','{models.Level}','{models.StationNum}','{models.PlcPos}','{models.WcsPos}','{models.PosType}','{models.Text}','0',GETDATE(),'{models.CreateUser}' ); ";

                sqlString.Append(str);

                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                if (num == 1) result = true;

                return result;

            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 修改IP信息
        /// </summary>
        /// <param name="models"></param>
        /// <returns></returns>
        public bool PlcUpdate(AjasWCSPlcInfo models)
        {
            bool result = false;
            try
            {
                StringBuilder sqlString = new StringBuilder();
                // 验证任务是否已存在
                //sqlString.Append($"select count(Id) from WCSIP where PalletNo = '{models.PalletNo}';");
                //DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);
                //if (dt.Rows[0][0].ToString() != "0")
                //{
                //    throw new Exception("托盘号:" + models.PalletNo + ";已存在!");
                //}

                // 新增任务
                sqlString.Clear();
                var str = $"update WCSPlcInfo set PlcIP = '{models.PlcIP}',LedIP = '{models.LedIP}',DbNumber ='{models.DbNumber}',Level = '{models.Level}',StationNum = '{models.StationNum}',PlcPos = '{models.PlcPos}',WcsPos = '{models.WcsPos}',PosType = '{models.PosType}',Text = '{models.Text}' where Id = {models.Id} ; ";

                sqlString.Append(str);

                var num = DataFactory.SqlDataBase().ExecuteBySql(sqlString);

                if (num == 1) result = true;

                return result;

            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }

        /// <summary>
        /// 删除IP信息
        /// </summary>
        /// <param name="Id"></param>
        /// <returns></returns>
        public bool PlcDel(string[] Id)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("WCSPlcInfo", "Id", Id);
                if (dt >= Id.Length)
                {
                    int i = 0;
                    while (i < Id.Length)
                    {

                        StringBuilder sql = new StringBuilder();
                        // 验证任务是否已存在
                        sql.Append($"select count(Id) from WCSPlcPos where PlcInfoId = {Id[i]};");
                        DataTable dt2 = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (dt2.Rows[0][0].ToString() != "0")
                        {
                            throw new Exception($"当前IP下存有流程字信息，请先移除!");
                        }
                        // 获取当前IP信息
                        sql.Clear();
                        sql.Append($"select * from WCSPlcInfo where Id = '{Id[i]}';");
                        DataTable monitorDt = DataFactory.SqlDataBase().GetDataTableBySQL(sql);
                        if (monitorDt != null && monitorDt.Rows.Count > 0)
                        {
                            if (monitorDt.Rows[0]["IsDel"].ToString() == "1")
                            {
                                i++;
                                continue;
                            }
                            sql.Clear();
                            // 修改任务状态
                            sql.Append($"update WCSPlcInfo set IsDel = '1' where Id = {Id[i]} ;");
                            int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                            if (_ret >= 1) result = true;
                        }
                        i++;
                    }

                }
                return result;

            }
            catch (Exception e)
            {
                throw new Exception(e.Message);
            }
        }
        

        #endregion


    }

    public class DicOption
    {
        public string Val { get; set; }

        public string Text { get; set; }
    }

}