response.go 8.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199
  1. // Package response 统一响应契约(HTTP 恒 200 + body code 信封)。
  2. //
  3. // 本包是"分包铁律第 6 条"的实现:所有接口(含业务错误)HTTP 状态码恒为 200,
  4. // 真实业务状态在 body 的 R.Code 中(成功 200,失败为分段错误码,见包 errors)。
  5. // 该契约源自教务 Go 重构在产验证 + 教学 api-conventions 双侧确证,
  6. // 设计决策见 ../../../../unified/01-architecture/backend-technical-architecture.md §3.1。
  7. //
  8. // 典型使用(Handler 层):
  9. //
  10. // func GetUser(c *fiber.Ctx) error {
  11. // var req GetUserReq
  12. // if !infra.Validate(c, &req) { // 校验失败:包内已回写 body(code=2001) 并返回 false
  13. // return nil
  14. // }
  15. // user, err := svc.Get(ctx, req.ID)
  16. // if err != nil {
  17. // return response.Fail(c, err) // 非 *errors.AppError 会被包成 5001 系统繁忙
  18. // }
  19. // return response.OK(c, user)
  20. // }
  21. package response
  22. import (
  23. "yuansiwei/unified-backend/internal/infra/errors"
  24. "github.com/gofiber/fiber/v2"
  25. )
  26. // R 统一响应信封(所有接口的出参顶层结构)。
  27. //
  28. // 前端约定:一律读 body 而非 HTTP 状态码——
  29. // 成功判断 res.success === true(兼容旧前端 res.success 写法);
  30. // 分页列表读 res.data.list / res.data.total(统一嵌套在 data 内,彻底消灭旧系统
  31. // Success(total 顶层) 与 SuccessPage(total 在 data 内) 两处结构不一致的坑);
  32. // 失败时 res.code 为分段错误码(1xxx/2xxx/3xxx/4xxx/5xxx),res.message 为可直接展示给用户的文案。
  33. //
  34. // Data 语义(统一约定):
  35. // - 分页列表接口 → *PageData(对象,含 list/total/page/pageSize/pages);
  36. // - 单实体接口 → 实体对象或 nil(操作成功无数据体)。
  37. // 即"分页接口 data 恒为对象、单实体接口 data 恒为对象/省略",前端 useListPage 无需区分两套读法。
  38. //
  39. // 典型 JSON 形态:
  40. //
  41. // // 成功(分页,Page 函数写出)
  42. // {"code":200,"message":"ok","data":{"list":[...],"total":42,"page":1,"pageSize":10,"pages":5},"success":true}
  43. // // 成功(单实体,OK 函数写出)
  44. // {"code":200,"message":"ok","data":{"id":"...","name":"..."},"success":true}
  45. // // 业务失败(注意:HTTP 状态码仍是 200)
  46. // {"code":3001,"message":"记录不存在","success":false}
  47. type R struct {
  48. // Code 业务状态码:200 表示成功;失败为分段错误码(1xxx 认证 / 2xxx 参数 / 3xxx 数据 / 4xxx 依赖 / 5xxx 系统)。
  49. Code int `json:"code"`
  50. // Message 面向用户的错误文案。脱敏铁律:不得包含 SQL 片段、堆栈、密码哈希等敏感信息。
  51. Message string `json:"message"`
  52. // Data 业务数据体(成功时填充;失败时省略)。分页接口传 *PageData,单实体接口传实体对象。
  53. Data interface{} `json:"data,omitempty"`
  54. // Success 成功标志,兼容旧前端 res.success 判断,与 Code 冗余但保留。
  55. Success bool `json:"success"`
  56. }
  57. // PageData 统一分页数据体(分页列表接口的 Data 固定结构,前端 useListPage 统一读法)。
  58. //
  59. // 设计要点:分页元信息(total/page/pageSize/pages)与数据(list)**同聚于 data 内**,
  60. // 不再散落顶层——旧系统 Success 的 total 在顶层、SuccessPage 的 total 在 data 内,
  61. // 前端两套读法各异的坑由此彻底消灭。
  62. //
  63. // 典型 JSON 形态:
  64. //
  65. // {"list":[{...},{...}],"total":42,"page":1,"pageSize":10,"pages":5}
  66. type PageData struct {
  67. // List 当前页数据切片;空列表必须传非 nil 的 []T{}(零值 nil 会序列化为 JSON null,前端取 list.map 报错)。
  68. List interface{} `json:"list"`
  69. // Total 符合筛选条件的总记录数(分页器显示"共 N 条")。
  70. Total int64 `json:"total"`
  71. // Page 当前页码(从 1 开始,与请求 query 的 page 回显一致)。
  72. Page int `json:"page"`
  73. // PageSize 每页条数(与请求 query 的 pageSize 回显一致;被 ParsePage 钳制后 ≤ 200)。
  74. PageSize int `json:"pageSize"`
  75. // Pages 总页数,= ceil(total / pageSize)(pageSize 为 0 时恒 0,防除零)。
  76. Pages int64 `json:"pages"`
  77. }
  78. // OK 写出成功响应(HTTP 200,body code=200,Data 填充业务数据)。
  79. //
  80. // 入参:
  81. // - c *fiber.Ctx:Fiber 请求上下文(提供 c.JSON 写出能力;调用前无需手动设置状态码,本函数内部恒置 200)。
  82. // - data interface{}:业务数据体;允许 nil(无数据体的成功响应,如"操作成功"类接口)。
  83. //
  84. // 出参:
  85. // - error:仅当 JSON 序列化/写出失败时返回(如客户端已断开);业务失败请用 Fail,不要用本函数表达。
  86. //
  87. // 样例:
  88. //
  89. // return response.OK(c, fiber.Map{"user": user, "roles": roles})
  90. func OK(c *fiber.Ctx, data interface{}) error {
  91. return c.Status(fiber.StatusOK).JSON(R{Code: 200, Message: "ok", Data: data, Success: true})
  92. }
  93. // Page 写出成功分页响应(HTTP 200,body code=200,Data 为 PageData 嵌套对象)。
  94. //
  95. // 出参形态:
  96. //
  97. // {"code":200,"message":"ok","data":{"list":[...],"total":42,"page":1,"pageSize":10,"pages":5},"success":true}
  98. //
  99. // 入参:
  100. // - c *fiber.Ctx:Fiber 请求上下文。
  101. // - list interface{}:当前页数据切片(通常 []T);空列表请传非 nil 的 `[]T{}`,避免 JSON 输出 null。
  102. // - page int:当前页码(从 1 开始);惯例经 ParsePage(c) 解析,缺省 1。
  103. // - pageSize int:每页条数;惯例经 ParsePage(c) 解析,缺省 10、上限钳制 200。
  104. // - total int64:符合筛选条件的总记录数(用于前端分页器;查询惯例见架构规格 §3.1"先 pluck 分页 id → 批量取详情"防 N+1)。
  105. //
  106. // 出参:
  107. // - error:同 OK,仅写出层失败时返回。
  108. //
  109. // 异常场景:
  110. // - list 传 nil:PageData.List 序列化为 JSON null,前端 list.map 报错——调用方必须保证传非 nil 切片;
  111. // - total < 0:不钳制(视为调用方 bug,应单测暴露);Pages 按 ceil 计算,负数 total 会得到 0 页。
  112. //
  113. // 样例:
  114. //
  115. // page, size := response.ParsePage(c) // page 默认 1、pageSize 默认 10(上限 200)
  116. // ids, total, err := repo.PagedIDs(ctx, filter, page, size)
  117. // users, err := repo.BatchGet(ctx, ids) // 一次批量取,防 N+1
  118. // return response.Page(c, users, page, size, total)
  119. func Page(c *fiber.Ctx, list interface{}, page, pageSize int, total int64) error {
  120. pages := int64(0)
  121. if pageSize > 0 {
  122. pages = (total + int64(pageSize) - 1) / int64(pageSize) // ceil,防除零
  123. }
  124. return c.Status(fiber.StatusOK).JSON(R{
  125. Code: 200, Message: "ok",
  126. Data: PageData{List: list, Total: total, Page: page, PageSize: pageSize, Pages: pages},
  127. Success: true,
  128. })
  129. }
  130. // Fail 写出业务失败响应(HTTP 仍为 200,body code 为业务错误码,Data 省略)。
  131. //
  132. // 入参:
  133. // - c *fiber.Ctx:Fiber 请求上下文。
  134. // - err error:业务错误。约定:
  135. // - *errors.AppError:按其 Code/Msg 原样写出(可预期业务错误,Service 层应返回此类 sentinel);
  136. // - 其它 error:降级为 errors.ErrInternal(code=5001 系统繁忙),原始错误仅用于服务端日志,不进入响应体。
  137. //
  138. // 出参:
  139. // - error:仅写出层失败时返回。
  140. //
  141. // 异常场景:
  142. // - err 为 nil:按内部错误 5001 处理(调用方逻辑错误,应在单测中暴露);
  143. // - AppError.Msg 为空:兜底为"系统繁忙",防止把空文案透传给前端。
  144. //
  145. // 样例:
  146. //
  147. // user, err := svc.Get(ctx, id)
  148. // if err != nil {
  149. // return response.Fail(c, err) // ErrNotFound → {"code":3001,"message":"记录不存在"}
  150. // }
  151. func Fail(c *fiber.Ctx, err error) error {
  152. e, ok := err.(*errors.AppError)
  153. if !ok {
  154. e = errors.ErrInternal // 非业务错误(含 err==nil)一律降级 5001,细节只进日志
  155. }
  156. msg := e.Msg
  157. if msg == "" {
  158. msg = "系统繁忙"
  159. }
  160. return c.Status(fiber.StatusOK).JSON(R{Code: e.Code, Message: msg, Success: false})
  161. }
  162. // ParsePage 解析分页参数(page/pageSize,带默认值与上限钳制)。
  163. //
  164. // 入参:
  165. // - c *fiber.Ctx:Fiber 请求上下文,从 query 中读取 page 与 pageSize。
  166. //
  167. // 出参:
  168. // - page int:页码,从 1 开始;query 缺失或非法(<1)时返回默认值 1。
  169. // - pageSize int:每页条数;query 缺失或非法(<1)时返回默认值 10,超过 200 时钳制为 200(防大查询打满数据库)。
  170. //
  171. // 异常场景:
  172. // - query 值非数字:c.QueryInt 返回 0,本函数按默认值处理(不报错,前端传错参数不产生 5xx)。
  173. //
  174. // 样例:
  175. //
  176. // page, size := response.ParsePage(c)
  177. // // page=0 非法 → 1;pageSize=500 → 200
  178. func ParsePage(c *fiber.Ctx) (page, pageSize int) {
  179. page = c.QueryInt("page", 1)
  180. if page < 1 {
  181. page = 1
  182. }
  183. pageSize = c.QueryInt("pageSize", 10)
  184. if pageSize < 1 {
  185. pageSize = 10
  186. }
  187. if pageSize > 200 {
  188. pageSize = 200
  189. }
  190. return page, pageSize
  191. }