package adminfinance import ( "errors" "testing" "time" "hfb_sys/backend/internal/auditlog" "hfb_sys/backend/internal/timeutil" "gorm.io/driver/sqlite" "gorm.io/gorm" "gorm.io/gorm/logger" ) func TestManualDisbursementCreateAndVoid(t *testing.T) { db, err := gorm.Open(sqlite.Open(":memory:"), &gorm.Config{Logger: logger.Default.LogMode(logger.Silent)}) if err != nil { t.Fatalf("打开测试数据库失败: %v", err) } statements := []string{ `CREATE TABLE manual_disbursements ( id INTEGER PRIMARY KEY AUTOINCREMENT, disbursement_no TEXT NOT NULL UNIQUE, category TEXT NOT NULL, payee_name TEXT NOT NULL, amount_cent INTEGER NOT NULL, paid_at DATETIME NOT NULL, remark TEXT NOT NULL, voucher_url TEXT NOT NULL, status TEXT NOT NULL, created_by INTEGER NOT NULL, voided_by INTEGER, voided_at DATETIME, void_reason TEXT NOT NULL DEFAULT '', created_at DATETIME, updated_at DATETIME )`, `CREATE TABLE admin_users (id INTEGER PRIMARY KEY, nickname TEXT, username TEXT)`, `CREATE TABLE audit_logs ( id INTEGER PRIMARY KEY AUTOINCREMENT, actor_type TEXT, actor_id INTEGER, action TEXT, biz_type TEXT, biz_id INTEGER, ip TEXT, user_agent TEXT, detail BLOB, created_at DATETIME )`, } for _, statement := range statements { if err := db.Exec(statement).Error; err != nil { t.Fatalf("创建测试表失败: %v", err) } } if err := db.Exec(`INSERT INTO admin_users (id, nickname, username) VALUES (7, '财务甲', 'finance_a'), (8, '财务乙', 'finance_b')`).Error; err != nil { t.Fatal(err) } repo := NewRepository(db) paidAt := time.Date(2026, 7, 20, 9, 30, 0, 0, timeutil.ShanghaiLocation()) created, err := repo.CreateManualDisbursement(t.Context(), CreateManualDisbursementRequest{ Category: "operating_expense", PayeeName: "测试供应商", AmountCent: 8800, PaidAt: paidAt, Remark: "测试运营支出", VoucherURL: "/api/files/object?key=manual-disbursement%2Fvoucher.webp", }, 7, auditlog.Meta{RequestID: "req-create"}) if err != nil { t.Fatalf("创建其他线下出款失败: %v", err) } if created.ID == 0 || created.DisbursementNo == "" || created.Status != "paid" || created.CreatedByName != "财务甲" { t.Fatalf("创建结果不正确: %+v", created) } voided, err := repo.VoidManualDisbursement(t.Context(), created.ID, "录入金额有误", 8, auditlog.Meta{RequestID: "req-void"}) if err != nil { t.Fatalf("作废其他线下出款失败: %v", err) } if voided.Status != "voided" || voided.VoidedByName != "财务乙" || voided.VoidReason != "录入金额有误" || voided.VoidedAt == nil { t.Fatalf("作废结果不正确: %+v", voided) } if _, err := repo.VoidManualDisbursement(t.Context(), created.ID, "重复作废", 8, auditlog.Meta{}); !errors.Is(err, ErrManualDisbursementNotPaid) { t.Fatalf("重复作废错误 = %v, want ErrManualDisbursementNotPaid", err) } var auditCount int64 if err := db.Table("audit_logs").Where("biz_type = ?", "manual_disbursement").Count(&auditCount).Error; err != nil { t.Fatal(err) } if auditCount != 2 { t.Fatalf("审计日志数量 = %d, want 2", auditCount) } } func TestManualDisbursementValidation(t *testing.T) { service := NewService(&Repository{}) _, err := service.CreateManualDisbursement(t.Context(), CreateManualDisbursementRequest{ Category: "unknown", PayeeName: "测试收款人", AmountCent: 100, PaidAt: timeutil.ShanghaiNow(), Remark: "测试", }, 1, auditlog.Meta{}) if !errors.Is(err, ErrInvalidManualDisbursement) { t.Fatalf("无效分类错误 = %v, want ErrInvalidManualDisbursement", err) } }