Tarioch\EveapiFetcherBundle\Command\ScheduleApiJobsCommand::execute()

Complexity

Conditions	4
Paths	4

Size

Total Lines	25
Code Lines	16

Duplication

Lines	0
Ratio	0 %

Importance

Changes	1
Bugs	0	Features	0

<?php
    protected function execute(InputInterface $input, OutputInterface $output)
    {
        $gearman = $this->getContainer()->get('gearman');
        $entityManager = $this->getContainer()->get('doctrine.orm.eveapi_entity_manager');

        $newKeys = $entityManager->getRepository('TariochEveapiFetcherBundle:ApiKey')->loadKeysWithoutApiCall();
        if (!empty($newKeys)) {
            $api = $entityManager->getRepository('TariochEveapiFetcherBundle:Api')->loadApiKeyInfoApi();
            foreach ($newKeys as $key) {
                $entityManager->persist(new ApiCall($api, null, $key));
            }
            $entityManager->flush();
        }

        $calls = $entityManager->getRepository('TariochEveapiFetcherBundle:ApiCall')->loadReadyCalls();
        foreach ($calls as $call) {
            $api = $call->getApi();

            $worker = $api->getWorker();
            $job = $worker . '~apiUpdate';
            $callId = $call->getApiCallId();

            $gearman->doBackgroundJob($job, $callId, $callId);
        }
    }
}