欢迎您访问程序员文章站本站旨在为大家提供分享程序员计算机编程知识!
您现在的位置是: 首页  >  IT编程

Java微信公众平台之群发接口(高级群发)

程序员文章站 2023-12-10 15:24:16
再次吐槽下,微信素材管理和群发这块文档对java很不友好,此文需要结合我和。 测试号调试群发只需看是否群发消息是否能组装成功,不需要看结果如何(反正不会发送成功的),因为...

再次吐槽下,微信素材管理和群发这块文档对java很不友好,此文需要结合我和。

测试号调试群发只需看是否群发消息是否能组装成功,不需要看结果如何(反正不会发送成功的),因为微信还没开放这个功能(估计也不会开放的)。

一、群发说明

在公众平台网站上,为订阅号提供了每天一条的群发权限,为服务号提供每月(自然月)4条的群发权限。

1、对于认证订阅号,群发接口每天可成功调用1次,此次群发可选择发送给全部用户或某个标签;

2、对于认证服务号虽然开发者使用高级群发接口的每日调用限制为100次,但是用户每月只能接收4条,无论在公众平台网站上,还是使用接口群发,用户每月只能接收4条群发消息,多于4条的群发将对该用户发送失败;

3、开发者可以主动设置 clientmsgid 来避免重复推送。

4、群发接口每分钟限制请求60次,超过限制的请求会被拒绝。

5、图文消息正文中插入自己帐号和其他公众号已群发文章链接的能力。

二、群发图文消息过程

1、首先,预先将图文消息中需要用到的图片,使用上传图文消息内图片接口,上传成功并获得图片 url;参考前文的上传图文消息内的图片获取url方法
2、上传图文消息素材,需要用到图片时,请使用上一步获取的图片 url;
3、使用对用户标签的群发,或对 openid 列表的群发,将图文消息群发出去,群发时微信会进行原创校验,并返回群发操作结果;
4、在上述过程中,如果需要,还可以预览图文消息、查询群发状态,或删除已群发的消息等。

三、群发图片、文本等其他消息类型的过程

1、如果是群发文本消息,则直接根据下面的接口说明进行群发即可;
2、如果是群发图片、视频等消息,则需要预先通过素材管理接口准备好 mediaid。

四、is_to_all说明

用于设定是否向全部用户发送,值为true或false,选择true该消息群发给所有用户,选择false可根据tag_id发送给指定群组的用户。

五、两种群发方式

根据标签进行群发,订阅号与服务号必须通过认证

接口:https://api.weixin.qq.com/cgi-bin/message/mass/sendall?access_token=access_token

根据openid列表群发,只适用于认证后的服务号

接口:https://api.weixin.qq.com/cgi-bin/message/mass/send?access_token=access_token

post数据可以是图文消息、文本、语音/音频、图片、视频、卡券消息(所有使用到media_id的地方,现在都可以使用素材管理中的永久素材media_id了)

