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-11 17:52:32 +08:00
parent aad37217f4
commit 97d260c256
1 changed files with 14 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

28
backend/country/src/logic/create.go
View File

@@ -4,7 +4,7 @@ import (
"net/http" "net/http"
"country/db" "country/db"
"time" "time"
"github.com/google/uuid" // 补充uuid导入（原代码使用但未显示导入） "github.com/google/uuid"
"github.com/gin-gonic/gin" "github.com/gin-gonic/gin"
"go.uber.org/zap" "go.uber.org/zap"
) )
@@ -33,11 +33,11 @@ func CreateHandler(c *gin.Context) {
reqID := c.Request.Header.Get("X-RegisterRequest-ID") reqID := c.Request.Header.Get("X-RegisterRequest-ID")
if reqID == "" { if reqID == "" {
reqID = uuid.New().String() reqID = uuid.New().String()
zap.L().Debug("生成新的请求ID", zap.String("req_id", reqID)) zap.L().Debug("✨ 生成新的请求ID", zap.String("req_id", reqID))
} }
// 标准化日志字段，增加请求路径和方法 // 标准化日志字段，增加请求路径和方法
zap.L().Info("收到国家创建请求", zap.L().Info("📥 收到国家创建请求",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.String("path", c.Request.URL.Path), zap.String("path", c.Request.URL.Path),
zap.String("method", c.Request.Method), zap.String("method", c.Request.Method),
@@ -46,7 +46,7 @@ func CreateHandler(c *gin.Context) {
var req CreateRequest var req CreateRequest
// 绑定并验证请求参数 // 绑定并验证请求参数
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),
zap.Error(err), zap.Error(err),
zap.Any("request_body", c.Request.Body), zap.Any("request_body", c.Request.Body),
@@ -59,7 +59,7 @@ func CreateHandler(c *gin.Context) {
} }
// 记录有效请求参数（敏感信息需脱敏，此处假设name和code非敏感） // 记录有效请求参数（敏感信息需脱敏，此处假设name和code非敏感）
zap.L().Debug("请求参数验证通过", zap.L().Debug("✅ 请求参数验证通过",
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),
@@ -68,7 +68,7 @@ func CreateHandler(c *gin.Context) {
// 开启事务（将事务提前，确保country表插入也在事务中） // 开启事务（将事务提前，确保country表插入也在事务中）
tx, err := db.DB.Begin() tx, err := db.DB.Begin()
if err != nil { if err != nil {
zap.L().Error("事务开启失败", zap.L().Error("❌ 事务开启失败",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.Error(err), zap.Error(err),
) )
@@ -82,12 +82,12 @@ func CreateHandler(c *gin.Context) {
// 发生panic时回滚事务 // 发生panic时回滚事务
if r := recover(); r != nil { if r := recover(); r != nil {
if err := tx.Rollback(); err != nil { if err := tx.Rollback(); err != nil {
zap.L().Error("panic后事务回滚失败", zap.L().Error("💥 panic后事务回滚失败",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.Error(err), zap.Error(err),
) )
} }
zap.L().Error("事务处理发生panic", zap.L().Error("💥 事务处理发生panic",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.Any("recover", r), zap.Any("recover", r),
) )
@@ -103,7 +103,7 @@ func CreateHandler(c *gin.Context) {
err = tx.QueryRow("INSERT INTO \"country\" DEFAULT VALUES RETURNING id").Scan(&countryID) err = tx.QueryRow("INSERT INTO \"country\" DEFAULT VALUES RETURNING id").Scan(&countryID)
if err != nil { if err != nil {
tx.Rollback() tx.Rollback()
zap.L().Error("country表插入失败", zap.L().Error("❌ country表插入失败",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.Error(err), zap.Error(err),
) )
@@ -114,7 +114,7 @@ func CreateHandler(c *gin.Context) {
return return
} }
zap.L().Debug("country表插入成功", zap.L().Debug("📝 country表插入成功",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.String("country_id", countryID), zap.String("country_id", countryID),
) )
@@ -123,7 +123,7 @@ func CreateHandler(c *gin.Context) {
_, err = tx.Exec("INSERT INTO name (country_id, name) VALUES ($1, $2)", countryID, req.Name) _, err = tx.Exec("INSERT INTO name (country_id, name) VALUES ($1, $2)", countryID, req.Name)
if err != nil { if err != nil {
tx.Rollback() tx.Rollback()
zap.L().Error("name表插入失败", zap.L().Error("❌ name表插入失败",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.String("country_id", countryID), zap.String("country_id", countryID),
zap.Error(err), zap.Error(err),
@@ -139,7 +139,7 @@ func CreateHandler(c *gin.Context) {
_, err = tx.Exec("INSERT INTO code (country_id, code) VALUES ($1, $2)", countryID, req.Code) _, err = tx.Exec("INSERT INTO code (country_id, code) VALUES ($1, $2)", countryID, req.Code)
if err != nil { if err != nil {
tx.Rollback() tx.Rollback()
zap.L().Error("code表插入失败", zap.L().Error("❌ code表插入失败",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.String("country_id", countryID), zap.String("country_id", countryID),
zap.Error(err), zap.Error(err),
@@ -154,7 +154,7 @@ func CreateHandler(c *gin.Context) {
// 提交事务 // 提交事务
if err := tx.Commit(); err != nil { if err := tx.Commit(); err != nil {
tx.Rollback() // 尝试回滚提交失败的事务 tx.Rollback() // 尝试回滚提交失败的事务
zap.L().Error("事务提交失败", zap.L().Error("❌ 事务提交失败",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.String("country_id", countryID), zap.String("country_id", countryID),
zap.Error(err), zap.Error(err),
@@ -168,7 +168,7 @@ func CreateHandler(c *gin.Context) {
// 记录请求处理耗时 // 记录请求处理耗时
duration := time.Since(startTime) duration := time.Since(startTime)
zap.L().Info("国家创建请求处理完成", zap.L().Info("✅ 国家创建请求处理完成",
zap.String("req_id", reqID), zap.String("req_id", reqID),
zap.String("country_id", countryID), zap.String("country_id", countryID),
zap.Duration("duration", duration), zap.Duration("duration", duration),