DEV-MERGE-LEGACY-BACKEND-2026/internal/academic/service/fund_service_transfer_test.go

// FundService.Transfer 单测（AC-04 ④）：课费转结按 **dump 语义**钉死——
// 不动 balance、106=+m / 206=−m、两侧 total_expenditure/total_income 反向调整、
// 目标账户不存在则建户、同校区自转与源账户缺失显式失败、同 requestId 幂等。
//
// 测试栈与 fund_service_test.go 同一套（sqlite 文件库 + 真实唯一键；助手复用同 package）。
package service

import (
	"context"
	"regexp"
	"strconv"
	"strings"
	"testing"

	"yuansiwei/unified-backend/internal/academic/model"
)

// TestTransferLeavesBalanceUntouchedAndWritesDumpDirections 转结核心口径（★dump 漂移项）。
//
// dump（yuansiwei_finance.sql:764661）：
//
//	源：total_expenditure−m, total_income−m ；目标：total_expenditure+m, total_income+m
//	log 106 = **+m**（转结出）；log 206 = **−m**（转结入）；**两端 balance 都不动**
//
// 与 P0-04 规格（106 负 / 206 正 且动 balance）相反——本用例就是把 dump 口径钉死的地方。
func TestTransferLeavesBalanceUntouchedAndWritesDumpDirections(t *testing.T) {
	db := newFundServiceDB(t)
	svc := NewFundService(db, fundSuperScope(), nil) // 转结跨机构/跨校区：用超管作用域
	ctx := context.Background()
	user := fundUserID(20)

	// 源校区（机构 1 / 校区 10）余额 100，目标校区（机构 1 / 校区 20）尚不存在
	if _, err := svc.Recharge(ctx, RechargeInput{UserID: user, InstitutionID: 1, CampusID: 10,
		Money: mustAmount(t, "100.00"), RequestID: "REQ-TRANSFER-SEED"}); err != nil {
		t.Fatalf("准备源校区余额失败: %v", err)
	}

	res, err := svc.Transfer(ctx, TransferInput{
		UserID:            user,
		FromInstitutionID: 1, FromCampusID: 10,
		ToInstitutionID: 1, ToCampusID: 20,
		Money: mustAmount(t, "40.00"), RequestID: "REQ-TRANSFER-1", Remark: "课费转结",
	})
	if err != nil {
		t.Fatalf("Transfer 失败: %v", err)
	}
	if res.LogID106 <= 0 || res.LogID206 <= 0 {
		t.Fatalf("两条流水 ID 都应 > 0，实得 %+v", res)
	}

	from := readSchool(t, db, user, 1, 10)
	to := readSchool(t, db, user, 1, 20)

	// ① **balance 不动**（dump 全程没有 balance 赋值）
	if got := cents(t, from.Balance); got != 10000 {
		t.Fatalf("源校区 balance 不得变动（应 10000 分），实得 %d", got)
	}
	if got := cents(t, to.Balance); got != 0 {
		t.Fatalf("目标校区 balance 不得变动（应 0 分），实得 %d", got)
	}
	// ② 源：total_expenditure/total_income 各 −40；目标：各 +40
	//    注意：充值只累加 balance/total_income，不动 total_expenditure，
	//    故源 total_expenditure 是 0 − 4000 = **−4000**（dump 无下限保护，按 dump 保留负值）
	if got := cents(t, from.TotalExpenditure); got != -4000 {
		t.Fatalf("源校区 total_expenditure 应 -4000 分（0−4000，dump 无下限），实得 %d", got)
	}
	if got := cents(t, from.TotalIncome); got != 6000 {
		t.Fatalf("源校区 total_income 应 6000 分，实得 %d", got)
	}
	if got := cents(t, to.TotalExpenditure); got != 4000 {
		t.Fatalf("目标校区 total_expenditure 应 4000 分，实得 %d", got)
	}
	if got := cents(t, to.TotalIncome); got != 4000 {
		t.Fatalf("目标校区 total_income 应 4000 分，实得 %d", got)
	}
	// ③ 全局钱包不参与转结
	global := readGlobal(t, db, user)
	if got := cents(t, global.Balance); got != 10000 {
		t.Fatalf("全局 balance 不应变动（应 10000 分），实得 %d", got)
	}
	if got := cents(t, global.TotalExpenditure); got != 0 {
		t.Fatalf("全局 total_expenditure 不应变动（应 0），实得 %d", got)
	}

	// ④ 流水方向：106 = +4000，206 = −4000（★与"出/入"直觉相反，按 dump）
	logs106 := logsByType(t, db, user, model.ExpenseLogTypeTransferOut)
	logs206 := logsByType(t, db, user, model.ExpenseLogTypeTransferIn)
	if len(logs106) != 1 || cents(t, logs106[0].Money) != 4000 {
		t.Fatalf("106 流水应为 +4000 分一条，实得 %+v", logs106)
	}
	if len(logs206) != 1 || cents(t, logs206[0].Money) != -4000 {
		t.Fatalf("206 流水应为 -4000 分一条，实得 %+v", logs206)
	}
}

