Skip to content

Commit c08d81d

Browse files
Copilotbinarywang
Copilot
and
binarywang
committed
Implement enterprise WeChat intelligent robot interface
Co-authored-by: binarywang <1343140+binarywang@users.noreply.github.com>
1 parent bb2598d commit c08d81d

12 files changed

Lines changed: 572 additions & 0 deletions

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

Lines changed: 67 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,67 @@
1+
package me.chanjar.weixin.cp.api;
2+
3+
import me.chanjar.weixin.common.error.WxErrorException;
4+
import me.chanjar.weixin.cp.bean.intelligentrobot.*;
5+
6+
/**
7+
* 企业微信智能机器人接口
8+
* 官方文档: https://developer.work.weixin.qq.com/document/path/101039
9+
*
10+
* @author Binary Wang
11+
*/
12+
public interface WxCpIntelligentRobotService {
13+
14+
/**
15+
* 创建智能机器人
16+
*
17+
* @param request 创建请求参数
18+
* @return 创建结果
19+
* @throws WxErrorException 微信接口异常
20+
*/
21+
WxCpIntelligentRobotCreateResponse createRobot(WxCpIntelligentRobotCreateRequest request) throws WxErrorException;
22+
23+
/**
24+
* 删除智能机器人
25+
*
26+
* @param robotId 机器人ID
27+
* @throws WxErrorException 微信接口异常
28+
*/
29+
void deleteRobot(String robotId) throws WxErrorException;
30+
31+
/**
32+
* 更新智能机器人
33+
*
34+
* @param request 更新请求参数
35+
* @throws WxErrorException 微信接口异常
36+
*/
37+
void updateRobot(WxCpIntelligentRobotUpdateRequest request) throws WxErrorException;
38+
39+
/**
40+
* 查询智能机器人
41+
*
42+
* @param robotId 机器人ID
43+
* @return 机器人信息
44+
* @throws WxErrorException 微信接口异常
45+
*/
46+
WxCpIntelligentRobot getRobot(String robotId) throws WxErrorException;
47+
48+
/**
49+
* 智能机器人会话
50+
*
51+
* @param request 聊天请求参数
52+
* @return 聊天响应
53+
* @throws WxErrorException 微信接口异常
54+
*/
55+
WxCpIntelligentRobotChatResponse chat(WxCpIntelligentRobotChatRequest request) throws WxErrorException;
56+
57+
/**
58+
* 重置智能机器人会话
59+
*
60+
* @param robotId 机器人ID
61+
* @param userid 用户ID
62+
* @param sessionId 会话ID
63+
* @throws WxErrorException 微信接口异常
64+
*/
65+
void resetSession(String robotId, String userid, String sessionId) throws WxErrorException;
66+
67+
}

‎weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpService.java‎

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -587,4 +587,11 @@ public interface WxCpService extends WxService {
587587
* @return
588588
*/
589589
WxCpCorpGroupService getCorpGroupService();
590+
591+
/**
592+
* 获取智能机器人服务
593+
*
594+
* @return 智能机器人服务 intelligent robot service
595+
*/
596+
WxCpIntelligentRobotService getIntelligentRobotService();
590597
}

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@ public abstract class BaseWxCpServiceImpl<H, P> implements WxCpService, RequestH
7474

7575
private final WxCpMeetingService meetingService = new WxCpMeetingServiceImpl(this);
7676
private final WxCpCorpGroupService corpGroupService = new WxCpCorpGroupServiceImpl(this);
77+
private final WxCpIntelligentRobotService intelligentRobotService = new WxCpIntelligentRobotServiceImpl(this);
7778

