公司级平台-IProgram_BLL
1、AreaService
public class AreaService : BaseService { #region 构造函数 public AreaService() :base() { } public AreaService(IBaseData mBase) : base(mBase) { } public AreaService(IListData mRepos) : base(mRepos) { } public AreaService(IBaseData mBase, IListData mRepos) : base(mBase, mRepos) { } #endregion #region 属性 #endregion #region 操作方法 /// <summary> /// 保存数据业务逻辑 /// </summary> /// <param name="entity">数据集</param> /// <param name="sType"></param> /// <returns></returns> public override Carpa.Web.Script.IHashObject SaveRecord(Carpa.Web.Script.IHashObject entity, SaveType sType) { if (this.iBase == null) throw new NullReferenceException("iBase 数据集为空"); if (entity == null) return Utils.ReturnObject.GetInstance().GetReturnObject("保存数据结果集为空"); if (SaveType.NEW == sType) return SaveNewRecord(entity); else SaveEditRecord(entity); return Utils.ReturnObject.GetInstance().GetReturnObject(); } private IHashObject SaveNewRecord(Carpa.Web.Script.IHashObject entity) { if (string.IsNullOrEmpty(entity.GetValue<string>("areacode"))) return Utils.ReturnObject.GetInstance().GetReturnObject("编号不能为空。"); if (string.IsNullOrEmpty(entity.GetValue<string>("areaname"))) return Utils.ReturnObject.GetInstance().GetReturnObject("名称不能为空。"); IHashObject objReturn = null; using (DbHelper db = IProgram.Utils.AppUtils.CreateDbHelper()) { try { db.BeginTransaction(); this.iBase._DbHelper = db; objReturn = this.iBase.InsertRecord(entity); if (!IProgram.Utils.AppUtils.ReturnObject.CheckReturnObjectIsOk(objReturn)) { db.RollbackTransaction(); return objReturn; } db.CommitTransaction(); return objReturn; } catch (Exception e) { db.RollbackTransaction(); //RtcServiceBase.AppUtils.WriteLog(string.Format("【新增失败】新增商品并发布 异常错误:{0}", e.Message), true); return Utils.ReturnObject.GetInstance().GetReturnObject("新增失败:" + e.Message); } } //删除临时目录 } private IHashObject SaveEditRecord(Carpa.Web.Script.IHashObject entity) { IHashObject objReturn = null; if (string.IsNullOrEmpty(entity.GetValue<string>("id"))) return Utils.ReturnObject.GetInstance().GetReturnObject("供应商ID传入错误。"); using (DbHelper db = IProgram.Utils.AppUtils.CreateDbHelper()) { try { db.BeginTransaction(); this.iBase._DbHelper = db; objReturn = this.iBase.UpdateRecord(entity); if (!IProgram.Utils.AppUtils.ReturnObject.CheckReturnObjectIsOk(objReturn)) { db.RollbackTransaction(); return objReturn; } db.CommitTransaction(); return objReturn; } catch (Exception e) { db.RollbackTransaction(); return Utils.ReturnObject.GetInstance().GetReturnObject("修改失败:" + e.Message); } } } /// <summary> /// 取得结果集业务逻辑 /// </summary> /// <param name="RowData">条件集</param> /// <returns></returns> public override IHashObject GetRecord(IHashObject RowData) { if (string.IsNullOrEmpty(RowData.GetValue<string>("id"))) return Utils.ReturnObject.GetInstance().GetReturnObject("编号不能为空。"); if (this.iBase == null) throw new NullReferenceException("iBase 数据集为空"); IHashObject _rowData = null; using (DbHelper db = IProgram.Utils.AppUtils.CreateDbHelper()) { this.iBase._DbHelper = db; _rowData = this.iBase.GetRecord(RowData); } return _rowData; } /// <summary> /// 删除记录 /// </summary> /// <param name="entity">删除条件集</param> /// <param name="objParmas"></param> /// <returns></returns> public override Carpa.Web.Script.IHashObject DeleteRecord(Carpa.Web.Script.IHashObject entity, Carpa.Web.Script.IHashObject objParmas) { if (this.iBase == null) throw new NullReferenceException("iBase 数据集为空"); IHashObject objReturn = null; //是否被使用 using (DbHelper db = IProgram.Utils.AppUtils.CreateDbHelper()) { this.iBase._DbHelper = db; try { db.BeginTransaction(); objReturn = this.iBase.DeleteRecord(entity); if (!IProgram.Utils.AppUtils.ReturnObject.CheckReturnObjectIsOk(objReturn)) { db.RollbackTransaction(); return objReturn; } db.CommitTransaction(); } catch (Exception e) { db.RollbackTransaction(); return Utils.ReturnObject.GetInstance().GetReturnObject("删除失败:" + e.Message); } } return objReturn; } #endregion #region 列表数据 public override IHashObjectList FindHashList(IHashObject Params, int pageIndex, int pageSize, ref int totalRecord, string SQLWhere = "", string SQLOrder = "") { IHashObjectList ilist = null; if (this.iRepos == null) throw new NullReferenceException("IListData 数据集为空"); using (DbHelper db = IProgram.Utils.AppUtils.CreateDbHelper()) { this.iRepos._DbHelper = db; ilist =base.FindHashList(Params, pageIndex, pageSize, ref totalRecord, SQLWhere, SQLOrder); } return ilist; } #endregion }