goflow

type BaseModel struct {
	Name        string `xml:"name,attr"`        //节点名称
	DisplayName string `xml:"displayName,attr"` //节点显示名称
}

type CCOrder struct {
	Id         string      `xorm:"varchar(36) pk notnull"` //主键ID
	OrderId    string      `xorm:"varchar(36) index"`      //流程实例ID
	ActorId    string      `xorm:"varchar(36)"`            //操作者ID
	Creator    string      `xorm:"varchar(36)"`            //流程实例创建者ID
	CreateTime time.Time   `xorm:"datetime"`               //流程实例创建时间
	FinishTime time.Time   `xorm:"datetime"`               //流程实例完成时间
	State      FLOW_STATUS `xorm:"tinyint"`                //流程实例状态
}

type DecisionModel struct {
	NodeModel
	Expr string `xml:"expr,attr"` //决策的条件表达式
}

type EXEC_ROLE string

type EndModel struct {
	NodeModel
}

type Engine struct {
	ProcessService //流程定义业务类
}

type Execution struct {
	Engine         *Engine                //引擎
	Process        *Process               //流程定义对象
	Order          *Order                 //流程实例对象
	ParentOrder    *Order                 //父流程实例
	ParentNodeName string                 //父流程实例节点名称
	ChildOrderId   string                 //子流程实例节点名称
	Args           map[string]interface{} //执行参数
	Operator       string                 //操作人
	Task           *Task                  //任务
	Tasks          []*Task                //返回的任务列表
	IsMerged       bool                   //是否已合并,针对join节点的处理
}

type FLOW_STATUS int

type ForkModel struct {
	NodeModel
}

type HistoryOrder struct {
	Id         string      `xorm:"varchar(36) pk notnull"`    //主键ID
	ProcessId  string      `xorm:"varchar(36) notnull index"` //流程定义ID
	Creator    string      `xorm:"varchar(36)"`               //流程实例创建者ID
	CreateTime time.Time   `xorm:"datetime notnull"`          //流程实例创建时间
	ParentId   string      `xorm:"varchar(36) index"`         //流程实例为子流程时，该字段标识父流程实例ID
	ExpireTime time.Time   `xorm:"datetime"`                  //流程实例期望完成时间
	Priority   int         `xorm:"tinyint"`                   //流程实例优先级
	OrderNo    string      `xorm:"varchar(100) index"`        //流程实例编号
	Variable   string      `xorm:"varchar(2000)"`             //流程实例附属变量
	OrderState FLOW_STATUS `xorm:"tinyint notnull"`           //流程实例状态
	FinishTime time.Time   `xorm:"datetime"`                  //完成时间
}

type HistoryTask struct {
	Id           string        `xorm:"varchar(36) pk notnull"`     //主键ID
	OrderId      string        `xorm:"varchar(36) notnull index"`  //流程实例ID
	TaskName     string        `xorm:"varchar(100) notnull index"` //任务名称
	DisplayName  string        `xorm:"varchar(200) notnull"`       //任务显示名称
	PerformType  PERFORM_ORDER `xorm:"tinyint"`                    //任务参与方式
	TaskType     TASK_ORDER    `xorm:"tinyint notnull"`            //任务类型
	Operator     string        `xorm:"varchar(36)"`                //任务处理者ID
	CreateTime   time.Time     `xorm:"datetime notnull"`           //任务创建时间
	FinishTime   time.Time     `xorm:"datetime"`                   //任务完成时间
	ExpireTime   time.Time     `xorm:"datetime"`                   //期望任务完成时间
	Action       string        `xorm:"varchar(200)"`               //任务关联的Action(WEB为表单URL)
	ParentTaskId string        `xorm:"varchar(36) index"`          //父任务ID
	Variable     string        `xorm:"varchar(2000)"`              //任务附属变量(json存储)
	TaskState    FLOW_STATUS   `xorm:"tinyint notnull"`            //任务状态
}

type HistoryTaskActor struct {
	Id      string `xorm:"varchar(36) pk notnull"`    //主键ID
	TaskId  string `xorm:"varchar(36) notnull index"` //任务ID
	ActorId string `xorm:"varchar(36) notnull"`       //参与者ID
}

