L03 7.x passport

.env.example

@@ -48,3 +48,12 @@ MIX_PUSHER_APP_CLUSTER="${PUSHER_APP_CLUSTER}"
 
 BAIDU_TRANSLATE_APPID=
 BAIDU_TRANSLATE_KEY=
+
+# aliyun 短信
+SMS_ALIYUN_ACCESS_KEY_ID=
+SMS_ALIYUN_ACCESS_KEY_SECRET=
+SMS_ALIYUN_TEMPLATE_REGISTER=
+
+# socialite weixin
+WEIXIN_KEY=
+WEIXIN_SECRET=

.gitignore

@@ -10,3 +10,4 @@ Homestead.json
 Homestead.yaml
 npm-debug.log
 yarn-error.log
+.idea

app/Console/Commands/GenerateToken.php

@@ -0,0 +1,41 @@
+<?php
+
+namespace App\Console\Commands;
+
+use App\Models\User;
+use Illuminate\Console\Command;
+
+class GenerateToken extends Command
+{
+
+    protected $signature = 'larabbs:generate-token';
+    protected $description = '快速为用户生成token';
+
+    /**
+     * Create a new command instance.
+     *
+     * @return void
+     */
+    public function __construct()
+    {
+        parent::__construct();
+    }
+
+    /**
+     * Execute the console command.
+     *
+     * @return int
+     */
+    public function handle()
+    {
+        $userId = $this->ask('请输入用户ID');
+        $user = User::find($userId);
+
+        if(!$user){
+            $this->error('用户不存在');
+        }
+
+        $ttl = 365*24*60;
+        $this->info(auth('api')->setTTL($ttl)->login($user));
+    }
+}

app/Exceptions/Handler.php

@@ -3,6 +3,7 @@
 namespace App\Exceptions;
 
 use Illuminate\Foundation\Exceptions\Handler as ExceptionHandler;
+use Illuminate\Support\Arr;
 use Throwable;
 
 class Handler extends ExceptionHandler
@@ -52,4 +53,25 @@ public function render($request, Throwable $exception)
     {
         return parent::render($request, $exception);
     }
+
+    /*
+     * 重写父类方法
+     * 增加了code字段，以显示自定义错误码
+     */
+    protected function convertExceptionToArray(Throwable $e)
+    {
+        return config('app.debug') ? [
+            'message' => $e->getMessage(),
+            'code' => $e->getCode(),
+            'exception' => get_class($e),
+            'file' => $e->getFile(),
+            'line' => $e->getLine(),
+            'trace' => collect($e->getTrace())->map(function ($trace) {
+                return Arr::except($trace, ['args']);
+            })->all(),
+        ] : [
+            'message' => $this->isHttpException($e) ? $e->getMessage() : 'Server Error',
+            'code' => $e->getCode(),
+        ];
+    }
 }

app/Http/Controllers/Api/AuthorizationsController.php

@@ -0,0 +1,111 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Requests\Api\AuthorizationRequest;
+use Illuminate\Http\Request;
+use App\Http\Requests\Api\SocialAuthorizationRequest;
+use Illuminate\Support\Facades\Auth;
+use Overtrue\Socialite\AccessToken;
+use Illuminate\Auth\AuthenticationException;
+use App\Models\User;
+use Illuminate\Support\Arr;
+use Tymon\JWTAuth\JWT;
+
+use Psr\Http\Message\ServerRequestInterface;
+use League\OAuth2\Server\AuthorizationServer;
+use Zend\Diactoros\Response as Psr7Response;
+use League\OAuth2\Server\Exception\OAuthServerException;
+use App\Traits\PassportToken;
+
+class AuthorizationsController extends Controller
+{
+    use PassportToken;
+    /*
+     * 第三方登录
+     */
+    public function socialStore($type,SocialAuthorizationRequest $request){
+        $driver = \Socialite::driver($type);
+        try {
+            if($code = $request->code){
+                $accessToken = $driver->getAccessToken($code);
+            }else{
+                $tokenData['access_token'] = $request->access_token;
+
+                // 微信需要增加 openid
+                if ($type == 'wechat') {
+                    $tokenData['openid'] = $request->openid;
+                }
+                $accessToken = new AccessToken($tokenData);
+            }
+            $oauthUser = $driver->user($accessToken);
+        }catch (\Exception $e) {
+            throw new AuthenticationException('参数错误，未获取用户信息');
+        }
+
+        switch ($type){
+            case 'wechat':
+                $unionid = $oauthUser->getOriginal()['unionid'] ?? null;
+                if($unionid){
+                    $user = User::where('weixin_unionid',$unionid)->first();
+                }else{
+                    $user = User::where('weixin_openid',$oauthUser->getId())->first();
+                }
+                //没有用户创建一个
+                if(!$user){
+                    $user = User::create([
+                        'name'=>$oauthUser->getNickname(),
+                        'avatar' => $oauthUser->getAvatar(),
+                        'weixin_openid' => $oauthUser->getId(),
+                        'weixin_unionid' => $unionid,
+                    ]);
+                }
+                break;
+        }
+
+        $result = $this->getBearerTokenByUser($user, '1', false);
+
+        return response()->json($result)->setStatusCode(201);
+    }
+
+    //登录
+    public function store(AuthorizationRequest $originRequest, AuthorizationServer $server, ServerRequestInterface $serverRequest)
+    {
+        try {
+            return $server->respondToAccessTokenRequest($serverRequest, new Psr7Response)->withStatus(201);
+        } catch(OAuthServerException $e) {
+            throw new AuthenticationException($e->getMessage());
+        }
+    }
+
+    //刷新token
+    public function update(AuthorizationServer $server, ServerRequestInterface $serverRequest)
+    {
+        try {
+            return $server->respondToAccessTokenRequest($serverRequest, new Psr7Response);
+        } catch(OAuthServerException $e) {
+            throw new AuthenticationException($e->getmessage());
+        }
+    }
+
+    //删除token
+    public function destroy()
+    {
+        if (auth('api')->check()) {
+            auth('api')->user()->token()->revoke();
+            return response(null, 204);
+        } else {
+            throw new AuthenticationException('The token is invalid.');
+        }
+    }
+
+    //简单封装
+    protected function respondWithToken($token)
+    {
+        return response()->json([
+            'access_token' => $token,
+            'token_type' => 'Bearer',
+            'expires_in' => auth('api')->factory()->getTTL() * 60,
+        ]);
+    }
+}

