mint/api-v13/app/Http/Controllers/DiscussionController.php

<?php

namespace App\Http\Controllers;

use App\Http\Api\ChannelApi;
use App\Http\Api\CourseApi;
use App\Http\Api\MdRender;
use App\Http\Api\Mq;
use App\Http\Api\UserApi;
use App\Http\Resources\DiscussionResource;
use App\Models\Channel;
use App\Models\Discussion;
use App\Models\PaliSentence;
use App\Models\Sentence;
use App\Models\Wbw;
use App\Models\WbwBlock;
use App\Services\AuthService;
use Illuminate\Http\Request;
use Illuminate\Http\Response;

class DiscussionController extends Controller
{
    /**
     * Display a listing of the resource.
     *
     * @return Response
     */
    public function index(Request $request)
    {
        //
        $user = AuthService::current($request);
        if ($user) {
            $userInfo = UserApi::getByUuid($user['user_uid']);
        }
        switch ($request->input('view')) {
            case 'question-by-topic':
                $topic = Discussion::where('id', $request->input('id'));
                $topic->where('status', $request->input('status', 'active'))
                    ->select('res_id')->first();
                if (! $topic) {
                    return $this->error('无效的id');
                }
                $table = Discussion::where('res_id', $topic->res_id);
                $activeNumber = Discussion::where('res_id', $topic->res_id)
                    ->where('status', 'active')->count();
                $closeNumber = Discussion::where('res_id', $topic->res_id)
                    ->where('status', 'close')->count();
                $table->where('status', $request->input('status', 'active'))
                    ->where('parent', null);
                break;
            case 'question':
                /**
                 * 禁止：
                 * 未注册用户看到任何人发表的discussion
                 * basic用户看到别人在别人channel发表的discussion
                 */
                if (! $user && $request->input('type') === 'discussion') {
                    return $this->ok([
                        'rows' => [],
                        'count' => 0,
                        'active' => 0,
                        'close' => 0,
                        'can_create' => false,
                        'can_reply' => false,
                    ]);
                }
                $resType = $request->input('res_type');
                if ($user) {
                    switch ($resType) {
                        case 'sentence':
                            // code...
                            break;
                        case 'wbw':
                            $block_uid = Wbw::where('uid', $request->input('id'))->value('block_uid');
                            if ($block_uid) {
                                $channelId = WbwBlock::where('uid', $block_uid)->value('channel_uid');
                                if ($channelId) {
                                    $canEdit = ChannelApi::userCanEdit($user['user_uid'], $channelId);
                                }
                            }
                            break;
                        default:
                            // code...
                            break;
                    }
                }

                $resId = [$request->input('id')];
                if (! empty($request->input('course'))) {
                    //
                    /**
                     * 如果res id 是答案，获取学员提问
                     * 如果是学员
                     */
                    // 获取学员提问
                    // 获取学员channel
                    if ($request->input('show_student') === 'true') {
                        $channelsId = CourseApi::getStudentChannels($request->input('course'));
                        switch ($resType) {
                            case 'wbw':
                                // 获取答案单词编号
                                $wbwWord = Wbw::where('uid', $request->input('id'))
                                    ->first();
                                $wbwId = WbwSentenceController::getWbwIdByChannels(
                                    $channelsId,
                                    $wbwWord->book_id,
                                    $wbwWord->paragraph,
                                    $wbwWord->wid
                                );
                                $resId = array_merge($resId, $wbwId);
                                break;
                            case 'sentence':
                                break;
                        }
                    }
                }
                $table = Discussion::whereIn('res_id', $resId)
                    ->where('type', $request->input('type', 'discussion'))
                    ->where('status', $request->input('status', 'active'))
                    ->where('parent', null);
                if ($request->input('type') === 'discussion') {
                    if (
                        isset($userInfo) &&
                        isset($userInfo['roles']) &&
                        in_array('basic', $userInfo['roles'])
                    ) {
                        if (isset($canEdit) && $canEdit === true) {
                        } else {
                            $table = $table->where('editor_uid', $userInfo['id']);
                        }
                    }
                }
                $activeNumber = Discussion::whereIn('res_id', $resId)
                    ->where('parent', null)
                    ->where('type', $request->input('type', 'discussion'))
                    ->where('status', 'active')->count();
                $closeNumber = Discussion::whereIn('res_id', $resId)
                    ->where('parent', null)
                    ->where('type', $request->input('type', 'discussion'))
                    ->where('status', 'close')->count();
                break;
            case 'answer':
                $table = Discussion::where('parent', $request->input('id'));
                $activeNumber = Discussion::where('parent', $request->input('id'))
                    ->where('status', 'active')->count();
                $closeNumber = Discussion::where('parent', $request->input('id'))
                    ->where('status', 'close')->count();
                break;
            case 'res_id':
                /**
                 * 先获取顶级节点
                 * 需要确定用户身份，manager查看全部topic 普通用户只显示自己提交的topic
                 */
                $roots = Discussion::where('res_id', $request->input('id'))
                    ->where('type', $request->input('type', 'discussion'))
                    ->whereIn('status', explode(',', $request->input('status', 'active')))
                    ->where('parent', null)
                    ->select('id')
                    ->get();

                $table = Discussion::where(function ($query) use ($roots) {
                    $query->whereIn('id', $roots)
                        ->orWhereIn('parent', $roots);
                });
                $activeNumber = Discussion::where('res_id', $request->input('id'))
                    ->where('type', $request->input('type', 'discussion'))
                    ->where('status', 'active')->count();
                $closeNumber = Discussion::where('res_id', $request->input('id'))
                    ->where('type', $request->input('type', 'discussion'))
                    ->where('status', 'close')->count();
                break;
            case 'topic-by-user':
                /**
                 * 某用户发表的全部topic
                 */
                if (! $user) {
                    return $this->error('', 403, 403);
                }
                $table = Discussion::where('editor_uid', $user['user_uid'])
                    ->where('type', $request->input('type', 'discussion'))
                    ->whereIn('status', explode(',', $request->input('status', 'active')))
                    ->where('parent', null);
                $activeNumber = Discussion::where('editor_uid', $user['user_uid'])
                    ->where('parent', null)
                    ->where('type', $request->input('type', 'discussion'))
                    ->where('status', 'active')->count();
                $closeNumber = Discussion::where('editor_uid', $user['user_uid'])
                    ->where('parent', null)
                    ->where('type', $request->input('type', 'discussion'))
                    ->where('status', 'close')->count();
                break;
            case 'all':
                $table = Discussion::where('parent', null);
                $activeNumber = Discussion::where('parent', null)
                    ->where('status', 'active')->count();
                $closeNumber = Discussion::where('parent', null)
                    ->where('status', 'close')->count();
                break;
        }
        if (! empty($search)) {
            $table = $table->where('title', 'like', $search.'%');
        }
        $count = $table->count();

        $table = $table->orderBy($request->input('order', 'created_at'), $request->input('dir', 'desc'));
        $table = $table->skip($request->input('offset', 0))
            ->take($request->input('limit', 100));

        $result = $table->get();

        $can_create = false;
        $can_reply = false;
        $user = AuthService::current($request);

        switch ($request->input('type', 'discussion')) {
            case 'qa':
                switch ($request->input('res_type')) {
                    case 'article':
                        if ($user && ArticleController::userCanEditId($user['user_uid'], $request->input('id'))) {
                            $can_create = true;
                            $can_reply = true;
                        }
                        break;
                }
                break;
            case 'help':
                switch ($request->input('res_type')) {
                    case 'article':
                        if ($user) {
                            $can_reply = true;
                            if (ArticleController::userCanEditId($user['user_uid'], $request->input('id'))) {
                                $can_create = true;
                            }
                        }
                        break;
                }
                break;
            case 'discussion':
                if ($user) {
                    $can_create = true;
                    $can_reply = true;
                }
                break;
        }

        return $this->ok([
            'rows' => DiscussionResource::collection($result),
            'count' => $count,
            'active' => $activeNumber,
            'close' => $closeNumber,
            'can_create' => $can_create,
            'can_reply' => $can_reply,
        ]);
    }

