微信api接口操作示例

Posted on 2018/2/7 15:17:54
日常随笔
By 王佳亮

一、服务器基本信息交互

public class WeiXinServlet extends HttpServlet{ private static final long serialVersionUID = 1L;

 /** * 确认请求来自微信服务器 */

public void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException { // 微信加密签名  String signature = request.getParameter("signature"); // 时间戳  String timestamp = request.getParameter("timestamp"); // 随机数  String nonce = request.getParameter("nonce"); // 随机字符串  String echostr = request.getParameter("echostr");  

        PrintWriter out = response.getWriter(); // 通过检验signature对请求进行校验，若校验成功则原样返回echostr，表示接入成功，否则接入失败  if (SignUtil.checkSignature(signature, timestamp, nonce)) {  
            out.print(echostr);
        }  
        out.close();  
        out = null;  
    }

/** * 处理微信服务器发来的消息  */

public void doPost(HttpServletRequest request, HttpServletResponse response)throws ServletException, IOException { // 将请求、响应的编码均设置为UTF-8（防止中文乱码）  request.setCharacterEncoding("UTF-8");  
            response.setCharacterEncoding("UTF-8"); // 调用核心业务类接收消息、处理消息  String respMessage = CoreService.processRequest(request); // 响应消息  PrintWriter out = response.getWriter();  
            out.print(respMessage);  
            out.close();  
    }  
}

二、功能实现

