eaiadminandClaude Code
e8aedd50d2
「仓库层」是 repository 的直译，中文里与「代码仓库 / git 仓库」同词， 而这一层做的事就是数据访问。名字改成它实际在做的事。 改名口径（纯机械替换，无逻辑改动）： - 包：internal/repository → internal/dal（package repository → package dal） - 类型：XxxRepo → XxxDAO（TaskRecordDAO / SpecialistDAO / PositionDAO …） - 变量：xxxRepo → xxxDAO - import 路径、包限定符、日志前缀 [repository] → [dal] 同步 - 注释里的「仓库层」→「数据访问层」；core.go 包注释补上 DAL/DAO 全称 命名规范补登（AR09 是命名问题的最高依据，改了名就得回去登记）： - AR09 §3.1 术语表新增「数据访问层 dal / DAO」一行 - AR09 §5.6 缩写表新增 DAO / dal —— 原文是「只有下表内的缩写允许使用」， 不登记就是自己破自己的规矩 - PROJECT_STATE.md 新增 D27 记录本次更名决策 验证：全部在 db 副本上做，生产库 data/eai_agentplatform.db 未触碰。 - 等价性对照：拿 HEAD 源码 + 仅改名 造出第二棵树，两棵树各自起 httptest 服务跑同一份探针（60 个 GET + 13 个写/回读，覆盖专员/技能/应用/ 任务/交付物/项目/岗位/考试/知识/积分/管理端只读等），逐端点比对响应体： 73 项里 52 项字节完全一致、21 项仅运行期时间戳不同、内容差异 0。 - 探针非空：往改名后的树注入「SpecialistDAO.List 限 3 条」变异， /api/specialists 立刻被抓出 —— 证明上面那个 0 不是没测到。 - 暂存区自洽：把索引整个导出成源码树，go build / go vet / go test ./... 全绿。 - gofmt：因 import 排序变化而错位的 19 个文件已修；另 2 个文件（skill_definition.go、 seed.go）的格式问题是工作区里别人的在制品带来的，未替其改动。 未纳入本次提交：工作区里正在进行中的「文生语音技能 + 技能展示色/交互卡」 （tts_handlers.go、text_to_speech/manifest.go、skillCatalog.js 等）， 以及 router.go / skill_definition.go / seed.go 三个文件里属于该在制品的改动 —— 这三个文件只把「改名那一版」放进索引，工作区原样保留。 Co-Authored-By: Claude Code <noreply@anthropic.com>
120 lines
3.3 KiB
Go
120 lines
3.3 KiB
Go
package dal
|
||
|
||
import (
|
||
"eai_agentplatform/backend/internal/model"
|
||
)
|
||
|
||
// User 用户仓库。
|
||
type UserDAO struct{ *QueryBuilder }
|
||
|
||
// List 获取用户列表（分页）。
|
||
func (r UserDAO) List(page, pageSize int, role, status string) []model.User {
|
||
q := r.Type(&model.User{})
|
||
if role != "" {
|
||
q = q.Where("role = ?", role)
|
||
}
|
||
if status != "" {
|
||
q = q.Where("status = ?", status)
|
||
}
|
||
offset := (page - 1) * pageSize
|
||
var items []model.User
|
||
if q.Order("id ASC").Limit(pageSize).Offset(offset).Find(&items) {
|
||
return items
|
||
}
|
||
return nil
|
||
}
|
||
|
||
// Total 统计用户总数。
|
||
func (r UserDAO) Total(role, status string) int64 {
|
||
q := r.Inner().Model(&model.User{})
|
||
if role != "" {
|
||
q = q.Where("role = ?", role)
|
||
}
|
||
if status != "" {
|
||
q = q.Where("status = ?", status)
|
||
}
|
||
var c int64
|
||
q.Count(&c)
|
||
return c
|
||
}
|
||
|
||
// ListEmployees 取 role=employee 的用户（id 升序）。
|
||
//
|
||
// status 语义刻意写成显式档位，避免与列表接口的「空=active」约定混淆：
|
||
//
|
||
// "active" → 仅在职（部门成员数、部门学情统计用这份口径）
|
||
// "" → 不限状态（管理端全员视图，含已停用）
|
||
// 其它 → 按该状态过滤
|
||
func (r UserDAO) ListEmployees(status string) []model.User {
|
||
q := r.Type(&model.User{}).Where("role = ?", "employee")
|
||
if status != "" {
|
||
q = q.Where("status = ?", status)
|
||
}
|
||
var items []model.User
|
||
if q.Order("id ASC").Find(&items) {
|
||
return items
|
||
}
|
||
return nil
|
||
}
|
||
|
||
// CountActiveByDepartment 统计归属某部门的在职员工数（按 user.department 字符串匹配）。
|
||
func (r UserDAO) CountActiveByDepartment(name string) int64 {
|
||
var c int64
|
||
r.Inner().Model(&model.User{}).
|
||
Where("department = ? AND status = ?", name, "active").Count(&c)
|
||
return c
|
||
}
|
||
|
||
// RenameDepartment 部门改名后同步员工归属字符串。
|
||
//
|
||
// 部门是字典表、用户以字符串归属，改字典名必须回写 user.department，
|
||
// 否则按部门统计与展示会当场对不上。
|
||
// 用 Updates（而非 UpdateColumn）是为了让 GORM 照常带上 updated_at，
|
||
// 与原实现 `Model(&User{}).Where(...).Update("department", ...)` 的行为一致。
|
||
func (r UserDAO) RenameDepartment(oldName, newName string) bool {
|
||
return r.Type(&model.User{}).Where("department = ?", oldName).
|
||
Updates(map[string]any{"department": newName})
|
||
}
|
||
|
||
// GetByID 按 ID 获取。
|
||
func (r UserDAO) GetByID(id uint) (model.User, bool) {
|
||
var u model.User
|
||
if r.Type(&u).Where("id = ?", id).First(&u) {
|
||
return u, true
|
||
}
|
||
return model.User{}, false
|
||
}
|
||
|
||
// GetByUsername 按用户名获取。
|
||
func (r UserDAO) GetByUsername(username string) (model.User, bool) {
|
||
var u model.User
|
||
if r.Type(&u).Where("username = ?", username).First(&u) {
|
||
return u, true
|
||
}
|
||
return model.User{}, false
|
||
}
|
||
|
||
// GetByEmail 按邮箱获取。
|
||
func (r UserDAO) GetByEmail(email string) (model.User, bool) {
|
||
var u model.User
|
||
if r.Type(&u).Where("email = ?", email).First(&u) {
|
||
return u, true
|
||
}
|
||
return model.User{}, false
|
||
}
|
||
|
||
// Insert 创建用户。
|
||
func (r UserDAO) Insert(u *model.User) bool {
|
||
return r.QueryBuilder.Insert(u)
|
||
}
|
||
|
||
// Update 更新用户。
|
||
func (r UserDAO) Update(u *model.User) bool {
|
||
return r.Save(u)
|
||
}
|
||
|
||
// UpdateStatus 更新状态。
|
||
func (r UserDAO) UpdateStatus(id uint, status string) bool {
|
||
return r.Type(&model.User{}).Where("id = ?", id).UpdateColumn("status", status)
|
||
}
|