using System;
using System.Collections.Generic;
using System.Data;
using System.Linq;
using System.Text;
using System.Threading.Tasks;
using Module.DB.Model;
using Module.DB.DBUtility;
namespace Module.DB.SQLServerDAL
{
    /// <summary>
    /// 热板2配方数据表操作类
    /// </summary>
    public class SRPHp2Info
    {
        /// <summary>
        /// 添加热板2配方信息
        /// </summary>
        /// <param name="hp2RecipeInfo"></param>
        /// <returns></returns>
        public bool AddRPHp2Info(MRPHp2Info hp2RecipeInfo)
        {
            try
            {
                bool bRes = false;

                #region 数据更新操作字符串

                string strResult = SQLHelper.GetInsertSQL<MRPHp2Info>("t_rp_hp2_info", hp2RecipeInfo, "f_id");
                SQLServerHelper sHelper = new SQLServerHelper();
                int iRes = sHelper.ExecuteNonQuerySQL(strResult);

                #endregion 数据更新操作字符串

                if (iRes != 0)
                {
                    bRes = true;
                }

                return bRes;
            }
            catch (Exception ex)
            {
                ex.ToString();
                return false;
            }
        }

        /// <summary>
        /// 编辑热板1配方信息
        /// </summary>
        /// <param name="hp2RecipeInfo"></param>
        /// <returns></returns>
        public bool EditRPHp2Info(MRPHp2Info hp2RecipeInfo)
        {
            try
            {
                bool bRes = false;

                #region 数据更新操作字符串

                string strSql = "UPDATE t_rp_hp2_info SET ";
                strSql += " " + "f_hp2_plc_no='" + hp2RecipeInfo.f_hp2_plc_no + "',";
                strSql += " " + "f_hp2_temp='" + hp2RecipeInfo.f_hp2_temp + "',";
                strSql += " " + "f_hp2_interval='" + hp2RecipeInfo.f_hp2_interval + "',";
                strSql += " " + "f_hp2_time_num='" + hp2RecipeInfo.f_hp2_time_num + "',";
                strSql += " " + "f_hp2_n2='" + hp2RecipeInfo.f_hp2_n2 + "',";
                strSql += " " + "f_hp2_n2_time='" + hp2RecipeInfo.f_hp2_n2_time + "',";
                strSql += " " + "f_modify_time='" + hp2RecipeInfo.f_modify_time + "'";
                strSql += " " + "WHERE f_id='" + hp2RecipeInfo.f_id + "'";

                SQLServerHelper sHelper = new SQLServerHelper();
                int iRes = sHelper.ExecuteNonQuerySQL(strSql);

                #endregion 数据更新操作字符串

                if (iRes != 0)
                {
                    bRes = true;
                }

                return bRes;
            }
            catch (Exception ex)
            {
                ex.ToString();
                return false;
            }
        }

        /// <summary>
        /// 删除热板2配方信息
        /// </summary>
        /// <param name="hp2RepNo">热板2配方号</param>
        public void DeleteRPHp2Info(string hp2RepNo, int trackNo)
        {
            try
            {
                string strSql = "";
                strSql += "DELETE FROM t_rp_hp2_info" + " ";
                strSql += "WHERE f_hp2_rep_no collate Chinese_PRC_CS_AS_WS ='" + hp2RepNo + "'" + " ";
                strSql += "AND f_track_no ='" + trackNo + "'" + " ";

                SQLServerHelper sHelper = new SQLServerHelper();
                sHelper.ExecuteNonQuerySQL(strSql);
            }
            catch (Exception ex)
            {
                ex.ToString();
            }
        }

