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 orderOnlineByJson() throws Exception{ |
String requestData= "{'LogisticsWeight':2.0," + |
"'LogisticsVol':2.0," + |
"'HQPOrderDesc':'尽快上门收件'," + |
"'HQPPayType':1," + |
"'IsNeedPay':2," + |
"'Payment':121.0," + |
"'OrderCode':'test_1234567890'," + |
"'StartDate':'2015-05-13 21:20:53'," + |
"'EndDate':'2015-05-14 21:20:53'," + |
"'ShipperCode':'LB'," + |
"'LogisticCode':'109932607391'," + |
"'ToCompany':'华为科技'," + |
"'ToName':'张三'," + |
"'ToAddressArea':'深圳市南山区桂庙路555号'," + |
"'ToTel':''," + |
"'ToMobile':'13800000000'," + |
"'OrderType':2," + |
"'ToPostCode':'518128'," + |
"'ToProvinceID':'广东省'," + |
"'ToCityID':'深圳市'," + |
"'ToExpAreaID':'南山区'," + |
"'FromCompany':'小米科技'," + |
"'FromName':'李四'," + |
"'FromAddressArea':'深圳市福田区华强北路222号'," + |
"'FromTel':'88888888'," + |
"'FromMobile':''," + |
"'FromPostCode':'529800'," + |
"'FromProvinceID':'广东省'," + |
"'FromCityID':'深圳市'," + |
"'FromExpAreaID':'福田区'," + |
"'Cost':21.0," + |
"'OtherCost':2.0," + |
"'Commoditys':" + |
"[{" + |
"'Goodsquantity':12," + |
"'GoodsName':'手机屏幕'," + |
"'GoodsCode':'kjyhu878787'," + |
"'GoodsPrice':121.0," + |
"}]}" ; |
|
Map<String, String> params = new HashMap<String, String>(); |
params.put( "RequestData" , urlEncoder(requestData, "UTF-8" )); |
params.put( "EBusinessID" , EBusinessID); |
params.put( "RequestType" , "1001" ); |
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 orderOnlineByXml() throws Exception{ |
String requestData= "<?xml version=\"1.0\" encoding=\"utf-8\" ?>" + |
"<Content>" + |
"<LogisticsWeight>1.5</LogisticsWeight>" + |
"<OrderCode>test_123456789</OrderCode>" + |
"<LogisticsVol>0.5</LogisticsVol>" + |
"<HQPOrderDesc>测试在线下单接口 20150510</HQPOrderDesc>" + |
"<HQPPayType>1</HQPPayType>" + |
"<IsNeedPay>1</IsNeedPay>" + |
"<Payment>1000</Payment>" + |
"<OrderType>1</OrderType>" + |
"<StartDate>2015-05-10 19:36:50</StartDate>" + |
"<EndDate>2015-05-11 19:36:50</EndDate>" + |
"<ShipperCode>LB</ShipperCode>" + |
"<LogisticCode></LogisticCode>" + |
"<ToName>张三</ToName>" + |
"<ToAddressArea>深圳市南山区南新路2055号</ToAddressArea>" + |
"<ToTel></ToTel>" + |
"<ToMobile>13800000000</ToMobile>" + |
"<ToPostCode></ToPostCode>" + |
"<ToProvinceID>广东省</ToProvinceID>" + |
"<ToCityID>深圳市</ToCityID>" + |
"<ToExpAreaID>南山区</ToExpAreaID>" + |
"<FromCompany>快递鸟科技</FromCompany>" + |
"<FromName>李四</FromName>" + |
"<FromAddressArea>深圳市福田区华强北路211号</FromAddressArea>" + |
"<FromTel></FromTel>" + |
"<FromMobile>13888888888</FromMobile>" + |
"<FromPostCode></FromPostCode>" + |
"<FromProvinceID>广东省</FromProvinceID>" + |
"<FromCityID>深圳市</FromCityID>" + |
"<FromExpAreaID>福田区</FromExpAreaID>" + |
"<Cost>12</Cost>" + |
"<OtherCost>1</OtherCost>" + |
"<Commoditys>" + |
"<Commodity>" + |
"<GoodsName>惠普显示器</GoodsName>" + |
"<GoodsCode>ABCD_123456789</GoodsCode>" + |
"<Goodsquantity>2</Goodsquantity>" + |
"<GoodsPrice>850</GoodsPrice>" + |
"</Commodity>" + |
"<Commodity>" + |
"<GoodsName>神州笔记本</GoodsName>" + |
"<GoodsCode>QWERT_456456</GoodsCode>" + |
"<Goodsquantity>2</Goodsquantity>" + |
"<GoodsPrice>4200</GoodsPrice>" + |
"</Commodity>" + |
"</Commoditys>" + |
"</Content>" ; |
|
Map<String, String> params = new HashMap<String, String>(); |
params.put( "RequestData" , urlEncoder(requestData, "UTF-8" )); |
params.put( "EBusinessID" , EBusinessID); |
params.put( "RequestType" , "1001" ); |
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(); |
} |
} |
by: 发表于:2017-07-17 16:47:19 顶(0) | 踩(0) 回复
??
回复评论