billiards-server/application/api/controller/Community.php

<?php


namespace app\api\controller;


use app\admin\model\dynamic\Dynamic;
use app\api\model\massager\Collect;
use app\api\validate\BaseApiValidate;
use app\common\controller\Api;
use think\Request;


class Community extends Api
{
    protected $noNeedLogin = ['*'];

    protected $massagerModel = null;


    public function __construct(Request $request = null)
    {
        parent::__construct($request);
        $this->massagerModel = new \app\api\model\massager\Massager();
    }

    public function fetch()
    {
        $params = (new BaseApiValidate([
            "lng" => "require|number",
            "lat" => "require|number",
            "page" => "require|number",
            "size" => "require|number",
            "hot" => "number",
            "topic_id" => "number",
            "local" => "number",
            "city_code" => "number",
            "collect" => "number",
        ]))->checkBody();
        $dynamicModel = new Dynamic();

        $where = [
            ['status', "=", \E_BASE_STATUS::Normal],
        ];
        $subQuery = $dynamicModel->field("*,round(st_distance_sphere (point({$params["lng"]},{$params["lat"]}), point ( `lng`, `lat` ))) distance");
        if (isset($params["hot"]) && $params["hot"] == 1) {
            array_push($where, ["hot", "=", 1]);
        }
        if (isset($params["topic_id"]) && $params["topic_id"] > 0) {
            array_push($where, ["topic_id", "=", $params["topic_id"]]);
        }
        if (isset($params["local"]) && $params["local"] == 1) {
            if (!isset($params["city_code"]))
                $this->error("定位错误!");
            array_push($where, ["city_code", "=", $params["city_code"]]);
        }
        if (isset($params["collect"]) && $params["collect"] == 1) {
            $user = $this->auth->getUser();
            $collects = (new Collect())->where("user_id", $user ? $user["id"] : -1)->select();
            array_push($where, ["massager_id", "in", array_map(function ($item) {
                return $item["massager_id"];
            }, $collects)]);
        }
        if (isset($params["search_text"]) && mb_strlen($params["search_text"]) > 0) {
            array_push($where, ["massager.name", "like", "%{$params["search_text"]}%"]);
        }
        foreach ($where as $item) {
            $subQuery->where($item[0], $item[1], $item[2]);
        }

        $query = $dynamicModel->table($subQuery->buildSql() . ' distance');
        foreach ($where as $item) {
            $query->where($item[0], $item[1], $item[2]);
        }
        $paginate = $query
            ->page($params["page"])
            ->paginate($params["size"]);
        $items = collection($paginate->items())->toArray();

        $massager_ids = array_map(function ($data) {
            return $data["massager_id"];
        }, $items);
        $massagers = $this->massagerModel->where("id", "in", $massager_ids)->select();
        $f_massager = array_reduce($massagers, function ($p, $cur) {
            $p[$cur["id"]] = $cur;
            return $p;
        }, []);

        foreach ($items as &$item) {
            $item["massager"] = isset($f_massager[$item["massager_id"]]) ? $f_massager[$item["massager_id"]] : ["id" => null, "name" => null];
        }

        $this->success([
            $items,
            $paginate->total()
        ]);
    }


    public function getDynamic($id)
    {
        $res = (new Dynamic())
            ->where("id", $id)
            ->with(["comments", "likes", "comments.user"])
            ->find();
        $user = $this->auth->getUser();
        $res["is_can_like"] = true;
        if ($user) {
            $q = array_column($res["likes"], "user_id", "user_id");
            if (isset($q[$user["id"]]))
                $res["is_can_like"] = false;
        }
        $res ? $this->success($res) : $this->error("数据不存在!");
    }


}