ProjektObjekteImDetailImporter update and statistic

app/Filament/Imports/ProjektObjekteImDetailImporter.php

@@ -15,14 +15,40 @@ class ProjektObjekteImDetailImporter extends Importer
 
     public static $projekte_id;
 
+    public static $count_have = 0;
+
+    public static $count_new = 0;
+
+    public static $raumarts = [];
+
+    public static $top_nummers = [];
+
     public function resolveRecord(): ProjektObjekteImDetail
     {
         self::$projekte_id = $this->options['projekte_id'];
 
-        $res = new ProjektObjekteImDetail;
-        $res->projekte_id = self::$projekte_id;
+        self::$raumarts[] = $this->data['raumart'];
+
+        self::$top_nummers[] = $this->data['top_nummer'];
+
+        $projekt_objekte_id = ProjektObjekte::where('projekte_id', self::$projekte_id)
+            ->where('top_nummer', $this->data['top_nummer'])
+            ->value('id');
+
+        if ($projekt_objekte_id && ProjektObjekteImDetail::where('projekte_id', self::$projekte_id)
+            ->where('projekt_objekte_id', $projekt_objekte_id)
+            ->where('raumart', $this->data['raumart'])->first()) {
+            self::$count_have++;
+        } else {
+            self::$count_new++;
+        }
+
+        return ProjektObjekteImDetail::firstOrNew([
+            'projekte_id' => self::$projekte_id,
+            'projekt_objekte_id' => $projekt_objekte_id,
+            'raumart' => $this->data['raumart'],
+        ]);
 
-        return $res;
     }
 
     public function getCsvSettings(): array
@@ -47,7 +73,7 @@ class ProjektObjekteImDetailImporter extends Importer
                 ->relationship(resolveUsing: function (string $state, $data): ?ProjektObjekte {
                     return ProjektObjekte::query()
                         ->where('projekte_id', self::$projekte_id)
-                        ->Where('top_nummer', $state)
+                        ->where('top_nummer', $state)
                         ->firstOrCreate([
                             'projekte_id' => self::$projekte_id,
                             'top_nummer' => $state,
@@ -83,7 +109,7 @@ class ProjektObjekteImDetailImporter extends Importer
                 ->example('14,75')
                 ->castStateUsing(function (string $state): ?float {
 
-                    if (blank($state)) {
+                    if (blank($state) || (float) $state == 0) {
                         return null;
                     }
 
@@ -98,12 +124,27 @@ class ProjektObjekteImDetailImporter extends Importer
 
     public static function getCompletedNotificationBody(Import $import): string
     {
-        $body = ' Der Import der Objekte ist abgeschlossen. Es wurden '.Number::format($import->successful_rows).' '.str('row')->plural($import->successful_rows).' importiert.';
+        $projektObjekteImDetailDeleted = ProjektObjekteImDetail::where('projekte_id', self::$projekte_id)
+            ->whereNotIn('raumart', self::$raumarts)
+            ->delete();
+
+        $projektObjekteDeleted = ProjektObjekte::query()
+            ->where('projekte_id', self::$projekte_id)
+            ->whereNotIn('top_nummer', self::$top_nummers)
+            ->delete();
+
+        $body = ' Der Import der Objekte ist abgeschlossen. Es wurden '.Number::format($import->successful_rows).' Zeile(n) importiert.';
 
         if ($failedRowsCount = $import->getFailedRowsCount()) {
-            $body .= ' Bei '.Number::format($failedRowsCount).' '.@lang('Reihe|Reihen', $failedRowsCount).' ist der Import fehlgeschlagen.';
+            $body .= ' Bei '.Number::format($failedRowsCount).' Zeile(n) ist der Import fehlgeschlagen.';
         }
 
+        $body .= '<br/><br/>';
+        $body .= 'Bestehende Objekte: '.self::$count_have.'<br/ >';
+        $body .= 'Neue Objekte: '.self::$count_new.'<br/>';
+        $body .= 'Objekte im Detail gelöscht: '.$projektObjekteImDetailDeleted.'<br/>';
+        $body .= 'Objekte gelöscht: '.$projektObjekteDeleted;
+
         return $body;
     }
 }