Updated the logic for migration

Leuchtfeuer · Sep 15, 2023 · 4b62e73 · 4b62e73
1 parent cfc29ba
commit 4b62e73
Show file tree

Hide file tree

Showing 2 changed files with 28 additions and 3 deletions.
diff --git a/Config/config.php b/Config/config.php
@@ -84,7 +84,7 @@
                 'class'     => \MauticPlugin\LeuchtfeuerGoToBundle\EventListener\PluginEventSubscriber::class,
                 'arguments' => [
                     'database_connection',
-                    'logger',
+                    'monolog.logger.mautic',
                 ],
             ]
         ],

diff --git a/EventListener/PluginEventSubscriber.php b/EventListener/PluginEventSubscriber.php
@@ -6,6 +6,7 @@
 
 use Doctrine\DBAL\Connection;
 use Doctrine\DBAL\Exception;
+use Doctrine\DBAL\Exception\RetryableException;
 use Mautic\PluginBundle\Event\PluginUpdateEvent;
 use Mautic\PluginBundle\PluginEvents;
 use Psr\Log\LoggerInterface;
@@ -59,11 +60,17 @@ private function updateSegments(): void
             return;
         }
 
+        $count = 0;
         foreach ($results as $segment) {
             $newFilters         = [];
             $newPropertyFilters = [];
             $filters            = unserialize($segment['filters']);
             foreach ($filters as $filter) {
+                if (!isset($filter['properties'])) {
+                    $newFilters[] = $filter;
+                    continue;
+                }
+
                 if (
                     !in_array($filter['field'], ['webinar-attendance', 'webinar-no-attendance', 'webinar-registration'])
                     || is_array($filter['properties']['filter'])
@@ -76,6 +83,11 @@ private function updateSegments(): void
                 $newPropertyFilters[$filter['field']][$filter['operator']]['filter'][] = $filter['properties']['filter'];
             }
 
+            if (empty($newPropertyFilters)) {
+                $this->logger->alert(sprintf('No updated for %s (%s)', $segment['public_name'], $segment['id']));
+                continue;
+            }
+
             foreach ($newPropertyFilters as $field => $filters) {
                 foreach ($filters as $key => $filter) {
                     $conversion = [
@@ -100,6 +112,16 @@ private function updateSegments(): void
                             'date' => sprintf('%%%s%%', date('Y-m-d H:i', strtotime($matches[1]))),
                         ]);
 
+                        if (false === $productKey) {
+                            $productKey = $value;
+                            $this->logger->critical(sprintf(
+                                'Please updated the Segment %s (%s) manually as the "%s" GOTO product is unavailable for mapping.',
+                                $segment['public_name'],
+                                $segment['id'],
+                                $value
+                            ));
+                        }
+
                         $conversion['properties']['filter'][] = $productKey;
                     }
                     $newFilters[] = $conversion;
@@ -112,8 +134,11 @@ private function updateSegments(): void
                 'id'      => $segment['id'],
             ]);
 
-            $this->logger->info(sprintf('Segment %s updated successfully', $segment['id']));
+            $count++;
+
+            $this->logger->alert(sprintf('Segment %s updated successfully', $segment['id']));
         }
-        $this->logger->info(sprintf('Total %s segments updated!!!', count($results)));
+
+        $this->logger->alert(sprintf('Total %s segments updated!!!', $count));
     }
 }