main.go 24 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586
  1. package main
  2. import (
  3. "context"
  4. "log"
  5. "os"
  6. "path/filepath"
  7. "strconv"
  8. "strings"
  9. "time"
  10. "github.com/2930134478/AI-CS/backend/controller"
  11. "github.com/2930134478/AI-CS/backend/infra"
  12. "github.com/2930134478/AI-CS/backend/infra/geoip"
  13. "github.com/2930134478/AI-CS/backend/infra/mcp"
  14. infra_search "github.com/2930134478/AI-CS/backend/infra/search"
  15. "github.com/2930134478/AI-CS/backend/middleware"
  16. "github.com/2930134478/AI-CS/backend/models"
  17. "github.com/2930134478/AI-CS/backend/repository"
  18. appRouter "github.com/2930134478/AI-CS/backend/router"
  19. "github.com/2930134478/AI-CS/backend/service"
  20. "github.com/2930134478/AI-CS/backend/service/embedding"
  21. "github.com/2930134478/AI-CS/backend/service/rag"
  22. "github.com/2930134478/AI-CS/backend/websocket"
  23. "github.com/gin-gonic/gin"
  24. "github.com/joho/godotenv"
  25. milvus "github.com/milvus-io/milvus-sdk-go/v2/client"
  26. "golang.org/x/crypto/bcrypt"
  27. )
  28. // 初始化默认管理员账号(如果不存在)
  29. // 用户名从环境变量 ADMIN_USERNAME 读取(默认:admin)
  30. // 密码从环境变量 ADMIN_PASSWORD 读取(必须设置)
  31. func initDefaultAdmin(userRepo *repository.UserRepository) {
  32. // 从环境变量读取管理员用户名和密码
  33. adminUsername := os.Getenv("ADMIN_USERNAME")
  34. if adminUsername == "" {
  35. adminUsername = "admin" // 默认用户名
  36. }
  37. adminPassword := os.Getenv("ADMIN_PASSWORD")
  38. if adminPassword == "" {
  39. log.Println("⚠️ 警告:未设置 ADMIN_PASSWORD 环境变量,跳过创建默认管理员账号")
  40. log.Println(" 请在 .env 文件中设置 ADMIN_PASSWORD 后重启服务")
  41. return
  42. }
  43. // 检查管理员账号是否已存在
  44. if _, err := userRepo.FindByUsername(adminUsername); err == nil {
  45. log.Printf("✅ 管理员账号 '%s' 已存在", adminUsername)
  46. return
  47. }
  48. // 加密密码
  49. hash, err := bcrypt.GenerateFromPassword([]byte(adminPassword), bcrypt.DefaultCost)
  50. if err != nil {
  51. log.Printf("⚠️ 创建默认管理员失败:密码加密错误 %v", err)
  52. return
  53. }
  54. admin := &models.User{
  55. Username: adminUsername,
  56. Password: string(hash),
  57. Role: "admin",
  58. }
  59. if err := userRepo.Create(admin); err != nil {
  60. log.Printf("⚠️ 创建默认管理员失败:%v", err)
  61. return
  62. }
  63. log.Printf("✅ 默认管理员账号创建成功")
  64. log.Printf(" 用户名: %s", adminUsername)
  65. log.Println(" ⚠️ 请首次登录后立即修改密码!")
  66. }
  67. // logVectorStartup 将向量库(Milvus)启动相关事件写入 system_logs,供前端「日志中心」查询;失败时仅打控制台,不影响启动。
  68. func logVectorStartup(sys *service.SystemLogService, level, event, message string, meta map[string]interface{}) {
  69. if sys == nil {
  70. return
  71. }
  72. if meta == nil {
  73. meta = map[string]interface{}{}
  74. }
  75. if err := sys.Create(service.CreateSystemLogInput{
  76. Level: level,
  77. Category: "vector",
  78. Event: event,
  79. Source: "backend",
  80. Message: message,
  81. Meta: meta,
  82. }); err != nil {
  83. log.Printf("写入 system_logs 失败 (event=%s): %v", event, err)
  84. }
  85. }
  86. // fatalVectorStartup 在启动阶段先写入一条 vector error 日志,再执行 fatal 退出。
  87. func fatalVectorStartup(sys *service.SystemLogService, event, message string, meta map[string]interface{}) {
  88. logVectorStartup(sys, "error", event, message, meta)
  89. log.Fatalf("%s", message)
  90. }
  91. func main() {
  92. // 加载 .env 文件(统一配置真源:优先当前目录 .env,其次上级目录 .env)
  93. wd, _ := os.Getwd()
  94. candidates := []string{
  95. filepath.Join(wd, ".env"),
  96. filepath.Join(wd, "..", ".env"),
  97. }
  98. envPath := ""
  99. for _, p := range candidates {
  100. if _, err := os.Stat(p); err == nil {
  101. envPath = p
  102. break
  103. }
  104. }
  105. if envPath == "" {
  106. log.Printf("⚠️ 未找到 .env 文件(已检查: %v)", candidates)
  107. log.Println("将仅使用系统环境变量")
  108. } else {
  109. log.Printf("✅ 找到 .env 文件: %s", envPath)
  110. }
  111. // 尝试加载 .env 文件
  112. // 注意:godotenv 不支持 UTF-8 BOM,如果文件有 BOM 会失败
  113. if envPath != "" {
  114. if err := godotenv.Load(envPath); err != nil {
  115. log.Printf("❌ 加载 .env 文件失败: %v", err)
  116. log.Println("⚠️ 提示:如果看到 'unexpected character' 错误,可能是文件编码问题(UTF-8 BOM)")
  117. log.Println(" 解决方法:用文本编辑器(如 VS Code)打开 .env,另存为 UTF-8 编码(不要 BOM)")
  118. log.Println("将使用系统环境变量")
  119. } else {
  120. log.Println("✅ .env 文件加载成功")
  121. }
  122. }
  123. geoip.InitFromEnv()
  124. defer geoip.Get().Close()
  125. db, err := infra.NewDB()
  126. if err != nil {
  127. log.Fatalf("数据库连接失败:%v", err)
  128. }
  129. //根据结构体定义自动创建更新表
  130. if err := db.AutoMigrate(&models.User{}, &models.Conversation{}, &models.Message{}, &models.AIConfig{}, &models.FAQ{}, &models.KnowledgeBase{}, &models.Document{}, &models.DocumentChunk{}, &models.EmbeddingConfig{}, &models.EmailNotificationConfig{}, &models.OfflineEmailJob{}, &models.PromptConfig{}, &models.WidgetOpenEvent{}, &models.SystemLog{}, &models.AppSetting{}); err != nil {
  131. log.Fatalf("自动创建表失败: %v", err)
  132. }
  133. userRepo := repository.NewUserRepository(db)
  134. conversationRepo := repository.NewConversationRepository(db)
  135. messageRepo := repository.NewMessageRepository(db)
  136. aiConfigRepo := repository.NewAIConfigRepository(db)
  137. faqRepo := repository.NewFAQRepository(db)
  138. kbRepo := repository.NewKnowledgeBaseRepository(db)
  139. docRepo := repository.NewDocumentRepository(db)
  140. chunkRepo := repository.NewDocumentChunkRepository(db)
  141. embeddingConfigRepo := repository.NewEmbeddingConfigRepository(db)
  142. emailNotificationConfigRepo := repository.NewEmailNotificationConfigRepository(db)
  143. offlineEmailJobRepo := repository.NewOfflineEmailJobRepository(db)
  144. promptConfigRepo := repository.NewPromptConfigRepository(db)
  145. systemLogRepo := repository.NewSystemLogRepository(db)
  146. appSettingRepo := repository.NewAppSettingRepository(db)
  147. systemLogMin := service.SystemLogMinPersistLevelFromEnv()
  148. systemLogService := service.NewSystemLogService(systemLogRepo, systemLogMin)
  149. if row, err := appSettingRepo.Get(models.AppSettingKeySystemLogMinLevel); err == nil && row != nil && strings.TrimSpace(row.Value) != "" {
  150. dbRank := service.ParseSystemLogMinPersistLevel(row.Value)
  151. systemLogService.SetMinPersistLevelRank(dbRank)
  152. log.Printf("ℹ️ 结构化日志最低落库级别: %s(数据库覆盖,环境变量默认 %s)",
  153. service.SystemLogMinLevelLabel(dbRank), service.SystemLogMinLevelLabel(systemLogMin))
  154. } else if systemLogMin == -1 {
  155. log.Println("ℹ️ SYSTEM_LOG_MIN_LEVEL=none,已关闭结构化日志写入数据库(日志中心将无新记录)")
  156. } else {
  157. log.Printf("ℹ️ 结构化日志最低落库级别: %s(SYSTEM_LOG_MIN_LEVEL)", service.SystemLogMinLevelLabel(systemLogMin))
  158. }
  159. // 初始化默认管理员账号(如果不存在)
  160. initDefaultAdmin(userRepo)
  161. //gin路由初始化
  162. gin.SetMode(gin.ReleaseMode)
  163. r := gin.Default()
  164. // trace_id + 结构化 HTTP 日志 + 控制台日志
  165. r.Use(middleware.TraceID())
  166. r.Use(middleware.StructuredHTTPLogger(systemLogService))
  167. r.Use(middleware.Logger())
  168. //跨域配置
  169. r.Use(middleware.CORS())
  170. // 初始化存储服务(本地存储)
  171. // 存储目录:backend/uploads(相对于工作目录)
  172. // 公共访问路径:/uploads(用于构建URL)
  173. // 复用之前获取的工作目录 wd(已在第 56 行声明)
  174. uploadDir := filepath.Join(wd, "uploads")
  175. publicPath := "/uploads"
  176. storageService := infra.NewLocalStorageService(uploadDir, publicPath)
  177. // 初始化 Milvus(向量数据库):默认连接失败时降级为「无向量库」启动;MILVUS_REQUIRED=true 时失败则退出
  178. milvusDisabled := infra.IsMilvusDisabled()
  179. milvusRequired := infra.IsMilvusRequired()
  180. var milvusClient milvus.Client
  181. defer func() {
  182. if milvusClient != nil {
  183. if err := milvusClient.Close(); err != nil {
  184. log.Printf("关闭 Milvus 客户端: %v", err)
  185. }
  186. }
  187. }()
  188. var vectorStore *infra.VectorStore
  189. milvusCfg := infra.GetMilvusConfig()
  190. milvusMeta := map[string]interface{}{
  191. "milvus_host": milvusCfg.Host,
  192. "milvus_port": milvusCfg.Port,
  193. "milvus_required": milvusRequired,
  194. "milvus_disabled": milvusDisabled,
  195. }
  196. if milvusDisabled {
  197. log.Println("ℹ️ 已设置 MILVUS_DISABLED / VECTOR_STORE_DISABLED,跳过 Milvus;知识库 RAG 与向量化不可用,直至启用并重启。")
  198. logVectorStartup(systemLogService, "info", "milvus_disabled",
  199. "已跳过 Milvus(MILVUS_DISABLED/VECTOR_STORE_DISABLED);知识库 RAG 与向量化不可用,启用后需重启",
  200. milvusMeta)
  201. } else {
  202. c, err := infra.NewMilvusClient()
  203. if err != nil {
  204. if milvusRequired {
  205. m := map[string]interface{}{}
  206. for k, v := range milvusMeta {
  207. m[k] = v
  208. }
  209. m["error"] = err.Error()
  210. fatalVectorStartup(systemLogService, "milvus_required_connect_failed",
  211. "连接 Milvus 失败(已设置 MILVUS_REQUIRED)", m)
  212. }
  213. log.Printf("⚠️ 连接 Milvus 失败,将以「无向量库」模式启动: %v", err)
  214. m := map[string]interface{}{}
  215. for k, v := range milvusMeta {
  216. m[k] = v
  217. }
  218. m["error"] = err.Error()
  219. logVectorStartup(systemLogService, "warn", "milvus_connect_failed",
  220. "连接 Milvus 失败,已降级为无向量库模式启动", m)
  221. } else {
  222. milvusClient = c
  223. if err := infra.HealthCheck(milvusClient); err != nil {
  224. _ = milvusClient.Close()
  225. milvusClient = nil
  226. if milvusRequired {
  227. m := map[string]interface{}{}
  228. for k, v := range milvusMeta {
  229. m[k] = v
  230. }
  231. m["error"] = err.Error()
  232. fatalVectorStartup(systemLogService, "milvus_required_health_check_failed",
  233. "Milvus 健康检查失败(已设置 MILVUS_REQUIRED)", m)
  234. }
  235. log.Printf("⚠️ Milvus 健康检查失败,将以「无向量库」模式启动: %v", err)
  236. m := map[string]interface{}{}
  237. for k, v := range milvusMeta {
  238. m[k] = v
  239. }
  240. m["error"] = err.Error()
  241. logVectorStartup(systemLogService, "warn", "milvus_health_check_failed",
  242. "Milvus 健康检查失败,已降级为无向量库模式启动", m)
  243. } else {
  244. log.Println("✅ Milvus 连接成功")
  245. }
  246. }
  247. }
  248. // 嵌入服务按需从 DB 配置获取(保存即生效,无需重启)
  249. embeddingConfigService := service.NewEmbeddingConfigService(embeddingConfigRepo, userRepo)
  250. promptConfigService := service.NewPromptConfigService(promptConfigRepo, userRepo)
  251. embeddingFactory := embedding.NewEmbeddingFactory()
  252. embeddingProvider := service.NewConfigBackedEmbeddingProvider(embeddingConfigService, embeddingFactory)
  253. // 启动时获取一次维度用于创建/校验向量集合
  254. initCtx := context.Background()
  255. initSvc, _ := embeddingProvider.Get(initCtx)
  256. if initSvc != nil {
  257. log.Printf("✅ 嵌入服务按需从「知识库向量配置」加载,模型: %s (维度: %d),修改配置后立即生效", initSvc.GetModelName(), initSvc.GetDimension())
  258. } else {
  259. log.Printf("⚠️ 未配置嵌入服务;知识库/RAG 需在「设置 - 知识库向量模型」中配置 API 后再使用")
  260. }
  261. dimension := 1536
  262. if initSvc != nil {
  263. dimension = initSvc.GetDimension()
  264. }
  265. // 向量存储:迁移时通过 getEmbedding 从当前配置重新向量化
  266. getEmbedding := func(ctx context.Context) (infra.EmbeddingService, error) {
  267. svc, err := embeddingProvider.Get(ctx)
  268. if err != nil || svc == nil {
  269. return nil, err
  270. }
  271. return svc, nil
  272. }
  273. if milvusClient != nil {
  274. vs, err := infra.NewVectorStore(milvusClient, "documents", dimension, getEmbedding)
  275. if err != nil {
  276. _ = milvusClient.Close()
  277. milvusClient = nil
  278. if milvusRequired {
  279. m := map[string]interface{}{}
  280. for k, v := range milvusMeta {
  281. m[k] = v
  282. }
  283. m["error"] = err.Error()
  284. fatalVectorStartup(systemLogService, "milvus_required_vector_store_init_failed",
  285. "创建向量存储失败(已设置 MILVUS_REQUIRED)", m)
  286. }
  287. log.Printf("⚠️ 创建向量存储失败,将以「无向量库」模式启动: %v", err)
  288. m := map[string]interface{}{}
  289. for k, v := range milvusMeta {
  290. m[k] = v
  291. }
  292. m["error"] = err.Error()
  293. logVectorStartup(systemLogService, "warn", "milvus_vector_store_init_failed",
  294. "创建向量存储(集合)失败,已降级为无向量库模式启动", m)
  295. } else {
  296. vectorStore = vs
  297. }
  298. }
  299. if vectorStore != nil {
  300. okMeta := map[string]interface{}{}
  301. for k, v := range milvusMeta {
  302. okMeta[k] = v
  303. }
  304. okMeta["collection"] = "documents"
  305. logVectorStartup(systemLogService, "info", "milvus_ready",
  306. "Milvus 已连接且向量集合可用", okMeta)
  307. }
  308. vectorStoreService := rag.NewVectorStoreService(vectorStore)
  309. // 文档向量化 / RAG 检索 / 健康检查均使用 provider,配置保存即生效
  310. documentEmbeddingService := rag.NewDocumentEmbeddingService(vectorStoreService, embeddingProvider)
  311. retrievalService := rag.NewRetrievalService(vectorStoreService, embeddingProvider, docRepo, kbRepo)
  312. retrievalService.EnableCache(5 * time.Minute)
  313. if v := os.Getenv("RAG_MIN_SCORE"); v != "" {
  314. if score, err := strconv.ParseFloat(v, 32); err == nil {
  315. retrievalService.SetMinScore(float32(score))
  316. log.Printf("ℹ️ RAG 相似度阈值: %.2f(来自 RAG_MIN_SCORE)", score)
  317. }
  318. }
  319. healthChecker := rag.NewHealthChecker(embeddingProvider, vectorStoreService)
  320. // 联网搜索(可选):优先通过 MCP 调用 Serper(SERPER_MCP_URL),否则使用 Serper HTTP API(SERPER_API_KEY)
  321. var webSearchProvider infra_search.WebSearchProvider
  322. if mcpURL := os.Getenv("SERPER_MCP_URL"); mcpURL != "" {
  323. mcpClient := mcp.NewClient(mcpURL)
  324. if err := mcpClient.Connect(initCtx); err != nil {
  325. log.Printf("⚠️ Serper MCP 连接失败(SERPER_MCP_URL=%s): %v,联网搜索将不可用", mcpURL, err)
  326. } else {
  327. webSearchProvider = mcp.NewSerperWebSearchProvider(mcpClient)
  328. log.Println("✅ 联网搜索已通过 MCP(Serper)接入")
  329. }
  330. }
  331. if webSearchProvider == nil {
  332. if apiKey := os.Getenv("SERPER_API_KEY"); apiKey != "" {
  333. webSearchProvider = infra_search.NewSerperProvider(apiKey)
  334. log.Println("✅ 联网搜索已通过 Serper HTTP API 接入")
  335. }
  336. }
  337. // 初始化服务层
  338. authService := service.NewAuthService(userRepo)
  339. conversationService := service.NewConversationService(conversationRepo, messageRepo, aiConfigRepo, userRepo, systemLogService, appSettingRepo)
  340. conversationService.StartStaleConversationCleanup()
  341. profileService := service.NewProfileService(userRepo, storageService)
  342. aiConfigService := service.NewAIConfigService(aiConfigRepo, userRepo)
  343. aiService := service.NewAIService(aiConfigRepo, messageRepo, conversationRepo, retrievalService, webSearchProvider, embeddingConfigService, promptConfigService, storageService, systemLogService, faqRepo)
  344. userService := service.NewUserService(userRepo, aiConfigRepo) // 用户管理服务
  345. faqService := service.NewFAQService(faqRepo, retrievalService, documentEmbeddingService) // FAQ 管理服务
  346. documentService := service.NewDocumentService(docRepo, kbRepo, documentEmbeddingService, retrievalService) // 文档管理服务
  347. knowledgeBaseService := service.NewKnowledgeBaseService(kbRepo, docRepo) // 知识库管理服务
  348. importService := service.NewImportService(docRepo, kbRepo, documentService, documentEmbeddingService) // 导入服务
  349. chunkService := service.NewChunkService(docRepo, kbRepo, chunkRepo, documentEmbeddingService, vectorStoreService) // 分段服务
  350. emailNotificationConfigService := service.NewEmailNotificationConfigService(emailNotificationConfigRepo, userRepo)
  351. // 声明 Hub / 离线邮件变量(Hub 创建后完成注入)
  352. var wsHub *websocket.Hub
  353. var offlineEmailSvc *service.OfflineEmailService
  354. // 创建 WebSocket Hub,设置回调函数来处理客户端连接/断开事件
  355. // 使用闭包来访问 conversationService、messageService、userRepo 和 wsHub
  356. onConnect := func(conversationID uint, isVisitor bool, visitorCount int, agentID uint) {
  357. if isVisitor {
  358. if err := conversationService.UpdateVisitorOnlineStatus(conversationID, true); err != nil {
  359. log.Printf("更新访客在线状态失败: %v", err)
  360. return
  361. }
  362. if offlineEmailSvc != nil {
  363. offlineEmailSvc.CancelPending(conversationID)
  364. }
  365. // 广播状态更新到所有客服端(不管连接到哪个对话)
  366. wsHub.BroadcastToAllAgents("visitor_status_update", map[string]interface{}{
  367. "conversation_id": conversationID,
  368. "is_online": true,
  369. "visitor_count": visitorCount,
  370. })
  371. } else if agentID > 0 {
  372. // 客服连接:创建系统消息 "{客服名}加入了会话"
  373. // 但需要检查是否已经存在该客服的加入消息,避免重复创建
  374. // 获取客服信息
  375. agent, err := userRepo.GetByID(agentID)
  376. if err != nil {
  377. log.Printf("获取客服信息失败: %v", err)
  378. return
  379. }
  380. // 确定显示名称:优先使用昵称,如果没有则使用用户名
  381. agentName := agent.Nickname
  382. if agentName == "" {
  383. agentName = agent.Username
  384. }
  385. // 检查是否已经存在该客服的加入消息
  386. hasJoinMessage, err := messageRepo.HasAgentJoinMessage(conversationID, agentID, agentName)
  387. if err != nil {
  388. log.Printf("检查客服加入消息失败: %v", err)
  389. return
  390. }
  391. // 如果已经存在加入消息,不再创建
  392. if hasJoinMessage {
  393. log.Printf("客服 %s 已经加入过对话 %d,跳过创建系统消息", agentName, conversationID)
  394. return
  395. }
  396. // 创建系统消息
  397. // 需要获取对话信息以确定当前模式
  398. conv, err := conversationRepo.GetByID(conversationID)
  399. if err != nil {
  400. log.Printf("获取对话信息失败: %v", err)
  401. return
  402. }
  403. now := time.Now()
  404. chatMode := conv.ChatMode
  405. if chatMode == "" {
  406. chatMode = "human" // 默认人工模式
  407. }
  408. systemMessage := &models.Message{
  409. ConversationID: conversationID,
  410. SenderID: agentID,
  411. SenderIsAgent: true,
  412. Content: agentName + "加入了会话",
  413. MessageType: "system_message",
  414. ChatMode: chatMode, // 记录系统消息发送时的对话模式
  415. IsRead: true, // 系统消息默认已读
  416. ReadAt: &now,
  417. }
  418. if err := messageRepo.Create(systemMessage); err != nil {
  419. log.Printf("创建客服加入系统消息失败: %v", err)
  420. return
  421. }
  422. // 延迟一小段时间后广播系统消息,确保客服的 WebSocket 连接已经完全建立
  423. // 这样可以确保系统消息能够被客服接收到
  424. go func() {
  425. time.Sleep(100 * time.Millisecond)
  426. wsHub.BroadcastMessage(conversationID, "new_message", systemMessage)
  427. log.Printf("✅ 客服加入系统消息已创建并广播: 对话ID=%d, 客服=%s", conversationID, agentName)
  428. }()
  429. }
  430. }
  431. onDisconnect := func(conversationID uint, isVisitor bool, visitorCount int) {
  432. if isVisitor {
  433. if visitorCount == 0 {
  434. if err := conversationService.UpdateVisitorOnlineStatus(conversationID, false); err != nil {
  435. log.Printf("更新访客离线状态失败: %v", err)
  436. return
  437. }
  438. // 广播状态更新到所有客服端(不管连接到哪个对话)
  439. wsHub.BroadcastToAllAgents("visitor_status_update", map[string]interface{}{
  440. "conversation_id": conversationID,
  441. "is_online": false,
  442. "visitor_count": 0,
  443. })
  444. } else {
  445. // 还有访客在线,只更新最后活跃时间
  446. if err := conversationService.UpdateLastSeenAt(conversationID); err != nil {
  447. log.Printf("更新最后活跃时间失败: %v", err)
  448. return
  449. }
  450. }
  451. }
  452. }
  453. // 创建 Hub(回调函数通过闭包访问 wsHub)
  454. // 可选启用 Redis Pub/Sub:配置 REDIS_URL 或 REDIS_ADDR 后自动开启跨实例广播。
  455. wsBus, wsBusErr := websocket.NewRedisBusFromEnv()
  456. if wsBusErr != nil {
  457. log.Printf("⚠️ Redis Pub/Sub 初始化失败,将回退为单实例广播: %v", wsBusErr)
  458. }
  459. if wsBus != nil {
  460. defer func() {
  461. if err := wsBus.Close(); err != nil {
  462. log.Printf("关闭 Redis Pub/Sub 失败: %v", err)
  463. }
  464. }()
  465. log.Println("✅ 已启用 Redis Pub/Sub 跨实例广播")
  466. }
  467. wsHub = websocket.NewHub(onConnect, onDisconnect, wsBus)
  468. go wsHub.Run() // 启动 Hub(在后台运行)
  469. offlineEmailSvc = service.NewOfflineEmailService(
  470. emailNotificationConfigService,
  471. offlineEmailJobRepo,
  472. conversationRepo,
  473. messageRepo,
  474. wsHub,
  475. )
  476. go offlineEmailSvc.StartWorker(context.Background())
  477. messageService := service.NewMessageService(db, conversationRepo, messageRepo, wsHub, aiService)
  478. messageService.SetOfflineEmailService(offlineEmailSvc)
  479. visitorService := service.NewVisitorService(userRepo, wsHub)
  480. // 初始化控制器
  481. authController := controller.NewAuthController(authService)
  482. conversationController := controller.NewConversationController(conversationService, aiConfigService, userService)
  483. messageController := controller.NewMessageController(messageService, conversationService, userService, storageService)
  484. adminController := controller.NewAdminController(authService, userService)
  485. profileController := controller.NewProfileController(profileService)
  486. aiConfigController := controller.NewAIConfigController(aiConfigService, userService)
  487. faqController := controller.NewFAQController(faqService, userService)
  488. documentController := controller.NewDocumentController(documentService, embeddingConfigService, userService)
  489. embeddingConfigController := controller.NewEmbeddingConfigController(embeddingConfigService, userService)
  490. promptConfigController := controller.NewPromptConfigController(promptConfigService, userService)
  491. knowledgeBaseController := controller.NewKnowledgeBaseController(knowledgeBaseService, embeddingConfigService, userService)
  492. importController := controller.NewImportController(importService, embeddingConfigService, userService) // 导入控制器
  493. chunkController := controller.NewDocumentChunkController(chunkService, userService) // 分段控制器
  494. emailNotificationController := controller.NewEmailNotificationConfigController(emailNotificationConfigService, offlineEmailSvc, userService)
  495. visitorController := controller.NewVisitorController(visitorService, embeddingConfigService)
  496. healthController := controller.NewHealthController(healthChecker, retrievalService) // 健康检查控制器
  497. widgetOpenRepo := repository.NewWidgetOpenRepository(db)
  498. analyticsService := service.NewAnalyticsService(db, widgetOpenRepo)
  499. analyticsController := controller.NewAnalyticsController(analyticsService, userService)
  500. systemLogController := controller.NewSystemLogController(systemLogService, userService, appSettingRepo)
  501. appRouter.RegisterRoutes(
  502. r,
  503. appRouter.ControllerSet{
  504. Auth: authController,
  505. Conversation: conversationController,
  506. Message: messageController,
  507. Admin: adminController,
  508. Profile: profileController,
  509. AIConfig: aiConfigController,
  510. EmbeddingConfig: embeddingConfigController,
  511. PromptConfig: promptConfigController,
  512. FAQ: faqController,
  513. Document: documentController,
  514. KnowledgeBase: knowledgeBaseController,
  515. Import: importController, // 导入控制器
  516. DocumentChunk: chunkController, // 分段控制器
  517. EmailNotification: emailNotificationController,
  518. Visitor: visitorController,
  519. Health: healthController, // 健康检查控制器
  520. Analytics: analyticsController,
  521. SystemLog: systemLogController,
  522. },
  523. websocket.HandleWebSocket(wsHub, userRepo, conversationService),
  524. )
  525. // 配置静态文件服务(用于访问上传的头像等文件)
  526. // 静态文件路径:/uploads -> backend/uploads
  527. r.Static("/uploads", uploadDir)
  528. //启动服务器
  529. // 监听所有网络接口(0.0.0.0),允许外部设备访问
  530. // 如果只想本地访问,可以改为 "127.0.0.1:8080" 或 ":8080"
  531. host := os.Getenv("SERVER_HOST")
  532. if host == "" {
  533. host = "0.0.0.0" // 默认监听所有网络接口,允许外部访问
  534. }
  535. port := os.Getenv("SERVER_PORT")
  536. if port == "" {
  537. port = "8080"
  538. }
  539. addr := host + ":" + port
  540. log.Println("🚀 服务器启动成功,监听 " + addr)
  541. log.Println("📡 WebSocket 服务已启动,路径: /ws?conversation_id=<对话ID>")
  542. log.Println("💡 提示:如需限制为仅本地访问,请设置环境变量 SERVER_HOST=127.0.0.1")
  543. r.Run(addr)
  544. }