Fixed： Saga 单例情况下, 导致concurrent和orders持久化

Saga 单例情况下, 导致concurrent和orders持久化

Author: PandaLIU-1111

src/Saga.php

@@ -12,14 +12,15 @@
 use DtmClient\Api\ApiInterface;
 use DtmClient\Constants\Protocol;
 use DtmClient\Constants\TransType;
+use DtmClient\Context\Context;
 use DtmClient\Exception\UnsupportedException;
 use Google\Protobuf\Internal\Message;
 
 class Saga extends AbstractTransaction
 {
-    protected array $orders = [];
+    protected const CONCURRENT = self::class . '.concurrent';
 
-    protected bool $concurrent = false;
+    protected const ORDERS = self::class . '.orders';
 
     protected ApiInterface $api;
 
@@ -33,6 +34,8 @@ public function init(?string $gid = null)
         if ($gid === null) {
             $gid = $this->generateGid();
         }
+        Context::set(static::CONCURRENT, false);
+        Context::set(static::ORDERS, []);
         TransContext::init($gid, TransType::SAGA, '');
     }
 
@@ -60,13 +63,15 @@ public function add(string $action, string $compensate, array|object $payload):
 
     public function addBranchOrder(int $branch, array $preBranches): static
     {
-        $this->orders[$branch] = $preBranches;
+        $orders = Context::get(static::ORDERS, []);
+        $orders[$branch] = $preBranches;
+        Context::set(static::ORDERS, $orders);
         return $this;
     }
 
     public function enableConcurrent()
     {
-        $this->concurrent = true;
+        Context::set(static::CONCURRENT, true);
     }
 
     public function submit()
@@ -77,10 +82,10 @@ public function submit()
 
     public function addConcurrentContext()
     {
-        if ($this->concurrent) {
+        if (Context::get(static::CONCURRENT, false)) {
             TransContext::setCustomData(json_encode([
-                'concurrent' => $this->concurrent,
-                'orders' => $this->orders ?: null,
+                'concurrent' => Context::get(static::CONCURRENT),
+                'orders' => Context::get(static::ORDERS) ?: null,
             ]));
         }
     }