JAVA小程序-获取OPENID

JAVA小程序-获取OPENID

package com.fh.controller.wxlogin;

import java.util.HashMap;
import java.util.Map;

import javax.annotation.Resource;

import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;

import com.fh.controller.base.BaseController;
import com.fh.controller.common.HttpRequest;
import com.fh.service.wxlogin.WxuserService;
import com.fh.util.AppUtil;
import com.fh.util.Const;
import com.fh.util.PageData;
import com.fh.util.wxPayUtils.WxPayConfig;

import net.sf.json.JSONObject;

/**

• 获取OPENID
• @author lenovo

*/
@Controller
@RequestMapping(value="/appuser")
public class GetOpenid extends BaseController{

@Resource(name="wxuserService")
private WxuserService wxuserService;


@RequestMapping(value="/openid",method = RequestMethod.POST)
@ResponseBody
public Object getOpenid(Model model,
        @RequestParam(value = "code",required = false) String code
       ) {
	System.out.println("进入");
	Map<String, Object> map = new HashMap<String, Object>();
	if(code.equals("")||code==null) {
		map.put("msg","code为空！");
		return map;
	}
    //获取微信小程序 session_key 和 openid
	String params = "appid="+WxPayConfig.APPID+"&secret="+Const.KEY+"&js_code=" + code + "&grant_type=authorization_code";
	String ss = HttpRequest.sendGet("https://api.weixin.qq.com/sns/jscode2session", params);
	JSONObject SessionKeyOpenId= JSONObject.fromObject(ss);
	if(SessionKeyOpenId.toString().indexOf("openid")<0) {
		  map.put("msg", "获取失败");
		  map.put("code", "fail");
		  return AppUtil.returnObject(new PageData(), map);	
	}
    String openid = SessionKeyOpenId.getString("openid" );
    map.put("code","success");//状态
    map.put("openid",openid);//:发送OPENID
    
    //缓存一份新的
    return AppUtil.returnObject(new PageData(), map);
}

}
注：WxPayConfig.APPID，Const.KEY（小程序的appid，从小程序获取）
2：HttpRequest类
package com.fh.controller.common;

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.URL;
import java.net.URLConnection;
import java.util.List;
import java.util.Map;

public class HttpRequest {

  public static void main(String[] args) {
      //发送 GET 请求
      String s=HttpRequest.sendGet("http://v.qq.com/x/cover/kvehb7okfxqstmc.html?vid=e01957zem6o", "");
      System.out.println(s);

// //发送 POST 请求
// String sr=HttpRequest.sendPost(“http://www.toutiao.com/stream/widget/local_weather/data/?city=上海”, “”);
// JSONObject json = JSONObject.fromObject(sr);
// System.out.println(json.get(“data”));
}

  /**
   * 向指定URL发送GET方法的请求

5 *
* @param url
* 发送请求的URL
* @param param
* 请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
* @return URL 所代表远程资源的响应结果
/
public static String sendGet(String url, String param) {
String result = “”;
BufferedReader in = null;
try {
String urlNameString = url + “?” + param;
URL realUrl = new URL(urlNameString);
// 打开和URL之间的连接
URLConnection connection = realUrl.openConnection();
// 设置通用的请求属性
connection.setRequestProperty(“accept”, "/*");
connection.setRequestProperty(“connection”, “Keep-Alive”);
connection.setRequestProperty(“user-agent”,
“Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)”);
// 建立实际的连接
connection.connect();
// 获取所有响应头字段
Map<String, List> map = connection.getHeaderFields();
// 遍历所有的响应头字段
for (String key : map.keySet()) {
System.out.println(key + “—>” + map.get(key));
}
// 定义 BufferedReader输入流来读取URL的响应
in = new BufferedReader(new InputStreamReader(
connection.getInputStream()));
String line;
while ((line = in.readLine()) != null) {
result += line;
}
} catch (Exception e) {
System.out.println(“发送GET请求出现异常！” + e);
e.printStackTrace();
}
// 使用finally块来关闭输入流
finally {
try {
if (in != null) {
in.close();
}
} catch (Exception e2) {
e2.printStackTrace();
}
}
return result;
}

  /**
   * 向指定 URL 发送POST方法的请求
   *
   * @param url
   *            发送请求的 URL
   * @param param
   *            请求参数，请求参数应该是 name1=value1&name2=value2 的形式。
   * @return 所代表远程资源的响应结果
   */
  public static String sendPost(String url, String param) {
      PrintWriter out = null;
      BufferedReader in = null;
      String result = "";
      try {
          URL realUrl = new URL(url);
          // 打开和URL之间的连接
          URLConnection conn = realUrl.openConnection();
          // 设置通用的请求属性
          conn.setRequestProperty("accept", "*/*");
          conn.setRequestProperty("connection", "Keep-Alive");
          conn.setRequestProperty("user-agent",
                  "Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)");
          // 发送POST请求必须设置如下两行
         conn.setDoOutput(true);
         conn.setDoInput(true);
         // 获取URLConnection对象对应的输出流
         out = new PrintWriter(conn.getOutputStream());
         // 发送请求参数
         out.print(param);
         // flush输出流的缓冲
         out.flush();
         // 定义BufferedReader输入流来读取URL的响应
         in = new BufferedReader(
                 new InputStreamReader(conn.getInputStream()));
         String line;
         while ((line = in.readLine()) != null) {
             result += line;
         }
     } catch (Exception e) {
         System.out.println("发送 POST 请求出现异常！"+e);
         e.printStackTrace();
     }
     //使用finally块来关闭输出流、输入流
     finally{
         try{
             if(out!=null){
                 out.close();
             }
             if(in!=null){
                 in.close();
             }
         }
         catch(IOException ex){
             ex.printStackTrace();
         }
     }
     return result;
 }

}