jbpm流程图

<?xml version="1.0" encoding="UTF-8"?>

<process-definition  xmlns=""  name="ibhSetAndDevelopeSetFlow">
   
    <start-state name="申请">
           <task name="project_1">
               <controller>
                    <variable access="read,write,required" name="工程编号" mapped-name="OrderId"></variable>
                    <variable access="read,write,required" name="项目名称" mapped-name="projectName"></variable>
                    <variable access="read,write,required" name="任务id" mapped-name="tid"></variable>
                </controller>                    
         </task>           
        <transition to="申报设计施工图"></transition>
    </start-state>
   

    <task-node name="申报设计施工图">
        <task name="申报设计施工图">
             <description>
                  14:市场发展部操作员
             </description>     
             <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="设计施工图晒预算图"></transition>
    </task-node>

    <task-node name="设计施工图晒预算图">
        <task name="设计施工图晒预算图">
            <description>
                  15:申报设计施工图
             </description>   
             <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="编制工程预算"></transition>
        <transition to="申报设计施工图" name="申报设计施工图"></transition>
    </task-node>

    <task-node name="编制工程预算">
        <task name="编制工程预算">
            <description>
                16:设计施工图晒预算图
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
            </task>
        <transition to="工程预算审计"></transition>   
        <transition to="设计施工图晒预算图" name="设计施工图晒预算图"></transition>
    </task-node>

    <task-node name="工程预算审计">
        <task name="工程预算审计">
            <description>
                20:编制工程预算
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="工程预算审批"></transition>
        <transition to="编制工程预算" name="编制工程预算"></transition>
    </task-node>

    <task-node name="工程预算审批">
        <task name="工程预算审批">
            <description>
                19:工程预算审计
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="转交工程预算及施工图"></transition>
        <transition to="工程预算审计" name="工程预算审计"></transition>
    </task-node>

    <task-node name="转交工程预算及施工图">
        <task name="转交工程预算及施工图">
            <description>
                16:工程预算审批
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment> 
        </task>
        <transition to="客户办理施工手续、缴清工程建设款后通知晒图"></transition>
        <transition to="工程预算审批" name="工程预算审批"></transition>
    </task-node>

    <task-node name="客户办理施工手续、缴清工程建设款后通知晒图">
        <task name="客户办理施工手续、缴清工程建设款后通知晒图">
            <description>
                14:转交工程预算及施工图
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="晒施工图移交施工图"></transition>
        <transition to="转交工程预算及施工图" name="转交工程预算及施工图"></transition>
    </task-node>

    <task-node name="晒施工图移交施工图">
        <task name="晒施工图移交施工图">
            <description>
                15:客户办理施工手续、缴清工程建设款后通知晒图
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="发放施工图"></transition>
        <transition to="客户办理施工手续、缴清工程建设款后通知晒图" name="客户办理施工手续、缴清工程建设款后通知晒图"></transition>
    </task-node>

    <task-node name="发放施工图">
        <task name="发放施工图">
            <description>
                16:晒施工图移交施工图
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="接装手续办理完毕下施工任务"></transition>
        <transition to="晒施工图移交施工图" name="晒施工图移交施工图"></transition>
    </task-node>

    <task-node name="接装手续办理完毕下施工任务">   
        <task name="接装手续办理完毕下施工任务">
            <description>
                14:发放施工图
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="下达施工、监理及技术服务通知书"></transition>
        <transition to="发放施工图" name="发放施工图"></transition>
    </task-node>

    <task-node name="下达施工、监理及技术服务通知书">
        <task name="下达施工、监理及技术服务通知书">
            <description>
                16:接装手续办理完毕下施工任务
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="接受工程技术服务任务"></transition>
        <transition to="接装手续办理完毕下施工任务" name="接装手续办理完毕下施工任务"></transition>
    </task-node>

    <task-node name="接受工程技术服务任务">
        <task name="接受工程技术服务任务">
            <description>
                15:下达施工、监理及技术服务通知书
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="办理工程施工手续"></transition>
        <transition to="下达施工、监理及技术服务通知书" name="下达施工、监理及技术服务通知书"></transition>
    </task-node>

    <task-node name="办理工程施工手续">
        <task name="办理工程施工手续">
            <description>
                16:接受工程技术服务任务
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="工程管理、协调、签证"></transition>
        <transition to="接受工程技术服务任务" name="接受工程技术服务任务"></transition>
    </task-node>

    <task-node name="工程管理、协调、签证">
        <task name="工程管理、协调、签证">
            <description>
                16:办理工程施工手续
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="工程技术服务、技术变更"></transition>
        <transition to="办理工程施工手续" name="办理工程施工手续"></transition>
    </task-node>

    <task-node name="工程技术服务、技术变更">
        <task name="工程技术服务、技术变更">
            <description>
                15:工程管理、协调、签证
            </description>       
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment> 
        </task>
        <transition to="检查工程安全、质量"></transition>
        <transition to="工程管理、协调、签证" name="工程管理、协调、签证"></transition>
    </task-node>

    <task-node name="检查工程安全、质量">
        <task name="检查工程安全、质量">
            <description>
                17:工程技术服务、技术变更
            </description>   
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment> 
        </task>
        <transition to="验收 "></transition>
        <transition to="工程技术服务、技术变更" name="工程技术服务、技术变更"></transition>
    </task-node>

    <task-node name="验收 ">
        <task name="验收">
            <description>
                17:检查工程安全、质量
            </description>   
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment> 
        </task>
        <transition to="建档"></transition>
        <transition to="检查工程安全、质量" name="检查工程安全、质量"></transition>
    </task-node>

    <task-node name="建档">
        <task name="建档">
            <description>
                  14:验收
             </description>     
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment> 
        </task>
        <transition to="接受客户资料"></transition>
        <transition to="验收 " name="验收"></transition>
    </task-node>

    <task-node name="接受客户资料">
        <task name="接受客户资料">
            <description>
                  14:建档
             </description>     
            <assignment class="org.springmodules.workflow.jbpm31.JbpmHandlerProxy" config-type="bean">
                  <targetBean>ProjectAssignHandler</targetBean>
                  <factoryKey>jbpmConfiguration</factoryKey>
             </assignment>
        </task>
        <transition to="结束"></transition>
        <transition to="建档" name="建档"></transition>
    </task-node>

    <end-state name="结束"></end-state>


