bill_service.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541
  1. // 学生账单查询服务(sp_user_expense_get_bill → BillService.GetBill)。
  2. //
  3. // 依据:unified/03-migration/academic-domain-design.md
  4. // - §3.4 #25 `sp_user_expense_get_bill`(dump **764094~764232**;4 张 MEMORY 临时表 → 内存结构)
  5. // - §3.8-**E2**(`create_time` 属**业务时间**,参与对账、逐值 0 容差)
  6. // - §3.8-**A18**(`type=108` 双来源:**只归因、不裁剪**——本服务的余额类汇总一律全类型计入)
  7. // - §5.1 纪律 4「横切优先」(账单恒等式 + 期初/期末不随分页变化)
  8. //
  9. // ---------------------------------------------------------------------------
  10. // dump 骨架(764133~764180,**按原文,不做"优化"**)
  11. // ---------------------------------------------------------------------------
  12. //
  13. // CREATE TEMPORARY TABLE temp_user_expense_log(type INT, logid VARCHAR(50), money DECIMAL(10,3), create_time VARCHAR(100));
  14. // INSERT INTO temp_user_expense_log SELECT type,logid,money,create_time FROM t_user_expense_log WHERE userid=inUserid;
  15. // -- 同法 temp_courses_activity_signed / temp_courses_activity_used_log / temp_user_balance_request
  16. //
  17. // 764170 SELECT SUM(money) FROM temp_user_expense_log WHERE type=107 AND create_time BETWEEN inStartTime AND inEndTime; -- 当期推荐额
  18. // 764172 SELECT SUM(money) FROM temp_user_expense_log WHERE type in(101,201,104,204,105,205) AND create_time BETWEEN ...; -- 当期消费
  19. // 764174 SELECT SUM(money) FROM temp_user_expense_log WHERE create_time<inEndTime; -- **期末余额**
  20. // 764176 SELECT SUM(money) FROM temp_user_expense_log WHERE create_time<inStartTime; -- **期初余额**
  21. // 764178-764192 赠送额结余(当前/上一次)→ 当期使用赠送 = 当期赠送 + 上期结余 − 当前结余(764194)
  22. //
  23. // ---------------------------------------------------------------------------
  24. // ★ 三种比较语义并存(**dump 的既有不对称,禁止统一**)
  25. // ---------------------------------------------------------------------------
  26. //
  27. // 「当期发生额」= `BETWEEN inStartTime AND inEndTime` → **两端闭**:start <= t <= end
  28. // 「期末余额」 = `create_time < inEndTime` → **不含右端**:t < end
  29. // 「期初余额」 = `create_time < inStartTime` → **不含右端**:t < start
  30. //
  31. // ⇒ 因此 **期末 − 期初 = Σ(start <= t < end)**,而**当期发生额 = Σ(start <= t <= end)**,
  32. // 二者在 `t = inEndTime` 处**恰好相差落在该时刻的那些流水**。
  33. // 这不是 bug,是 dump 把 `create_time` 当 `VARCHAR(100)` 直接字符串比较留下的历史口径:
  34. // 用户在 `end` 当天/当时刻的流水会进"当期发生额",但不进"期末余额"。
  35. // 本服务把这个差额**显式暴露**为 `FlowInclusiveEnd − FlowExclusiveEnd`(`BillSummary` 两字段),
  36. // 让调用方/对账脚本能看见它,而不是靠"统一成一种语义"把它抹掉(抹掉就与旧系统数字不一致)。
  37. //
  38. // ---------------------------------------------------------------------------
  39. // ★ 入参时间边界(前端必须知道的一句话)
  40. // ---------------------------------------------------------------------------
  41. //
  42. // `from` 是**含**下界(>= from),`to` 是**不含**上界(< to)—— 对"余额/期初期末"而言。
  43. // **若前端要"含当日",必须传次日或 `23:59:59`**(例如查 2026-03-01 当日流水,应传
  44. // from=2026-03-01T00:00:00, to=2026-03-02T00:00:00;传 to=2026-03-01T00:00:00 会得到该日 0 条)。
  45. // dump 用 `VARCHAR` 做 `BETWEEN`,语义随字符串格式漂移;目标态改用 `datetime(3)` 后,
  46. // **入参语义按上述定死**(这是"目标态显式化",不是行为漂移:旧系统前端一直传 `YYYY-MM-DD`,
  47. // dump 里 `BETWEEN '2026-03-01' AND '2026-03-31'` 同样不含 03-31 的时分秒部分)。
  48. //
  49. // ---------------------------------------------------------------------------
  50. // ★ `campusIds` 入参的真相(dump 里是**死参数**)
  51. // ---------------------------------------------------------------------------
  52. //
  53. // dump 764094 声明了 `IN inCampusids VARCHAR(1000)`,但 764095~764232 的**整段过程体一次都没引用它**
  54. // (在 dump 里 grep 结果只有声明行)。因此本服务的 `CampusIDs` **只做解析/回显,不做过滤**——
  55. // 与 dump 完全一致。绝不为此给 `t_user_expense_log` 加 campus 维度(§3.8-f 约束 2:
  56. // 流水表无 campus 列,账单恒等式只能按 user 做);若产品确需"校区视图",须另开"按
  57. // t_courses_student / t_user_expense_school 的 join 路径"需求,不能在这里偷偷过滤。
  58. package service
  59. import (
  60. "context"
  61. "strconv"
  62. "strings"
  63. "time"
  64. "gorm.io/gorm"
  65. "yuansiwei/unified-backend/internal/academic/model"
  66. "yuansiwei/unified-backend/internal/academic/money"
  67. "yuansiwei/unified-backend/internal/academic/port"
  68. "yuansiwei/unified-backend/internal/academic/repository"
  69. infraerrors "yuansiwei/unified-backend/internal/infra/errors"
  70. appscope "yuansiwei/unified-backend/internal/infra/scope"
  71. )
  72. // 账单汇总用到的流水类型集合(dump 764172 原文 `type in(101,201,104,204,105,205)`)。
  73. var (
  74. // billSpendTypes 「当期消费」类型集合(逐值与 dump 764172 的 IN 列表一致)。
  75. billSpendTypes = []int32{
  76. model.ExpenseLogTypeCourseCampus, // 101
  77. model.ExpenseLogTypeCourseCampusB, // 201
  78. model.ExpenseLogTypeCourseSchoolA, // 104
  79. model.ExpenseLogTypeCourseSchoolC, // 204
  80. model.ExpenseLogTypeCourseSchoolB, // 105
  81. model.ExpenseLogTypeCourseSchoolD, // 205
  82. }
  83. )
  84. // BillService 学生账单查询服务(只读;无事务)。
  85. //
  86. // 字段:
  87. // - repo 账单仓储(4 张来源表按 user 全量取回);
  88. // - member 成员校验器(可 nil;非 nil 时对"学生是否属于当前机构/校区"做越权预检);
  89. // - sc 请求作用域(可 nil:系统任务/双跑脚本视角)。
  90. type BillService struct {
  91. repo *repository.BillRepo
  92. member port.MembershipChecker
  93. sc *appscope.Scope
  94. }
  95. // NewBillService 构造账单服务。
  96. //
  97. // 入参:db *gorm.DB(必填);sc *appscope.Scope(请求作用域;系统任务可 nil)。
  98. // 出参:*BillService(成员校验需 `WithMembershipChecker` 注入后生效)。
  99. func NewBillService(db *gorm.DB, sc *appscope.Scope) *BillService {
  100. return &BillService{repo: repository.NewBillRepo(db), sc: sc}
  101. }
  102. // WithMembershipChecker 注入成员校验器(返自身,便于链式装配)。
  103. //
  104. // 入参:member port.MembershipChecker(nil 表示不做越权预检——仅限双跑/回填脚本)。
  105. // 出参:*BillService(同一实例)。
  106. func (s *BillService) WithMembershipChecker(member port.MembershipChecker) *BillService {
  107. s.member = member
  108. return s
  109. }
  110. // GetBillInput 账单查询入参(对齐 dump 的 4 个入参 + 明细分页)。
  111. //
  112. // 字段:
  113. // - UserID 学生(ULID;必填);
  114. // - CampusIDs 校区逗号串(dump 第二入参 `inCampusids`;**只解析回显、不过滤**,见文件头);
  115. // - From 起始时间(**含**下界);
  116. // - To 结束时间(**不含**上界——"期末"口径;「当期发生额」按 dump 的 BETWEEN 含右端);
  117. // - Page / PageSize 明细分页(<=0 由 ClampPage 归一;PageSize 上限 200)。
  118. type GetBillInput struct {
  119. // UserID 学生(canonical_user_id / ULID 26 位)。
  120. UserID string
  121. // CampusIDs 校区逗号串(如 "1,2,3";"" 或不传 = 不加过滤;**dump 未使用,仅回显**)。
  122. CampusIDs string
  123. // From 起始时间(含)。
  124. From time.Time
  125. // To 结束时间(不含)。
  126. To time.Time
  127. // Page 页码(1 基)。
  128. Page int
  129. // PageSize 每页条数。
  130. PageSize int
  131. }
  132. // BillSummary 账单汇总(dump 764218-764230 的 9 个 SELECT 列 + 3 个对账辅助列)。
  133. //
  134. // 全部金额为 `money.Amount`(分,定点),JSON 输出为"两位小数字符串"(如 "123.45")——
  135. // 与旧库 `DECIMAL(10,3)` 的显示习惯对齐到 2 位(目标态 DDL 为 `decimal(12,2)`)。
  136. type BillSummary struct {
  137. // PrevBalance 期初余额 = Σ(money WHERE create_time < From)(dump 764176 `previousBalance`)。
  138. PrevBalance money.Amount `json:"prevBalance"`
  139. // EndBalance 期末余额 = Σ(money WHERE create_time < To)(dump 764174 `currentBalance`)。
  140. EndBalance money.Amount `json:"endBalance"`
  141. // Recharge 当期充值 = Σ(money WHERE type=100 AND From <= create_time <= To)(dump 764168 游标)。
  142. Recharge money.Amount `json:"recharge"`
  143. // Gift 当期赠送额 = Σ(signed.activity_money)(经"充值工单 × 报名"关联,dump 764168 第二列)。
  144. Gift money.Amount `json:"gift"`
  145. // RecommendAmount 当期老带新推荐额 = Σ(money WHERE type=107 AND 区间内)(dump 764170)。
  146. RecommendAmount money.Amount `json:"recommendAmount"`
  147. // Spend 当期消费 = Σ(money WHERE type IN (101,201,104,204,105,205) AND 区间内)(dump 764172)。
  148. Spend money.Amount `json:"spend"`
  149. // GiveUsed 当期使用赠送额(dump 764194 `currentUsedGiveCost` = Gift + GivePrevBalance − GiveEndBalance)。
  150. GiveUsed money.Amount `json:"giveUsed"`
  151. // GivePrevBalance 期初赠送结余(dump 764192 `previousGiveCost`;口径见 giveBalanceBefore)。
  152. GivePrevBalance money.Amount `json:"givePrevBalance"`
  153. // GiveEndBalance 期末赠送结余(dump 764180 `currentGiveCost`;口径同上)。
  154. GiveEndBalance money.Amount `json:"giveEndBalance"`
  155. // FlowExclusiveEnd 窗口内全类型流水合计(From <= t **<** To)——
  156. // **恒等于 EndBalance − PrevBalance**(§5.1 第 4 条:账单恒等式的可判定形式)。
  157. FlowExclusiveEnd money.Amount `json:"flowExclusiveEnd"`
  158. // FlowInclusiveEnd 窗口内全类型流水合计(From <= t **<=** To)——
  159. // 与「当期发生额」同口径(BETWEEN 含右端)。二者之差 == 落在 `t = To` 的那些流水。
  160. FlowInclusiveEnd money.Amount `json:"flowInclusiveEnd"`
  161. // CampusIDs dump 第二入参的解析结果(**仅回显**:dump 全程未引用该参数,本服务不过滤)。
  162. CampusIDs []int64 `json:"campusIds"`
  163. }
  164. // BillDetail 账单明细行(分页;按 `create_time DESC, id DESC`)。
  165. type BillDetail struct {
  166. // ID 流水 ID(同一时刻多行的稳定排序键)。
  167. ID int64 `json:"id"`
  168. // Type 流水类型(model.ExpenseLogType*)。
  169. Type int32 `json:"type"`
  170. // TypeTitle 类型中文名(只用于展示;未登记类型返回 "其它")。
  171. TypeTitle string `json:"typeTitle"`
  172. // LogID 业务单号(原 logid;可为空串)。
  173. LogID string `json:"logId"`
  174. // Money 变更金额(元;符号已表方向,见 model.ExpenseLogType* 注释)。
  175. Money money.Amount `json:"money"`
  176. // CreateTime 业务时间(§3.8-E2 ①类,参与对账、逐值 0 容差)。
  177. CreateTime time.Time `json:"createTime"`
  178. }
  179. // BillResult 账单查询结果(汇总 + 明细分页两段,设计 §3.4 #25「两段返回」)。
  180. type BillResult struct {
  181. // Summary 汇总(**不受分页影响**)。
  182. Summary BillSummary `json:"summary"`
  183. // Details 明细(当前页)。
  184. Details []BillDetail `json:"details"`
  185. // Total 明细总条数(分页总数)。
  186. Total int64 `json:"total"`
  187. // Page 当前页码(已钳制)。
  188. Page int `json:"page"`
  189. // PageSize 每页条数(已钳制)。
  190. PageSize int `json:"pageSize"`
  191. // From / To 回显查询窗口(审计用;语义见 GetBillInput)。
  192. From time.Time `json:"from"`
  193. To time.Time `json:"to"`
  194. }
  195. // GetBill 查询学生账单(汇总 + 明细分页)。
  196. //
  197. // 入参:
  198. // - ctx 请求上下文;
  199. // - in GetBillInput(UserID 必填;From/To 必填且 From <= To)。
  200. //
  201. // 出参:
  202. // - *BillResult:汇总 + 明细;明细为空时 Details 为长度 0 的非 nil 切片;
  203. // - ErrBadParam(2001) 缺参/时间窗非法;ErrUnscoped(1004) 越权(注入了 MembershipChecker 时);
  204. // ErrDBError(5002) 数据库异常或金额字面量解析失败。
  205. //
  206. // **明细口径**:`Details` 是该账户的**全量流水**(`create_time DESC, id DESC` 分页),
  207. // **不按 from/to 过滤** —— dump 的 `get_bill` 只返回 9 个汇总列、没有明细列表;设计 §3.4 #25
  208. // 要求"Go 侧支持分页明细 + 汇总对象两段返回",明细即"账户流水账",配合汇总看当期发生额。
  209. // 若前端要"只看窗口内流水",按 `Details[].CreateTime` 自行过滤或另开参数(本期不加,
  210. // 免得"明细被窗口裁掉、汇总却是全量"这种两处口径不一的错觉)。
  211. //
  212. // 只读:本方法**不开事务**(dump 的 4 张 MEMORY 临时表是一次性快照,等价于"同一读视图";
  213. // 目标态在单连接上顺序执行 4 次查询,落库并发写入造成的瞬间不一致由"流水只增不改"兜底)。
  214. func (s *BillService) GetBill(ctx context.Context, in GetBillInput) (*BillResult, error) {
  215. if strings.TrimSpace(in.UserID) == "" {
  216. return nil, infraerrors.WithCause(infraerrors.ErrBadParam, errString("service: GetBill 需要 user_id"))
  217. }
  218. if in.From.IsZero() || in.To.IsZero() {
  219. return nil, infraerrors.WithCause(infraerrors.ErrBadParam,
  220. errString("service: GetBill 需要 from/to(账户区间对账的两个边界都是必填)"))
  221. }
  222. if in.From.After(in.To) {
  223. return nil, infraerrors.WithCause(infraerrors.ErrBadParam,
  224. errString("service: GetBill 的 from 不能晚于 to"))
  225. }
  226. campusIDs, err := parseCampusIDs(in.CampusIDs)
  227. if err != nil {
  228. return nil, err
  229. }
  230. // 越权预检:4 张来源表都无作用域列(或跨校区可见),必须在这里断"该学生属于当前机构/校区"
  231. if s.member != nil && s.sc != nil {
  232. if err := s.member.AssertInScope(ctx, in.UserID, s.sc.InstitutionID, s.sc.CampusID); err != nil {
  233. return nil, err
  234. }
  235. }
  236. logs, err := s.repo.LoadLogs(ctx, in.UserID)
  237. if err != nil {
  238. return nil, err
  239. }
  240. // 充值工单**只在"赠送额"这条链上用到**(dump 764168 游标的 LEFT JOIN),BETWEEN 含两端。
  241. reqNos, err := s.repo.LoadRechargeRequestNos(ctx, in.UserID, in.From, in.To)
  242. if err != nil {
  243. return nil, err
  244. }
  245. signed, err := s.repo.LoadActivitySigned(ctx, in.UserID)
  246. if err != nil {
  247. return nil, err
  248. }
  249. used, err := s.repo.LoadActivityUsedLogs(ctx, in.UserID)
  250. if err != nil {
  251. return nil, err
  252. }
  253. summary, err := buildBillSummary(logs, reqNos, signed, used, in.From, in.To)
  254. if err != nil {
  255. return nil, err
  256. }
  257. summary.CampusIDs = campusIDs
  258. page := repository.PageQuery{Page: in.Page, PageSize: in.PageSize}
  259. pageNo, pageSize := page.Normalize()
  260. total, err := s.repo.CountLogs(ctx, in.UserID)
  261. if err != nil {
  262. return nil, err
  263. }
  264. rows, err := s.repo.PageLogs(ctx, in.UserID, page)
  265. if err != nil {
  266. return nil, err
  267. }
  268. details := make([]BillDetail, 0, len(rows))
  269. for i := range rows {
  270. amount, perr := money.Parse(rows[i].Money)
  271. if perr != nil {
  272. return nil, infraerrors.WithCause(infraerrors.ErrDBError, perr)
  273. }
  274. logID := ""
  275. if rows[i].LogID != nil {
  276. logID = *rows[i].LogID
  277. }
  278. details = append(details, BillDetail{
  279. ID: rows[i].ID,
  280. Type: rows[i].Type,
  281. TypeTitle: billTypeTitle(rows[i].Type),
  282. LogID: logID,
  283. Money: amount,
  284. CreateTime: rows[i].CreateTime,
  285. })
  286. }
  287. return &BillResult{
  288. Summary: summary,
  289. Details: details,
  290. Total: total,
  291. Page: pageNo,
  292. PageSize: pageSize,
  293. From: in.From,
  294. To: in.To,
  295. }, nil
  296. }
  297. // buildBillSummary 由 4 份内存结构算出 dump 的 9 个汇总列 + 3 个对账辅助列(纯函数,便于单测)。
  298. //
  299. // 入参:
  300. // - logs 该 user 全量流水(LoadLogs);
  301. // - reqNos 区间内已通过的普通充值工单 biz_no 列表(LoadRechargeRequestNos,BETWEEN 含两端);
  302. // - signed 该 user 全部活动报名行(LoadActivitySigned);
  303. // - used 该 user 全部老带新获得/使用记录(LoadActivityUsedLogs);
  304. // - from/to 查询窗口(from 含、to 不含;「当期发生额」用 BETWEEN 含 to)。
  305. //
  306. // 出参:BillSummary;金额字面量非法 → ErrDBError。
  307. //
  308. // 累加纪律:**全部在 Go 侧用 money.Amount 定点累加**(禁止 SQL SUM(decimal),见 BillRepo 头注释)。
  309. func buildBillSummary(
  310. logs []model.UserExpenseLog,
  311. reqNos []string,
  312. signed []model.CoursesActivitySigned,
  313. used []model.CoursesActivityUsedLog,
  314. from, to time.Time,
  315. ) (BillSummary, error) {
  316. var out BillSummary
  317. // dump 764168:充值工单参与集合(`temp_user_balance_request`)
  318. rechargeReqNos := make(map[string]struct{}, len(reqNos))
  319. for _, no := range reqNos {
  320. if no == "" {
  321. continue // 空串不参与匹配(旧库 requestid 可为空串,误配会凭空造出赠送额)
  322. }
  323. rechargeReqNos[no] = struct{}{}
  324. }
  325. // 实际参与赠送额汇总的工单号:dump 的 join 路径是 `log.logid = request.id`,
  326. // 因此**还要有一条区间内的 type=100 流水**指向该工单,才可能把 signed.activity_money 计进来。
  327. matchedReqNos := make(map[string]struct{}, len(rechargeReqNos))
  328. for i := range logs {
  329. row := logs[i]
  330. amount, err := money.Parse(row.Money)
  331. if err != nil {
  332. return BillSummary{}, infraerrors.WithCause(infraerrors.ErrDBError, err)
  333. }
  334. // 期初 / 期末:`create_time < 边界`(不含右端,dump 764174 / 764176)
  335. if row.CreateTime.Before(from) {
  336. out.PrevBalance = out.PrevBalance.Add(amount)
  337. }
  338. if row.CreateTime.Before(to) {
  339. out.EndBalance = out.EndBalance.Add(amount)
  340. }
  341. // 窗口内合计:两个口径各算一次(差额 == 落在 t = to 的流水,见 BillSummary 字段注释)
  342. if !row.CreateTime.Before(from) {
  343. if row.CreateTime.Before(to) {
  344. out.FlowExclusiveEnd = out.FlowExclusiveEnd.Add(amount)
  345. }
  346. if !row.CreateTime.After(to) {
  347. out.FlowInclusiveEnd = out.FlowInclusiveEnd.Add(amount)
  348. }
  349. }
  350. // 三类「当期发生额」:BETWEEN = 两端闭(dump 764170 / 764172 / 764168)
  351. if row.CreateTime.Before(from) || row.CreateTime.After(to) {
  352. continue
  353. }
  354. switch {
  355. case row.Type == model.ExpenseLogTypeRecharge:
  356. out.Recharge = out.Recharge.Add(amount)
  357. if row.LogID != nil {
  358. if _, ok := rechargeReqNos[*row.LogID]; ok {
  359. matchedReqNos[*row.LogID] = struct{}{}
  360. }
  361. }
  362. case row.Type == model.ExpenseLogTypeRecommend:
  363. out.RecommendAmount = out.RecommendAmount.Add(amount)
  364. case isBillSpendType(row.Type):
  365. out.Spend = out.Spend.Add(amount)
  366. }
  367. }
  368. // 当期赠送额:Σ(signed.activity_money) where signed.request_no ∈ matchedReqNos
  369. signedByActivity := make(map[int64]money.Amount, len(signed))
  370. for i := range signed {
  371. amount, err := money.Parse(signed[i].ActivityMoney)
  372. if err != nil {
  373. return BillSummary{}, infraerrors.WithCause(infraerrors.ErrDBError, err)
  374. }
  375. signedByActivity[signed[i].ActivityID] = signedByActivity[signed[i].ActivityID].Add(amount)
  376. if signed[i].RequestNo == nil {
  377. continue
  378. }
  379. if _, ok := matchedReqNos[*signed[i].RequestNo]; ok {
  380. out.Gift = out.Gift.Add(amount)
  381. }
  382. }
  383. // 赠送结余(dump 764178-764192):RIGHT JOIN 使"**只有出现过 used_log 的活动**"才进入汇总,
  384. // 且 used_log 的金额是**原值相加**(老带新结算写负值,重放写正值)——逐字复刻,不做符号归一。
  385. giveEnd, err := giveBalanceBefore(used, signedByActivity, to)
  386. if err != nil {
  387. return BillSummary{}, err
  388. }
  389. givePrev, err := giveBalanceBefore(used, signedByActivity, from)
  390. if err != nil {
  391. return BillSummary{}, err
  392. }
  393. out.GiveEndBalance = giveEnd
  394. out.GivePrevBalance = givePrev
  395. // dump 764194:`currentUsedGiveCost = currentTotalActivityMoney + previousGiveCost - currentGiveCost`
  396. out.GiveUsed = out.Gift.Add(givePrev).Sub(giveEnd)
  397. return out, nil
  398. }
  399. // giveBalanceBefore 复刻 dump 764178-764192 的"某个 cutoff 之前的赠送金额结余"。
  400. //
  401. // dump 原文(原文嵌套三层;这里按语义等价拆解,**箭头右侧是本函数的实现**):
  402. //
  403. // SELECT SUM(activity_money) , SUM(activity_money_used)
  404. // FROM ( SELECT signed.activity_money, usedLog.activity_money_used
  405. // FROM temp_courses_activity_signed signed
  406. // RIGHT JOIN ( SELECT activityid, SUM(activity_money_used) AS activity_money_used
  407. // FROM temp_courses_activity_used_log
  408. // WHERE create_time < cutoff GROUP BY activityid ) usedLog
  409. // ON signed.activityid = usedLog.activityid ) t1
  410. // → 结果 = Σ(该 user 在"有 used_log(< cutoff)的活动"上的全部 signed.activity_money)
  411. // + Σ(used_log.activity_money_used where create_time < cutoff)
  412. //
  413. // **RIGHT JOIN 的两个后果(必须照抄,不得"修好")**:
  414. // 1. 某活动若从未产生 used_log(< cutoff),其 signed.activity_money **完全不计入**结余;
  415. // 2. 某活动只有 used_log、没有 signed 行时,signed 侧为 NULL,SUM 按 0 计(不报错)。
  416. //
  417. // 入参:
  418. // - used 全量 used_log;
  419. // - signedByActivity 按 activity_id 汇总的 signed.activity_money(**无时间过滤**);
  420. // - cutoff 截止时间(严格小于:`create_time < cutoff`)。
  421. //
  422. // 出参:money.Amount 结余(可为负);金额字面量非法 → ErrDBError。
  423. func giveBalanceBefore(
  424. used []model.CoursesActivityUsedLog,
  425. signedByActivity map[int64]money.Amount,
  426. cutoff time.Time,
  427. ) (money.Amount, error) {
  428. total := money.Amount(0)
  429. activityHit := make(map[int64]struct{}, len(used))
  430. usedSum := money.Amount(0)
  431. for i := range used {
  432. if !used[i].CreateTime.Before(cutoff) {
  433. continue
  434. }
  435. amount, err := money.Parse(used[i].ActivityMoneyUsed)
  436. if err != nil {
  437. return 0, infraerrors.WithCause(infraerrors.ErrDBError, err)
  438. }
  439. usedSum = usedSum.Add(amount)
  440. activityHit[used[i].ActivityID] = struct{}{}
  441. }
  442. total = total.Add(usedSum)
  443. for activityID := range activityHit {
  444. total = total.Add(signedByActivity[activityID])
  445. }
  446. return total, nil
  447. }
  448. // isBillSpendType 判断流水类型是否属于「当期消费」集合(dump 764172 的 IN 列表)。
  449. func isBillSpendType(logType int32) bool {
  450. for _, t := range billSpendTypes {
  451. if t == logType {
  452. return true
  453. }
  454. }
  455. return false
  456. }
  457. // parseCampusIDs 解析 dump 第二入参(逗号串 `"1,2,3"`;空串 → 空切片)。
  458. //
  459. // 入参:raw 原始字符串(可含空格)。
  460. // 出参:[]int64 解析结果(**仅回显**,不参与过滤);非法片段 → ErrBadParam。
  461. //
  462. // 说明:dump 该参数是**死参数**(764094 声明、过程体零引用),这里只做"格式合法"校验,
  463. // 让前端传错(如 "1,a")时立刻报错,而不是悄悄当作"没过滤"跑出一份"看起来对"的账单。
  464. func parseCampusIDs(raw string) ([]int64, error) {
  465. trimmed := strings.TrimSpace(raw)
  466. if trimmed == "" {
  467. return []int64{}, nil
  468. }
  469. parts := strings.Split(trimmed, ",")
  470. out := make([]int64, 0, len(parts))
  471. for _, part := range parts {
  472. item := strings.TrimSpace(part)
  473. if item == "" {
  474. continue
  475. }
  476. id, err := strconv.ParseInt(item, 10, 64)
  477. if err != nil || id <= 0 {
  478. return nil, infraerrors.WithCause(infraerrors.ErrBadParam,
  479. errString("service: campusIds 必须是正整数逗号串(非法片段: "+item+")"))
  480. }
  481. out = append(out, id)
  482. }
  483. return out, nil
  484. }
  485. // billTypeTitle 流水类型的展示名(只用于明细展示;未登记类型返回 "其它")。
  486. //
  487. // 入参:logType 流水类型编码(model.ExpenseLogType*)。
  488. // 出参:中文标题常量。
  489. func billTypeTitle(logType int32) string {
  490. switch logType {
  491. case model.ExpenseLogTypeRecharge:
  492. return "充值"
  493. case model.ExpenseLogTypeCourseCampus, model.ExpenseLogTypeCourseCampusB:
  494. return "课程消费(校区)"
  495. case model.ExpenseLogTypeCourseSchoolA, model.ExpenseLogTypeCourseSchoolB,
  496. model.ExpenseLogTypeCourseSchoolC, model.ExpenseLogTypeCourseSchoolD:
  497. return "课程消费(学校)"
  498. case model.ExpenseLogTypeTransferOut:
  499. return "课费转结(转出)"
  500. case model.ExpenseLogTypeTransferIn:
  501. return "课费转结(转入)"
  502. case model.ExpenseLogTypeRecommend:
  503. return "老带新推荐"
  504. case model.ExpenseLogTypeBadDebt:
  505. return "坏账处理"
  506. case model.ExpenseLogTypeHistoryDeduct:
  507. return "历史扣费"
  508. case model.ExpenseLogTypeRefund:
  509. return "余额退费"
  510. case model.ExpenseLogTypeClearBalance:
  511. return "余额清零"
  512. case model.ExpenseLogTypeCancelRechargeAct:
  513. return "取消充值活动"
  514. default:
  515. return "其它"
  516. }
  517. }