THE コンポーネントは長い間、フレームワークの最も強力で未使用の宝石の1つであり、開発者はビジネスプロセス論理をエンティティステートから切り離し、複雑な「スパゲッティコード」状態チェックをクリーンで可視化可能な指向グラフに変換することができます。 symfony/workflow しかし、長年にわたり、このコンポーネントはペトリネットの実装に根ざした厳しい制限を持っていました。 オブジェクトはある場所(状態)にあったか、あるいは存在しなかったが、複数の場所(並行処理)に同時にいることはできないが、複数回同じ場所にいることはできない。 Tokens were boolean Symfony 7.4 changes the game with Weighted Transitions. この新機能が導入 量が重要なシナリオをモデル化する: 「4 つの署名を収集する」、「プロセス 5 バッチの項目を処理する」または「3 つのサブシステムが初期化されるのを待つ」 multiplicity この記事では、強力な 我々は、重量化された移行を構成し、エンティティ・ロジックを実装し、厳格なテストでフローを検証する方法を調べる - すべてSymfony 7.4とPHP 8.3を使用して。 Multi-Signature Approval System ペトリ・ネットス(Petri Nets vs. State Machines) コードを書く前に、この機能が存在する理由を理解することが重要です。 国家機械の制限 A state machine is linear. エレベーターは で、 あるいは ( ) It cannot be これは、よりシンプルなステータス(例えば、 ( ) STOPPED MOVING_UP MOVING_DOWN MOVING_UP Order::STATUS_PAID ワークフロー(Petri Net) A 「New Employee Onboarding」プロセスでは、従業員が同時に: Workflow 
 
 
 トップ > ラップトップ アカウント作成_email_account 両方とも移動する前に完成しなければなりません。 . onboarded The Missing Piece: 多様性 Symfony 7.4 以前は、「支出を承認するために 3 人のマネージャーが必要だった」のであれば、これを単にワークフローでモデル化することはできませんでした。 
 
 
 
 waiting_for_approval を設定します。 エンティティにカウンターフィールド($approvalCount)を追加します。 Guard Event listener を使用して、移行を許可する前に ($subject->getApprovalCount() >= 3) を確認します。 同 「The」 」は現在、ワークフロー状態自体の一部であり、ワークフロー エンジンは、対象が ステータス3回 Weighted Transitions counter approved プロジェクト設定 新しいSymfonyプロジェクトを作成し、必要なコンポーネントをインストールしましょう。 composer create-project symfony/skeleton:"7.4.*" fintech-approval
cd fintech-approval
composer require symfony/workflow symfony/framework-bundle symfony/orm-pack symfony/maker-bundle
 この例では、シンプルさのためにSQLiteを使用しますが、MySQL/PostgreSQLの論理はまったく同じです。 # .env
DATABASE_URL="sqlite:///%kernel.project_dir%/var/data.db"
 コアロジック(Core Logic) ここで魔法が起こります。Expense_approvalと呼ばれるワークフローを定義します。 The Scenario: 
 
 
 
 
 
 費用報告書(プロジェクト)を作成する。 提出される(review_required) 重量化ステップ:システムは要求を3つの必要な承認者に配布します。 各承認者は個別に承認を行います。 3 つの承認が収集されると、コストは ready_for_payment に移動します。 作成または更新 : config/packages/workflow.yaml # config/packages/workflow.yaml
framework:
    workflows:
        expense_approval:
            type: workflow # MUST be 'workflow', not 'state_machine'
            audit_trail:
                enabled: true
            marking_store:
                type: method
                property: currentState # This must hold an array
            
            supports:
                - App\Entity\ExpenseReport

            initial_marking: draft

            places:
                - draft
                - review_pool
                - approved_pool
                - ready_for_payment
                - rejected

            transitions:
                submit:
                    from: draft
                    to:
                        - place: review_pool
                          weight: 3 # <--- OUTPUT WEIGHT
                          
                approve:
                    from: review_pool
                    to: approved_pool
                    # Default weight is 1. One 'review_pool' token becomes one 'approved_pool' token.

                reject:
                    from: review_pool
                    to: rejected
                    # If rejected, we might want to clear all tokens, 
                    # but for simplicity, one rejection moves to rejected.

                finalize:
                    from:
                        - place: approved_pool
                          weight: 3 # <--- INPUT WEIGHT
                    to: ready_for_payment
 Configを解体する 
 
 
 
 
 type: workflow: Weighted transitions rely on token buckets. This is not possible in a state machine. 重量化された移行はトークンバケットに依存します。 submitTransition:- to: {place: review_pool, weight: 3 } - This fires, thereview_poolplace receives 3 tokens.- これを打撃する必要がある3つの「チケット」を作成するように考えてください。 approveTransition:-from: review_pool, to: approved_pool.- Standard 1-to-1 weight.- We have 3 tokens inreview_pool, we can fire this transition 3 times. inreview_pool, we can fire this transition 3 times. finalizeTransition:- from: {place: approved_pool, weight: 3 }- This transition is blocked until theapproved_poolcontains exactly (or at least) 3 tokens.- Once the 3rd approval comes in, this path unlocks. この移行は、approved_poolが正確に(または少なくとも) 3 個のトークンを含むまでブロックされます。 エンティティ この「Multi-State」マーキングストアをサポートするエンティティが必要です。 資産は、トークン数を保持するマレージでなければなりません(例えば、 ( ) currentState [‘review_pool’ => 2, ‘approved_pool’ => 1] 
namespace App\Entity;

use App\Repository\ExpenseReportRepository;
use Doctrine\ORM\Mapping as ORM;

#[ORM\Entity(repositoryClass: ExpenseReportRepository::class)]
class ExpenseReport
{
    #[ORM\Id]
    #[ORM\GeneratedValue]
    #[ORM\Column]
    private ?int $id = null;

    #[ORM\Column(length: 255)]
    private string $description;

    #[ORM\Column]
    private float $amount;

    /**
     * Stores the workflow state.
     * For Weighted Workflows, this stores the places and their quantities.
     * Example DB content: {"review_pool": 2, "approved_pool": 1}
     */
    #[ORM\Column(type: 'json')]
    private array $currentState = [];

    public function __construct(string $description, float $amount)
    {
        $this->description = $description;
        $this->amount = $amount;
        // Initial marking is handled by the workflow component, 
        // but initializing to empty array is good practice.
    }

    public function getId(): ?int
    {
        return $this->id;
    }

    public function getDescription(): string
    {
        return $this->description;
    }

    public function getAmount(): float
    {
        return $this->amount;
    }

    public function getCurrentState(): array
    {
        return $this->currentState;
    }

    public function setCurrentState(array $currentState): self
    {
        $this->currentState = $currentState;
        return $this;
    }
}
 移住を進める: Run the migration: php bin/console make:migration
php bin/console doctrine:migrations:migrate
 サービスレイヤー このワークフローと清潔に相互作用するには、サービスを作成する必要があります. このサービスは「誰」の論理を処理しますが、このチュートリアルでは、ワークフローのメカニクスに焦点を当てます。 
namespace App\Service;

use App\Entity\ExpenseReport;
use Symfony\Component\Workflow\WorkflowInterface;
use Symfony\Component\Workflow\Registry;

readonly class ExpenseManager
{
    public function __construct(
        private Registry $workflowRegistry,
    ) {}

    public function submit(ExpenseReport $expense): void
    {
        $workflow = $this->getWorkflow($expense);
        
        if ($workflow->can($expense, 'submit')) {
            $workflow->apply($expense, 'submit');
        } else {
            throw new \LogicException('Cannot submit this expense report.');
        }
    }

    public function approve(ExpenseReport $expense): void
    {
        $workflow = $this->getWorkflow($expense);

        // In a real app, you would check "Is the current user one of the allowed approvers?" here.
        
        if ($workflow->can($expense, 'approve')) {
            $workflow->apply($expense, 'approve');
            
            // Check if we can auto-finalize (if 3 approvals are met)
            if ($workflow->can($expense, 'finalize')) {
                $workflow->apply($expense, 'finalize');
            }
        } else {
            throw new \LogicException('Approval not needed or not allowed.');
        }
    }
    
    public function getStatus(ExpenseReport $expense): array
    {
        // returns something like ['review_pool' => 2, 'approved_pool' => 1]
        return $expense->getCurrentState();
    }

    private function getWorkflow(ExpenseReport $expense): WorkflowInterface
    {
        return $this->workflowRegistry->get($expense, 'expense_approval');
    }
}
 「自動完成」の論理 承認方法を参照してください. 承認方法を適用した後、すぐにチェックできます($expense, ‘finalize’)。 
 
 
 
 FirstApproval:-review_pool: 2-approved_pool: 1-finalize needs 3 approved_pool. can(‘finalize’) は false を返します。 SecondApproval:-review_pool: 1-approved_pool: 2-can(‘finalize’) は false を返します。 ThirdApproval:review_pool: 0approved_pool: 3finalize needs 3. can(‘finalize’) は true.We applyfinalize.New State:ready_for_payment: 1. ワークフローの視覚化 テストの前に、特に重量に関与するグラフを視覚化することは非常に役に立ちます。 php bin/console workflow:dump expense_approval | dot -Tpng -o workflow.png
 あなたがそれを持っていない場合は、テキスト出力をオンライン Graphviz ビューアに挿入することができます。 出力は、重量:3のようなラベルで矢印を視覚的に表し、提出移行が複数のトークンを産むことを明確にします。 検証(ユニットテスト) We don't just hope it works; we prove it. We will use a 実際のワークフローの構成をロードし、移行をテストします。 KernelTestCase //tests/Workflow/ExpenseApprovalWorkflowTest.php
namespace App\Tests\Workflow;

use App\Entity\ExpenseReport;
use Symfony\Bundle\FrameworkBundle\Test\KernelTestCase;
use Symfony\Component\Workflow\WorkflowInterface;

class ExpenseApprovalWorkflowTest extends KernelTestCase
{
    private WorkflowInterface $workflow;

    protected function setUp(): void
    {
        self::bootKernel();
        $container = static::getContainer();
        $registry = $container->get('workflow.registry');
        
        // We create a dummy subject to get the workflow
        // In a real app, passing the class name to the registry is preferred if supported,
        // or fetching by name directly if you have a custom service alias.
        $subject = new ExpenseReport('Test', 100.0);
        $this->workflow = $registry->get($subject, 'expense_approval');
    }

    public function testWeightedApprovalFlow(): void
    {
        $expense = new ExpenseReport('MacBook Pro', 3000.00);

        // 1. Initial State
        $this->assertTrue($this->workflow->can($expense, 'submit'));
        $this->workflow->apply($expense, 'submit');

        // Verify tokens: Should be in review_pool 3 times
        $marking = $expense->getCurrentState();
        $this->assertArrayHasKey('review_pool', $marking);
        $this->assertEquals(3, $marking['review_pool'], 'Should have 3 pending reviews');

        // 2. First Approval
        $this->assertTrue($this->workflow->can($expense, 'approve'));
        $this->workflow->apply($expense, 'approve');
        
        $marking = $expense->getCurrentState();
        $this->assertEquals(2, $marking['review_pool']);
        $this->assertEquals(1, $marking['approved_pool']);

        // Check that we CANNOT finalize yet (need 3 approvals)
        $this->assertFalse($this->workflow->can($expense, 'finalize'), 'Should not finalize with only 1 approval');

        // 3. Second Approval
        $this->workflow->apply($expense, 'approve');
        $marking = $expense->getCurrentState();
        $this->assertEquals(1, $marking['review_pool']);
        $this->assertEquals(2, $marking['approved_pool']);

        // 4. Third Approval
        $this->workflow->apply($expense, 'approve');
        $marking = $expense->getCurrentState();
        
        // At this specific moment, review_pool is 0, approved_pool is 3
        $this->assertEquals(0, $marking['review_pool'] ?? 0);
        $this->assertEquals(3, $marking['approved_pool']);

        // 5. Finalize
        $this->assertTrue($this->workflow->can($expense, 'finalize'), 'Should be able to finalize now');
        $this->workflow->apply($expense, 'finalize');

        // 6. Verify End State
        $marking = $expense->getCurrentState();
        $this->assertArrayHasKey('ready_for_payment', $marking);
        $this->assertEquals(1, $marking['ready_for_payment']);
        // Previous tokens should be consumed
        $this->assertArrayNotHasKey('approved_pool', $marking);
    }
}
 テストを実行: php bin/phpunit tests/Workflow/ExpenseApprovalWorkflowTest.php
 Advanced Usage & Best Practices(最先端の使用と最良の実践) Enums for Places (New in 7.4) Symfony 7.4 では、ワークフローにおけるバックアップされたエノムのサポートも追加されています。 「Enumを定義すべきだ。 review_pool namespace App\Enum;

enum ExpenseState: string
{
    case DRAFT = 'draft';
    case REVIEW_POOL = 'review_pool';
    case APPROVED_POOL = 'approved_pool';
    case READY = 'ready_for_payment';
    case REJECTED = 'rejected';
}
 次に、workflow.yaml を更新できます(YAML はまだ文字列を使用していますが、PHP コードは ( ) ExpenseState::REVIEW_POOL->value Guard Events with Weights シングル 同じことを避けたいのかもしれない。 3 重量化された移行により、移行が可能になります。 3回呼び出されることになるが、ワークフローエンジンは誰が呼んだのか知らない。 person approve この問題を解決するには、ガード・ライターを使用してください。 #[AsEventListener('workflow.expense_approval.guard.approve')]
public function preventDoubleApproval(GuardEvent $event): void
{
    /** @var ExpenseReport $expense */
    $expense = $event->getSubject();
    $user = $this->security->getUser();

    // Imagine the entity has a list of who already approved
    if ($expense->hasApproved($user)) {
        $event->setBlocked(true, 'You have already approved this expense.');
    }
}
 トークンクリーニング(Token Cleanup) 重量トークンの課題の1つは、クリーニングです. もし2つの承認があり、3番目の人が呼び出すなら , what happens to the 2 tokens sitting in 座っているトークンに何が起こるか ? reject approved_pool 標準ワークフローでは、移動する 彼らを離れるかもしれない。 トークンストラグリング(レポートが拒否され、部分的に承認されているゾンビ状態を作成する)。 rejected approved_pool THE 過渡期は理想的に消費するべき しかし、ダイナミックな消費はYAMLで完全にサポートされていません(「すべてを消費する」とは言えません)。 reject all Event Subscriber を使用する マーキングストアを手動でリセットできます。 workflow.entered.rejected public function onRejected(Event $event): void
{
    $expense = $event->getSubject();
    // Force reset state to ONLY rejected
    $expense->setCurrentState(['rejected' => 1]);
}
 結論 シンフォニア 7.4 単純な状態管理と複雑なペトリネットロジックの間のギャップをブリッジすることによって、複数の状態のインスタンス(トークン)が同時に存在することを可能にすることによって、私たちは今、投票システム、製造アセンブリライン、およびバッチ処理ロジックを直接構成し、カスタムPHPボイラープレートが必要な量を劇的に減らすことができます。 Weighted Workflow Transitions Key Takeaways: 
 
 
 
 
 Multiplicity: Places can hold multiple tokens, allowing for parallel accumulation of state. 場所は複数のトークンを保持することができ、状態の並行的な蓄積を可能にします。 Configuration: Use weight in your to (output) and from (input) definitions to control token flow. トークン フローを制御するために、あなたの To (output) and From (input) 定義の重量を使用します。 ストレージ:マーキングストアのプロパティは、場所ごとにトークン数を追跡するために、数列(例えば、JSON列)であることを確認します。 検証: ワークフロー:ダンプ コマンドを常に使用し、展開前に KernelTestCase テストを書き、グラフの論理を証明します。 この機能は、SymfonyのWorkflowコンポーネントを州管理のための主要なPHPソリューションとして強化し、脆弱な「カウンター」属性を削除し、数学的に健全なアーキテクチャに頼ることができます。 Let's be in touch ♪ これらの高度なパターンを採用すると、ドメインの論理を大幅に簡素化できますが、移行は必ずしも明らかではありません。Symfony スタックを近代化しようとしている場合、アーキテクチャに目を向ける必要がある場合、または最新の Petri ネットの実装を気に入りたい場合、私はあなたから聞きたいと思います。 Linkedin(LinkedInでつながる) ) 現代のPHPアーキテクチャについての会話を続ける。 https://www.linkedin.com/in/matthew-mochalkin/ https://www.linkedin.com/in/matthew-mochalkin/

Read My Stories

このオーディオは、ストーリーの元の言語で制作されています。

Symfony 7.4 で FinTech 承認システムを構築する方法

About Author

コメント

ラベル

この記事は

Related Stories

18 種類の開発者ツールで生産性を向上しましょう 🚀🔥

目に見えない層: ユーザーインタビューがかけがえのない資産である理由

ユニークなエコシステムを支えるビットコインUTXOのモデル

海を航海する: データレイクを使用した本番環境レベルの RAG アプリケーションの開発

18 種類の開発者ツールで生産性を向上しましょう 🚀🔥

目に見えない層: ユーザーインタビューがかけがえのない資産である理由

ユニークなエコシステムを支えるビットコインUTXOのモデル

海を航海する: データレイクを使用した本番環境レベルの RAG アプリケーションの開発

Light-Mode

Classic

Newspaper

Minty

Dark-Mode

Neon Noir

Minty

HN StartUps