Add application file

.env

@@ -0,0 +1,22 @@
+# 数据库连接信息
+DATABASE_URL="mysql+pymysql://root:mysql00@localhost:3306/xxxx"
+#DATABASE_URL="mysql+pymysql://root:root%40000@101.126.146.60:33066/xxxx"
+
+# 用于JWT签名的密钥
+SECRET_KEY="your-secret-key-here"
+
+# 算法
+ALGORITHM="HS256"
+
+# 访问令牌过期时间（分钟）
+ACCESS_TOKEN_EXPIRE_MINUTES=600
+
+# Cloudflare R2 配置
+R2_ACCOUNT_ID="efcdfff6eb9a02a52320c089f89bcd39"
+R2_ACCESS_KEY_ID="5a43e2f19b371745dc68f8a3e939fe40"
+R2_SECRET_ACCESS_KEY="cf6421cc77954373a34b65925d34c9234e49679d8d31bc46a1404862af5c308e"
+R2_BUCKET_NAME="yomaton"
+R2_PUBLIC_URL="https://img.yomaton.com"
+
+# 是否启用 R2 上传（true/false）
+R2_ENABLED=true

Dockerfile

@@ -0,0 +1,23 @@
+# 基础镜像：python 3.11-slim（你的项目唯一稳定版本）
+FROM python:3.11-slim
+
+# 创建用户（和示例保持一致）
+RUN useradd -m -u 1000 user
+USER user
+ENV PATH="/home/user/.local/bin:$PATH"
+
+# 工作目录
+WORKDIR /app
+
+# 复制依赖清单
+COPY --chown=user ./requirements.txt requirements.txt
+
+# 安装依赖 + 额外缺失包（pillow, email-validator, pydantic[email]）
+RUN pip install --no-cache-dir pillow email-validator pydantic[email] -i https://mirrors.aliyun.com/pypi/simple/ \
+    && pip install --no-cache-dir --upgrade -r requirements.txt -i https://mirrors.aliyun.com/pypi/simple/
+
+# 复制全部项目代码
+COPY --chown=user . /app
+
+# 启动命令（你的命令：main.py runserver 8000）
+CMD ["python", "main.py", "runserver", "0.0.0.0:8000"]

config/certification_types.py

@@ -0,0 +1,35 @@
+# 商品认证类型配置文件
+# 包含主流外贸产品常用的认证类型
+
+DEFAULT_CERTIFICATION_TYPES = [
+    {
+        "value": "CE",
+        "label": "CE",
+        "description": "欧盟强制性安全认证"
+    },
+    {
+        "value": "FDA",
+        "label": "FDA",
+        "description": "美国食品药品监督管理局认证"
+    },
+    {
+        "value": "RoHS",
+        "label": "RoHS",
+        "description": "欧盟环保认证"
+    },
+    {
+        "value": "FCC",
+        "label": "FCC",
+        "description": "美国联邦通信委员会认证"
+    },
+    {
+        "value": "ISO",
+        "label": "ISO",
+        "description": "国际标准化组织认证"
+    },
+    {
+        "value": "OTHER",
+        "label": "OTHER",
+        "description": "其他认证类型"
+    }
+]

config/default_companies.py

@@ -0,0 +1,22 @@
+# 默认会员公司数据
+DEFAULT_COMPANIES = [
+    {
+        "company_code": "ymt0",
+        "name": "云贸通测试公司",
+        "description": "云贸通智能科技测试公司",
+        "phone": "13800138000",
+        "email": "test@ymt.com",
+        "address": "北京市朝阳区"
+    }
+]
+
+# 默认会员账号数据
+DEFAULT_USERS = [
+    {
+        "username": "ymt0",
+        "email": "ymt0@ymt.com",
+        "password": "ymt123456",  # 原始密码
+        "is_superadmin": False,
+        "company_code": "ymt0"
+    }
+]

config/member_levels.py

@@ -0,0 +1,77 @@
+# 会员等级配置文件
+# 包含不同会员等级的权益配置
+
+DEFAULT_MEMBER_LEVELS = [
+    {
+        "level": 0,
+        "name": "普通会员",
+        "description": "普通会员",
+        "annual_fee": 5980,
+        "discount_price": 5980,
+        "deployment_nodes": 1,
+        "email_marketing_limit": 10000,
+        "product_sku_limit": 100,
+        "sku_image_limit": 10,
+        "image_size_limit": 5,
+        "sku_video_limit": 1,
+        "image_storage_limit": 10,
+        "template_access": False,
+        "geo_seo_access": False,
+        "social_automation_access": False,
+        "custom_development_access": False
+    },
+    {
+        "level": 1,
+        "name": "金卡会员",
+        "description": "金卡会员",
+        "annual_fee": 9680,
+        "discount_price": 9680,
+        "deployment_nodes": 3,
+        "email_marketing_limit": 30000,
+        "product_sku_limit": 1000,
+        "sku_image_limit": 10,
+        "image_size_limit": 5,
+        "sku_video_limit": 1,
+        "image_storage_limit": 10,
+        "template_access":True,
+        "geo_seo_access": True,
+        "social_automation_access": False,
+        "custom_development_access": False
+    },
+    {
+        "level": 2,
+        "name": "钻石会员",
+        "description": "钻石会员",
+        "annual_fee": 16800,
+        "discount_price": 16800,
+        "deployment_nodes": 6,
+        "email_marketing_limit": 30000,
+        "product_sku_limit": 10000,
+        "sku_image_limit": 10,
+        "image_size_limit": 5,
+        "sku_video_limit": 1,
+        "image_storage_limit": 10,
+        "template_access": True,
+        "geo_seo_access": True,
+        "social_automation_access": True,
+        "custom_development_access": False
+    },
+        {
+        "level": 3,
+        "name": "皇冠会员",
+        "description": "定制化会员",
+        "annual_fee": 26800,
+        "discount_price": 26800,
+        "deployment_nodes": 6,
+        "email_marketing_limit": 50000,
+        "product_sku_limit": 10000,
+        "sku_image_limit": 10,
+        "image_size_limit": 5,
+        "sku_video_limit": 1,
+        "image_storage_limit": 10,
+        "template_access": True,
+        "geo_seo_access": True,
+        "social_automation_access": True,
+        "custom_development_access": True
+    }
+]

config/templates.py

