|
using Common;
|
using Model;
|
using Oracle.DataAccess.Client;
|
using System;
|
using System.Collections.Generic;
|
using System.Data.Common;
|
using System.Text;
|
|
namespace Dao
|
{
|
public class GwChargeLogDao : IDisposable
|
{
|
public List<GwChargeLog> LoadInfoList(string clientID, string clientName, string spID, DateTime sDate, DateTime eDate, out int recordcount, int pageSize, int PageIndex)
|
{
|
List<GwChargeLog> list = new List<GwChargeLog>();
|
recordcount = 0;
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append("from GW_CHARGE_LOG_VIEW where OCCUR_TIME BETWEEN :SDATE AND :EDATE AND (SP_ID=:SP_ID OR :SP_ID IS NULL) AND (CLIENT_ID=:CLIENT_ID OR :CLIENT_ID IS NULL) AND (CLIENT_NAME LIKE :CLIENT_NAME OR :CLIENT_NAME='%%')");
|
OracleParameter[] oracleParameterArray = new OracleParameter[5]
|
{
|
new OracleParameter(":SP_ID", (object) spID),
|
new OracleParameter(":CLIENT_ID", (object) clientID),
|
new OracleParameter(":CLIENT_NAME", (object) ("%" + clientName + "%")),
|
new OracleParameter(":SDATE", (object) sDate),
|
new OracleParameter(":EDATE", (object) eDate)
|
};
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader)reader).Read())
|
recordcount = this.ReadCount(reader);
|
}
|
stringBuilder.Append(" order by CHARGE_ID DESC");
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + stringBuilder.ToString()).ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader)reader).Read())
|
{
|
GwChargeLog o = new GwChargeLog();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
return list;
|
}
|
|
public bool Add(GwChargeLog o)
|
{
|
return OracleHelper.ExecuteSql("insert into GW_CHARGE_LOG(CHARGE_ID,SP_ID,OCCUR_TIME,AMOUNT,OPERATOR_ID,FLAG,FLUSH_TIME,REMARK,PAYMENT_TYPE,PAYLOG_ID) values(GW_CHARGE_LOG_SEQ.nextval,:SpID,sysdate,:Amount,:OperatorId,0,sysdate,:Remark,:PayMentType,:PayLogID)", OracleHelper.Connection, new OracleParameter(":SpID", (object)o.SpID), new OracleParameter(":Amount", (object)o.Amount), new OracleParameter(":OperatorID", (object)o.OperatorID), new OracleParameter(":Remark", (object)o.Remark), new OracleParameter(":PayMentType", (object)o.PayMentType), new OracleParameter(":PayLogID", (object)o.PayLogID)) > 0;
|
}
|
|
public bool UpdatePayState(GwChargeLog o)
|
{
|
return OracleHelper.ExecuteSql("update GW_CHARGE_LOG set FLAG=:FLAG WHERE CHARGE_ID=:CHARGE_ID ", OracleHelper.Connection, new OracleParameter(":FLAG", (object)o.Flag), new OracleParameter("CHARGE_ID", (object)o.ChargeID)) > 0;
|
}
|
|
public GwChargeLog Get(string chargeID)
|
{
|
GwChargeLog o = new GwChargeLog();
|
if (string.IsNullOrEmpty(chargeID) || string.Equals("0", chargeID))
|
return o;
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_CHARGE_LOG where CHARGE_ID=:CHARGE_ID"), OracleHelper.Connection, new OracleParameter(":CHARGE_ID", (object)chargeID)))
|
{
|
if (((DbDataReader)reader).Read())
|
{
|
this.ReadInfo(reader, o);
|
return o;
|
}
|
}
|
return o;
|
}
|
|
public GwChargeLog GetLog(int paylogID)
|
{
|
GwChargeLog o = new GwChargeLog();
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("SELECT FlAG FROM GW_CHARGE_LOG WHERE PAYLOG_ID=: PAYLOG_ID"), OracleHelper.Connection, new OracleParameter(":PAYLOG_ID", (object)paylogID)))
|
{
|
if (((DbDataReader)reader).Read())
|
{
|
this.ReadInfo(reader, o);
|
return o;
|
}
|
}
|
return (GwChargeLog)null;
|
}
|
|
private bool ReadInfo(OracleDataReader reader, GwChargeLog o)
|
{
|
OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
|
o.ChargeID = oracleReaderWrapper.GetInt("CHARGE_ID", 0);
|
o.ClientID = oracleReaderWrapper.GetString("CLIENT_ID", "");
|
o.ClientName = oracleReaderWrapper.GetString("CLIENT_NAME", "");
|
o.SpID = oracleReaderWrapper.GetString("SP_ID", "");
|
o.OccurTime = oracleReaderWrapper.GetDateTime("OCCUR_TIME");
|
o.Amount = oracleReaderWrapper.GetInt64("AMOUNT", 0L);
|
o.OperatorID = oracleReaderWrapper.GetString("OPERATOR_ID", "");
|
o.Flag = oracleReaderWrapper.GetInt("FLAG", 0);
|
o.FlushTime = oracleReaderWrapper.GetDateTime("FLUSH_TIME");
|
o.Remark = oracleReaderWrapper.GetString("REMARK", "");
|
o.PayMentType = oracleReaderWrapper.GetInt("PAYMENT_TYPE", 0);
|
o.PayLogID = oracleReaderWrapper.GetInt("PAYLOG_ID", 0);
|
return true;
|
}
|
|
private int ReadCount(OracleDataReader reader)
|
{
|
return new OracleReaderWrapper(reader).GetInt("count", 0);
|
}
|
|
public void Dispose()
|
{
|
}
|
|
public List<GwChargeLog> GetChargeLog(string spid)
|
{
|
List<GwChargeLog> list = new List<GwChargeLog>();
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_CHARGE_LOG WHERE SP_ID=:SP_ID ORDER BY CHARGE_ID DESC", OracleHelper.Connection, new OracleParameter(":SP_ID", (object)spid)))
|
{
|
while (reader != null && ((DbDataReader)reader).Read())
|
{
|
GwChargeLog o = new GwChargeLog();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
return list;
|
}
|
|
public List<GwChargeLog> GetChargeLog(string spid, int payLogID, out int recordCount, int pageSize, int pageIndex)
|
{
|
List<GwChargeLog> list1 = new List<GwChargeLog>();
|
recordCount = 0;
|
StringBuilder stringBuilder = new StringBuilder();
|
List<OracleParameter> list2 = new List<OracleParameter>();
|
stringBuilder.Append(" FROM GW_CHARGE_LOG WHERE SP_ID=:SP_ID ");
|
list2.Add(new OracleParameter(":SP_ID", (object)spid));
|
if (payLogID > 0)
|
{
|
stringBuilder.Append("AND PAYLOG_ID=:PAYLOG_ID ");
|
list2.Add(new OracleParameter(":PAYLOG_ID", (object)payLogID));
|
}
|
stringBuilder.Append("ORDER BY CHARGE_ID DESC");
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT count(*) as count" + (object)stringBuilder, OracleHelper.Connection, list2.ToArray()))
|
{
|
while (((DbDataReader)reader).Read())
|
recordCount = this.ReadCount(reader);
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(pageIndex, pageSize, recordCount, "SELECT * " + stringBuilder.ToString()).ToString(), OracleHelper.Connection, list2.ToArray()))
|
{
|
while (reader != null && ((DbDataReader)reader).Read())
|
{
|
GwChargeLog o = new GwChargeLog();
|
if (this.ReadInfo(reader, o))
|
list1.Add(o);
|
}
|
}
|
return list1;
|
}
|
|
public List<GwChargeLog> CLientChargeLogList(string spid, string payLogID, out int recordCount, int pageSize, int pageIndex)
|
{
|
List<GwChargeLog> list = new List<GwChargeLog>();
|
recordCount = 0;
|
OracleParameter[] oracleParameterArray = new OracleParameter[0];
|
string str = string.Format(" FROM GW_CHARGE_LOG WHERE SP_ID in ({0})", (object)spid) + string.Format("ORDER BY CHARGE_ID DESC");
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT count(*) as count" + str, OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader)reader).Read())
|
recordCount = this.ReadCount(reader);
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(pageIndex, pageSize, recordCount, "SELECT * " + str.ToString()).ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (reader != null && ((DbDataReader)reader).Read())
|
{
|
GwChargeLog o = new GwChargeLog();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
return list;
|
}
|
}
|
}
|
