springBoot + 工廠模式 實現 快遞鳥、順豐和快遞100的物流查詢

来源:https://www.cnblogs.com/blbl-blog/archive/2023/11/25/17856150.html
-Advertisement-
Play Games

前言： 在Spring Boot中實現快遞鳥、順豐和快遞100的物流查詢功能通常需要與它們提供的API進行交互。當然使用他們的API 我們是需要申請和註冊，從而去拿到 key 來進行調用。所以為註冊的必須先進行註冊，以下是他們的官網地址，可以快捷到達。 快遞鳥官網：快遞鳥 - 快遞查詢介面_免費快遞 ...


前言：

在Spring Boot中實現快遞鳥、順豐和快遞100的物流查詢功能通常需要與它們提供的API進行交互。當然使用他們的API 我們是需要申請和註冊，從而去拿到 key 來進行調用。所以為註冊的必須先進行註冊，以下是他們的官網地址，可以快捷到達。

快遞鳥官網：快遞鳥 - 快遞查詢介面_免費快遞查詢api介面 (kdniao.com)

順豐快遞官網：順豐開放平臺 (sf-express.com) 介面名為：物流軌跡查詢介面

快遞100官網：快遞物流介面文檔_電子面單介面文檔_快遞100api介面文檔 (kuaidi100.com)

為了實現這一功能，可以創建一個工廠類，用於封裝不同快遞查詢服務的邏輯，併為每個服務創建一個實現類。以下是一個簡單的示例，演示如何在Spring Boot中創建這些類和實現快遞查詢功能。

1. 創建工廠類

首先，創建一個工廠類，該類根據不同的快遞服務創建對應的查詢實例。

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

@Service
public class ExpressServiceFactory {

    private final Kuaidi100Service kuaidi100Service;
    private final KdniaoService kdniaoService;
    private final ShunfengService shunfengService;

    @Autowired
    public ExpressServiceFactory(Kuaidi100Service kuaidi100Service, KdniaoService kdniaoService, ShunfengService shunfengService) {
        this.kuaidi100Service = kuaidi100Service;
        this.kdniaoService = kdniaoService;
        this.shunfengService = shunfengService;
    }

    public ExpressService getExpressService(String provider) {
        switch (provider) {
            case "kuaidi100":
                return kuaidi100Service;
            case "kdniao":
                return kdniaoService;
            case "shunfeng":
                return shunfengService;
            default:
                throw new IllegalArgumentException("Invalid provider: " + provider);
        }
    }
}

2. 創建介面和實現類

接下來，為每個快遞服務創建一個介面和實現類，分別實現快遞查詢的邏輯。以下是示例代碼：

快遞100 (Kuaidi100)

import org.springframework.stereotype.Service;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import java.util.Map;

@Service
public class Kuaidi100Service implements ExpressService {
    
    @Autowired
    private RestTemplate restTemplate;

    @Override
    public ExpressInfo queryExpress(String trackingNumber) {
        // 調用Kuaidi100的API，查詢物流信息
        // 以下是偽代碼，實際中需要調用Kuaidi100的API並解析返回的數據
        String apiUrl = "https://api.kuaidi100.com/query";
        String apiKey = "your_api_key";
        
        // 構建請求參數
        Map<String, String> params = new HashMap<>();
        params.put("com", "your_com_code");  // 快遞公司編碼
        params.put("num", trackingNumber);   // 快遞單號
        params.put("key", apiKey);           // API密鑰,可以使用@Vaer註解配置在yaml
        
        // 發送HTTP請求並獲取響應
        ResponseEntity<String> response = restTemplate.getForEntity(apiUrl, String.class, params);
        
        if (response.getStatusCode() == HttpStatus.OK) {
            // 解析返回的JSON數據，構建ExpressInfo對象
            String responseBody = response.getBody();
            ExpressInfo expressInfo = parseKuaidi100Response(responseBody);
            return expressInfo;
        } else {
            throw new RuntimeException("Failed to query Kuaidi100: " + response.getStatusCode());
        }
    }

