82 lines
2.4 KiB
PHP
82 lines
2.4 KiB
PHP
<?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 (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;
|
|
}
|
|
}
|