2.1 公众平台通用接口工具类 public class WeixinUtil {

private static Logger log = LoggerFactory.getLogger(WeixinUtil.class);

// 第三方用户唯一凭证

public final static String appId = "wx71335f894797efd0";

// 第三方用户唯一凭证密钥

public final static String appSecret = "d524fcf5147c6c732a2270a64f5869a5";

 // 获取access_token的接口地址（GET）

public final static String access_token_url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=APPID&secret=APPSECRET";

// 菜单创建

public final static String menu_create_url = "https://api.weixin.qq.com/cgi-bin/menu/create?access_token=ACCESS_TOKEN";

 // 发送模板消息

public final static String sendtemplat_url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=ACCESS_TOKEN";

// 获取code后，请求以下链接获取用户access_token：

 public final static String userinfotoken_url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=APPID&secret=APPSECRET&code=CODE&grant_type=authorization_code";

 // 粉丝列表

 public final static String fansi_url = "https://api.weixin.qq.com/cgi-bin/user/get?access_token=ACCESS_TOKEN";

// 获取用户信息

public final static String user_url = "https://api.weixin.qq.com/sns/userinfo?access_token=ACCESS_TOKEN&openid=OPENID&lang=zh_CN";

// 获取用户基本信息（包括UnionID机制） 粉丝列表时使用

 public final static String fansi_userinfo_url = "https://api.weixin.qq.com/cgi-bin/user/info?access_token=ACCESS_TOKEN&openid=OPENID&lang=zh_CN";

// 创建临时二维码ticket

public final static String temporary_url = "https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=ACCESS_TOKEN";

// 创建永久二维码ticket

public final static String permanent_url = "https://api.weixin.qq.com/cgi-bin/qrcode/create?access_token=ACCESS_TOKEN";

// 通过ticket换取二维码 提醒：TICKET记得进行UrlEncode

public final static String qrcode_url = "https://mp.weixin.qq.com/cgi-bin/showqrcode?ticket=TICKET";

// 获取用户增减数据 最大时间跨度7天

public final static String getusersummary_url = "https://api.weixin.qq.com/datacube/getusersummary?access_token=ACCESS_TOKEN";

 // 获取累计用户数据 最大时间跨度7天

public final static String getusercumulate_url = "https://api.weixin.qq.com/datacube/getusercumulate?access_token=ACCESS_TOKEN";

// 获取jsapi_ticket

public final static String jsapi_ticket_url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=ACCESS_TOKEN&type=jsapi";

// 创建分组 POST数据例子：{"group":{"name":"test"}}

public final static String create_group_url = "https://api.weixin.qq.com/cgi-bin/groups/create?access_token=ACCESS_TOKEN";

// 查询所有分组

public final static String selete_group_url = "https://api.weixin.qq.com/cgi-bin/groups/get?access_token=ACCESS_TOKEN";

// 查询用户所在分组 POST数据例子：{"openid":"od8XIjsmk6QdVTETa9jLtGWA6KBc"}

public final static String selectUsers_group_url = "https://api.weixin.qq.com/cgi-bin/groups/getid?access_token=ACCESS_TOKEN";

// 修改分组名 POST数据例子：{"group":{"id":108,"name":"test2_modify2"}}

public final static String update_group_url = "https://api.weixin.qq.com/cgi-bin/groups/update?access_token=ACCESS_TOKEN";

// 批量移动用户分组

public final static String batch_group_url = "https://api.weixin.qq.com/cgi-bin/groups/members/batchupdate?access_token=ACCESS_TOKEN";

// 获取微信卡券 api_ticket

public final static String api_ticket_url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=ACCESS_TOKEN&type=wx_card";

 // 批量查询卡券列表

public final static String batchget_url = "https://api.weixin.qq.com/card/batchget?access_token=ACCESS_TOKEN";

// 查询卡券详情 http请求方式: POST POST数据 {"card_id":"pFS7Fjg8kV1IdDz01r4SQwMkuCKc"}

public final static String get_card_url = "https://api.weixin.qq.com/card/get?access_token=ACCESS_TOKEN";

// 创建卡券二维码 ticket post请求

public final static String create_cardTicket_url = "https://api.weixin.qq.com/card/qrcode/create?access_token=ACCESS_TOKEN";

// 核销卡券Code接口

 public final static String delete_code_url = "https://api.weixin.qq.com/card/code/consume?access_token=ACCESS_TOKEN";

// Code解码接口

public final static String code_decrypt_url = "https://api.weixin.qq.com/card/code/decrypt?access_token=ACCESS_TOKEN";

// 检测Code是否正常状态

public final static String check_code_url = "https://api.weixin.qq.com/card/code/get?access_token=ACCESS_TOKEN";

// 创建卡券货架接口

public final static String create_cardhj_url = "https://api.weixin.qq.com/card/landingpage/create?access_token=ACCESS_TOKEN";

// 获取用户已领取卡券接口

public final static String getcardlist_url = "https://api.weixin.qq.com/card/user/getcardlist?access_token=ACCESS_TOKEN";

       public static AccessToken getAccessToken(String appid, String appsecret) {

        AccessToken accessToken = null;

        String requestUrl = access_token_url.replace("APPID", appid).replace( "APPSECRET", appsecret);

        JSONObject jsonObject = httpRequest(requestUrl, "GET", null); // 如果请求成功 if (null != jsonObject) {

 try{

                accessToken = new AccessToken();

                accessToken.setToken(jsonObject.getString("access_token"));

                accessToken.setExpiresIn(jsonObject.getInteger("expires_in"));

            } catch (JSONException e) {

                accessToken = null; // 获取token失败 log.error("获取token失败 errcode:{} errmsg:{}",

                        jsonObject.getInteger("errcode"),

                        jsonObject.getString("errmsg"));

        } return accessToken;

 /**获取网页授权用户的token */

 public static OAuthInfo getUserToken(String code) {
        String requestUrl = userinfotoken_url.replace("APPID", appId)
                .replace("APPSECRET", appSecret).replace("CODE", code);
        JSONObject jsonObject = httpRequest(requestUrl, "GET", null);
        OAuthInfo oa = new OAuthInfo(); if (null != jsonObject) { try {
                oa.setAccessToken(jsonObject.getString("access_token"));
                oa.setExpiresin(jsonObject.getInteger("expires_in").toString());
                oa.setRefreshToken(jsonObject.getString("refresh_token"));
                oa.setOpenid(jsonObject.getString("openid"));
                oa.setScope(jsonObject.getString("scope"));
            } catch (JSONException e) { // 获取token失败 log.error("网页授权获取openId失败 errcode:{} errmsg:{}",
                        jsonObject.getInteger("errcode"),
                        jsonObject.getString("errmsg"));
            }
        } return oa;
      }

   /**获取网页授权用户的详细信息 */

 public static WxUserinfo getWxUserInfo(OAuthInfo oa) {
        String requestUrl = user_url.replace("ACCESS_TOKEN",
                oa.getAccessToken()).replace("OPENID", oa.getOpenid());
        JSONObject jsonObject = httpRequest(requestUrl, "GET", null);
        WxUserinfo user = new WxUserinfo(); if (jsonObject != null) {
            user.setOpenid(jsonObject.getString("openid"));
            user.setNickname(jsonObject.getString("nickname"));
            user.setSex(jsonObject.getString("sex"));
            user.setProvince(jsonObject.getString("province"));
            user.setCity(jsonObject.getString("city"));
            user.setCountry(jsonObject.getString("country"));
            user.setHeadimgurl(jsonObject.getString("headimgurl"));
            user.setPrivilege(jsonObject.getString("privilege"));
        } return user;
    }

     /**创建菜单*/

    public static int createMenu(Menu menu, String accessToken) { int result = 0;

 // 拼装创建菜单的url

     String url = menu_create_url.replace("ACCESS_TOKEN", accessToken);

 // 将菜单对象转换成json字符串

    String jsonMenu = JSONObject.toJSONString(menu);

 // 调用接口创建菜单

     JSONObject jsonObject = httpRequest(url, "POST", jsonMenu); if (null != jsonObject) { if (0 != jsonObject.getInteger("errcode")) {
                result = jsonObject.getInteger("errcode");
                log.error("创建菜单失败 errcode:{} errmsg:{}",
                        jsonObject.getInteger("errcode"),
                        jsonObject.getString("errmsg"));
            }
        } return result;
    }

