~chenjiahe/hx_parent.git

fwq

2024-09-29 225ca62d67cb6ac70eca7546f0e2f1eb61aa90c4

提交 \| 用户 \| age
826b66	1	package com.hx.mp.util;
C	2
	3	import com.hx.util.HttpMethodUtil;
	4	import com.hx.util.StringUtils;
	5	import net.sf.json.JSONException;
	6	import net.sf.json.JSONObject;
	7	import org.apache.commons.codec.binary.Base64;
	8	import org.apache.commons.io.IOUtils;
	9
	10	import java.io.ByteArrayOutputStream;
	11	import java.io.InputStream;
	12	import java.io.OutputStream;
	13	import java.net.HttpURLConnection;
	14	import java.net.URL;
	15	import java.sql.Timestamp;
	16	import java.text.MessageFormat;
	17	import java.util.Date;
	18	import java.util.HashMap;
	19	import java.util.Map;
	20
	21	/**
	22	* 微信小程序工具类
	23	*/
	24	public class MpUtil {
	25
	26	/** 请求access_token */
	27	public static final String URL_ACCESS_TOKEN = "https://api.weixin.qq.com/cgi-bin/token?grant_type=client_credential&appid={0}&secret={1}";
	28	/** 请求服务器IP地址 */
	29	public static final String URL_SERVER_ADDR = "https://api.weixin.qq.com/cgi-bin/getcallbackip?access_token=";
	30	/** 微信js的code换去sessionKey */
	31	public static final String JSCODE2SESSION_URL = "https://api.weixin.qq.com/sns/jscode2session?appid={0}&secret={1}&grant_type=authorization_code&js_code=";
	32	/ 请求小程序码 /
	33	public static final String URL_WXACODE = "https://api.weixin.qq.com/wxa/getwxacode?access_token=";
	34	/ 请求小程序码-无数量限制 /
	35	public static final String URL_WXACODEUNLIMIT = "https://api.weixin.qq.com/wxa/getwxacodeunlimit?access_token=";
	36	/** 请求小程序二维码 */
	37	public static final String URL_QRCODE = "https://api.weixin.qq.com/cgi-bin/wxaapp/createwxaqrcode?access_token=";
	38	/** 发模版消息 */
	39	public static final String URL_SEND_TEMP_MSG = "https://api.weixin.qq.com/cgi-bin/message/wxopen/template/send?access_token=";
	40	/** 设置发票授权字段 */
	41	public static final String URL_SET_TICKET_FIELD = "https://api.weixin.qq.com/card/invoice/setbizattr?action=set_auth_field&access_token=";
	42	/** 获取发票ticket */
	43	public static final String URL_GET_TICKET_TICKET = "https://api.weixin.qq.com/cgi-bin/ticket/getticket?type=wx_card&access_token=";
	44	/** 获取发票授权页链接 */
	45	public static final String URL_GET_TICKET_AUTH_LINK = "https://api.weixin.qq.com/card/invoice/getauthurl?access_token=";
	46	/** 查询发票授权字段 */
	47	public static final String URL_GET_AUTH_FIELD = "https://api.weixin.qq.com/card/invoice/getauthdata?access_token=";
	48	/** 设置支付后开发票 */
	49	public static final String URL_SET_PAY_INVOICE = "https://api.weixin.qq.com/card/invoice/setbizattr?action=set_pay_mch&access_token=";
	50	/** 查询支付后开发票 */
	51	public static final String URL_GET_PAY_INVOICE = "https://api.weixin.qq.com/card/invoice/setbizattr?action=get_pay_mch&access_token=";
	52	/** 发送客服消息 */
	53	public static final String URL_SEND_KF_MSG = "https://api.weixin.qq.com/cgi-bin/message/custom/send?access_token=";
	54
	55	/*************************************************
	56	* 小程序
	57	*************************/
	58	/** 利用code换取sessionKey */
	59	public static JSONObject jsCode2session(String code, String appId, String appSecret) {
	60	JSONObject obj = new JSONObject();
	61	String url = StringUtils.format(JSCODE2SESSION_URL, appId, appSecret) + code;
	62	obj = HttpURLUtil(url, null);
	63	return obj;
	64	}
	65
	66	/** 获取小程序二维码图片 */
	67	public static String getQrCode(String accessToken, String jsonParam)
	68	throws Exception {
	69	JSONObject obj = HttpURLUtilJson(URL_QRCODE + accessToken, jsonParam);
	70	String qrStr = obj.optString("data");
	71	return qrStr;
	72	}
	73
	74	/ 从weixin接口获取Access_token /
	75	public static JSONObject getApplication_Access_tokenForUrl(String appId, String appSecret)
	76	throws Exception {
	77	String url = MessageFormat.format(URL_ACCESS_TOKEN, appId, appSecret);
	78	JSONObject obj = HttpURLUtil(url, null);
	79	return obj;
	80	}
	81
	82	/ 请求http协议获取信息工具 /
	83	public static InputStream HttpURLUtilStream(String url, String data) {
	84	HttpURLConnection con = null;
	85	URL u = null;
	86	try {
	87	u = new URL(url);
	88	con = (HttpURLConnection) u.openConnection();
	89	con.setRequestMethod("POST");
	90	con.setDoOutput(true);
	91	con.setDoInput(true);
	92	con.setUseCaches(false);
	93	con.setReadTimeout(200000);
	94	con.setRequestProperty("Charset", "UTF-8");
	95	con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
	96
	97	if (data != null) {
	98	OutputStream os = con.getOutputStream();
	99	os.write(data.getBytes("utf-8"));
	100	}
	101
	102	if (con.getResponseCode() != 200)
	103	throw new RuntimeException("请求url失败");
	104
	105	return con.getInputStream();
	106	} catch (Exception e) {
	107	e.printStackTrace();
	108	} finally {
	109	if (con != null) {
	110	con.disconnect();
	111	}
	112	}
	113	return null;
	114	}
	115
	116	/ 获取二维码图片 /
	117	public static JSONObject HttpURLUtilJson(String urlx, String objx) {
	118	JSONObject jo = new JSONObject();
	119	try {
	120	// 创建url资源
	121	URL url = new URL(urlx);
	122	// 建立http连接
	123	HttpURLConnection conn = (HttpURLConnection) url.openConnection();
	124	// 设置允许输出
	125	conn.setDoOutput(true);
	126
	127	conn.setDoInput(true);
	128
	129	// 设置不用缓存
	130	conn.setUseCaches(false);
	131	// 设置传递方式
	132	conn.setRequestMethod("POST");
	133	// 设置维持长连接
	134	conn.setRequestProperty("Connection", "Keep-Alive");
	135	// 设置文件字符集:
	136	conn.setRequestProperty("Charset", "UTF-8");
	137	// 设置文件类型:
	138	conn.setRequestProperty("contentType", "application/json");
	139	// 开始连接请求
	140	conn.connect();
	141	OutputStream out = conn.getOutputStream();
	142	// 写入请求的字符串
	143	out.write(objx.getBytes());
	144	out.flush();
	145	out.close();
	146
	147	// 请求返回的状态
	148	if (conn.getResponseCode() == 200) {
	149	// 请求返回的数据
	150	InputStream in = conn.getInputStream();
	151	try {
	152	ByteArrayOutputStream swapStream = new ByteArrayOutputStream();
	153	byte[] temp = new byte[1024];
	154	int rc = 0;
	155	while ((rc = in.read(temp, 0, 100)) > 0) {
	156	swapStream.write(temp, 0, rc);
	157	}
	158	byte[] buffer = swapStream.toByteArray();
	159	String base64 = Base64.encodeBase64String(buffer);
	160	jo.put("data", base64);
	161	} catch (Exception e1) {
	162	e1.printStackTrace();
	163	}
	164	} else {
	165	// System.out.println("no++");
	166	}
	167
	168	} catch (Exception e) {
	169	e.printStackTrace();
	170	}
	171	return jo;
	172	}
	173
	174	/ 请求http协议获取信息工具 /
	175	public static JSONObject HttpURLUtil(String url, String data) {
	176	HttpURLConnection con = null;
	177	URL u = null;
	178	String wxMsgXml = null;
	179	JSONObject obj = null;
	180	try {
	181	u = new URL(url);
	182	con = (HttpURLConnection) u.openConnection();
	183	con.setRequestMethod("POST");
	184	con.setDoOutput(true);
	185	con.setDoInput(true);
	186	con.setUseCaches(false);
	187	con.setReadTimeout(5000);
	188	con.setRequestProperty("Charset", "UTF-8");
	189	con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded");
	190
	191	if (data != null) {
	192	OutputStream os = con.getOutputStream();
	193	os.write(data.getBytes("utf-8"));
	194	}
	195
	196	if (con.getResponseCode() != 200)
	197	throw new RuntimeException("请求url失败");
	198	// 读取返回内容
	199	wxMsgXml = IOUtils.toString(con.getInputStream(), "utf-8");
	200	obj = JSONObject.fromObject(wxMsgXml);
	201	// //System.out.println("HttpURLUtil:"+wxMsgXml);
	202	} catch (Exception e) {
	203	e.printStackTrace();
	204	obj = new JSONObject();
	205	try {
	206	obj.put("status", 1);
	207	obj.put("errMsg", e.getMessage());
	208	} catch (JSONException e1) {
	209	e1.printStackTrace();
	210	}
	211	} finally {
	212	if (con != null) {
	213	con.disconnect();
	214	}
	215	}
	216	return obj;
	217	}
	218
	219	/ 发送模版消息 /
	220	public static JSONObject sendTempMsg(String accessToken, String jsonStr) {
	221	JSONObject obj = HttpURLUtil(URL_SEND_TEMP_MSG + accessToken, jsonStr);
	222	return obj;
	223	}
	224
	225	public static Integer DateToTimestamp(Date time) {
	226	Timestamp ts = new Timestamp(time.getTime());
	227	return (int) ((ts.getTime()) / 1000);
	228	}
	229
	230	/**
	231	* 发送链接客服消息
	232	*
	233	* @throws JSONException
	234	*/
	235	public static String sendKfLinkMsg(String at, String openId, String title, String description, String url,
	236	String imgUrl) throws JSONException {
	237	String result = "fail";
	238
	239	JSONObject obj = new JSONObject();
	240	obj.put("touser", openId);
	241	obj.put("msgtype", "link");
	242
	243	JSONObject pObj = new JSONObject();
	244	pObj.put("title", title);
	245	pObj.put("description", description);
	246	pObj.put("url", url);
	247	pObj.put("thumb_url", imgUrl);
	248	obj.put("link", pObj);
	249
	250	JSONObject rObj = HttpURLUtil(URL_SEND_KF_MSG + at, obj.toString());
	251	// System.out.println("rObj==="+rObj);
	252	if (rObj != null) {
	253	if (rObj.optInt("errcode", -1) == 0) {
	254	result = "suc";
	255	} else {
	256	result = rObj.optString("errmsg");
	257	}
	258	}
	259	rObj = null;
	260	obj = null;
	261
	262	return result;
	263	}
	264
	265	/**
	266	* 发送图片客户消息
	267	*
	268	* @param access_token
	269	* access_token
	270	* @param toUser
	271	* 用户openid
	272	* @param media_id
	273	* 素材id
	274	* @return
	275	*/
	276	public static String sendKfImageMsg(String access_token, String toUser, String media_id) {
	277	String result = "fail";
	278
	279	try {
	280	JSONObject obj = new JSONObject();
	281	obj.put("touser", toUser);
	282	obj.put("msgtype", "image");
	283
	284	JSONObject pObj = new JSONObject();
	285	pObj.put("media_id", media_id);
	286	obj.put("image", pObj);
	287
	288	JSONObject rObj = HttpURLUtil(URL_SEND_KF_MSG + access_token, obj.toString());
	289	System.out.println("rObj==" + rObj.toString());
	290	if (rObj != null) {
	291	if (rObj.optInt("errcode", -1) == 0) {
	292	result = "suc";
	293	} else {
	294	result = rObj.optString("errmsg");
	295	}
	296	}
	297	rObj = null;
	298	obj = null;
	299	} catch (Exception e) {
	300	e.printStackTrace();
	301	}
	302
	303	return result;
	304	}
	305
	306	/**
	307	* 发送文本客户消息
	308	*
	309	* @param access_token
	310	* access_token
	311	* @param toUser
	312	* 用户openid
	313	* @return
	314	*/
	315	public static String sendKfTextMsg(String access_token, String toUser, String content) {
	316	String result = "fail";
	317
	318	try {
	319	JSONObject obj = new JSONObject();
	320	obj.put("touser", toUser);
	321	obj.put("msgtype", "text");
	322
	323	JSONObject pObj = new JSONObject();
	324	pObj.put("content", content);
	325	obj.put("text", pObj);
	326
	327	JSONObject rObj = HttpURLUtil(URL_SEND_KF_MSG + access_token, obj.toString());
	328	if (rObj != null) {
	329	if (rObj.optInt("errcode", -1) == 0) {
	330	result = "suc";
	331	} else {
	332	result = rObj.optString("errmsg");
	333	}
	334	}
	335	rObj = null;
	336	obj = null;
	337	} catch (Exception e) {
	338	e.printStackTrace();
	339	}
	340
	341	return result;
	342	}
	343
	344	/** 获取小程序码图片 */
	345	public static String getWXACode(String accessToken, String jsonParam, String path)
	346	throws Exception {
	347	JSONObject obj = HttpURLUtilJson(URL_WXACODE + accessToken, jsonParam);
	348	String qrStr = obj.optString("data");
	349	return qrStr;
	350	}
	351
	352	/** 获取小程序码图片 */
	353	public static String getWXACodeUnlimit(String accessToken, String jsonParam, String path)
	354	throws Exception {
	355	JSONObject obj = HttpURLUtilJson(URL_WXACODEUNLIMIT + accessToken, jsonParam);
	356	String qrStr = obj.optString("data");
	357	return qrStr;
	358	}
	359
	360	/**
	361	* 获取小程序链接
	362	* @param token 小程序token
	363	* @param path 小程序页面路径
	364	* @param query 传值参数
	365	* @param env_version
	366	* @return 要打开的小程序版本。正式版为 "release"，体验版为"trial"，开发版为"develop"，仅在微信外打开时生效
	367	*/
	368	public static String getAooLetUrl(String token, String path, String query, String env_version) {
	369	Map<String, Object> map = new HashMap<>();
	370	map.put("access_token", token);
	371	JSONObject data = new JSONObject();
	372	data.put("path", path);
	373	data.put("query", query);
	374	data.put("env_version", env_version);
	375	return HttpMethodUtil.HttpURLUtilJson("https://api.weixin.qq.com/wxa/generate_urllink", data.toString(), map, null, "POST");
	376	}
	377
	378
	379	/**
	380	* 公众号发送小程序卡片客户消息
	381	* @param access_token access_token
	382	* @param toUser 用户openid
	383	* @param title 标题
	384	* @param appid 小程序appid
	385	* @param pagepath 跳转页面路径
	386	* @param thumb_media_id 缩略图/小程序卡片图片的媒体ID，小程序卡片图片建议大小为520*416
	387	* @return
	388	*/
	389	public static String sendMpMsg(String access_token, String toUser, String title,String appid,String pagepath,String thumb_media_id) {
	390	String result = "fail";
	391
	392	try {
	393	JSONObject obj = new JSONObject();
	394	obj.put("touser", toUser);
	395	obj.put("msgtype", "miniprogrampage");
	396
	397	JSONObject pObj = new JSONObject();
	398	pObj.put("title", title);
	399	pObj.put("appid", appid);
	400	pObj.put("pagepath", pagepath);
	401	pObj.put("thumb_media_id", thumb_media_id);
	402	obj.put("miniprogrampage", pObj);
	403
	404	JSONObject rObj = HttpURLUtil(URL_SEND_KF_MSG + access_token, obj.toString());
	405	if (rObj != null) {
	406	if (rObj.optInt("errcode", -1) == 0) {
	407	result = "suc";
	408	} else {
	409	result = rObj.optString("errmsg");
	410	}
	411	}
	412	rObj = null;
	413	obj = null;
	414	} catch (Exception e) {
	415	e.printStackTrace();
	416	}
	417
	418	return result;
	419	}
	420	}