</process-definition>

 

 

handler

 

package com.together.crm.assignment;

import java.math.BigDecimal;
import java.util.List;

import org.jbpm.graph.exe.ExecutionContext;
import org.jbpm.taskmgmt.def.AssignmentHandler;
import org.jbpm.taskmgmt.exe.Assignable;
import org.jbpm.JbpmContext;
import org.jbpm.context.exe.ContextInstance;

import com.together.crm.util.CommonSearch;
import com.together.sys.action.BaseAction;
import com.together.sys.service.OrgEmployeeService;
import com.together.sys.service.OrgOrganizationService;
import com.together.sys.vo.SysEmployee;
import com.together.sys.vo.SysOrganization;

public class ProjectAssignHandler extends BaseAction implements AssignmentHandler {
    private static final long serialVersionUID = 1L;
    private OrgEmployeeService empService;
    private OrgOrganizationService orgService;
    /**
     * 构造注入
     * @param empService
     */
    public ProjectAssignHandler(OrgEmployeeService empService,OrgOrganizationService orgService) {
        this.empService = empService;
        this.orgService=orgService;
    }
    public void assign(Assignable assignable, ExecutionContext executionContext)
            throws Exception {
        //获得这一步的变量:处理部门
//        String handleDept=executionContext.getVariable("HandleDept").toString();
//        String handleTeam=executionContext.getVariable("HandleTeam").toString();
        //获得当前任务节点对应的角色
        String description=executionContext.getTask().getDescription();
        JbpmContext ctx = executionContext.getJbpmContext();
        ContextInstance ci = executionContext.getContextInstance();
        Long tid = executionContext.getTask().getId();
        System.out.println("tid "+tid);
        System.out.println("fdf"+description);
        System.out.println("ff"+description.substring(0,description.indexOf(":")));
        System.out.println(empService.hashCode());
        //根据角色key查询对应的人员列表
        Integer roleKey = Integer.parseInt(description.substring(0,description.indexOf(":")));
        System.out.println(roleKey);
        List<SysEmployee> list=empService.getUsersByRoleKey(roleKey);
        System.out.println("ff"+list.size());
        //List<SysEmployee> list=empService.getUsersByRoleKey(new Integer(description.substring(0,description.indexOf(":"))));
        StringBuffer userIds=new StringBuffer("");
        for(int i = 0; i < list.size(); i++) {
            SysEmployee employee=(SysEmployee)list.get(i);
            userIds.append(employee.getUserid()+",");
            System.out.println("33"+userIds.toString());
        };
        if (!userIds.equals("")) {
            userIds=new StringBuffer(userIds.substring(0,userIds.lastIndexOf(",")));
        }
        // 获取这一步的参与者
        String ass = userIds.toString();
        // 流程进入的时候同时设置一个变量，这个变量名称是当前节点名称，值是 当前参与者(为了回退时不用再查询一遍)
        executionContext.setVariable(executionContext.getTask().getName(),ass);
        ci.setVariable("tid", tid);
        String[] colAss = ass.split(","); // 分离成数组
        // 设置参与者
        executionContext.getTaskInstance().setPooledActors(colAss);
        executionContext.getTaskInstance().setActorId(null);
        // 保存流程
        executionContext.getJbpmContext().save(executionContext.getContextInstance().getProcessInstance());
    }

}

 

