DEV-MERGE-LEGACY-BACKEND-2026/internal/org/repository/campus_repo.go

// 校区仓储（T6）：t_campus 的**作用域**数据访问。
//
// 与 identity 平台级仓储的关键差异（架构规格 §3.5）：
//   - **继承 scope.BaseRepo**：t_campus 隶属机构（institution_id 列），是"租户内的校区"维度资源，
//     每次查询必须经 Scoping 强制过滤——多租户防线的唯一收口点在 BaseRepo.Scoping，
//     本包禁止裸查（r.DB.Where(...) 不经过 Scoping = 跨校区/跨机构越权，风险登记册项）。
//   - scoping 行为（由 scope 包保证）：
//     Sc 为 nil → panic（fail-fast，正常请求链路 Auth 中间件保证作用域已注入）；
//     SuperAdmin=true → 不加机构/校区过滤（平台超管跨机构视角）；
//     普通用户 → 强制 institution_id = Sc.InstitutionID；CampusID>0 时再强制 campus_id
//     （老师角色锁定本校；教务/财务 campus=0 时可看本机构全部校区）。
//
// 依赖方向铁律：org repository → infra/scope + org/model + infra/errors（全下层/同域），
// 不依赖 handler/service。
package repository

import (
	"context"
	stderrors "errors"

	"gorm.io/gorm"

	"yuansiwei/unified-backend/internal/infra/errors"
	appscope "yuansiwei/unified-backend/internal/infra/scope"
	"yuansiwei/unified-backend/internal/org/model"
)

// CampusRepo 校区仓储（作用域强制过滤）。
type CampusRepo struct {
	appscope.BaseRepo
}

// NewCampusRepo 构造校区仓储（Handler 在拿到 Scope 后调用；db 必填、sc 可为 nil——
// nil 进入 Scoping 会 panic，属预期 fail-fast，见 scope.BaseRepo 注释）。
func NewCampusRepo(db *gorm.DB, sc *appscope.Scope) *CampusRepo {
	return &CampusRepo{BaseRepo: appscope.NewBaseRepo(db, sc)}
}

// CampusFilter 校区列表筛选条件（keyword 模糊匹配校区名 / 状态精确匹配；均可空）。
type CampusFilter struct {
	Keyword string
	Status  string
}

// PagedList 分页取校区列表（强制作用域过滤：普通用户仅见本机构；CampusID>0 时仅见本校区）。
//
// 入参：
//   - ctx context.Context：请求上下文（GORM WithContext 传递取消/超时）。
//   - f CampusFilter：筛选条件（Keyword/Status 为空则不过滤该维度）。
//   - page int：页码（从 1 开始；<1 按 1 处理）。
//   - pageSize int：每页条数（0/负数按 10 兜底——与 response.ParsePage 同语义）。
//
// 出参：
//   - []model.Campus：当前页记录（无记录时返回非 nil 空切片，JSON 序列化为 [] 而非 null）。
//   - int64：符合筛选条件的总记录数（分页器"共 N 条"）。
//   - error：*AppError——ErrDBError(5002) 数据库异常；无作用域由 Scoping panic 兜底（全局 Recover）。
func (r *CampusRepo) PagedList(ctx context.Context, f CampusFilter, page, pageSize int) ([]model.Campus, int64, error) {
	if page < 1 {
		page = 1
	}
	if pageSize < 1 {
		pageSize = 10
	}
	q := r.Scoping(r.WithContext(ctx).Model(&model.Campus{}))
	if f.Keyword != "" {
		q = q.Where("campus_name LIKE ?", "%"+f.Keyword+"%")
	}
	if f.Status != "" {
		q = q.Where("status = ?", f.Status)
	}
	var total int64
	if err := q.Count(&total).Error; err != nil { // GORM 纪律：Count 收 *int64
		return nil, 0, errors.WithCause(errors.ErrDBError, err)
	}
	list := make([]model.Campus, 0, pageSize)
	if err := q.Order("campus_id ASC").
		Offset((page - 1) * pageSize).
		Limit(pageSize).
		Find(&list).Error; err != nil {
		return nil, 0, errors.WithCause(errors.ErrDBError, err)
	}
	return list, total, nil
}

// Get 按校区 ID 取单个校区（强制作用域过滤：非超管取别家/别校校区 → 查不到 → ErrNotFound）。
//
// 入参：ctx 请求上下文；campusID 校区 ID（>0）。
// 出参：*model.Campus（命中）；error——ErrNotFound(3001) 不存在或作用域外 / ErrDBError(5002)。
func (r *CampusRepo) Get(ctx context.Context, campusID int64) (*model.Campus, error) {
	var cp model.Campus
	err := r.Scoping(r.WithContext(ctx)).
		Where("campus_id = ?", campusID).
		First(&cp).Error
	if stderrors.Is(err, gorm.ErrRecordNotFound) {
		return nil, errors.ErrNotFound
	}
	if err != nil {
		return nil, errors.WithCause(errors.ErrDBError, err)
	}
	return &cp, nil
}