更新

wzp

2021-09-16 96eac0ce567dc3eef6900ce57dcb4c029fac2082

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
 
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()
    {
    }
  }
}