学步园

一：定义表单页面

1.新建StartInstance.aspx页面，修改页面类继承至BasePage

该页面显示所有的流程模板，选择模板提交后进入启动页（第一个活动项），该页面表单如下：

Start按钮事件定义如下：

protected void btnStart_Click(object sender, EventArgs e)
{
    if (ddlVersion.SelectedIndex > -1)
    {
        //根据流程类型，名称和板本，得到流程模板
        OThinker.H3.WorkflowTemplate.WorkflowTemplate workflow = OThinker.H3.Server.Engine.WorkflowManager.GetWorkflow(ddlFlowType.Text, ddlFlowName.Text, Convert.ToInt32(ddlVersion.Text));

        // 开始节点（活动项)
        OThinker.H3.WorkflowTemplate.ActivityTemplate startActivity = workflow.GetActivity(workflow.StartActivity);
        // 开始的表单
        OThinker.H3.WorkflowTemplate.Sheet startSheet = workflow.GetSheet(startActivity.SheetName);
        // URL参数,传入流程类型，名称和版本，以及操作
        System.Text.StringBuilder instanceParamBuilder = new System.Text.StringBuilder();
        foreach (string key in this.Request.QueryString.Keys)
        {
            string lowerKey = key.ToLower();
            if (lowerKey != "mode" &&
                lowerKey != "workflowpackage" &&
                lowerKey != "workflowname" &&
                lowerKey != "workflowversion")
            {
                if (instanceParamBuilder.Length > 0)
                {
                    instanceParamBuilder.Append("&");
                }

                instanceParamBuilder.Append(key + "=" + this.Request.QueryString[key]);
            }
        }
        string url = GetFlowSheetUrl(startSheet);
        this.Response.Redirect(
            url + "?" + Param_Mode + "=" + SheetMode.Originate + "&" +
             "workflowpackage=" + System.Web.HttpUtility.UrlEncode(workflow.WorkflowPackageName) + "&" +
             "workflowname=" + System.Web.HttpUtility.UrlEncode(workflow.WorkflowName) + "&" +
            "workflowversion=" + workflow.WorkflowVersion +
            (instanceParamBuilder.Length == 0 ? null : ("&" + instanceParamBuilder.ToString())));
    }
}
 

其中GetFlowSheetUrl在BasePage中定义：

 public string GetFlowSheetUrl(OThinker.H3.WorkflowTemplate.Sheet sheet)<br /> {<br /> if (string.IsNullOrEmpty(sheet.SheetAddress)) throw new ArgumentNullException(sheet.SheetName + "没有定义表单", "SheetAddress");<br /> string m_rootUrl = "http://" + HttpContext.Current.Request.Url.Authority;<br /> if (!string.IsNullOrEmpty(HttpContext.Current.Request.ApplicationPath))<br /> {<br /> m_rootUrl += HttpContext.Current.Request.ApplicationPath;<br /> }<br /> if (sheet.SheetAddress[0] == '/')<br /> {<br /> m_rootUrl += sheet.SheetAddress;<br /> }<br /> else<br /> {<br /> m_rootUrl += "/" + sheet.SheetAddress;<br /> }<br /> return m_rootUrl;<br /> }<br />

2.创建表单页面放到Examples/WorkSheets下面，取名为ApplyLeave.aspx（路径和名称自便，这里只是以本人的习惯取的）

修改页面类继承至BasePage，设计页面如下，全部用Asp.net自带的控件，不用H3的WorkSheet里的控件，怕不好扩展

提交事件定义如下：

