Add saving for aggregated rider rating. #764

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()