php实现工作流

PHP实现工作流的方法

使用Symfony Workflow组件

Symfony提供了一个强大的Workflow组件，可以用于定义和管理工作流。通过定义状态、转换和事件，可以轻松实现复杂的工作流逻辑。

安装Symfony Workflow组件：

composer require symfony/workflow

定义工作流配置（YAML格式）：

framework:
    workflows:
        article_publishing:
            type: 'state_machine'
            marking_store:
                type: 'single_state'
                arguments: ['currentState']
            supports:
                - App\Entity\Article
            initial_marking: draft
            places:
                - draft
                - review
                - published
                - rejected
            transitions:
                to_review:
                    from: draft
                    to: review
                publish:
                    from: review
                    to: published
                reject:
                    from: review
                    to: rejected

在PHP代码中使用工作流：

use Symfony\Component\Workflow\Workflow;
use App\Entity\Article;

$article = new Article();
$workflow = $container->get('workflow.article_publishing');

if ($workflow->can($article, 'to_review')) {
    $workflow->apply($article, 'to_review');
}

使用Laravel的Eloquent状态机

对于Laravel项目，可以使用Eloquent模型结合状态机模式实现工作流。

定义模型状态：

class Order extends Model
{
    const STATUS_PENDING = 'pending';
    const STATUS_APPROVED = 'approved';
    const STATUS_REJECTED = 'rejected';
    const STATUS_COMPLETED = 'completed';

    protected $attributes = [
        'status' => self::STATUS_PENDING,
    ];
}

实现状态转换逻辑：

class OrderController extends Controller
{
    public function approve(Order $order)
    {
        if ($order->status === Order::STATUS_PENDING) {
            $order->status = Order::STATUS_APPROVED;
            $order->save();
            return redirect()->back()->with('success', 'Order approved');
        }

        throw new \Exception('Invalid transition');
    }
}

自定义工作流引擎

对于需要完全控制的情况，可以创建自定义工作流引擎。

定义工作流类：

class WorkflowEngine
{
    private $states = [];
    private $transitions = [];

    public function addState(string $state): void
    {
        $this->states[$state] = true;
    }

    public function addTransition(string $from, string $to, callable $condition): void
    {
        $this->transitions[] = [
            'from' => $from,
            'to' => $to,
            'condition' => $condition
        ];
    }

    public function canTransition(string $currentState, string $targetState): bool
    {
        foreach ($this->transitions as $transition) {
            if ($transition['from'] === $currentState 
                && $transition['to'] === $targetState) {
                return $transition['condition']();
            }
        }
        return false;
    }
}

使用自定义工作流：

$workflow = new WorkflowEngine();
$workflow->addState('draft');
$workflow->addState('published');
$workflow->addTransition('draft', 'published', function() {
    return auth()->user()->canPublish();
});

if ($workflow->canTransition('draft', 'published')) {
    // 执行发布操作
}

使用现成的PHP工作流库

PHP生态系统中有多个专门的工作流库可供选择：

• State Machine：轻量级状态机实现

  composer require winzou/state-machine

• Workflow Core：功能丰富的工作流引擎

  composer require php-workflow/workflow

• Oro Workflow：企业级工作流解决方案

  composer require oro/workflow

这些库提供了可视化工作流设计器、持久化支持和复杂条件判断等功能，适合企业级应用。

数据库设计模式

持久化工作流状态通常需要合理的数据库设计：

CREATE TABLE workflows (
    id INT AUTO_INCREMENT PRIMARY KEY,
    name VARCHAR(255) NOT NULL,
    description TEXT
);

CREATE TABLE workflow_states (
    id INT AUTO_INCREMENT PRIMARY KEY,
    workflow_id INT NOT NULL,
    name VARCHAR(255) NOT NULL,
    FOREIGN KEY (workflow_id) REFERENCES workflows(id)
);

CREATE TABLE workflow_transitions (
    id INT AUTO_INCREMENT PRIMARY KEY,
    workflow_id INT NOT NULL,
    from_state_id INT NOT NULL,
    to_state_id INT NOT NULL,
    FOREIGN KEY (workflow_id) REFERENCES workflows(id),
    FOREIGN KEY (from_state_id) REFERENCES workflow_states(id),
    FOREIGN KEY (to_state_id) REFERENCES workflow_states(id)
);

CREATE TABLE workflow_instances (
    id INT AUTO_INCREMENT PRIMARY KEY,
    workflow_id INT NOT NULL,
    current_state_id INT NOT NULL,
    entity_type VARCHAR(255) NOT NULL,
    entity_id INT NOT NULL,
    FOREIGN KEY (workflow_id) REFERENCES workflows(id),
    FOREIGN KEY (current_state_id) REFERENCES workflow_states(id)
);

这种设计允许跟踪多个实体的工作流状态，并支持复杂的工作流定义。