7879
/**
7980
* 全局的是否正在刷新access token的锁.
@@ -702,4 +703,9 @@ public WxCpMeetingService getMeetingService() {
702703
public WxCpCorpGroupService getCorpGroupService() {
703704
return corpGroupService;
704705
}
706+
707+
@Override
708+
public WxCpIntelligentRobotService getIntelligentRobotService() {
709+
return this.intelligentRobotService;
710+
}
705711
}

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

Lines changed: 64 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,64 @@
1+
package me.chanjar.weixin.cp.api.impl;
2+
3+
import com.google.gson.JsonObject;
4+
import lombok.RequiredArgsConstructor;
5+
import me.chanjar.weixin.common.error.WxErrorException;
6+
import me.chanjar.weixin.cp.api.WxCpIntelligentRobotService;
7+
import me.chanjar.weixin.cp.api.WxCpService;
8+
import me.chanjar.weixin.cp.bean.intelligentrobot.*;
9+
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
10+
11+
import static me.chanjar.weixin.cp.constant.WxCpApiPathConsts.IntelligentRobot.*;
12+
13+
/**
14+
* 企业微信智能机器人接口实现
15+
*
16+
* @author Binary Wang
17+
*/
18+
@RequiredArgsConstructor
19+
public class WxCpIntelligentRobotServiceImpl implements WxCpIntelligentRobotService {
20+
21+
private final WxCpService cpService;
22+
23+
@Override
24+
public WxCpIntelligentRobotCreateResponse createRobot(WxCpIntelligentRobotCreateRequest request) throws WxErrorException {
25+
String responseText = this.cpService.post(CREATE_ROBOT, request.toJson());
26+
return WxCpIntelligentRobotCreateResponse.fromJson(responseText);
27+
}
28+
29+
@Override
30+
public void deleteRobot(String robotId) throws WxErrorException {
31+
JsonObject jsonObject = new JsonObject();
32+
jsonObject.addProperty("robot_id", robotId);
33+
this.cpService.post(DELETE_ROBOT, jsonObject.toString());
34+
}
35+
36+
@Override
37+
public void updateRobot(WxCpIntelligentRobotUpdateRequest request) throws WxErrorException {
38+
this.cpService.post(UPDATE_ROBOT, request.toJson());
39+
}
40+
41+
@Override
42+
public WxCpIntelligentRobot getRobot(String robotId) throws WxErrorException {
43+
JsonObject jsonObject = new JsonObject();
44+
jsonObject.addProperty("robot_id", robotId);
45+
String responseText = this.cpService.post(GET_ROBOT, jsonObject.toString());
46+
return WxCpIntelligentRobot.fromJson(responseText);
47+
}
48+
49+
@Override
50+
public WxCpIntelligentRobotChatResponse chat(WxCpIntelligentRobotChatRequest request) throws WxErrorException {
51+
String responseText = this.cpService.post(CHAT, request.toJson());
52+
return WxCpIntelligentRobotChatResponse.fromJson(responseText);
53+
}
54+
55+
@Override
56+
public void resetSession(String robotId, String userid, String sessionId) throws WxErrorException {
57+
JsonObject jsonObject = new JsonObject();
58+
jsonObject.addProperty("robot_id", robotId);
59+
jsonObject.addProperty("userid", userid);
60+
jsonObject.addProperty("session_id", sessionId);
61+
this.cpService.post(RESET_SESSION, jsonObject.toString());
62+
}
63+
64+
}

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

Lines changed: 77 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,77 @@
1+
package me.chanjar.weixin.cp.bean.intelligentrobot;
2+
3+
import com.google.gson.annotations.SerializedName;
4+
import lombok.Data;
5+
import lombok.EqualsAndHashCode;
6+
import me.chanjar.weixin.cp.bean.WxCpBaseResp;
7+
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
8+
9+
import java.io.Serializable;
10+
11+
/**
12+
* 智能机器人信息
13+
*
14+
* @author Binary Wang
15+
*/
16+
@Data
17+
@EqualsAndHashCode(callSuper = true)
18+
public class WxCpIntelligentRobot extends WxCpBaseResp implements Serializable {
19+
private static final long serialVersionUID = -1L;
20+
21+
/**
22+
* 机器人ID
23+
*/
24+
@SerializedName("robot_id")
25+
private String robotId;
26+
27+
/**
28+
* 机器人名称
29+
*/
30+
@SerializedName("name")
31+
private String name;
32+
33+
/**
34+
* 机器人描述
35+
*/
36+
@SerializedName("description")
37+
private String description;
38+
39+
/**
40+
* 机器人头像
41+
*/
42+
@SerializedName("avatar")
43+
private String avatar;
44+
45+
/**
46+
* 机器人状态 0:停用 1:启用
47+
*/
48+
@SerializedName("status")
49+
private Integer status;
50+
51+
/**
52+
* 创建时间
53+
*/
54+
@SerializedName("create_time")
55+
private Long createTime;
56+
57+
/**
58+
* 更新时间
59+
*/
60+
@SerializedName("update_time")
61+
private Long updateTime;
62+
63+
/**
64+
* From json wx cp intelligent robot.
65+
*
66+
* @param json the json
67+
* @return the wx cp intelligent robot
68+
*/
69+
public static WxCpIntelligentRobot fromJson(String json) {
70+
return WxCpGsonBuilder.create().fromJson(json, WxCpIntelligentRobot.class);
71+
}
72+
73+
public String toJson() {
74+
return WxCpGsonBuilder.create().toJson(this);
75+
}
76+
77+
}

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

