/**
|
* EC_OrderDAL.cs
|
*
|
* 功 能： 订单请求数据访问接口实现类
|
* 类 名： EC_OrderDAL
|
*
|
* Ver 变更日期 负责人 变更内容
|
* ───────────────────────────────────
|
* V0.01 2013-5-11 15:20 吴崎均 增加分页查询方法
|
* V0.02 2013-5-11 16:38 吴崎均 修改分页查询，非必要条件改用集合传输
|
* V0.03 2013-6-7 15:58 吴崎均 修改分页查询申请方法使可以按申请人查询
|
*
|
*
|
*
|
*
|
*/
|
|
using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using CY.IDAL;
|
using CY.Model;
|
using System.Data.SqlClient;
|
using System.Data;
|
|
namespace CY.SQLDAL
|
{
|
/// <summary>
|
/// 订单请求数据访问接口实现类
|
/// </summary>
|
public class EC_OrderDialogueDAL : IEC_OrderDialogueDAL
|
{
|
Database _database = null;
|
/// <summary>
|
/// 初始化构造
|
/// </summary>
|
public EC_OrderDialogueDAL()
|
{
|
_database = new Database();
|
}
|
|
/// <summary>
|
/// 分页查询订单请求
|
/// </summary>
|
/// <param name="pagination">分页对象</param>
|
/// <param name="memberId">会员编号</param>
|
/// <param name="searchParam">可空查询条件</param>
|
/// <returns></returns>
|
public IEnumerable<EC_OrderDialogue> SelectModelPage(Infrastructure.Query.Pagination pagination, Dictionary<int, object> searchParam)
|
{
|
|
|
|
if (null == pagination || null == searchParam || (!searchParam.ContainsKey(8) && !searchParam.ContainsKey(9))) return null; else { }
|
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter() { ParameterName = "@BeginSubmit", SqlDbType = SqlDbType.Date, Value = DBNull.Value },//0
|
new SqlParameter() { ParameterName = "@EndSubmit", SqlDbType = SqlDbType.Date, Value = DBNull.Value },//1
|
new SqlParameter() { ParameterName = "@OrderId", SqlDbType = SqlDbType.VarChar, Value = DBNull.Value, Size = 25 },//2
|
new SqlParameter() { ParameterName = "@DialogueTypeId", SqlDbType = SqlDbType.Int, Value = DBNull.Value },//3
|
new SqlParameter() { ParameterName = "@IsAllow", SqlDbType = SqlDbType.Int, Value = DBNull.Value },//4
|
new SqlParameter() { ParameterName = "@IsExecuted", SqlDbType = SqlDbType.Int, Value = DBNull.Value },//5
|
new SqlParameter() { ParameterName = "@BeginReply", SqlDbType = SqlDbType.Date, Value = DBNull.Value },//6
|
new SqlParameter() { ParameterName = "@EndReply", SqlDbType = SqlDbType.Date, Value = DBNull.Value },//7
|
new SqlParameter() { ParameterName = "@ReceiverId", SqlDbType = SqlDbType.UniqueIdentifier, Value = DBNull.Value },//8 接手人
|
new SqlParameter() { ParameterName = "@InitiatorId", SqlDbType = SqlDbType.UniqueIdentifier, Value = DBNull.Value }//9 申请人
|
|
};
|
|
sqlParms.Add(new SqlParameter() { ParameterName = "@pageIndex", SqlDbType = SqlDbType.Int, Value = pagination.PageIndex });
|
sqlParms.Add(new SqlParameter() { ParameterName = "@pageSize", SqlDbType = SqlDbType.Int, Value = pagination.PageSize });
|
sqlParms.Add(new SqlParameter() { ParameterName = "@pageCount", SqlDbType = SqlDbType.Int, Direction = ParameterDirection.Output });
|
sqlParms.Add(new SqlParameter() { ParameterName = "@recordCount", SqlDbType = SqlDbType.Int, Direction = ParameterDirection.Output });
|
|
|
/*
|
* 拷贝参数
|
*/
|
if (null != searchParam && 0 < searchParam.Count)
|
{
|
foreach (int index in searchParam.Keys)
|
{
|
if (0 > index || index >= sqlParms.Count)
|
continue;
|
else
|
sqlParms[index].Value = searchParam[index];
|
}
|
}
|
else
|
{
|
|
}
|
|
IList<EC_OrderDialogue> result = null;
|
//执行分页存储
|
using (IDataReader reader = _database.QueryDataReader("sp_OrderPropertyChangeRequestGetterByPage", CommandType.StoredProcedure, sqlParms.ToArray()))
|
{
|
result = _database.ReadDataToModel<EC_OrderDialogue>(reader);
|
}
|
/*获取页数与返回数据条数*/
|
int? resultValue = CY.Infrastructure.Common.MyConvert.ConvertToInt32(sqlParms[12].Value);
|
pagination.PageCount = resultValue.HasValue ? resultValue.Value : 0;
|
resultValue = CY.Infrastructure.Common.MyConvert.ConvertToInt32(sqlParms[13].Value);
|
pagination.RecordCount = resultValue.HasValue ? resultValue.Value : 0;
|
|
return result;
|
}
|
|
}
|
}
|
