java推送框架_微信公众号开发基于WxJava（微信开发JavaSDK）框架的，客服消息推送实现...

主动发送客服消息&＃xff0c;示例&＃xff1a;

// 客服消息、图文消息

// 图文消息1

WxMpKefuMessage.WxArticle article1 &＃61; new WxMpKefuMessage.WxArticle();

article1.setUrl("http://xial9527.w3.luyouxia.net/wx/jsp/login.html");

article1.setPicUrl("http://test.iwocloud.com/wx/images/index_bg.png");

article1.setDescription("今天天气很好&＃xff0c;适合出去玩");

article1.setTitle("测试测试测试一下啦啦啦");

// 图文消息2

WxMpKefuMessage.WxArticle article2 &＃61; new WxMpKefuMessage.WxArticle();

article2.setUrl("http://xial9527.w3.luyouxia.net/wx/index?code&＃61;1YF00137");

article2.setPicUrl("http://test.iwocloud.com/wx/images/index_bg.png");

article2.setDescription("晚上去吃火锅吧&＃xff0c;逛超市");

article2.setTitle("今日安排");

// 封装 xml

WxMpKefuMessage wxMpKefuMessage &＃61; WxMpKefuMessage.NEWS()

.toUser("otAIM6PimOuARRXXTWcloLL-XLU0")

.addArticle(article1)

//.addArticle(article2)

.build();

// 发送给指定openid

wxMpService.getKefuService().sendKefuMessage(wxMpKefuMessage);

MP_主动发送消息(客服消息)

更多用例&＃xff0c;请参考me.chanjar.weixin.mp.api.impl.WxMpKefuServiceImplTest&＃xff0c;用例连接&＃xff1a;https://github.com/Wechat-Group/WxJava/blob/master/weixin-java-mp/src/test/java/me/chanjar/weixin/mp/api/impl/WxMpKefuServiceImplTest.java

WxMpKefuMessage message &＃61; ...;

// 设置消息的内容等信息

wxMpService.getKefuService().sendKefuMessage(message);

WxXmlOutTextMessage

不同类型的客服消息有不同的构造方法&＃xff1a;

文本消息

WxMpKefuMessage

.TEXT()

.toUser("OPENID")

.content("sfsfdsdf")

.build();

图片消息

WxMpKefuMessage

.IMAGE()

.toUser("OPENID")

.mediaId("MEDIA_ID")

.build();

语音消息

WxMpKefuMessage.VOICE()

.toUser("OPENID")

.mediaId("MEDIA_ID")

.build();

视频消息

WxMpKefuMessage.VIDEO()

.toUser("OPENID")

.title("TITLE")

.mediaId("MEDIA_ID")

.thumbMediaId("MEDIA_ID")

.description("DESCRIPTION")

.build();

音乐消息

WxMpKefuMessage.MUSIC()

.toUser("OPENID")

.title("TITLE")

.thumbMediaId("MEDIA_ID")

.description("DESCRIPTION")

.musicUrl("MUSIC_URL")

.hqMusicUrl("HQ_MUSIC_URL")

.build();

图文消息

WxMpKefuMessage.WxArticle article1 &＃61; new WxMpKefuMessage.WxArticle();

article1.setUrl("URL");

article1.setPicUrl("PIC_URL");

article1.setDescription("Is Really A Happy Day");

article1.setTitle("Happy Day");

WxMpKefuMessage.WxArticle article2 &＃61; new WxMpKefuMessage.WxArticle();

article2.setUrl("URL");

article2.setPicUrl("PIC_URL");

article2.setDescription("Is Really A Happy Day");

article2.setTitle("Happy Day");

WxMpKefuMessage.NEWS()

.toUser("OPENID")

.addArticle(article1)

.addArticle(article2)

.build();

参考文档地址&＃xff1a;

微信官方文档(客服消息)&＃xff1a;https://developers.weixin.qq.com/doc/offiaccount/Message_Management/Service_Center_messages.html

WxJava (微信开发 Java SDK)框架文档&＃xff1a;

https://github.com/Wechat-Group/WxJava/wiki/MP_%E4%B8%BB%E5%8A%A8%E5%8F%91%E9%80%81%E6%B6%88%E6%81%AF%EF%BC%88%E5%AE%A2%E6%9C%8D%E6%B6%88%E6%81%AF%EF%BC%89

完&＃xff01;&＃xff01;&＃xff01;

示例&＃xff1a;

/**

* 图文消息推送(客服消息推送)

*

* &＃64;param req

* &＃64;param resp

* &＃64;return

* &＃64;throws Exception

*/

&＃64;RequestMapping(value &＃61; "/notifyPreferential.api")

&＃64;ResponseBody