    private ExpressInfo parseKuaidi100Response(String responseBody) {
        // 解析Kuaidi100返回的JSON數據並構建ExpressInfo對象的邏輯
        // 以下是示例代碼，實際中需要根據API返回的數據結構進行解析
        ObjectMapper objectMapper = new ObjectMapper();
        try {
            Kuaidi100Response kuaidi100Response = objectMapper.readValue(responseBody, Kuaidi100Response.class);
            ExpressInfo expressInfo = new ExpressInfo();
            expressInfo.setTrackingNumber(kuaidi100Response.getTrackingNumber());
            expressInfo.setLogisticsStatus(kuaidi100Response.getLogisticsStatus());
            expressInfo.setLogisticsDetail(kuaidi100Response.getLogisticsDetail());
            return expressInfo;
        } catch (IOException e) {
            throw new RuntimeException("Failed to parse Kuaidi100 response", e);
        }
    }
}

快遞鳥 (Kdniao)

import org.springframework.stereotype.Service;
import org.springframework.http.ResponseEntity;
import org.springframework.web.client.RestTemplate;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.util.MultiValueMap;

@Service
public class KdniaoService implements ExpressService {

    @Autowired
    private RestTemplate restTemplate;

    @Override
    public ExpressInfo queryExpress(String trackingNumber) {
        // 調用快遞鳥的API，查詢物流信息
        // 以下是偽代碼，實際中需要調用Kdniao的API並解析返回的數據
        String apiUrl = "https://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx";
        String apiKey = "your_api_key";

        // 構建請求參數
        MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
        params.add("ShipperCode", "your_shipper_code");  // 快遞公司編碼
        params.add("LogisticCode", trackingNumber);       // 快遞單號
        params.add("RequestType", "1002");               // 查詢方式
        params.add("apiKey", apiKey);

        // 發送HTTP請求並獲取響應
        ResponseEntity<String> response = restTemplate.postForEntity(apiUrl, params, String.class);

        if (response.getStatusCode() == HttpStatus.OK) {
            // 解析返回的XML數據，構建ExpressInfo對象
            String responseBody = response.getBody();
            ExpressInfo expressInfo = parseKdniaoResponse(responseBody);
            return expressInfo;
        } else {
            throw new RuntimeException("Failed to query Kdniao: " + response.getStatusCode());
        }
    }

    private ExpressInfo parseKdniaoResponse(String responseBody) {
        // 解析Kdniao返回的XML數據並構建ExpressInfo對象的邏輯
        // 以下是示例代碼，實際中需要根據API返回的數據結構進行解析
        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
        DocumentBuilder builder;
        Document doc;

        try {
            builder = factory.newDocumentBuilder();
            doc = builder.parse(new InputSource(new StringReader(responseBody)));
        } catch (Exception e) {
            throw new RuntimeException("Failed to parse Kdniao response", e);
        }

        // 解析XML數據並構建ExpressInfo對象
        ExpressInfo expressInfo = new ExpressInfo();
        // 根據XML結構解析數據並設置到ExpressInfo對象中
        return expressInfo;
    }
}

順豐 (Shunfeng)

import org.springframework.stereotype.Service;

@Service
public class ShunfengService implements ExpressService {

    @Override
    public ExpressInfo queryExpress(String trackingNumber) {
        // 調用順豐的API，查詢物流信息
        // 以下是偽代碼，實際中需要調用順豐的API並解析返回的數據
        String apiUrl = "https://api.sf-express.com/std/service";
        String apiKey = "your_api_key";
        
        // 構建請求參數
        Map<String, Object> params = new HashMap<>();
        params.put("tracking_number", trackingNumber);
        params.put("api_key", apiKey);
        
        // 發送HTTP請求並獲取響應
        ResponseEntity<String> response = restTemplate.postForEntity(apiUrl, params, String.class);
        
        if (response.getStatusCode() == HttpStatus.OK) {
            // 解析返回的JSON數據，構建ExpressInfo對象
            String responseBody = response.getBody();
            // 解析JSON數據並構建ExpressInfo對象
            ExpressInfo expressInfo = parseShunfengResponse(responseBody);
            return expressInfo;
        } else {
            throw new RuntimeException("Failed to query Shunfeng: " + response.getStatusCode());
        }
    }

