当前位置:首页 > 随笔 > 正文内容

基于经纬度查询附近商家的MySQL实现

访客 随笔 2026年7月1日 1

首先创建一个用于存储地理位置信息的表:

CREATE TABLE location (
    id INT NOT NULL AUTO_INCREMENT,
    longitude FLOAT NOT NULL COMMENT '经度',
    latitude FLOAT NOT NULL COMMENT '纬度',
    place_name VARCHAR(100) DEFAULT NULL COMMENT '地点名称',
    PRIMARY KEY (id)
);

插入一些测试数据:

INSERT INTO `location`(`longitude`, `latitude`, `place_name`) VALUES (118.302416, 33.958887, "实验小学");
INSERT INTO `location`(`longitude`, `latitude`, `place_name`) VALUES (118.303997, 33.95188, "宿迁市人民医院");
INSERT INTO `location`(`longitude`, `latitude`, `place_name`) VALUES (118.302991, 33.935828, "宿迁学院");
INSERT INTO `location`(`longitude`, `latitude`, `place_name`) VALUES (118.28215, 33.959307, "金陵名府");
INSERT INTO `location`(`longitude`, `latitude`, `place_name`) VALUES (118.290081, 33.925404, "润园");
INSERT INTO `location`(`longitude`, `latitude`, `place_name`) VALUES (118.354751, 33.959007, "国际馆");

以下是基于公里计算距离的SQL查询语句:

SELECT 
    id, 
    place_name,
    (
        6371 * ACOS(
            COS(RADIANS(33.958887)) 
            * COS(RADIANS(latitude)) 
            * COS(RADIANS(longitude) - RADIANS(118.302416)) 
            + SIN(RADIANS(33.958887)) 
            * SIN(RADIANS(latitude))
        )
    ) AS distance
FROM location
HAVING distance < 20
ORDER BY distance ASC
LIMIT 0, 20;

其中,33.958887 是纬度,118.302416 是经度。

下面是完整的PHP实现代码,用于分页获取附近的商家信息:

public function getNearbyBusiness() {
    // 验证经纬度是否合法
    if (!$this->validator->check('longitude', ['required', 'regex' => '-?((0|1?[0-7]?[0-9]?)(([.][0-9]{1,4})?)|180(([.][0]{1,4})?))'])) {
        $this->response->setError(10001, '缺少或经纬度格式不正确');
        $this->response->send();
    }

    if (!$this->validator->check('latitude', ['required', 'regex' => '-?((0|[1-8]?[0-9]?)(([.][0-9]{1,4})?)|90(([.][0]{1,4})?))'])) {
        $this->response->setError(10001, '缺少或经纬度格式不正确');
        $this->response->send();
    }

    // 设置默认分页参数
    $page = isset($_POST['page']) && $_POST['page'] >= 1 ? $_POST['page'] : 1;

    // 查询符合条件的商家总数
    $queryCount = "
        SELECT COUNT(*) AS total FROM business_data
        WHERE status = 1 AND (
            6371 * ACOS(
                COS(RADIANS(" . $_POST['latitude'] . ")) 
                * COS(RADIANS(latitude)) 
                * COS(RADIANS(longitude) - RADIANS(" . $_POST['longitude'] . ")) 
                + SIN(RADIANS(" . $_POST['latitude'] . ")) 
                * SIN(RADIANS(latitude))
            )
        ) < 10
    ";
    $totalRecords = M()->query($queryCount)[0]['total'];
    $totalPages = ceil($totalRecords / C('PAGE_LIMIT'));
    $totalPages = $totalPages ? $totalPages : 1;

    if ($page > $totalPages) {
        $this->response->setError(10002, '页数超出范围');
        $this->response->send();
    }

    // 计算分页偏移量
    $offset = ($page - 1) * C('PAGE_LIMIT');

    // 查询具体商家列表
    $queryList = "
        SELECT id, name, info, (
            6371 * ACOS(
                COS(RADIANS(" . $_POST['latitude'] . ")) 
                * COS(RADIANS(latitude)) 
                * COS(RADIANS(longitude) - RADIANS(" . $_POST['longitude'] . ")) 
                + SIN(RADIANS(" . $_POST['latitude'] . ")) 
                * SIN(RADIANS(latitude))
            )
        ) AS distance FROM business_data
        WHERE status = 1 AND distance < 10
        ORDER BY distance ASC
        LIMIT $offset, " . C('PAGE_LIMIT') . "
    ";
    $businessList = M()->query($queryList);

    if ($businessList) {
        // 处理商家主图
        $businessImageModel = M('business_image');
        foreach ($businessList as &$item) {
            $mainImage = $businessImageModel->where([
                'business_id' => $item['id'],
                'type' => 1,
                'is_main' => 1
            ])->find();

            $item['image'] = $mainImage['image'];
            if (strpos($item['image'], 'cdn') === false) {
                $item['image'] = C('CDN_URL') . $item['image'];
            }
        }

        $result = [
            'list' => $businessList,
            'current_page' => $page,
            'total_pages' => $totalPages
        ];

        $this->response->setError(0, '查询成功');
        $this->response->setData($result);
        $this->response->send();
    } else {
        $this->response->setError(10003, '暂无数据');
        $this->response->send();
    }
}

