package com.ruoyi.member.controller;
|
|
import java.io.BufferedReader;
|
|
import java.io.IOException;
|
import java.io.InputStreamReader;
|
import java.net.MalformedURLException;
|
import java.net.URL;
|
import java.net.URLConnection;
|
import java.security.AlgorithmParameters;
|
import java.security.Security;
|
import java.util.Arrays;
|
import java.util.Date;
|
import java.util.HashMap;
|
import java.util.Map;
|
|
import javax.crypto.Cipher;
|
import javax.crypto.spec.IvParameterSpec;
|
import javax.crypto.spec.SecretKeySpec;
|
import javax.servlet.http.HttpServletRequest;
|
|
import com.ruoyi.common.core.domain.R;
|
import com.ruoyi.common.core.utils.sign.Base64;
|
import com.ruoyi.member.util.*;
|
import io.swagger.annotations.ApiOperation;
|
import org.springframework.stereotype.Controller;
|
import org.springframework.web.bind.annotation.RequestMapping;
|
import org.springframework.web.bind.annotation.ResponseBody;
|
|
import com.alibaba.fastjson.JSONObject;
|
|
|
import net.sf.json.JSON;
|
|
import org.bouncycastle.jce.provider.BouncyCastleProvider;
|
|
/**
|
* 微信授权方面
|
*
|
* @author tuzx
|
* @date 2018年8月9日
|
* @version 1.0
|
*/
|
@Controller
|
@RequestMapping("/weixin")
|
public class WeiXinAppController {
|
|
private static String appid = "wx0e4769839d84fde0";
|
private static String appSecret = "ede69db0303ddde49b5db95f186918ec";
|
|
@RequestMapping("/getAddress")
|
@ResponseBody
|
@ApiOperation(value = "获取微信的地址信息")
|
public R<Map<String, String>> getAddress(String url, HttpServletRequest request) {
|
Map<String,String> data=new HashMap<>();
|
String jsapiTicket = JsapiTicketUtil.getJSApiTicket();
|
Map<String, String> map = Sign.sign(jsapiTicket, url);
|
request.getSession().setAttribute("nonceStr", map.get("nonceStr"));
|
request.getSession().setAttribute("timestamp", map.get("timestamp"));
|
request.getSession().setAttribute("signature", map.get("signature"));
|
data.put("nonceStr", map.get("nonceStr"));
|
data.put("timestamp", map.get("timestamp"));
|
data.put("signature", map.get("signature"));
|
data.put("url",url);
|
data.put("jsapi_ticket", jsapiTicket);
|
return R.ok(map);
|
}
|
|
@ResponseBody
|
@RequestMapping("/getOpenId")
|
@ApiOperation(value = "获取微信的OpenId")
|
public R<Map<String, String>> getOpenId(String code) {
|
try {
|
String openID = JsapiTicketUtil.getOpenId(code);
|
Map<String,String> data=new HashMap<>();
|
data.put("openID",openID);
|
return R.ok(data);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return R.fail("获取异常");
|
}
|
|
@ResponseBody
|
@RequestMapping("getUserInfoAccessToken")
|
@ApiOperation(value = "获取微信的UserInfoAccessToken")
|
public R<String> getUserInfoAccessToken(String code) {
|
try {
|
//微信端登录code
|
String wxCode = code;
|
String requestUrl = "https://api.weixin.qq.com/sns/jscode2session";
|
Map<String,String> requestUrlParam = new HashMap<String, String>( );
|
requestUrlParam.put( "appid",appid);//小程序appId
|
requestUrlParam.put( "secret",appSecret );
|
requestUrlParam.put( "js_code",wxCode );//小程序端返回的code
|
requestUrlParam.put( "grant_type","authorization_code" );//默认参数
|
String jsonObject = HttpRequestUtil.getRequest(requestUrl,requestUrlParam );
|
return R.ok(jsonObject);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return R.fail("获取异常");
|
}
|
|
@ResponseBody
|
@RequestMapping("/getRdSession")
|
@ApiOperation(value = "获取微信的Session")
|
public R<Map<String, String>> getRdSession(String code, String rdSession, HttpServletRequest request) {
|
try {
|
Map<String, String> map = new HashMap<>();
|
if (SinataUtil.isNotEmpty(rdSession)) {
|
String str = (String) request.getSession().getAttribute(rdSession);
|
if (SinataUtil.isNotEmpty(str)) {
|
map = new HashMap<String, String>();
|
map.put("rdSession", rdSession);
|
map.put("status", "1");
|
map.put("appId", appid);
|
map.put("session_key", str);
|
} else {
|
map = new HashMap<String, String>();
|
map.put("rdSession", rdSession);
|
map.put("status", "2");// 过期
|
map.put("appId", appid);
|
map.put("session_key", str);
|
}
|
}
|
map = JsapiTicketUtil.getToken(code);
|
String openid = map.get("openid");
|
String session_key = map.get("session_key");
|
String rdSessions = new Date().getTime() + "";
|
if (SinataUtil.isNotEmpty(openid)) {
|
request.getSession().setAttribute(rdSessions, session_key + openid);
|
map = new HashMap<String, String>();
|
map.put("rdSession", rdSessions);
|
map.put("status", "1");
|
map.put("appId", appid);
|
map.put("session_key", session_key);
|
} else {
|
map = new HashMap<String, String>();
|
map.put("rdSession", rdSessions);
|
map.put("status", "3");// 获取失败
|
map.put("appId", appid);
|
map.put("session_key", session_key);
|
}
|
|
return R.ok(map);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return R.fail("获取异常");
|
}
|
|
/**
|
* 获取微信用户信息
|
*
|
* @param token
|
* @param openid
|
* @return
|
*/
|
@ResponseBody
|
@RequestMapping("/getWXinfo")
|
@ApiOperation(value = "获取微信用户信息")
|
public R<Object> getWXinfo(String token, String openid) {
|
try {
|
String str = getJSApiTicket(token, openid);
|
return R.ok(str);
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return R.fail("获取异常");
|
}
|
|
public static String getJSApiTicket(String token, String openid) {
|
// 获取token
|
// String acess_token= JsapiTicketUtil.getAccessToken();
|
|
String urlStr = "https://api.weixin.qq.com/sns/userinfo?access_token=" + token + "&openid=" + openid
|
+ "&lang=zh_CN";
|
String backData = sendGet(urlStr, "utf-8", 10000);
|
// String ticket = (String)
|
// JSONObject.fromObject(backData).get("ticket");
|
return backData;
|
|
}
|
|
|
/**
|
* 小程序使用jscode获取openid
|
* @param jscode
|
* @return
|
*//*
|
public String code2Session(String jscode){
|
String url = "https://api.weixin.qq.com/sns/jscode2session?appid=" + appid + "&secret=" + appSecret
|
+ "&js_code=" + jscode + "&grant_type=authorization_code";
|
String forObject = restTemplate.getForObject(url, String.class);
|
JSONObject jsonObject = JSON.parseObject(forObject);
|
int errcode = jsonObject.getIntValue("errcode");
|
if(errcode == 0){//成功
|
return forObject;
|
}
|
if(errcode == -1){//系统繁忙，此时请开发者稍候再试
|
return jsonObject.getString("errmsg");
|
}
|
if(errcode == 40029){//code 无效
|
return jsonObject.getString("errmsg");
|
}
|
if(errcode == 45011){//频率限制，每个用户每分钟100次
|
return jsonObject.getString("errmsg");
|
}
|
return null;
|
}*/
|
|
/***
|
* 模拟get请求
|
*
|
* @param url
|
* @param charset
|
* @param timeout
|
* @return
|
*/
|
public static String sendGet(String url, String charset, int timeout) {
|
String result = "";
|
try {
|
URL u = new URL(url);
|
try {
|
URLConnection conn = u.openConnection();
|
conn.connect();
|
conn.setConnectTimeout(timeout);
|
BufferedReader in = new BufferedReader(new InputStreamReader(conn.getInputStream(), charset));
|
String line = "";
|
while ((line = in.readLine()) != null) {
|
|
result = result + line;
|
}
|
in.close();
|
} catch (IOException e) {
|
return result;
|
}
|
} catch (MalformedURLException e) {
|
return result;
|
}
|
|
return result;
|
}
|
|
static void senMsg(String openId, String access_token, String namen, String OrderNum, String isstate) {
|
// 用户是否订阅该公众号标识 (0代表此用户没有关注该公众号 1表示关注了该公众号)
|
Integer state = WX_UserUtil.subscribeState(openId, access_token);
|
// 绑定了微信并且关注了服务号的用户 , 注册成功-推送注册短信
|
if (state == 1) {
|
Map<String, TemplateData> param = new HashMap<>();
|
param.put("first", new TemplateData(namen, "#696969"));
|
param.put("OrderSn", new TemplateData(OrderNum, "#696969"));
|
param.put("OrderStatus", new TemplateData(isstate, "#696969"));
|
// 调用发送微信消息给用户的接口
|
WX_TemplateMsgUtil.sendWechatMsgToUser(openId, "RZfKB9pj1rIjrBIjFTiTss_NJzxGU11s0k6nf9fyi6w", "", "#000000",
|
WX_TemplateMsgUtil.packJsonmsg(param), access_token);
|
}
|
|
}
|
|
public static void main(String[] args) {
|
Object phoneNumber = getPhoneNumber(
|
"vgq1QAPOVeBN3F4x5a/Gcq8SuCUiDb3S4g6AlMLnkueD3Gs0sVDygNd6JKSMgQjuYtEwFeFJH8jkR95pAUJIaedNiZSvwtwtuVBtgO0bs5n0aL3ALnTvyJ7j48x15mDi1tGQhSVamzi0qSf2lVCAsIvmoahraUdRts+HexODDr5YueIj9VELFLkyFP12ve2dO/vNwiUiNVnqwbGL4gq34Q==",
|
"0332NDK62xknkK0UAVL62oCvK622NDKr", "nB7w8ZM8obq3wY5OzMbDPg==");
|
System.out.println(phoneNumber);
|
net.sf.json.JSONObject parse = net.sf.json.JSONObject.fromObject(phoneNumber);
|
System.out.println(parse.get("phoneNumber"));
|
}
|
|
public static Object getPhoneNumber(String encryptedData, String code, String iv) {
|
Map<String, String> map = JsapiTicketUtil.getToken(code);
|
String session_key = "";
|
if (map != null) {
|
// session_key = json.getString("session_key");
|
session_key = map.get("session_key");
|
// 被加密的数据
|
byte[] dataByte = Base64.decode(encryptedData);
|
// 加密秘钥
|
byte[] keyByte = Base64.decode(session_key);
|
// 偏移量
|
byte[] ivByte = Base64.decode(iv);
|
try {
|
// 如果密钥不足16位，那么就补足. 这个if 中的内容很重要
|
int base = 16;
|
if (keyByte.length % base != 0) {
|
int groups = keyByte.length / base + (keyByte.length % base != 0 ? 1 : 0);
|
byte[] temp = new byte[groups * base];
|
Arrays.fill(temp, (byte) 0);
|
System.arraycopy(keyByte, 0, temp, 0, keyByte.length);
|
keyByte = temp;
|
}
|
// 初始化
|
Security.addProvider(new BouncyCastleProvider());
|
Cipher cipher = Cipher.getInstance("AES/CBC/PKCS5Padding");
|
SecretKeySpec spec = new SecretKeySpec(keyByte, "AES");
|
AlgorithmParameters parameters = AlgorithmParameters.getInstance("AES");
|
parameters.init(new IvParameterSpec(ivByte));
|
cipher.init(Cipher.DECRYPT_MODE, spec, parameters);// 初始化
|
byte[] resultByte = cipher.doFinal(dataByte);
|
if (null != resultByte && resultByte.length > 0) {
|
String result = new String(resultByte, "UTF-8");
|
return JSONObject.parseObject(result);
|
}
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
}
|
return null;
|
}
|
}
|
