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

namespace Dao
{
  public class GwRmResendDao : IDisposable
  {
    public  List<GwRmResend> LoadGwRmSendList(string sDate, out int recordcount, int pageSize, int PageIndex)
    {
      List<GwRmResend> list = new List<GwRmResend>();
      recordcount = 0;
      try
      {
        string str = " FROM GW_RM_RESEND ORDER BY REPORT_TIME DESC";
        using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + str.ToString(), OracleHelper.Connection))
        {
          while (((DbDataReader) reader).Read())
            recordcount = this.ReadCount(reader);
        }
        using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + str.ToString()).ToString(), OracleHelper.Connection))
        {
          while (((DbDataReader) reader).Read())
          {
            GwRmResend o = new GwRmResend();
            if (this.ReadInfo(reader, o))
              list.Add(o);
          }
        }
      }
      catch (Exception ex)
      {
        LogHelper.Error(ex);
        return list;
      }
      return list;
    }

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

    private bool ReadInfo(OracleDataReader reader, GwRmResend o)
    {
      OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
      o.APMID = oracleReaderWrapper.GetString("AP_MID", string.Empty);
      o.OPMID = oracleReaderWrapper.GetString("OP_MID", string.Empty);
      o.ClientID = oracleReaderWrapper.GetString("CLIENT_ID", string.Empty);
      o.SPID = oracleReaderWrapper.GetString("SP_ID", string.Empty);
      o.ApID = oracleReaderWrapper.GetInt("AP_ID", 0);
      o.OpID = oracleReaderWrapper.GetInt("OP_ID", 0);
      o.AccessCode = oracleReaderWrapper.GetString("ACCESS_CODE", "");
      o.Mobile = oracleReaderWrapper.GetString("MOBILE", "");
      o.Stat = oracleReaderWrapper.GetString("STAT", "");
      o.SubmitTime = oracleReaderWrapper.GetString("SUBMIT_TIME", "");
      o.DoneTime = oracleReaderWrapper.GetString("DONE_TIME", "");
      o.ReportTime = oracleReaderWrapper.GetDateTime("REPORT_TIME");
      o.ExtMsg = oracleReaderWrapper.GetString("EXT_MSG", "");
      return true;
    }

    public void Dispose()
    {
    }
  }
}