niko/weixin4j
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

up

Browse Source
This commit is contained in:
jinyu 2016-04-15 12:01:32 +08:00
parent 746c0f6961
commit c70cf38a3f
4 changed files with 204 additions and 157 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
weixin4j-mp/src/main/java/com/foxinmy/weixin4j/mp/WeixinProxy.java
View File

@ -33,6 +33,7 @@ import com.foxinmy.weixin4j.mp.model.Group;
import com.foxinmy.weixin4j.mp.model.KfAccount; import com.foxinmy.weixin4j.mp.model.KfAccount;
import com.foxinmy.weixin4j.mp.model.KfChatRecord; import com.foxinmy.weixin4j.mp.model.KfChatRecord;
import com.foxinmy.weixin4j.mp.model.KfSession; import com.foxinmy.weixin4j.mp.model.KfSession;
import com.foxinmy.weixin4j.mp.model.KfSession.kfSessionCounter;
import com.foxinmy.weixin4j.mp.model.Menu; import com.foxinmy.weixin4j.mp.model.Menu;
import com.foxinmy.weixin4j.mp.model.MenuMatchRule; import com.foxinmy.weixin4j.mp.model.MenuMatchRule;
import com.foxinmy.weixin4j.mp.model.MenuSetting; import com.foxinmy.weixin4j.mp.model.MenuSetting;
@ -234,9 +235,6 @@ public class WeixinProxy {
/** /**
* 上传媒体文件 </br> * 上传媒体文件 </br>
* <font color="red">此接口只包含图片、语音、缩略图、视频(临时)四种媒体类型的上传</font> * <font color="red">此接口只包含图片、语音、缩略图、视频(临时)四种媒体类型的上传</font>
* <p>
* 正常情况下返回{"type":"TYPE","media_id":"MEDIA_ID","created_at":123456789},
* 否则抛出异常.
* </p> * </p>
* *
* @param isMaterial * @param isMaterial
@ -244,7 +242,7 @@ public class WeixinProxy {
* @param is * @param is
* 媒体数据流 * 媒体数据流
* @param fileName * @param fileName
* 文件名 * 文件名 为空时将自动生成
* @return 上传到微信服务器返回的媒体标识 * @return 上传到微信服务器返回的媒体标识
* @see <a href= * @see <a href=
* "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1444738726&token=&lang=zh_CN"> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1444738726&token=&lang=zh_CN">
@ -688,18 +686,18 @@ public class WeixinProxy {
} }
/** /**
* 获取未接入会话列表:获取当前正在等待队列中的会话列表，此接口最多返回最早进入队列的100个未接入会话。</br> * 获取未接入会话列表:获取当前正在等待队列中的会话列表，此接口最多返回最早进入队列的100个未接入会话
* <font color="red">缺陷：没有count字段</font>
* *
* @return 会话列表 * @return 会话列表
* @throws WeixinException * @throws WeixinException
* @see com.foxinmy.weixin4j.mp.api.CustomApi * @see com.foxinmy.weixin4j.mp.api.CustomApi
* @see com.foxinmy.weixin4j.mp.model.KfSession * @see com.foxinmy.weixin4j.mp.model.KfSession
* @see com.foxinmy.weixin4j.mp.model.KfSession.kfSessionCounter
* @see <a href= * @see <a href=
* "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN"> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">
* 获取客服的会话列表</a> * 获取客服的会话列表</a>
*/ */
public List<KfSession> listKfWaitSession() throws WeixinException { public kfSessionCounter listKfWaitSession() throws WeixinException {
return customApi.listKfWaitSession(); return customApi.listKfWaitSession();
} }

150
weixin4j-mp/src/main/java/com/foxinmy/weixin4j/mp/api/CustomApi.java
View File

@ -19,6 +19,7 @@ import com.foxinmy.weixin4j.model.Token;
import com.foxinmy.weixin4j.mp.model.KfAccount; import com.foxinmy.weixin4j.mp.model.KfAccount;
import com.foxinmy.weixin4j.mp.model.KfChatRecord; import com.foxinmy.weixin4j.mp.model.KfChatRecord;
import com.foxinmy.weixin4j.mp.model.KfSession; import com.foxinmy.weixin4j.mp.model.KfSession;
import com.foxinmy.weixin4j.mp.model.KfSession.kfSessionCounter;
import com.foxinmy.weixin4j.token.TokenHolder; import com.foxinmy.weixin4j.token.TokenHolder;
import com.foxinmy.weixin4j.util.DigestUtil; import com.foxinmy.weixin4j.util.DigestUtil;
import com.foxinmy.weixin4j.util.FileUtil; import com.foxinmy.weixin4j.util.FileUtil;
@ -54,11 +55,11 @@ public class CustomApi extends MpApi {
* @throws WeixinException * @throws WeixinException
* @see com.foxinmy.weixin4j.mp.model.KfChatRecord * @see com.foxinmy.weixin4j.mp.model.KfChatRecord
* @see <a href="http://dkf.qq.com/document-1_1.html">查询客服聊天记录</a> * @see <a href="http://dkf.qq.com/document-1_1.html">查询客服聊天记录</a>
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044854&token=&lang=zh_CN">查询客服聊天记录</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044854&token=&lang=zh_CN">
* 查询客服聊天记录</a>
*/ */
public List<KfChatRecord> getKfChatRecord(Date startTime, Date endTime, public List<KfChatRecord> getKfChatRecord(Date startTime, Date endTime, Pageable pageable) throws WeixinException {
Pageable pageable) throws WeixinException {
List<KfChatRecord> records = new ArrayList<KfChatRecord>(); List<KfChatRecord> records = new ArrayList<KfChatRecord>();
String kf_chatrecord_uri = getRequestUri("kf_chatrecord_uri"); String kf_chatrecord_uri = getRequestUri("kf_chatrecord_uri");
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
@ -68,8 +69,7 @@ public class CustomApi extends MpApi {
for (int i = 0; i < (int) Math.ceil(pageable.getPageSize() / 50d); i++) { for (int i = 0; i < (int) Math.ceil(pageable.getPageSize() / 50d); i++) {
obj.put("pagesize", Math.min(50, pageable.getPageSize())); obj.put("pagesize", Math.min(50, pageable.getPageSize()));
obj.put("pageindex", pageable.getPageNumber()); obj.put("pageindex", pageable.getPageNumber());
WeixinResponse response = weixinExecutor.post( WeixinResponse response = weixinExecutor.post(String.format(kf_chatrecord_uri, token.getAccessToken()),
String.format(kf_chatrecord_uri, token.getAccessToken()),
obj.toJSONString()); obj.toJSONString());
String text = response.getAsJson().getString("recordlist"); String text = response.getAsJson().getString("recordlist");
@ -78,8 +78,8 @@ public class CustomApi extends MpApi {
} }
records.addAll(JSON.parseArray(text, KfChatRecord.class)); records.addAll(JSON.parseArray(text, KfChatRecord.class));
pageable = new Pageable(pageable.getPageNumber() + 1, Math.min(50, pageable = new Pageable(pageable.getPageNumber() + 1,
Math.max(1, pageable.getPageSize() - ((i + 1) * 50)))); Math.min(50, Math.max(1, pageable.getPageSize() - ((i + 1) * 50))));
} }
return records; return records;
} }
@ -93,24 +93,22 @@ public class CustomApi extends MpApi {
* @return 多客服信息列表 * @return 多客服信息列表
* @see com.foxinmy.weixin4j.mp.model.KfAccount * @see com.foxinmy.weixin4j.mp.model.KfAccount
* @see <a href="http://dkf.qq.com/document-3_1.html">获取客服基本信息</a> * @see <a href="http://dkf.qq.com/document-3_1.html">获取客服基本信息</a>
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">获取客服基本信息</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">
* 获取客服基本信息</a>
* @see <a href="http://dkf.qq.com/document-3_2.html">获取在线客服接待信息</a> * @see <a href="http://dkf.qq.com/document-3_2.html">获取在线客服接待信息</a>
* @throws WeixinException * @throws WeixinException
*/ */
public List<KfAccount> listKfAccount(boolean isOnline) public List<KfAccount> listKfAccount(boolean isOnline) throws WeixinException {
throws WeixinException {
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String text = ""; String text = "";
if (isOnline) { if (isOnline) {
String kf_onlinelist_uri = getRequestUri("kf_onlinelist_uri"); String kf_onlinelist_uri = getRequestUri("kf_onlinelist_uri");
WeixinResponse response = weixinExecutor.get(String.format( WeixinResponse response = weixinExecutor.get(String.format(kf_onlinelist_uri, token.getAccessToken()));
kf_onlinelist_uri, token.getAccessToken()));
text = response.getAsJson().getString("kf_online_list"); text = response.getAsJson().getString("kf_online_list");
} else { } else {
String kf_list_uri = getRequestUri("kf_list_uri"); String kf_list_uri = getRequestUri("kf_list_uri");
WeixinResponse response = weixinExecutor.get(String.format( WeixinResponse response = weixinExecutor.get(String.format(kf_list_uri, token.getAccessToken()));
kf_list_uri, token.getAccessToken()));
text = response.getAsJson().getString("kf_list"); text = response.getAsJson().getString("kf_list");
} }
return JSON.parseArray(text, KfAccount.class); return JSON.parseArray(text, KfAccount.class);
@ -128,19 +126,18 @@ public class CustomApi extends MpApi {
* 客服账号登录密码 * 客服账号登录密码
* @return 处理结果 * @return 处理结果
* @throws WeixinException * @throws WeixinException
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">新增客服账号</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">
* 新增客服账号</a>
*/ */
public JsonResult createKfAccount(String id, String name, String pwd) public JsonResult createKfAccount(String id, String name, String pwd) throws WeixinException {
throws WeixinException {
JSONObject obj = new JSONObject(); JSONObject obj = new JSONObject();
obj.put("kf_account", id); obj.put("kf_account", id);
obj.put("nickname", name); obj.put("nickname", name);
obj.put("password", DigestUtil.MD5(pwd)); obj.put("password", DigestUtil.MD5(pwd));
String kf_create_uri = getRequestUri("kf_create_uri"); String kf_create_uri = getRequestUri("kf_create_uri");
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
WeixinResponse response = weixinExecutor.post( WeixinResponse response = weixinExecutor.post(String.format(kf_create_uri, token.getAccessToken()),
String.format(kf_create_uri, token.getAccessToken()),
obj.toJSONString()); obj.toJSONString());
return response.getAsJsonResult(); return response.getAsJsonResult();
} }
@ -157,19 +154,18 @@ public class CustomApi extends MpApi {
* 客服账号登录密码 * 客服账号登录密码
* @return 处理结果 * @return 处理结果
* @throws WeixinException * @throws WeixinException
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">新增客服账号</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">
* 新增客服账号</a>
*/ */
public JsonResult updateKfAccount(String id, String name, String pwd) public JsonResult updateKfAccount(String id, String name, String pwd) throws WeixinException {
throws WeixinException {
JSONObject obj = new JSONObject(); JSONObject obj = new JSONObject();
obj.put("kf_account", id); obj.put("kf_account", id);
obj.put("nickname", name); obj.put("nickname", name);
obj.put("password", DigestUtil.MD5(pwd)); obj.put("password", DigestUtil.MD5(pwd));
String kf_update_uri = getRequestUri("kf_update_uri"); String kf_update_uri = getRequestUri("kf_update_uri");
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
WeixinResponse response = weixinExecutor.post( WeixinResponse response = weixinExecutor.post(String.format(kf_update_uri, token.getAccessToken()),
String.format(kf_update_uri, token.getAccessToken()),
obj.toJSONString()); obj.toJSONString());
return response.getAsJsonResult(); return response.getAsJsonResult();
} }
@ -189,15 +185,13 @@ public class CustomApi extends MpApi {
* >邀请绑定客服帐号<a/> * >邀请绑定客服帐号<a/>
* @throws WeixinException * @throws WeixinException
*/ */
public JsonResult inviteKfAccount(String kfAccount, String inviteAccount) public JsonResult inviteKfAccount(String kfAccount, String inviteAccount) throws WeixinException {
throws WeixinException {
JSONObject obj = new JSONObject(); JSONObject obj = new JSONObject();
obj.put("kf_account", kfAccount); obj.put("kf_account", kfAccount);
obj.put("invite_wx", inviteAccount); obj.put("invite_wx", inviteAccount);
String kf_invite_uri = getRequestUri("kf_invite_uri"); String kf_invite_uri = getRequestUri("kf_invite_uri");
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
WeixinResponse response = weixinExecutor.post( WeixinResponse response = weixinExecutor.post(String.format(kf_invite_uri, token.getAccessToken()),
String.format(kf_invite_uri, token.getAccessToken()),
obj.toJSONString()); obj.toJSONString());
return response.getAsJsonResult(); return response.getAsJsonResult();
} }
@ -213,11 +207,11 @@ public class CustomApi extends MpApi {
* 文件名 为空时将自动生成 * 文件名 为空时将自动生成
* @return 处理结果 * @return 处理结果
* @throws WeixinException * @throws WeixinException
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">上传客服头像</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">
* 上传客服头像</a>
*/ */
public JsonResult uploadKfAvatar(String accountId, InputStream is, public JsonResult uploadKfAvatar(String accountId, InputStream is, String fileName) throws WeixinException {
String fileName) throws WeixinException {
if (StringUtil.isBlank(fileName)) { if (StringUtil.isBlank(fileName)) {
fileName = ObjectId.get().toHexString(); fileName = ObjectId.get().toHexString();
} }
@ -226,11 +220,8 @@ public class CustomApi extends MpApi {
} }
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String kf_avatar_uri = getRequestUri("kf_avatar_uri"); String kf_avatar_uri = getRequestUri("kf_avatar_uri");
WeixinResponse response = weixinExecutor WeixinResponse response = weixinExecutor.post(String.format(kf_avatar_uri, token.getAccessToken(), accountId),
.post(String.format(kf_avatar_uri, token.getAccessToken(), new FormBodyPart("media", new InputStreamBody(is, ContentType.IMAGE_JPG.getMimeType(), fileName)));
accountId),
new FormBodyPart("media", new InputStreamBody(is,
ContentType.IMAGE_JPG.getMimeType(), fileName)));
return response.getAsJsonResult(); return response.getAsJsonResult();
} }
@ -242,14 +233,14 @@ public class CustomApi extends MpApi {
* 完整客服账号，格式为：账号前缀@公众号微信号 * 完整客服账号，格式为：账号前缀@公众号微信号
* @return 处理结果 * @return 处理结果
* @throws WeixinException * @throws WeixinException
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">删除客服账号</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044813&token=&lang=zh_CN">
* 删除客服账号</a>
*/ */
public JsonResult deleteKfAccount(String id) throws WeixinException { public JsonResult deleteKfAccount(String id) throws WeixinException {
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String kf_delete_uri = getRequestUri("kf_delete_uri"); String kf_delete_uri = getRequestUri("kf_delete_uri");
WeixinResponse response = weixinExecutor.get(String.format( WeixinResponse response = weixinExecutor.get(String.format(kf_delete_uri, token.getAccessToken(), id));
kf_delete_uri, token.getAccessToken(), id));
return response.getAsJsonResult(); return response.getAsJsonResult();
} }
@ -269,19 +260,18 @@ public class CustomApi extends MpApi {
* 附加信息，文本会展示在客服人员的多客服客户端 * 附加信息，文本会展示在客服人员的多客服客户端
* @return 处理结果 * @return 处理结果
* @throws WeixinException * @throws WeixinException
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">创建会话</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">
* 创建会话</a>
*/ */
public JsonResult createKfSession(String userOpenId, String kfAccount, public JsonResult createKfSession(String userOpenId, String kfAccount, String text) throws WeixinException {
String text) throws WeixinException {
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String kfsession_create_uri = getRequestUri("kfsession_create_uri"); String kfsession_create_uri = getRequestUri("kfsession_create_uri");
JSONObject obj = new JSONObject(); JSONObject obj = new JSONObject();
obj.put("openid", userOpenId); obj.put("openid", userOpenId);
obj.put("kf_account", kfAccount); obj.put("kf_account", kfAccount);
obj.put("text", text); obj.put("text", text);
WeixinResponse response = weixinExecutor.post( WeixinResponse response = weixinExecutor.post(String.format(kfsession_create_uri, token.getAccessToken()),
String.format(kfsession_create_uri, token.getAccessToken()),
obj.toJSONString()); obj.toJSONString());
return response.getAsJsonResult(); return response.getAsJsonResult();
@ -298,19 +288,18 @@ public class CustomApi extends MpApi {
* 附加信息，文本会展示在客服人员的多客服客户端 * 附加信息，文本会展示在客服人员的多客服客户端
* @return 处理结果 * @return 处理结果
* @throws WeixinException * @throws WeixinException
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">关闭会话</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">
* 关闭会话</a>
*/ */
public JsonResult closeKfSession(String userOpenId, String kfAccount, public JsonResult closeKfSession(String userOpenId, String kfAccount, String text) throws WeixinException {
String text) throws WeixinException {
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String kfsession_close_uri = getRequestUri("kfsession_close_uri"); String kfsession_close_uri = getRequestUri("kfsession_close_uri");
JSONObject obj = new JSONObject(); JSONObject obj = new JSONObject();
obj.put("openid", userOpenId); obj.put("openid", userOpenId);
obj.put("kf_account", kfAccount); obj.put("kf_account", kfAccount);
obj.put("text", text); obj.put("text", text);
WeixinResponse response = weixinExecutor.post( WeixinResponse response = weixinExecutor.post(String.format(kfsession_close_uri, token.getAccessToken()),
String.format(kfsession_close_uri, token.getAccessToken()),
obj.toJSONString()); obj.toJSONString());
return response.getAsJsonResult(); return response.getAsJsonResult();
@ -324,17 +313,17 @@ public class CustomApi extends MpApi {
* @return 会话对象 * @return 会话对象
* @throws WeixinException * @throws WeixinException
* @see com.foxinmy.weixin4j.mp.model.KfSession * @see com.foxinmy.weixin4j.mp.model.KfSession
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">获取会话状态</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">
* 获取会话状态</a>
*/ */
public KfSession getKfSession(String userOpenId) throws WeixinException { public KfSession getKfSession(String userOpenId) throws WeixinException {
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String kfsession_get_uri = getRequestUri("kfsession_get_uri"); String kfsession_get_uri = getRequestUri("kfsession_get_uri");
WeixinResponse response = weixinExecutor.get(String.format( WeixinResponse response = weixinExecutor
kfsession_get_uri, token.getAccessToken(), userOpenId)); .get(String.format(kfsession_get_uri, token.getAccessToken(), userOpenId));
KfSession session = response KfSession session = response.getAsObject(new TypeReference<KfSession>() {
.getAsObject(new TypeReference<KfSession>() {
}); });
session.setUserOpenId(userOpenId); session.setUserOpenId(userOpenId);
return session; return session;
@ -348,39 +337,38 @@ public class CustomApi extends MpApi {
* @return 会话列表 * @return 会话列表
* @throws WeixinException * @throws WeixinException
* @see com.foxinmy.weixin4j.mp.model.KfSession * @see com.foxinmy.weixin4j.mp.model.KfSession
* @see <a * @see <a href=
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">获取客服的会话列表</a> * "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">
* 获取客服的会话列表</a>
*/ */
public List<KfSession> listKfSession(String kfAccount) public List<KfSession> listKfSession(String kfAccount) throws WeixinException {
throws WeixinException {
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String kfsession_list_uri = getRequestUri("kfsession_list_uri"); String kfsession_list_uri = getRequestUri("kfsession_list_uri");
WeixinResponse response = weixinExecutor.get(String.format( WeixinResponse response = weixinExecutor
kfsession_list_uri, token.getAccessToken(), kfAccount)); .get(String.format(kfsession_list_uri, token.getAccessToken(), kfAccount));
List<KfSession> sessionList = JSON.parseArray(response.getAsJson() List<KfSession> sessionList = JSON.parseArray(response.getAsJson().getString("sessionlist"), KfSession.class);
.getString("sessionlist"), KfSession.class);
return sessionList; return sessionList;
} }
/** /**
* 获取未接入会话列表:获取当前正在等待队列中的会话列表，此接口最多返回最早进入队列的100个未接入会话。</br> <font * 获取未接入会话列表:获取当前正在等待队列中的会话列表，此接口最多返回最早进入队列的100个未接入会话。</br>
* color="red">缺陷：没有count字段</font> * <font color="red">缺陷：没有count字段</font>
* *
* @return 会话列表 * @return 会话列表
* @throws WeixinException * @throws WeixinException
* @see com.foxinmy.weixin4j.mp.model.KfSession * @see com.foxinmy.weixin4j.mp.model.KfSession
* @see <a * @see com.foxinmy.weixin4j.mp.model.KfSession.kfSessionCounter
* href="https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">获取客服的会话列表</a> * @see <a href=
* "https://mp.weixin.qq.com/wiki?t=resource/res_main&id=mp1458044820&token=&lang=zh_CN">
* 获取客服的会话列表</a>
*/ */
public List<KfSession> listKfWaitSession() throws WeixinException { public kfSessionCounter listKfWaitSession() throws WeixinException {
Token token = tokenHolder.getToken(); Token token = tokenHolder.getToken();
String kfsession_wait_uri = getRequestUri("kfsession_wait_uri"); String kfsession_wait_uri = getRequestUri("kfsession_wait_uri");
WeixinResponse response = weixinExecutor.get(String.format( WeixinResponse response = weixinExecutor.get(String.format(kfsession_wait_uri, token.getAccessToken()));
kfsession_wait_uri, token.getAccessToken()));
List<KfSession> sessionList = JSON.parseArray(response.getAsJson() return response.getAsObject(new TypeReference<kfSessionCounter>() {
.getString("waitcaselist"), KfSession.class); });
return sessionList;
} }
} }

65
weixin4j-mp/src/main/java/com/foxinmy/weixin4j/mp/model/KfSession.java
View File

@ -2,6 +2,8 @@ package com.foxinmy.weixin4j.mp.model;
import java.io.Serializable; import java.io.Serializable;
import java.util.Date; import java.util.Date;
import java.util.Iterator;
import java.util.List;
import com.alibaba.fastjson.annotation.JSONField; import com.alibaba.fastjson.annotation.JSONField;
@ -33,6 +35,11 @@ public class KfSession implements Serializable {
*/ */
@JSONField(name = "createtime") @JSONField(name = "createtime")
private Date createTime; private Date createTime;
/**
* 最后一条消息的时间,在`获取未接入会话列表`接口中有值
*/
@JSONField(name = "latest_time")
private Date latestTime;
public String getKfAccount() { public String getKfAccount() {
return kfAccount; return kfAccount;
@ -58,9 +65,63 @@ public class KfSession implements Serializable {
this.createTime = createTime; this.createTime = createTime;
} }
public Date getLatestTime() {
return latestTime;
}
public void setLatestTime(Date latestTime) {
this.latestTime = latestTime;
}
/**
* 会话计数,如 未接入会话列表
*
* @className: kfSessionCounter
* @description:
* @author jinyu
* @date 2016年4月15日
* @since JDK 1.6
* @see
*/
public static class kfSessionCounter implements Iterable<KfSession>, Serializable {
private static final long serialVersionUID = -2200434961546270829L;
@JSONField(name = "count")
private int count;
@JSONField(name = "waitcaselist")
private List<KfSession> kfSessions;
@Override
public Iterator<KfSession> iterator() {
return kfSessions.iterator();
}
public int getCount() {
return count;
}
public void setCount(int count) {
this.count = count;
}
public List<KfSession> getKfSessions() {
return kfSessions;
}
public void setKfSessions(List<KfSession> kfSessions) {
this.kfSessions = kfSessions;
}
@Override @Override
public String toString() { public String toString() {
return "KfSession [kfAccount=" + kfAccount + ", userOpenId=" return "kfSessionCounter [count=" + count + ", kfSessions=" + kfSessions + "]";
+ userOpenId + ", createTime=" + createTime + "]"; }
}
@Override
public String toString() {
return "KfSession [kfAccount=" + kfAccount + ", userOpenId=" + userOpenId + ", createTime=" + createTime
+ ", latestTime=" + latestTime + "]";
} }
} }

4
weixin4j-server/src/main/java/com/foxinmy/weixin4j/dispatcher/WeixinMessageDispatcher.java
View File

@ -178,7 +178,7 @@ public class WeixinMessageDispatcher {
* 微信消息 * 微信消息
*/ */
protected void noHandlerFound(ChannelHandlerContext context, protected void noHandlerFound(ChannelHandlerContext context,
WeixinRequest request, Object message) { WeixinRequest request, WeixinMessage message) {
logger.warn("no handler found for {}", request); logger.warn("no handler found for {}", request);
if (alwaysResponse) { if (alwaysResponse) {
context.write(BlankResponse.global); context.write(BlankResponse.global);
@ -234,7 +234,7 @@ public class WeixinMessageDispatcher {
return m2.weight() - m1.weight(); return m2.weight() - m1.weight();
} }
}); });
logger.info("matched message handler '{}'", matchedMessageHandlers); logger.info("matched message handlers '{}'", matchedMessageHandlers);
return new MessageHandlerExecutor(context, return new MessageHandlerExecutor(context,
matchedMessageHandlers.get(0), getMessageInterceptors()); matchedMessageHandlers.get(0), getMessageInterceptors());
} }