src/Biz/Question/Service/Impl/QuestionServiceImpl.php

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

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

<?php

namespace Biz\Question\Service\Impl;

use Biz\BaseService;
use AppBundle\Common\ArrayToolkit;
use Biz\Question\QuestionException;
use Codeages\Biz\Framework\Event\Event;
use Biz\Question\Service\QuestionService;

class QuestionServiceImpl extends BaseService implements QuestionService
{
    public function get($id)
    {
        return $this->getQuestionDao()->get($id);
    }

    public function create($fields)
    {
        $argument = $fields;
        $user = $this->getCurrentuser();
        $fields['createdUserId'] = $user['id'];
        $fields['updatedUserId'] = $user['id'];

        if (isset($fields['content'])) {
            $fields['content'] = $this->purifyHtml($fields['content'], true);
        }

        $this->beginTransaction();
        try {
            $questionConfig = $this->getQuestionConfig($fields['type']);
            $media = $questionConfig->create($fields);

            if (!empty($media)) {
                $fields['metas']['mediaId'] = $media['id'];
            }

            $fields['createdTime'] = time();
            $fields['updatedTime'] = time();
            $fields = $questionConfig->filter($fields);

            if (!empty($fields['parentId'])) {
                $parentQuestion = $this->get($fields['parentId']);
                $fields['courseId'] = $parentQuestion['courseId'];
                $fields['lessonId'] = $parentQuestion['lessonId'];
            }

            $fields['target'] = empty($fields['courseSetId']) ? '' : 'course-'.$fields['courseSetId'];

            $question = $this->getQuestionDao()->create($fields);

            if ($question['parentId'] > 0) {
                $this->waveCount($question['parentId'], array('subCount' => '1'));
            }

            //$this->getLogService()->info('course', 'add_question', "新增题目(#{$question['id']})", $question);
            $this->dispatchEvent('question.create', new Event($question, array('argument' => $argument)));

            $this->commit();