        /// <summary>
        /// 根据热板1配方号查找的热板1配方信息
        /// </summary>
        /// <param name="hp2PlcNo">热板1下发配方号</param>
        /// <returns>热板1配方信息</returns>
        public List<MRPHp2Info> GetRPHp2Info(string hp2PlcNo)
        {
            List<MRPHp2Info> lstRpHp2Info = null;
            try
            {
                string strSql = "";
                strSql += "SELECT * FROM t_rp_hp2_info" + " ";
                strSql += "WHERE f_hp2_plc_no ='" + hp2PlcNo + "'" + " ";
                strSql += "ORDER BY f_id ASC";

                SQLServerHelper sHelper = new SQLServerHelper();
                DataTable dtResult = sHelper.QuerySql(strSql);
                int rownum = dtResult.Rows.Count;
                if (rownum > 0)
                {
                    lstRpHp2Info = new List<MRPHp2Info>();
                    for (int i = 0; i < rownum; i++)
                    {
                        MRPHp2Info rpHp2Info = new MRPHp2Info();
                        object objID = dtResult.Rows[i]["f_id"];
                        rpHp2Info.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
                        rpHp2Info.f_hp2_rep_no = dtResult.Rows[i]["f_hp2_rep_no"] == null ? "" : dtResult.Rows[i]["f_hp2_rep_no"].ToString().Trim();

                        object objHp2PlcNo = dtResult.Rows[i]["f_hp2_plc_no"];
                        rpHp2Info.f_hp2_plc_no = (objHp2PlcNo == null || objHp2PlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2PlcNo);

                        object objTrackNo = dtResult.Rows[0]["f_track_no"];
                        rpHp2Info.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);

                        object objHp2Temp = dtResult.Rows[i]["f_hp2_temp"];
                        rpHp2Info.f_hp2_temp = (objHp2Temp == null || objHp2Temp.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2Temp);

                        object objHp2SeqNo = dtResult.Rows[i]["f_hp2_seq_no"];
                        rpHp2Info.f_hp2_seq_no = (objHp2SeqNo == null || objHp2SeqNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2SeqNo);

                        object objHp2Interval = dtResult.Rows[i]["f_hp2_interval"];
                        rpHp2Info.f_hp2_interval = (objHp2Interval == null || objHp2Interval.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2Interval);

                        object objHp2TimeNum = dtResult.Rows[i]["f_hp2_time_num"];
                        rpHp2Info.f_hp2_time_num = (objHp2TimeNum == null || objHp2TimeNum.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2TimeNum);

                        object objHp2N2 = dtResult.Rows[i]["f_hp2_n2"];
                        rpHp2Info.f_hp2_n2 = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2N2);

                        object objHp2N2Time = dtResult.Rows[i]["f_hp2_n2_time"];
                        rpHp2Info.f_hp2_n2_time = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2N2Time);

                        rpHp2Info.f_creator = dtResult.Rows[i]["f_creator"].ToString();
                        object objCreationDate = dtResult.Rows[i]["f_create_time"];
                        rpHp2Info.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);

                        object objModifyDate = dtResult.Rows[i]["f_modify_time"];
                        rpHp2Info.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);

