|
@@ -0,0 +1,229 @@
|
|
|
+package com.ygj.yuemum.service.global;
|
|
|
+
|
|
|
+import com.alibaba.fastjson.JSON;
|
|
|
+import com.ygj.yuemum.dao.global.WeChatInfoDao;
|
|
|
+import com.ygj.yuemum.domain.global.WeChatInfo;
|
|
|
+import org.springframework.beans.factory.annotation.Autowired;
|
|
|
+import org.springframework.stereotype.Service;
|
|
|
+
|
|
|
+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.security.MessageDigest;
|
|
|
+import java.security.NoSuchAlgorithmException;
|
|
|
+import java.util.HashMap;
|
|
|
+import java.util.List;
|
|
|
+import java.util.Map;
|
|
|
+import java.util.UUID;
|
|
|
+
|
|
|
+@Service
|
|
|
+public class WeChatInfoService {
|
|
|
+ @Autowired
|
|
|
+
|
|
|
+ private WeChatInfoDao weChatInfoDao;
|
|
|
+ public static String APPID = "wx52852a3c47540fad";
|
|
|
+ public static String APPSECRET = "31e4eef58038830327eb88661e3a681f";
|
|
|
+ public static String GRANT_TYPE = "client_credential";
|
|
|
+ public static String JSAPI_TICKET_TYPE = "jsapi";
|
|
|
+ public static String ACCESS_TOKEN_URL = "https://api.weixin.qq.com/cgi-bin/token";
|
|
|
+ public static String JSAPI_TICKET_URL = "https://api.weixin.qq.com/cgi-bin/ticket/getticket";
|
|
|
+ private static final char[] HEX_DIGITS = {'0', '1', '2', '3', '4', '5','6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
|
|
|
+ String access_Token;
|
|
|
+ String expires_in;
|
|
|
+ String jsapi_Ticket;
|
|
|
+ String noncestr;
|
|
|
+ String timeStamp;
|
|
|
+ String signaTure;
|
|
|
+
|
|
|
+ public int SaveWeChatInfo() {
|
|
|
+ try {
|
|
|
+ //access_token
|
|
|
+ String resultToken = sendGet(ACCESS_TOKEN_URL + "?grant_type=" + GRANT_TYPE + "&appid=" + APPID + "&secret=" + APPSECRET);
|
|
|
+ Map mapToken = JSON.parseObject(resultToken);
|
|
|
+ access_Token = String.valueOf(mapToken.get("access_token"));
|
|
|
+ expires_in = String.valueOf(mapToken.get("expires_in"));
|
|
|
+ System.out.println("access_Token=="+access_Token);
|
|
|
+ System.out.println("expires_in=="+expires_in);
|
|
|
+ //get jsApi_ticket
|
|
|
+ String resultJsapi = sendGet(JSAPI_TICKET_URL + "?access_token=" + access_Token + "&type=" + JSAPI_TICKET_TYPE);
|
|
|
+ Map mapJsapi = JSON.parseObject(resultJsapi);
|
|
|
+ jsapi_Ticket = String.valueOf(mapJsapi.get("ticket"));
|
|
|
+ System.out.println("jsapi_Ticket==="+jsapi_Ticket);
|
|
|
+ //保存到数据库中
|
|
|
+ WeChatInfo weChatInfo = new WeChatInfo();
|
|
|
+ weChatInfo.setAccess_token(access_Token);
|
|
|
+ weChatInfo.setJsapi_ticket(jsapi_Ticket);
|
|
|
+ weChatInfoDao.updateWeChatInfo(weChatInfo);
|
|
|
+ }catch (Exception ex){
|
|
|
+ ex.printStackTrace();
|
|
|
+ return 0;
|
|
|
+ }
|
|
|
+ return 1;
|
|
|
+ }
|
|
|
+ public Map<String,String> getWeChatInfo(String url){
|
|
|
+ System.out.println(url);
|
|
|
+ WeChatInfo weChatInfo = weChatInfoDao.getWeChatInfo();
|
|
|
+ Map<String, String> result = new HashMap<>();
|
|
|
+ String timestamp = getTimestamp();
|
|
|
+ String noncestr = getNoncestr();
|
|
|
+ String signature =SHA1(jointString(weChatInfo.getJsapi_ticket(),noncestr,timestamp,url));
|
|
|
+ result.put("timestamp",timestamp);
|
|
|
+ result.put("nonceStr",noncestr);
|
|
|
+ result.put("signature",signature);
|
|
|
+ result.put("appid",APPID);
|
|
|
+ result.put("jsapi_ticket",weChatInfo.getJsapi_ticket());
|
|
|
+ return result;
|
|
|
+ }
|
|
|
+
|
|
|
+ //-----------------------------------
|
|
|
+ public static String jointString(String jsapi_Ticket,String noncestr,String timestamp,String url){
|
|
|
+ String sb = new String ();
|
|
|
+ sb +="jsapi_ticket=" + jsapi_Ticket+"&";
|
|
|
+ sb +="noncestr=" + noncestr+"&";
|
|
|
+ sb +="timestamp=" + timestamp+"&";
|
|
|
+ sb +="url=" + url;
|
|
|
+ return sb;
|
|
|
+ }
|
|
|
+
|
|
|
+ public static String SHA1(String str) {
|
|
|
+ try {
|
|
|
+ MessageDigest digest = java.security.MessageDigest
|
|
|
+ .getInstance("SHA-1"); //如果是SHA加密只需要将"SHA-1"改成"SHA"即可
|
|
|
+ digest.update(str.getBytes());
|
|
|
+ byte messageDigest[] = digest.digest();
|
|
|
+ // Create Hex String
|
|
|
+ StringBuffer hexStr = new StringBuffer();
|
|
|
+ // 字节数组转换为 十六进制 数
|
|
|
+ for (int i = 0; i < messageDigest.length; i++) {
|
|
|
+ String shaHex = Integer.toHexString(messageDigest[i] & 0xFF);
|
|
|
+ if (shaHex.length() < 2) {
|
|
|
+ hexStr.append(0);
|
|
|
+ }
|
|
|
+ hexStr.append(shaHex);
|
|
|
+ }
|
|
|
+ return hexStr.toString();
|
|
|
+
|
|
|
+ } catch (NoSuchAlgorithmException e) {
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ return null;
|
|
|
+ }
|
|
|
+
|
|
|
+ public static String getTimestamp(){
|
|
|
+ return Long.toString(System.currentTimeMillis()/1000);
|
|
|
+ }
|
|
|
+ public static String getNoncestr(){
|
|
|
+ return UUID.randomUUID().toString();
|
|
|
+ }
|
|
|
+
|
|
|
+ public static String sendGet(String url) {
|
|
|
+ String result = "";
|
|
|
+ StringBuilder jsonStr = new StringBuilder();
|
|
|
+ BufferedReader in = null;
|
|
|
+ try {
|
|
|
+ String urlNameString = url;
|
|
|
+ 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<String>> map = connection.getHeaderFields();
|
|
|
+ // 遍历所有的响应头字段
|
|
|
+ for (String key : map.keySet()) {
|
|
|
+ System.out.println(key + "--->" + map.get(key));
|
|
|
+ }
|
|
|
+
|
|
|
+ //ConstantUtil.UTF_CODE 编码格式
|
|
|
+ InputStreamReader reader = new InputStreamReader(connection.getInputStream());
|
|
|
+ char[] buff = new char[1024];
|
|
|
+ int length = 0;
|
|
|
+ while ((length = reader.read(buff)) != -1) {
|
|
|
+ result = new String(buff, 0, length);
|
|
|
+ jsonStr.append(result);
|
|
|
+ }
|
|
|
+ } catch (Exception e) {
|
|
|
+ System.out.println("发送GET请求出现异常!" + e);
|
|
|
+ e.printStackTrace();
|
|
|
+ }
|
|
|
+ // 使用finally块来关闭输入流
|
|
|
+ finally {
|
|
|
+ try {
|
|
|
+ if (in != null) {
|
|
|
+ in.close();
|
|
|
+ }
|
|
|
+ } catch (Exception e2) {
|
|
|
+ e2.printStackTrace();
|
|
|
+ }
|
|
|
+ }
|
|
|
+ return jsonStr.toString();
|
|
|
+ }
|
|
|
+
|
|
|
+ /**
|
|
|
+ * 向指定 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;
|
|
|
+ URLConnection conn = null;
|
|
|
+ StringBuilder jsonStr = new StringBuilder();
|
|
|
+ try {
|
|
|
+ URL realUrl = new URL(url);
|
|
|
+ // 打开和URL之间的连接
|
|
|
+ conn = realUrl.openConnection();
|
|
|
+ conn.setConnectTimeout(20000);
|
|
|
+ // 设置通用的请求属性
|
|
|
+ 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的响应
|
|
|
+
|
|
|
+ InputStreamReader reader = new InputStreamReader(conn.getInputStream());
|
|
|
+ char[] buff = new char[1024];
|
|
|
+ int length = 0;
|
|
|
+ while ((length = reader.read(buff)) != -1) {
|
|
|
+ String result = new String(buff, 0, length);
|
|
|
+ jsonStr.append(result);
|
|
|
+ }
|
|
|
+ } 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 jsonStr.toString();
|
|
|
+ }
|
|
|
+}
|