using Commom.Utility;
using Common;
using Model;
using Model.WcsModel;
using System;
using System.Collections;
using System.Collections.Generic;
using System.Data;
using System.Text;

namespace BLL.DAL
{
    public class DAL_AlarmInfo
    {
        #region 报警维护
        /// <summary>
        /// 根据ID获取报警信息
        /// </summary>
        /// <returns></returns>
        public WCSAlarmInfo GetAlarmInfo(string Id)
        {
            try
            {

                StringBuilder strSql = new StringBuilder();
                strSql.Append($"select * from WCSAlarmInfo where IsDel = 0 and Id = '{Id}' order by createTime;");

                IDataReader dt = DataFactory.SqlDataBase().GetDataReaderBySQL(strSql);
                var model = ModelConvertHelper<WCSAlarmInfo>.ReaderToModel(dt);
                return model;
            }
            catch
            {
                throw new NotImplementedException();
            }
        }

        /// <summary>
        /// 获取报警信息数据集合
        /// </summary>
        /// <param name="Json">查询条件</param>
        /// <param name="pageInfo">分页信息</param>
        /// <returns></returns>
        public IList<WCSAlarmInfo> GetAlarmInfoList(AjaxAlarmInfoList Json, ref PageInfo pageInfo)
        {
            try
            {
                IList<WCSAlarmInfo> list = new List<WCSAlarmInfo>();
                StringBuilder sqlString = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();

                sqlString.Append("select tb1.*,tb2.RealName as CreateUserName ");
                sqlString.Append("from WCSAlarmInfo as tb1 left join UserInfo as tb2 on tb1.CreateUser = tb2.ID ");
                sqlString.Append("where tb1.IsDel = 0 ");
                if (!string.IsNullOrWhiteSpace(Json.AlarmCode))
                {
                    sqlString.Append($"and tb1.AlarmCode like '%{Json.AlarmCode}%' ");
                }

                if (!string.IsNullOrWhiteSpace(Json.AlarmName))
                {
                    sqlString.Append($"and tb1.AlarmName like '%{Json.AlarmName}%' ");
                }

                DataTable dt = DataFactory.SqlDataBase().GetPageList(sqlString.ToString(), null, "CreateTime", "DESC", ref pageInfo);

                list = ModelConvertHelper<WCSAlarmInfo>.DataTableToModel(dt);

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

        /// <summary>
        /// 删除报警信息
        /// </summary>
        /// <param name="ID">ID集合</param>
        /// <returns></returns>
        public bool DeleteAlarmInfo(string[] ID)
        {
            bool result = false;
            try
            {
                int dt = DataFactory.SqlDataBase().IsExist("WCSAlarmInfo", "ID", ID);
                if (dt >= ID.Length)
                {
                    int i = 0;
                    while (i < ID.Length)
                    {
                        StringBuilder sql = new StringBuilder();
                        sql.Append("update WCSAlarmInfo set IsDel=1 where Id='" + ID[i] + "'");
                        int _ret = DataFactory.SqlDataBase().ExecuteBySql(sql);
                        if (_ret >= ID.Length) result = true;
                        i++;
                    }

                }
                return result;
            }
            catch
            {
                return result;
            }
        }

        /// <summary>
        /// 新增编辑报警信息
        /// </summary>
        /// <param name="model">流程字信息</param>
        /// <returns>true:保存成功 false:保存失败</returns>
        public bool AddAlarmInfo(AjaxAlarmInfo model, string loginName)
        {
            bool bl = false;
            try
            {
                int rowCount = 0;
                Hashtable ht = new Hashtable();
                if (model.Operation == "Add")
                {
                    // add
                    ht["PlcIP"] = model.PlcIP.AddQuotes();
                    ht["AlarmCode"] = model.AlarmCode.AddQuotes();
                    ht["AlarmName"] = model.AlarmName.AddQuotes();
                    ht["AlarmType"] = model.AlarmType.AddQuotes();
                    ht["LedIP"] = model.LedIP.AddQuotes();
                    ht["Type"] = model.Type.AddQuotes();
                    ht["AlarmTime"] = model.AlarmTime.AddQuotes();
                    ht["LedStatus"] = 0;
                    ht["CreateUser"] = model.CreateUser;

                    rowCount = DataFactory.SqlDataBase().InsertByHashtableNullParam("WCSAlarmInfo", ht);

                    StringBuilder sql = new StringBuilder();
                    sql.Append($"");

                    if (rowCount >= 1)
                    {
                        DAL_OperationRecord oper = new DAL_OperationRecord();
                        var operation = new OperationModel()
                        {
                            MenuName = "报警维护",
                            FkNo = model.AlarmCode + "-" + model.AlarmName,
                            Msg = "添加报警维护",
                            Type = "添加",
                        };
                        oper.AddOperation(operation, loginName);
                        bl = true;
                    }
                    if (rowCount >= 1)
                    {
                        DAL_AlarmLog oper = new DAL_AlarmLog();
                        var operation = new WCSAlarmLogModel()
                        {
                            PlcIP = model.PlcIP,
                            AlarmCode = model.AlarmCode,
                            AlarmName = model.AlarmName,
                            AlarmType = model.AlarmType,
                            LedIP = model.LedIP,
                            Type = model.Type,
                            AlarmTime = model.AlarmTime,
                            LedStatus = model.LedStatus,
                            CreateUser = model.CreateUser.ToInt(),
                        };
                        oper.AddAlarmLog(operation, loginName);
                        bl = true;
                    }

                }
                else
                {
                    // Edit
                    ht["PlcIP"] = model.PlcIP.AddQuotes();
                    ht["AlarmCode"] = model.AlarmCode.AddQuotes();
                    ht["AlarmName"] = model.AlarmName.AddQuotes();
                    ht["AlarmType"] = model.AlarmType.AddQuotes();
                    ht["LedIP"] = model.LedIP.AddQuotes();
                    ht["Type"] = model.Type.AddQuotes();
                    ht["LedStatus"] = 0;
                    //ht["CreateUser"] = "";

                    rowCount = DataFactory.SqlDataBase().UpdateByHashtable("WCSAlarmInfo", "id", model.Id.ToString(), ht);

                    if (rowCount >= 1)
                    {
                        DAL_OperationRecord oper = new DAL_OperationRecord();
                        var operation = new OperationModel()
                        {
                            MenuName = "报警维护",
                            FkNo = model.AlarmCode + "-" + model.AlarmName,
                            Msg = "修改报警维护",
                            Type = "修改",
                        };
                        oper.AddOperation(operation, loginName);
                        bl = true;
                    }
                    if (rowCount >= 1)
                    {
                        DAL_AlarmLog oper = new DAL_AlarmLog();
                        var operation = new WCSAlarmLogModel()
                        {
                            PlcIP = model.PlcIP,
                            AlarmCode = model.AlarmCode,
                            AlarmName = model.AlarmName,
                            AlarmType = model.AlarmType,
                            LedIP = model.LedIP,
                            Type = model.Type,
                            AlarmTime = model.AlarmTime,
                            LedStatus = model.LedStatus,
                            CreateUser = model.CreateUser.ToInt(),
                        };
                        oper.AddAlarmLog(operation, loginName);
                        bl = true;
                    }
                }

                if (rowCount == 1)
                {
                    bl = true;
                }
            }
            catch (Exception)
            {
                bl = false;
            }

            return bl;
        }


        /// <summary>
        /// 获取设备下拉框  （此方法不启用 liudl)
        /// </summary>
        /// <param name="PlcInfoId">工位ID</param>
        /// <returns></returns>
        public string GetAlarmInfoHtml(string PlcInfoId = "")
        {
            try
            {
                StringBuilder sb = new StringBuilder();
                string resMenuTemplate = "<option value='{0}' {1}>{2}</option>";
                sb.AppendFormat(resMenuTemplate, "", "", "选择");

                StringBuilder sqlString = new StringBuilder();
                sqlString.Append("select * from WCSIP where IsDel = 0;");
                DataTable dt = DataFactory.SqlDataBase().GetDataTableBySQL(sqlString);

                foreach (DataRow row in dt.Rows)
                {
                    sb.AppendFormat(resMenuTemplate, row["Id"].ToString(), row["Id"].ToString() == PlcInfoId ? "selected='selected'" :
                        string.Empty, row["Type"].ToString() + "-" + row["Text"].ToString());
                }

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


        /// <summary>
        /// 验证是否存在重复项
        /// </summary>
        /// <param name="sqlWhere">查询条件</param>
        /// <returns></returns>
        public bool IsExist(string sqlWhere)
        {
            return DataFactory.SqlDataBase().IsExist("WCSAlarmInfo", sqlWhere);
        }
        #endregion

        #region 报警日志
        /// <summary>
        /// 获取报警日志数据集合
        /// </summary>
        /// <param name="Json">查询条件</param>
        /// <param name="pageInfo">分页信息</param>
        /// <returns></returns>
        public IList<WCSAlarmInfo> GetAlarmLogList(AjaxAlarmInfoList Json, ref PageInfo pageInfo)
        {
            try
            {
                IList<WCSAlarmInfo> list = new List<WCSAlarmInfo>();
                StringBuilder sqlString = new StringBuilder();
                List<SqlParam> para = new List<SqlParam>();

                sqlString.Append("select tb1.*,tb2.RealName as CreateUserName ");
                sqlString.Append("from WCSAlarmLog as tb1 left join UserInfo as tb2 on tb1.CreateUser = tb2.ID ");
                sqlString.Append("where tb1.IsDel = 0 ");
                if (!string.IsNullOrWhiteSpace(Json.AlarmCode))
                {
                    sqlString.Append($"and tb1.AlarmCode like '%{Json.AlarmCode}%' ");
                }

                if (!string.IsNullOrWhiteSpace(Json.AlarmName))
                {
                    sqlString.Append($"and tb1.AlarmName like '%{Json.AlarmName}%' ");
                }

                if (!string.IsNullOrWhiteSpace(Json.BeAlarmTime))
                {
                    sqlString.Append($"and AlarmTime >= '{Json.BeAlarmTime}' ");
                }
                if (!string.IsNullOrWhiteSpace(Json.EnAlarmTime))
                {
                    sqlString.Append($"and AlarmTime <= '{Json.EnAlarmTime}' ");
                }

                DataTable dt = DataFactory.SqlDataBase().GetPageList(sqlString.ToString(), null, "CreateTime", "DESC", ref pageInfo);

                list = ModelConvertHelper<WCSAlarmInfo>.DataTableToModel(dt);

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