    private ExpressInfo parseShunfengResponse(String responseBody) {
        // 解析順豐API響應的JSON數據
        try {
            // 解析JSON數據，具體欄位和格式需要根據順豐API文檔來定義
            ObjectMapper objectMapper = new ObjectMapper();
            JsonNode root = objectMapper.readTree(responseBody);

            // 檢查響應狀態
            String status = root.get("status").asText();
            if ("OK".equals(status)) {
                // 從響應中提取物流信息
                JsonNode dataNode = root.get("data");
                String trackingNumber = dataNode.get("tracking_number").asText();
                String deliveryStatus = dataNode.get("delivery_status").asText();
                String lastUpdateTime = dataNode.get("last_update_time").asText();

                // 構建ExpressInfo對象
                ExpressInfo expressInfo = new ExpressInfo();
                expressInfo.setTrackingNumber(trackingNumber);
                expressInfo.setDeliveryStatus(deliveryStatus);
                expressInfo.setLastUpdateTime(lastUpdateTime);

                return expressInfo;
            } else {
                // 響應中包含錯誤信息
                String errorMsg = root.get("message").asText();
                throw new RuntimeException("Shunfeng API error: " + errorMsg);
            }
        } catch (IOException e) {
            // 處理解析錯誤
            throw new RuntimeException("Failed to parse Shunfeng API response", e);
        }
    }
}

3. 創建介面

創建一個通用的快遞查詢服務介面，以便在工廠類中使用。

public interface ExpressService {

    /**
     * 根據快遞單號查詢快遞物流信息
     * @param trackingNumber  快遞單號
     * @return 快遞物流信息
     */
    ExpressInfo queryExpress(String trackingNumber);
}

4. 使用工廠類查詢物流信息

在你的控制器或服務類中，使用工廠類來獲取適當的快遞查詢服務實例，並查詢物流信息。

@RestController
public class ExpressController {

    private final ExpressServiceFactory expressServiceFactory;

    @Autowired
    public ExpressController(ExpressServiceFactory expressServiceFactory) {
        this.expressServiceFactory = expressServiceFactory;
    }


     /**
     * 根據快遞類型和單號查詢快遞物流信息
     * @param provider 快遞類型
     * @param trackingNumber  快遞單號
     * @return 快遞物流信息
     */
    @GetMapping("/query-express")
    public ExpressInfo queryExpress(@RequestParam String provider, @RequestParam String trackingNumber) {
        ExpressService expressService = expressServiceFactory.getExpressService(provider);
        return expressService.queryExpress(trackingNumber);
    }
}

到這裡代碼就寫好！！！接下來就可以進行測試或者前端調用介面！！！

