diff --git a/backend/src/logic4variety/delete.go b/backend/src/logic4variety/delete.go index 92360ce..5bcb55a 100644 --- a/backend/src/logic4variety/delete.go +++ b/backend/src/logic4variety/delete.go @@ -1 +1,185 @@ -package logic4variety \ No newline at end of file + +package logic4exchange + +import ( + "asset_assistant/db" + "net/http" + "time" + + "github.com/gin-gonic/gin" + "github.com/google/uuid" + "go.uber.org/zap" +) + +// DeleteRequest 删除请求参数结构 +type DeleteRequest struct { + ExchangeID string `json:"exchange_id" binding:"required"` // 交易所ID,必填 +} + +// DeleteResponse 删除响应结构 +type DeleteResponse struct { + Success bool `json:"success"` // 操作是否成功 + Message string `json:"message"` // 提示信息 +} + +// DeleteHandler 处理删除逻辑(软删除) +func DeleteHandler(c *gin.Context) { + startTime := time.Now() + reqID := c.Request.Header.Get("X-DeleteRequest-ID") + if reqID == "" { + reqID = uuid.New().String() + zap.L().Debug("✨ 生成新的请求ID", zap.String("req_id", reqID)) + } + + zap.L().Info("📥 收到交易所删除请求", + zap.String("req_id", reqID), + zap.String("path", c.Request.URL.Path), + zap.String("method", c.Request.Method), + ) + + var req DeleteRequest + // 绑定并验证请求参数 + if err := c.ShouldBindJSON(&req); err != nil { + zap.L().Warn("⚠️ 请求参数验证失败", + zap.String("req_id", reqID), + zap.Error(err), + ) + c.JSON(http.StatusBadRequest, DeleteResponse{ + Success: false, + Message: "请求参数错误:exchange_id为必填项", + }) + return + } + + zap.L().Debug("✅ 请求参数验证通过", + zap.String("req_id", reqID), + zap.String("exchange_id", req.ExchangeID), + ) + + // 开启数据库事务 + tx, err := db.DB.Begin() + if err != nil { + zap.L().Error("❌ 事务开启失败", + zap.String("req_id", reqID), + zap.Error(err), + ) + c.JSON(http.StatusInternalServerError, DeleteResponse{ + Success: false, + Message: "系统错误,请稍后重试", + }) + return + } + + // 延迟处理panic情况 + defer func() { + if r := recover(); r != nil { + if err := tx.Rollback(); err != nil { + zap.L().Error("💥 panic后事务回滚失败", + zap.String("req_id", reqID), + zap.Error(err), + ) + } + zap.L().Error("💥 事务处理发生panic", + zap.String("req_id", reqID), + zap.Any("recover", r), + ) + c.JSON(http.StatusInternalServerError, DeleteResponse{ + Success: false, + Message: "系统错误,请稍后重试", + }) + } + }() + + // 1. 更新exchange表 + _, err = tx.Exec("UPDATE exchange SET deleted = TRUE WHERE id = $1", req.ExchangeID) + if err != nil { + tx.Rollback() + zap.L().Error("❌ exchange表更新失败", + zap.String("req_id", reqID), + zap.String("exchange_id", req.ExchangeID), + zap.Error(err), + ) + c.JSON(http.StatusInternalServerError, DeleteResponse{ + Success: false, + Message: "删除交易所记录失败", + }) + return + } + + // 2. 更新exchange_name表 + _, err = tx.Exec("UPDATE exchange_name SET deleted = TRUE WHERE exchange_id = $1", req.ExchangeID) + if err != nil { + tx.Rollback() + zap.L().Error("❌ exchange_name表更新失败", + zap.String("req_id", reqID), + zap.String("exchange_id", req.ExchangeID), + zap.Error(err), + ) + c.JSON(http.StatusInternalServerError, DeleteResponse{ + Success: false, + Message: "删除名称信息失败", + }) + return + } + + // 3. 新增:更新exchange_short_name表(软删除短名称记录) + _, err = tx.Exec("UPDATE exchange_short_name SET deleted = TRUE WHERE exchange_id = $1", req.ExchangeID) + if err != nil { + tx.Rollback() + zap.L().Error("❌ exchange_short_name表更新失败", + zap.String("req_id", reqID), + zap.String("exchange_id", req.ExchangeID), + zap.Error(err), + ) + c.JSON(http.StatusInternalServerError, DeleteResponse{ + Success: false, + Message: "删除短名称信息失败", + }) + return + } + + // 4. 更新exchange_code表 + _, err = tx.Exec("UPDATE exchange_code SET deleted = TRUE WHERE exchange_id = $1", req.ExchangeID) + if err != nil { + tx.Rollback() + zap.L().Error("❌ exchange_code表更新失败", + zap.String("req_id", reqID), + zap.String("exchange_id", req.ExchangeID), + zap.Error(err), + ) + c.JSON(http.StatusInternalServerError, DeleteResponse{ + Success: false, + Message: "删除代码信息失败", + }) + return + } + + // 提交事务 + if err := tx.Commit(); err != nil { + tx.Rollback() + zap.L().Error("❌ 事务提交失败", + zap.String("req_id", reqID), + zap.String("exchange_id", req.ExchangeID), + zap.Error(err), + ) + c.JSON(http.StatusInternalServerError, DeleteResponse{ + Success: false, + Message: "数据提交失败,请稍后重试", + }) + return + } + + // 记录请求处理耗时 + duration := time.Since(startTime) + zap.L().Info("✅ 交易所删除请求处理完成", + zap.String("req_id", reqID), + zap.String("exchange_id", req.ExchangeID), + zap.Duration("duration", duration), + ) + + // 返回成功响应 + c.JSON(http.StatusOK, DeleteResponse{ + Success: true, + Message: "删除成功", + }) +}