快递轨迹第三方接口接入（快递鸟）

你的名字 2022-09-25 07:24 5阅读 0赞

一、登陆快递鸟官网：[http://kdniao.com/api-subscribe][http_kdniao.com_api-subscribe]

一、申请快递鸟商家ID和KEY

a) 点击如图中2中Free申请服务按钮，按照申请单要求填写完成，如图：

![Center][]

a) 申请通过，然后使用，申请中自己输入的用户名和密码，登陆快递鸟后台，如图：

![Center 1][]

一、开始接入订阅\-推送接口

a)        发起订阅订单信息（订阅），订阅代码如下：

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.security.MessageDigest;
    import java.util.HashMap;
    import java.util.Map; 
    
    /**
     *
     * 快递鸟物流轨迹即时查询接口
     *
     * @技术QQ群: 456320272
     * @see: http://www.kdniao.com/YundanChaxunAPI.aspx
     * @copyright: 深圳市快金数据技术服务有限公司
     *
     * DEMO中的电商ID与私钥仅限测试使用，正式环境请单独注册账号
     * 单日超过500单查询量，建议接入我方物流轨迹订阅推送接口
     * 
     * ID和Key请到官网申请：http://www.kdniao.com/ServiceApply.aspx
     */
    
    public class KdniaoTrackQueryAPI {
    	
    	//DEMO
    	public static void main(String[] args) {
    		KdniaoTrackQueryAPI api = new KdniaoTrackQueryAPI();
    		try {
    			String result = api.getOrderTracesByJson("ANE", "210001633605");
    			System.out.print(result);
    			
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    	
    	//电商ID
    	private String EBusinessID="请到快递鸟官网申请http://www.kdniao.com/ServiceApply.aspx";
    	//电商加密私钥，快递鸟提供，注意保管，不要泄漏
    	private String AppKey="请到快递鸟官网申请http://www.kdniao.com/ServiceApply.aspx";
    	//请求url，日请求量不限（>3000）的订阅接口
    	private String ReqURL="http://api.kdniao.cc/api/dist";	
     
    	/**
         * Json方式 查询订单物流轨迹
    	 * @throws Exception 
         */
    	public String getOrderTracesByJson(String expCode, String expNo) throws Exception{
    		String requestData= "{'OrderCode':'','ShipperCode':'" + expCode + "','LogisticCode':'" + expNo + "'}";
    		
    		Map<String, String> params = new HashMap<String, String>();
    		params.put("RequestData", urlEncoder(requestData, "UTF-8"));
    		params.put("EBusinessID", EBusinessID);
    		params.put("RequestType", "1008");
    		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;
    	}
     
    	/**
         * 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 = base64Encode(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();
        }
    	
    	
        private static char[] base64EncodeChars = new char[] { 
            'A', 'B', 'C', 'D', 'E', 'F', 'G', 'H', 
            'I', 'J', 'K', 'L', 'M', 'N', 'O', 'P', 
            'Q', 'R', 'S', 'T', 'U', 'V', 'W', 'X', 
            'Y', 'Z', 'a', 'b', 'c', 'd', 'e', 'f', 
            'g', 'h', 'i', 'j', 'k', 'l', 'm', 'n', 
            'o', 'p', 'q', 'r', 's', 't', 'u', 'v', 
            'w', 'x', 'y', 'z', '0', '1', '2', '3', 
            '4', '5', '6', '7', '8', '9', '+', '/' }; 
    	
        public static String base64Encode(byte[] data) { 
            StringBuffer sb = new StringBuffer(); 
            int len = data.length; 
            int i = 0; 
            int b1, b2, b3; 
            while (i < len) { 
                b1 = data[i++] & 0xff; 
                if (i == len) 
                { 
                    sb.append(base64EncodeChars[b1 >>> 2]); 
                    sb.append(base64EncodeChars[(b1 & 0x3) << 4]); 
                    sb.append("=="); 
                    break; 
                } 
                b2 = data[i++] & 0xff; 
                if (i == len) 
                { 
                    sb.append(base64EncodeChars[b1 >>> 2]); 
                    sb.append(base64EncodeChars[((b1 & 0x03) << 4) | ((b2 & 0xf0) >>> 4)]); 
                    sb.append(base64EncodeChars[(b2 & 0x0f) << 2]); 
                    sb.append("="); 
                    break; 
                } 
                b3 = data[i++] & 0xff; 
                sb.append(base64EncodeChars[b1 >>> 2]); 
                sb.append(base64EncodeChars[((b1 & 0x03) << 4) | ((b2 & 0xf0) >>> 4)]); 
                sb.append(base64EncodeChars[((b2 & 0x0f) << 2) | ((b3 & 0xc0) >>> 6)]); 
                sb.append(base64EncodeChars[b3 & 0x3f]); 
            } 
            return sb.toString(); 
        }
    }

a)        接收推送订单轨迹信息（推送）

i.   建立一个servlet接收快递鸟推送的信息

1. 在web.xml中添加如下代码：

<servlet>
    		<servlet-name>express</servlet-name>
    		<servlet-class>com.Express</servlet-class>
    	</servlet>
    	<servlet-mapping>
    		<servlet-name>express</servlet-name>
    		<url-pattern>/express</url-pattern>
    	</servlet-mapping>

1.        在Express.java类中，接收信息，代码如下：

package com;
    
    import java.io.IOException;
    import java.io.PrintWriter;
    import java.text.SimpleDateFormat;
    import java.util.Date;
    
    import javax.servlet.ServletException;
    import javax.servlet.http.HttpServlet;
    import javax.servlet.http.HttpServletRequest;
    import javax.servlet.http.HttpServletResponse;
    
    import org.json.JSONArray;
    import org.json.JSONException;
    
    import net.sf.json.JSONObject;
    
    
    /**
     * @author an 快递鸟快递运单轨迹信息订阅推送接口 适用于日查询量>3000次的系统
     */
    @SuppressWarnings("serial")
    public class Express extends HttpServlet {
    
    	// 电商ID
    	private String EBusinessID = "请到快递鸟官网申请http://www.kdniao.com/ServiceApply.aspx";
    
    	@Override
    	protected void doGet(HttpServletRequest req, HttpServletResponse resp)
    			throws ServletException, IOException {
    		doPost(req, resp);
    	}
    
    	@Override
    	protected void doPost(HttpServletRequest request,
    			HttpServletResponse response) {
    		
    		try {
    			String RequestData = request.getParameter("RequestData");
    			parseJson(RequestData);
    			returnMessageToKuaiDiNiao(response);
    		} catch (Exception e) {
    			returnMessageToKuaiDiNiao(response);//保证快递鸟公司能够接收到信息
    			e.printStackTrace();
    		}
    	}
    
    	/**
    	 * @param returnJson
    	 *            解析json数据
    	 * @throws JSONException
    	 */
    	private void parseJson(String returnJson) throws JSONException {
    		org.json.JSONObject obj = new org.json.JSONObject(returnJson);
    		JSONArray array = obj.getJSONArray("Data");// 存放着订阅的多个订单信息
    		for (int i = 0; i < array.length(); i++) {
    			org.json.JSONObject json = array.getJSONObject(i);
    			String LogisticCode = json.getString("LogisticCode");// 订单号
    			String ShipperCode = json.getString("ShipperCode");// 快递公司编号
    			JSONArray traces = json.getJSONArray("Traces");
    			//将接收到的信息按照公司的业务进行处理.....
    		}
    	}
    
    
    	/**
    	 * @param response
    	 *            返回信息给快递鸟公司
    	 */
    	private void returnMessageToKuaiDiNiao(HttpServletResponse response) {
    		try {
    			PrintWriter out = response.getWriter();
    			SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
    			JSONObject obj = new JSONObject();
    			obj.put("EBusinessID", EBusinessID);
    			obj.put("UpdateTime", sdf.format(new Date()));
    			obj.put("Success", true);
    			obj.put("Reason", "");
    			out.write(obj.toString());
    			out.flush();
    			out.close();
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    	}
    
    }

i.  确认回掉地址url：http://ip/项目名/express

联系快递鸟技术，将回掉地址url告诉快递鸟技术，进行联调，然后就可以使用

[http_kdniao.com_api-subscribe]: http://kdniao.com/api-subscribe
[Center]: /images/20220718/13586dbd72e543e9a5573e919859a6ef.png
[Center 1]: /images/20220718/fd6d88941240480c85bcc69ccc56fcae.png