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-15 17:35:13 +08:00
parent 578e1596ef
commit a5753f0c47
1 changed files with 21 additions and 60 deletions
Download Patch File Download Diff File Expand all files Collapse all files

81
backend/futures_trade_record/src/logic/exchange/exchange_create.go
View File

@@ -1,30 +1,31 @@
package logic4exchange package logic4exchange
import ( import (
"futures_trade_record/db" // 数据库操作相关包 "futures_trade_record/db"
"net/http" "net/http"
"time" // 时间处理包 "time"
"github.com/gin-gonic/gin" // Gin框架，用于处理HTTP请求 "github.com/gin-gonic/gin"
"github.com/google/uuid" // UUID生成工具 "github.com/google/uuid"
"go.uber.org/zap" // 日志库 "go.uber.org/zap"
) )
// CreateExchangeRequest 注册请求参数结构 // CreateExchangeRequest 交易所创建请求参数（仅包含SQL中定义的必要字段）
type CreateExchangeRequest struct { type CreateExchangeRequest struct {
Name string `json:"name" binding:"required"` // 交易所名称（对应exchange_name表）
Code string `json:"code" binding:"required"` // 交易所代码（对应exchange_code表）
} }
// CreateExchangeResponse 注册响应结构 // CreateExchangeResponse 响应结构
type CreateExchangeResponse struct { type CreateExchangeResponse struct {
Success bool `json:"success"` // 操作是否成功 Success bool `json:"success"`
Message string `json:"message"` // 提示信息 Message string `json:"message"`
Data CreateExchangeData `json:"data"` // 响应数据 Data CreateExchangeData `json:"data"`
} }
// CreateExchangeData 响应数据结构 // CreateExchangeData 响应数据
type CreateExchangeData struct { type CreateExchangeData struct {
ExchangeID string `json:"exchange_id"` // 交易所唯一标识ID ExchangeID string `json:"exchange_id"`
} }
// CreateExchangeHandler 处理交易所创建逻辑 // CreateExchangeHandler 处理交易所创建逻辑
@@ -43,7 +44,7 @@ func CreateExchangeHandler(c *gin.Context) {
) )
var req CreateExchangeRequest var req CreateExchangeRequest
// 绑定并验证请求参数（包含新增的tick和tick_price） // 绑定并验证请求参数（仅验证name和code）
if err := c.ShouldBindJSON(&req); err != nil { if err := c.ShouldBindJSON(&req); err != nil {
zap.L().Warn("🔴 请求参数验证失败", zap.L().Warn("🔴 请求参数验证失败",
zap.String("req_id", reqID), zap.String("req_id", reqID),
@@ -52,7 +53,7 @@ func CreateExchangeHandler(c *gin.Context) {
) )
c.JSON(http.StatusBadRequest, CreateExchangeResponse{ c.JSON(http.StatusBadRequest, CreateExchangeResponse{
Success: false, Success: false,
Message: "请求参数错误：name、code、tick和tick_price为必填项，且tick和tick_price需大于等于0", Message: "请求参数错误：name和code为必填项",
}) })
return return
} }
@@ -61,8 +62,6 @@ func CreateExchangeHandler(c *gin.Context) {
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.String("name", req.Name), zap.String("name", req.Name),
zap.String("code", req.Code), zap.String("code", req.Code),
zap.Float64("tick", req.Tick),
zap.Float64("tick_price", req.TickPrice),
) )
// 开启数据库事务 // 开启数据库事务
@@ -97,7 +96,7 @@ func CreateExchangeHandler(c *gin.Context) {
} }
}() }()
// 1. 在exchange表中创建记录并获取自动生成的ID // 1. 在exchange主表创建记录并获取ID
var exchangeID string var exchangeID string
err = tx.QueryRow("INSERT INTO exchange DEFAULT VALUES RETURNING id").Scan(&exchangeID) err = tx.QueryRow("INSERT INTO exchange DEFAULT VALUES RETURNING id").Scan(&exchangeID)
if err != nil { if err != nil {
@@ -113,12 +112,7 @@ func CreateExchangeHandler(c *gin.Context) {
return return
} }
zap.L().Debug("📝 exchange表插入成功", // 2. 插入交易所名称到exchange_name子表
zap.String("req_id", reqID),
zap.String("exchange_id", exchangeID),
)
// 2. 插入交易所名称到exchange_name表（修正表名）
_, err = tx.Exec("INSERT INTO exchange_name (exchange_id, name) VALUES ($1, $2)", exchangeID, req.Name) _, err = tx.Exec("INSERT INTO exchange_name (exchange_id, name) VALUES ($1, $2)", exchangeID, req.Name)
if err != nil { if err != nil {
tx.Rollback() tx.Rollback()
@@ -134,7 +128,7 @@ func CreateExchangeHandler(c *gin.Context) {
return return
} }
// 3. 插入交易所代码到exchange_code表（修正表名） // 3. 插入交易所代码到exchange_code子表
_, err = tx.Exec("INSERT INTO exchange_code (exchange_id, code) VALUES ($1, $2)", exchangeID, req.Code) _, err = tx.Exec("INSERT INTO exchange_code (exchange_id, code) VALUES ($1, $2)", exchangeID, req.Code)
if err != nil { if err != nil {
tx.Rollback() tx.Rollback()
@@ -150,38 +144,6 @@ func CreateExchangeHandler(c *gin.Context) {
return return
} }
// 4. 插入跳点值到exchange_tick表（新增）
_, err = tx.Exec("INSERT INTO exchange_tick (exchange_id, tick) VALUES ($1, $2)", exchangeID, req.Tick)
if err != nil {
tx.Rollback()
zap.L().Error("❌ exchange_tick表插入失败",
zap.String("req_id", reqID),
zap.String("exchange_id", exchangeID),
zap.Error(err),
)
c.JSON(http.StatusInternalServerError, CreateExchangeResponse{
Success: false,
Message: "保存跳点信息失败",
})
return
}
// 5. 插入跳点价格到exchange_tick_price表（新增）
_, err = tx.Exec("INSERT INTO exchange_tick_price (exchange_id, price) VALUES ($1, $2)", exchangeID, req.TickPrice)
if err != nil {
tx.Rollback()
zap.L().Error("❌ exchange_tick_price表插入失败",
zap.String("req_id", reqID),
zap.String("exchange_id", exchangeID),
zap.Error(err),
)
c.JSON(http.StatusInternalServerError, CreateExchangeResponse{
Success: false,
Message: "保存跳点价格信息失败",
})
return
}
// 提交事务 // 提交事务
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {
tx.Rollback() tx.Rollback()
@@ -197,7 +159,7 @@ func CreateExchangeHandler(c *gin.Context) {
return return
} }
// 记录请求处理耗时 // 记录处理耗时并返回成功响应
duration := time.Since(startTime) duration := time.Since(startTime)
zap.L().Info("✅ 交易所创建请求处理完成", zap.L().Info("✅ 交易所创建请求处理完成",
zap.String("req_id", reqID), zap.String("req_id", reqID),
@@ -205,7 +167,6 @@ func CreateExchangeHandler(c *gin.Context) {
zap.Duration("duration", duration), zap.Duration("duration", duration),
) )
// 返回成功响应
c.JSON(http.StatusOK, CreateExchangeResponse{ c.JSON(http.StatusOK, CreateExchangeResponse{
Success: true, Success: true,
Message: "创建成功", Message: "创建成功",
@@ -213,4 +174,4 @@ func CreateExchangeHandler(c *gin.Context) {
ExchangeID: exchangeID, ExchangeID: exchangeID,
}, },
}) })
} }