package com.xzx.gc.common.utils.payutil;
|
|
import org.apache.http.HttpEntity;
|
import org.apache.http.client.methods.CloseableHttpResponse;
|
import org.apache.http.client.methods.HttpPost;
|
import org.apache.http.conn.ssl.SSLConnectionSocketFactory;
|
import org.apache.http.entity.StringEntity;
|
import org.apache.http.impl.client.CloseableHttpClient;
|
import org.apache.http.impl.client.HttpClients;
|
import org.apache.http.ssl.SSLContexts;
|
import org.apache.http.util.EntityUtils;
|
import org.jdom2.Document;
|
import org.jdom2.Element;
|
import org.jdom2.input.SAXBuilder;
|
import org.springframework.stereotype.Component;
|
import org.springframework.transaction.annotation.Transactional;
|
|
import javax.net.ssl.SSLContext;
|
import java.io.*;
|
import java.security.KeyStore;
|
import java.util.HashMap;
|
import java.util.Iterator;
|
import java.util.List;
|
import java.util.Map;
|
|
@Component
|
public class WxUtilAdmin {
|
|
//@Value("#{ssl.certificate}")
|
String sslCertificate;
|
|
|
/**
|
* 微信小程序现金红包支付
|
* @param param
|
* @return
|
* @throws Exception
|
*/
|
@Transactional
|
public Map<String, String> sendWxXcxPay(String url, String param) throws Exception {
|
return reqPost(url, param);
|
}
|
|
Map<String, String> reqPost(String url,String xmlParam) throws Exception{
|
KeyStore keyStore = KeyStore.getInstance("PKCS12");
|
//读取商户证书（我下载下来的证书保存到D盘，根据自己实际情况填写）
|
try(FileInputStream instream = new FileInputStream(new File(sslCertificate+"apiclient_cert.p12"))) {
|
keyStore.load(instream, "1546567611".toCharArray());
|
}
|
|
// Trust own CA and all self-signed certs
|
SSLContext sslcontext = SSLContexts.custom()
|
.loadKeyMaterial(keyStore, "1546567611".toCharArray())
|
.build();
|
// Allow TLSv1 protocol only
|
SSLConnectionSocketFactory sslsf = new SSLConnectionSocketFactory(
|
sslcontext,
|
new String[] { "TLSv1" },
|
null,
|
SSLConnectionSocketFactory.BROWSER_COMPATIBLE_HOSTNAME_VERIFIER);
|
CloseableHttpClient httpclient = HttpClients.custom()
|
.setSSLSocketFactory(sslsf)
|
.build();
|
HttpPost httpPost = new HttpPost(url);
|
|
httpPost.setEntity(new StringEntity(xmlParam));
|
try(CloseableHttpResponse response1 = httpclient.execute(httpPost) ) {
|
int status = response1.getStatusLine().getStatusCode();
|
if(status>=200&&status<400){
|
System.out.println(response1.getStatusLine());
|
HttpEntity entity1 = response1.getEntity();
|
String jsonStr = EntityUtils.toString(entity1, "UTF-8");
|
Map<String, Object> dataMap = new HashMap<String, Object>();
|
System.out.println("返回数据："+jsonStr);
|
/*if(jsonStr.indexOf("FAIL")!=-1){
|
return prepay_id;
|
}*/
|
// jsonStr=new String(jsonStr.getBytes("UTF-8"), "GBK");
|
Map map = doXMLParse(jsonStr);
|
return map;
|
}
|
return null;
|
}
|
}
|
|
|
/**
|
* 解析xml,返回第一级元素键值对。如果第一级元素有子节点，则此节点的值是子节点的xml数据。
|
* @param strxml
|
* @return
|
* @throws Exception
|
* @throws IOException
|
*/
|
static Map doXMLParse(String strxml) throws Exception {
|
if(null == strxml || "".equals(strxml)) {
|
return null;
|
}
|
|
Map m = new HashMap();
|
InputStream in = new ByteArrayInputStream(strxml.getBytes());
|
SAXBuilder builder = new SAXBuilder();
|
Document doc = builder.build(in);
|
Element root = doc.getRootElement();
|
List list = root.getChildren();
|
Iterator it = list.iterator();
|
while(it.hasNext()) {
|
Element e = (Element) it.next();
|
String k = e.getName();
|
String v = "";
|
List children = e.getChildren();
|
if(children.isEmpty()) {
|
v = e.getTextNormalize();
|
} else {
|
// v = getChildrenText(children);
|
}
|
|
m.put(k, v);
|
}
|
//关闭流
|
in.close();
|
return m;
|
}
|
|
|
|
}
|
