|
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 GwMoRouteDao : IDisposable
|
{
|
/// <summary>
|
/// 加载上行路由表信息
|
/// </summary>
|
/// <param name="OpID"></param>
|
/// <param name="SpID"></param>
|
/// <param name="AccessCode"></param>
|
/// <param name="recordcount"></param>
|
/// <param name="PageIndex"></param>
|
/// <param name="pageSize"></param>
|
/// <returns></returns>
|
public List<GwMoRoute> LoadInfoList(int OpID, string SpID, string AccessCode, out int recordcount, int PageIndex, int pageSize)
|
{
|
List<GwMoRoute> list = new List<GwMoRoute>();
|
recordcount = 0;
|
try
|
{
|
StringBuilder stringBuilder = new StringBuilder();
|
stringBuilder.Append("from GW_MO_ROUTE_VIEW where 1=1");
|
OracleParameter[] oracleParameterArray = new OracleParameter[3];
|
if (OpID > 0)
|
{
|
oracleParameterArray[0] = new OracleParameter(":OpID", (OracleDbType) 112);
|
((DbParameter) oracleParameterArray[0]).Value = (object) OpID;
|
stringBuilder.Append(" and OP_ID=:OpID");
|
}
|
if (SpID != null && SpID != "")
|
{
|
oracleParameterArray[1] = new OracleParameter(":SpID", (OracleDbType) 126);
|
((DbParameter) oracleParameterArray[1]).Value = (object) SpID;
|
stringBuilder.Append(" and SP_ID=:SpID");
|
}
|
if (AccessCode != null && AccessCode != "")
|
{
|
oracleParameterArray[2] = new OracleParameter(":AccessCode", (OracleDbType) 126);
|
((DbParameter) oracleParameterArray[2]).Value = (object) AccessCode;
|
stringBuilder.Append(" and INSTR(:AccessCode,ACCESS_CODE) = 1");
|
}
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("select count(*) as count " + stringBuilder.ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader) reader).Read())
|
{
|
OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
|
recordcount = oracleReaderWrapper.GetInt("count", 0);
|
}
|
}
|
stringBuilder.Append(" order by OP_ID ASC,ACCESS_CODE DESC,PRIORITY DESC");
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(PubConstant.doOracleSql(PageIndex, pageSize, recordcount, "select * " + stringBuilder.ToString()).ToString(), OracleHelper.Connection, oracleParameterArray))
|
{
|
while (((DbDataReader) reader).Read())
|
{
|
GwMoRoute o = new GwMoRoute();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
}
|
catch (Exception ex)
|
{
|
LogHelper.Error(ex);
|
return list;
|
}
|
return list;
|
}
|
|
public List<GwMoRoute> LoadInfoList()
|
{
|
List<GwMoRoute> list = new List<GwMoRoute>();
|
using (OracleDataReader reader = OracleHelper.ExecuteReader("SELECT * FROM GW_MO_ROUTE", OracleHelper.Connection))
|
{
|
while (((DbDataReader) reader).Read())
|
{
|
GwMoRoute o = new GwMoRoute();
|
if (this.ReadInfo(reader, o))
|
list.Add(o);
|
}
|
}
|
return list;
|
}
|
|
private bool ReadInfo(OracleDataReader reader, GwMoRoute o)
|
{
|
OracleReaderWrapper oracleReaderWrapper = new OracleReaderWrapper(reader);
|
o.RouteID = oracleReaderWrapper.GetInt("ROUTE_ID", 0);
|
o.Priority = oracleReaderWrapper.GetInt("PRIORITY", 0);
|
o.OpID = oracleReaderWrapper.GetInt("OP_ID", 0);
|
o.AccessCode = oracleReaderWrapper.GetString("ACCESS_CODE", "");
|
o.SpID = oracleReaderWrapper.GetString("SP_ID", "");
|
o.IsManual = oracleReaderWrapper.GetInt("IS_MANUAL", 0);
|
return true;
|
}
|
|
public bool Update(GwMoRoute o)
|
{
|
return OracleHelper.ExecuteSql("update GW_MO_ROUTE set PRIORITY=:PRIORITY,OP_ID=:OP_ID,ACCESS_CODE=:ACCESS_CODE,SP_ID=:SP_ID,IS_MANUAL=1 where ROUTE_ID=:ROUTE_ID", OracleHelper.Connection, new OracleParameter(":ROUTE_ID", (object) o.RouteID), new OracleParameter(":PRIORITY", (object) o.Priority), new OracleParameter(":OP_ID", (object) o.OpID), new OracleParameter(":ACCESS_CODE", (object) o.AccessCode), new OracleParameter(":SP_ID", (object) o.SpID)) > 0;
|
}
|
|
public bool Add(GwMoRoute o)
|
{
|
return OracleHelper.ExecuteSql("insert into GW_MO_ROUTE(ROUTE_ID,PRIORITY,OP_ID,ACCESS_CODE,SP_ID,IS_MANUAL) values(GW_MO_ROUTE_ID_SEQ.NEXTVAL,:PRIORITY,:OP_ID,:ACCESS_CODE,:SP_ID,1)", OracleHelper.Connection, new OracleParameter(":PRIORITY", (object) o.Priority), new OracleParameter(":OP_ID", (object) o.OpID), new OracleParameter(":ACCESS_CODE", (object) o.AccessCode), new OracleParameter(":SP_ID", (object) o.SpID)) > 0;
|
}
|
|
public GwMoRoute GetGwMoRoute(int rid)
|
{
|
GwMoRoute o = new GwMoRoute();
|
if (rid == 0)
|
return o;
|
using (OracleDataReader reader = OracleHelper.ExecuteReader(string.Format("select * from GW_MO_ROUTE where ROUTE_ID=:ROUTE_ID"), OracleHelper.Connection, new OracleParameter(":ROUTE_ID", (object) rid)))
|
{
|
if (((DbDataReader) reader).Read())
|
{
|
if (!this.ReadInfo(reader, o))
|
throw new Exception("ReadInfo发生异常");
|
return o;
|
}
|
}
|
return o;
|
}
|
|
public bool Delete(int rid)
|
{
|
if (rid == 0)
|
return false;
|
return OracleHelper.ExecuteSql("delete from GW_MO_ROUTE where ROUTE_ID=:ROUTE_ID", OracleHelper.Connection, new OracleParameter(":ROUTE_ID", (object) rid)) > 0;
|
}
|
|
public bool LoadRefresh()
|
{
|
return OracleHelper.ExecuteSql("INSERT INTO GW_EVENT_LOG(EVENT_ID,ASSIGNED_TO,EVENT_TYPE,CONTENT,EVENT_TIME,HANDLE_FLAG)VALUES(GW_EVENT_LOG_SEQ.NEXTVAL,'SMEXC','MO','',SYSDATE,0)", OracleHelper.Connection) > 0;
|
}
|
|
public void Dispose()
|
{
|
}
|
}
|
}
|
