Set Peaks internal order id when uploading order

Setono · Jun 19, 2024 · 741a776 · 741a776
1 parent d8ebc9b
commit 741a776
Show file tree

Hide file tree

Showing 4 changed files with 24 additions and 2 deletions.
diff --git a/src/Message/CommandHandler/ProcessUploadOrderRequestHandler.php b/src/Message/CommandHandler/ProcessUploadOrderRequestHandler.php
@@ -56,8 +56,8 @@ public function __invoke(ProcessUploadOrderRequest $message): void
             $salesOrder = new SalesOrder();
             $this->salesOrderDataMapper->map($order, $salesOrder);
 
-            $this->peakWMSClient->salesOrder()->create($salesOrder);
-
+            $response = $this->peakWMSClient->salesOrder()->create($salesOrder);
+            $uploadOrderRequest->setPeakOrderId($response->id);
             $this->uploadOrderRequestWorkflow->apply($order, UploadOrderRequestWorkflow::TRANSITION_UPLOAD);
         } catch (\Throwable $e) {
             $uploadOrderRequest->setError($e->getMessage());

diff --git a/src/Model/UploadOrderRequest.php b/src/Model/UploadOrderRequest.php
@@ -20,6 +20,8 @@ class UploadOrderRequest implements UploadOrderRequestInterface
 
     protected ?string $error = null;
 
+    protected ?int $peakOrderId = null;
+
     public function getId(): ?int
     {
         return $this->id;
@@ -84,4 +86,14 @@ public function setError(?string $error): void
     {
         $this->error = $error;
     }
+
+    public function getPeakOrderId(): ?int
+    {
+        return $this->peakOrderId;
+    }
+
+    public function setPeakOrderId(?int $peakOrderId): void
+    {
+        $this->peakOrderId = $peakOrderId;
+    }
 }
diff --git a/src/Model/UploadOrderRequestInterface.php b/src/Model/UploadOrderRequestInterface.php
@@ -38,4 +38,11 @@ public function setResponse(?string $response): void;
     public function getError(): ?string;
 
     public function setError(?string $error): void;
+
+    /**
+     * If the order was uploaded successfully, this method will return the peak order id
+     */
+    public function getPeakOrderId(): ?int;
+
+    public function setPeakOrderId(?int $peakOrderId): void;
 }
diff --git a/src/Resources/config/doctrine/model/UploadOrderRequest.orm.xml b/src/Resources/config/doctrine/model/UploadOrderRequest.orm.xml
@@ -12,6 +12,9 @@
 
         <field name="version" type="integer" version="true"/>
         <field name="state" type="string"/>
+        <field name="request" type="text" nullable="true"/>
+        <field name="response" type="text" nullable="true"/>
+        <field name="error" type="text" nullable="true"/>
 
         <one-to-one field="order" target-entity="Sylius\Component\Order\Model\OrderInterface" inversed-by="peakWMSUploadOrderRequest">
             <join-column name="order_id" referenced-column-name="id" nullable="false" unique="true" on-delete="CASCADE"/>