@@ -0,0 +1,239 @@
+# 模板配置文件
+# 包含20+主流外贸独立站模板风格
+
+DEFAULT_TEMPLATES = [
+    {
+        "key": "Home",
+        "name": "通用外贸",
+        "description": "适合大多数外贸行业的通用模板",
+        "color": "#3498db",
+        "features": ["响应式设计", "多语言支持", "产品展示"],
+        "applicable_scene": "通用外贸行业",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Electronics",
+        "name": "电子产品",
+        "description": "专为电子产品行业设计的模板",
+        "color": "#27ae60",
+        "features": ["产品对比", "技术规格", "客户评价"],
+        "applicable_scene": "电子产品、数码设备",
+        "regions": ["欧美", "全球"]
+    },
+    {
+        "key": "Fashion",
+        "name": "时尚服装",
+        "description": "专为时尚服装行业设计的模板",
+        "color": "#e74c3c",
+        "features": ["图片轮播", "搭配推荐", "季节趋势"],
+        "applicable_scene": "服装、配饰、时尚产品",
+        "regions": ["欧美", "全球"]
+    },
+    {
+        "key": "Furniture",
+        "name": "家居家具",
+        "description": "专为家居家具行业设计的模板",
+        "color": "#f39c12",
+        "features": ["3D展示", "空间搭配", "材质说明"],
+        "applicable_scene": "家具、家居用品、装饰品",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Robotics",
+        "name": "机器人",
+        "description": "专为机器人行业设计的模板",
+        "color": "#9b59b6",
+        "features": ["技术参数", "应用场景", "视频展示"],
+        "applicable_scene": "工业机器人、服务机器人、智能设备",
+        "regions": ["欧美", "全球"]
+    },
+    {
+        "key": "Medical",
+        "name": "医疗器械",
+        "description": "专为医疗器械行业设计的模板",
+        "color": "#1abc9c",
+        "features": ["产品认证", "技术文档", "案例展示"],
+        "applicable_scene": "医疗设备、健康产品、医疗器械",
+        "regions": ["欧美", "全球"]
+    },
+    {
+        "key": "Automotive",
+        "name": "汽车配件",
+        "description": "专为汽车配件行业设计的模板",
+        "color": "#e67e22",
+        "features": ["适配车型", "安装指南", "质量认证"],
+        "applicable_scene": "汽车零部件、汽车用品、改装配件",
+        "regions": ["欧美", "全球"]
+    },
+    {
+        "key": "Beauty",
+        "name": "美容美妆",
+        "description": "专为美容美妆行业设计的模板",
+        "color": "#f1948a",
+        "features": ["产品功效", "使用方法", "用户评价"],
+        "applicable_scene": "化妆品、护肤品、美容工具",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Sports",
+        "name": "运动户外",
+        "description": "专为运动户外行业设计的模板",
+        "color": "#e84118",
+        "features": ["产品参数", "使用场景", "用户体验"],
+        "applicable_scene": "运动器材、户外装备、健身用品",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Toys",
+        "name": "玩具礼品",
+        "description": "专为玩具礼品行业设计的模板",
+        "color": "#e1b12c",
+        "features": ["年龄适用", "安全认证", "创意展示"],
+        "applicable_scene": "儿童玩具、礼品、益智产品",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Jewelry",
+        "name": "珠宝首饰",
+        "description": "专为珠宝首饰行业设计的模板",
+        "color": "#8e44ad",
+        "features": ["材质说明", "工艺展示", "证书认证"],
+        "applicable_scene": "珠宝、首饰、配饰",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Food",
+        "name": "食品饮料",
+        "description": "专为食品饮料行业设计的模板",
+        "color": "#c0392b",
+        "features": ["营养成分", "生产工艺", "品尝体验"],
+        "applicable_scene": "食品、饮料、保健品",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Pet",
+        "name": "宠物用品",
+        "description": "专为宠物用品行业设计的模板",
+        "color": "#16a085",
+        "features": ["适用宠物", "产品功能", "用户反馈"],
+        "applicable_scene": "宠物食品、宠物用品、宠物玩具",
+        "regions": ["欧美", "全球"]
+    },
+    {
+        "key": "Office",
+        "name": "办公文具",
+        "description": "专为办公文具行业设计的模板",
+        "color": "#34495e",
+        "features": ["产品规格", "适用场景", "批量采购"],
+        "applicable_scene": "办公用品、文具、办公设备",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Building",
+        "name": "建筑建材",
+        "description": "专为建筑建材行业设计的模板",
+        "color": "#7f8c8d",
+        "features": ["材料规格", "施工指南", "质量认证"],
+        "applicable_scene": "建筑材料、装饰材料、五金工具",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Packaging",
+        "name": "包装印刷",
+        "description": "专为包装印刷行业设计的模板",
+        "color": "#2c3e50",
+        "features": ["定制服务", "印刷工艺", "样品展示"],
+        "applicable_scene": "包装材料、印刷制品、定制包装",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Energy",
+        "name": "能源环保",
+        "description": "专为能源环保行业设计的模板",
+        "color": "#22a7f0",
+        "features": ["节能效果", "环保认证", "技术参数"],
+        "applicable_scene": "太阳能产品、节能设备、环保材料",
+        "regions": ["欧美", "全球"]
+    },
+    {
+        "key": "Textile",
+        "name": "纺织面料",
+        "description": "专为纺织面料行业设计的模板",
+        "color": "#ec407a",
+        "features": ["面料材质", "规格参数", "应用领域"],
+        "applicable_scene": "纺织品、面料、服装辅料",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Hardware",
+        "name": "五金工具",
+        "description": "专为五金工具行业设计的模板",
+        "color": "#7d5fff",
+        "features": ["工具规格", "使用方法", "质量保证"],
+        "applicable_scene": "五金工具、电动工具、手动工具",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Chemicals",
+        "name": "化工产品",
+        "description": "专为化工产品行业设计的模板",
+        "color": "#00b894",
+        "features": ["产品规格", "安全说明", "应用领域"],
+        "applicable_scene": "化工原料、化学制品、工业化学品",
+        "regions": ["全球"]
+    },
+    {
+        "key": "Agriculture",
+        "name": "农业产品",
+        "description": "专为农业产品行业设计的模板",
+        "color": "#6ab04c",
+        "features": ["产品规格", "种植技术", "质量认证"],
+        "applicable_scene": "农产品、农业设备、农业用品",
+        "regions": ["全球"]
+    },
+    {
+        "key": "SoutheastAsia",
+        "name": "东南亚风格",
+        "description": "专为东南亚市场设计的模板，融入当地文化元素",
+        "color": "#ff6b6b",
+        "features": ["热带风格", "本地化语言", "移动优先"],
+        "applicable_scene": "面向东南亚市场的各类产品",
+        "regions": ["东南亚"]
+    },
+    {
+        "key": "MiddleEast",
+        "name": "中东风格",
+        "description": "专为中东市场设计的模板，考虑当地文化和宗教因素",
+        "color": "#feca57",
+        "features": ["符合当地文化", "多语言支持", "尊贵感设计"],
+        "applicable_scene": "面向中东市场的各类产品",
+        "regions": ["中东"]
+    },
+    {
+        "key": "European",
+        "name": "欧洲风格",
+        "description": "专为欧洲市场设计的模板，体现欧洲美学和品味",
+        "color": "#54a0ff",
+        "features": ["简约优雅", "高质量视觉", "环保理念"],
+        "applicable_scene": "面向欧洲市场的各类产品",
+        "regions": ["欧洲"]
+    },
+    {
+        "key": "American",
+        "name": "美国风格",
+        "description": "专为美国市场设计的模板，体现美国消费者偏好",
+        "color": "#48dbfb",
+        "features": ["大胆设计", "清晰信息", "快速加载"],
+        "applicable_scene": "面向美国市场的各类产品",
+        "regions": ["美洲"]
+    },
+    {
+        "key": "EastAsia",
+        "name": "东亚风格",
+        "description": "专为东亚市场设计的模板，融入东亚文化元素",
+        "color": "#ff9ff3",
+        "features": ["精致设计", "细腻体验", "社交分享"],
+        "applicable_scene": "面向东亚市场的各类产品",
+        "regions": ["东亚"]
+    }
+]

