feat: 支持快速回复文本消息和 Markdown 消息

app-stream-api/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>open-app-stream-client</artifactId>
         <groupId>com.dingtalk.open</groupId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <modelVersion>4.0.0</modelVersion>

app-stream-api/src/main/java/com/dingtalk/open/app/api/chatbot/BotReplier.java

@@ -0,0 +1,113 @@
+package com.dingtalk.open.app.api.chatbot;
+
+import com.alibaba.fastjson.JSON;
+import com.alibaba.fastjson.serializer.SerializerFeature;
+import com.dingtalk.open.app.api.open.http.HttpConstants;
+import com.dingtalk.open.app.api.util.IoUtils;
+
+import java.io.IOException;
+import java.net.HttpURLConnection;
+import java.net.URL;
+import java.nio.charset.StandardCharsets;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+public class BotReplier {
+    private final String webhook;
+    private final int timeout = 60000;
+
+    public BotReplier(String webhook) {
+        this.webhook = webhook;
+    }
+
+    public static BotReplier fromWebhook(String webhook) {
+        return new BotReplier(webhook);
+    }
+
+    public String replyText(String text) throws IOException {
+        return replyText(text, null);
+    }
+    public String replyMarkdown(String title, String text) throws IOException {
+        return replyMarkdown(title, text, null);
+    }
+
+    public String replyText(String text, List<String> atUserIds) throws IOException {
+        final HttpURLConnection connection = getHttpURLConnection();
+
+        Map<String, Object> textContent = new HashMap<>();
+        textContent.put("content", text);
+        Map<String, Object> request = new HashMap<>();
+        request.put("msgtype", "text");
+        request.put("text", textContent);
+        if (atUserIds != null && atUserIds.size() > 0) {
+            Map<String, Object> atContent = new HashMap<>();
+            atContent.put("atUserIds", Collections.singletonList(""));
+            request.put("at", atContent);
+        }
+        connection.getOutputStream().write(JSON.toJSONBytes(request, SerializerFeature.WriteEnumUsingToString));
+        connection.getOutputStream().flush();
+        if (connection.getResponseCode() == HttpConstants.STATUS_OK) {
+            try {
+                byte[] bytes = IoUtils.readAll(connection.getInputStream());
+                return new String(bytes, StandardCharsets.UTF_8);
+            } catch (Exception e) {
+                throw new IOException(e.getMessage());
+            }
+        } else {
+            try {
+                byte[] bytes = IoUtils.readAll(connection.getErrorStream());
+                throw new IOException(String.format("status=%s, msg=%s", connection.getResponseCode(), bytes != null ? new String(bytes) : ""));
+            } catch (Exception e) {
+                throw new IOException(e.getMessage());
+            }
+        }
+    }
+
+
+    public String replyMarkdown(String title, String text, List<String> atUserIds) throws IOException {
+        final HttpURLConnection connection = getHttpURLConnection();
+        Map<String, Object> markdownContent = new HashMap<>();
+        markdownContent.put("title", title);
+        markdownContent.put("text", text);
+        Map<String, Object> request = new HashMap<>();
+        request.put("msgtype", "markdown");
+        request.put("markdown", markdownContent);
+        if (atUserIds != null && atUserIds.size() > 0) {
+            Map<String, Object> atContent = new HashMap<>();
+            atContent.put("atUserIds", Collections.singletonList(""));
+            request.put("at", atContent);
+        }
+        connection.getOutputStream().write(JSON.toJSONBytes(request, SerializerFeature.WriteEnumUsingToString));
+        connection.getOutputStream().flush();
+        if (connection.getResponseCode() == HttpConstants.STATUS_OK) {
+            try {
+                byte[] bytes = IoUtils.readAll(connection.getInputStream());
+                return new String(bytes, StandardCharsets.UTF_8);
+            } catch (Exception e) {
+                throw new IOException(e.getMessage());
+            }
+        } else {
+            try {
+                byte[] bytes = IoUtils.readAll(connection.getErrorStream());
+                throw new IOException(String.format("status=%s, msg=%s", connection.getResponseCode(), bytes != null ? new String(bytes) : ""));
+            } catch (Exception e) {
+                throw new IOException(e.getMessage());
+            }
+        }
+    }
+
+    private HttpURLConnection getHttpURLConnection() throws IOException {
+        final HttpURLConnection connection = (HttpURLConnection) new URL(webhook).openConnection();
+        connection.setRequestMethod(HttpConstants.METHOD_POST);
+        connection.setReadTimeout(this.timeout);
+        connection.setConnectTimeout(this.timeout);
+        connection.setRequestProperty(HttpConstants.HEADER_CONTENT_TYPE, HttpConstants.CONTENT_TYPE_APPLICATION_JSON);
+        connection.setRequestProperty(HttpConstants.HEADER_ACCEPT, "application/json");
+        connection.setDoInput(true);
+        connection.setDoOutput(true);
+        connection.connect();
+        return connection;
+    }
+}

app-stream-client/pom.xml

@@ -4,13 +4,13 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>app-stream-client</artifactId>
     <packaging>jar</packaging>
-    <version>1.1.0</version>
+    <version>1.2.0</version>
     <name>app-stream-client</name>
 
     <dependencies>

app-stream-network/app-stream-network-api/pom.xml

@@ -4,12 +4,12 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>app-stream-network-api</artifactId>
-    <version>1.1.0</version>
+    <version>1.2.0</version>
     <packaging>jar</packaging>
 
     <name>app-stream-network-api</name>

app-stream-network/app-stream-network-core/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

app-stream-network/app-stream-network-rsocket/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

app-stream-network/app-stream-network-ws/pom.xml

@@ -4,7 +4,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>app-stream-network</artifactId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 

app-stream-network/pom.xml

@@ -5,7 +5,7 @@
     <parent>
         <artifactId>open-app-stream-client</artifactId>
         <groupId>com.dingtalk.open</groupId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
     <packaging>pom</packaging>

app-stream-protocol/pom.xml

@@ -6,7 +6,7 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
     </parent>
 
     <artifactId>app-stream-protocol</artifactId>

dingtalk-stream/pom.xml

@@ -4,13 +4,13 @@
     <parent>
         <groupId>com.dingtalk.open</groupId>
         <artifactId>open-app-stream-client</artifactId>
-        <version>1.1.0</version>
+        <version>1.2.0</version>
         <relativePath>../pom.xml</relativePath>
     </parent>
 
     <artifactId>dingtalk-stream</artifactId>
     <packaging>jar</packaging>
-    <version>1.1.0</version>
+    <version>1.2.0</version>
     <name>app-stream-client</name>
 
     <dependencies>

pom.xml

@@ -5,7 +5,7 @@
     <groupId>com.dingtalk.open</groupId>
     <artifactId>open-app-stream-client</artifactId>
     <packaging>pom</packaging>
-    <version>1.1.0</version>
+    <version>1.2.0</version>
     <modules>
         <module>app-stream-client</module>
         <module>app-stream-api</module>

version.sh

@@ -1,3 +1,3 @@
 #!/usr/bin/env bash
 
-mvn versions:set -DnewVersion=1.1.0
+mvn versions:set -DnewVersion=1.2.0