app/Services/ShjElevenService.php を削除

app/Services/ShjElevenService.php

@@ -1,432 +0,0 @@
-<?php
-
-namespace App\Services;
-
-use Illuminate\Support\Facades\DB;
-use Illuminate\Support\Facades\Log;
-use App\Models\Batch\BatchLog;
-use App\Models\RegularContract;
-use App\Models\Park;
-use App\Models\Psection;
-use App\Models\Ptype;
-use Carbon\Carbon;
-
-/**
- * SHJ-11 現在契約台数集計サービス
- * 
- * 集計単位每个の契約台数を算出し、ゾーンマスタとの管理処理を実行
- */
-class ShjElevenService
-{
-    /**
-     * 【処理1】集計単位每个の契約台数を算出する
-     * 
-     * 集計単位: 駐輪場ID + 車種区分ID + 駐輪分類ID + ゾーンID
-     * 
-     * SQL仕様に基づく複雑なJOIN処理:
-     * - regular_contract (T1) 
-     * - park (T2)
-     * - psection (T4)
-     * - price_a (T5) 
-     * - ptype (T3)
-     *
-     * @return array 契約台数集計結果
-     */
-    public function calculateContractCounts(): array
-    {
-        try {
-            $query = DB::table('regular_contract as T1')
-                ->select([
-                    'T1.park_id',               // 駐輪場ID
-                    'T2.park_name',             // 駐輪場名
-                    'T5.psection_id',           // 車種区分ID
-                    'T4.psection_subject',      // 車種区分名
-                    'T5.ptype_id',              // 駐輪分類ID
-                    'T3.ptype_subject',         // 駐輪分類名
-                    'T1.zone_id',               // ゾーンID
-                    DB::raw('count(T1.contract_id) as cnt')  // 契約台数
-                ])
-                // park テーブルとの JOIN
-                ->join('park as T2', 'T1.park_id', '=', 'T2.park_id')
-                // psection テーブルとの JOIN
-                ->join('psection as T4', 'T1.psection_id', '=', 'T4.psection_id')
-                // price_a テーブルとの複合条件 JOIN
-                ->join('price_a as T5', function($join) {
-                    $join->on('T1.park_id', '=', 'T5.park_id')
-                         ->on('T1.price_parkplaceid', '=', 'T5.price_parkplaceid')
-                         ->on('T1.psection_id', '=', 'T5.psection_id');
-                })
-                // ptype テーブルとの JOIN
-                ->join('ptype as T3', 'T5.ptype_id', '=', 'T3.ptype_id')
-                ->where([
-                    ['T1.contract_flag', '=', 1],           // 有効契約
-                    ['T2.park_close_flag', '=', 0],         // 駐輪場未閉鎖
-                ])
-                // 契約有効期間内の条件
-                ->whereRaw("date_format(now(), '%y %m %d') BETWEEN T1.contract_periods AND T1.contract_periode")
-                ->groupBy([
-                    'T1.park_id',
-                    'T2.park_name',
-                    'T5.psection_id',
-                    'T4.psection_subject',
-                    'T5.ptype_id',
-                    'T3.ptype_subject',
-                    'T1.zone_id'
-                ])
-                ->get();
-
-            Log::info('SHJ-11 契約台数算出完了', [
-                'count' => $query->count(),
-                'sql_conditions' => [
-                    'contract_flag' => 1,
-                    'park_close_flag' => 0,
-                    'contract_period_check' => 'BETWEEN contract_periods AND contract_periode'
-                ]
-            ]);
-
-            return $query->toArray();
-
-        } catch (\Exception $e) {
-            Log::error('SHJ-11 契約台数算出エラー', [
-                'error' => $e->getMessage(),
-                'trace' => $e->getTraceAsString()
-            ]);
-            throw $e;
-        }
-    }
-
-    /**
-     * 【処理2・3】ゾーンマスタ管理処理
-     * 
-     * 処理フロー:
-     * 1. ゾーンマスタを取得する
-     * 2. 取得判定 → 存在しない場合は新規登録
-     * 3. 契約台数チェック（限界台数超過判定）
-     * 4. 契約台数を反映する（ゾーンマスタ更新）
-     *
-     * @param array $contractCounts 契約台数集計結果
-     * @return array 処理結果
-     */
-    public function processZoneManagement(array $contractCounts): array
-    {
-        $createdZones = 0;
-        $updatedZones = 0;
-        $overCapacityCount = 0;
-        $errors = [];
-        $processParameters = [];
-
-        try {
-            DB::beginTransaction();
-
-            foreach ($contractCounts as $contractData) {
-                try {
-                    // 【処理2】ゾーンマスタを取得する
-                    $zoneData = $this->getZoneData($contractData);
-
-                    if (!$zoneData) {
-                        // 【判断2】ゾーンマスタが存在しない場合 → 新規登録
-                        $createResult = $this->createZoneData($contractData);
-                        if ($createResult['success']) {
-                            $createdZones++;
-                        }
-                        $zoneData = $createResult['zone_data'];
-                    }
-
-                    // 【判断3】契約台数チェック（限界台数超過判定）
-                    $isOverCapacity = $this->checkCapacityLimit($contractData, $zoneData);
-                    if ($isOverCapacity) {
-                        $overCapacityCount++;
-                        Log::warning('SHJ-11 限界台数超過検出', [
-                            'park_id' => $contractData->park_id,
-                            'zone_id' => $contractData->zone_id,
-                            'current_count' => $contractData->cnt,
-                            'limit_capacity' => $zoneData->zone_tolerance ?? 0
-                        ]);
-                    }
-
-                    // 【処理3】契約台数を反映する（ゾーンマスタ更新）
-                    $updateResult = $this->updateZoneContractCount($contractData);
-                    if ($updateResult['success']) {
-                        $updatedZones++;
-                    }
-
-                    // 処理パラメータ記録
-                    $processParameters[] = [
-                        'park_id' => $contractData->park_id,
-                        'psection_id' => $contractData->psection_id,
-                        'ptype_id' => $contractData->ptype_id,
-                        'zone_id' => $contractData->zone_id,
-                        'contract_count' => $contractData->cnt,
-                        'is_over_capacity' => $isOverCapacity,
-                        'zone_created' => !$zoneData && $createResult['success'] ?? false,
-                        'zone_updated' => $updateResult['success'] ?? false
-                    ];
-
-                } catch (\Exception $e) {
-                    $errors[] = [
-                        'park_id' => $contractData->park_id ?? null,
-                        'zone_id' => $contractData->zone_id ?? null,
-                        'error' => $e->getMessage()
-                    ];
-                    
-                    Log::warning('SHJ-11 個別処理エラー', [
-                        'park_id' => $contractData->park_id ?? null,
-                        'zone_id' => $contractData->zone_id ?? null,
-                        'error' => $e->getMessage()
-                    ]);
-                }
-            }
-
-            DB::commit();
-
-            return [
-                'success' => true,
-                'created_zones' => $createdZones,
-                'updated_zones' => $updatedZones,
-                'over_capacity_count' => $overCapacityCount,
-                'parameters' => $processParameters,
-                'errors' => $errors,
-                'message' => '現在契約台数集計処理完了'
-            ];
-
-        } catch (\Exception $e) {
-            DB::rollBack();
-            
-            Log::error('SHJ-11 ゾーンマスタ管理処理全体エラー', [
-                'error' => $e->getMessage(),
-                'processed_count' => count($processParameters)
-            ]);
-
-            return [
-                'success' => false,
-                'created_zones' => $createdZones,
-                'updated_zones' => $updatedZones,
-                'over_capacity_count' => $overCapacityCount,
-                'parameters' => $processParameters,
-                'errors' => $errors,
-                'message' => 'ゾーンマスタ管理処理エラー: ' . $e->getMessage(),
-                'details' => $e->getTraceAsString()
-            ];
-        }
-    }
-
-    /**
-     * ゾーンマスタデータ取得
-     * 
-     * 集計単位に対応するゾーンマスタを取得
-     *
-     * @param object $contractData 契約台数集計データ
-     * @return object|null ゾーンマスタデータ
-     */
-    private function getZoneData($contractData)
-    {
-        try {
-            return DB::table('zone')
-                ->select([
-                    'zone_id',
-                    'park_id',
-                    'ptype_id',
-                    'psection_id',
-                    'zone_name',
-                    'zone_number',          // 現在契約台数
-                    'zone_standard',        // 標準収容台数
-                    'zone_tolerance'        // 限界収容台数
-                ])
-                ->where([
-                    ['park_id', '=', $contractData->park_id],
-                    ['psection_id', '=', $contractData->psection_id],
-                    ['ptype_id', '=', $contractData->ptype_id],
-                    ['zone_id', '=', $contractData->zone_id]
-                ])
-                ->first();
-
-        } catch (\Exception $e) {
-            Log::error('SHJ-11 ゾーンマスタ取得エラー', [
-                'park_id' => $contractData->park_id,
-                'zone_id' => $contractData->zone_id,
-                'error' => $e->getMessage()
-            ]);
-            throw $e;
-        }
-    }
-
-    /**
-     * ゾーンマスタ新規作成
-     * 
-     * 仕様書に基づくINSERT処理
-     *
-     * @param object $contractData 契約台数集計データ
-     * @return array 作成結果
-     */
-    private function createZoneData($contractData): array
-    {
-        try {
-            // 新規ゾーンマスタのデフォルト値設定
-            $newZoneData = [
-                'zone_id' => $contractData->zone_id,
-                'park_id' => $contractData->park_id,
-                'ptype_id' => $contractData->ptype_id,
-                'psection_id' => $contractData->psection_id,
-                'zone_name' => null,                           // デフォルトnull
-                'zone_number' => $contractData->cnt,           // 算出した契約台数
-                'zone_standard' => null,                       // デフォルトnull
-                'zone_tolerance' => null,                      // デフォルトnull
-                'zone_sort' => null,                          // デフォルトnull
-                'delete_flag' => 0,                           // 削除フラグOFF
-                'created_at' => now(),
-                'updated_at' => now(),
-                'ope_id' => 9999999                           // 仕様書指定値
-            ];
-
-            DB::table('zone')->insert($newZoneData);
-
-            Log::info('SHJ-11 ゾーンマスタ新規作成完了', [
-                'zone_id' => $contractData->zone_id,
-                'park_id' => $contractData->park_id,
-                'contract_count' => $contractData->cnt
-            ]);
-
-            return [
-                'success' => true,
-                'zone_data' => (object) $newZoneData,
-                'message' => 'ゾーンマスタを新規作成しました'
-            ];
-
-        } catch (\Exception $e) {
-            Log::error('SHJ-11 ゾーンマスタ新規作成エラー', [
-                'zone_id' => $contractData->zone_id,
-                'park_id' => $contractData->park_id,
-                'error' => $e->getMessage()
-            ]);
-
-            return [
-                'success' => false,
-                'zone_data' => null,
-                'message' => 'ゾーンマスタ新規作成エラー: ' . $e->getMessage()
-            ];
-        }
-    }
-
-    /**
-     * 契約台数限界チェック
-     * 
-     * 【判断3】契約台数 > 限界収容台数の判定
-     *
-     * @param object $contractData 契約台数集計データ
-     * @param object|null $zoneData ゾーンマスタデータ
-     * @return bool 限界台数超過フラグ
-     */
-    private function checkCapacityLimit($contractData, $zoneData = null): bool
-    {
-        if (!$zoneData || is_null($zoneData->zone_tolerance)) {
-            // ゾーンデータが存在しないか、限界収容台数が未設定の場合は超過判定しない
-            return false;
-        }
-
-        // 契約台数 > 限界収容台数の判定
-        return $contractData->cnt > $zoneData->zone_tolerance;
-    }
-
-    /**
-     * ゾーンマスタ契約台数更新
-     * 
-     * 【処理3】現在契約台数をゾーンマスタに反映
-     *
-     * @param object $contractData 契約台数集計データ
-     * @return array 更新結果
-     */
-    private function updateZoneContractCount($contractData): array
-    {
-        try {
-            $updateData = [
-                'zone_number' => $contractData->cnt,           // 現在契約台数を更新
-                'updated_at' => now(),                         // 更新日時
-                'ope_id' => 'SHJ-11'                          // 更新オペレータID
-            ];
-
-            $updated = DB::table('zone')
-                ->where([
-                    ['park_id', '=', $contractData->park_id],
-                    ['psection_id', '=', $contractData->psection_id],
-                    ['ptype_id', '=', $contractData->ptype_id],
-                    ['zone_id', '=', $contractData->zone_id]
-                ])
-                ->update($updateData);
-
-            if ($updated > 0) {
-                Log::info('SHJ-11 ゾーンマスタ更新完了', [
-                    'zone_id' => $contractData->zone_id,
-                    'park_id' => $contractData->park_id,
-                    'new_contract_count' => $contractData->cnt
-                ]);
-
-                return [
-                    'success' => true,
-                    'message' => 'ゾーンマスタ契約台数を更新しました'
-                ];
-            } else {
-                return [
-                    'success' => false,
-                    'message' => 'ゾーンマスタ更新対象が見つかりません'
-                ];
-            }
-
-        } catch (\Exception $e) {
-            Log::error('SHJ-11 ゾーンマスタ更新エラー', [
-                'zone_id' => $contractData->zone_id,
-                'park_id' => $contractData->park_id,
-                'error' => $e->getMessage()
-            ]);
-
-            return [
-                'success' => false,
-                'message' => 'ゾーンマスタ更新エラー: ' . $e->getMessage()
-            ];
-        }
-    }
-
-    /**
-     * 【処理4】バッチ処理ログを作成する
-     * 
-     * 統一BatchLogシステムを使用してSHJ-11の実行ログを記録
-     *
-     * @param string $status ステータス
-     * @param array $parameters パラメータ
-     * @param string $message メッセージ
-     * @param int $executionCount 実行回数
-     * @param int $successCount 成功回数
-     * @param int $errorCount エラー回数
-     * @return void
-     */
-    public function createBatchLog(
-        string $status,
-        array $parameters,
-        string $message,
-        int $executionCount = 0,
-        int $successCount = 0,
-        int $errorCount = 0
-    ): void {
-        try {
-            BatchLog::createBatchLog(
-                'SHJ-11',
-                $status,
-                $parameters,
-                $message,
-                [
-                    'execution_count' => $executionCount,
-                    'success_count' => $successCount,
-                    'error_count' => $errorCount,
-                    'process_type' => '現在契約台数集計',
-                    'executed_at' => now()->toISOString()
-                ]
-            );
-
-        } catch (\Exception $e) {
-            Log::error('SHJ-11 バッチログ作成エラー', [
-                'error' => $e->getMessage(),
-                'status' => $status,
-                'message' => $message
-            ]);
-        }
-    }
-}