pkg/controller/admin/config/sso.go (4)

24-27: Swagger 返回类型与实际响应不一致

List 实际返回的是 total + items 的列表结构，而注释写成了 string。这会导致前端／生成的 OpenAPI schema 误解返回格式。请改为指向真实响应结构，例如：

-// @Success 200 {object} string
+// @Success 200 {object} amis.ListResponse "包含 total 与 items 字段"

---

40-43: Save 接口文档同样需修正返回体

Save 实际返回 {"id": <int>}，建议在 Swagger 中声明具体字段，避免默认成未知字符串。

-// @Success 200 {object} string
+// @Success 200 {object} map[string]int "返回创建/更新后的主键 ID"

---

65-69: Delete 接口的返回描述不准确

当前注释仍为 string，但实现里调用 WriteJsonOK，返回的是统一 OK 结构体。保持一致性更易读。

-// @Success 200 {object} string
+// @Success 200 {object} amis.OKResponse

---

83-88: QuickSave 接口的 HTTP Method 与语义

快速切换启用状态属于部分更新，推荐使用 PATCH 或在注释里说明理由；此外 @Success 类型同样需修正，避免 Swagger 生成无用 schema。

pkg/controller/admin/config/config.go (2)

19-22: All 接口返回体注释应为系统配置结构

实际返回 models.Config，请在注释中指明：

-// @Success 200 {object} string
+// @Success 200 {object} models.Config

---

32-36: Update 接口成功响应应体现统一 OK 结构

目前实现 WriteJsonOK，建议 Swagger 使用统一结构体而非 string。

pkg/controller/admin/inspection/record.go (1)

49-54: Push 接口返回体注释需与实现统一

返回的是标准 OK 结构，注释应更新；同时可添加错误场景描述，提升文档完整度。

pkg/controller/admin/cluster/kubeconfig.go (2)

15-19: SaveKubeConfig 的成功响应类型不明确

建议将 string 改为统一 OK 结构，或声明实际字段，便于前端生成类型。

---

83-87: RemoveKubeConfig 的返回类型同上，需要保持一致

与 SaveKubeConfig 一致，保持统一 OK 响应结构。

pkg/controller/admin/config/condition.go (4)

22-25: List 接口返回体应为列表结构而非 string

同样问题，建议改为 amis.ListResponse 或自定义响应体。

---

38-41: Save 接口文档需指明返回字段

返回 {"id": <int>}，应体现在 Swagger，否则前端难以解析。

---

61-65: Delete 接口返回类型需统一

请将 string 改为统一 OK 结构，保持与实现一致。

---

79-84: QuickSave 路由命名与 HTTP Method 语义

快速启停状态属于部分更新，可考虑使用 PATCH；同时 @Success 描述需修正。

swagger/swagger.json (1)

1320-1374: 敏感字段直接暴露在模型定义中，需确认最小权限原则

models.User 定义中包含 password, salt, two_fa_secret 等高敏感字段。虽然仅管理员可调用相关接口，但在 Swagger 文档中公开这些字段会放大泄漏风险，也可能误导前端直接传输明文密码/密钥。建议：

• 对外只暴露必要的可写字段（如 password 使用单独 DTO）。
• 对只读字段设定 readOnly: true，避免出现在请求示例中。
• 对绝不应返回的字段（salt、secret）从响应模型中移除或打 writeOnly: true。

遵循最小暴露原则提高整体安全性。

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

swagger/docs.go (1)

850-857: 与 YAML 文件存在相同的参数定义问题。

此处的 script_codes 参数定义与 swagger.yaml 中的问题一致，应该定义为对象类型而不是简单字符串。由于这是生成文件，需要在源码的 Swagger 注释中修正。

这个问题与 swagger.yaml 文件中 line 585-606 的问题相同。

swagger/swagger.json (3)

153-171: 接口缺少定位删除目标的参数

