| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125 |
- // 分账端点处理器(端点 38 分账树 / 43 流水列表)——AC-13 第 1 批(读路径优先)。
- //
- // 依据:unified/03-migration/academic-frontend-contract-v1.md §3.4 B/C 表 + 设计 §3.3 #22~#25。
- //
- // 本批**只做两条读端点**,理由见文件末"本批范围";41/42 是写路径(要新增 `DeleteLogByID`
- // 等 Service 方法并配套事务用例),放在第 2 批,避免"半实现的写端点"混进首次提交。
- //
- // ---------------------------------------------------------------------------
- // 量纲红线(mock 已在此错过一次,后端不得重犯)
- // ---------------------------------------------------------------------------
- //
- // `quota` = **金额**(元/次分成,`DECIMAL(12,2)`,两位小数字符串),**不是** 0~1 比率。
- //
- // 本文件金额出参一律 `money.Amount`(JSON 两位小数字符串),DTO 里**不出现 float64**。
- //
- // ---------------------------------------------------------------------------
- // 作用域口径(`t_user_divide_into*` 无 institution_id/campus_id,§1.7 例外二)
- // ---------------------------------------------------------------------------
- //
- // 两张表都是**全局推广体系**(推广关系不归属某个机构),数据层无法按机构过滤 ⇒ 防线只有两条:
- // 1. `scope.FromFiber` 必须存在(取不到 → 1001,避免匿名读全平台分账数据);
- // 2. 端点角色白名单(AC-14 落 RBAC):预期 `super_admin / finance / market`。
- //
- // 这也是它与其他端点的本质差异:**分账树是跨机构的,不存在"本机构分账树"**。
- package handler
- import (
- "github.com/gofiber/fiber/v2"
- "yuansiwei/unified-backend/internal/academic/service"
- "yuansiwei/unified-backend/internal/infra/response"
- appscope "yuansiwei/unified-backend/internal/infra/scope"
- )
- // 分账域路径常量(**不含 `/api`**,§4 口径表)。
- const (
- // PathDivideTree 端点 38:分账树(`GET /admin/divide-into/tree`)。
- PathDivideTree = "/admin/divide-into/tree"
- // PathDivideLogs 端点 43:分账流水列表(`GET /admin/divide-into/logs`)。
- // 端点 41(POST 同路径)与 42(`DELETE /admin/divide-into/logs/:id`)在第 2 批接入。
- PathDivideLogs = "/admin/divide-into/logs"
- )
- // GetDivideTree 分账树(端点 38 `GET /admin/divide-into/tree`)。
- //
- // 出参(成功):`{tree:[…], nodeCount, rootCount}` —— **包一层 `tree`**
- // (契约 §3.4 结构约定 2 的显式例外:树不是分页对象)。
- // 节点:`userId / realName / parentUserId|null / quota:金额 / cumulativeIncome:金额 / layer / children[]`。
- // 出参(失败):1001(无作用域)/ 5001(**Nested Set 不变式被破坏**,数据损坏)/ 5002(读库或金额异常)。
- //
- // ⚠ 5001 是**有意的**:树坏了就**不返回**一棵"看起来对"的树。位移错位无法从当前数据推断原值,
- // 猜测式修复会把"确定性错误"变成"随机正确"(不变式 I1~I4 见 `service.divide_tree_service.go` 文件头)。
- func (h *Handler) GetDivideTree(c *fiber.Ctx) error {
- sc, err := mustScope(c)
- if err != nil {
- return response.Fail(c, err)
- }
- tree, err := h.divideServiceFor(sc).GetTree(c.Context())
- if err != nil {
- return response.Fail(c, err)
- }
- return response.OK(c, tree)
- }
- // ListDivideLogs 分账流水列表(端点 43 `GET /admin/divide-into/logs`)。
- //
- // 入参(query):
- // - `findUserId`(分成获得者;**表列是 `user_id`**,契约响应字段才叫 `findUserId`);
- // - `studentId`;
- // - `from`/`to`(**右开**:`from <= createTime < to`,与契约 §1.3 一致);
- // - `page`/`pageSize`(钳制上限 200)。
- //
- // 出参(成功):`分页`——`{list,total,page,pageSize,pages}`,行字段见 `service.DivideLogView`。
- //
- // ⚠ 列表端点用通用分页形状(键名 `list`),**不是**端点 17 的 `details`
- // (那是"汇总 + 明细"的复合 data,两者不要互相抄)。
- //
- // 出参(失败):1001 / 2001(`from > to`)/ 2002(时间格式非法)/ 5002。
- func (h *Handler) ListDivideLogs(c *fiber.Ctx) error {
- sc, err := mustScope(c)
- if err != nil {
- return response.Fail(c, err)
- }
- from, _, ferr := parseTimeParam(c.Query("from"), "from")
- if ferr != nil {
- return response.Fail(c, ferr)
- }
- to, _, terr := parseTimeParam(c.Query("to"), "to")
- if terr != nil {
- return response.Fail(c, terr)
- }
- page, pageSize := parsePage(c)
- q := service.DivideLogQuery{
- FindUserID: c.Query("findUserId"), StudentID: c.Query("studentId"),
- Page: page, PageSize: pageSize,
- }
- if !from.IsZero() {
- q.From = &from
- }
- if !to.IsZero() {
- q.To = &to
- }
- rows, total, err := h.divideServiceFor(sc).ListLogs(c.Context(), q)
- if err != nil {
- return response.Fail(c, err)
- }
- return response.Page(c, rows, page, pageSize, total)
- }
- // divideServiceFor 按作用域装配分账查询服务(分账域**不**做机构 scoping,见文件头"作用域口径")。
- //
- // 姓名解析器本批未注入(`realName` 返回空串):姓名在 identity/org 域,academic 未持有
- // `t_user` 结构(§1.3 跨域只读要经 port);AC-14 装配时注入真实实现即可,不影响树结构与金额。
- // **不编造**姓名 —— 空串是显式的"未解析",前端按"未填"展示。
- func (h *Handler) divideServiceFor(sc *appscope.Scope) *service.DivideTreeService {
- return service.NewDivideTreeService(h.db, sc, nil)
- }
- // 本批范围(AC-13 增量交付,明确边界防"以为做完了")
- //
- // ✅ 38 分账树(含 Nested Set 不变式 I1~I4 校验)
- // ✅ 43 分账流水列表(右开时间窗 + 同快照 total)
- // ⏳ 41 记流水 / 42 删流水 —— 需要新增 Service 写方法(`AddLog` 已存在、`DeleteLogByID` 需新增)
- // 并配套"撤销回滚 total_income 同事务"的跨表断言,放第 2 批
- // ⏳ 22~37 活动 / 39~40 分账额度 / 44~57 课程排班 / 58~63 课酬维护 —— 后续批次
|