flow

package module
v1.0.21 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 17, 2024 License: GPL-2.0 Imports: 28 Imported by: 0

README

工作流引擎

本项目是根据github.com/antlinker/flow演变而来，原来的项目长时间不更新，并且代码qlang部分无法跑通.

目前这个项目支持如下类型：

  1. 开始/结束/终止事件
  2. 人工任务/脚本任务
  3. 排他网关/并行网关
  4. 支持rpc println(Rpc("GET", "https://httpbin.org/ip", nil))

注：暂时不支持子流程，后续有支持计划

工作流设计器

获取项目

go get github.com/meixiaofei/flow-bpmn

使用

1. 初始化工作流引擎
package main
import (
    "github.com/meixiaofei/flow-bpmn"
    "github.com/meixiaofei/flow-bpmn/service/db"
    _ "github.com/go-sql-driver/mysql"
)
func main() {
    flow.Init(
		db.SetDSN("root:123456@tcp(127.0.0.1:3306)/flows?charset=utf8"),
		db.SetTrace(true),
	)
}
2. 加载工作流文件
	err := flow.LoadFile("leave.bpmn")
	if err != nil {
		// 处理错误
	}
3. 发起流程
  input := map[string]interface{}{
	"day": 1,
  }

	result, err := flow.StartFlow("process_leave_test", "流程发起人ID", input)
	if err != nil {
		// 处理错误
	}
4. 查询待办流程列表
	todos, err := flow.QueryTodoFlows("process_leave_test", "1")
	if err != nil {
		// 处理错误
	}
5. 处理流程
  input := map[string]interface{}{
	"action": "pass",
  }

  result, err = flow.HandleFlow("待办流程节点实例ID", "流程处理人ID", input)
	if err != nil {
		// 处理错误
	}
6. 停止流程
	err := flow.StopFlow("待办流程节点实例ID", func(flowInstance *schema.FlowInstance) bool {
		return flowInstance.Launcher == "XXX"
	})
	if err != nil {
		// 处理错误
	}
7. 接入WEB流程管理
func main() {
serverOptions := []flow.ServerOption{
	    flow.ServerStaticRootOption("./web"),
	    flow.ServerPrefixOption("/flow/"),
	    flow.ServerMiddlewareOption(filter),
	}

	http.Handle("/flow/", flow.StartServer(serverOptions...))
}

func filter(ctx *gear.Context) error {
	fmt.Printf("请求参数：%s - %s \n", ctx.Path, ctx.Method)
	return nil
}
8. 查询流程待办数据
	result,err := flow.QueryTodoFlows("process_leave_test","流程处理人ID")
	if err != nil {
		// 处理错误
	}
9. 查询流程历史数据
result,err := flow.QueryFlowHistory("待办流程实例ID")
if err != nil {
	// 处理错误
}
10. 查询已办理的流程实例ID列表
ids,err := flow.QueryDoneFlowIDs("process_leave_test","流程处理人ID")
if err != nil {
	// 处理错误
}
11. 查询节点实例的候选人ID列表
ids,err := flow.QueryNodeCandidates("待办流程节点实例ID")
if err != nil {
	// 处理错误
}
12. 停止流程实例
	err := flow.StopFlowInstance("待办流程节点实例ID", func(flowInstance *schema.FlowInstance) bool {
		return flowInstance.Launcher == "XXX"
	})
	if err != nil {
		// 处理错误
	}

流程管理 流程设计器

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrNotFound = errors.New("未找到流程相关的信息")
)

定义错误

Functions

func CreateFlow added in v1.0.5 

func CreateFlow(data []byte) (string, error)

func DeleteFlow added in v1.0.5 

func DeleteFlow(recordID string) error

func FromExpContext 

func FromExpContext(ctx context.Context) (expression.ExpContext, bool)

FromExpContext 获取表达式的上下文

func FromFlagContext 

func FromFlagContext(ctx context.Context) (string, bool)

