|
|
|
|
|
<?php
|
|
|
|
|
|
|
|
|
|
|
|
namespace App\Console\Commands;
|
|
|
|
|
|
|
|
|
|
|
|
use App\Jobs\SendAppointCar;
|
|
|
|
|
|
use App\Models\Appointment;
|
|
|
|
|
|
use App\Models\ThirdAppointmentLog;
|
|
|
|
|
|
use Illuminate\Console\Command;
|
|
|
|
|
|
|
|
|
|
|
|
class SyncAppointmentCarAppointments extends Command
|
|
|
|
|
|
{
|
|
|
|
|
|
/**
|
|
|
|
|
|
* The name and signature of the console command.
|
|
|
|
|
|
*
|
|
|
|
|
|
* @var string
|
|
|
|
|
|
*/
|
|
|
|
|
|
protected $signature = 'sync_appointment_car_appointments';
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* The console command description.
|
|
|
|
|
|
*
|
|
|
|
|
|
* @var string
|
|
|
|
|
|
*/
|
|
|
|
|
|
protected $description = '同步预约未提交的新增车牌号';
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* Execute the console command.
|
|
|
|
|
|
*
|
|
|
|
|
|
* @return int
|
|
|
|
|
|
*/
|
|
|
|
|
|
public function handle()
|
|
|
|
|
|
{
|
|
|
|
|
|
$now = date('Y-m-d H:i:s');
|
|
|
|
|
|
$total = 0;
|
|
|
|
|
|
|
|
|
|
|
|
// 只处理还没开始的、已审核通过的预约。
|
|
|
|
|
|
// 车牌预约是发给第三方停车系统的，过期预约不需要补发；未审核通过的预约也不能提前发起车牌预约。
|
|
|
|
|
|
$appointments = Appointment::with('user')
|
|
|
|
|
|
->where('status', 1)
|
|
|
|
|
|
->where('start_time', '>', $now)
|
|
|
|
|
|
// 用户后续在个人资料里绑定了车牌，才有可能需要补发。
|
|
|
|
|
|
->whereHas('user', function ($query) {
|
|
|
|
|
|
$query->whereNotNull('plate')
|
|
|
|
|
|
->where('plate', '!=', '');
|
|
|
|
|
|
})->get();
|
|
|
|
|
|
|
|
|
|
|
|
foreach ($appointments as $appointment) {
|
|
|
|
|
|
// 用户当前车牌：以 users.plate 为准，表示用户后来补充/更新后的完整车牌列表。
|
|
|
|
|
|
$userPlates = $this->parsePlates($appointment->user->plate);
|
|
|
|
|
|
// 预约记录车牌：表示当时提交预约时已经记录过的车牌列表。
|
|
|
|
|
|
$appointmentPlates = $this->parsePlates($appointment->plate);
|
|
|
|
|
|
// 只找用户后来新增、但预约记录里没有的车牌，避免重复提交老车牌。
|
|
|
|
|
|
$newPlates = array_values(array_diff($userPlates, $appointmentPlates));
|
|
|
|
|
|
// 需要确认是否预约成功的车牌：以用户当前车牌为准。
|
|
|
|
|
|
// 即使车牌已经回写到 appointments.plate，只要第三方没有成功记录，后续任务仍然应该继续补发。
|
|
|
|
|
|
$pendingPlates = $userPlates;
|
|
|
|
|
|
|
|
|
|
|
|
if (empty($newPlates) && empty($pendingPlates)) {
|
|
|
|
|
|
continue;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
if (!empty($newPlates)) {
|
|
|
|
|
|
// 把新增车牌回写到 appointments.plate，保持预约记录和用户当前车牌一致。
|
|
|
|
|
|
// 注意：补发判断不能只依赖 appointments.plate，否则队列失败后会因为已回写而不再补发。
|
|
|
|
|
|
$appointment->plate = implode(',', array_values(array_unique(array_merge($appointmentPlates, $newPlates))));
|
|
|
|
|
|
$appointment->save();
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
foreach ($pendingPlates as $plate) {
|
|
|
|
|
|
// 第三方日志里如果已经有这个预约 + 车牌的成功记录，说明之前已经预约成功。
|
|
|
|
|
|
// 这里再做一次幂等校验，防止手动补数据、任务重复执行或队列重试导致重复预约。
|
|
|
|
|
|
$hasAppointment = ThirdAppointmentLog::where('appointment_id', $appointment->id)
|
|
|
|
|
|
->where('plate', $plate)
|
|
|
|
|
|
->where('plate_status', 1)
|
|
|
|
|
|
->exists();
|
|
|
|
|
|
|
|
|
|
|
|
if ($hasAppointment) {
|
|
|
|
|
|
continue;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
// 没有成功记录才投递队列任务，由 SendAppointCar 调用第三方停车系统发起预约。
|
|
|
|
|
|
dispatch(new SendAppointCar($appointment, $plate));
|
|
|
|
|
|
$total++;
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
$this->info("预约车牌同步完成，共提交 {$total} 条车牌预约");
|
|
|
|
|
|
|
|
|
|
|
|
return self::SUCCESS;
|
|
|
|
|
|
}
|
|
|
|
|
|
|
|
|
|
|
|
/**
|
|
|
|
|
|
* 解析车牌字符串。
|
|
|
|
|
|
*
|
|
|
|
|
|
* 数据库存储格式是多个车牌用英文逗号分隔，例如：苏E12345,苏E67890。
|
|
|
|
|
|
* 这里统一做 trim、去空值、去重，兼容空字符串、null、以及用户输入时带空格的情况。
|
|
|
|
|
|
*/
|
|
|
|
|
|
protected function parsePlates($plate)
|
|
|
|
|
|
{
|
|
|
|
|
|
return array_values(array_unique(array_filter(array_map('trim', explode(',', (string) $plate)))));
|
|
|
|
|
|
}
|
|
|
|
|
|
}
|
