diff --git a/app/workers/batch_generate_weather_arts_worker.rb b/app/workers/batch_generate_weather_arts_worker.rb index 184c9db..9d9abaa 100644 --- a/app/workers/batch_generate_weather_arts_worker.rb +++ b/app/workers/batch_generate_weather_arts_worker.rb @@ -11,7 +11,7 @@ class BatchGenerateWeatherArtsWorker break if Time.current - start_time > max_duration # GenerateWeatherArtJob.perform_now(city) - GenerateWeatherArtWorker.perform_async(city) + GenerateWeatherArtWorker.perform_async(city.id) sleep 1.minute # 确保不超过API限制 end end diff --git a/app/workers/generate_weather_art_worker.rb b/app/workers/generate_weather_art_worker.rb index 74f1ced..b2deb18 100644 --- a/app/workers/generate_weather_art_worker.rb +++ b/app/workers/generate_weather_art_worker.rb @@ -2,7 +2,8 @@ class GenerateWeatherArtWorker include Sidekiq::Worker def perform(*args) - city = args[0] + city_id = args[0] + city = City.find(city_id) return if city.last_weather_fetch&.today? weather_service = WeatherService.new