fish/asset_assistant
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add

Browse Source
This commit is contained in:
vipg
2025-11-17 18:17:14 +08:00
parent fde1929b2c
commit cca0e14823
6 changed files with 85 additions and 85 deletions
Download Patch File Download Diff File Expand all files Collapse all files

32
backend/src/logic4exchange/delete.go
View File

@@ -12,7 +12,7 @@ import (
// DeleteRequest 删除请求参数结构
type DeleteRequest struct {
CountryID string `json:"exchange_id" binding:"required"` // 国家ID，必填
ExchangeID string `json:"exchange_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),
@@ -52,7 +52,7 @@ func DeleteHandler(c *gin.Context) {
zap.L().Debug("✅ 请求参数验证通过",
zap.String("req_id", reqID),
zap.String("exchange_id", req.CountryID),
zap.String("exchange_id", req.ExchangeID),
)
// 开启数据库事务
@@ -90,28 +90,28 @@ func DeleteHandler(c *gin.Context) {
}()
// 3.1 更新exchange表
_, err = tx.Exec("UPDATE exchange SET deleted = TRUE WHERE id = $1", req.CountryID)
_, 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.CountryID),
zap.String("exchange_id", req.ExchangeID),
zap.Error(err),
)
c.JSON(http.StatusInternalServerError, DeleteResponse{
Success: false,
Message: "删除国家记录失败",
Message: "删除交易所记录失败",
})
return
}
// 3.2 更新name表
_, err = tx.Exec("UPDATE name SET deleted = TRUE WHERE exchange_id = $1", req.CountryID)
_, err = tx.Exec("UPDATE exchange_name SET deleted = TRUE WHERE exchange_id = $1", req.ExchangeID)
if err != nil {
tx.Rollback()
zap.L().Error("❌ name表更新失败",
zap.L().Error("❌ exchange_name表更新失败",
zap.String("req_id", reqID),
zap.String("exchange_id", req.CountryID),
zap.String("exchange_id", req.ExchangeID),
zap.Error(err),
)
c.JSON(http.StatusInternalServerError, DeleteResponse{
@@ -122,12 +122,12 @@ func DeleteHandler(c *gin.Context) {
}
// 3.3 更新code表
_, err = tx.Exec("UPDATE code SET deleted = TRUE WHERE exchange_id = $1", req.CountryID)
_, err = tx.Exec("UPDATE exchange_code SET deleted = TRUE WHERE exchange_id = $1", req.ExchangeID)
if err != nil {
tx.Rollback()
zap.L().Error("❌ code表更新失败",
zap.L().Error("❌ exchange_code表更新失败",
zap.String("req_id", reqID),
zap.String("exchange_id", req.CountryID),
zap.String("exchange_id", req.ExchangeID),
zap.Error(err),
)
c.JSON(http.StatusInternalServerError, DeleteResponse{
@@ -142,7 +142,7 @@ func DeleteHandler(c *gin.Context) {
tx.Rollback()
zap.L().Error("❌ 事务提交失败",
zap.String("req_id", reqID),
zap.String("exchange_id", req.CountryID),
zap.String("exchange_id", req.ExchangeID),
zap.Error(err),
)
c.JSON(http.StatusInternalServerError, DeleteResponse{
@@ -154,9 +154,9 @@ func DeleteHandler(c *gin.Context) {
// 记录请求处理耗时
duration := time.Since(startTime)
zap.L().Info("✅ 国家删除请求处理完成",
zap.L().Info("✅ 交易所删除请求处理完成",
zap.String("req_id", reqID),
zap.String("exchange_id", req.CountryID),
zap.String("exchange_id", req.ExchangeID),
zap.Duration("duration", duration),
)