weixin/app/Services/Base/UserMessageService.php

<?php

namespace App\Services\Base;

use App\Contracts\Repositories\Base\UserMessageRepository;
use App\Repositories\Criteria\Base\UserMessageCriteria;
use App\Repositories\Eloquent\Base\UserMessageRepositoryEloquent;
use App\Repositories\Models\Base\UserMessage;
use App\Repositories\Presenters\Base\UserMessagePresenter;
use Illuminate\Http\Request;

class UserMessageService
{
    /**
     * @var UserMessageRepositoryEloquent
     */
    private $userMessageRepository;

    /**
     * UserMessageService constructor.
     *
     * @param UserMessageRepositoryEloquent $userMessageRepositoryEloquent
     */
    public function __construct(UserMessageRepositoryEloquent $userMessageRepositoryEloquent)
    {
        $this->userMessageRepository = $userMessageRepositoryEloquent;
    }

    /**
     * @param Request $request
     *
     * @return mixed
     * @throws \Prettus\Repository\Exceptions\RepositoryException
     */
    public function handleList(Request $request)
    {
        $this->userMessageRepository->pushCriteria(new UserMessageCriteria($request));
        $this->userMessageRepository->setPresenter(UserMessagePresenter::class);

        return $this->userMessageRepository->searchUserMessagesByPage();
    }

    /**
     * @param $id
     *
     * @return \Illuminate\Database\Eloquent\Model
     */
    public function handleProfile($id)
    {
        $this->userMessageRepository->setPresenter(UserMessagePresenter::class);
        return $this->userMessageRepository->searchUserMessageBy($id);
    }

    /**
     * @param Request $request
     *
     * @return mixed
     * @throws \Prettus\Validator\Exceptions\ValidatorException
     */
    public function handleStore(Request $request)
    {
        $userMessage = $this->userMessageRepository->create($request->all());
        return $userMessage;
    }

    /**
     * @param Request $request
     *
     * @return mixed
     * @throws \Prettus\Validator\Exceptions\ValidatorException
     */
    public function handleUpdate(Request $request)
    {
        $userMessage = $this->userMessageRepository->update($request->all(), $request->get('id'));
        return $userMessage;
    }

    /**
     * @param Request $request
     *
     * @return mixed
     * @throws \Prettus\Validator\Exceptions\ValidatorException
     */
    public function handleDelete($id)
    {
        return $this->userMessageRepository->delete($id);
    }

    /**
     * 获取我的未读信息
     * @param Request $request
     * @return mixed
     * @throws \Prettus\Repository\Exceptions\RepositoryException
     */
    public function handleMe(Request $request)
    {
        $this->userMessageRepository->pushCriteria(new UserMessageCriteria($request));
        $this->userMessageRepository->setPresenter(UserMessagePresenter::class);

        return $this->userMessageRepository->searchMeMessagesByPage($request->get('guard'));
    }

    /**
     * 标记已读
     * @return \Illuminate\Contracts\Pagination\LengthAwarePaginator|\Illuminate\Support\Collection|mixed
     * @throws \Prettus\Validator\Exceptions\ValidatorException
     */
    public function handleReadMessage(Request $request)
    {
        $userMessage = $this->userMessageRepository->update(['is_read' => UserMessage::IS_READ_OK], $request->get('id'));
        return $userMessage;
    }

    /**
     * 标记全部已读
     * @return mixed
     */
    public function handleReadAllMessages(Request $request)
    {
        return $this->userMessageRepository->readAllMessages($request->get('guard'));
    }
}