create_tables.py

@@ -0,0 +1,23 @@
+from database import engine, Base
+from models.product import Product
+from models.company import Company
+from models.user import User
+from models.category import Category
+from models.membership import Membership
+from models.operation_log import OperationLog
+from models.contact import Contact
+from models.template import Template
+from models.member_level import MemberLevel
+from models.customer_relationship import CustomerRelationship
+
+print("=" * 80)
+print("开始创建数据库表...")
+print("=" * 80)
+
+# 创建所有表
+Base.metadata.create_all(bind=engine)
+
+print()
+print("=" * 80)
+print("所有表创建完成！")
+print("=" * 80)

database.py

@@ -0,0 +1,111 @@
+from sqlalchemy import create_engine
+from sqlalchemy.ext.declarative import declarative_base
+from sqlalchemy.orm import sessionmaker
+from dotenv import load_dotenv
+import os
+import pymysql
+
+# 加载环境变量
+load_dotenv()
+
+# 获取数据库连接 URL
+DATABASE_URL = os.getenv("DATABASE_URL")
+
+# 处理MySQL数据库自动创建
+if DATABASE_URL.startswith("mysql"):
+    # 解析数据库连接信息
+    import re
+    match = re.match(r"mysql\+pymysql://([^:]+):([^@]+)@([^:]+):(\d+)/(.+)", DATABASE_URL)
+    if match:
+        user, password, host, port, db_name = match.groups()
+        port = int(port)
+        
+        # 先连接到MySQL服务器
+        try:
+            # 连接到MySQL服务器（不指定数据库）
+            conn = pymysql.connect(
+                host=host,
+                port=port,
+                user=user,
+                password=password,
+                charset='utf8mb4'
+            )
+            cursor = conn.cursor()
+            
+            # 检查数据库是否存在
+            cursor.execute(f"SHOW DATABASES LIKE '{db_name}'")
+            result = cursor.fetchone()
+            
+            # 如果数据库不存在，创建它
+            if not result:
+                cursor.execute(f"CREATE DATABASE {db_name} CHARACTER SET utf8mb4 COLLATE utf8mb4_unicode_ci")
+                print(f"数据库 {db_name} 已创建")
+            
+            cursor.close()
+            conn.close()
+        except Exception as e:
+            print(f"创建数据库时出错: {e}")
+
+# 创建数据库引擎
+# 对于SQLite，需要添加check_same_thread参数
+if DATABASE_URL.startswith("sqlite"):
+    engine = create_engine(DATABASE_URL, connect_args={"check_same_thread": False})
+else:
+    # 对于MySQL，添加charset参数确保utf8编码
+    if DATABASE_URL.startswith("mysql"):
+        engine = create_engine(DATABASE_URL + "?charset=utf8mb4")
+    else:
+        engine = create_engine(DATABASE_URL)
+
+# 创建会话工厂
+SessionLocal = sessionmaker(autocommit=False, autoflush=False, bind=engine)
+
+# 创建基类
+Base = declarative_base()
+
+# 检查表结构并自动更新
+def check_and_update_tables():
+    """检查表结构是否与models一致，不一致则自动更新"""
+    try:
+        # 导入所有模型，确保它们被注册到 Base
+        from models.product import Product
+        from models.company import Company
+        from models.user import User
+        from models.category import Category
+        from models.membership import Membership
+        from models.operation_log import OperationLog
+        from models.contact import Contact
+        from models.template import Template
+        from models.member_level import MemberLevel
+        from models.customer_relationship import CustomerRelationship
+        from models.product_certification import ProductCertification
+        from models.product_media import ProductMedia
+        from models.product_packaging import ProductPackaging
+        from models.company_r2_config import CompanyR2Config
+        from models.media import Media, MediaTag, MediaTagMapping, MediaDirectory
+        
+        # 检查数据库连接
+        with engine.connect() as conn:
+            print("数据库连接成功")
+                
+        # 自动创建不存在的表
+        Base.metadata.create_all(bind=engine)
+        print("表结构检查完成，不存在的表已创建")
+        
+        # 注意：SQLAlchemy的create_all()只会创建不存在的表，不会更新已存在表的结构
+        # 对于表结构的更新，建议使用Alembic迁移工具
+        # print("提示：已存在表的结构更新需要使用Alembic迁移工具")
+        
+    except Exception as e:
+        print(f"检查表结构时出错: {e}")
+
+# 调用检查表结构的函数
+check_and_update_tables()
+
+# 依赖项，用于获取数据库会话
+def get_db():
+    db = SessionLocal()
+    try:
+        yield db
+    finally:
+        db.close()

