110 lines
3.8 KiB
PHP
110 lines
3.8 KiB
PHP
<?php
|
|
|
|
namespace App\Commands;
|
|
|
|
use CodeIgniter\CLI\BaseCommand;
|
|
use CodeIgniter\CLI\CLI;
|
|
|
|
use App\Models\Entities\NaverWorkerLogModel; // 새로 만든 테이블용 모델
|
|
|
|
// 헬퍼 로드 (app/Helpers/log_helper.php 가 있어야 함 autoload 설정 넣어놓았음)
|
|
|
|
class NaverWorker extends BaseCommand
|
|
{
|
|
protected $group = 'Workers';
|
|
protected $name = 'naver:worker';
|
|
protected $description = 'Redis에서 데이터를 꺼내 DB에 저장하고 네이버 API를 호출합니다.';
|
|
|
|
// DB 객체를 담을 변수 선언
|
|
protected $db;
|
|
|
|
public function run(array $params)
|
|
{
|
|
helper('log'); // 여기서 로드 완료!
|
|
|
|
$this->db = \Config\Database::connect();
|
|
$logModel = model(NaverWorkerLogModel::class);
|
|
$naverService = new \App\Services\NaverService(); // 서비스 생성
|
|
|
|
$redis = new \Redis();
|
|
try {
|
|
$redis->connect('redis', 6379);
|
|
$redis->select(9);
|
|
CLI::write(CLI::color('🟢 Naver Worker running...', 'green'));
|
|
} catch (\Exception $e) {
|
|
CLI::error("Redis 연결 불가: " . $e->getMessage());
|
|
return;
|
|
}
|
|
|
|
|
|
|
|
while (true) {
|
|
|
|
// 1. DB 연결 상태 체크 (더 견고하게)
|
|
try {
|
|
// connID가 없거나, 가벼운 쿼리 실행 실패 시 재연결 시도
|
|
if ($this->db->connID === false || !$this->db->simpleQuery('SELECT 1')) {
|
|
$this->db->reconnect();
|
|
CLI::write(CLI::color('🔄 Database reconnected.', 'yellow'));
|
|
}
|
|
} catch (\Throwable $e) {
|
|
// 어떤 이유로든 에러 발생 시 재연결 시도
|
|
$this->db->reconnect();
|
|
}
|
|
|
|
$result = $redis->brPop(['naver:raw_queue'], 30);
|
|
|
|
if (!$result) {
|
|
// 데이터가 없어서 타임아웃 난 경우.
|
|
// 굳이 sleep 안 해도 바로 다음 brPop이 다시 30초 대기를 시작함.
|
|
continue;
|
|
}
|
|
|
|
if ($result) {
|
|
$rawData = $result[1];
|
|
// [1] 꺼내자마자 DB에 원문 저장 (2차 임시 저장)
|
|
$logId = $logModel->insert([
|
|
'raw_payload' => $rawData,
|
|
'status' => 'INIT'
|
|
]);
|
|
|
|
try {
|
|
$responseJson = json_decode($result[1], true);
|
|
$payload = $responseJson['request_data'] ?? [];
|
|
|
|
if (empty($payload)) {
|
|
throw new \Exception("빈 페이로드 데이터");
|
|
}
|
|
|
|
// 서비스의 함수 하나로 모든 처리 완료
|
|
$insertId = $naverService->processArticle($payload);
|
|
|
|
// [3] 성공 시 로그 업데이트
|
|
$logModel->update($logId, [
|
|
'atcl_no' => $payload['articleNumber'] ?? null,
|
|
'status' => 'SUCCESS',
|
|
'target_db_id' => $insertId
|
|
]);
|
|
|
|
CLI::write("✅ Success! DB ID: $insertId", 'cyan');
|
|
|
|
} catch (\Exception $e) {
|
|
CLI::error("❌ Task Failed: " . $e->getMessage());
|
|
// 실패 로그는 여기서 남김
|
|
// 1. DB 상태를 FAIL로 업데이트 (필수)
|
|
$logModel->update($logId, ['status' => 'FAIL', 'error_msg' => $e->getMessage()]);
|
|
|
|
// 2. Redis 실패 큐에 백업 (선택 - 나중에 모아서 다시 던질 때 편함)
|
|
$redis->lPush('naver:failed_queue', $rawData);
|
|
helper('log');
|
|
write_custom_log("FAILED_DATA | Error: " . $e->getMessage(), 'ERROR', 'failed');
|
|
|
|
// 루프 과부하 방지 (연속 에러 시)
|
|
sleep(1);
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
} |