FromFlagContext 获取flag的上下文

func GetFlow added in v1.0.5 

func GetFlow(recordID string) (*schema.Flow, error)

func GetFlowFormByFlowID added in v1.0.9 

func GetFlowFormByFlowID(flowID string) (*schema.Form, error)

func GetNodeInstance 

func GetNodeInstance(nodeInstanceID string) (*schema.NodeInstance, error)

GetNodeInstance 获取节点实例

func GetTodoByID added in v1.0.5 

func GetTodoByID(nodeInstanceID string) (*schema.FlowTodoResult, error)

func Init 

func Init(opts ...db.Option)

Init 初始化流程配置

func LoadFile 

func LoadFile(name string) error

LoadFile 加载流程文件数据

func NewExpContext 

func NewExpContext(ctx context.Context, exp expression.ExpContext) context.Context

NewExpContext 创建表达式的上下文值

func NewFlagContext 

func NewFlagContext(ctx context.Context, flag string) context.Context

NewFlagContext 创建flag的上下文值

func QueryAllFlowPage added in v1.0.5 

func QueryAllFlowPage(params schema.FlowQueryParam, pageIndex, pageSize uint) (int64, []*schema.FlowQueryResult, error)

func QueryDone added in v1.0.5 

func QueryDone(typeCode, flowCode, userID string, lastTime int64, count int) ([]*schema.FlowDoneResult, error)

func QueryDoneByPage added in v1.0.9 

func QueryDoneByPage(typeCode, flowCode, userID string, status, dataType, pageIndex, pageSize int) (int64, []*schema.FlowDoneResult, error)

func QueryDoneFlowIDs 

func QueryDoneFlowIDs(flowCode, userID string) ([]string, error)

QueryDoneFlowIDs 查询已办理的流程实例ID列表

func QueryFlowHistory 

func QueryFlowHistory(flowInstanceID string) ([]*schema.FlowHistoryResult, error)

QueryFlowHistory 查询流程历史数据 flowInstanceID 流程实例内码

func QueryGroupFlowPage added in v1.0.8 

func QueryGroupFlowPage(params schema.FlowQueryParam, pageIndex, pageSize uint) (int64, []*schema.FlowQueryResult, error)

func QueryLastNodeInstance 

func QueryLastNodeInstance(flowInstanceID string) (*schema.NodeInstance, error)

func QueryNodeCandidates 

func QueryNodeCandidates(nodeInstanceID string) ([]string, error)

QueryNodeCandidates 查询节点实例的候选人ID列表

func QueryTodoFlows 

func QueryTodoFlows(flowCode, userID string) ([]*schema.FlowTodoResult, error)

QueryTodoFlows 查询流程待办数据 flowCode 流程编号 userID 待办人

func QueryTodoFlowsPaginate 

func QueryTodoFlowsPaginate(flowCode, userID string, page int, pageSize int) (int, []*schema.FlowTodoResult, error)

QueryTodoFlowsPaginate 分页查询流程待办数据 flowCode 流程编号 userID 待办人

func SetExecer 

func SetExecer(execer Execer)

SetExecer 设定表达式执行器

func SetParser 

func SetParser(parser Parser)

SetParser 设定解析器

func StartServer 

func StartServer(opts ...ServerOption) http.Handler

StartServer 启动管理服务

func StopFlow 

func StopFlow(nodeInstanceID string, allowStop func(*schema.FlowInstance) bool) error

StopFlow 停止流程

func StopFlowInstance 

func StopFlowInstance(flowInstanceID string, allowStop func(*schema.FlowInstance) bool) error

StopFlowInstance 停止流程实例

Types

type API 

type API struct {
	// contains filtered or unexported fields
}

API 提供API管理

func (*API) DeleteFlow 

func (a *API) DeleteFlow(ctx *gear.Context) error

DeleteFlow 删除流程数据

func (*API) GetFlow 

func (a *API) GetFlow(ctx *gear.Context) error