main.py

@@ -0,0 +1,181 @@
+from fastapi import FastAPI
+from fastapi.middleware.cors import CORSMiddleware
+from fastapi.staticfiles import StaticFiles
+from fastapi.responses import FileResponse
+from routers import auth, company, categories, products, product_certifications, product_media, product_packaging, membership, operation_log, contact, template, customer_relationship, member_level, r2_config, media, statistics
+from database import engine, Base, get_db
+from sqlalchemy.orm import Session
+import json
+import os
+from pathlib import Path
+from dotenv import load_dotenv
+from datetime import datetime, timedelta
+
+# 导入中间件
+from middleware.trace import TraceMiddleware
+
+# 导入日志模块
+from utils.logger import logger
+
+# 加载 .env 文件
+load_dotenv()
+
+# 导入模板配置
+from config.templates import DEFAULT_TEMPLATES
+# 导入会员等级配置
+from config.member_levels import DEFAULT_MEMBER_LEVELS
+# 导入默认公司和用户配置
+from config.default_companies import DEFAULT_COMPANIES, DEFAULT_USERS
+
+# 导入所有模型，确保它们被注册到Base
+from models.user import User
+from models.company import Company
+from models.category import Category
+from models.product import Product
+from models.membership import Membership
+from models.operation_log import OperationLog
+from models.contact import Contact
+from models.template import Template
+from models.customer_relationship import CustomerRelationship
+from models.member_level import MemberLevel
+from models.company_r2_config import CompanyR2Config
+from models.media import Media, MediaTag, MediaTagMapping, MediaDirectory
+from models.site_visit import SiteVisit
+from utils.auth import get_password_hash
+
+# 数据库表创建已在database.py中处理
+
+app = FastAPI(
+    title="外贸独立站 API",
+    description="用于外贸独立站的后端 API",
+    version="1.0.0"
+)
+
+# 配置 CORS
+app.add_middleware(
+    CORSMiddleware,
+    allow_origins=["*"],  # 在生产环境中应该设置具体的前端域名
+    allow_credentials=True,
+    allow_methods=["*"],
+    allow_headers=["*"],
+)
+
+# 添加 TraceMiddleware 中间件
+app.add_middleware(TraceMiddleware)
+
+# 挂载静态文件目录（用于访问上传的图片）
+BASE_DIR = Path(__file__).parent
+IMAGES_DIR = BASE_DIR / "images"
+if IMAGES_DIR.exists():
+    app.mount("/images", StaticFiles(directory=str(IMAGES_DIR)), name="images")
+
+# 注册路由
+# 注意：更具体的路由（如 /{product_number}/media）必须在较不具体的路由（如 /{product_number}）之前注册
+app.include_router(auth.router, prefix="/api/auth", tags=["认证"])
+app.include_router(product_media.router, prefix="/api/products", tags=["产品媒体"])
+app.include_router(product_certifications.router, prefix="/api/products", tags=["产品认证"])
+app.include_router(product_packaging.router, prefix="/api/products", tags=["产品包装"])
+app.include_router(products.router, prefix="/api/products", tags=["产品"])
+app.include_router(company.router, prefix="/api/company", tags=["公司信息"])
+app.include_router(categories.router, prefix="/api/categories", tags=["类目"])
+app.include_router(membership.router, prefix="/api/membership", tags=["会员充值"])
+app.include_router(operation_log.router, prefix="/api/operation-logs", tags=["操作日志"])
+app.include_router(contact.router, prefix="/api/contact", tags=["联系信息管理"])
+app.include_router(template.router, prefix="/api/templates", tags=["模板管理"])
+app.include_router(customer_relationship.router, prefix="/api/customer-relationships", tags=["客户关系管理"])
+app.include_router(member_level.router, prefix="/api/member-levels", tags=["会员等级管理"])
+app.include_router(r2_config.router, prefix="/api/r2-config", tags=["R2 配置管理"])
+app.include_router(media.router, prefix="/api/media", tags=["媒体素材管理"])
+app.include_router(statistics.router, prefix="/api/statistics", tags=["统计指标"])
+
+# 初始化超级管理员用户和默认类目
+@app.on_event("startup")
+def startup_event():
+    try:
+        db = next(get_db())
+        # 检查是否已有超级管理员
+        superadmin = db.query(User).filter(User.is_superadmin == True).first()
+        if not superadmin:
+            # 创建超级管理员
+            superadmin = User(
+                username="admin",
+                email="admin@mail.yomaton.com",
+                password=get_password_hash("admin00"),
+                is_superadmin=True,
+                company_code="0000"
+            )
+            db.add(superadmin)
+            db.commit()
+            logger.info("超级管理员已创建: username=admin, password=admin00")
+        
+        
+        # 创建默认模板
+        for template_data in DEFAULT_TEMPLATES:
+            # 转换features和regions列表为JSON字符串
+            template_data["features"] = json.dumps(template_data["features"], ensure_ascii=False)
+            template_data["regions"] = json.dumps(template_data["regions"], ensure_ascii=False)
+            
+            existing_template = db.query(Template).filter(Template.key == template_data["key"]).first()
+            if not existing_template:
+                new_template = Template(**template_data)
+                db.add(new_template)
+        db.commit()
+        logger.info("默认模板已创建")
+        
+        # 创建默认会员等级
+        for level_data in DEFAULT_MEMBER_LEVELS:
+            existing_level = db.query(MemberLevel).filter(MemberLevel.level == level_data["level"]).first()
+            if not existing_level:
+                new_level = MemberLevel(**level_data)
+                db.add(new_level)
+        db.commit()
+        logger.info("默认会员等级已创建")
+        
+        # 创建默认公司
+        for company_data in DEFAULT_COMPANIES:
+            existing_company = db.query(Company).filter(Company.company_code == company_data["company_code"]).first()
+            if not existing_company:
+                new_company = Company(**company_data)
+                db.add(new_company)
+        db.commit()
+        logger.info("默认公司已创建")
+        
+        # 创建默认用户和会员信息
+        for user_data in DEFAULT_USERS:
+            existing_user = db.query(User).filter(User.username == user_data["username"]).first()
+            if not existing_user:
+                user_data_copy = user_data.copy()
+                user_data_copy["password"] = get_password_hash(user_data_copy["password"])
+                new_user = User(**user_data_copy)
+                db.add(new_user)
+                db.flush()
+                
+                # 为用户创建默认会员信息
+                existing_membership = db.query(Membership).filter(Membership.company_code == user_data["company_code"]).first()
+                if not existing_membership:
+                    new_membership = Membership(
+                        company_code = user_data["company_code"],
+                        level = 0,  # 默认普通会员
+                        start_date = datetime.now(),
+                        end_date = datetime.now() + timedelta(days=365)
+                    )
+                    db.add(new_membership)
+        db.commit()
+        logger.info("默认用户和会员信息已创建")
+    except Exception as e:
+        logger.error(f"初始化数据时出错: {e}")
+
+@app.get("/")
+def read_root():
+    logger.info("访问根路径")
+    return {"message": "欢迎使用外贸独立站 API"}
+
+@app.get("/health")
+def health_check():
+    logger.info("健康检查")
+    return {"status": "healthy"}
+
+if __name__ == "__main__":
+    import uvicorn
+    logger.info("启动应用服务器")
+    uvicorn.run(app, host="0.0.0.0", port=8000)

