Javascript工作流引擎代码及实例

核心提示： //定义引擎Yi={};Yi.Utils={};Yi.Utils.execute=function(o){if(typeofo!='function')eval(o)();elseo();}//工作流类Yi.Workflow=function(workflowDef){th

//////////定义引擎////////////

Yi　=　{};

Yi.Utils　=　{};

Yi.Utils.execute　=　function(o){

　　　　　　　　　if(typeof　o　!=　'function')

　　　　　　　　　　　　　　　　　　　eval(o)();

　　　　　　　　　else

　　　　　　　　　　　　　　　　　　　o();

}

//工作流类

Yi.Workflow　=　function(workflowDef){

　　　　　　　　　this.def　=　workflowDef;

　　　　　　　　　this.tasks　=　this.def.tasks;

}

//public按照环节id查找查找

Yi.Workflow.prototype.findTask　=　function(taskId){

　　　　　　　　　for(var　i=0;i<this.tasks.length;i++){

　　　　　　　　　　　　　　　　　　　if(this.tasks[i].id　==　taskId)

　　　　　　　　　　　　　　　　　　　　　　　　　　　　return　this.tasks[i];

　　　　　　　　　}

}

//public启动工作流

Yi.Workflow.prototype.start　=　function(){

　　　　　　　　　this.currentTasks　=　[];

　　　　　　　　　Yi.Utils.execute(this.def.start.fn);

　　　　　　　　　for(var　i=0;i<this.def.start.next.length;i++){

　　　　　　　　　　　　　　　　　　　this.currentTasks[i]　=　this.findTask(this.def.start.next[i]);

　　　　　　　　　　　　　　　　　　　Yi.Utils.execute(this.currentTasks[i].before);

　　　　　　　　　}

}

//private

Yi.Workflow.prototype.findCurrentTaskById　=　function(taskId){

　　　　　　　　　for(var　i=0;i<this.currentTasks.length;i++){

　　　　　　　　　　　　　　　　　　　if(this.currentTasks[i].id　==　taskId)

　　　　　　　　　　　　　　　　　　　　　　　　　　　　return　this.currentTasks[i];

　　　　　　　　　}

　　　　　　　　　return　null;

}

//private

Yi.Workflow.prototype.removeFromCurrentTasks　=　function(task){

　　　　　　　　　var　temp　=　[];

　　　　　　　　　for(var　i=0;i<this.currentTasks.length;i++){

　　　　　　　　　　　　　　　　　　　if(!(this.currentTasks[i]　==　task))

　　　　　　　　　　　　　　　　　　　　　　　　　　　　temp.push(this.currentTasks[i]);　

　　　　　　　　　}

　　　　　　　　　this.currentTasks　=　temp;

　　　　　　　　　temp　=　null;

}

//public触发当前环节

Yi.Workflow.prototype.signal　=　function(taskId){

　　　　　　　　　//只处理当前活动环节

　　　　　　　　　var　task　=　this.findCurrentTaskById(taskId);

　　　　　　　　　if(task　==　null){

　　　　　　　　　　　　　　　　　　　alert("工作流未流转到此环节!");

　　　　　　　　　　　　　　　　　　　return;

　　　　　　　　　}

　　　　　　　　　//对于合并的处理

　　　　　　　　　if(task.merge　!=　undefined){

　　　　　　　　　　　　　　　　　　　if(task.merge　!=　0){

　　　　　　　　　　　　　　　　　　　　　　　　　　　　alert("工作流流转条件不充分!");

　　　　　　　　　　　　　　　　　　　　　　　　　　　　return;

　　　　　　　　　　　　　　　　　　　}else{

　　　　　　　　　　　　　　　　　　　　　　　　　　　　Yi.Utils.execute(task.before);

　　　　　　　　　　　　　　　　　　　}　　　　　　　　

　　　　　　　　　}

　　　　　　　　　//触发当前环节

　　　　　　　　　Yi.Utils.execute(task.fn);

　　　　　　　　　//触发后动作

　　　　　　　　　Yi.Utils.execute(task.after);

　　　　　　　　　//下一步如果工作流结束

　　　　　　　　　if(task.next　===　"EOWF"){

　　　　　　　　　　　　　　　　　　　Yi.Utils.execute(this.def.end);

　　　　　　　　　　　　　　　　　　　delete　this.currentTasks;

　　　　　　　　　　　　　　　　　　　return;

　　　　　　　　　}

　　　　　　　　　//遍历下一步环节

　　　　　　　　　this.removeFromCurrentTasks(task);

　　　　　　　　　for(var　i=0;i<task.next.length;i++){

　　　　　　　　　　　　　　　　　　　var　tempTask　=　this.findTask(task.next[i]);

　　　　　　　　　　　　　　　　　　　if(!tempTask.inCurrentTasks)

　　　　　　　　　　　　　　　　　　　　　　　　　　　　this.currentTasks.push(tempTask);

　　　　　　　　　　　　　　　　　　　if(tempTask.merge　!=　undefined){

　　　　　　　　　　　　　　　　　　　　　　　　　　　　tempTask.merge--;

　　　　　　　　　　　　　　　　　　　　　　　　　　　　tempTask.inCurrentTasks　=　true;

　　　　　　　　　　　　　　　　　　　}

　　　　　　　　　　　　　　　　　　　else

　　　　　　　　　　　　　　　　　　　　　　　　　　　　Yi.Utils.execute(tempTask.before);

　　　　　　　　　}

}

//public获取当前的活动环节

Yi.Workflow.prototype.getCurrentTasks　=　function(){

　　　　　　　　　return　this.currentTasks;

}

//public获取流程定义

Yi.Workflow.prototype.getDef　=　function(){

　　　　　　　　　return　this.def;

}

////////应用系统///////////////

var　wf　=　new　Yi.Workflow(workflowDef);

alert("启动工作流");

wf.start();

alert("尝试手工执行任务3,返回工作流没有流转到这里");

wf.signal("task3");

alert("分支开始");

alert("手工执行任务1");

wf.signal("task1");

alert("手工执行任务2");

wf.signal("task2");

alert("手工执行任务4");

wf.signal("task4");

alert("手工执行任务5");

wf.signal("task5");

alert("手工执行任务3");

wf.signal("task3");

function　begin(){

　　　　　　　　　alert("流程开始，该函数在外部定义");

}

function　end(){

　　　　　　　　　alert("流程结束");

}