开发者社区> dsn727455218> 正文

微信开发之获取openid及推送模板消息

简介: 有很多的朋友再问我怎么获取code,openid之类的问题,在这里我就给大家分享一下。 在做微信支付是需要获取openid的,推送模板消息也是需要openid包括其他一些功能分享等也都是需要的,openid是什么呢,这里给大家解释一下,是用户在公众号中的一个标识,就相当于你数据表中的ID一样,一个身份标识。
+关注继续查看
有很多的朋友再问我怎么获取code,openid之类的问题,在这里我就给大家分享一下。

在做微信支付是需要获取openid的,推送模板消息也是需要openid包括其他一些功能分享等也都是需要的,openid是什么呢,这里给大家解释一下,是用户在公众号中的一个标识,就相当于你数据表中的ID一样,一个身份标识。

不多说废话了这里直接上代码了:

这里写一个了a标签来获取code,需要注意的是redirect_uri=接收code的回调地址(是带http://格式)可以指向下面的register

<a style="color: #fff" href="https://open.weixin.qq.com/connect/oauth2/authorize?appid=你公众号的appid&redirect_uri=接收code的回调地址(是带http://格式)&response_type=code&scope=snsapi_base&state=wxsq123#wechat_redirect">获取openid</a>

appid:是公众号的ID,appsecrect:是公众号的密钥,code:就是上面a标签重定向的获取到的  


@RequestMapping(params = "method=register", method = RequestMethod.POST)
    public @ResponseBody Map<String, Object> register(HttpServletRequest request) throws Exception {
 
    //接收来之页面a标签重定向的参数
    String code = request.getParameter("code");
    
    //返回openid
    String openid = WeiXinUtils.getOpenid(appid, appsecrt, code);
 
    //推送模板消息给用户
    WeiXinUtils.sendMsg(openid, "标题", "内容");
    
 
}

给一个封装的WeiXinUtils类:

 
 
import java.io.IOException;
import java.util.HashMap;
import java.util.Map;
 
import javax.servlet.http.Cookie;
import javax.servlet.http.HttpServletResponse;
 
import org.joda.time.DateTime;
 
import com.alibaba.fastjson.JSONObject;
 
 
public class WeiXinUtils {
 
    /**
     * Description: 获取微信公众号token<BR>
     * 
     * @author dsn
     * @date 2018年9月21日 上午9:53:26
     * @param appid
     * @param secret
     * @return
     * @version 1.0
     */
    public static String getAccessToken(String appid, String secret) {
        String token = "";
        String token_url = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid=" + appid
                + "&secret=" + secret;
        JSONObject result = PayCommonUtil.httpsRequest(token_url, "POST");
        if (result.get("access_token") != null) {
            token = result.get("access_token").toString();
        }
        return token;
    }
 
    /**
     * Description: 获取微信ticket<BR>
     * 
     * @author dsn
     * @date 2018年9月21日 上午9:54:03
     * @param token
     * @return
     * @version 1.0
     */
    public static String getTicket(String token) {
        if ("".equalsIgnoreCase(token) || null == token) {
            return "";
        }
        String ticket_url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?access_token=" + token + "&type=jsapi";
        JSONObject result = PayCommonUtil.httpsRequest(ticket_url, "POST");
        return result.get("ticket").toString();
 
    }
 
    /**
     * Description: 获取code <BR>
     * 
     * @author dsn
     * @date 2018年9月21日 下午12:02:43
     * @param redirect_uri
     * @param appid
     * @return
     * @version 1.0
     */
    public static void getCode(String redirect_uri, String appid, HttpServletResponse response) {
        String code_url = "https://open.weixin.qq.com/connect/oauth2/authorize?redirect_uri=" + redirect_uri + "&appid="
                + appid + "&response_type=code&scope=snsapi_base&state=1#wechat_redirect";
        try {
            response.sendRedirect(code_url);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
 
    /**
     * Description: 通过code获取用户openid<BR>
     * 
     * @author dsn
     * @date 2018年9月21日 下午12:02:18
     * @param appid
     * @param appsecret
     * @param code
     * @return
     * @version 1.0
     */
    public static String getOpenid(String appid, String appsecret, String code) {
        String openid_url = "https://api.weixin.qq.com/sns/oauth2/access_token?appid=" + appid + "&secret=" + appsecret
                + "&code=" + code + "&grant_type=authorization_code";
        JSONObject result = PayCommonUtil.httpsRequest(openid_url, "POST");
        if (result.containsKey("errcode")) {
            return "";
        } else {
            return result.getString("openid");
        }
    }
 
    /**
     * Description: 根据微信openid 获取用户是否关注公众号<BR>
     * 
     * @author dsn
     * @date 2018年9月21日 上午9:56:10
     * @param openId
     * @return
     * @version 1.0
     */
    public static Integer subscribeState(String openId) {
        String tmpurl = "https://api.weixin.qq.com/cgi-bin/user/info?access_token="
                + getAccessToken("wxcd1feb93b3454edc", "0a05181ac3bc53c44206a58e97d99b26") + "&openid=" + openId;
        JSONObject result = PayCommonUtil.httpsRequest(tmpurl, "GET");
        JSONObject resultJson = new JSONObject(result);
        String errmsg = (String) resultJson.get("errmsg");
        if (errmsg == null) {
            //用户是否订阅该公众号标识(0代表此用户没有关注该公众号 1表示关注了该公众号)。
            Integer subscribe = (Integer) resultJson.get("subscribe");
            return subscribe;
        }
        return -1;
    }
 
    /**
     * Description: 推送消息给用户<BR>
     * 
     * @author dsn
     * @date 2018年9月21日 上午11:44:09
     * @param openId
     * @param title
     * @param carname
     * @version 1.0
     */
    public static void sendMsg(String openId, String title, String carname) {
        final String appid = "";
        final String sercet = "";
        //用户是否订阅该公众号标识 (0代表此用户没有关注该公众号 1表示关注了该公众号)
        Integer state = WeiXinUtils.subscribeState(openId);
        // 绑定了微信并且关注了服务号的用户 , 注册成功-推送注册短信
        if (state == 1) {
            String date = DateTime.now().toString("yyyy-MM-dd HH:mm:ss");
            Map<String, TemplateData> param = new HashMap<>();
            param.put("first", new TemplateData(title, "#FF0000"));
            param.put("keyword1", new TemplateData(carname, "#696969"));
            param.put("keyword2", new TemplateData(date, "#696969"));
            param.put("remark", new TemplateData("", "#696969"));
            //注册的微信-模板Id
            //            String regTempId = WX_TemplateMsgUtil
            //                    .getWXTemplateMsgId(WeiXinEnum.WX_TEMPLATE_MSG_NUMBER.CAR_REMIND.getMsgNumber(), appid, sercet);
            //调用发送微信消息给用户的接口
            WX_TemplateMsgUtil.sendWechatMsgToUser(openId, "模板ID", "", "#000000",
                    WX_TemplateMsgUtil.packJsonmsg(param), appid, sercet);
        }
    }
 
    
    
 
    
}

发送post请求封装的httpsRqquest方法也贴出来了: 

/**
     * 发送https请求
     * 
     * @param requestUrl
     *            请求地址
     * @param requestMethod
     *            请求方式(GET、POST)
     * @param outputStr
     *            提交的数据
     * @return JSONObject(通过JSONObject.get(key)的方式获取json对象的属性值)
     */
    public static JSONObject httpsRequest(String requestUrl, String requestMethod) {
        JSONObject jsonObject = null;
        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 conn = (HttpsURLConnection) url.openConnection();
            // conn.setSSLSocketFactory(ssf);
            conn.setDoOutput(true);
            conn.setDoInput(true);
            conn.setUseCaches(false);
            conn.setConnectTimeout(3000);
            // 设置请求方式(GET/POST)
            conn.setRequestMethod(requestMethod);
            // conn.setRequestProperty("content-type",
            // "application/x-www-form-urlencoded");
            // 当outputStr不为null时向输出流写数据
            // 从输入流读取返回内容
            InputStream inputStream = conn.getInputStream();
            InputStreamReader inputStreamReader = new InputStreamReader(inputStream, "UTF-8");
            BufferedReader bufferedReader = new BufferedReader(inputStreamReader);
            String str = null;
            StringBuffer buffer = new StringBuffer();
            while ((str = bufferedReader.readLine()) != null) {
                buffer.append(str);
            }
            // 释放资源
            bufferedReader.close();
            inputStreamReader.close();
            inputStream.close();
            inputStream = null;
            conn.disconnect();
            jsonObject = JSONObject.parseObject(buffer.toString());
        } catch (ConnectException ce) {
            logger.error("", ce);
        } catch (Exception e) {
            logger.error("", e);
        }
        return jsonObject;
    }

还需要一个模板消息封装类WX_TemplateMsgUtil:

 
 
import java.util.Map;
 
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
 
import com.alibaba.fastjson.JSONObject;
 
 
public class WX_TemplateMsgUtil {
    private static Logger log = LoggerFactory.getLogger(WX_TemplateMsgUtil.class);
 
    /**
     * 封装模板详细信息
     * 
     * @return
     */
    public static JSONObject packJsonmsg(Map<String, TemplateData> param) {
        JSONObject json = new JSONObject();
        for (Map.Entry<String, TemplateData> entry : param.entrySet()) {
            JSONObject keyJson = new JSONObject();
            TemplateData dta = entry.getValue();
            keyJson.put("value", dta.getValue());
            keyJson.put("color", dta.getColor());
            json.put(entry.getKey(), keyJson);
        }
        return json;
    }
 
    /**
     * 根据模板的编号 新增并获取模板ID
     * 
     * @param templateSerialNumber
     *            模板库中模板的 "编号"
     * @return 模板ID
     */
    public static String getWXTemplateMsgId(String templateSerialNumber, String appid, String secret) {
        String tmpurl = "https://api.weixin.qq.com/cgi-bin/template/api_add_template?access_token="
                + WeiXinUtils.getAccessToken(appid, secret);
        JSONObject json = new JSONObject();
        json.put("template_id_short", templateSerialNumber);
        JSONObject result = PayCommonUtil.HttpsRequest(tmpurl, "POST", json.toString());
        JSONObject resultJson = new JSONObject(result);
        String errmsg = (String) resultJson.get("errmsg");
        //        log.info("获取模板编号返回信息:" + errmsg);
        if (!"ok".equals(errmsg)) {
            return "error";
        }
        String templateId = (String) resultJson.get("template_id");
        return templateId;
    }
 
    /**
     * 根据模板ID 删除模板消息
     * 
     * @param templateId
     *            模板ID
     * @return
     */
    public static String deleteWXTemplateMsgById(String templateId, String appid, String secret) {
        String tmpurl = "https://api.weixin.qq.com/cgi-bin/template/del_private_template?access_token="
                + WeiXinUtils.getAccessToken(appid, secret);
        JSONObject json = new JSONObject();
        json.put("template_id", templateId);
        try {
            JSONObject result = PayCommonUtil.HttpsRequest(tmpurl, "POST", json.toString());
            JSONObject resultJson = new JSONObject(result);
            //            log.info("删除" + templateId + "模板消息,返回CODE:" + resultJson.get("errcode"));
            String errmsg = (String) resultJson.get("errmsg");
            if (!"ok".equals(errmsg)) {
                return "error";
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
        return "success";
    }
 
    /**
     * 发送微信消息(模板消息)
     * 
     * @param touser
     *            用户 OpenID
     * @param templatId
     *            模板消息ID
     * @param clickurl
     *            URL置空,则在发送后,点击模板消息会进入一个空白页面(ios),或无法点击(android)。
     * @param topcolor
     *            标题颜色
     * @param data
     *            详细内容
     * @return
     */
    public static String sendWechatMsgToUser(String touser, String templatId, String clickurl, String topcolor,
            JSONObject data, String appid, String secret) {
        String tmpurl = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token="
                + WeiXinUtils.getAccessToken(appid, secret);
        JSONObject json = new JSONObject();
        json.put("touser", touser);
        json.put("template_id", templatId);
        json.put("url", clickurl);
        json.put("topcolor", topcolor);
        json.put("data", data);
        try {
            JSONObject result = PayCommonUtil.HttpsRequest(tmpurl, "POST", json.toString());
            JSONObject resultJson = new JSONObject(result);
            //            log.info("发送微信消息返回信息:" + resultJson.get("errcode"));
            String errmsg = (String) resultJson.get("errmsg");
            if (!"ok".equals(errmsg)) { //如果为errmsg为ok,则代表发送成功,公众号推送信息给用户了。
                return "error";
            }
        } catch (Exception e) {
            e.printStackTrace();
            return "error";
        } finally {
            if (templatId != null) {
                //删除新增的 微信模板
                //                deleteWXTemplateMsgById(templatId, appid, secret);
            }
        }
        return "success";
    }
}

TemplateData类: 

public class TemplateData {
    public String getValue() {
        return value;
    }
 
    public void setValue(String value) {
        this.value = value;
    }
 
    public String getColor() {
        return color;
    }
 
    public void setColor(String color) {
        this.color = color;
    }
 
    private String value;
    private String color;
 
    public TemplateData(String value, String color) {
        this.value = value;
        this.color = color;
    }
 
}

到这里就是一个完整的流程了,其实是很简单的,只要理解了流程。

当然还有一种用户授权登录,会弹出一个需要用户点击的确定,就可以获取用户的昵称,性别之类的信息。

https://blog.csdn.net/dsn727455218/article/details/65630151 找个地址就是授权登录的

需要注意的是a标签里面的scope为snsapi_userinfo 才能调起授权页面。

                                                                                                                                                                                                                                        

版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
异步tcp通信——APM.Server 消息推送服务的实现
消息推送服务   服务器推送目前流行就是私信、发布/订阅等模式,基本上都是基于会话映射,消息对列等技术实现的;高性能、分布式可以如下解决:会话映射可采用redis cluster等技术实现,消息对列可使用kafka等分布式消息队列方案实现。
1043 0
阿里云服务器端口号设置
阿里云服务器初级使用者可能面临的问题之一. 使用tomcat或者其他服务器软件设置端口号后,比如 一些不是默认的, mysql的 3306, mssql的1433,有时候打不开网页, 原因是没有在ecs安全组去设置这个端口号. 解决: 点击ecs下网络和安全下的安全组 在弹出的安全组中,如果没有就新建安全组,然后点击配置规则 最后如上图点击添加...或快速创建.   have fun!  将编程看作是一门艺术,而不单单是个技术。
20130 0
阿里云服务器怎么设置密码?怎么停机?怎么重启服务器?
如果在创建实例时没有设置密码,或者密码丢失,您可以在控制台上重新设置实例的登录密码。本文仅描述如何在 ECS 管理控制台上修改实例登录密码。
23538 0
【Android 异步操作】HandlerThread 示例 ( 初始化并执行 | 获取Looper | 获取 Handler | 获取消息队列 | 设置空闲队列 | 代码示例 )
【Android 异步操作】HandlerThread 示例 ( 初始化并执行 | 获取Looper | 获取 Handler | 获取消息队列 | 设置空闲队列 | 代码示例 )
30 0
阿里云服务器如何登录?阿里云服务器的三种登录方法
购买阿里云ECS云服务器后如何登录?场景不同,大概有三种登录方式:
13080 0
与众不同 windows phone (10) - Push Notification(推送通知)之推送 Tile 通知, 推送自定义信息
原文:与众不同 windows phone (10) - Push Notification(推送通知)之推送 Tile 通知, 推送自定义信息 [索引页][源码下载] 与众不同 windows phone (10) - Push Notification(推送通知)之推送 Tile 通知, 推送自定义信息 作者:webabcd介绍与众不同 windows phone 7.
954 0
RabbitMQ通过HTTP API获取队列消息内容
RabbitMQ通过HTTP API获取队列消息内容 背景 为配合公司数据中台建设,我们对公司内部使用的mysql binlog数据分发中间件(现已开源:https://gitee.com/kekingcn/keking-binlog-distributor )进行定制化改造,使其能够同时支持re.
3354 0
+关注
dsn727455218
一个奋斗的程序猿
35
文章
1
问答
文章排行榜
最热
最新
相关电子书
更多
JS零基础入门教程(上册)
立即下载
性能优化方法论
立即下载
手把手学习日志服务SLS,云启实验室实战指南
立即下载