bill_service.go 24 KB

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