add

frontend/asset_assistant/lib/pages/country_add_page.dart

@@ -14,7 +14,7 @@ class _AddCountryPageState extends State<AddCountryPage> {
   // 输入控制器 - 新增国旗控制器
   final TextEditingController _nameController = TextEditingController();
   final TextEditingController _codeController = TextEditingController();
-  final TextEditingController _flagController = TextEditingController(); // 新增
+  final TextEditingController _flagController = TextEditingController();
 
   // 加载状态
   bool _isLoading = false;

frontend/asset_assistant/lib/pages/create.go

@@ -1,205 +0,0 @@
-package logic4country
-
-import (
-	"asset_assistant/db"
-	"net/http"
-	"time"
-
-	"github.com/gin-gonic/gin"
-	"github.com/google/uuid"
-	"go.uber.org/zap"
-)
-
-// CreateRequest 注册请求参数结构
-type CreateRequest struct {
-	Name string `json:"name" binding:"required"` // 国家名称，必填
-	Code string `json:"code" binding:"required"` // 国家代码，必填
-	Flag string `json:"flag"`                    // 国旗信息，可选
-}
-
-// CreateResponse 注册响应结构
-type CreateResponse struct {
-	Success bool       `json:"success"`
-	Message string     `json:"message"`
-	Data    CreateData `json:"data"`
-}
-
-// CreateData 响应数据结构
-type CreateData struct {
-	CountryID string `json:"country_id"`
-}
-
-// CreateHandler 处理国家创建逻辑
-func CreateHandler(c *gin.Context) {
-	startTime := time.Now()
-	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
-	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),
-		zap.String("flag", req.Flag), // 新增国旗参数日志
-	)
-
-	// 开启数据库事务
-	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
-	}
-
-	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, CreateResponse{
-				Success: false,
-				Message: "系统错误，请稍后重试",
-			})
-		}
-	}()
-
-	// 1. 创建country主表记录
-	var countryID string
-	err = tx.QueryRow("INSERT INTO country DEFAULT VALUES RETURNING id").Scan(&countryID)
-	if err != nil {
-		tx.Rollback()
-		zap.L().Error("❌ country表插入失败",
-			zap.String("req_id", reqID),
-			zap.Error(err),
-		)
-		c.JSON(http.StatusInternalServerError, CreateResponse{
-			Success: false,
-			Message: "创建国家记录失败",
-		})
-		return
-	}
-
-	zap.L().Debug("📝 country表插入成功",
-		zap.String("req_id", reqID),
-		zap.String("country_id", countryID),
-	)
-
-	// 2. 插入国家名称
-	_, err = tx.Exec("INSERT INTO country_name (country_id, name) VALUES ($1, $2)", countryID, req.Name)
-	if err != nil {
-		tx.Rollback()
-		zap.L().Error("❌ country_name表插入失败",
-			zap.String("req_id", reqID),
-			zap.String("country_id", countryID),
-			zap.Error(err),
-		)
-		c.JSON(http.StatusInternalServerError, CreateResponse{
-			Success: false,
-			Message: "保存名称信息失败",
-		})
-		return
-	}
-
-	// 3. 插入国家代码
-	_, err = tx.Exec("INSERT INTO country_code (country_id, code) VALUES ($1, $2)", countryID, req.Code)
-	if err != nil {
-		tx.Rollback()
-		zap.L().Error("❌ country_code表插入失败",
-			zap.String("req_id", reqID),
-			zap.String("country_id", countryID),
-			zap.Error(err),
-		)
-		c.JSON(http.StatusInternalServerError, CreateResponse{
-			Success: false,
-			Message: "保存代码信息失败",
-		})
-		return
-	}
-
-	// 4. 新增：插入国旗信息（如果提供）
-	if req.Flag != "" {
-		_, err = tx.Exec("INSERT INTO country_flag (country_id, flag) VALUES ($1, $2)", countryID, req.Flag)
-		if err != nil {
-			tx.Rollback()
-			zap.L().Error("❌ country_flag表插入失败",
-				zap.String("req_id", reqID),
-				zap.String("country_id", countryID),
-				zap.Error(err),
-			)
-			c.JSON(http.StatusInternalServerError, CreateResponse{
-				Success: false,
-				Message: "保存国旗信息失败",
-			})
-			return
-		}
-		zap.L().Debug("📝 country_flag表插入成功",
-			zap.String("req_id", reqID),
-			zap.String("country_id", countryID),
-		)
-	}
-
-	// 提交事务
-	if err := tx.Commit(); err != nil {
-		tx.Rollback()
-		zap.L().Error("❌ 事务提交失败",
-			zap.String("req_id", reqID),
-			zap.String("country_id", countryID),
-			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("country_id", countryID),
-		zap.Duration("duration", duration),
-	)
-
-	c.JSON(http.StatusOK, CreateResponse{
-		Success: true,
-		Message: "创建成功",
-		Data: CreateData{
-			CountryID: countryID,
-		},
-	})
-}