Tarioch\EveapiFetcherBundle\Component\EveApi\Corp\WalletTransactionUpdater::update()

Complexity

Conditions	4
Paths	4

Size

Total Lines	53
Code Lines	39

Duplication

Lines	0
Ratio	0 %

Importance

Changes	8
Bugs	3	Features	2

<?php
    public function update(ApiCall $call, ApiKey $key, Pheal $pheal)
    {
        $owner = $call->getOwner();
        $charId = $owner->getCharacterId();
        $corpId = $owner->getCorporationId();

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

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

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

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

                $criteria = array('transactionId' => $transId, 'ownerId' => $corpId, 'accountKey' => $accountKey);
                $entity = $repo->findOneBy($criteria);
                if ($entity === null) {
                    $entity = new CorpWalletTransaction($transId, $corpId, $accountKey);
                    $this->entityManager->persist($entity);

                    $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);
                    $entity->setCharacterId($transaction->characterID);
                    $entity->setCharacterName($transaction->characterName);

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

        return $cached;
    }
}