本项目是根据github.com/antlinker/flow演变而来，原来的项目长时间不更新，并且代码qlang部分无法跑通，所以新开了这个项目进行开发
如果您有什么疑问，请联系wx：debugall，注明【go-workflow】，谢谢
目前这个项目支持如下类型：
- 开始/结束/终止事件
- 人工任务
- 排他网关/并行网关
注：暂时不支持子流程，后续有支持计划
go get github.com/jmniu/workflowpackage main
import (
"github.com/jmniu/workflow"
"github.com/jmniu/workflow/service/db"
_ "github.com/go-sql-driver/mysql"
)
func main() {
workflow.Init(
db.SetDSN("root:123456@tcp(127.0.0.1:3306)/flows?charset=utf8"),
db.SetTrace(true),
)
} err := workflow.LoadFile("leave.bpmn")
if err != nil {
// 处理错误
} input := map[string]interface{}{
"day": 1,
}
result, err := workflow.StartFlow("流程编号", "开始节点编号", "流程发起人ID", input)
if err != nil {
// 处理错误
} todos, err := workflow.QueryTodoFlows("流程编号", "流程待办人ID")
if err != nil {
// 处理错误
} input := map[string]interface{}{
"action": "pass",
}
result, err = workflow.HandleFlow("待办流程节点实例ID", "流程处理人ID", input)
if err != nil {
// 处理错误
} err := workflow.StopFlow("待办流程节点实例ID", func(flowInstance *schema.FlowInstance) bool {
return flowInstance.Launcher == "XXX"
})
if err != nil {
// 处理错误
}func main() {
serverOptions := []flow.ServerOption{
workflow.ServerStaticRootOption("./web"),
workflow.ServerPrefixOption("/flow/"),
workflow.ServerMiddlewareOption(filter),
}
http.Handle("/flow/", workflow.StartServer(serverOptions...))
}
func filter(ctx *gear.Context) error {
fmt.Printf("请求参数：%s - %s \n", ctx.Path, ctx.Method)
return nil
} result,err := workflow.QueryTodoFlows("流程编号","���程处理人ID")
if err != nil {
// 处理错误
}result,err := workflow.QueryFlowHistory("待办流程实例ID")
if err != nil {
// 处理错误
}ids,err := workflow.QueryDoneFlowIDs("流程编号","流程处理人ID")
if err != nil {
// 处理错误
}ids,err := workflow.QueryNodeCandidates("待办流程节点实例ID")
if err != nil {
// 处理错误
} err := workflow.StopFlowInstance("待办流程节点实例ID", func(flowInstance *schema.FlowInstance) bool {
return flowInstance.Launcher == "XXX"
})
if err != nil {
// 处理错误
}