GetFlow 获取流程数据

func (*API) Init 

func (a *API) Init(engine *Engine) *API

Init 初始化

func (*API) QueryFlowPage 

func (a *API) QueryFlowPage(ctx *gear.Context) error

QueryFlowPage 查询流程分页数据

func (*API) SaveFlow 

func (a *API) SaveFlow(ctx *gear.Context) error

SaveFlow 保存流程

type AutoCallbackHandler 

type AutoCallbackHandler func(action, flag, userID string, input []byte, result *HandleResult) error

AutoCallbackHandler 自动执行节点回调处理

type EndHandle 

type EndHandle func(*schema.FlowInstance)

EndHandle 定义流程结束处理函数

type Engine 

type Engine struct {
	// contains filtered or unexported fields
}

Engine 流程引擎

func DefaultEngine 

func DefaultEngine() *Engine

DefaultEngine 默认引擎

func (*Engine) CreateFlow 

func (e *Engine) CreateFlow(data []byte) (string, error)

CreateFlow 创建流程数据

func (*Engine) DeleteFlow added in v1.0.5 

func (e *Engine) DeleteFlow(recordID string) error

func (*Engine) FlowBll 

func (e *Engine) FlowBll() *bll.Flow

FlowBll 流程业务

func (*Engine) GetExecer added in v1.0.1 

func (e *Engine) GetExecer() Execer

func (*Engine) GetFlow added in v1.0.5 

func (e *Engine) GetFlow(recordID string) (*schema.Flow, error)

func (*Engine) GetFlowFormByFlowID added in v1.0.9 

func (e *Engine) GetFlowFormByFlowID(flowID string) (*schema.Form, error)

func (*Engine) GetNodeInstance 

func (e *Engine) GetNodeInstance(nodeInstanceID string) (*schema.NodeInstance, error)

GetNodeInstance 获取节点实例

func (*Engine) GetTodoByID added in v1.0.5 

func (e *Engine) GetTodoByID(nodeInstanceID string) (*schema.FlowTodoResult, error)

func (*Engine) HandleFlow 

func (e *Engine) HandleFlow(ctx context.Context, nodeInstanceID, userID string, inputData []byte) (*HandleResult, error)

HandleFlow 处理流程节点 nodeInstanceID 节点实例内码 userID 处理人 inputData 输入数据

func (*Engine) Init 

func (e *Engine) Init(parser Parser, execer Execer, sqlDB *sql.DB, trace bool) (*Engine, error)

Init 初始化流程引擎

func (*Engine) LaunchFlow 

func (e *Engine) LaunchFlow(ctx context.Context, flowID, userID string, inputData []byte) (*HandleResult, error)

LaunchFlow 发起流程（基于流程ID）

func (*Engine) LoadFile 

func (e *Engine) LoadFile(name string) error

LoadFile 加载文件数据

func (*Engine) QueryAllFlowPage added in v1.0.5 

func (e *Engine) QueryAllFlowPage(params schema.FlowQueryParam, pageIndex, pageSize uint) (int64, []*schema.FlowQueryResult, error)

func (*Engine) QueryDone added in v1.0.5 

func (e *Engine) QueryDone(typeCode, flowCode, userID string, lastTime int64, count int) ([]*schema.FlowDoneResult, error)

func (*Engine) QueryDoneByPage added in v1.0.9 

func (e *Engine) QueryDoneByPage(typeCode, flowCode, userID string, status, dataType, pageIndex, pageSize int) (int64, []*schema.FlowDoneResult, error)

func (*Engine) QueryDoneFlowIDs 

func (e *Engine) QueryDoneFlowIDs(flowCode, userID string) ([]string, error)

QueryDoneFlowIDs 查询已办理的流程实例ID列表

func (*Engine) QueryFlowHistory 

func (e *Engine) QueryFlowHistory(flowInstanceID string) ([]*schema.FlowHistoryResult, error)

QueryFlowHistory 查询流程历史数据 flowInstanceID 流程实例内码

