src/Biz/Xapi/Service/Impl/XapiServiceImpl.php

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

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

<?php

namespace Biz\Xapi\Service\Impl;

use AppBundle\Common\ArrayToolkit;
use Biz\BaseService;
use Biz\Task\Service\TaskService;
use Biz\User\UserException;
use Biz\Xapi\Dao\ActivityWatchLogDao;
use Biz\Xapi\Dao\StatementArchiveDao;
use Biz\Xapi\Dao\StatementDao;
use Biz\Xapi\Service\XapiService;
use Codeages\Biz\Framework\Dao\BatchCreateHelper;
use Codeages\Biz\Framework\Dao\BatchUpdateHelper;

class XapiServiceImpl extends BaseService implements XapiService
{
    public function createStatement($statement)
    {
        if (empty($this->biz['user'])) {
            $this->createNewException(UserException::UN_LOGIN());
        }

        $statement['version'] = $this->biz['xapi.options']['version'];
        $statement['uuid'] = $this->generateUUID();

        return $this->getStatementDao()->create($statement);
    }

    public function batchCreateStatements($statements)
    {
        if (empty($this->biz['user'])) {
            $this->createNewException(UserException::UN_LOGIN());
        }
        $batchCreateHelper = new BatchCreateHelper($this->getStatementDao());
        foreach ($statements as $statement) {
            $statement['version'] = $this->biz['xapi.options']['version'];
            $statement['uuid'] = $this->generateUUID();
            $batchCreateHelper->add($statement);
        }
        $batchCreateHelper->flush();
    }

    public function getStatement($id)
    {
        return $this->getStatementDao()->get($id);
    }

    public function deleteStatement($id)
    {
        return $this->getStatementDao()->update($id, array('status' => 'deleted'));
    }

    protected function generateUUID()
    {
        $charid = strtoupper(md5(uniqid(rand(), true)));
        $hyphen = chr(45);
        $uuid = ''.substr($charid, 0, 8).$hyphen.substr($charid, 8, 4).$hyphen.substr($charid, 12, 4).$hyphen.substr($charid, 16, 4).$hyphen.substr($charid, 20, 12);

        return $uuid;