|
|
using System;
|
|
|
using System.Collections;
|
|
|
using System.Data;
|
|
|
using BP.DA;
|
|
|
using BP.En;
|
|
|
using BP.Difference;
|
|
|
using BP.Web;
|
|
|
using BP.Sys;
|
|
|
using BP.WF.XML;
|
|
|
|
|
|
namespace BP.WF
|
|
|
{
|
|
|
/// <summary>
|
|
|
/// 流程事件基类
|
|
|
/// 0,集成该基类的子类,可以重写事件的方法与基类交互.
|
|
|
/// 1,一个子类必须与一个流程模版绑定.
|
|
|
/// 2,基类里有很多流程运行过程中的变量，这些变量可以辅助开发者在编写复杂的业务逻辑的时候使用.
|
|
|
/// 3,该基类有一个子类模版，位于:\CCFlow\WF\Admin\AttrFlow\F001Templepte.cs .
|
|
|
/// </summary>
|
|
|
abstract public class FlowEventBase
|
|
|
{
|
|
|
#region 要求子类强制重写的属性.
|
|
|
/// <summary>
|
|
|
/// 流程编号/流程标记.
|
|
|
/// 该参数用于说明要把此事件注册到那一个流程模版上.
|
|
|
/// </summary>
|
|
|
abstract public string FlowMark
|
|
|
{
|
|
|
get;
|
|
|
}
|
|
|
#endregion 要求子类重写的属性.
|
|
|
|
|
|
#region 属性/内部变量(流程在运行的时候触发各类事件，子类可以访问这些属性来获取引擎内部的信息).
|
|
|
/// <summary>
|
|
|
/// 发送对象
|
|
|
/// </summary>
|
|
|
public SendReturnObjs SendReturnObjs = null;
|
|
|
/// <summary>
|
|
|
/// 实体，一般是工作实体
|
|
|
/// </summary>
|
|
|
public Entity HisEn = null;
|
|
|
private Node _hisNode = null;
|
|
|
/// <summary>
|
|
|
/// 当前节点
|
|
|
/// </summary>
|
|
|
public Node HisNode
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return _hisNode;
|
|
|
}
|
|
|
set
|
|
|
{
|
|
|
_hisNode = value;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 流程注册表
|
|
|
/// </summary>
|
|
|
public GenerWorkFlow HisGenerWorkFlow = null;
|
|
|
/// <summary>
|
|
|
/// 参数对象.
|
|
|
/// </summary>
|
|
|
private Row _SysPara = null;
|
|
|
/// <summary>
|
|
|
/// 参数
|
|
|
/// </summary>
|
|
|
public Row SysPara
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
if (_SysPara == null)
|
|
|
_SysPara = new Row();
|
|
|
return _SysPara;
|
|
|
}
|
|
|
set
|
|
|
{
|
|
|
_SysPara = value;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 成功信息
|
|
|
/// </summary>
|
|
|
public string SucessInfo = null;
|
|
|
#endregion 属性/内部变量(流程在运行的时候触发各类事件，子类可以访问这些属性来获取引擎内部的信息).
|
|
|
|
|
|
#region 在发送前的事件里可以改变参数.
|
|
|
/// <summary>
|
|
|
/// 要跳转的节点.(开发人员可以设置该参数,改变发送到的节点转向.)
|
|
|
/// </summary>
|
|
|
private int _JumpToNodeID = 0;
|
|
|
public int JumpToNodeID
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return _JumpToNodeID;
|
|
|
}
|
|
|
set
|
|
|
{
|
|
|
this._JumpToNodeID = value;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 接受人, (开发人员可以设置该参数,改变接受人的范围.)
|
|
|
/// </summary>
|
|
|
private string _JumpToEmps = null;
|
|
|
public string JumpToEmps
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return _JumpToEmps;
|
|
|
}
|
|
|
set
|
|
|
{
|
|
|
this._JumpToEmps = value;
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 是否停止流程？
|
|
|
/// </summary>
|
|
|
public bool ItIsStopFlow = false;
|
|
|
#endregion 在发送前的事件里可以改变参数
|
|
|
|
|
|
#region 系统参数
|
|
|
/// <summary>
|
|
|
/// 表单ID
|
|
|
/// </summary>
|
|
|
public string FK_Mapdata
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStr("FK_MapData");
|
|
|
}
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 常用属性.
|
|
|
/// <summary>
|
|
|
/// 工作ID
|
|
|
/// </summary>
|
|
|
public int OID
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValInt("OID");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 工作ID
|
|
|
/// </summary>
|
|
|
public Int64 WorkID
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
return this.GetValInt64("WorkID"); /*有可能开始节点的WorkID=0*/
|
|
|
}
|
|
|
catch (Exception)
|
|
|
{
|
|
|
return this.OID;
|
|
|
}
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 流程ID
|
|
|
/// </summary>
|
|
|
public Int64 FID
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValInt64("FID");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 传过来的WorkIDs集合，子流程.
|
|
|
/// </summary>
|
|
|
public string WorkIDs
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStr("WorkIDs");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 编号集合s
|
|
|
/// </summary>
|
|
|
public string Nos
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStr("Nos");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 项目编号
|
|
|
/// </summary>
|
|
|
public string PrjNo
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStr("PrjNo");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 项目名称
|
|
|
/// </summary>
|
|
|
public string PrjName
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStr("PrjName");
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 流程标题
|
|
|
/// </summary>
|
|
|
public string Title
|
|
|
{
|
|
|
get
|
|
|
{
|
|
|
return this.GetValStr(GERptAttr.Title);
|
|
|
}
|
|
|
}
|
|
|
#endregion 常用属性.
|
|
|
|
|
|
#region 获取参数方法
|
|
|
/// <summary>
|
|
|
/// 事件参数
|
|
|
/// </summary>
|
|
|
/// <param name="key">时间字段</param>
|
|
|
/// <returns>根据字段返回一个时间,如果为Null,或者不存在就抛出异常.</returns>
|
|
|
public DateTime GetValDateTime(string key)
|
|
|
{
|
|
|
try
|
|
|
{
|
|
|
string str = this.SysPara.GetValByKey(key).ToString();
|
|
|
return DataType.ParseSysDateTime2DateTime(str);
|
|
|
}
|
|
|
catch (Exception ex)
|
|
|
{
|
|
|
throw new Exception("@流程事件实体在获取参数期间出现错误，请确认字段(" + key + ")是否拼写正确,技术信息:" + ex.Message);
|
|
|
}
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取字符串参数
|
|
|
/// </summary>
|
|
|
/// <param name="key">key</param>
|
|
|
/// <returns>如果为Null,或者不存在就抛出异常</returns>
|
|
|
public string GetValStr(string key)
|
|
|
{
|
|
|
if (this.SysPara.ContainsKey(key) == false)
|
|
|
throw new Exception("@流程事件实体在获取参数期间出现错误，请确认字段(" + key + ")是否拼写正确.");
|
|
|
|
|
|
return this.SysPara.GetValByKey(key).ToString();
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取Int64的数值
|
|
|
/// </summary>
|
|
|
/// <param name="key">键值</param>
|
|
|
/// <returns>如果为Null,或者不存在就抛出异常</returns>
|
|
|
public Int64 GetValInt64(string key)
|
|
|
{
|
|
|
return Int64.Parse(this.GetValStr(key));
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取int的数值
|
|
|
/// </summary>
|
|
|
/// <param name="key">键值</param>
|
|
|
/// <returns>如果为Null,或者不存在就抛出异常</returns>
|
|
|
public int GetValInt(string key)
|
|
|
{
|
|
|
return int.Parse(this.GetValStr(key));
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取Boolen值
|
|
|
/// </summary>
|
|
|
/// <param name="key">字段</param>
|
|
|
/// <returns>如果为Null,或者不存在就抛出异常</returns>
|
|
|
public bool GetValBoolen(string key)
|
|
|
{
|
|
|
if (int.Parse(this.GetValStr(key)) == 0)
|
|
|
return false;
|
|
|
return true;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 获取decimal的数值
|
|
|
/// </summary>
|
|
|
/// <param name="key">字段</param>
|
|
|
/// <returns>如果为Null,或者不存在就抛出异常</returns>
|
|
|
public decimal GetValDecimal(string key)
|
|
|
{
|
|
|
return decimal.Parse(this.GetValStr(key));
|
|
|
}
|
|
|
#endregion 获取参数方法
|
|
|
|
|
|
#region 构造方法
|
|
|
/// <summary>
|
|
|
/// 流程事件基类
|
|
|
/// </summary>
|
|
|
public FlowEventBase()
|
|
|
{
|
|
|
}
|
|
|
#endregion 构造方法
|
|
|
|
|
|
#region 节点表单事件
|
|
|
public virtual string FrmLoadAfter()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
public virtual string FrmLoadBefore()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
#endregion
|
|
|
|
|
|
#region 要求子类重写的方法(流程事件).
|
|
|
/// <summary>
|
|
|
/// 当创建WorkID的时候
|
|
|
/// </summary>
|
|
|
/// <returns>创建WorkID所执行的操作</returns>
|
|
|
public virtual string FlowOnCreateWorkID()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 流程完成前
|
|
|
/// </summary>
|
|
|
/// <returns>返回null，不提示信息，返回string提示结束信息,抛出异常就阻止流程删除.</returns>
|
|
|
public virtual string FlowOverBefore()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 流程结束后
|
|
|
/// </summary>
|
|
|
/// <returns>返回null，不提示信息，返回string提示结束信息,抛出异常不处理。</returns>
|
|
|
public virtual string FlowOverAfter()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 流程删除前
|
|
|
/// </summary>
|
|
|
/// <returns>返回null,不提示信息,返回信息，提示删除警告/提示信息, 抛出异常阻止删除操作.</returns>
|
|
|
public virtual string BeforeFlowDel()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 流程删除后
|
|
|
/// </summary>
|
|
|
/// <returns>返回null,不提示信息,返回信息，提示删除警告/提示信息, 抛出异常不处理.</returns>
|
|
|
public virtual string AfterFlowDel()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
#endregion 要求子类重写的方法(流程事件).
|
|
|
|
|
|
#region 要求子类重写的方法(节点事件).
|
|
|
/// <summary>
|
|
|
/// 保存后
|
|
|
/// </summary>
|
|
|
public virtual string SaveAfter()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 保存前
|
|
|
/// </summary>
|
|
|
public virtual string SaveBefore()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 创建工作ID后的事件
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string CreateWorkID()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
///发送前 @Info=xxxx@ToNodeID=xxxx@ToEmps=xxxx
|
|
|
/// </summary>
|
|
|
public virtual string SendWhen()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 发送成功时
|
|
|
/// </summary>
|
|
|
public virtual string SendSuccess()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 发送失败
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string SendError()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 退回前
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string ReturnBefore() { return null; }
|
|
|
/// <summary>
|
|
|
/// 退后后
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string ReturnAfter() { return null; }
|
|
|
/// <summary>
|
|
|
/// 撤销之前
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string UndoneBefore() { return null; }
|
|
|
/// <summary>
|
|
|
/// 撤销之后
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string UndoneAfter() { return null; }
|
|
|
/// <summary>
|
|
|
/// 移交后
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string ShiftAfter()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 加签后
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string AskerAfter()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 加签答复后
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string AskerReAfter()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 队列节点发送后
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string QueueSendAfter()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
/// <summary>
|
|
|
/// 工作到达的时候
|
|
|
/// </summary>
|
|
|
/// <returns></returns>
|
|
|
public virtual string WorkArrive()
|
|
|
{
|
|
|
return null;
|
|
|
}
|
|
|
#endregion 要求子类重写的方法(节点事件).
|
|
|
|
|
|
#region 基类方法.
|
|
|
/// <summary>
|
|
|
/// 执行事件
|
|
|
/// </summary>
|
|
|
/// <param name="eventType">事件类型</param>
|
|
|
/// <param name="en">实体参数</param>
|
|
|
public string DoIt(string eventType, Node currNode, Entity en, string atPara, int jumpToNodeID = 0, string toEmps = null,GenerWorkFlow hisGWF=null)
|
|
|
{
|
|
|
this.HisEn = en;
|
|
|
this.HisNode = currNode;
|
|
|
this.HisGenerWorkFlow = hisGWF;
|
|
|
// this.WorkID = en.GetValInt64ByKey("OID");
|
|
|
this.JumpToEmps = toEmps;
|
|
|
this.JumpToNodeID = jumpToNodeID;
|
|
|
this.SysPara = null;
|
|
|
this.ItIsStopFlow = false;
|
|
|
|
|
|
#region 处理参数.
|
|
|
Row r = en.Row;
|
|
|
|
|
|
//系统参数.
|
|
|
if (r.ContainsKey("FK_MapData") == true)
|
|
|
r["FK_MapData"] = en.ClassID;
|
|
|
else
|
|
|
r.Add("FK_MapData", en.ClassID);
|
|
|
|
|
|
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的变量.*/
|
|
|
foreach (string key in HttpContextHelper.RequestParamKeys)
|
|
|
{
|
|
|
if ( key == null)
|
|
|
continue;
|
|
|
|
|
|
switch (key)
|
|
|
{
|
|
|
case "WorkID":
|
|
|
case "NodeID":
|
|
|
case "FrmID":
|
|
|
case "IsReadonly":
|
|
|
case "__VIEWSTATE":
|
|
|
case "__EVENTVALIDATION":
|
|
|
case "OID":
|
|
|
continue;
|
|
|
default:
|
|
|
break;
|
|
|
}
|
|
|
|
|
|
|
|
|
string val = HttpContextHelper.RequestParams(key); //BP.Sys.Base.Glo.Request.QueryString[key];
|
|
|
|
|
|
if (r.ContainsKey(key) == true)
|
|
|
r[key] = val;
|
|
|
else
|
|
|
r.Add(key, val);
|
|
|
}
|
|
|
}
|
|
|
this.SysPara = r;
|
|
|
#endregion 处理参数.
|
|
|
|
|
|
#region 执行事件.
|
|
|
switch (eventType)
|
|
|
{
|
|
|
case EventListFlow.FlowOnCreateWorkID: // 节点表单事件。
|
|
|
return this.CreateWorkID();
|
|
|
case EventListNode.FrmLoadAfter: // 节点表单事件。
|
|
|
return this.FrmLoadAfter();
|
|
|
case EventListNode.FrmLoadBefore: // 节点表单事件。
|
|
|
return this.FrmLoadBefore();
|
|
|
case EventListNode.NodeFrmSaveAfter: // 节点事件 保存后。
|
|
|
return this.SaveAfter();
|
|
|
case EventListNode.NodeFrmSaveBefore: // 节点事件 - 保存前.。
|
|
|
return this.SaveBefore();
|
|
|
case EventListNode.SendWhen: // 节点事件 - 发送前。
|
|
|
|
|
|
this.ItIsStopFlow = false;
|
|
|
|
|
|
string str = this.SendWhen();
|
|
|
|
|
|
if (this.ItIsStopFlow == true)
|
|
|
return "@Info=" + str + "@IsStopFlow=1";
|
|
|
|
|
|
if (this.JumpToNodeID == 0 && this.JumpToEmps == null)
|
|
|
return str;
|
|
|
|
|
|
//返回这个格式, NodeSend 来解析.
|
|
|
return "@Info=" + str + "@ToNodeID=" + this.JumpToNodeID + "@ToEmps=" + this.JumpToEmps;
|
|
|
|
|
|
case EventListNode.SendSuccess: // 节点事件 - 发送成功时。
|
|
|
return this.SendSuccess();
|
|
|
case EventListNode.SendError: // 节点事件 - 发送失败。
|
|
|
return this.SendError();
|
|
|
case EventListNode.ReturnBefore: // 节点事件 - 退回前。
|
|
|
return this.ReturnBefore();
|
|
|
case EventListNode.ReturnAfter: // 节点事件 - 退回后。
|
|
|
return this.ReturnAfter();
|
|
|
case EventListNode.UndoneBefore: // 节点事件 - 撤销前。
|
|
|
return this.UndoneBefore();
|
|
|
case EventListNode.UndoneAfter: // 节点事件 - 撤销后。
|
|
|
return this.UndoneAfter();
|
|
|
case EventListNode.ShitAfter:// 节点事件-移交后
|
|
|
return this.ShiftAfter();
|
|
|
case EventListNode.AskerAfter://节点事件 加签后
|
|
|
return this.AskerAfter();
|
|
|
case EventListNode.AskerReAfter://节点事件加签回复后
|
|
|
return this.FlowOverBefore();
|
|
|
case EventListNode.QueueSendAfter://队列节点发送后
|
|
|
return this.AskerReAfter();
|
|
|
|
|
|
case EventListFlow.FlowOverBefore: // 流程结束前.。
|
|
|
return this.FlowOverBefore();
|
|
|
case EventListFlow.FlowOverAfter: // 流程结束后。
|
|
|
return this.FlowOverAfter();
|
|
|
case EventListFlow.BeforeFlowDel: // 流程删除前。
|
|
|
return this.BeforeFlowDel();
|
|
|
case EventListFlow.AfterFlowDel: // 删除后.
|
|
|
return this.AfterFlowDel();
|
|
|
case EventListNode.WorkArrive: // 工作到达时.
|
|
|
return this.WorkArrive();
|
|
|
default:
|
|
|
throw new Exception("@没有判断的事件类型:" + eventType);
|
|
|
break;
|
|
|
}
|
|
|
#endregion 执行事件.
|
|
|
return null;
|
|
|
}
|
|
|
#endregion 基类方法.
|
|
|
}
|
|
|
}
|