func (*Engine) QueryLastNodeInstance 

func (e *Engine) QueryLastNodeInstance(flowInstanceID string) (*schema.NodeInstance, error)

func (*Engine) QueryNodeCandidates 

func (e *Engine) QueryNodeCandidates(nodeInstanceID string) ([]string, error)

QueryNodeCandidates 查询节点实例的候选人ID列表

func (*Engine) QueryTodoFlows 

func (e *Engine) QueryTodoFlows(flowCode, userID string) ([]*schema.FlowTodoResult, error)

QueryTodoFlows 查询流程待办数据 flowCode 流程编号 userID 待办人

func (*Engine) QueryTodoFlowsPaginate 

func (e *Engine) QueryTodoFlowsPaginate(flowCode, userID string, page int, pageSize int) (int, []*schema.FlowTodoResult, error)

QueryTodoFlowsPaginate 分页查询流程待办数据 flowCode 流程编号 userID 待办人

func (*Engine) SetAutoCallback 

func (e *Engine) SetAutoCallback(callback AutoCallbackHandler)

SetAutoCallback 设定自动节点回调函数

func (*Engine) SetExecer 

func (e *Engine) SetExecer(execer Execer)

SetExecer 设定表达式执行器

func (*Engine) SetGetDBContext 

func (e *Engine) SetGetDBContext(fn func(flag string) context.Context)

SetGetDBContext 设定获取DB上下文

func (*Engine) SetLogger 

func (e *Engine) SetLogger(logger Logger)

SetLogger 设定日志接口

func (*Engine) SetParser 

func (e *Engine) SetParser(parser Parser)

SetParser 设定解析器

func (*Engine) StartFlow 

func (e *Engine) StartFlow(ctx context.Context, flowCode, userID string, inputData []byte) (*HandleResult, error)

StartFlow 启动流程 flowCode 流程编号 userID 发起人 inputData 输入数据

func (*Engine) StartTiming 

func (e *Engine) StartTiming(interval time.Duration)

StartTiming 启动定时器

func (*Engine) StopFlow 

func (e *Engine) StopFlow(nodeInstanceID string, allowStop func(*schema.FlowInstance) bool) error

StopFlow 停止流程

func (*Engine) StopFlowInstance 

func (e *Engine) StopFlowInstance(flowInstanceID string, allowStop func(*schema.FlowInstance) bool) error

StopFlowInstance 停止流程实例

func (*Engine) StopTiming 

func (e *Engine) StopTiming()

StopTiming 停止定时器

type Execer 

type Execer interface {
	// 执行表达式返回布尔类型的值
	ExecReturnBool(ctx context.Context, exp, params []byte) (bool, error)
	ExecReturnMap(ctx context.Context, exp, params []byte) (map[string]interface{}, error)

	// 执行表达式返回字符串切片类型的值
	ExecReturnStringSlice(ctx context.Context, exp, params []byte) ([]string, error)
}

Execer 表达式执行器

func NewQLangExecer 

func NewQLangExecer() Execer

NewQLangExecer 创建基于qlang的表达式执行器

type FieldOption 

type FieldOption struct {
	ID   string // 选项值ID
	Name string // 选项值名称
}

FieldOption 枚举选项

type FieldProperty 

type FieldProperty struct {
	ID    string // 属性ID
	Value string // 属性值
}

FieldProperty 字段属性

type FieldValidation 

type FieldValidation struct {
	Name   string // 约束名
	Config string // 约束配置
}

FieldValidation 字段验证

type FormFieldResult 

type FormFieldResult struct {
	ID           string             // 字段ID
	Type         string             // 字段类型
	Label        string             // 字段标签
	DefaultValue string             // 默认值
	Values       []*FieldOption     // 枚举类型
	Validations  []*FieldValidation // 字段验证
	Properties   []*FieldProperty   // 字段属性
}

FormFieldResult 表单字段

type HandleResult 

