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;
|
using System.Transactions;
|
|
namespace CY.SQLDAL
|
{
|
public class OA_CommoditySpeciAssociateDAL : IOA_CommoditySpeciAssociateDAL
|
{
|
|
private Database _dataBase = null;
|
|
public OA_CommoditySpeciAssociateDAL()
|
{
|
_dataBase = new Database();
|
}
|
|
/// <summary>
|
/// 新增
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool InserModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
Model.OA_CommoditySpeciAssociate trueModel = model as Model.OA_CommoditySpeciAssociate;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@CommodityId",trueModel.CommodityId),
|
new SqlParameter("@SpecificationId",trueModel.SpecificationId)
|
};
|
try
|
{
|
_dataBase.Query("sp_OA_CommoditySpeciAssociate_Insert", CommandType.StoredProcedure, sqlParms.ToArray<SqlParameter>());
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
return true;
|
}
|
|
|
|
|
|
|
/// <summary>
|
/// 批量删除
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool DeleteModel(Model.OA_CommoditySpeciAssociate[] models)
|
{
|
if (null == models || 0 == models.Length)
|
{
|
return false;
|
}
|
else
|
{
|
};
|
bool isOK = false;
|
using (TransactionScope tran = new TransactionScope())
|
{
|
int i = -1;
|
while (++i < models.Length)
|
{
|
isOK = DeleteModel(models[i]);
|
if (!isOK)
|
return false;
|
else
|
continue;
|
}
|
|
if (isOK)
|
tran.Complete();
|
}
|
return true;
|
}
|
/// <summary>
|
/// 批量添加数据
|
/// </summary>
|
/// <param name="modles"></param>
|
/// <returns></returns>
|
public bool InserModel(OA_CommoditySpeciAssociate[] modles)
|
{
|
if (null == modles || 0 == modles.Length)
|
{
|
return false;
|
}
|
else
|
{
|
}
|
bool isWin = false;
|
|
using (TransactionScope tran = new TransactionScope())
|
{
|
int i = -1;
|
while (++i < modles.Length)
|
{
|
isWin = InserModel(modles[i]);
|
if (!isWin)
|
return false;
|
else
|
continue;
|
}
|
|
if (isWin)
|
tran.Complete();
|
}
|
return true;
|
}
|
/// <summary>
|
/// 管理关联类别-规格
|
/// </summary>
|
/// <param name="Deletemodels"></param>
|
/// <param name="Insertmodles"></param>
|
/// <returns></returns>
|
public bool MananeModel(Model.OA_CommoditySpeciAssociate[] Deletemodels, OA_CommoditySpeciAssociate[] Insertmodles)
|
{
|
|
if (null == Deletemodels || 0 == Deletemodels.Length)
|
{
|
return false;
|
}
|
else
|
{
|
};
|
if (null == Insertmodles || 0 == Insertmodles.Length)
|
{
|
return false;
|
}
|
else
|
{
|
}
|
bool isOK = false;
|
|
using (TransactionScope tran = new TransactionScope())
|
{
|
int i = -1;
|
while (++i < Insertmodles.Length)
|
{
|
isOK = InserModel(Insertmodles[i]);
|
if (!isOK)
|
return false;
|
else
|
continue;
|
}
|
|
int j = -1;
|
while (++j < Deletemodels.Length)
|
{
|
isOK = DeleteModel(Deletemodels[i]);
|
if (!isOK)
|
return false;
|
else
|
continue;
|
}
|
|
if (isOK)
|
tran.Complete();
|
}
|
return true;
|
}
|
/// <summary>
|
/// 修改
|
/// </summary>
|
/// <param name="model"></param>
|
/// <returns></returns>
|
public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model)
|
{
|
Model.OA_CommoditySpeciAssociate trueModel = model as Model.OA_CommoditySpeciAssociate;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@CommodityId",trueModel.CommodityId),
|
new SqlParameter("@SpecificationId",trueModel.SpecificationId)
|
};
|
try
|
{
|
_dataBase.Query("sp_OA_CommoditySpeciAssociate_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.OA_CommoditySpeciAssociate trueModel = model as Model.OA_CommoditySpeciAssociate;
|
if (trueModel == null)
|
{
|
return false;
|
}
|
IList<SqlParameter> sqlParms = new List<SqlParameter>()
|
{
|
new SqlParameter("@CommodityId",trueModel.CommodityId)
|
};
|
try
|
{
|
_dataBase.Query("sp_OA_CommoditySpeciAssociate_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.OA_CommoditySpeciAssociate> SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination)
|
{
|
throw new NotImplementedException();
|
}
|
|
/// <summary>
|
/// 得到类别下面的规格
|
/// </summary>
|
/// <param name="CommodityId"></param>
|
/// <returns></returns>
|
public DataTable SelectModelPage(string CommodityId)
|
{
|
string selTaget = " * ";
|
string fromSource = " OA_CommoditySpeciAssociate where CommodityId='" + CommodityId + "'";
|
return _dataBase.SelectModel(selTaget, fromSource);
|
}
|
public IEnumerable<Model.OA_CommoditySpeciAssociate> SelectALLModel(string CommodityId)
|
{
|
string selTarget = " a.*,b.Name AS OA_SpecificationName ";
|
string fromSource = " ( SELECT * FROM dbo.OA_CommoditySpeciAssociate WHERE CommodityId='" + CommodityId + "') AS a LEFT JOIN dbo.OA_Specification AS b ON a.SpecificationId =b.Keyid ";
|
return _dataBase.SelectModel<Model.OA_CommoditySpeciAssociate>(selTarget, fromSource);
|
}
|
|
|
|
/// <summary>
|
/// 单个查询
|
/// </summary>
|
/// <param name="query"></param>
|
/// <returns></returns>
|
public IEnumerable<Model.OA_CommoditySpeciAssociate> SelectAllModel(Infrastructure.Query.Query query)
|
{
|
throw new NotImplementedException();
|
}
|
/// <summary>
|
/// 单个查询
|
/// </summary>
|
/// <param name="SpecificationId"></param>
|
/// <returns></returns>
|
public Model.OA_CommoditySpeciAssociate SelectSingelModel(string SpecificationId)
|
{
|
try
|
{
|
string selTarget = " * ";
|
string fromSource = " OA_CommoditySpeciAssociate where SpecificationId='" + SpecificationId + "'";
|
List<CY.Model.OA_CommoditySpeciAssociate> m_OA_CommoditySpeciAssociateList = _dataBase.SelectModel<Model.OA_CommoditySpeciAssociate>(selTarget, fromSource).ToList();
|
if (m_OA_CommoditySpeciAssociateList != null && m_OA_CommoditySpeciAssociateList.Count > 0)
|
{
|
return m_OA_CommoditySpeciAssociateList[0];
|
}
|
else
|
{
|
return null;
|
}
|
}
|
catch (Exception ex)
|
{
|
throw ex;
|
}
|
}
|
}
|
}
|
