我的微型工作流引擎-功能解析及API设计 - 萧秦 - 博客园

//初始化流程引擎
BpmConfiguration
    .Instance()
    .Config(@"C:\Configration\BpmConfig.xml")
    .Start();

//初始化流程引擎
BpmConfiguration
    .Instance()
    .Start();

//A租户引擎配置
BpmConfiguration
    .Instance("TenantA")
    .Config(@"C:\BpmConfigA.xml")

    .Start();

//B租户引擎配置
BpmConfiguration
    .Instance("TenantB")
    .Config(@"C:\BpmConfigB.xml")
    .Start();

var bpm = new BpmContext()
    .UseTransaction(true)
    .SetActor("萧秦");

var bpm = new BpmContext("TenantA");
var bpm = new BpmContext("TenantB");

bpm.UseTransaction(true);
bpm.Commit();
bpm.Rollback();

//新增流程定义
bpm.NewProcessDefinition("请假流程")
    .SetXmlFile(@"C:\Definition\demo1.xml")
    .SetCategory("分类1")
    .SetEffectDate(DateTime.Now)
    .SetExpireDate(DateTime.Now.AddDays(180))
    .SetMemo("memo1")
    .Create()   //创建流程定义
    .Parse()    //解析xml

//加载流程定义
var processDefinition = bpm.LoadProcessDefiniton("1");
processDefinition.Deploy();     //发布流程定义
processDefinition.Revoke();     //召回流程定义
processDefinition.Delete();     //删除流程定义

//发起流程实例
var process = bpm.NewProcessIntance("请假流程","萧秦");
process.SetVariable("project_id", 1399); //保存流程变量
process.Start();   //启动 
process.Suspend(); //挂起
process.Resume();  //恢复
process.Cancel();  //撤销
process.End();     //结束

//启动流程
var startTask = process.Start();
startTask.SetRecord("SO20150903001");       //保存表单数据（关联）
startTask.SetAttach("01", "02");            //保存附件信息（关联）,可多个
startTask.SetVariable("var1", "value1");    //保存任务变量
startTask.Signal();                         //转交下一步

//审批任务
var task = bpm.LoadTaskInstance("00");
task.SetOpinion(SignResult.Passed, "我同意");  //设置审批意见
task.SetReceiver("颜经理");                    //设置下一步的审批人
task.Signal();                                //转交下一步

//任务委派
var task1 = bpm.LoadTaskInstance("01");
task1.AssignCandidate("小郑,小胡");              //添加任务候选人
task1.AssignCandidate("saler", ActorType.Role); //添加任务候选人
task1.AssignTo("李四");                         //把任务分配给李四

public enum AssignStatus
{
    //未决
    Pending,

    //认领， 用户认领任务并接收任务输入数据
    Claim,

    //委办， 委派给另一个人（例如，经理）以代替他或她执行任务
    Depute,

    //到期， 没有在指定的时间段内处理批准任务
    Expire,

    //续订， 没有在给定的时间范围内处理此任务，则该任务将被续订，以便在另一时间段内执行
    Renew
}

//工作催办
task.Urge("很急，请经理尽快处理，在线等！");

//汇报当前工作进度
task.Report(0.6, "预计这个星期就能完成");

//查询变量
var var0 = process.GetVariable("project_id");
var var1 = task1.GetVariable("var1");
var var2 = task1.GetVariable<DateTime>("var2");
var var3 = task1.GetVariableObject("var3");

public enum RunMode
{
    //串行
    Serial,

    //并行
    Parallel
}

public enum DecisionMode
{
    //主办人模式
    Sponsor, 
    
    //投票模式
    Vote, 
    
    //一票通过
    OnePass, 
    
    //一票否决
    OneVeto
}

//转会签
var task2 = bpm.LoadTaskInstance("02"); 
task2.ToCountersign(RunMode.Parallel, DecisionMode.Vote, true, 0.65M);
task2.CountersignAdd(new Countersigner() { actor_id = "张三", vote_weight = 1 });
task2.CountersignAdd(new Countersigner() { actor_id = "李四", vote_weight = 0.5 });
task2.CountersignAdd(new Countersigner() { actor_id = "小五", vote_weight = 2 });

//前加签
task2.CountersignAddBefore("萧秦", new Countersigner() { actor_id = "张三"});

//后加签
task2.CountersignAddAfter("萧秦", new Countersigner() { actor_id = "李四", is_sponsor = true});

//减签
task2.CountersignRemove("王五");

//转审批
 task2.ToSinglesign("隔壁老王");

//自由流
var task3 = bpm.LoadTaskInstance("03");
task3.SetFreeRedirect("总经理审批");
task3.Signal();

//流程实例指定任意节点回退
var process2 = bpm.LoadProcessInstance("02");
process2.Rollback("填写请假单");

//当前工作任务回退到上一个审批节点
var task4 = bpm.LoadTaskInstance("04");
task4.Rollback();

bpm.NewDeputeService("张三", "李四")
   .ForTaskInstance("任务实例ID")
   .Depute();

bpm.NewDeputeService("张三", "李四")
   .ForProcessInstance("流程实例ID")
   .Depute();

bpm.NewDeputeService("张三", "李四")
   .ForTaskDefinition("任务定义ID")
   .Depute();

bpm.NewDeputeService("张三", "李四")
   .ForProcessDefinition("流程定义ID")
   .SetDateRange(DateTime.Now, DateTime.Now.AddDays(30)) //生效期间
   .SetMemo("这个月出差,这个流程都委托给李四代办")            //委托说明
   .Depute();

//收回委办工作
bpm.NewDeputeService("张三", "李四")
   .ForProcessInstance("流程实例ID")
   .Revoke();

//关注订阅
bpm.NewSubscribeService("张三")
   .ForTaskInstance("任务实例ID")
   .Subscribe();

bpm.NewSubscribeService("张三")
   .ForProcessInstance("流程实例ID")
   .Subscribe();

bpm.NewSubscribeService("张三")
   .ForProcessDefinition("流程定义ID")
   .Subscribe();

bpm.NewSubscribeService("张三","李四","王五")
   .ForTaskDefinition("任务定义ID")
   .Subscribe();

//取消订阅
bpm.NewSubscribeService("李四")
   .ForProcessDefinition("采购流程")
   .Unsubscribe();

select * from bpm_definition_process where state = 'Deploy'

public enum ProcessDefinitionState
{
    //创建
    Create,

    //解析
    Parse,

    //发布
    Deploy,

    //回收
    Revoke,

    //删除
    Delete
}

select * from bpm_instance_process where state = 'Run' and starter = '萧秦'

public enum ProcessState
{
    //创建
    Create,

    //运行
    Run,

    //挂起
    Pending,

    //终止
    Termination,

    //完成
    Complete,

    //取消
    Cancel
}

select * from bpm_instance_task where state = 'Run' and actor_id = '萧秦'

select * from bpm_instance_task where state = 'Run' and owner_id = '萧秦'

public enum TaskState
{
    //创建， 任务已被创建
    Create,

    //阻塞， 到达线中有阻塞任务还未完成
    Blocking,

    //启动
    Run,
   
    //完成， 用户已经完成任务并提供了任务的输出数据
    Complete,

    //失败， 用户已经完成任务， 并且提供了错误消息
    Failure,

    //回退
    Rollback
}

select * from bpm_instance_assignment where task_instance_id = 'ID'

select * from bpm_application_notify where state='Unread' and reciever_id = '萧秦'