type IInterceptor interface {
	GetName() string //Unique
	Intercept(execution *Execution)
	Clone() IInterceptor
}

type INodeModel interface {
	GetName() string
	Exec(execution *Execution)
	Execute(execution *Execution)
	GetInputs() []*TransitionModel
	GetOutputs() []*TransitionModel
	AddInputs(tm ...*TransitionModel)
	BuildInterceptors(processService *ProcessService)
}

type JoinModel struct {
	NodeModel
}

type NodeModel struct {
	INodeModel
	BaseModel
	Inputs                  []*TransitionModel `xml:"-"`                     //输入变迁集合
	Outputs                 []*TransitionModel `xml:"transition"`            //输出变迁集合
	PrevInterceptorsSetting string             `xml:"prevInterceptors,attr"` //局部前置拦截器
	PostInterceptorsSetting string             `xml:"postInterceptors,attr"` //局部后置拦截器
	PrevInterceptors        []IInterceptor     `xml:"-"`                     //局部前置拦截器对象
	PostInterceptors        []IInterceptor     `xml:"-"`                     //局部后置拦截器对象
}

type Order struct {
	Id             string    `xorm:"varchar(36) pk notnull"`    //主键ID
	Version        int       `xorm:"tinyint"`                   //版本
	ProcessId      string    `xorm:"varchar(36) notnull index"` //流程定义ID
	Creator        string    `xorm:"varchar(36)"`               //流程实例创建者ID
	CreateTime     time.Time `xorm:"datetime notnull"`          //流程实例创建时间
	ParentId       string    `xorm:"varchar(36) index"`         //流程实例为子流程时，该字段标识父流程实例ID
	ParentNodeName string    `xorm:"varchar(100)"`              //流程实例为子流程时，该字段标识父流程哪个节点模型启动的子流程
	ExpireTime     time.Time `xorm:"datetime"`                  //流程实例期望完成时间
	LastUpdateTime time.Time `xorm:"datetime"`                  //流程实例上一次更新时间
	LastUpdator    string    `xorm:"varchar(36)"`               //流程实例上一次更新人员ID
	Priority       int       `xorm:"tinyint"`                   //流程实例优先级
	OrderNo        string    `xorm:"varchar(100) index"`        //流程实例编号
	Variable       string    `xorm:"varchar(3000)"`             //流程实例附属变量
}

type PERFORM_ORDER int

type PERFORM_TYPE string

type Process struct {
	Id             string        `xorm:"varchar(36) pk notnull"` //主键ID
	Version        int           `xorm:"tinyint"`                //版本
	Name           string        `xorm:"varchar(100) index"`     //流程定义名称
	DisplayName    string        `xorm:"varchar(200)"`           //流程定义显示名称
	InstanceAction string        `xorm:"varchar(200)"`           //当前流程的实例Action,(Web为URL,一般为流程第一步的URL;APP需要自定义),该字段可以直接打开流程申请的表单
	State          FLOW_STATUS   `xorm:"tinyint"`                //状态
	CreateTime     time.Time     `xorm:"datetime"`               //创建时间
	Creator        string        `xorm:"varchar(36)"`            //创建人
	Content        string        `xorm:"text"`                   //流程定义XML
	Model          *ProcessModel `xorm:"-"`                      //Model对象
}

type ProcessModel struct {
	BaseModel
	StartNodes       []*StartModel      `xml:"start"`               //开始节点
	EndModels        []*EndModel        `xml:"end"`                 //结束阶段
	TaskModels       []*TaskModel       `xml:"task"`                //任务节点
	DecisionModels   []*DecisionModel   `xml:"decision"`            //决策节点
	ForkModels       []*ForkModel       `xml:"fork"`                //分支节点
	JoinModels       []*JoinModel       `xml:"join"`                //合并节点
	SubProcessModels []*SubProcessModel `xml:"subprocess"`          //子流程节点
	InstanceAction   string             `xml:"instanceAction,attr"` //流程实例启动Action(web为url)
	ExpireTime       string             `xml:"expireTime,attr"`     //期望完成时间
	Models           []INodeModel       `xml:"-"`                   //上面所有Node节点(Start\End\Task\Decision\Fork\Join\SubProcess)的集合
}

