| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542 |
- // 学生账单查询服务(sp_user_expense_get_bill → BillService.GetBill)。
- //
- // 依据:unified/03-migration/academic-domain-design.md
- // - §3.4 #25 `sp_user_expense_get_bill`(dump **764094~764238**;4 张 MEMORY 临时表 → 内存结构)
- // - §3.8-**E2**(`create_time` 属**业务时间**,参与对账、逐值 0 容差)
- // - §3.8-**A18**(`type=108` 双来源:**只归因、不裁剪**——本服务的余额类汇总一律全类型计入)
- // - §5.1 纪律 4「横切优先」(账单恒等式 + 期初/期末不随分页变化)
- //
- // ---------------------------------------------------------------------------
- // dump 骨架(764116~764198,**按原文,不做"优化"**)
- // ---------------------------------------------------------------------------
- //
- // CREATE TEMPORARY TABLE temp_user_expense_log(type INT, logid VARCHAR(50), money DECIMAL(10,3), create_time VARCHAR(100));
- // INSERT INTO temp_user_expense_log SELECT type,logid,money,create_time FROM t_user_expense_log WHERE userid=inUserid;
- // -- 同法 temp_courses_activity_signed / temp_courses_activity_used_log / temp_user_balance_request
- //
- // 764173 SELECT SUM(money) FROM temp_user_expense_log WHERE type=107 AND create_time BETWEEN inStartTime AND inEndTime; -- 当期推荐额
- // 764175 SELECT SUM(money) FROM temp_user_expense_log WHERE type in(101,201,104,204,105,205) AND create_time BETWEEN ...; -- 当期消费
- // 764177 SELECT SUM(money) FROM temp_user_expense_log as log1 WHERE create_time<inEndTime; -- **期末余额**
- // 764179 SELECT SUM(money) FROM temp_user_expense_log as log2 WHERE create_time<inStartTime; -- **期初余额**
- // 764182-764189 赠送额结余(当前 764182-764184 / 上一次 764187-764189)
- // → 764193 当期使用赠送 = 当期赠送 + 上期结余 − 当前结余(`SET currentUsedGiveCost = ...`)
- //
- // ---------------------------------------------------------------------------
- // ★ 三种比较语义并存(**dump 的既有不对称,禁止统一**)
- // ---------------------------------------------------------------------------
- //
- // 「当期发生额」= `BETWEEN inStartTime AND inEndTime` → **两端闭**:start <= t <= end
- // 「期末余额」 = `create_time < inEndTime` → **不含右端**:t < end
- // 「期初余额」 = `create_time < inStartTime` → **不含右端**:t < start
- //
- // ⇒ 因此 **期末 − 期初 = Σ(start <= t < end)**,而**当期发生额 = Σ(start <= t <= end)**,
- // 二者在 `t = inEndTime` 处**恰好相差落在该时刻的那些流水**。
- // 这不是 bug,是 dump 把 `create_time` 当 `VARCHAR(100)` 直接字符串比较留下的历史口径:
- // 用户在 `end` 当天/当时刻的流水会进"当期发生额",但不进"期末余额"。
- // 本服务把这个差额**显式暴露**为 `FlowInclusiveEnd − FlowExclusiveEnd`(`BillSummary` 两字段),
- // 让调用方/对账脚本能看见它,而不是靠"统一成一种语义"把它抹掉(抹掉就与旧系统数字不一致)。
- //
- // ---------------------------------------------------------------------------
- // ★ 入参时间边界(前端必须知道的一句话)
- // ---------------------------------------------------------------------------
- //
- // `from` 是**含**下界(>= from),`to` 是**不含**上界(< to)—— 对"余额/期初期末"而言。
- // **若前端要"含当日",必须传次日或 `23:59:59`**(例如查 2026-03-01 当日流水,应传
- // from=2026-03-01T00:00:00, to=2026-03-02T00:00:00;传 to=2026-03-01T00:00:00 会得到该日 0 条)。
- // dump 用 `VARCHAR` 做 `BETWEEN`,语义随字符串格式漂移;目标态改用 `datetime(3)` 后,
- // **入参语义按上述定死**(这是"目标态显式化",不是行为漂移:旧系统前端一直传 `YYYY-MM-DD`,
- // dump 里 `BETWEEN '2026-03-01' AND '2026-03-31'` 同样不含 03-31 的时分秒部分)。
- //
- // ---------------------------------------------------------------------------
- // ★ `campusIds` 入参的真相(dump 里是**死参数**)
- // ---------------------------------------------------------------------------
- //
- // dump 764094 声明了 `IN inCampusids VARCHAR(1000)`,但 764095~764237 的**整段过程体一次都没引用它**
- // (在 dump 里 grep 结果只有声明行)。因此本服务的 `CampusIDs` **只做解析/回显,不做过滤**——
- // 与 dump 完全一致。绝不为此给 `t_user_expense_log` 加 campus 维度(§3.8-f 约束 2:
- // 流水表无 campus 列,账单恒等式只能按 user 做);若产品确需"校区视图",须另开"按
- // t_courses_student / t_user_expense_school 的 join 路径"需求,不能在这里偷偷过滤。
- package service
- import (
- "context"
- "strconv"
- "strings"
- "time"
- "gorm.io/gorm"
- "yuansiwei/unified-backend/internal/academic/model"
- "yuansiwei/unified-backend/internal/academic/money"
- "yuansiwei/unified-backend/internal/academic/port"
- "yuansiwei/unified-backend/internal/academic/repository"
- infraerrors "yuansiwei/unified-backend/internal/infra/errors"
- appscope "yuansiwei/unified-backend/internal/infra/scope"
- )
- // 账单汇总用到的流水类型集合(dump 764175 原文 `type in(101,201,104,204,105,205)`)。
- var (
- // billSpendTypes 「当期消费」类型集合(逐值与 dump 764175 的 IN 列表一致)。
- billSpendTypes = []int32{
- model.ExpenseLogTypeCourseCampus, // 101
- model.ExpenseLogTypeCourseCampusB, // 201
- model.ExpenseLogTypeCourseSchoolA, // 104
- model.ExpenseLogTypeCourseSchoolC, // 204
- model.ExpenseLogTypeCourseSchoolB, // 105
- model.ExpenseLogTypeCourseSchoolD, // 205
- }
- )
- // BillService 学生账单查询服务(只读;无事务)。
- //
- // 字段:
- // - repo 账单仓储(4 张来源表按 user 全量取回);
- // - member 成员校验器(可 nil;非 nil 时对"学生是否属于当前机构/校区"做越权预检);
- // - sc 请求作用域(可 nil:系统任务/双跑脚本视角)。
- type BillService struct {
- repo *repository.BillRepo
- member port.MembershipChecker
- sc *appscope.Scope
- }
- // NewBillService 构造账单服务。
- //
- // 入参:db *gorm.DB(必填);sc *appscope.Scope(请求作用域;系统任务可 nil)。
- // 出参:*BillService(成员校验需 `WithMembershipChecker` 注入后生效)。
- func NewBillService(db *gorm.DB, sc *appscope.Scope) *BillService {
- return &BillService{repo: repository.NewBillRepo(db), sc: sc}
- }
- // WithMembershipChecker 注入成员校验器(返自身,便于链式装配)。
- //
- // 入参:member port.MembershipChecker(nil 表示不做越权预检——仅限双跑/回填脚本)。
- // 出参:*BillService(同一实例)。
- func (s *BillService) WithMembershipChecker(member port.MembershipChecker) *BillService {
- s.member = member
- return s
- }
- // GetBillInput 账单查询入参(对齐 dump 的 4 个入参 + 明细分页)。
- //
- // 字段:
- // - UserID 学生(ULID;必填);
- // - CampusIDs 校区逗号串(dump 第二入参 `inCampusids`;**只解析回显、不过滤**,见文件头);
- // - From 起始时间(**含**下界);
- // - To 结束时间(**不含**上界——"期末"口径;「当期发生额」按 dump 的 BETWEEN 含右端);
- // - Page / PageSize 明细分页(<=0 由 ClampPage 归一;PageSize 上限 200)。
- type GetBillInput struct {
- // UserID 学生(canonical_user_id / ULID 26 位)。
- UserID string
- // CampusIDs 校区逗号串(如 "1,2,3";"" 或不传 = 不加过滤;**dump 未使用,仅回显**)。
- CampusIDs string
- // From 起始时间(含)。
- From time.Time
- // To 结束时间(不含)。
- To time.Time
- // Page 页码(1 基)。
- Page int
- // PageSize 每页条数。
- PageSize int
- }
- // BillSummary 账单汇总(dump 764228-764236 的 9 个 SELECT 列 + 3 个对账辅助列)。
- //
- // 全部金额为 `money.Amount`(分,定点),JSON 输出为"两位小数字符串"(如 "123.45")——
- // 与旧库 `DECIMAL(10,3)` 的显示习惯对齐到 2 位(目标态 DDL 为 `decimal(12,2)`)。
- type BillSummary struct {
- // PrevBalance 期初余额 = Σ(money WHERE create_time < From)(dump 764179 `previousBalance`)。
- PrevBalance money.Amount `json:"prevBalance"`
- // EndBalance 期末余额 = Σ(money WHERE create_time < To)(dump 764177 `currentBalance`)。
- EndBalance money.Amount `json:"endBalance"`
- // Recharge 当期充值 = Σ(money WHERE type=100 AND From <= create_time <= To)(dump 764116 `DECLARE rechargeCur CURSOR ...`,764159 `OPEN`)。
- Recharge money.Amount `json:"recharge"`
- // Gift 当期赠送额 = Σ(signed.activity_money)(经"充值工单 × 报名"关联,dump 764116 游标第二列 `SUM(activity.activity_money)`)。
- Gift money.Amount `json:"gift"`
- // RecommendAmount 当期老带新推荐额 = Σ(money WHERE type=107 AND 区间内)(dump 764173)。
- RecommendAmount money.Amount `json:"recommendAmount"`
- // Spend 当期消费 = Σ(money WHERE type IN (101,201,104,204,105,205) AND 区间内)(dump 764175)。
- Spend money.Amount `json:"spend"`
- // GiveUsed 当期使用赠送额(dump 764193 `currentUsedGiveCost` = Gift + GivePrevBalance − GiveEndBalance)。
- GiveUsed money.Amount `json:"giveUsed"`
- // GivePrevBalance 期初赠送结余(dump 764187-764189 `previousGiveCost`;口径见 giveBalanceBefore)。
- GivePrevBalance money.Amount `json:"givePrevBalance"`
- // GiveEndBalance 期末赠送结余(dump 764182-764184 `currentGiveCost`;口径同上)。
- GiveEndBalance money.Amount `json:"giveEndBalance"`
- // FlowExclusiveEnd 窗口内全类型流水合计(From <= t **<** To)——
- // **恒等于 EndBalance − PrevBalance**(§5.1 第 4 条:账单恒等式的可判定形式)。
- FlowExclusiveEnd money.Amount `json:"flowExclusiveEnd"`
- // FlowInclusiveEnd 窗口内全类型流水合计(From <= t **<=** To)——
- // 与「当期发生额」同口径(BETWEEN 含右端)。二者之差 == 落在 `t = To` 的那些流水。
- FlowInclusiveEnd money.Amount `json:"flowInclusiveEnd"`
- // CampusIDs dump 第二入参的解析结果(**仅回显**:dump 全程未引用该参数,本服务不过滤)。
- CampusIDs []int64 `json:"campusIds"`
- }
- // BillDetail 账单明细行(分页;按 `create_time DESC, id DESC`)。
- type BillDetail struct {
- // ID 流水 ID(同一时刻多行的稳定排序键)。
- ID int64 `json:"id"`
- // Type 流水类型(model.ExpenseLogType*)。
- Type int32 `json:"type"`
- // TypeTitle 类型中文名(只用于展示;未登记类型返回 "其它")。
- TypeTitle string `json:"typeTitle"`
- // LogID 业务单号(原 logid;可为空串)。
- LogID string `json:"logId"`
- // Money 变更金额(元;符号已表方向,见 model.ExpenseLogType* 注释)。
- Money money.Amount `json:"money"`
- // CreateTime 业务时间(§3.8-E2 ①类,参与对账、逐值 0 容差)。
- CreateTime time.Time `json:"createTime"`
- }
- // BillResult 账单查询结果(汇总 + 明细分页两段,设计 §3.4 #25「两段返回」)。
- type BillResult struct {
- // Summary 汇总(**不受分页影响**)。
- Summary BillSummary `json:"summary"`
- // Details 明细(当前页)。
- Details []BillDetail `json:"details"`
- // Total 明细总条数(分页总数)。
- Total int64 `json:"total"`
- // Page 当前页码(已钳制)。
- Page int `json:"page"`
- // PageSize 每页条数(已钳制)。
- PageSize int `json:"pageSize"`
- // From / To 回显查询窗口(审计用;语义见 GetBillInput)。
- From time.Time `json:"from"`
- To time.Time `json:"to"`
- }
- // GetBill 查询学生账单(汇总 + 明细分页)。
- //
- // 入参:
- // - ctx 请求上下文;
- // - in GetBillInput(UserID 必填;From/To 必填且 From <= To)。
- //
- // 出参:
- // - *BillResult:汇总 + 明细;明细为空时 Details 为长度 0 的非 nil 切片;
- // - ErrBadParam(2001) 缺参/时间窗非法;ErrUnscoped(1004) 越权(注入了 MembershipChecker 时);
- // ErrDBError(5002) 数据库异常或金额字面量解析失败。
- //
- // **明细口径**:`Details` 是该账户的**全量流水**(`create_time DESC, id DESC` 分页),
- // **不按 from/to 过滤** —— dump 的 `get_bill` 只返回 9 个汇总列、没有明细列表;设计 §3.4 #25
- // 要求"Go 侧支持分页明细 + 汇总对象两段返回",明细即"账户流水账",配合汇总看当期发生额。
- // 若前端要"只看窗口内流水",按 `Details[].CreateTime` 自行过滤或另开参数(本期不加,
- // 免得"明细被窗口裁掉、汇总却是全量"这种两处口径不一的错觉)。
- //
- // 只读:本方法**不开事务**(dump 的 4 张 MEMORY 临时表是一次性快照,等价于"同一读视图";
- // 目标态在单连接上顺序执行 4 次查询,落库并发写入造成的瞬间不一致由"流水只增不改"兜底)。
- func (s *BillService) GetBill(ctx context.Context, in GetBillInput) (*BillResult, error) {
- if strings.TrimSpace(in.UserID) == "" {
- return nil, infraerrors.WithCause(infraerrors.ErrBadParam, errString("service: GetBill 需要 user_id"))
- }
- if in.From.IsZero() || in.To.IsZero() {
- return nil, infraerrors.WithCause(infraerrors.ErrBadParam,
- errString("service: GetBill 需要 from/to(账户区间对账的两个边界都是必填)"))
- }
- if in.From.After(in.To) {
- return nil, infraerrors.WithCause(infraerrors.ErrBadParam,
- errString("service: GetBill 的 from 不能晚于 to"))
- }
- campusIDs, err := parseCampusIDs(in.CampusIDs)
- if err != nil {
- return nil, err
- }
- // 越权预检:4 张来源表都无作用域列(或跨校区可见),必须在这里断"该学生属于当前机构/校区"
- if s.member != nil && s.sc != nil {
- if err := s.member.AssertInScope(ctx, in.UserID, s.sc.InstitutionID, s.sc.CampusID); err != nil {
- return nil, err
- }
- }
- logs, err := s.repo.LoadLogs(ctx, in.UserID)
- if err != nil {
- return nil, err
- }
- // 充值工单**只在"赠送额"这条链上用到**(dump 764116-764121 游标的 LEFT JOIN),BETWEEN 含两端。
- reqNos, err := s.repo.LoadRechargeRequestNos(ctx, in.UserID, in.From, in.To)
- if err != nil {
- return nil, err
- }
- signed, err := s.repo.LoadActivitySigned(ctx, in.UserID)
- if err != nil {
- return nil, err
- }
- used, err := s.repo.LoadActivityUsedLogs(ctx, in.UserID)
- if err != nil {
- return nil, err
- }
- summary, err := buildBillSummary(logs, reqNos, signed, used, in.From, in.To)
- if err != nil {
- return nil, err
- }
- summary.CampusIDs = campusIDs
- page := repository.PageQuery{Page: in.Page, PageSize: in.PageSize}
- pageNo, pageSize := page.Normalize()
- total, err := s.repo.CountLogs(ctx, in.UserID)
- if err != nil {
- return nil, err
- }
- rows, err := s.repo.PageLogs(ctx, in.UserID, page)
- if err != nil {
- return nil, err
- }
- details := make([]BillDetail, 0, len(rows))
- for i := range rows {
- amount, perr := money.Parse(rows[i].Money)
- if perr != nil {
- return nil, infraerrors.WithCause(infraerrors.ErrDBError, perr)
- }
- logID := ""
- if rows[i].LogID != nil {
- logID = *rows[i].LogID
- }
- details = append(details, BillDetail{
- ID: rows[i].ID,
- Type: rows[i].Type,
- TypeTitle: billTypeTitle(rows[i].Type),
- LogID: logID,
- Money: amount,
- CreateTime: rows[i].CreateTime,
- })
- }
- return &BillResult{
- Summary: summary,
- Details: details,
- Total: total,
- Page: pageNo,
- PageSize: pageSize,
- From: in.From,
- To: in.To,
- }, nil
- }
- // buildBillSummary 由 4 份内存结构算出 dump 的 9 个汇总列 + 3 个对账辅助列(纯函数,便于单测)。
- //
- // 入参:
- // - logs 该 user 全量流水(LoadLogs);
- // - reqNos 区间内已通过的普通充值工单 biz_no 列表(LoadRechargeRequestNos,BETWEEN 含两端);
- // - signed 该 user 全部活动报名行(LoadActivitySigned);
- // - used 该 user 全部老带新获得/使用记录(LoadActivityUsedLogs);
- // - from/to 查询窗口(from 含、to 不含;「当期发生额」用 BETWEEN 含 to)。
- //
- // 出参:BillSummary;金额字面量非法 → ErrDBError。
- //
- // 累加纪律:**全部在 Go 侧用 money.Amount 定点累加**(禁止 SQL SUM(decimal),见 BillRepo 头注释)。
- func buildBillSummary(
- logs []model.UserExpenseLog,
- reqNos []string,
- signed []model.CoursesActivitySigned,
- used []model.CoursesActivityUsedLog,
- from, to time.Time,
- ) (BillSummary, error) {
- var out BillSummary
- // dump 764116 游标:充值工单参与集合(`temp_user_balance_request`,764128 装入)
- rechargeReqNos := make(map[string]struct{}, len(reqNos))
- for _, no := range reqNos {
- if no == "" {
- continue // 空串不参与匹配(旧库 requestid 可为空串,误配会凭空造出赠送额)
- }
- rechargeReqNos[no] = struct{}{}
- }
- // 实际参与赠送额汇总的工单号:dump 的 join 路径是 `log.logid = request.id`,
- // 因此**还要有一条区间内的 type=100 流水**指向该工单,才可能把 signed.activity_money 计进来。
- matchedReqNos := make(map[string]struct{}, len(rechargeReqNos))
- for i := range logs {
- row := logs[i]
- amount, err := money.Parse(row.Money)
- if err != nil {
- return BillSummary{}, infraerrors.WithCause(infraerrors.ErrDBError, err)
- }
- // 期初 / 期末:`create_time < 边界`(不含右端,dump 764177 / 764179)
- if row.CreateTime.Before(from) {
- out.PrevBalance = out.PrevBalance.Add(amount)
- }
- if row.CreateTime.Before(to) {
- out.EndBalance = out.EndBalance.Add(amount)
- }
- // 窗口内合计:两个口径各算一次(差额 == 落在 t = to 的流水,见 BillSummary 字段注释)
- if !row.CreateTime.Before(from) {
- if row.CreateTime.Before(to) {
- out.FlowExclusiveEnd = out.FlowExclusiveEnd.Add(amount)
- }
- if !row.CreateTime.After(to) {
- out.FlowInclusiveEnd = out.FlowInclusiveEnd.Add(amount)
- }
- }
- // 三类「当期发生额」:BETWEEN = 两端闭(dump 764173 / 764175 / 764116)
- if row.CreateTime.Before(from) || row.CreateTime.After(to) {
- continue
- }
- switch {
- case row.Type == model.ExpenseLogTypeRecharge:
- out.Recharge = out.Recharge.Add(amount)
- if row.LogID != nil {
- if _, ok := rechargeReqNos[*row.LogID]; ok {
- matchedReqNos[*row.LogID] = struct{}{}
- }
- }
- case row.Type == model.ExpenseLogTypeRecommend:
- out.RecommendAmount = out.RecommendAmount.Add(amount)
- case isBillSpendType(row.Type):
- out.Spend = out.Spend.Add(amount)
- }
- }
- // 当期赠送额:Σ(signed.activity_money) where signed.request_no ∈ matchedReqNos
- signedByActivity := make(map[int64]money.Amount, len(signed))
- for i := range signed {
- amount, err := money.Parse(signed[i].ActivityMoney)
- if err != nil {
- return BillSummary{}, infraerrors.WithCause(infraerrors.ErrDBError, err)
- }
- signedByActivity[signed[i].ActivityID] = signedByActivity[signed[i].ActivityID].Add(amount)
- if signed[i].RequestNo == nil {
- continue
- }
- if _, ok := matchedReqNos[*signed[i].RequestNo]; ok {
- out.Gift = out.Gift.Add(amount)
- }
- }
- // 赠送结余(dump 764182-764189):RIGHT JOIN 使"**只有出现过 used_log 的活动**"才进入汇总,
- // 且 used_log 的金额是**原值相加**(老带新结算写负值,重放写正值)——逐字复刻,不做符号归一。
- giveEnd, err := giveBalanceBefore(used, signedByActivity, to)
- if err != nil {
- return BillSummary{}, err
- }
- givePrev, err := giveBalanceBefore(used, signedByActivity, from)
- if err != nil {
- return BillSummary{}, err
- }
- out.GiveEndBalance = giveEnd
- out.GivePrevBalance = givePrev
- // dump 764193:`SET currentUsedGiveCost = currentTotalActivityMoney + previousGiveCost - currentGiveCost`
- out.GiveUsed = out.Gift.Add(givePrev).Sub(giveEnd)
- return out, nil
- }
- // giveBalanceBefore 复刻 dump 764182-764189 的"某个 cutoff 之前的赠送金额结余"。
- //
- // dump 原文(原文嵌套三层;这里按语义等价拆解,**箭头右侧是本函数的实现**):
- //
- // SELECT SUM(activity_money) , SUM(activity_money_used)
- // FROM ( SELECT signed.activity_money, usedLog.activity_money_used
- // FROM temp_courses_activity_signed signed
- // RIGHT JOIN ( SELECT activityid, SUM(activity_money_used) AS activity_money_used
- // FROM temp_courses_activity_used_log
- // WHERE create_time < cutoff GROUP BY activityid ) usedLog
- // ON signed.activityid = usedLog.activityid ) t1
- // → 结果 = Σ(该 user 在"有 used_log(< cutoff)的活动"上的全部 signed.activity_money)
- // + Σ(used_log.activity_money_used where create_time < cutoff)
- //
- // **RIGHT JOIN 的两个后果(必须照抄,不得"修好")**:
- // 1. 某活动若从未产生 used_log(< cutoff),其 signed.activity_money **完全不计入**结余;
- // 2. 某活动只有 used_log、没有 signed 行时,signed 侧为 NULL,SUM 按 0 计(不报错)。
- //
- // 入参:
- // - used 全量 used_log;
- // - signedByActivity 按 activity_id 汇总的 signed.activity_money(**无时间过滤**);
- // - cutoff 截止时间(严格小于:`create_time < cutoff`)。
- //
- // 出参:money.Amount 结余(可为负);金额字面量非法 → ErrDBError。
- func giveBalanceBefore(
- used []model.CoursesActivityUsedLog,
- signedByActivity map[int64]money.Amount,
- cutoff time.Time,
- ) (money.Amount, error) {
- total := money.Amount(0)
- activityHit := make(map[int64]struct{}, len(used))
- usedSum := money.Amount(0)
- for i := range used {
- if !used[i].CreateTime.Before(cutoff) {
- continue
- }
- amount, err := money.Parse(used[i].ActivityMoneyUsed)
- if err != nil {
- return 0, infraerrors.WithCause(infraerrors.ErrDBError, err)
- }
- usedSum = usedSum.Add(amount)
- activityHit[used[i].ActivityID] = struct{}{}
- }
- total = total.Add(usedSum)
- for activityID := range activityHit {
- total = total.Add(signedByActivity[activityID])
- }
- return total, nil
- }
- // isBillSpendType 判断流水类型是否属于「当期消费」集合(dump 764175 的 IN 列表)。
- func isBillSpendType(logType int32) bool {
- for _, t := range billSpendTypes {
- if t == logType {
- return true
- }
- }
- return false
- }
- // parseCampusIDs 解析 dump 第二入参(逗号串 `"1,2,3"`;空串 → 空切片)。
- //
- // 入参:raw 原始字符串(可含空格)。
- // 出参:[]int64 解析结果(**仅回显**,不参与过滤);非法片段 → ErrBadParam。
- //
- // 说明:dump 该参数是**死参数**(764094 声明、过程体零引用),这里只做"格式合法"校验,
- // 让前端传错(如 "1,a")时立刻报错,而不是悄悄当作"没过滤"跑出一份"看起来对"的账单。
- func parseCampusIDs(raw string) ([]int64, error) {
- trimmed := strings.TrimSpace(raw)
- if trimmed == "" {
- return []int64{}, nil
- }
- parts := strings.Split(trimmed, ",")
- out := make([]int64, 0, len(parts))
- for _, part := range parts {
- item := strings.TrimSpace(part)
- if item == "" {
- continue
- }
- id, err := strconv.ParseInt(item, 10, 64)
- if err != nil || id <= 0 {
- return nil, infraerrors.WithCause(infraerrors.ErrBadParam,
- errString("service: campusIds 必须是正整数逗号串(非法片段: "+item+")"))
- }
- out = append(out, id)
- }
- return out, nil
- }
- // billTypeTitle 流水类型的展示名(只用于明细展示;未登记类型返回 "其它")。
- //
- // 入参:logType 流水类型编码(model.ExpenseLogType*)。
- // 出参:中文标题常量。
- func billTypeTitle(logType int32) string {
- switch logType {
- case model.ExpenseLogTypeRecharge:
- return "充值"
- case model.ExpenseLogTypeCourseCampus, model.ExpenseLogTypeCourseCampusB:
- return "课程消费(校区)"
- case model.ExpenseLogTypeCourseSchoolA, model.ExpenseLogTypeCourseSchoolB,
- model.ExpenseLogTypeCourseSchoolC, model.ExpenseLogTypeCourseSchoolD:
- return "课程消费(学校)"
- case model.ExpenseLogTypeTransferOut:
- return "课费转结(转出)"
- case model.ExpenseLogTypeTransferIn:
- return "课费转结(转入)"
- case model.ExpenseLogTypeRecommend:
- return "老带新推荐"
- case model.ExpenseLogTypeBadDebt:
- return "坏账处理"
- case model.ExpenseLogTypeHistoryDeduct:
- return "历史扣费"
- case model.ExpenseLogTypeRefund:
- return "余额退费"
- case model.ExpenseLogTypeClearBalance:
- return "余额清零"
- case model.ExpenseLogTypeCancelRechargeAct:
- return "取消充值活动"
- default:
- return "其它"
- }
- }
|