/**获取粉丝列表信息*/

 public static JSONArray getFansList(String accessToken) {
        JSONArray arrs = new JSONArray();
        String url = fansi_url.replace("ACCESS_TOKEN", accessToken);
        JSONObject jsonObject = httpRequest(url, "GET", null); if (null != jsonObject) {
            JSONObject data = (JSONObject) jsonObject.get("data");
            JSONArray openidList = data.getJSONArray("openid"); for (int i = 0; i < openidList.size(); i++) {
                System.out.println(openidList.getString(i));
                JSONObject obj = httpRequest(
                        fansi_userinfo_url.replace("ACCESS_TOKEN", accessToken)
                                .replace("OPENID", openidList.getString(i)), "GET", null); if (obj != null) {
                    arrs.add(obj);
                }
            }
        } return arrs;
    }

/** 创建二维码ticket*/

 public static JSONObject createTicket(String type, String accessToken,
            String expire_seconds, String scene_id) {
        String requestUrl = "";
        String jsonStr = ""; if (type.equals("1")) {// 临时 requestUrl = temporary_url.replace("ACCESS_TOKEN", accessToken);
            jsonStr = "{\"expire_seconds\": 604800, \"action_name\": \"QR_SCENE\", \"action_info\": {\"scene\": {\"scene_id\": 123}}}";
        } else {// 永久 requestUrl = permanent_url.replace("ACCESS_TOKEN", accessToken);
            jsonStr = "{\"action_name\": \"QR_LIMIT_SCENE\", \"action_info\": {\"scene\": {\"scene_id\": 123}}}";
        }
        JSONObject jsonObject = httpRequest(requestUrl, "POST", jsonStr); return jsonObject;
    }

 /** 发起https请求并获取结果*/

 public static JSONObject httpRequest(String requestUrl,
        String requestMethod, String outputStr) {
        JSONObject jsonObject = null;
        StringBuffer buffer = new StringBuffer(); try {

 // 创建SSLContext对象，并使用我们指定的信任管理器初始化

            TrustManager[] tm = { new MyX509TrustManager() };
            SSLContext sslContext = SSLContext.getInstance("SSL", "SunJSSE");
            sslContext.init(null, tm, new java.security.SecureRandom()); // 从上述SSLContext对象中得到SSLSocketFactory对象 SSLSocketFactory ssf = sslContext.getSocketFactory();

            URL url = new URL(requestUrl);
            HttpsURLConnection httpUrlConn = (HttpsURLConnection) url
                    .openConnection();
            httpUrlConn.setSSLSocketFactory(ssf);

            httpUrlConn.setDoOutput(true);
            httpUrlConn.setDoInput(true);
            httpUrlConn.setUseCaches(false); // 设置请求方式（GET/POST） httpUrlConn.setRequestMethod(requestMethod); if ("GET".equalsIgnoreCase(requestMethod))
                httpUrlConn.connect(); // 当有数据需要提交时 if (null != outputStr) {
                OutputStream outputStream = httpUrlConn.getOutputStream(); // 注意编码格式，防止中文乱码 outputStream.write(outputStr.getBytes("UTF-8"));
                outputStream.close();
            } // 将返回的输入流转换成字符串 InputStream inputStream = httpUrlConn.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(
                    inputStream, "utf-8");
            BufferedReader bufferedReader = new BufferedReader(
                    inputStreamReader);

            String str = null; while ((str = bufferedReader.readLine()) != null) {
                buffer.append(str);
            }
            bufferedReader.close();
            inputStreamReader.close(); // 释放资源 inputStream.close();
            inputStream = null;
            httpUrlConn.disconnect();
            jsonObject = JSONObject.parseObject(buffer.toString());
        } catch (ConnectException ce) {
            log.error("Weixin server connection timed out.");
        } catch (Exception e) {
            log.error("https request error:{}", e);
        } return jsonObject;
    }

public static Map<String, Object> wxMsgMap(Map<String, Object> allMap,
            String key, String value, String color) {
        Map<String, Object> map = new HashMap<String, Object>();
        map.put("value", value);
        map.put("color", color);
        allMap.put(key, map); return allMap;

    }

/**发送模板消息 */

public static JSONObject postTemplateMsg(String accessToken, String OpenId,
        String template_id, String detailUrl, Map<String, Object> map) {
        String url = sendtemplat_url.replace("ACCESS_TOKEN", accessToken);
        JSONObject jso = new JSONObject();
        jso.put("touser", OpenId);
        jso.put("template_id", template_id); if (detailUrl != null)
            jso.put("url", detailUrl);
        jso.put("data", map); return httpRequest(url, "POST", jso.toString());
    }
}

微信api接口操作示例

微信公众号

抖音视频号

著作成果