diff --git a/pkg/channels/dingtalk.go b/pkg/channels/dingtalk.go index 263785c0c..79cc85219 100644 --- a/pkg/channels/dingtalk.go +++ b/pkg/channels/dingtalk.go @@ -155,6 +155,14 @@ func (c *DingTalkChannel) onChatBotMessageReceived(ctx context.Context, data *ch "session_webhook": data.SessionWebhook, } + if data.ConversationType == "1" { + metadata["peer_kind"] = "direct" + metadata["peer_id"] = senderID + } else { + metadata["peer_kind"] = "group" + metadata["peer_id"] = data.ConversationId + } + logger.DebugCF("dingtalk", "Received message", map[string]interface{}{ "sender_nick": senderNick, "sender_id": senderID,