public MapnotifyPreferential(HttpServletRequest req, HttpServletResponse resp) {

wxMpService.setMaxRetryTimes(1);

// 获取用户手机号、密码、action

String phone &＃61; (String) req.getParameter("tellphone");

String openid &＃61; (String) req.getParameter("openid");

String title &＃61; (String) req.getParameter("title");

String desc &＃61; (String) req.getParameter("desc");

String picUrl &＃61; (String) req.getParameter("picUrl");

String status &＃61; (String) req.getParameter("status");

String startTime &＃61; (String) req.getParameter("startTime");

String endTime &＃61; (String) req.getParameter("endTime");

logger.info("收到服务器图文消息推送&＃xff1a;请求参数为" &＃43; phone &＃43; "," &＃43; openid &＃43; "," &＃43; title &＃43; "," &＃43; picUrl &＃43; "," &＃43; status);

try { /*

// 客服消息、图文消息

// 图文消息1

WxMpKefuMessage.WxArticle article1 &＃61; new WxMpKefuMessage.WxArticle();

article1.setUrl("http://xial9527.w3.luyouxia.net/wx/jsp/login.html");

article1.setPicUrl("http://test.iwocloud.com/wx/images/index_bg.png");

article1.setDescription("今天天气很好&＃xff0c;适合出去玩");

article1.setTitle("测试测试测试一下啦啦啦");

// 图文消息2

WxMpKefuMessage.WxArticle article2 &＃61; new WxMpKefuMessage.WxArticle();

article2.setUrl("http://xial9527.w3.luyouxia.net/wx/index?code&＃61;1YF00137");

article2.setPicUrl("http://test.iwocloud.com/wx/images/index_bg.png");

article2.setDescription("晚上去吃火锅吧&＃xff0c;逛超市");

article2.setTitle("今日安排");

// 封装 xml

WxMpKefuMessage wxMpKefuMessage &＃61; WxMpKefuMessage.NEWS()

.toUser("otAIM6PimOuARRXXTWcloLL-XLU0")

.addArticle(article1)

//.addArticle(article2)

.build();

// 发送给指定openid

wxMpService.getKefuService().sendKefuMessage(wxMpKefuMessage); */

InputStream inputStream &＃61; null;

HttpURLConnection conn &＃61; (HttpURLConnection) new URL("http://test.iwocloud.com/wx/images/index_bg.png").openConnection();

conn.setReadTimeout(5000);

conn.setConnectTimeout(5000);

conn.setRequestMethod("GET");

if (conn.getResponseCode() &＃61;&＃61; HttpURLConnection.HTTP_OK) {

inputStream &＃61; conn.getInputStream();

}

/*

String path &＃61; this.getClass().getResource("/").getPath();

path &＃61; path.substring(0, path.indexOf("WEB-INF")) &＃43; "images/index_bg.png";

logger.info(path);

inputStream &＃61; new FileInputStream(new File(path)); */

// 上传图文消息的封面图片

WxMediaUploadResult uploadMediaRes &＃61; wxMpService.getMaterialService().mediaUpload(WxConsts.MediaFileType.IMAGE, "png", inputStream);

WxMpMassNews news &＃61; new WxMpMassNews();

WxMpMassNews.WxMpMassNewsArticle article1 &＃61; new WxMpMassNews.WxMpMassNewsArticle();

article1.setTitle("标题1");

article1.setContent("内容1");

article1.setThumbMediaId(uploadMediaRes.getMediaId());

//article1.setThumbMediaId("67MYWryQ20BhSCeG8DPavcpHubxbjk9OPBlDJpkywXJi16kec7Pjs7Ul-H8ubN3T");

news.addArticle(article1);

WxMpMassNews.WxMpMassNewsArticle article2 &＃61; new WxMpMassNews.WxMpMassNewsArticle();

article2.setTitle("标题2");

article2.setContent("内容2");

article2.setThumbMediaId(uploadMediaRes.getMediaId());

//article2.setThumbMediaId("67MYWryQ20BhSCeG8DPavcpHubxbjk9OPBlDJpkywXJi16kec7Pjs7Ul-H8ubN3T");

article2.setShowCoverPic(true);

article2.setAuthor("作者2");

article2.setContentSourceUrl("www.baidu.com");

article2.setDigest("摘要2");

news.addArticle(article2);

WxMpMassUploadResult massUploadResult &＃61; wxMpService.getMassMessageService().massNewsUpload(news);

WxMpMassOpenIdsMessage massMessage &＃61; new WxMpMassOpenIdsMessage();

massMessage.setMsgType(WxConsts.MassMsgType.MPNEWS);

massMessage.setMediaId(massUploadResult.getMediaId());

//massMessage.setMediaId("67MYWryQ20BhSCeG8DPavcpHubxbjk9OPBlDJpkywXJi16kec7Pjs7Ul-H8ubN3T");

massMessage.getToUsers().add("otAIM6PimOuARRXXTWcloLL-XLU0");

massMessage.getToUsers().add("otAIM6OlscpCu4PSFb8dSM0jwIxE");

WxMpMassSendResult massResult &＃61; wxMpService.getMassMessageService().massOpenIdsMessageSend(massMessage);

} catch (Exception e) {

logger.error(e.getMessage());

}

// 封装返回结果

MapreturnMap &＃61; new HashMap();

returnMap.put(GlobalDeclare.RETURN_CODE, 0);

returnMap.put(GlobalDeclare.RETURN_MSG, "success");

returnMap.put(GlobalDeclare.RETURN_DATA, "{}");

return returnMap;

}