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

namespace Dao
{
    public class GwRptCodeDao : IDisposable
    {
        public List<RptCode> LoadRptCodeList()
        {
            List<RptCode> list = new List<RptCode>();
            using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE ORDER BY CREATE_TIME ASC", OracleHelper.Connection))
            {
                while (reader != null && ((DbDataReader)reader).Read())
                {
                    OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
                    list.Add(new RptCode()
                    {
                        NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""),
                        OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""),
                        CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"),
                        Remark = oracleReaderWrapper.GetString("REMARK", "")
                    });
                }
            }
            return list;
        }


        /// <summary>
        /// 获取账号比例
        /// </summary>
        /// <returns></returns>
        public List<RptAccount> LoadRptAccountList()
        {
            List<RptAccount> list = new List<RptAccount>();
            using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_ACCOUNT ORDER BY CREATETIME ASC", OracleHelper.Connection))
            {
                while (reader != null && ((DbDataReader)reader).Read())
                {
                    OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
                    list.Add(new RptAccount()
                    {
                        Spid = oracleReaderWrapper.GetString("SPID", ""),
                        Proportion = oracleReaderWrapper.GetString("Proportion", ""),
                        CreateTime = oracleReaderWrapper.GetDateTime("CREATETIME"),
                        TimeSpan = oracleReaderWrapper.GetString("TimeSpan","10"),
                        Threshold = oracleReaderWrapper.GetString("Threshold", "10000"),
                        WhitePhone = oracleReaderWrapper.GetString("WhitePhone", ""),
                    });
                }
            }
            return list;
        }

        public bool AddAccountCode(RptAccount code)
        {
            return OracleHelper.ExecuteSql("INSERT INTO GW_RPT_ACCOUNT(SPID,PROPORTION,CREATETIME,TimeSpan,Threshold,WhitePhone) VALUES(:SPID,:PROPORTION,SYSDATE,:TimeSpan,:Threshold,:WhitePhone)",
                OracleHelper.Connection, new OracleParameter(":SPID", (object)code.Spid), new OracleParameter(":PROPORTION", (object)code.Proportion),
                new OracleParameter(":TimeSpan", (object)code.TimeSpan), new OracleParameter(":Threshold", (object)code.Threshold),new OracleParameter(":WhitePhone", (object)code.WhitePhone)) > 0;
        }

        public bool DeleteAccount(string spid)
        {
            return OracleHelper.ExecuteSql("DELETE FROM GW_RPT_ACCOUNT WHERE SPID = :SPID", OracleHelper.Connection, new OracleParameter(":SPID", (object)spid)) > 0;
        }


        public void Dispose()
        {
        }

        public RptCode GetRptCode(string oldCode)
        {
            using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_RPT_CODE WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object)oldCode)))
            {
                if (reader != null && ((DbDataReader)reader).Read())
                {
                    OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
                    return new RptCode()
                    {
                        NewCode = oracleReaderWrapper.GetString("NEW_CODE", ""),
                        OldCode = oracleReaderWrapper.GetString("OLD_CODE", ""),
                        CreateTime = oracleReaderWrapper.GetDateTime("CREATE_TIME"),
                        Remark = oracleReaderWrapper.GetString("REMARK", "")
                    };
                }
            }
            return (RptCode)null;
        }

        public bool UpdateCode(RptCode code)
        {
            return OracleHelper.ExecuteSql("UPDATE GW_RPT_CODE SET NEW_CODE =:NEW_CODE,REMARK=:REMARK WHERE OLD_CODE=:OLD_CODE", OracleHelper.Connection, new OracleParameter(":NEW_CODE", (object)code.NewCode), new OracleParameter(":OLD_CODE", (object)code.OldCode), new OracleParameter(":REMARK", (object)code.Remark)) > 0;
        }

        public bool DeleteCode(string oldCode)
        {
            return OracleHelper.ExecuteSql("DELETE FROM GW_RPT_CODE WHERE OLD_CODE = :OLD_CODE", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object)oldCode)) > 0;
        }

        public bool AddCode(RptCode code)
        {
            return OracleHelper.ExecuteSql("INSERT INTO GW_RPT_CODE(OLD_CODE,NEW_CODE,CREATE_TIME,REMARK) VALUES(:OLD_CODE,:NEW_CODE,SYSDATE,:REMARK)", OracleHelper.Connection, new OracleParameter(":OLD_CODE", (object)code.OldCode), new OracleParameter(":NEW_CODE", (object)code.NewCode), new OracleParameter(":REMARK", (object)code.Remark)) > 0;
        }

        public List<ErrCode> LoadErrCodeList()
        {
            List<ErrCode> list = new List<ErrCode>();
            using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_ERR_CODE ORDER BY TYPE,CODE ASC", OracleHelper.Connection))
            {
                while (reader != null && ((DbDataReader)reader).Read())
                {
                    OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
                    list.Add(new ErrCode()
                    {
                        Code = oracleReaderWrapper.GetString("CODE", ""),
                        Remark = oracleReaderWrapper.GetString("REMARK", ""),
                        Type = oracleReaderWrapper.GetInt("TYPE", 0)
                    });
                }
            }
            return list;
        }
    }
}