Быстрый старт

git clone git@github.com:nicolas-vp/go-bpm.git
cd go-bpm
createdb -h localhost -U postgres go_bpm      # или: docker exec go-bpm-pg createdb -U postgres go_bpm
make run

level=INFO msg="demo started" addr=:8080 console=http://localhost:8080/ui/

# запустить процесс с бизнес-ключом
curl -XPOST localhost:8080/api/v1/processes/TestDecision/instances \
  -d '{"variables":{"a":"foo","b":"bar"},"businessKey":"order-1"}'
# {"id":"01a17412-d14e-77d9-9651-a32ee9008420"}

# экземпляры процесса
curl 'localhost:8080/api/v1/instances?processName=TestDecision'

# история экземпляра: каждый пройденный элемент с переменными
curl localhost:8080/api/v1/instances/01a17412-d14e-77d9-9651-a32ee9008420/history

bpm history: completed process="TestDecision" instance=01a17412-... element="Activity_0xzljrt" type=Method variables={"a":"foo",...,"c":"correct foobar"}
rules history: process="TestDecision" instance=01a17412-... element="Activity_0xzljrt" decision="Decision_1" rules=["DecisionRule_04e4bk8"] result="correct foobar"

mkdir orders && cd orders
go mod init example.com/orders
go get github.com/nicolas-vp/go-bpm@latest
go get -tool github.com/nicolas-vp/go-bpm/cmd/go-bpm-gen@latest

// internal/gen/generate.go
package gen

//go:generate go tool go-bpm-gen

go generate ./internal/gen

go-bpm-gen: .../orders/process -> .../orders/internal/bpmgen
переменных нет в модели данных model, добавьте поля:
	model.DataModel:
		Amount int `json:"amount"`
используются в:
	процесс OrderApproval: условие IsBig

process/bpmn-gen.go                               вшитые BPMN/DMN (сгенерирован)
internal/bpmgen/
  bpm-gen.go, queue-gen.go                        сборка процессов и очередей (сгенерированы)
  model/data_model.go                             DataModel — пишете вы
  services/services.go                            внешние зависимости методов — пишете вы
  handlers/notify_client.go                       обработчик service task — пишете вы
  order_approval/
    flow-gen.go                                   схема процесса (сгенерирован)
    method_check_order.go                         метод задачи «Проверить заказ» — пишете вы

// internal/bpmgen/model/data_model.go
type DataModel struct {
	Amount   float64 `json:"amount"`
	Checked  bool    `json:"checked"`
	Notified bool    `json:"notified"`
}

// internal/bpmgen/order_approval/method_check_order.go
func CheckOrder(ctx context.Context, svc *services.Services, data *model.DataModel) error {
	if data.Amount <= 0 {
		return fmt.Errorf("сумма заказа должна быть положительной: %v", data.Amount)
	}
	data.Checked = true
	return nil
}

// internal/bpmgen/handlers/notify_client.go
func NotifyClient(ctx context.Context, svc *services.Services, job bpm.Job, data *model.DataModel) error {
	slog.InfoContext(ctx, "уведомляем клиента", "instance", job.InstanceUid, "amount", data.Amount)
	data.Notified = true
	return nil
}

go generate ./internal/gen

// cmd/orders/main.go
package main

import (
	"context"
	"log"
	"net/http"
	"os"
	"os/signal"

	"github.com/jackc/pgx/v5/pgxpool"

	"github.com/nicolas-vp/go-bpm/engine"
	"github.com/nicolas-vp/go-bpm/httpapi"
	"github.com/nicolas-vp/go-bpm/migrations"
	"github.com/nicolas-vp/go-bpm/queue"
	"github.com/nicolas-vp/go-bpm/webui"

	"example.com/orders/internal/bpmgen"
	"example.com/orders/internal/bpmgen/services"
)

func main() {
	ctx, stop := signal.NotifyContext(context.Background(), os.Interrupt)
	defer stop()

	pool, err := pgxpool.New(ctx, os.Getenv("DATABASE_URL"))
	if err != nil {
		log.Fatal(err)
	}
	defer pool.Close()
	// таблицы bpm_*: применяются недостающие миграции, безопасно при одновременном старте подов
	if err := migrations.Up(ctx, pool); err != nil {
		log.Fatal(err)
	}

	svc := &services.Services{} // клиенты внешних систем для методов и обработчиков
	processes := bpmgen.Processes(svc)
	on := func() bool { return true }

	q := queue.New(pool, queue.Options{})
	e, err := engine.New(q, engine.Config{
		History:      engine.HistoryConfig{ToDB: on}, // экземпляры и история элементов
		RulesHistory: engine.HistoryConfig{ToDB: on}, // сработавшие правила DMN
	}, processes, bpmgen.Queues(svc))
	if err != nil {
		log.Fatal(err)
	}
	history := engine.NewHistoryReader(pool, processes, bpmgen.Decisions)

	mux := http.NewServeMux()
	httpapi.Register(mux, e, history)                                  // процессы и экземпляры
	httpapi.RegisterUserTasks(mux, engine.NewUserTaskService(pool, e)) // задачи пользователей
	webui.Register(mux, history)                                       // консоль /ui/

	q.Start(ctx) // воркеры очереди: с этого момента процессы исполняются
	defer q.Stop()

	server := &http.Server{Addr: ":8080", Handler: mux}
	go func() {
		<-ctx.Done()
		server.Shutdown(context.Background())
	}()
	log.Println("консоль: http://localhost:8080/ui/")
	if err := server.ListenAndServe(); err != http.ErrServerClosed {
		log.Fatal(err)
	}
}

go mod tidy
createdb orders
DATABASE_URL='postgres://postgres:postgres@localhost:5432/orders?sslmode=disable' go run ./cmd/orders

curl -XPOST localhost:8080/api/v1/processes/OrderApproval/instances -d '{"variables":{"amount":500},"businessKey":"order-1"}'
curl -XPOST localhost:8080/api/v1/processes/OrderApproval/instances -d '{"variables":{"amount":5000},"businessKey":"order-2"}'

INFO уведомляем клиента instance=01a17411-e693-... amount=500
INFO process completed process=OrderApproval instance=01a17411-e693-...

curl 'localhost:8080/api/v1/tasks?candidateUser=bob&candidateGroup=managers'
# {"tasks":[{"task_uid":"01a17411-e6a2-...","element_id":"Approve","name":"Согласовать заказ",
#            "business_key":"order-2","candidate_groups":["managers"],"status":"created",...}]}

curl -XPOST localhost:8080/api/v1/tasks/01a17411-e6a2-.../claim -d '{"userId":"bob","groups":["managers"]}'      # 204
curl -XPOST localhost:8080/api/v1/tasks/01a17411-e6a2-.../complete -d '{"userId":"bob","variables":{"approved":true}}' # 204

completed Start       {"amount": 5000}
completed CheckOrder  {"amount": 5000, "checked": true, "notified": false}
completed IsBig
completed Flow_big
activated Approve     {"amount": 5000, "checked": true, "notified": false}
completed Approve     {"amount": 5000, "approved": true, "checked": true, "notified": false}
activated Notify      ...
completed Notify      {"amount": 5000, "approved": true, "checked": true, "notified": true}
completed End