diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpService.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpService.java index d9ce9edd..63abc79c 100644 --- a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpService.java +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpService.java @@ -562,12 +562,20 @@ public interface WxCpService { * @param mediaId * @throws WxErrorException */ - void replaceParty(String mediaId) throws WxErrorException; + String replaceParty(String mediaId) throws WxErrorException; /** * 上传用户列表覆盖企业号上的用户信息 * @param mediaId * @throws WxErrorException */ - void replaceUser(String mediaId) throws WxErrorException; + String replaceUser(String mediaId) throws WxErrorException; + + /** + * 获取异步任务结果 + * @param joinId + * @return + * @throws WxErrorException + */ + String getTaskResult(String joinId) throws WxErrorException; } diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpServiceImpl.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpServiceImpl.java index 1452ed16..7b95c32c 100644 --- a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpServiceImpl.java +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpServiceImpl.java @@ -656,19 +656,25 @@ public class WxCpServiceImpl implements WxCpService { } @Override - public void replaceParty(String mediaId) throws WxErrorException { + public String replaceParty(String mediaId) throws WxErrorException { String url = "https://qyapi.weixin.qq.com/cgi-bin/batch/replaceparty"; JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("media_id", mediaId); - post(url, jsonObject.toString()); + return post(url, jsonObject.toString()); } @Override - public void replaceUser(String mediaId) throws WxErrorException { + public String replaceUser(String mediaId) throws WxErrorException { String url = "https://qyapi.weixin.qq.com/cgi-bin/batch/replaceuser"; JsonObject jsonObject = new JsonObject(); jsonObject.addProperty("media_id", mediaId); - post(url, jsonObject.toString()); + return post(url, jsonObject.toString()); + } + + @Override + public String getTaskResult(String joinId) throws WxErrorException { + String url = "https://qyapi.weixin.qq.com/cgi-bin/batch/getresult?jobid="+joinId; + return get(url, null); } public File getTmpDirFile() {