添加企微智能机器人消息接收和主动发送功能

weixin-java-cp/INTELLIGENT_ROBOT.md

@@ -73,6 +73,42 @@ String sessionId = "session123";
 robotService.resetSession(robotId, userid, sessionId);
 ```
 
+### 主动发送消息
+
+智能机器人可以主动向用户发送消息，用于推送通知或提醒。
+
+```java
+WxCpIntelligentRobotSendMessageRequest request = new WxCpIntelligentRobotSendMessageRequest();
+request.setRobotId("robot_id_here");
+request.setUserid("user123");
+request.setMessage("您好，这是来自智能机器人的主动消息");
+request.setSessionId("session123"); // 可选，用于保持会话连续性
+
+WxCpIntelligentRobotSendMessageResponse response = robotService.sendMessage(request);
+String msgId = response.getMsgId();
+String sessionId = response.getSessionId();
+```
+
+### 接收用户消息
+
+当用户向智能机器人发送消息时，企业微信会通过回调接口推送消息。可以使用 `WxCpXmlMessage` 接收和解析这些消息：
+
+```java
+// 在接收回调消息的接口中
+WxCpXmlMessage message = WxCpXmlMessage.fromEncryptedXml(
+ requestBody, wxCpConfigStorage, timestamp, nonce, msgSignature
+);
+
+// 获取智能机器人相关字段
+String robotId = message.getRobotId(); // 机器人ID
+String sessionId = message.getSessionId(); // 会话ID
+String content = message.getContent(); // 消息内容
+String fromUser = message.getFromUserName(); // 发送用户
+
+// 处理消息并回复
+// ...
+```
+
 ### 删除智能机器人
 
 ```java
@@ -87,13 +123,19 @@ robotService.deleteRobot(robotId);
 - `WxCpIntelligentRobotCreateRequest`: 创建机器人请求
 - `WxCpIntelligentRobotUpdateRequest`: 更新机器人请求 
 - `WxCpIntelligentRobotChatRequest`: 智能对话请求
+- `WxCpIntelligentRobotSendMessageRequest`: 主动发送消息请求
 
 ### 响应类
 
 - `WxCpIntelligentRobotCreateResponse`: 创建机器人响应
 - `WxCpIntelligentRobotChatResponse`: 智能对话响应
+- `WxCpIntelligentRobotSendMessageResponse`: 主动发送消息响应
 - `WxCpIntelligentRobot`: 机器人信息实体
 
+### 消息接收
+
+- `WxCpXmlMessage`: 支持接收智能机器人回调消息，包含 `robotId` 和 `sessionId` 字段
+
 ### 服务接口
 
 - `WxCpIntelligentRobotService`: 智能机器人服务接口

weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpIntelligentRobotService.java

@@ -64,4 +64,14 @@ public interface WxCpIntelligentRobotService {
  */
  void resetSession(String robotId, String userid, String sessionId) throws WxErrorException;
 
+ /**
+ * 智能机器人主动发送消息
+ * 官方文档: https://developer.work.weixin.qq.com/document/path/100719
+ *
+ * @param request 发送消息请求参数
+ * @return 发送消息响应
+ * @throws WxErrorException 微信接口异常
+ */
+ WxCpIntelligentRobotSendMessageResponse sendMessage(WxCpIntelligentRobotSendMessageRequest request) throws WxErrorException;
+
 }

weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/WxCpIntelligentRobotServiceImpl.java

@@ -61,4 +61,10 @@ public void resetSession(String robotId, String userid, String sessionId) throws
  this.cpService.post(RESET_SESSION, jsonObject.toString());
  }
 
+ @Override
+ public WxCpIntelligentRobotSendMessageResponse sendMessage(WxCpIntelligentRobotSendMessageRequest request) throws WxErrorException {
+ String responseText = this.cpService.post(SEND_MESSAGE, request.toJson());
+ return WxCpIntelligentRobotSendMessageResponse.fromJson(responseText);
+ }
+
 }

weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/intelligentrobot/WxCpIntelligentRobotSendMessageRequest.java

