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

<?php

namespace App\Http\Controllers;

use Illuminate\Support\Facades\Log;
use Illuminate\Http\Request;

use App\Models\Discussion;
use App\Models\Wbw;
use App\Models\WbwBlock;
use App\Models\PaliSentence;
use App\Models\Sentence;
use App\Models\Channel;
use App\Http\Controllers\ArticleController;
use App\Http\Controllers\WbwSentenceController;
use App\Http\Resources\DiscussionResource;
use App\Http\Api\MdRender;
use App\Http\Api\AuthApi;
use App\Http\Api\Mq;
use App\Http\Api\UserApi;
use App\Http\Api\ChannelApi;
use App\Http\Api\CourseApi;

class DiscussionController extends Controller
{
    /**
     * Display a listing of the resource.
     *
     * @return \Illuminate\Http\Response
     */
    public function index(Request $request)
    {
        //
        $user = AuthApi::current($request);
        if($user){
            $userInfo = UserApi::getByUuid($user['user_uid']);
        }
		switch ($request->get('view')) {
            case 'question-by-topic':
                $topic = Discussion::where('id',$request->get('id'));
                $topic->where('status',$request->get('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->get('status','active'))
                                    ->where('parent',null);
                break;
            case 'question':
                /**
                 * 禁止：
                 * 未注册用户看到任何人发表的discussion
                 * basic用户看到别人在别人channel发表的discussion
                 *
                 */
                if(!$user && $request->get('type')==='discussion'){
                    return $this->ok([
                        "rows" => [],
                        "count" => 0,
                        'active' => 0,
                        'close' => 0,
                        'can_create' => false,
                        'can_reply' => false,
                        ]);
                }
                $resType = $request->get('res_type');
                if($user){
                    switch ($resType) {
                        case 'sentence':
                            # code...
                            break;
                        case 'wbw':
                            $block_uid = Wbw::where('uid',$request->get('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->get('id')];
                if(!empty($request->get('course'))){
                    //
                    /**
                     * 如果res id 是答案，获取学员提问
                     * 如果是学员
                     */
                    //获取学员提问
                    //获取学员channel
                    if($request->get('show_student') === 'true'){
                        $channelsId = CourseApi::getStudentChannels($request->get('course'));
                        switch ($resType) {
                            case 'wbw':
                                //获取答案单词编号
                                $wbwWord = Wbw::where('uid',$request->get('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->get('type','discussion'))
                                    ->where('status',$request->get('status','active'))
                                    ->where('parent',null);
                if($request->get('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->get('type','discussion'))
                                            ->where('status','active')->count();
                $closeNumber = Discussion::whereIn('res_id',$resId)
                                            ->where('parent',null)
                                            ->where('type', $request->get('type','discussion'))
                                            ->where('status','close')->count();
                break;
            case 'answer':
                $table = Discussion::where('parent',$request->get('id'));
                $activeNumber = Discussion::where('parent',$request->get('id'))
                                        ->where('status','active')->count();
                $closeNumber = Discussion::where('parent',$request->get('id'))
                                        ->where('status','close')->count();
                break;
            case 'res_id':
                /**
                 * 先获取顶级节点
                 * 需要确定用户身份，manager查看全部topic 普通用户只显示自己提交的topic
                 */
                $roots = Discussion::where('res_id',$request->get('id'))
                                    ->where('type', $request->get('type','discussion'))
                                    ->whereIn('status',explode(',',$request->get('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->get('id'))
                                            ->where('type', $request->get('type','discussion'))
                                            ->where('status','active')->count();
                $closeNumber = Discussion::where('res_id',$request->get('id'))
                                            ->where('type', $request->get('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->get('type','discussion'))
                                    ->whereIn('status',explode(',',$request->get('status','active')) )
                                    ->where('parent',null);
                $activeNumber = Discussion::where('editor_uid',$user['user_uid'])
                                            ->where('parent',null)
                                            ->where('type', $request->get('type','discussion'))
                                            ->where('status','active')->count();
                $closeNumber = Discussion::where('editor_uid',$user['user_uid'])
                                            ->where('parent',null)
                                            ->where('type', $request->get('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->get('order','created_at'),$request->get('dir','desc'));
        $table = $table->skip($request->get("offset",0))
              ->take($request->get('limit',1000));

        $result = $table->get();

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

        switch ($request->get('type','discussion')) {
            case 'qa':
                switch ($request->get('res_type')) {
                    case 'article':
                        if($user && ArticleController::userCanEditId($user['user_uid'],$request->get('id'))){
                            $can_create = true;
                            $can_reply = true;
                        }
                        break;
                }
                break;
            case 'help':
                switch ($request->get('res_type')) {
                    case 'article':
                        if($user){
                            $can_reply = true;
                            if(ArticleController::userCanEditId($user['user_uid'],$request->get('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->get("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.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\Response
     */
    public function store(Request $request)
    {
        $user = AuthApi::current($request);
        if(!$user){
            Log::error('discussion store auth failed {request}',['request'=>$request]);
            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->get('parent'));
            if(!$parentInfo){
                return $this->error('no record');
            }
        }else{
            $rules = array(
            '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->get('res_id');
            $discussion->res_type = $request->get('res_type');
        }
        $discussion->type = $request->get('type','discussion');
        $discussion->tpl_id = $request->get('tpl_id');
        $discussion->title = $request->get('title',null);
        $discussion->content = $request->get('content',null);
        $discussion->content_type = $request->get('content_type',"markdown");
        $discussion->parent = $request->get('parent',null);
        $discussion->editor_uid = $user['user_uid'];
        $discussion->save();
        //更新parent children_count
        if($request->has('parent')){
            $parentInfo->increment('children_count',1);
            $parentInfo->save();
        }
        Mq::publish('discussion',new DiscussionResource($discussion));

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

    /**
     * Display the specified resource.
     *
     * @param  \App\Models\Discussion  $discussion
     * @return \Illuminate\Http\Response
     */
    public function show(Discussion $discussion)
    {
        //
        return $this->ok(new DiscussionResource($discussion));

    }

        /**
     * 获取discussion 锚点的数据。以句子为最小单位，逐词解析也要显示单词所在的句子
     *
     * @param  string  $id
     * @return \Illuminate\Http\Response
     */
    public function anchor($id)
    {
        //
        $discussion = Discussion::find($id);
        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]);
                return $this->ok($content);
                break;

            default:
                # code...
                break;
        }
        return $this->ok();

    }
    /**
     * Update the specified resource in storage.
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  \App\Models\Discussion  $discussion
     * @return \Illuminate\Http\Response
     */
    public function update(Request $request, Discussion $discussion)
    {
        //
        $user = AuthApi::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;
                }
            }else if($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->get('title',null);
        $discussion->content = $request->get('content',null);
        $discussion->status = $request->get('status','active');
        if($request->has('type')){
            $discussion->type = $request->get('type');
        }
        //$discussion->editor_uid = $user['user_uid'];
        $discussion->save();
        return $this->ok(new DiscussionResource($discussion));

    }

    /**
     * Remove the specified resource from storage.
     *
     * @param  \App\Models\Discussion  $discussion
     * @return \Illuminate\Http\Response
     */
    public function destroy(Request $request,Discussion $discussion)
    {
        //
        $user = AuthApi::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);
    }
}