Laravel Vuejs 实战：开发知乎 （12）使用 Repository 模式

关于Repository可以参考：

为什么你应该使用 Repository

推荐：好用的 Laravel Repository 包

Repository 模式作用和实现原理

PHP Laravel框架的 Repository 模式

关于 Repository 的设计模式

服务容器

不过你不一定需要Repository，具体使用中，视情况而定：

Laravel repository：

Repository 模式和 Eloquent 的 ORM 在本质上是冲突的，只能二选一，否则就是白费力气；

本身用 repository 不会变的更方便，了解这个模式的初衷，主要是用来将数据存储和业务逻辑分离，具体数据持久化到哪里，领域服务并不用关心，这也隔离了后续持久化变更问题，还有一点很重要的是了解一下 DDD (领域驱动设计) 估计会更好的理解这个模式，关于提到复杂查询，我在项目中更倾向于将 cmd 和 query 分开（cqrs 架构），对于领域服务而言，不存在过于复杂的查询，repository 基本够用，但对于后台这种是需要复杂查询的，query 查询走 db builder 或者裸写都可以，你方便怎么来就怎么来，也不会对业务带来影响，甚至你的数据还可能来自 es 呢

但为了了解Repository，我们在本项目中尝试使用：

1.在app文件夹下，创建Repositories文件夹，并在该文件夹内新建一个QuestionRepository：

将QuestionController中数据查询的逻辑移入本类的方法中，这些方法都必须使用便于理解的名字命名。

class QuestionRepository
{

    /**
     * 根据提供的数据，使用Eloquent创建question，存储到数据库中并且返回该实例
     * @param array $data
     * @return mixed
     */
    public function create(array $data)
    {
        $question = Question::create($data);
        return $question;
    }
}

然后在QuestionController构造函数中，通过依赖注入的方式，将QuestionRepository 注入到QuestionController 中并赋值给QuestionController中的属性，

/**
 * @var QuestionRepository
 */
private $questionRepository;

public function __construct(QuestionRepository $questionRepository)
{
    $this->middleware(
        'auth',
        [
            'except' =>
                [
                    'index',
                    'show',
                ]//非注册用户只能查看不能编辑添加更改删除
        ]
    );

    $this->questionRepository = $questionRepository;
}

后续调用QuestionRepository中的方法，取代之前QuestionController 对数据层的操作即可。

    /**
     * @param QuestionStoreRequest $request
     * @return IlluminateHttpRedirectResponse
     */
    public function store(QuestionStoreRequest $request)//依赖注入QuestionStoreRequest实例
    {
        //
//        $data = $request->validate([
//            'title' => 'required|min:8',
//            'content' => 'required|min:28',
//        ]);
        //存储topics
        $topics = $this->normalizeTopics($request->get('topics'));
        //初始化question要用到的数据
        $data = $request->all();
        $data['user_id'] = auth()->user()->id;

//        $question=Question::create($data); 被下方代码取代
        $question = $this->questionRepository->create($data);

        //使用我们再question model里面添加的topics方法获得 topics关联，再使用attach方法

        $question->topics()->attach($topics);

        return redirect()->route('questions.show', $question);
    }

代码不多的时候，看起来多此一举，但是这样在思维上做到了数据和操作控制分离，代码多了之后可能会比较方便。

比如将QuestionController之中的normalizeTopics移入到QuestionRepository中：

最后代码：

<?php

namespace AppRepositories;

use AppModelsQuestion;
use AppTopic;

class QuestionRepository
{

    /**
     * 根据提供的数据，使用Eloquent创建question，存储到数据库中并且返回该实例
     * @param array $data
     * @return mixed
     */
    public function create(array $data)
    {
        $question = Question::create($data);
        return $question;
    }

    /**
     * @param array $topics
     * @return array
     */
    public function normalizeTopics(array $topics)
    {
        //返回topic的id序列，如果不是数字，则强制认为是数据库中的topic的id，
        //这样虽然会漏掉用户如果设置的topic就是数字的情况，但是因为是测试，所以暂时忽略
        $normalizedTopics = collect($topics)->map(function ($topic) {
            if (is_numeric($topic))//是数字
            {
                //在数据库中找id
                $num_topic = Topic::query()->find($topic);
                if (isset($num_topic) && $num_topic->count() > 0) //在数据库中找得到id
                {
                    //因为是找到了 且是从question处提交，其内部的question_count应该增加1个
                    $num_topic->increment('questions_count');
                    //返回id
                    return (int)$num_topic->id;
                }
            }
            //否则创建一个新的topic
            //再之前先判断是否找得到，因为有时候重复提交，select2在提交的数据中不为数字，但是实际上数据库中已经有值
            $already = Topic::query()->select('id', 'name')->where('name', '=', $topic);

            if ($already->count() > 0) {
                //因为是找到了 且是从question处提交，其内部的question_count应该增加1个
                $already->increment('questions_count');
                //返回id
                return $already->first()->id;
            }
            $data_of_topic = [
                'name' => $topic,//目前view中topic只有一个选择框，没有设置content的输入框
                'questions_count' => 1,//因为是找到了 且是从question处提交，其内部的question_count应该初始化为1个
            ];
            //入库
            $newTopic = Topic::create($data_of_topic);
            //返回id
            return $newTopic->id;
        })->toArray();

        return $normalizedTopics;
    }
}

<?php

namespace AppHttpControllers;

use AppHttpRequestsQuestionStoreRequest;
use AppModelsQuestion;
use AppRepositoriesQuestionRepository;
use IlluminateHttpRequest;

class QuestionController extends Controller
{

    /**
     * @var QuestionRepository
     */
    private $questionRepository;

    public function __construct(QuestionRepository $questionRepository)
    {
        $this->middleware(
            'auth',
            [
                'except' =>
                    [
                        'index',
                        'show',
                    ]//非注册用户只能查看不能编辑添加更改删除
            ]
        );

        $this->questionRepository = $questionRepository;
    }

    /**
     * Display a listing of the resource.
     *
     * @return IlluminateHttpResponse
     */
    public function index()
    {
        //

    }


    /**
     * @return IlluminateContractsViewFactory|IlluminateViewView
     */
    public function create()
    {
        //
        return view('questions.create');
    }


    /**
     * @param QuestionStoreRequest $request
     * @return IlluminateHttpRedirectResponse
     */
    public function store(QuestionStoreRequest $request)//依赖注入QuestionStoreRequest实例
    {
        //
//        $data = $request->validate([
//            'title' => 'required|min:8',
//            'content' => 'required|min:28',
//        ]);
        //存储topics
        $topics = $this->questionRepository->normalizeTopics($request->get('topics'));
        //初始化question要用到的数据
        $data = $request->all();
        $data['user_id'] = auth()->user()->id;

//        $question=Question::create($data); 被下方代码取代
        $question = $this->questionRepository->create($data);

        //使用我们再question model里面添加的topics方法获得 topics关联，再使用attach方法

        $question->topics()->attach($topics);

        return redirect()->route('questions.show', $question);
    }


    /**
     * @param Question $question
     * @return IlluminateContractsViewFactory|IlluminateViewView
     */
    public function show(Question $question)
    {
        //使用关系关联加载，with方法会将分类之下的商品一起查询出来，而且不会出现N+1影响性能的问题
        $question->with('topics')->get();

        return view('questions.show', compact('question'));
    }

    /**
     * Show the form for editing the specified resource.
     *
     * @param int $id
     * @return IlluminateHttpResponse
     */
    public function edit($id)
    {
        //
    }

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

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


}