3960e062b9
All checks were successful
Deploy so-manager (auto) / deploy (push) Successful in 21s
SHJ-13契約台数追加
208 lines
8.2 KiB
PHP
208 lines
8.2 KiB
PHP
<?php
|
||
|
||
namespace App\Console\Commands;
|
||
|
||
use Illuminate\Console\Command;
|
||
use Illuminate\Support\Facades\Log;
|
||
use App\Services\ShjFiveService;
|
||
use App\Models\Batch\BatchLog;
|
||
|
||
/**
|
||
* SHJ-5 空き待ち通知処理コマンド
|
||
*
|
||
* 駐輪場の空き状況を確認し、空き待ち予約者への通知処理を実行する
|
||
* バックグラウンドで実行される定期バッチ処理
|
||
*/
|
||
class ShjFiveCommand extends Command
|
||
{
|
||
/**
|
||
* コンソールコマンドの名前とシグネチャ
|
||
*
|
||
* 引数なし - 全ての駐輪場を対象に処理を実行
|
||
*
|
||
* @var string
|
||
*/
|
||
protected $signature = 'shj:5';
|
||
|
||
/**
|
||
* コンソールコマンドの説明
|
||
*
|
||
* @var string
|
||
*/
|
||
protected $description = 'SHJ-5 空き待ち通知処理 - 駐輪場の空き状況確認と空き待ち者への通知を実行';
|
||
|
||
/**
|
||
* SHJ-5サービスクラス
|
||
*
|
||
* @var ShjFiveService
|
||
*/
|
||
protected $shjFiveService;
|
||
|
||
/**
|
||
* コンストラクタ
|
||
*
|
||
* @param ShjFiveService $shjFiveService
|
||
*/
|
||
public function __construct(ShjFiveService $shjFiveService)
|
||
{
|
||
parent::__construct();
|
||
$this->shjFiveService = $shjFiveService;
|
||
}
|
||
|
||
/**
|
||
* コンソールコマンドを実行
|
||
*
|
||
* 処理フロー:
|
||
* 1. バッチログ開始記録
|
||
* 2. 駐輪場の空き状況を取得する
|
||
* 3. 空き状況判定
|
||
* 4. 空き待ち者の情報を取得する
|
||
* 5. 取得件数判定
|
||
* 6. 空き待ち者への通知、またはオペレーターキュー追加処理
|
||
* 7. バッチ処理ログを作成する
|
||
* 8. 処理結果返却
|
||
*
|
||
* @return int
|
||
*/
|
||
public function handle()
|
||
{
|
||
$batchLog = null;
|
||
|
||
try {
|
||
// 開始ログ出力
|
||
$startTime = now();
|
||
$this->info('SHJ-5 空き待ち通知処理を開始します。');
|
||
|
||
Log::info('SHJ-5 空き待ち通知処理開始', [
|
||
'start_time' => $startTime
|
||
]);
|
||
|
||
// SHJ-8共通処理呼び出し - 仕様書準拠
|
||
$batchLog = BatchLog::createBatchLog(
|
||
'SHJ-5空き待ち通知処理',
|
||
BatchLog::STATUS_START,
|
||
[
|
||
'device_id' => 1, // 仕様書：device_id=1
|
||
'process_code' => 1, // 仕様書：process_code=1
|
||
'status_comment' => '処理開始' // 仕様書：内部変数.ステータスコメント
|
||
],
|
||
'SHJ-5処理開始: 駐輪場空き状況確認と空き待ち通知処理'
|
||
);
|
||
|
||
// SHJ-5メイン処理実行
|
||
$result = $this->shjFiveService->executeParkVacancyNotification();
|
||
|
||
$endTime = now();
|
||
$this->info('SHJ-5 空き待ち通知処理が完了しました。');
|
||
$this->info("処理時間: {$startTime->diffInSeconds($endTime)}秒");
|
||
|
||
// 処理結果表示
|
||
$this->displayProcessResult($result);
|
||
|
||
// SHJ-8共通処理 - バッチログ完了記録（仕様書準拠）
|
||
$logStatus = $result['success'] ? BatchLog::STATUS_SUCCESS : BatchLog::STATUS_ERROR;
|
||
|
||
// 仕様書準拠：サービス側で作成した完全なステータスコメントを使用
|
||
$statusComment = $result['success'] ?
|
||
($result['status_comment'] ?? 'ステータスコメント生成エラー') :
|
||
sprintf('処理失敗: %s', $result['message'] ?? 'エラー');
|
||
|
||
$batchLog->update([
|
||
'status' => $logStatus,
|
||
'end_time' => $endTime,
|
||
'message' => $result['message'],
|
||
'parameters' => [
|
||
'device_id' => 1, // 仕様書：device_id=1
|
||
'process_code' => 1, // 仕様書：process_code=1
|
||
'status_comment' => $statusComment, // 仕様書：内部変数.ステータスコメント（完全版）
|
||
'processed_parks_count' => $result['processed_parks_count'] ?? 0,
|
||
'vacant_parks_count' => $result['vacant_parks_count'] ?? 0,
|
||
'total_waiting_users' => $result['total_waiting_users'] ?? 0,
|
||
'notification_success_count' => $result['notification_success_count'] ?? 0,
|
||
'operator_queue_count' => $result['operator_queue_count'] ?? 0,
|
||
'error_count' => $result['error_count'] ?? 0,
|
||
'duration_seconds' => $result['duration_seconds'] ?? 0
|
||
],
|
||
'execution_count' => 1,
|
||
'success_count' => $result['notification_success_count'] ?? 0,
|
||
'error_count' => $result['error_count'] ?? 0
|
||
]);
|
||
|
||
Log::info('SHJ-5 空き待ち通知処理完了', [
|
||
'end_time' => $endTime,
|
||
'duration_seconds' => $startTime->diffInSeconds($endTime),
|
||
'result' => $result
|
||
]);
|
||
|
||
return $result['success'] ? self::SUCCESS : self::FAILURE;
|
||
|
||
} catch (\Exception $e) {
|
||
$this->error('SHJ-5 空き待ち通知処理で予期しないエラーが発生しました: ' . $e->getMessage());
|
||
|
||
// SHJ-8共通処理 - エラーログ記録（仕様書準拠）
|
||
if ($batchLog) {
|
||
$statusComment = sprintf(
|
||
'メール正常終了件数：0／メール異常終了件数：1／キュー登録正常終了件数：0／キュー登録異常終了件数：1 - 処理エラー: %s',
|
||
$e->getMessage()
|
||
);
|
||
$batchLog->update([
|
||
'status' => BatchLog::STATUS_ERROR,
|
||
'end_time' => now(),
|
||
'message' => 'SHJ-5処理中にエラーが発生: ' . $e->getMessage(),
|
||
'parameters' => [
|
||
'device_id' => 1, // 仕様書：device_id=1
|
||
'process_code' => 1, // 仕様書：process_code=1
|
||
'status_comment' => $statusComment // 仕様書：内部変数.ステータスコメント（完全版）
|
||
],
|
||
'error_details' => $e->getMessage(),
|
||
'error_count' => 1
|
||
]);
|
||
}
|
||
|
||
Log::error('SHJ-5 空き待ち通知処理例外エラー', [
|
||
'exception' => $e->getMessage(),
|
||
'trace' => $e->getTraceAsString()
|
||
]);
|
||
|
||
return self::FAILURE;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 処理結果を表示
|
||
*
|
||
* @param array $result 処理結果
|
||
* @return void
|
||
*/
|
||
private function displayProcessResult(array $result): void
|
||
{
|
||
$this->line('');
|
||
$this->info('=== 処理結果 ===');
|
||
|
||
if ($result['success']) {
|
||
$this->info("✓ 処理実行成功: " . $result['message']);
|
||
} else {
|
||
$this->error("✗ 処理実行失敗: " . $result['message']);
|
||
}
|
||
|
||
$this->line('');
|
||
$this->info('=== 処理統計 ===');
|
||
$this->line(" 処理対象駐輪場数: " . ($result['processed_parks_count'] ?? 0));
|
||
$this->line(" 空きあり駐輪場数: " . ($result['vacant_parks_count'] ?? 0));
|
||
$this->line(" 空き待ち者総数: " . ($result['total_waiting_users'] ?? 0));
|
||
$this->line(" 通知送信成功: " . ($result['notification_success_count'] ?? 0) . "件");
|
||
$this->line(" オペレーターキュー追加: " . ($result['operator_queue_count'] ?? 0) . "件");
|
||
$this->line(" エラー件数: " . ($result['error_count'] ?? 0) . "件");
|
||
$this->line(" 処理時間: " . ($result['duration_seconds'] ?? 0) . "秒");
|
||
|
||
// エラー詳細があれば表示
|
||
if (!empty($result['errors'])) {
|
||
$this->line('');
|
||
$this->warn('=== エラー詳細 ===');
|
||
foreach ($result['errors'] as $index => $error) {
|
||
$this->line(" " . ($index + 1) . ". " . $error);
|
||
}
|
||
}
|
||
}
|
||
}
|