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

<?php

namespace App\Http\Controllers;

use App\Http\Api\StudioApi;
use App\Http\Api\UserApi;
use App\Http\Resources\TransferResource;
use App\Models\Article;
use App\Models\Channel;
use App\Models\Transfer;
use App\Services\AuthService;
use Illuminate\Http\Request;
use Illuminate\Http\Response;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;

class TransferController extends Controller
{
    /**
     * Display a listing of the resource.
     *
     * @return Response
     */
    public function index(Request $request)
    {
        switch ($request->input('view')) {
            case 'studio':
                // 获取studio内所有channel
                $user = AuthService::current($request);
                if (! $user) {
                    return $this->error(__('auth.failed'));
                }
                // 判断当前用户是否有指定的studio的管理权限
                $studioId = StudioApi::getIdByName($request->input('name'));
                if ($user['user_uid'] !== $studioId) {
                    return $this->error(__('auth.failed'));
                }
                switch ($request->input('view2')) {
                    case 'in':
                        $table = Transfer::where('new_owner', $studioId);
                        break;
                    case 'out':
                        $table = Transfer::where('origin_owner', $studioId);
                        break;
                    default:
                        return $this->error('no view2');
                        break;
                }
                $outNumber = Transfer::where('origin_owner', $studioId)
                    ->where('status', 'transferred')
                    ->count();
                $inNumber = Transfer::where('new_owner', $studioId)
                    ->where('status', 'transferred')
                    ->count();
                break;
        }
        if (! empty($search)) {
            $table->where('title', 'like', $search.'%');
        }
        $table->orderBy(
            $request->input('order', 'updated_at'),
            $request->input('dir', 'desc')
        );
        $count = $table->count();
        $table->skip($request->input('offset', 0))
            ->take($request->input('limit', 100));

        $result = $table->get();

        return $this->ok([
            'rows' => TransferResource::collection($result),
            'count' => $count,
            'out' => $outNumber,
            'in' => $inNumber,
        ]);
    }

    /**
     * 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'));
        }
        //
        // validate
        // read more on validation at http://laravel.com/docs/validation

        $rules = [
            'res_id' => 'required',
            'res_type' => 'required',
            'new_owner' => 'required',
        ];

        $validated = $request->validate($rules);

        $resId = $request->input('res_id');
        foreach ($resId as $id) {
            $transfer = new Transfer;
            // 查看权限
            switch ($request->input('res_type')) {
                case 'channel':
                    $oldRes = Channel::find($id);
                    if ($oldRes->owner_uid !== $user['user_uid']) {
                        return $this->error(__('auth.failed'), [403], 403);
                    }
                    $transfer->origin_owner = $oldRes->owner_uid;
                    break;
                case 'article':
                    $oldRes = Article::find($id);
                    if ($oldRes->owner !== $user['user_uid']) {
                        return $this->error(__('auth.failed'), [403], 403);
                    }
                    $transfer->origin_owner = $oldRes->owner;
                    break;
                default:
                    // code...
                    break;
            }
            // 查重
            if (Transfer::where('res_id', $id)
                ->where('res_type', $request->input('res_type'))
                ->where('status', 'transferred')
                ->exists()
            ) {
                return $this->error('该资源已经进入转让流程', [200], 200);
            }
            $transfer->res_id = $id;
            $transfer->res_type = $request->input('res_type');

            $transfer->transferor_id = $user['user_uid'];
            $transfer->new_owner = $request->input('new_owner');
            $transfer->save();
        }

        return $this->ok(count($resId));
    }

    /**
     * Display the specified resource.
     *
     * @return Response
     */
    public function show(Transfer $transfer)
    {
        //
        return $this->ok(new TransferResource($discussion));
    }

    /**
     * Update the specified resource in storage.
     *
     * @return Response
     */
    public function update(Request $request, Transfer $transfer)
    {
        $user = AuthService::current($request);
        if (! $user) {
            return $this->error(__('auth.failed'), [403], 403);
        }
        // 权限
        switch ($request->input('status')) {
            case 'accept':
            case 'refuse':
                if ($transfer->new_owner !== $user['user_uid']) {
                    return $this->error(__('auth.failed'), [403], 403);
                }
                $transfer->status = $request->input('status');
                break;
            case 'cancel':
                if ($transfer->origin_owner !== $user['user_uid']) {
                    return $this->error(__('auth.failed'), [403], 403);
                }
                $transfer->status = 'cancel';
                break;
            default:
                return $this->error(__('auth.failed'), [404], 404);
                break;
        }

        try {
            DB::transaction(function () use ($transfer, $request, $user) {
                $transfer->editor_id = $user['user_uid'];
                $transfer->save();

                if ($request->input('status') === 'accept') {
                    $newOwner = UserApi::getByUuid($transfer->new_owner);
                    $isBasic = false;
                    if (isset($newOwner['roles']) && is_array($newOwner['roles'])) {
                        $isBasic = in_array('basic', $newOwner['roles']);
                    }
                    switch ($transfer->res_type) {
                        case 'channel':
                            $newData = ['owner_uid' => $transfer->new_owner];
                            if ($isBasic) {
                                $newData['status'] = 5;
                            }
                            Channel::where('uid', $transfer->res_id)
                                ->update($newData);
                            break;
                        case 'article':
                            $userId = UserApi::getIdByUuid($transfer->new_owner);
                            $newData = ['owner' => $transfer->new_owner, 'owner_id' => $userId];
                            if ($isBasic) {
                                $newData['status'] = 10;
                            }
                            Article::where('uid', $transfer->res_id)
                                ->update($newData);
                            break;
                        default:
                            // code...
                            break;
                    }
                }
            });
        } catch (\Exception $e) {
            Log::error('update.fail', ['error' => $e]);

            return $this->error('update.fail', ['message' => $e], 500);
        }

        return $this->ok(new TransferResource($transfer));
    }

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