springBoot + 工厂模式 实现 快递鸟、顺丰和快递100的物流查询
生活随笔
收集整理的這篇文章主要介紹了
springBoot + 工厂模式 实现 快递鸟、顺丰和快递100的物流查询
小編覺(jué)得挺不錯(cuò)的,現(xiàn)在分享給大家,幫大家做個(gè)參考.
前言：
在Spring Boot中實(shí)現(xiàn)快遞鳥、順豐和快遞100的物流查詢功能通常需要與它們提供的API進(jìn)行交互。當(dāng)然使用他們的API 我們是需要申請(qǐng)和注冊(cè)，從而去拿到 key 來(lái)進(jìn)行調(diào)用。所以為注冊(cè)的必須先進(jìn)行注冊(cè)，以下是他們的官網(wǎng)地址，可以快捷到達(dá)。
快遞鳥官網(wǎng)：快遞鳥 - 快遞查詢接口_免費(fèi)快遞查詢api接口 (kdniao.com)
順豐快遞官網(wǎng)：順豐開(kāi)放平臺(tái) (sf-express.com) 接口名為：物流軌跡查詢接口
快遞100官網(wǎng)：快遞物流接口文檔_電子面單接口文檔_快遞100api接口文檔 (kuaidi100.com)
為了實(shí)現(xiàn)這一功能，可以創(chuàng)建一個(gè)工廠類，用于封裝不同快遞查詢服務(wù)的邏輯，并為每個(gè)服務(wù)創(chuàng)建一個(gè)實(shí)現(xiàn)類。以下是一個(gè)簡(jiǎn)單的示例，演示如何在Spring Boot中創(chuàng)建這些類和實(shí)現(xiàn)快遞查詢功能。
1. 創(chuàng)建工廠類
首先，創(chuàng)建一個(gè)工廠類，該類根據(jù)不同的快遞服務(wù)創(chuàng)建對(duì)應(yīng)的查詢實(shí)例。
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. 創(chuàng)建接口和實(shí)現(xiàn)類
接下來(lái)，為每個(gè)快遞服務(wù)創(chuàng)建一個(gè)接口和實(shí)現(xiàn)類，分別實(shí)現(xiàn)快遞查詢的邏輯。以下是示例代碼：
快遞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) {
// 調(diào)用Kuaidi100的API，查詢物流信息
// 以下是偽代碼，實(shí)際中需要調(diào)用Kuaidi100的API并解析返回的數(shù)據(jù)
String apiUrl = "https://api.kuaidi100.com/query";
String apiKey = "your_api_key";
// 構(gòu)建請(qǐng)求參數(shù)
Map<String, String> params = new HashMap<>();
params.put("com", "your_com_code"); // 快遞公司編碼
params.put("num", trackingNumber); // 快遞單號(hào)
params.put("key", apiKey); // API密鑰,可以使用@Vaer注解配置在yaml
// 發(fā)送HTTP請(qǐng)求并獲取響應(yīng)
ResponseEntity<String> response = restTemplate.getForEntity(apiUrl, String.class, params);
if (response.getStatusCode() == HttpStatus.OK) {
// 解析返回的JSON數(shù)據(jù)，構(gòu)建ExpressInfo對(duì)象
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數(shù)據(jù)并構(gòu)建ExpressInfo對(duì)象的邏輯
// 以下是示例代碼，實(shí)際中需要根據(jù)API返回的數(shù)據(jù)結(jié)構(gòu)進(jìn)行解析
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) {
// 調(diào)用快遞鳥的API，查詢物流信息
// 以下是偽代碼，實(shí)際中需要調(diào)用Kdniao的API并解析返回的數(shù)據(jù)
String apiUrl = "https://api.kdniao.com/Ebusiness/EbusinessOrderHandle.aspx";
String apiKey = "your_api_key";
// 構(gòu)建請(qǐng)求參數(shù)
MultiValueMap<String, String> params = new LinkedMultiValueMap<>();
params.add("ShipperCode", "your_shipper_code"); // 快遞公司編碼
params.add("LogisticCode", trackingNumber); // 快遞單號(hào)
params.add("RequestType", "1002"); // 查詢方式
params.add("apiKey", apiKey);
// 發(fā)送HTTP請(qǐng)求并獲取響應(yīng)
ResponseEntity<String> response = restTemplate.postForEntity(apiUrl, params, String.class);
if (response.getStatusCode() == HttpStatus.OK) {
// 解析返回的XML數(shù)據(jù)，構(gòu)建ExpressInfo對(duì)象
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數(shù)據(jù)并構(gòu)建ExpressInfo對(duì)象的邏輯
// 以下是示例代碼，實(shí)際中需要根據(jù)API返回的數(shù)據(jù)結(jié)構(gòu)進(jìn)行解析
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數(shù)據(jù)并構(gòu)建ExpressInfo對(duì)象
ExpressInfo expressInfo = new ExpressInfo();
// 根據(jù)XML結(jié)構(gòu)解析數(shù)據(jù)并設(shè)置到ExpressInfo對(duì)象中
return expressInfo;
}
}
順豐 (Shunfeng)
import org.springframework.stereotype.Service;
@Service
public class ShunfengService implements ExpressService {
@Override
public ExpressInfo queryExpress(String trackingNumber) {
// 調(diào)用順豐的API，查詢物流信息
// 以下是偽代碼，實(shí)際中需要調(diào)用順豐的API并解析返回的數(shù)據(jù)
String apiUrl = "https://api.sf-express.com/std/service";
String apiKey = "your_api_key";
// 構(gòu)建請(qǐng)求參數(shù)
Map<String, Object> params = new HashMap<>();
params.put("tracking_number", trackingNumber);
params.put("api_key", apiKey);
// 發(fā)送HTTP請(qǐng)求并獲取響應(yīng)
ResponseEntity<String> response = restTemplate.postForEntity(apiUrl, params, String.class);
if (response.getStatusCode() == HttpStatus.OK) {
// 解析返回的JSON數(shù)據(jù)，構(gòu)建ExpressInfo對(duì)象
String responseBody = response.getBody();
// 解析JSON數(shù)據(jù)并構(gòu)建ExpressInfo對(duì)象
ExpressInfo expressInfo = parseShunfengResponse(responseBody);
return expressInfo;
} else {
throw new RuntimeException("Failed to query Shunfeng: " + response.getStatusCode());
}
}
private ExpressInfo parseShunfengResponse(String responseBody) {
// 解析順豐API響應(yīng)的JSON數(shù)據(jù)
try {
// 解析JSON數(shù)據(jù)，具體字段和格式需要根據(jù)順豐API文檔來(lái)定義
ObjectMapper objectMapper = new ObjectMapper();
JsonNode root = objectMapper.readTree(responseBody);
// 檢查響應(yīng)狀態(tài)
String status = root.get("status").asText();
if ("OK".equals(status)) {
// 從響應(yīng)中提取物流信息
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();
// 構(gòu)建ExpressInfo對(duì)象
ExpressInfo expressInfo = new ExpressInfo();
expressInfo.setTrackingNumber(trackingNumber);
expressInfo.setDeliveryStatus(deliveryStatus);
expressInfo.setLastUpdateTime(lastUpdateTime);
return expressInfo;
} else {
// 響應(yīng)中包含錯(cuò)誤信息
String errorMsg = root.get("message").asText();
throw new RuntimeException("Shunfeng API error: " + errorMsg);
}
} catch (IOException e) {
// 處理解析錯(cuò)誤
throw new RuntimeException("Failed to parse Shunfeng API response", e);
}
}
}
3. 創(chuàng)建接口
創(chuàng)建一個(gè)通用的快遞查詢服務(wù)接口，以便在工廠類中使用。
public interface ExpressService {
/**
* 根據(jù)快遞單號(hào)查詢快遞物流信息
* @param trackingNumber 快遞單號(hào)
* @return 快遞物流信息
*/
ExpressInfo queryExpress(String trackingNumber);
}
4. 使用工廠類查詢物流信息
在你的控制器或服務(wù)類中，使用工廠類來(lái)獲取適當(dāng)?shù)目爝f查詢服務(wù)實(shí)例，并查詢物流信息。
@RestController
public class ExpressController {
private final ExpressServiceFactory expressServiceFactory;
@Autowired
public ExpressController(ExpressServiceFactory expressServiceFactory) {
this.expressServiceFactory = expressServiceFactory;
}
/**
* 根據(jù)快遞類型和單號(hào)查詢快遞物流信息
* @param provider 快遞類型
* @param trackingNumber 快遞單號(hào)
* @return 快遞物流信息
*/
@GetMapping("/query-express")
public ExpressInfo queryExpress(@RequestParam String provider, @RequestParam String trackingNumber) {
ExpressService expressService = expressServiceFactory.getExpressService(provider);
return expressService.queryExpress(trackingNumber);
}
}
到這里代碼就寫好！！！接下來(lái)就可以進(jìn)行測(cè)試或者前端調(diào)用接口！！！
如果對(duì)你有用就點(diǎn)個(gè)贊或者關(guān)注一下吧！
總結(jié)
以上是生活随笔為你收集整理的springBoot + 工厂模式 实现 快递鸟、顺丰和快递100的物流查询的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。
- 上一篇： 工厂方法模式
- 下一篇： 微信小程序文件预览和下载-文件系统