type ProcessService struct {
	ProcessCache           map[string]*Process     //Process缓存，KEY为[名称.版本]
	NameCache              map[string]string       //ProcessName缓存，KEY为ID
	InnerInterceptorCache  map[string]IInterceptor //内置拦截器
	CustomInterceptorCache map[string]IInterceptor //自定义拦截器
}

type SURROGATE_STATUS int

type StartModel struct {
	NodeModel
}

type SubProcessModel struct {
	WorkModel
	ProcessName string `xml:"processName,attr"` //子流程名称
	Version     int    `xml:"version,attr"`     //子流程版本号
}

type Surrogate struct {
	Id          string           `xorm:"varchar(36) pk notnull"`    //主键ID
	ProcessName string           `xorm:"varchar(36) notnull"`       //流程名称
	Operator    string           `xorm:"varchar(36) notnull index"` //授权人
	Surrogate   string           `xorm:"varchar(36)"`               //代理人
	OpTime      time.Time        `xorm:"datetime"`                  //操作时间
	StartTime   time.Time        `xorm:"datetime"`                  //开始时间
	EndTime     time.Time        `xorm:"datetime"`                  //结束时间
	State       SURROGATE_STATUS `xorm:"tinyint"`                   //状态
}

type SurrogateInterceptor struct {
}

type TASK_ORDER int

type TASK_TYPE string

type Task struct {
	Id           string        `xorm:"varchar(36) pk notnull"`     //主键ID
	Version      int           `xorm:"tinyint"`                    //版本
	OrderId      string        `xorm:"varchar(36) notnull index"`  //流程实例ID
	TaskName     string        `xorm:"varchar(100) notnull index"` //任务名称
	DisplayName  string        `xorm:"varchar(200) notnull"`       //任务显示名称
	PerformType  PERFORM_ORDER `xorm:"tinyint"`                    //任务参与方式
	TaskType     TASK_ORDER    `xorm:"tinyint notnull"`            //任务类型
	Operator     string        `xorm:"varchar(36)"`                //任务处理者ID
	CreateTime   time.Time     `xorm:"datetime"`                   //任务创建时间
	FinishTime   time.Time     `xorm:"datetime"`                   //任务完成时间
	ExpireTime   time.Time     `xorm:"datetime"`                   //期望任务完成时间
	RemindTime   time.Time     `xorm:"datetime"`                   //提醒时间
	Action       string        `xorm:"varchar(200)"`               //任务关联的Action(WEB为表单URL)
	ParentTaskId string        `xorm:"varchar(36) index"`          //父任务ID
	Variable     string        `xorm:"varchar(2000)"`              //任务附属变量(json存储)
	Model        *TaskModel    `xorm:"-"`                          //Model对象
}

type TaskActor struct {
	Id      string `xorm:"varchar(36) pk notnull"`                        //主键ID
	TaskId  string `xorm:"varchar(36) notnull index(IDX_TASKACTOR_TASK)"` //任务ID
	ActorId string `xorm:"varchar(36) notnull"`                           //参与者ID
}

type TaskModel struct {
	WorkModel
	Assignee    string       `xml:"assignee,attr"`    //参与者变量名称
	PerformType PERFORM_TYPE `xml:"performType,attr"` //参与方式
	TaskType    TASK_TYPE    `xml:"taskType,attr"`    //任务类型
	AutoExecute bool         `xml:"autoExecute,attr"` //是否自动执行
	ExpireTime  string       `xml:"expireTime,attr"`  //期望完成时间
}

type TransitionModel struct {
	BaseModel
	Source  INodeModel `xml:"-"`         //变迁的源节点引用
	Target  INodeModel `xml:"-"`         //变迁的目标节点引用
	To      string     `xml:"to,attr"`   //变迁的目的节点
	Expr    string     `xml:"expr,attr"` //变迁的条件表达式，用于decision
	Enabled bool       `xml:"-"`         //当前变迁路径是否可用
}

type WorkModel struct {
	NodeModel
	Action string `xml:"action,attr"`
}