Add saving for aggregated rider rating. #764

This commit is contained in:
Korina Cordero 2023-10-06 10:39:47 +08:00
parent 53a45ac4f4
commit 83c0e1cd51

View file

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