type HandleResult struct {
	IsEnd        bool                 `json:"is_end"`        // 是否结束
	NextNodes    []*NextNode          `json:"next_nodes"`    // 下一处理节点
	FlowInstance *schema.FlowInstance `json:"flow_instance"` // 流程实例
}

HandleResult 处理结果

func HandleFlow 

func HandleFlow(nodeInstanceID, userID string, input interface{}) (*HandleResult, error)

HandleFlow 处理流程节点 nodeInstanceID 节点实例内码 userID 处理人 input 输入数据

func HandleFlowWithContext 

func HandleFlowWithContext(ctx context.Context, nodeInstanceID, userID string, input interface{}) (*HandleResult, error)

HandleFlowWithContext 处理流程节点 nodeInstanceID 节点实例内码 userID 处理人 input 输入数据

func LaunchFlow added in v1.0.8 

func LaunchFlow(flowID, userID string, inputData []byte) (*HandleResult, error)

func StartFlow 

func StartFlow(flowCode, userID string, input interface{}) (*HandleResult, error)

StartFlow 启动流程 flowCode 流程编号 userID 发起人 input 输入数据

func StartFlowWithContext 

func StartFlowWithContext(ctx context.Context, flowCode, userID string, input interface{}) (*HandleResult, error)

StartFlowWithContext 启动流程 flowCode 流程编号 nodeCode 开始节点编号 userID 发起人 input 输入数据

func (*HandleResult) String 

func (r *HandleResult) String() string

type Logger 

type Logger interface {
	Errorf(format string, args ...interface{})
}

Logger 定义日志接口

type NextNode 

type NextNode struct {
	Node         *schema.Node         // 节点信息
	CandidateIDs []string             // 节点候选人
	NodeInstance *schema.NodeInstance // 节点实例
}

NextNode 下一节点

type NextNodeHandle 

type NextNodeHandle func(*schema.Node, *schema.NodeInstance, []*schema.NodeCandidate)

NextNodeHandle 定义下一节点处理函数

type NodeFormResult 

type NodeFormResult struct {
	ID     string             // 表单ID
	Fields []*FormFieldResult // 表单字段
}

NodeFormResult 节点表单

type NodeResult 

type NodeResult struct {
	NodeID               string            // 节点ID
	NodeName             string            // 节点名称
	NodeType             NodeType          // 节点类型
	Content              string            // 节点执行脚本内容
	Routers              []*RouterResult   // 节点路由
	Properties           []*PropertyResult // 节点属性
	CandidateExpressions []string          // 候选人表达式
	FormResult           *NodeFormResult   // 节点表单
}

NodeResult 节点数据

type NodeRouter 

type NodeRouter struct {
	// contains filtered or unexported fields
}

NodeRouter 节点路由

func (*NodeRouter) GetFlowInstance 

func (n *NodeRouter) GetFlowInstance() *schema.FlowInstance

GetFlowInstance 获取流程实例

func (*NodeRouter) Init 

func (n *NodeRouter) Init(ctx context.Context, engine *Engine, nodeInstanceID string, inputData []byte, options ...NodeRouterOption) (*NodeRouter, error)

Init 初始化节点路由

func (*NodeRouter) Next 

func (n *NodeRouter) Next(processor string) error

Next 流向下一节点

type NodeRouterOption 

type NodeRouterOption func(*nodeRouterOptions)

NodeRouterOption 节点路由配置

func AutoStartOption 

func AutoStartOption(autoStart bool) NodeRouterOption

AutoStartOption 自动开始流程配置

func OnFlowEndOption 

func OnFlowEndOption(fn EndHandle) NodeRouterOption

OnFlowEndOption 注册流程结束事件

func OnNextNodeOption 

func OnNextNodeOption(fn NextNodeHandle) NodeRouterOption

OnNextNodeOption 注册下一节点处理事件配置

type NodeType 

type NodeType string

NodeType 节点类型 