    public function discussion_tree(Request $request)
    {
        $output = [];
        $sentences = $request->input('data');
        foreach ($sentences as $key => $sentence) {
            // 先查句子信息
            $sentInfo = Sentence::where('book_id', $sentence['book'])
                ->where('paragraph', $sentence['paragraph'])
                ->where('word_start', $sentence['word_start'])
                ->where('word_end', $sentence['word_end'])
                ->where('channel_uid', $sentence['channel_id'])
                ->first();
            if ($sentInfo) {
                $sentPr = Discussion::where('res_id', $sentInfo['uid'])
                    ->whereNull('parent')
                    ->select('title', 'children_count', 'editor_uid')
                    ->orderBy('created_at', 'desc')->get();
                if (count($sentPr) > 0) {
                    $output[] = [
                        'sentence' => [
                            'book' => $sentInfo->book_id,
                            'paragraph' => $sentInfo->paragraph,
                            'word_start' => $sentInfo->word_start,
                            'word_end' => $sentInfo->word_end,
                            'channel_id' => $sentInfo->channel_uid,
                            'content' => $sentInfo->content,
                            'pr_count' => count($sentPr),
                        ],
                        'pr' => $sentPr,
                    ];
                }
            }
        }

        return $this->ok(['rows' => $output, 'count' => count($output)]);
    }

