看了下大家引擎的代码，总感觉比较臃肿。现在做了如下修改，希望对大家设计引擎有帮助。
首先对BLL层进行了改动，修改为CSMS2.Mould。这里包含所有与业务相关的表。但Mould中的类是已聚合（一次增删改数据的最小单位）作为最小单位。也就是说一些主表和子表被放在了一个聚合中。另外引擎中的表的操作也放在了Mould中，并没有把这些表的操作单独放在引擎中。结构如下：
如果这些聚合之间有相互的操作，且是在一个引擎中的。则需要调用引擎，如果涉及到多个引擎之间的调用，则需要使用引擎调度。
也就是说引擎是一系列表的相互操作，哪些表属于某个引擎，可以由引擎开发人员做的时候确定。
下面看个刚才写的聚合和引擎的例子
新装业务聚合：
//********************************************************************************// //创建日期：<创建日期，2013-2-19> //创建作者：<张易，zhangyi@shanghai3h.com> //功能说明：新装业务 //********************************************************************************// using System; using CSMS2.Application.DTO.MinBanYW; using CSMS2.DataAccess.MinBanYW; using CSMS2.Entity; using CSMS2.Infrastructure.DataType; using Oracle.DataAccess.Client; namespace CSMS2.Mould.MinBanYW { /// <summary> /// 新装业务，包括新装业务和新装审核资料 /// </summary> public class XinZhuangYW { #region 变量 private static MB_XINZHUANGYWProcess _MB_XINZHUANGYWProcess = new MB_XINZHUANGYWProcess(); #endregion #region 增删改操作 /// <summary> /// 新装受理，如果无数据插入，有数据则更新 /// </summary> /// <param name="gongChengBH">工程编号</param> /// <param name="minBanGCMXDTO">dto</param> /// <param name="logininfo">登陆信息</param> /// <param name="tran">事务</param> /// <returns>true or false</returns> public static bool XinZhuangSL(string gongChengBH, MinBanGCMXDTO minBanGCMXDTO, LoginInfo logininfo, OracleTransaction tran) { bool result = false; Entity.MB_XINZHUANGYW xinZhuang = new Entity.MB_XINZHUANGYW(); if (minBanGCMXDTO.ID > 0) { xinZhuang = _MB_XINZHUANGYWProcess.SelectMB_XINZHUANGYW(minBanGCMXDTO.ID,tran); } xinZhuang.S_GONGCHENGBH = gongChengBH; xinZhuang.N_BIAONENGL = minBanGCMXDTO.N_BIAONENGL; xinZhuang.I_CHAOBIAOFS = minBanGCMXDTO.I_CHAOBIAOFS; xinZhuang.S_BIAOWEI = minBanGCMXDTO.S_BIAOWEI; xinZhuang.I_LIANJIEFS = minBanGCMXDTO.I_LIANJIEFS; xinZhuang.S_RANQIBTXM = minBanGCMXDTO.S_RANQIBTXM; xinZhuang.I_CHUSHICM = minBanGCMXDTO.I_CHUSHICM; xinZhuang.I_FANGWULX = minBanGCMXDTO.I_FANGWULX; xinZhuang.S_GONGQIHTH = minBanGCMXDTO.S_GONGQIHTH; xinZhuang.S_PDABH = minBanGCMXDTO.S_PDABH; xinZhuang.S_ANJIANBH = minBanGCMXDTO.S_ANJIANBH; xinZhuang.S_CAOZUOR = logininfo.Account; xinZhuang.D_CAOZUOSJ = DateTime.Now; xinZhuang.I_JLZT = 0; xinZhuang.S_SHIJISYR = minBanGCMXDTO.S_SHIJISYR; result = _MB_XINZHUANGYWProcess.InsertOrUpdate(xinZhuang, tran); return result; } #endregion #region 查询操作 #endregion } }
工程信息业务聚合：
//********************************************************************************// //创建日期：<创建日期，2013-2-19> //创建作者：<王磊，wanglei@shanghai3h.com> //功能说明：工程信息 //********************************************************************************// using System; using CSMS2.Application.DTO.MinBanYW; using CSMS2.DataAccess.MinBanYW; using CSMS2.Entity; using CSMS2.Infrastructure.DataType; using Oracle.DataAccess.Client; namespace CSMS2.Mould.MinBanYW { /// <summary> /// 工程信息 /// </summary> public class GongChengXX { #region 变量 private static MB_GONGCHENGXXProcess _MB_GONGCHENGXXProcess = new MB_GONGCHENGXXProcess(); #endregion #region 增删改操作 /// <summary> /// 受理 根据MinBanGCZBDTO插入民办工程信息表，如果无数据插入，有数据则更新 /// </summary> /// <param name="minBanGCZBDTO">dto</param> /// <param name="logininfo">登陆信息</param> /// <param name="tran">事务</param> /// <returns>true or false</returns> public static bool InsertGongChengXX(MinBanGCZBDTO minBanGCZBDTO, LoginInfo logininfo, OracleTransaction tran) { bool result = false; MB_GONGCHENGXX gongChengXX = new MB_GONGCHENGXX(); if (minBanGCZBDTO.ID > 0) { gongChengXX = _MB_GONGCHENGXXProcess.SelectMB_GONGCHENGXX(minBanGCZBDTO.ID, tran); } gongChengXX.S_GONGCHENGBH = minBanGCZBDTO.S_GONGCHENGBH;// gongChengBH; gongChengXX.I_GONGCHENGLX = minBanGCZBDTO.I_GONGCHENGLX; gongChengXX.I_YEWULX = minBanGCZBDTO.I_YEWULX; gongChengXX.I_KID = minBanGCZBDTO.I_KID; gongChengXX.I_LIUCHENGID = minBanGCZBDTO.I_LIUCHENGID;//???? gongChengXX.S_CID = minBanGCZBDTO.S_CID; gongChengXX.S_ST = minBanGCZBDTO.S_ST; gongChengXX.S_HM = minBanGCZBDTO.S_HM; gongChengXX.S_DZ = minBanGCZBDTO.S_DZ; gongChengXX.I_QUYUBH = minBanGCZBDTO.I_QUYUBH; gongChengXX.I_ZHENGJIANLX = minBanGCZBDTO.I_ZHENGJIANLX; gongChengXX.S_ZHENGJIANHM = minBanGCZBDTO.S_ZHENGJIANHM; gongChengXX.S_YONGHUDZ = minBanGCZBDTO.S_YONGHUDZ; gongChengXX.I_DAOLUBH = minBanGCZBDTO.I_DAOLUBH; gongChengXX.S_YONGHUYB = minBanGCZBDTO.S_YONGHUYB; gongChengXX.S_LIANXISJ = minBanGCZBDTO.S_LIANXISJ; gongChengXX.S_LIANXIDH = minBanGCZBDTO.S_LIANXIDH; gongChengXX.S_ZHANGDANMC = minBanGCZBDTO.S_ZHANGDANMC; gongChengXX.S_ZHANGDANDZ = minBanGCZBDTO.S_ZHANGDANDZ; gongChengXX.S_ZHANGDANYB = minBanGCZBDTO.S_ZHANGDANYB; gongChengXX.I_QIYUAN = minBanGCZBDTO.I_QIYUAN; gongChengXX.N_BIAONENGL = minBanGCZBDTO.N_BIAONENGL; gongChengXX.I_CHAOBIAOFS = minBanGCZBDTO.I_CHAOBIAOFS; gongChengXX.S_SHOULIR = minBanGCZBDTO.S_SHOULIR; gongChengXX.S_SHOULIZD = minBanGCZBDTO.S_SHOULIZD; gongChengXX.I_SHOULIFS = minBanGCZBDTO.I_SHOULIFS; gongChengXX.D_SHOULISJ = minBanGCZBDTO.D_SHOULISJ; gongChengXX.S_GONGCHENGBZ = ""; gongChengXX.I_LIUCHENGZT = 0; gongChengXX.S_CAOZUOR = logininfo.Account; gongChengXX.D_CAOZUOSJ = DateTime.Now; gongChengXX.I_JLZT = 0; gongChengXX.I_CEGU = minBanGCZBDTO.I_CEGU; gongChengXX.I_YONGQIXZ = minBanGCZBDTO.I_YONGQIXZ; result = _MB_GONGCHENGXXProcess.InsertOrUpdate(gongChengXX, tran); return result; } /// <summary> /// 根据主键更新工程状态 /// </summary> /// <param name="id"></param> /// <param name="gongChengZT"></param> /// <param name="tran"></param> /// <returns></returns> public static bool UpdateGongChengZT(int id, int gongChengZT,OracleTransaction tran) { bool result = false; MB_GONGCHENGXX gongChengXX = _MB_GONGCHENGXXProcess.SelectMB_GONGCHENGXX(id, tran); gongChengXX.I_GONGCHENGZT = gongChengZT; result = _MB_GONGCHENGXXProcess.InsertOrUpdate(gongChengXX, tran); return result; } #endregion #region 查询方法 #endregion } }
民用业务引擎
/// <summary> /// 受理 /// </summary> /// <param name="errMess">错误信息</param> /// <param name="minBanGCZBDTO">主表</param> /// <param name="minBanGCMXDTO">明细表</param> /// <param name="logininfo">登陆信息</param> /// <returns>true or false</returns> public static bool MinBanYWSL(out string errMess, MinBanGCZBDTO minBanGCZBDTO, MinBanGCMXDTO minBanGCMXDTO, LoginInfo logininfo) { errMess = ""; Func<OracleTransaction, bool> func = tran => { //流程ID int liuChengID = 0; //流程类别 string liuChengLB = GetLiuChengLB(minBanGCZBDTO.I_GONGCHENGLX.Value, out liuChengID); minBanGCZBDTO.I_KID = WorkFlow.GetInstanceID(liuChengLB, tran); minBanGCZBDTO.I_LIUCHENGID = liuChengID; //插入工程信息 bool result = GongChengXX.InsertGongChengXX(minBanGCZBDTO, logininfo, tran); if (result) { switch (minBanGCZBDTO.I_YEWULX) { case MB_YEWULX.新装: result = XinZhuangYW.XinZhuangSL(minBanGCZBDTO.S_GONGCHENGBH, minBanGCMXDTO,logininfo, tran); break; case MB_YEWULX.拆除: result = LianXiD.ChaiChuSL(minBanGCZBDTO, minBanGCMXDTO, logininfo, tran); break; case MB_YEWULX.过户: result = GuoHuYW.GuoHuSL(minBanGCZBDTO, minBanGCMXDTO, logininfo, tran); break; default: break; } } //新增时需要启动流程 if (result && minBanGCZBDTO.ID <= 0) { //启动流程 int nextStep = 0; WorkFlow.Start(minBanGCZBDTO.I_KID.Value,logininfo.Account, liuChengLB, out nextStep, tran); //需要测估 if (minBanGCZBDTO.I_CEGU == 1) { result = WorkFlow.GoToNext(minBanGCZBDTO.I_KID.Value,2, logininfo.Account, tran); } //更改工程信息工程状态 if (result) { result = GongChengXX.UpdateGongChengZT(minBanGCZBDTO.ID, WorkFlow.GetNextStepInt(minBanGCZBDTO.I_KID.Value,tran), tran); } } return result; }; return Transaction.InvokeOracleTransaction(logininfo.Account, func, out errMess); }