dingtalk reply with markdown as default

syonghua · syonghua · commit 5b456664d794 · 2026-03-16T15:48:25.000+08:00
diff --git a/backend/cmd/sop-chat-server/main.go b/backend/cmd/sop-chat-server/main.go
@@ -45,6 +45,11 @@ func main() {
 		return
 	}
 
+	// start 子命令：效果等同于直接运行（移除子命令参数后继续正常启动）
+	if len(os.Args) >= 2 && os.Args[1] == "start" {
+		os.Args = append(os.Args[:1], os.Args[2:]...)
+	}
+
 	// 解析命令行参数
 	var configPath string
 	var showHelp bool
@@ -58,6 +63,7 @@ func main() {
 		fmt.Fprintf(os.Stderr, "SOP Chat API Server\n\n")
 		fmt.Fprintf(os.Stderr, "用法: %s [子命令] [选项]\n\n", os.Args[0])
 		fmt.Fprintf(os.Stderr, "子命令:\n")
+		fmt.Fprintf(os.Stderr, "  start       启动服务（效果同直接运行，可附带选项）\n")
 		fmt.Fprintf(os.Stderr, "  stop        停止后台守护进程\n")
 		fmt.Fprintf(os.Stderr, "  adminurl    打印当前运行实例的配置管理 UI 地址\n\n")
 		fmt.Fprintf(os.Stderr, "选项:\n")
@@ -121,10 +127,11 @@ func main() {
 		if data, err := os.ReadFile(pidPath); err == nil {
 			if pid, err := strconv.Atoi(strings.TrimSpace(string(data))); err == nil {
 				if proc, err := os.FindProcess(pid); err == nil {
-					if proc.Signal(syscall.Signal(0)) == nil {
-						fmt.Fprintf(os.Stderr, "sop-chat-server 已在运行（PID=%d），\n如需重启请先执行: ./sop-chat-server stop\n如需查看管理地址: ./sop-chat-server adminurl\n", pid)
-						os.Exit(1)
-					}
+				if proc.Signal(syscall.Signal(0)) == nil {
+					fmt.Fprintf(os.Stderr, "sop-chat-server 已在运行（PID=%d），\n如需重启请先执行: ./sop-chat-server stop\n如需查看管理地址: ./sop-chat-server adminurl\n", pid)
+					fmt.Fprintln(os.Stderr, "❌ 启动失败")
+					os.Exit(1)
+				}
 				}
 			}
 			// PID 文件存在但进程已不在，清理残留文件
@@ -212,9 +219,39 @@ func main() {
 		logFile.Close() // 父进程不再需要，关闭自己持有的 fd
 
 		pidPath := filepath.Join(logsDir, adminPIDName)
-		fmt.Printf("守护进程已启动 PID=%d，端口绑定成功后 PID 将写入 %s\n", cmd.Process.Pid, pidPath)
+
+		// 等待子进程启动结果：轮询 PID 文件（子进程绑端口成功后写入），最多等待 10 秒。
+		// 若子进程提前退出则判定为启动失败。
+		started := false
+		deadline := time.Now().Add(10 * time.Second)
+		for time.Now().Before(deadline) {
+			// 检查子进程是否已退出（启动失败）
+			if err := cmd.Process.Signal(syscall.Signal(0)); err != nil {
+				break
+			}
+			// PID 文件出现即表示端口绑定成功
+			if data, err := os.ReadFile(pidPath); err == nil {
+				if pid, err := strconv.Atoi(strings.TrimSpace(string(data))); err == nil && pid == cmd.Process.Pid {
+					started = true
+					break
+				}
+			}
+			time.Sleep(200 * time.Millisecond)
+		}
+
+		if !started {
+			// 子进程已退出，从日志文件尾部取最后几行作为错误提示
+			fmt.Printf("❌ 启动失败（PID=%d 已退出），错误详情:\n", cmd.Process.Pid)
+			if tail := tailFile(logPath, 10); tail != "" {
+				fmt.Print(tail)
+			} else {
+				fmt.Printf("  （请查看日志: %s）\n", logPath)
+			}
+			os.Exit(1)
+		}
 		fmt.Printf("停止服务: ./sop-chat-server stop\n")
 		fmt.Printf("查看管理地址: ./sop-chat-server adminurl\n")
+		fmt.Printf("✅ 启动成功 PID=%d\n", cmd.Process.Pid)
 
 		return
 	}
@@ -440,6 +477,25 @@ func isPortAvailable(port int) bool {
 	return true
 }
 
+// tailFile 读取文件末尾最多 n 行并返回（用于启动失败时展示日志片段）。
+func tailFile(path string, n int) string {
+	data, err := os.ReadFile(path)
+	if err != nil {
+		return ""
+	}
+	lines := strings.Split(strings.TrimRight(string(data), "\n"), "\n")
+	if len(lines) > n {
+		lines = lines[len(lines)-n:]
+	}
+	var sb strings.Builder
+	for _, l := range lines {
+		sb.WriteString("  ")
+		sb.WriteString(l)
+		sb.WriteByte('\n')
+	}
+	return sb.String()
+}
+
 // localAddresses 返回本机所有真实 IPv4 单播地址，过滤掉常见虚拟网桥接口。
 func localAddresses() []string {
 	skipPrefixes := []string{"docker", "br-", "veth", "virbr", "vmnet", "vboxnet", "tun", "tap"}
diff --git a/backend/internal/api/server.go b/backend/internal/api/server.go
@@ -114,11 +114,17 @@ func NewServer(cfg *client.Config, globalConfig *config.Config, configPath strin
 	// 注册路由
 	server.setupRoutes()
 
-	if globalConfig != nil && globalConfig.Channels != nil {
+	if globalConfig != nil {
+		// 无论 CMS 凭据是否完整，都尝试启动 IM 渠道机器人。
+		// 机器人启动只需要各平台自身的凭据（如钉钉 clientId/clientSecret），
+		// CMS 凭据仅在响应消息时才用到；凭据缺失时机器人仍可连接，查询时再报错。
+		// 这与 reloadConfig 的行为保持一致。
 		cmsClientCfg, cmsErr := globalConfig.ToClientConfig()
 		if cmsErr != nil {
-			log.Printf("警告: 无法获取 CMS 配置，消息渠道机器人未启动: %v", cmsErr)
-		} else {
+			log.Printf("提示: CMS 凭据未配置或解析失败，消息渠道机器人将以空凭据启动（%v）", cmsErr)
+			cmsClientCfg = &config.ClientConfig{}
+		}
+		if globalConfig.Channels != nil {
 			// 启动钉钉机器人
 			if len(globalConfig.Channels.DingTalk) > 0 {
 				server.syncDingTalkBots(globalConfig.Channels.DingTalk, cmsClientCfg)
diff --git a/backend/internal/dingtalk/bot.go b/backend/internal/dingtalk/bot.go
@@ -157,14 +157,16 @@ func errorMessage(err error) string {
 	return err.Error()
 }
 
-// replyAtText 向钉钉回复文本，并 @ 提问者。
+// replyAtMarkdown 向钉钉发送 Markdown 消息，并 @ 提问者。
+// title 作为钉钉 markdown 消息的标题字段（不显示在正文中，但出现在通知预览）。
 // atDingtalkIds 负责触发客户端通知和渲染高亮 @，content 本身不再重复拼 @前缀，
 // 避免钉钉客户端自动显示的 @ 头与手动拼接的前缀重叠造成双 @。
-func replyAtText(ctx context.Context, webhook, senderId, _, content string) error {
+func replyAtMarkdown(ctx context.Context, webhook, senderId, title, content string) error {
 	body := map[string]interface{}{
-		"msgtype": "text",
-		"text": map[string]interface{}{
-			"content": content,
+		"msgtype": "markdown",
+		"markdown": map[string]interface{}{
+			"title": title,
+			"text":  content,
 		},
 		"at": map[string]interface{}{
 			"atDingtalkIds": []string{senderId},
@@ -253,13 +255,20 @@ func (b *Bot) onMessage(ctx context.Context, data *chatbot.BotCallbackDataModel)
 		}
 
 		log.Printf("[DingTalk] 正在回复钉钉消息，sessionWebhook=%s", webhook)
+
 		var replyErr error
 		if conversationType == "2" {
 			// 群聊：@ 提问者，触发客户端通知和高亮
-			replyErr = replyAtText(asyncCtx, webhook, senderId, senderNick, replyText)
+			replyErr = replyAtMarkdown(asyncCtx, webhook, senderId, "回复", replyText)
 		} else {
 			// 单聊：直接回复，无需 @
-			replyErr = chatbot.NewChatbotReplier().SimpleReplyText(asyncCtx, webhook, []byte(replyText))
+			replyErr = chatbot.NewChatbotReplier().ReplyMessage(asyncCtx, webhook, map[string]interface{}{
+				"msgtype": "markdown",
+				"markdown": map[string]interface{}{
+					"title": "回复",
+					"text":  replyText,
+				},
+			})
 		}
 		if replyErr != nil {
 			log.Printf("[DingTalk] 回复消息失败: %v", replyErr)
@@ -483,7 +492,7 @@ func (b *Bot) getOrCreateThreadId(conversationId, senderNick, employeeName strin
 }
 
 // conciseInstruction 是开启简洁模式时附加到用户消息末尾的指令
-const conciseInstruction = "\n\n（请用简洁的纯文本回答，避免复杂排版，适合在 IM 中直接阅读，控制在几句话以内。 尽量拟人的语气，少用markdown）"
+const conciseInstruction = "\n\n（请用简洁的回答，控制在几句话以内，尽量拟人的语气。）"
 
 // queryEmployee 向 CMS 数字员工发送消息，返回收集到的回复文本和线程 ID。
 // employeeName 为路由解析后的目标员工（可能与 cfg.EmployeeName 不同）。
diff --git a/frontend/public/config.html b/frontend/public/config.html
@@ -1596,7 +1596,7 @@
   ).join('');
   const whType = task.webhook ? (task.webhook.type || '') : '';
   const whUrl  = task.webhook ? (task.webhook.url || '') : '';
-  const whMsg  = task.webhook ? (task.webhook.msgType || 'text') : 'text';
+  const whMsg  = task.webhook ? (task.webhook.msgType || (task.webhook.type === 'dingtalk' ? 'markdown' : 'text')) : 'text';
   const whTitle = task.webhook ? (task.webhook.title || '') : '';
   const titleField = whMsg === 'text' ? 'style="display:none"' : '';
 
@@ -1692,7 +1692,7 @@
     cron: '0 9 * * 1-5',
     employeeName: 'apsara-ops',
     conciseReply: true,
-    webhook: { type: 'dingtalk', msgType: 'text' },
+    webhook: { type: 'dingtalk', msgType: 'markdown', title: '定时任务通知' },
   }, container.children.length, true));
 }
 
@@ -1761,8 +1761,16 @@
   const card = sel.closest('.task-card');
   const msgSel = card.querySelector('[data-field=webhookMsgType]');
   if (!msgSel) return;
-  // 重建 options，保留当前选中值（如果新平台不支持则回退到第一项）
-  msgSel.innerHTML = buildMsgTypeOptions(sel.value, msgSel.value);
+  // 钉钉默认使用 markdown，其他平台保留当前选中值（不支持则回退到第一项）
+  const preferredMsg = sel.value === 'dingtalk' ? 'markdown' : msgSel.value;
+  msgSel.innerHTML = buildMsgTypeOptions(sel.value, preferredMsg);
+  // 切换到钉钉且标题为空时，补上默认标题
+  if (sel.value === 'dingtalk') {
+    const titleInput = card.querySelector('[data-field=webhookTitle]');
+    if (titleInput && !titleInput.value.trim()) {
+      titleInput.value = '定时任务通知';
+    }
+  }
   onMsgTypeChange(msgSel);
 }
 
