src/App/Subscriber/OneRoster/OneRosterOrgProcessSubscriber.php line 32

Open in your IDE?
  1. <?php
  3. namespace App\Subscriber\OneRoster;
  5. use App\Entity\System\School;
  6. use Cms\CoreBundle\Entity\AbstractOneRosterEntity;
  7. use Cms\CoreBundle\Entity\OneRoster\OneRosterOrg;
  8. use Cms\CoreBundle\Entity\OneRosterSync;
  9. use Cms\CoreBundle\Events\OneRosterProcessEvent;
  10. use Cms\CoreBundle\Model\Interfaces\OneRosterable\AbstractOneRosterableSubscriber;
  11. use Doctrine\Common\Util\ClassUtils;
  13. /**
  14.  */
  15. final class OneRosterOrgProcessSubscriber extends AbstractOneRosterableSubscriber
  16. {
  17.     /**
  18.      * {@inheritdoc}
  19.      */
  20.     static public function getSubscribedEvents(): array
  21.     {
  22.         return [
  23.             OneRosterProcessEvent::EVENT__ORG => [
  24.                 ['populateSchools', 100],
  25.             ],
  26.         ];
  27.     }
  29.     /**
  30.      * @param OneRosterProcessEvent $event
  31.      */
  32.     public function populateSchools(OneRosterProcessEvent $event): void
  33.     {
  34.         // ensure we are meant to process this
  35.         if ( ! $this->checkTypes($event->getSync(), [
  36.             OneRosterSync::STRATEGIES__SCHOOLS,
  37.         ])) {
  38.             return;
  39.         }
  41.         // get the org
  42.         $org = $event->getEntity();
  43.         if ( ! $org instanceof OneRosterOrg) {
  44.             throw new \Exception(sprintf(
  45.                 'Org is not of proper type, got "%s".',
  46.                 ClassUtils::getClass($org)
  47.             ));
  48.         }
  50.         // branch on the org type
  51.         switch (true) {
  52.             case $this->checkTypes($event->getSync(), [OneRosterSync::STRATEGIES__SCHOOLS]) && $org->isType(AbstractOneRosterEntity::ENUMS__ORG_TYPE__DISTRICT):
  53.             case $this->checkTypes($event->getSync(), [OneRosterSync::STRATEGIES__SCHOOLS])
  54.                 && $org->isType(AbstractOneRosterEntity::ENUMS__ORG_TYPE__SCHOOL)
  55.                 && ! $event->getSync()->hasFlag(OneRosterSync::FLAGS__SINGLE_SCHOOL):
  56.                 break;
  57.             default:
  59.                 // DEBUGGING
  60.                 $event->getOutput()->writeln(sprintf(
  61.                     'Org type for #%s is "%s", skipping...',
  62.                     $org->getSourcedId(),
  63.                     $org->getType()
  64.                 ));
  66.                 return;
  68.         }
  70.         // try to find an existing school for the org based on the oneroster id
  71.         $school = $this->em->getRepository(School::class)->findOneBy([
  72.             'oneRosterOrg' => $org->getSourcedId(),
  73.         ]);
  75.         // if we don't have one, attempt to find one based on the name
  76.         if ( ! $school) {
  77.             $school = $this->em->getRepository(School::class)->findOneBy([
  78.                 'name' => $org->getName(),
  79.             ]);
  80.         }
  82.         // if we still don't have one, make one
  83.         if ( ! $school) {
  84.             $school = (new School())
  85.                 ->setType(
  86.                 $org->isType(AbstractOneRosterEntity::ENUMS__ORG_TYPE__DISTRICT)
  87.                         ? School::TYPES__DISTRICT
  88.                         : School::TYPES__OTHER
  89.                 )
  90.             ;
  91.         }
  93.         // set stuff
  94.         $school
  95.             ->setName($school->getName() ?: $org->getName())
  96.             ->setOneRosterOrg($org->getSourcedId())
  97.         ;
  99.         // TODO: schools should now be a onerosterable object...
  101.         // save the school
  102.         $this->em->save($school);
  103.     }
  104. }