debug fetch stock movements

inikoo · Sep 24, 2024 · c9818cc · c9818cc
1 parent 4136902
commit c9818cc
Show file tree

Hide file tree

Showing 3 changed files with 28 additions and 9 deletions.
diff --git a/app/Actions/Transfers/Aurora/FetchAuroraAction.php b/app/Actions/Transfers/Aurora/FetchAuroraAction.php
@@ -66,6 +66,7 @@ protected function preProcessCommand(Command $command): void
             'fetch:outers',
             'fetch:portfolios',
             'fetch:stock_movements',
+            'fetch:deleted-locations',
         ])) {
             $this->onlyNew = (bool)$command->option('only_new');
         }

diff --git a/app/Actions/Transfers/Aurora/FetchAuroraDeletedLocations.php b/app/Actions/Transfers/Aurora/FetchAuroraDeletedLocations.php
@@ -40,13 +40,13 @@ public function handle(SourceOrganisationService $organisationSource, int $organ
                 );
 
                 $this->recordNew($organisationSource);
-                $sourceData = explode(':', $location->source_id);
-                DB::connection('aurora')->table('Location Deleted Dimension')
-                    ->where('Location Deleted Key', $sourceData[1])
-                    ->update(['aiku_id' => $location->id]);
-
             }
 
+            $sourceData = explode(':', $location->source_id);
+            DB::connection('aurora')->table('Location Deleted Dimension')
+                ->where('Location Deleted Key', $sourceData[1])
+                ->update(['aiku_id' => $location->id]);
+
             return $location;
         }
 
@@ -55,18 +55,32 @@ public function handle(SourceOrganisationService $organisationSource, int $organ
 
     public function getModelsQuery(): Builder
     {
-        return DB::connection('aurora')
+        $query = DB::connection('aurora')
             ->table('Location Deleted Dimension')
-            ->select('Location Deleted Key as source_id')
-            ->orderBy('source_id')
+            ->select('Location Deleted Key as source_id');
+
+        if ($this->onlyNew) {
+            $query->whereNull('aiku_id');
+        }
+
+        $query->orderBy('source_id')
             ->when(app()->environment('testing'), function ($query) {
                 return $query->limit(20);
             });
+
+        return $query;
     }
 
 
     public function count(): ?int
     {
-        return DB::connection('aurora')->table('Location Deleted Dimension')->count();
+        $query =  DB::connection('aurora')
+            ->table('Location Deleted Dimension');
+        if ($this->onlyNew) {
+            $query->whereNull('aiku_id');
+        }
+
+        return $query->count();
+
     }
 }
diff --git a/app/Transfers/Aurora/FetchAuroraOrgStockMovement.php b/app/Transfers/Aurora/FetchAuroraOrgStockMovement.php
@@ -36,6 +36,10 @@ protected function parseModel(): void
 
         $location = $this->parseLocation($this->organisation->id.':'.$this->auroraModelData->{'Location Key'}, $this->organisationSource);
 
+        if (!$location) {
+            dd($this->auroraModelData->{'Location Key'});
+        }
+
         $date = $this->parseDatetime($this->auroraModelData->{'Date'});
 
         $type        = null;