| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139 |
- // academic 域装配(AC-11 交付部分)——跨服务依赖注入点。
- //
- // 为什么单独成文件:academic 的路由/Handler 由 AC-14 挂载,但**服务间注入关系**必须在
- // 本期固定下来,否则会退化成"端口永远没人实现 → 生产永远走降级分支"的静默缺陷。
- //
- // 本期唯一必须固定的注入(设计 §3.3 #23 / AC-11 硬要点 5):
- //
- // DivideService.firstCharged ← RecordRepo(FirstChargedRecordID)
- //
- // 背景:`divide_into_log_delete`(撤销分成)有两条分支——
- //
- // ① 学生存在"首次扣费上课记录" → **改绑 order_no 保留分成**(dump 口径,D11 已拍板);
- // ② 无首扣记录 → 回滚 total_income 并物理删除明细。
- //
- // 若端口未注入,DivideService 只能走 ②(保守分支)——即"撤销首扣订单"时把真实产生的分成整组冲掉
- // (少发钱,且与旧系统双跑必然不一致)。因此本文件的存在本身就是一条**回归防线**:
- // 谁把注入去掉,`TestWiringAcademicFirstChargedInjected` 立刻红(cmd/api 侧单测)。
- package main
- import (
- "context"
- "os"
- "github.com/gofiber/fiber/v2"
- "go.uber.org/zap"
- "gorm.io/gorm"
- academichandler "yuansiwei/unified-backend/internal/academic/handler"
- academicport "yuansiwei/unified-backend/internal/academic/port"
- academicrepo "yuansiwei/unified-backend/internal/academic/repository"
- academicservice "yuansiwei/unified-backend/internal/academic/service"
- identityhandler "yuansiwei/unified-backend/internal/identity/handler"
- )
- // 编译期契约断言(签名漂移即编译失败,杜绝"注入了但方法对不上"的隐蔽错误):
- //
- // ① RecordRepo 必须满足 DivideService 声明的 FirstChargedRecordReader(D11 改绑前提);
- // ② *DivideService 必须满足 RecordService 声明的 DivideLogGranter(结课联动分账前提)。
- var (
- _ academicservice.FirstChargedRecordReader = (*academicrepo.RecordRepo)(nil)
- _ academicservice.DivideLogGranter = (*academicservice.DivideService)(nil)
- )
- // academicServices academic 域已装配的服务集合(AC-14 接线时在此继续追加 Handler/路由)。
- type academicServices struct {
- // Divide 分账服务(AC-09;本章节只负责把首次扣费端口注入它)。
- Divide *academicservice.DivideService
- // FirstChargedInjected 首次扣费记录端口是否已注入(D11 改绑分支生效的判据,供启动日志与单测断言)。
- FirstChargedInjected bool
- }
- // newAcademicServices 装配 academic 域服务。
- //
- // 入参:gdb *gorm.DB——全局数据库句柄(连接池)。
- // 出参:*academicServices(永不返回 nil;装配失败由后续域初始化暴露)。
- //
- // 关键说明(**评审必看**):
- // - `NewRecordRepo(gdb, nil)` 的 nil 是**有意**的:FirstChargedRecordID 的取数口径
- // (dump `yuansiwei_finance.sql:763811`)按 student_id 精确过滤、无机构/校区维度,
- // 分账撤销场景也没有请求作用域(系统/后台动作)。该端口方法内部**不调用 Scoped**,
- // 因此 nil scope 安全;但这个 repo 实例**不得**用于任何带作用域的查询
- // (带作用域的方法一调用即 panic fail-fast,属预期行为)。
- // - 其余 academic 服务(Course/Record/Maintenance)需要请求作用域,由 Handler 层
- // `repository.NewXxxRepo(db, scope.FromFiber(c))` 按请求构造(AC-13/14),不在此处单例化。
- func newAcademicServices(gdb *gorm.DB) *academicServices {
- firstChargedReader := academicrepo.NewRecordRepo(gdb, nil)
- divide := academicservice.NewDivideService(gdb, firstChargedReader)
- return &academicServices{
- Divide: divide,
- FirstChargedInjected: true,
- }
- }
- // registerAcademicRoutes academic 域路由接线(AC-14 第一批:40 个已交付端点)。
- //
- // 这是 `cmd/api/main.go` 里**唯一**的 academic 挂载调用点(main 不关心端点清单、不关心顺序,
- // 全部收在 `internal/academic/handler/route.go` 的注册表里)。
- //
- // 入参:
- // - app *fiber.App:应用实例;
- // - gdb *gorm.DB:数据库句柄(academic 的 Service 按请求作用域现场装配,Handler 只持 DB);
- // - authMw fiber.Handler:identity 的验签 + 作用域注入中间件(本批 40 端点**全部**需登录);
- // - log *zap.Logger:结构化日志器。
- //
- // 出参:error——Handler 装配失败 / 路由表非法(含 `/api`、空白名单、未知角色码)/
- // 断言 ①(`method+path` 全局重复)/ 断言 ②(一级段越界,如误注册 `/auth/*`)。
- // **任一失败都必须让进程起不来**:这类缺陷在运行期是"静默失效"(Fiber 后注册者被丢弃、
- // 或某角色恒 1003),启动失败是唯一可靠的暴露点。
- //
- // 副作用(仅 dev):`UNIFIED_AUTO_MIGRATE=1` 时顺带写 RBAC 种子(三张表,`INSERT IGNORE` 幂等)。
- // 生产不在此处写权限表——按"DDL 先行"纪律随迁移脚本执行(种子 SQL 由
- // `academichandler.RBACSeed.SQL("mysql")` 渲染,与路由表 1:1,不会手抄漏行)。
- // 种子写入失败**不阻断启动**(表未建时告警;空策略是 fail-closed,不会放行越权)。
- func registerAcademicRoutes(app *fiber.App, gdb *gorm.DB, authMw fiber.Handler, log *zap.Logger) error {
- academicH, err := academichandler.New(academichandler.Config{
- DB: gdb,
- // 成员校验器(Service 层对象级越权预检):academic 域经 port 只读 t_membership,
- // 不去 import org 的 repository(依赖方向铁律,见 academic/port/orgadapter.go)。
- Member: academicport.NewOrgMembershipChecker(gdb),
- Log: log,
- })
- if err != nil {
- return err
- }
- reg, err := academichandler.Register(app, academicH, academichandler.RegisterOptions{
- Auth: authMw,
- RoleGuard: identityhandler.RequireRole,
- })
- if err != nil {
- return err
- }
- log.Info("academic 路由已挂载",
- zap.Int("routes", len(reg.Routes)),
- zap.Strings("firstSegments", reg.Prefixes))
- if os.Getenv("UNIFIED_AUTO_MIGRATE") == "1" {
- res, serr := academichandler.SeedRBAC(context.Background(), gdb, reg.Routes)
- switch {
- case serr != nil:
- // **不阻断启动**:种子是"运维动作"而不是"启动前提"。
- // 三张表里只有 t_permission/t_role_permission 在 AutoMigrate 名单内,`casbin_rule`
- // 按"目标态 DDL 先行"纪律**不**由 GORM 建表(见 infra/rbac/enforcer.go 包注释),
- // 因此 dev/预发若还没跑 DDL,这里一定报 "no such table"。
- // 若此时 os.Exit(1),结果是"没跑 DDL 就完全起不来"(连带登录也不可用),
- // 代价远大于"策略表为空"——策略为空是 fail-closed(非超管全 1003),不会放行越权。
- log.Warn("academic RBAC 种子未写入(通常是 casbin_rule 等权限表尚未按 DDL 建表)",
- zap.Error(serr))
- default:
- log.Info("academic RBAC 种子已应用(幂等:changed=0 表示已是最新)",
- zap.Int("casbinRules", res.CasbinRules),
- zap.Int64("insertedCasbinRules", res.InsertedCasbinRules),
- zap.Int("permissions", res.Permissions),
- zap.Int64("insertedPermissions", res.InsertedPermissions),
- zap.Int("rolePermissions", res.RolePermissions),
- zap.Int64("insertedRolePermissions", res.InsertedRolePermissions))
- }
- }
- return nil
- }
|