config-manage/app/Repositories/MessageRuleRepository.php

<?php
/**
 * Created by PhpStorm.
 * User: Administrator
 * Date: 2019/6/12
 * Time: 9:13
 */

namespace App\Repositories;

use App\Models\MessageRule;
use Illuminate\Database\QueryException;
use Dingo\Api\Http\Response;
use Illuminate\Support\Carbon;
use Illuminate\Support\Facades\DB;
use Illuminate\Support\Facades\Log;
use Illuminate\Support\Facades\Redis;
use Symfony\Component\HttpKernel\Exception\HttpException;
use Tymon\JWTAuth\Facades\JWTAuth;

class MessageRuleRepository
{
    public function __construct(MessageRule $messageRule)
    {
        $this->messageRule = $messageRule;
    }

    /**
     * 内容列表
     */
    public function lists($request)
    {
        $perPage = isset($request['per_page']) ? $request['per_page'] : 20;
        $where = [];
        if(isset($request['title'])){
            $where[] = ['title', 'like', "%{$request['title']}%"];
        }
        if(isset($request['message_type'])){
            $where[] = ['message_type', $request['message_type']];
        }
        return $this->messageRule
            ->where($where)
            ->orderBy('id','desc')
            ->paginate($perPage);
    }

    /**
     * 创建消息
     */
    public function create($request)
    {
        return 2223;
        //验证小号
        $userInfo = $this->getUserInfo($request['uid']);
        if(!$userInfo || $userInfo['type'] != 1){
            return Response::create([
                'message'  => '所选小号信息有误',
                'status_code'   => 500
            ]);
        }
        //验证话题
        $topicIds = $this->topic->whereIn('id', explode(',', $request['topic_ids']))->pluck('id')->toArray();
        $topicCount = count($topicIds);
        if($topicCount == 0 || $topicCount > 5){
            return Response::create([
                'message'  => '所选话题必须1-5个',
                'status_code'   => 500
            ]);
        }
        $topicIds = implode(',', $topicIds);

        $data = [
            'uid' => $request['uid'],
            'username' => $userInfo['username'],
            'mobile' => $userInfo['mobile'],
            'avatar' => $userInfo['avatar'],
            'type' => $request['type'],
            'img' => $request['img'],
            'video' => $request['video']??'',
            'topic_ids' => $topicIds,
            'title' => $request['title']??'',
            'content' => $request['content'],
            'location' => $request['location']??'',
            'is_suggest' => $request['is_suggest'],
            'is_hide' => 0
        ];

        $date = date('Y-m-d H:i:s');


        DB::beginTransaction();
        try{
            $post = $this->post->create($data);

            $this->postData->create([
                'post_id' => $post->id,
                'pv' => 0,
                'pv_real' => 0,
                'dislike_count' => 0,
                'praise_count' => 0,
                'praise_real_count' => 0,
                'share_count' => 0,
                'share_real_count' => 0,
                'comment_count' => 0,
                'comment_real_count' => 0,
                'collect_count' => 0,
                'collect_real_count' => 0,
                'available_bean' => $this->availableBean(),
                'will_collect_bean' => rand(100, 200),
                'collect_bean' => 0,
                'weight' => 0
            ]);

            if(!empty($request['imgs']) && $request['type'] == 'image'){
                $imgData = [];
                foreach($request['imgs'] as $img){
                    $imgData[] = [
                        'post_id' => $post->id,
                        'img' => $img,
                        'created_at' => $date,
                        'updated_at' => $date
                    ];
                }
                $this->postImgs->insert($imgData);
            }

            DB::commit();
            return Response::create();

        }catch (QueryException $exception){
            DB::rollBack();
            Log::debug('发布内容：'.$exception->getMessage());
            return Response::create([
                'message'  => '发布失败，请重试',
                'error' => $exception->getMessage(),
                'status_code'   => 500
            ]);
        }
    }
}