/admin/cluster/kubeconfig/remove 仍未声明任何 path、query 或 body 参数来标识要删除的 KubeConfig 记录，调用方无法指定目标记录，Swagger 校验也会报 missing required parameters。请补充参数定义，示例（任选其一）：

   "parameters": [
+    {
+      "name": "ids",
+      "in": "path",
+      "description": "KubeConfig 记录 ID，多个用逗号分隔",
+      "required": true,
+      "type": "string"
+    }
+  ],

或改为 body 方式批量删除。
与之前 review 建议一致，问题仍未修复。

---

172-190: 保存接口缺少请求体定义，Swagger 无法生成示例

/admin/cluster/kubeconfig/save 为新增 / 更新接口，应至少包含 KubeConfig 内容、名称等字段的 body 参数，但目前完全缺失，导致自动化客户端无法正确生成。建议：

   "consumes": ["application/json"],
   "parameters": [
+    {
+      "in": "body",
+      "name": "data",
+      "description": "KubeConfig 文件内容及元数据",
+      "required": true,
+      "schema": {
+        "type": "object",
+        "properties": {
+          "name":   { "type": "string" },
+          "content":{ "type": "string" }
+        },
+        "required": ["name","content"]
+      }
+    }
   ],

---

762-778: 路径与参数不匹配，OpenAPI 校验会失败

/admin/inspection/record/list 声明了 id 且 in: "path"，但路径并未包含 {id} 占位符。两种修正方式：

1. 若按计划 ID 过滤：改为 "/admin/inspection/record/{id}/list"；
2. 若无需 ID：删除该参数或改为 in: "query"。

此问题与之前 review 相同，依旧存在。

pkg/controller/admin/inspection/schedule.go (1)

280-285: 建议完善请求体参数文档。

虽然代码中定义了 requestBody 结构体，但 Swagger 注释中的 @Param script_codes body string 可以更详细地描述请求体的结构。

考虑使用更具体的参数定义：

-// @Param script_codes body string true "脚本代码"
+// @Param script_codes body object true "脚本代码" schema({script_codes:string})

swagger/swagger.json (2)

210-265: Base64 集群 ID 类型说明建议补充格式

/admin/cluster/{cluster}/disconnect 与 reconnect 已使用 string 类型，但最好在描述中说明格式示例（如 Y2x1c3RlcjE=），便于前端校验；亦可使用 pattern 字段约束 Base64。

---

1488-1550: 时间字段未指定 format: date-time

models.Config 中 created_at、updated_at 字段声明为 string，缺少 format: date-time，Swagger UI 会按普通字符串展示。建议：

- "type": "string"
+ "type": "string",
+ "format": "date-time"

同理可应用到 models.User、models.UserGroup 的时间字段。

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

swagger/swagger.json (1)

89-105: /admin/ai/model/save 缺少请求体定义

创建 / 更新模型配置需要明确字段（名称、类型、地址等）。当前未声明任何 body 参数，Swagger UI 无法生成示例。

"consumes": [
+  "application/json"
],
"parameters": [
+  {
+    "in": "body",
+    "name": "data",
+    "description": "AI 模型配置",
+    "required": true,
+    "schema": {
+      "type": "object",
+      "properties": {
+        "name": { "type": "string" },
+        "endpoint": { "type": "string" },
+        "token": { "type": "string" }
+      },
+      "required": ["name", "endpoint"]
+    }
+  }
]

swagger/swagger.yaml (1)

613-634: 脚本代码更新接口的请求体定义仍需修正

该接口的请求体定义存在与之前评审中相同的问题。当前将 script_codes 定义为简单的 string 类型，但根据控制器代码的实际需求，应该是包含 script_codes 字段的JSON对象。

请参考之前的评审建议修正请求体定义，确保Swagger文档与实际的控制器实现保持一致。

swagger/swagger.json (4)

153-171: /admin/cluster/kubeconfig/remove 仍缺少用于定位删除目标的参数

