From d5c336e94649f8a86426a950da58a02be68a5d24 Mon Sep 17 00:00:00 2001 From: huang <1724659546@qq.com> Date: Mon, 3 Nov 2025 21:11:19 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=B8=85=E5=8D=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../provide-logger-with-mothed/task-list.md | 107 ++++++++++++++++++ main.go | 1 - 2 files changed, 107 insertions(+), 1 deletion(-) create mode 100644 design/provide-logger-with-mothed/task-list.md diff --git a/design/provide-logger-with-mothed/task-list.md b/design/provide-logger-with-mothed/task-list.md new file mode 100644 index 0000000..0c274a1 --- /dev/null +++ b/design/provide-logger-with-mothed/task-list.md @@ -0,0 +1,107 @@ +### 重构任务清单：纯 Context 驱动的调用链追踪 + +--- + +#### 1. 核心改造 (`logs` 包) + +- **`internal/infra/logs/logs.go`**: + - [ ] 实现 `AddCompName`, `AddFuncName`, `GetLogger`, `Trace` 四个核心包级函数。 + - [ ] 移除旧 `Logger` 结构体中的状态字段（如 `component`）。 + +--- + +#### 2. 依赖注入与结构体改造 + +- **`internal/core/application.go`**: + - [ ] 移除 `Application` 结构体中的 `Logger *logs.Logger` 成员。 + - [ ] 修改 `NewApplication` 函数，使其不再创建 `logger`，而是创建根 `context.Background()`。 + - [ ] 调整 `NewApplication`，将根 `context` 传递给 `initInfrastructure`, `initDomainServices`, `initAppServices` 和 `api.NewAPI`。 + - [ ] 移除 `Application` 结构体中所有对 `app.Logger` 的直接调用，改为通过 `context` 获取 `Logger`。 + +- **`internal/core/component_initializers.go`**: + - [ ] **修改所有组件结构体定义**: 遍历所有相关组件（Controllers, Services, Repositories 等），将其结构体中的 `logger *logs.Logger` 成员变量替换为 `selfCtx context.Context`。 + - [ ] **重构所有 `init...` 函数**: + - 移除所有 `logger *logs.Logger` 参数，改为接收 `ctx context.Context`。 + - 在每个 `init...` 函数内部，为即将创建的组件生成其专属的 `selfCtx`。例如：`selfCtx := logs.AddCompName(ctx, "ComponentName")`。 + - 将这个 `selfCtx` 注入到组件的构造函数中，并由组件保存为 `selfCtx` 成员。 + +--- + +#### 3. 全局方法签名改造：传递 `context.Context` + +**以下所有列出的组件，其所有公共方法都需要进行签名改造，将 `ctx context.Context` 作为第一个参数。** + +##### 3.1. API 层 + +- **`internal/app/api/api.go` (`API`)**: + - [ ] 修改 `NewAPI` 函数，移除 `logger` 参数，改为接收 `ctx context.Context`。 + - [ ] 移除 `API` 结构体中的 `logger` 成员，改为保存 `selfCtx context.Context`。 + - [ ] 为 `API` 组件本身创建 `selfCtx`：`selfCtx := logs.AddCompName(ctx, "API")`，并传递给所有 `Controller` 的构造函数。 + +- **`internal/app/controller/user/user_controller.go` (`user.Controller`)** +- **`internal/app/controller/device/device_controller.go` (`device.Controller`)** +- **`internal/app/controller/plan/plan_controller.go` (`plan.Controller`)** +- **`internal/app/controller/management/pig_farm_controller.go` (`management.PigFarmController`)** +- **`internal/app/controller/management/pig_batch_controller.go` (`management.PigBatchController`)** +- **`internal/app/controller/monitor/monitor_controller.go` (`monitor.Controller`)** + - **改造动作**: + - [ ] 修改 `NewController` 函数，移除 `logger` 参数，改为接收 `selfCtx context.Context`。 + - [ ] 移除 `Controller` 结构体中的 `logger` 成员，改为保存 `selfCtx`。 + - [ ] **所有公共方法**: 接收 `echo.Context` 的方法，需要从中提取 `request.Context()` 作为 `upstreamCtx`。 + +- **`internal/app/middleware/auth.go`** +- **`internal/app/middleware/audit.go`** + - **改造动作**: + - [ ] 检查并重构所有日志记录中间件。 + - [ ] 中间件应该从请求的 `c.Request().Context()` 中提取 `upstreamCtx`。 + - [ ] 使用 `logs.Trace` 或 `logs.AddFuncName` 创建新的 `Context` 和 `Logger`。 + - [ ] **关键**: 使用 `c.SetRequest(c.Request().WithContext(newCtx))` 将更新后的 `Context` 写回 `echo.Context`，以便传递给后续的中间件和 `Controller`。 + +##### 3.2. 应用层 (Application Services) + +- **`internal/app/service/pig_farm_service.go` (`service.PigFarmService`)** +- **`internal/app/service/pig_batch_service.go` (`service.PigBatchService`)** +- **`internal/app/service/monitor_service.go` (`service.MonitorService`)** +- **`internal/app/service/device_service.go` (`service.DeviceService`)** +- **`internal/app/service/plan_service.go` (`service.PlanService`)** +- **`internal/app/service/user_service.go` (`service.UserService`)** + +##### 3.3. 领域层 (Domain Services) + +- **`internal/domain/audit/service.go` (`audit.Service`)** +- **`internal/domain/device/general_device_service.go` (`device.Service`)** +- **`internal/domain/notify/notify.go` (`domain_notify.Service` - `failoverService` 实现)** +- **`internal/domain/pig/pen_transfer_manager.go` (`pig.PigPenTransferManager`)** +- **`internal/domain/pig/pig_trade_manager.go` (`pig.PigTradeManager`)** +- **`internal/domain/pig/pig_sick_manager.go` (`pig.SickPigManager`)** +- **`internal/domain/pig/pig_batch_service.go` (`pig.PigBatchService`)** +- **`internal/domain/plan/analysis_plan_task_manager.go` (`plan.AnalysisPlanTaskManager`)** +- **`internal/domain/plan/plan_execution_manager.go` (`plan.ExecutionManager`)** +- **`internal/domain/plan/plan_service.go` (`plan.Service`)** +- **`internal/domain/task/task.go` (`task.TaskFactory`)** + +##### 3.4. 基础设施层 (Infrastructure) + +- **`internal/infra/database/storage.go` (`database.Storage`)** +- **`internal/infra/logs/logs.go` (`logs.Logger` - 内部实现，非注入)** +- **`internal/infra/notify/log_notifier.go` (`notify.LogNotifier`)** +- **`internal/infra/repository/unit_of_work.go` (`repository.UnitOfWork` - `gormUnitOfWork` 实现)** +- **`internal/infra/transport/lora/chirp_stack.go` (`lora.ChirpStackTransport`)** +- **`internal/infra/transport/lora/lora_mesh_uart_passthrough_transport.go` (`lora.LoRaMeshUartPassthroughTransport`)** +- **`internal/infra/transport/lora/placeholder_transport.go` (`lora.PlaceholderTransport`)** +- **`internal/app/webhook/chirp_stack.go` (`webhook.ChirpStackListener`)** +- **`internal/app/webhook/placeholder_listener.go` (`webhook.PlaceholderListener`)** + +--- + +#### 4. 日志调用点及方法内部逻辑改造 + +- [ ] **遍历所有业务方法** (针对上述所有列出的组件的公共方法): + - [ ] **定位旧日志**: 搜索所有对旧 `z.logger.*` 成员的调用。 + - [ ] **改造方法入口** (对于非 Controller 方法): + 1. 在方法开始处，使用作为参数传入的 `ctx` (作为 `upstreamCtx`) 和组件自身持有的 `z.selfCtx`，调用 `logs.Trace`。 + - `newCtx, logger := logs.Trace(ctx, z.selfCtx, "MethodName")` + 2. 将所有旧的 `z.logger.*(...)` 调用，替换为使用新获取的 `logger.*(...)`。 + - [ ] **改造下游调用**: + 1. 在方法内部，当需要调用其他组件的方法时（如下游服务），**必须传递 `newCtx`**。 + - `err := z.downstreamService.DoSomething(newCtx, data)` diff --git a/main.go b/main.go index ebfc9a0..6b7519a 100644 --- a/main.go +++ b/main.go @@ -3,7 +3,6 @@ package main import ( "log" - _ "git.huangwc.com/pig/pig-farm-controller/docs" // 引入 swag 生成的 docs "git.huangwc.com/pig/pig-farm-controller/internal/core" )