middleware/trace.py

@@ -0,0 +1,29 @@
+from fastapi import Request, Response
+from starlette.middleware.base import BaseHTTPMiddleware
+import uuid
+from contextvars import ContextVar
+
+# 创建一个上下文变量来存储 trace_id
+trace_id_var = ContextVar('trace_id', default=None)
+
+class TraceMiddleware(BaseHTTPMiddleware):
+    async def dispatch(self, request: Request, call_next) -> Response:
+        # 生成唯一的 trace_id
+        trace_id = str(uuid.uuid4())
+        
+        # 设置上下文变量
+        token = trace_id_var.set(trace_id)
+        
+        try:
+            # 处理请求
+            response = await call_next(request)
+            # 将 trace_id 添加到响应头中
+            response.headers['X-Trace-ID'] = trace_id
+            return response
+        finally:
+            # 清理上下文变量
+            trace_id_var.reset(token)
+
+def get_trace_id():
+    """获取当前请求的 trace_id"""
+    return trace_id_var.get()

models/category.py

@@ -0,0 +1,19 @@
+from sqlalchemy import Column, Integer, String, DateTime, text
+from sqlalchemy.orm import relationship
+from database import Base
+
+class Category(Base):
+    __tablename__ = "categories"
+
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    parent_code = Column(String(100), nullable=False, server_default="", index=True, comment='父分类编码，空为顶级分类')
+    code = Column(String(100), nullable=False, server_default="", index=True, comment='分类编码，级联编码格式')
+    name = Column(String(100), nullable=False, server_default="", index=True, comment='分类名称')
+    sort_order = Column(Integer, nullable=False, server_default="0", comment='排序顺序')
+    status = Column(Integer, nullable=False, server_default="1", comment='状态：0-禁用，1-启用')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码，用于数据隔离')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')
+
+    # 关系
+    products = relationship("Product", back_populates="category")

models/company.py

@@ -0,0 +1,24 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime
+from sqlalchemy.sql import text
+from database import Base
+
+class Company(Base):
+    __tablename__ = "companies"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    company_code = Column(String(50), nullable=False, server_default="", unique=True, index=True, comment='公司编码')
+    name = Column(String(100), nullable=False, server_default="", comment='公司名称')
+    logo_url = Column(String(255), nullable=False, server_default="", comment='公司logo')
+    description = Column(Text, nullable=False, default="", comment='公司描述')
+    address = Column(Text, nullable=False, default="", comment='公司地址')
+    phone = Column(String(50), nullable=False, server_default="", comment='联系电话')
+    email = Column(String(100), nullable=False, server_default="", comment='联系邮箱')
+    website = Column(String(255), nullable=False, server_default="", comment='公司网站')
+    business_license = Column(String(255), nullable=False, server_default="", comment='营业执照')
+    established_date = Column(DateTime, nullable=True, comment='成立日期')
+    employees_count = Column(Integer, nullable=False, server_default="0", comment='员工数量')
+    business_scope = Column(Text, nullable=False, default="", comment='经营范围')
+    level = Column(Integer, nullable=False, server_default="0", comment='会员等级：0-普通会员，1-金卡，2-钻石，3-皇冠')
+    template = Column(String(50), nullable=False, server_default="Home", comment='模板选择')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/company_r2_config.py

@@ -0,0 +1,17 @@
+from sqlalchemy import Column, Integer, String, DateTime
+from sqlalchemy.sql import text
+from database import Base
+
+class CompanyR2Config(Base):
+    __tablename__ = "company_r2_configs"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    company_code = Column(String(50), nullable=False, unique=True, index=True, comment='公司编码，唯一')
+    r2_account_id = Column(String(200), nullable=False, server_default="", comment='R2 账户 ID')
+    r2_access_key_id = Column(String(200), nullable=False, server_default="", comment='R2 访问密钥 ID')
+    r2_secret_access_key = Column(String(200), nullable=False, server_default="", comment='R2 密钥')
+    r2_bucket_name = Column(String(200), nullable=False, server_default="", comment='R2 桶名称')
+    r2_public_url = Column(String(500), nullable=False, server_default="", comment='R2 公共访问 URL')
+    r2_enabled = Column(Integer, nullable=False, server_default="1", comment='是否启用 R2：0-禁用，1-启用')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/contact.py

