add

backend/src/logic4variety/delete.go

@@ -1 +1,185 @@
-package logic4variety
+
+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: "删除成功",
+	})
+}