protected void btnSubmit_Click(object sender, EventArgs e)<br /> {<br /> if (string.IsNullOrEmpty(WorkflowName) || WorkflowVersion < 0)<br /> {<br /> return;<br /> }<br /> DateTime tempTime;<br /> //验证数据...<br /> if (!DateTime.TryParse(txtStartDate.Text, out tempTime))<br /> {<br /> return;<br /> }<br /> if (!DateTime.TryParse(txtEndDate.Text, out tempTime))<br /> {<br /> return;<br /> }<br /> //保存到流程引擎<br /> string InstanceName = base.UserValidator.UserName + "的请假申请";//实例名称<br /> //获取流程模板<br /> OThinker.H3.WorkflowTemplate.WorkflowTemplate workflow = OThinker.H3.Server.Engine.WorkflowManager.GetWorkflow(WorkflowPackage, WorkflowName, WorkflowVersion);<br /> string InstanceId=null;<br /> string workItemId = null;<br /> //创建流程实例<br /> OriginateInstance(workflow, InstanceName, ref InstanceId, ref workItemId);<br /> //保存到业务库（这里有个问题，如果业务库的操作失败了怎么办，但该方法又不能写在前面，因为WorkItemId得从H3的接口返回）<br /> Microsoft.Practices.EnterpriseLibrary.Data.Database dataBase = Microsoft.Practices.EnterpriseLibrary.Data.DatabaseFactory.CreateDatabase();<br /> string sql = string.Format("insert into [ApplyLeaveInfo] ([startDate],[endDate] ,[ApplyResult],[WorkItemId]) values('{0}','{1}','false','{2}')", txtStartDate.Text, txtEndDate.Text, workItemId);<br /> dataBase.ExecuteNonQuery(System.Data.CommandType.Text, sql);<br /> //返回待处理<br /> Response.Redirect("../../default.aspx");</p> <p> }<br />

其中OriginateInstance为创建流程实例的方法，该方法里保存了实例记录，并且通过Soket通知H3服务一个实例创建的消息，服务接到消息后会在WorkItem中插入一条发起的消息，不过还没完，还得要记录下一步的操作数据，要不然下一步的用户在待处理列表里就看不到了

 /// <summary><br /> /// 启动一个流程实例，并且提交起始活动项<br /> /// </summary><br /> /// <param name="Workflow">流程模板对象</param><br /> /// <param name="InstanceName">实例名称</param><br /> /// <param name="InstanceId">实例编号</param><br /> /// <param name="workItemId">起始流动项在OT_WorkItem的ID</param><br /> public void OriginateInstance(OThinker.H3.WorkflowTemplate.WorkflowTemplate Workflow, string InstanceName, ref string InstanceId, ref string workItemId)<br /> {<br /> OThinker.H3.Acl.UserValidator userValidator = this.UserValidator;</p> <p> if (Workflow == null)<br /> {<br /> throw new ArgumentNullException("流程模板不存在", "Workflow");<br /> }<br /> //开始一个流程实例<br /> InstanceId = OThinker.H3.Server.Engine.InstanceManager.CreateInstance(WorkflowPackage,<br /> WorkflowName,<br /> WorkflowVersion,<br /> InstanceName,<br /> userValidator.UserID,<br /> null,<br /> userValidator.Department,<br /> false,<br /> "",<br /> null,<br /> -1L);<br /> OThinker.H3.Messages.MessageEmergencyType normal = OThinker.H3.Messages.MessageEmergencyType.Normal;<br /> if (Workflow.StartWithSheet)<br /> {<br /> normal = OThinker.H3.Messages.MessageEmergencyType.High;<br /> }<br /> //发送实例消息给服务<br /> OThinker.H3.Messages.StartInstanceMessage message = new OThinker.H3.Messages.StartInstanceMessage(<br /> normal,<br /> InstanceId,<br /> null,<br /> OThinker.H3.Instance.PriorityType.Normal,<br /> false,<br /> 0L,<br /> -1L,<br /> null);<br /> OThinker.H3.Server.Engine.InstanceManager.SendMessage(message);<br /> //记录WorkItem,失败后尝试10次<br /> string[] strArray = null;<br /> for (int i = 0; i < 10; i++)<br /> {<br /> System.Threading.Thread.Sleep(1500);<br /> strArray = OThinker.H3.Server.Engine.WorkItemManager.Query(null,<br /> new string[] { InstanceId },<br /> new string[] { userValidator.UserID },<br /> DateTime.MinValue,<br /> DateTime.MaxValue,<br /> OThinker.H3.WorkItem.WorkItemState.Unfinished<br /> );<br /> if ((strArray != null) && (strArray.Length != 0))<br /> {<br /> break;<br /> }<br /> }<br /> if ((strArray == null) || (strArray.Length == 0))<br /> {<br /> throw new Exception("发起流程失败");<br /> }<br /> workItemId = strArray[0];<br /> //提交起始活动项<br /> SubmitWorkItem(Workflow, workItemId);<br /> }</p> <p>/// <summary><br /> /// 提交流程步骤<br /> /// </summary><br /> /// <param name="Workflow">流程模板对象</param><br /> /// <param name="workItemId">活动项ID</param><br /> public void SubmitWorkItem(OThinker.H3.WorkflowTemplate.WorkflowTemplate Workflow, string workItemId)<br /> {<br /> OThinker.H3.Acl.UserValidator userValidator = this.UserValidator;<br /> OThinker.H3.WorkItem.WorkItem workItem = OThinker.H3.Server.Engine.WorkItemManager.GetWorkItem(workItemId);<br /> workItem.State = OThinker.H3.WorkItem.WorkItemState.Finished;<br /> //完成活动<br /> OThinker.H3.Server.Engine.WorkItemManager.FinishWorkItem(workItemId, this.UserValidator.UserID, null, OThinker.Data.BoolMatchValue.Unspecified, null);<br /> // 设置操作描述（Portal有这一步骤，不知道去掉后会有影响没）<br /> string description = "submit";<br /> OThinker.H3.Server.Engine.TokenPool.AppendDescription(workItem.InstanceId, workItem.TokenId, description);<br /> OThinker.H3.WorkflowTemplate.ActivityTemplate destActivityTemplate = Workflow.GetActivity(DestActivityName);<br /> //如果地址栏没有传入下一活动名称<br /> if (destActivityTemplate == null)<br /> {<br /> // 需要通知实例事件管理器结束事件<br /> OThinker.H3.Messages.AsyncEndMessage endMessage = new OThinker.H3.Messages.AsyncEndMessage(<br /> OThinker.H3.Messages.MessageEmergencyType.Normal,<br /> workItem.InstanceId,<br /> workItem.ActivityName,<br /> workItem.ReplyID,<br /> true,<br /> this.UserValidator.UserID,<br /> OThinker.Data.BoolMatchValue.Unspecified,<br /> null,<br /> null);<br /> OThinker.H3.Server.Engine.InstanceManager.SendMessage(endMessage);<br /> }<br /> else<br /> {</p> <p> // 准备触发后面Activity的消息<br /> OThinker.H3.Messages.ActivateActivityMessage activateMessage<br /> = new OThinker.H3.Messages.ActivateActivityMessage(<br /> OThinker.H3.Messages.MessageEmergencyType.Normal,<br /> workItem.InstanceId,<br /> destActivityTemplate.Name,<br /> OThinker.H3.Instance.Token.UnspecifiedID,<br /> null,<br /> new long[] { workItem.TokenId },<br /> false,<br /> OThinker.H3.Messages.ActivateType.Normal,<br /> null);</p> <p> // 通知该活动已经完成<br /> OThinker.H3.Messages.AsyncEndMessage endMessage =<br /> new OThinker.H3.Messages.AsyncEndMessage(<br /> OThinker.H3.Messages.MessageEmergencyType.Normal,<br /> workItem.InstanceId,<br /> workItem.ActivityName,<br /> workItem.ReplyID,<br /> false,<br /> userValidator.UserID,<br /> OThinker.Data.BoolMatchValue.Unspecified,<br /> activateMessage,<br /> null);<br /> OThinker.H3.Server.Engine.InstanceManager.SendMessage(endMessage);<br /> }</p> <p>}<br />

源码下源：FlowSite