@@ -0,0 +1,28 @@
+from sqlalchemy import Column, Integer, String, Text, ForeignKey, DateTime
+from sqlalchemy.sql import text
+from database import Base
+
+class Contact(Base):
+    __tablename__ = "contacts"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    company_code = Column(String(50), ForeignKey("companies.company_code"), nullable=False, server_default="", index=True, comment='公司编码')
+    contact_name = Column(String(100), nullable=False, server_default="", comment='联系人姓名')
+    phone = Column(String(50), nullable=False, server_default="", comment='联系电话')
+    email = Column(String(100), nullable=False, server_default="", comment='电子邮箱')
+    position = Column(String(100), nullable=False, server_default="", comment='职位')
+    department = Column(String(100), nullable=False, server_default="", comment='部门')
+    facebook = Column(String(255), nullable=False, server_default="", comment='Facebook账号')
+    facebook_api_key = Column(String(255), nullable=False, server_default="", comment='Facebook API Key')
+    facebook_app_secret = Column(String(255), nullable=False, server_default="", comment='Facebook App Secret')
+    tiktok = Column(String(255), nullable=False, server_default="", comment='TikTok账号')
+    tiktok_api_key = Column(String(255), nullable=False, server_default="", comment='TikTok API Key')
+    tiktok_app_secret = Column(String(255), nullable=False, server_default="", comment='TikTok App Secret')
+    whatsapp = Column(String(50), nullable=False, server_default="", comment='WhatsApp账号')
+    whatsapp_api_key = Column(String(255), nullable=False, server_default="", comment='WhatsApp API Key')
+    whatsapp_app_secret = Column(String(255), nullable=False, server_default="", comment='WhatsApp App Secret')
+    wechat = Column(String(100), nullable=False, server_default="", comment='微信账号')
+    linkedin = Column(String(255), nullable=False, server_default="", comment='LinkedIn账号')
+    note = Column(Text, nullable=False, default="", comment='备注')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/customer_relationship.py

@@ -0,0 +1,18 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime, ForeignKey
+from sqlalchemy.sql import text
+from database import Base
+
+class CustomerRelationship(Base):
+    __tablename__ = "customer_relationships"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码')
+    customer_name = Column(String(100), nullable=False, server_default="", comment='客户名称')
+    contact_person = Column(String(100), nullable=False, server_default="", comment='联系人')
+    phone = Column(String(50), nullable=False, server_default="", comment='电话')
+    email = Column(String(100), nullable=False, server_default="", comment='邮箱')
+    social_media = Column(Text, nullable=False, default="", comment='社交平台账号，JSON格式')
+    address = Column(Text, nullable=False, default="", comment='地址')
+    notes = Column(Text, nullable=False, default="", comment='备注')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/media.py

@@ -0,0 +1,87 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime, ForeignKey, JSON, Enum, Float, Boolean
+from sqlalchemy.sql import text
+from database import Base
+import enum
+
+
+class MediaStatus(enum.Enum):
+    PENDING = "pending"
+    UPLOADING = "uploading"
+    SUCCESS = "success"
+    FAILED = "failed"
+
+
+class MediaTag(Base):
+    """素材标签表"""
+    __tablename__ = "media_tags"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    tag_name = Column(String(50), nullable=False, unique=True, index=True, comment='标签名称')
+    tag_color = Column(String(20), nullable=False, server_default="#3b82f6", comment='标签颜色（hex）')
+    sort_order = Column(Integer, nullable=False, server_default="0", comment='排序顺序')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')
+
+
+class MediaTagMapping(Base):
+    """素材-标签关联表（多对多）"""
+    __tablename__ = "media_tag_mappings"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    media_id = Column(String(32), ForeignKey('media.media_id'), nullable=False, index=True, comment='素材ID')
+    tag_id = Column(Integer, ForeignKey('media_tags.id'), nullable=False, index=True, comment='标签ID')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+
+
+class Media(Base):
+    __tablename__ = "media"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    media_id = Column(String(32), nullable=False, unique=True, index=True, comment='素材唯一ID（32位UUID）')
+    file_name = Column(String(500), nullable=False, comment='原始文件名')
+    r2_key = Column(String(500), nullable=False, server_default="", comment='R2原图对象键（MD5命名）')
+    r2_url = Column(String(500), nullable=False, server_default="", comment='R2原图URL')
+    thumbnail_r2_key = Column(String(500), nullable=False, server_default="", comment='R2缩略图对象键')
+    thumbnail_r2_url = Column(String(500), nullable=False, server_default="", comment='R2缩略图URL')
+    media_type = Column(String(20), nullable=False, server_default="image", comment='媒体类型：image, video')
+    mime_type = Column(String(100), nullable=False, server_default="", comment='MIME类型')
+    file_size = Column(Integer, nullable=False, server_default="0", comment='文件大小（字节）')
+    width = Column(Integer, nullable=True, comment='图片宽度')
+    height = Column(Integer, nullable=True, comment='图片高度')
+    duration = Column(Float, nullable=True, comment='视频时长（秒）')
+    directory_id = Column(Integer, ForeignKey('media_directories.id'), nullable=True, comment='目录ID')
+    status = Column(Enum(MediaStatus), nullable=False, server_default="pending", comment='上传状态')
+    error_message = Column(Text, nullable=True, comment='错误信息')
+    batch_id = Column(String(32), nullable=True, index=True, comment='批次ID（批量上传时使用）')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码')
+    is_deleted = Column(Boolean, nullable=False, server_default="0", index=True, comment='是否已删除：0-未删除，1-已删除')
+    deleted_at = Column(DateTime(timezone=True), nullable=True, comment='删除时间')
+    
+    # 关联关系
+    tags = Column(JSON, nullable=True, comment='标签ID列表（JSON数组）')
+
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')
+
+
+
+class MediaDirectory(Base):
+    __tablename__ = "media_directories"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    name = Column(String(100), nullable=False, comment='目录名称')
+    parent_id = Column(Integer, ForeignKey('media_directories.id'), nullable=True, comment='父目录ID')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码')
+    path = Column(String(500), nullable=False, server_default="", comment='完整路径')
+    level = Column(Integer, nullable=False, server_default="0", comment='目录层级')
+    sort_order = Column(Integer, nullable=False, server_default="0", comment='排序顺序')
+    cover_r2_key = Column(String(500), nullable=True, comment='目录封面图R2键')
+    cover_r2_url = Column(String(500), nullable=True, comment='目录封面图R2URL')
+    description = Column(Text, nullable=True, comment='目录描述')
+    is_public = Column(Boolean, nullable=False, server_default="0", comment='是否公开')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')
+    
+    # 关联关系
+    media_count = Column(Integer, nullable=False, server_default="0", comment='素材数量（缓存字段）')

models/member_level.py