                        lstRpHp2Info.Add(rpHp2Info);
                    }
                }
            }
            catch (Exception ex)
            {
                ex.ToString();
            }
            return lstRpHp2Info;
        }

        public List<MRPHp2Info> GetRPHp2InfoByRepNo(string hp2RepNo, int trackNo)
        {
            List<MRPHp2Info> lstRpHp2Info = null;
            try
            {
                string strSql = "";
                strSql += "SELECT * FROM t_rp_hp2_info" + " ";
                strSql += "WHERE f_hp2_rep_no collate Chinese_PRC_CS_AS ='" + hp2RepNo + "'" + " ";
                strSql += "AND f_track_no ='" + trackNo + "'" + " ";
                strSql += "ORDER BY f_id ASC";

                SQLServerHelper sHelper = new SQLServerHelper();
                DataTable dtResult = sHelper.QuerySql(strSql);
                int rownum = dtResult.Rows.Count;
                if (rownum > 0)
                {
                    lstRpHp2Info = new List<MRPHp2Info>();
                    for (int i = 0; i < rownum; i++)
                    {
                        MRPHp2Info rpHp2Info = new MRPHp2Info();
                        object objID = dtResult.Rows[i]["f_id"];
                        rpHp2Info.f_id = (objID == null || objID.ToString().Trim() == "") ? 0 : Convert.ToInt32(objID);
                        rpHp2Info.f_hp2_rep_no = dtResult.Rows[i]["f_hp2_rep_no"] == null ? "" : dtResult.Rows[i]["f_hp2_rep_no"].ToString().Trim();

                        object objTrackNo = dtResult.Rows[0]["f_track_no"];
                        rpHp2Info.f_track_no = (objTrackNo == null || objTrackNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objTrackNo);

                        object objHp2PlcNo = dtResult.Rows[i]["f_hp2_plc_no"];
                        rpHp2Info.f_hp2_plc_no = (objHp2PlcNo == null || objHp2PlcNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2PlcNo);

                        object objHp2Temp = dtResult.Rows[i]["f_hp2_temp"];
                        rpHp2Info.f_hp2_temp = (objHp2Temp == null || objHp2Temp.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2Temp);

                        object objHp2SeqNo = dtResult.Rows[i]["f_hp2_seq_no"];
                        rpHp2Info.f_hp2_seq_no = (objHp2SeqNo == null || objHp2SeqNo.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2SeqNo);

                        object objHp2Interval = dtResult.Rows[i]["f_hp2_interval"];
                        rpHp2Info.f_hp2_interval = (objHp2Interval == null || objHp2Interval.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2Interval);

                        object objHp2TimeNum = dtResult.Rows[i]["f_hp2_time_num"];
                        rpHp2Info.f_hp2_time_num = (objHp2TimeNum == null || objHp2TimeNum.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2TimeNum);

                        object objHp2N2 = dtResult.Rows[i]["f_hp2_n2"];
                        rpHp2Info.f_hp2_n2 = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToInt32(objHp2N2);

                        object objHp2N2Time = dtResult.Rows[i]["f_hp2_n2_time"];
                        rpHp2Info.f_hp2_n2_time = (objHp2N2 == null || objHp2N2.ToString().Trim() == "") ? 0 : Convert.ToDecimal(objHp2N2Time);

                        rpHp2Info.f_creator = dtResult.Rows[i]["f_creator"].ToString();
                        object objCreationDate = dtResult.Rows[i]["f_create_time"];
                        rpHp2Info.f_create_time = (objCreationDate == null || objCreationDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objCreationDate);

                        object objModifyDate = dtResult.Rows[i]["f_modify_time"];
                        rpHp2Info.f_modify_time = (objModifyDate == null || objModifyDate.ToString() == "") ? Convert.ToDateTime("1800-1-1") : Convert.ToDateTime(objModifyDate);

                        lstRpHp2Info.Add(rpHp2Info);
                    }
                }
            }
            catch (Exception ex)
            {
                ex.ToString();
            }
            return lstRpHp2Info;
        }

        /// <summary>
        /// 判断数据表是否存在该下发的PLC配方号
        /// </summary>
        /// <param name="hp2PlcNo">热板1下发配方号</param>
        /// <returns>是否存在该下发的PLC配方号</returns>
        public bool ExistHp2PlcNo(string hp2PlcNo)
        {
            try
            {
                bool bRes = false;

                #region  数据查询是否存在

                string strSql = "SELECT * FROM t_rp_hp2_info  ";
                strSql += " " + "WHERE f_hp2_plc_no='" + hp2PlcNo + "'";

                SQLServerHelper sHelper = new SQLServerHelper();
                DataTable dtResult = sHelper.QuerySql(strSql);
                int rownum = dtResult.Rows.Count;

                if (rownum > 0)
                {
                    bRes = true;
                }

                #endregion 数据查询是否存在

                return bRes;
            }
            catch (Exception ex)
            {
                ex.ToString();
                return false;
            }
        }

        public bool ExistHp2RepNo(string hp2RepNo, int trackNo)
        {
            try
            {
                bool bRes = false;

                #region  数据查询是否存在

                string strSql = "SELECT * FROM t_rp_hp2_info  ";
                strSql += " " + "WHERE f_hp2_rep_no collate Chinese_PRC_CS_AS ='" + hp2RepNo + "'";
                strSql += " " + "AND f_track_no ='" + trackNo + "'" + " ";

                SQLServerHelper sHelper = new SQLServerHelper();
                DataTable dtResult = sHelper.QuerySql(strSql);
                int rownum = dtResult.Rows.Count;

                if (rownum > 0)
                {
                    bRes = true;
                }

                #endregion 数据查询是否存在

                return bRes;
            }
            catch (Exception ex)
            {
                ex.ToString();
                return false;
            }
        }


        /// <summary>
        /// 获取所有的配方号
        /// </summary>
        /// <returns></returns>
        public List<string> GetAllRecpieRepNo(int trackNo)
        {
            var list = new List<string>() { "请选择" };
            string strSql = "SELECT distinct(f_hp2_rep_no collate Chinese_PRC_CS_AS_WS) FROM t_rp_hp2_info";
            strSql += " " + "WHERE f_track_no ='" + trackNo + "'" + " ";
            strSql += " " + "ORDER BY f_hp2_rep_no collate Chinese_PRC_CS_AS_WS ASC";

            SQLServerHelper sHelper = new SQLServerHelper();
            var dataset = sHelper.QuerySqlDataset(strSql);

            if (dataset.Tables.Count == 0 || dataset.Tables[0].Rows.Count == 0)
            {
                return list;
            }

            for (int i = 0; i < dataset.Tables[0].Rows.Count; i++)
            {
                list.Add(dataset.Tables[0].Rows[i][0].ToString());
            }

            return list;
        }

        public List<Hp2InfoModel> GetList()
        {
            try
            {
                var list = new List<Hp2InfoModel>();
                string strSql = "SELECT * FROM t_rp_hp2_info ORDER BY f_id ASC ";

                SQLServerHelper sHelper = new SQLServerHelper();

                DataTable dtResult = sHelper.QuerySql(strSql);
                int rownum = dtResult.Rows.Count;
                if (rownum > 0)
                {
                    for (var i = 0; i < rownum; i++)
                    {
                        var hp2Info = new Hp2InfoModel();
                        var temp = dtResult.Rows[i];

                        hp2Info.f_hp2_rep_no = temp["f_hp2_rep_no"].ToString();
                        hp2Info.f_hp2_temp = Convert.ToDecimal(temp["f_hp2_temp"]);
                        hp2Info.f_hp2_n2_time = Convert.ToDecimal(temp["f_hp2_n2_time"]);
                        hp2Info.f_hp2_n2 = Convert.ToInt32(temp["f_hp2_n2"]);
                        hp2Info.f_hp2_seq_no = Convert.ToInt32(temp["f_hp2_seq_no"]);
                        hp2Info.f_hp2_interval = Convert.ToDecimal(temp["f_hp2_interval"]);
                        hp2Info.f_hp2_time_num = Convert.ToDecimal(temp["f_hp2_time_num"]);

                        list.Add(hp2Info);
                    }
                }

                return list;
            }
            catch (Exception ex)
            {
                ex.ToString();
                return new List<Hp2InfoModel>();
            }
        }
    }
}