「仓库层」是 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>
100 lines
2.7 KiB
Go
100 lines
2.7 KiB
Go
package main
|
|
|
|
import (
|
|
"log"
|
|
"os"
|
|
"time"
|
|
|
|
"github.com/gin-gonic/gin"
|
|
|
|
"eai_agentplatform/backend/internal/api"
|
|
"eai_agentplatform/backend/internal/auth"
|
|
"eai_agentplatform/backend/internal/config"
|
|
"eai_agentplatform/backend/internal/dal"
|
|
"eai_agentplatform/backend/internal/model"
|
|
specialistseeding "eai_agentplatform/backend/internal/specialists/seeding"
|
|
"eai_agentplatform/backend/internal/store"
|
|
)
|
|
|
|
func main() {
|
|
// 交付维护子命令(不进服务主流程)
|
|
if len(os.Args) > 1 {
|
|
switch os.Args[1] {
|
|
case "-reset-admin":
|
|
resetAdmin(os.Args[2:])
|
|
return
|
|
case "-backup":
|
|
backupOnce()
|
|
return
|
|
}
|
|
}
|
|
|
|
cfg := config.Load()
|
|
|
|
db, err := store.Init(cfg.DBPath)
|
|
if err != nil {
|
|
log.Fatalf("数据库初始化失败: %v", err)
|
|
}
|
|
dal.SetDB(db)
|
|
if err := store.SeedDefaults(); err != nil {
|
|
log.Fatalf("种子数据初始化失败: %v", err)
|
|
}
|
|
if err := specialistseeding.SeedSpecialists(store.DB); err != nil {
|
|
log.Fatalf("专员目录种子初始化失败: %v", err)
|
|
}
|
|
|
|
config.StartAIRouteHealthLoop(30 * time.Minute)
|
|
|
|
// 定期备份:SQLite 是单文件且无外部副本,坏一份就是全丢。
|
|
// 失败只在日志里报,绝不因此拦下服务。
|
|
if cfg.BackupEnabled {
|
|
store.StartBackupLoop(store.DB, cfg.DBPath, cfg.BackupDir, cfg.BackupKeep, cfg.BackupIntervalHours)
|
|
}
|
|
|
|
r := gin.Default()
|
|
|
|
api.RegisterRoutes(r, cfg)
|
|
|
|
log.Printf("eai_agentplatform 后端启动,端口 :%s", cfg.Port)
|
|
if err := r.Run(":" + cfg.Port); err != nil {
|
|
log.Fatalf("启动失败: %v", err)
|
|
}
|
|
}
|
|
|
|
// backupOnce 手工备份一次后退出:eai_agentplatform-server -backup
|
|
// 用于升级/迁移/交付前留一份手边的副本,比等定期那份更让人放心。
|
|
func backupOnce() {
|
|
cfg := config.Load()
|
|
db, err := store.Init(cfg.DBPath)
|
|
if err != nil {
|
|
log.Fatalf("数据库初始化失败: %v", err)
|
|
}
|
|
dal.SetDB(db)
|
|
path, err := store.Backup(store.DB, cfg.BackupDir, cfg.BackupKeep, time.Now())
|
|
if err != nil {
|
|
log.Fatalf("备份失败: %v", err)
|
|
}
|
|
log.Printf("[OK] 已备份到 %s", path)
|
|
}
|
|
|
|
// resetAdmin 交付前重置管理员密码:eai_agentplatform-server -reset-admin <新密码>
|
|
func resetAdmin(args []string) {
|
|
if len(args) < 1 || args[0] == "" {
|
|
log.Fatal("用法: eai_agentplatform-server -reset-admin <新密码>")
|
|
}
|
|
cfg := config.Load()
|
|
db, err := store.Init(cfg.DBPath)
|
|
if err != nil {
|
|
log.Fatalf("数据库初始化失败: %v", err)
|
|
}
|
|
dal.SetDB(db)
|
|
hash, err := auth.HashPassword(args[0])
|
|
if err != nil {
|
|
log.Fatalf("密码加密失败: %v", err)
|
|
}
|
|
if err := store.DB.Model(&model.User{}).Where("username = ?", "admin").Update("password_hash", hash).Error; err != nil {
|
|
log.Fatalf("重置密码失败: %v", err)
|
|
}
|
|
log.Println("[OK] 管理员密码已重置")
|
|
}
|