diff --git a/backend/country/src/logic/update.go b/backend/country/src/logic/update.go new file mode 100644 index 0000000..51dc9d7 --- /dev/null +++ b/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: "更新成功", + }) +} \ No newline at end of file diff --git a/backend/country/src/main.go b/backend/country/src/main.go index 91f068b..e4fba60 100644 --- a/backend/country/src/main.go +++ b/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) diff --git a/backend/提示词条.md b/backend/提示词条.md index ebbb53e..64fdb38 100644 --- a/backend/提示词条.md +++ b/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 中。 --- \ No newline at end of file