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

<?php

namespace App\Http\Controllers;

use App\Models\AccessToken;
use Illuminate\Http\Request;
use Illuminate\Support\Str;
use Firebase\JWT\JWT;
use Firebase\JWT\Key;
use Illuminate\Support\Facades\Log;
use App\Services\AuthService;
use App\Http\Api\ChannelApi;

class AccessTokenController extends Controller
{
    /**
     * Display a listing of the resource.
     *
     * @return \Illuminate\Http\Response
     */
    public function index()
    {
        //
    }


    /**
     * Store a newly created resource in storage.
     *
     * @param  \Illuminate\Http\Request  $request
     * @return \Illuminate\Http\Response
     */
    public function store(Request $request)
    {
        //
        $user = AuthService::current($request);
        if (!$user) {
            Log::error('未登录');
            return $this->error(__('auth.failed'), [], 401);
        }
        $payload = $request->input('payload');
        $result = array();
        Log::debug('token', ['payload' => $payload]);
        foreach ($payload as $key => $value) {
            //鉴权
            switch ($value['res_type']) {
                case 'channel':
                    if (!isset($value['power']) || !isset($value['res_id'])) {
                        continue 2;
                    }
                    if ($value['power'] === 'edit') {
                        if (!ChannelApi::userCanEdit($user['user_uid'], $value['res_id'])) {
                            continue 2;
                        }
                    } else {
                        if (!ChannelApi::userCanRead($user['user_uid'], $value['res_id'])) {
                            continue 2;
                        }
                    }
                    break;
                default:
                    continue 2;
                    break;
            }
            //获取token
            $token = AccessToken::firstOrNew(
                [
                    'res_type' => $value['res_type'],
                    'res_id' => $value['res_id']
                ],
                [
                    'token' => (string)Str::uuid()
                ]
            );
            if (!$token->exists) {
                $token->save();
            }

            try {
                $jwt = JWT::encode($value, $token->token . $token->token, 'HS512');
            } catch (\Exception $e) {
                Log::error('jwt', ['error' => $e]);
                continue;
            }
            $result[] = [
                'payload' => $value,
                'token' => $jwt
            ];
        }
        return $this->ok(['rows' => $result, 'count' => count($result)]);
    }

    /**
     * Display the specified resource.
     *
     * @param  \App\Models\AccessToken  $accessToken
     * @return \Illuminate\Http\Response
     */
    public function show(AccessToken $accessToken)
    {
        //
    }

    /**
     * Update the specified resource in storage.
     *
     * @param  \Illuminate\Http\Request  $request
     * @param  \App\Models\AccessToken  $accessToken
     * @return \Illuminate\Http\Response
     */
    public function update(Request $request, AccessToken $accessToken)
    {
        //
    }

    /**
     * Remove the specified resource from storage.
     *
     * @param  \App\Models\AccessToken  $accessToken
     * @return \Illuminate\Http\Response
     */
    public function destroy(AccessToken $accessToken)
    {
        //
    }
}