src/Biz/Xapi/Job/ConvertStatementJob.php

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

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

<?php

namespace Biz\Xapi\Job;

use AppBundle\Common\ArrayToolkit;
use AppBundle\Common\TimeMachine;
use Biz\Xapi\Dao\StatementDao;
use Biz\Xapi\Service\XapiService;
use Codeages\Biz\Framework\Scheduler\AbstractJob;

class ConvertStatementJob extends AbstractJob
{
    private $perCount = 2000;

    public function execute()
    {
        try {
            $this->getStatementDao()->retryStatusPushingToCreatedByCreatedTime(strtotime('-3 day', TimeMachine::time()));
            $condition = array(
                'status' => 'created',
            );
            $statements = $this->getXapiService()->searchStatements($condition, array('created_time' => 'DESC'), 0, $this->perCount);
            $statements = ArrayToolkit::index($statements, 'uuid');

            foreach ($statements as &$statement) {
                if (!empty($statement['verb']) && !empty($statement['target_type'])) {
                    $statement['key'] = "{$statement['verb']}_{$statement['target_type']}";
                }
            }

            $groupStatements = ArrayToolkit::group($statements, 'key');
            $pushStatements = array();

            foreach ($groupStatements as $key => $values) {
                $push = $this->biz["xapi.push.{$key}"];
                $result = $push->packages($values);

                if (is_array($result)) {
                    $pushStatements = array_merge($pushStatements, $result);
                }
            }

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

            $pushData = array();
            $pushStatements = ArrayToolkit::index($pushStatements, 'id');
            foreach ($pushStatements as $key => $data) {
                if (isset($statements[$key])) {
                    $pushData[$statements[$key]['id']] = $data;
                }
            }

            $this->getXapiService()->updateStatementsConvertedAndDataByStatementData($pushData);
        } catch (\Exception $e) {
            $this->biz['logger']->error($e);
        }
    }