@@ -0,0 +1,56 @@
+package me.chanjar.weixin.cp.bean.intelligentrobot;
+
+import com.google.gson.annotations.SerializedName;
+import lombok.Data;
+import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
+
+import java.io.Serializable;
+
+/**
+ * 智能机器人发送消息请求
+ * 官方文档: https://developer.work.weixin.qq.com/document/path/100719
+ *
+ * @author Binary Wang
+ */
+@Data
+public class WxCpIntelligentRobotSendMessageRequest implements Serializable {
+ private static final long serialVersionUID = -1L;
+
+ /**
+ * 机器人ID，必填
+ */
+ @SerializedName("robot_id")
+ private String robotId;
+
+ /**
+ * 接收消息的用户ID，必填
+ */
+ @SerializedName("userid")
+ private String userid;
+
+ /**
+ * 消息内容，必填
+ */
+ @SerializedName("message")
+ private String message;
+
+ /**
+ * 会话ID，可选，用于保持会话连续性
+ */
+ @SerializedName("session_id")
+ private String sessionId;
+
+ /**
+ * 消息ID，可选
+ */
+ @SerializedName("msg_id")
+ private String msgId;
+
+ public String toJson() {
+ return WxCpGsonBuilder.create().toJson(this);
+ }
+
+ public static WxCpIntelligentRobotSendMessageRequest fromJson(String json) {
+ return WxCpGsonBuilder.create().fromJson(json, WxCpIntelligentRobotSendMessageRequest.class);
+ }
+}

weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/intelligentrobot/WxCpIntelligentRobotSendMessageResponse.java

@@ -0,0 +1,42 @@
+package me.chanjar.weixin.cp.bean.intelligentrobot;
+
+import com.google.gson.annotations.SerializedName;
+import lombok.Data;
+import lombok.EqualsAndHashCode;
+import me.chanjar.weixin.cp.bean.WxCpBaseResp;
+import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
+
+import java.io.Serializable;
+
+/**
+ * 智能机器人发送消息响应
+ * 官方文档: https://developer.work.weixin.qq.com/document/path/100719
+ *
+ * @author Binary Wang
+ */
+@Data
+@EqualsAndHashCode(callSuper = true)
+public class WxCpIntelligentRobotSendMessageResponse extends WxCpBaseResp implements Serializable {
+ private static final long serialVersionUID = -1L;
+
+ /**
+ * 消息ID
+ */
+ @SerializedName("msg_id")
+ private String msgId;
+
+ /**
+ * 会话ID
+ */
+ @SerializedName("session_id")
+ private String sessionId;
+
+ public static WxCpIntelligentRobotSendMessageResponse fromJson(String json) {
+ return WxCpGsonBuilder.create().fromJson(json, WxCpIntelligentRobotSendMessageResponse.class);
+ }
+
+ @Override
+ public String toJson() {
+ return WxCpGsonBuilder.create().toJson(this);
+ }
+}

weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/message/WxCpXmlMessage.java

@@ -253,6 +253,24 @@ public class WxCpXmlMessage implements Serializable {
  @XStreamConverter(value = XStreamCDataConverter.class)
  private String linkId;
 
+ /**
+ * 智能机器人ID
+ * 接收智能机器人消息时使用
+ * https://developer.work.weixin.qq.com/document/path/100719
+ */
+ @XStreamAlias("RobotId")
+ @XStreamConverter(value = XStreamCDataConverter.class)
+ private String robotId;
+
+ /**
+ * 智能机器人会话ID
+ * 接收智能机器人消息时使用，用于保持会话连续性
+ * https://developer.work.weixin.qq.com/document/path/100719
+ */
+ @XStreamAlias("SessionId")
+ @XStreamConverter(value = XStreamCDataConverter.class)
+ private String sessionId;
+
  /**
  * 通讯录变更事件.
  * 请参考常量 me.chanjar.weixin.cp.constant.WxCpConsts.ContactChangeType

weixin-java-cp/src/main/java/me/chanjar/weixin/cp/constant/WxCpApiPathConsts.java

@@ -1666,5 +1666,11 @@ interface IntelligentRobot {
  * 重置智能机器人会话
  */
  String RESET_SESSION = "/cgi-bin/intelligent_robot/reset_session";
+
+ /**
+ * 智能机器人主动发送消息
+ * 官方文档: https://developer.work.weixin.qq.com/document/path/100719
+ */
+ String SEND_MESSAGE = "/cgi-bin/intelligent_robot/send_message";
  }
 }