路径无 {id} 占位符，也未声明 body/formData，导致调用方无法指定要删除的记录。请补充参数定义或改为在路径中携带 ids。

---

172-190: /admin/cluster/kubeconfig/save 缺少请求体定义

作为保存接口，至少应声明包含 kubeconfig 内容与元数据的 body 参数，并声明 consumes: ["application/json"]。

---

762-778: 路径与参数不匹配

/admin/inspection/record/list 声明了 id 且 in: path，但路径本身无 {id}。须二选一：

1. 修改路径 .../record/{id}/list 并保留 path 参数；
2. 将参数改为 query 或直接删除。

---

1025-1041: /admin/inspection/schedule/save 缺少请求体

保存巡检计划应包含周期、脚本等字段，请补充 body schema，并声明 consumes: ["application/json"]。

pkg/controller/admin/user/user.go (1)

257-283: 用户状态快速更新接口需要改进错误处理

该接口实现了用户状态的快速切换功能，但存在一些可以改进的地方：

1. 布尔值转换逻辑过于简单，只检查 "true"，其他所有值都视为 false
2. 最后的错误处理调用了 amis.WriteJsonErrorOrOK(c, err)，但实际上 err 永远不会是 nil（因为前面已经处理了错误情况）

建议改进实现：

func (a *AdminUserController) UserStatusQuickSave(c *gin.Context) {
	id := c.Param("id")
	disabled := c.Param("disabled")

	var entity models.User
	entity.ID = utils.ToUInt(id)

-	if disabled == "true" {
-		entity.Disabled = true
-	} else {
-		entity.Disabled = false
-	}
+	// 更严格的布尔值解析
+	switch strings.ToLower(disabled) {
+	case "true", "1", "yes":
+		entity.Disabled = true
+	case "false", "0", "no":
+		entity.Disabled = false
+	default:
+		amis.WriteJsonError(c, fmt.Errorf("无效的状态值: %s", disabled))
+		return
+	}
+	
	err := dao.DB().Model(&entity).Select("disabled").Updates(entity).Error

	if err != nil {
		amis.WriteJsonError(c, err)
		return
	}
-	amis.WriteJsonErrorOrOK(c, err)
+	amis.WriteJsonOK(c)
}

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

pkg/controller/dynamic/pod_link.go (1)

458-476: 缺少 Swagger 文档注释

LinksPod 方法缺少 Swagger 文档注释，而文件中其他所有方法都有完整的 Swagger 注释。为保持一致性，应该添加相应的文档注释。

为 LinksPod 方法添加 Swagger 注释：

