java微信接口之五—消息分組群發

一、微信消息分組群發接口簡介

　　1、請求：該請求是使用post提交地址為： 

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

　   其中ACCESS_TOKEN是我們動態獲取的。

　   發送的數據：(這里使用圖文消息示例)

{
   "filter":{
      "group_id":"2"
   },
   "mpnews":{
      "media_id":"123dsdajkasd231jhksad"
   },
    "msgtype":"mpnews"
}

　　filter，用於設定圖文消息的接收者；
　　group_id，群發到的分組的group_id（可在java微信接口之二—獲取用戶組）；

　　mpnews,用於設定即將發送的圖文消息；

　　media_id, 用於群發的消息的media_id(可在java微信接口之四—上傳素材中獲取)； 　msgtype,群發的消息類型，圖文消息為mpnews，文本消息為text，語音為voice，音樂為music，圖片為image，視頻為video.

　2、響應：該響應也是以json方式返回的

　　正確的時候返回的數據： 

{
   "errcode":0,
   "errmsg":"send job submission success",
   "msg_id":34182
}

　　errcode 錯誤碼
　　errmsg 錯誤信息
　　msg_id 消息ID　

　　錯誤的時候返回的數據：{"errcode":40004,"errmsg":"invalid media type"}

　　errcode，為錯誤代碼，errmsg為錯誤信息

　　具體api可查看：http://mp.weixin.qq.com/wiki/index.php?title=%E9%AB%98%E7%BA%A7%E7%BE%A4%E5%8F%91%E6%8E%A5%E5%8F%A3

二、關於java代碼的調用

　　該接口的調用與java微信接口四—上傳素材一樣，需要使用到commons-httpclient。其中數據是構造成json數據后，放在post方法請求體里面發送給服務器端。

三、代碼實現

 

package com.demo.test;

import java.io.File;
import java.util.ArrayList;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.apache.commons.httpclient.methods.PostMethod;
import org.apache.commons.httpclient.methods.multipart.FilePart;
import org.apache.commons.httpclient.methods.multipart.MultipartRequestEntity;
import org.apache.commons.httpclient.methods.multipart.Part;
import org.apache.http.HttpEntity;
import org.apache.http.HttpResponse;
import org.apache.http.HttpStatus;
import org.apache.http.client.HttpClient;
import org.apache.http.client.methods.HttpGet;
import org.apache.http.impl.client.DefaultHttpClient;
import org.apache.http.util.EntityUtils;

import com.google.gson.Gson;
import com.google.gson.JsonArray;
import com.google.gson.JsonObject;
import com.google.gson.JsonParser;

public class Test
{
    public static final String GET_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token";// 獲取access
    public static final String UPLOAD_IMAGE_URL = "http://file.api.weixin.qq.com/cgi-bin/media/upload";// 上傳多媒體文件
    public static final String UPLOAD_FODDER_URL = "https://api.weixin.qq.com/cgi-bin/media/uploadnews";
    public static final String GET_USER_GROUP = "https://api.weixin.qq.com/cgi-bin/groups/get"; // url
    public static final String SEND_MESSAGE_URL = "https://api.weixin.qq.com/cgi-bin/message/mass/sendall";
    public static final String APP_ID = "wxa549b28c24cf341e";
    public static final String SECRET = "78d8a8cd7a4fa700142d06b96bf44a37";


