namespace Dao
{
    using Common;
    using Model;
    using Oracle.ManagedDataAccess.Client;
    using System;
    using System.Collections.Generic;
    using System.Runtime.InteropServices;
    using System.Text;

    public class GwApDao : IDisposable
    {
        public void Dispose()
        {
        }

        public GwAp Get(string apID)
        {
            GwAp o = new GwAp();
            if (!string.IsNullOrEmpty(apID) && !string.Equals("0", apID))
            {
                using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_ID", apID) }))
                {
                    if (reader.Read())
                    {
                        this.ReadInfo(reader, o);
                        return o;
                    }
                }
            }
            return o;
        }

        public bool IsApIDExits(string apID)
        {
            if (string.IsNullOrEmpty(apID) || string.Equals("0", apID))
            {
                return true;
            }
            using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_ID", apID) }))
            {
                while (reader.Read())
                {
                    return true;
                }
            }
            return false;
        }

        public bool IsNameEixsts(string apName, int apID)
        {
            if ((string.IsNullOrEmpty(apName) || string.Equals("0", apName)) || (apID == 0))
            {
                return true;
            }
            using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_NAME=:AP_NAME and AP_ID<>:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_ID", apID), new OracleParameter(":AP_NAME", apName) }))
            {
                while (reader.Read())
                {
                    return true;
                }
            }
            return false;
        }

        public bool IsPortExits(int port, int apID)
        {
            if ((port == 0) || (apID == 0))
            {
                return true;
            }
            using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_PORT=:AP_PORT and AP_ID<>:AP_ID", new object[0]), OracleHelper.Connection, new OracleParameter[] { new OracleParameter(":AP_PORT", port), new OracleParameter(":AP_ID", apID) }))
            {
                if (reader.Read())
                {
                    return true;
                }
            }
            return false;
        }

        public List<GwAp> LoadInfoList()
        {
            List<GwAp> list = new List<GwAp>();
            using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_AP", OracleHelper.Connection))
            {
                while (reader.Read())
                {
                    GwAp o = new GwAp();
                    if (this.ReadInfo(reader, o))
                    {
                        list.Add(o);
                    }
                }
            }
            return list;
        }

        public List<GwAp> LoadInfoList(out int recordCount, int pageSize, int pageIndex)
        {
            List<GwAp> list = new List<GwAp>();
            recordCount = 0;
            using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT count(*) as count FROM GW_AP", OracleHelper.Connection))
            {
                while (reader.Read())
                {
                    recordCount = this.ReadCount(reader);
                }
            }
            using (OracleDataReader reader2 = OracleHelper.ExecuteReader(PubConstant.doOracleSql(pageIndex, pageSize, recordCount, "SELECT * FROM GW_AP").ToString(), OracleHelper.Connection))
            {
                while (reader2.Read())
                {
                    GwAp o = new GwAp();
                    if (this.ReadInfo(reader2, o))
                    {
                        list.Add(o);
                    }
                }
            }
            return list;
        }

