1、项目介绍

技术栈
Flask作为后端Web框架，Vue用于前端页面构建，Echarts和BaiduMap实现数据可视化与地图展示，去哪儿网为数据采集来源，Python负责爬虫开发与业务逻辑处理。

功能模块
· 用户登录模块
· 数据采集模块
· 旅游景点数据中心模块
· 旅游景点数据分析大屏模块
· 旅游景点等级与热度分析模块
· 旅游景点地区分布与销量分析模块
· 后台管理模块

项目介绍
本系统是一个基于Python的旅游大数据分析可视化平台。系统通过爬虫技术对去哪儿网旅游数据进行自动化采集，获取景点名称、等级、地址、价格、销量、热度等关键信息，并将数据存储于数据库中。后端采用Flask框架进行业务逻辑处理，前端使用Vue框架构建交互式页面，结合Echarts图表库和BaiduMap地图组件实现数据可视化展示。系统提供数据中心表格管理、数据大屏多维度分析、等级热度分析、地区分布与销量分析等功能模块，能够以漏斗图、地图、饼图、柱状图、环形图、气泡图等多种形式展示最热景点、景点等级分布、价格销量关联、省份景点数量等分析结果，为用户提供全面的旅游数据查询与分析工具，辅助旅游市场决策与趋势洞察。

2、项目界面

旅游景点数据分析大屏
这是旅游景点数据分析系统的可视化大屏页面，系统包含数据采集、后台管理、数据分析与可视化等功能模块，当前大屏通过漏斗图展示最热景点，以地图呈现热门景点分布，搭配饼图、柱状图和环形图分别呈现热点城市景点销量、景区销售统计、城市销售排行及行政区销量分析，多维度直观呈现旅游数据核心指标，辅助旅游决策与趋势洞察。

旅游景点数据中心
这是旅游景点数据分析系统的数据中心页面，系统包含数据采集、后台管理、数据分析与可视化等功能模块，当前页面以表格形式展示景点的id、名称、等级、地址、价格、销量、热度等信息，支持省份筛选、名称搜索，还可对景点进行查看、编辑、删除和新增操作，实现旅游数据的高效管理与维护。

旅游景点等级与热度分析
这是旅游景点数据分析系统的等级与热度分析页面，系统包含数据采集、后台管理、数据分析与可视化等功能模块，当前页面通过环形图展示景点等级分布情况，以柱状图呈现各等级景点平均热度，用气泡图分析景点价格与销量的关联，多维度直观呈现旅游数据的等级、热度及消费特征，辅助旅游市场洞察与决策。

旅游景点地区分布与销量分析
这是旅游景点数据分析系统的地区分布与销量分析页面，系统包含数据采集、后台管理、数据分析与可视化等功能模块，当前页面通过柱状图展示各省份景点数量和热门城市景点销量排行，以地图呈现景点销量地区分布，直观呈现旅游资源与销量的地域特征，辅助区域旅游市场决策。

用户登录
这是旅游数据分析系统的登录页面，系统包含数据采集、后台管理、数据分析与可视化等功能模块，当前页面提供账号密码输入与登录功能，支持新用户注册入口，用于完成用户身份验证，保障系统数据安全与权限分配，是进入系统各功能模块的前置入口。

3、项目说明

一、技术栈简要说明
本系统基于Python语言开发，采用Flask作为后端Web框架，负责业务逻辑处理与API接口构建。前端使用Vue框架进行页面搭建，实现单页应用效果与交互体验。数据可视化方面，结合Echarts图表库和BaiduMap地图组件，实现多样化的数据展示与地理信息呈现。数据采集通过Python爬虫技术对去哪儿网旅游页面进行自动化抓取，获取景点核心信息。MySQL数据库用于存储采集到的旅游数据，确保数据持久化与高效管理。

二、功能模块详细介绍
· 用户登录模块
系统设置用户登录页面，提供账号密码输入与登录验证功能，支持新用户注册入口。该模块用于完成用户身份验证，保障系统数据安全与权限分配，是进入系统各功能模块的前置入口，确保只有授权用户才能访问数据采集、分析与后台管理等功能。

· 数据采集模块
该模块通过Python编写的爬虫脚本，对去哪儿网旅游页面进行自动化数据抓取。爬取过程中获取景点名称、等级、地址、价格、销量、热度等关键字段，并对数据进行清洗和格式化处理。采集到的数据存入MySQL数据库，为后续的数据分析与可视化展示提供基础数据支撑。

· 旅游景点数据中心模块
模块以表格形式展示景点的id、名称、等级、地址、价格、销量、热度等详细信息。页面支持省份筛选和名称搜索功能，方便用户快速定位目标景点。同时提供对景点的查看、编辑、删除和新增操作，实现旅游数据的高效管理与维护，确保数据的准确性和实时性。

· 旅游景点数据分析大屏模块
该模块是系统的可视化核心页面，通过大屏形式多维度展示旅游数据。漏斗图呈现最热景点排名，地图展示热门景点地理位置分布，饼图分析热点城市景点销量占比，柱状图展示景区销售统计，环形图呈现城市销售排行，此外还包含行政区销量分析。多种图表组合直观呈现旅游数据核心指标，辅助旅游决策与趋势洞察。

· 旅游景点等级与热度分析模块
模块通过环形图展示景点等级分布情况，清晰呈现不同等级景区的比例结构。以柱状图形式呈现各等级景点平均热度，对比分析等级与热度的关联特征。采用气泡图分析景点价格与销量的关系，直观展示价格区间与市场表现的分布规律，多维度呈现旅游数据的等级、热度及消费特征。

