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

<?php

namespace App\Http\Controllers;

use App\Http\Api\ChannelApi;
use App\Http\Api\PaliTextApi;
use App\Http\Api\ShareApi;
use App\Http\Api\StudioApi;
use App\Http\Resources\ChannelResource;
use App\Models\Channel;
use App\Models\CustomBook;
use App\Models\DhammaTerm;
use App\Models\PaliSentence;
use App\Models\Sentence;
use App\Models\WbwBlock;
use App\Services\AuthService;
use Illuminate\Http\Request;
use Illuminate\Http\Response;
use Illuminate\Support\Arr;
use Illuminate\Support\Facades\DB;

class ChannelController extends Controller
{
    /**
     * Display a listing of the resource.
     *
     * @return Response
     */
    public function index(Request $request)
    {
        //
        $result = false;
        // $chapter 只有 view=user-in-chapter 会赋值，下面按进度取数时要先判断
        $chapter = null;
        $indexCol = [
            'channels.uid',
            'name',
            'channels.summary',
            'type',
            'owner_uid',
            'channels.lang',
            'status',
            'is_system',
            'channels.updated_at',
            'channels.created_at',
        ];
        if ($request->has('book')) {
            $indexCol[] = 'progress_chapters.progress';
        }
        switch ($request->input('view')) {
            case 'public':
                $table = Channel::select($indexCol)
                    ->where('status', 30);
                break;
            case 'studio':
                // 获取studio内所有channel
                $user = AuthService::current($request);
                if (! $user) {
                    return $this->error(__('auth.failed'));
                }
                // 判断当前用户是否有指定的studio的权限
                $studioId = StudioApi::getIdByName($request->input('name'));
                if (! StudioApi::userCanList($user['user_uid'], $studioId)) {
                    return $this->error(__('auth.failed'), 403, 403);
                }

                $table = Channel::select($indexCol);
                if ($request->input('view2', 'my') === 'my') {
                    $table = $table->where('owner_uid', $studioId);
                } else {
                    // 协作
                    $resList = ShareApi::getResList($studioId, 2);
                    $resId = [];
                    foreach ($resList as $res) {
                        $resId[] = $res['res_id'];
                    }
                    $table = $table->whereIn('channels.uid', $resId);
                    if ($request->input('collaborator', 'all') !== 'all') {
                        $table = $table->where('owner_uid', $request->input('collaborator'));
                    } else {
                        $table = $table->where('owner_uid', '<>', $studioId);
                    }
                }
                break;
            case 'studio-all':
                /**
                 * studio 的和协作的
                 */
                // 获取user所有有权限的channel列表
                $user = AuthService::current($request);
                if (! $user) {
                    return $this->error(__('auth.failed'));
                }
                // 判断当前用户是否有指定的studio的权限
                if ($user['user_uid'] !== StudioApi::getIdByName($request->input('name'))) {
                    return $this->error(__('auth.failed'));
                }
                $channelById = [];
                $channelId = [];
                // 获取共享channel
                $allSharedChannels = ShareApi::getResList($user['user_uid'], 2);
                foreach ($allSharedChannels as $key => $value) {
                    // code...
                    $channelId[] = $value['res_id'];
                    $channelById[$value['res_id']] = $value;
                }
                $table = Channel::select($indexCol)
                    ->whereIn('uid', $channelId)
                    ->orWhere('owner_uid', $user['user_uid']);
                break;
            case 'user-edit':
                /**
                 * 某用户有编辑权限的
                 */
                // 获取user所有有权限的channel列表
                $user = AuthService::current($request);
                if (! $user) {
                    return $this->error(__('auth.failed'));
                }
                $channelById = [];
                $channelId = [];
                // 获取共享channel
                $allSharedChannels = ShareApi::getResList($user['user_uid'], 2);
                foreach ($allSharedChannels as $key => $value) {
                    // code...
                    if ($value['power'] >= 20) {
                        $channelId[] = $value['res_id'];
                        $channelById[$value['res_id']] = $value;
                    }
                }
                $table = Channel::select($indexCol)
                    ->whereIn('uid', $channelId)
                    ->orWhere('owner_uid', $user['user_uid']);
                break;
            case 'user-in-chapter':
                // 获取user 在某章节 所有有权限的channel列表
                $user = AuthService::current($request);
                if (! $user) {
                    return $this->error(__('auth.failed'));
                }
                $channelById = [];
                $channelId = [];
                // 获取共享channel
                $allSharedChannels = ShareApi::getResList($user['user_uid'], 2);
                foreach ($allSharedChannels as $key => $value) {
                    // code...
                    $channelId[] = $value['res_id'];
                    $channelById[$value['res_id']] = $value;
                }
                // 获取全网公开channel
                $chapter = PaliTextApi::getChapterStartEnd($request->input('book'), $request->input('para'));
                $publicChannelsWithContent = Sentence::where('book_id', $request->input('book'))
                    ->whereBetween('paragraph', $chapter)
                    ->where('strlen', '>', 0)
                    ->where('status', 30)
                    ->groupBy('channel_uid')
                    ->select('channel_uid')
                    ->get();
                foreach ($publicChannelsWithContent as $key => $value) {
                    // code...
                    $value['res_id'] = $value->channel_uid;
                    $value['power'] = 10;
                    $value['type'] = 2;
                    if (! isset($channelById[$value['res_id']])) {
                        $channelId[] = $value['res_id'];
                        $channelById[$value['res_id']] = $value;
                    }
                }
                $table = Channel::select($indexCol)
                    ->whereIn('uid', $channelId)
                    ->orWhere('owner_uid', $user['user_uid']);
                break;
            case 'system':
                $table = Channel::select($indexCol)
                    ->where('owner_uid', config('mint.admin.root_uuid'));
                break;
            case 'paragraphs':
                $channels = Sentence::where('book_id', $request->input('book_id'))
                    ->whereIn('paragraph', explode(',', $request->input('para')))
                    ->groupBy('channel_uid')->select('channel_uid')->get();
                if (count($channels) > 0) {
                    $channelIds = array_map(fn ($item) => $item['channel_uid'], $channels->toArray());
                    $table = Channel::select($indexCol)
                        ->whereIn('uid', $channelIds);
                } else {
                    $table = Channel::select($indexCol)->whereIsNull('uid');
                }
                break;
            case 'id':
                $table = Channel::select($indexCol)
                    ->whereIn('uid', explode(',', $request->input('id')));
        }

        if ($request->has('book')) {
            if ($request->input('view') === 'public') {
                $table = $table->leftJoin('progress_chapters', 'channels.uid', '=', 'progress_chapters.channel_id')
                    ->where('progress_chapters.book', $request->input('book'))
                    ->where('progress_chapters.para', $request->input('paragraph'));
            } else {
                $table = $table->leftJoin('progress_chapters', function ($join) use ($request) {
                    $join->on('channels.uid', '=', 'progress_chapters.channel_id')
                        ->where('progress_chapters.book', $request->input('book'))
                        ->where('progress_chapters.para', $request->input('paragraph')); // 条件写在这里！
                });
            }
        }
        // 处理搜索
        if (! empty($request->input('search'))) {
            $table = $table->where('name', 'like', '%'.$request->input('search').'%');
        }
        if ($request->has('type')) {
            $table = $table->where('type', $request->input('type'));
        }
        if ($request->has('updated_at')) {
            $table = $table->where('updated_at', '>', $request->input('updated_at'));
        }
        if ($request->has('created_at')) {
            $table = $table->where('created_at', '>', $request->input('created_at'));
        }
        // 获取记录总条数
        $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', 200));
        // 获取数据
        $result = $table->get();
        // TODO 将下面代码转移到resource
        if ($result) {
            if ($request->has('progress') && $chapter) {
                // 获取进度
                // 获取单句长度
                $sentLen = PaliSentence::where('book', $request->input('book'))
                    ->whereBetween('paragraph', $chapter)
                    ->orderBy('word_begin')
                    ->select(['book', 'paragraph', 'word_begin', 'word_end', 'length'])
                    ->get();
            }
            foreach ($result as $key => $value) {
                if ($request->has('progress') && $chapter) {
                    // 获取进度
                    $finalTable = Sentence::where('book_id', $request->input('book'))
                        ->whereBetween('paragraph', $chapter)
                        ->where('channel_uid', $value->uid)
                        ->where('strlen', '>', 0)
                        ->select(['strlen', 'book_id', 'paragraph', 'word_start', 'word_end']);
                    if ($finalTable->count() > 0) {
                        $finished = $finalTable->get();
                        $final = [];
                        foreach ($sentLen as $sent) {
                            // code...
                            $first = Arr::first($finished, function ($value, $key) use ($sent) {
                                return $value->book_id == $sent->book &&
                                    $value->paragraph == $sent->paragraph &&
                                    $value->word_start == $sent->word_begin &&
                                    $value->word_end == $sent->word_end;
                            });
                            $final[] = [$sent->length, $first ? true : false];
                        }
                        $value['final'] = $final;
                    }
                }
                // 角色
                if (isset($user['user_uid'])) {
                    if ($value->owner_uid === $user['user_uid']) {
                        $value['role'] = 'owner';
                    } else {
                        if (isset($channelById) && isset($channelById[$value->uid])) {
                            switch ($channelById[$value->uid]['power']) {
                                case 10:
                                    // code...
                                    $value['role'] = 'member';
                                    break;
                                case 20:
                                    $value['role'] = 'editor';
                                    break;
                                case 30:
                                    $value['role'] = 'owner';
                                    break;
                                default:
                                    // code...
                                    $value['role'] = $channelById[$value->uid]['power'];
                                    break;
                            }
                        }
                    }
                }
                // 获取studio信息
                $value->studio = StudioApi::getById($value->owner_uid);
            }

            return $this->ok(['rows' => $result, 'count' => $count]);
        } else {
            return $this->ok(['rows' => [], 'count' => 0]);
        }
    }

