From f5e3c60e8c3eea3bbbf6009241425d274b19aada Mon Sep 17 00:00:00 2001 From: vipg Date: Fri, 14 Nov 2025 15:14:40 +0800 Subject: [PATCH] add --- .../src/logic/create.go | 194 +-------------- .../src/logic/delete.go | 166 ------------- .../futures_trading_record/src/logic/read.go | 229 ------------------ .../src/logic/update.go | 183 -------------- backend/futures_trading_record/src/main.go | 16 +- 5 files changed, 3 insertions(+), 785 deletions(-) diff --git a/backend/futures_trading_record/src/logic/create.go b/backend/futures_trading_record/src/logic/create.go index aa286d9..697a16f 100644 --- a/backend/futures_trading_record/src/logic/create.go +++ b/backend/futures_trading_record/src/logic/create.go @@ -1,193 +1 @@ -package logic - -import ( - "net/http" - "futures_trading_record/db" // 数据库操作相关包 - "time" // 时间处理包 - "github.com/google/uuid" // UUID生成工具 - "github.com/gin-gonic/gin" // Gin框架，用于处理HTTP请求 - "go.uber.org/zap" // 日志库 -) - -// CreateRequest 注册请求参数结构 -// 用于接收客户端发送的JSON数据，绑定并验证必填字段 -type CreateRequest struct { - Name string `json:"name" binding:"required"` // 国家名称，必填 - Code string `json:"code" binding:"required"` // 国家代码，必填 -} - -// CreateResponse 注册响应结构 -// 统一的API响应格式，包含成功状态、提示信息和数据 -type CreateResponse struct { - Success bool `json:"success"` // 操作是否成功 - Message string `json:"message"` // 提示信息 - Data CreateData `json:"data"` // 响应数据 -} - -// CreateData 响应数据结构 -// 包含创建成功后的国家ID -type CreateData struct { - futures_trading_recordID string `json:"futures_trading_record_id"` // 国家唯一标识ID -} - -// CreateHandler 处理国家创建逻辑 -// 接收HTTP请求，完成参数验证、数据库事务处理并返回响应 -func CreateHandler(c *gin.Context) { - startTime := time.Now() // 记录请求开始时间，用于统计耗时 - // 获取或生成请求ID，用于追踪整个请求链路 - reqID := c.Request.Header.Get("X-RegisterRequest-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 CreateRequest - // 绑定并验证请求参数（检查name和code是否存在） - if err := c.ShouldBindJSON(&req); err != nil { - zap.L().Warn("⚠️ 请求参数验证失败", - zap.String("req_id", reqID), - zap.Error(err), - zap.Any("request_body", c.Request.Body), - ) - // 返回参数错误响应 - c.JSON(http.StatusBadRequest, CreateResponse{ - Success: false, - Message: "请求参数错误：name和code为必填项", - }) - return - } - - // 记录通过验证的请求参数 - zap.L().Debug("✅ 请求参数验证通过", - zap.String("req_id", reqID), - zap.String("name", req.Name), - zap.String("code", req.Code), - ) - - // 开启数据库事务，确保多表操作原子性（要么全成功，要么全失败） - tx, err := db.DB.Begin() - if err != nil { - zap.L().Error("❌ 事务开启失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, CreateResponse{ - Success: false, - Message: "系统错误，请稍后重试", - }) - return - } - // 延迟执行的恢复函数，处理panic情况 - defer func() { - if r := recover(); r != nil { // 捕获panic - // 回滚事务 - 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, CreateResponse{ - Success: false, - Message: "系统错误，请稍后重试", - }) - } - }() - - // 1. 在futures_trading_record表中创建记录并获取自动生成的ID - var futures_trading_recordID string - err = tx.QueryRow("INSERT INTO futures_trading_record DEFAULT VALUES RETURNING id").Scan(&futures_trading_recordID) - if err != nil { - tx.Rollback() // 操作失败，回滚事务 - zap.L().Error("❌ futures_trading_record表插入失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, CreateResponse{ - Success: false, - Message: "创建国家记录失败", - }) - return - } - - zap.L().Debug("📝 futures_trading_record表插入成功", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", futures_trading_recordID), - ) - - // 2. 插入国家名称到name表（与futures_trading_record_id关联） - _, err = tx.Exec("INSERT INTO name (futures_trading_record_id, name) VALUES ($1, $2)", futures_trading_recordID, req.Name) - if err != nil { - tx.Rollback() // 操作失败，回滚事务 - zap.L().Error("❌ name表插入失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, CreateResponse{ - Success: false, - Message: "保存名称信息失败", - }) - return - } - - // 3. 插入国家代码到code表（与futures_trading_record_id关联） - _, err = tx.Exec("INSERT INTO code (futures_trading_record_id, code) VALUES ($1, $2)", futures_trading_recordID, req.Code) - if err != nil { - tx.Rollback() // 操作失败，回滚事务 - zap.L().Error("❌ code表插入失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, CreateResponse{ - Success: false, - Message: "保存代码信息失败", - }) - return - } - - // 提交事务（所有操作成功后确认提交） - if err := tx.Commit(); err != nil { - tx.Rollback() // 提交失败时尝试回滚 - zap.L().Error("❌ 事务提交失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, CreateResponse{ - Success: false, - Message: "数据提交失败，请稍后重试", - }) - return - } - - // 记录请求处理耗时 - duration := time.Since(startTime) - zap.L().Info("✅ 国家创建请求处理完成", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", futures_trading_recordID), - zap.Duration("duration", duration), - ) - - // 返回成功响应，包含创建的国家ID - c.JSON(http.StatusOK, CreateResponse{ - Success: true, - Message: "创建成功", - Data: CreateData{ - futures_trading_recordID: futures_trading_recordID, - }, - }) -} \ No newline at end of file +package logic \ No newline at end of file diff --git a/backend/futures_trading_record/src/logic/delete.go b/backend/futures_trading_record/src/logic/delete.go index 190b4aa..4c79103 100644 --- a/backend/futures_trading_record/src/logic/delete.go +++ b/backend/futures_trading_record/src/logic/delete.go @@ -1,167 +1 @@ package logic - -import ( - "net/http" - "futures_trading_record/db" - "time" - "github.com/google/uuid" - "github.com/gin-gonic/gin" - "go.uber.org/zap" -) - -// DeleteRequest 删除请求参数结构 -type DeleteRequest struct { - futures_trading_recordID string `json:"futures_trading_record_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: "请求参数错误：futures_trading_record_id为必填项", - }) - return - } - - zap.L().Debug("✅ 请求参数验证通过", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - ) - - // 开启数据库事务 - 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: "系统错误，请稍后重试", - }) - } - }() - - // 3.1 更新futures_trading_record表 - _, err = tx.Exec("UPDATE futures_trading_record SET deleted = TRUE WHERE id = $1", req.futures_trading_recordID) - if err != nil { - tx.Rollback() - zap.L().Error("❌ futures_trading_record表更新失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, DeleteResponse{ - Success: false, - Message: "删除国家记录失败", - }) - return - } - - // 3.2 更新name表 - _, err = tx.Exec("UPDATE name SET deleted = TRUE WHERE futures_trading_record_id = $1", req.futures_trading_recordID) - if err != nil { - tx.Rollback() - zap.L().Error("❌ name表更新失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, DeleteResponse{ - Success: false, - Message: "删除名称信息失败", - }) - return - } - - // 3.3 更新code表 - _, err = tx.Exec("UPDATE code SET deleted = TRUE WHERE futures_trading_record_id = $1", req.futures_trading_recordID) - if err != nil { - tx.Rollback() - zap.L().Error("❌ code表更新失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - 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("futures_trading_record_id", req.futures_trading_recordID), - 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("futures_trading_record_id", req.futures_trading_recordID), - zap.Duration("duration", duration), - ) - - // 返回成功响应 - c.JSON(http.StatusOK, DeleteResponse{ - Success: true, - Message: "删除成功", - }) -} \ No newline at end of file diff --git a/backend/futures_trading_record/src/logic/read.go b/backend/futures_trading_record/src/logic/read.go index 5967544..4c79103 100644 --- a/backend/futures_trading_record/src/logic/read.go +++ b/backend/futures_trading_record/src/logic/read.go @@ -1,230 +1 @@ package logic - -import ( - "futures_trading_record/db" - "net/http" - "strconv" - "time" - "strings" - - "fmt" - "github.com/gin-gonic/gin" - "github.com/google/uuid" - "go.uber.org/zap" -) - -// ReadRequest 读取请求参数结构 -type ReadRequest struct { - futures_trading_recordID string `form:"futures_trading_record_id"` // 国家ID，可选 - Name string `form:"name"` // 国家名称，可选 - Code string `form:"code"` // 国家代码，可选 - Page string `form:"page"` // 页码，可选 - PageSize string `form:"page_size"` // 每页条数，可选 -} - -// ReadData 读取响应数据结构 -type ReadData struct { - Total int64 `json:"total"` // 总条数 - Page int `json:"page"` // 当前页码 - PageSize int `json:"page_size"`// 每页条数 - Items []futures_trading_recordInfoViewItem `json:"items"` // 数据列表 -} - -// futures_trading_recordInfoViewItem 视图数据项结构 -type futures_trading_recordInfoViewItem struct { - futures_trading_recordID string `json:"futures_trading_record_id"` // 国家ID - Name string `json:"name"` // 国家名称 - Code string `json:"code"` // 国家代码 -} - -// ReadResponse 读取响应结构 -type ReadResponse struct { - Success bool `json:"success"` // 操作是否成功 - Message string `json:"message"` // 提示信息 - Data ReadData `json:"data"` // 响应数据 -} - -// ReadHandler 处理国家信息查询逻辑 -func ReadHandler(c *gin.Context) { - startTime := time.Now() - // 获取或生成请求ID - reqID := c.Request.Header.Get("X-ReadRequest-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 ReadRequest - if err := c.ShouldBindQuery(&req); err != nil { - zap.L().Warn("⚠️ 请求参数解析失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusBadRequest, ReadResponse{ - Success: false, - Message: "请求参数格式错误", - }) - return - } - - // 验证查询条件至少有一个不为空 - if req.futures_trading_recordID == "" && req.Name == "" && req.Code == "" { - zap.L().Warn("⚠️ 请求参数验证失败", - zap.String("req_id", reqID), - zap.String("reason", "futures_trading_record_id、name、code不能同时为空"), - ) - c.JSON(http.StatusBadRequest, ReadResponse{ - Success: false, - Message: "请求参数错误：futures_trading_record_id、name、code不能同时为空", - }) - return - } - - // 处理分页参数默认值 - page, err := strconv.Atoi(req.Page) - if err != nil || page < 1 { - page = 1 - } - pageSize, err := strconv.Atoi(req.PageSize) - if err != nil || pageSize < 1 { - pageSize = 20 - } - - zap.L().Debug("✅ 请求参数验证通过", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.String("name", req.Name), - zap.String("code", req.Code), - zap.Int("page", page), - zap.Int("page_size", pageSize), - ) - - // 构建查询条件和参数 - whereClauses := []string{} - args := []interface{}{} - paramIndex := 1 - - if req.futures_trading_recordID != "" { - whereClauses = append(whereClauses, "futures_trading_record_id = $"+strconv.Itoa(paramIndex)) - args = append(args, req.futures_trading_recordID) - paramIndex++ - } - if req.Name != "" { - whereClauses = append(whereClauses, "name LIKE $"+strconv.Itoa(paramIndex)) - args = append(args, "%"+req.Name+"%") - paramIndex++ - } - if req.Code != "" { - whereClauses = append(whereClauses, "code LIKE $"+strconv.Itoa(paramIndex)) - args = append(args, "%"+req.Code+"%") - paramIndex++ - } - - // 构建基础SQL - baseSQL := "SELECT futures_trading_record_id, name, code FROM futures_trading_record_info_view" - countSQL := "SELECT COUNT(*) FROM futures_trading_record_info_view" - if len(whereClauses) > 0 { - whereStr := " WHERE " + strings.Join(whereClauses, " AND ") - baseSQL += whereStr - countSQL += whereStr - } - - // 计算分页偏移量 - offset := (page - 1) * pageSize - - // 拼接分页SQL（使用fmt.Sprintf更清晰） - querySQL := fmt.Sprintf("%s ORDER BY futures_trading_record_id LIMIT $%d OFFSET $%d", baseSQL, paramIndex, paramIndex+1) - args = append(args, pageSize, offset) - - // 查询总条数（修正参数传递方式） - var total int64 - countArgs := args[:len(args)-2] // 排除分页参数 - err = db.DB.QueryRow(countSQL, countArgs...).Scan(&total) - if err != nil { - zap.L().Error("❌ 查询总条数失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, ReadResponse{ - Success: false, - Message: "查询数据失败，请稍后重试", - }) - return - } - - // 执行分页查询 - rows, err := db.DB.Query(querySQL, args...) - if err != nil { - zap.L().Error("❌ 分页查询失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, ReadResponse{ - Success: false, - Message: "查询数据失败，请稍后重试", - }) - return - } - defer rows.Close() - - // 处理查询结果 - var items []futures_trading_recordInfoViewItem - for rows.Next() { - var item futures_trading_recordInfoViewItem - if err := rows.Scan(&item.futures_trading_recordID, &item.Name, &item.Code); err != nil { - zap.L().Error("❌ 解析查询结果失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, ReadResponse{ - Success: false, - Message: "数据处理失败，请稍后重试", - }) - return - } - items = append(items, item) - } - - // 检查行迭代过程中是否发生错误 - if err := rows.Err(); err != nil { - zap.L().Error("❌ 行迭代错误", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, ReadResponse{ - Success: false, - Message: "查询数据失败，请稍后重试", - }) - return - } - - // 记录请求处理耗时 - duration := time.Since(startTime) - zap.L().Info("✅ 国家查询请求处理完成", - zap.String("req_id", reqID), - zap.Int64("total", total), - zap.Int("page", page), - zap.Int("page_size", pageSize), - zap.Duration("duration", duration), - ) - - // 返回成功响应 - c.JSON(http.StatusOK, ReadResponse{ - Success: true, - Message: "查询成功", - Data: ReadData{ - Total: total, - Page: page, - PageSize: pageSize, - Items: items, - }, - }) -} \ No newline at end of file diff --git a/backend/futures_trading_record/src/logic/update.go b/backend/futures_trading_record/src/logic/update.go index ee040d0..4c79103 100644 --- a/backend/futures_trading_record/src/logic/update.go +++ b/backend/futures_trading_record/src/logic/update.go @@ -1,184 +1 @@ package logic - -import ( - "futures_trading_record/db" - "net/http" - "time" - - "github.com/gin-gonic/gin" - "github.com/google/uuid" - "go.uber.org/zap" -) - -// UpdateRequest 更新请求参数结构 -type UpdateRequest struct { - futures_trading_recordID string `json:"futures_trading_record_id" binding:"required"` // 国家ID，必填 - Name string `json:"name"` // 国家名称，可选 - Code string `json:"code"` // 国家代码，可选 -} - -// UpdateResponse 更新响应结构 -type UpdateResponse struct { - Success bool `json:"success"` // 操作是否成功 - Message string `json:"message"` // 提示信息 -} - -// UpdateHandler 处理国家信息更新逻辑 -func UpdateHandler(c *gin.Context) { - startTime := time.Now() - // 获取或生成请求ID - reqID := c.Request.Header.Get("X-UpdateRequest-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 UpdateRequest - // 绑定并验证请求参数（主要验证futures_trading_record_id必填） - if err := c.ShouldBindJSON(&req); err != nil { - zap.L().Warn("⚠️ 请求参数验证失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusBadRequest, UpdateResponse{ - Success: false, - Message: "请求参数错误：futures_trading_record_id为必填项", - }) - return - } - - // 验证name和code不能同时为空 - if req.Name == "" && req.Code == "" { - zap.L().Warn("⚠️ 请求参数验证失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.String("reason", "name和code不能同时为空"), - ) - c.JSON(http.StatusBadRequest, UpdateResponse{ - Success: false, - Message: "请求参数错误：name和code不能同时为空", - }) - return - } - - zap.L().Debug("✅ 请求参数验证通过", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.String("name", req.Name), - zap.String("code", req.Code), - ) - - // 开启数据库事务 - tx, err := db.DB.Begin() - if err != nil { - zap.L().Error("❌ 事务开启失败", - zap.String("req_id", reqID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, UpdateResponse{ - 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, UpdateResponse{ - Success: false, - Message: "系统错误，请稍后重试", - }) - } - }() - - // 如果name不为空，更新name表 - if req.Name != "" { - _, err = tx.Exec("UPDATE name SET name = $1 WHERE futures_trading_record_id = $2", req.Name, req.futures_trading_recordID) - if err != nil { - tx.Rollback() - zap.L().Error("❌ name表更新失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, UpdateResponse{ - Success: false, - Message: "更新名称信息失败", - }) - return - } - zap.L().Debug("📝 name表更新成功", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - ) - } - - // 如果code不为空，更新code表 - if req.Code != "" { - _, err = tx.Exec("UPDATE code SET code = $1 WHERE futures_trading_record_id = $2", req.Code, req.futures_trading_recordID) - if err != nil { - tx.Rollback() - zap.L().Error("❌ code表更新失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, UpdateResponse{ - Success: false, - Message: "更新代码信息失败", - }) - return - } - zap.L().Debug("📝 code表更新成功", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - ) - } - - // 提交事务 - if err := tx.Commit(); err != nil { - tx.Rollback() - zap.L().Error("❌ 事务提交失败", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.Error(err), - ) - c.JSON(http.StatusInternalServerError, UpdateResponse{ - Success: false, - Message: "数据提交失败，请稍后重试", - }) - return - } - - // 记录请求处理耗时 - duration := time.Since(startTime) - zap.L().Info("✅ 国家更新请求处理完成", - zap.String("req_id", reqID), - zap.String("futures_trading_record_id", req.futures_trading_recordID), - zap.Duration("duration", duration), - ) - - // 返回成功响应 - c.JSON(http.StatusOK, UpdateResponse{ - Success: true, - Message: "更新成功", - }) -} \ No newline at end of file diff --git a/backend/futures_trading_record/src/main.go b/backend/futures_trading_record/src/main.go index 0f3ffe2..c353e15 100644 --- a/backend/futures_trading_record/src/main.go +++ b/backend/futures_trading_record/src/main.go @@ -51,20 +51,8 @@ func main() { zap.L().Info("✅ 配置跨域中间件完成") // 注册创建国家的接口，POST请求，由logic.CreateHandler处理 - r.POST("/futures_trading_record/create", logic.CreateHandler) - zap.L().Info("✅ 创建接口注册完成: POST /futures_trading_record/create") - - // 注册读取国家的接口，POST请求，由logic.ReadHandler - r.POST("/futures_trading_record/read", logic.ReadHandler) - zap.L().Info("✅ 读取接口注册完成: POST /futures_trading_record/read") - - // 注册更新国家的接口，POST请求，由logic.UpdateHandler - r.POST("/futures_trading_record/update", logic.UpdateHandler) - zap.L().Info("✅ 更新接口注册完成: POST /futures_trading_record/update") - - // 注册删除国家的接口，POST请求，由logic.DeleteHandler处理 - r.POST("/futures_trading_record/delete", logic.DeleteHandler) - zap.L().Info("✅ 删除接口注册完成: POST /futures_trading_record/delete") + // r.POST("/futurestradingrecord/create", logic.CreateHandler) + // zap.L().Info("✅ 创建接口注册完成: POST /futurestradingrecord/create") // 记录服务启动日志，监听80端口 zap.L().Info("✅ 服务启动在80端口")