php – ZF2,Oracle,SlmQueueDoctrine,ClearObjectManagerStrateg

我怀疑我的工作不是使用ClearObjectManagerStrategy,并且在执行单个作业之前不会清除ObjectManager.

它在队列启动后不反映数据库修改.但是如果我杀死队列守护进程并重新开始,它会选择新的值.

如何在执行单个作业之前实现ClearObjectManagerStrategy并清除ObjectManager？

我试过很多没有运气的人.

composer.json

{
    "repositories": [
        {
            "url": "https://github.com/pradeep-sanjaya/doctrine-extensions.git","type": "git"
        }
    ],"require": {
        "php": ">=5.3.3","zendframework/zendframework": "2.3.3","doctrine/doctrine-orm-module": "0.7.*","pradeep-sanjaya/doctrine-extensions": "dev-master","spoonx/sxmail": "1.4.*","slm/locale": "dev-master","imagine/Imagine": "0.6.*","tecnick.com/tcpdf": "dev-master","slm/queue": "0.4.*","slm/queue-doctrine": "0.4.*"
    }
}

配置/自动加载/ slm_queue.local.php

<?php
return array(
    'slm_queue' => array(
        'queue_manager' => array(
            'factories' => array(
                'doctrineQueue' => 'SlmQueueDoctrineFactoryDoctrineQueueFactory'
            ),),'job_manager' => array(
            'factories' => array(
                'ReportJobRank' => 'ReportJobRankFactory','shared' => array(
                'ReportJobRank' => false
            ),'queues' => array(
            'doctrineQueue' => array(
                'table_name' => 'IOQUEUE'
            )
        )
    )
);
?>

模块/报告/ src目录/报告/招聘/ Rank.php

<?php
namespace ReportJob;

use DoctrineModulePersistenceObjectManagerAwareInterface;
use DoctrineModulePersistenceProvidesObjectManager as ProvidesObjectManagerTrait;
use SlmQueueJobAbstractJob;

use ApplicationEntityReport;

use ApplicationLogLoggerAwareInterface;
use ApplicationLogLoggerAwareTrait;

use ApplicationServiceReportService;

class Rank extends AbstractJob implements ObjectManagerAwareInterface,LoggerAwareInterface
{
    use LoggerAwareTrait;
    use ProvidesObjectManagerTrait;

    /**
     * @var ReportService
     */
    protected $reportService;

    /**
     * @var array
     */
    protected $reportId = array();

    public function setReportService(ReportService $reportService)
    {
        $this->reportService = $reportService;
    }

    /**
     * Execute the job
     *
     * @return void
     */
    public function execute()
    {
        //clear object manager does not work
        //$om = $this->getObjectManager();
        //$om->clear();

        $content = $this->getContent();
        $this->setReportId($content['reportId']);

        if (!empty($this->reportId)) {
            try {
                if (is_array($this->reportId)) {
                    foreach ($this->reportId as $reportId) {
                        $this->updateRank($reportId);
                    }
                    unset($reportId);
                } else {
                    $this->updateRank($this->reportId);
                }
            } catch (Exception $exception) {
                echo "Exception message is {$exception->getMessage()} n";
            }
        }
    }

    private function updateRank($reportId)
    {
        /* @var $report Report */
        $report = $this->reportService->getReport($reportId);
        $this->logInfo(print_r($report,true)); // this always return older db values,the values before it start queue deamon

        if (!$report instanceof Report) {
            return;
        }

        if (empty($rankData)) {
            return;
        }

        //more codes,application related logics

        $this->reportService->updateReportEntity($report);
    }

    private function setReportId($reportId)
    {
        if (is_numeric($reportId)) {
            $this->reportId = array($reportId);
        } elseif (is_array($reportId)) {
            $this->reportId = $reportId;
        } else {
            throw new Exception('Expects reportId as int or array');
        }
    }
}