    /**
     * Store a newly created resource in storage.
     *
     * @return Response
     */
    public function store(Request $request)
    {
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), [401], 401);
        }
        //
        // validate
        // read more on validation at http://laravel.com/docs/validation

        if ($request->has('parent')) {
            $rules = [];
            $parentInfo = Discussion::find($request->input('parent'));
            if (! $parentInfo) {
                return $this->error('no record');
            }
        } else {
            $rules = [
                'res_id' => 'required',
                'res_type' => 'required',
                'title' => 'required',
            ];
        }

        $validated = $request->validate($rules);

        $discussion = new Discussion;
        if ($request->has('parent')) {
            $discussion->res_id = $parentInfo->res_id;
            $discussion->res_type = $parentInfo->res_type;
        } else {
            $discussion->res_id = $request->input('res_id');
            $discussion->res_type = $request->input('res_type');
        }
        $discussion->type = $request->input('type', 'discussion');
        $discussion->tpl_id = $request->input('tpl_id');
        $discussion->title = $request->input('title', null);
        $discussion->content = $request->input('content', null);
        $discussion->content_type = $request->input('content_type', 'markdown');
        $discussion->parent = $request->input('parent', null);
        $discussion->editor_uid = $user['user_uid'];
        $discussion->save();
        // 更新parent children_count
        if ($request->has('parent')) {
            $parentInfo->increment('children_count', 1);
            $parentInfo->save();
        }
        if ($request->input('notification', true)) {
            Mq::publish('discussion', new DiscussionResource($discussion));
        }

        return $this->ok(new DiscussionResource($discussion));
    }

    /**
     * Display the specified resource.
     *
     * @return Response
     */
    public function show(Discussion $discussion)
    {
        //
        return $this->ok(new DiscussionResource($discussion));
    }

    /**
     * 获取discussion 锚点的数据。以句子为最小单位，逐词解析也要显示单词所在的句子
     *
     * @param  string  $id
     * @return Response
     */
    public function anchor($id)
    {
        //
        $discussion = Discussion::find($id);
        $content = '';
        switch ($discussion->res_type) {
            case 'wbw':
                // 从逐词解析表获取逐词解析数据
                $wbw = Wbw::where('uid', $discussion->res_id)->first();
                if (! $wbw) {
                    return $this->error('no wbw data');
                }
                $wbwBlock = WbwBlock::where('uid', $wbw->block_uid)->first();
                if (! $wbwBlock) {
                    return $this->error('no wbwBlock data');
                }
                $sent = PaliSentence::where('book', $wbw->book_id)
                    ->where('paragraph', $wbw->paragraph)
                    ->where('word_begin', '<=', $wbw->wid)
                    ->where('word_end', '>=', $wbw->wid)
                    ->first();
                if (! $sent) {
                    return $this->error('no sent data');
                }
                $sentId = "{$sent['book']}-{$sent['paragraph']}-{$sent['word_begin']}-{$sent['word_end']}";
                $channel = $wbwBlock->channel_uid;
                $content = MdRender::render('{{'.$sentId.'}}', [$channel]);
                break;

            default:
                // code...
                break;
        }

        return $this->ok($content);
    }

    /**
     * Update the specified resource in storage.
     *
     * @return Response
     */
    public function update(Request $request, Discussion $discussion)
    {
        //
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), [403], 403);
        }
        //
        $isManager = false;
        $isResManager = false;
        if ($discussion->editor_uid === $user['user_uid']) {
            $isManager = true;
        } else {
            // 查看是否是资源拥有者
            if ($discussion->res_type === 'sentence') {
                $res = Sentence::find($discussion->res_id);
                if ($res) {
                    $channelId = $res->channel_uid;
                }
            } elseif ($discussion->res_type === 'wbw') {
                $res = Wbw::where('uid', $discussion->res_id)->first();
                if ($res) {
                    $block = WbwBlock::where('uid', $res->block_uid)->first();
                    if ($block) {
                        $channelId = $block->channel_uid;
                    }
                }
            }
            if (isset($channelId)) {
                $channel = Channel::find($channelId);
                if ($channel) {
                    $isResManager = ChannelApi::userCanEdit($user['user_uid'], $channelId);
                }
            }
        }
        if (! $isManager && ! $isResManager) {
            return $this->error(__('auth.failed'), [403], 403);
        }

        $discussion->title = $request->input('title', null);
        $discussion->content = $request->input('content', null);
        $discussion->status = $request->input('status', 'active');
        if ($request->has('type')) {
            $discussion->type = $request->input('type');
        }
        // $discussion->editor_uid = $user['user_uid'];
        $discussion->save();

        return $this->ok(new DiscussionResource($discussion));
    }

    /**
     * Remove the specified resource from storage.
     *
     * @return Response
     */
    public function destroy(Request $request, Discussion $discussion)
    {
        //
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), [401], 401);
        }
        // TODO 其他有权限的人也可以删除
        if ($discussion->editor_uid !== $user['user_uid']) {
            return $this->error(__('auth.failed'), [403], 403);
        }
        $delete = $discussion->delete();

        return $this->ok($delete);
    }
}