From 25d7c30f7363b9e810a286edc3d16238f412095c Mon Sep 17 00:00:00 2001
From: Korina Cordero <cordero.korina@gmail.com>
Date: Fri, 6 Oct 2023 10:39:47 +0800
Subject: [PATCH] Add saving for aggregated rider rating. #764

---
 .../LoadAggregateRiderRatingsComand.php       | 19 +++++++++++++++----
 1 file changed, 15 insertions(+), 4 deletions(-)

diff --git a/src/Command/LoadAggregateRiderRatingsComand.php b/src/Command/LoadAggregateRiderRatingsComand.php
index eb2eb3fd..7e10230f 100644
--- a/src/Command/LoadAggregateRiderRatingsComand.php
+++ b/src/Command/LoadAggregateRiderRatingsComand.php
@@ -9,7 +9,6 @@ use Symfony\Component\Console\Output\OutputInterface;
 
 use Doctrine\ORM\EntityManagerInterface;
 
-use App\Entity\RiderRating;
 use App\Entity\AggregatedRiderRating;
 
 use PDO;
@@ -87,9 +86,21 @@ class LoadAggregateRiderRatingsComand extends Command
     {
         error_log(print_r($agg_rider_ratings, true));
 
-        // TODO: create new AggregatedRiderRating object
-        // set fields
-        // save to database
+        foreach ($agg_rider_ratings as $key => $data)
+        {
+            // create new AggregatedRiderRating object
+            $obj = new AggregatedRiderRating();
+
+            // set fields
+            $obj->setRiderId($key)
+              ->setAggregateRating($data['agg_rating'])
+              ->setAggregateCount($data['agg_count']);
+
+            // save to database
+            $this->em->persist($obj);
+        }
+
+        $this->em->flush();
     }
 
     protected function getRiderIds()