goeast_serve/app/Http/Controllers/Api/Museum/Spot.php

<?php

namespace App\Http\Controllers\Api\Museum;

use App\Http\Controllers\Controller;
use Illuminate\Http\Request;
use Illuminate\Support\Facades\DB;
use App\Servers\Wenlv\MuseumServer;
use App\Models\Api\Museum\Spot as SpotModel;
use App\Models\Api\Museum\SpotTmp as SpotTmpModel;

class Spot extends Controller
{
    /**
     * 采集博物馆列表数据
     * @author    唐远望
     * @version   1.0
     * @date      2026-04-02
     */
    public function collect_data(SpotTmpModel $SpotTmpModel)
    {
        $MuseumServer = new MuseumServer();
        $page_data = $MuseumServer->getMuseumPageData();
        $pages = $page_data['pages'];
        if ($pages > 0) {
            for ($page = 1; $page < $pages; $page++) {
                //查询是否存在第一页数据
                $page_data = $SpotTmpModel->where(['page' => $page])->first();
                if ($page_data) {
                    $museum_list = json_decode($page_data->data, true);
                    $this->add_museum($museum_list);
                    continue;
                }
                $list_data = $MuseumServer->getMuseumList($page);
                $list = isset($list_data['rows']['records']) ? $list_data['rows']['records'] : '';
                if (!$list) continue;
                $SpotTmpModel->insert(['page' => $page, 'data' => json_encode($list)]);
            }
        }
        // 加载模板
        return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => '']);
    }


    /**
     * 添加博物馆数据到数据库
     * @author    唐远望
     * @version   1.0
     * @date      2026-04-02
     */
    public function add_museum($list)
    {
        $SpotModel = new SpotModel();
        $museum_type_config = [
            '文化文物系统国有博物馆' => '1',
            '其他行业国有博物馆' => '2',
            '非国有博物馆' => '3',
        ];
        foreach ($list as $key => $value) {
            $insert_data['museum_type_id'] = isset($museum_type_config[$value['NB_BWGXZ_NAME']]) ? $museum_type_config[$value['NB_BWGXZ_NAME']] : '0';
            $insert_data['museum_level'] = isset($value['NB_ZLDJ_NAME']) ? $value['NB_ZLDJ_NAME'] : '';
            $insert_data['is_open'] = '0';
            $insert_data['name'] = isset($value['NB_BWGMC']) ? $value['NB_BWGMC'] : '';
            $insert_data['intro'] = isset($value['NB_BWGJJ']) ? $value['NB_BWGJJ'] : '';
            $insert_data['province_name'] = isset($value['NB_S_NAME']) ? $value['NB_S_NAME'] : '';
            $insert_data['city_name'] = isset($value['NB_X_NAME']) ? $value['NB_X_NAME'] : '';
            $insert_data['district_name'] = '';
            $insert_data['insert_time'] = time();
            //查询是否存在博物馆
            $museum_info = $SpotModel->where(['name' => $insert_data['name'], 'province_name' => $insert_data['province_name']])->first();
            if (!$museum_info) {
                $SpotModel->insert($insert_data);
            }
        }
    }

    /**
     * 获取附近博物馆列表数据
     * @author    唐远望
     * @version   1.0
     * @date      2026-04-02
     */
    public function nearby_list(Request $request, SpotModel $SpotModel)
    {
        $longitude = $request->input('longitude', '');
        $latitude = $request->input('latitude', '');
        $page = $request->input('page', 1);
        $limit = $request->input('limit', 10);
        $query = $SpotModel->query()->where('status', 0);
        $field = ['id', 'name', 'museum_type_id', 'museum_level', 'is_open', 'intro', 'longitude', 'latitude', 'province_name', 'city_name', 'district_name'];
        $latlot_feild = ["DB::raw('(6371 * ACOS(COS(RADIANS(' . $latitude . ')) * COS(RADIANS(latitude)) * COS(RADIANS(longitude) - RADIANS(' . $longitude . ')) + SIN(RADIANS(' . $latitude . ')) * SIN(RADIANS(latitude)))) AS distance')"];
        if (is_numeric($longitude) && $longitude > 0 && is_numeric($latitude) && $latitude > 0) {
            $field = array_merge($field, $latlot_feild);
            $query->select($field)->orderBy('distance', 'asc');
        } else {
            $query->select($field);
        }
        $data = $query->paginate($limit, ['*'], 'page', $page);
        if (!empty($data['data'])) {
            foreach ($$data['data'] as $key => $value) {
                $data['data'][$key]['distance'] = isset($value['distance']) ? $value['distance'] : '0';
            }
        }
        return json_send(['code' => 'success', 'msg' => '获取成功', 'data' => $data]);
    }
}