Neo
6f8f12314f
包含多个会话的累积代码变更： - backend: AI 聊天服务、触发器调度、认证增强、WebSocket、调度器最小间隔 - admin-web: ETL 状态页、任务管理、调度配置、登录优化 - miniprogram: 看板页面、聊天集成、UI 组件、导航更新 - etl: DWS 新任务（finance_area_daily/board_cache）、连接器增强 - tenant-admin: 项目初始化 - db: 19 个迁移脚本（etl_feiqiu 11 + zqyy_app 8） - packages/shared: 枚举和工具函数更新 - tools: 数据库工具、报表生成、健康检查 - docs: PRD/架构/部署/合约文档更新 Co-Authored-By: Claude Opus 4.6 <noreply@anthropic.com>
30 lines
872 B
Python
30 lines
872 B
Python
"""AI 数据获取层。
|
|
|
|
为 AI 应用提供共享的数据获取函数，封装 FDW 查询和业务库查询逻辑。
|
|
所有 FDW 查询通过 get_etl_readonly_connection(site_id) 获取只读连接，
|
|
自动设置 RLS 门店隔离。
|
|
|
|
模块：
|
|
- member_data: 客户消费数据获取（应用 3/6/7 共用）
|
|
- assistant_data: 助教数据获取（应用 4/5 共用）
|
|
- page_context: 页面上下文文本化（应用 1 专用）
|
|
"""
|
|
|
|
from app.ai.data_fetchers.member_data import (
|
|
fetch_member_consumption_data,
|
|
fetch_member_notes,
|
|
)
|
|
from app.ai.data_fetchers.assistant_data import (
|
|
fetch_assistant_info,
|
|
fetch_service_history,
|
|
)
|
|
from app.ai.data_fetchers.page_context import build_page_text
|
|
|
|
__all__ = [
|
|
"fetch_member_consumption_data",
|
|
"fetch_member_notes",
|
|
"fetch_assistant_info",
|
|
"fetch_service_history",
|
|
"build_page_text",
|
|
]
|