feiqiu-ETL/tmp/py_inventory.md

Python Inventory (function-level)

File	Symbol	Type	Doc (first line)	Reuse
etl_billiards/api/client.py	(module)	module	API客户端：统一封装 POST/重试/分页与列表提取逻辑。	High
etl_billiards/api/client.py	APIClient	class	HTTP API 客户端（默认使用 POST + JSON 请求体）	High
etl_billiards/api/client.py	APIClient.init	method		High
etl_billiards/api/client.py	APIClient._get_session	method	获取或创建带重试的 Session。	High
etl_billiards/api/client.py	APIClient.get	method	兼容旧名的请求入口（实际以 POST JSON 方式请求）。	High
etl_billiards/api/client.py	APIClient._post_json	method		High
etl_billiards/api/client.py	APIClient._build_headers	method		High
etl_billiards/api/client.py	APIClient._normalize_token	method		High
etl_billiards/api/client.py	APIClient._ensure_success	method	API 返回 code 非 0 时主动抛错，便于上层重试/记录。	High
etl_billiards/api/client.py	APIClient._iter_paginated_single	method	单一 endpoint 的分页迭代器（不包含 recent/former 路由逻辑）。	High
etl_billiards/api/client.py	APIClient.iter_paginated	method	分页迭代器：逐页拉取数据并产出 (page_no, records, request_params, raw_response)。	High
etl_billiards/api/client.py	APIClient.get_paginated	method	分页获取数据并将所有记录汇总在一个列表中。	High
etl_billiards/api/client.py	APIClient._extract_list	method	根据 data_path/list_key 提取列表结构，兼容常见字段名。	High
etl_billiards/api/endpoint_routing.py	(module)	module	“近期记录 / 历史记录(Former)”接口路由规则。	High
etl_billiards/api/endpoint_routing.py	WindowSpec	class		High
etl_billiards/api/endpoint_routing.py	RoutedCall	class		High
etl_billiards/api/endpoint_routing.py	is_former_endpoint	function		High
etl_billiards/api/endpoint_routing.py	_parse_dt	function		High
etl_billiards/api/endpoint_routing.py	_fmt_dt	function		High
etl_billiards/api/endpoint_routing.py	extract_window_spec	function		High
etl_billiards/api/endpoint_routing.py	derive_former_endpoint	function		High
etl_billiards/api/endpoint_routing.py	recent_boundary	function	3个月（自然月）边界：取 (now - months) 所在月份的 1 号 00:00:00。	High
etl_billiards/api/endpoint_routing.py	plan_calls	function	根据 endpoint + params 的时间窗口，返回要调用的 endpoint/params 列表（可能拆分为两段）。	High
etl_billiards/api/local_json_client.py	(module)	module	本地 JSON 客户端，模拟 APIClient 的分页接口，从落盘的 JSON 回放数据。	High
etl_billiards/api/local_json_client.py	LocalJsonClient	class	读取 RecordingAPIClient 生成的 JSON，提供 iter_paginated/get_paginated 接口。	High
etl_billiards/api/local_json_client.py	LocalJsonClient.init	method		High
etl_billiards/api/local_json_client.py	LocalJsonClient.get_source_hint	method	Return the JSON file path for this endpoint (for source_file lineage).	High
etl_billiards/api/local_json_client.py	LocalJsonClient.iter_paginated	method		High
etl_billiards/api/local_json_client.py	LocalJsonClient.get_paginated	method		High
etl_billiards/api/recording_client.py	(module)	module	包装 APIClient，将分页响应落盘便于后续本地清洗。	High
etl_billiards/api/recording_client.py	RecordingAPIClient	class	代理 APIClient，在调用 iter_paginated/get_paginated 时同时把响应写入 JSON 文件。	High
etl_billiards/api/recording_client.py	RecordingAPIClient.init	method		High
etl_billiards/api/recording_client.py	RecordingAPIClient.get_source_hint	method	Return the JSON dump path for this endpoint (for source_file lineage).	High
etl_billiards/api/recording_client.py	RecordingAPIClient.iter_paginated	method		High
etl_billiards/api/recording_client.py	RecordingAPIClient.get_paginated	method		High
etl_billiards/api/recording_client.py	RecordingAPIClient._dump	method		High
etl_billiards/api/recording_client.py	_cfg_get	function		High
etl_billiards/api/recording_client.py	build_recording_client	function	Build RecordingAPIClient from AppConfig or dict config.	High
etl_billiards/build_exe.py	(module)	module	ETL GUI 打包脚本	Medium
etl_billiards/build_exe.py	get_project_root	function	获取项目根目录	Medium
etl_billiards/build_exe.py	clean_build	function	清理旧的构建文件	Medium
etl_billiards/build_exe.py	build_exe	function	构建 EXE	Medium
etl_billiards/build_exe.py	slim_dist	function	精简打包后的文件，删除不需要的内容	Medium
etl_billiards/build_exe.py	main	function	主函数	Medium
etl_billiards/cli/main.py	(module)	module	CLI主入口	Medium
etl_billiards/cli/main.py	setup_logging	function	设置日志	Medium
etl_billiards/cli/main.py	parse_args	function	解析命令行参数	Medium
etl_billiards/cli/main.py	build_cli_overrides	function	从命令行参数构建配置覆盖	Medium
etl_billiards/cli/main.py	main	function	主函数	Medium
etl_billiards/config/defaults.py	(module)	module	配置默认值定义	High
etl_billiards/config/env_parser.py	(module)	module	环境变量解析	High
etl_billiards/config/env_parser.py	_deep_set	function		High
etl_billiards/config/env_parser.py	_coerce_env	function		High
etl_billiards/config/env_parser.py	_strip_inline_comment	function	去掉未被引号包裹的内联注释	High
etl_billiards/config/env_parser.py	_unquote_value	function	处理引号/原始字符串以及尾随逗号	High
etl_billiards/config/env_parser.py	_parse_dotenv_line	function	解析 .env 文件中的单行	High
etl_billiards/config/env_parser.py	_load_dotenv_values	function	从项目根目录读取 .env 文件键值	High
etl_billiards/config/env_parser.py	_apply_env_values	function		High
etl_billiards/config/env_parser.py	load_env_overrides	function		High
etl_billiards/config/settings.py	(module)	module	配置管理主类	High
etl_billiards/config/settings.py	AppConfig	class	应用配置管理器	High
etl_billiards/config/settings.py	AppConfig.init	method		High
etl_billiards/config/settings.py	AppConfig.load	method	加载配置: DEFAULTS < ENV < CLI	High
etl_billiards/config/settings.py	AppConfig._deep_merge	method	深度合并字典	High
etl_billiards/config/settings.py	AppConfig._normalize	method	规范化配置	High
etl_billiards/config/settings.py	AppConfig._validate	method	验证必填配置	High
etl_billiards/config/settings.py	AppConfig.get	method	获取配置值（支持点号路径）	High
etl_billiards/config/settings.py	AppConfig.getitem	method		High
etl_billiards/database/base.py	(module)	module	数据库操作（批量、RETURNING支持）	High
etl_billiards/database/base.py	DatabaseOperations	class	扩展数据库操作（包含批量upsert和returning支持）	High
etl_billiards/database/base.py	DatabaseOperations.batch_execute	method	批量执行SQL（不带RETURNING）	High
etl_billiards/database/base.py	DatabaseOperations.batch_upsert_with_returning	method	批量 UPSERT 并统计插入/更新数	High
etl_billiards/database/base.py	DatabaseOperations._execute_with_returning_vectorized	method	向量化执行（使用execute_values）	High
etl_billiards/database/base.py	DatabaseOperations._execute_with_returning_row_by_row	method	逐行执行（回退方案）	High
etl_billiards/database/base.py	DatabaseOperations._extract_inserted_flag	method	从返回记录中提取inserted标志	High
etl_billiards/database/connection.py	(module)	module	Database connection manager with capped connect_timeout.	High
etl_billiards/database/connection.py	DatabaseConnection	class	Wrap psycopg2 connection with session parameters and timeout guard.	High
etl_billiards/database/connection.py	DatabaseConnection.init	method		High
etl_billiards/database/connection.py	DatabaseConnection.query	method	Execute a query and fetch all rows.	High
etl_billiards/database/connection.py	DatabaseConnection.execute	method	Execute a SQL statement without returning rows.	High
etl_billiards/database/connection.py	DatabaseConnection.commit	method	Commit current transaction.	High
etl_billiards/database/connection.py	DatabaseConnection.rollback	method	Rollback current transaction.	High
etl_billiards/database/connection.py	DatabaseConnection.close	method	Safely close the connection.	High
etl_billiards/database/operations.py	(module)	module	数据库批量操作	High
etl_billiards/database/operations.py	DatabaseOperations	class	数据库批量操作封装	High
etl_billiards/database/operations.py	DatabaseOperations.init	method		High
etl_billiards/database/operations.py	DatabaseOperations.batch_execute	method	批量执行SQL	High
etl_billiards/database/operations.py	DatabaseOperations.batch_upsert_with_returning	method	批量UPSERT并返回插入/更新计数	High
etl_billiards/database/operations.py	DatabaseOperations._is_inserted	method	判断是否为插入操作	High
etl_billiards/database/operations.py	DatabaseOperations.commit	method	提交事务（委托给底层连接）	High
etl_billiards/database/operations.py	DatabaseOperations.rollback	method	回滚事务（委托给底层连接）	High
etl_billiards/database/operations.py	DatabaseOperations.query	method	执行查询并返回结果	High
etl_billiards/database/operations.py	DatabaseOperations.execute	method	执行任意 SQL	High
etl_billiards/database/operations.py	DatabaseOperations.cursor	method	暴露原生 cursor，供特殊操作使用	High
etl_billiards/fetch-test/compare_recent_former_endpoints.py	(module)	module	对比“近期记录”与“历史记录(Former)”接口：	Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	EndpointCheckResult	class		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_reconfigure_stdout_utf8	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	derive_former_endpoint	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_parse_day_start	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_window_from_dates	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_build_window_params	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_extract_records	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_walk_paths	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_schema_from_records	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_schema_from_data	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_cell	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_format_diff	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_post_first_page	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	_load_specs_for_range_only	function		Low
etl_billiards/fetch-test/compare_recent_former_endpoints.py	main	function		Low
etl_billiards/gui/init.py	(module)	module	ETL GUI 客户端模块	Medium
etl_billiards/gui/main.py	(module)	module	ETL GUI 应用入口	Medium
etl_billiards/gui/main.py	main	function	主函数	Medium
etl_billiards/gui/main_window.py	(module)	module	主窗口	Medium
etl_billiards/gui/main_window.py	MainWindow	class	ETL GUI 主窗口	Medium
etl_billiards/gui/main_window.py	MainWindow.init	method		Medium
etl_billiards/gui/main_window.py	MainWindow.showEvent	method	窗口显示事件	Medium
etl_billiards/gui/main_window.py	MainWindow._init_ui	method	初始化界面	Medium
etl_billiards/gui/main_window.py	MainWindow._create_nav_widget	method	创建导航侧边栏	Medium
etl_billiards/gui/main_window.py	MainWindow._create_panels	method	创建各个功能面板	Medium
etl_billiards/gui/main_window.py	MainWindow._init_menu	method	初始化菜单栏	Medium
etl_billiards/gui/main_window.py	MainWindow._init_status_bar	method	初始化状态栏	Medium
etl_billiards/gui/main_window.py	MainWindow._connect_signals	method	连接信号	Medium
etl_billiards/gui/main_window.py	MainWindow._on_nav_changed	method	导航项切换	Medium
etl_billiards/gui/main_window.py	MainWindow._switch_panel	method	切换到指定面板	Medium
etl_billiards/gui/main_window.py	MainWindow._refresh_config	method	刷新配置	Medium
etl_billiards/gui/main_window.py	MainWindow._on_task_started	method	任务开始时	Medium
etl_billiards/gui/main_window.py	MainWindow._on_task_finished	method	任务完成时	Medium
etl_billiards/gui/main_window.py	MainWindow._on_db_connection_changed	method	数据库连接状态变化	Medium
etl_billiards/gui/main_window.py	MainWindow._show_status_message	method	显示状态栏消息	Medium
etl_billiards/gui/main_window.py	MainWindow._on_add_to_queue	method	添加任务到队列	Medium
etl_billiards/gui/main_window.py	MainWindow._on_create_schedule	method	创建调度任务	Medium
etl_billiards/gui/main_window.py	MainWindow._show_settings	method	显示设置对话框	Medium
etl_billiards/gui/main_window.py	MainWindow._check_config_on_startup	method	启动时检查配置	Medium
etl_billiards/gui/main_window.py	MainWindow._show_about	method	显示关于对话框	Medium
etl_billiards/gui/main_window.py	MainWindow.closeEvent	method	关闭事件	Medium
etl_billiards/gui/models/init.py	(module)	module	数据模型模块	Medium
etl_billiards/gui/models/schedule_model.py	(module)	module	调度任务数据模型	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleType	class	调度类型	Medium
etl_billiards/gui/models/schedule_model.py	IntervalUnit	class	间隔单位	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleConfig	class	调度配置	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleConfig.to_dict	method	转换为字典	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleConfig.from_dict	method	从字典创建	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleConfig.get_description	method	获取调度描述	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleConfig.get_next_run_time	method	计算下次运行时间	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleConfig._parse_simple_cron	method	简化版 Cron 解析	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleExecutionRecord	class	调度执行记录	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleExecutionRecord.to_dict	method		Medium
etl_billiards/gui/models/schedule_model.py	ScheduleExecutionRecord.from_dict	method		Medium
etl_billiards/gui/models/schedule_model.py	ScheduledTask	class	调度任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduledTask.add_execution_record	method	添加执行记录	Medium
etl_billiards/gui/models/schedule_model.py	ScheduledTask.update_execution_record	method	更新执行记录状态	Medium
etl_billiards/gui/models/schedule_model.py	ScheduledTask.to_dict	method	转换为字典	Medium
etl_billiards/gui/models/schedule_model.py	ScheduledTask.from_dict	method	从字典创建	Medium
etl_billiards/gui/models/schedule_model.py	ScheduledTask.update_next_run	method	更新下次运行时间	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore	class	调度任务存储	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.init	method		Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.load	method	加载任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.save	method	保存任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.add_task	method	添加任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.remove_task	method	移除任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.update_task	method	更新任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.get_task	method	获取任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.get_all_tasks	method	获取所有任务	Medium
etl_billiards/gui/models/schedule_model.py	ScheduleStore.get_due_tasks	method	获取到期需要执行的任务	Medium
etl_billiards/gui/models/task_model.py	(module)	module	任务数据模型	Medium
etl_billiards/gui/models/task_model.py	TaskStatus	class	任务状态枚举	Medium
etl_billiards/gui/models/task_model.py	TaskCategory	class	任务分类	Medium
etl_billiards/gui/models/task_model.py	get_task_category	function	获取任务分类	Medium
etl_billiards/gui/models/task_model.py	TaskItem	class	任务项	Medium
etl_billiards/gui/models/task_model.py	TaskItem.post_init	method		Medium
etl_billiards/gui/models/task_model.py	TaskConfig	class	任务执行配置	Medium
etl_billiards/gui/models/task_model.py	TaskHistory	class	任务执行历史	Medium
etl_billiards/gui/models/task_model.py	TaskHistory.duration_seconds	method	执行时长（秒）	Medium
etl_billiards/gui/models/task_model.py	TaskHistory.duration_str	method	格式化的执行时长	Medium
etl_billiards/gui/models/task_model.py	QueuedTask	class	队列中的任务	Medium
etl_billiards/gui/models/task_registry.py	(module)	module	任务注册表：定义所有可用任务及其业务域分组。	Medium
etl_billiards/gui/models/task_registry.py	BusinessDomain	class	业务域枚举	Medium
etl_billiards/gui/models/task_registry.py	TaskDefinition	class	任务定义	Medium
etl_billiards/gui/models/task_registry.py	_build_ods_task_definition	function	根据 ODS 任务编码构建任务定义	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry	class	任务注册表：管理所有可用任务	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.new	method		Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.init	method		Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry._load_tasks	method	加载所有任务定义	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_task	method	获取任务定义	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_all_tasks	method	获取所有任务	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_ods_tasks	method	获取所有 ODS 任务	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_fact_ods_tasks	method	获取事实类 ODS 任务（需要时间窗口）	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_dimension_ods_tasks	method	获取维度类 ODS 任务	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_tasks_by_domain	method	按业务域获取任务	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_ods_tasks_grouped	method	获取按业务域分组的 ODS 任务	Medium
etl_billiards/gui/models/task_registry.py	TaskRegistry.get_non_ods_tasks	method	获取非 ODS 任务	Medium
etl_billiards/gui/models/task_registry.py	get_ods_task_codes	function	获取所有 ODS 任务编码	Medium
etl_billiards/gui/models/task_registry.py	get_fact_ods_task_codes	function	获取事实类 ODS 任务编码	Medium
etl_billiards/gui/models/task_registry.py	get_dimension_ods_task_codes	function	获取维度类 ODS 任务编码	Medium
etl_billiards/gui/models/task_registry.py	get_all_task_tuples	function	获取所有任务的 (code, name, description) 元组列表	Medium
etl_billiards/gui/models/task_registry.py	get_ods_tasks_for_ui	function	获取 ODS 任务列表供 UI 使用：(code, display_name, domain)	Medium
etl_billiards/gui/resources/init.py	(module)	module	GUI 资源模块	Medium
etl_billiards/gui/resources/init.py	load_stylesheet	function	加载样式表	Medium
etl_billiards/gui/utils/init.py	(module)	module	工具模块	Medium
etl_billiards/gui/utils/app_settings.py	(module)	module	应用程序设置管理	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings	class	应用程序设置单例	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.new	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.init	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings._get_settings_path	method	获取设置文件路径	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings._auto_detect_paths	method	自动检测 ETL 项目路径	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings._load	method	加载设置	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings._save	method	保存设置	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.etl_project_path	method	获取 ETL 项目路径	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.etl_project_path	method	设置 ETL 项目路径	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.env_file_path	method	获取 .env 文件路径	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.env_file_path	method	设置 .env 文件路径	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.is_configured	method	检查是否已配置	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.validate	method	验证配置	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_hours	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_hours	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_overlap_seconds	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_overlap_seconds	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_include_dwd	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_include_dwd	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_auto_verify	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_auto_verify	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_selected_tasks	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.auto_update_selected_tasks	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_mode	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_mode	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_history_start	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_history_start	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_history_end	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_history_end	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_lookback_hours	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_lookback_hours	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_include_dimensions	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_include_dimensions	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_auto_backfill	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_auto_backfill	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_ods_tasks	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.integrity_ods_tasks	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_pipeline_flow	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_pipeline_flow	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_dry_run	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_dry_run	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_start	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_start	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_end	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_end	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_ingest_source	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_ingest_source	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_split	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_split	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_compensation	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.advanced_window_compensation	method		Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.get_all_settings	method	获取所有设置（用于调试）	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.save_all	method	强制保存所有设置	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings._get_history_path	method	获取任务历史文件路径	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.save_task_history	method	保存任务历史到文件	Medium
etl_billiards/gui/utils/app_settings.py	AppSettings.load_task_history	method	从文件加载任务历史	Medium
etl_billiards/gui/utils/cli_builder.py	(module)	module	CLI 命令构建器	Medium
etl_billiards/gui/utils/cli_builder.py	CLIBuilder	class	构建 CLI 命令行参数	Medium
etl_billiards/gui/utils/cli_builder.py	CLIBuilder.init	method		Medium
etl_billiards/gui/utils/cli_builder.py	CLIBuilder.build_command	method	根据任务配置构建命令行参数列表	Medium
etl_billiards/gui/utils/cli_builder.py	CLIBuilder.build_command_string	method	构建命令行字符串（用于显示）	Medium
etl_billiards/gui/utils/cli_builder.py	CLIBuilder.build_from_dict	method	从字典构建命令行参数	Medium
etl_billiards/gui/utils/config_helper.py	(module)	module	配置辅助工具	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper	class	配置文件辅助类	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper.init	method	初始化配置辅助器	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper.load_env	method	加载 .env 文件内容	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper.save_env	method	保存环境变量到 .env 文件	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper.get_grouped_env	method	获取分组的环境变量	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper.validate_env	method	验证环境变量	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper.mask_sensitive	method	脱敏敏感值	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper._parse_line	method	解析 .env 文件的一行	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper._unquote_value	method	处理引号和注释	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper._strip_inline_comment	method	去除内联注释	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper._format_line	method	格式化为 .env 行	Medium
etl_billiards/gui/utils/config_helper.py	ConfigHelper.get_group_title	method	获取分组标题	Medium
etl_billiards/gui/widgets/init.py	(module)	module	GUI 组件模块	Medium
etl_billiards/gui/widgets/db_viewer.py	(module)	module	数据库查看器	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer	class	数据库查看器	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer.init	method		Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._create_table_browser	method	创建表浏览器	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._create_query_area	method	创建查询区域	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._connect_signals	method	连接信号	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._load_dsn_from_env	method	从环境变量加载 DSN	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._toggle_dsn_visibility	method	切换 DSN 可见性	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._connect_db	method	连接数据库	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._disconnect_db	method	断开数据库连接	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._refresh_tables	method	刷新表列表	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._on_connection_status	method	处理连接状态变化	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._on_tables_loaded	method	处理表列表加载完成	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._on_template_selected	method	模板选择变化	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._on_table_double_clicked	method	表双击事件	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._execute_query	method	执行查询	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._on_query_finished	method	查询完成	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer._on_query_error	method	查询错误	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer.close_connection	method	关闭连接	Medium
etl_billiards/gui/widgets/db_viewer.py	DBViewer.keyPressEvent	method	键盘事件	Medium
etl_billiards/gui/widgets/env_editor.py	(module)	module	环境变量编辑器	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor	class	环境变量编辑器	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor.init	method		Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._create_config_groups	method	创建配置分组	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor.load_config	method	加载配置	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._save_config	method	保存配置	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._import_config	method	导入配置	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._export_config	method	导出配置	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._toggle_sensitive	method	切换敏感信息显示	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._on_value_changed	method	值变化时验证	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._validate	method	验证配置	Medium
etl_billiards/gui/widgets/env_editor.py	EnvEditor._get_placeholder	method	获取占位符提示	Medium
etl_billiards/gui/widgets/log_viewer.py	(module)	module	日志查看器	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer	class	日志查看器	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer.init	method		Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._connect_signals	method	连接信号	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer.append_log	method	追加日志	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._append_formatted_line	method	追加格式化的行	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._matches_filter	method	检查是否匹配过滤器	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._apply_filter	method	应用过滤器	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._toggle_auto_scroll	method	切换自动滚动	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._copy_all	method	复制全部日志	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._export_log	method	导出日志	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._clear_log	method	清空日志	Medium
etl_billiards/gui/widgets/log_viewer.py	LogViewer._update_line_count	method	更新行数显示	Medium
etl_billiards/gui/widgets/settings_dialog.py	(module)	module	应用程序设置对话框	Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog	class	设置对话框	Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog.init	method		Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog._init_ui	method		Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog._load_settings	method	加载设置	Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog._browse_project_path	method	浏览项目路径	Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog._browse_env_path	method	浏览 .env 文件	Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog._validate_config	method	验证配置	Medium
etl_billiards/gui/widgets/settings_dialog.py	SettingsDialog._save_and_accept	method	保存并关闭	Medium
etl_billiards/gui/widgets/status_panel.py	(module)	module	ETL 状态面板	Medium
etl_billiards/gui/widgets/status_panel.py	StatusCard	class	状态卡片	Medium
etl_billiards/gui/widgets/status_panel.py	StatusCard.init	method		Medium
etl_billiards/gui/widgets/status_panel.py	StatusCard.set_value	method	设置值	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel	class	ETL 状态面板	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel.init	method		Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._connect_signals	method	连接信号	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._toggle_auto_refresh	method	切换自动刷新	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._auto_refresh	method	自动刷新	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._refresh_all	method	刷新所有数据	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._on_connection_status	method	处理连接状态	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._load_status_data	method	加载状态数据	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._on_query_finished	method	处理查询结果	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._process_table_count	method	处理表数量数据	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._process_cutoff_data	method	处理 Cutoff 数据	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._process_history_data	method	处理运行历史数据	Medium
etl_billiards/gui/widgets/status_panel.py	StatusPanel._on_query_error	method	处理查询错误	Medium
etl_billiards/gui/widgets/task_manager.py	(module)	module	任务管理器面板	Medium
etl_billiards/gui/widgets/task_manager.py	_get_schedulable_tasks	function	从任务注册表动态获取可调度任务列表	Medium
etl_billiards/gui/widgets/task_manager.py	TaskLogDialog	class	任务日志查看对话框	Medium
etl_billiards/gui/widgets/task_manager.py	TaskLogDialog.init	method		Medium
etl_billiards/gui/widgets/task_manager.py	TaskLogDialog._init_ui	method		Medium
etl_billiards/gui/widgets/task_manager.py	TaskLogDialog._copy_log	method	复制日志到剪贴板	Medium
etl_billiards/gui/widgets/task_manager.py	TaskLogDialog._get_status_text	method		Medium
etl_billiards/gui/widgets/task_manager.py	TaskLogDialog._get_status_color	method		Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog	class	调度任务编辑对话框	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog.init	method		Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog._init_ui	method		Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog._on_type_changed	method		Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog._load_task	method	加载任务数据	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog.get_task	method	获取配置的任务	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog._connect_preview_signals	method	连接信号以实时更新 CLI 预览	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog._update_cli_preview	method	更新 CLI 命令行预览	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog._on_cli_editable_changed	method	切换 CLI 编辑模式	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleEditDialog._copy_cli_to_clipboard	method	复制 CLI 命令到剪贴板	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog	class	调度任务日志查看对话框	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog.init	method		Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._init_ui	method		Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._load_history	method	加载执行历史	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._on_selection_changed	method	选择变化时显示对应的日志	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._show_running_task_log	method	显示执行中任务的实时日志	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._refresh_running_log	method	定时刷新执行中任务的日志	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._copy_log	method	复制日志到剪贴板	Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._get_status_text	method		Medium
etl_billiards/gui/widgets/task_manager.py	ScheduleLogDialog._get_status_color	method		Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager	class	任务管理器	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager.init	method		Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._connect_signals	method	连接信号	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager.add_task	method	添加任务到队列	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._toggle_auto_run	method	切换自动执行	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._clear_queue	method	清空队列	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._run_next	method	执行下一个任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._run_all	method	执行全部任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._stop_current	method	停止当前任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._clear_history	method	清空历史	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._execute_task	method	执行任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._on_output	method	收到输出	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._on_finished	method	任务完成	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._on_error	method	发生错误	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._is_running	method	是否有任务在运行	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._has_scheduled_tasks_pending	method	检查队列中是否有待执行的定时任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._refresh_display	method	刷新显示	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._refresh_queue_table	method	刷新队列表格	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._refresh_history_table	method	刷新历史表格	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._show_queue_menu	method	显示队列右键菜单	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._remove_task	method	移除任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._show_history_menu	method	显示历史右键菜单	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._view_task_log	method	双击查看任务日志	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._show_task_log_dialog	method	显示任务日志对话框	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._rerun_task	method	重新执行任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._remove_from_history	method	从历史中删除任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._load_task_history	method	从文件加载任务历史	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._save_task_history	method	保存任务历史到文件	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._extract_result_summary	method	从任务输出中提取结果摘要	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._get_status_text	method	获取状态文本	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._get_status_color	method	获取状态颜色	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._toggle_scheduler	method	切换调度器状态	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._check_scheduled_tasks	method	检查并执行到期的调度任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._execute_scheduled_task	method	执行调度任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._add_schedule	method	添加调度任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._edit_schedule	method	编辑调度任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._delete_schedule	method	删除调度任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._toggle_schedule_enabled	method	切换调度任务启用状态	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._run_schedule_now	method	立即执行调度任务	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._show_schedule_menu	method	显示调度任务右键菜单	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._refresh_schedule_table	method	刷新调度任务表格	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._update_schedule_execution_record	method	更新调度执行记录（如果此任务来自调度）	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._view_schedule_log	method	查看调度任务日志	Medium
etl_billiards/gui/widgets/task_manager.py	TaskManager._on_schedule_double_click	method	双击调度任务查看日志	Medium
etl_billiards/gui/widgets/task_panel.py	(module)	module	任务配置面板	Medium
etl_billiards/gui/widgets/task_panel.py	_get_all_tasks	function	从注册表动态获取所有任务	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel	class	任务配置面板	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel.init	method		Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._create_task_selection	method	创建任务选择区域	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._create_config_area	method	创建参数配置区域	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._create_quick_actions_tab	method	创建快捷操作选项卡	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._on_reload_include_dimensions_changed	method	全量重刷的"包含维度表"选项变化	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._create_advanced_config_tab	method	创建高级配置选项卡	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._create_bottom_area	method	创建底部区域	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._connect_signals	method	连接信号	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._on_backfill_option_changed	method	自动补齐选项变化时，联动其他选项	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel.refresh_tasks	method	刷新任务列表	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._filter_tasks	method	过滤任务列表	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._on_selection_changed	method	选择变化时	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._select_all	method	全选	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._deselect_all	method	全不选	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._browse_source_dir	method	浏览数据源目录	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._get_config	method	获取当前配置	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._update_preview	method	更新命令行预览	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._run_task	method	执行任务	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._stop_task	method	停止任务	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._on_output	method	收到输出	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._on_finished	method	任务完成	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._on_error	method	发生错误	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel.is_running	method	是否正在执行任务	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._add_task_to_queue	method	将任务列表中选中的任务添加到队列	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._on_integrity_mode_changed	method	校验模式变化	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._update_sync_time_preview	method	更新日常同步的时间范围预览（精确到秒）	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._run_daily_sync	method	执行日常增量同步	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._create_sync_schedule	method	创建日常同步调度任务	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._run_full_reload	method	执行全量重刷	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._get_integrity_config	method	获取数据校验配置	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._run_integrity_check	method	执行数据完整性校验	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._create_integrity_schedule	method	创建数据校验调度任务	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._load_settings	method	从持久化存储加载设置	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._save_sync_settings	method	保存日常同步设置	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._save_reload_settings	method	保存全量重刷设置	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._save_integrity_settings	method	保存数据校验设置	Medium
etl_billiards/gui/widgets/task_panel.py	TaskPanel._save_advanced_settings	method	保存高级设置	Medium
etl_billiards/gui/widgets/task_selector.py	(module)	module	可复用的 ODS 任务选择组件：按业务域分组显示，支持全选/反选。	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget	class	ODS 任务选择组件：按业务域分组显示	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget.init	method	初始化任务选择器	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._create_domain_group	method	创建业务域分组框	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._apply_default_selection	method	应用默认选择	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._on_selection_changed	method	选择变化时	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._update_count_label	method	更新选中计数标签	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._select_all	method	全选	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._deselect_all	method	全不选	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget._select_facts_only	method	只选事实表任务	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget.get_selected_codes	method	获取选中的任务编码列表	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget.set_selected_codes	method	设置选中的任务编码	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget.get_all_codes	method	获取所有任务编码	Medium
etl_billiards/gui/widgets/task_selector.py	TaskSelectorWidget.is_any_selected	method	是否有任何任务被选中	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector	class	紧凑型任务选择器：单行显示业务域，点击展开选择	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector.init	method		Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector._init_ui	method	初始化界面	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector._apply_default_selection	method	应用默认选择	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector._on_selection_changed	method	选择变化时	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector._update_count_label	method	更新计数标签	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector._select_all	method	全选所有业务域	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector._deselect_all	method	取消全选	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector.get_selected_codes	method	获取选中的任务编码	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector.set_selected_domains	method	设置选中的业务域	Medium
etl_billiards/gui/widgets/task_selector.py	CompactTaskSelector.is_any_selected	method	是否有任何任务被选中	Medium
etl_billiards/gui/workers/init.py	(module)	module	后台工作线程模块	Medium
etl_billiards/gui/workers/db_worker.py	(module)	module	数据库查询工作线程	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker	class	数据库查询工作线程	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker.init	method		Medium
etl_billiards/gui/workers/db_worker.py	DBWorker.connect_db	method	连接数据库	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker.disconnect_db	method	断开数据库连接	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker.execute_query	method	执行查询	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker.load_tables	method	加载表列表	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker.run	method	执行任务	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker._do_connect	method	执行连接	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker._do_disconnect	method	执行断开连接	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker._do_query	method	执行查询	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker._do_load_tables	method	加载表列表	Medium
etl_billiards/gui/workers/db_worker.py	DBWorker.is_connected	method	检查是否已连接	Medium
etl_billiards/gui/workers/task_worker.py	(module)	module	任务执行工作线程	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker	class	任务执行工作线程	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker.init	method		Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker.run	method	执行任务	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker.stop	method	停止任务	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker._parse_progress	method	解析进度信息	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker._generate_summary	method	生成执行摘要	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker._parse_detailed_summary	method	解析详细的执行摘要	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker.exit_code	method	获取退出码	Medium
etl_billiards/gui/workers/task_worker.py	TaskWorker.output	method	获取完整输出	Medium
etl_billiards/loaders/base_loader.py	(module)	module	数据加载器基类	Medium
etl_billiards/loaders/base_loader.py	BaseLoader	class	数据加载器基类	Medium
etl_billiards/loaders/base_loader.py	BaseLoader.init	method		Medium
etl_billiards/loaders/base_loader.py	BaseLoader.upsert	method	执行 UPSERT 操作	Medium
etl_billiards/loaders/base_loader.py	BaseLoader._batch_size	method	批次大小	Medium
etl_billiards/loaders/dimensions/assistant.py	(module)	module	助教维度加载器	Medium
etl_billiards/loaders/dimensions/assistant.py	AssistantLoader	class	写入 dim_assistant	Medium
etl_billiards/loaders/dimensions/assistant.py	AssistantLoader.upsert_assistants	method		Medium
etl_billiards/loaders/dimensions/member.py	(module)	module	会员维度表加载器	Medium
etl_billiards/loaders/dimensions/member.py	MemberLoader	class	会员维度加载器	Medium
etl_billiards/loaders/dimensions/member.py	MemberLoader.upsert_members	method	加载会员数据	Medium
etl_billiards/loaders/dimensions/package.py	(module)	module	团购/套餐定义加载器	Medium
etl_billiards/loaders/dimensions/package.py	PackageDefinitionLoader	class	写入 dim_package_coupon	Medium
etl_billiards/loaders/dimensions/package.py	PackageDefinitionLoader.upsert_packages	method		Medium
etl_billiards/loaders/dimensions/product.py	(module)	module	商品维度 + 价格SCD2 加载器	Medium
etl_billiards/loaders/dimensions/product.py	ProductLoader	class	商品维度加载器（dim_product + dim_product_price_scd）	Medium
etl_billiards/loaders/dimensions/product.py	ProductLoader.init	method		Medium
etl_billiards/loaders/dimensions/product.py	ProductLoader.upsert_products	method	加载商品维度及价格SCD	Medium
etl_billiards/loaders/dimensions/table.py	(module)	module	台桌维度加载器	Medium
etl_billiards/loaders/dimensions/table.py	TableLoader	class	将台桌档案写入 dim_table	Medium
etl_billiards/loaders/dimensions/table.py	TableLoader.upsert_tables	method	批量写入台桌档案	Medium
etl_billiards/loaders/facts/assistant_abolish.py	(module)	module	助教作废事实表	Medium
etl_billiards/loaders/facts/assistant_abolish.py	AssistantAbolishLoader	class	写入 fact_assistant_abolish	Medium
etl_billiards/loaders/facts/assistant_abolish.py	AssistantAbolishLoader.upsert_records	method		Medium
etl_billiards/loaders/facts/assistant_ledger.py	(module)	module	助教流水事实表	Medium
etl_billiards/loaders/facts/assistant_ledger.py	AssistantLedgerLoader	class	写入 fact_assistant_ledger	Medium
etl_billiards/loaders/facts/assistant_ledger.py	AssistantLedgerLoader.upsert_ledgers	method		Medium
etl_billiards/loaders/facts/coupon_usage.py	(module)	module	券核销事实表	Medium
etl_billiards/loaders/facts/coupon_usage.py	CouponUsageLoader	class	写入 fact_coupon_usage	Medium
etl_billiards/loaders/facts/coupon_usage.py	CouponUsageLoader.upsert_coupon_usage	method		Medium
etl_billiards/loaders/facts/inventory_change.py	(module)	module	库存变动事实表	Medium
etl_billiards/loaders/facts/inventory_change.py	InventoryChangeLoader	class	写入 fact_inventory_change	Medium
etl_billiards/loaders/facts/inventory_change.py	InventoryChangeLoader.upsert_changes	method		Medium
etl_billiards/loaders/facts/order.py	(module)	module	订单事实表加载器	Medium
etl_billiards/loaders/facts/order.py	OrderLoader	class	订单数据加载器	Medium
etl_billiards/loaders/facts/order.py	OrderLoader.upsert_orders	method	加载订单数据	Medium
etl_billiards/loaders/facts/payment.py	(module)	module	支付事实表加载器	Medium
etl_billiards/loaders/facts/payment.py	PaymentLoader	class	支付数据加载器	Medium
etl_billiards/loaders/facts/payment.py	PaymentLoader.upsert_payments	method	加载支付数据	Medium
etl_billiards/loaders/facts/refund.py	(module)	module	退款事实表加载器	Medium
etl_billiards/loaders/facts/refund.py	RefundLoader	class	写入 fact_refund	Medium
etl_billiards/loaders/facts/refund.py	RefundLoader.upsert_refunds	method		Medium
etl_billiards/loaders/facts/table_discount.py	(module)	module	台费打折事实表	Medium
etl_billiards/loaders/facts/table_discount.py	TableDiscountLoader	class	写入 fact_table_discount	Medium
etl_billiards/loaders/facts/table_discount.py	TableDiscountLoader.upsert_discounts	method		Medium
etl_billiards/loaders/facts/ticket.py	(module)	module	小票详情加载器	Medium
etl_billiards/loaders/facts/ticket.py	TicketLoader	class	Loader for parsing Ticket Detail JSON and populating DWD fact tables.	Medium
etl_billiards/loaders/facts/ticket.py	TicketLoader.process_tickets	method	Process a batch of ticket JSONs.	Medium
etl_billiards/loaders/facts/ticket.py	TicketLoader._upsert_orders	method		Medium
etl_billiards/loaders/facts/ticket.py	TicketLoader._upsert_goods	method		Medium
etl_billiards/loaders/facts/ticket.py	TicketLoader._upsert_table_usages	method		Medium
etl_billiards/loaders/facts/ticket.py	TicketLoader._upsert_assistant_services	method		Medium
etl_billiards/loaders/facts/topup.py	(module)	module	充值记录事实表	Medium
etl_billiards/loaders/facts/topup.py	TopupLoader	class	写入 fact_topup	Medium
etl_billiards/loaders/facts/topup.py	TopupLoader.upsert_topups	method		Medium
etl_billiards/loaders/ods/init.py	(module)	module	ODS loader helpers.	Medium
etl_billiards/loaders/ods/generic.py	(module)	module	Generic ODS loader that keeps raw payload + primary keys.	Medium
etl_billiards/loaders/ods/generic.py	GenericODSLoader	class	Insert/update helper for ODS tables that share the same pattern.	Medium
etl_billiards/loaders/ods/generic.py	GenericODSLoader.init	method		Medium
etl_billiards/loaders/ods/generic.py	GenericODSLoader.upsert_rows	method	Insert/update the provided iterable of dictionaries.	Medium
etl_billiards/loaders/ods/generic.py	GenericODSLoader._build_sql	method		Medium
etl_billiards/loaders/ods/generic.py	GenericODSLoader._normalize_row	method		Medium
etl_billiards/models/parsers.py	(module)	module	数据类型解析器	Medium
etl_billiards/models/parsers.py	TypeParser	class	类型解析工具	Medium
etl_billiards/models/parsers.py	TypeParser.parse_timestamp	method	解析时间戳	Medium
etl_billiards/models/parsers.py	TypeParser.parse_decimal	method	解析金额	Medium
etl_billiards/models/parsers.py	TypeParser.parse_int	method	解析整数	Medium
etl_billiards/models/parsers.py	TypeParser.format_timestamp	method	格式化时间戳	Medium
etl_billiards/models/validators.py	(module)	module	数据验证器	Medium
etl_billiards/models/validators.py	DataValidator	class	数据验证工具	Medium
etl_billiards/models/validators.py	DataValidator.validate_positive_amount	method	验证金额为正数	Medium
etl_billiards/models/validators.py	DataValidator.validate_required	method	验证必填字段	Medium
etl_billiards/models/validators.py	DataValidator.validate_range	method	验证值范围	Medium
etl_billiards/orchestration/cursor_manager.py	(module)	module	游标管理器	High
etl_billiards/orchestration/cursor_manager.py	CursorManager	class	ETL游标管理	High
etl_billiards/orchestration/cursor_manager.py	CursorManager.init	method		High
etl_billiards/orchestration/cursor_manager.py	CursorManager.get_or_create	method	获取或创建游标	High
etl_billiards/orchestration/cursor_manager.py	CursorManager.advance	method	推进游标	High
etl_billiards/orchestration/run_tracker.py	(module)	module	运行记录追踪器	High
etl_billiards/orchestration/run_tracker.py	RunTracker	class	ETL运行记录管理	High
etl_billiards/orchestration/run_tracker.py	RunTracker.init	method		High
etl_billiards/orchestration/run_tracker.py	RunTracker.create_run	method	创建运行记录	High
etl_billiards/orchestration/run_tracker.py	RunTracker.update_run	method	更新运行记录	High
etl_billiards/orchestration/scheduler.py	(module)	module	ETL 调度：支持在线抓取、离线清洗入库、全流程三种模式。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler	class	调度多个任务，按 pipeline.flow 执行抓取/清洗入库。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler.init	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler._attach_run_file_logger	method	为本次 run_uuid 动态挂载文件日志处理器。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler.run_tasks	method	按配置或传入列表执行任务。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._run_single_task	method	单个任务的抓取/清洗编排。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._execute_fetch	method	在线抓取阶段：用 RecordingAPIClient 拉取并落盘，不做 Transform/Load。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._is_ods_task	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler._execute_ods_record_and_load	method	Execute an ODS task with RecordingAPIClient so it fetches online and writes JSON dumps.	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._execute_ingest	method	本地清洗入库：使用 LocalJsonClient 回放 JSON，走原有任务 ETL。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._build_fetch_dir	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler._resolve_ingest_source	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler._counts_from_fetch	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler._flow_includes_fetch	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler._flow_includes_ingest	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler._run_utility_task	method	执行工具类任务（不记录 cursor/run，直接执行）。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._load_task_config	method	从数据库加载任务配置。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._maybe_run_integrity_check	method		High
etl_billiards/orchestration/scheduler.py	ETLScheduler.close	method	关闭连接。	High
etl_billiards/orchestration/scheduler.py	ETLScheduler._map_run_status	method	将任务返回的状态转换为 etl_admin.run_status_enum	High
etl_billiards/orchestration/task_registry.py	(module)	module	任务注册表	High
etl_billiards/orchestration/task_registry.py	TaskRegistry	class	任务注册和工厂	High
etl_billiards/orchestration/task_registry.py	TaskRegistry.init	method		High
etl_billiards/orchestration/task_registry.py	TaskRegistry.register	method	注册任务类	High
etl_billiards/orchestration/task_registry.py	TaskRegistry.create_task	method	创建任务实例	High
etl_billiards/orchestration/task_registry.py	TaskRegistry.get_all_task_codes	method	获取所有已注册的任务代码	High
etl_billiards/quality/balance_checker.py	(module)	module	余额一致性检查器	Medium
etl_billiards/quality/balance_checker.py	BalanceChecker	class	检查订单、支付、退款的金额一致性	Medium
etl_billiards/quality/balance_checker.py	BalanceChecker.check	method	检查指定时间范围内的余额一致性	Medium
etl_billiards/quality/base_checker.py	(module)	module	数据质量检查器基类	Medium
etl_billiards/quality/base_checker.py	BaseDataQualityChecker	class	数据质量检查器基类	Medium
etl_billiards/quality/base_checker.py	BaseDataQualityChecker.init	method		Medium
etl_billiards/quality/base_checker.py	BaseDataQualityChecker.check	method	执行质量检查	Medium
etl_billiards/quality/integrity_checker.py	(module)	module	Integrity checks across API -> ODS -> DWD.	Medium
etl_billiards/quality/integrity_checker.py	IntegrityWindow	class		Medium
etl_billiards/quality/integrity_checker.py	_ensure_tz	function		Medium
etl_billiards/quality/integrity_checker.py	_month_start	function		Medium
etl_billiards/quality/integrity_checker.py	_next_month	function		Medium
etl_billiards/quality/integrity_checker.py	_date_to_start	function		Medium
etl_billiards/quality/integrity_checker.py	_date_to_end_exclusive	function		Medium
etl_billiards/quality/integrity_checker.py	build_history_windows	function	Build weekly windows for current month, monthly windows for earlier months.	Medium
etl_billiards/quality/integrity_checker.py	_split_table	function		Medium
etl_billiards/quality/integrity_checker.py	_pick_time_column	function		Medium
etl_billiards/quality/integrity_checker.py	_fetch_columns	function		Medium
etl_billiards/quality/integrity_checker.py	_amount_columns	function		Medium
etl_billiards/quality/integrity_checker.py	_build_hash_expr	function		Medium
etl_billiards/quality/integrity_checker.py	_build_snapshot_subquery	function		Medium
etl_billiards/quality/integrity_checker.py	_build_snapshot_expr_subquery	function		Medium
etl_billiards/quality/integrity_checker.py	_cast_expr	function		Medium
etl_billiards/quality/integrity_checker.py	_fetch_pk_columns	function		Medium
etl_billiards/quality/integrity_checker.py	_pick_snapshot_order_column	function		Medium
etl_billiards/quality/integrity_checker.py	_count_table	function		Medium
etl_billiards/quality/integrity_checker.py	_sum_column	function		Medium
etl_billiards/quality/integrity_checker.py	run_dwd_vs_ods_check	function		Medium
etl_billiards/quality/integrity_checker.py	_default_report_path	function		Medium
etl_billiards/quality/integrity_checker.py	run_integrity_window	function		Medium
etl_billiards/quality/integrity_checker.py	run_integrity_history	function		Medium
etl_billiards/quality/integrity_checker.py	compute_last_etl_end	function		Medium
etl_billiards/quality/integrity_service.py	(module)	module	Shared integrity flow helpers (window/history + optional backfill).	Medium
etl_billiards/quality/integrity_service.py	_normalize_windows	function		Medium
etl_billiards/quality/integrity_service.py	build_window_report	function		Medium
etl_billiards/quality/integrity_service.py	run_window_flow	function		Medium
etl_billiards/quality/integrity_service.py	run_history_flow	function		Medium
etl_billiards/quality/integrity_service.py	write_report	function		Medium
etl_billiards/reports/init.py	(module)	module	Reports package.	Medium
etl_billiards/reports/loyal_billiards_customers_report.py	(module)	module	统计“忠实台球类竞技客户”Top N（按平均单次日打球小时数排序）。	Medium
etl_billiards/reports/loyal_billiards_customers_report.py	SessionRow	class		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	MemberAgg	class		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_as_tz	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_parse_date	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_date_floor	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_split_by_day	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_union_seconds	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_avg_gap_days	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_load_sessions	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_load_member_profiles	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_load_latest_settlement_contact	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_build_member_aggs	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	_write_report	function		Medium
etl_billiards/reports/loyal_billiards_customers_report.py	main	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	(module)	module	按自定义名单统计累计打球总时长（同“忠实台球类竞技客户”口径）	Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	InputRow	class		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_digits	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_normalize_name	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_read_input	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_load_member_candidates_by_phone	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_load_member_candidates_by_mobile	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_resolve_member_ids	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_load_sessions_for_members	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	_write_report	function		Medium
etl_billiards/reports/loyal_customers_total_hours_for_list.py	main	function		Medium
etl_billiards/run_update.py	(module)	module	一键增量更新脚本（ODS -> DWD -> DWS）。	Medium
etl_billiards/run_update.py	_coerce_date	function		Medium
etl_billiards/run_update.py	_compute_dws_window	function		Medium
etl_billiards/run_update.py	_run_check_cutoff	function		Medium
etl_billiards/run_update.py	_iter_daily_windows	function		Medium
etl_billiards/run_update.py	_run_step_worker	function		Medium
etl_billiards/run_update.py	_run_step_with_timeout	function		Medium
etl_billiards/run_update.py	main	function		Medium
etl_billiards/scd/scd2_handler.py	(module)	module	SCD2 (Slowly Changing Dimension Type 2) 处理逻辑	Medium
etl_billiards/scd/scd2_handler.py	_row_to_dict	function		Medium
etl_billiards/scd/scd2_handler.py	SCD2Handler	class	SCD2历史记录处理	Medium
etl_billiards/scd/scd2_handler.py	SCD2Handler.init	method		Medium
etl_billiards/scd/scd2_handler.py	SCD2Handler.upsert	method	处理SCD2更新	Medium
etl_billiards/scripts/backfill_missing_data.py	(module)	module	补全丢失的 ODS 数据	Low
etl_billiards/scripts/backfill_missing_data.py	_reconfigure_stdout_utf8	function		Low
etl_billiards/scripts/backfill_missing_data.py	_parse_dt	function		Low
etl_billiards/scripts/backfill_missing_data.py	_get_spec	function	根据任务代码获取 ODS 任务规格	Low
etl_billiards/scripts/backfill_missing_data.py	_merge_record_layers	function	Flatten nested data layers into a single dict.	Low
etl_billiards/scripts/backfill_missing_data.py	_get_value_case_insensitive	function	Fetch value without case sensitivity.	Low
etl_billiards/scripts/backfill_missing_data.py	_normalize_pk_value	function	Normalize PK value.	Low
etl_billiards/scripts/backfill_missing_data.py	_pk_tuple_from_record	function	Extract PK tuple from record.	Low
etl_billiards/scripts/backfill_missing_data.py	_get_table_pk_columns	function	获取表的主键列	Low
etl_billiards/scripts/backfill_missing_data.py	_get_table_columns	function	获取表的所有列信息	Low
etl_billiards/scripts/backfill_missing_data.py	_fetch_existing_pk_set	function	获取已存在的 PK 集合	Low
etl_billiards/scripts/backfill_missing_data.py	_cast_value	function	类型转换	Low
etl_billiards/scripts/backfill_missing_data.py	_normalize_scalar	function	规范化标量值	Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller	class	丢失数据补全器	Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller.init	method		Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller.close	method	关闭连接	Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller._ensure_db	method	确保数据库连接可用	Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller.backfill_from_gap_check	method	运行 gap check 并补全丢失数据	Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller._backfill_task	method	补全单个任务的丢失数据	Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller._build_params	method	构建 API 请求参数	Low
etl_billiards/scripts/backfill_missing_data.py	MissingDataBackfiller._insert_records	method	插入记录到数据库	Low
etl_billiards/scripts/backfill_missing_data.py	run_backfill	function	运行数据补全	Low
etl_billiards/scripts/backfill_missing_data.py	main	function		Low
etl_billiards/scripts/bootstrap_schema.py	(module)	module	Apply the PRD-aligned warehouse schema (ODS/DWD/DWS) to PostgreSQL.	Low
etl_billiards/scripts/bootstrap_schema.py	parse_args	function		Low
etl_billiards/scripts/bootstrap_schema.py	apply_schema	function		Low
etl_billiards/scripts/bootstrap_schema.py	main	function		Low
etl_billiards/scripts/build_dwd_from_ods.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Low
etl_billiards/scripts/build_dws_order_summary.py	(module)	module	Recompute billiards_dws.dws_order_summary from DWD tables (dwd_*).	Low
etl_billiards/scripts/build_dws_order_summary.py	parse_args	function		Low
etl_billiards/scripts/build_dws_order_summary.py	main	function		Low
etl_billiards/scripts/check_data_integrity.py	(module)	module	Run data integrity checks across API -> ODS -> DWD.	Low
etl_billiards/scripts/check_data_integrity.py	_parse_dt	function		Low
etl_billiards/scripts/check_data_integrity.py	main	function		Low
etl_billiards/scripts/check_ods_gaps.py	(module)	module	Check missing ODS records by comparing API primary keys vs ODS table primary keys.	Low
etl_billiards/scripts/check_ods_gaps.py	_reconfigure_stdout_utf8	function		Low
etl_billiards/scripts/check_ods_gaps.py	_parse_dt	function		Low
etl_billiards/scripts/check_ods_gaps.py	_iter_windows	function		Low
etl_billiards/scripts/check_ods_gaps.py	_merge_record_layers	function		Low
etl_billiards/scripts/check_ods_gaps.py	_chunked	function		Low
etl_billiards/scripts/check_ods_gaps.py	_get_table_pk_columns	function		Low
etl_billiards/scripts/check_ods_gaps.py	_table_has_column	function		Low
etl_billiards/scripts/check_ods_gaps.py	_fetch_existing_pk_set	function		Low
etl_billiards/scripts/check_ods_gaps.py	_fetch_existing_pk_hash_set	function		Low
etl_billiards/scripts/check_ods_gaps.py	_init_db_state	function		Low
etl_billiards/scripts/check_ods_gaps.py	_reconnect_db	function		Low
etl_billiards/scripts/check_ods_gaps.py	_ensure_db_conn	function		Low
etl_billiards/scripts/check_ods_gaps.py	_merge_common_params	function		Low
etl_billiards/scripts/check_ods_gaps.py	_build_params	function		Low
etl_billiards/scripts/check_ods_gaps.py	_pk_tuple_from_merged	function		Low
etl_billiards/scripts/check_ods_gaps.py	_pk_tuple_from_record	function		Low
etl_billiards/scripts/check_ods_gaps.py	_pk_tuple_from_ticket_candidate	function		Low
etl_billiards/scripts/check_ods_gaps.py	_format_missing_sample	function		Low
etl_billiards/scripts/check_ods_gaps.py	_format_mismatch_sample	function		Low
etl_billiards/scripts/check_ods_gaps.py	_check_spec	function		Low
etl_billiards/scripts/check_ods_gaps.py	_check_settlement_tickets	function		Low
etl_billiards/scripts/check_ods_gaps.py	_compute_ods_cutoff	function		Low
etl_billiards/scripts/check_ods_gaps.py	_resolve_window_from_cutoff	function		Low
etl_billiards/scripts/check_ods_gaps.py	run_gap_check	function		Low
etl_billiards/scripts/check_ods_gaps.py	main	function		Low
etl_billiards/scripts/check_ods_json_vs_table.py	(module)	module	ODS JSON 字段核对脚本：对照当前数据库中的 ODS 表字段，检查示例 JSON（默认目录 export/test-json-doc）	Low
etl_billiards/scripts/check_ods_json_vs_table.py	_flatten_keys	function	递归展开 JSON 所有键路径，返回形如 data.assistantInfos.id 的集合。列表不保留索引，仅继续向下展开。	Low
etl_billiards/scripts/check_ods_json_vs_table.py	_load_json_keys	function	读取单个 JSON 文件并返回展开后的键集合以及末段->路径列表映射，若文件不存在或无法解析则返回空集合。	Low
etl_billiards/scripts/check_ods_json_vs_table.py	_load_ods_columns	function	从数据库读取 billiards_ods.* 的列名集合，按表返回。	Low
etl_billiards/scripts/check_ods_json_vs_table.py	main	function	主流程：遍历 FILE_MAPPING 中的 ODS 表，检查 JSON 键覆盖情况并打印报告。	Low
etl_billiards/scripts/migrate_snapshot_ods.py	(module)	module	迁移到“快照型 ODS + DWD SCD2”：	Low
etl_billiards/scripts/migrate_snapshot_ods.py	_hash_default	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_sanitize_record_for_hash	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_compute_content_hash	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_fetch_tables	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_fetch_columns	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_fetch_pk_constraint	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_ensure_content_hash_column	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_backfill_content_hash	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_ensure_ods_primary_key	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_migrate_ods	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_backfill_scd2_fields	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_ensure_dwd_primary_key	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	_migrate_dwd	function		Low
etl_billiards/scripts/migrate_snapshot_ods.py	main	function		Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	(module)	module	一键重建 ETL 相关 Schema，并执行 ODS → DWD。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	RunArgs	class	脚本参数对象（用于减少散落的参数传递）。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_attach_file_logger	function	给 root logger 附加文件日志处理器（UTF-8）。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_parse_args	function	解析命令行/环境变量参数。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_build_config	function	构建本次执行所需的最小配置覆盖。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_drop_schemas	function	删除并重建 ETL 相关 schema（具备破坏性，请谨慎）。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_terminate_own_idle_in_tx	function	终止当前用户在本库中处于 idle-in-transaction 的会话，避免阻塞 DROP/DDL。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_run_task	function	统一运行任务并打印关键结果。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_basic_validate	function	做最基础的可用性校验：schema 存在、关键表行数可查询。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_connect_db_with_retry	function	创建数据库连接（带重试），避免短暂网络抖动导致脚本直接失败。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_is_connection_error	function	判断是否为连接断开/服务端异常导致的可重试错误。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	_run_stage_with_reconnect	function	运行单个阶段：失败（尤其是连接断开）时自动重连并重试。	Low
etl_billiards/scripts/rebuild_db_and_run_ods_to_dwd.py	main	function	脚本主入口：按顺序重建并跑通 ODS→DWD。	Low
etl_billiards/scripts/rebuild_ods_from_json.py	(module)	module	从本地 JSON 示例目录重建 billiards_ods.* 表，并导入样例数据。	Low
etl_billiards/scripts/rebuild_ods_from_json.py	sanitize_identifier	function	将任意字符串转为可用的 SQL identifier（小写、非字母数字转下划线）。	Low
etl_billiards/scripts/rebuild_ods_from_json.py	_extract_list_via_path	function		Low
etl_billiards/scripts/rebuild_ods_from_json.py	load_records	function	尝试从 JSON 结构中提取记录列表：	Low
etl_billiards/scripts/rebuild_ods_from_json.py	collect_columns	function	汇总所有顶层键，作为表字段；仅处理 dict 记录。	Low
etl_billiards/scripts/rebuild_ods_from_json.py	create_table	function	创建表：字段全部 jsonb，外加 source_file、record_index、payload、ingested_at。	Low
etl_billiards/scripts/rebuild_ods_from_json.py	insert_records	function	批量插入记录。	Low
etl_billiards/scripts/rebuild_ods_from_json.py	rebuild	function		Low
etl_billiards/scripts/reload_ods_windowed.py	(module)	module	Reload ODS tasks by fixed time windows with optional sleep between windows.	Low
etl_billiards/scripts/reload_ods_windowed.py	_parse_dt	function		Low
etl_billiards/scripts/reload_ods_windowed.py	_iter_windows	function		Low
etl_billiards/scripts/reload_ods_windowed.py	_run_task_window	function		Low
etl_billiards/scripts/reload_ods_windowed.py	main	function		Low
etl_billiards/scripts/run_tests.py	(module)	module	灵活的测试执行脚本，可像搭积木一样组合不同参数或预置命令（模式/数据库/归档路径等），	Low
etl_billiards/scripts/run_tests.py	_load_presets	function		Low
etl_billiards/scripts/run_tests.py	parse_args	function		Low
etl_billiards/scripts/run_tests.py	apply_presets_to_args	function		Low
etl_billiards/scripts/run_tests.py	apply_env	function		Low
etl_billiards/scripts/run_tests.py	build_pytest_args	function		Low
etl_billiards/scripts/run_tests.py	main	function		Low
etl_billiards/scripts/test_db_connection.py	(module)	module	Quick utility for validating PostgreSQL connectivity (ASCII-only output).	Low
etl_billiards/scripts/test_db_connection.py	parse_args	function		Low
etl_billiards/scripts/test_db_connection.py	main	function		Low
etl_billiards/scripts/test_db_performance.py	(module)	module	PostgreSQL connection performance test (ASCII-only output).	Low
etl_billiards/scripts/test_db_performance.py	_load_env	function		Low
etl_billiards/scripts/test_db_performance.py	_apply_dsn_overrides	function		Low
etl_billiards/scripts/test_db_performance.py	_build_dsn_from_env	function		Low
etl_billiards/scripts/test_db_performance.py	_safe_dsn_summary	function		Low
etl_billiards/scripts/test_db_performance.py	_percentile	function		Low
etl_billiards/scripts/test_db_performance.py	_format_stats	function		Low
etl_billiards/scripts/test_db_performance.py	parse_args	function		Low
etl_billiards/scripts/test_db_performance.py	_run_round	function		Low
etl_billiards/scripts/test_db_performance.py	main	function		Low
etl_billiards/scripts/test_presets.py	(module)	module	测试命令仓库：集中维护 run_tests.py 的常用组合，支持一键执行。	Low
etl_billiards/scripts/test_presets.py	print_parameter_help	function		Low
etl_billiards/scripts/test_presets.py	print_presets	function		Low
etl_billiards/scripts/test_presets.py	resolve_targets	function		Low
etl_billiards/scripts/test_presets.py	run_presets	function		Low
etl_billiards/scripts/test_presets.py	main	function		Low
etl_billiards/setup.py	(module)	module	Setup script for ETL Billiards	Medium
etl_billiards/tasks/assistant_abolish_task.py	(module)	module	助教作废任务	Task
etl_billiards/tasks/assistant_abolish_task.py	AssistantAbolishTask	class	同步助教作废记录	Task
etl_billiards/tasks/assistant_abolish_task.py	AssistantAbolishTask.get_task_code	method		Task
etl_billiards/tasks/assistant_abolish_task.py	AssistantAbolishTask.extract	method		Task
etl_billiards/tasks/assistant_abolish_task.py	AssistantAbolishTask.transform	method		Task
etl_billiards/tasks/assistant_abolish_task.py	AssistantAbolishTask.load	method		Task
etl_billiards/tasks/assistant_abolish_task.py	AssistantAbolishTask._parse_record	method		Task
etl_billiards/tasks/assistants_task.py	(module)	module	助教账号任务	Task
etl_billiards/tasks/assistants_task.py	AssistantsTask	class	同步助教账号资料	Task
etl_billiards/tasks/assistants_task.py	AssistantsTask.get_task_code	method		Task
etl_billiards/tasks/assistants_task.py	AssistantsTask.extract	method		Task
etl_billiards/tasks/assistants_task.py	AssistantsTask.transform	method		Task
etl_billiards/tasks/assistants_task.py	AssistantsTask.load	method		Task
etl_billiards/tasks/assistants_task.py	AssistantsTask._parse_assistant	method		Task
etl_billiards/tasks/base_dwd_task.py	(module)	module	DWD任务基类	Task
etl_billiards/tasks/base_dwd_task.py	BaseDwdTask	class	DWD 层任务基类	Task
etl_billiards/tasks/base_dwd_task.py	BaseDwdTask._get_ods_cursor	method	获取上次处理的 ODS 数据的时间点 (fetched_at)	Task
etl_billiards/tasks/base_dwd_task.py	BaseDwdTask.iter_ods_rows	method	分批迭代读取 ODS 表数据	Task
etl_billiards/tasks/base_dwd_task.py	BaseDwdTask.parse_payload	method	解析 ODS 行中的 payload JSON	Task
etl_billiards/tasks/base_task.py	(module)	module	ETL任务基类（引入 Extract/Transform/Load 模板方法）	Task
etl_billiards/tasks/base_task.py	TaskContext	class	统一透传给 Extract/Transform/Load 的运行期信息。	Task
etl_billiards/tasks/base_task.py	BaseTask	class	提供 E/T/L 模板的任务基类。	Task
etl_billiards/tasks/base_task.py	BaseTask.init	method		Task
etl_billiards/tasks/base_task.py	BaseTask.get_task_code	method	获取任务代码	Task
etl_billiards/tasks/base_task.py	BaseTask.extract	method	提取数据	Task
etl_billiards/tasks/base_task.py	BaseTask.transform	method	转换数据	Task
etl_billiards/tasks/base_task.py	BaseTask.load	method	加载数据并返回统计信息	Task
etl_billiards/tasks/base_task.py	BaseTask.execute	method	统一 orchestrate Extract → Transform → Load	Task
etl_billiards/tasks/base_task.py	BaseTask._build_context	method		Task
etl_billiards/tasks/base_task.py	BaseTask._build_context_for_window	method		Task
etl_billiards/tasks/base_task.py	BaseTask._accumulate_counts	method		Task
etl_billiards/tasks/base_task.py	BaseTask._get_time_window	method	计算时间窗口	Task
etl_billiards/tasks/base_task.py	BaseTask._is_in_idle_window	method	判断是否在闲时窗口	Task
etl_billiards/tasks/base_task.py	BaseTask._merge_common_params	method	合并全局/任务级参数池，便于在配置中统一覆<E4B880>?/追加过滤条件。	Task
etl_billiards/tasks/base_task.py	BaseTask._build_result	method	构建结果字典	Task
etl_billiards/tasks/check_cutoff_task.py	(module)	module	Task: report last successful cursor cutoff times from etl_admin.	Task
etl_billiards/tasks/check_cutoff_task.py	CheckCutoffTask	class	Report per-task cursor cutoff times (etl_admin.etl_cursor.last_end).	Task
etl_billiards/tasks/check_cutoff_task.py	CheckCutoffTask.get_task_code	method		Task
etl_billiards/tasks/check_cutoff_task.py	CheckCutoffTask.execute	method		Task
etl_billiards/tasks/check_cutoff_task.py	CheckCutoffTask._probe_ods_fetched_at	method		Task
etl_billiards/tasks/check_cutoff_task.py	CheckCutoffTask._probe_dw_time_columns	method		Task
etl_billiards/tasks/coupon_usage_task.py	(module)	module	平台券核销任务	Task
etl_billiards/tasks/coupon_usage_task.py	CouponUsageTask	class	同步平台券验券/核销记录	Task
etl_billiards/tasks/coupon_usage_task.py	CouponUsageTask.get_task_code	method		Task
etl_billiards/tasks/coupon_usage_task.py	CouponUsageTask.extract	method		Task
etl_billiards/tasks/coupon_usage_task.py	CouponUsageTask.transform	method		Task
etl_billiards/tasks/coupon_usage_task.py	CouponUsageTask.load	method		Task
etl_billiards/tasks/coupon_usage_task.py	CouponUsageTask._parse_usage	method		Task
etl_billiards/tasks/data_integrity_task.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Task
etl_billiards/tasks/dwd_load_task.py	(module)	module	DWD 装载任务：从 ODS 增量写入 DWD（维度 SCD2，事实按时间增量）。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask	class	负责 DWD 装载：维度表做 SCD2 合并，事实表按时间增量写入。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._strip_scd2_keys	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._pick_snapshot_order_column	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._latest_snapshot_select_sql	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask.get_task_code	method	返回任务编码。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask.extract	method	准备运行所需的上下文信息。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask.load	method	遍历映射关系，维度执行 SCD2 合并，事实表按时间增量插入。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._get_columns	method	获取指定表的列名（小写）。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._get_primary_keys	method	获取表的主键列名列表。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._get_column_types	method	获取列的数据类型（information_schema.data_type）。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._build_column_mapping	method	合并显式 FACT_MAPPINGS 与主键兜底映射。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._fetch_source_rows	method	从源表读取指定列，返回小写键的字典列表。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._expand_goods_category_rows	method	将分类表中的 categoryboxes 元素展开为子类记录。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._merge_dim	method	维表合并策略：	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._merge_dim_type1_upsert	method	维表 Type1 Upsert（主键冲突则更新），兼容带 scd2 字段但主键不支持多版本的表。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._merge_dim_scd2	method	对维表执行 SCD2 合并：对比变更关闭旧版并插入新版。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._close_current_dim_bulk	method	批量关闭当前版本（scd2_is_current=0 + 填充结束时间）。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._insert_dim_rows_bulk	method	批量插入新的 SCD2 版本行。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._upsert_scd2_row	method	SCD2 合并：若有变更则关闭旧版并插入新版本。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._close_current_dim	method	关闭当前版本，标记 scd2_is_current=0 并填充结束时间。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._insert_dim_row	method	插入新的 SCD2 版本行。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._is_row_changed	method	比较非 SCD2 列，判断是否存在变更。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._values_equal	method	Normalize common type mismatches (numeric/text, naive/aware datetime) before compare.	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._normalize_empty	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._normalize_datetime	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._looks_numeric	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._coerce_numeric	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._looks_bool	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._coerce_bool	method		Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._merge_fact_increment	method	事实表按时间增量插入，默认按列名交集写入。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._pick_order_column	method	Pick an incremental order column that exists in both DWD and ODS.	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._get_fact_watermark	method	Fetch incremental watermark; default from DWD, fallback from ODS join.	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._insert_missing_by_pk	method	Backfill missing PK rows for facts that can receive late data.	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._build_fact_select_exprs	method	构造事实表 SELECT 列表，需要时做类型转换。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._split_table_name	method	拆分 schema.table，若无 schema 则补默认 schema。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._table_base	method	获取不含 schema 的表名。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._format_table	method	返回带引号的 schema.table 名称。	Task
etl_billiards/tasks/dwd_load_task.py	DwdLoadTask._cast_expr	method	构造带可选 CAST 的列表达式。	Task
etl_billiards/tasks/dwd_quality_task.py	(module)	module	DWD 质量核对任务：按 dwd_quality_check.md 输出行数/金额对照报表。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask	class	对 ODS 与 DWD 进行行数、金额对照核查，生成 JSON 报表。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask.get_task_code	method	返回任务编码。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask.extract	method	准备运行时上下文。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask.load	method	输出行数/金额差异报表到本地文件。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask._compare_counts	method	统计两端行数并返回差异。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask._compare_amounts	method	扫描金额相关列，生成 ODS 与 DWD 的汇总对照。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask._get_numeric_amount_columns	method	获取列名包含金额关键词的数值型字段。	Task
etl_billiards/tasks/dwd_quality_task.py	DwdQualityTask._split_table_name	method	拆分 schema 与表名，缺省使用 default_schema。	Task
etl_billiards/tasks/dws_build_order_summary_task.py	(module)	module	Build DWS order summary table from DWD fact tables.	Task
etl_billiards/tasks/dws_build_order_summary_task.py	DwsBuildOrderSummaryTask	class	Recompute/refresh billiards_dws.dws_order_summary for a date window.	Task
etl_billiards/tasks/dws_build_order_summary_task.py	DwsBuildOrderSummaryTask.get_task_code	method		Task
etl_billiards/tasks/dws_build_order_summary_task.py	DwsBuildOrderSummaryTask.execute	method		Task
etl_billiards/tasks/dws_build_order_summary_task.py	DwsBuildOrderSummaryTask.extract	method		Task
etl_billiards/tasks/dws_build_order_summary_task.py	DwsBuildOrderSummaryTask.load	method		Task
etl_billiards/tasks/dws_build_order_summary_task.py	_as_date	function		Task
etl_billiards/tasks/dws_build_order_summary_task.py	_jsonable_date	function		Task
etl_billiards/tasks/init_dwd_schema_task.py	(module)	module	初始化 DWD Schema：执行 schema_dwd_doc.sql，可选先 DROP SCHEMA。	Task
etl_billiards/tasks/init_dwd_schema_task.py	InitDwdSchemaTask	class	通过调度执行 DWD schema 初始化。	Task
etl_billiards/tasks/init_dwd_schema_task.py	InitDwdSchemaTask.get_task_code	method	返回任务编码。	Task
etl_billiards/tasks/init_dwd_schema_task.py	InitDwdSchemaTask.extract	method	读取 DWD SQL 文件与参数。	Task
etl_billiards/tasks/init_dwd_schema_task.py	InitDwdSchemaTask.load	method	可选 DROP schema，再执行 DWD DDL。	Task
etl_billiards/tasks/init_dws_schema_task.py	(module)	module	Initialize DWS schema (billiards_dws).	Task
etl_billiards/tasks/init_dws_schema_task.py	InitDwsSchemaTask	class	Apply DWS schema SQL.	Task
etl_billiards/tasks/init_dws_schema_task.py	InitDwsSchemaTask.get_task_code	method		Task
etl_billiards/tasks/init_dws_schema_task.py	InitDwsSchemaTask.extract	method		Task
etl_billiards/tasks/init_dws_schema_task.py	InitDwsSchemaTask.load	method		Task
etl_billiards/tasks/init_schema_task.py	(module)	module	任务：初始化运行环境，执行 ODS 与 etl_admin 的 DDL，并准备日志/导出目录。	Task
etl_billiards/tasks/init_schema_task.py	InitOdsSchemaTask	class	通过调度执行初始化：创建必要目录，执行 ODS 与 etl_admin 的 DDL。	Task
etl_billiards/tasks/init_schema_task.py	InitOdsSchemaTask.get_task_code	method	返回任务编码。	Task
etl_billiards/tasks/init_schema_task.py	InitOdsSchemaTask.extract	method	读取 SQL 文件路径，收集需创建的目录。	Task
etl_billiards/tasks/init_schema_task.py	InitOdsSchemaTask.load	method	执行 DDL 并创建必要目录。	Task
etl_billiards/tasks/inventory_change_task.py	(module)	module	库存变更任务	Task
etl_billiards/tasks/inventory_change_task.py	InventoryChangeTask	class	同步库存变化记录	Task
etl_billiards/tasks/inventory_change_task.py	InventoryChangeTask.get_task_code	method		Task
etl_billiards/tasks/inventory_change_task.py	InventoryChangeTask.extract	method		Task
etl_billiards/tasks/inventory_change_task.py	InventoryChangeTask.transform	method		Task
etl_billiards/tasks/inventory_change_task.py	InventoryChangeTask.load	method		Task
etl_billiards/tasks/inventory_change_task.py	InventoryChangeTask._parse_change	method		Task
etl_billiards/tasks/ledger_task.py	(module)	module	助教流水任务	Task
etl_billiards/tasks/ledger_task.py	LedgerTask	class	同步助教服务台账	Task
etl_billiards/tasks/ledger_task.py	LedgerTask.get_task_code	method		Task
etl_billiards/tasks/ledger_task.py	LedgerTask.extract	method		Task
etl_billiards/tasks/ledger_task.py	LedgerTask.transform	method		Task
etl_billiards/tasks/ledger_task.py	LedgerTask.load	method		Task
etl_billiards/tasks/ledger_task.py	LedgerTask._parse_ledger	method		Task
etl_billiards/tasks/manual_ingest_task.py	(module)	module	手工示例数据灌入：按 schema_ODS_doc.sql 的表结构写入 ODS。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask	class	本地示例 JSON 灌入 ODS，确保表名/主键/插入列与 schema_ODS_doc.sql 对齐。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask.get_task_code	method	返回任务编码。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask.execute	method	从目录读取 JSON，按表定义批量入库（按文件提交事务，避免长事务导致连接不稳定）。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._match_by_filename	method	根据文件名关键字匹配目标表。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._extract_records	method	兼容多层 data/list 包装，抽取记录列表。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._get_table_columns	method	查询 information_schema，获取目标表列信息。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._ingest_table	method	构建 INSERT/ON CONFLICT 语句并批量执行（优先向量化，小批次提交）。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._get_value_case_insensitive	method	忽略大小写获取值，兼容 information_schema 与 JSON 原始字段。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._normalize_scalar	method	将空字符串/空 JSON 规范为 None，避免类型转换错误。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._cast_value	method	根据列类型做简单转换，保证批量插入兼容。	Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._hash_default	method		Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._sanitize_record_for_hash	method		Task
etl_billiards/tasks/manual_ingest_task.py	ManualIngestTask._compute_content_hash	method		Task
etl_billiards/tasks/members_dwd_task.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Task
etl_billiards/tasks/members_task.py	(module)	module	会员ETL任务	Task
etl_billiards/tasks/members_task.py	MembersTask	class	会员ETL任务	Task
etl_billiards/tasks/members_task.py	MembersTask.get_task_code	method		Task
etl_billiards/tasks/members_task.py	MembersTask.extract	method		Task
etl_billiards/tasks/members_task.py	MembersTask.transform	method		Task
etl_billiards/tasks/members_task.py	MembersTask.load	method		Task
etl_billiards/tasks/members_task.py	MembersTask._parse_member	method	解析会员记录	Task
etl_billiards/tasks/ods_json_archive_task.py	(module)	module	在线抓取 ODS 相关接口并落盘为 JSON（用于后续离线回放/入库）。	Task
etl_billiards/tasks/ods_json_archive_task.py	EndpointSpec	class		Task
etl_billiards/tasks/ods_json_archive_task.py	OdsJsonArchiveTask	class	抓取一组 ODS 所需接口并落盘为“简化 JSON”：	Task
etl_billiards/tasks/ods_json_archive_task.py	OdsJsonArchiveTask.get_task_code	method		Task
etl_billiards/tasks/ods_json_archive_task.py	OdsJsonArchiveTask.extract	method		Task
etl_billiards/tasks/ods_json_archive_task.py	OdsJsonArchiveTask._build_params	method		Task
etl_billiards/tasks/ods_tasks.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Task
etl_billiards/tasks/orders_task.py	(module)	module	订单ETL任务	Task
etl_billiards/tasks/orders_task.py	OrdersTask	class	订单数据ETL任务	Task
etl_billiards/tasks/orders_task.py	OrdersTask.get_task_code	method		Task
etl_billiards/tasks/orders_task.py	OrdersTask.extract	method	调用 API 拉取订单记录	Task
etl_billiards/tasks/orders_task.py	OrdersTask.transform	method	解析原始订单 JSON	Task
etl_billiards/tasks/orders_task.py	OrdersTask.load	method	写入 fact_order	Task
etl_billiards/tasks/orders_task.py	OrdersTask._parse_order	method	解析单条订单记录	Task
etl_billiards/tasks/packages_task.py	(module)	module	团购/套餐定义任务	Task
etl_billiards/tasks/packages_task.py	PackagesDefTask	class	同步团购套餐定义	Task
etl_billiards/tasks/packages_task.py	PackagesDefTask.get_task_code	method		Task
etl_billiards/tasks/packages_task.py	PackagesDefTask.extract	method		Task
etl_billiards/tasks/packages_task.py	PackagesDefTask.transform	method		Task
etl_billiards/tasks/packages_task.py	PackagesDefTask.load	method		Task
etl_billiards/tasks/packages_task.py	PackagesDefTask._parse_package	method		Task
etl_billiards/tasks/payments_dwd_task.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Task
etl_billiards/tasks/payments_task.py	(module)	module	支付记录ETL任务	Task
etl_billiards/tasks/payments_task.py	PaymentsTask	class	支付记录 E/T/L 任务	Task
etl_billiards/tasks/payments_task.py	PaymentsTask.get_task_code	method		Task
etl_billiards/tasks/payments_task.py	PaymentsTask.extract	method	调用 API 抓取支付记录	Task
etl_billiards/tasks/payments_task.py	PaymentsTask.transform	method	解析支付 JSON	Task
etl_billiards/tasks/payments_task.py	PaymentsTask.load	method	写入 fact_payment	Task
etl_billiards/tasks/payments_task.py	PaymentsTask._parse_payment	method	解析支付记录	Task
etl_billiards/tasks/products_task.py	(module)	module	商品档案（PRODUCTS）ETL任务	Task
etl_billiards/tasks/products_task.py	ProductsTask	class	商品维度 ETL 任务	Task
etl_billiards/tasks/products_task.py	ProductsTask.get_task_code	method		Task
etl_billiards/tasks/products_task.py	ProductsTask.extract	method		Task
etl_billiards/tasks/products_task.py	ProductsTask.transform	method		Task
etl_billiards/tasks/products_task.py	ProductsTask.load	method		Task
etl_billiards/tasks/products_task.py	ProductsTask._parse_product	method		Task
etl_billiards/tasks/refunds_task.py	(module)	module	退款记录任务	Task
etl_billiards/tasks/refunds_task.py	RefundsTask	class	同步支付退款流水	Task
etl_billiards/tasks/refunds_task.py	RefundsTask.get_task_code	method		Task
etl_billiards/tasks/refunds_task.py	RefundsTask.extract	method		Task
etl_billiards/tasks/refunds_task.py	RefundsTask.transform	method		Task
etl_billiards/tasks/refunds_task.py	RefundsTask.load	method		Task
etl_billiards/tasks/refunds_task.py	RefundsTask._parse_refund	method		Task
etl_billiards/tasks/table_discount_task.py	(module)	module	台费折扣任务	Task
etl_billiards/tasks/table_discount_task.py	TableDiscountTask	class	同步台费折扣/调价记录	Task
etl_billiards/tasks/table_discount_task.py	TableDiscountTask.get_task_code	method		Task
etl_billiards/tasks/table_discount_task.py	TableDiscountTask.extract	method		Task
etl_billiards/tasks/table_discount_task.py	TableDiscountTask.transform	method		Task
etl_billiards/tasks/table_discount_task.py	TableDiscountTask.load	method		Task
etl_billiards/tasks/table_discount_task.py	TableDiscountTask._parse_discount	method		Task
etl_billiards/tasks/tables_task.py	(module)	module	台桌档案任务	Task
etl_billiards/tasks/tables_task.py	TablesTask	class	同步门店台桌列表	Task
etl_billiards/tasks/tables_task.py	TablesTask.get_task_code	method		Task
etl_billiards/tasks/tables_task.py	TablesTask.extract	method		Task
etl_billiards/tasks/tables_task.py	TablesTask.transform	method		Task
etl_billiards/tasks/tables_task.py	TablesTask.load	method		Task
etl_billiards/tasks/tables_task.py	TablesTask._parse_table	method		Task
etl_billiards/tasks/ticket_dwd_task.py	TicketDwdTask	class	DWD Task: Process Ticket Details from ODS to Fact Tables	Task
etl_billiards/tasks/ticket_dwd_task.py	TicketDwdTask.get_task_code	method		Task
etl_billiards/tasks/ticket_dwd_task.py	TicketDwdTask.execute	method		Task
etl_billiards/tasks/topups_task.py	(module)	module	充值记录任务	Task
etl_billiards/tasks/topups_task.py	TopupsTask	class	同步储值充值结算记录	Task
etl_billiards/tasks/topups_task.py	TopupsTask.get_task_code	method		Task
etl_billiards/tasks/topups_task.py	TopupsTask.extract	method		Task
etl_billiards/tasks/topups_task.py	TopupsTask.transform	method		Task
etl_billiards/tasks/topups_task.py	TopupsTask.load	method		Task
etl_billiards/tasks/topups_task.py	TopupsTask._parse_topup	method		Task
etl_billiards/tests/integration/test_database.py	(module)	module	数据库集成测试	Low
etl_billiards/tests/integration/test_database.py	db_connection	function	数据库连接fixture	Low
etl_billiards/tests/integration/test_database.py	test_database_query	function	测试数据库查询	Low
etl_billiards/tests/integration/test_database.py	test_database_operations	function	测试数据库操作	Low
etl_billiards/tests/unit/task_test_utils.py	(module)	module	ETL 任务测试的共用辅助模块，涵盖在线/离线模式所需的伪造数据、客户端与配置等工具函数。	Low
etl_billiards/tests/unit/task_test_utils.py	TaskSpec	class	描述单个任务在测试中如何被驱动的元数据，包含任务代码、API 路径、数据路径与样例记录。	Low
etl_billiards/tests/unit/task_test_utils.py	TaskSpec.archive_filename	method		Low
etl_billiards/tests/unit/task_test_utils.py	wrap_records	function	按照 data_path 逐层包裹记录列表，使其结构与真实 API 返回体一致，方便离线回放。	Low
etl_billiards/tests/unit/task_test_utils.py	create_test_config	function	构建一份适合测试的 AppConfig，自动填充存储、日志、归档目录等参数并保证目录存在。	Low
etl_billiards/tests/unit/task_test_utils.py	dump_offline_payload	function	将 TaskSpec 的样例数据写入指定归档目录，供离线测试回放使用，并返回生成文件的完整路径。	Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor	class	极简游标桩对象，记录 SQL/参数并支持上下文管理，供 FakeDBOperations 与 SCD2Handler 使用。	Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor.init	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor.execute	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor.fetchone	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor.fetchall	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor.mogrify	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor._record_upserts	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor._fake_columns	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor.enter	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeCursor.exit	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeConnection	class	仿 psycopg 连接对象，仅满足 SCD2Handler 对 cursor 的最小需求，并缓存执行过的语句。	Low
etl_billiards/tests/unit/task_test_utils.py	FakeConnection.init	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeConnection.cursor	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations	class	拦截并记录批量 upsert/事务操作，避免触碰真实数据库，同时提供 commit/rollback 计数。	Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.init	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.batch_upsert_with_returning	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.batch_execute	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.execute	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.query	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.cursor	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.commit	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeDBOperations.rollback	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeAPIClient	class	在线模式使用的伪 API Client，直接返回预置的内存数据并记录调用，以确保任务参数正确传递。	Low
etl_billiards/tests/unit/task_test_utils.py	FakeAPIClient.init	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeAPIClient.iter_paginated	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeAPIClient.get_paginated	method		Low
etl_billiards/tests/unit/task_test_utils.py	FakeAPIClient.get_source_hint	method		Low
etl_billiards/tests/unit/task_test_utils.py	OfflineAPIClient	class	离线模式专用 API Client，根据 endpoint 读取归档 JSON、套入 data_path 并回放列表数据。	Low
etl_billiards/tests/unit/task_test_utils.py	OfflineAPIClient.init	method		Low
etl_billiards/tests/unit/task_test_utils.py	OfflineAPIClient.iter_paginated	method		Low
etl_billiards/tests/unit/task_test_utils.py	OfflineAPIClient.get_paginated	method		Low
etl_billiards/tests/unit/task_test_utils.py	OfflineAPIClient.get_source_hint	method		Low
etl_billiards/tests/unit/task_test_utils.py	RealDBOperationsAdapter	class	连接真实 PostgreSQL 的适配器，为任务提供 batch_upsert + 事务能力。	Low
etl_billiards/tests/unit/task_test_utils.py	RealDBOperationsAdapter.init	method		Low
etl_billiards/tests/unit/task_test_utils.py	RealDBOperationsAdapter.batch_upsert_with_returning	method		Low
etl_billiards/tests/unit/task_test_utils.py	RealDBOperationsAdapter.batch_execute	method		Low
etl_billiards/tests/unit/task_test_utils.py	RealDBOperationsAdapter.commit	method		Low
etl_billiards/tests/unit/task_test_utils.py	RealDBOperationsAdapter.rollback	method		Low
etl_billiards/tests/unit/task_test_utils.py	RealDBOperationsAdapter.close	method		Low
etl_billiards/tests/unit/task_test_utils.py	get_db_operations	function	测试专用的 DB 操作上下文：	Low
etl_billiards/tests/unit/test_config.py	(module)	module	配置管理测试	Low
etl_billiards/tests/unit/test_config.py	test_config_load	function	测试配置加载	Low
etl_billiards/tests/unit/test_config.py	test_config_override	function	测试配置覆盖	Low
etl_billiards/tests/unit/test_config.py	test_config_get_nested	function	测试嵌套配置获取	Low
etl_billiards/tests/unit/test_endpoint_routing.py	(module)	module	Unit tests for recent/former endpoint routing.	Low
etl_billiards/tests/unit/test_endpoint_routing.py	_now	function		Low
etl_billiards/tests/unit/test_endpoint_routing.py	test_recent_boundary_month_start	function		Low
etl_billiards/tests/unit/test_endpoint_routing.py	test_paylog_routes_to_former_when_old_window	function		Low
etl_billiards/tests/unit/test_endpoint_routing.py	test_coupon_usage_stays_same_path_even_when_old	function		Low
etl_billiards/tests/unit/test_endpoint_routing.py	test_goods_outbound_routes_to_queryformer_when_old	function		Low
etl_billiards/tests/unit/test_endpoint_routing.py	test_settlement_records_split_when_crossing_boundary	function		Low
etl_billiards/tests/unit/test_endpoint_routing.py	test_explicit_former_endpoint_not_rerouted	function		Low
etl_billiards/tests/unit/test_etl_tasks_offline.py	(module)	module	离线模式任务测试，通过回放归档 JSON 来验证 T+L 链路可用。	Low
etl_billiards/tests/unit/test_etl_tasks_offline.py	test_task_offline_mode	function	确保每个任务都能读取归档 JSON 并完成 Transform + Load 操作。	Low
etl_billiards/tests/unit/test_etl_tasks_online.py	(module)	module	在线模式下的端到端任务测试，验证所有任务在模拟 API 下能顺利执行。	Low
etl_billiards/tests/unit/test_etl_tasks_online.py	test_task_online_mode	function	针对每个 TaskSpec 验证：模拟 API 数据下依旧能完整跑完 ETL，并正确统计。	Low
etl_billiards/tests/unit/test_etl_tasks_stages.py	(module)	module	验证 14 个任务的 E/T/L 分阶段调用（FakeDB/FakeAPI，不访问真实接口或数据库）。	Low
etl_billiards/tests/unit/test_etl_tasks_stages.py	_build_context	function		Low
etl_billiards/tests/unit/test_etl_tasks_stages.py	test_etl_stage_flow	function	对每个任务，单独调用 transform/load，验证 counts 结构与 FakeDB 写入。	Low
etl_billiards/tests/unit/test_ods_tasks.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Low
etl_billiards/tests/unit/test_parsers.py	(module)	module	解析器测试	Low
etl_billiards/tests/unit/test_parsers.py	test_parse_decimal	function	测试金额解析	Low
etl_billiards/tests/unit/test_parsers.py	test_parse_int	function	测试整数解析	Low
etl_billiards/tests/unit/test_parsers.py	test_parse_timestamp	function	测试时间戳解析	Low
etl_billiards/tests/unit/test_reporting.py	(module)	module	汇总与报告工具的单测。	Low
etl_billiards/tests/unit/test_reporting.py	test_summarize_counts_and_format	function		Low
etl_billiards/utils/helpers.py	(module)	module	通用工具函数	High
etl_billiards/utils/helpers.py	ensure_dir	function	确保目录存在	High
etl_billiards/utils/helpers.py	make_surrogate_key	function	生成代理键	High
etl_billiards/utils/helpers.py	now_local	function	获取本地当前时间	High
etl_billiards/utils/json_store.py	(module)	module	JSON 归档/读取的通用工具。	High
etl_billiards/utils/json_store.py	endpoint_to_filename	function	将 API endpoint 转换为规范化的文件名，优先使用 非球接口API.md 中约定的名称。	High
etl_billiards/utils/json_store.py	dump_json	function	将 JSON 对象写入文件，默认紧凑，可选美化。	High
etl_billiards/utils/json_store.py	_normalize_endpoint	function	标准化 endpoint，提取路径部分并统一小写、去除 base 前缀。	High
etl_billiards/utils/logging_utils.py	TeeStream	class		High
etl_billiards/utils/logging_utils.py	TeeStream.init	method		High
etl_billiards/utils/logging_utils.py	TeeStream.write	method		High
etl_billiards/utils/logging_utils.py	TeeStream.flush	method		High
etl_billiards/utils/logging_utils.py	TeeStream.isatty	method		High
etl_billiards/utils/logging_utils.py	TeeStream.fileno	method		High
etl_billiards/utils/logging_utils.py	build_log_path	function		High
etl_billiards/utils/logging_utils.py	configure_logging	function		High
etl_billiards/utils/ods_record_utils.py	(module)	module	Shared helpers for ODS/API record normalization.	High
etl_billiards/utils/ods_record_utils.py	merge_record_layers	function	Flatten nested data/settleList layers into a single dict.	High
etl_billiards/utils/ods_record_utils.py	get_value_case_insensitive	function	Fetch column value without case sensitivity.	High
etl_billiards/utils/ods_record_utils.py	normalize_pk_value	function	Normalize PK value (e.g., digit string -> int).	High
etl_billiards/utils/ods_record_utils.py	pk_tuple_from_record	function	Extract PK tuple from a record.	High
etl_billiards/utils/reporting.py	(module)	module	简单的任务结果汇总与格式化工具。	High
etl_billiards/utils/reporting.py	summarize_counts	function	汇总多个任务的 counts，返回总计与逐任务明细。	High
etl_billiards/utils/reporting.py	format_report	function	将 summarize_counts 的输出格式化为可读文案。	High
etl_billiards/utils/windowing.py	(module)	module	Time window helpers for ETL and validation tasks.	High
etl_billiards/utils/windowing.py	_ensure_tz	function		High
etl_billiards/utils/windowing.py	_next_month_start	function		High
etl_billiards/utils/windowing.py	calc_window_minutes	function		High
etl_billiards/utils/windowing.py	split_window	function		High
etl_billiards/utils/windowing.py	build_window_segments	function		High
query_db.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/etl_billiards_misc/0.py	(module)	module	Simple PostgreSQL connectivity smoke-checker.	Medium
tmp/etl_billiards_misc/0.py	check_postgres_connection	function	Return True if connection succeeds; print diagnostics otherwise.	Medium
tmp/etl_billiards_misc/backups/manual_ingest_task.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/fetch_member_balance_change.py	(module)	module	获取会员余额变动数据: /MemberProfile/GetMemberCardBalanceChange	Medium
tmp/fetch_member_balance_change.py	main	function		Medium
tmp/hebing.py	merge_md_and_json	function	在指定目录下，将 .md 和 .json 文件按规则合并输出到一个文件中。	Medium
tmp/query_missing_tables.py	safe_str	function		Medium
tmp/rewrite_schema_dwd_doc_comments.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/rewrite_schema_ods_doc_comments.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/tmp_debug_sql.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/tmp_drop_dwd.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/tmp_dwd_tasks.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/tmp_problems.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium
tmp/tmp_run_sql.py	(parse_error)	module	invalid non-printable character U+FEFF (, line 1)	Medium