屏蔽机器人消息

调用签到🔧注入时间
up
2026-07-02 11:02:48 +08:00 · 2026-07-01 12:43:05 +08:00 · 2026-07-01 12:36:55 +08:00 · 2026-07-01 12:24:38 +08:00 · 2026-07-01 12:12:23 +08:00 · 2026-07-01 11:55:37 +08:00
24 changed files with 1000 additions and 156 deletions
@@ -32,9 +32,9 @@
 ### 3. 检查操作 (action=check) **新增**

 检查当前节点今天是否已签到：
- 用于回答"我今天签到了吗"之类的问题
+- 用于回答"我今天签到了吗"、"我什么时候签到的"之类的问题
 - 直接查询数据库，不依赖对话历史
- 返回明确的已签到/未签到状态
+- 返回明确的签到状态，**包括签到时间和签到内容**

 ## 修改内容

@@ -102,15 +102,21 @@ AI 调用：
 ```

 返回（未签到）：
-```
+```text
 Test Node 今天还没有签到。
 ```

 返回（已签到）：
-```
+```text
 Test Node 今天已经签到过了。
+签到时间：10:30:45
+签到内容：上海闵行-Kevin-GAT562签到
 ```

+**用户**："我什么时候签到的？"
+
+AI 同样调用 check 操作，返回包含签到时间和内容的完整信息。
+
 #### 查询今天的签到情况
 ```json
 {
@@ -3,6 +3,7 @@ set -euo pipefail

 SERVICE_NAME="mesh_mqtt_go"
 SERVICE_USER="mesh_mqtt_go"
+SERVICE_GROUP="${SERVICE_USER}"
 CONFIG_DIR="/etc/${SERVICE_NAME}"
 DATA_DIR="/srv/${SERVICE_NAME}"
 INSTALL_DIR="/opt/${SERVICE_NAME}"
@@ -17,6 +18,12 @@ if [[ "${EUID}" -ne 0 ]]; then
  exit 1
 fi

+if id -u "www" >/dev/null 2>&1; then
+  SERVICE_USER="www"
+  SERVICE_GROUP=$(id -gn "www")
+  echo "检测到 www 用户，将以 www 用户运行服务"
+fi
+
 SCRIPT_DIR="$(cd "$(dirname "${BASH_SOURCE[0]}")" && pwd)"
 cd "${SCRIPT_DIR}"

@@ -42,8 +49,8 @@ if ! id -u "${SERVICE_USER}" >/dev/null 2>&1; then
 fi

 echo "创建目录..."
-install -d -m 0750 -o "${SERVICE_USER}" -g "${SERVICE_USER}" "${CONFIG_DIR}" "${DATA_DIR}"
-install -d -m 0755 -o "${SERVICE_USER}" -g "${SERVICE_USER}" "${INSTALL_DIR}"
+install -d -m 0750 -o "${SERVICE_USER}" -g "${SERVICE_GROUP}" "${CONFIG_DIR}" "${DATA_DIR}"
+install -d -m 0755 -o "${SERVICE_USER}" -g "${SERVICE_GROUP}" "${INSTALL_DIR}"

 echo "安装程序和前端文件..."
 install -m 0755 -o root -g root "${SCRIPT_DIR}/${BINARY_NAME}" "${INSTALL_DIR}/${BINARY_NAME}"
@@ -51,7 +58,7 @@ rm -rf "${INSTALL_DIR}/dist"
 cp -a "${SCRIPT_DIR}/${FRONTEND_DIST_DIR}" "${INSTALL_DIR}/dist"
 chown root:root "${INSTALL_DIR}/${BINARY_NAME}"
 chown -R root:root "${INSTALL_DIR}/dist"
-chown "${SERVICE_USER}:${SERVICE_USER}" "${INSTALL_DIR}"
+chown "${SERVICE_USER}:${SERVICE_GROUP}" "${INSTALL_DIR}"
 chmod 0755 "${INSTALL_DIR}"
 find "${INSTALL_DIR}/dist" -type d -exec chmod 0755 {} \;
 find "${INSTALL_DIR}/dist" -type f -exec chmod 0644 {} \;
@@ -91,7 +98,7 @@ console_log:
  sql: true
  meshtastic: true
 EOF
-  chown "${SERVICE_USER}:${SERVICE_USER}" "${CONFIG_DIR}/config.yaml"
+  chown "${SERVICE_USER}:${SERVICE_GROUP}" "${CONFIG_DIR}/config.yaml"
  chmod 0640 "${CONFIG_DIR}/config.yaml"
 fi

@@ -105,7 +112,7 @@ Wants=network-online.target
 [Service]
 Type=simple
 User=${SERVICE_USER}
-Group=${SERVICE_USER}
+Group=${SERVICE_GROUP}
 WorkingDirectory=${INSTALL_DIR}
 ExecStart=${INSTALL_DIR}/${BINARY_NAME} -web-socket-path ${SOCKET_PATH} -web-static-dir ${INSTALL_DIR}/dist
 Restart=on-failure
@@ -179,7 +179,7 @@ func (t *Tool) executeSign(ctx context.Context, params signParams, runtime agent
 	return fmt.Sprintf("签到成功！%s\n签到内容：%s", displayName(node), record.SignText), nil
 }

-// executeCheck 检查当前节点今天是否已签到
+// executeCheck 检查当前节点今天是否已签到，并返回签到详情
 func (t *Tool) executeCheck(ctx context.Context, params signParams, runtime agenttool.Runtime) (string, error) {
 	// 节点身份来自消息上下文
 	node, ok := agenttool.NodeContextFromContext(ctx)
@@ -192,16 +192,36 @@ func (t *Tool) executeCheck(ctx context.Context, params signParams, runtime agen
 		now = time.Now()
 	}

-	// 查询数据库检查今天是否已签到
-	signed, err := t.store.HasSignedOnDay(node.NodeID, now)
-	if err != nil {
-		return "", fmt.Errorf("检查签到状态失败：%w", err)
+	// 构建查询选项：查询今天的签到记录
+	loc := now.Location()
+	if loc == nil {
+		loc = time.Local
+	}
+	start := time.Date(now.Year(), now.Month(), now.Day(), 0, 0, 0, 0, loc)
+	end := start.AddDate(0, 0, 1)
+
+	opts := storepkg.ListOptions{
+		NodeID: node.NodeID,
+		Since:  &start,
+		Until:  &end,
+		Limit:  1,
 	}

-	if signed {
-		return fmt.Sprintf("%s 今天已经签到过了。", displayName(node)), nil
+	// 查询数据库获取今天的签到记录
+	signs, err := t.store.ListSigns(opts)
+	if err != nil {
+		return "", fmt.Errorf("查询签到记录失败：%w", err)
 	}
-	return fmt.Sprintf("%s 今天还没有签到。", displayName(node)), nil
+
+	if len(signs) == 0 {
+		return fmt.Sprintf("%s 今天还没有签到。", displayName(node)), nil
+	}
+
+	// 返回签到详情
+	sign := signs[0]
+	signTimeStr := sign.SignTime.Format("15:04:05")
+	return fmt.Sprintf("%s 今天已经签到过了。\n签到时间：%s\n签到内容：%s",
+		displayName(node), signTimeStr, sign.SignText), nil
 }

 // executeQuery 执行查询操作
@@ -85,6 +85,11 @@ func (m *mockSignStore) CountSignsByDay(opts storepkg.ListOptions) ([]storepkg.S
 func (m *mockSignStore) ListSigns(opts storepkg.ListOptions) ([]storepkg.SignRecord, error) {
 	var result []storepkg.SignRecord
 	for _, sign := range m.signs {
+		// 过滤 NodeID
+		if opts.NodeID != "" && sign.NodeID != opts.NodeID {
+			continue
+		}
+		// 过滤时间范围
 		if opts.Since != nil && sign.SignTime.Before(*opts.Since) {
 			continue
 		}
@@ -93,6 +98,10 @@ func (m *mockSignStore) ListSigns(opts storepkg.ListOptions) ([]storepkg.SignRec
 		}
 		result = append(result, sign)
 	}
+	// 应用 Limit
+	if opts.Limit > 0 && len(result) > opts.Limit {
+		result = result[:opts.Limit]
+	}
 	return result, nil
 }

@@ -261,12 +270,13 @@ func TestSignTool_CheckAction(t *testing.T) {

 	// 测试场景2：今天已签到
 	t.Run("今天已签到", func(t *testing.T) {
+		signTime := time.Date(2024, 6, 23, 10, 30, 45, 0, time.UTC)
 		store := &mockSignStore{
 			signs: []storepkg.SignRecord{
 				{
 					NodeID:   "test_node_123",
 					SignText: "上海-TestUser-TestDevice签到",
-					SignTime: now,
+					SignTime: signTime,
 				},
 			},
 			nodeInfoMap: make(map[string]*storepkg.NodeInfoRecord),
@@ -300,6 +310,15 @@ func TestSignTool_CheckAction(t *testing.T) {
 		if !contains(result, "已经签到") {
 			t.Errorf("Expected result to indicate already signed")
 		}
+		if !contains(result, "签到时间") {
+			t.Errorf("Expected result to contain sign time")
+		}
+		if !contains(result, "10:30:45") {
+			t.Errorf("Expected result to contain the exact sign time")
+		}
+		if !contains(result, "签到内容") {
+			t.Errorf("Expected result to contain sign text")
+		}
 	})
 }

@@ -0,0 +1,203 @@
+package ai
+
+import (
+	"context"
+	"fmt"
+	"sync"
+
+	"meshtastic_mqtt_server/internal/autoreply"
+	"meshtastic_mqtt_server/internal/llm"
+	storepkg "meshtastic_mqtt_server/internal/store"
+
+	"gorm.io/gorm"
+)
+
+// AIServiceStatus reports the current state of the AI service
+type AIServiceStatus struct {
+	Running       bool   `json:"running"`
+	Enabled       bool   `json:"enabled"`
+	ProviderCount int    `json:"provider_count"`
+	Message       string `json:"message,omitempty"`
+}
+
+// AIManager manages the lifecycle of the AI service, supporting restart
+type AIManager struct {
+	mu        sync.Mutex
+	service   *Service
+	cfg       Config
+	db        *gorm.DB
+	botSender autoreply.BotSender
+	ctx       context.Context
+	store     *storepkg.Store
+}
+
+// NewAIManager creates a new AIManager
+func NewAIManager(cfg Config, db *gorm.DB, botSender autoreply.BotSender, ctx context.Context, store *storepkg.Store) *AIManager {
+	return &AIManager{
+		cfg:       cfg,
+		db:        db,
+		botSender: botSender,
+		ctx:       ctx,
+		store:     store,
+	}
+}
+
+// SetConfigEnabled sets the enabled flag on the config
+func (m *AIManager) SetConfigEnabled(enabled bool) {
+	m.cfg.Enabled = enabled
+}
+
+// SetProviderConfigs sets the LLM provider configs
+func (m *AIManager) SetProviderConfigs(configs []llm.ProviderConfig) {
+	m.cfg.LLMProviders = configs
+}
+
+// Init creates and starts the AI service
+func (m *AIManager) Init() error {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+
+	svc, err := NewService(m.cfg, m.db, m.botSender)
+	if err != nil {
+		return fmt.Errorf("failed to create AI service: %w", err)
+	}
+	if err := svc.Start(m.ctx); err != nil {
+		return fmt.Errorf("failed to start AI service: %w", err)
+	}
+	m.service = svc
+	return nil
+}
+
+// Stop stops the currently running AI service
+func (m *AIManager) Stop() {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+	if m.service != nil {
+		m.service.Stop()
+		m.service = nil
+	}
+}
+
+// Status returns the current AI service status
+func (m *AIManager) Status() AIServiceStatus {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+
+	providerCount := len(m.cfg.LLMProviders)
+	if m.service == nil {
+		msg := "AI 服务未运行，可在配置提供商后点击重启"
+		if providerCount == 0 {
+			msg = "尚未配置 AI 提供商，请先添加提供商配置"
+		}
+		return AIServiceStatus{
+			Running:       false,
+			Enabled:       m.cfg.Enabled,
+			ProviderCount: providerCount,
+			Message:       msg,
+		}
+	}
+	enabled := m.service.Enabled()
+	if !enabled {
+		return AIServiceStatus{
+			Running:       false,
+			Enabled:       false,
+			ProviderCount: providerCount,
+			Message:       "AI 服务未启用",
+		}
+	}
+	return AIServiceStatus{
+		Running:       true,
+		Enabled:       true,
+		ProviderCount: providerCount,
+	}
+}
+
+// Restart stops the current AI service and creates a new one from DB
+func (m *AIManager) Restart() error {
+	m.mu.Lock()
+	defer m.mu.Unlock()
+
+	if m.service != nil {
+		m.service.Stop()
+		m.service = nil
+	}
+
+	providers, err := m.store.ListLLMProviders(true)
+	if err != nil {
+		return fmt.Errorf("加载 LLM 提供商列表失败: %w", err)
+	}
+	if len(providers) == 0 {
+		return fmt.Errorf("没有配置任何 LLM 提供商，请先添加配置")
+	}
+
+	providerConfigs := make([]llm.ProviderConfig, 0, len(providers))
+	for _, p := range providers {
+		providerConfigs = append(providerConfigs, llm.ProviderConfig{
+			Name:                p.Name,
+			Active:              p.Active,
+			APIKey:              p.APIKey,
+			BaseURL:             p.BaseURL,
+			Model:               p.Model,
+			Timeout:             p.Timeout,
+			ContextWindowTokens: p.ContextWindowTokens,
+		})
+	}
+	m.cfg.LLMProviders = providerConfigs
+
+	svc, err := NewService(m.cfg, m.db, m.botSender)
+	if err != nil {
+		return fmt.Errorf("创建 AI 服务失败: %w", err)
+	}
+	if err := svc.Start(m.ctx); err != nil {
+		return fmt.Errorf("启动 AI 服务失败: %w", err)
+	}
+
+	m.service = svc
+	return nil
+}
+
+// ReloadLLMProvider delegates to the current service
+func (m *AIManager) ReloadLLMProvider(config interface{}) error {
+	m.mu.Lock()
+	svc := m.service
+	m.mu.Unlock()
+
+	if svc == nil {
+		return nil
+	}
+	return svc.ReloadLLMProvider(config)
+}
+
+// AddLLMProvider delegates to the current service
+func (m *AIManager) AddLLMProvider(config interface{}) error {
+	m.mu.Lock()
+	svc := m.service
+	m.mu.Unlock()
+
+	if svc == nil {
+		return nil
+	}
+	return svc.AddLLMProvider(config)
+}
+
+// RemoveLLMProvider delegates to the current service
+func (m *AIManager) RemoveLLMProvider(name string) error {
+	m.mu.Lock()
+	svc := m.service
+	m.mu.Unlock()
+
+	if svc == nil {
+		return nil
+	}
+	return svc.RemoveLLMProvider(name)
+}
+
+// AIServiceStatus returns the AI service status for the web interface
+func (m *AIManager) AIServiceStatus() AIServiceStatus {
+	return m.Status()
+}
+
+// RestartAIService restarts the AI service for the web interface
+func (m *AIManager) RestartAIService() error {
+	return m.Restart()
+}
@@ -262,6 +262,9 @@ func (s *Service) Enabled() bool {

 // ReloadLLMProvider reloads a specific LLM provider configuration
 func (s *Service) ReloadLLMProvider(config interface{}) error {
+	if s == nil {
+		return nil
+	}
 	if !s.enabled || s.LLMState == nil {
 		return nil
 	}
@@ -274,6 +277,9 @@ func (s *Service) ReloadLLMProvider(config interface{}) error {

 // AddLLMProvider adds a new LLM provider
 func (s *Service) AddLLMProvider(config interface{}) error {
+	if s == nil {
+		return nil
+	}
 	if !s.enabled || s.LLMState == nil {
 		return nil
 	}
@@ -286,6 +292,9 @@ func (s *Service) AddLLMProvider(config interface{}) error {

 // RemoveLLMProvider removes an LLM provider
 func (s *Service) RemoveLLMProvider(name string) error {
+	if s == nil {
+		return nil
+	}
 	if !s.enabled || s.LLMState == nil {
 		return nil
 	}
@@ -509,6 +509,16 @@ func cleanReplyText(text string) string {
 			sb.WriteRune(r)
 		case r == 0x3002 || r == 0xFF1F || r == 0xFF01 || r == 0xFF0C || r == 0xFF1A: // Fullwidth punctuation
 			sb.WriteRune(r)
+		case r >= 0x1F600 && r <= 0x1F64F: // Emoticons
+			sb.WriteRune(r)
+		case r >= 0x1F300 && r <= 0x1F5FF: // Misc Symbols and Pictographs
+			sb.WriteRune(r)
+		case r >= 0x1F680 && r <= 0x1F6FF: // Transport and Map Symbols
+			sb.WriteRune(r)
+		case r >= 0x1F900 && r <= 0x1F9FF: // Supplemental Symbols and Pictographs
+			sb.WriteRune(r)
+		case r >= 0x2600 && r <= 0x27BF: // Misc Symbols + Dingbats
+			sb.WriteRune(r)
 		default:
 			continue // Skip all other characters
 		}
@@ -9,6 +9,7 @@ import (
 	"github.com/gin-gonic/gin"
 	"gorm.io/gorm"

+	aipkg "meshtastic_mqtt_server/internal/ai"
 	storepkg "meshtastic_mqtt_server/internal/store"
 	"meshtastic_mqtt_server/internal/webutil"
 )
@@ -18,6 +19,8 @@ type LLMProviderReloader interface {
 	ReloadLLMProvider(config interface{}) error
 	AddLLMProvider(config interface{}) error
 	RemoveLLMProvider(name string) error
+	AIServiceStatus() aipkg.AIServiceStatus
+	RestartAIService() error
 }

 func RegisterRoutes(r *gin.RouterGroup, store *storepkg.Store, aiService LLMProviderReloader) {
@@ -49,6 +52,10 @@ func RegisterRoutes(r *gin.RouterGroup, store *storepkg.Store, aiService LLMProv
 		// LLM Primary Config - 主 AI 回复配置
 		group.GET("/primary-config", handleGetLLMPrimaryConfig(store))
 		group.PUT("/primary-config", handleUpdateLLMPrimaryConfig(store))
+
+		// AI Service Status
+		group.GET("/status", handleGetAIServiceStatus(aiService))
+		group.POST("/restart", handleRestartAIService(aiService))
 	}
 }

@@ -298,25 +305,30 @@ func handleCreateLLMProvider(store *storepkg.Store, aiService LLMProviderReloade
 		}

 		// Reload AI service with new provider
-		if aiService != nil {
-			providerConfig := map[string]interface{}{
-				"Name":                record.Name,
-				"Active":              record.Active,
-				"APIKey":              record.APIKey,
-				"BaseURL":             record.BaseURL,
-				"Model":               record.Model,
-				"Timeout":             record.Timeout,
-				"ContextWindowTokens": record.ContextWindowTokens,
-			}
-			if err := aiService.AddLLMProvider(providerConfig); err != nil {
-				// Log warning but don't fail the request - database is already updated
-				c.JSON(http.StatusOK, gin.H{
-					"status":  "ok",
-					"item":    llmProviderDTO(*record),
-					"warning": "provider created but failed to reload AI service: " + err.Error(),
-				})
-				return
-			}
+		if aiService == nil {
+			c.JSON(http.StatusOK, gin.H{
+				"status":  "ok",
+				"item":    llmProviderDTO(*record),
+				"warning": "AI 服务未运行，配置已保存但需重启服务后生效",
+			})
+			return
+		}
+		providerConfig := map[string]interface{}{
+			"Name":                record.Name,
+			"Active":              record.Active,
+			"APIKey":              record.APIKey,
+			"BaseURL":             record.BaseURL,
+			"Model":               record.Model,
+			"Timeout":             record.Timeout,
+			"ContextWindowTokens": record.ContextWindowTokens,
+		}
+		if err := aiService.AddLLMProvider(providerConfig); err != nil {
+			c.JSON(http.StatusOK, gin.H{
+				"status":  "ok",
+				"item":    llmProviderDTO(*record),
+				"warning": "provider created but failed to reload AI service: " + err.Error(),
+			})
+			return
 		}

 		c.JSON(http.StatusOK, gin.H{"status": "ok", "item": llmProviderDTO(*record)})
@@ -385,25 +397,30 @@ func handleUpdateLLMProvider(store *storepkg.Store, aiService LLMProviderReloade
 		}

 		// Reload AI service with updated provider
-		if aiService != nil {
-			providerConfig := map[string]interface{}{
-				"Name":                record.Name,
-				"Active":              record.Active,
-				"APIKey":              record.APIKey,
-				"BaseURL":             record.BaseURL,
-				"Model":               record.Model,
-				"Timeout":             record.Timeout,
-				"ContextWindowTokens": record.ContextWindowTokens,
-			}
-			if err := aiService.ReloadLLMProvider(providerConfig); err != nil {
-				// Log warning but don't fail the request - database is already updated
-				c.JSON(http.StatusOK, gin.H{
-					"status":  "ok",
-					"item":    llmProviderDTO(*record),
-					"warning": "provider updated but failed to reload AI service: " + err.Error(),
-				})
-				return
-			}
+		if aiService == nil {
+			c.JSON(http.StatusOK, gin.H{
+				"status":  "ok",
+				"item":    llmProviderDTO(*record),
+				"warning": "AI 服务未运行，配置已保存但需重启服务后生效",
+			})
+			return
+		}
+		providerConfig := map[string]interface{}{
+			"Name":                record.Name,
+			"Active":              record.Active,
+			"APIKey":              record.APIKey,
+			"BaseURL":             record.BaseURL,
+			"Model":               record.Model,
+			"Timeout":             record.Timeout,
+			"ContextWindowTokens": record.ContextWindowTokens,
+		}
+		if err := aiService.ReloadLLMProvider(providerConfig); err != nil {
+			c.JSON(http.StatusOK, gin.H{
+				"status":  "ok",
+				"item":    llmProviderDTO(*record),
+				"warning": "provider updated but failed to reload AI service: " + err.Error(),
+			})
+			return
 		}

 		c.JSON(http.StatusOK, gin.H{"status": "ok", "item": llmProviderDTO(*record)})
@@ -424,15 +441,19 @@ func handleDeleteLLMProvider(store *storepkg.Store, aiService LLMProviderReloade
 		}

 		// Remove provider from AI service
-		if aiService != nil {
-			if err := aiService.RemoveLLMProvider(name); err != nil {
-				// Log warning but don't fail the request - database is already updated
-				c.JSON(http.StatusOK, gin.H{
-					"status":  "ok",
-					"warning": "provider deleted but failed to reload AI service: " + err.Error(),
-				})
-				return
-			}
+		if aiService == nil {
+			c.JSON(http.StatusOK, gin.H{
+				"status":  "ok",
+				"warning": "AI 服务未运行，配置已删除但需重启服务后生效",
+			})
+			return
+		}
+		if err := aiService.RemoveLLMProvider(name); err != nil {
+			c.JSON(http.StatusOK, gin.H{
+				"status":  "ok",
+				"warning": "provider deleted but failed to reload AI service: " + err.Error(),
+			})
+			return
 		}

 		c.JSON(http.StatusOK, gin.H{"status": "ok"})
@@ -814,3 +835,49 @@ func llmPrimaryConfigDTO(row storepkg.LLMPrimaryConfigRecord) map[string]any {
 		"updated_at":     row.UpdatedAt,
 	}
 }
+
+// ============================================
+// AI Service Status & Restart Handlers
+// ============================================
+
+func handleGetAIServiceStatus(aiService LLMProviderReloader) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		if aiService == nil {
+			c.JSON(http.StatusOK, gin.H{
+				"running":        false,
+				"enabled":        false,
+				"provider_count": 0,
+				"message":        "AI 服务未初始化",
+			})
+			return
+		}
+		status := aiService.AIServiceStatus()
+		c.JSON(http.StatusOK, gin.H{
+			"running":        status.Running,
+			"enabled":        status.Enabled,
+			"provider_count": status.ProviderCount,
+			"message":        status.Message,
+		})
+	}
+}
+
+func handleRestartAIService(aiService LLMProviderReloader) gin.HandlerFunc {
+	return func(c *gin.Context) {
+		if aiService == nil {
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "AI 服务未初始化，无法重启"})
+			return
+		}
+		if err := aiService.RestartAIService(); err != nil {
+			c.JSON(http.StatusInternalServerError, gin.H{"error": "重启 AI 服务失败: " + err.Error()})
+			return
+		}
+		status := aiService.AIServiceStatus()
+		c.JSON(http.StatusOK, gin.H{
+			"status":         "ok",
+			"running":        status.Running,
+			"enabled":        status.Enabled,
+			"provider_count": status.ProviderCount,
+			"message":        "AI 服务已重启",
+		})
+	}
+}
@@ -20,6 +20,7 @@ type PacketBuildOptions struct {
 	PSK         []byte
 	Encrypt     bool
 	ViaMQTT     bool
+	HopLimit    uint32
 }

 type TextMessageBuildOptions struct {
@@ -252,6 +253,14 @@ func buildMeshPacket(opts PacketBuildOptions, data []byte) ([]byte, error) {
 		out = protowire.AppendTag(out, 14, protowire.VarintType)
 		out = protowire.AppendVarint(out, 1)
 	}
+	hop := opts.HopLimit
+	if hop == 0 {
+		hop = 7
+	}
+	out = protowire.AppendTag(out, 9, protowire.VarintType)
+	out = protowire.AppendVarint(out, uint64(hop))
+	out = protowire.AppendTag(out, 15, protowire.VarintType)
+	out = protowire.AppendVarint(out, uint64(hop))
 	return out, nil
 }

@@ -0,0 +1,78 @@
+package mqttforward
+
+import (
+	"crypto/sha256"
+	"encoding/hex"
+	"sync"
+	"time"
+)
+
+const dedupTTL = 15 * time.Second
+
+type DedupQueue struct {
+	mu      sync.Mutex
+	entries map[string]time.Time
+	stopCh  chan struct{}
+}
+
+func NewDedupQueue() *DedupQueue {
+	return &DedupQueue{
+		entries: make(map[string]time.Time),
+		stopCh:  make(chan struct{}),
+	}
+}
+
+func (dq *DedupQueue) TryForward(topic string, payload []byte) bool {
+	hash := dedupHash(topic, payload)
+	now := time.Now()
+	dq.mu.Lock()
+	defer dq.mu.Unlock()
+	if expiry, ok := dq.entries[hash]; ok && now.Before(expiry) {
+		return false
+	}
+	dq.entries[hash] = now.Add(dedupTTL)
+	return true
+}
+
+func (dq *DedupQueue) Start() {
+	go func() {
+		ticker := time.NewTicker(dedupTTL)
+		defer ticker.Stop()
+		for {
+			select {
+			case <-ticker.C:
+				dq.cleanup()
+			case <-dq.stopCh:
+				return
+			}
+		}
+	}()
+}
+
+func (dq *DedupQueue) Stop() {
+	close(dq.stopCh)
+}
+
+func (dq *DedupQueue) Len() int {
+	dq.mu.Lock()
+	defer dq.mu.Unlock()
+	return len(dq.entries)
+}
+
+func (dq *DedupQueue) cleanup() {
+	now := time.Now()
+	dq.mu.Lock()
+	defer dq.mu.Unlock()
+	for hash, expiry := range dq.entries {
+		if now.After(expiry) {
+			delete(dq.entries, hash)
+		}
+	}
+}
+
+func dedupHash(topic string, payload []byte) string {
+	h := sha256.New()
+	h.Write([]byte(topic))
+	h.Write(payload)
+	return hex.EncodeToString(h.Sum(nil))
+}
@@ -290,27 +290,24 @@ func insertInboundBotDirectMessage(s *Store, record map[string]any, clientInfo M
 	}
 	_ = clientInfo // mqtt 元数据已经记录在 content_json 里，这里保留参数以保持队列签名一致

-	// 同时将消息添加到 LLM 队列（忽略机器人自己发送的消息）
-	if peerNodeID != bot.NodeID {
-		longName := NullableString(record["long_name"])
-		shortName := NullableString(record["short_name"])
-		channelID := NullableString(record["channel_id"])
-		_, err = s.EnqueueLLMMessage(LLMMessageQueueInput{
-			BotID:       bot.ID,
-			BotNodeID:   bot.NodeID,
-			BotNodeNum:  bot.NodeNum,
-			FromNodeID:  peerNodeID,
-			FromNodeNum: int64(peerNum),
-			LongName:    longName,
-			ShortName:   shortName,
-			Text:        text,
-			PacketID:    int64(packetID),
-			ChannelID:   channelID,
-			Topic:       topic,
-			MessageType: "direct",
-			ContentJSON: contentPtr,
-		})
-	}
+	longName := NullableString(record["long_name"])
+	shortName := NullableString(record["short_name"])
+	channelID := NullableString(record["channel_id"])
+	_, err = s.EnqueueLLMMessage(LLMMessageQueueInput{
+		BotID:       bot.ID,
+		BotNodeID:   bot.NodeID,
+		BotNodeNum:  bot.NodeNum,
+		FromNodeID:  peerNodeID,
+		FromNodeNum: int64(peerNum),
+		LongName:    longName,
+		ShortName:   shortName,
+		Text:        text,
+		PacketID:    int64(packetID),
+		ChannelID:   channelID,
+		Topic:       topic,
+		MessageType: "direct",
+		ContentJSON: contentPtr,
+	})
 	if err != nil {
 		printJSON(map[string]any{
 			"event":   "llm_queue_enqueue_failed",
@@ -66,6 +66,12 @@ func (s *Store) CountBotNodes(opts ListOptions) (int64, error) {
 	return total, s.db.Model(&BotNodeRecord{}).Count(&total).Error
 }

+func (s *Store) IsBotNodeID(nodeID string) bool {
+	var count int64
+	s.db.Model(&BotNodeRecord{}).Where("node_id = ?", nodeID).Count(&count)
+	return count > 0
+}
+
 func (s *Store) GetBotNode(id uint64) (*BotNodeRecord, error) {
 	var row BotNodeRecord
 	if err := s.db.Where("id = ?", id).Take(&row).Error; err != nil {
@@ -306,8 +306,7 @@ func (s *Store) EnqueueLLMMessage(input LLMMessageQueueInput) (*LLMMessageQueueR
 		return nil, nil // 机器人的 LLM 队列未启用，静默返回
 	}

-	// 忽略机器人自己发送的消息，避免自循环
-	if input.FromNodeID == bot.NodeID {
+	if s.IsBotNodeID(input.FromNodeID) {
 		return nil, nil
 	}

@@ -526,6 +525,10 @@ func enqueueChannelMessageToLLM(s *Store, record map[string]any) error {
 		shortName = &sn
 	}

+	if s.IsBotNodeID(fromNodeID) {
+		return nil
+	}
+
 	var channelID *string
 	if cid, ok := record["channel_id"].(string); ok && cid != "" {
 		channelID = &cid
@@ -546,11 +549,7 @@ func enqueueChannelMessageToLLM(s *Store, record map[string]any) error {
 		return fmt.Errorf("query bots for channel message enqueue: %w", err)
 	}

-	// 为每个符合条件的机器人创建一条队列记录（忽略机器人自己发送的消息）
 	for _, bot := range bots {
-		if fromNodeID == bot.NodeID {
-			continue
-		}
 		_, err = s.EnqueueLLMMessage(LLMMessageQueueInput{
 			BotID:       bot.ID,
 			BotNodeID:   bot.NodeID,
@@ -88,6 +88,7 @@ func RunAgentToolLoop(ctx context.Context, state *State, profile *llm.Profile, s
 	if routerPrompt == "" {
 		routerPrompt = primaryPrompt
 	}
+	routerPrompt = routerPrompt + "\n当前日期：" + time.Now().Format("2006-01-02")
 	if primaryPrompt != "" {
 		primarySystemMessage := &model.ChatCompletionMessage{
 			Role: "system",
@@ -48,7 +48,7 @@ func NewState(cfg *Config, ai *llm.State, options ...Option) (*State, error) {
 			Enabled:      true,
 			Timeout:      30,
 			MaxTokens:    512,
-			SystemPrompt: "你可以按需直接调用可用工具来回答用户问题。\n每个工具的 description 描述了它的适用场景和调用条件。\n工具结果优先于模型内置知识；工具失败时必须如实说明，不要编造结果。\n只调用确实必要的工具。",
+			SystemPrompt: "你可以按需直接调用可用工具来回答用户问题。\n每个工具的 description 描述了它的适用场景和调用条件。\n工具结果优先于模型内置知识；工具失败时必须如实说明，不要编造结果。\n只调用确实必要的工具。\n\n重要规则：\n- 当用户问题包含\"今天\"、\"昨天\"、\"最近\"、\"本周\"、\"本月\"等相对时间词时，你必须先调用 time 工具获取当前准确日期，然后再用该日期调用其他工具。绝不可以使用模型内置知识猜测日期。\n- 你不知道\"今天\"是哪一天，必须通过 time 工具查询。",
 		}
 	}
 	if ai == nil {
@@ -30,6 +30,7 @@ type MQTTRuntimeStatus struct {
 	Stats       *mqttforwardpkg.Stats
 	ClientStats *mqttforwardpkg.ClientStats
 	DBQueue     *storepkg.WriteQueue
+	DedupQueue  *mqttforwardpkg.DedupQueue
 }

 // AdminMQTTStatus 是 admin 路由 GET /admin/mqtt-status 返回的 JSON 视图。
@@ -50,6 +51,7 @@ type AdminMQTTStatus struct {
 	MessagesSent        int64             `json:"messages_sent"`
 	MessagesDropped     int64             `json:"messages_dropped"`
 	DBWriteQueueLength  int               `json:"db_write_queue_length"`
+	DedupQueueLength    int               `json:"dedup_queue_len"`
 	Retained            int64             `json:"retained"`
 	Inflight            int64             `json:"inflight"`
 	InflightDropped     int64             `json:"inflight_dropped"`
@@ -71,7 +73,7 @@ type AdminMQTTClient struct {
 // Status 实现 MQTTStatusProvider。
 func (m MQTTRuntimeStatus) Status() AdminMQTTStatus {
 	if m.Server == nil || m.Server.Info == nil {
-		return AdminMQTTStatus{Running: false, Address: m.Address, TLS: m.TLS, DBWriteQueueLength: m.DBQueue.Len()}
+		return AdminMQTTStatus{Running: false, Address: m.Address, TLS: m.TLS, DBWriteQueueLength: m.DBQueue.Len(), DedupQueueLength: m.dedupQueueLen()}
 	}
 	info := m.Server.Info.Clone()
 	status := AdminMQTTStatus{
@@ -91,6 +93,7 @@ func (m MQTTRuntimeStatus) Status() AdminMQTTStatus {
 		MessagesSent:        m.Stats.Forwarded(),
 		MessagesDropped:     m.Stats.Dropped(),
 		DBWriteQueueLength:  m.DBQueue.Len(),
+		DedupQueueLength:    m.dedupQueueLen(),
 		Retained:            info.Retained,
 		Inflight:            info.Inflight,
 		InflightDropped:     info.InflightDropped,
@@ -136,6 +139,13 @@ func mqttClientInfo(c *mqtt.Client) mqttClientInfoView {
 	}
 }

+func (m MQTTRuntimeStatus) dedupQueueLen() int {
+	if m.DedupQueue == nil {
+		return 0
+	}
+	return m.DedupQueue.Len()
+}
+
 // DisconnectClient 实现 MQTTStatusProvider：发送 Disconnect 报文并关闭连接。
 // 使用 ErrAdministrativeAction 作为断开理由，便于日志区分。
 func (m MQTTRuntimeStatus) DisconnectClient(clientID string) bool {
@@ -13,6 +13,7 @@ import (
 	"github.com/gin-gonic/gin"
 	"gorm.io/gorm"

+	aipkg "meshtastic_mqtt_server/internal/ai"
 	"meshtastic_mqtt_server/internal/auth"
 	blockingpkg "meshtastic_mqtt_server/internal/blocking"
 	botpkg "meshtastic_mqtt_server/internal/bot"
@@ -32,6 +33,8 @@ type LLMProviderReloader interface {
 	ReloadLLMProvider(config interface{}) error
 	AddLLMProvider(config interface{}) error
 	RemoveLLMProvider(name string) error
+	AIServiceStatus() aipkg.AIServiceStatus
+	RestartAIService() error
 }

 func NewHTTPServer(cfg configpkg.WebConfig, consoleLog bool, store *storepkg.Store, sessions *auth.Manager, mqttStatus MQTTStatusProvider, blocking *blockingpkg.Cache, forwarder mqttforwardpkg.Reloader, settings *rspkg.Cache, botSender botpkg.TextSender, aiService LLMProviderReloader) *http.Server {
@@ -57,8 +57,9 @@ type meshtasticFilterHook struct {
 	settings        *rspkg.Cache
 	pkiResolver     func(toNodeNum, fromNodeNum uint32) ([]byte, []byte, bool)
 	autoAcker       func(record map[string]any)
-	consoleLog      bool // 控制台是否打印 MQTT 连接/订阅事件
+	consoleLog       bool // 控制台是否打印 MQTT 连接/订阅事件
 	packetConsoleLog bool // 控制台是否打印 Meshtastic 数据包
+	dedupQueue       *mqttforwardpkg.DedupQueue
 }

 // ID 返回用于识别 Meshtastic payload 过滤器的 hook 名称。
@@ -225,6 +226,10 @@ func (h *meshtasticFilterHook) OnPublish(cl *mqtt.Client, pk packets.Packet) (pa
 		h.rejectPublish(cl, pk, record)
 		return pk, packets.ErrRejectPacket
 	}
+	if h.dedupQueue != nil && !h.dedupQueue.TryForward(pk.TopicName, pk.Payload) {
+		h.stats.IncDropped()
+		return pk, packets.ErrRejectPacket
+	}
 	h.stats.IncForwarded()

 	h.dbQueue.EnqueueRecord(record, mqttClientInfoFromClient(cl))
@@ -393,16 +398,48 @@ func run(cfg *configpkg.Config) error {
 	defer forwardManager.StopAll()

 	// Initialize AI Service
-	var aiService *ai.Service
+	// Create bot sender adapter - 支持频道消息和私聊消息两种发送方式
+	botSenderAdapter := autoreply.NewBotServiceAdapter(
+		// SendDirectText: 发送私聊消息
+		func(ctx context.Context, botID uint64, toNodeNum int64, text string) error {
+			_, err := botSender.SendText(ctx, botpkg.SendTextRequest{
+				BotID:       botID,
+				MessageType: "direct",
+				ToNodeNum:   &toNodeNum,
+				Text:        text,
+			})
+			return err
+		},
+		// SendChannelText: 发送频道消息
+		func(ctx context.Context, botID uint64, channelID string, text string) error {
+			_, err := botSender.SendText(ctx, botpkg.SendTextRequest{
+				BotID:       botID,
+				MessageType: "channel",
+				ChannelID:   channelID,
+				Text:        text,
+			})
+			return err
+		},
+	)
+
+	aiManager := ai.NewAIManager(ai.Config{
+		DataDir:          cfg.AI.DataDir,
+		Enabled:          cfg.AI.Enabled,
+		ConsoleLog:       cfg.ConsoleLog.LLM,
+		ToolConfigStore:  store,
+		ToolRouterStore:  store,
+		TopicRouterStore: store,
+		Store:            store,
+	}, store.DB(), botSenderAdapter, botCtx, store)
+
 	if cfg.AI.Enabled {
-		// Get LLM providers from database
-		llmProviders, err := store.ListLLMProviders(true)
+		aiManager.SetConfigEnabled(true)
+		providers, err := store.ListLLMProviders(true)
 		if err != nil {
 			fmt.Fprintf(os.Stderr, "Warning: failed to load LLM providers: %v\n", err)
-		} else if len(llmProviders) > 0 {
-			// Convert database records to provider configs
-			providerConfigs := make([]llm.ProviderConfig, 0, len(llmProviders))
-			for _, p := range llmProviders {
+		} else if len(providers) > 0 {
+			providerConfigs := make([]llm.ProviderConfig, 0, len(providers))
+			for _, p := range providers {
 				providerConfigs = append(providerConfigs, llm.ProviderConfig{
 					Name:                p.Name,
 					Active:              p.Active,
@@ -413,48 +450,11 @@ func run(cfg *configpkg.Config) error {
 					ContextWindowTokens: p.ContextWindowTokens,
 				})
 			}
-
-			// Create bot sender adapter - 支持频道消息和私聊消息两种发送方式
-			botSenderAdapter := autoreply.NewBotServiceAdapter(
-				// SendDirectText: 发送私聊消息
-				func(ctx context.Context, botID uint64, toNodeNum int64, text string) error {
-					_, err := botSender.SendText(ctx, botpkg.SendTextRequest{
-						BotID:       botID,
-						MessageType: "direct",
-						ToNodeNum:   &toNodeNum,
-						Text:        text,
-					})
-					return err
-				},
-				// SendChannelText: 发送频道消息
-				func(ctx context.Context, botID uint64, channelID string, text string) error {
-					_, err := botSender.SendText(ctx, botpkg.SendTextRequest{
-						BotID:       botID,
-						MessageType: "channel",
-						ChannelID:   channelID,
-						Text:        text,
-					})
-					return err
-				},
-			)
-
-			aiService, err = ai.NewService(ai.Config{
-				LLMProviders:     providerConfigs,
-				DataDir:          cfg.AI.DataDir,
-				Enabled:          cfg.AI.Enabled,
-				ConsoleLog:       cfg.ConsoleLog.LLM,
-				ToolConfigStore:  store,
-				ToolRouterStore:  store,
-				TopicRouterStore: store,
-				Store:            store,
-			}, store.DB(), botSenderAdapter)
-			if err != nil {
+			aiManager.SetProviderConfigs(providerConfigs)
+			if err := aiManager.Init(); err != nil {
 				fmt.Fprintf(os.Stderr, "Warning: failed to initialize AI service: %v\n", err)
 			} else {
-				if err := aiService.Start(botCtx); err != nil {
-					fmt.Fprintf(os.Stderr, "Warning: failed to start AI service: %v\n", err)
-				}
-				defer aiService.Stop()
+				defer aiManager.Stop()
 				printJSON(map[string]any{"event": "ai_service_started", "providers": len(providerConfigs)})
 			}
 		} else {
@@ -469,8 +469,8 @@ func run(cfg *configpkg.Config) error {
 		if err != nil {
 			return err
 		}
-		mqttStatus := webpkg.MQTTRuntimeStatus{Server: server, Address: mqttAddr, TLS: cfg.MQTT.TLS.Enabled, Stats: messageStats, ClientStats: clientStats, DBQueue: dbQueue}
-		handler := webpkg.NewRouter(cfg.Web, cfg.ConsoleLog.Web, store, sessions, mqttStatus, blocking, forwardManager, settings, botSender, aiService)
+		mqttStatus := webpkg.MQTTRuntimeStatus{Server: server, Address: mqttAddr, TLS: cfg.MQTT.TLS.Enabled, Stats: messageStats, ClientStats: clientStats, DBQueue: dbQueue, DedupQueue: mqttHook.dedupQueue}
+		handler := webpkg.NewRouter(cfg.Web, cfg.ConsoleLog.Web, store, sessions, mqttStatus, blocking, forwardManager, settings, botSender, aiManager)
 		webAddresses := []string{}
 		if cfg.Web.PortEnabled {
 			httpServer := &http.Server{
@@ -521,6 +521,9 @@ func run(cfg *configpkg.Config) error {
 	if err := server.Close(); err != nil && runErr == nil {
 		runErr = err
 	}
+	if mqttHook.dedupQueue != nil {
+		mqttHook.dedupQueue.Stop()
+	}
 	return runErr
 }

@@ -529,6 +532,8 @@ func startMQTTServer(cfg *configpkg.Config, store *storepkg.Store, dbQueue *stor
 	if err := server.AddHook(new(mqttauth.AllowHook), nil); err != nil {
 		return nil, nil, "", err
 	}
+	dedupQueue := mqttforwardpkg.NewDedupQueue()
+	dedupQueue.Start()
 	hook := &meshtasticFilterHook{
 		server:           server,
 		key:              cfg.Key,
@@ -540,6 +545,7 @@ func startMQTTServer(cfg *configpkg.Config, store *storepkg.Store, dbQueue *stor
 		pkiResolver:      botpkg.NewPKIKeyResolver(store),
 		consoleLog:       cfg.ConsoleLog.MQTT,
 		packetConsoleLog: cfg.ConsoleLog.Meshtastic,
+		dedupQueue:       dedupQueue,
 	}
 	if err := server.AddHook(hook, nil); err != nil {
 		return nil, nil, "", err
@@ -6,6 +6,7 @@ import type {
  AdminRuntimeSettingsPayload,
  AdminRuntimeSettingsResponse,
  AdminUsersResponse,
+  AIServiceStatus,
  BotMessage,
  BotMessageMutationResponse,
  BotNode,
@@ -515,8 +516,17 @@ export function updateLLMProvider(name: string, payload: Partial<LLMProviderPayl
  return putJSON<LLMProviderResponse>(`/api/admin/llm/providers/${encodeURIComponent(name)}`, payload)
 }

-export function deleteLLMProvider(name: string): Promise<{ status: string }> {
-  return deleteJSON<{ status: string }>(`/api/admin/llm/providers/${encodeURIComponent(name)}`)
+export function deleteLLMProvider(name: string): Promise<{ status: string; warning?: string }> {
+  return deleteJSON<{ status: string; warning?: string }>(`/api/admin/llm/providers/${encodeURIComponent(name)}`)
+}
+
+// AI Service Status API
+export function getAIServiceStatus(): Promise<AIServiceStatus> {
+  return getJSON<AIServiceStatus>('/api/admin/llm/status')
+}
+
+export function restartAIService(): Promise<AIServiceStatus & { status: string; message?: string }> {
+  return postJSON<AIServiceStatus & { status: string; message?: string }>('/api/admin/llm/restart')
 }

 // LLM Tool Router API
@@ -200,6 +200,7 @@ onBeforeUnmount(() => {
        <div><span>订阅数</span><strong>{{ status.subscriptions }}</strong></div>
        <div><span>转发消息</span><strong>{{ status.messages_sent }}</strong></div>
        <div><span>数据库队列</span><strong>{{ status.db_write_queue_length }}</strong></div>
+        <div><span>去重队列</span><strong>{{ status.dedup_queue_len }}</strong></div>
        <a class="status-card-link" href="/admin/discard_details"><span>丢弃消息</span><strong>{{ status.messages_dropped }}</strong></a>
        <div><span>收到包</span><strong>{{ status.packets_received }}</strong></div>
        <div><span>发送包</span><strong>{{ status.packets_sent }}</strong></div>
@@ -11,12 +11,19 @@ import {
  updateLLMToolRouter,
  updateLLMTopicConfig,
  updateLLMPrimaryConfig,
+  getAIServiceStatus,
+  restartAIService,
 } from '../api'
-import type { LLMPlatformRouter, LLMTopicConfig, LLMProvider, LLMPrimaryConfig } from '../types'
+import type { LLMPlatformRouter, LLMTopicConfig, LLMProvider, LLMPrimaryConfig, AIServiceStatus } from '../types'

 const loading = ref(false)
 const error = ref('')
 const success = ref('')
+const showWarning = ref(false)
+
+// AI Service Status
+const aiStatus = ref<AIServiceStatus>({ running: false, enabled: false, provider_count: 0 })
+const restarting = ref(false)

 // LLM Provider 相关
 const providers = ref<LLMProvider[]>([])
@@ -169,12 +176,18 @@ async function saveProvider() {
  }

  try {
+    let response: any
    if (isCreatingProvider.value) {
-      await createLLMProvider(providerForm.value)
-      success.value = '创建成功'
+      response = await createLLMProvider(providerForm.value)
    } else if (editingProvider.value) {
-      await updateLLMProvider(editingProvider.value.name, providerForm.value)
-      success.value = '更新成功'
+      response = await updateLLMProvider(editingProvider.value.name, providerForm.value)
+    }
+    if (response.warning) {
+      success.value = response.warning
+      showWarning.value = true
+    } else {
+      success.value = isCreatingProvider.value ? '创建成功' : '更新成功'
+      showWarning.value = false
    }
    clearSuccess()
    closeProviderForm()
@@ -189,8 +202,14 @@ async function confirmDeleteProvider(name: string) {
    return
  }
  try {
-    await deleteLLMProvider(name)
-    success.value = '删除成功'
+    const response = await deleteLLMProvider(name)
+    if (response.warning) {
+      success.value = response.warning
+      showWarning.value = true
+    } else {
+      success.value = '删除成功'
+      showWarning.value = false
+    }
    clearSuccess()
    await loadProviders()
  } catch (err) {
@@ -286,7 +305,31 @@ async function savePrimaryConfig() {
  }
 }

+async function loadAIStatus() {
+  try {
+    aiStatus.value = await getAIServiceStatus()
+  } catch (err) {
+    console.warn('Failed to load AI service status', err)
+  }
+}
+
+async function handleRestartAI() {
+  if (!confirm('确定要重启 AI 服务吗？')) return
+  restarting.value = true
+  try {
+    const result = await restartAIService()
+    aiStatus.value = result
+    success.value = result.message || 'AI 服务已重启'
+    clearSuccess()
+  } catch (err) {
+    error.value = err instanceof Error ? err.message : String(err)
+  } finally {
+    restarting.value = false
+  }
+}
+
 onMounted(() => {
+  loadAIStatus()
  loadProviders()
  loadToolRouter()
  loadTopicConfig()
@@ -298,8 +341,23 @@ onMounted(() => {
  <div class="admin-llm-api">
    <h2>LLM API 配置管理</h2>

+    <div class="ai-status-bar">
+      <span class="status-indicator" :class="{ running: aiStatus.running, stopped: !aiStatus.running }"></span>
+      <span class="status-text">
+        <template v-if="aiStatus.running">AI 服务运行中，{{ aiStatus.provider_count }} 个提供商</template>
+        <template v-else>{{ aiStatus.message || 'AI 服务未运行' }}</template>
+      </span>
+      <button
+        class="admin-button admin-button-small"
+        :disabled="restarting"
+        @click="handleRestartAI"
+      >
+        {{ restarting ? '重启中...' : '重启 AI 服务' }}
+      </button>
+    </div>
+
    <p v-if="error" class="error">{{ error }}</p>
-    <p v-if="success" class="success">{{ success }}</p>
+    <p v-if="success" :class="showWarning ? 'warning' : 'success'">{{ success }}</p>

    <!-- LLM Provider 列表 -->
    <div class="admin-section">
@@ -690,13 +748,49 @@ onMounted(() => {
 }

 .admin-llm-api h2 {
-  margin: 0 0 2rem;
+  margin: 0 0 1rem;
  font-size: 1.75rem;
  font-weight: 700;
  color: #1e293b;
  letter-spacing: -0.02em;
 }

+.ai-status-bar {
+  display: flex;
+  align-items: center;
+  gap: 0.75rem;
+  padding: 0.75rem 1.25rem;
+  background: white;
+  border-radius: 12px;
+  border: 1px solid #e2e8f0;
+  margin-bottom: 1.5rem;
+  box-shadow: 0 1px 3px rgba(0, 0, 0, 0.05);
+}
+
+.status-indicator {
+  width: 10px;
+  height: 10px;
+  border-radius: 50%;
+  flex-shrink: 0;
+}
+
+.status-indicator.running {
+  background: #22c55e;
+  box-shadow: 0 0 6px rgba(34, 197, 94, 0.5);
+}
+
+.status-indicator.stopped {
+  background: #ef4444;
+  box-shadow: 0 0 6px rgba(239, 68, 68, 0.4);
+}
+
+.status-text {
+  flex: 1;
+  font-size: 0.9rem;
+  color: #475569;
+  font-weight: 500;
+}
+
 .admin-section {
  background: white;
  padding: 1.75rem;
@@ -973,6 +1067,19 @@ onMounted(() => {
  gap: 0.5rem;
 }

+.warning {
+  color: #92400e;
+  padding: 1rem 1.25rem;
+  background: linear-gradient(135deg, #fef3c7 0%, #fde68a 100%);
+  border-radius: 10px;
+  margin-bottom: 1.25rem;
+  border: 1px solid #fcd34d;
+  font-weight: 500;
+  display: flex;
+  align-items: center;
+  gap: 0.5rem;
+}
+
 .admin-loading {
  padding: 3rem;
  text-align: center;
@@ -364,6 +364,7 @@ export interface AdminMqttStatus {
  messages_sent: number
  messages_dropped: number
  db_write_queue_length: number
+  dedup_queue_len: number
  retained: number
  inflight: number
  inflight_dropped: number
@@ -643,6 +644,14 @@ export interface LLMProviderPayload {

 export interface LLMProviderResponse {
  item: LLMProvider
+  warning?: string
+}
+
+export interface AIServiceStatus {
+  running: boolean
+  enabled: boolean
+  provider_count: number
+  message?: string
 }

 // LLM Tool Router 相关类型
@@ -1 +1,2 @@
-__pycache__
+__pycache__
+db_config.py
@@ -0,0 +1,266 @@
+#!/usr/bin/env python3
+"""
+MySQL 8 -> MySQL 5.7 数据库迁移脚本
+
+依赖: pip install pymysql
+
+使用方法:
+    python py/migrate_mysql8_to_mysql57.py
+
+功能:
+    1. 从源 MySQL 8 读取表结构，修正 collation 后在目标 MySQL 5.7 建表
+    2. 逐表批量拷贝数据
+    3. 修正 auto-increment 值
+
+注意:
+    - 目标库应为空库（无同名表）
+    - 运行前请确保源库和目标库都可连接
+"""
+
+from __future__ import annotations
+
+import re
+import sys
+from typing import Any
+
+import pymysql
+import pymysql.cursors
+
+from db_config import SOURCE_CONFIG, TARGET_CONFIG
+
+BATCH_SIZE = 5000
+
+# ============================================================
+# 工具函数
+# ============================================================
+
+
+def _conn(config: dict[str, Any]) -> pymysql.Connection:
+    """创建数据库连接，使用 DictCursor 方便按列名访问"""
+    return pymysql.connect(
+        host=config["host"],
+        port=config["port"],
+        user=config["user"],
+        password=config["password"],
+        database=config["database"],
+        charset=config["charset"],
+        cursorclass=pymysql.cursors.DictCursor,
+    )
+
+
+def fix_collation(ddl: str) -> str:
+    """将 MySQL 8 默认 collation 替换为 MySQL 5.7 兼容版本"""
+    ddl = ddl.replace("utf8mb4_0900_ai_ci", "utf8mb4_general_ci")
+    ddl = ddl.replace("utf8mb4_0900_as_ci", "utf8mb4_general_ci")
+    return ddl
+
+
+def fix_text_blob_index(ddl: str) -> str:
+    """为 TEXT/BLOB 列在索引中添加前缀长度 (255)，兼容 MySQL 5.7"""
+    text_cols = set()
+    for m in re.finditer(r'`(\w+)`\s+(?:tinytext|text|mediumtext|longtext|tinyblob|blob|mediumblob|longblob)\b', ddl, re.IGNORECASE):
+        text_cols.add(m.group(1))
+    if not text_cols:
+        return ddl
+
+    def _add_prefix(match: re.Match) -> str:
+        col = match.group(1)
+        rest = match.group(2)
+        if col in text_cols and not rest.strip().startswith('('):
+            return f'`{col}`(255){rest}'
+        return match.group(0)
+
+    # 匹配 KEY 定义中的列引用: `col_name` 后面不跟 ( 的情况
+    ddl = re.sub(r'`(\w+)`(\s*[,\)])', _add_prefix, ddl)
+    return ddl
+
+
+def get_all_tables(conn: pymysql.Connection) -> list[str]:
+    with conn.cursor() as cur:
+        cur.execute("SHOW TABLES")
+        key = list(cur.description[0])[0]
+        return [row[key] for row in cur.fetchall()]
+
+
+def get_table_columns(conn: pymysql.Connection, table: str) -> list[str]:
+    """返回表的所有列名（按顺序）"""
+    with conn.cursor() as cur:
+        cur.execute("SHOW COLUMNS FROM `%s`" % table)
+        return [row["Field"] for row in cur.fetchall()]
+
+
+def get_auto_increment(
+    conn: pymysql.Connection, table: str
+) -> int | None:
+    """获取某张表当前的 AUTO_INCREMENT 值"""
+    with conn.cursor() as cur:
+        cur.execute(
+            "SELECT AUTO_INCREMENT FROM information_schema.TABLES "
+            "WHERE TABLE_SCHEMA = DATABASE() AND TABLE_NAME = %s",
+            (table,),
+        )
+        row = cur.fetchone()
+        if row and row["AUTO_INCREMENT"]:
+            return int(row["AUTO_INCREMENT"])
+    return None
+
+
+def row_count(conn: pymysql.Connection, table: str) -> int:
+    with conn.cursor() as cur:
+        cur.execute("SELECT COUNT(*) AS cnt FROM `%s`" % table)
+        return cur.fetchone()["cnt"]
+
+
+# ============================================================
+# 主流程
+# ============================================================
+
+
+def migrate() -> int:
+    src = _conn(SOURCE_CONFIG)
+    tgt = _conn(TARGET_CONFIG)
+    print(f"[连接] 源 MySQL 8 @ {SOURCE_CONFIG['host']}:{SOURCE_CONFIG['port']}")
+    print(f"[连接] 目标 MySQL 5.7 @ {TARGET_CONFIG['host']}:{TARGET_CONFIG['port']}")
+    print()
+
+    # 1. 在目标库建库（如还不存在）
+    try:
+        with tgt.cursor() as cur:
+            cur.execute(
+                "CREATE DATABASE IF NOT EXISTS `%s` "
+                "CHARACTER SET utf8mb4 COLLATE utf8mb4_general_ci"
+                % TARGET_CONFIG["database"]
+            )
+            cur.execute("USE `%s`" % TARGET_CONFIG["database"])
+        tgt.select_db(TARGET_CONFIG["database"])
+    except Exception as e:
+        print(f"[错误] 创建目标数据库失败: {e}")
+        return 1
+
+    tables = get_all_tables(src)
+    print(f"[发现] 源库共 {len(tables)} 张表: {', '.join(tables)}")
+    print()
+
+    # 2. 逐表建表（修正 collation）
+    print("=" * 60)
+    print("阶段 1: 在目标库创建表结构")
+    print("=" * 60)
+    for idx, table in enumerate(tables, 1):
+        with src.cursor() as cur:
+            cur.execute("SHOW CREATE TABLE `%s`" % table)
+            row = cur.fetchone()
+            ddl = row["Create Table"]
+        ddl = fix_collation(ddl)
+        ddl = fix_text_blob_index(ddl)
+
+        try:
+            with tgt.cursor() as cur:
+                cur.execute(ddl)
+            tgt.commit()
+            print(f"  [{idx:2d}/{len(tables)}] OK `{table}`")
+        except Exception as e:
+            print(f"  [{idx:2d}/{len(tables)}] 错误 `{table}`: {e}")
+            tgt.rollback()
+            return 1
+
+    print()
+
+    # 3. 逐表拷贝数据
+    print("=" * 60)
+    print("阶段 2: 拷贝表数据")
+    print("=" * 60)
+
+    total_rows_copied = 0
+    auto_increments: dict[str, int | None] = {}
+
+    for idx, table in enumerate(tables, 1):
+        columns = get_table_columns(src, table)
+        if not columns:
+            auto_increments[table] = None
+            print(f"  [{idx:2d}/{len(tables)}] SKIP `{table}` (0 列)")
+            continue
+
+        col_quoted = ", ".join("`%s`" % c for c in columns)
+        placeholders = ", ".join(["%s"] * len(columns))
+        insert_sql = "INSERT INTO `%s` (%s) VALUES (%s)" % (
+            table,
+            col_quoted,
+            placeholders,
+        )
+
+        table_count = 0
+        with src.cursor() as read_cur:
+            read_cur.execute("SELECT * FROM `%s`" % table)
+            batch = read_cur.fetchmany(BATCH_SIZE)
+            while batch:
+                rows_values = [
+                    [row.get(c) for c in columns] for row in batch
+                ]
+                try:
+                    with tgt.cursor() as write_cur:
+                        write_cur.executemany(insert_sql, rows_values)
+                    tgt.commit()
+                    table_count += len(rows_values)
+                    print(
+                        f"\r  [{idx:2d}/{len(tables)}] `{table}` -> {table_count} 行",
+                        end="",
+                        flush=True,
+                    )
+                except Exception as e:
+                    print()
+                    print(f"  [{idx:2d}/{len(tables)}] 错误 `{table}`: {e}")
+                    tgt.rollback()
+                    return 1
+                batch = read_cur.fetchmany(BATCH_SIZE)
+
+        # 修正 auto_increment
+        ai = get_auto_increment(src, table)
+        auto_increments[table] = ai
+        if ai is not None:
+            with tgt.cursor() as cur:
+                cur.execute(
+                    "ALTER TABLE `%s` AUTO_INCREMENT = %s" % (table, ai)
+                )
+            tgt.commit()
+
+        total_rows_copied += table_count
+        print(
+            f"\r  [{idx:2d}/{len(tables)}] `{table}` -> {table_count} 行  [OK]"
+        )
+
+    # 4. 验证
+    print()
+    print("=" * 60)
+    print("阶段 3: 验证行数")
+    print("=" * 60)
+    all_match = True
+    src_total = 0
+    tgt_total = 0
+    for table in tables:
+        s = row_count(src, table)
+        t = row_count(tgt, table)
+        src_total += s
+        tgt_total += t
+        status = "OK" if s == t else "不匹配!"
+        if s != t:
+            all_match = False
+        print(f"  `{table}`: 源={s}  目标={t}  [{status}]")
+
+    print()
+    print(f"  总计: 源={src_total}  目标={tgt_total}")
+
+    src.close()
+    tgt.close()
+
+    if all_match:
+        print()
+        print("迁移完成，所有表行数一致。")
+        return 0
+    else:
+        print()
+        print("警告: 部分表行数不一致，请检查。")
+        return 1
+
+
+if __name__ == "__main__":
+    sys.exit(migrate())
Author	SHA1	Message	Date
kevin	7bc2e53ce6	屏蔽机器人消息	2026-07-02 11:02:48 +08:00
kevin	6052bf90ec	调用签到🔧注入时间	2026-07-01 12:43:05 +08:00
kevin	16d0d0ec0b	up	2026-07-01 12:36:55 +08:00
kevin	f11c2ed138	回复ai回复emoji的能力	2026-07-01 12:24:38 +08:00
kevin	04e105c6ba	更新迁移脚本	2026-07-01 12:12:23 +08:00
kevin	99fb474bcf	ai服务状态更新	2026-07-01 11:55:37 +08:00
kevin	f6fa167d76	更新ai服务提醒	2026-07-01 11:26:08 +08:00
kevin	716f711373	up 安装脚本	2026-07-01 11:05:40 +08:00
kevin	a75ab812d2	添加 MySQL 8 到 MySQL 5.7 数据库迁移脚本	2026-06-30 12:36:43 +08:00
kevin	01c7275763	admin 页面 MQTT 服务状态增加去重队列长度显示	2026-06-30 12:18:40 +08:00
kevin	4782e84c15	添加 MQTT 消息去重队列：Hook 层基于 payload+topic hash 去重，TTL 15 秒，定时清理	2026-06-30 12:10:29 +08:00
kevin	ca59c5f316	修改机器人hops为7	2026-06-29 10:43:18 +08:00
kevinandClaude Fable 5	6620192322	签到检查功能增强：返回签到时间和内容问题： - 用户询问'我什么时候签到的'时，AI 说'系统只记录是否签到，没有时间戳' - 实际上数据库 signs 表有完整的 sign_time 和 sign_text 字段解决方案： - 修改 executeCheck 方法，改用 ListSigns 查询今天的签到记录 - 返回完整的签到详情：签到时间（HH:MM:SS格式）+ 签到内容 - 未签到时仍返回简单提示改动内容： - executeCheck 使用 ListSigns 替代 HasSignedOnDay - 构建 ListOptions 查询今天的签到记录（过滤 NodeID + 时间范围） - 返回格式：'XXX 今天已经签到过了。\n签到时间：10:30:45\n签到内容：上海-Kevin-GAT562签到' - 更新测试验证返回内容包含时间和签到文本 - 更新 mockSignStore.ListSigns 支持 NodeID 和 Limit 过滤使用效果： - 用户：'我今天签到了吗？' → 返回是否签到 + 时间 + 内容 - 用户：'我什么时候签到的？' → 返回签到时间：10:30:45 测试： - ✅ 未签到场景测试通过 - ✅ 已签到场景测试通过（验证时间和内容） - ✅ 所有签到工具测试通过 - ✅ 项目编译成功 Co-Authored-By: Claude Fable 5 <noreply@anthropic.com>	2026-06-23 21:47:16 +08:00