const (
	// StartEvent 开始事件
	StartEvent NodeType = "startEvent"
	// EndEvent 结束事件
	EndEvent NodeType = "endEvent"
	// TerminateEvent 终止事件
	TerminateEvent NodeType = "terminateEvent"
	// UserTask 人工任务
	UserTask   NodeType = "userTask"
	ScriptTask NodeType = "scriptTask"
	// ExclusiveGateway 排他网关
	ExclusiveGateway NodeType = "exclusiveGateway"
	// ParallelGateway 并行网关
	ParallelGateway NodeType = "parallelGateway"
	// Unknown 未知类型
	Unknown NodeType = "Unknown"
)

func GetNodeTypeByName 

func GetNodeTypeByName(s string) (NodeType, error)

GetNodeTypeByName 转换节点类型

func (NodeType) String 

func (n NodeType) String() string

type ParseResult 

type ParseResult struct {
	FlowID      string        // 流程ID
	FlowName    string        // 流程名称
	FlowMemo    string        // 流程笔记
	FlowVersion int64         // 流程版本号
	FlowStatus  int           // 流程状态(1:可用 2:不可用)
	IsAutoStart bool          // 是否自动启动
	Nodes       []*NodeResult // 节点数据
}

ParseResult 流程数据

type Parser 

type Parser interface {
	// 解析流程定义数据
	Parse(ctx context.Context, data []byte) (*ParseResult, error)
}

Parser 流程数据解析器

func NewXMLParser 

func NewXMLParser() Parser

NewXMLParser xml解析器

type PropertyResult 

type PropertyResult struct {
	Name  string // 属性名称
	Value string // 属性值
}

PropertyResult 节点属性

type Renderer 

type Renderer interface {
	Render(context.Context, *NodeFormResult) ([]byte, error)
}

Renderer 表单渲染器

func NewIonicRenderer 

func NewIonicRenderer() Renderer

NewIonicRenderer 渲染到ionic

type RouterResult 

type RouterResult struct {
	TargetNodeID string // 目标节点ID
	Explain      string // 说明
	Expression   string // 条件表达式
}

RouterResult 节点路由数据

type Server 

type Server struct {
	// contains filtered or unexported fields
}

Server 流程管理服务

func (*Server) Init 

func (a *Server) Init(engine *Engine, opts ...ServerOption) *Server

Init 初始化

func (*Server) ServeHTTP 

func (a *Server) ServeHTTP(w http.ResponseWriter, r *http.Request)

type ServerOption 

type ServerOption func(*serverOptions)

ServerOption 流程服务配置

func ServerMiddlewareOption 

func ServerMiddlewareOption(middlewares ...gear.Middleware) ServerOption

ServerMiddlewareOption 中间件

func ServerPrefixOption 

func ServerPrefixOption(prefix string) ServerOption

ServerPrefixOption 访问前缀

func ServerStaticRootOption 

func ServerStaticRootOption(staticRoot string) ServerOption

ServerStaticRootOption 静态文件目录

Source Files

View all Source files

Directories

Path Synopsis
builtin
sql
cl
cl/interpreter
cmd/eql
cmd/eql/example/stringset.v1
cmd/eql/example/uint32set.v1
cmd/miniqlang
cmd/playground/sandbox
cmd/qexport
cmd/qlang
cmd/qlang.safe
cmd/qshell
exec
lib
lib/bufio
lib/builtin
lib/bytes
lib/chan
lib/compress/lzw
lib/crypto/hmac
lib/crypto/md5
lib/crypto/sha1
lib/crypto/sha256
lib/encoding/hex
lib/encoding/json
lib/eqlang
lib/errors
lib/io
lib/io/ioutil
lib/math
lib/meta
lib/net/http
lib/os
lib/path
lib/qlang.all
lib/reflect
lib/runtime
lib/strconv
lib/strings
lib/sync
lib/terminal
lib/tpl/extractor
lib/version
spec
spec/types
service
db

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.