From a5753f0c478e5e5b1ad0158bb16dacf1974b246e Mon Sep 17 00:00:00 2001
From: vipg <vipg@vipg.com>
Date: Sat, 15 Nov 2025 17:35:13 +0800
Subject: [PATCH] add

---
 .../src/logic/exchange/exchange_create.go     | 81 +++++--------------
 1 file changed, 21 insertions(+), 60 deletions(-)

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