· 旅游景点地区分布与销量分析模块
该模块通过柱状图展示各省份景点数量，对比不同地区的旅游资源丰富程度。热门城市景点销量排行以柱状图呈现，直观反映各城市旅游市场的热度差异。地图组件呈现景点销量地区分布，用颜色深浅或标记大小表示销量高低，直观呈现旅游资源与销量的地域特征，辅助区域旅游市场决策。

· 后台管理模块
后台管理模块提供对系统数据的全面维护功能，包括景点数据管理、用户信息管理、权限分配等。管理员可对采集到的旅游数据进行审核、修改和更新，管理注册用户账号信息，分配不同用户的操作权限，确保系统运行的安全性与数据的可维护性。

三、项目总结
本系统是一个集数据采集、多维度分析、可视化展示与后台管理于一体的旅游大数据平台。通过Python爬虫技术实现对去哪儿网旅游数据的自动化采集，解决了数据获取的效率问题。后端采用Flask框架构建稳定可靠的API服务，前端使用Vue框架打造流畅的交互体验，结合Echarts和BaiduMap实现丰富多样的数据可视化效果。系统涵盖用户登录、数据采集、数据中心管理、数据大屏展示、等级热度分析、地区分布与销量分析、后台管理等功能模块，能够以漏斗图、地图、饼图、柱状图、环形图、气泡图等多种形式展示最热景点、景点等级分布、价格销量关联、省份景点数量等分析结果。整个项目实现了从数据采集、存储、分析到可视化展示的完整闭环，为用户提供全面的旅游数据查询与分析工具，有效辅助旅游市场决策与趋势洞察。

4、核心代码

from flask import Flask, request, jsonify
from flask_sqlalchemy import SQLAlchemy
from flask_marshmallow import Marshmallow
from sqlalchemy.sql import func
import json
from flask_socketio import SocketIO
import threading
import time
from werkzeug.security import generate_password_hash, check_password_hash

app = Flask(__name__)
app.config['SQLALCHEMY_DATABASE_URI'] = 'mysql+pymysql://root:123456@localhost/baidumap_tour'
app.config['SQLALCHEMY_TRACK_MODIFICATIONS'] = False
app.config['JSON_AS_ASCII'] = False
app.secret_key = 'your-secret-key-here'  # 在生产环境中应该使用更安全的密钥

db = SQLAlchemy(app)
ma = Marshmallow(app)

# 用户模型
class User(db.Model):
    __tablename__ = 'users'
    id = db.Column(db.Integer, primary_key=True)
    username = db.Column(db.String(80), unique=True, nullable=False)
    email = db.Column(db.String(120), unique=True, nullable=False)
    password_hash = db.Column(db.String(128), nullable=False)
    
    def set_password(self, password):
        self.password_hash = generate_password_hash(password)
        
    def check_password(self, password):
        return check_password_hash(self.password_hash, password)

class Tour(db.Model):
    __tablename__ = 'tb_tour'  # 表名
    id = db.Column(db.Integer, primary_key=True, autoincrement=True)
    name = db.Column(db.String(500))
    grade = db.Column(db.String(20))
    address = db.Column(db.String(500))
    intro = db.Column(db.String(500))
    hot = db.Column(db.DECIMAL)
    price = db.Column(db.DECIMAL)
    msold = db.Column(db.Integer)
    lng = db.Column(db.DECIMAL)
    lat = db.Column(db.DECIMAL)
    img = db.Column(db.String(500))
    province = db.Column(db.String(90))
    city = db.Column(db.String(90))
    district = db.Column(db.String(90))

    def __init__(self, name, grade, address, intro, hot, price, msold, lng, lat, img, province, city, district):
        self.name = name
        self.grade = grade
        self.address = address
        self.intro = intro
        self.hot = hot
        self.price = price
        self.msold = msold
        self.lng = lng
        self.lat = lat
        self.img = img
        self.province = province
        self.city = city
        self.district = district

# Tour模型的序列化器
class TourSchema(ma.Schema):
    class Meta:
        fields = ('id', 'name', 'grade', 'address', 'intro', 'hot', 'price', 'msold', 'lng', 'lat', 'img', 'province', 'city', 'district')

tour_schema = TourSchema()
tours_schema = TourSchema(many=True)

# 创建数据表
@app.before_first_request
def create_tables():
    db.create_all()

# 用户注册API
@app.route('/api/auth/register', methods=['POST'])
def register():
    try:
        data = request.get_json()
        username = data.get('username')
        email = data.get('email')
        password = data.get('password')
        
        # 检查必填字段
        if not username or not email or not password:
            return jsonify({'code': 400, 'message': '用户名、邮箱和密码不能为空'}), 400
        
        # 检查用户是否已存在
        if User.query.filter_by(username=username).first():
            return jsonify({'code': 400, 'message': '用户名已存在'}), 400
        
        if User.query.filter_by(email=email).first():
            return jsonify({'code': 400, 'message': '邮箱已被注册'}), 400
        
        # 创建新用户
        user = User(username=username, email=email)
        user.set_password(password)
        db.session.add(user)
        db.session.commit()
        
        return jsonify({'code': 200, 'message': '注册成功'}), 200
    except Exception as e:
        db.session.rollback()
        return jsonify({'code': 500, 'message': '服务器内部错误'}), 500