JiuContinent
db751f03b4
refactor(Dockerfile): 使用requirements.txt替代硬编码依赖 将Dockerfile中的硬编码pip包列表替换为通过requirements.txt文件安装， 提高依赖管理的灵活性和可维护性。 feat(scheduling): 移除内置APScheduler，采用独立调度系统 移除app/core/background/scheduler.py中原来的APScheduler实现， 改为使用新的应用级调度系统app.application.scheduling。 refactor(task_queue): 调整任务队列模块结构和导入路径 将任务队列相关常量从app.core.background.task_queue.constants迁移至 app.tasks.constants，并更新所有相关导入路径和引用。 refactor(events): 将事件服务重构为独立的应用层组件 将事件分发逻辑从核心层迁移到应用层，使用app.application.events.EventDispatchService 替代原有的app.modules.events.services.EventService。 feat(ai_memory): 增强AI记忆自动写入的安全策略 新增ai_memory_blocked_content_terms配置项用于阻止敏感内容， 添加TTL过期机制控制自动写入条目的生命周期。 fix(security): 强化生产环境安全验证机制 增加model_validator确保生产环境中数据库连接、API密钥、CORS设置等 关键安全配置符合要求。 feat(risks): 优化风险事件操作动作的外键约束 为RiskEventAction模型的风险事件ID字段添加外键约束， 防止孤立记录并增强数据完整性。 refactor(audit): 优化审计服务方法命名和事务处理 将AuditService的log方法重命名为record以反映其阶段行为， 并调整事务提交时机以提高性能。 feat(events): 增强领域事件并发处理和响应模型 添加事件锁定机制防止重复处理，更新API响应模型以提供 更准确的数据类型定义。 ```
67 lines
1.6 KiB
Python
67 lines
1.6 KiB
Python
from enum import StrEnum
|
|
|
|
|
|
class EventStatus(StrEnum):
|
|
PENDING = "pending"
|
|
PROCESSED = "processed"
|
|
FAILED = "failed"
|
|
|
|
|
|
class EventType(StrEnum):
|
|
RISK_ACTION_RECORDED = "risk.action_recorded"
|
|
REPORT_PUSH_SUCCEEDED = "report.push_succeeded"
|
|
REPORT_PUSH_FAILED = "report.push_failed"
|
|
REPORT_GENERATED = "report.generated"
|
|
LEGACY_SYNC_COMPLETED = "legacy.sync_completed"
|
|
LEGACY_SYNC_FAILED = "legacy.sync_failed"
|
|
AI_MEMORY_WRITTEN = "ai.memory_written"
|
|
ENTERPRISE_ANALYTICS_GENERATED = "enterprise.analytics_generated"
|
|
|
|
|
|
class EventSource(StrEnum):
|
|
RISK = "risk"
|
|
REPORTS = "reports"
|
|
LEGACY_MYSQL = "legacy_mysql"
|
|
AI_MEMORY = "ai_memory"
|
|
ANALYTICS = "analytics"
|
|
API = "api"
|
|
|
|
|
|
class EventAggregateType(StrEnum):
|
|
RISK_EVENT = "risk-event"
|
|
REPORT_PUSH_RUN = "report-push-run"
|
|
WORK_REPORT = "work-report"
|
|
LEGACY_SYNC_RUN = "legacy-sync-run"
|
|
AI_MEMORY_ENTRY = "ai-memory-entry"
|
|
ENTERPRISE_ANALYTICS = "enterprise-analytics"
|
|
|
|
|
|
class EventResponseKey(StrEnum):
|
|
ITEMS = "items"
|
|
EVENT = "event"
|
|
TOTAL = "total"
|
|
|
|
|
|
class EventPayloadKey(StrEnum):
|
|
ACTION = "action"
|
|
STATUS = "status"
|
|
DOMAIN = "domain"
|
|
RECORD_ID = "record_id"
|
|
COMMENT = "comment"
|
|
CODE = "code"
|
|
CREATED = "created"
|
|
UPDATED = "updated"
|
|
SKIPPED = "skipped"
|
|
ERROR_MESSAGE = "error_message"
|
|
ATTEMPTS = "attempts"
|
|
HANDLED = "handled"
|
|
|
|
|
|
class EventErrorDetail(StrEnum):
|
|
EVENT_NOT_FOUND = "Domain event not found"
|
|
EVENT_NOT_RETRYABLE = "Domain event is not retryable"
|
|
EVENT_LOCKED = "Domain event is already being processed"
|
|
|
|
|
|
EVENT_CODE_PREFIX = "EVT"
|