diff --git a/app/Controllers/CLI/Collector.php b/app/Controllers/CLI/Collector.php index 0ce416a..a05d9bd 100644 --- a/app/Controllers/CLI/Collector.php +++ b/app/Controllers/CLI/Collector.php @@ -26,18 +26,20 @@ class Collector extends CommonController } public function execute(): void { + $message = ""; 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"); + $message = "트래픽 계산 및 저장 완료 (UID: {$trafficEntity->getPK()}), In: {$entity->getIn()} Kb/s / Out: {$entity->getOut()} Kb/s"; } } catch (ValidationException $e) { - log_message("error", "트래픽 계산 및 저장 검증오류:{$e->getMessage()}"); + $message = "트래픽 계산 및 저장 검증오류:{$e->getMessage()}"; } catch (\Exception $e) { - log_message('error', "트래픽 계산 및 저장 실패:{$e->getMessage()}"); + $message = "트래픽 계산 및 저장 실패오류:{$e->getMessage()}"; } + log_message('info', $message); } }