src/AppBundle/Controller/Admin/QueueController.php

这里只显示每个文件的开头 60 行。登录后可以解锁完整代码。

微信扫码关注公众号，代码整理好后第一时间通知你。

<?php

namespace AppBundle\Controller\Admin;

use AppBundle\Common\Paginator;
use Codeages\Biz\Framework\Queue\Service\QueueService;
use Symfony\Component\HttpFoundation\Request;

class QueueController extends BaseController
{
    public function failedJobsAction(Request $request)
    {
        $count = $this->getQueueService()->countFailedJobs(array());

        $paginator = new Paginator(
            $request,
            $count,
            20
        );

        $jobs = $this->getQueueService()->searchFailedJobs(
            array(),
            array('failed_time' => 'desc'),
            $paginator->getOffsetCount(),
            $paginator->getPerPageCount()
        );

        return $this->render(
            'admin/queue/failed-logs.html.twig',
            array(
                'jobs' => $jobs,
                'paginator' => $paginator,
            )
        );
    }

    public function failedJobAction(Request $request, $id)
    {
        $failedJob = $this->getQueueService()->getFailedJob($id);

        return $this->render(
            'admin/queue/failed-log-modal.html.twig',
            array(
                'failedJob' => $failedJob,
            )
        );
    }

    /**
     * @return QueueService
     */
    protected function getQueueService()
    {
        return $this->createService('Queue:QueueService');
    }
}