video_server/runtime/container/proxy/Modules_Api_Controllers_TopicController.proxy.php

<?php

/**
 * 话题控制器.
 *
 * @author zhangjunbao <junbaoz1314@gmail.com>
 * @date   2020-01-29 10:13:09
 */
declare (strict_types=1);
namespace Modules\Api\Controllers;

use App\Constants\CommonConstant;
use App\Repositories\Criterias\OrderLimitCriteria;
use App\Repositories\Criterias\TopicCriteria;
use App\Repositories\TopicRepository;
use Hyperf\Validation\Contract\ValidatorFactoryInterface;
use Modules\Api\Responses\TopicPagesResponse;
use Modules\Manage\Responses\CommonSuccessPkResponse;
class TopicController extends BaseController
{
    use \Hyperf\Di\Aop\ProxyTrait;
    use \Hyperf\Di\Aop\PropertyHandlerTrait;
    function __construct()
    {
        if (method_exists(parent::class, '__construct')) {
            parent::__construct(...func_get_args());
        }
        $this->__handlePropertyHandler(__CLASS__);
    }
    public function lists()
    {
        $inputData = $this->getJsonData();
        $rules = [
            'page' => 'nullable|integer',
            'page_size' => 'nullable|integer',
            'category_id' => 'nullable|integer',
            'top_type' => 'nullable|string',
            // all, only_top, not_top
            'digest' => 'nullable|string',
        ];
        $validator = make(ValidatorFactoryInterface::class)->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $orders = [['created_at', 'DESC']];
        $pageSize = $inputData['page_size'] ?? CommonConstant::PAGE_SIZE;
        if ($pageSize > 100) {
            $pageSize = CommonConstant::PAGE_SIZE;
        }
        $page = format_page($inputData['page']);
        $pageSize = intval($pageSize);
        if ($pageSize <= 0) {
            $pageSize = CommonConstant::PAGE_SIZE;
        }
        $plusParams = [];
        $criteriaParams = $inputData;
        $criteriaParams['status'] = 1;
        // 追加状态条件.
        $lists = make(TopicRepository::class)->pushCriteria(new TopicCriteria($criteriaParams))->pushCriteria(new OrderLimitCriteria($orders))->paginate($pageSize, ['*'], $page);
        return new TopicPagesResponse($lists);
    }
    public function create()
    {
        $inputData = $this->getJsonData();
        $rules = ['category_id' => 'required|integer', 'content' => 'required|max:1000', 'ct_type' => 'required|integer|in:1,2', 'video_id' => 'required_if:ct_type,2', 'mulit_pic' => 'nullable|array'];
        $validator = make(ValidatorFactoryInterface::class)->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $userId = $this->getUserId();
        $categoryId = intval(data_get($inputData, 'category_id', 0));
        $content = strval(data_get($inputData, 'content', ''));
        $ctType = intval(data_get($inputData, 'ct_type', 1));
        $videoId = strval(data_get($inputData, 'video_id', ''));
        $arrMulitPic = data_get($inputData, 'mulit_pic', []);
        $status = $ctType == 2 ? 3 : 1;
        $firstPic = '';
        $arrData = [];
        if (!empty($arrMulitPic)) {
            $arrData['mulit_pic'] = $arrMulitPic;
            reset($arrMulitPic);
            $firstPic = current($arrMulitPic);
            // 取第一张图.
        }
        // 封面.
        $coverPic = $firstPic;
        $sdata = json_encode($arrData, JSON_UNESCAPED_UNICODE);
        $setarr = ['user_id' => $userId, 'category_id' => $categoryId, 'content' => $content, 'ct_type' => $ctType, 'video_id' => $videoId, 'status' => $status, 'cover_pic' => $coverPic, 'sdata' => $sdata];
        $item = make(TopicRepository::class)->createTopic($setarr);
        if (empty($item->id)) {
            return json_fail('话题失败了');
        }
        return new CommonSuccessPkResponse($item->id);
    }
    public function support()
    {
        $inputData = $this->getJsonData();
        $rules = ['id' => 'required|integer'];
        $validator = make(ValidatorFactoryInterface::class)->make($inputData, $rules);
        if ($validator->fails()) {
            // 如果有错误（可能是多个信息），这里只取第一个错误信息返回.
            return json_fail($validator->errors()->first());
        }
        $id = intval(data_get($inputData, 'id', 0));
        $item = make(TopicRepository::class)->find($id);
        if (!$item) {
            return json_fail('点赞失败哦');
        }
        $item->total_support = intval($item->total_support) + 1;
        $result = $item->save();
        if (!$result) {
            return json_fail('点赞失败了');
        }
        $logSubject = '话题点赞';
        $logSvalue = $id;
        $this->log($logSubject, $logSvalue);
        return new CommonSuccessPkResponse($id);
    }
}