Tarioch\EveapiFetcherBundle\Component\EveApi\Char\WalletTransactionUpdater

Complexity

Total Complexity

4

Size/Duplication

Total Lines	56
Duplicated Lines	0 %

Coupling/Cohesion

Components	1
Dependencies	5

Importance

Changes	4
Bugs	0	Features	2

1 Method

Rating	Name	Duplication	Size	Complexity
B	update()	0	50	4

<?php
namespace Tarioch\EveapiFetcherBundle\Component\EveApi\Char;

use JMS\DiExtraBundle\Annotation as DI;
use Tarioch\EveapiFetcherBundle\Entity\ApiCall;
use Pheal\Pheal;
use Tarioch\EveapiFetcherBundle\Entity\ApiKey;
use Tarioch\EveapiFetcherBundle\Entity\CharWalletTransaction;

/**
 * @DI\Service("tarioch.eveapi.char.WalletTransactions")
 */
class WalletTransactionUpdater extends AbstractCharUpdater
{
    /**
     * @inheritdoc
     */
    public function update(ApiCall $call, ApiKey $key, Pheal $pheal)
    {
        $owner = $call->getOwner();
        $charId = $owner->getCharacterId();

        $accountRepo = $this->entityManager->getRepository('TariochEveapiFetcherBundle:CharAccountBalance');
        $accounts = $accountRepo->findByOwnerId($charId);

        $cached = 'now';
        foreach ($accounts as $account) {
            $accountKey = $account->getAccountKey();

            $api = $pheal->charScope->WalletTransactions(array(
                'characterID' => $charId,
                'rowCount' => 2560,
                'accountKey' => $accountKey
            ));
            $cached = $api->cached_until;

            $repo = $this->entityManager->getRepository('TariochEveapiFetcherBundle:CharWalletTransaction');
            foreach ($api->transactions as $transaction) {
                $transId = $transaction->transactionID;

                $entity = $repo->findOneBy(array('transactionId' => $transId, 'ownerId' => $charId));
                if ($entity === null) {
                    $entity = new CharWalletTransaction($transId, $charId);
                    $this->entityManager->persist($entity);

                    $entity->setAccountKey($accountKey);
                    $entity->setJournalTransactionId($transaction->journalTransactionID);
                    $entity->setTransactionDateTime(new \DateTime($transaction->transactionDateTime));
                    $entity->setQuantity($transaction->quantity);
                    $entity->setTypeName($transaction->typeName);
                    $entity->setTypeId($transaction->typeID);
                    $entity->setPrice($transaction->price);
                    $entity->setClientId($transaction->clientID);
                    $entity->setClientName($transaction->clientName);
                    $entity->setClientTypeId($transaction->clientTypeID);
                    $entity->setStationId($transaction->stationID);
                    $entity->setStationName($transaction->stationName);
                    $entity->setTransactionType($transaction->transactionType);
                    $entity->setTransactionFor($transaction->transactionFor);

                    $this->entityManager->flush($entity);
                }
            }
        }

        return $cached;
    }
}