diff --git a/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatDllServiceImpl.java b/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatDllServiceImpl.java index f5f5600..dc41f2d 100644 --- a/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatDllServiceImpl.java +++ b/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatDllServiceImpl.java @@ -343,6 +343,8 @@ public class WeChatDllServiceImpl implements WeChatDllService { if ("21".equals(request.getXmlType())) { // 小程序 xmlType = 0x21; + } else { + xmlType = Integer.parseInt(request.getXmlType()); } Wcf.XmlMsg xmlMsg = Wcf.XmlMsg.newBuilder().setContent(request.getXmlContent()).setReceiver(request.getRecipient()) .setPath(request.getResourcePath()).setType(xmlType).build(); @@ -376,7 +378,6 @@ public class WeChatDllServiceImpl implements WeChatDllService { return null; } - @Deprecated @Override public WxPpWcfSendEmojiMsgResp sendEmojiMsg(WxPpWcfSendEmojiMsgReq request) { long startTime = System.currentTimeMillis(); @@ -584,7 +585,8 @@ public class WeChatDllServiceImpl implements WeChatDllService { public String queryFriendCircle() { long startTime = System.currentTimeMillis(); log.info("[查询]-[刷新朋友圈]-开始"); - Wcf.Request req = Wcf.Request.newBuilder().setFuncValue(Wcf.Functions.FUNC_REFRESH_PYQ_VALUE).build(); + // id 开始 id,0 为最新页 (string based uint64) + Wcf.Request req = Wcf.Request.newBuilder().setFuncValue(Wcf.Functions.FUNC_REFRESH_PYQ_VALUE).setUi64(0).build(); Wcf.Response rsp = wechatSocketClient.sendCmd(req); int state = judgeWcfCmdState(rsp); long endTime = System.currentTimeMillis(); diff --git a/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatMsgServiceImpl.java b/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatMsgServiceImpl.java index 5fb9cc3..c268777 100644 --- a/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatMsgServiceImpl.java +++ b/clients/java/wechat-ferry-mvn/src/main/java/com/wechat/ferry/service/impl/WeChatMsgServiceImpl.java @@ -41,7 +41,7 @@ public class WeChatMsgServiceImpl implements WeChatMsgService { // 有开启的群聊配置 if (!CollectionUtils.isEmpty(weChatFerryProperties.getOpenMsgGroups())) { // 指定处理的群聊 - if (weChatFerryProperties.getOpenMsgGroups().contains(dto.getRoomId())) { + if (weChatFerryProperties.getOpenMsgGroups().contains(dto.getRoomId()) || weChatFerryProperties.getOpenMsgGroups().contains("ALL")) { // TODO 模式有多种 1-根据消息类型单独调用某一个 2-全部调用,各业务类中自己决定是否继续 if (true) { // 因为一种消息允许进行多种处理,这里采用执行所有策略,请自行在各策略中判断是否需要执行