// TestTransferIdempotentSameRequestID 同 requestId 再转 → 两条流水都不新增、金额不再变动。
func TestTransferIdempotentSameRequestID(t *testing.T) {
	db := newFundServiceDB(t)
	svc := NewFundService(db, fundSuperScope(), nil)
	ctx := context.Background()
	user := fundUserID(21)

	if _, err := svc.Recharge(ctx, RechargeInput{UserID: user, InstitutionID: 1, CampusID: 10,
		Money: mustAmount(t, "100.00")}); err != nil {
		t.Fatalf("准备余额失败: %v", err)
	}
	in := TransferInput{
		UserID:            user,
		FromInstitutionID: 1, FromCampusID: 10,
		ToInstitutionID: 1, ToCampusID: 20,
		Money: mustAmount(t, "10.00"), RequestID: "REQ-TRANSFER-IDEMPOTENT",
	}
	first, err := svc.Transfer(ctx, in)
	if err != nil {
		t.Fatalf("首次转结失败: %v", err)
	}
	second, err := svc.Transfer(ctx, in)
	if err != nil {
		t.Fatalf("重复转结应幂等成功: %v", err)
	}
	if !second.Repeated {
		t.Fatalf("重复转结应 repeated=true")
	}
	if second.LogID106 != first.LogID106 || second.LogID206 != first.LogID206 {
		t.Fatalf("重复转结应回放首次流水 %+v，实得 %+v", first, second)
	}
	if got := len(logsByType(t, db, user, model.ExpenseLogTypeTransferOut)); got != 1 {
		t.Fatalf("106 流水应只 1 条，实得 %d", got)
	}
	if got := len(logsByType(t, db, user, model.ExpenseLogTypeTransferIn)); got != 1 {
		t.Fatalf("206 流水应只 1 条，实得 %d", got)
	}
	if got := cents(t, readSchool(t, db, user, 1, 10).TotalIncome); got != 9000 {
		t.Fatalf("源校区 total_income 应只减一次（9000 分），实得 %d", got)
	}
}

// TestTransferSameCampusRejected 同校区自转（净效应为零）→ 3140。
func TestTransferSameCampusRejected(t *testing.T) {
	db := newFundServiceDB(t)
	svc := NewFundService(db, fundScope(), nil)
	_, err := svc.Transfer(context.Background(), TransferInput{
		UserID:            fundUserID(22),
		FromInstitutionID: 1, FromCampusID: 10,
		ToInstitutionID: 1, ToCampusID: 10,
		Money: mustAmount(t, "10.00"),
	})
	requireAppCode(t, err, 3140)
}

// TestTransferSourceAccountMissing 源账户不存在 → 3001（dump 静默 no-op；Go 显式失败）。
func TestTransferSourceAccountMissing(t *testing.T) {
	db := newFundServiceDB(t)
	svc := NewFundService(db, fundSuperScope(), nil)
	_, err := svc.Transfer(context.Background(), TransferInput{
		UserID:            fundUserID(23),
		FromInstitutionID: 1, FromCampusID: 10,
		ToInstitutionID: 1, ToCampusID: 20,
		Money: mustAmount(t, "10.00"),
	})
	requireAppCode(t, err, 3001)
}

