package com.nuvole.util;
|
|
import cn.binarywang.wx.miniapp.api.WxMaService;
|
import cn.binarywang.wx.miniapp.api.impl.WxMaServiceImpl;
|
import cn.binarywang.wx.miniapp.bean.WxMaTemplateData;
|
import cn.binarywang.wx.miniapp.bean.WxMaTemplateMessage;
|
import cn.binarywang.wx.miniapp.config.WxMaInMemoryConfig;
|
import cn.hutool.http.HttpUtil;
|
import cn.hutool.json.JSONUtil;
|
import com.alibaba.fastjson.JSONObject;
|
import com.nuvole.common.domain.dto.AppDTO;
|
import com.nuvole.common.domain.wx.PushMsg;
|
import lombok.extern.slf4j.Slf4j;
|
import me.chanjar.weixin.common.error.WxErrorException;
|
import org.springframework.beans.BeanUtils;
|
import org.springframework.http.HttpEntity;
|
import org.springframework.http.HttpMethod;
|
import org.springframework.http.MediaType;
|
import org.springframework.http.ResponseEntity;
|
import org.springframework.util.LinkedMultiValueMap;
|
import org.springframework.util.MultiValueMap;
|
import org.springframework.web.client.RestTemplate;
|
import org.springframework.web.util.HtmlUtils;
|
|
import java.util.*;
|
|
/**
|
* 小程序工具类
|
*
|
* @author liujun
|
* @Date 2019/5/27 16:40
|
*/
|
@Slf4j
|
public class WxUtil {
|
|
/**
|
* 获取临时登录凭证code
|
*
|
* @param appid AppID(小程序ID)
|
* @param secret AppSecret(小程序密钥)
|
* @param jsCode 登录时获取的Code
|
* @return
|
*/
|
public static String getOpenidSessionKey(String appid, String secret, String jsCode) {
|
String url = "https://api.weixin.qq.com/sns/jscode2session";
|
Map<String, Object> paramMap = new HashMap<>(3);
|
paramMap.put("appid", appid);
|
paramMap.put("secret", secret);
|
paramMap.put("js_code", jsCode);
|
paramMap.put("grant_type", "authorization_code");
|
return HttpUtil.get(url, paramMap);
|
}
|
|
/**
|
* 获取AccessToken
|
*
|
* @param appid AppID(小程序ID)
|
* @param secret AppSecret(小程序密钥)
|
* @return
|
*/
|
public static String getAccessToken(String appid, String secret) {
|
String url = "https://api.weixin.qq.com/cgi-bin/token";
|
Map<String, Object> paramMap = new HashMap<>(3);
|
paramMap.put("appid", appid);
|
paramMap.put("secret", secret);
|
paramMap.put("grant_type", "client_credential");
|
String s = HttpUtil.get(url, paramMap);
|
log.info("获取AccessToken 参数= 》appid:{},secret:{}", appid, secret);
|
log.info("获取AccessToken = 》{}", s);
|
return s;
|
}
|
|
/**
|
* 获取AccessToken
|
*
|
* @param accessToken getAccessToken方法获取的access_token
|
* @return
|
*/
|
public static String getJsapTicket(String accessToken) {
|
String url = "https://api.weixin.qq.com/cgi-bin/ticket/getticket";
|
Map<String, Object> paramMap = new HashMap<>(3);
|
paramMap.put("type", "jsapi");
|
paramMap.put("access_token", accessToken);
|
return HttpUtil.get(url, paramMap);
|
}
|
|
/**
|
* Createed by PKZ Date 2019/6/18 17:11 Description：微信公众号获取access_token
|
**/
|
public static String getWechatAccessToken(String appid, String secret, String code) {
|
String url = "https://api.weixin.qq.com/sns/oauth2/access_token";
|
Map<String, Object> paramMap = new HashMap<>(3);
|
paramMap.put("appid", appid);
|
paramMap.put("secret", secret);
|
paramMap.put("code", code);
|
paramMap.put("grant_type", "authorization_code");
|
return HttpUtil.get(url, paramMap);
|
}
|
|
/**
|
* Createed by PKZ Date 2019/6/18 17:13 Description：微信公众号获取用户信息
|
**/
|
public static String getWechatUserInfo(String access_token, String openid) {
|
String url = "https://api.weixin.qq.com/sns/userinfo";
|
Map<String, Object> paramMap = new HashMap<>(3);
|
paramMap.put("access_token", access_token);
|
paramMap.put("openid", openid);
|
paramMap.put("lang", "zh_CN");
|
return HttpUtil.get(url, paramMap);
|
}
|
|
/**
|
* 该接口用于将 code 换取用户手机号
|
*
|
* @param access_token
|
* @param code
|
* @return
|
*/
|
public static String getUserPhoneNumber(String access_token, String code) {
|
String url = "https://api.weixin.qq.com/wxa/business/getuserphonenumber?access_token=" + access_token;
|
Map<String, Object> paramMap = new HashMap<>(1);
|
paramMap.put("code", code);
|
String result = HttpUtil.post(url, JSONUtil.toJsonStr(paramMap));
|
log.info("getUserPhoneNumber=>{}", result);
|
JSONObject resultInfo = JSONObject.parseObject(result);
|
if (resultInfo.getIntValue("errcode") == 0) {
|
return resultInfo.getJSONObject("phone_info").getString("purePhoneNumber");
|
}
|
return null;
|
}
|
|
/**
|
* 获取 URL Link
|
*
|
* @param access_token
|
* @return
|
*/
|
public static String generateUrllink(String access_token) {
|
String url = "https://api.weixin.qq.com/wxa/generate_urllink?access_token=" + access_token;
|
Map<String, Object> paramMap = new HashMap<>(1);
|
String result = HttpUtil.post(url, JSONUtil.toJsonStr(paramMap));
|
log.info("generateUrllink=>{}", result);
|
JSONObject resultInfo = JSONObject.parseObject(result);
|
if (resultInfo.getIntValue("errcode") == 0) {
|
return resultInfo.getString("url_link");
|
}
|
return null;
|
}
|
|
|
/*
|
* @Author : liu.q [916000612@qq.com]
|
*
|
* @Date : 2019-06-27 09:49
|
*
|
* @Description :获取小程序码（前提是已发布）
|
*
|
* @secne 参数
|
*
|
* @width 码宽
|
*
|
* @page 码跳转路径
|
*/
|
public static byte[] getQRcode(String access_token, String scene, int width, String page) {
|
RestTemplate rest = new RestTemplate();
|
byte[] result = null;
|
try {
|
String url = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=" + access_token;
|
Map<String, Object> param = new HashMap<>();
|
param.put("scene", scene);
|
// param.put("access_token", access_token); //access_token接在url后
|
param.put("page", page);
|
param.put("width", width);
|
param.put("auto_color", true);
|
Map<String, Object> line_color = new HashMap<>();
|
line_color.put("r", 54);
|
line_color.put("g", 56);
|
line_color.put("b", 115);
|
param.put("line_color", line_color);
|
MultiValueMap<String, String> headers = new LinkedMultiValueMap<>();
|
AppDTO sto = new AppDTO();
|
AppDTO s = new AppDTO();
|
sto.setMap(param);
|
sto.setPro(url);
|
BeanUtils.copyProperties(sto, s);
|
// String result22 = HttpUtil.post(url, JSONUtil.toJsonStr(param));
|
// log.info("getUserPhoneNumber=>{}",result22);
|
HttpEntity requestEntity = new HttpEntity(s.getMap(), headers);
|
ResponseEntity<byte[]> entity = rest.exchange(s.getPro(), HttpMethod.POST, requestEntity, byte[].class,
|
new Object[0]);
|
result = entity.getBody();
|
if (entity.getHeaders().getContentType().isCompatibleWith(MediaType.APPLICATION_JSON)) {
|
log.error(new String(result));
|
return null;
|
}
|
System.out.println(entity.toString());
|
|
String imageStr = Base64.getEncoder().encodeToString(result);
|
imageStr = HtmlUtils.htmlEscape(imageStr);
|
result = Base64.getDecoder().decode(imageStr);
|
} catch (Exception e) {
|
e.printStackTrace();
|
log.error("调用小程序生成微信永久小程序码URL接口异常", e);
|
}
|
return result;
|
}
|
|
/**
|
* 推送消息
|
*
|
* @param appId
|
* @param secret
|
* @param openId
|
* @param formId
|
* @param templateId
|
* @param page
|
* @param items
|
*/
|
public static void push(String appId, String secret, String openId, String formId, String templateId, String page,
|
List<String> items) {
|
// 1,配置小程序信息
|
WxMaInMemoryConfig wxConfig = new WxMaInMemoryConfig();
|
// 小程序appid
|
wxConfig.setAppid(appId);
|
// 小程序AppSecret
|
wxConfig.setSecret(secret);
|
WxMaService wxMaService = new WxMaServiceImpl();
|
wxMaService.setWxMaConfig(wxConfig);
|
// 2,设置模版信息（keyword1：类型，keyword2：内容）
|
List<WxMaTemplateData> templateDataList = new ArrayList<>(items.size());
|
for (int i = 0; i < items.size(); i++) {
|
WxMaTemplateData data = new WxMaTemplateData("keyword" + (i + 1), items.get(i));
|
templateDataList.add(data);
|
}
|
// 3，设置推送消息
|
WxMaTemplateMessage templateMessage = WxMaTemplateMessage.builder().toUser(openId).formId(formId)
|
.templateId(templateId).data(templateDataList).page(page).build();
|
// 4，发起推送
|
try {
|
wxMaService.getMsgService().sendTemplateMsg(templateMessage);
|
} catch (WxErrorException e) {
|
log.info("任务失败：" + e.getMessage());
|
}
|
}
|
|
/* *
|
* 小程序-订阅消息-推送消息
|
*
|
* @author lc
|
* @date 2019/12/30 9:52
|
*/
|
public static String pushSend(PushMsg pushMsg, String accessToken) {
|
String url = "https://api.weixin.qq.com/cgi-bin/message/subscribe/send?access_token=" + accessToken;
|
try {
|
System.out.println("is :" + JSONUtil.toJsonStr(pushMsg));
|
String result = HttpUtil.post(url, JSONUtil.toJsonStr(pushMsg));
|
log.info("is push result:" + result);
|
return result;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
/* *
|
* 公众号-模板消息
|
*
|
*/
|
public static String h5PubpushSend(PushMsg pushMsg, String accessToken) {
|
String url = "https://api.weixin.qq.com/cgi-bin/message/template/send?access_token=" + accessToken;
|
try {
|
System.out.println("is :" + JSONUtil.toJsonStr(pushMsg));
|
String result = HttpUtil.post(url, JSONUtil.toJsonStr(pushMsg));
|
log.info("is push result:" + result);
|
return result;
|
} catch (Exception e) {
|
e.printStackTrace();
|
}
|
return null;
|
}
|
|
|
|
}
|
