using System;
|
using System.Collections.Generic;
|
using System.Linq;
|
using System.Text;
|
using CY.IDAL;
|
using System.Data.SqlClient;
|
using System.Data;
|
using CY.Model;
|
|
namespace CY.SQLDAL
|
{
|
public class Pay_ScoreRecordDAL : IPay_ScoreRecordDAL
|
{
|
private Database _dataBase = null;
|
|
public Pay_ScoreRecordDAL()
|
{
|
_dataBase = new Database();
|
}
|
public Pay_ScoreRecordDAL(Database database)
|
{
|
_dataBase = database;
|
}
|
|
/// <summary>
|
/// 新增
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
Model.Pay_ScoreRecord trueModel = model as Model.Pay_ScoreRecord;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@PayId",trueModel.PayId),
|
new SqlParameter("@TradingName",trueModel.TradingName),
|
new SqlParameter("@TradingType",trueModel.TradingType),
|
new SqlParameter("@TradingState",trueModel.TradingState),
|
new SqlParameter("@TradingScore",trueModel.TradingScore),
|
new SqlParameter("@ResidualScore",trueModel.ResidualScore),
|
new SqlParameter("@CreateTime",trueModel.CreateTime),
|
new SqlParameter("@Remark",trueModel.Remark)
|
};
|
try
|
{
|
_dataBase.Query("sp_Pay_ScoreRecord_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
/// <summary>
|
/// 修改
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
Model.Pay_ScoreRecord trueModel = model as Model.Pay_ScoreRecord;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{ new SqlParameter("@Keyid",trueModel.Keyid),
|
new SqlParameter("@PayId",trueModel.PayId),
|
new SqlParameter("@TradingName",trueModel.TradingName),
|
new SqlParameter("@TradingType",trueModel.TradingType),
|
new SqlParameter("@TradingState",trueModel.TradingState),
|
new SqlParameter("@TradingScore",trueModel.TradingScore),
|
new SqlParameter("@ResidualScore",trueModel.ResidualScore),
|
new SqlParameter("@CreateTime",trueModel.CreateTime),
|
new SqlParameter("@Remark",trueModel.Remark)
|
};
|
try
|
{
|
_dataBase.Query("sp_Pay_ScoreRecord_Update", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
/// <summary>
|
/// 删除
|
/// </summary>
|
/// <param name="id"></param>
|
/// <returns></returns>
|
public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
Model.Pay_ScoreRecord trueModel = model as Model.Pay_ScoreRecord;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@Keyid",trueModel.Keyid)
|
};
|
try
|
{
|
_dataBase.Query("sp_Pay_ScoreRecord_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
/// <summary>
|
/// 分页查询
|
/// </summary>
|
/// <param name="query"></param>
|
/// <param name="pagination"></param>
|
/// <returns></returns>
|
public IEnumerable<Model.Pay_ScoreRecord> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
|
{
|
throw new NotImplementedException();
|
}
|
|
/// <summary>
|
/// 单个查询
|
/// </summary>
|
/// <param name="query"></param>
|
/// <returns></returns>
|
public IEnumerable<Model.Pay_ScoreRecord> SelectAllModel(Infrastructure.Query.Query query)
|
{
|
throw new NotImplementedException();
|
}
|
|
/// <summary>
|
/// 全部查询
|
/// </summary>
|
/// <param name="query"></param>
|
/// <returns></returns>
|
public IEnumerable<Model.Pay_ScoreRecord> SelectOrderMemberByTopNum(int? TopNum)
|
{
|
return _dataBase.SelectModel<Model.Pay_ScoreRecord>(" * ", " Pay_ScoreRecord ") as IList<Model.Pay_ScoreRecord>;//执行查询
|
}
|
|
/// <summary>
|
/// 积分记录
|
/// </summary>
|
/// <param name="pagination"></param>
|
/// <param name="PayId"></param>
|
/// <param name="TradingType"></param>
|
/// <param name="TradingState"></param>
|
/// <param name="CreatStartTime"></param>
|
/// <param name="CreatEndTime"></param>
|
/// <returns></returns>
|
public IEnumerable<Model.Pay_ScoreRecord> SelectAllModel(Infrastructure.Query.Pagination pagination, int? PayId, int? TradingType, int? TradingState, DateTime? CreatStartTime, DateTime? CreatEndTime)
|
{
|
if (PayId == null || PayId <= 0)
|
return null;//错误数据返会空
|
try
|
{
|
string condtion = " 1=1 ";
|
if (PayId > 0)
|
{
|
condtion = condtion + " and PayId ='" + PayId + "' ";
|
}
|
if (TradingType > 0)
|
{
|
condtion = condtion + " and TradingType ='" + TradingType + "' ";
|
}
|
if (TradingState > 0)
|
{
|
condtion = condtion + " and TradingState ='" + TradingState + "' ";
|
}
|
if (CreatStartTime != null)
|
{
|
condtion = condtion + " and CreateTime >='" + CreatStartTime + "' ";
|
}
|
if (CreatEndTime != null)
|
{
|
condtion = condtion + " and CreateTime <='" + CreatEndTime.Value.AddDays(1) + "' ";
|
}
|
|
IList<Pay_ScoreRecord> result = _dataBase.SelectModelPage<Model.Pay_ScoreRecord>(pagination, "*", "Pay_ScoreRecord", "CreateTime DESC", "CreateTime DESC", condtion) as IList<Pay_ScoreRecord>;//执行查询
|
return null == result ? null : result;//返回结果
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
|
}
|
|
public IEnumerable<Model.Pay_ScoreRecord> SelectAllModel(Infrastructure.Query.Pagination pagination, int TradingType, string startDate, string endDate, string province, string city, string country)
|
{
|
IEnumerable<Model.Pay_ScoreRecord> list = null;
|
string selectTarget = " a.*,c.Name as MemberName ";
|
string fromSouce = " dbo.Pay_ScoreRecord a INNER JOIN dbo.Pay_PaymentAccount b ON a.Payid=b.Keyid INNER JOIN dbo.EC_MemberBasic c ON c.MemberId=b.MemberId ";
|
fromSouce += " where 1=1 and a.TradingState=-1 ";
|
fromSouce += " and a.tradingType=" + TradingType;
|
if (!string.IsNullOrEmpty(startDate))
|
fromSouce += " And a.CreateTime >= '" + startDate + "' ";
|
if (!string.IsNullOrEmpty(endDate))
|
fromSouce += " And a.CreateTime < '" + endDate + "' ";
|
|
if (!string.IsNullOrEmpty(province))
|
{
|
fromSouce += " and c.Province='" + province + "'";
|
}
|
|
if (!string.IsNullOrEmpty(city))
|
{
|
fromSouce += " and c.City='" + city + "'";
|
}
|
|
if (!string.IsNullOrEmpty(country))
|
{
|
fromSouce += " and c.County='" + country + "'";
|
}
|
|
list = _dataBase.SelectModelPage<Pay_ScoreRecord>(pagination, selectTarget, fromSouce, " a.CreateTime desc ", " CreateTime desc ", string.Empty);
|
return list;
|
}
|
}
|
}
|
