package com.xzx.gc.common.utils.wxpay;
|
|
import cn.hutool.core.io.FileUtil;
|
import cn.hutool.core.text.StrFormatter;
|
import cn.hutool.core.thread.ThreadUtil;
|
import cn.hutool.core.util.StrUtil;
|
import cn.hutool.http.HttpRequest;
|
import cn.hutool.http.HttpUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import com.xzx.gc.common.Result;
|
import com.xzx.gc.common.constant.Constants;
|
import com.xzx.gc.common.utils.BusinessUtil;
|
import com.xzx.gc.common.utils.RedisUtil;
|
import com.xzx.gc.common.utils.StringUtils;
|
import com.xzx.gc.model.user.UserInfoVo;
|
import lombok.extern.slf4j.Slf4j;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.stereotype.Component;
|
|
import java.io.BufferedReader;
|
import java.io.File;
|
import java.io.InputStream;
|
import java.io.InputStreamReader;
|
import java.net.URL;
|
import java.net.URLConnection;
|
|
@Component
|
@Slf4j
|
public class WxUtil {
|
|
|
|
@Autowired
|
private RedisUtil redisUtil;
|
|
@Autowired
|
private BusinessUtil businessUtil;
|
|
/**
|
* 获取微信token
|
* @return
|
*/
|
public String getAccessToken(){
|
//获取微信accessToken
|
String wxToken = redisUtil.get(Constants.REDIS_USER_KEY+Constants.WX_TOKEN);
|
if(StringUtils.isBlank(wxToken)){
|
String url=StrFormatter.format("https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={}&secret={}",Constants.WX_APPID,Constants.WX_SECRET);
|
String s = HttpUtil.get(url);
|
cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(s);
|
log.debug("生成微信TOKEN返回数据:{}",JSONUtil.toJsonPrettyStr(jsonObject));
|
String access_token = jsonObject.getStr("access_token");
|
String expires_in = jsonObject.getStr("expires_in");
|
if(StrUtil.isNotBlank(expires_in)) {
|
redisUtil.setex(Constants.REDIS_USER_KEY + Constants.WX_TOKEN, access_token, Integer.parseInt(expires_in) - 100);
|
}
|
wxToken=access_token;
|
}
|
return wxToken;
|
}
|
|
|
/**
|
* 获取微信token
|
* @return
|
*/
|
public String getAppOpenId(String code){
|
String url=StrFormatter.format("https://api.weixin.qq.com/sns/oauth2/access_token?appid={}&secret={}&code={}&grant_type=authorization_code",Constants.WX_APP_APPID,Constants.WX_APP_SECRET,code);
|
String s = HttpUtil.get(url);
|
cn.hutool.json.JSONObject jsonObject = JSONUtil.parseObj(s);
|
log.info("获取微信APP登录openid返回：{}",jsonObject);
|
String openid = jsonObject.getStr("openid");
|
return openid;
|
}
|
|
public String generateAcode(String scene,String path,String imgName,String width){
|
return generateAcode(scene, path, imgName, width, null);
|
}
|
|
/**
|
* 生成小程序码
|
* @param scene 参数
|
* @param path 跳转路径
|
* @param imgName 图片唯一名称
|
* @return
|
*/
|
public String generateAcode(String scene,String path,String imgName,String width, Integer type){
|
String urlPrefix=businessUtil.getViewUrl();
|
String imgPath=Constants.IMG_UPLOAD_PATH+imgName;
|
if(!FileUtil.exist(imgPath)){
|
|
cn.hutool.json.JSONObject obj = JSONUtil.createObj();
|
//调用二维码接口
|
String url = null;
|
if (type == null) {
|
// 该接口无数量限制，但是 scene 传参最大字符长度为32个字符
|
url = StrFormatter.format("https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token={}", getAccessToken());
|
obj.put("scene", scene);
|
obj.put("path", path);
|
} else {
|
// 该接口存在数量限制, 总共可生成10w个, 但参数是接在path后面
|
url = StrFormatter.format("https://api.weixin.qq.com/wxa/getwxacode?access_token={}", getAccessToken());
|
obj.put("path", path + "?" + scene );
|
}
|
|
//最小 280px，最大 1280px
|
obj.put("width", width);
|
obj.put("auto_color", false);
|
cn.hutool.json.JSONObject obj2 = JSONUtil.createObj();
|
obj2.put("r", 0);
|
obj2.put("g", 0);
|
obj2.put("b", 0);
|
obj.put("line_color", obj2);
|
//是否需要透明底色，为 true 时，生成透明底色的小程序码
|
obj.put("is_hyaline", false);
|
try {
|
InputStream inputStream = HttpRequest.post(url).body(obj.toString(), "application/json").execute().bodyStream();
|
File file = new File(imgPath);
|
FileUtil.writeFromStream(inputStream, file);
|
long uploadUrl = FileUtil.size(file);
|
//小于10kb重新生成
|
if(uploadUrl<=Constants.MIN_FILE_SIZE){
|
log.error("生成微信小程序码失败:图片大小异常：{}",uploadUrl);
|
return null;
|
}
|
} catch (Exception e) {
|
log.error("生成微信小程序码失败",e);
|
return null;
|
}
|
|
}else {
|
//判断文件是否正常 不正常 删除
|
File file = new File(imgPath);
|
long uploadUrl = FileUtil.size(file);
|
if(uploadUrl<=Constants.MIN_FILE_SIZE){
|
FileUtil.del(file);
|
return null;
|
}
|
}
|
log.debug("生成微信小程序码成功，路径：" + imgPath);
|
return urlPrefix+"/"+imgName;
|
}
|
|
|
|
|
public Result<UserInfoVo> getOpenId(String code){
|
String appid =Constants.WX_APPID;
|
String secret = Constants.WX_SECRET;
|
|
UserInfoVo userInfoVo = new UserInfoVo();
|
Result result = new Result();
|
|
BufferedReader in = null;
|
//appid和secret是开发者分别是小程序ID和小程序密钥，开发者通过微信公众平台-》设置-》开发设置就可以直接获取，
|
String url="https://api.weixin.qq.com/sns/jscode2session?appid="
|
+appid+"&secret="+secret+"&js_code="+code+"&grant_type=authorization_code";
|
JSONObject jsonObject=null;
|
try {
|
URL weChatUrl = new URL(url);
|
// 打开和URL之间的连接
|
URLConnection connection = weChatUrl.openConnection();
|
// 设置通用的请求属性
|
connection.setConnectTimeout(5000);
|
connection.setReadTimeout(5000);
|
// 建立实际的连接
|
connection.connect();
|
|
// 定义 BufferedReader输入流来读取URL的响应
|
in = new BufferedReader(new InputStreamReader(connection.getInputStream()));
|
StringBuffer sb = new StringBuffer();
|
String line;
|
while ((line = in.readLine()) != null) {
|
sb.append(line);
|
}
|
jsonObject = JSONObject.parseObject(sb.toString());
|
String openId = (String)jsonObject.get("openid");
|
String session_key = (String)jsonObject.get("session_key");
|
if(StringUtils.isBlank(openId)){
|
result.setCode(-1);
|
result.setMsg("获取用户OPENID失败");
|
return result;
|
}
|
userInfoVo.setOpenId(openId);
|
userInfoVo.setSessionKey(session_key);
|
result.setData(userInfoVo);
|
return result;
|
} catch (Exception e) {
|
result.setCode(-1);
|
result.setMsg("获取用户OPENID失败");
|
return result;
|
}
|
//使用finally块来关闭输入流
|
finally {
|
try {
|
if (in != null) {
|
in.close();
|
}
|
} catch (Exception e2) {
|
e2.printStackTrace();
|
}
|
}
|
}
|
|
|
}
|
