using System; using System.Collections.Generic; using System.Reflection; using System.Text; using System.Collections; using BP.DA; using BP.En; using BP.Port; using BP.Web; using BP.Difference; using BP.Tools; namespace BP.Sys { /// /// 事件属性 /// public class FrmEventAttr { /// /// 事件类型 /// public const string FK_Event = "EventID"; /// /// 表单ID /// public const string FrmID = "FrmID"; /// /// 流程编号 /// public const string FK_Flow = "FK_Flow"; /// /// 节点ID /// public const string FK_Node = "FK_Node"; /// /// 事件源 /// public const string EventSource = "EventSource"; /// /// 关联的流程编号 /// public const string RefFlowNo = "RefFlowNo"; /// /// 执行类型 /// public const string EventDoType = "EventDoType"; /// /// 数据源 /// public const string FK_DBSrc = "FK_DBSrc"; /// /// 执行内容 /// public const string DoDoc = "DoDoc"; /// /// 标签 /// public const string MsgOK = "MsgOK"; /// /// 执行错误提示 /// public const string MsgError = "MsgError"; #region 消息设置. /// /// 控制方式 /// public const string MsgCtrl = "MsgCtrl"; /// /// 邮件是否启用 /// public const string MailEnable = "MailEnable"; /// /// 消息标题 /// public const string MailTitle = "MailTitle"; /// /// 消息内容模版 /// public const string MailDoc = "MailDoc"; /// /// 是否启用短信 /// public const string SMSEnable = "SMSEnable"; /// /// 短信内容模版 /// public const string SMSDoc = "SMSDoc"; /// /// 是否推送? /// public const string MobilePushEnable = "MobilePushEnable"; /// /// DLL路径 /// public const string MonthedDLL = "MonthedDLL"; /// /// DLL中所选的类名 /// public const string MonthedClass = "MonthedClass"; /// /// DLL中所选类中的方法字符串 /// public const string MonthedName = "MonthedName"; /// /// DLL中所选类所选方法的参数表达式 /// public const string MonthedParas = "MonthedParas"; #endregion 消息设置. } /// /// 事件 /// 节点的节点保存事件有两部分组成. /// 记录了从一个节点到其他的多个节点. /// 也记录了到这个节点的其他的节点. /// public class FrmEvent : EntityMyPK { #region 参数属性. /// /// 名称 /// public string MonthedDLL { get { return this.GetParaString(FrmEventAttr.MonthedDLL); } set { this.SetPara(FrmEventAttr.MonthedDLL, value); } } /// /// 类名 /// public string MonthedClass { get { return this.GetParaString(FrmEventAttr.MonthedClass); } set { this.SetPara(FrmEventAttr.MonthedClass, value); } } /// /// 方法名 /// public string MonthedName { get { return this.GetParaString(FrmEventAttr.MonthedName); } set { this.SetPara(FrmEventAttr.MonthedName, value); } } /// /// 方法参数. /// public string MonthedParas { get { return this.GetParaString(FrmEventAttr.MonthedParas); } set { this.SetPara(FrmEventAttr.MonthedParas, value); } } public string FK_DBSrc { get { return this.GetValStringByKey(FrmEventAttr.FK_DBSrc); } } #endregion 参数属性. #region 基本属性 public override En.UAC HisUAC { get { UAC uac = new En.UAC(); uac.IsAdjunct = false; uac.IsDelete = false; uac.IsInsert = false; uac.IsUpdate = true; return uac; } } /// /// 节点ID /// public int FK_Node { get { return this.GetValIntByKey(FrmEventAttr.FK_Node); } set { this.SetValByKey(FrmEventAttr.FK_Node, value); } } /// /// 关联的流程编号 /// public string RefFlowNo { get { return this.GetValStringByKey(FrmEventAttr.RefFlowNo); } set { this.SetValByKey(FrmEventAttr.RefFlowNo, value); } } /// /// 流程 /// public string FK_Flow { get { return this.GetValStringByKey(FrmEventAttr.FK_Flow); } set { this.SetValByKey(FrmEventAttr.FK_Flow, value); } } /// /// 节点 /// public string FrmID { get { return this.GetValStringByKey(FrmEventAttr.FrmID); } set { this.SetValByKey(FrmEventAttr.FrmID, value); } } public void setFrmID(string val) { this.SetValByKey("FrmID", val); } public string DoDoc { get { return this.GetValStringByKey(FrmEventAttr.DoDoc).Replace("~", "'"); } set { string doc = value.Replace("'", "~"); this.SetValByKey(FrmEventAttr.DoDoc, doc); } } /// /// 执行成功提示 /// public string MsgOK(Entity en) { string val = this.GetValStringByKey(FrmEventAttr.MsgOK); if (val.Trim() == "") return ""; if (val.IndexOf('@') == -1) return val; foreach (Attr attr in en.EnMap.Attrs) { val = val.Replace("@" + attr.Key, en.GetValStringByKey(attr.Key)); } return val; } public string MsgOKString { get { return this.GetValStringByKey(FrmEventAttr.MsgOK); } set { this.SetValByKey(FrmEventAttr.MsgOK, value); } } public string MsgErrorString { get { return this.GetValStringByKey(FrmEventAttr.MsgError); } set { this.SetValByKey(FrmEventAttr.MsgError, value); } } /// /// 错误或异常提示 /// /// /// public string MsgError(Entity en) { string val = this.GetValStringByKey(FrmEventAttr.MsgError); if (val.Trim() == "") return null; if (val.IndexOf('@') == -1) return val; foreach (Attr attr in en.EnMap.Attrs) { val = val.Replace("@" + attr.Key, en.GetValStringByKey(attr.Key)); } return val; } public string FK_Event { get { return this.GetValStringByKey(FrmEventAttr.FK_Event); } set { this.SetValByKey(FrmEventAttr.FK_Event, value); } } /// /// 执行类型 /// public EventDoType HisDoType { get { return (EventDoType)this.GetValIntByKey(FrmEventAttr.EventDoType); } set { this.SetValByKey(FrmEventAttr.EventDoType, (int)value); } } public int HisDoTypeInt { get { return this.GetValIntByKey(FrmEventAttr.EventDoType); } set { this.SetValByKey(FrmEventAttr.EventDoType, value); } } #endregion #region 事件消息. /// /// 消息控制类型. /// public MsgCtrl MsgCtrl { get { return (MsgCtrl)this.GetValIntByKey(FrmEventAttr.MsgCtrl); } set { this.SetValByKey(FrmEventAttr.MsgCtrl, (int)value); } } /// /// 是否手机推送? /// public bool MobilePushEnable { get { return this.GetValBooleanByKey(FrmEventAttr.MobilePushEnable); } set { this.SetValByKey(FrmEventAttr.MobilePushEnable, value); } } public bool MailEnable { get { return this.GetValBooleanByKey(FrmEventAttr.MailEnable); } set { this.SetValByKey(FrmEventAttr.MailEnable, value); } } /// /// 邮件标题 /// public string MailTitle { get { string str = this.GetValStrByKey(FrmEventAttr.MailTitle); if (DataType.IsNullOrEmpty(str) == false) return str; switch (this.FK_Event) { case EventListNode.SendSuccess: return "新工作@Title,发送人@WebUser.No,@WebUser.Name"; case EventListNode.ShitAfter: return "移交来的新工作@Title,移交人@WebUser.No,@WebUser.Name"; case EventListNode.ReturnAfter: return "被退回来@Title,退回人@WebUser.No,@WebUser.Name"; case EventListNode.UndoneAfter: return "工作被撤销@Title,发送人@WebUser.No,@WebUser.Name"; case EventListNode.AskerReAfter: return "加签新工作@Title,发送人@WebUser.No,@WebUser.Name"; case EventListFlow.AfterFlowDel: return "工作流程被删除@Title,发送人@WebUser.No,@WebUser.Name"; case EventListFlow.FlowOverAfter: return "流程结束@Title,发送人@WebUser.No,@WebUser.Name"; default: throw new Exception("@该事件类型没有定义默认的消息模版:" + this.FK_Event); break; } return str; } } /// /// 邮件标题 /// public string MailTitle_Real { get { string str = this.GetValStrByKey(FrmEventAttr.MailTitle); return str; } set { this.SetValByKey(FrmEventAttr.MailTitle, value); } } /// /// 邮件内容 /// public string MailDoc_Real { get { return this.GetValStrByKey(FrmEventAttr.MailDoc); } set { this.SetValByKey(FrmEventAttr.MailDoc, value); } } /// /// 邮件内容模版 /// public string MailDoc { get { string str = this.GetValStrByKey(FrmEventAttr.MailDoc); if (DataType.IsNullOrEmpty(str) == false) return str; switch (this.FK_Event) { case EventListNode.SendSuccess: str += "\t\n您好:"; str += "\t\n 有新工作@Title需要您处理, 点击这里打开工作{Url} ."; str += "\t\n致! "; str += "\t\n @WebUser.No, @WebUser.Name"; str += "\t\n @RDT"; break; case EventListNode.ReturnAfter: str += "\t\n您好:"; str += "\t\n 工作@Title被退回来了, 点击这里打开工作{Url} ."; str += "\t\n 致! "; str += "\t\n @WebUser.No,@WebUser.Name"; str += "\t\n @RDT"; break; case EventListNode.ShitAfter: str += "\t\n您好:"; str += "\t\n 移交给您的工作@Title, 点击这里打开工作{Url} ."; str += "\t\n 致! "; str += "\t\n @WebUser.No,@WebUser.Name"; str += "\t\n @RDT"; break; case EventListNode.UndoneAfter: str += "\t\n您好:"; str += "\t\n 移交给您的工作@Title, 点击这里打开工作{Url} ."; str += "\t\n 致! "; str += "\t\n @WebUser.No,@WebUser.Name"; str += "\t\n @RDT"; break; case EventListNode.AskerReAfter: //加签. str += "\t\n您好:"; str += "\t\n 移交给您的工作@Title, 点击这里打开工作{Url} ."; str += "\t\n 致! "; str += "\t\n @WebUser.No,@WebUser.Name"; str += "\t\n @RDT"; break; case EventListFlow.AfterFlowDel: //流程删除 str += "\t\n您好:"; str += "\t\n 被删除的工作@Title."; str += "\t\n 致! "; str += "\t\n @WebUser.No,@WebUser.Name"; str += "\t\n @RDT"; break; case EventListFlow.FlowOverAfter: //流程结束 str += "\t\n您好:"; str += "\t\n 工作@Title已经结束,点击这里查看工作{Url}."; str += "\t\n 致! "; str += "\t\n @WebUser.No,@WebUser.Name"; str += "\t\n @RDT"; break; default: throw new Exception("@该事件类型没有定义默认的消息模版:" + this.FK_Event); break; } return str; } } /// /// 是否启用短信发送 /// public bool SMSEnable { get { return this.GetValBooleanByKey(FrmEventAttr.SMSEnable); } set { this.SetValByKey(FrmEventAttr.SMSEnable, value); } } /// /// 短信模版内容 /// public string SMSDoc_Real { get { string str = this.GetValStrByKey(FrmEventAttr.SMSDoc); return str; } set { this.SetValByKey(FrmEventAttr.SMSDoc, value); } } /// /// 短信模版内容 /// public string SMSDoc { get { string str = this.GetValStrByKey(FrmEventAttr.SMSDoc); if (DataType.IsNullOrEmpty(str) == false) return str; switch (this.FK_Event) { case EventListNode.SendSuccess: str = "有新工作@Title需要您处理, 发送人:@WebUser.No, @WebUser.Name,打开{Url} ."; break; case EventListNode.ReturnAfter: str = "工作@Title被退回,退回人:@WebUser.No, @WebUser.Name,打开{Url} ."; break; case EventListNode.ShitAfter: str = "移交工作@Title,移交人:@WebUser.No, @WebUser.Name,打开{Url} ."; break; case EventListNode.UndoneAfter: str = "工作撤销@Title,撤销人:@WebUser.No, @WebUser.Name,打开{Url}."; break; case EventListNode.AskerReAfter: //加签. str = "工作加签@Title,加签人:@WebUser.No, @WebUser.Name,打开{Url}."; break; default: throw new Exception("@该事件类型没有定义默认的消息模版:" + this.FK_Event); break; } return str; } set { this.SetValByKey(FrmEventAttr.SMSDoc, value); } } #endregion #region 构造方法 /// /// 事件 /// public FrmEvent() { } public FrmEvent(string mypk) { this.setMyPK(mypk); this.RetrieveFromDBSources(); } public FrmEvent(string fk_mapdata, string fk_Event) { this.FK_Event = fk_Event; this.setFrmID(fk_mapdata); this.setMyPK(this.FrmID + "_" + this.FK_Event); this.RetrieveFromDBSources(); } /// /// 重写基类方法 /// public override Map EnMap { get { if (this._enMap != null) return this._enMap; Map map = new Map("Sys_FrmEvent", "外部自定义事件(表单,从表,流程,节点)"); map.IndexField = FrmEventAttr.FrmID; map.AddMyPK(); //0=表单事件,1=流程,2=节点事件. map.AddTBInt(FrmEventAttr.EventSource, 0, "事件类型", true, true); map.AddTBString(FrmEventAttr.FK_Event, null, "事件标记", true, true, 0, 400, 10); map.AddTBString(FrmEventAttr.RefFlowNo, null, "关联的流程编号", true, true, 0, 10, 10); //事件类型的主键. map.AddTBString(FrmEventAttr.FrmID, null, "表单ID", true, true, 0, 100, 10); map.AddTBString(FrmEventAttr.FK_Flow, null, "流程编号", true, true, 0, 100, 10); map.AddTBInt(FrmEventAttr.FK_Node, 0, "节点ID", true, true); //执行内容. EventDoType 0=SQL,1=URL.... map.AddTBInt(FrmEventAttr.EventDoType, 0, "事件执行类型", true, true); map.AddTBString(FrmEventAttr.FK_DBSrc, "local", "数据源", true, false, 0, 100, 20); map.AddTBString(FrmEventAttr.DoDoc, null, "执行内容", true, true, 0, 400, 10); map.AddTBString(FrmEventAttr.MsgOK, null, "成功执行提示", true, true, 0, 400, 10); map.AddTBString(FrmEventAttr.MsgError, null, "异常信息提示", true, true, 0, 400, 10); #region 消息设置. 如下属性放入了节点参数信息了. map.AddDDLSysEnum(FrmEventAttr.MsgCtrl, 0, "消息发送控制", true, true, FrmEventAttr.MsgCtrl, "@0=不发送@1=按设置的下一步接受人自动发送(默认)@2=由本节点表单系统字段(IsSendEmail,IsSendSMS)来决定@3=由SDK开发者参数(IsSendEmail,IsSendSMS)来决定", true); map.AddBoolean(FrmEventAttr.MailEnable, true, "是否启用邮件发送?(如果启用就要设置邮件模版,支持ccflow表达式。)", true, true, true); map.AddTBString(FrmEventAttr.MailTitle, null, "邮件标题模版", true, false, 0, 200, 20, true); map.AddTBStringDoc(FrmEventAttr.MailDoc, null, "邮件内容模版", true, false, true); //是否启用手机短信? map.AddBoolean(FrmEventAttr.SMSEnable, false, "是否启用短信发送?(如果启用就要设置短信模版,支持ccflow表达式。)", true, true, true); map.AddTBStringDoc(FrmEventAttr.SMSDoc, null, "短信内容模版", true, false, true); map.AddBoolean(FrmEventAttr.MobilePushEnable, true, "是否推送到手机、pad端。", true, true, true); #endregion 消息设置. #region webApi设置. //@Get=Get模式@POST=Post模式 map.AddTBString("PostModel", "Get", "请求模式", true, true, 0, 100, 10); map.AddTBInt("ParaMoel", 0, "参数模式", true, true);//@0=自定义模式@1=全量模式 map.AddTBString("ParaDocs", "0", "自定义数据内容", true, true, 0, 100, 10);//@0=自定义模式@1=全量模式 map.AddTBString("ParaDTModel", "0", "数据格式", true, true, 0, 100, 10);//@0=From@1=JSON #endregion 消息设置. //参数属性 map.AddTBAtParas(4000); this._enMap = map; return this._enMap; } } #endregion protected override bool beforeUpdateInsertAction() { //设置关联的FlowNo编号,以方便流程删除与模版导入导出. if (DataType.IsNullOrEmpty(this.FK_Flow) == false) this.RefFlowNo = this.FK_Flow; if (this.FK_Node != 0) this.RefFlowNo = DBAccess.RunSQLReturnString("SELECT FK_Flow FROM WF_Node WHERE NodeID=" + this.FK_Node); if (this.FrmID.StartsWith("ND") == true) { string nodeStr = this.FrmID.Replace("ND", ""); if (DataType.IsNumStr(nodeStr) == true) { int nodeid = int.Parse(nodeStr); this.RefFlowNo = DBAccess.RunSQLReturnString("SELECT FK_Flow FROM WF_Node WHERE NodeID=" + nodeid); } } return base.beforeUpdateInsertAction(); } protected override bool beforeInsert() { //在属性实体集合插入前,clear父实体的缓存. if (DataType.IsNullOrEmpty(this.FrmID) == false) BP.Sys.Base.Glo.ClearMapDataAutoNum(this.FrmID); return base.beforeInsert(); } protected override void afterInsertUpdateAction() { base.afterInsertUpdateAction(); } protected override void afterDelete() { base.afterDelete(); } } /// /// 事件 /// public class FrmEvents : EntitiesMyPK { /// /// 执行事件 /// /// 执行类型 /// 数据实体 /// null 没有事件,其他为执行了事件。 public string DoEventNode(string dotype, Entity en) { // return null; // 2019-08-27 取消节点事件 zl return DoEventNode(dotype, en, null); } /// /// 执行事件 /// /// 执行类型 /// 数据实体 /// 参数 /// null 没有事件,其他为执行了事件。 /// /// 不再使用节点事件 2019-08-27 zl /// 原调用点有两处:(1)FrmEvent.cs 中的DoEventNode(); (2)Flow.cs中的DoFlowEventEntity()方法中,3973行 fes.DoEventNode(doType, en, atPara)。 /// 现在都已经取消调用 /// public string DoEventNode(string dotype, Entity en, string atPara) { if (this.Count == 0) return null; string val = _DoEventNode(dotype, en, atPara); if (val != null) val = val.Trim(); if (DataType.IsNullOrEmpty(val)) return ""; // 说明有事件,执行成功了。 else return val; // 没有事件. } /// /// 执行事件,事件标记是 EventList. /// /// 执行类型 /// 数据实体 /// 特殊的参数格式@key=value 方式. /// private string _DoEventNode(string dotype, Entity en, string atPara) { if (this.Count == 0) return null; FrmEvent nev = this.GetEntityByKey(FrmEventAttr.FK_Event, dotype) as FrmEvent; if (nev == null || nev.HisDoType == EventDoType.Disable) return null; #region 执行的是业务单元. if (nev.HisDoType == EventDoType.BuessUnit) { /* 获得业务单元,开始执行他 */ BuessUnitBase enBuesss = BP.Sys.Base.Glo.GetBuessUnitEntityByEnName(nev.DoDoc); enBuesss.WorkID = Int64.Parse(en.PKVal.ToString()); return enBuesss.DoIt(); } #endregion 执行的是业务单元. string doc = nev.DoDoc.Trim(); if ((doc == null || doc == "") && nev.HisDoType != EventDoType.SpecClass) //edited by liuxc,2016-01-16,执行DLL文件不需要判断doc为空 return null; #region 处理执行内容 Attrs attrs = en.EnMap.Attrs; string MsgOK = ""; string MsgErr = ""; if (nev.FK_Node != 0) { doc = doc.Replace("@FK_Node", ""+nev.FK_Node); doc = doc.Replace("@NodeID", "" + nev.FK_Node); } if (DataType.IsNullOrEmpty(nev.FK_Flow) == false) { doc = doc.Replace("@FlowNo", "" + nev.FK_Flow); doc = doc.Replace("@FK_Flow", "" + nev.FK_Flow); } doc = doc.Replace("~", "'"); doc = doc.Replace("@WebUser.No", BP.Web.WebUser.No); doc = doc.Replace("@WebUser.Name", BP.Web.WebUser.Name); doc = doc.Replace("@WebUser.FK_Dept", BP.Web.WebUser.FK_Dept); doc = doc.Replace("@FK_Node", nev.FrmID.Replace("ND", "")); doc = doc.Replace("@FrmID", nev.FrmID); doc = doc.Replace("@FK_MapData", nev.FrmID); doc = doc.Replace("@WorkID", en.GetValStrByKey("OID", "@WorkID")); doc = doc.Replace("@WebUser.OrgNo", BP.Web.WebUser.OrgNo); if (doc.Contains("@") == true) { foreach (Attr attr in attrs) { if (doc.Contains("@" + attr.Key) == false) continue; doc = doc.Replace("@" + attr.Key, en.GetValStrByKey(attr.Key)); } } //替换。 if (DataType.IsNullOrEmpty(atPara) == false && doc.Contains("@")==true) { AtPara ap = new AtPara(atPara); foreach (string key in ap.HisHT.Keys) { doc = doc.Replace("@" + key, ap.GetValStrByKey(key)); } } //SDK表单上服务器地址,应用到使用ccflow的时候使用的是sdk表单,该表单会存储在其他的服务器上. doc = doc.Replace("@SDKFromServHost", BP.Difference.SystemConfig.AppSettings["SDKFromServHost"]); if (doc.Contains("@") == true) { if (HttpContextHelper.Current != null) { /*如果是 bs 系统, 有可能参数来自于url ,就用url的参数替换它们 .*/ //string url = BP.Sys.Base.Glo.Request.RawUrl; //2019-07-25 zyt改造 string url = HttpContextHelper.RequestRawUrl; if (url.IndexOf('?') != -1) url = url.Substring(url.IndexOf('?')).TrimStart('?'); string[] paras = url.Split('&'); foreach (string s in paras) { string[] mys = s.Split('='); if (doc.Contains("@" + mys[0]) == false) continue; doc = doc.Replace("@" + mys[0], mys[1]); } } } if (nev.HisDoType == EventDoType.URLOfSelf) { if (doc.Contains("?") == false) doc += "?1=2"; doc += "&UserNo=" + WebUser.No; doc += "&Token=" + WebUser.Token; doc += "&FK_Dept=" + WebUser.FK_Dept; // doc += "&FK_Unit=" + WebUser.FK_Unit; doc += "&OID=" + en.PKVal; if (BP.Difference.SystemConfig.IsBSsystem) { /*是bs系统,并且是url参数执行类型.*/ //2019-07-25 zyt改造 string url = HttpContextHelper.RequestRawUrl; if (url.IndexOf('?') != -1) url = url.Substring(url.IndexOf('?')).TrimStart('?'); string[] paras = url.Split('&'); foreach (string s in paras) { string[] mys = s.Split('='); if (doc.Contains(mys[0] + "=")) continue; doc += "&" + s; } doc = doc.Replace("&?", "&"); } if (BP.Difference.SystemConfig.IsBSsystem == false) { /*非bs模式下调用,比如在cs模式下调用它,它就取不到参数. */ } if (doc.StartsWith("http") == false) { /*如果没有绝对路径 */ if (BP.Difference.SystemConfig.IsBSsystem) { /*在cs模式下自动获取*/ //string host = BP.Sys.Base.Glo.Request.Url.Host; //2019-07-25 zyt改造 string host = HttpContextHelper.RequestUrlHost; if (doc.Contains("@AppPath")) doc = doc.Replace("@AppPath", "http://" + host + HttpContextHelper.RequestApplicationPath); else doc = "http://" + HttpContextHelper.RequestUrlAuthority + doc; } if (BP.Difference.SystemConfig.IsBSsystem == false) { /*在cs模式下它的baseurl 从web.config中获取.*/ string cfgBaseUrl = BP.Difference.SystemConfig.HostURL; if (DataType.IsNullOrEmpty(cfgBaseUrl)) { string err = "调用url失败:没有在web.config中配置BaseUrl,导致url事件不能被执行."; BP.DA.Log.DebugWriteError(err); throw new Exception(err); } doc = cfgBaseUrl + doc; } } //增加上系统约定的参数. doc += "&EntityName=" + en.ToString() + "&EntityPK=" + en.PK + "&EntityPKVal=" + en.PKVal + "&FK_Event=" + nev.MyPK; } #endregion 处理执行内容 if (atPara != null && doc.Contains("@") == true) { AtPara ap = new AtPara(atPara); foreach (string s in ap.HisHT.Keys) doc = doc.Replace("@" + s, ap.GetValStrByKey(s)); } if (dotype == EventListFrm.FrmLoadBefore) { string frmType = en.GetParaString("FrmType"); if (DataType.IsNullOrEmpty(frmType) == true || frmType.Equals("DBList") == false) en.Retrieve(); /*如果不执行,就会造成实体的数据与查询的数据不一致.*/ } switch (nev.HisDoType) { case EventDoType.SP: case EventDoType.SQL: //SQLServer数据库中执行带参的存储过程 try { if (nev.HisDoType == EventDoType.SP && doc.Contains("=") == true && BP.Difference.SystemConfig.AppCenterDBType == DBType.MSSQL) { RunSQL(doc); return nev.MsgOK(en); } if (DataType.IsNullOrEmpty(nev.FK_DBSrc) == false && nev.FK_DBSrc.Equals("local") == false) { SFDBSrc sfdb = new SFDBSrc(nev.FK_DBSrc); sfdb.RunSQLs(doc); } else { // 允许执行带有GO的sql. DBAccess.RunSQLs(doc); } return nev.MsgOK(en); } catch (Exception ex) { throw new Exception(nev.MsgError(en) + ",异常信息:" + ex.Message); } break; case EventDoType.URLOfSelf: string myURL = doc.Clone() as string; if (myURL.Contains("http") == false) { if (BP.Difference.SystemConfig.IsBSsystem) { //string host = BP.Sys.Base.Glo.Request.Url.Host; //2019-07-25 zyt改造 string host = HttpContextHelper.RequestUrlHost; if (myURL.Contains("@AppPath")) myURL = myURL.Replace("@AppPath", "http://" + host + HttpContextHelper.RequestApplicationPath); else myURL = "http://" + HttpContextHelper.RequestUrlAuthority + myURL; } else { string cfgBaseUrl = BP.Difference.SystemConfig.HostURL; if (DataType.IsNullOrEmpty(cfgBaseUrl)) { string err = "调用url失败:没有在web.config中配置BaseUrl,导致url事件不能被执行."; BP.DA.Log.DebugWriteError(err); throw new Exception(err); } myURL = cfgBaseUrl + myURL; } } myURL = myURL.Replace("@SDKFromServHost", BP.Difference.SystemConfig.AppSettings["SDKFromServHost"]); if (myURL.Contains("&FID=") == false && en.Row.ContainsKey("FID") == true) { string str = en.Row["FID"].ToString(); myURL = myURL + "&FID=" + str; } if (myURL.Contains("&FK_Flow=") == false && en.Row.ContainsKey("FK_Flow") == true) { string str = en.Row["FK_Flow"].ToString(); myURL = myURL + "&FK_Flow=" + str; } if (myURL.Contains("&WorkID=") == false) { String str = ""; if (en.Row.ContainsKey("WorkID") == true) { str = en.Row["WorkID"].ToString(); myURL = myURL + "&WorkID=" + str; } else if (en.Row.ContainsKey("OID") == true) { str = en.Row["OID"].ToString(); myURL = myURL + "&WorkID=" + str; } } try { Encoding encode = System.Text.Encoding.GetEncoding("gb2312"); string text = DataType.ReadURLContext(myURL, 600000, encode); if (text == null) throw new Exception("@流程设计错误,执行的url错误:" + myURL + ", 返回为null, 请检查url设置是否正确。提示:您可以copy出来此url放到浏览器里看看是否被正确执行。"); if (text != null && text.Length > 7 && text.Substring(0, 7).ToLower().Contains("err")) throw new Exception(text); if (text == null || text.Trim() == "") return null; return text; } catch (Exception ex) { throw new Exception("@" + nev.MsgError(en) + " Error:" + ex.Message); } break; case EventDoType.EventBase: //执行事件类. // 获取事件类. string evName = doc.Clone() as string; BP.Sys.Base.EventBase ev = null; try { ev = BP.En.ClassFactory.GetEventBase(evName); } catch (Exception ex) { throw new Exception("@事件名称:" + evName + "拼写错误,或者系统不存在。说明:事件所在的类库必须是以BP.开头,并且类库的BP.xxx.dll。"); } if (ev == null) throw new Exception("@事件名称:" + evName + "拼写错误,或者系统不存在。说明:事件所在的类库必须是以BP.开头,并且类库的BP.xxx.dll。"); //开始执行. try { #region 处理整理参数. Row r = en.Row; try { //系统参数. r.Add("FK_MapData", en.ClassID); } catch { r["FK_MapData"] = en.ClassID; } try { r.Add("EventSource", nev.FK_Event); } catch { r["EventSource"] = nev.FK_Event; } if (atPara != null) { AtPara ap = new AtPara(atPara); foreach (string s in ap.HisHT.Keys) { try { r.Add(s, ap.GetValStrByKey(s)); } catch { r[s] = ap.GetValStrByKey(s); } } } if (BP.Difference.SystemConfig.IsBSsystem == true) { /*如果是bs系统, 就加入外部url的变量.*/ //2019 - 07 - 25 zyt改造 foreach (string key in HttpContextHelper.RequestParamKeys) { string val = HttpContextHelper.RequestParams(key); try { r.Add(key, val); } catch { r[key] = val; } } } #endregion 处理整理参数. ev.SysPara = r; ev.HisEn = en; ev.Do(); string str = ev.SucessInfo; if (str.Contains("err@") == true) throw new Exception(str); return str; } catch (Exception ex) { throw new Exception("@执行事件(" + ev.Title + ")期间出现错误:" + ex.Message); } break; case EventDoType.WSOfSelf: //执行webservices.. 为石油修改. string[] strs = doc.Split('@'); string url = ""; string method = ""; Hashtable paras = new Hashtable(); foreach (string str in strs) { if (str.Contains("=") && str.Contains("Url")) { url = str.Split('=')[2]; continue; } if (str.Contains("=") && str.Contains("Method")) { method = str.Split('=')[2]; continue; } //处理参数. string[] paraKeys = str.Split(','); if (paraKeys[3].Equals("Int")) paras.Add(paraKeys[0], int.Parse(paraKeys[1])); if (paraKeys[3].Equals("String")) paras.Add(paraKeys[0], paraKeys[1]); if (paraKeys[3].Equals("Float")) paras.Add(paraKeys[0], float.Parse(paraKeys[1])); if (paraKeys[3].Equals("Double")) paras.Add(paraKeys[0], double.Parse(paraKeys[1])); } return null; //开始执行webserives. break; /*case EventDoType.WebApi: try { //接收返回值 string postData = ""; //获取webapi接口地址 string apiUrl = doc.Clone() as string; if (apiUrl.Contains("@WebApiHost"))//可以替换配置文件中配置的webapi地址 apiUrl = apiUrl.Replace("@WebApiHost", BP.Difference.SystemConfig.AppSettings["WebApiHost"]); if (apiUrl.Contains("?") == true) apiUrl += "&WorkID=" + en.PKVal + "&UserNo=" + BP.Web.WebUser.No + "&Token=" + WebUser.Token; else apiUrl += "?WorkID=" + en.PKVal + "&UserNo=" + BP.Web.WebUser.No + "&Token=" + WebUser.Token; //api接口地址 string apiHost = apiUrl.Split('?')[0]; //api参数 string apiParams = apiUrl.Split('?')[1]; //参数替换 apiParams = BP.Tools.PubGlo.DealExp(apiParams, en); //执行POST postData = BP.Tools.PubGlo.HttpPostConnect(apiHost, apiParams); return postData; } catch (Exception ex) { throw new Exception("@" + nev.MsgError(en) + " Error:" + ex.Message); } break;*/ case EventDoType.WebApi: try { string urlExt = doc; //url. urlExt = BP.Tools.PubGlo.DealExp(urlExt, en); string urlUodel = nev.GetValStringByKey("PostModel"); //模式. Post,Get int paraMode = nev.GetValIntByKey("ParaModel"); //参数模式. 0=自定义模式, 1=全量模式. string pdocs = nev.GetValStringByKey("ParaDocs"); //参数内容. 对自定义模式有效. string paraDTModel = nev.GetValStringByKey("ParaDTModel"); //参数内容. 对自定义模式有效. bool isJson = false; if (paraDTModel.Equals("1")) isJson = true; //全量参数模式. if (paraMode == 1) { pdocs = en.ToJson(false); } else { pdocs = pdocs.Replace("~", "\""); pdocs = BP.Tools.PubGlo.DealExp(pdocs, en); if (pdocs.Contains("@") == true) throw new Exception("@_DoEvent参数不完整:" + pdocs); } //判断提交模式. string result = ""; if (urlUodel.ToLower().Equals("get") == true) result = DataType.ReadURLContext(urlExt, 9000); //返回字符串. else result = BP.Tools.PubGlo.HttpPostConnect(urlExt, pdocs, "POST", isJson); if (DataType.IsNullOrEmpty(result) == true) throw new Exception("@执行WebAPI[" + urlExt + "]没有返回结果值"); //数据序列化 var jsonData = result.ToJObject(); //code=200,表示请求成功,否则失败 string msg = jsonData["msg"] != null ? jsonData["msg"].ToString() : ""; if (!jsonData["code"].ToString().Equals("200")) throw new Exception("@执行WebAPI[" + urlExt + "]失败:" + msg); return msg; } catch (Exception ex) { throw new Exception("@" + nev.MsgError(en) + " Error:" + ex.Message); } break; case EventDoType.SpecClass: #region //执行dll文件中指定类的指定方法,added by liuxc,2016-01-16 string evdll = nev.MonthedDLL; string evclass = nev.MonthedClass; string evmethod = nev.MonthedName; string evparams = nev.MonthedParas; if (string.IsNullOrWhiteSpace(evdll) || !System.IO.File.Exists(evdll)) throw new Exception("@DLL文件【MonthedDLL】“" + (evdll ?? string.Empty) + "”设置不正确,请重新设置!"); Assembly abl = Assembly.LoadFrom(evdll); //判断类是否是静态类 Type type = abl.GetType(evclass, false); if (type == null) throw new Exception(@"@DLL文件【MonthedDLL】“" + evdll + "”中的类名【MonthedClass】“" + (evclass ?? string.Empty) + "”设置不正确,未检索到此类,请重新设置!"); //方法 if (string.IsNullOrWhiteSpace(evmethod)) throw new Exception(@"@DLL文件【MonthedDLL】“" + evdll + "”中类【MonthedClass】“" + evclass + "”的方法名【MonthedName】不能为空,请重新设置!"); MethodInfo md = null; //当前方法 ParameterInfo[] pis = null; //方法的参数集合 Dictionary pss = new Dictionary(); //参数名,参数值类型名称字典,如:Name,String string mdName = evmethod.Split('(')[0]; //方法名称 //获取method对象 if (mdName.Length == evmethod.Length - 2) { md = type.GetMethod(mdName); } else { string[] pssArr = null; //获取设置里的参数信息 foreach (string pstr in evmethod.Substring(mdName.Length + 1, evmethod.Length - mdName.Length - 2).Split(',')) { pssArr = pstr.Split(' '); pss.Add(pssArr[1], pssArr[0]); } //与设置里的参数信息对比,取得MethodInfo对象 foreach (MethodInfo m in type.GetMethods()) { if (m.Name != mdName) continue; pis = m.GetParameters(); bool isOK = true; int idx = 0; foreach (KeyValuePair ps in pss) { if (pis[idx].Name != ps.Key || pis[idx].ParameterType.ToString() .Replace("System.IO.", "") .Replace("System.", "") .Replace("System.Collections.Generic.", "") .Replace("System.Collections.", "") != ps.Value) { isOK = false; break; } idx++; } if (isOK) { md = m; break; } } } if (md == null) throw new Exception(@"@DLL文件【MonthedDLL】“" + evdll + "”中类【MonthedClass】“" + evclass + "”的方法名【MonthedName】“" + evmethod + "”设置不正确,未检索到此方法,请重新设置!"); //处理参数 object[] pvs = new object[pss.Count]; //invoke,传递的paramaters参数,数组中的项顺序与方法参数顺序一致 if (pss.Count > 0) { if (string.IsNullOrWhiteSpace(evparams)) throw new Exception(@"@DLL文件【MonthedDLL】“" + evdll + "”中类【MonthedClass】“" + evclass + "”的方法【MonthedName】“" + evmethod + "”的参数【MonthedParas】不能为空,请重新设置!"); Dictionary pds = new Dictionary(); //MonthedParas中保存的参数信息集合,格式如:title,@Title int idx = 0; int pidx = -1; string[] pdsArr = evparams.Split(';'); string val; //将参数中的名称与值分开 foreach (string p in pdsArr) { pidx = p.IndexOf('='); if (pidx == -1) continue; pds.Add(p.Substring(0, pidx), p.Substring(pidx + 1)); } foreach (KeyValuePair ps in pss) { if (!pds.ContainsKey(ps.Key)) { //设置中没有此参数的值信息,则将值赋为null pvs[idx] = null; } else { val = pds[ps.Key]; foreach (BP.En.Attr attr in en.EnMap.Attrs) { if (pds[ps.Key] == "`" + attr.Key + "`") { //表示此参数与该attr的值一致,类型也一致 pvs[idx] = en.Row[attr.Key]; break; } //替换@属性 val = val.Replace("`" + attr.Key + "`", (en.Row[attr.Key] ?? string.Empty).ToString()); } //转换参数类型,从字符串转换到参数的实际类型,NOTE:此处只列出了简单类型的转换,其他类型暂未考虑 switch (ps.Value) { case "String": pvs[idx] = val; break; case "Int32": pvs[idx] = int.Parse(val); break; case "Int64": pvs[idx] = long.Parse(val); break; case "Double": pvs[idx] = double.Parse(val); break; case "Single": pvs[idx] = float.Parse(val); break; case "Decimal": pvs[idx] = decimal.Parse(val); break; case "DateTime": pvs[idx] = DateTime.Parse(val); break; default: pvs[idx] = val; break; } } idx++; } } if (type.IsSealed && type.IsAbstract) { //静态类 return (md.Invoke(null, pvs) ?? string.Empty).ToString(); } //非静态类 //虚类必须被重写,不能直接使用 if (type.IsAbstract) return null; //静态方法 if (md.IsStatic) return (md.Invoke(null, pvs) ?? string.Empty).ToString(); //非静态方法 return (md.Invoke(abl.CreateInstance(evclass), pvs) ?? string.Empty).ToString(); #endregion case EventDoType.SFProcedure: #region 自定义存储过程 SFProcedure procedure = new SFProcedure(doc); string requestMethod = procedure.GetValStringByKey("RequestMethod"); string expDoc = procedure.GetValStringByKey("ExpDoc"); if (DataType.IsNullOrEmpty(expDoc) == true) throw new Exception("err@表达式"); SFDBSrc sfdbsrc = new SFDBSrc(procedure.FK_SFDBSrc); string dbsrcType = sfdbsrc.DBSrcType; if (dbsrcType.Equals(DBSrcType.WebApi) == true) { expDoc = BP.Tools.PubGlo.DealExp(expDoc, en); if (expDoc.StartsWith("htt") == false) expDoc = sfdbsrc.ConnString + expDoc; if (requestMethod.Equals("Get") == true) return BP.Tools.PubGlo.HttpPostConnect(expDoc, ""); if (requestMethod.Equals("POST") == true) { int paraModel = procedure.GetValIntByKey("ParaModel"); if (paraModel == 0)//主表参数 { } } } return null; #endregion 自定义存储过程 break; default: throw new Exception("@no such way." + nev.HisDoType.ToString()); } } /// /// 事件 /// public FrmEvents() { } /// /// 事件 /// /// FK_MapData public FrmEvents(string fk_MapData) { QueryObject qo = new QueryObject(this); qo.AddWhere(FrmEventAttr.FrmID, fk_MapData); qo.DoQuery(); } /// /// 事件 /// /// 按节点ID查询 public FrmEvents(int nodeID) { QueryObject qo = new QueryObject(this); qo.AddWhere(FrmEventAttr.FK_Node, nodeID); qo.DoQuery(); } public FrmEvents(int nodeID, string fk_flow) { QueryObject qo = new QueryObject(this); qo.AddWhere(FrmEventAttr.FK_Node, nodeID); qo.addOr(); qo.addLeftBracket(); qo.AddWhere(FrmEventAttr.FK_Flow, fk_flow); qo.addAnd(); qo.AddWhere(FrmEventAttr.FK_Node, 0); qo.addRightBracket(); qo.DoQuery(); } /// /// 得到它的 Entity /// public override Entity GetNewEntity { get { return new FrmEvent(); } } #region 为了适应自动翻译成java的需要,把实体转换成List. /// /// 转化成 java list,C#不能调用. /// /// List public System.Collections.Generic.IList ToJavaList() { return (System.Collections.Generic.IList)this; } /// /// 转化成list /// /// List public System.Collections.Generic.List Tolist() { System.Collections.Generic.List list = new System.Collections.Generic.List(); for (int i = 0; i < this.Count; i++) { list.Add((FrmEvent)this[i]); } return list; } #endregion 为了适应自动翻译成java的需要,把实体转换成List. } }