first commit

2026-04-28 16:10:27 +03:00
commit b73f568d90
107 changed files with 18067 additions and 0 deletions
@@ -0,0 +1,126 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Models\City;
+use App\Models\Attraction;
+use App\Services\OpenTripMapService;
+use App\Services\OverpassService;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Queue\Queueable;
+use Illuminate\Support\Facades\Log;
+
+class FetchAttractionsJob implements ShouldQueue
+{
+    use Queueable;
+
+    public int $tries = 3;
+    public int $timeout = 120;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(
+        public City $city,
+        public bool $forceRefresh = false
+    ) {
+    }
+
+    /**
+     * Execute the job.
+     */
+    public function handle(
+        OpenTripMapService $openTripMapService,
+        OverpassService $overpassService
+    ): void {
+        try {
+            // Check if we need to refresh
+            if (!$this->forceRefresh) {
+                $lastAttraction = $this->city->attractions()
+                    ->orderBy('cached_at', 'desc')
+                    ->first();
+
+                if ($lastAttraction && $lastAttraction->cached_at) {
+                    $cacheAge = now()->diffInDays($lastAttraction->cached_at);
+                    $cacheTtl = config('services.opentripmap.cache_ttl', 7);
+
+                    if ($cacheAge < $cacheTtl) {
+                        Log::info("Attractions data is still fresh, skipping fetch", [
+                            'city_id' => $this->city->id,
+                            'cache_age' => $cacheAge,
+                        ]);
+                        return;
+                    }
+                }
+            }
+
+            if (!$this->city->latitude || !$this->city->longitude) {
+                Log::warning("City coordinates not set, cannot fetch attractions", [
+                    'city_id' => $this->city->id,
+                ]);
+                return;
+            }
+
+            $attractionsCreated = 0;
+
+            // Fetch from OpenTripMap
+            $openTripMapData = $openTripMapService->getAttractions(
+                $this->city->latitude,
+                $this->city->longitude
+            );
+
+            foreach ($openTripMapData as $data) {
+                $this->createOrUpdateAttraction($data, 'opentripmap');
+                $attractionsCreated++;
+            }
+
+            // Fetch from Overpass
+            $overpassData = $overpassService->getPointsOfInterest(
+                $this->city->latitude,
+                $this->city->longitude
+            );
+
+            foreach ($overpassData as $data) {
+                $this->createOrUpdateAttraction($data, 'overpass');
+                $attractionsCreated++;
+            }
+
+            Log::info("Attractions fetched successfully", [
+                'city_id' => $this->city->id,
+                'city_name' => $this->city->name,
+                'attractions_created' => $attractionsCreated,
+            ]);
+        } catch (\Exception $e) {
+            Log::error("Error in FetchAttractionsJob", [
+                'city_id' => $this->city->id,
+                'error' => $e->getMessage(),
+            ]);
+
+            throw $e;
+        }
+    }
+
+    /**
+     * Create or update an attraction
+     */
+    private function createOrUpdateAttraction(array $data, string $source): void
+    {
+        Attraction::updateOrCreate(
+            [
+                'city_id' => $this->city->id,
+                'source' => $source,
+                'source_id' => $data['source_id'],
+            ],
+            [
+                'name' => $data['name'],
+                'description' => $data['description'] ?? null,
+                'latitude' => $data['latitude'],
+                'longitude' => $data['longitude'],
+                'category' => $data['category'] ?? 'other',
+                'rating' => $data['rating'] ?? null,
+                'image_url' => $data['image_url'] ?? null,
+                'cached_at' => now(),
+            ]
+        );
+    }
+}
@@ -0,0 +1,93 @@
+<?php
+
+namespace App\Jobs;
+
+use App\Models\City;
+use App\Services\WikipediaService;
+use Illuminate\Contracts\Queue\ShouldQueue;
+use Illuminate\Foundation\Queue\Queueable;
+use Illuminate\Support\Facades\Log;
+
+class FetchCityDataJob implements ShouldQueue
+{
+    use Queueable;
+
+    public int $tries = 3;
+    public int $timeout = 60;
+
+    /**
+     * Create a new job instance.
+     */
+    public function __construct(
+        public City $city,
+        public bool $forceRefresh = false
+    ) {
+    }
+
+    /**
+     * Execute the job.
+     */
+    public function handle(WikipediaService $wikipediaService): void
+    {
+        try {
+            // Check if we need to refresh the data
+            if (!$this->forceRefresh && $this->city->wikipedia_cached_at) {
+                $cacheAge = now()->diffInDays($this->city->wikipedia_cached_at);
+                $cacheTtl = config('services.wikipedia.cache_ttl', 30);
+
+                if ($cacheAge < $cacheTtl) {
+                    Log::info("City data is still fresh, skipping fetch", [
+                        'city_id' => $this->city->id,
+                        'cache_age' => $cacheAge,
+                    ]);
+                    return;
+                }
+            }
+
+            // Fetch data from Wikipedia
+            $data = $wikipediaService->getCitySummary($this->city->name);
+
+            if ($data) {
+                // Update city with Wikipedia data
+                $this->city->update([
+                    'wikipedia_summary' => $data['summary'],
+                    'wikipedia_url' => $data['url'],
+                    'thumbnail_url' => $data['thumbnail'] ?? null,
+                    'image_url' => $data['image'] ?? null,
+                    'wikipedia_page_id' => $data['page_id'],
+                    'wikipedia_cached_at' => now(),
+                ]);
+
+                // Update coordinates if they exist in Wikipedia data and not set
+                if (isset($data['latitude']) && isset($data['longitude'])) {
+                    if (!$this->city->latitude || !$this->city->longitude) {
+                        $this->city->update([
+                            'latitude' => $data['latitude'],
+                            'longitude' => $data['longitude'],
+                        ]);
+                    }
+                }
+
+                Log::info("City data fetched successfully", [
+                    'city_id' => $this->city->id,
+                    'city_name' => $this->city->name,
+                ]);
+
+                // Dispatch job to fetch attractions
+                FetchAttractionsJob::dispatch($this->city);
+            } else {
+                Log::warning("Failed to fetch city data from Wikipedia", [
+                    'city_id' => $this->city->id,
+                    'city_name' => $this->city->name,
+                ]);
+            }
+        } catch (\Exception $e) {
+            Log::error("Error in FetchCityDataJob", [
+                'city_id' => $this->city->id,
+                'error' => $e->getMessage(),
+            ]);
+
+            throw $e; // Re-throw to trigger retry
+        }
+    }
+}