// TestTransferRejectsInvalidAmount 金额 <=0 / 超上限 → 2002（不改任何账户）。
func TestTransferRejectsInvalidAmount(t *testing.T) {
	db := newFundServiceDB(t)
	svc := NewFundService(db, fundSuperScope(), nil)
	ctx := context.Background()
	user := fundUserID(24)
	if _, err := svc.Recharge(ctx, RechargeInput{UserID: user, InstitutionID: 1, CampusID: 10,
		Money: mustAmount(t, "100.00")}); err != nil {
		t.Fatalf("准备余额失败: %v", err)
	}
	base := TransferInput{
		UserID:            user,
		FromInstitutionID: 1, FromCampusID: 10,
		ToInstitutionID: 1, ToCampusID: 20,
	}
	for _, amount := range []string{"0.00", "-1.00", "1000000.01"} {
		in := base
		in.Money = mustAmount(t, amount)
		_, err := svc.Transfer(ctx, in)
		var want = 2002
		requireAppCode(t, err, want)
	}
	if got := cents(t, readSchool(t, db, user, 1, 10).TotalIncome); got != 10000 {
		t.Fatalf("非法金额不得改动账户（应仍 10000 分），实得 %d", got)
	}
}

// TestTransferLocksCampusAccountsAscending 多账户加锁顺序：按 campus_id ASC（§1.4 防死锁）。
//
// 断言口径：抓真实执行的 SQL 序列，要求"较小 campus_id 的校区锁语句"先出现。
func TestTransferLocksCampusAccountsAscending(t *testing.T) {
	db, rec := newFundServiceDBWithRecorder(t)
	svc := NewFundService(db, fundSuperScope(), nil)
	ctx := context.Background()
	user := fundUserID(25)

	if _, err := svc.Recharge(ctx, RechargeInput{UserID: user, InstitutionID: 1, CampusID: 20,
		Money: mustAmount(t, "100.00")}); err != nil {
		t.Fatalf("准备余额失败: %v", err)
	}
	// 源校区 campus_id=20，目标校区 campus_id=10 → 加锁必须先 10 后 20（升序）
	rec.Reset()
	if _, err := svc.Transfer(ctx, TransferInput{
		UserID:            user,
		FromInstitutionID: 1, FromCampusID: 20,
		ToInstitutionID: 1, ToCampusID: 10,
		Money: mustAmount(t, "10.00"), RequestID: "REQ-TRANSFER-LOCK",
	}); err != nil {
		t.Fatalf("Transfer 失败: %v", err)
	}
	order := campusLockOrder(t, rec.Snapshot())
	if order.firstCampusID != 10 || order.secondCampusID != 20 {
		t.Fatalf("校区加锁顺序应为 10 → 20（campus_id ASC），实得 %d → %d",
			order.firstCampusID, order.secondCampusID)
	}
}

// campusLockOrder 从 SQL 序列里提取"两次校区账户 SELECT ... FOR UPDATE 命中的 campus_id"。
//
// 实现说明：sqlite 不渲染 `FOR UPDATE`，故用**语句里的 campus_id 字面量**判定命中的是哪一行
// （GetCampusForUpdateExact 的 WHERE 一定带 `campus_id = ?` 参数，GORM 会把参数内联进日志）。
type lockOrder struct {
	firstCampusID  int64
	secondCampusID int64
}

// campusLockOrder 解析加锁顺序（见类型注释）。
func campusLockOrder(t *testing.T, stmts []string) lockOrder {
	t.Helper()
	var out lockOrder
	seen := 0
	for _, sql := range stmts {
		if !strings.Contains(sql, "FROM") || !strings.Contains(sql, "t_user_expense_school") {
			continue
		}
		if !strings.Contains(sql, "LIMIT") {
			continue // 只要点查（加锁读）语句，跳过 UPDATE
		}
		id := extractCampusIDParam(t, sql)
		if id <= 0 {
			continue
		}
		seen++
		switch seen {
		case 1:
			out.firstCampusID = id
		case 2:
			out.secondCampusID = id
		}
		if seen == 2 {
			return out
		}
	}
	t.Fatalf("未捕获到两次校区账户加锁语句（seen=%d），实际 SQL=%v", seen, stmts)
	return out
}

// campusIDParamRe 匹配语句中被内联的 `campus_id = N` 参数（GORM 日志 Explain 会内联实参）。
var campusIDParamRe = regexp.MustCompile(`campus_id\s*=\s*(-?\d+)`)

// extractCampusIDParam 从单条 SQL 中取出 campus_id 实参（取不到 → 0）。
func extractCampusIDParam(t *testing.T, sql string) int64 {
	t.Helper()
	m := campusIDParamRe.FindStringSubmatch(sql)
	if len(m) < 2 {
		return 0
	}
	v, err := strconv.ParseInt(m[1], 10, 64)
	if err != nil {
		return 0
	}
	return v
}