add

backend/country/src/logic/update.go

@@ -0,0 +1,184 @@
+package logic
+
+import (
+	"country/db"
+	"net/http"
+	"time"
+
+	"github.com/gin-gonic/gin"
+	"github.com/google/uuid"
+	"go.uber.org/zap"
+)
+
+// UpdateRequest 更新请求参数结构
+type UpdateRequest struct {
+	CountryID string `json:"country_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
+	// 绑定并验证请求参数（主要验证country_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: "请求参数错误：country_id为必填项",
+		})
+		return
+	}
+
+	// 验证name和code不能同时为空
+	if req.Name == "" && req.Code == "" {
+		zap.L().Warn("⚠️ 请求参数验证失败",
+			zap.String("req_id", reqID),
+			zap.String("country_id", req.CountryID),
+			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("country_id", req.CountryID),
+		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 country_id = $2", req.Name, req.CountryID)
+		if err != nil {
+			tx.Rollback()
+			zap.L().Error("❌ name表更新失败",
+				zap.String("req_id", reqID),
+				zap.String("country_id", req.CountryID),
+				zap.Error(err),
+			)
+			c.JSON(http.StatusInternalServerError, UpdateResponse{
+				Success: false,
+				Message: "更新名称信息失败",
+			})
+			return
+		}
+		zap.L().Debug("📝 name表更新成功",
+			zap.String("req_id", reqID),
+			zap.String("country_id", req.CountryID),
+		)
+	}
+
+	// 如果code不为空，更新code表
+	if req.Code != "" {
+		_, err = tx.Exec("UPDATE code SET code = $1 WHERE country_id = $2", req.Code, req.CountryID)
+		if err != nil {
+			tx.Rollback()
+			zap.L().Error("❌ code表更新失败",
+				zap.String("req_id", reqID),
+				zap.String("country_id", req.CountryID),
+				zap.Error(err),
+			)
+			c.JSON(http.StatusInternalServerError, UpdateResponse{
+				Success: false,
+				Message: "更新代码信息失败",
+			})
+			return
+		}
+		zap.L().Debug("📝 code表更新成功",
+			zap.String("req_id", reqID),
+			zap.String("country_id", req.CountryID),
+		)
+	}
+
+	// 提交事务
+	if err := tx.Commit(); err != nil {
+		tx.Rollback()
+		zap.L().Error("❌ 事务提交失败",
+			zap.String("req_id", reqID),
+			zap.String("country_id", req.CountryID),
+			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("country_id", req.CountryID),
+		zap.Duration("duration", duration),
+	)
+
+	// 返回成功响应
+	c.JSON(http.StatusOK, UpdateResponse{
+		Success: true,
+		Message: "更新成功",
+	})
+}

backend/country/src/main.go

@@ -34,6 +34,10 @@ func main() {
 	// 注册创建国家的接口，POST请求，由logic.CreateHandler处理
 	r.POST("/country/create", logic.CreateHandler)
 	zap.L().Info("✅ 创建接口注册完成: POST /country/create")
+
+	// 注册更新国家的接口，POST请求，由logic.UpdateHandler
+	r.POST("/country/update", logic.UpdateHandler)
+	zap.L().Info("✅ 删除接口注册完成: POST /country/update")
 	
 	// 注册删除国家的接口，POST请求，由logic.DeleteHandler处理
 	r.POST("/country/delete", logic.DeleteHandler)

backend/提示词条.md

@@ -14,4 +14,13 @@
 3.1、把 country 中，country.id==req.country_id 的 deleted 字段更新为true。
 3.2、把 name 中，name.country_id==req.country_id 的 deleted 字段更新为true。
 3.3、把 code code.country_id==req.country_id 的 deleted 字段更新为true。
+---
+分析这个项目，在 update.go 中完成以下需求：
+
+1、接收 country_id,name，code 两个参数。
+2、确认提交的 country_id 参数有不能为空，如果为空，则返回提示。
+3、确认提交的 name，code 两个参数，必须有一个不能为空，如果都为空，则返回提示。
+4、如果 name 不为空，开启事务保存到 name 中。
+5、如果 code 不为空，开启事务保存到 code 中。
+6、如果 name，code 都不为空，开启事务保存到 name，code 中。
 ---