using Common;
using Oracle.DataAccess.Client;
using System;
using System.Collections.Generic;
using System.Data.Common;

namespace Dao
{
    public class GwDiverterDao : IDisposable
    {
        public List<GwDiverter> LoadList()
        {
            List<GwDiverter> list = new List<GwDiverter>();
            try
            {
                using (OracleDataReader reader = OracleHelper.ExecuteReader("select * from GW_Diverter order by Diverter_id desc ", OracleHelper.Connection))
                {
                    while (((DbDataReader)reader).Read())
                    {
                        GwDiverter diverter = new GwDiverter();
                        if (this.ReadInfo(reader, diverter))
                            list.Add(diverter);
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return list;
            }
            return list;
        }

        public List<GwDiverterItem> LoadItemList(string diverterID)
        {
            List<GwDiverterItem> list = new List<GwDiverterItem>();
            try
            {
                using (OracleDataReader reader = OracleHelper.ExecuteReader("select * from GW_DIVERTER_ITEM WHERE DIVERTER_ID=:DIVERTER_ID", OracleHelper.Connection, new OracleParameter(":DIVERTER_ID", (object)diverterID)))
                {
                    while (((DbDataReader)reader).Read())
                    {
                        GwDiverterItem diverterItem = new GwDiverterItem();
                        if (this.ReadInfoItem(reader, diverterItem))
                            list.Add(diverterItem);
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return list;
            }
            return list;
        }

        private bool ReadInfo(OracleDataReader reader, GwDiverter diverter)
        {
            OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
            diverter.DiverterID = oracleReaderWrapper.GetInt("DIVERTER_ID", 0);
            diverter.DiverterName = oracleReaderWrapper.GetString("DIVERTER_NAME", string.Empty);
            diverter.Content = oracleReaderWrapper.GetString("CONTENT", "");
            return true;
        }

        private bool ReadInfoItem(OracleDataReader reader, GwDiverterItem diverterItem)
        {
            OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
            diverterItem.Mode = oracleReaderWrapper.GetInt("DMODE", 0);
            diverterItem.Keywords = oracleReaderWrapper.GetString("KEYWORDS", string.Empty);
            diverterItem.SmMaxLength = oracleReaderWrapper.GetInt("SM_MAX_LENGTH", 0);
            diverterItem.SmMinLength = oracleReaderWrapper.GetInt("SM_MIN_LENGTH", 0);
            diverterItem.Segments = oracleReaderWrapper.GetString("SEGMENTS", string.Empty);
            diverterItem.ExtNoMode = oracleReaderWrapper.GetString("EXTNO_MODE", string.Empty);
            diverterItem.Province = oracleReaderWrapper.GetString("PROVINCE", string.Empty);
            diverterItem.CMOPID = oracleReaderWrapper.GetInt("CM_OP_ID", 0);
            diverterItem.CUOPID = oracleReaderWrapper.GetInt("CU_OP_ID", 0);
            diverterItem.CTOPID = oracleReaderWrapper.GetInt("CT_OP_ID", 0);
            diverterItem.CMExtNo = oracleReaderWrapper.GetString("CM_EXT_NO", "");
            diverterItem.CUExtNo = oracleReaderWrapper.GetString("CU_EXT_NO", "");
            diverterItem.CTExtNo = oracleReaderWrapper.GetString("CT_EXT_NO", "");
            diverterItem.CMExtParams = oracleReaderWrapper.GetString("CM_EXT_PARAMS", "");
            diverterItem.CTExtParams = oracleReaderWrapper.GetString("CU_EXT_PARAMS", "");
            diverterItem.CUExtParams = oracleReaderWrapper.GetString("CT_EXT_PARAMS", "");
            return true;
        }

        public void Dispose()
        {
        }

        public GwDiverter GetEntity(string diverterID)
        {
            try
            {
                using (OracleDataReader reader = OracleHelper.ExecuteReader("select * from GW_Diverter WHERE DIVERTER_ID=:DIVERTER_ID", OracleHelper.Connection, new OracleParameter(":DIVERTER_ID", (object)diverterID)))
                {
                    while (((DbDataReader)reader).Read())
                    {
                        GwDiverter diverter = new GwDiverter();
                        if (this.ReadInfo(reader, diverter))
                            return diverter;
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
            }
            return (GwDiverter)null;
        }

        public bool Exists(int diverterID, string diverterName)
        {
            return Convert.ToInt32(OracleHelper.ExecuteScalar("SELECT COUNT(*) FROM GW_DIVERTER WHERE DIVERTER_ID<>:DIVERTER_ID AND DIVERTER_NAME=:DIVERTER_NAME", OracleHelper.Connection, new OracleParameter(":DIVERTER_ID", (object)diverterID), new OracleParameter(":DIVERTER_NAME", (object)diverterName))) > 0;
        }

        public bool UpdateInfo(GwDiverter diverter, List<GwDiverterItem> items)
        {
            List<KeyValuePair<string, OracleParameter[]>> list = new List<KeyValuePair<string, OracleParameter[]>>();
            if (diverter.DiverterID == 0)
            {
                diverter.DiverterID = Convert.ToInt32(OracleHelper.ExecuteScalar("SELECT GW_DIVERTER_SEQ.NEXTVAL FROM DUAL", OracleHelper.Connection));
                string key = " INSERT INTO GW_DIVERTER(DIVERTER_ID,DIVERTER_NAME,CONTENT,CREATE_TIME) VALUES(:DIVERTER_ID,:DIVERTER_NAME,:CONTENT,SYSDATE)";
                OracleParameter[] oracleParameterArray = new OracleParameter[3]
        {
          new OracleParameter(":DIVERTER_ID", (object) diverter.DiverterID),
          new OracleParameter(":DIVERTER_NAME", (object) diverter.DiverterName),
          new OracleParameter(":CONTENT", (object) diverter.Content)
        };
                list.Add(new KeyValuePair<string, OracleParameter[]>(key, oracleParameterArray));
            }
            else
            {
                string key = "UPDATE GW_DIVERTER SET DIVERTER_NAME=:DIVERTER_NAME,CONTENT=:CONTENT WHERE DIVERTER_ID=:DIVERTER_ID";
                OracleParameter[] oracleParameterArray = new OracleParameter[3]
        {
          new OracleParameter(":DIVERTER_NAME", (object) diverter.DiverterName),
          new OracleParameter(":CONTENT", (object) diverter.Content),
          new OracleParameter(":DIVERTER_ID", (object) diverter.DiverterID)
        };
                list.Add(new KeyValuePair<string, OracleParameter[]>(key, oracleParameterArray));
            }
            string key1 = "DELETE FROM GW_DIVERTER_ITEM WHERE DIVERTER_ID=:DIVERTER_ID";
            OracleParameter[] oracleParameterArray1 = new OracleParameter[1]
      {
        new OracleParameter(":DIVERTER_ID", (object) diverter.DiverterID)
      };
            list.Add(new KeyValuePair<string, OracleParameter[]>(key1, oracleParameterArray1));
            string key2 = "INSERT INTO GW_DIVERTER_ITEM(ITEM_ID, DIVERTER_ID, CM_OP_ID, CU_OP_ID, CT_OP_ID, CM_EXT_NO, CU_EXT_NO, CT_EXT_NO, CM_EXT_PARAMS, CU_EXT_PARAMS, CT_EXT_PARAMS, DMODE, SM_MAX_LENGTH, SM_MIN_LENGTH, SEGMENTS, KEYWORDS,PROVINCE,EXTNO_MODE) VALUES(GW_DIVERTER_ITEM_ID_SEQ.NEXTVAL, :DIVERTER_ID, :CM_OP_ID, :CU_OP_ID, :CT_OP_ID, :CM_EXT_NO, :CU_EXT_NO, :CT_EXT_NO, :CM_EXT_PARAMS, :CU_EXT_PARAMS, :CT_EXT_PARAMS, :DMODE, :SM_MAX_LENGTH, :SM_MIN_LENGTH, :SEGMENTS, :KEYWORDS,:PROVINCE,:EXTNO_MODE)";
            foreach (GwDiverterItem gwDiverterItem in items)
            {
                OracleParameter[] oracleParameterArray2 = new OracleParameter[17]
        {
          new OracleParameter(":DIVERTER_ID", (object) diverter.DiverterID),
          new OracleParameter(":CM_OP_ID", (object) gwDiverterItem.CMOPID),
          new OracleParameter(":CU_OP_ID", (object) gwDiverterItem.CUOPID),
          new OracleParameter(":CT_OP_ID", (object) gwDiverterItem.CTOPID),
          new OracleParameter(":CM_EXT_NO", (object) gwDiverterItem.CMExtNo),
          new OracleParameter(":CU_EXT_NO", (object) gwDiverterItem.CUExtNo),
          new OracleParameter(":CT_EXT_NO", (object) gwDiverterItem.CTExtNo),
          new OracleParameter(":CM_EXT_PARAMS", (object) gwDiverterItem.CMExtParams),
          new OracleParameter(":CU_EXT_PARAMS", (object) gwDiverterItem.CUExtParams),
          new OracleParameter(":CT_EXT_PARAMS", (object) gwDiverterItem.CTExtParams),
          new OracleParameter(":DMODE", (object) gwDiverterItem.Mode),
          new OracleParameter(":SM_MIN_LENGTH", (object) gwDiverterItem.SmMinLength),
          new OracleParameter(":SM_MAX_LENGTH", (object) gwDiverterItem.SmMaxLength),
          new OracleParameter(":SEGMENTS", (object) gwDiverterItem.Segments),
          new OracleParameter(":KEYWORDS", (object) gwDiverterItem.Keywords),
          new OracleParameter(":PROVINCE", (object) gwDiverterItem.Province),
          new OracleParameter(":EXTNO_MODE", (object) gwDiverterItem.ExtNoMode)
        };
                list.Add(new KeyValuePair<string, OracleParameter[]>(key2, oracleParameterArray2));
            }
            OracleHelper.ExecuteSqlTran(list, OracleHelper.Connection);
            return true;
        }

        public bool AddNew(GwDiverter diverter)
        {
            return OracleHelper.ExecuteSql("INSERT INTO GW_DIVERTER(DIVERTER_NAME,CONTENT,DIVERTER_ID) VALUES(:DIVERTER_NAME,:CONTENT,GW_DIVERTER_SEQ.NEXTVAL)", OracleHelper.Connection, new OracleParameter(":DIVERTER_NAME", (object)diverter.DiverterName), new OracleParameter(":CONTENT", (object)diverter.Content)) > 0;
        }

        public bool Delete(string diverterID)
        {
            return OracleHelper.ExecuteSql("DELETE FROM GW_DIVERTER WHERE DIVERTER_ID=:DIVERTER_ID", OracleHelper.Connection, new OracleParameter(":DIVERTER_ID", (object)diverterID)) > 0;
        }
    }
}