feat: K8s集群拓扑图接入真实后端数据 — 分层可视化Cluster→Ingress→Service→Deployment→Node + http.ts类型修复

backend/internal/api/handlers/user.go

@@ -1,8 +1,10 @@
 package handlers
 
 import (
+	"fmt"
 	"net/http"
 	"strconv"
+	"strings"
 
 	"ezops/internal/api/middleware"
 	"ezops/internal/config"
@@ -597,3 +599,106 @@ func (h *UserHandler) DeleteUser(c *gin.Context) {
 		Message: "删除成功",
 	})
 }
+
+// BatchImportUsers 批量导入用户
+// POST /api/v1/admin/users/batch-import
+func (h *UserHandler) BatchImportUsers(c *gin.Context) {
+	var req struct {
+		Users []struct {
+			Username string `json:"username"`
+			Nickname string `json:"nickname"`
+			Email    string `json:"email"`
+			Phone    string `json:"phone"`
+			Password string `json:"password"`
+			Role     string `json:"role"`
+		} `json:"users"`
+		SkipExisting bool `json:"skip_existing"`
+	}
+	if err := c.ShouldBindJSON(&req); err != nil {
+		c.JSON(http.StatusBadRequest, models.Response{
+			Code:    400,
+			Message: "请求参数错误: " + err.Error(),
+		})
+		return
+	}
+
+	imported := 0
+	skipped := 0
+	var errors []string
+
+	for i, u := range req.Users {
+		if u.Username == "" {
+			errors = append(errors, fmt.Sprintf("第%d行: 用户名为空", i+1))
+			continue
+		}
+		// Check if exists
+		var existing models.User
+		if err := h.db.Where("username = ?", u.Username).First(&existing).Error; err == nil {
+			if req.SkipExisting {
+				skipped++
+				continue
+			}
+			errors = append(errors, fmt.Sprintf("第%d行: 用户 %s 已存在", i+1, u.Username))
+			skipped++
+			continue
+		}
+
+		// Default password
+		pwd := u.Password
+		if pwd == "" {
+			pwd = "admin123"
+		}
+		hashed, err := bcrypt.GenerateFromPassword([]byte(pwd), bcrypt.DefaultCost)
+		if err != nil {
+			errors = append(errors, fmt.Sprintf("第%d行: 密码加密失败", i+1))
+			continue
+		}
+
+		user := models.User{
+			Username:   u.Username,
+			Password:   string(hashed),
+			Email:      u.Email,
+			Phone:      u.Phone,
+			RealName:   u.Nickname,
+			Status:     1,
+			AuthSource: "local",
+		}
+		if err := h.db.Create(&user).Error; err != nil {
+			errors = append(errors, fmt.Sprintf("第%d行: 创建用户 %s 失败", i+1, u.Username))
+			continue
+		}
+		imported++
+	}
+
+	msg := fmt.Sprintf("导入完成: %d 成功, %d 跳过", imported, skipped)
+	if len(errors) > 0 {
+		msg += fmt.Sprintf(", %d 个错误", len(errors))
+	}
+
+	c.JSON(http.StatusOK, models.Response{
+		Code:    200,
+		Message: msg,
+		Data: gin.H{
+			"imported": imported,
+			"skipped":  skipped,
+			"errors":   errors,
+		},
+	})
+}
+
+// ImportTemplate 下载用户导入模板
+// GET /api/v1/admin/users/import-template
+func (h *UserHandler) ImportTemplate(c *gin.Context) {
+	// UTF-8 BOM for Excel compatibility
+	bom := "\xEF\xBB\xBF"
+	csv := bom + "用户名,昵称,邮箱,手机号,角色,密码\n"
+	csv += "zhangsan,张三,zhangsan@example.com,13800138000,developer,123456\n"
+	csv += "lisi,李四,lisi@example.com,13800138001,developer,123456\n"
+
+	c.Header("Content-Type", "text/csv; charset=utf-8")
+	c.Header("Content-Disposition", "attachment; filename=users_import_template.csv")
+	c.String(http.StatusOK, csv)
+}
+
+// ensure strings import is used
+var _ = strings.TrimSpace