@@ -0,0 +1,26 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime, Boolean, Float
+from sqlalchemy.sql import text
+from database import Base
+
+class MemberLevel(Base):
+    __tablename__ = "member_levels"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    level = Column(Integer, nullable=False, server_default="0", unique=True, index=True, comment='会员等级')
+    name = Column(String(50), nullable=False, server_default="", comment='等级名称')
+    description = Column(Text, nullable=False, default="", comment='等级描述')
+    annual_fee = Column(Float, nullable=False, server_default="0", comment='会员每年权益服务费')
+    discount_price = Column(Float, nullable=False, server_default="0", comment='当前优惠价')
+    deployment_nodes = Column(Integer, nullable=False, server_default="1", comment='独立站部署全球节点数')
+    email_marketing_limit = Column(Integer, nullable=False, server_default="10000", comment='每个月邮件营销推送数量')
+    product_sku_limit = Column(Integer, nullable=False, server_default="100", comment='产品SKU数')
+    sku_image_limit = Column(Integer, nullable=False, server_default="10", comment='每个SKU可加图片数量')
+    image_size_limit = Column(Integer, nullable=False, server_default="5", comment='图片大小限制（MB）')
+    sku_video_limit = Column(Integer, nullable=False, server_default="1", comment='每个SKU可加视频数量')
+    image_storage_limit = Column(Integer, nullable=False, server_default="5", comment='图片空间大小（G）')
+    template_access = Column(Boolean, nullable=False, server_default="0", comment='模板选择权限')
+    geo_seo_access = Column(Boolean, nullable=False, server_default="0", comment='GEO,SEO关键词营销')
+    social_automation_access = Column(Boolean, nullable=False, server_default="0", comment='社交平台自动化营销')
+    custom_development_access = Column(Boolean, nullable=False, server_default="0", comment='定制化需求开发')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/membership.py

@@ -0,0 +1,14 @@
+from sqlalchemy import Column, Integer, String, DateTime, ForeignKey
+from sqlalchemy.sql import func, text
+from database import Base
+
+class Membership(Base):
+    __tablename__ = "membership"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码')
+    level = Column(Integer, nullable=False, server_default="0", comment='会员等级')
+    start_date = Column(DateTime, nullable=True, comment='有效期开始')
+    end_date = Column(DateTime, nullable=True, comment='有效期结束')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/operation_log.py

@@ -0,0 +1,17 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime, ForeignKey
+from sqlalchemy.sql import text
+from database import Base
+
+class OperationLog(Base):
+    __tablename__ = "operation_logs"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    user_id = Column(Integer, nullable=False, server_default="0", comment='操作人ID')
+    username = Column(String(50), nullable=False, server_default="", comment='操作人用户名')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='操作所属公司编码')
+    module = Column(String(50), nullable=False, server_default="", comment='操作模块（如：user, company, product等）')
+    operation_type = Column(String(20), nullable=False, server_default="", comment='操作类型：add, edit, delete')
+    operation_detail = Column(Text, nullable=False, default="", comment='操作详情')
+    before_data = Column(Text, nullable=False, default="", comment='修改前的数据')
+    after_data = Column(Text, nullable=False, default="", comment='修改后的数据')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='操作时间')

models/product.py

@@ -0,0 +1,46 @@
+from sqlalchemy import Column, Integer, String, Float, Text, DateTime, JSON, ForeignKey
+from sqlalchemy.sql import text
+from sqlalchemy.orm import relationship
+from database import Base
+
+class Product(Base):
+    __tablename__ = "products"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    category_id = Column(Integer, ForeignKey("categories.id"), nullable=False, server_default="0", index=True, comment='分类 ID')
+    product_number = Column(String(11), nullable=False, unique=True, index=True, comment='产品货号，11 位 UUID')
+    model = Column(String(50), nullable=False, server_default="", comment='产品型号，业务输入')
+    name = Column(String(200), nullable=False, server_default="", index=True, comment='产品名称')
+    brand = Column(String(100), nullable=False, server_default="", comment='品牌名称')
+    price = Column(Float, nullable=False, server_default="0", comment='价格')
+    original_price = Column(Float, nullable=False, server_default="0", comment='原价')
+    currency = Column(String(10), nullable=False, server_default="USD", comment='货币符号')
+    stock = Column(Integer, nullable=False, server_default="0", comment='库存')
+    min_order = Column(Integer, nullable=False, server_default="1", comment='最小起订量')
+    unit = Column(String(20), nullable=False, server_default="pcs", comment='计量单位')
+    status = Column(Integer, nullable=False, server_default="1", comment='状态：0-下架，1-上架')
+    is_new = Column(Integer, nullable=False, server_default="0", comment='是否新品：0-否，1-是')
+    is_hot = Column(Integer, nullable=False, server_default="0", comment='是否热销：0-否，1-是')
+    is_best_seller = Column(Integer, nullable=False, server_default="0", comment='是否畅销：0-否，1-是')
+    sort_order = Column(Integer, nullable=False, server_default="0", comment='排序顺序')
+    
+    # 商品详情字段
+    description = Column(Text, nullable=False, comment='功能描述')
+    usage = Column(Text, nullable=False, comment='适用范围')
+    material = Column(String(200), nullable=False, server_default="", comment='材质')
+    parameters = Column(Text, nullable=False, comment='其他参数说明')
+    
+    # SEO 字段
+    seo_title_tag = Column(String(200), nullable=False, server_default="", comment='SEO 页面标题')
+    seo_meta_keywords = Column(String(500), nullable=False, server_default="", comment='SEO 元关键词')
+    
+    # 产地字段
+    country_of_origin = Column(String(100), nullable=False, server_default="", comment='原产国')
+    made_in_label = Column(String(100), nullable=False, server_default="", comment='Made in 标签')
+    
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码，用于数据隔离')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')
+    
+    # 关系
+    category = relationship("Category", back_populates="products")

models/product_certification.py

@@ -0,0 +1,17 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime, ForeignKey
+from sqlalchemy.sql import text
+from database import Base
+
+class ProductCertification(Base):
+    __tablename__ = "product_certifications"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    product_id = Column(Integer, ForeignKey('products.id'), nullable=True, index=True, comment='产品 ID（外键）')
+    product_number = Column(String(11), nullable=False, server_default="", index=True, comment='产品货号')
+    certification_type = Column(String(50), nullable=False, server_default="", index=True, comment='认证类型：CE, FDA, RoHS, FCC, ISO, OTHER')
+    r2_url = Column(String(500), nullable=False, server_default="", comment='认证文件 URL（R2 URL）')
+    thumbnail_r2_url = Column(String(500), nullable=False, server_default="", comment='认证缩略图路径（R2 URL）')
+    media_id = Column(String(32), nullable=False, server_default="", comment='素材ID')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码，用于数据隔离')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/product_media.py