+// @Summary 获取Pod关联的Pod列表
+// @Security BearerAuth
+// @Param cluster query string true "集群名称"
+// @Param kind path string true "资源类型"
+// @Param group path string true "API组"
+// @Param version path string true "API版本"
+// @Param ns path string true "命名空间"
+// @Param name path string true "资源名称"
+// @Success 200 {object} string
+// @Router /k8s/cluster/{cluster}/{kind}/group/{group}/version/{version}/ns/{ns}/name/{name}/links/pod [get]
 func (pc *PodLinkController) LinksPod(c *gin.Context) {

pkg/controller/deploy/deploy.go (4)

64-80: 改进批量操作的错误处理机制

当前实现在批量操作中如果遇到错误会继续处理其他部署，但只返回最后遇到的错误，这可能会掩盖之前的错误信息。

建议收集所有错误信息：

-	for i := 0; i < len(req.Names); i++ {
-		name := req.Names[i]
-		ns := req.Namespaces[i]
-		x := kom.Cluster(selectedCluster).WithContext(ctx).Resource(&v1.Deployment{}).Namespace(ns).Name(name).
-			Ctl().Scaler().Stop()
-		if x != nil {
-			klog.V(6).Infof("批量停止 deploy 错误 %s/%s %v", ns, name, x)
-
-			err = x
-		}
-	}
-
-	if err != nil {
-		amis.WriteJsonError(c, err)
-		return
-	}
+	var errors []string
+	for i := 0; i < len(req.Names); i++ {
+		name := req.Names[i]
+		ns := req.Namespaces[i]
+		x := kom.Cluster(selectedCluster).WithContext(ctx).Resource(&v1.Deployment{}).Namespace(ns).Name(name).
+			Ctl().Scaler().Stop()
+		if x != nil {
+			klog.V(6).Infof("批量停止 deploy 错误 %s/%s %v", ns, name, x)
+			errors = append(errors, fmt.Sprintf("%s/%s: %v", ns, name, x))
+		}
+	}
+
+	if len(errors) > 0 {
+		amis.WriteJsonError(c, fmt.Errorf("批量操作失败: %s", strings.Join(errors, "; ")))
+		return
+	}

---

55-66: 添加数组长度验证防止运行时异常

批量操作假设 name_list 和 ns_list 数组长度相同，但没有进行验证。如果数组长度不匹配会导致运行时异常。

在所有批量操作中添加长度验证：

 	var req struct {
 		Names      []string `json:"name_list"`
 		Namespaces []string `json:"ns_list"`
 	}
 	if err = c.ShouldBindJSON(&req); err != nil {
 		amis.WriteJsonError(c, err)
 		return
 	}
+
+	if len(req.Names) != len(req.Namespaces) {
+		amis.WriteJsonError(c, fmt.Errorf("name_list 和 ns_list 长度必须相同"))
+		return
+	}

---

253-266: 改进版本比较的错误处理和可读性

当前实现没有处理找不到指定版本的情况，且忽略了 YAML 转换的错误。

 	var rsVersion *v1.ReplicaSet
 	for _, r := range rsList {
 		if r.ObjectMeta.Annotations != nil && r.ObjectMeta.Annotations[deployment.RevisionAnnotation] == revision {
 			rsVersion = r
 			break
 		}
 	}
+
+	if rsVersion == nil {
+		amis.WriteJsonError(c, fmt.Errorf("未找到版本 %s 的 ReplicaSet", revision))
+		return
+	}

-	current, _ := yaml.JSONToYAML([]byte(utils.ToJSON(rsVersion)))
-	latest, _ := yaml.JSONToYAML([]byte(utils.ToJSON(rsLatest)))
+	currentYAML, err := yaml.JSONToYAML([]byte(utils.ToJSON(rsVersion)))
+	if err != nil {
+		amis.WriteJsonError(c, fmt.Errorf("转换当前版本为 YAML 失败: %v", err))
+		return
+	}
+	latestYAML, err := yaml.JSONToYAML([]byte(utils.ToJSON(rsLatest)))
+	if err != nil {
+		amis.WriteJsonError(c, fmt.Errorf("转换最新版本为 YAML 失败: %v", err))
+		return
+	}
 	amis.WriteJsonData(c, gin.H{
-		"current": string(current),
-		"latest":  string(latest),
+		"current": string(currentYAML),
+		"latest":  string(latestYAML),
 	})

---

480-540: 简化请求结构并添加字段验证

当前的嵌套结构过于复杂，且缺少必要的字段验证。硬编码的标签值可能不适用于所有场景。

建议简化结构并添加验证：

 	var req struct {
-		Metadata struct {
-			Namespace   string            `json:"namespace"`
-			Name        string            `json:"name"`
-			Labels      map[string]string `json:"labels,omitempty"`
-			Annotations map[string]string `json:"annotations,omitempty"`
-		}
-		Spec struct {
-			Replicas int32 `json:"replicas"`
-			Template struct {
-				Spec struct {
-					Containers []struct {
-						Name            string            `json:"name"`
-						Image           string            `json:"image"`
-						ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy"`
-					} `json:"containers"`
-				} `json:"spec"`
-			} `json:"template"`
-		}
+		Namespace   string            `json:"namespace" binding:"required"`
+		Name        string            `json:"name" binding:"required"`
+		Labels      map[string]string `json:"labels,omitempty"`
+		Annotations map[string]string `json:"annotations,omitempty"`
+		Replicas    int32            `json:"replicas" binding:"min=1"`
+		Containers  []struct {
+			Name            string            `json:"name" binding:"required"`
+			Image           string            `json:"image" binding:"required"`
+			ImagePullPolicy corev1.PullPolicy `json:"imagePullPolicy"`
+		} `json:"containers" binding:"required,min=1"`
 	}

同时，避免硬编码版本标签：

-				Labels: map[string]string{
-					"app":     req.Metadata.Name,
-					"version": "v1",
-				},
+				Labels: map[string]string{
+					"app": req.Name,
+				},

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro

pkg/controller/rs/rs.go (3)

74-84: 批量操作的错误处理可能导致部分失败被掩盖

在批量重启逻辑中，如果某个 ReplicaSet 重启失败，错误会被覆盖而不是累积。这可能导致只报告最后一个错误，而掩盖了前面的失败。

建议改进错误处理逻辑：

+	var errors []string
	for i := 0; i < len(req.Names); i++ {
		name := req.Names[i]
		ns := req.Namespaces[i]

		x := kom.Cluster(selectedCluster).WithContext(ctx).Resource(&v1.ReplicaSet{}).Namespace(ns).Name(name).
			Ctl().Rollout().Restart()
		if x != nil {
			klog.V(6).Infof("批量重启 rs 错误 %s/%s %v", ns, name, x)
-			err = x
+			errors = append(errors, fmt.Sprintf("%s/%s: %v", ns, name, x))
		}
	}

-	if err != nil {
-		amis.WriteJsonError(c, err)
+	if len(errors) > 0 {
+		amis.WriteJsonError(c, fmt.Errorf("批量操作失败: %s", strings.Join(errors, "; ")))
		return
	}

---

117-127: 批量停止和恢复操作存在相同的错误处理问题

BatchStop 和 BatchRestore 方法中的错误处理逻辑与 BatchRestart 存在相同问题，建议应用相同的修复方案。

Also applies to: 160-170

---

210-212: Event 方法中的资源类型不匹配

在获取 Pod 列表时使用了错误的资源类型 &v1.Deployment{}，应该使用 &v1.Pod{}。

-	pods, err := kom.Cluster(selectedCluster).WithContext(ctx).Resource(&v1.Deployment{}).
+	pods, err := kom.Cluster(selectedCluster).WithContext(ctx).Resource(&v1.Pod{}).
		Namespace(ns).Name(name).
		Ctl().ReplicaSet().ManagedPods()

pkg/controller/pod/pod_forward.go (1)

220-244: 随机端口分配算法可能导致无限循环

在端口范围耗尽的情况下，getRandomPort 函数可能会陷入无限循环。

建议添加重试次数限制：

func getRandomPort() string {
+	maxRetries := 100
+	for retry := 0; retry < maxRetries; retry++ {
-	for {
		port := utils.RandInt(40000, 49999)
		portStr := fmt.Sprintf("%d", port)

		portForwardTableMutex.RLock()
		isUsed := false
		for _, portInfo := range portForwardTable {
			if portInfo.LocalPort == portStr {
				isUsed = true
				break
			}
		}
		portForwardTableMutex.RUnlock()

		if !isUsed {
			return portStr
		}
	}
+	// 如果所有重试都失败，返回错误或使用固定端口
+	return "0" // 让系统自动分配
}

pkg/controller/pod/pod_forward.go (1)

148-152: 停止端口转发时可能出现阻塞

直接向 channel 发送信号可能会阻塞，如果接收方没有准备好接收。

建议使用非阻塞发送或关闭 channel：

	if pf, ok := portForwardTable[key]; ok {
-		pf.StopCh <- struct{}{}
+		close(pf.StopCh)
		pf.Status = "stopped"
		pf.LocalPort = ""
	}

Configuration used: CodeRabbit UI
Review profile: CHILL
Plan: Pro