Lines changed: 49 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,49 @@
1+
package me.chanjar.weixin.cp.bean.intelligentrobot;
2+
3+
import com.google.gson.annotations.SerializedName;
4+
import lombok.Data;
5+
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
6+
7+
import java.io.Serializable;
8+
9+
/**
10+
* 智能机器人聊天请求
11+
*
12+
* @author Binary Wang
13+
*/
14+
@Data
15+
public class WxCpIntelligentRobotChatRequest implements Serializable {
16+
private static final long serialVersionUID = -1L;
17+
18+
/**
19+
* 机器人ID
20+
*/
21+
@SerializedName("robot_id")
22+
private String robotId;
23+
24+
/**
25+
* 用户ID
26+
*/
27+
@SerializedName("userid")
28+
private String userid;
29+
30+
/**
31+
* 消息内容
32+
*/
33+
@SerializedName("message")
34+
private String message;
35+
36+
/**
37+
* 会话ID，可选，用于保持会话连续性
38+
*/
39+
@SerializedName("session_id")
40+
private String sessionId;
41+
42+
public String toJson() {
43+
return WxCpGsonBuilder.create().toJson(this);
44+
}
45+
46+
public static WxCpIntelligentRobotChatRequest fromJson(String json) {
47+
return WxCpGsonBuilder.create().fromJson(json, WxCpIntelligentRobotChatRequest.class);
48+
}
49+
}

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

Lines changed: 46 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,46 @@
1+
package me.chanjar.weixin.cp.bean.intelligentrobot;
2+
3+
import com.google.gson.annotations.SerializedName;
4+
import lombok.Data;
5+
import lombok.EqualsAndHashCode;
6+
import me.chanjar.weixin.cp.bean.WxCpBaseResp;
7+
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
8+
9+
import java.io.Serializable;
10+
11+
/**
12+
* 智能机器人聊天响应
13+
*
14+
* @author Binary Wang
15+
*/
16+
@Data
17+
@EqualsAndHashCode(callSuper = true)
18+
public class WxCpIntelligentRobotChatResponse extends WxCpBaseResp implements Serializable {
19+
private static final long serialVersionUID = -1L;
20+
21+
/**
22+
* 机器人回复内容
23+
*/
24+
@SerializedName("reply")
25+
private String reply;
26+
27+
/**
28+
* 会话ID
29+
*/
30+
@SerializedName("session_id")
31+
private String sessionId;
32+
33+
/**
34+
* 消息ID
35+
*/
36+
@SerializedName("msg_id")
37+
private String msgId;
38+
39+
public static WxCpIntelligentRobotChatResponse fromJson(String json) {
40+
return WxCpGsonBuilder.create().fromJson(json, WxCpIntelligentRobotChatResponse.class);
41+
}
42+
43+
public String toJson() {
44+
return WxCpGsonBuilder.create().toJson(this);
45+
}
46+
}

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

Lines changed: 43 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,43 @@
1+
package me.chanjar.weixin.cp.bean.intelligentrobot;
2+
3+
import com.google.gson.annotations.SerializedName;
4+
import lombok.Data;
5+
import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder;
6+
7+
import java.io.Serializable;
8+
9+
/**
10+
* 创建智能机器人请求
11+
*
12+
* @author Binary Wang
13+
*/
14+
@Data
15+
public class WxCpIntelligentRobotCreateRequest implements Serializable {
16+
private static final long serialVersionUID = -1L;
17+
18+
/**
19+
* 机器人名称
20+
*/
21+
@SerializedName("name")
22+
private String name;
23+
24+
/**
25+
* 机器人描述
26+
*/
27+
@SerializedName("description")
28+
private String description;
29+
30+
/**
31+
* 机器人头像
32+
*/
33+
@SerializedName("avatar")
34+
private String avatar;
35+
36+
public String toJson() {
37+
return WxCpGsonBuilder.create().toJson(this);
38+
}
39+
40+
public static WxCpIntelligentRobotCreateRequest fromJson(String json) {
41+
return WxCpGsonBuilder.create().fromJson(json, WxCpIntelligentRobotCreateRequest.class);
42+
}
43+
}

0 commit comments

Comments
 (0)