        public List<GwAp> LoadInfoList(string ApID, string ApName, string ApPort, out int recordcount, int pageSize, int PageIndex)
        {
            List<GwAp> list = new List<GwAp>();
            recordcount = 0;
            try
            {
                StringBuilder builder = new StringBuilder();
                builder.Append("from GW_AP where 1=1");
                OracleParameter[] cmdParms = new OracleParameter[3];
                if ((ApID != null) && (ApID != ""))
                {
                    cmdParms[0] = new OracleParameter(":ApID", 0x70);
                    cmdParms[0].Value = ApID;
                    builder.Append(" and AP_ID=:ApID");
                }
                if ((ApName != null) && (ApName != ""))
                {
                    cmdParms[1] = new OracleParameter(":ApName", 0x7e);
                    cmdParms[1].Value = ApName;
                    builder.Append(" and AP_NAME like '%'||:ApName||'%'");
                }
                if ((ApPort != null) && (ApPort != ""))
                {
                    cmdParms[2] = new OracleParameter(":ApPort", 0x70);
                    cmdParms[2].Value = ApPort;
                    builder.Append(" and AP_PORT=:ApPort");
                }
                using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + builder.ToString(), OracleHelper.Connection, cmdParms))
                {
                    while (reader.Read())
                    {
                        recordcount = this.ReadCount(reader);
                    }
                }
                using (OracleDataReader reader2 = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + builder.ToString()).ToString(), OracleHelper.Connection, cmdParms))
                {
                    while (reader2.Read())
                    {
                        GwAp o = new GwAp();
                        if (this.ReadInfo(reader2, o))
                        {
                            list.Add(o);
                        }
                    }
                }
            }
            catch (Exception exception)
            {
                LogHelper.Error(exception);
                return list;
            }
            return list;
        }

        private int ReadCount(OracleDataReader reader)
        {
            OracleReaderWrapper wrapper = new OracleReaderWrapper(reader);
            return wrapper.GetInt("count", 0);
        }

        private bool ReadInfo(OracleDataReader reader, GwAp o)
        {
            OracleReaderWrapper wrapper = new OracleReaderWrapper(reader);
            o.ApID = wrapper.GetInt("AP_ID", 0);
            o.ApName = wrapper.GetString("AP_NAME", "");
            o.ApPort = wrapper.GetInt("AP_PORT", 0);
            o.AccessCode = wrapper.GetString("ACCESS_CODE", "");
            o.CMSegments = wrapper.GetString("CM_SEGMENTS", "");
            o.CTSegments = wrapper.GetString("CT_SEGMENTS", "");
            o.UNSegments = wrapper.GetString("UN_SEGMENTS", "");
            o.AlarmData = wrapper.GetString("ALARM_SETTING", "");
            return true;
        }

        public bool Update(GwAp o)
        {
            OracleParameter[] cmdParms = new OracleParameter[] { new OracleParameter(":ApName", o.ApName), new OracleParameter(":ApPort", o.ApPort), new OracleParameter(":ApID", o.ApID), new OracleParameter(":ACCESS_CODE", o.AccessCode), new OracleParameter(":CM_SEGMENTS", o.CMSegments), new OracleParameter(":UN_SEGMENTS", o.UNSegments), new OracleParameter(":CT_SEGMENTS", o.CTSegments), new OracleParameter(":ALARM_SETTING", o.AlarmData) };
            string sql = "UPDATE GW_AP SET AP_NAME=:APNAME,AP_PORT=:APPORT,ACCESS_CODE=:ACCESS_CODE,CM_SEGMENTS=:CM_SEGMENTS,CT_SEGMENTS=:CT_SEGMENTS,UN_SEGMENTS=:UN_SEGMENTS,ALARM_SETTING=:ALARM_SETTING WHERE AP_ID=:APID";
            return (OracleHelper.ExecuteSql(sql, OracleHelper.Connection, cmdParms) > 0);
        }

        public bool UpdateSegments(GwAp o)
        {
            OracleParameter[] cmdParms = new OracleParameter[] { new OracleParameter(":CM_SEGMENTS", o.CMSegments), new OracleParameter(":UN_SEGMENTS", o.UNSegments), new OracleParameter(":CT_SEGMENTS", o.CTSegments) };
            string sql = "UPDATE GW_AP SET CM_SEGMENTS=:CM_SEGMENTS,CT_SEGMENTS=:CT_SEGMENTS,UN_SEGMENTS=:UN_SEGMENTS ";
            return (OracleHelper.ExecuteSql(sql, OracleHelper.Connection, cmdParms) > 0);
        }
    }
}




