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

<?php

namespace App\Http\Controllers;

use App\Http\Api\Mq;
use App\Http\Resources\SentPrResource;
use App\Models\Channel;
use App\Models\Notification;
use App\Models\Sentence;
use App\Models\SentPr;
use App\Services\AuthService;
use Illuminate\Http\Request;
use Illuminate\Http\Response;
use Illuminate\Support\Str;

class SentPrController extends Controller
{
    /**
     * Display a listing of the resource.
     *
     * @return Response
     */
    public function index(Request $request)
    {
        //
        switch ($request->input('view')) {
            case 'sent-info':
                $table = SentPr::where('book_id', $request->input('book'))
                    ->where('paragraph', $request->input('para'))
                    ->where('word_start', $request->input('start'))
                    ->where('word_end', $request->input('end'))
                    ->where('channel_uid', $request->input('channel'));
                $all_count = $table->count();
                $result = $table->orderBy('created_at', 'desc')->get();

                break;
        }
        if ($result) {
            // 修改notification 已读状态
            $user = AuthService::current($request);
            if ($user) {
                $id = [];
                foreach ($result as $key => $row) {
                    $id[] = $row->uid;
                }
                Notification::whereIn('res_id', $id)
                    ->where('to', $user['user_uid'])
                    ->update(['status' => 'read']);
            }

            return $this->ok([
                'rows' => SentPrResource::collection($result),
                'count' => $all_count,
            ]);
        } else {
            return $this->error('no data');
        }
    }

    public function pr_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();
            $sentPr = SentPr::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'])
                ->select('content', 'editor_uid')
                ->orderBy('created_at', 'desc')->get();
            if (count($sentPr) > 0) {
                if ($sentInfo) {
                    $content = $sentInfo->content;
                } else {
                    $content = 'null';
                }
                $output[] = [
                    'sentence' => [
                        'book' => $sentence['book'],
                        'paragraph' => $sentence['paragraph'],
                        'word_start' => $sentence['word_start'],
                        'word_end' => $sentence['word_end'],
                        'channel_id' => $sentence['channel_id'],
                        'content' => $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);
        }
        $user_uid = $user['user_uid'];

        $data = $request->all();

        // 查询是否存在
        // 同样的内容只能提交一次
        $exists = SentPr::where('book_id', $data['book'])
            ->where('paragraph', $data['para'])
            ->where('word_start', $data['begin'])
            ->where('word_end', $data['end'])
            ->where('content', $data['text'])
            ->where('channel_uid', $data['channel'])
            ->exists();
        if ($exists) {
            return $this->error('已经存在同样的修改建议', 200, 200);
        }

        // 不存在，新建
        $new = new SentPr;
        $new->id = app('snowflake')->id();
        $new->uid = Str::uuid();
        $new->book_id = $data['book'];
        $new->paragraph = $data['para'];
        $new->word_start = $data['begin'];
        $new->word_end = $data['end'];
        $new->channel_uid = $data['channel'];
        $new->editor_uid = $user_uid;
        $new->content = $data['text'];
        $new->language = Channel::where('uid', $data['channel'])->value('lang');
        $new->status = 1; // 未处理状态
        $new->strlen = mb_strlen($data['text'], 'UTF-8');
        $new->create_time = time() * 1000;
        $new->modify_time = time() * 1000;
        $new->save();

        $suggestionData = [
            'data' => new SentPrResource($new),
            'token' => AuthService::getToken($request),
            'notification' => $request->input('notification', true),
            'webhook' => $request->input('webhook', true),
        ];
        Mq::publish(
            'suggestion',
            $suggestionData
        );

        $robotMessageOk = true;
        $webHookMessage = '';

        // 同时返回此句子pr数量
        $info['book_id'] = $data['book'];
        $info['paragraph'] = $data['para'];
        $info['word_start'] = $data['begin'];
        $info['word_end'] = $data['end'];
        $info['channel_uid'] = $data['channel'];
        $count = SentPr::where('book_id', $data['book'])
            ->where('paragraph', $data['para'])
            ->where('word_start', $data['begin'])
            ->where('word_end', $data['end'])
            ->where('channel_uid', $data['channel'])
            ->count();

        return $this->ok(['new' => $info, 'count' => $count, 'webhook' => ['message' => $webHookMessage, 'ok' => $robotMessageOk]]);
    }

    /**
     * Display the specified resource.
     *
     * @return Response
     */
    public function show(Request $request, string $uid)
    {
        //

        $pr = SentPr::where('uid', $uid)->first();
        if (! $pr) {
            return $this->error('no data', 404, 404);
        }
        // 修改notification 已读状态
        $user = AuthService::current($request);
        if ($user) {
            Notification::where('res_id', $uid)
                ->where('to', $user['user_uid'])
                ->update(['status' => 'read']);
        }

        return $this->ok(new SentPrResource($pr));
    }

    /**
     * Update the specified resource in storage.
     *
     * @param  SentPr  $sentPr
     * @return Response
     */
    public function update(Request $request, string $id)
    {
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), 401, 401);
        }

        $sentPr = SentPr::find($id);
        if (! $sentPr) {
            return $this->error('no res');
        }
        if ($sentPr->editor_uid !== $user['user_uid']) {
            return $this->error('not power', 403, 403);
        }
        $sentPr->content = $request->input('text');
        $sentPr->modify_time = time() * 1000;
        $sentPr->save();

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

    /**
     * Remove the specified resource from storage.
     *
     * @return Response
     */
    public function destroy(Request $request, string $id)
    {
        //
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), 401, 401);
        }
        $old = SentPr::where('id', $id)->first();
        if (! $old) {
            return $this->error('no res');
        }
        // 鉴权
        if ($old->editor_uid !== $user['user_uid']) {
            return $this->error(__('auth.failed'), 403, 403);
        }
        $result = SentPr::where('id', $id)
            ->where('editor_uid', $user['user_uid'])
            ->delete();
        if ($result > 0) {
            // 同时返回此句子pr数量
            $count = SentPr::where('book_id', $old->book_id)
                ->where('paragraph', $old->paragraph)
                ->where('word_start', $old->word_start)
                ->where('word_end', $old->word_end)
                ->where('channel_uid', $old->channel_uid)
                ->count();

            return $this->ok($count);
        } else {
            return $this->error('not power', 403, 403);
        }
    }
}