diff --git a/backend/internal/modules/pickup/repository.go b/backend/internal/modules/pickup/repository.go index 4ee045a..2552ebd 100644 --- a/backend/internal/modules/pickup/repository.go +++ b/backend/internal/modules/pickup/repository.go @@ -492,7 +492,7 @@ func (r *Repository) CreateFinancialAdjustment(ctx context.Context, pickupID uin ActorType: "admin", ActorID: adminID, Action: "pickup_financial_adjustment_create", - BizType: "admin_pickup_financial_adjustment", + BizType: "admin_pickup", BizID: &bid, Meta: meta, Detail: map[string]any{ @@ -564,7 +564,7 @@ func (r *Repository) SettleFinancialAdjustment(ctx context.Context, adjustmentID ActorType: "admin", ActorID: adminID, Action: "pickup_financial_adjustment_settle", - BizType: "admin_pickup_financial_adjustment", + BizType: "admin_pickup", BizID: &bid, Meta: meta, Detail: map[string]any{ diff --git a/backend/internal/modules/pickup/repository_test.go b/backend/internal/modules/pickup/repository_test.go index 589ebb1..1f1a5a2 100644 --- a/backend/internal/modules/pickup/repository_test.go +++ b/backend/internal/modules/pickup/repository_test.go @@ -469,6 +469,13 @@ func TestRepositoryFinancialAdjustmentUsesRecoveryForInternalReduction(t *testin if adjustment.Status != FinancialAdjustmentStatusRecovery || adjustment.SettleDeltaCent != -2000 { t.Fatalf("追回调整 = %+v", adjustment) } + var audit model.AuditLog + if err := db.Where("action = ?", "pickup_financial_adjustment_create").First(&audit).Error; err != nil { + t.Fatalf("查询财务调整审计日志失败: %v", err) + } + if audit.BizType != "admin_pickup" { + t.Fatalf("财务调整审计业务类型 = %q, want admin_pickup", audit.BizType) + } var ledgerCount int64 if err := db.Model(&model.WalletLedger{}).Where("biz_type = ?", "admin_pickup_adjustment").Count(&ledgerCount).Error; err != nil { t.Fatalf("统计补款流水失败: %v", err) @@ -512,6 +519,13 @@ func TestRepositoryFinancialAdjustmentSettlesPlatformManagedPickupSeparately(t * if adjustments[0].Status != FinancialAdjustmentStatusPending { t.Fatalf("代管补款状态 = %q, want pending", adjustments[0].Status) } + var createAudit model.AuditLog + if err := db.Where("action = ?", "pickup_financial_adjustment_create").First(&createAudit).Error; err != nil { + t.Fatalf("查询创建财务调整审计日志失败: %v", err) + } + if createAudit.BizType != "admin_pickup" { + t.Fatalf("创建财务调整审计业务类型 = %q, want admin_pickup", createAudit.BizType) + } if err := repo.SettleFinancialAdjustment(t.Context(), adjustments[0].ID, FinancialAdjustmentSettlementRequest{Remark: "已补款"}, 102, auditlog.Meta{}); err != nil { t.Fatalf("SettleFinancialAdjustment() error = %v", err) } @@ -519,6 +533,13 @@ func TestRepositoryFinancialAdjustmentSettlesPlatformManagedPickupSeparately(t * if err != nil || adjustments[0].Status != FinancialAdjustmentStatusSettled || adjustments[0].SettledBy == nil || *adjustments[0].SettledBy != 102 { t.Fatalf("确认后的调整流水 = %+v, %v", adjustments, err) } + var settleAudit model.AuditLog + if err := db.Where("action = ?", "pickup_financial_adjustment_settle").First(&settleAudit).Error; err != nil { + t.Fatalf("查询确认财务调整审计日志失败: %v", err) + } + if settleAudit.BizType != "admin_pickup" { + t.Fatalf("确认财务调整审计业务类型 = %q, want admin_pickup", settleAudit.BizType) + } } func TestRepositoryOfflineSettlementProcessesPendingPickupAdjustments(t *testing.T) {