app/Http/Controllers/Api/CaptchasController.php

@@ -0,0 +1,43 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Requests\Api\CaptchaRequest;
+use Gregwar\Captcha\CaptchaBuilder;
+use Illuminate\Support\Facades\Cache;
+use Illuminate\Support\Str;
+use Illuminate\Http\Request;
+
+class CaptchasController extends Controller
+{
+    public function store(CaptchaRequest $request,CaptchaBuilder $captchaBuilder){
+        $key = 'captcha-'.Str::random(15);
+        $phone =$request->phone;
+
+        $captcha = $captchaBuilder->build();
+        $expiredAt = now()->addMinutes(5);
+        Cache::put($key,['phone' => $phone, 'code' => $captcha->getPhrase()],$expiredAt);
+
+        $result = [
+            'captcha_key'=>$key,
+            'expired_at'=>$expiredAt->toDateTimeString(),
+            'url'=>url('api/v1/captchas/'.$key),
+            'cptach_img_content'=>$captcha->inline(),
+        ];
+        return response()->json($result)->setStatusCode(201);
+    }
+
+    public function show(Request $request){
+        $key = $request->captcha_key;
+        $captchaData = Cache::get($key);
+        if(!$captchaData){
+            abort(403,'验证码已失效');
+        }
+
+        $captchaBuilder = new CaptchaBuilder($captchaData['code']);
+        $captchaBuilder->build();
+        header('Content-type: image/jpeg');
+
+        $captchaBuilder->output();
+    }
+}

app/Http/Controllers/Api/CategoriesController.php

@@ -0,0 +1,20 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Controllers\Controller;
+use App\Http\Resources\CategoryResource;
+use App\Models\Category;
+use Illuminate\Http\Request;
+
+class CategoriesController extends Controller
+{
+    /*
+     * 分类列表
+     */
+    public function show(){
+        CategoryResource::wrap('data');
+        return CategoryResource::collection(Category::all());
+
+    }
+}

app/Http/Controllers/Api/Controller.php

@@ -0,0 +1,15 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Controllers\Controller as BaseController;
+use Illuminate\Http\Request;
+use Symfony\Component\HttpKernel\Exception\HttpException;
+
+class Controller extends BaseController
+{
+    public function errorResponse($statusCode, $message=null, $code=0)
+    {
+        throw new HttpException($statusCode, $message, null, [], $code);
+    }
+}

app/Http/Controllers/Api/ImagesController.php

@@ -0,0 +1,29 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Handlers\ImageUploadHandler;
+use App\Http\Requests\Api\ImageRequest;
+use App\Http\Resources\ImageResource;
+use App\Models\Image;
+use Illuminate\Http\Request;
+use Illuminate\Support\Str;
+
+class ImagesController extends Controller
+{
+    /*
+     * 图片上传
+     */
+    public function store(ImageRequest $request,Image $image,ImageUploadHandler $uploader){
+        $user = $request->user();
+        $size = $request->type == 'avatar' ? 416 : 1000;
+        $result = $uploader->save($request->image,Str::plural($request->type),$user->id,$size);
+
+        $image->path = $result['path'];
+        $image->type = $request->type;
+        $image->user_id = $user->id;
+        $image->save();
+
+        return new ImageResource($image);
+    }
+}

app/Http/Controllers/Api/LinksController.php

@@ -0,0 +1,19 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Resources\LinkResource;
+use App\Models\Link;
+use Illuminate\Http\Request;
+
+class LinksController extends Controller
+{
+    /*
+     * 资源推荐
+     */
+    public function index(Link $link){
+        $links = $link->getAllCached();
+        LinkResource::wrap('data');
+        return LinkResource::collection($links);
+    }
+}

app/Http/Controllers/Api/NotificationsController.php

@@ -0,0 +1,34 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use Illuminate\Http\Request;
+use App\Http\Resources\NotificationResource;
+
+class NotificationsController extends Controller
+{
+    /*
+     * 消息列表
+     */
+    public function index(Request $request){
+        $data = $request->user()->notifications()->paginate();
+        return NotificationResource::collection($data);
+    }
+
+    /*
+     * 未读消息数量
+     */
+    public function stats(Request $request){
+        return response()->json([
+            'unread_count' => $request->user()->notification_count,
+        ]);
+    }
+
+    /*
+     * 标记已读
+     */
+    public function read(Request $request){
+        $request->user()->markAsRead();
+        return response(null, 204);
+    }
+}

app/Http/Controllers/Api/PermissionsController.php

@@ -0,0 +1,18 @@
+<?php
+
+namespace App\Http\Controllers\Api;
+
+use App\Http\Resources\PermissionResource;
+use Illuminate\Http\Request;
+
+class PermissionsController extends Controller
+{
+    /*
+     * 当前登录用户的权限列表
+     */
+    public function index(Request $request){
+        $permissions = $request->user()->getAllPermissions();
+        PermissionResource::wrap('data');
+        return PermissionResource::collection($permissions);
+    }
+}