新增支付配置备份导出功能

This commit is contained in:
yml2213
2026-06-07 14:11:16 +08:00
parent 53eb4acad8
commit 9740ff8799
11 changed files with 161 additions and 14 deletions
@@ -106,3 +106,13 @@ type ListResponse struct {
Page int `json:"page"`
PageSize int `json:"page_size"`
}
// ExportBackup 支付配置备份导出内容。
type ExportBackup struct {
Type string `json:"type"`
Version int `json:"version"`
ExportedAt string `json:"exported_at"`
ExportedBy uint64 `json:"exported_by"`
Total int `json:"total"`
Configs []ConfigDTO `json:"configs"`
}
@@ -1,8 +1,10 @@
package paymentconfig
import (
"encoding/json"
"net/http"
"strconv"
"time"
"hfb_sys/backend/internal/middleware"
"hfb_sys/backend/pkg/response"
@@ -73,6 +75,40 @@ func (h *Handler) Get(c *gin.Context) {
response.OK(c, config)
}
// ExportBackup 导出支付配置备份
// @Summary 导出支付配置备份
// @Tags 管理后台-支付配置
// @Success 200 {file} file "支付配置备份 JSON"
// @Router /admin/payment-configs/export [get]
func (h *Handler) ExportBackup(c *gin.Context) {
adminID, ok := currentAdminID(c)
if !ok {
response.Unauthorized(c, "未授权")
return
}
backup, err := h.service.ExportBackup(adminID, auditMeta(c))
if err == ErrDecryptionFailed {
response.Error(c, http.StatusInternalServerError, "decrypt_failed", "密钥解密失败")
return
}
if err != nil {
response.Error(c, http.StatusInternalServerError, "internal_error", "导出失败")
return
}
data, err := json.MarshalIndent(backup, "", " ")
if err != nil {
response.Error(c, http.StatusInternalServerError, "internal_error", "导出失败")
return
}
filename := "payment-config-backup-" + time.Now().Format("20060102-150405") + ".json"
contentType := "application/json; charset=utf-8"
c.Header("Content-Disposition", `attachment; filename="`+filename+`"`)
c.Data(http.StatusOK, contentType, data)
}
// Create 创建支付配置
// @Summary 创建支付配置
// @Tags 管理后台-支付配置
@@ -153,6 +153,45 @@ func (r *Repository) FindByProviderMerchant(provider string, merchantID string,
return &dto, nil
}
// ExportBackup 导出所有支付配置备份,包含解密后的密钥。
func (r *Repository) ExportBackup(actorID uint64, meta AuditMeta) (*ExportBackup, error) {
var backup *ExportBackup
err := r.db.Transaction(func(tx *gorm.DB) error {
var items []model.PaymentMerchantConfig
if err := tx.Order("is_default DESC, id DESC").Find(&items).Error; err != nil {
return err
}
configs := make([]ConfigDTO, 0, len(items))
for _, item := range items {
dto, err := r.toDTO(item, true)
if err != nil {
return err
}
configs = append(configs, dto)
}
exportedAt := time.Now().Format(time.RFC3339)
backup = &ExportBackup{
Type: "payment_config_backup",
Version: 1,
ExportedAt: exportedAt,
ExportedBy: actorID,
Total: len(configs),
Configs: configs,
}
return appendAuditLog(tx, actorID, "payment_config.export", 0, meta, map[string]any{
"total": len(configs),
"exported_at": exportedAt,
})
})
if err != nil {
return nil, err
}
return backup, nil
}
// FindActiveByProvider 查询提供商的所有激活配置
func (r *Repository) FindActiveByProvider(provider string) ([]model.PaymentMerchantConfig, error) {
var items []model.PaymentMerchantConfig
@@ -37,6 +37,11 @@ func (s *Service) Get(id uint64, includeSecret bool) (*ConfigDTO, error) {
return s.repo.FindByID(id, includeSecret)
}
// ExportBackup 导出支付配置备份。
func (s *Service) ExportBackup(actorID uint64, meta AuditMeta) (*ExportBackup, error) {
return s.repo.ExportBackup(actorID, meta)
}
// Create 创建配置
func (s *Service) Create(req CreateRequest, actorID uint64, meta AuditMeta) (*ConfigDTO, error) {
return s.repo.Create(req, actorID, meta)
+1
View File
@@ -424,6 +424,7 @@ func New(cfg config.Config, deps Dependencies, logger *zap.Logger) *gin.Engine {
// 支付配置管理
if paymentConfigHandler != nil {
adminRoutes.GET("/payment-configs", requirePerm("payment_config:list"), paymentConfigHandler.List)
adminRoutes.GET("/payment-configs/export", requirePerm("payment_config:view_secret"), paymentConfigHandler.ExportBackup)
adminRoutes.GET("/payment-configs/:id", requirePerm("payment_config:list"), paymentConfigHandler.Get)
adminRoutes.POST("/payment-configs", requirePerm("payment_config:create"), paymentConfigHandler.Create)
adminRoutes.PUT("/payment-configs/:id", requirePerm("payment_config:update"), paymentConfigHandler.Update)
@@ -1,10 +0,0 @@
-- 支付多渠道和拉卡拉配置字段扩展
ALTER TABLE payment_orders
MODIFY COLUMN provider VARCHAR(32) NOT NULL COMMENT '支付服务商: leshua乐刷, lakala拉卡拉, mock模拟',
MODIFY COLUMN merchant_id VARCHAR(128) NOT NULL DEFAULT '' COMMENT '商户号';
ALTER TABLE payment_merchant_configs
MODIFY COLUMN provider VARCHAR(32) NOT NULL COMMENT '支付服务商: leshua乐刷, lakala拉卡拉, mock模拟',
MODIFY COLUMN sign_key TEXT NULL COMMENT '签名密钥/商户私钥(加密存储)',
MODIFY COLUMN notify_key TEXT NULL COMMENT '通知验签密钥/平台通知证书(加密存储)',
MODIFY COLUMN sign_type VARCHAR(32) NOT NULL DEFAULT 'MD5' COMMENT '签名类型: MD5, SHA256withRSA';