    /**
     * 获取我的，和协作channel数量
     *
     * @return Response
     */
    public function showMyNumber(Request $request)
    {
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'));
        }
        // 判断当前用户是否有指定的studio的权限
        $studioId = StudioApi::getIdByName($request->input('studio'));
        if ($user['user_uid'] !== $studioId) {
            return $this->error(__('auth.failed'));
        }
        // 我的
        $my = Channel::where('owner_uid', $studioId)->count();
        // 协作
        $resList = ShareApi::getResList($studioId, 2);
        $resId = [];
        foreach ($resList as $res) {
            $resId[] = $res['res_id'];
        }
        $collaboration = Channel::whereIn('uid', $resId)->where('owner_uid', '<>', $studioId)->count();

        return $this->ok(['my' => $my, 'collaboration' => $collaboration]);
    }

    /**
     * 获取章节的进度
     *
     * @return Response
     */
    public function progress(Request $request)
    {
        $indexCol = ['uid', 'name', 'summary', 'type', 'owner_uid', 'lang', 'status', 'updated_at', 'created_at'];

        $sent = $request->input('sentence');
        $query = [];
        $queryWithChannel = [];
        $sentContainer = [];
        $sentLenContainer = [];

        $paliChannel = ChannelApi::getSysChannel('_System_Pali_VRI_');
        $customBookChannel = [];

        foreach ($sent as $value) {
            $ids = explode('-', $value);
            $idWithChannel = $ids;
            if (count($ids) === 4) {
                if ($ids[0] < 1000) {
                    $idWithChannel[] = $paliChannel;
                } else {
                    if (! isset($customBookChannel[$ids[0]])) {
                        $cbChannel = CustomBook::where('book_id', $ids[0])->value('channel_id');
                        if ($cbChannel) {
                            $customBookChannel[$ids[0]] = $cbChannel;
                        } else {
                            $customBookChannel[$ids[0]] = $paliChannel;
                        }
                    }
                    $idWithChannel[] = $customBookChannel[$ids[0]];
                }
                $sentContainer[$value] = false;
                $query[] = $ids;
                $queryWithChannel[] = $idWithChannel;
            }
        }
        // 获取单句长度
        if (count($query) > 0) {
            $table = Sentence::whereIns([
                'book_id',
                'paragraph',
                'word_start',
                'word_end',
                'channel_uid',
            ], $queryWithChannel)
                ->select(['book_id', 'paragraph', 'word_start', 'word_end', 'strlen']);
            $sentLen = $table->get();

            foreach ($sentLen as $value) {
                $strlen = $value->strlen;
                if (empty($strlen)) {
                    $strlen = 0;
                }
                $sentId = "{$value->book_id}-{$value->paragraph}-{$value->word_start}-{$value->word_end}";
                $sentLenContainer[$sentId] = $strlen;
            }
        }

        $channelById = [];
        $channelId = [];

        // 获取全网公开的有译文的channel
        if ($request->input('owner') === 'all' || $request->input('owner') === 'public') {
            if (count($query) > 0) {
                $fields = ['book_id', 'paragraph', 'word_start', 'word_end'];
                $publicChannelsWithContent = Sentence::whereIns($fields, $query)
                    ->where('strlen', '>', 0)
                    ->where('status', 30)
                    ->groupBy('channel_uid')
                    ->select('channel_uid')
                    ->get();
                foreach ($publicChannelsWithContent as $key => $value) {
                    // code...
                    $value['res_id'] = $value->channel_uid;
                    $value['power'] = 10;
                    $value['type'] = 2;
                    if (! isset($channelById[$value['res_id']])) {
                        $channelId[] = $value['res_id'];
                        $channelById[$value['res_id']] = $value;
                    }
                }
            }
        }

        // 获取 user 在某章节 所有有权限的 channel 列表
        $user = AuthService::current($request);
        if ($user !== false) {
            // 我自己的
            if ($request->input('owner') === 'all' || $request->input('owner') === 'my') {
                $my = Channel::select($indexCol)->where('owner_uid', $user['user_uid'])->get();
                foreach ($my as $key => $value) {
                    $channelId[] = $value->uid;
                    $channelById[$value->uid] = [
                        'res_id' => $value->uid,
                        'power' => 30,
                        'type' => 2,
                    ];
                }
            }

            // 获取共享channel
            if ($request->input('owner') === 'all' || $request->input('owner') === 'collaborator') {
                $allSharedChannels = ShareApi::getResList($user['user_uid'], 2);
                foreach ($allSharedChannels as $key => $value) {
                    // code...
                    if (! in_array($value['res_id'], $channelId)) {
                        $channelId[] = $value['res_id'];
                        $channelById[$value['res_id']] = $value;
                    }
                }
            }
        }

        // 所有有这些句子译文的channel
        if (count($query) > 0) {
            $allChannels = Sentence::whereIns(['book_id', 'paragraph', 'word_start', 'word_end'], $query)
                ->where('strlen', '>', 0)
                ->groupBy('channel_uid')
                ->select('channel_uid')
                ->get();
        }

        // 所有需要查询的channel
        $table = Channel::select(['uid', 'name', 'summary', 'type', 'owner_uid', 'lang', 'status', 'updated_at', 'created_at'])
            ->whereIn('uid', $channelId);
        if ($user !== false) {
            $table->orWhere('owner_uid', $user['user_uid']);
        }
        $result = $table->get();

        foreach ($result as $key => $value) {
            // 角色
            if ($user !== false && $value->owner_uid === $user['user_uid']) {
                $value['role'] = 'owner';
            } else {
                if (isset($channelById[$value->uid])) {
                    switch ($channelById[$value->uid]['power']) {
                        case 10:
                            // code...
                            $value['role'] = 'member';
                            break;
                        case 20:
                            $value['role'] = 'editor';
                            break;
                        case 30:
                            $value['role'] = 'owner';
                            break;
                        default:
                            // code...
                            $value['role'] = $channelById[$value->uid]['power'];
                            break;
                    }
                }
            }
            // 获取studio信息
            $result[$key]['studio'] = StudioApi::getById($value->owner_uid);

            // 获取进度
            if (count($query) > 0) {
                $currChannelId = $value->uid;
                $hasContent = Arr::first($allChannels, function ($value, $key) use ($currChannelId) {
                    return $value->channel_uid === $currChannelId;
                });
                if ($hasContent && count($query) > 0) {
                    $finalTable = Sentence::whereIns(['book_id', 'paragraph', 'word_start', 'word_end'], $query)
                        ->where('channel_uid', $currChannelId)
                        ->where('strlen', '>', 0)
                        ->select(['strlen', 'book_id', 'paragraph', 'word_start', 'word_end', 'created_at', 'updated_at']);
                    $created_at = time();
                    $edit_at = 0;
                    if ($finalTable->count() > 0) {
                        $finished = $finalTable->get();
                        $currChannel = [];
                        foreach ($finished as $rowFinish) {
                            $createTime = strtotime($rowFinish->created_at);
                            $updateTime = strtotime($rowFinish->updated_at);
                            if ($createTime < $created_at) {
                                $created_at = $createTime;
                            }
                            if ($updateTime > $edit_at) {
                                $edit_at = $updateTime;
                            }
                            $currChannel["{$rowFinish->book_id}-{$rowFinish->paragraph}-{$rowFinish->word_start}-{$rowFinish->word_end}"] = 1;
                        }
                        $final = [];
                        foreach ($sentContainer as $sentId => $rowSent) {
                            // code...
                            if (isset($currChannel[$sentId])) {
                                $final[] = [$sentLenContainer[$sentId], true];
                            } else {
                                $final[] = [$sentLenContainer[$sentId], false];
                            }
                        }
                        $result[$key]['final'] = $final;
                        $result[$key]['content_created_at'] = date('Y-m-d H:i:s', $created_at);
                        $result[$key]['content_updated_at'] = date('Y-m-d H:i:s', $edit_at);
                    }
                }
            }
        }

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

    /**
     * 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);
        }
        // 判断当前用户是否有指定的studio的权限
        $studioId = StudioApi::getIdByName($request->input('studio'));
        if (! StudioApi::userCanManage($user['user_uid'], $studioId)) {
            return $this->error(__('auth.failed'), 403, 403);
        }
        $studio = StudioApi::getById($studioId);
        // 查询是否重复
        if (Channel::where('name', $request->input('name'))
            ->where('owner_uid', $studioId)
            ->exists()
        ) {
            return $this->error(__('validation.exists', ['name']), 200, 200);
        }

        $channel = new Channel;
        $channel->id = app('snowflake')->id();
        $channel->name = $request->input('name');
        $channel->owner_uid = $studioId;
        $channel->type = $request->input('type');
        $channel->lang = $request->input('lang');
        $channel->editor_id = $user['user_id'];
        if (isset($studio['roles'])) {
            if (in_array('basic', $studio['roles'])) {
                $channel->status = 5;
            }
        }
        $channel->create_time = time() * 1000;
        $channel->modify_time = time() * 1000;
        $channel->save();

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

    /**
     * Display the specified resource.
     *
     * @param  int  $id
     * @return Response
     */
    public function show($id)
    {
        //
        $channel = Channel::find($id);
        if (! $channel) {
            return $this->error('no res');
        }
        $studio = StudioApi::getById($channel->owner_uid);
        $channel->studio = $studio;
        $channel->owner_info = ['nickname' => $studio['nickName'], 'username' => $studio['realName']];

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

    /**
     * Display the specified resource.
     *
     * @return Response
     */
    public function showByName(string $name)
    {
        //
        $indexCol = ['uid', 'name', 'summary', 'type', 'owner_uid', 'lang', 'is_system', 'status', 'updated_at', 'created_at'];
        $channel = Channel::where('name', $name)->select($indexCol)->first();
        if ($channel) {
            return $this->ok(new ChannelResource($channel));
        } else {
            return $this->error('no channel');
        }
    }

    /**
     * Update the specified resource in storage.
     *
     * @return Response
     */
    public function update(Request $request, Channel $channel)
    {
        // 鉴权
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), 401, 401);
        }
        if ($channel->is_system) {
            return $this->error('system channel', 403, 403);
        }
        if ($channel->owner_uid !== $user['user_uid']) {
            // 判断是否为协作
            $power = ShareApi::getResPower($user['user_uid'], $request->input('id'));
            if ($power < 30) {
                return $this->error(__('auth.failed'), 403, 403);
            }
        }
        $channel->name = $request->input('name');
        $channel->type = $request->input('type');
        $channel->summary = $request->input('summary');
        $channel->lang = $request->input('lang');
        $channel->status = $request->input('status');
        if ($request->has('source_type')) {
            $channel->source_type = $request->input('source_type');
        }
        if ($request->has('source_id')) {
            $channel->source_id = $request->input('source_id');
        }
        $channel->save();

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

    /**
     * patch the specified resource in storage.
     *
     * @return Response
     */
    public function patch(Request $request, Channel $channel)
    {
        // 鉴权
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), [], 401);
        }
        if ($channel->is_system) {
            return $this->error('system channel', 403, 403);
        }
        if ($channel->owner_uid !== $user['user_uid']) {
            // 判断是否为协作
            $power = ShareApi::getResPower($user['user_uid'], $request->input('id'));
            if ($power < 30) {
                return $this->error(__('auth.failed'), [], 403);
            }
        }
        if ($request->has('name')) {
            $channel->name = $request->input('name');
        }
        if ($request->has('type')) {
            $channel->type = $request->input('type');
        }
        if ($request->has('summary')) {
            $channel->summary = $request->input('summary');
        }
        if ($request->has('lang')) {
            $channel->lang = $request->input('lang');
        }
        if ($request->has('status')) {
            $channel->status = $request->input('status');
        }
        if ($request->has('config')) {
            $channel->config = $request->input('config');
        }
        $channel->save();

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

    /**
     * Remove the specified resource from storage.
     *
     * @return Response
     */
    public function destroy(Request $request, Channel $channel)
    {
        //
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'));
        }
        // 判断当前用户是否有指定的studio的权限
        if ($user['user_uid'] !== $channel->owner_uid) {
            return $this->error(__('auth.failed'));
        }
        // 查询其他资源
        if (Sentence::where('channel_uid', $channel->uid)->exists()) {
            return $this->error('译文有数据无法删除');
        }
        if (DhammaTerm::where('channal', $channel->uid)->exists()) {
            return $this->error('术语有数据无法删除');
        }
        if (WbwBlock::where('channel_uid', $channel->uid)->exists()) {
            return $this->error('逐词解析有数据无法删除');
        }
        $delete = 0;
        DB::transaction(function () use ($channel, $delete) {
            // TODO 删除相关资源
            $delete = $channel->delete();
        });

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