diff --git a/app/Controllers/CLI/Collector.php b/app/Controllers/CLI/Collector.php index 7cf0073..6dfb39a 100644 --- a/app/Controllers/CLI/Collector.php +++ b/app/Controllers/CLI/Collector.php @@ -25,12 +25,16 @@ class Collector extends CommonController } public function execute(): void { - $trafficService = service('trafficservice'); - foreach ($trafficService->getEntities(['status' => STATUS['AVAILABLE']]) as $trafficEntity) { - $data = $this->service->getCalculatedData($trafficEntity); - // Collector DB에 결과 저장 - $entity = $this->service->create($this->createDTO($data)); - log_message('info', "트래픽 계산 및 저장 완료 (UID: {$trafficEntity->getPK()}), In: {$entity->getIn()} Kb/s / Out: {$entity->getOut()} Kb/s"); + try { + $trafficService = service('trafficservice'); + foreach ($trafficService->getEntities(['status' => STATUS['AVAILABLE']]) as $trafficEntity) { + $data = $this->service->getCalculatedData($trafficEntity); + // Collector DB에 결과 저장 + $entity = $this->service->create($this->createDTO($data)); + log_message('info', "트래픽 계산 및 저장 완료 (UID: {$trafficEntity->getPK()}), In: {$entity->getIn()} Kb/s / Out: {$entity->getOut()} Kb/s"); + } + } catch (\Exception $e) { + log_message('info', "트래픽 계산 및 저장 실패:{$e->getMessage()}"); } } }