weixin-java-cp/src/test/java/me/chanjar/weixin/cp/api/impl/WxCpIntelligentRobotServiceImplTest.java

@@ -85,4 +85,38 @@ public void testServiceIntegration() {
  assert this.wxCpService.getIntelligentRobotService() != null;
  assert this.wxCpService.getIntelligentRobotService() instanceof WxCpIntelligentRobotServiceImpl;
  }
+
+ @Test
+ public void testSendMessageRequest() {
+ // 测试主动发送消息请求对象创建
+ WxCpIntelligentRobotSendMessageRequest request = new WxCpIntelligentRobotSendMessageRequest();
+ request.setRobotId("robot123");
+ request.setUserid("user123");
+ request.setMessage("您好，这是来自智能机器人的主动消息");
+ request.setSessionId("session123");
+ request.setMsgId("msg123");
+
+ // 验证JSON序列化
+ String json = request.toJson();
+ assert json.contains("robot123");
+ assert json.contains("您好，这是来自智能机器人的主动消息");
+ assert json.contains("session123");
+
+ // 验证反序列化
+ WxCpIntelligentRobotSendMessageRequest fromJson = WxCpIntelligentRobotSendMessageRequest.fromJson(json);
+ assert fromJson.getRobotId().equals("robot123");
+ assert fromJson.getMessage().equals("您好，这是来自智能机器人的主动消息");
+ assert fromJson.getSessionId().equals("session123");
+ }
+
+ @Test
+ public void testSendMessageResponse() {
+ // 测试主动发送消息响应对象
+ String responseJson = "{\"errcode\":0,\"errmsg\":\"ok\",\"msg_id\":\"msg123\",\"session_id\":\"session123\"}";
+ WxCpIntelligentRobotSendMessageResponse response = WxCpIntelligentRobotSendMessageResponse.fromJson(responseJson);
+
+ assert response.getMsgId().equals("msg123");
+ assert response.getSessionId().equals("session123");
+ assert response.getErrcode() == 0;
+ }
 }

weixin-java-cp/src/test/java/me/chanjar/weixin/cp/bean/message/WxCpXmlMessageTest.java

@@ -471,4 +471,30 @@ public void testMsgIdStringAndNumericFormats() {
  WxCpXmlMessage wxMessageString = WxCpXmlMessage.fromXml(xmlWithString);
  assertEquals(wxMessageString.getMsgId(), "CAIQg/PKxgYY2sC9tpuAgAMg9/zKaw==");
  }
+
+ /**
+ * Test intelligent robot message parsing
+ * 测试智能机器人消息解析
+ */
+ public void testIntelligentRobotMessage() {
+ String xml = "<xml>"
+ + "<ToUserName><![CDATA[toUser]]></ToUserName>"
+ + "<FromUserName><![CDATA[fromUser]]></FromUserName>"
+ + "<CreateTime>1348831860</CreateTime>"
+ + "<MsgType><![CDATA[text]]></MsgType>"
+ + "<Content><![CDATA[你好，智能机器人]]></Content>"
+ + "<MsgId>msg123456</MsgId>"
+ + "<RobotId><![CDATA[robot_id_123]]></RobotId>"
+ + "<SessionId><![CDATA[session_id_456]]></SessionId>"
+ + "</xml>";
+ WxCpXmlMessage wxMessage = WxCpXmlMessage.fromXml(xml);
+ assertEquals(wxMessage.getToUserName(), "toUser");
+ assertEquals(wxMessage.getFromUserName(), "fromUser");
+ assertEquals(wxMessage.getCreateTime(), Long.valueOf(1348831860));
+ assertEquals(wxMessage.getMsgType(), WxConsts.XmlMsgType.TEXT);
+ assertEquals(wxMessage.getContent(), "你好，智能机器人");
+ assertEquals(wxMessage.getMsgId(), "msg123456");
+ assertEquals(wxMessage.getRobotId(), "robot_id_123");
+ assertEquals(wxMessage.getSessionId(), "session_id_456");
+ }
 }