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_DocumentDicDAL:IOA_DocumentDicDAL { private Database _dataBase = null; public OA_DocumentDicDAL() { _dataBase = new Database(); } public OA_DocumentDicDAL(Database dataBase) { _dataBase = dataBase; } /// /// 新增 /// /// /// public bool InserModel(Infrastructure.Domain.IAggregateRoot model) { Model.OA_DocumentDic trueModel = model as Model.OA_DocumentDic; 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_DocumentDic_Insert", CommandType.StoredProcedure, sqlParms.ToArray()); } catch (Exception ex) { throw ex; } return true; } /// /// 修改 /// /// /// public bool UpdateModel(Infrastructure.Domain.IAggregateRoot model) { Model.OA_DocumentDic trueModel = model as Model.OA_DocumentDic; 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_DocumentDic_Update", CommandType.StoredProcedure, sqlParms.ToArray()); } catch (Exception ex) { throw ex; } return true; } /// /// 删除 /// /// /// public bool DeleteModel(Infrastructure.Domain.IAggregateRoot model) { Model.OA_DocumentDic trueModel = model as Model.OA_DocumentDic; if (trueModel == null) { return false; } IList sqlParms = new List() { new SqlParameter("@Keyid",trueModel.Keyid) }; try { _dataBase.Query("sp_OA_DocumentDic_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 SelectAllModel(Infrastructure.Query.Query query) { throw new NotImplementedException(); } /// /// 根据编号获得信息 /// /// 编号 /// public OA_DocumentDic GetModelByKeyid(int? Keyid) { try { if (Keyid == null || Keyid < 0) return null;//错误数据返会空 IList result = _dataBase.SelectModel(" * ", " OA_DocumentDic ", string.Format(" Keyid='{0}'", Keyid)) as IList;//执行查询 return (null == result || result.Count == 0) ? null : result[0];//返回结果 } catch (Exception ex) { throw ex; } } /// /// 分页查询 /// /// /// public IEnumerable SelectModelPage(Infrastructure.Query.Pagination pagination,Guid _MemberId,string _ParType,string _ParName,DateTime? _BeginLastUpdateTime,DateTime? _EndLastUpdateTime,string _Operator) { try { string condition = " 1=1 "; if (_MemberId != Guid.Empty) condition += " and MemberId = '" + _MemberId + "'"; if (!string.IsNullOrEmpty(_ParType)) condition += " and ParType = '" + _ParType + "'"; if (!string.IsNullOrEmpty(_ParName)) condition += " and ParName = '" + _ParName + "'"; if (_BeginLastUpdateTime.HasValue) condition += string.Format(" and CAST(LastUpdateTime AS DATE) >='{0}'", _BeginLastUpdateTime); if (_EndLastUpdateTime.HasValue) condition += string.Format(" and CAST(LastUpdateTime AS DATE) <='{0}'", _EndLastUpdateTime); if (!string.IsNullOrEmpty(_Operator)) condition += " and Operator = '" + _Operator + "'"; return _dataBase.SelectModelPage(pagination, " * ", " OA_DocumentDic ", " Keyid desc", " Keyid desc ", condition); } catch (Exception ex) { throw ex; } } } }