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

namespace Dao
{
    public class GwStrategyDao : IDisposable
    {
        public List<GwStrategy> LoadInfoList(string StrategyId, string StrategyName, out int recordcount, int pageSize, int PageIndex)
        {
            List<GwStrategy> list = new List<GwStrategy>();
            recordcount = 0;
            try
            {
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("from GW_STRATEGY where 1=1");
                OracleParameter[] oracleParameterArray = new OracleParameter[2];
                if (StrategyId != null && StrategyId != "")
                {
                    oracleParameterArray[0] = new OracleParameter(":StrategyId", (OracleDbType)112);
                    ((DbParameter)oracleParameterArray[0]).Value = (object)StrategyId;
                    stringBuilder.Append(" and STRATEGY_ID=:StrategyId");
                }
                if (StrategyName != null && StrategyName != "")
                {
                    oracleParameterArray[1] = new OracleParameter(":StrategyName", (OracleDbType)126);
                    ((DbParameter)oracleParameterArray[1]).Value = (object)StrategyName;
                    stringBuilder.Append(" and STRATEGY_NAME like '%'||:StrategyName||'%'");
                }
                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())
                    {
                        GwStrategy o = new GwStrategy();
                        if (this.ReadInfo(reader, o))
                            list.Add(o);
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return list;
            }
            return list;
        }

        public List<GwStrategy> LoadInfoList(string StrategyId, string StrategyName)
        {
            List<GwStrategy> list = new List<GwStrategy>();
            try
            {
                StringBuilder stringBuilder = new StringBuilder();
                stringBuilder.Append("from GW_STRATEGY where 1=1");
                OracleParameter[] oracleParameterArray = new OracleParameter[2];
                if (StrategyId != null && StrategyId != "")
                {
                    oracleParameterArray[0] = new OracleParameter(":StrategyId", (OracleDbType)112);
                    ((DbParameter)oracleParameterArray[0]).Value = (object)StrategyId;
                    stringBuilder.Append(" and STRATEGY_ID=:StrategyId");
                }
                if (StrategyName != null && StrategyName != "")
                {
                    oracleParameterArray[1] = new OracleParameter(":StrategyName", (OracleDbType)126);
                    ((DbParameter)oracleParameterArray[1]).Value = (object)StrategyName;
                    stringBuilder.Append(" and STRATEGY_NAME like '%'||:StrategyName||'%'");
                }
                using (OracleDataReader reader = OracleHelper.ExecuteReader("select * " + stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray))
                {
                    while (((DbDataReader)reader).Read())
                    {
                        GwStrategy o = new GwStrategy();
                        if (this.ReadInfo(reader, o))
                            list.Add(o);
                    }
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return list;
            }
            return list;
        }

        public bool UpdateInfo(GwStrategy o)
        {
            return OracleHelper.ExecuteSql("update GW_STRATEGY set STRATEGY_NAME=:StrategyName,WORD_LIST=:WordList,PATTERN_LIST=:PatternList where STRATEGY_ID=:StrategyId", OracleHelper.Connection, new OracleParameter(":StrategyName", (object)o.StrategyName), new OracleParameter(":WordList", (OracleDbType)105, (object)o.WordList, ParameterDirection.Input), new OracleParameter(":PatternList", (object)o.PatternList), new OracleParameter(":StrategyId", (object)o.StrategyId)) > 0;
        }

        public bool InsertInfo(GwStrategy o)
        {
            return OracleHelper.ExecuteSql("insert into GW_STRATEGY(STRATEGY_ID,STRATEGY_NAME,WORD_LIST,PATTERN_LIST) values(GW_STRATEGY_SEQ.nextval,:StrategyName,:WordList,:PatternList)", OracleHelper.Connection, new OracleParameter(":StrategyName", (object)o.StrategyName), new OracleParameter(":WordList", (OracleDbType)105, (object)o.WordList, ParameterDirection.Input), new OracleParameter(":PatternList", (object)o.PatternList)) > 0;
        }

        public GwStrategy getObjById(string StrategyId)
        {
            GwStrategy o = new GwStrategy();
            if (string.IsNullOrEmpty(StrategyId))
                return o;
            using (OracleDataReader reader = OracleHelper.ExecuteReader("select * from GW_STRATEGY where STRATEGY_ID=:STRATEGY_ID", OracleHelper.Connection, new OracleParameter(":STRATEGY_ID", (object)StrategyId)))
            {
                if (((DbDataReader)reader).Read())
                {
                    if (!this.ReadInfo(reader, o))
                        throw new Exception("读取策略出错！");
                    return o;
                }
            }
            return o;
        }

        public bool hasId(string StrategyId)
        {
            if (string.IsNullOrEmpty(StrategyId) || string.Equals("0", StrategyId))
                return true;
            try
            {
                using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_STRATEGY where STRATEGY_ID='{0}'", (object)StrategyId), OracleHelper.Connection))
                {
                    if (((DbDataReader)oracleDataReader).Read())
                        return true;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return false;
            }
            return false;
        }

        public bool hasName(string StrategyName, string StrategyId)
        {
            if (string.IsNullOrEmpty(StrategyName) || string.Equals("0", StrategyName) || string.IsNullOrEmpty(StrategyId))
                return true;
            try
            {
                using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_STRATEGY where STRATEGY_NAME='{0}' and STRATEGY_ID<>'{1}'", (object)StrategyName, (object)StrategyId), OracleHelper.Connection))
                {
                    if (((DbDataReader)oracleDataReader).Read())
                        return true;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return false;
            }
            return false;
        }

        public bool hasName(string StrategyName)
        {
            if (string.IsNullOrEmpty(StrategyName) || string.Equals("0", StrategyName))
                return true;
            try
            {
                using (OracleDataReader oracleDataReader = OracleHelper.ExecuteReader(string.Format("select * from GW_STRATEGY where STRATEGY_NAME='{0}'", (object)StrategyName), OracleHelper.Connection))
                {
                    if (((DbDataReader)oracleDataReader).Read())
                        return true;
                }
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return false;
            }
            return false;
        }

        public bool delById(string StrategyId)
        {
            if (string.IsNullOrEmpty(StrategyId) || string.Equals("0", StrategyId))
                return false;
            try
            {
                return OracleHelper.ExecuteSql(string.Format("delete from GW_STRATEGY where STRATEGY_ID='{0}'", (object)StrategyId), OracleHelper.Connection) > 0;
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return false;
            }
        }

        private bool ReadInfo(OracleDataReader reader, GwStrategy o)
        {
            OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
            o.StrategyId = oracleReaderWrapper.GetInt("STRATEGY_ID", 0);
            o.StrategyName = oracleReaderWrapper.GetString("STRATEGY_NAME", "");
            o.WordList = oracleReaderWrapper.GetString("WORD_LIST", "");
            o.PatternList = oracleReaderWrapper.GetString("PATTERN_LIST", "");
            return true;
        }

        private int ReadCount(OracleDataReader reader)
        {
            int @int;
            try
            {
                @int = new OracleReaderWrapper(reader).GetInt("count", 0);
            }
            catch (Exception ex)
            {
                LogHelper.Error(ex);
                return 0;
            }
            return @int;
        }

        public void Dispose()
        {
        }
    }
}