• Java之各平台快递对接

    韵达快递、安能快递、百世快递、中国邮政快递、EMS、德邦快递、极兔快递、顺丰快递、申通快递、众邮快递、圆通快递、中通快递
     
    Express接口类 

    1. public interface Express {
    2.     /**
    3.      * 快递编码
    4.      *
    5.      * @return String
    6.      */
    7.     String expressCode();
    8.  
    9.     /**
    10.      * 根据快递编码相关信息查询快递信息
    11.      *
    12.      * @param request 请求参数
    13.      * @return ExpressSearchResponse
    14.      * @throws NoSuchAlgorithmException
    15.      */
    16.     ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) throws NoSuchAlgorithmException;
    17. }

    SelectExpress类

    1. import org.springframework.boot.CommandLineRunner;
    2. import org.springframework.context.ApplicationContext;
    3. import org.springframework.stereotype.Service;
    4.  
    5. import javax.annotation.Resource;
    6. import java.util.HashMap;
    7. import java.util.Map;
    8.  
    9. @Service
    10. public class SelectExpress implements CommandLineRunner {
    11.     @Resource
    12.     private ApplicationContext applicationContext;
    13.  
    14.     private Map expressMap = new HashMap<>();
    15.  
    16.     /**
    17.      * 根据名字返回相应的实现类
    18.      *
    19.      * @param code 快递公司编码
    20.      * @return 实现类
    21.      */
    22.     public Express get(String code) {
    23.         return expressMap.get(code);
    24.     }
    25.  
    26.     @Override
    27.     public void run(String... args) throws Exception {
    28.         applicationContext.getBeansOfType(Express.class).values()
    29.                 .forEach(express -> expressMap.put(express.expressCode(), express));
    30.     }
    31. }

    ExpressSearchRequest请求类

    1. import io.swagger.annotations.ApiModelProperty;
    2. import lombok.Data;
    3.  
    4. import java.io.Serializable;
    5.  
    6. @Data
    7. public class ExpressSearchRequest implements Serializable {
    8.     private static final long serialVersionUID = -880253965590928905L;
    9.     @ApiModelProperty(value = "真实物流单号")
    10.     private String logisticsNo;
    11.     @ApiModelProperty(value = "物流公司名称", hidden = true)
    12.     private String expressName;
    13.     @ApiModelProperty(value = "物流公司编码", hidden = true)
    14.     private String expressCode;
    15.     @ApiModelProperty(value = "订单编码", hidden = true)
    16.     private String orderNo;
    17.     @ApiModelProperty(value = "收件人姓名", hidden = true)
    18.     private String receiverName;
    19.     @ApiModelProperty(value = "收件人手机号", hidden = true)
    20.     private String receiverMobile;
    21.     @ApiModelProperty(value = "收人地址:省份名称", hidden = true)
    22.     private String provinceName;
    23.     @ApiModelProperty(value = "收人地址:地市名称", hidden = true)
    24.     private String cityName;
    25.     @ApiModelProperty(value = "收人地址:区县名称", hidden = true)
    26.     private String districtName;
    27.     @ApiModelProperty(value = "收件人详细地址", hidden = true)
    28.     private String detailAddress;
    29. }

     ExpressSearchResponse返回类

    1. import io.swagger.annotations.ApiModelProperty;
    2. import lombok.Data;
    3.  
    4. import java.io.Serializable;
    5. import java.util.ArrayList;
    6. import java.util.List;
    7.  
    8. @Data
    9. public class ExpressSearchResponse implements Serializable {
    10.     private static final long serialVersionUID = 8570085965157271803L;
    11.     @ApiModelProperty("快递公司名称")
    12.     private String logisticsName = "";
    13.     @ApiModelProperty("快递单号")
    14.     private String logisticsNo = "";
    15.     @ApiModelProperty("描述")
    16.     List descList = new ArrayList<>();
    17. }

    ExpressDescDTO返回类子类 

    1. import io.swagger.annotations.ApiModelProperty;
    2. import lombok.Data;
    3.  
    4. import java.io.Serializable;
    5.  
    6. @Data
    7. public class ExpressDescDTO implements Serializable {
    8.     private static final long serialVersionUID = 2774275564551643616L;
    9.     @ApiModelProperty("轨迹描述")
    10.     private String desc = "";
    11.     @ApiModelProperty("日期")
    12.     private String date = "";
    13. }

     ResponseController返回结果封装类

    1. import com.alibaba.fastjson.JSONArray;
    2. import com.alibaba.fastjson.JSONObject;
    3. import com.jumi.microservice.warehouse.entity.dto.ExpressDescDTO;
    4. import com.jumi.microservice.warehouse.entity.dto.ExpressSearchRequest;
    5. import com.jumi.microservice.warehouse.entity.dto.ExpressSearchResponse;
    6.  
    7. import java.text.SimpleDateFormat;
    8. import java.util.ArrayList;
    9. import java.util.Comparator;
    10. import java.util.Date;
    11. import java.util.List;
    12. import java.util.stream.Collectors;
    13.  
    14. public class ResponseController {
    15.  
    16.     /**
    17.      * 校验返回结果
    18.      *
    19.      * @param jsonArray json数组
    20.      * @param request   请求参数
    21.      * @return ExpressSearchResponse
    22.      */
    23.     public ExpressSearchResponse checkResult(JSONArray jsonArray, ExpressSearchRequest request) {
    24.         ExpressSearchResponse expressSearchResponse = new ExpressSearchResponse();
    25.         expressSearchResponse.setLogisticsName(request.getExpressName());
    26.         expressSearchResponse.setLogisticsNo(request.getLogisticsNo());
    27.         if (jsonArray == null || jsonArray.isEmpty()) {
    28.             expressSearchResponse.setDescList(new ArrayList<>());
    29.         }
    30.         return expressSearchResponse;
    31.     }
    32.  
    33.     /**
    34.      * 组装返回实体类
    35.      *
    36.      * @param expressSearchResponse 返回信息
    37.      * @param jsonArr               json数组
    38.      * @param descKey               描述
    39.      * @param dateKey               时间
    40.      * @return 组装返回实体类
    41.      */
    42.     public ExpressSearchResponse controller(ExpressSearchResponse expressSearchResponse, JSONArray jsonArr,
    43.                                             String descKey, String dateKey) {
    44.         if (jsonArr == null || jsonArr.isEmpty()) {
    45.             return expressSearchResponse;
    46.         }
    47.         List list = new ArrayList<>();
    48.         for (Object j : jsonArr) {
    49.             JSONObject json = JSONObject.parseObject(j.toString());
    50.             ExpressDescDTO expressDescDTO = new ExpressDescDTO();
    51.             if (json.getString(descKey) == null || json.getString(dateKey) == null) {
    52.                 return expressSearchResponse;
    53.             }
    54.             expressDescDTO.setDesc(json.getString(descKey));
    55.             expressDescDTO.setDate(json.getString(dateKey));
    56.             list.add(expressDescDTO);
    57.         }
    58.         list = list.stream().sorted(Comparator.comparing(ExpressDescDTO::getDate).reversed()).collect(Collectors.toList());
    59.         expressSearchResponse.setDescList(list);
    60.         return expressSearchResponse;
    61.     }
    62.  
    63.     /**
    64.      * 组装返回实体类
    65.      *
    66.      * @param expressSearchResponse 返回信息
    67.      * @param jsonArr               json数组
    68.      * @param descKey               描述
    69.      * @param dateKey               时间
    70.      * @return 组装返回实体类
    71.      */
    72.     public ExpressSearchResponse controllerZto(ExpressSearchResponse expressSearchResponse, JSONArray jsonArr,
    73.                                                String descKey, String dateKey) {
    74.         if (jsonArr == null || jsonArr.isEmpty()) {
    75.             return expressSearchResponse;
    76.         }
    77.         List list = new ArrayList<>();
    78.         for (Object j : jsonArr) {
    79.             JSONObject json = JSONObject.parseObject(j.toString());
    80.             ExpressDescDTO expressDescDTO = new ExpressDescDTO();
    81.             if (json.getString(descKey) == null || json.getString(dateKey) == null) {
    82.                 return expressSearchResponse;
    83.             }
    84.             expressDescDTO.setDesc(json.getString(descKey));
    85.             expressDescDTO.setDate(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date(Long.parseLong(json.getString(dateKey)))));
    86.             list.add(expressDescDTO);
    87.         }
    88.         list = list.stream().sorted(Comparator.comparing(ExpressDescDTO::getDate).reversed()).collect(Collectors.toList());
    89.         expressSearchResponse.setDescList(list);
    90.         return expressSearchResponse;
    91.     }
    92. }

    通用查询快递方法 

    1.     /**
    2.      * 查询快递
    3.      *
    4.      * @param sn   快递单号
    5.      * @param name 快递公司名称
    6.      * @param code 快递公司编码
    7.      * @return 结果
    8.      */
    9.     public ExpressSearchResponse queryExpress(String sn, String name, String code) {
    10.  
    11.         ExpressSearchResponse response;
    12.         if (StringUtils.isBlank(sn)) {
    13.             return new ExpressSearchResponse();
    14.         }
    15.         Express express = selectExpress.get(code);
    16.         ExpressSearchRequest request = new ExpressSearchRequest();
    17.         request.setExpressName(name);
    18.         request.setLogisticsNo(sn);
    19.         request.setExpressCode(code);
    20.         return express.logisticsSearch(request);
    21.     }

     HttpClientUtils工具类 

    1. import org.apache.http.HttpEntity;
    2. import org.apache.http.HttpResponse;
    3. import org.apache.http.client.methods.HttpGet;
    4. import org.apache.http.client.methods.HttpPost;
    5. import org.apache.http.entity.StringEntity;
    6. import org.apache.http.impl.client.HttpClients;
    7. import org.apache.http.util.EntityUtils;
    8. import org.springframework.stereotype.Component;
    9.  
    10. import java.io.IOException;
    11. import java.util.Map;
    12. import java.util.Set;
    13.  
    14. @Component
    15. public class HttpClientUtils {
    16.     /**
    17.      * http get
    18.      *
    19.      * @param url   可带参数的 url 链接
    20.      * @param heads http 头信息
    21.      */
    22.     public String get(String url, Map heads) {
    23.         org.apache.http.client.HttpClient httpClient = HttpClients.createDefault();
    24.         HttpResponse httpResponse = null;
    25.         String result = "";
    26.         HttpGet httpGet = new HttpGet(url);
    27.         if (heads != null) {
    28.             Set keySet = heads.keySet();
    29.             for (String s : keySet) {
    30.                 httpGet.addHeader(s, heads.get(s));
    31.             }
    32.         }
    33.         try {
    34.             httpResponse = httpClient.execute(httpGet);
    35.             HttpEntity httpEntity = httpResponse.getEntity();
    36.             if (httpEntity != null) {
    37.                 result = EntityUtils.toString(httpEntity, "utf-8");
    38.             }
    39.         } catch (IOException e) {
    40.             e.printStackTrace();
    41.         }
    42.         return result;
    43.     }
    44.  
    45.     /**
    46.      * http post
    47.      */
    48.     public String post(String url, String data, Map heads) {
    49.         org.apache.http.client.HttpClient httpClient = HttpClients.createDefault();
    50.         HttpResponse httpResponse = null;
    51.         String result = "";
    52.         HttpPost httpPost = new HttpPost(url);
    53.         if (heads != null) {
    54.             Set keySet = heads.keySet();
    55.             for (String s : keySet) {
    56.                 httpPost.addHeader(s, heads.get(s));
    57.             }
    58.         }
    59.         try {
    60.             StringEntity s = new StringEntity(data, "utf-8");
    61.             httpPost.setEntity(s);
    62.             httpResponse = httpClient.execute(httpPost);
    63.             HttpEntity httpEntity = httpResponse.getEntity();
    64.             if (httpEntity != null) {
    65.                 result = EntityUtils.toString(httpEntity, "utf-8");
    66.             }
    67.         } catch (IOException e) {
    68.             e.printStackTrace();
    69.         }
    70.         return result;
    71.     }
    72. }

     MD5工具类

    1. import com.google.common.collect.Maps;
    2. import org.springframework.stereotype.Component;
    3.  
    4. import java.nio.charset.StandardCharsets;
    5. import java.security.MessageDigest;
    6. import java.util.Map;
    7. import java.util.concurrent.locks.ReentrantLock;
    8.  
    9.  
    10. @Component
    11. public class MD5 {
    12.     private static int DIGITS_SIZE = 16;
    13.     private static char[] digits = {'0', '1', '2', '3', '4', '5', '6', '7', '8', '9', 'a', 'b', 'c', 'd', 'e', 'f'};
    14.  
    15.     private static Map rDigits = Maps.newHashMapWithExpectedSize(16);
    16.  
    17.     static {
    18.         for (int i = 0; i < digits.length; ++i) {
    19.             rDigits.put(digits[i], i);
    20.         }
    21.     }
    22.  
    23.     private static MD5 me = new MD5();
    24.     private MessageDigest mHasher;
    25.     private ReentrantLock opLock = new ReentrantLock();
    26.  
    27.     private MD5() {
    28.         try {
    29.             mHasher = MessageDigest.getInstance("md5");
    30.         } catch (Exception e) {
    31.             throw new RuntimeException(e);
    32.         }
    33.  
    34.     }
    35.  
    36.     public static MD5 getInstance() {
    37.         return me;
    38.     }
    39.  
    40.     public String getMD5String(String content) {
    41.         return bytes2string(hash(content));
    42.     }
    43.  
    44.     public String getMD5String(byte[] content) {
    45.         return bytes2string(hash(content));
    46.     }
    47.  
    48.     public byte[] getMD5Bytes(byte[] content) {
    49.         return hash(content);
    50.     }
    51.  
    52.     /**
    53.      * 对字符串进行md5
    54.      *
    55.      * @param str
    56.      * @return md5 byte[16]
    57.      */
    58.     public byte[] hash(String str) {
    59.         opLock.lock();
    60.         try {
    61.             byte[] bt = mHasher.digest(str.getBytes(StandardCharsets.UTF_8));
    62.             if (null == bt || bt.length != DIGITS_SIZE) {
    63.                 throw new IllegalArgumentException("md5 need");
    64.             }
    65.             return bt;
    66.         } finally {
    67.             opLock.unlock();
    68.         }
    69.     }
    70.  
    71.     /**
    72.      * 对二进制数据进行md5
    73.      *
    74.      * @param data
    75.      * @return md5 byte[16]
    76.      */
    77.     public byte[] hash(byte[] data) {
    78.         opLock.lock();
    79.         try {
    80.             byte[] bt = mHasher.digest(data);
    81.             if (null == bt || bt.length != DIGITS_SIZE) {
    82.                 throw new IllegalArgumentException("md5 need");
    83.             }
    84.             return bt;
    85.         } finally {
    86.             opLock.unlock();
    87.         }
    88.     }
    89.  
    90.     /**
    91.      * 将一个字节数组转化为可见的字符串
    92.      *
    93.      * @param bt
    94.      * @return
    95.      */
    96.     public String bytes2string(byte[] bt) {
    97.         int l = bt.length;
    98.         char[] out = new char[l << 1];
    99.         for (int i = 0, j = 0; i < l; i++) {
    100.             out[j++] = digits[(0xF0 & bt[i]) >>> 4];
    101.             out[j++] = digits[0x0F & bt[i]];
    102.         }
    103.         return new String(out);
    104.     }
    105. }

    MD5加密工具类

    1. import org.slf4j.Logger;
    2. import org.slf4j.LoggerFactory;
    3. import org.springframework.stereotype.Component;
    4.  
    5. import java.security.MessageDigest;
    6.  
    7. @Component
    8. public class Md5Utils {
    9.     private static final Logger log = LoggerFactory.getLogger(Md5Utils.class);
    10.  
    11.     private static byte[] md5(String s) {
    12.         MessageDigest algorithm;
    13.         try {
    14.             algorithm = MessageDigest.getInstance("MD5");
    15.             algorithm.reset();
    16.             algorithm.update(s.getBytes("UTF-8"));
    17.             byte[] messageDigest = algorithm.digest();
    18.             return messageDigest;
    19.         } catch (Exception e) {
    20.             log.error("MD5 Error...", e);
    21.         }
    22.         return null;
    23.     }
    24.  
    25.     private static final String toHex(byte hash[]) {
    26.         if (hash == null) {
    27.             return null;
    28.         }
    29.         StringBuffer buf = new StringBuffer(hash.length * 2);
    30.         int i;
    31.         for (i = 0; i < hash.length; i++) {
    32.             if ((hash[i] & 0xff) < 0x10) {
    33.                 buf.append("0");
    34.             }
    35.             buf.append(Long.toString(hash[i] & 0xff, 16));
    36.         }
    37.         return buf.toString();
    38.     }
    39.  
    40.     public static String hash(String s) {
    41.         try {
    42.             return new String(toHex(md5(s)).getBytes("UTF-8"), "UTF-8");
    43.         } catch (Exception e) {
    44.             log.error("not supported charset...{}", e);
    45.             return s;
    46.         }
    47.     }
    48. }

    pom.xml——>引入顺丰、申通、众邮快递SDK。引入谷歌工具包：调用com.google.common.collect.Maps。

    1.         <dependency>
    2.                 <groupId>com.expressgroupId>
    3.             <artifactId>lop-zhongyou-api-sdkartifactId>
    4.             <version>2.0.0version>
    5.             <scope>compilescope>
    6.         dependency>
    7.         <dependency>
    8.             <groupId>com.expressgroupId>
    9.             <artifactId>sf-csim-express-sdkartifactId>
    10.             <version>2.0.0version>
    11.             <scope>compilescope>
    12.         dependency>
    13.         <dependency>
    14.             <groupId>com.expressgroupId>
    15.             <artifactId>sto-link-sdkartifactId>
    16.             <version>2.0.0version>
    17.             <scope>compilescope>
    18.         dependency>
    19.         <dependency>
    20.             <groupId>com.google.guavagroupId>
    21.             <artifactId>guavaartifactId>
    22.             <version>22.0version>
    23.          dependency>

     韵达快递——>接收OrderInfo类

    1. import lombok.Data;
    2.  
    3. @Data
    4. public class OrderInfo {
    5.     private String orderid;
    6.     private String mailno;
    7.     private UserInfo sender;
    8.     private UserInfo receiver;
    9. }

     韵达快递——>接收子类UserInfo类 

    1. import lombok.Data;
    2.  
    3. @Data
    4. public class UserInfo {
    5.     private String name;
    6.     private String province;
    7.     private String city;
    8.     private String county;
    9.     private String address;
    10.     private String phone;
    11.     private String mobile;
    12. }

    例1：YdExpress——>韵达快递

    1. import cn.hutool.core.util.StrUtil;
    2. import com.alibaba.fastjson.JSON;
    3. import com.alibaba.fastjson.JSONArray;
    4. import com.alibaba.fastjson.JSONObject;
    5. import OrderInfo;
    6. import UserInfo;
    7. import ExpressSearchRequest;
    8. import ExpressSearchResponse;
    9. import org.slf4j.Logger;
    10. import org.slf4j.LoggerFactory;
    11. import org.springframework.data.redis.core.RedisTemplate;
    12. import org.springframework.stereotype.Service;
    13.  
    14. import javax.annotation.Resource;
    15. import java.io.*;
    16. import java.net.HttpURLConnection;
    17. import java.net.URL;
    18. import java.nio.charset.StandardCharsets;
    19. import java.security.MessageDigest;
    20. import java.util.ArrayList;
    21. import java.util.List;
    22. import java.util.concurrent.TimeUnit;
    23.  
    24. /**
    25.  * 韵达
    26.  */
    27. @Service
    28. public class YdExpress extends ResponseController implements Express {
    29.     private static final Logger log = LoggerFactory.getLogger(YdExpress.class);
    30.     private static final String TRACK_SERVER_URL = "https://openapi.yundaex.com/openapi/outer/logictis/subscribe";
    31.     private static final String SERVER_URL = "https://openapi.yundaex.com/openapi/outer/logictis/query";
    32.     private static final String APP_KEY = "123456";
    33.     private static final String APP_SECRET = "e10adc3949ba59abbe56e057f20f883e";
    34.     @Resource
    35.     private RedisTemplate redisTemplate;
    36.     private static final String LOGISTICS_TRACK = "logistics::track:{}";
    37.  
    38.     @Override
    39.     public String expressCode() {
    40.         return "YD";
    41.     }
    42.  
    43.     @Override
    44.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    45.         log.info("韵达快递查询参数[{}]", JSON.toJSONString(request));
    46.         JSONArray jsonArray = new JSONArray();
    47.         String logisticsTrack = StrUtil.format(LOGISTICS_TRACK, request.getLogisticsNo());
    48.         boolean isTrack = false;
    49.         try {
    50.             if (!redisTemplate.hasKey(logisticsTrack)) {
    51.                 //物流轨迹订阅
    52.                 String orderid = request.getOrderNo();
    53.                 String mailno = request.getLogisticsNo();
    54.  
    55.                 String senderName = request.getReceiverName();
    56.                 String senderProvince = request.getProvinceName();
    57.                 String senderCity = request.getCityName();
    58.                 String senderCounty = request.getDistrictName();
    59.                 String senderAddress = request.getDetailAddress();
    60.                 String senderPhone = request.getReceiverMobile();
    61.                 String senderMobile = request.getReceiverMobile();
    62.  
    63.                 String receiverName = request.getReceiverName();
    64.                 String receiverProvince = request.getProvinceName();
    65.                 String receiverCity = request.getCityName();
    66.                 String receiverCounty = request.getDistrictName();
    67.                 String receiverAddress = request.getDetailAddress();
    68.                 String receiverPhone = request.getReceiverMobile();
    69.                 String receiverMobile = request.getReceiverMobile();
    70.  
    71.                 List orderInfoList = new ArrayList<>();
    72.                 OrderInfo orderInfo = new OrderInfo();
    73.                 orderInfo.setOrderid(orderid);
    74.                 orderInfo.setMailno(mailno);
    75.                 //发货人信息
    76.                 UserInfo userInfoSender = new UserInfo();
    77.                 userInfoSender.setName(senderName);
    78.                 userInfoSender.setProvince(senderProvince);
    79.                 userInfoSender.setCity(senderCity);
    80.                 userInfoSender.setCounty(senderCounty);
    81.                 userInfoSender.setAddress(senderAddress);
    82.                 userInfoSender.setPhone(senderPhone);
    83.                 userInfoSender.setMobile(senderMobile);
    84.                 orderInfo.setSender(userInfoSender);
    85.                 //接收人信息
    86.                 UserInfo userInfoReceiver = new UserInfo();
    87.                 userInfoReceiver.setName(receiverName);
    88.                 userInfoReceiver.setProvince(receiverProvince);
    89.                 userInfoReceiver.setCity(receiverCity);
    90.                 userInfoReceiver.setCounty(receiverCounty);
    91.                 userInfoReceiver.setAddress(receiverAddress);
    92.                 userInfoReceiver.setPhone(receiverPhone);
    93.                 userInfoReceiver.setMobile(receiverMobile);
    94.                 orderInfo.setReceiver(userInfoReceiver);
    95.                 orderInfoList.add(orderInfo);
    96.                 String orders = "{\"orders\":" + JSONObject.toJSONString(orderInfoList) + "}";
    97.                 String resTrack = doPostJson(TRACK_SERVER_URL, orders);
    98.                 JSONObject jsonObjTrack = JSON.parseObject(resTrack);
    99.                 if (jsonObjTrack.getBoolean("result")) {
    100.                     redisTemplate.expire(logisticsTrack, 60, TimeUnit.DAYS);
    101.                     isTrack = true;
    102.                 }
    103.             }
    104.             if (isTrack) {
    105.                 String sourceContent = "{\"mailno\":\"" + request.getLogisticsNo() + "\"}";
    106.                 String res = doPostJson(SERVER_URL, sourceContent);
    107.                 log.info("请求返回结果[{}]", res);
    108.                 JSONObject jsonObj = JSON.parseObject(res);
    109.                 if (jsonObj.containsKey("data")) {
    110.                     JSONObject json = jsonObj.getJSONObject("data");
    111.                     if (json.containsKey("steps")) {
    112.                         jsonArray = json.getJSONArray("steps");
    113.                     }
    114.                 }
    115.             }
    116.         } catch (Exception e) {
    117.             log.error("韵达快递查询出错[{}]", e.getMessage());
    118.         }
    119.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    120.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "description", "time")));
    121.         return controller(expressSearchResponse, jsonArray, "description", "time");
    122.     }
    123.  
    124.     /**
    125.      * 发送HTTP请求
    126.      *
    127.      * @param apiUrl     请求URL
    128.      * @param jsonParams 请求参数
    129.      * @return String
    130.      */
    131.     private static String doPostJson(String apiUrl, String jsonParams) {
    132.         StringBuffer sbResult = new StringBuffer();
    133.         try {
    134.             URL url = new URL(apiUrl);
    135.             HttpURLConnection conn = (HttpURLConnection) url.openConnection();
    136.             conn.setDoOutput(true);
    137.             conn.setDoInput(true);
    138.             conn.setUseCaches(false);
    139.             conn.setRequestMethod("POST");
    140.             conn.setRequestProperty("Connection", "Keep-Alive");
    141.             conn.setRequestProperty("Charset", "UTF-8");
    142.             byte[] data = jsonParams.getBytes(StandardCharsets.UTF_8);
    143.             conn.setRequestProperty("Content-Length", String.valueOf(data.length));
    144.             conn.setRequestProperty("Content-Type", "application/json");
    145.             conn.setRequestProperty("app-key", YdExpress.APP_KEY);
    146.             conn.setRequestProperty("req-time", String.valueOf(System.currentTimeMillis()));
    147.             conn.setRequestProperty("sign", MD5(jsonParams + "_" + YdExpress.APP_SECRET));
    148.             conn.connect();
    149.             OutputStream out = new DataOutputStream(conn.getOutputStream());
    150.             out.write(data);
    151.             out.flush();
    152.             out.close();
    153.             if (200 == conn.getResponseCode()) {
    154.                 InputStream inputStream = conn.getInputStream();
    155.                 try {
    156.                     String readLine = null;
    157.                     BufferedReader responseReader = new BufferedReader(new InputStreamReader(inputStream, StandardCharsets.UTF_8));
    158.  
    159.                     while ((readLine = responseReader.readLine()) != null) {
    160.                         sbResult.append(readLine).append("\n");
    161.                     }
    162.  
    163.                     responseReader.close();
    164.                 } catch (Exception var12) {
    165.                     var12.printStackTrace();
    166.                 }
    167.             }
    168.         } catch (Exception var13) {
    169.             var13.printStackTrace();
    170.         }
    171.         return sbResult.toString();
    172.     }
    173.  
    174.     /**
    175.      * Md5加密算法
    176.      *
    177.      * @param str
    178.      * @return
    179.      * @throws Exception
    180.      */
    181.     private static String MD5(String str) throws Exception {
    182.         MessageDigest md = MessageDigest.getInstance("MD5");
    183.         md.update(str.getBytes(StandardCharsets.UTF_8));
    184.         byte[] result = md.digest();
    185.         StringBuffer sb = new StringBuffer(32);
    186.         for (int i = 0; i < result.length; ++i) {
    187.             int val = result[i] & 255;
    188.             if (val <= 15) {
    189.                 sb.append("0");
    190.             }
    191.             sb.append(Integer.toHexString(val));
    192.         }
    193.         return sb.toString().toLowerCase();
    194.     }
    195. }

    例2：AneExpress——>安能快递

    1. import cn.hutool.core.codec.Base64;
    2. import cn.hutool.crypto.SecureUtil;
    3. import cn.hutool.http.HttpRequest;
    4. import com.alibaba.fastjson.JSON;
    5. import com.alibaba.fastjson.JSONArray;
    6. import com.alibaba.fastjson.JSONObject;
    7. import ExpressSearchRequest;
    8. import ExpressSearchResponse;
    9. import org.slf4j.Logger;
    10. import org.slf4j.LoggerFactory;
    11. import org.springframework.stereotype.Service;
    12.  
    13. import java.security.NoSuchAlgorithmException;
    14.  
    15. /**
    16.  * 安能
    17.  **/
    18. @Service
    19. public class AneExpress extends ResponseController implements Express {
    20.     private static final Logger log = LoggerFactory.getLogger(AneExpress.class);
    21.     private static String URL = "http://opc.ane56.com/aneop/services/logisticsQuery/new/query";
    22.     private static String APPKEY = "e10adc3949ba59abbe56e057f20f883e";
    23.     private static String CODE = "ANENG";
    24.  
    25.     @Override
    26.     public String expressCode() {
    27.         return "ANE";
    28.     }
    29.  
    30.     @Override
    31.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) throws NoSuchAlgorithmException {
    32.         log.info("安能快递查询参数[{}]", JSON.toJSONString(request));
    33.         JSONArray jsonArray = new JSONArray();
    34.         try {
    35.             JSONObject jsonObject = new JSONObject();
    36.             JSONObject params = new JSONObject();
    37.             params.put("ewbNo", request.getLogisticsNo());
    38.             jsonObject.put("params", params.toJSONString());
    39.             String digest = Base64.encode(SecureUtil.md5("{\"ewbNo\":\"" + request.getLogisticsNo() + "\"}" + CODE + APPKEY));
    40.             jsonObject.put("digest", digest);
    41.             jsonObject.put("code", CODE);
    42.             String timestamp = Long.toString(System.currentTimeMillis());
    43.             jsonObject.put("timestamp", timestamp);
    44.             String res = HttpRequest.post(URL).header("Content-type", "application/json").body(jsonObject.toJSONString()).execute().body();
    45.             log.info("请求返回结果[{}]", res);
    46.             JSONObject resObject = JSONObject.parseObject(res);
    47.             jsonArray = resObject.getJSONObject("resultInfo").getJSONArray("traces");
    48.         } catch (Exception e) {
    49.             log.error("安能快递查询出错[{}]", e.getMessage());
    50.         }
    51.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    52.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "desc", "operateTime")));
    53.         return controller(expressSearchResponse, jsonArray, "desc", "operateTime");
    54.     }
    55. }

    例3：BestExpress——>百世快递

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import org.slf4j.Logger;
    7. import org.slf4j.LoggerFactory;
    8. import org.springframework.stereotype.Service;
    9.  
    10. import javax.annotation.Resource;
    11. import java.util.HashMap;
    12. import java.util.Map;
    13.  
    14. /**
    15.  * 百世
    16.  */
    17. @Service
    18. public class BestExpress extends ResponseController implements Express {
    19.  
    20.     private static final Logger log = LoggerFactory.getLogger(BestExpress.class);
    21.     private static String url = "http://edi-q9.ns.800best.com/kd/api/process";
    22.     private static String partnerKey = "49ba59abbe56";
    23.     private static String partnerID = "12345";
    24.     private static String serviceType = "KD_TRACE_QUERY";
    25.     @Resource
    26.     HttpClientUtils httpClientUtils;
    27.  
    28.     @Override
    29.     public String expressCode() {
    30.         return "HTKY";
    31.     }
    32.  
    33.     @Override
    34.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    35.         log.info("百世快递查询参数[{}]", JSON.toJSONString(request));
    36.         JSONArray jsonArr = null;
    37.         ExpressSearchResponse expressSearchResponse = null;
    38.         try {
    39.             //拼接请求头
    40.             Map headers = new HashMap<>(4);
    41.             headers.put("accept", "text/html,application/xhtml+xml,application/xml;q=0.9,*/*;q=0.8");
    42.             headers.put("connection", "keep-alive");
    43.             headers.put("user-agent", "Mozilla/5.0 (Windows NT 6.1; WOW64; rv:34.0) Gecko/20100101 Firefox/34.0");
    44.             headers.put("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
    45.             //组建数据格式
    46.             String bizData = "{\"mailNos\": {\"mailNo\": [\"" + request.getLogisticsNo() + "\"]}}";
    47.             String sign = Md5Utils.hash(bizData + partnerKey);
    48.             String requestData = "partnerID=" + partnerID + "&serviceType=" + serviceType + "&bizData=" + bizData + "&sign=" + sign;
    49.             //发送请求并接受返回
    50.             String res = httpClientUtils.post(url, requestData, headers);
    51.             log.info("请求返回结果[{}]", res);
    52.             JSONObject json = JSONObject.parseObject(res);
    53.             jsonArr = json.getJSONArray("traceLogs");
    54.             //处理返回结果
    55.             jsonArr = jsonArr.getJSONObject(0).getJSONObject("traces").getJSONArray("trace");
    56.         } catch (Exception e) {
    57.             log.error("百世快递查询出错[{}]", e.getMessage());
    58.         }
    59.         expressSearchResponse = checkResult(jsonArr, request);
    60.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "remark", "acceptTime")));
    61.         return controller(expressSearchResponse, jsonArr, "remark", "acceptTime");
    62.     }
    63. }

    例4：中国邮政快递——>ChinaPostExpress【线下联系邮政快递人员开通账号信息】

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import org.slf4j.Logger;
    7. import org.slf4j.LoggerFactory;
    8. import org.springframework.stereotype.Service;
    9.  
    10. import javax.annotation.Resource;
    11. import java.util.HashMap;
    12. import java.util.Map;
    13.  
    14. /**
    15.  * 中国邮政
    16.  */
    17. @Service
    18. public class ChinaPostExpress extends ResponseController implements Express {
    19.     private static final Logger log = LoggerFactory.getLogger(ChinaPostExpress.class);
    20.     @Resource
    21.     HttpClientUtils httpClientUtils;
    22.  
    23.     @Override
    24.     public String expressCode() {
    25.         return "YZPY";
    26.     }
    27.  
    28.     @Override
    29.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    30.         log.info("邮政快递包裹查询参数[{}]", JSON.toJSONString(request));
    31.         JSONArray jsonArray = null;
    32.         try {
    33.             String url = "http://211.156.193.140:8000/cotrackapi/api/track/mail/";
    34.             //拼接请求头
    35.             Map headers = new HashMap<>(2);
    36.             headers.put("Version", "ems_track_cn_1.0");
    37.             headers.put("authenticate", "E10ADC3949BA59ABBE56E057F20F883E");
    38.             //组建数据格式
    39.             url = url + request.getLogisticsNo();
    40.             //发送请求并接受返回
    41.             String res = httpClientUtils.get(url, headers);
    42.             //处理返回结果
    43.             log.info("请求返回结果[{}]", res);
    44.             JSONObject json = JSONObject.parseObject(res);
    45.             jsonArray = json.getJSONArray("traces");
    46.         } catch (Exception e) {
    47.             log.error("邮政快递包裹查询出错[{}]", e.getMessage());
    48.         }
    49.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    50.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "remark", "acceptTime")));
    51.         return controller(expressSearchResponse, jsonArray, "remark", "acceptTime");
    52.     }
    53. }

    例5：EMS——>EmsExpress【线下联系邮政快递人员开通账号信息】

    1. import ExpressSearchRequest;
    2. import ExpressSearchResponse;
    3. import org.springframework.stereotype.Service;
    4.  
    5. import javax.annotation.Resource;
    6.  
    7. /**
    8.  * EMS
    9.  */
    10. @Service
    11. public class EmsExpress extends ResponseController implements Express {
    12.     @Resource
    13.     ChinaPostExpress chinaPostExpress;
    14.  
    15.     @Override
    16.     public String expressCode() {
    17.         return "EMS";
    18.     }
    19.  
    20.     @Override
    21.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    22.         return chinaPostExpress.logisticsSearch(request);
    23.     }
    24. }

    例6：德邦快递——>DepponExpress

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import org.apache.commons.codec.binary.Base64;
    7. import org.apache.commons.codec.digest.DigestUtils;
    8. import org.slf4j.Logger;
    9. import org.slf4j.LoggerFactory;
    10. import org.springframework.stereotype.Service;
    11.  
    12. import javax.annotation.Resource;
    13. import java.util.HashMap;
    14. import java.util.Map;
    15.  
    16. /**
    17.  * 德邦
    18.  */
    19. @Service
    20. public class DepponExpress extends ResponseController implements Express {
    21.  
    22.     private static final Logger log = LoggerFactory.getLogger(DepponExpress.class);
    23.     private static String url = "http://dpapi.deppon.com/dop-interface-sync/standard-query/newTraceQuery.action";
    24.     private static String companyCode = "ABCDEFGHIJKLM";
    25.     private static String appKey = "e10adc3949ba59abbe56e057f20f883e";
    26.     @Resource
    27.     HttpClientUtils httpClientUtils;
    28.  
    29.     @Override
    30.     public String expressCode() {
    31.         return "DBL";
    32.     }
    33.  
    34.     @Override
    35.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    36.         JSONArray jsonArray = null;
    37.         log.info("德邦快递查询参数[{}]", JSON.toJSONString(request));
    38.         try {
    39.             //拼接请求头
    40.             Map headers = new HashMap<>(1);
    41.             headers.put("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
    42.             //组建数据格式
    43.             String timestamp = String.valueOf(System.currentTimeMillis());
    44.             String params = "{\"mailNo\":\"" + request.getLogisticsNo() + "\"}";
    45.             String digest = Base64.encodeBase64String(DigestUtils.md5Hex(params + appKey + timestamp).getBytes());
    46.             String requestData = "params=" + params + "&digest=" + digest + "×tamp=" + timestamp + "&companyCode=" + companyCode;
    47.             //发送请求并接受返回
    48.             String res = httpClientUtils.post(url, requestData, headers);
    49.             //处理返回结果
    50.             log.info("请求返回结果[{}]", res);
    51.             JSONObject json = JSONObject.parseObject(res);
    52.             jsonArray = json.getJSONObject("responseParam").getJSONArray("trace_list");
    53.         } catch (Exception e) {
    54.             log.error("德邦快递查询出错[{}]", e.getMessage());
    55.         }
    56.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    57.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "description", "time")));
    58.         return controller(expressSearchResponse, jsonArray, "description", "time");
    59.     }
    60. }

    例7：极兔快递——>JtExpress 

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import org.slf4j.Logger;
    7. import org.slf4j.LoggerFactory;
    8. import org.springframework.stereotype.Service;
    9. import org.apache.commons.codec.binary.Base64;
    10. import org.apache.commons.codec.digest.DigestUtils;
    11.  
    12. import javax.annotation.Resource;
    13. import java.util.HashMap;
    14. import java.util.Map;
    15.  
    16. /**
    17.  * 极兔
    18.  */
    19. @Service
    20. public class JtExpress extends ResponseController implements Express {
    21.     private static final Logger log = LoggerFactory.getLogger(JtExpress.class);
    22.     private static final String API_ACCOUNT = "178337126125932605";
    23.     private static final String PRIVATE_KEY = "0258d71b55fc45e3ad7a7f38bf4b201a";
    24.     private static final String SERVICE_URL = "https://openapi.jtexpress.com.cn/webopenplatformapi/api/logistics/trace";
    25.     @Resource
    26.     HttpClientUtils httpClientUtils;
    27.  
    28.     @Override
    29.     public String expressCode() {
    30.         return "JTSD";
    31.     }
    32.  
    33.     @Override
    34.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    35.         log.info("极兔查询参数[{}]", JSON.toJSONString(request));
    36.         JSONArray jsonArray = new JSONArray();
    37.         try {
    38.             //查询参数
    39.             String bizContent = "{\"billCodes\":\"" + request.getLogisticsNo() + "\"}";
    40.             //拼接请求头
    41.             Map headers = new HashMap<>();
    42.             headers.put("Content-Type", "application/x-www-form-urlencoded;charset=utf-8");
    43.             headers.put("apiAccount", API_ACCOUNT);
    44.             headers.put("digest", digestForHead(bizContent));
    45.             headers.put("timestamp", String.valueOf(System.currentTimeMillis()));
    46.             String requestData = "bizContent=" + bizContent;
    47.             Map jsonMap = new HashMap<>();
    48.             jsonMap.put("header", JSON.toJSONString(headers));
    49.             jsonMap.put("body", requestData);
    50.             log.info("请求参数digest[{}]", digestForHead(bizContent));
    51.             log.info("请求参数headers[{}]", JSON.toJSONString(headers));
    52.             log.info("请求参数body[{}]", requestData);
    53.             log.info("请求jsonMap[{}]", JSON.toJSONString(jsonMap));
    54.             //发送请求并接受返回
    55.             String res = httpClientUtils.post(SERVICE_URL, requestData, headers);
    56.             //处理返回结果
    57.             log.info("请求返回结果[{}]", res);
    58.             JSONObject json = JSONObject.parseObject(res);
    59.             jsonArray = json.getJSONArray("data").getJSONObject(0).getJSONArray("details");
    60.         } catch (Exception e) {
    61.             log.error("极兔快递查询出错[{}]", e.getMessage());
    62.         }
    63.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    64.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "desc", "scanTime")));
    65.         return controller(expressSearchResponse, jsonArray, "desc", "scanTime");
    66.     }
    67.  
    68.     private static String digestForHead(String json) {
    69.         String signStr = json + JtExpress.PRIVATE_KEY;
    70.         byte[] encode = (new Base64()).encode(DigestUtils.md5(signStr));
    71.         return new String(encode);
    72.     }
    73. }

     例8：顺丰快递——>SfExpress 【引用顺丰SDK】

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import com.sf.csim.express.service.CallExpressServiceTools;
    7. import com.sf.csim.express.service.HttpClientUtil;
    8. import org.slf4j.Logger;
    9. import org.slf4j.LoggerFactory;
    10. import org.springframework.stereotype.Service;
    11.  
    12. import java.util.HashMap;
    13. import java.util.Map;
    14. import java.util.UUID;
    15.  
    16.  
    17. /**
    18.  * 顺丰
    19.  */
    20. @Service
    21. public class SfExpress extends ResponseController implements Express {
    22.     private static final Logger log = LoggerFactory.getLogger(SfExpress.class);
    23.     /**
    24.      * 顾客编码
    25.      */
    26.     private static final String CLIENT_CODE = "ABCDEFGHIJKL";
    27.     /**
    28.      * 丰桥平台生产校验码
    29.      */
    30.     private static final String CHECK_WORD = "E10ADC3949BA59ABBE56E057F20F883E";
    31.     /**
    32.      * 接口服务代码
    33.      */
    34.     private static final String SERVICE_CODE = "EXP_RECE_SEARCH_ROUTES";
    35.     /**
    36.      * 生产环境的地址
    37.      */
    38.     private static final String CALL_URL_PROD = "https://sfapi.sf-express.com/std/service";
    39.  
    40.     @Override
    41.     public String expressCode() {
    42.         return "SF";
    43.     }
    44.  
    45.     @Override
    46.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    47.         log.info("顺丰查询参数[{}]", JSON.toJSONString(request));
    48.         JSONArray jsonArray = new JSONArray();
    49.         try {
    50.             Map params = new HashMap<>();
    51.             String msgData = "{" +
    52.                     "    \"language\": 0," +
    53.                     "    \"trackingType\": 1," +
    54.                     "    \"trackingNumber\": [\"" + request.getLogisticsNo() + "\"]," +
    55.                     "    \"methodType\": 1," +
    56.                     "    \"checkPhoneNo\": \"" + request.getReceiverMobile().substring(7) + "\"" +
    57.                     "}";
    58.             String timeStamp = String.valueOf(System.currentTimeMillis());
    59.             params.put("partnerID", CLIENT_CODE);
    60.             params.put("requestID", UUID.randomUUID().toString().replace("-", ""));
    61.             params.put("serviceCode", SERVICE_CODE);
    62.             params.put("timestamp", timeStamp);
    63.             params.put("msgData", msgData);
    64.             params.put("msgDigest", CallExpressServiceTools.getMsgDigest(msgData, timeStamp, CHECK_WORD));
    65.             System.out.println(params);
    66.             String res = HttpClientUtil.post(CALL_URL_PROD, params);
    67.             log.info("请求返回结果[{}]", res);
    68.             JSONObject jsonObj = JSON.parseObject(res);
    69.             if (jsonObj.containsKey("apiResultData")) {
    70.                 JSONObject json = jsonObj.getJSONObject("apiResultData");
    71.                 if (json.containsKey("msgData")) {
    72.                     json = json.getJSONObject("msgData").getJSONArray("routeResps").getJSONObject(0);
    73.                     if (json.containsKey("routes")) {
    74.                         jsonArray = json.getJSONArray("routes");
    75.                     }
    76.                 }
    77.             }
    78.         } catch (Exception e) {
    79.             log.error("顺丰查询出错[{}]", e.getMessage());
    80.         }
    81.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    82.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "remark", "acceptTime")));
    83.         return controller(expressSearchResponse, jsonArray, "remark", "acceptTime");
    84.     }
    85.  
    86. }

      例9：申通快递——>StoExpress 【引用申通SDK】

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import com.sto.link.request.LinkRequest;
    7. import com.sto.link.util.LinkUtils;
    8. import org.slf4j.Logger;
    9. import org.slf4j.LoggerFactory;
    10. import org.springframework.stereotype.Service;
    11.  
    12. import java.util.ArrayList;
    13. import java.util.List;
    14.  
    15. /**
    16.  * 申通
    17.  */
    18. @Service
    19. public class StoExpress extends ResponseController implements Express {
    20.     private static final Logger log = LoggerFactory.getLogger(StoExpress.class);
    21.     private static String url = "https://cloudinter-linkgatewayonline.sto.cn/gateway/link.do";
    22.     private static String api_name = "STO_TRACE_QUERY_COMMON";
    23.     private static String from_appkey = "ABCDEFGHIJKLMNO";
    24.     private static String from_code = "ABCDEFGHIJKLMNO";
    25.     private static String to_appkey = "sto_trace_query";
    26.     private static String to_code = "sto_trace_query";
    27.     private static String secretKey = "E10ADC3949BA59ABBE56E057F20F883E";
    28.  
    29.     @Override
    30.     public String expressCode() {
    31.         return "STO";
    32.     }
    33.  
    34.     @Override
    35.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    36.         log.info("申通快递查询参数[{}]", JSON.toJSONString(request));
    37.         JSONArray jsonArray = new JSONArray();
    38.         try {
    39.             LinkRequest data = new LinkRequest();
    40.             data.setFromAppkey(from_appkey);
    41.             data.setFromCode(from_code);
    42.             data.setToAppkey(to_appkey);
    43.             data.setToCode(to_code);
    44.             data.setApiName(api_name);
    45.             JSONObject jsonObject = new JSONObject();
    46.             List ll = new ArrayList<>();
    47.             ll.add(request.getLogisticsNo());
    48.             jsonObject.put("waybillNoList", ll);
    49.             data.setContent(jsonObject.toJSONString());
    50.             String res = LinkUtils.request(data, url, secretKey);
    51.             log.info("请求返回结果[{}]", res);
    52.             jsonArray = JSONObject.parseObject(res).getJSONObject("data").getJSONArray(request.getLogisticsNo());
    53.         } catch (Exception e) {
    54.             log.error("申通快递查询出错[{}]", e.getMessage());
    55.         }
    56.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    57.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "memo", "opTime")));
    58.         return controller(expressSearchResponse, jsonArray, "memo", "opTime");
    59.     }
    60. }

     例9：众邮快递——>ZyExpress 【引用众邮SDK】

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import com.jdwl.open.api.sdk.DefaultJdClient;
    5. import com.jdwl.open.api.sdk.JdClient;
    6. import com.jdwl.open.api.sdk.JdException;
    7. import com.jdwl.open.api.sdk.domain.zhongyouex.OrderTraceApi.CommonParam;
    8. import com.jdwl.open.api.sdk.request.zhongyouex.OrderFindTraceInfoByWaybillCodeLopRequest;
    9. import com.jdwl.open.api.sdk.response.zhongyouex.OrderFindTraceInfoByWaybillCodeResponse;
    10. import ExpressSearchRequest;
    11. import ExpressSearchResponse;
    12. import org.slf4j.Logger;
    13. import org.slf4j.LoggerFactory;
    14. import org.springframework.stereotype.Service;
    15.  
    16. /**
    17.  * 众邮
    18.  */
    19. @Service
    20. public class ZyExpress extends ResponseController implements Express {
    21.     private static final Logger log = LoggerFactory.getLogger(ZyExpress.class);
    22.     private static String serverUrl = "https://api.zhongyouex.com/routerjson";
    23.     private static String accessToken = "E10ADC3949BA59ABBE56E057F20F883E";
    24.     private static String appKey = "E10ADC3949BA59ABBE56E057F20F883E";
    25.     private static String appSecret = "E10ADC3949BA59ABBE56E057F20F883E";
    26.     private static String appCode = "EXPRESS_100";
    27.     private static String source = "1234";
    28.     private static String userCode = "zhangsan123";
    29.  
    30.     @Override
    31.     public String expressCode() {
    32.         return "ZY";
    33.     }
    34.  
    35.     @Override
    36.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    37.         log.info("众邮快递查询参数[{}]", JSON.toJSONString(request));
    38.         JSONArray jsonArray = new JSONArray();
    39.         try {
    40.             JdClient client = new DefaultJdClient(serverUrl, accessToken, appKey, appSecret);
    41.             OrderFindTraceInfoByWaybillCodeLopRequest lopRequest = new OrderFindTraceInfoByWaybillCodeLopRequest();
    42.             lopRequest.setWaybillCode(request.getLogisticsNo());
    43.             CommonParam commonParam = new CommonParam();
    44.             commonParam.setAppCode(appCode);
    45.             commonParam.setSource(source);
    46.             commonParam.setUserCode(userCode);
    47.             lopRequest.setCommonParam(commonParam);
    48.             OrderFindTraceInfoByWaybillCodeResponse response = client.execute(lopRequest);
    49.             log.info("请求返回结果[{}]", response.getMsg());
    50.             JSONObject jsonObject = JSONObject.parseObject(response.getMsg());
    51.             jsonArray = jsonObject.getJSONObject("response").getJSONObject("content").getJSONArray("data");
    52.         } catch (JdException e) {
    53.             log.error("众邮快递查询出错[{}]", e.getErrMsg());
    54.         }
    55.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    56.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "content", "operateTime")));
    57.         return controller(expressSearchResponse, jsonArray, "content", "operateTime");
    58.     }
    59. }

     例10：圆通快递——>YtoExpress

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import org.apache.commons.lang3.time.DateFormatUtils;
    7. import org.slf4j.Logger;
    8. import org.slf4j.LoggerFactory;
    9. import org.springframework.stereotype.Service;
    10.  
    11. import javax.annotation.Resource;
    12. import java.net.URLEncoder;
    13. import java.util.Date;
    14. import java.util.HashMap;
    15. import java.util.Map;
    16.  
    17. /**
    18.  * 圆通
    19.  */
    20. @Service
    21. public class YtoExpress extends ResponseController implements Express {
    22.     private static final Logger log = LoggerFactory.getLogger(YtoExpress.class);
    23.     private static String url = "http://openapi.yto.net.cn/service/waybill_query/v1/X1FKbA";
    24.     private static String user_id = "YTOTEST";
    25.     private static String app_key = "sF1Jzn";
    26.     private static String secret_key = "1QLlIZ";
    27.     private static String v = "1.01";
    28.     private static String method = "yto.Marketing.WaybillTrace";
    29.     @Resource
    30.     HttpClientUtils httpClientUtils;
    31.  
    32.     @Override
    33.     public String expressCode() {
    34.         return "YTO";
    35.     }
    36.  
    37.     @Override
    38.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) {
    39.         log.info("圆通快递查询参数[{}]", JSON.toJSONString(request));
    40.         JSONArray jsonArray = new JSONArray();
    41.         try {
    42.             JSONObject jsonObject = new JSONObject();
    43.             jsonObject.put("Number", request.getLogisticsNo());
    44.             String timestamp = DateFormatUtils.format(new Date(), "yyyy-mm-dd HH:mm:ss");
    45.             String sign = secret_key + "app_key" + app_key + "formatJSONmethod" + method + "timestamp"
    46.                     + timestamp + "user_id" + user_id + "v" + v;
    47.             sign = MD5.getInstance().getMD5String(sign).toUpperCase();
    48.             String params = "sign=" + sign + "&app_key=" + app_key + "&format=JSON&method=" + method + "×tamp="
    49.                     + timestamp + "&user_id=" + user_id + "&v=" + v + "¶m=" + URLEncoder.encode(jsonObject.toJSONString(), "UTF-8");
    50.             Map headers = new HashMap<>(1);
    51.             headers.put("Content-Type", "application/x-www-form-urlencoded");
    52.             String res = httpClientUtils.post(url, params, headers);
    53.             log.info("请求返回结果[{}]", res);
    54.             jsonArray = JSONObject.parseArray(res);
    55.         } catch (Exception e) {
    56.             log.error("圆通快递查询出错[{}]", e.getMessage());
    57.         }
    58.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    59.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "processInfo", "upload_Time")));
    60.         return controller(expressSearchResponse, jsonArray, "processInfo", "upload_Time");
    61.     }
    62. }

     例11：中通快递——>ZtoExpress【旧版】

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import org.slf4j.Logger;
    7. import org.slf4j.LoggerFactory;
    8. import org.springframework.stereotype.Component;
    9. import org.springframework.util.Base64Utils;
    10.  
    11. import javax.annotation.Resource;
    12. import java.net.URLEncoder;
    13. import java.security.NoSuchAlgorithmException;
    14. import java.util.HashMap;
    15. import java.util.Map;
    16.  
    17. /**
    18.  * 中通
    19.  */
    20. @Component
    21. public class ZtoExpress extends ResponseController implements Express {
    22.     private static final Logger log = LoggerFactory.getLogger(ZtoExpress.class);
    23.     private static String url = "https://japi.zto.com/traceInterfaceNewTraces";
    24.     private static String companyId = "e10adc3949ba59abbe56e057f20f883e";
    25.     private static String key = "abcdefghijkl";
    26.     private static String msg_type = "NEW_TRACES";
    27.     @Resource
    28.     HttpClientUtils httpClientUtils;
    29.  
    30.     @Override
    31.     public String expressCode() {
    32.         return "ZTO";
    33.     }
    34.  
    35.     @Override
    36.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) throws NoSuchAlgorithmException {
    37.         JSONArray jsonArray = null;
    38.         log.info("中通快递查询参数[{}]", JSON.toJSONString(request));
    39.         try {
    40.             //组建数据格式
    41.             String strToDigest = "data=['" + request.getLogisticsNo() + "']&company_id=" + companyId + "&msg_type=" + msg_type + key;
    42.             String dataDigest = Base64Utils.encodeToString(MD5.getInstance().hash(strToDigest));
    43.             String requestData = "data=" + URLEncoder.encode("['" + request.getLogisticsNo() + "']", "UTF-8") +
    44.                     "&company_id=" + companyId + "&msg_type=" + msg_type;
    45.             //拼接请求头
    46.             Map headers = new HashMap<>(3);
    47.             headers.put("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
    48.             headers.put("x-companyId", companyId);
    49.             headers.put("x-dataDigest", dataDigest);
    50.             //发送请求并接受返回
    51.             String res = httpClientUtils.post(url, requestData, headers);
    52.             //处理返回结果
    53.             log.info("请求返回结果[{}]", res);
    54.             JSONObject json = JSONObject.parseObject(res);
    55.             jsonArray = json.getJSONArray("data").getJSONObject(0).getJSONArray("traces");
    56.         } catch (Exception e) {
    57.             log.error("中通快递查询出错[{}]", e.getMessage());
    58.         }
    59.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    60.         log.info("请求返回[{}]", JSON.toJSONString(controller(expressSearchResponse, jsonArray, "desc", "scanDate")));
    61.         return controller(expressSearchResponse, jsonArray, "desc", "scanDate");
    62.     }
    63. }

    例12：中通快递——>ZtoExpress【新版】 

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONArray;
    3. import com.alibaba.fastjson.JSONObject;;
    4. import ExpressSearchRequest;
    5. import ExpressSearchResponse;
    6. import zop.EncryptionType;
    7. import zop.ZopClient;
    8. import zop.ZopPublicRequest;
    9. import org.slf4j.Logger;
    10. import org.slf4j.LoggerFactory;
    11. import org.springframework.stereotype.Component;
    12.  
    13. import java.io.IOException;
    14. import java.security.NoSuchAlgorithmException;
    15.  
    16. /**
    17.  * 中通
    18.  */
    19. @Component
    20. public class ZtoExpress extends ResponseController implements Express {
    21.     private static final Logger log = LoggerFactory.getLogger(ZtoExpress.class);
    22.     private static String url = "https://japi.zto.com/zto.merchant.waybill.track.query";
    23.     private static String appKey = "ea8a706c4c34a168abcde";
    24.     private static String appSecret = "827ccb0eea8a706c4c34a16891f84e7b";
    25.  
    26.     @Override
    27.     public String expressCode() {
    28.         return "ZTO";
    29.     }
    30.  
    31.     @Override
    32.     public ExpressSearchResponse logisticsSearch(ExpressSearchRequest request) throws NoSuchAlgorithmException {
    33.         JSONArray jsonArray = null;
    34.         log.info("中通快递查询参数[{}]", JSON.toJSONString(request));
    35.         ZopClient client = new ZopClient(appKey, appSecret);
    36.         ZopPublicRequest zopPublicRequest = new ZopPublicRequest();
    37.         String mobilePhone = request.getReceiverMobile().substring(request.getReceiverMobile().length() - 4);
    38.         zopPublicRequest.setBody("{\"billCode\":\"" + request.getLogisticsNo() + "\",\"mobilePhone\":\"" + mobilePhone + "\"}");
    39.         zopPublicRequest.setUrl(url);
    40.         zopPublicRequest.setBase64(true);
    41.         zopPublicRequest.setEncryptionType(EncryptionType.MD5);
    42.         zopPublicRequest.setTimestamp(null);
    43.         try {
    44.             String res = client.execute(zopPublicRequest);
    45.             //处理返回结果
    46.             log.info("请求返回结果[{}]", res);
    47.             JSONObject json = JSONObject.parseObject(res);
    48.             jsonArray = json.getJSONArray("result");
    49.             log.info("请求返回结果jsonArray[{}]", jsonArray);
    50.         } catch (IOException e) {
    51.             log.error("中通快递查询出错[{}]", e.getMessage());
    52.         }
    53.         ExpressSearchResponse expressSearchResponse = checkResult(jsonArray, request);
    54.         log.info("中通快递返回数据[{}]", JSON.toJSONString(controllerZto(expressSearchResponse, jsonArray, "desc", "scanDate")));
    55.         return controllerZto(expressSearchResponse, jsonArray, "desc", "scanDate");
    56.     }
    57. }

    zop ：中通快递新版所需公共资源包

     

    zop 之 EncryptionType 枚举类

    1. public enum EncryptionType {
    2.     MD5,
    3.     SHA256,
    4.     HmacSHA256
    5. }

     zop 之 HttpUtil 工具类

    1. import java.io.BufferedReader;
    2. import java.io.DataOutputStream;
    3. import java.io.IOException;
    4. import java.io.InputStreamReader;
    5. import java.net.HttpURLConnection;
    6. import java.net.URL;
    7. import java.nio.charset.Charset;
    8. import java.util.Map;
    9.  
    10. public class HttpUtil {
    11.     private static final int DEFAULT_TIMEOUT = 3000;
    12.  
    13.     public static String post(String interfaceUrl, Map headers, String queryString) throws IOException {
    14.         URL url = new URL(interfaceUrl);
    15.         HttpURLConnection con = (HttpURLConnection) url.openConnection();
    16.         con.setRequestMethod("POST");
    17.         con.setRequestProperty("Content-Type", "application/x-www-form-urlencoded; charset=utf-8");
    18.         con.setDoOutput(true);
    19.         con.setConnectTimeout(DEFAULT_TIMEOUT);
    20.         con.setReadTimeout(DEFAULT_TIMEOUT);
    21.         for (Map.Entry e : headers.entrySet()) {
    22.             con.setRequestProperty(e.getKey(), e.getValue());
    23.         }
    24.         DataOutputStream out = null;
    25.         BufferedReader in = null;
    26.         try {
    27.             out = new DataOutputStream(con.getOutputStream());
    28.             out.write(queryString.getBytes(Charset.forName("UTF-8")));
    29.             out.flush();
    30.             in = new BufferedReader(
    31.                     new InputStreamReader(con.getInputStream(), "UTF-8"));
    32.             String inputLine;
    33.             StringBuilder content = new StringBuilder();
    34.             while ((inputLine = in.readLine()) != null) {
    35.                 content.append(inputLine);
    36.             }
    37.             return content.toString();
    38.         } finally {
    39.             if (out != null) {
    40.                 try {
    41.                     out.close();
    42.                 } catch (Exception ignored) {
    43.                 }
    44.             }
    45.             if (in != null) {
    46.                 try {
    47.                     in.close();
    48.                 } catch (Exception ignored) {
    49.                 }
    50.             }
    51.         }
    52.     }
    53.  
    54.     public static String postJson(String interfaceUrl, Map headers, String json) throws IOException {
    55.         URL url = new URL(interfaceUrl);
    56.         HttpURLConnection con = (HttpURLConnection) url.openConnection();
    57.         con.setRequestMethod("POST");
    58.         con.setRequestProperty("Content-Type", "application/json; charset=utf-8");
    59.         con.setDoOutput(true);
    60.         con.setConnectTimeout(DEFAULT_TIMEOUT);
    61.         con.setReadTimeout(DEFAULT_TIMEOUT);
    62.         for (Map.Entry e : headers.entrySet()) {
    63.             con.setRequestProperty(e.getKey(), e.getValue());
    64.         }
    65.         DataOutputStream out = null;
    66.         BufferedReader in = null;
    67.         try {
    68.             out = new DataOutputStream(con.getOutputStream());
    69.             out.write(json.getBytes(Charset.forName("UTF-8")));
    70.             out.flush();
    71.             in = new BufferedReader(
    72.                     new InputStreamReader(con.getInputStream(), "UTF-8"));
    73.             String inputLine;
    74.             StringBuilder content = new StringBuilder();
    75.             while ((inputLine = in.readLine()) != null) {
    76.                 content.append(inputLine);
    77.             }
    78.             return content.toString();
    79.         } finally {
    80.             if (out != null) {
    81.                 try {
    82.                     out.close();
    83.                 } catch (Exception ignored) {
    84.                 }
    85.             }
    86.             if (in != null) {
    87.                 try {
    88.                     in.close();
    89.                 } catch (Exception ignored) {
    90.                 }
    91.             }
    92.         }
    93.     }
    94. }

      zop 之 ZopClient 工具类

    1. import java.io.IOException;
    2. import java.io.UnsupportedEncodingException;
    3. import java.net.URLEncoder;
    4. import java.util.HashMap;
    5. import java.util.Map;
    6.  
    7. public class ZopClient {
    8.     private final ZopProperties properties;
    9.  
    10.     public ZopClient(ZopProperties properties) {
    11.         this.properties = properties;
    12.     }
    13.  
    14.     public ZopClient(String appKey, String appSecret) {
    15.         this.properties = new ZopProperties(appKey, appSecret);
    16.     }
    17.  
    18.     public String execute(ZopPublicRequest request) throws IOException {
    19.         String jsonBody = request.getBody();
    20.         if (jsonBody == null) {
    21.             Map params = request.getParams();
    22.             StringBuilder queryBuilder = new StringBuilder();
    23.             StringBuilder strToDigestBuilder = new StringBuilder();
    24.             for (Map.Entry e : params.entrySet()) {
    25.                 strToDigestBuilder.append(e.getKey()).append("=").append(e.getValue()).append("&");
    26.                 queryBuilder.append(urlEncode(e.getKey())).append("=").append(urlEncode(e.getValue())).append("&");
    27.             }
    28.             String queryString = queryBuilder.substring(0, queryBuilder.length() - 1);
    29.             String strToDigest = strToDigestBuilder.substring(0, strToDigestBuilder.length() - 1);
    30.             strToDigest = strToDigest + properties.getKey();
    31.             Map headers = new HashMap();
    32.             headers.put("x-companyid", properties.getCompanyId());
    33.             headers.put("x-datadigest", ZopDigestUtil.digest(strToDigest, request.getBase64(), request.getEncryptionType(), request.getTimestamp(), request.getSecretKey()));
    34.             if (request.getTimestamp() != null) {
    35.                 headers.put("x-timestamp", String.valueOf(request.getTimestamp()));
    36.             }
    37.             return HttpUtil.post(request.getUrl(), headers, queryString);
    38.         } else {
    39.             Map headers = new HashMap<>();
    40.             String strToDigest = jsonBody + properties.getKey();
    41.             headers.put("x-companyid", properties.getCompanyId());
    42.             headers.put("x-datadigest", ZopDigestUtil.digest(strToDigest, request.getBase64(), request.getEncryptionType(), request.getTimestamp(), request.getSecretKey()));
    43.             if (request.getTimestamp() != null) {
    44.                 headers.put("x-timestamp", String.valueOf(request.getTimestamp()));
    45.             }
    46.             return HttpUtil.postJson(request.getUrl(), headers, jsonBody);
    47.         }
    48.     }
    49.  
    50.     private String urlEncode(String str) {
    51.         try {
    52.             return URLEncoder.encode(str, "UTF-8");
    53.         } catch (UnsupportedEncodingException e) {
    54.             return str;
    55.         }
    56.     }
    57. }

       zop 之 ZopDigestUtil 工具类

    1. import org.apache.commons.codec.binary.Base64;
    2. import org.apache.commons.codec.binary.Hex;
    3. import org.apache.commons.codec.digest.DigestUtils;
    4.  
    5. import javax.crypto.Mac;
    6. import javax.crypto.SecretKey;
    7. import javax.crypto.spec.SecretKeySpec;
    8. import java.nio.charset.StandardCharsets;
    9. import java.security.InvalidKeyException;
    10. import java.security.NoSuchAlgorithmException;
    11. import java.util.Map;
    12. import java.util.Objects;
    13. import java.util.concurrent.ConcurrentHashMap;
    14.  
    15. public class ZopDigestUtil {
    16.     private static final String HMAC_SHA_256 = "HmacSHA256";
    17.     private static final Map MAC_MAP = new ConcurrentHashMap<>();
    18.  
    19.     public static String digest(String str, Boolean isBase64, EncryptionType encryptionType, Long timestamp, String secretKey) {
    20.         if (timestamp != null) {
    21.             str = timestamp + str;
    22.         }
    23.         boolean base64 = isBase64 == null || isBase64;
    24.         switch (encryptionType) {
    25.             case SHA256:
    26.                 return base64 ? Base64.encodeBase64String(DigestUtils.sha256(str)) : DigestUtils.sha256Hex(str);
    27.             case HmacSHA256:
    28.                 return base64 ? Base64.encodeBase64String(hmacSha256(secretKey, str)) : hmacSha256Str(secretKey, str);
    29.             default:
    30.                 return base64 ? Base64.encodeBase64String(DigestUtils.md5(str)) : DigestUtils.md5Hex(str);
    31.         }
    32.     }
    33.  
    34.     public static String hmacSha256Str(String key, String body) {
    35.         return Hex.encodeHexString(hmacSha256(key, body));
    36.     }
    37.  
    38.     public static byte[] hmacSha256(String key, String body) {
    39.         if (Objects.isNull(key)) {
    40.             key = "";
    41.         }
    42.         Mac mac = MAC_MAP.get(key);
    43.         if (mac == null) {
    44.             try {
    45.                 mac = Mac.getInstance(HMAC_SHA_256);
    46.                 SecretKey secretKey = new SecretKeySpec(key.getBytes(StandardCharsets.UTF_8), HMAC_SHA_256);
    47.                 mac.init(secretKey);
    48.                 MAC_MAP.put(key, mac);
    49.             } catch (NoSuchAlgorithmException | InvalidKeyException e) {
    50.                 throw new RuntimeException(e);
    51.             }
    52.         }
    53.         return mac.doFinal(body.getBytes(StandardCharsets.UTF_8));
    54.     }
    55. }

       zop 之 ZopProperties 配置类

    1. public class ZopProperties {
    2.     private String companyId;
    3.     private String key;
    4.  
    5.     public ZopProperties() {
    6.     }
    7.  
    8.     public ZopProperties(String appKey, String appSecret) {
    9.         this.companyId = appKey;
    10.         this.key = appSecret;
    11.     }
    12.  
    13.     public String getCompanyId() {
    14.         return companyId;
    15.     }
    16.  
    17.     public void setCompanyId(String companyId) {
    18.         this.companyId = companyId;
    19.     }
    20.  
    21.     public String getKey() {
    22.         return key;
    23.     }
    24.  
    25.     public void setKey(String key) {
    26.         this.key = key;
    27.     }
    28. }

        zop 之 ZopPublicRequest 请求类

    1. import com.alibaba.fastjson.JSON;
    2. import com.alibaba.fastjson.JSONObject;
    3.  
    4. import java.util.HashMap;
    5. import java.util.Map;
    6.  
    7. public class ZopPublicRequest {
    8.  
    9.     private String url;
    10.  
    11.     private Map params = new HashMap();
    12.  
    13.     // 如果body有值，表示使用application/json的方式传值
    14.     private String body;
    15.  
    16.     /**
    17.      * 签名是否需要base64
    18.      */
    19.     private Boolean isBase64;
    20.  
    21.     /**
    22.      * 加密方式，MD5或者SHA256
    23.      */
    24.     private EncryptionType encryptionType;
    25.  
    26.     /**
    27.      * HmacSHA256加密key
    28.      */
    29.     private String secretKey;
    30.  
    31.     /**
    32.      * 时间戳，如果接口文档未标识使用时间戳请不要传值，否则会导致签名错误
    33.      */
    34.     private Long timestamp;
    35.  
    36.     public ZopPublicRequest() {
    37.     }
    38.  
    39.     public void setBody(String body) {
    40.         this.body = body;
    41.     }
    42.  
    43.  
    44.     public String getBody() {
    45.         return body;
    46.     }
    47.  
    48.     public void addParam(String k, String v) {
    49.         params.put(k, v);
    50.     }
    51.  
    52.     public void setData(String data) {
    53.         try {
    54.             JSONObject jsonObject = JSON.parseObject(data);
    55.             for (Map.Entry entry : jsonObject.entrySet()) {
    56.                 params.put(entry.getKey(), entry.getValue().toString());
    57.             }
    58.         } catch (Exception e) {
    59.             throw new RuntimeException("JSON格式不对,请检查数据", e);
    60.         }
    61.     }
    62.  
    63.     public void setDataObj(Map data) {
    64.         params.putAll(data);
    65.     }
    66.  
    67.     public void addParam(Map p) {
    68.         for (Map.Entry entry : p.entrySet()) {
    69.             params.put(entry.getKey(), entry.getValue());
    70.         }
    71.     }
    72.  
    73.     public String getUrl() {
    74.         return url;
    75.     }
    76.  
    77.     public void setUrl(String url) {
    78.         this.url = url;
    79.     }
    80.  
    81.     public Map getParams() {
    82.         return params;
    83.     }
    84.  
    85.     public void setParams(Map params) {
    86.         this.params = params;
    87.     }
    88.  
    89.     public Boolean getBase64() {
    90.         return isBase64;
    91.     }
    92.  
    93.     public void setBase64(Boolean base64) {
    94.         isBase64 = base64;
    95.     }
    96.  
    97.     public EncryptionType getEncryptionType() {
    98.         return encryptionType;
    99.     }
    100.  
    101.     public void setEncryptionType(EncryptionType encryptionType) {
    102.         this.encryptionType = encryptionType;
    103.     }
    104.  
    105.     public String getSecretKey() {
    106.         return secretKey;
    107.     }
    108.  
    109.     public void setSecretKey(String secretKey) {
    110.         this.secretKey = secretKey;
    111.     }
    112.  
    113.     public Long getTimestamp() {
    114.         return timestamp;
    115.     }
    116.  
    117.     public void setTimestamp(Long timestamp) {
    118.         this.timestamp = timestamp;
    119.     }
    120. }
  • 相关阅读:
    猜数字--
    2023全网最火的接口自动化框架对比 （建议收藏）
    软考高项——计算专题
    【元胞自动机】元胞自动机晶体生长【含Matlab源码 232期】
    FastJson解析对象出现 “$ref“:“$[0].portInfoBean“ 导致list数据错乱的解决方案
    每日一博 - 闲聊SQL Query Execution Order
    ZYNQ之FPGA学习----IIC协议驱动模块仿真实验
    全志F133（D1s）芯片 如何在Tina下进行显示旋转？
    这几个Python实战项目，让大家了解到它的神奇
    ubuntu 22.04安装cuda、cudnn、conda、pytorch
  • 原文地址：https://blog.csdn.net/netuser1937/article/details/126477495