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

<?php

/**
 * 文章全文搜索
 */

namespace App\Http\Controllers;

use App\Models\Article;
use App\Models\ArticleCollection;
use Illuminate\Http\Request;
use Illuminate\Http\Response;
use Illuminate\Support\Facades\Http;
use Illuminate\Support\Facades\Log;

class ArticleFtsController extends Controller
{
    /**
     * Display a listing of the resource.
     * http://127.0.0.1:8000/api/v2/article-fts?id=df6c6609-6fc1-42d0-9ef1-535ef3e702c9&anthology=697c9169-cb9d-4a60-8848-92745e467bab&channesl=7fea264d-7a26-40f8-bef7-bc95102760fb
     *
     * @return Response
     */
    public function index(Request $request)
    {
        //
        $pageSize = 10;
        $pageCurrent = $request->input('from', 0);

        $articlesId = [];
        if (! empty($request->input('anthology'))) {
            // 子节点
            $node = ArticleCollection::where('article_id', $request->input('id'))
                ->where('collect_id', $request->input('anthology'))->first();
            if ($node) {
                $nodeList = ArticleCollection::where('collect_id', $request->input('anthology'))
                    ->where('id', '>=', (int) $node->id)
                    ->orderBy('id')
                    ->skip($request->input('from', 0))
                    ->get();
                $result = [];
                $count = 0;
                foreach ($nodeList as $curr) {
                    if ($count > 0 && $curr->level <= $node->level) {
                        break;
                    }
                    $result[] = $curr;
                }
                foreach ($result as $key => $value) {
                    $articlesId[] = $value->article_id;
                }
            }
        } else {
            $articlesId[] = $request->input('id');
        }
        $total = count($articlesId);
        $channels = explode(',', $request->input('channels'));
        $output = [];
        for ($i = $pageCurrent; $i < $pageCurrent + $pageSize; $i++) {
            if ($i >= $total) {
                break;
            }
            $curr = $articlesId[$i];
            foreach ($channels as $channel) {
                // code...
                $article = $this->fetch($curr, $channel);
                if ($article === false) {
                    Log::error('fetch fail');
                } else {
                    // code...
                    $content = $article['html'];
                    if (! empty($request->input('key'))) {
                        if (strpos($content, $request->input('key')) !== false) {
                            $output[] = $article;
                        }
                    }
                }
            }
        }

        return $this->ok([
            'rows' => $output,
            'page' => [
                'size' => $pageSize,
                'current' => $pageCurrent,
                'total' => $total,
            ],
        ]);
    }

    private function fetch($articleId, $channel, $token = null)
    {
        try {
            $api = config('mint.server.api.bamboo');
            $basicUrl = $api.'/v2/article/';
            $url = $basicUrl.$articleId;

            $urlParam = [
                'mode' => 'read',
                'format' => 'text',
                'channel' => $channel,
            ];
            if ($token) {
                $response = Http::withToken($this->option('token'))->get($url, $urlParam);
            } else {
                $response = Http::get($url, $urlParam);
            }

            if ($response->failed()) {
                Log::error('http request error'.$response->json('message'));

                return false;
            }
            if (! $response->json('ok')) {
                return false;
            }
            $article = $response->json('data');

            return $article;
        } catch (\Throwable $th) {
            // 处理请求过程中抛出的异常
            Log::error('fetch', ['error' => $th]);

            return false;
        }
    }

    /**
     * Store a newly created resource in storage.
     *
     * @return Response
     */
    public function store(Request $request)
    {
        //
    }

    /**
     * Display the specified resource.
     *
     * @param  int  $id
     * @return Response
     */
    public function show($id)
    {
        //
    }

    /**
     * Update the specified resource in storage.
     *
     * @param  int  $id
     * @return Response
     */
    public function update(Request $request, $id)
    {
        //
    }

    /**
     * Remove the specified resource from storage.
     *
     * @param  int  $id
     * @return Response
     */
    public function destroy($id)
    {
        //
    }
}