add map events

pagopa · Apr 4, 2024 · f0aaa7a · f0aaa7a
1 parent f026c3f
commit f0aaa7a
Show file tree

Hide file tree

Showing 7 changed files with 54 additions and 8 deletions.
diff --git a/src/sql/02_2024_create_table.sql b/src/sql/02_2024_create_table.sql
@@ -84,6 +84,3 @@ create table if not exists public.metadata_2024 (
     constraint "METADATA_2024_pk" primary key (date_event, id)
 )
 PARTITION BY RANGE (date_event);
-
-
-
diff --git a/src/src/crawler/MapEvents.php b/src/src/crawler/MapEvents.php
@@ -0,0 +1,44 @@
+<?php
+
+namespace pagopa\crawler;
+
+class MapEvents
+{
+
+    protected static array $map_events =
+        [
+            array(
+                'type'      => 'activatePaymentNotice',
+                'subtype'   => 'REQ',
+                'id'        => 1
+            ),
+            array(
+                'type'      => 'activatePaymentNotice',
+                'subtype'   => 'RESP',
+                'id'        => 2
+            ),
+            array(
+                'type'      => 'nodoInviaCarrelloRPT',
+                'subtype'   => 'REQ',
+                'id'        => 3
+            ),
+            array(
+                'type'      => 'nodoInviaCarrelloRPT',
+                'subtype'   => 'RESP',
+                'id'        => 4
+            )
+        ];
+
+
+    public static function getMethodId(string $type, string $subtype) : int|null
+    {
+        foreach(self::$map_events as $event)
+        {
+            if (($event['type'] == $type) && ($event['subtype'] == $subtype))
+            {
+                return $event['id'];
+            }
+        }
+        return null;
+    }
+}
diff --git a/src/src/crawler/events/req/activatePaymentNotice.php b/src/src/crawler/events/req/activatePaymentNotice.php
@@ -2,6 +2,7 @@
 namespace pagopa\crawler\events\req;
 
 use pagopa\crawler\AbstractEvent;
+use pagopa\crawler\MapEvents;
 use pagopa\crawler\methods\MethodInterface;
 use pagopa\crawler\methods\req\activatePaymentNotice as Payload;
 use pagopa\database\sherlock\Transaction;
@@ -285,7 +286,7 @@ public function workflowEvent(int $index = 0): Workflow|null
         $workflow->setNewColumnValue('date_event', $this->getInsertedTimestamp()->format('Y-m-d'));
         $workflow->setEventTimestamp($this->getInsertedTimestamp());
         $workflow->setEventId($this->getUniqueId());
-        $workflow->setFkTipoEvento(1);
+        $workflow->setFkTipoEvento(MapEvents::getMethodId($this->getTipoEvento(), $this->getSottoTipoEvento()));
 
         $id_psp     = $this->getPsp();
         $stazione   = $this->getStazione();

diff --git a/src/src/crawler/events/req/nodoInviaCarrelloRPT.php b/src/src/crawler/events/req/nodoInviaCarrelloRPT.php
@@ -3,6 +3,7 @@
 namespace pagopa\crawler\events\req;
 
 use pagopa\crawler\AbstractEvent;
+use pagopa\crawler\MapEvents;
 use pagopa\database\sherlock\Transaction;
 use pagopa\crawler\methods\req\nodoInviaCarrelloRPT as Payload;
 use pagopa\database\sherlock\TransactionDetails;
@@ -266,7 +267,7 @@ public function workflowEvent(int $index = 0): Workflow|null
         {
             $workflow->setStazione($this->getStazione());
         }
-        $workflow->setFkTipoEvento(3);
+        $workflow->setFkTipoEvento(MapEvents::getMethodId($this->getTipoEvento(), $this->getSottoTipoEvento()));
         return $workflow;
     }
 

diff --git a/src/src/crawler/events/resp/activatePaymentNotice.php b/src/src/crawler/events/resp/activatePaymentNotice.php
@@ -4,6 +4,7 @@
 
 use pagopa\crawler\AbstractEvent;
 use pagopa\crawler\FaultInterface;
+use pagopa\crawler\MapEvents;
 use pagopa\crawler\methods\resp\activatePaymentNotice as Payload;
 use pagopa\database\sherlock\Transaction;
 use pagopa\database\sherlock\TransactionDetails;
@@ -230,7 +231,8 @@ public function workflowEvent(int $index = 0): Workflow|null
         $workflow->setNewColumnValue('date_event', $this->getInsertedTimestamp()->format('Y-m-d'));
         $workflow->setEventTimestamp($this->getInsertedTimestamp());
         $workflow->setEventId($this->getUniqueId());
-        $workflow->setFkTipoEvento(2);
+        $workflow->setFkTipoEvento(MapEvents::getMethodId($this->getTipoEvento(), $this->getSottoTipoEvento()));
+
 
         $id_psp     = $this->getPsp();
         $stazione   = $this->getStazione();

diff --git a/src/src/crawler/events/resp/nodoInviaCarrelloRPT.php b/src/src/crawler/events/resp/nodoInviaCarrelloRPT.php
@@ -3,6 +3,7 @@
 namespace pagopa\crawler\events\resp;
 
 use pagopa\crawler\AbstractEvent;
+use pagopa\crawler\MapEvents;
 use pagopa\crawler\methods\MethodInterface;
 use pagopa\database\sherlock\Transaction;
 use pagopa\crawler\methods\resp\nodoInviaCarrelloRPT as Payload;
@@ -209,7 +210,7 @@ public function workflowEvent(int $index = 0): Workflow|null
         $workflow->setNewColumnValue('date_event', $this->getInsertedTimestamp()->format('Y-m-d'));
         $workflow->setEventId($this->getUniqueId());
         $workflow->setEventTimestamp($this->getInsertedTimestamp());
-        $workflow->setFkTipoEvento(4);
+        $workflow->setFkTipoEvento(MapEvents::getMethodId($this->getTipoEvento(), $this->getSottoTipoEvento()));
         $stazione = $this->getStazione();
         if (!is_null($this->getMethodInterface()->getFaultCode()))
         {

diff --git a/src/tests/.phpunit.result.cache b/src/tests/.phpunit.result.cache
Original file line number	Diff line number	Diff line change
Expand Up		@@ -84,6 +84,3 @@ create table if not exists public.metadata_2024 (
		constraint "METADATA_2024_pk" primary key (date_event, id)
		)
		PARTITION BY RANGE (date_event);