add
This commit is contained in:
@@ -12,7 +12,7 @@ import (
|
||||
|
||||
// DeleteRequest 删除请求参数结构
|
||||
type DeleteRequest struct {
|
||||
CountryID string `json:"currency_id" binding:"required"` // 国家ID,必填
|
||||
CountryID string `json:"currency_id" binding:"required"` // 货币ID,必填
|
||||
}
|
||||
|
||||
// DeleteResponse 删除响应结构
|
||||
@@ -21,7 +21,7 @@ type DeleteResponse struct {
|
||||
Message string `json:"message"` // 提示信息
|
||||
}
|
||||
|
||||
// DeleteHandler 处理国家删除逻辑(软删除)
|
||||
// DeleteHandler 处理货币删除逻辑(软删除)
|
||||
func DeleteHandler(c *gin.Context) {
|
||||
startTime := time.Now()
|
||||
reqID := c.Request.Header.Get("X-DeleteRequest-ID")
|
||||
@@ -30,7 +30,7 @@ func DeleteHandler(c *gin.Context) {
|
||||
zap.L().Debug("✨ 生成新的请求ID", zap.String("req_id", reqID))
|
||||
}
|
||||
|
||||
zap.L().Info("📥 收到国家删除请求",
|
||||
zap.L().Info("📥 收到货币删除请求",
|
||||
zap.String("req_id", reqID),
|
||||
zap.String("path", c.Request.URL.Path),
|
||||
zap.String("method", c.Request.Method),
|
||||
@@ -100,16 +100,16 @@ func DeleteHandler(c *gin.Context) {
|
||||
)
|
||||
c.JSON(http.StatusInternalServerError, DeleteResponse{
|
||||
Success: false,
|
||||
Message: "删除国家记录失败",
|
||||
Message: "删除货币记录失败",
|
||||
})
|
||||
return
|
||||
}
|
||||
|
||||
// 3.2 更新name表
|
||||
_, err = tx.Exec("UPDATE name SET deleted = TRUE WHERE currency_id = $1", req.CountryID)
|
||||
_, err = tx.Exec("UPDATE currency_name SET deleted = TRUE WHERE currency_id = $1", req.CountryID)
|
||||
if err != nil {
|
||||
tx.Rollback()
|
||||
zap.L().Error("❌ name表更新失败",
|
||||
zap.L().Error("❌ currency_name表更新失败",
|
||||
zap.String("req_id", reqID),
|
||||
zap.String("currency_id", req.CountryID),
|
||||
zap.Error(err),
|
||||
@@ -122,10 +122,10 @@ func DeleteHandler(c *gin.Context) {
|
||||
}
|
||||
|
||||
// 3.3 更新code表
|
||||
_, err = tx.Exec("UPDATE code SET deleted = TRUE WHERE currency_id = $1", req.CountryID)
|
||||
_, err = tx.Exec("UPDATE currency_code SET deleted = TRUE WHERE currency_id = $1", req.CountryID)
|
||||
if err != nil {
|
||||
tx.Rollback()
|
||||
zap.L().Error("❌ code表更新失败",
|
||||
zap.L().Error("❌ currency_code表更新失败",
|
||||
zap.String("req_id", reqID),
|
||||
zap.String("currency_id", req.CountryID),
|
||||
zap.Error(err),
|
||||
@@ -154,7 +154,7 @@ func DeleteHandler(c *gin.Context) {
|
||||
|
||||
// 记录请求处理耗时
|
||||
duration := time.Since(startTime)
|
||||
zap.L().Info("✅ 国家删除请求处理完成",
|
||||
zap.L().Info("✅ 货币删除请求处理完成",
|
||||
zap.String("req_id", reqID),
|
||||
zap.String("currency_id", req.CountryID),
|
||||
zap.Duration("duration", duration),
|
||||
|
||||
Reference in New Issue
Block a user