From 487cc7f689452779a5c8574b32e67148047c8380 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=AD=94=E6=98=8E?= <41773644+fu9809@users.noreply.github.com> Date: Thu, 20 Jan 2022 12:07:56 +0800 Subject: [PATCH] =?UTF-8?q?:new:=20#2309=20=E3=80=90=E4=BC=81=E4=B8=9A?= =?UTF-8?q?=E5=BE=AE=E4=BF=A1=E3=80=91=E6=96=B0=E5=A2=9E=E5=BE=AE=E4=BF=A1?= =?UTF-8?q?=E5=AE=A2=E6=9C=8D=E5=B8=90=E5=8F=B7=E7=AE=A1=E7=90=86=E9=83=A8?= =?UTF-8?q?=E5=88=86=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../chanjar/weixin/cp/api/WxCpKfService.java | 70 ++++++++++++++++ .../me/chanjar/weixin/cp/api/WxCpService.java | 13 +++ .../cp/api/impl/BaseWxCpServiceImpl.java | 11 +++ .../weixin/cp/api/impl/WxCpKfServiceImpl.java | 64 +++++++++++++++ .../weixin/cp/bean/kf/WxCpKfAccountAdd.java | 33 ++++++++ .../cp/bean/kf/WxCpKfAccountAddResp.java | 32 ++++++++ .../weixin/cp/bean/kf/WxCpKfAccountDel.java | 28 +++++++ .../weixin/cp/bean/kf/WxCpKfAccountLink.java | 40 +++++++++ .../cp/bean/kf/WxCpKfAccountLinkResp.java | 32 ++++++++ .../cp/bean/kf/WxCpKfAccountListResp.java | 57 +++++++++++++ .../weixin/cp/bean/kf/WxCpKfAccountUpd.java | 41 ++++++++++ .../weixin/cp/constant/WxCpApiPathConsts.java | 9 ++ .../cp/api/impl/WxCpKfServiceImplTest.java | 82 +++++++++++++++++++ 13 files changed, 512 insertions(+) create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpKfService.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImpl.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAdd.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAddResp.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountDel.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLink.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLinkResp.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountListResp.java create mode 100644 weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountUpd.java create mode 100644 weixin-java-cp/src/test/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImplTest.java diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpKfService.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpKfService.java new file mode 100644 index 000000000..a77b42a6c --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/WxCpKfService.java @@ -0,0 +1,70 @@ +package me.chanjar.weixin.cp.api; + +import me.chanjar.weixin.common.error.WxErrorException; +import me.chanjar.weixin.cp.bean.WxCpBaseResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountAdd; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountAddResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountDel; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountLink; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountLinkResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountListResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountUpd; + +/** + * 微信客服接口 + * + * 微信客服由腾讯微信团队为企业打造，用于满足企业的客服需求，帮助企业做好客户服务。企业可以在微信内、外各个场景中接入微信客服， + * 用户可以发起咨询，企业可以进行回复。 + * 企业可在微信客服官网使用企业微信扫码开通微信客服，开通后即可使用。 + * + * @author Fu + * @date 2022/1/19 19:25 + */ +public interface WxCpKfService { + + /** + * 添加客服帐号，并可设置客服名称和头像。目前一家企业最多可添加10个客服帐号 + * + * @param add 客服帐号信息 + * @return result-新创建的客服帐号ID + * @throws WxErrorException 异常 + */ + WxCpKfAccountAddResp addAccount(WxCpKfAccountAdd add) throws WxErrorException; + + /** + * 修改已有的客服帐号，可修改客服名称和头像。 + * + * @param upd 新的客服账号信息 + * @return result + * @throws WxErrorException 异常 + */ + WxCpBaseResp updAccount(WxCpKfAccountUpd upd) throws WxErrorException; + + /** + * 删除已有的客服帐号 + * + * @param del 要删除的客服帐号 + * @return result + * @throws WxErrorException 异常 + */ + WxCpBaseResp delAccount(WxCpKfAccountDel del) throws WxErrorException; + + /** + * 获取客服帐号列表，包括所有的客服帐号的客服ID、名称和头像。 + * + * @return 客服帐号列表 + * @throws WxErrorException 异常 + */ + WxCpKfAccountListResp listAccount() throws WxErrorException; + + /** + * 企业可通过此接口获取带有不同参数的客服链接，不同客服帐号对应不同的客服链接。获取后，企业可将链接嵌入到网页等场景中， + * 微信用户点击链接即可向对应的客服帐号发起咨询。企业可依据参数来识别用户的咨询来源等 + * + * @param link 参数 + * @return 链接 + * @throws WxErrorException 异常 + */ + WxCpKfAccountLinkResp getAccountLink(WxCpKfAccountLink link) throws WxErrorException; + +} 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 123697b8e..5e525213f 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 @@ -427,6 +427,13 @@ public interface WxCpService extends WxService { */ WxCpAgentWorkBenchService getWorkBenchService(); + /** + * 获取微信客服服务 + * + * @return 微信客服服务 + */ + WxCpKfService getKfService(); + /** * http请求对象 * @@ -476,4 +483,10 @@ public interface WxCpService extends WxService { */ void setTagService(WxCpTagService tagService); + /** + * Sets kf service. + * + * @param kfService the kf service + */ + void setKfService(WxCpKfService kfService); } diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/BaseWxCpServiceImpl.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/BaseWxCpServiceImpl.java index 210d54f54..18a8a9e52 100644 --- a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/BaseWxCpServiceImpl.java +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/BaseWxCpServiceImpl.java @@ -57,6 +57,7 @@ public abstract class BaseWxCpServiceImpl implements WxCpService, RequestH private WxCpOaCalendarService oaCalendarService = new WxCpOaCalendarServiceImpl(this); private WxCpOaScheduleService oaScheduleService = new WxCpOaOaScheduleServiceImpl(this); private WxCpAgentWorkBenchService workBenchService = new WxCpAgentWorkBenchServiceImpl(this); + private WxCpKfService kfService = new WxCpKfServiceImpl(this); /** * 全局的是否正在刷新access token的锁. @@ -556,4 +557,14 @@ public abstract class BaseWxCpServiceImpl implements WxCpService, RequestH public WxCpOaScheduleService getOaScheduleService() { return this.oaScheduleService; } + + @Override + public WxCpKfService getKfService() { + return kfService; + } + + @Override + public void setKfService(WxCpKfService kfService) { + this.kfService = kfService; + } } diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImpl.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImpl.java new file mode 100644 index 000000000..53e520d3c --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImpl.java @@ -0,0 +1,64 @@ +package me.chanjar.weixin.cp.api.impl; + +import lombok.RequiredArgsConstructor; +import me.chanjar.weixin.common.error.WxErrorException; +import me.chanjar.weixin.cp.api.WxCpKfService; +import me.chanjar.weixin.cp.api.WxCpService; +import me.chanjar.weixin.cp.bean.WxCpBaseResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountAdd; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountAddResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountDel; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountLink; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountLinkResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountListResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountUpd; +import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder; + +import static me.chanjar.weixin.cp.constant.WxCpApiPathConsts.Kf.*; + +/** + * 微信客服接口-服务实现 + * + * @author Fu + * @date 2022/1/19 19:41 + */ +@RequiredArgsConstructor +public class WxCpKfServiceImpl implements WxCpKfService { + private final WxCpService cpService; + + @Override + public WxCpKfAccountAddResp addAccount(WxCpKfAccountAdd add) throws WxErrorException { + String url = cpService.getWxCpConfigStorage().getApiUrl(ACCOUNT_ADD); + String responseContent = cpService.post(url, WxCpGsonBuilder.create().toJson(add)); + return WxCpKfAccountAddResp.fromJson(responseContent); + } + + @Override + public WxCpBaseResp updAccount(WxCpKfAccountUpd upd) throws WxErrorException { + String url = cpService.getWxCpConfigStorage().getApiUrl(ACCOUNT_UPD); + String responseContent = cpService.post(url, WxCpGsonBuilder.create().toJson(upd)); + return WxCpBaseResp.fromJson(responseContent); + } + + @Override + public WxCpBaseResp delAccount(WxCpKfAccountDel del) throws WxErrorException { + String url = cpService.getWxCpConfigStorage().getApiUrl(ACCOUNT_DEL); + String responseContent = cpService.post(url, WxCpGsonBuilder.create().toJson(del)); + return WxCpBaseResp.fromJson(responseContent); + } + + @Override + public WxCpKfAccountListResp listAccount() throws WxErrorException { + String url = cpService.getWxCpConfigStorage().getApiUrl(ACCOUNT_LIST); + String responseContent = cpService.post(url, "{}"); + return WxCpKfAccountListResp.fromJson(responseContent); + } + + @Override + public WxCpKfAccountLinkResp getAccountLink(WxCpKfAccountLink link) throws WxErrorException { + String url = cpService.getWxCpConfigStorage().getApiUrl(ADD_CONTACT_WAY); + String responseContent = cpService.post(url, WxCpGsonBuilder.create().toJson(link)); + return WxCpKfAccountLinkResp.fromJson(responseContent); + } + +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAdd.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAdd.java new file mode 100644 index 000000000..14ca9f0f8 --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAdd.java @@ -0,0 +1,33 @@ +package me.chanjar.weixin.cp.bean.kf; + +import com.google.gson.annotations.SerializedName; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.Serializable; + +/** + * 添加客服帐号-请求参数 + * + * @author Fu + * @date 2022/1/19 18:59 + */ +@NoArgsConstructor +@Data +public class WxCpKfAccountAdd implements Serializable { + + private static final long serialVersionUID = 3565729481246537411L; + + /** + * 客服名称；不多于16个字符 + */ + @SerializedName("name") + private String name; + + /** + * 客服头像临时素材。可以调用上传临时素材接口获取。 + * 不多于128个字节 + */ + @SerializedName("media_id") + private String mediaId; +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAddResp.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAddResp.java new file mode 100644 index 000000000..1e47d696b --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountAddResp.java @@ -0,0 +1,32 @@ +package me.chanjar.weixin.cp.bean.kf; + +import com.google.gson.annotations.SerializedName; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import me.chanjar.weixin.cp.bean.WxCpBaseResp; +import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder; + +/** + * 添加客服帐号-返回结果 + * + * @author Fu + * @date 2022/1/19 19:04 + */ +@EqualsAndHashCode(callSuper = true) +@NoArgsConstructor +@Data +public class WxCpKfAccountAddResp extends WxCpBaseResp { + + private static final long serialVersionUID = -6649323005421772827L; + + /** + * 新创建的客服帐号ID + */ + @SerializedName("open_kfid") + private String openKfid; + + public static WxCpKfAccountAddResp fromJson(String json) { + return WxCpGsonBuilder.create().fromJson(json, WxCpKfAccountAddResp.class); + } +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountDel.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountDel.java new file mode 100644 index 000000000..026e05510 --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountDel.java @@ -0,0 +1,28 @@ +package me.chanjar.weixin.cp.bean.kf; + +import com.google.gson.annotations.SerializedName; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.Serializable; + +/** + * 删除客服帐号-请求参数 + * + * @author Fu + * @date 2022/1/19 19:09 + */ +@NoArgsConstructor +@Data +public class WxCpKfAccountDel implements Serializable { + + private static final long serialVersionUID = 1997221467585676772L; + + /** + * 客服帐号ID。 + * 不多于64字节 + */ + @SerializedName("open_kfid") + private String openKfid; + +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLink.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLink.java new file mode 100644 index 000000000..a17e5c5e8 --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLink.java @@ -0,0 +1,40 @@ +package me.chanjar.weixin.cp.bean.kf; + +import com.google.gson.annotations.SerializedName; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.Serializable; + +/** + * 获取客服帐号链接-请求参数 + * + * @author Fu + * @date 2022/1/19 19:18 + */ +@NoArgsConstructor +@Data +public class WxCpKfAccountLink implements Serializable { + + private static final long serialVersionUID = -1920926948347984256L; + + /** + * 客服帐号ID + */ + @SerializedName("open_kfid") + private String openKfid; + + /** + * 场景值，字符串类型，由开发者自定义。 + * 不多于32字节 + * 字符串取值范围(正则表达式)：[0-9a-zA-Z_-]* + * + * 1. 若scene非空，返回的客服链接开发者可拼接scene_param=SCENE_PARAM参数使用，用户进入会话事件会将SCENE_PARAM原样返回。 + * 其中SCENE_PARAM需要urlencode，且长度不能超过128字节。 + * 如 https://work.weixin.qq.com/kf/kfcbf8f8d07ac7215f?enc_scene=ENCGFSDF567DF&scene_param=a%3D1%26b%3D2 + * 2. 历史调用接口返回的客服链接（包含encScene=XXX参数），不支持scene_param参数。 + * 3. 返回的客服链接，不能修改或复制参数到其他链接使用。否则进入会话事件参数校验不通过，导致无法回调。 + */ + @SerializedName("scene") + private String scene; +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLinkResp.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLinkResp.java new file mode 100644 index 000000000..89bf63595 --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountLinkResp.java @@ -0,0 +1,32 @@ +package me.chanjar.weixin.cp.bean.kf; + +import com.google.gson.annotations.SerializedName; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import me.chanjar.weixin.cp.bean.WxCpBaseResp; +import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder; + +/** + * 获取客服帐号链接-结果 + * + * @author Fu + * @date 2022/1/19 19:18 + */ +@EqualsAndHashCode(callSuper = true) +@NoArgsConstructor +@Data +public class WxCpKfAccountLinkResp extends WxCpBaseResp { + + private static final long serialVersionUID = 910205439597092481L; + + /** + * 客服链接，开发者可将该链接嵌入到H5页面中，用户点击链接即可向对应的微信客服帐号发起咨询。开发者也可根据该url自行生成需要的二维码图片 + */ + @SerializedName("url") + private String url; + + public static WxCpKfAccountLinkResp fromJson(String json) { + return WxCpGsonBuilder.create().fromJson(json, WxCpKfAccountLinkResp.class); + } +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountListResp.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountListResp.java new file mode 100644 index 000000000..c2676a44d --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountListResp.java @@ -0,0 +1,57 @@ +package me.chanjar.weixin.cp.bean.kf; + +import com.fasterxml.jackson.annotation.JsonProperty; +import com.google.gson.annotations.SerializedName; +import lombok.Data; +import lombok.EqualsAndHashCode; +import lombok.NoArgsConstructor; +import me.chanjar.weixin.cp.bean.WxCpBaseResp; +import me.chanjar.weixin.cp.util.json.WxCpGsonBuilder; + +import java.util.List; + +/** + * 获取客服帐号列表-结果 + * + * @author Fu + * @date 2022/1/19 19:13 + */ +@EqualsAndHashCode(callSuper = true) +@NoArgsConstructor +@Data +public class WxCpKfAccountListResp extends WxCpBaseResp { + + private static final long serialVersionUID = -1317201649692262217L; + + /** + * 帐号信息列表 + */ + @JsonProperty("account_list") + private List accountList; + + @NoArgsConstructor + @Data + public static class AccountListDTO { + /** + * 客服帐号ID + */ + @SerializedName("open_kfid") + private String openKfid; + + /** + * 客服名称 + */ + @SerializedName("name") + private String name; + + /** + * 客服头像URL + */ + @SerializedName("avatar") + private String avatar; + } + + public static WxCpKfAccountListResp fromJson(String json) { + return WxCpGsonBuilder.create().fromJson(json, WxCpKfAccountListResp.class); + } +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountUpd.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountUpd.java new file mode 100644 index 000000000..d3ce7269a --- /dev/null +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/bean/kf/WxCpKfAccountUpd.java @@ -0,0 +1,41 @@ +package me.chanjar.weixin.cp.bean.kf; + +import com.google.gson.annotations.SerializedName; +import lombok.Data; +import lombok.NoArgsConstructor; + +import java.io.Serializable; + +/** + * 修改客服帐号-请求参数 + * + * @author Fu + * @date 2022/1/19 19:10 + */ +@NoArgsConstructor +@Data +public class WxCpKfAccountUpd implements Serializable { + + private static final long serialVersionUID = -900712046553752529L; + + /** + * 要修改的客服帐号ID。 + * 不多于64字节 + */ + @SerializedName("open_kfid") + private String openKfid; + + /** + * 新的客服名称，如不需要修改可不填。 + * 不多于16个字符 + */ + @SerializedName("name") + private String name; + + /** + * 新的客服头像临时素材，如不需要修改可不填。可以调用上传临时素材接口获取。 + * 不多于128个字节 + */ + @SerializedName("media_id") + private String mediaId; +} diff --git a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/constant/WxCpApiPathConsts.java b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/constant/WxCpApiPathConsts.java index cea1bcb9b..a55b4726f 100644 --- a/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/constant/WxCpApiPathConsts.java +++ b/weixin-java-cp/src/main/java/me/chanjar/weixin/cp/constant/WxCpApiPathConsts.java @@ -244,4 +244,13 @@ public interface WxCpApiPathConsts { String GROUP_WELCOME_TEMPLATE_DEL = "/cgi-bin/externalcontact/group_welcome_template/del"; } + + interface Kf { + String ACCOUNT_ADD = "/cgi-bin/kf/account/add"; + String ACCOUNT_UPD = "/cgi-bin/kf/account/update"; + String ACCOUNT_DEL = "/cgi-bin/kf/account/del"; + String ACCOUNT_LIST = "/cgi-bin/kf/account/list"; + String ADD_CONTACT_WAY = "/cgi-bin/kf/add_contact_way"; + + } } diff --git a/weixin-java-cp/src/test/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImplTest.java b/weixin-java-cp/src/test/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImplTest.java new file mode 100644 index 000000000..09a4f568c --- /dev/null +++ b/weixin-java-cp/src/test/java/me/chanjar/weixin/cp/api/impl/WxCpKfServiceImplTest.java @@ -0,0 +1,82 @@ +package me.chanjar.weixin.cp.api.impl; + +import com.google.inject.Inject; +import me.chanjar.weixin.common.api.WxConsts; +import me.chanjar.weixin.common.bean.result.WxMediaUploadResult; +import me.chanjar.weixin.cp.api.ApiTestModule; +import me.chanjar.weixin.cp.api.WxCpService; +import me.chanjar.weixin.cp.bean.WxCpBaseResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountAdd; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountAddResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountDel; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountLink; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountLinkResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountListResp; +import me.chanjar.weixin.cp.bean.kf.WxCpKfAccountUpd; +import org.testng.annotations.Guice; +import org.testng.annotations.Test; + +import java.io.InputStream; + +/** + * WxCpKfServiceImpl-测试类 + * 需要用到专门的 secret https://kf.weixin.qq.com/api/doc/path/93304#secret + * + * @author Fu + * @date 2022/1/19 20:12 + */ +@Guice(modules = ApiTestModule.class) +public class WxCpKfServiceImplTest { + + @Inject + private WxCpService wxService; + + private static String kfid = "wkPzhXVAAAJD9oR75LrO1DmURSOUFBIg"; + + @Test(priority = 1) + public void testAccountAdd() throws Exception { + try (InputStream in = ClassLoader.getSystemResourceAsStream("mm.jpeg")) { + WxMediaUploadResult result = this.wxService.getMediaService().upload(WxConsts.MediaFileType.IMAGE, "jpeg", in); + String mediaId = result.getMediaId(); + WxCpKfAccountAdd add = new WxCpKfAccountAdd(); + add.setMediaId(mediaId); + add.setName("kefu01"); + WxCpKfAccountAddResp resp = this.wxService.getKfService().addAccount(add); + System.out.println(resp); + kfid = resp.getOpenKfid(); + } + } + + @Test(priority = 2) + public void testAccountUpd() throws Exception { + WxCpKfAccountUpd upd = new WxCpKfAccountUpd(); + upd.setOpenKfid(kfid); + upd.setName("kefu01-upd"); + WxCpBaseResp resp = this.wxService.getKfService().updAccount(upd); + System.out.println(resp); + } + + @Test(priority = 3) + public void testAccountList() throws Exception { + WxCpKfAccountListResp resp = this.wxService.getKfService().listAccount(); + System.out.println(resp); + } + + @Test(priority = 4) + public void testAccountLink() throws Exception { + WxCpKfAccountLink link = new WxCpKfAccountLink(); + link.setOpenKfid(kfid); + link.setScene("scene"); + WxCpKfAccountLinkResp resp = this.wxService.getKfService().getAccountLink(link); + System.out.println(resp); + } + + @Test(priority = 5) + public void testAccountDel() throws Exception { + WxCpKfAccountDel del = new WxCpKfAccountDel(); + del.setOpenKfid(kfid); + WxCpBaseResp resp = this.wxService.getKfService().delAccount(del); + System.out.println(resp); + } + +}