action 函数

 

    /**
     * define by wl
     * 时间：2010-02-23
     * description:勘察状态
     */
    public void nextOption() throws Exception{
        String message ;
        System.out.println("fff");
        try{
            String orderId = getRequest().getParameter("orderId");
            String tid = getRequest().getParameter("tid");
           
            SomOrder order = this.somOrderService.selectByPrimaryKey(orderId);
            //流程推送
            JbpmContext ctx = this.jbpmConfiguration.createJbpmContext();
            ProcessInstance pi = ctx.loadProcessInstance(new Long(order.getProcessInstanceId().toString()));
            ContextInstance ci =pi.getContextInstance();
            ci.setVariable("OrderId", orderId);
            ci.setVariable("projectName", this.model.getProjectName());       
           // ci.setVariable("controller", 10);
            pi.getRootToken().signal();
            System.out.println("ttttttt");
           
            ctx.save(pi);
           
            TaskInstance ti = pi.getTaskMgmtInstance().getTaskInstances().iterator().next();
            //TaskInstance ti = ctx.loadTaskInstance(tidd);
            String stepName = ti.getName();
            ctx.close();     
            //添加日志
            SomActivities sa = new SomActivities();
            sa.setOrderId(orderId);
            sa.setCurrentOperation("流程推送之--"+stepName);
            sa.setStartTime(new Date());
            sa.setTaskInstanceId(new BigDecimal(ti.getId()));
            sa.setOperator(this.commonSearch.selectEmpCode());
            String bumen = this.commonSearch.selectOrgCodeByUser();
             if (bumen.indexOf(".") > 0) {
                 SysOrganization org = this.commonSearch.selectOrgInfoByCode(bumen);
                 if (org == null) {
                     sa.setHandleDept(bumen);
                     sa.setHandleTeam("");
                 } else {
                     BigDecimal pid=org.getParentorgid();//获取父机构
                     SysOrganization pOrg=this.orgOrganizationService.getOrgInfo(pid.toString());//获取父机构信息
                     sa.setHandleDept(pOrg.getOrgcode());
                     sa.setHandleTeam(bumen);
                 }
             } else {
                 sa.setHandleDept(bumen);
                    sa.setHandleTeam("");
             }
             this.somOrderService.insertActivities(sa);
            order.setSubstatus(Constants.ORDERSTATUS_NEW_ID); //设置工单状态为未接受
            this.somOrderService.updateByPrimaryKey(order);
            System.out.println("ii"+ti.getName());               
            message = "{success:true,msg:'推送成功',orderId:"+orderId+"}";
        }catch(Exception e){
            System.out.println(e);
            message = "{success:true,msg:'推送失败'}";
        }
        outJsonString(message);
    }   
   
    /**
     * 处理结果提交
     */
    public void treatResult() throws Exception{
        String orderId = getRequest().getParameter("orderId");   //工程编号       
        String tid = getRequest().getParameter("tid"); //任务编号
        JSONObject json = new JSONObject();
        SomOrder order = this.somOrderService.selectByPrimaryKey(orderId);
        //流程推送
        JbpmContext ctx = this.jbpmConfiguration.createJbpmContext();
        TaskInstance ti = ctx.getTaskInstance(Long.parseLong(tid));
        String pn = ti.getName();
        ctx.close();
        String textarea_c = getRequest().getParameter("textarea_c"); //处理结果内容
        json.put("textarea_c", textarea_c);
        if(pn.equals("申报设计施工图")){
            String sj_content = getRequest().getParameter("sj_content"); //设计要求和内容
            String sj_sign = getRequest().getParameter("sj_sign"); //设计领导意见
            String sj_time = getRequest().getParameter("sj_time"); //设计要求时间
            String sj_money = getRequest().getParameter("sj_money"); //设计金额
            String sj_combo = getRequest().getParameter("sj_combo"); //设计要求           
            json.put("sj_content", sj_content);
            json.put("sj_sign", sj_sign);
            json.put("sj_time", sj_time);
            json.put("sj_money", sj_money);
            json.put("sj_combo",sj_combo);
        };
        if(pn.equals("接装手续办理完毕下施工任务")){
            String sg_content = getRequest().getParameter("sg_content"); //施工内容
            String sg_htbh = getRequest().getParameter("sg_htbh"); //合同编号           
            json.put("sg_content", sg_content);
            json.put("sg_htbh", sg_htbh);

        };
        if(pn.equals("验收")){
            String ys_content = getRequest().getParameter("ys_content"); //验收内容
            String ys_jldw = getRequest().getParameter("ys_jldw"); //监理单位
            String ys_sgdw = getRequest().getParameter("ys_sgdw"); //施工单位
            String ys_htbh = getRequest().getParameter("ys_htbh"); //合同编号           
            json.put("ys_content", ys_content);
            json.put("ys_jldw", ys_jldw);
            json.put("ys_sgdw", ys_sgdw);
            json.put("ys_htbh", ys_htbh);

        };               
        System.out.println("fd"+json.toString());
       
        //添加日志
        SomActivities sa = new SomActivities();
        sa.setOrderId(orderId);
        sa.setCurrentOperation(pn);
        sa.setStartTime(new Date());
        sa.setOperator(this.commonSearch.selectEmpCode());
        String bumen = this.commonSearch.selectOrgCodeByUser();
         if (bumen.indexOf(".") > 0) {
             SysOrganization org = this.commonSearch.selectOrgInfoByCode(bumen);
             if (org == null) {
                 sa.setHandleDept(bumen);
                 sa.setHandleTeam("");
             } else {
                 BigDecimal pid=org.getParentorgid();//获取父机构
                 System.out.println("8");
                 SysOrganization pOrg=this.orgOrganizationService.getOrgInfo(pid.toString());//获取父机构信息
                 sa.setHandleDept(pOrg.getOrgcode());
                 sa.setHandleTeam(bumen);
             }
         } else {
             sa.setHandleDept(bumen);
                sa.setHandleTeam("");
         }
         sa.setDetail(json.toString());
         this.somOrderService.insertActivities(sa);           
    }
   
    /**
     * 流程回退
     */
    public void backOption() throws Exception {
        String orderId = getRequest().getParameter("orderId");
        String tid = getRequest().getParameter("tid");
        SomOrder order = this.somOrderService.selectByPrimaryKey(orderId);
        Long picd = Long.parseLong(order.getProcessInstanceId().toString());
        System.out.println("fdfd"+order+"fdf"+picd);
        JbpmContext ctx = this.jbpmConfiguration.createJbpmContext();       
        ProcessInstance pi = ctx.loadProcessInstance(picd);
        TaskInstance ti = ctx.loadTaskInstance(Long.parseLong(tid));
        String trn = ti.getDescription().substring(ti.getDescription().indexOf(":")+1);
        System.out.println(trn+"ffffffffffffffffff");
        ContextInstance ci = ti.getContextInstance();
        pi.getRootToken().signal(trn);
        ctx.save(pi);
        //ti = pi.getTaskMgmtInstance().getTaskInstances().iterator().next();
        //String stepName = ti.getName();
        System.out.println("fdf流程返回");
        ctx.close();
       
        //添加日志
        SomActivities sa = new SomActivities();
        sa.setOrderId(orderId);
        sa.setCurrentOperation("流程回退到--"+trn);
        sa.setStartTime(new Date());
        sa.setOperator(this.commonSearch.selectEmpCode());
        String bumen = this.commonSearch.selectOrgCodeByUser();
         if (bumen.indexOf(".") > 0) {
             SysOrganization org = this.commonSearch.selectOrgInfoByCode(bumen);
             if (org == null) {
                 sa.setHandleDept(bumen);
                 sa.setHandleTeam("");
             } else {
                 BigDecimal pid=org.getParentorgid();//获取父机构
                 System.out.println("8");
                 SysOrganization pOrg=this.orgOrganizationService.getOrgInfo(pid.toString());//获取父机构信息
                 sa.setHandleDept(pOrg.getOrgcode());
                 sa.setHandleTeam(bumen);
             }
         } else {
             sa.setHandleDept(bumen);
                sa.setHandleTeam("");
         }
         //sa.setDetail(json.toString());
         this.somOrderService.insertActivities(sa);
         order.setSubstatus(Constants.ORDERSTATUS_NEW_ID);
         this.somOrderService.updateByPrimaryKey(order);       
    }
}

 

问题：

2个transition 指向有问题，但是handler正常 ，nextoption 函数single（）后获取的task 不正常。但是single()里handler函数却是正常的