/*
using Common;
using Model;
using Oracle.ManagedDataAccess.Client;
using System;
using System.Collections.Generic;
using System.Data.Common;
using System.Text;

namespace Dao
{
  public class GwApDao : IDisposable
  {
    public List<GwAp> LoadInfoList(string ApID, string ApName, string ApPort, out int recordcount, int pageSize, int PageIndex)
    {
      List<GwAp> list = new List<GwAp>();
      recordcount = 0;
      try
      {
        StringBuilder stringBuilder = new StringBuilder();
        stringBuilder.Append("from GW_AP where 1=1");
        OracleParameter[] oracleParameterArray = new OracleParameter[3];
        if (ApID != null && ApID != "")
        {
          oracleParameterArray[0] = new OracleParameter(":ApID", (OracleDbType) 112);
          ((DbParameter) oracleParameterArray[0]).Value = (object) ApID;
          stringBuilder.Append(" and AP_ID=:ApID");
        }
        if (ApName != null && ApName != "")
        {
          oracleParameterArray[1] = new OracleParameter(":ApName", (OracleDbType) 126);
          ((DbParameter) oracleParameterArray[1]).Value = (object) ApName;
          stringBuilder.Append(" and AP_NAME like '%'||:ApName||'%'");
        }
        if (ApPort != null && ApPort != "")
        {
          oracleParameterArray[2] = new OracleParameter(":ApPort", (OracleDbType) 112);
          ((DbParameter) oracleParameterArray[2]).Value = (object) ApPort;
          stringBuilder.Append(" and AP_PORT=:ApPort");
        }
        using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray))
        {
          while (((DbDataReader) reader).Read())
            recordcount = this.ReadCount(reader);
        }
        using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + stringBuilder.ToString()).ToString(), OracleHelper.Connection, oracleParameterArray))
        {
          while (((DbDataReader) reader).Read())
          {
            GwAp o = new GwAp();
            if (this.ReadInfo(reader, o))
              list.Add(o);
          }
        }
      }
      catch (Exception ex)
      {
        LogHelper.Error(ex);
        return list;
      }
      return list;
    }

    public List<GwAp> LoadInfoList()
    {
      List<GwAp> list = new List<GwAp>();
      using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_AP", OracleHelper.Connection))
      {
        while (((DbDataReader) reader).Read())
        {
          GwAp o = new GwAp();
          if (this.ReadInfo(reader, o))
            list.Add(o);
        }
      }
      return list;
    }

    public bool Update(GwAp o)
    {
      return OracleHelper.ExecuteSql("UPDATE GW_AP SET AP_NAME=:APNAME,AP_PORT=:APPORT,ACCESS_CODE=:ACCESS_CODE,CM_SEGMENTS=:CM_SEGMENTS,CT_SEGMENTS=:CT_SEGMENTS,UN_SEGMENTS=:UN_SEGMENTS,ALARM_SETTING=:ALARM_SETTING WHERE AP_ID=:APID", OracleHelper.Connection, new OracleParameter(":ApName", (object) o.ApName), new OracleParameter(":ApPort", (object) o.ApPort), new OracleParameter(":ApID", (object) o.ApID), new OracleParameter(":ACCESS_CODE", (object) o.AccessCode), new OracleParameter(":CM_SEGMENTS", (object) o.CMSegments), new OracleParameter(":UN_SEGMENTS", (object) o.UNSegments), new OracleParameter(":CT_SEGMENTS", (object) o.CTSegments), new OracleParameter(":ALARM_SETTING", (object) o.AlarmData)) > 0;
    }

    public GwAp Get(string apID)
    {
      GwAp o = new GwAp();
      if (string.IsNullOrEmpty(apID) || string.Equals("0", apID))
        return o;
      using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_ID", (object) apID)))
      {
        if (((DbDataReader) reader).Read())
        {
          this.ReadInfo(reader, o);
          return o;
        }
      }
      return o;
    }

    public bool IsApIDExits(string apID)
    {
      if (string.IsNullOrEmpty(apID) || string.Equals("0", apID))
        return true;
      using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_ID=:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_ID", (object) apID)))
      {
        if (((DbDataReader) oracleDataReader).Read())
          return true;
      }
      return false;
    }

    public bool IsNameEixsts(string apName, int apID)
    {
      if (string.IsNullOrEmpty(apName) || string.Equals("0", apName) || apID == 0)
        return true;
      using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_NAME=:AP_NAME and AP_ID<>:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_ID", (object) apID), new OracleParameter(":AP_NAME", (object) apName)))
      {
        if (((DbDataReader) oracleDataReader).Read())
          return true;
      }
      return false;
    }

    public bool IsPortExits(int port, int apID)
    {
      if (port == 0 || apID == 0)
        return true;
      using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_AP where AP_PORT=:AP_PORT and AP_ID<>:AP_ID"), OracleHelper.Connection, new OracleParameter(":AP_PORT", (object) port), new OracleParameter(":AP_ID", (object) apID)))
      {
        if (((DbDataReader) oracleDataReader).Read())
          return true;
      }
      return false;
    }

    private bool ReadInfo(OracleDataReader reader, GwAp o)
    {
      OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
      o.ApID = oracleReaderWrapper.GetInt("AP_ID", 0);
      o.ApName = oracleReaderWrapper.GetString("AP_NAME", "");
      o.ApPort = oracleReaderWrapper.GetInt("AP_PORT", 0);
      o.AccessCode = oracleReaderWrapper.GetString("ACCESS_CODE", "");
      o.CMSegments = oracleReaderWrapper.GetString("CM_SEGMENTS", "");
      o.CTSegments = oracleReaderWrapper.GetString("CT_SEGMENTS", "");
      o.UNSegments = oracleReaderWrapper.GetString("UN_SEGMENTS", "");
      o.AlarmData = oracleReaderWrapper.GetString("ALARM_SETTING", "");
      return true;
    }

    private int ReadCount(OracleDataReader reader)
    {
      return new OracleReaderWrapper(reader).GetInt("count", 0);
    }

    public void Dispose()
    {
    }
  }
}
*/