1、图文消息post数据中的media_id需要通过上传图文消息素材接口获取(https://api.weixin.qq.com/cgi-bin/media/uploadnews?access_token=access_token)
这个跟素材管理里的新增永久图文素材接口post数据一样,只是接口不一样、返回的json多了一个type和created_at,参考我前文的新增永久图文素材方法
2、语音/音频、图片post数据中的media_id需要通过上传下载多媒体文件接口获得,参考我前文的新增临时/永久素材方法

3、视频post数据中的media_id最麻烦,先得通过上传下载多媒体文件接口获取到media_id(经测试,永久的下一步报错提示无效media_id),然后再通过特别接口再获取到一个media_id,这才是群发所需要的media_id

六、群发示例controller

@requestmapping("/sendbyopenid") 
public massmsgresult sendbyopenid() throws exception { 
  // 根据openid列表群发图文消息 
  string mediapath1 = "c:/users/phil/pictures/image/8538572f61d7a94cf0b9fe0f290cdb28.jpg"; 
  uploadmediasresult result1 = httprequtil.uploadtempmedia("phil_token", "image", mediapath1); 
  string mediapath2 = "c:/users/phil/pictures/image/685977abgw1f8xqp46dgyj20qo0zktfi.jpg"; 
  uploadmediasresult result2 = httprequtil.uploadtempmedia("phil_token", "image", mediapath2); 
  list<uploadnewsmedia> array = new arraylist<>(); 
  uploadnewsmedia entity1 = new uploadnewsmedia(); 
  entity1.setauthor("phil"); 
  entity1.setcontent("人生只有经历才会懂得,只有懂得才知道珍惜,一生中,总会有一个人让你笑得最甜,也总会有一个人让你痛得最深,忘记,是善待自己"); 
  entity1.setcontent_source_url("http://blog.csdn.net/phil_jing"); 
  // entity1.setdigest("digest"); 
  entity1.setshow_conver_pic(1); 
  entity1.setthumb_media_id(result1.getmedia_id()); 
  entity1.settitle("心灵鸡汤"); 
  array.add(entity1); 
  uploadnewsmedia entity2 = new uploadnewsmedia(); 
  entity2.setauthor("phil"); 
  entity2.setcontent("什么是幸福,幸福就是自己的一种愉快的心理状态和感受。时时、事事都能使自己快乐的人才是最幸福的人。最快乐的人,就是最幸福的人。笑口常开的人,是最幸福的。"); 
  entity2.setcontent_source_url("http://www.qq.com"); 
  // entity2.setdigest("digest"); 
  entity2.setshow_conver_pic(0); 
  entity2.setthumb_media_id(result2.getmedia_id()); 
  entity2.settitle(" 经典语录"); 
  array.add(entity2); 
  uploadmediasresult ur = httprequtil.uploadnewsmedia("phil_token", array); 
  list<string> openids = new arraylist<>(); 
  openids.add("ovhq5v9-zshucax_ntcqwip-sbcg"); 
  openids.add("ovhq5v6cw3inkwuscl3olodif0cc"); 
  massmsgresult result_news = wechatmsgservice.sendmpnewstoopenid("phil_token", openids, 
  ur.getmedia_id()); 
  logger.debug(" send by openid msg {} " ,result_news.geterrmsg()); 
  // 根据openid列表群发文字消息 
  massmsgresult result_text = wechatmsgservice.sendtexttoopenid("phil_token", openids, 
  "什么是幸福,幸福就是自己的一种愉快的心理状态和感受。时时、事事都能使自己快乐的人才是最幸福的人。最快乐的人,就是最幸福的人。笑口常开的人,是最幸福的"); 
  logger.debug(" send by openid msg {} " ,result_text.geterrmsg()); 
  return null; 
} 

七、部分用到的类和方法

群发方法

/** 
 * 根据标签进行群发文本消息 
 * @param accesstoken 授权token 
 * @param entity 图文消息对象 
 * @return 
 */ 
public massmsgresult sendtexttotag(string accesstoken, int tagid, string content){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> filterparams = new hashmap<>(); 
  filterparams.put("is_to_all", false); 
  filterparams.put("tag_id", tagid); 
  map<string, object> textparams = new hashmap<>(); 
  textparams.put("content", content); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("filter", filterparams); 
  dataparams.put("text", textparams); 
  dataparams.put("msgtype", "text"); 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_all_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据标签进行群发图文消息 
 * @param accesstoken 授权token 
 * @param tagid 标签 
 * @param mediaid uploadmedia方法获得 
 * @return 
 */ 
public massmsgresult sendmpnewstotag(string accesstoken, int tagid, string mediaid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> filterparams = new hashmap<>(); 
  filterparams.put("is_to_all", false); 
  filterparams.put("tag_id", tagid); 
  map<string, object> mpnewsparams = new hashmap<>(); 
  mpnewsparams.put("media_id", mediaid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("filter", filterparams); 
  dataparams.put("mpnews", mpnewsparams); 
  dataparams.put("msgtype", "mpnews"); 
  dataparams.put("send_ignore_reprint", 0);//不能省略 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_all_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据标签进行群发图片 
 * @param accesstoken 授权token 
 * @param tagid 标签 
 * @param mediaid uploadmedia方法获得 
 * @return 
 */ 
public massmsgresult sendimagetotag(string accesstoken, int tagid, string mediaid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> filterparams = new hashmap<>(); 
  filterparams.put("is_to_all", false); 
  filterparams.put("tag_id", tagid); 
  map<string, object> imageparams = new hashmap<>(); 
  imageparams.put("media_id", mediaid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("filter", filterparams); 
  dataparams.put("image", imageparams); 
  dataparams.put("msgtype", "image"); 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_all_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据标签进行群发语音/音频 
 * @param accesstoken 授权token 
 * @param tagid 标签 
 * @param mediaid uploadmedia方法获得 
 * @return 
 */ 
public massmsgresult sendvoicetotag(string accesstoken, int tagid, string mediaid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> filterparams = new hashmap<>(); 
  filterparams.put("is_to_all", false); 
  filterparams.put("tag_id", tagid); 
  map<string, object> voiceparams = new hashmap<>(); 
  voiceparams.put("media_id", mediaid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("filter", filterparams); 
  dataparams.put("voice", voiceparams); 
  dataparams.put("msgtype", "voice"); 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_all_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据标签进行群发视频 
 * @param accesstoken 授权token 
 * @param tagid 标签 
 * @param mediaid uploadmedia方法获得 
 * @return 
 */ 
public massmsgresult sendvideototag(string accesstoken, int tagid, string mediaid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> filterparams = new hashmap<>(); 
  filterparams.put("is_to_all", false); 
  filterparams.put("tag_id", tagid); 
  map<string, object> mpvideoparams = new hashmap<>(); 
  mpvideoparams.put("media_id", mediaid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("filter", filterparams); 
  dataparams.put("mpvideo", mpvideoparams); 
  dataparams.put("msgtype", "mpvideo"); 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_all_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据标签进行群发卡券 
 * @param accesstoken 授权token 
 * @param tagid 标签 
 * @param card_id 
 * @return 
 */ 
public massmsgresult sendwxcardtotag(string accesstoken, int tagid, string cardid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> filterparams = new hashmap<>(); 
  filterparams.put("is_to_all", false); 
  filterparams.put("tag_id", tagid); 
  map<string, object> wxcardparams = new hashmap<>(); 
  wxcardparams.put("card_id", cardid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("filter", filterparams); 
  dataparams.put("wxcard", wxcardparams); 
  dataparams.put("msgtype", "wxcard"); 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_all_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据openid进行群发图文消息 
 * @param accesstoken 授权token 
 * @param tagid 标签 
 * @param mediaid uploadmedia方法获得 
 * @return 
 */ 
public massmsgresult sendmpnewstoopenid(string accesstoken, list<string> openids, string mediaid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> mpnewsparams = new hashmap<>(); 
  mpnewsparams.put("media_id", mediaid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("touser", openids); 
  dataparams.put("mpnews", mpnewsparams); 
  dataparams.put("msgtype", "mpnews"); 
  dataparams.put("send_ignore_reprint", 0); 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据openid进行群发文本消息 
 * @param accesstoken 授权token 
 * @param openids openid 
 * @param content 
 * @return 
 */ 
public massmsgresult sendtexttoopenid(string accesstoken, list<string> openids, string content){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> textparams = new hashmap<>(); 
  textparams.put("content", content); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("touser", openids); 
  dataparams.put("text", textparams); 
  dataparams.put("msgtype", "text"); 
  string data = jsonutil.tojsonstring(dataparams); 
  system.out.println(data); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据openid进行群发语音消息 
 * @param accesstoken 授权token 
 * @param openids openid 
 * @param mediaid 
 * @return 
 */ 
public massmsgresult sendvocietoopenid(string accesstoken, list<string> openids, string mediaid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> voiceparams = new hashmap<>(); 
  voiceparams.put("media_id", mediaid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("touser", openids); 
  dataparams.put("voice", voiceparams); 
  dataparams.put("msgtype", "voice"); 
  string data = jsonutil.tojsonstring(dataparams); 
  system.out.println(data); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
 
/** 
 * 根据openid进行群发图片消息 
 * @param accesstoken 授权token 
 * @param openids openid 
 * @param mediaid 
 * @return 
 */ 
public massmsgresult sendimagetoopenid(string accesstoken, list<string> openids, string mediaid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> imageparams = new hashmap<>(); 
  imageparams.put("media_id", mediaid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("touser", openids); 
  dataparams.put("image", imageparams); 
  dataparams.put("msgtype", "image"); 
  string data = jsonutil.tojsonstring(dataparams); 
  system.out.println(data); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据openid进行群发视频消息 
 * @param accesstoken 授权token 
 * @param openids openid 
 * @param mpvideomedia uploadmediavideo方法获得media 
 * @return 
 */ 
public massmsgresult sendvideotoopenid(string accesstoken, list<string> openids, mpvideomedia mpvideomedia){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("touser", openids); 
  dataparams.put("mpvideo", mpvideomedia); 
  dataparams.put("msgtype", "mpvideo"); 
  string data = jsonutil.tojsonstring(dataparams); 
  system.out.println(data); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 
 
/** 
 * 根据openid进行群发卡券消息 
 * @param accesstoken 授权token 
 * @param openids openid 
 * @param mediaid 
 * @return 
 */ 
public massmsgresult sendwxcardtoopenid(string accesstoken, list<string> openids, string cardid){ 
  massmsgresult result = null; 
  treemap<string, string> params = new treemap<>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  map<string, object> wxcardparams = new hashmap<>(); 
  wxcardparams.put("card_id", cardid); 
  treemap<string,object> dataparams = new treemap<>(); 
  dataparams.put("touser", openids); 
  dataparams.put("wxcard", wxcardparams); 
  dataparams.put("msgtype", "wxcard"); 
  string data = jsonutil.tojsonstring(dataparams); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.send_mass_message_url, params, data); 
  try { 
    result = jsonutil.fromjsonstring(json, massmsgresult.class); 
  } catch (exception e) { 
    e.printstacktrace(); 
  } 
  return result; 
} 

视频post数据bean

/** 
 * 视频post数据bean 
 * @author phil 
 * @date 2017年9月20日 
 * 
 */ 
public class mpvideomedia {  
  private string media_id;   
  private string title; 
  private string description; 
} 

获取群发视频post中的media_id

/** 
 * 获取群发视频post中的media_id 
 * 
 * @param accesstoken 
 * @param uploadvideo 
 * @return 
 */ 
public static uploadmediasresult uploadmediavideo(string accesstoken, mpvideomedia mpvideomedia) { 
  uploadmediasresult result = null; 
  treemap<string, string> params = new treemap<string, string>(); 
  params.put("access_token", accesstoken); 
  // post 提交的参数 
  string data = jsonutil.tojsonstring(mpvideomedia); 
  string json = httprequtil.httpsdefaultexecute(systemconfig.post_method, wechatconfig.upload_video_media_url, 
      params, data); 
  result = jsonutil.fromjsonstring(json, uploadmediasresult.class); 
  return result; 
} 

群发返回的结果

package com.phil.wechat.msg.model.resp; 
 
import com.phil.wechat.base.result.resultstate; 
 
/** 
 * 群发消息返回的结果 
 * 根据openid列表群发 
 * @author phil 
 * @date 2017年7月2日 
 * 
 */  
public class massmsgresult extends resultstate{  
   
  private string type; //媒体文件类型,分别有图片(image)、语音(voice)、视频(video)和缩略图(thumb),次数为news,即图文消息  
  private string msg_id;  
  private string msg_data_id;  
}  

配置类

// 按分组进行群发 
public static final string send_all_mass_message_url = "https://api.weixin.qq.com/cgi-bin/message/mass/sendall"; 
// 按照openid进行群发消息(openid最少2个,最多10000个 10000个) 
public static final string send_mass_message_url = "https://api.weixin.qq.com/cgi-bin/message/mass/send"; 
//上传图文消息素材 
public static final string upload_news_media_url = "https://api.weixin.qq.com/cgi-bin/media/uploadnews"; 
//获取群发视频post中的media_id 
public static final string upload_video_media_url = " https://api.weixin.qq.com/cgi-bin/media/uploadvideo"; 

,希望帮到了你

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持。