import java.io.BufferedReader; |
import java.io.IOException; |
import java.io.InputStreamReader; |
import java.io.OutputStreamWriter; |
import java.io.UnsupportedEncodingException; |
import java.net.HttpURLConnection; |
import java.net.URL; |
import java.net.URLEncoder; |
import java.util.HashMap; |
import java.util.Map; |
import com.sun.org.apache.xerces.internal.impl.dv.util.Base64; |
import java.security.MessageDigest; |
public class KdGoldAPIDemo { |
|
//电商ID |
private String EBusinessID= "1237100" ; |
//电商加密私钥,快递鸟提供,注意保管,不要泄漏 |
private String AppKey= "518a73d8-1f7f-441a-b644-33e77b49d846" ; |
//请求url |
private String ReqURL= "http://api.kdniao.cc/Ebusiness/EbusinessOrderHandle.aspx" ; |
|
/** |
* Json方式 物流信息订阅 |
* @throws Exception |
*/ |
public String orderTracesSubByJson() throws Exception{ |
String requestData= "{'Code': 'SF','Item': [" + |
"{'No': '909261024507','Bk': 'test'}," + |
"{'No': '589554393102','Bk': 'test'}," + |
"{'No': '589522101958','Bk': 'test'}," + |
"{'No': '909198822942', 'Bk': 'test'}" + |
"]}" ; |
|
Map<String, String> params = new HashMap<String, String>(); |
params.put( "RequestData" , urlEncoder(requestData, "UTF-8" )); |
params.put( "EBusinessID" , EBusinessID); |
params.put( "RequestType" , "1005" ); |
String dataSign=encrypt(requestData, AppKey, "UTF-8" ); |
params.put( "DataSign" , urlEncoder(dataSign, "UTF-8" )); |
params.put( "DataType" , "2" ); |
|
String result=sendPost(ReqURL, params); |
|
//根据公司业务处理返回的信息...... |
|
return result; |
} |
|
/** |
* XML方式 物流信息订阅 |
* @throws Exception |
*/ |
public String orderTracesSubByXml() throws Exception{ |
String requestData= "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + |
"<Content>" + |
"<Code>SF</Code>" + |
"<Items>" + |
"<Item>" + |
"<No>909261024507</No>" + |
"<Bk>test</Bk>" + |
"</Item>" + |
"<Item>" + |
"<No>909261024507</No>" + |
"<Bk>test</Bk>" + |
"</Item>" + |
"</Items>" + |
"</Content>" ; |
|
Map<String, String> params = new HashMap<String, String>(); |
params.put( "RequestData" , urlEncoder(requestData, "UTF-8" )); |
params.put( "EBusinessID" , EBusinessID); |
params.put( "RequestType" , "1005" ); |
String dataSign=encrypt(requestData, AppKey, "UTF-8" ); |
params.put( "DataSign" , urlEncoder(dataSign, "UTF-8" )); |
params.put( "DataType" , "1" ); |
|
String result=sendPost(ReqURL, params); |
|
//根据公司业务处理返回的信息...... |
|
return result; |
} |
|
/** |
* MD5加密 |
* @param str 内容 |
* @param charset 编码方式 |
* @throws Exception |
*/ |
@SuppressWarnings ( "unused" ) |
private String MD5(String str, String charset) throws Exception { |
MessageDigest md = MessageDigest.getInstance( "MD5" ); |
md.update(str.getBytes(charset)); |
byte [] result = md.digest(); |
StringBuffer sb = new StringBuffer( 32 ); |
for ( int i = 0 ; i < result.length; i++) { |
int val = result[i] & 0xff ; |
if (val <= 0xf ) { |
sb.append( "0" ); |
} |
sb.append(Integer.toHexString(val)); |
} |
return sb.toString().toLowerCase(); |
} |
|
/** |
* base64编码 |
* @param str 内容 |
* @param charset 编码方式 |
* @throws UnsupportedEncodingException |
*/ |
private String base64(String str, String charset) throws UnsupportedEncodingException{ |
String encoded = Base64.encode(str.getBytes(charset)); |
return encoded; |
} |
|
@SuppressWarnings ( "unused" ) |
private String urlEncoder(String str, String charset) throws UnsupportedEncodingException{ |
String result = URLEncoder.encode(str, charset); |
return result; |
} |
|
/** |
* 电商Sign签名生成 |
* @param content 内容 |
* @param keyValue Appkey |
* @param charset 编码方式 |
* @throws UnsupportedEncodingException ,Exception |
* @return DataSign签名 |
*/ |
@SuppressWarnings ( "unused" ) |
private String encrypt (String content, String keyValue, String charset) throws UnsupportedEncodingException, Exception |
{ |
if (keyValue != null ) |
{ |
return base64(MD5(content + keyValue, charset), charset); |
} |
return base64(MD5(content, charset), charset); |
} |
|
/** |
* 向指定 URL 发送POST方法的请求 |
* @param url 发送请求的 URL |
* @param params 请求的参数集合 |
* @return 远程资源的响应结果 |
*/ |
@SuppressWarnings ( "unused" ) |
private String sendPost(String url, Map<String, String> params) { |
OutputStreamWriter out = null ; |
BufferedReader in = null ; |
StringBuilder result = new StringBuilder(); |
try { |
URL realUrl = new URL(url); |
HttpURLConnection conn =(HttpURLConnection) realUrl.openConnection(); |
// 发送POST请求必须设置如下两行 |
conn.setDoOutput( true ); |
conn.setDoInput( true ); |
// POST方法 |
conn.setRequestMethod( "POST" ); |
// 设置通用的请求属性 |
conn.setRequestProperty( "accept" , "*/*" ); |
conn.setRequestProperty( "connection" , "Keep-Alive" ); |
conn.setRequestProperty( "user-agent" , |
"Mozilla/4.0 (compatible; MSIE 6.0; Windows NT 5.1;SV1)" ); |
conn.setRequestProperty( "Content-Type" , "application/x-www-form-urlencoded" ); |
conn.connect(); |
// 获取URLConnection对象对应的输出流 |
out = new OutputStreamWriter(conn.getOutputStream(), "UTF-8" ); |
// 发送请求参数 |
if (params != null ) { |
StringBuilder param = new StringBuilder(); |
for (Map.Entry<String, String> entry : params.entrySet()) { |
if (param.length()> 0 ){ |
param.append( "&" ); |
} |
param.append(entry.getKey()); |
param.append( "=" ); |
param.append(entry.getValue()); |
System.out.println(entry.getKey()+ ":" +entry.getValue()); |
} |
System.out.println( "param:" +param.toString()); |
out.write(param.toString()); |
} |
// flush输出流的缓冲 |
out.flush(); |
// 定义BufferedReader输入流来读取URL的响应 |
in = new BufferedReader( |
new InputStreamReader(conn.getInputStream(), "UTF-8" )); |
String line; |
while ((line = in.readLine()) != null ) { |
result.append(line); |
} |
} catch (Exception e) { |
e.printStackTrace(); |
} |
//使用finally块来关闭输出流、输入流 |
finally { |
try { |
if (out!= null ){ |
out.close(); |
} |
if (in!= null ){ |
in.close(); |
} |
} |
catch (IOException ex){ |
ex.printStackTrace(); |
} |
} |
return result.toString(); |
} |
} |