DerDu/SPHERE-Framework

<?php
namespace SPHERE\Application\Platform\System\Archive\Service;

use SPHERE\Application\Platform\Gatekeeper\Authorization\Account\Service\Entity\TblAccount;
use SPHERE\Application\Platform\Gatekeeper\Authorization\Consumer\Service\Entity\TblConsumer;
use SPHERE\Application\Platform\System\Archive\Service\Entity\TblArchive;
use SPHERE\System\Database\Binding\AbstractData;
use SPHERE\System\Database\Fitting\Element;
use SPHERE\System\Database\Fitting\Manager;

/**
 * Class Data
 *
 * @package SPHERE\Application\Platform\System\Archive\Service
 */
class Data extends AbstractData
{
    /** @var null|Manager $BulkManager */
    private static $BulkManager = null;

    /**
     * @return void
     */
    public function setupDatabaseContent()
    {

    }

    /**
     * @return TblArchive[]|bool
     */
    public function getArchiveAll()
    {

        $Manager = $this->getConnection()->getEntityManager();

        $Query = $Manager->getQueryBuilder()
            ->select('A')
            ->from(__NAMESPACE__ . '\Entity\TblArchive', 'A')
            ->orderBy('A.Id', 'DESC')
            ->setMaxResults(100)
            ->getQuery();

        $EntityList = $Query->getResult();
        return ( empty( $EntityList ) ? false : $EntityList );
    }

    /**
     * @param TblConsumer $tblConsumer
     *
     * @return bool|TblArchive[]
     */
    public function getArchiveAllByConsumer(TblConsumer $tblConsumer)
    {

        $EntityList = $this->getConnection()->getEntityManager()->getEntity('TblArchive')->findBy(array(
            TblArchive::SERVICE_TBL_CONSUMER => $tblConsumer->getId()
        ));
        return ( empty( $EntityList ) ? false : $EntityList );
    }

    /**
     * @param string           $DatabaseName
     * @param null|TblAccount  $tblAccount
     * @param null|TblConsumer $tblConsumer
     * @param null|Element     $Entity
     * @param int              $Type
     * @param bool $useBulkSave
     * @return false|TblArchive
     */
    public function createArchiveEntry(
        $DatabaseName,
        TblAccount $tblAccount = null,
        TblConsumer $tblConsumer = null,
        Element $Entity = null,
        $Type = TblArchive::ARCHIVE_TYPE_CREATE,
        $useBulkSave = false
    ) {


        if ($useBulkSave) {
            if (self::$BulkManager) {
                $Manager = self::$BulkManager;
            } else {
                $Manager = self::$BulkManager = $this->getConnection()->getEntityManager();
            }
        } else {
            $Manager = $this->getConnection()->getEntityManager();
        }

        $Entity = ( $Entity ? serialize($this->persistData($Entity)) : null );

        $Archive = new TblArchive($Type);
        $Archive->setArchiveDatabase($DatabaseName);
        $Archive->setArchiveTimestamp(time());
        if ($tblAccount) {
            $Archive->setServiceTblAccount($tblAccount);
            $Archive->setAccountUsername($tblAccount->getUsername());
        }
        if ($tblConsumer) {
            $Archive->setServiceTblConsumer($tblConsumer);
            $Archive->setConsumerName($tblConsumer->getName());
            $Archive->setConsumerAcronym($tblConsumer->getAcronym());
        }
        $Archive->setEntity($Entity);

        if( $useBulkSave ) {
            $Manager->bulkSaveEntity($Archive);
        } else {
            $Manager->saveEntity($Archive);
        }

        return $Archive;
    }

    /**
     * @param Element $Entity
     *
     * @return array
     */
    private function persistData(Element $Entity)
    {

        $Data = array();
        $Class = new \ReflectionClass($Entity);
        $PropertyList = $Class->getProperties();
        /** @var \ReflectionProperty $Property */
        foreach ((array)$PropertyList as $Property) {
            if ($Class->hasMethod('get'.$Property->getName())) {
                $Data[$Property->getName()] = $Entity->{'get'.$Property->getName()}();
            }
        }
        $Data['EntityName'] = $Class->getShortName();
        return $this->followData($Data);
    }

    /**
     * @param array $Data
     *
     * @return array
     */
    private function followData($Data)
    {

        foreach ((array)$Data as $Key => $Value) {
            if ($Value instanceof Element) {
                $Data[$Key] = $this->persistData($Value);
            }
            if ($Value instanceof \DateTime) {
                $Data[$Key] = $Value->getTimestamp();
            }
        }
        return $Data;
    }

    /**
     *
     */
    public function flushBulkSave()
    {
        if (self::$BulkManager) {
            self::$BulkManager->flushCache();
        }
    }
}