diff --git a/app/Console/Commands/SoilMonitoringLogFixCommand.php b/app/Console/Commands/SoilMonitoringLogFixCommand.php
new file mode 100644
index 0000000..b04bdd4
--- /dev/null
+++ b/app/Console/Commands/SoilMonitoringLogFixCommand.php
@@ -0,0 +1,81 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Enums\DeviceStatus;
+use App\Enums\DeviceType;
+use App\Models\Device;
+use App\Models\SoilMonitoringLog;
+use App\Services\LinkosDeviceLogService;
+use Illuminate\Console\Command;
+use Illuminate\Support\Carbon;
+use Throwable;
+
+class SoilMonitoringLogFixCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'soil-monitoring-log:fix {hour? : 时间格式 Y-m-d H:i:s, 示例: 2022-11-11 00:00:00}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '修复土壤监控数据';
+
+    /**
+     * Execute the console command.
+     *
+     * @return int
+     */
+    public function handle(LinkosDeviceLogService $linkosDeviceLogService)
+    {
+        $time = now()->subHour()->startOfHour();
+
+        if ($hour = $this->argument('hour')) {
+            $time = Carbon::createFromFormat('Y-m-d H:i:s', $hour)->startOfHour();
+        }
+
+        $devices = Device::where('type', DeviceType::Soil)
+            ->where('status', DeviceStatus::Online)
+            ->get();
+
+        foreach ($devices as $device) {
+            if (is_null(SoilMonitoringLog::where('device_id', $device->id)->where('monitored_at', $time)->first())) {
+                continue;
+            }
+
+            $last = SoilMonitoringLog::where('device_id', $device->id)
+                ->where('monitored_at', $time->copy()->subHour())
+                ->first();
+
+            if ($last === null) {
+                continue;
+            }
+
+            try {
+                SoilMonitoringLog::create([
+                    'device_id' => $device->id,
+                    'agricultural_base_id' => $device->agricultural_base_id,
+                    'conductivity' => $last->conductivity,
+                    'humidity' => $last->humidity,
+                    'temperature' => $last->temperature,
+                    'n' => $last->n,
+                    'p' => $last->p,
+                    'k' => $last->k,
+                    'monitored_at' => $time,
+                ]);
+
+                $linkosDeviceLogService->handleSoilMonitoringDailyLog($device, $time);
+            } catch (Throwable $e) {
+                report($e);
+            }
+        }
+
+        return Command::SUCCESS;
+    }
+}
diff --git a/app/Console/Commands/WaterQualityMonitoringLogFixCommand.php b/app/Console/Commands/WaterQualityMonitoringLogFixCommand.php
new file mode 100644
index 0000000..e041fd8
--- /dev/null
+++ b/app/Console/Commands/WaterQualityMonitoringLogFixCommand.php
@@ -0,0 +1,81 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Enums\DeviceStatus;
+use App\Enums\DeviceType;
+use App\Models\Device;
+use App\Models\WaterQualityMonitoringLog;
+use App\Services\LinkosDeviceLogService;
+use Illuminate\Console\Command;
+use Illuminate\Support\Carbon;
+use Throwable;
+
+class WaterQualityMonitoringLogFixCommand extends Command
+{
+    /**
+     * The name and signature of the console command.
+     *
+     * @var string
+     */
+    protected $signature = 'water-quality-monitoring-log:fix {hour? : 时间格式 Y-m-d H:i:s, 示例: 2022-11-11 00:00:00}';
+
+    /**
+     * The console command description.
+     *
+     * @var string
+     */
+    protected $description = '修复水质监控数据';
+
+    /**
+     * Execute the console command.
+     *
+     * @return int
+     */
+    public function handle(LinkosDeviceLogService $linkosDeviceLogService)
+    {
+        $time = now()->subHour()->startOfHour();
+
+        if ($hour = $this->argument('hour')) {
+            $time = Carbon::createFromFormat('Y-m-d H:i:s', $hour)->startOfHour();
+        }
+
+        $devices = Device::where('type', DeviceType::WaterQuality)
+            ->where('status', DeviceStatus::Online)
+            ->get();
+
+        foreach ($devices as $device) {
+            if (is_null(WaterQualityMonitoringLog::where('device_id', $device->id)->where('monitored_at', $time)->first())) {
+                continue;
+            }
+
+            $last = WaterQualityMonitoringLog::where('device_id', $device->id)
+                ->where('monitored_at', $time->copy()->subHour())
+                ->first();
+
+            if ($last === null) {
+                continue;
+            }
+
+            try {
+                WaterQualityMonitoringLog::create([
+                    'device_id' => $device->id,
+                    'agricultural_base_id' => $device->agricultural_base_id,
+                    'chlorine' => $last->chlorine,
+                    'conductivity' => $last->conductivity,
+                    'oxygen' => $last->oxygen,
+                    'ph' => $last->ph,
+                    'temperature' => $last->temperature,
+                    'turbidity' => $last->turbidity,
+                    'monitored_at' => $time,
+                ]);
+
+                $linkosDeviceLogService->handleWaterQualityMonitoringDailyLog($device, $time);
+            } catch (Throwable $e) {
+                report($e);
+            }
+        }
+
+        return Command::SUCCESS;
+    }
+}
diff --git a/app/Console/Kernel.php b/app/Console/Kernel.php
index d8bc1d2..8e3a6c0 100644
--- a/app/Console/Kernel.php
+++ b/app/Console/Kernel.php
@@ -15,7 +15,13 @@ class Kernel extends ConsoleKernel
      */
     protected function schedule(Schedule $schedule)
     {
-        // $schedule->command('inspire')->hourly();
+        $schedule->command(Commands\SoilMonitoringLogFixCommand::class)
+            ->hourly()
+            ->runInBackground();
+
+        $schedule->command(Commands\WaterQualityMonitoringLogFixCommand::class)
+            ->hourly()
+            ->runInBackground();
     }
 
     /**