From e1f2ddbfa3aa38eb24d3137f99915d77a64a356b Mon Sep 17 00:00:00 2001
From: "choi.jh" <choi.jh@prime-idc.jp>
Date: Wed, 12 Nov 2025 15:11:30 +0900
Subject: [PATCH] trafficmonitor init...2

---
 app/Controllers/CLI/Collector.php | 8 ++++----
 app/Services/CollectorService.php | 8 ++++----
 2 files changed, 8 insertions(+), 8 deletions(-)

diff --git a/app/Controllers/CLI/Collector.php b/app/Controllers/CLI/Collector.php
index e18e886..7cf0073 100644
--- a/app/Controllers/CLI/Collector.php
+++ b/app/Controllers/CLI/Collector.php
@@ -26,11 +26,11 @@ class Collector extends CommonController
     public function execute(): void
     {
         $trafficService = service('trafficservice');
-        foreach ($trafficService->getEntities(['status' => STATUS['AVAILABLE']]) as $entity) {
-            $data = $this->service->getCalculatedData($entity);
+        foreach ($trafficService->getEntities(['status' => STATUS['AVAILABLE']]) as $trafficEntity) {
+            $data = $this->service->getCalculatedData($trafficEntity);
             // Collector DB에 결과 저장
-            $this->service->create($this->createDTO($data));
-            log_message('info', "트래픽 계산 및 저장 완료 (UID: {$entity->getPK()}), In: {$data['in_kbits_sec']} Kb/s");
+            $entity = $this->service->create($this->createDTO($data));
+            log_message('info', "트래픽 계산 및 저장 완료 (UID: {$trafficEntity->getPK()}), In: {$entity->getIn()} Kb/s / Out: {$entity->getOut()} Kb/s");
         }
     }
 }
diff --git a/app/Services/CollectorService.php b/app/Services/CollectorService.php
index b6f71e6..8a2f5ac 100644
--- a/app/Services/CollectorService.php
+++ b/app/Services/CollectorService.php
@@ -131,10 +131,10 @@ class CollectorService extends CommonService
         // DB에 저장할 데이터를 배열로 반환
         return [
             'trafficinfo_uid' => $trafficEntity->getPK(),
-            'in_kbits_sec' => round($inKbitsSec, 2),
-            'out_kbits_sec' => round($outKbitsSec, 2),
-            'raw_in_octets' => $currentInOctets,
-            'raw_out_octets' => $currentOutOctets,
+            'in' => round($inKbitsSec, 2),
+            'out' => round($outKbitsSec, 2),
+            'raw_in' => $currentInOctets,
+            'raw_out' => $currentOutOctets,
         ];
     }
 }