返回的JSON结果示例:

{
    "errno": 0,
    "errdesc": "查询成功",
    "timestamp": 1524749336,
    "data": {
        "list": [
            {
                "id": "3",
                "name": "京东",
                "info": "京东",
                "distance": "4.665364145881758",
                "image": "https://cdn.caomall.net/1524732806744365022.png"
            }
        ],
        "current_page": "1",
        "total_pages": 1
    }
}
标签: MySQLPHP

相关文章

可以按小时收费的VPS

很多 VPS 提供商都支持 按小时计费(hourly billing),想短期试用 / 临时搭建节点、测试网络、短期项目等场景非常合适。下面是当前最主流且靠谱的按小时 VPS 选项,分别按不同需求场景整理: 1. Vultr(全球节点,包括日本) 按小时计费 可选机房:东京 / 大阪 / 洛杉矶 / 法兰克福 / 伦敦 … 支持 PayPal(部分情况),但更常用信用卡/PayPal+卡价格参考$...

在 iPhone 上下载国外App

地区/国家限制App Store 会根据 Apple ID 的国家或地区限制应用下载。如果你的 Apple ID 绑定的是中国大陆,就可能无法下载 OpenAI 官方的 ChatGPT 应用,因为它在大陆 App Store 不上架。解决办法:换成美国、加拿大、香港等地区的 Apple ID。或者在现有 Apple ID 上更改地区。注册一个国外 Apple ID(推荐)比如注册 美国区 Appl...

Node.js 中的异步编程:回调与 Promise

Node.js 是一个基于 JavaScript 构建的单线程、非阻塞运行环境,它通过异步编程机制来高效处理多个操作。在执行如文件读取、API 请求或数据库查询等任务时,Node.js 不会等待这些操作完成,而是使用回调函数和 Promise 来避免阻塞主线程。 回调方式实现异步 那么当异步操作完成后,Node.js 如何知道接下来要做什么呢?这就要用到 回调函数(callback)。 回调本质上...

Selenium自动化测试入门指南

Selenium自动化测试入门指南

什么是自动化测试? 自动化测试是指利用软件工具自动执行测试用例,模拟用户操作,如打开网页、点击链接、输入文本等,并验证结果是否符合预期。 其主要优点包括: 大幅减少人工成本 测试速度快 可以在非工作时间运行 支持持续集成和交付 然而,它也存在一些局限性,例如开发成本较高、不适合快速变化的项目、依赖稳定的UI界面等。 自动化测试的应用条件 适合引入自动化测试的情况包括: 手动测试耗时且需要大量...

MariaDB Galera集群故障快速恢复指南

OpenStack控制节点采用三节点MariaDB Galera集群架构。当数据库集群因故障重启时,有时会出现Galera集群无法正常启动的问题。虽然有多种方法可以恢复数据库服务,但如何实现快速启动同时确保数据完整性呢? 通过分析日志发现,MariaDB Galera集群节点宕机时会在日志中输出以下信息: [Note] WSREP: 新集群视图:全局状态: 874d8e7e-5980-11e8-8...

Android 中 EventBus 的通信机制与实现原理深度解析

EventBus 核心设计思想 EventBus 是一个基于观察者模式的事件总线框架,广泛应用于 Android 平台以实现组件解耦。它通过中心化的消息分发机制,使不同层级、不同线程的对象能够以"发布-订阅"方式通信,避免了传统接口回调或广播带来的强依赖问题。 核心角色说明 事件(Event):任意 Java 对象,作为数据载体,如网络状态变更通知、用户登录信息等。 发布者(Publi...

发表评论

访客

◎欢迎参与讨论,请在这里发表您的看法和观点。