50bb8543a5
All checks were successful
Deploy preview (main_xxx) / Deploy ${{ github.ref_name }} (push) Successful in 13s
- SHJ-11: 現在契約台数集計処理を実装 - SHJ-12: 未払い者通知処理を実装
336 lines
11 KiB
PHP
336 lines
11 KiB
PHP
<?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\User;
|
|
use App\Models\Park;
|
|
use App\Models\Ope;
|
|
use App\Services\ShjMailSendService;
|
|
|
|
/**
|
|
* SHJ-12 未払い者通知処理サービス
|
|
*
|
|
* 定期契約マスタより未払い者を取得し、通知処理またはオペレーターキュー追加を実行
|
|
*/
|
|
class ShjTwelveService
|
|
{
|
|
/**
|
|
* SHJメール送信サービス
|
|
*
|
|
* @var ShjMailSendService
|
|
*/
|
|
protected $shjMailSendService;
|
|
|
|
/**
|
|
* コンストラクタ
|
|
*
|
|
* @param ShjMailSendService $shjMailSendService
|
|
*/
|
|
public function __construct(ShjMailSendService $shjMailSendService)
|
|
{
|
|
$this->shjMailSendService = $shjMailSendService;
|
|
}
|
|
|
|
/**
|
|
* 【処理1】定期契約マスタより未払い者を取得する
|
|
*
|
|
* SQL条件:
|
|
* - 解約フラグ = 0 (未解約)
|
|
* - 授受フラグ = 0 (授受フラグOFF)
|
|
* - 請求金額 > 0 (請求金額あり)
|
|
*
|
|
* @return array 未払い者リスト
|
|
*/
|
|
public function getUnpaidUsers(): array
|
|
{
|
|
try {
|
|
$query = DB::table('regular_contract as T1')
|
|
->select([
|
|
'T1.contract_id', // 定期契約ID
|
|
'T2.user_seq', // 利用者ID
|
|
'T2.user_name', // 利用者名
|
|
'T2.user_manual_flag', // 手動登録フラグ
|
|
'T2.user_mail', // メールアドレス
|
|
'T2.user_mail_sub', // 予備メールアドレス
|
|
'T2.park_id', // 駐輪場ID (userテーブルから)
|
|
'T3.park_name', // 駐輪場名
|
|
'T1.billing_amount' // 請求金額
|
|
])
|
|
->join('user as T2', function($join) {
|
|
$join->on('T1.user_seq', '=', 'T2.user_seq');
|
|
})
|
|
->join('park as T3', 'T1.park_id', '=', 'T3.park_id')
|
|
->where([
|
|
['T1.contract_cancel_flag', '=', 0], // 解約フラグ = 0
|
|
['T1.contract_flag', '=', 0], // 授受フラグ = 0
|
|
])
|
|
->where('T1.billing_amount', '>', 0) // 請求金額 > 0
|
|
->get();
|
|
|
|
Log::info('SHJ-12 未払い者取得完了', [
|
|
'count' => $query->count(),
|
|
'sql_conditions' => [
|
|
'contract_cancel_flag' => 0,
|
|
'contract_flag' => 0,
|
|
'billing_amount' => '> 0'
|
|
]
|
|
]);
|
|
|
|
return $query->toArray();
|
|
|
|
} catch (\Exception $e) {
|
|
Log::error('SHJ-12 未払い者取得エラー', [
|
|
'error' => $e->getMessage(),
|
|
'trace' => $e->getTraceAsString()
|
|
]);
|
|
throw $e;
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 【処理2】未払い者への通知、またはオペレーターキュー追加処理
|
|
*
|
|
* 各未払い者に対して以下の処理を実行:
|
|
* 1. メール通知の実行 (SHJ-7連携)
|
|
* 2. オペレーターキューへの追加 (opeテーブル)
|
|
*
|
|
* @param array $unpaidUsers 未払い者リスト
|
|
* @return array 処理結果
|
|
*/
|
|
public function processUnpaidUserNotifications(array $unpaidUsers): array
|
|
{
|
|
$notificationCount = 0;
|
|
$queueCount = 0;
|
|
$errors = [];
|
|
$processParameters = [];
|
|
|
|
try {
|
|
DB::beginTransaction();
|
|
|
|
foreach ($unpaidUsers as $user) {
|
|
try {
|
|
// メール通知処理
|
|
$mailResult = $this->sendNotificationMail($user);
|
|
if ($mailResult['success']) {
|
|
$notificationCount++;
|
|
}
|
|
|
|
// オペレーターキュー追加処理
|
|
$queueResult = $this->addToOperatorQueue($user);
|
|
if ($queueResult['success']) {
|
|
$queueCount++;
|
|
}
|
|
|
|
// 処理パラメータ記録
|
|
$processParameters[] = [
|
|
'contract_id' => $user->contract_id,
|
|
'user_seq' => $user->user_seq,
|
|
'billing_amount' => $user->billing_amount,
|
|
'mail_sent' => $mailResult['success'],
|
|
'queue_added' => $queueResult['success']
|
|
];
|
|
|
|
} catch (\Exception $e) {
|
|
$errors[] = [
|
|
'contract_id' => $user->contract_id,
|
|
'error' => $e->getMessage()
|
|
];
|
|
|
|
Log::warning('SHJ-12 個別処理エラー', [
|
|
'contract_id' => $user->contract_id,
|
|
'user_seq' => $user->user_seq,
|
|
'error' => $e->getMessage()
|
|
]);
|
|
}
|
|
}
|
|
|
|
DB::commit();
|
|
|
|
return [
|
|
'success' => true,
|
|
'notification_count' => $notificationCount,
|
|
'queue_count' => $queueCount,
|
|
'parameters' => $processParameters,
|
|
'errors' => $errors,
|
|
'message' => '未払い者通知処理完了'
|
|
];
|
|
|
|
} catch (\Exception $e) {
|
|
DB::rollBack();
|
|
|
|
Log::error('SHJ-12 通知処理全体エラー', [
|
|
'error' => $e->getMessage(),
|
|
'processed_count' => count($processParameters)
|
|
]);
|
|
|
|
return [
|
|
'success' => false,
|
|
'notification_count' => $notificationCount,
|
|
'queue_count' => $queueCount,
|
|
'parameters' => $processParameters,
|
|
'errors' => $errors,
|
|
'message' => '通知処理エラー: ' . $e->getMessage(),
|
|
'details' => $e->getTraceAsString()
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 未払い者へのメール通知送信
|
|
*
|
|
* SHJ-7 メール送信サービスを使用してメール通知を実行
|
|
*
|
|
* @param object $user 未払い者情報
|
|
* @return array 送信結果
|
|
*/
|
|
private function sendNotificationMail($user): array
|
|
{
|
|
try {
|
|
// メールアドレスの確認
|
|
$emailAddress = $user->user_mail ?: $user->user_mail_sub;
|
|
|
|
if (empty($emailAddress)) {
|
|
return [
|
|
'success' => false,
|
|
'message' => 'メールアドレスが設定されていません'
|
|
];
|
|
}
|
|
|
|
// SHJ-7 メール送信サービス呼び出し
|
|
$mailParams = [
|
|
'to_email' => $emailAddress,
|
|
'user_name' => $user->user_name,
|
|
'park_name' => $user->park_name,
|
|
'billing_amount' => $user->billing_amount,
|
|
'contract_id' => $user->contract_id
|
|
];
|
|
|
|
$result = $this->shjMailSendService->sendUnpaidNotificationMail($mailParams);
|
|
|
|
Log::info('SHJ-12 メール送信結果', [
|
|
'contract_id' => $user->contract_id,
|
|
'email' => $emailAddress,
|
|
'success' => $result['success']
|
|
]);
|
|
|
|
return $result;
|
|
|
|
} catch (\Exception $e) {
|
|
Log::error('SHJ-12 メール送信エラー', [
|
|
'contract_id' => $user->contract_id,
|
|
'error' => $e->getMessage()
|
|
]);
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => 'メール送信エラー: ' . $e->getMessage()
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* オペレーターキューへの追加
|
|
*
|
|
* opeテーブルにオペレーター処理キューとして登録
|
|
*
|
|
* @param object $user 未払い者情報
|
|
* @return array 追加結果
|
|
*/
|
|
private function addToOperatorQueue($user): array
|
|
{
|
|
try {
|
|
$queueData = [
|
|
'ope_device_id' => null, // デバイスID (未設定)
|
|
'ope_process_name' => 'SHJ-12', // プロセス名
|
|
'ope_job_name' => '未払い者通知', // ジョブ名
|
|
'ope_status' => 'pending', // ステータス
|
|
'ope_comment' => sprintf(
|
|
'契約ID:%s ユーザー:%s 金額:%s円',
|
|
$user->contract_id,
|
|
$user->user_name,
|
|
number_format($user->billing_amount)
|
|
),
|
|
'ope_target_user_id' => $user->user_seq, // 対象ユーザーID
|
|
'ope_target_contract_id' => $user->contract_id, // 対象契約ID
|
|
'ope_billing_amount' => $user->billing_amount, // 請求金額
|
|
'created_at' => now(),
|
|
'updated_at' => now()
|
|
];
|
|
|
|
// opeテーブルに挿入
|
|
DB::table('ope')->insert($queueData);
|
|
|
|
Log::info('SHJ-12 オペレーターキュー追加完了', [
|
|
'contract_id' => $user->contract_id,
|
|
'user_seq' => $user->user_seq,
|
|
'billing_amount' => $user->billing_amount
|
|
]);
|
|
|
|
return [
|
|
'success' => true,
|
|
'message' => 'オペレーターキューに追加しました'
|
|
];
|
|
|
|
} catch (\Exception $e) {
|
|
Log::error('SHJ-12 オペレーターキュー追加エラー', [
|
|
'contract_id' => $user->contract_id,
|
|
'error' => $e->getMessage()
|
|
]);
|
|
|
|
return [
|
|
'success' => false,
|
|
'message' => 'オペレーターキュー追加エラー: ' . $e->getMessage()
|
|
];
|
|
}
|
|
}
|
|
|
|
/**
|
|
* 【処理3】バッチ処理ログを作成する
|
|
*
|
|
* 統一BatchLogシステムを使用してSHJ-12の実行ログを記録
|
|
*
|
|
* @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-12',
|
|
$status,
|
|
$parameters,
|
|
$message,
|
|
[
|
|
'execution_count' => $executionCount,
|
|
'success_count' => $successCount,
|
|
'error_count' => $errorCount,
|
|
'process_type' => '未払い者通知処理',
|
|
'executed_at' => now()->toISOString()
|
|
]
|
|
);
|
|
|
|
} catch (\Exception $e) {
|
|
Log::error('SHJ-12 バッチログ作成エラー', [
|
|
'error' => $e->getMessage(),
|
|
'status' => $status,
|
|
'message' => $message
|
|
]);
|
|
}
|
|
}
|
|
}
|