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_CarDictionaryDAL : IOA_CarDictionaryDAL { private Database _dataBase = null; public OA_CarDictionaryDAL() { _dataBase = new Database(); } public OA_CarDictionaryDAL(Database database) { _dataBase = database; } /// /// 新增 /// /// /// public bool InserModel(Infrastructure.Domain.IAggregateRoot model) { Model.OA_CarDictionary trueModel = model as Model.OA_CarDictionary; if (trueModel == null) { return false; } IList sqlParms = new List() { new SqlParameter("@MemberId",trueModel.MemberId), new SqlParameter("@ParType",trueModel.ParType), new SqlParameter("@ParName",trueModel.ParName), new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime), new SqlParameter("@Operator",trueModel.Operator) }; try { _dataBase.Query("sp_OA_CarDictionary_Insert", CommandType.StoredProcedure, sqlParms.ToArray()); } catch (Exception ex) { throw ex; } return true; } /// /// 修改 /// /// /// public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model) { Model.OA_CarDictionary trueModel = model as Model.OA_CarDictionary; if (trueModel == null) { return false; } IList sqlParms = new List() { new SqlParameter("@Keyid",trueModel.Keyid), new SqlParameter("@MemberId",trueModel.MemberId), new SqlParameter("@ParType",trueModel.ParType), new SqlParameter("@ParName",trueModel.ParName), new SqlParameter("@LastUpdateTime",trueModel.LastUpdateTime), new SqlParameter("@Operator",trueModel.Operator) }; try { _dataBase.Query("sp_OA_CarDictionary_Update", CommandType.StoredProcedure, sqlParms.ToArray()); } catch (Exception ex) { throw ex; } return true; } /// /// 删除 /// /// /// public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model) { Model.OA_CarDictionary trueModel = model as Model.OA_CarDictionary; if (trueModel == null) { return false; } IList sqlParms = new List() { new SqlParameter("@Keyid",trueModel.Keyid) }; try { _dataBase.Query("sp_OA_CarDictionary_DeleteRow", CommandType.StoredProcedure, sqlParms.ToArray()); } catch (Exception ex) { throw ex; } return true; } /// /// 分页查询 /// /// /// /// public IEnumerable SelectModelPage(Infrastructure.Query.Query query, Infrastructure.Query.Pagination pagination) { throw new NotImplementedException(); } /// /// 分页查询 /// /// /// /// /// /// public IEnumerable SelectModelPage(Infrastructure.Query.Pagination pagination, Guid MemberId, string ParType, string ParName) { try { string condition = " 1=1 and MemberId = '" + MemberId + "'"; if (!string.IsNullOrEmpty(ParName)) { condition += "and ParName like '%" + ParName + "%'"; } if (!string.IsNullOrEmpty(ParType)) { condition += " and ParType = '" + ParType + "'"; } return _dataBase.SelectModelPage(pagination, " * ", " OA_CarDictionary", " ParType ASC ,ParName ASC ", " ParType ASC ,ParName DESC ", condition); } catch (Exception ex) { throw ex; } } /// /// 单个查询 /// /// /// public IEnumerable SelectAllModel(Infrastructure.Query.Query query) { throw new NotImplementedException(); } /// /// 根据编号获得信息 /// /// 编号 /// public OA_CarDictionary GetModelByKeyid(int? Keyid) { try { if (Keyid == null || Keyid < 0) return null;//错误数据返会空 IList result = _dataBase.SelectModel("*", "OA_CarDictionary", string.Format(" Keyid='{0}'", Keyid)) as IList;//执行查询 return (null == result || result.Count == 0) ? null : result[0];//返回结果 } catch (Exception ex) { throw ex; } } /// /// 根据会员编号和类型获取列表 /// /// /// /// public IEnumerable SelectListByMemberIdAndParType(Guid MemberId, string ParType) { try { IList m_OA_CarDictionaryList = _dataBase.SelectModel("*", "OA_CarDictionary", string.Format(" MemberId='{0}' and ParType='{1}'", MemberId, ParType)) as IList;//执行查询 return m_OA_CarDictionaryList;//返回结果 } catch (Exception ex) { throw ex; } } /// /// 批量删除 /// /// /// /// public bool DelAllModel(string keyids, Guid Memberid) { try { int result = _dataBase.ExecuteSql(" DELETE dbo.OA_CarDictionary WHERE Keyid IN (" + keyids.Trim(',') + ") AND MemberId = '" + Memberid.ToString() + "'"); return (result > 0); } catch (Exception ex) { throw ex; } } } }