1461a8d113
按 2026-11-02 需求补齐计划交付后端能力： - 角色授权：权限目录化，接口统一准入校验，未登记默认拒绝； 管理员判断改为按数据库角色重新判定，防止权限码持有者绕过 - 系统监控：单进程采集资源、请求与异常指标，分钟级聚合， 阈值配置化；敏感配置增加 repr 保护，Redis 密码 URL 转义 - 试用期计提：按回款日判定并写入快照，年度结清与调整单联动； 人员模型补试用期、离职日期与工资版本历史字段 - 计提模板：公式骨架受控，页面维护名称与参数绑定 - T+ 采集：自动化配置表与进度查询 内置角色禁停用保护对齐模块注释；核算规则版本提为常量并 补充批量核算失败堆栈日志。 影响范围：后端全部模块、数据库迁移 V22-V28 验证：uv run ruff check 通过；922 个单元测试全部通过； 集成测试因本机 MySQL 数据卷被其他容器锁定暂未运行
41 lines
1.8 KiB
Python
41 lines
1.8 KiB
Python
"""只按明确的源驱动错误分类，不把含凭据的驱动文本写入响应。"""
|
||
|
||
from sqlalchemy.exc import TimeoutError as PoolTimeoutError
|
||
|
||
TRANSIENT_CODES = frozenset({"SOURCE_CONNECTION_LOST", "SOURCE_TIMEOUT"})
|
||
MESSAGES = {
|
||
"TASK_AUTHORIZATION_REVOKED": "请求账号已停用或权限已撤销，请重新授权后创建任务",
|
||
"SOURCE_CONNECTION_LOST": "源连接中断，请检查网络和只读连接",
|
||
"SOURCE_TIMEOUT": "源连接或查询超时",
|
||
"SOURCE_AUTH_ERROR": "源账号认证失败，请核对只读账号配置",
|
||
"SOURCE_SCHEMA_ERROR": "源表或字段不匹配，请核对版本与映射",
|
||
"SOURCE_CONFIG_ERROR": "源连接配置不完整或任务排队后发生变化",
|
||
"SOURCE_DRIVER_ERROR": "源数据库驱动不可用，请检查已验证的ODBC驱动",
|
||
"QUERY_FILE_MISSING": "缺少源查询文件，请核对部署包",
|
||
}
|
||
|
||
|
||
def classify_source_error(exc, fallback="READ_ERROR"):
|
||
from app.core.exceptions import ForbiddenError
|
||
|
||
if isinstance(exc, ForbiddenError):
|
||
return "TASK_AUTHORIZATION_REVOKED"
|
||
if isinstance(exc, (TimeoutError, PoolTimeoutError)):
|
||
return "SOURCE_TIMEOUT"
|
||
if isinstance(exc, ModuleNotFoundError):
|
||
return "SOURCE_DRIVER_ERROR"
|
||
if isinstance(exc, FileNotFoundError):
|
||
return "QUERY_FILE_MISSING"
|
||
original = getattr(exc, "orig", exc)
|
||
args = getattr(original, "args", ())
|
||
state = str(args[0]).upper() if args else ""
|
||
if state in {"HYT00", "HYT01"}:
|
||
return "SOURCE_TIMEOUT"
|
||
if state in {"08S01", "08001", "08003", "08006"}:
|
||
return "SOURCE_CONNECTION_LOST"
|
||
if state == "28000":
|
||
return "SOURCE_AUTH_ERROR"
|
||
if state in {"42S02", "42S22", "07002"}:
|
||
return "SOURCE_SCHEMA_ERROR"
|
||
return fallback
|