    /**
     * 發送消息
     * 
     * @param uploadurl
     *            apiurl
     * @param access_token
     * @param data
     *            發送數據
     * @return
     */
    public static String sendMsg(String url, String token, String data)
    {
        org.apache.commons.httpclient.HttpClient client = new org.apache.commons.httpclient.HttpClient();
        String sendurl = String.format("%s?access_token=%s", url, token);
        PostMethod post = new UTF8PostMethod(sendurl);
        post
                .setRequestHeader(
                        "User-Agent",
                        "Mozilla/5.0 (Macintosh; Intel Mac OS X 10.9; rv:30.0) Gecko/20100101 Firefox/30.0");

        post.setRequestHeader("Host", "file.api.weixin.qq.com");
        post.setRequestHeader("Connection", "Keep-Alive");
        post.setRequestHeader("Cache-Control", "no-cache");
        String result = null;
        try
        {
            post.setRequestBody(data);
            int status = client.executeMethod(post);
            if (status == HttpStatus.SC_OK)
            {
                String responseContent = post.getResponseBodyAsString();
                System.out.println(responseContent);
                JsonParser jsonparer = new JsonParser();// 初始化解析json格式的對象
                JsonObject json = jsonparer.parse(responseContent)
                        .getAsJsonObject();
                if (json.get("errcode") != null
                        && json.get("errcode").getAsString().equals("0"))
                {
                    result = json.get("errmsg").getAsString();
                }
            }
        }
        catch (Exception e)
        {
            e.printStackTrace();
        }
        finally
        {
            return result;
        }
    }
    
    public static class UTF8PostMethod extends PostMethod {//防止發送的消息產生亂碼
        public UTF8PostMethod(String url) {
            super(url);
        }

        @Override
        public String getRequestCharSet() {//文本編碼格式
            return "UTF-8";
        }
    }

    public static void main(String[] args) throws Exception
    {
        String accessToken = getToken(GET_TOKEN_URL, APP_ID, SECRET);// 獲取token在微信接口之一中獲取
        if (accessToken != null)// token成功獲取
        {
            System.out.println(accessToken);
            File file = new File("f:" + File.separator + "2000.JPG"); // 獲取本地文件
            String id = uploadImage(UPLOAD_IMAGE_URL, accessToken, "image",
                    file);// java微信接口之三—上傳多媒體文件 可獲取
            if (id != null)
            {
                // 構造數據
                Map map = new HashMap();
                map.put("thumb_media_id", id);
                map.put("author", "wxx");
                map.put("title", "標題");
                map.put("content", "測試fdsfdsfsdfssfdsfsdfsdfs");
                map.put("digest", "digest");
                map.put("show_cover_pic", "0");

                Map map2 = new HashMap();
                map2.put("thumb_media_id", id);
                map2.put("author", "wxx");
                map2.put("content_source_url", "www.google.com");
                map2.put("title", "標題");
                map2.put("content", "測試fdsfdsfsdfssfdsfsdfsdfs");
                map2.put("digest", "digest");

                Map map3 = new HashMap();
                List<Map> list = new ArrayList<Map>();
                list.add(map);
                list.add(map2);
                map3.put("articles", list);

                Gson gson = new Gson();
                String result = gson.toJson(map3);// 轉換成json數據格式
                String mediaId = uploadFodder(UPLOAD_FODDER_URL, accessToken,
                        result);
                if (mediaId != null)
                {
                    String ids = getGroups(GET_USER_GROUP, accessToken);// 在java微信接口之二—獲取用戶組
                    if (ids != null)
                    {
                        String[] idarray = ids.split(",");// 用戶組id數組
                        for (String gid : idarray)
                        {
                            
                            JsonObject jObj = new JsonObject();
                            JsonObject filter = new JsonObject();
                            filter.addProperty("group_id", gid);
                            jObj.add("filter", filter);
 
 
                            JsonObject mpnews = new JsonObject();
                            mpnews.addProperty("media_id", mediaId);
                            jObj.add("mpnews", mpnews);
 
                            jObj.addProperty("msgtype", "mpnews"); 
                            System.out.println(jObj.toString());

                            String result2 = sendMsg(SEND_MESSAGE_URL,
                                    accessToken, jObj.toString());
                            System.out.println(result2);
                        }
                    }
                }

            }
        }
    }
}

　　發成功后會打印消息，但由於微信服務器的原因，消息不會立即發送，會過一段時間發送。