|
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 GwDmDao : IDisposable
|
{
|
public List<GwDm> LoadInfoList(string ApID, string OpID, string spID, string DestnationId, string sDate, string permissionsSQL, out int recordcount, int pageSize, int PageIndex)
|
{
|
List<GwDm> list1 = new List<GwDm>();
|
recordcount = 0;
|
try
|
{
|
string str = sDate.Replace("-", "");
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append(" from LG_DM_").Append(str).Append(" where 1=1");
|
List<OracleParameter> list2 = new List<OracleParameter>();
|
if (ApID != null && ApID != "")
|
{
|
OracleParameter oracleParameter = new OracleParameter(":AP_ID", (OracleDbType) 126);
|
((DbParameter) oracleParameter).Value = (object) ApID;
|
list2.Add(oracleParameter);
|
stringBuilder.Append(" and AP_ID=:AP_ID ");
|
}
|
if (OpID != null && OpID != "")
|
{
|
OracleParameter oracleParameter = new OracleParameter(":OP_ID", (OracleDbType) 126);
|
((DbParameter) oracleParameter).Value = (object) OpID;
|
list2.Add(oracleParameter);
|
stringBuilder.Append(" and OP_ID=:OP_ID ");
|
}
|
if (DestnationId != null && DestnationId != "")
|
{
|
OracleParameter oracleParameter = new OracleParameter(":MOBILE", (OracleDbType) 126);
|
((DbParameter) oracleParameter).Value = (object) DestnationId;
|
list2.Add(oracleParameter);
|
stringBuilder.Append(" and MOBILE=:MOBILE ");
|
}
|
if (!string.IsNullOrEmpty(spID))
|
{
|
OracleParameter oracleParameter = new OracleParameter(":SP_ID", (OracleDbType) 126);
|
((DbParameter) oracleParameter).Value = (object) spID;
|
list2.Add(oracleParameter);
|
stringBuilder.Append(" and SP_ID=:SP_ID ");
|
}
|
|
//客户权限SQL脚本
|
stringBuilder.Append(permissionsSQL);
|
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(" select count(*) as count " + stringBuilder.ToString(), OracleHelper.Connection, list2.ToArray()))
|
{
|
while (((DbDataReader) reader).Read())
|
recordcount = this.ReadCount(reader);
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, string.Format(" select * {0} order by DELIVER_TIME DESC", (object) stringBuilder)).ToString(), OracleHelper.Connection, list2.ToArray()))
|
{
|
while (((DbDataReader) reader).Read())
|
{
|
GwDm o = new GwDm();
|
if (this.ReadInfo(reader, o))
|
list1.Add(o);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex);
|
return list1;
|
}
|
return list1;
|
}
|
|
private bool ReadInfo(OracleDataReader reader, GwDm o)
|
{
|
OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
|
o.OPMID = oracleReaderWrapper.GetString("OP_MID", string.Empty);
|
o.ApID = oracleReaderWrapper.GetInt("AP_ID", 0);
|
o.OpID = oracleReaderWrapper.GetInt("OP_ID", 0);
|
o.ClientID = oracleReaderWrapper.GetString("CLIENT_ID", "");
|
o.SPID = oracleReaderWrapper.GetString("SP_ID", "");
|
o.Mobile = oracleReaderWrapper.GetString("MOBILE", "");
|
o.AccessCode = oracleReaderWrapper.GetString("ACCESS_CODE", "");
|
o.ExtNo = oracleReaderWrapper.GetString("EXT_NO", "");
|
o.RDFlag = oracleReaderWrapper.GetInt("RD_FLAG", 0);
|
o.MsgFormat = oracleReaderWrapper.GetInt("MSG_FORMAT", 0);
|
o.MsgLength = oracleReaderWrapper.GetInt("MSG_LENGTH", 0);
|
o.MsgContent = oracleReaderWrapper.GetString("MSG_CONTENT", "");
|
o.DeliverTime = oracleReaderWrapper.GetDateTime("DELIVER_TIME");
|
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()
|
{
|
}
|
|
public List<GwDm> LoadInfoList(string clientID, string spID, string destnationId, string sDate, string beginTime, string endTime, string permissionsSQL, out int recordcount, int pageSize, int pageIndex)
|
{
|
List<GwDm> list = new List<GwDm>();
|
recordcount = 0;
|
try
|
{
|
string str = sDate.Replace("-", "");
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append("from LG_DM_").Append(str).Append(" where 1=1");
|
OracleParameter[] oracleParameterArray = new OracleParameter[3];
|
if (clientID != null && clientID != "")
|
{
|
oracleParameterArray[0] = new OracleParameter(":CLIENT_ID", (OracleDbType) 126);
|
((DbParameter) oracleParameterArray[0]).Value = (object) clientID;
|
stringBuilder.Append(" and CLIENT_ID=:CLIENT_ID");
|
}
|
if (spID != null && spID != "")
|
{
|
oracleParameterArray[0] = new OracleParameter(":SP_ID", (OracleDbType) 126);
|
((DbParameter) oracleParameterArray[0]).Value = (object) spID;
|
stringBuilder.Append(" and SP_ID=:SP_ID");
|
}
|
if (destnationId != null && destnationId != "")
|
{
|
oracleParameterArray[0] = new OracleParameter(":DestnationId", (OracleDbType) 126);
|
((DbParameter) oracleParameterArray[0]).Value = (object) destnationId;
|
stringBuilder.Append(" and MOBILE=:DestnationId");
|
}
|
|
//客户权限SQL脚本
|
stringBuilder.Append(permissionsSQL);
|
|
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, string.Format("select * {0} order by DELIVER_TIME DESC", (object) stringBuilder)).ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader) reader).Read())
|
{
|
GwDm o = new GwDm();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex);
|
return list;
|
}
|
return list;
|
}
|
}
|
}
|