@@ -0,0 +1,20 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime, ForeignKey
+from sqlalchemy.sql import text
+from database import Base
+
+class ProductMedia(Base):
+    __tablename__ = "product_media"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    product_id = Column(Integer, ForeignKey('products.id'), nullable=True, index=True, comment='产品 ID（外键）')
+    product_number = Column(String(11), nullable=False, server_default="", index=True, comment='产品货号')
+    media_type = Column(String(20), nullable=False, server_default="image", index=True, comment='媒体类型：image, video')
+    r2_url = Column(String(500), nullable=False, server_default="", comment='媒体 URL（R2 原图 URL）')
+    thumbnail_r2_url = Column(String(500), nullable=False, server_default="", comment='缩略图 URL（R2 缩略图 URL）')
+    media_id = Column(String(32), nullable=False, server_default="", comment='素材ID')
+    media_alt = Column(String(200), nullable=False, server_default="", comment='ALT 标签/描述')
+    is_main = Column(Integer, nullable=False, server_default="0", comment='是否主图：0-否，1-是')
+    sort_order = Column(Integer, nullable=False, server_default="0", comment='排序顺序')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码，用于数据隔离')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/product_packaging.py

@@ -0,0 +1,18 @@
+from sqlalchemy import Column, Integer, String, Float, DateTime, ForeignKey
+from sqlalchemy.sql import text
+from database import Base
+
+class ProductPackaging(Base):
+    __tablename__ = "product_packaging"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    product_number = Column(String(11), nullable=False, server_default="", index=True, comment='产品货号')
+    model = Column(String(50), nullable=False, server_default="", comment='型号')
+    length = Column(Float, nullable=False, server_default="0", comment='长度 (cm)')
+    width = Column(Float, nullable=False, server_default="0", comment='宽度 (cm)')
+    height = Column(Float, nullable=False, server_default="0", comment='高度 (cm)')
+    volume = Column(Float, nullable=False, server_default="0", comment='体积 (cm³)')
+    weight = Column(Float, nullable=False, server_default="0", comment='重量 (g)')
+    company_code = Column(String(50), nullable=False, server_default="", index=True, comment='公司编码，用于数据隔离')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/site_visit.py

@@ -0,0 +1,30 @@
+from sqlalchemy import Column, Integer, String, DateTime, Index, text
+from sqlalchemy.sql import func
+from database import Base
+
+
+class SiteVisit(Base):
+    __tablename__ = "site_visits"
+
+    id = Column(Integer, primary_key=True, index=True, comment='主键 ID')
+    company_code = Column(String(50), nullable=False, index=True, comment='公司编码')
+    ip_address = Column(String(45), nullable=False, index=True, comment='访问IP地址')
+    visitor_id = Column(String(100), nullable=True, index=True, comment='访客ID')
+    
+    # 地理位置信息
+    country = Column(String(50), nullable=True, comment='国家')
+    region = Column(String(50), nullable=True, comment='地区/省份')
+    city = Column(String(50), nullable=True, comment='城市')
+    latitude = Column(String(20), nullable=True, comment='纬度')
+    longitude = Column(String(20), nullable=True, comment='经度')
+    
+    # 访问信息
+    user_agent = Column(String(500), nullable=True, comment='用户代理')
+    referer = Column(String(500), nullable=True, comment='来源页面')
+    page_url = Column(String(500), nullable=True, comment='访问页面')
+    visit_date = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='访问时间')
+    
+    __table_args__ = (
+        Index('idx_company_visit_date', 'company_code', 'visit_date'),
+        Index('idx_company_country', 'company_code', 'country'),
+    )

models/template.py

@@ -0,0 +1,20 @@
+from sqlalchemy import Column, Integer, String, Text, DateTime
+from sqlalchemy.sql import func, text
+from database import Base
+
+class Template(Base):
+    __tablename__ = "templates"
+    
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    key = Column(String(50), nullable=False, server_default="", unique=True, index=True, comment='模板标识')
+    name = Column(String(100), nullable=False, server_default="", comment='模板名称')
+    description = Column(Text, nullable=False, default="", comment='模板描述')
+    color = Column(String(20), nullable=False, server_default="#000000", comment='模板主色调')
+    features = Column(Text, nullable=False, default="", comment='模板特性，JSON格式')
+    applicable_scene = Column(Text, nullable=False, default="", comment='适用场景')
+    regions = Column(Text, nullable=False, default="", comment='适用区域，JSON格式')
+    select_count = Column(Integer, nullable=False, server_default="0", comment='被选择总次数')
+    use_count = Column(Integer, nullable=False, server_default="0", comment='当前使用次数')
+    status = Column(Integer, nullable=False, server_default="0", comment='状态：0-不可用，1-可用')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

models/user.py

@@ -0,0 +1,15 @@
+from sqlalchemy import Column, Integer, String, ForeignKey, Boolean, DateTime, text
+from sqlalchemy.orm import relationship
+from database import Base
+
+class User(Base):
+    __tablename__ = "users"
+
+    id = Column(Integer, primary_key=True, index=True, comment='主键ID')
+    username = Column(String(50), unique=True, nullable=False, server_default="", index=True, comment='用户名')
+    password = Column(String(255), nullable=False, server_default="", comment='密码')
+    email = Column(String(100), unique=True, nullable=False, server_default="", index=True, comment='邮箱')
+    is_superadmin = Column(Boolean, nullable=False, server_default="0", comment='是否为超级管理员')
+    company_code = Column(String(50), nullable=False, server_default="", comment='公司编码')
+    created_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP'), comment='创建时间')
+    updated_at = Column(DateTime(timezone=True), nullable=False, server_default=text('CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP'), comment='更新时间')

requirements.txt

@@ -0,0 +1,27 @@
+# FastAPI 及其依赖
+fastapi==0.104.1
+uvicorn[standard]==0.24.0.post1
+pydantic==2.5.2
+pydantic-settings==2.1.0
+
+# 数据库相关
+sqlalchemy==2.0.23
+pymysql==1.1.0
+
+# 安全相关
+python-jose[cryptography]==3.3.0
+passlib[bcrypt]==1.7.4
+python-multipart==0.0.6
+
+# 环境变量管理
+python-dotenv==1.0.0
+
+# 其他
+python-magic==0.4.27
+boto3==1.34.0
+requests==2.31.0
+
+# 开发工具
+black==23.12.1
+flake8==6.1.0
+isort==5.12.0