如果對你有用就點個贊或者關註一下吧！


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 第九單元 連接查詢
    請問上圖中顯示的數據是一張表中的嗎？ 1. 連接查詢的分類 內連接 外連接（左外連接，右外連接，全連接） 自連接 交差連接（不講） 2. 內連接 註意:Join 與 inner join等效(預設為內連接) 語法格式： select 欄位列表 from 表1 inner join 表2 on 表1. ...
  • MySQL Group by 優化查詢
    Group by 未加索引 使用的是臨時表，加文件排序（數據量小用記憶體排序） 加個索引（一般是聯合索引） 註意：這裡加的索引一般不會僅僅是group by後面的欄位索引（大多數多少條件是一個以該欄位開頭聯合索引，方便使用覆蓋索引或者索引下推）。如果該欄位是一個varchar類型，最好加個int冗餘字 ...
  • 第八單元 嵌套查詢
    什麼時候要使用嵌套查詢？ 學生信息表： 學生編號姓名班級Id電話性別生日 180325011 任我行 5 13823204456 男 1999-09-09 180325012 張三 4 13823204452 女 1998-08-08 180325013 李四 2 18899251152 男 199 ...
  • 小天才手錶系統指南
    ，： 小天才手錶系統指南（僅限Z6及以下舊款小天才主流機型）強烈推薦使用PDF版本閱讀 【 聲明】允許規範轉載並說明來源，不可用於商業用途。 【 重要提示】本教程配套其他up的講解視頻 點擊觀看 【 支持機型】降級和ROOT：Z2 Z3 Z5A/PRO/Q Z6（不含巔峰版、Z6A） → Z7以及更 ...
  • 記錄--求你了，別再說不會JSONP了
    這裡給大家分享我在網上總結出來的一些知識，希望對大家有所幫助 JSONP是一種很遠古用來解決跨域問題的技術，當然現在實際工作當中很少用到該技術了，但是很多同學在找工作面試過程中還是經常被問到，本文將帶您深入瞭解JSONP的工作原理、使用場景及安全註意事項，讓您輕鬆掌握JSONP。 JSONP是什麼？ ...
  • [JS] 事件匯流排
    事件匯流排是對發佈-訂閱模式的一種實現。 發佈-訂閱模式定義對象間的一種一對多的依賴關係，當一個對象的狀態發生改變時，所有依賴於它的對象都將得到通知。 發佈-訂閱模式實現了松耦合，發佈者不是直接將消息發送給訂閱者，而是經過了一個中間的代理，事件匯流排就是一種中間代理的實現。 ...
  • 大數據分析/機器學習基礎之matplotlib繪圖篇
    matplotlib是基於python生態開發的一個可視化繪圖庫，它的出現讓python在數據分析及機器學習方面占了重要的一部分，目前很多數據分析及機器學習相關方面的工程都有使用到這個庫，並且由於其簡單易用，安裝簡單等方面的優勢深得廣大開發者的喜愛。 ...
  • 15、SpringMVC之常用組件及執行流程
    15.1、常用組件 15.1.1、 DispatcherServlet DispatcherServlet 是前端控制器，由框架提供，不需要工程師開發； 作用：統一處理請求和響應，整個流程式控制制的中心，由它調用其它組件處理用戶的請求。 15.1.2、HandlerMapping HandlerMapp ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發（一）：使用.NET MAUI開發第一個安卓APP
    移動開發（一）：使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說，近來想嘗試開發一款安卓APP，考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP，畢竟是使用Visual Studio開發工具，使用起來也比較的順手，結合微軟官方的教程進行了安卓 ...
  • wpf ToggleButton選中效果和一個登錄界面
    前言 QuestPDF 是一個開源 .NET 庫，用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫，它徹底改變了我們生成 PDF 文檔的方 ...
  • 彈幕樹洞項目功能新增篇
    項目地址 項目後端地址： https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址： ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址： http://tree ...
  • 第27篇 sqlserver2022詳細安裝步驟
    話不多說，直接開乾 一.下載 1.官方鏈接下載： https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe，運行開始下載SQL server； 二. ...
  • .NET 開源高性能 MQTT 類庫
    前言 隨著物聯網（IoT）技術的迅猛發展，MQTT（消息隊列遙測傳輸）協議憑藉其輕量級和高效性，已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫，為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog文檔翻譯系列（六） - 可用的接收器、增強器、格式化輸出
    Serilog支持多種接收器用於日誌存儲，增強器用於添加屬性，LogContext管理動態屬性，支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項，適用於不同需求。 ...
  • 警惕 Visual Studio 屬性求值副作用導致邏輯不符合預期
    目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據，爬取信息時需要模擬瀏覽器行為，否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下： 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • [使用目前最新版]HybridCLR6.9.0+YooAsset2.2.4實現純C# Unity熱更新方案 (一)
    1.前言 什麼是熱更新 游戲或者軟體更新時，無需重新下載客戶端進行安裝，而是在應用程式啟動的情況下，在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR，Xlua，ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles，Addressable， ...
  • 在 ASP.NET Core Web API 中使用操作篩選器統一處理通用操作
    本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺，其實像阿裡雲，騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後，它會送 ...
  • 第28篇 如何.net中實現高效可靠數據同步api
    通過以下方式可以高效，並保證數據同步的可靠性 1.API設計 使用RESTful設計，確保API端點明確，並使用適當的HTTP方法（如POST用於創建，PUT用於更新）。 設計清晰的請求和響應模型，以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證，確保接收到的數據符合預期格 ...
所有分類