DeXun/klp-oa
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

feat(wms): 添加物流预览和快递问题相关功能

Browse Source 
- 新增物流预览和快递问题相关的实体类、Mapper、Service和Controller
- 实现物流预览列表查询、导出、详情获取、新增、修改和删除功能
- 实现快递问题列表查询、详情获取、新增、修改和删除功能
- 添加百世、顺丰、申通快递的路由查询工具类
- 更新pom.xml，添加fastjson2等依赖
- 修改application-stage.yml，禁用xxl-job
This commit is contained in:
Joshi
2025-08-11 18:06:37 +08:00
parent 542b481155
commit 1cd1699bf3
40 changed files with 3321 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

156
klp-wms/src/main/java/com/klp/utils/BestRouteQueryUtil.java Normal file
View File

@@ -0,0 +1,156 @@
package com.klp.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.klp.domain.vo.WmsExpressVo;
import org.apache.commons.lang3.StringUtils;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.util.Arrays;
public class BestRouteQueryUtil {
// 百世开放平台 partnerID
private static final String PARTNER_ID = "7285";
// 百世开放平台接口地址（请替换为实际地址）
private static final String API_URL = "http://openapi.800best.com/api-server/ky/api/process";
// 百世开放平台 partnerKey
private static final String PARTNER_KEY = "NMGA0BQI";
// 固定参数
private static final String SERVICE_TYPE = "KY_TRACE_QUERY";
/**
* 查询百世快递路由
* @param mailNo 运单号
* @return 查询结果WmsExpressVo
*/
public static WmsExpressVo queryRoute(String mailNo) {
try {
// 1. 构造业务数据bizData
JSONObject bizData = new JSONObject();
bizData.put("logisticCompanyID", "BESTQJT");
bizData.put("codes", Arrays.asList(mailNo));
String bizDataStr = bizData.toJSONString();
// 2. 生成签名（签名前不做URLEncode）
String sign = genSign(bizDataStr, PARTNER_KEY);
// 3. 拼接表单参数（此处做URLEncode）
StringBuilder formParams = new StringBuilder();
formParams.append("partnerID=").append(URLEncoder.encode(PARTNER_ID, "UTF-8"));
formParams.append("&serviceType=").append(URLEncoder.encode(SERVICE_TYPE, "UTF-8"));
formParams.append("&sign=").append(URLEncoder.encode(sign, "UTF-8"));
formParams.append("&bizData=").append(URLEncoder.encode(bizDataStr, "UTF-8"));
String formBody = formParams.toString();
// 4. 发送POST请求（表单格式，UTF-8编码）
return doPost(API_URL, formBody);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 百世签名生成方式：MD5(bizData + partnerKey)，再转大写
*/
private static String genSign(String bizData, String partnerKey) throws Exception {
String toSign = bizData + partnerKey;
MessageDigest md5 = MessageDigest.getInstance("MD5");
md5.update(toSign.getBytes("UTF-8"));
byte[] digest = md5.digest();
StringBuilder sb = new StringBuilder();
for (byte b : digest) {
sb.append(String.format("%02x", b));
}
return sb.toString();
}
/**
* 发送POST请求（表单格式，UTF-8编码）
*/
private static WmsExpressVo doPost(String urlStr, String formBody) throws Exception {
URL url = new URL(urlStr);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("POST");
conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
conn.setDoOutput(true);
try (OutputStream os = conn.getOutputStream()) {
os.write(formBody.getBytes(StandardCharsets.UTF_8));
}
int code = conn.getResponseCode();
if (code == 200) {
try (BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8))) {
StringBuilder sb = new StringBuilder();
String line;
while ((line = br.readLine()) != null) {
sb.append(line);
}
return parseData(sb.toString());
}
} else {
throw new RuntimeException("HTTP请求失败，状态码：" + code);
}
}
/**
* 解析百世快递返回数据，只取第一个轨迹的acceptTime和remark
*/
public static WmsExpressVo parseData(String result) {
if (StringUtils.isBlank(result)) {
System.out.println("返回结果为空");
return null;
}
try {
JSONObject json = JSON.parseObject(result);
Boolean success = json.getBoolean("result");
if (success == null || !success) {
System.out.println("查询失败：" + json.getString("resultInfo"));
return null;
}
JSONArray orderTraceList = json.getJSONArray("orderTraceList");
if (orderTraceList == null || orderTraceList.isEmpty()) {
System.out.println("无轨迹信息");
return null;
}
// 只取第一个轨迹的最后一个步骤
JSONObject orderTrace = orderTraceList.getJSONObject(0);
JSONArray steps = orderTrace.getJSONArray("steps");
if (steps == null || steps.isEmpty()) {
System.out.println("无轨迹步骤信息");
return null;
}
JSONObject step = steps.getJSONObject(steps.size() - 1);
WmsExpressVo vo = new WmsExpressVo();
vo.setExpressCode(orderTrace.getString("code"));
vo.setFirstStatusName(step.getString("remark"));
String acceptTimeStr = step.getString("acceptTime");
if (acceptTimeStr != null) {
// 假设格式为 yyyy-MM-dd HH:mm:ss
try {
vo.setAcceptTime(java.sql.Timestamp.valueOf(acceptTimeStr));
} catch (Exception e) {
vo.setAcceptTime(null);
}
}
return vo;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
// main方法测试
public static void main(String[] args) {
String mailNo = "80004559434";
WmsExpressVo vo = queryRoute(mailNo);
System.out.println(vo);
}
}

216
klp-wms/src/main/java/com/klp/utils/SfRouteQueryUtil.java Normal file
View File

@@ -0,0 +1,216 @@
package com.klp.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.klp.common.utils.DateUtils;
import com.klp.domain.vo.WmsExpressVo;
import org.apache.commons.lang3.StringUtils;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.security.MessageDigest;
import java.util.*;
/**
* 顺丰路由地址查询工具
*/
public class SfRouteQueryUtil {
// 顺丰开放平台 partnerID
private static final String PARTNER_ID = "YIX65G10";
// 顺丰开放平台接口地址
private static final String API_URL = "https://bspgw.sf-express.com/std/service";
// 顺丰开放平台 checkWord
private static final String CHECK_WORD = "PkJL4cpEQIUuV1goWvhIznqthletmddX";
// 顺丰OAuth认证
private static final String OAUTH_URL = "https://sfapi.sf-express.com/oauth2/accessToken";
private static final String GRANT_TYPE = "password";
/**
* 查询顺丰路由
* @param mailNo 顺丰运单号
* @return 查询结果JSON
*/
public static String queryRoute(String mailNo,String phoneNumber) {
List<String> mailNos = Arrays.asList(mailNo);
try {
// 1. 构造业务数据msgData
JSONObject msgData = new JSONObject();
msgData.put("language", "zh-CN");
msgData.put("trackingType", "1"); // 1:运单号 2:订单号
msgData.put("methodType", "1"); // 1:标准路由
msgData.put("trackingNumber", mailNos);
msgData.put("checkPhoneNo", StringUtils.right(phoneNumber, 4));
String msgDataStr = msgData.toJSONString();
System.out.println(msgDataStr);
// 2. 公共参数
String requestID = UUID.randomUUID().toString().replaceAll("-", "");
String serviceCode = "EXP_RECE_SEARCH_ROUTES";
String timestamp = String.valueOf(System.currentTimeMillis());
// String msgDigest = genSign(msgDataStr, timestamp, CHECK_WORD);
// System.out.println(msgDigest);
String accessToken = oAuth();
System.out.println(accessToken);
// 3. 拼接表单参数
StringBuilder formParams = new StringBuilder();
formParams.append("partnerID=").append(URLEncoder.encode(PARTNER_ID, "UTF-8"));
formParams.append("&requestID=").append(URLEncoder.encode(requestID, "UTF-8"));
formParams.append("&serviceCode=").append(URLEncoder.encode(serviceCode, "UTF-8"));
formParams.append("&timestamp=").append(URLEncoder.encode(timestamp, "UTF-8"));
formParams.append("&accessToken=").append(URLEncoder.encode(accessToken, "UTF-8"));
formParams.append("&msgData=").append(URLEncoder.encode(msgDataStr, "UTF-8"));
String formBody = formParams.toString();
System.out.println(formBody);
// 4. 发送POST请求
return doPost(API_URL, formBody);
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 顺丰msgDigest生成方式：Base64(MD5(URLEncode(msgData+timestamp+partnerId+checkWord)))
*/
private static String genSign(String msgData, String timestamp, String checkWord) throws Exception {
String toVerifyText = msgData + timestamp + checkWord;
MessageDigest md5 = MessageDigest.getInstance("MD5");
md5.update(toVerifyText.getBytes("UTF-8"));
byte[] digest = md5.digest();
return Base64.getEncoder().encodeToString(digest);
}
/**
* 顺丰OAUTH2
*/
private static String oAuth() throws Exception {
StringBuilder formParams = new StringBuilder();
formParams.append("partnerID=").append(URLEncoder.encode(PARTNER_ID, "UTF-8"));
formParams.append("&secret=").append(URLEncoder.encode(CHECK_WORD, "UTF-8"));
formParams.append("&grantType=").append(URLEncoder.encode(GRANT_TYPE, "UTF-8"));
String oauthResponse = doPost(OAUTH_URL, formParams.toString());
JSONObject jsonObject = JSON.parseObject(oauthResponse);
return jsonObject.getString("accessToken");
}
/**
* 发送POST请求（表单格式）
*/
private static String doPost(String urlStr, String formBody) throws Exception {
URL url = new URL(urlStr);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setRequestMethod("POST");
conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
conn.setDoOutput(true);
try (OutputStream os = conn.getOutputStream()) {
os.write(formBody.getBytes(StandardCharsets.UTF_8));
}
int code = conn.getResponseCode();
if (code == 200) {
try (BufferedReader br = new BufferedReader(new InputStreamReader(conn.getInputStream(), StandardCharsets.UTF_8))) {
StringBuilder sb = new StringBuilder();
String line;
while ((line = br.readLine()) != null) {
sb.append(line);
}
return sb.toString();
}
} else {
throw new RuntimeException("HTTP请求失败，状态码：" + code);
}
}
public static WmsExpressVo parseData(String result) {
if (StringUtils.isBlank(result)) {
return null;
}
try {
// 1. 解析最外层的JSON
JSONObject outerJson = JSON.parseObject(result);
if (outerJson == null) {
return null;
}
// 2. 获取apiResultData字符串并再次解析
String apiResultDataStr = outerJson.getString("apiResultData");
if (StringUtils.isBlank(apiResultDataStr)) {
return null;
}
JSONObject innerJson = JSON.parseObject(apiResultDataStr);
if (innerJson == null) {
return null;
}
// 3. 提取所需数据
JSONObject msgData = innerJson.getJSONObject("msgData");
if (msgData == null) {
return null;
}
JSONArray routeResps = msgData.getJSONArray("routeResps");
if (routeResps == null || routeResps.isEmpty()) {
return null;
}
JSONObject firstRouteResp = routeResps.getJSONObject(0);
if (firstRouteResp == null) {
return null;
}
JSONArray routes = firstRouteResp.getJSONArray("routes");
if (routes == null || routes.isEmpty()) {
return null;
}
JSONObject lastRoute = routes.getJSONObject(routes.size() - 1);
if (lastRoute == null) {
return null;
}
String acceptTime = lastRoute.getString("acceptTime");
String firstStatusName = lastRoute.getString("firstStatusName");
WmsExpressVo WmsExpressVo = new WmsExpressVo();
// 转换日期并设置，如果日期格式不正确则设置为null
if (StringUtils.isNotBlank(acceptTime)) {
try {
Date date = DateUtils.parseDate(acceptTime);
WmsExpressVo.setAcceptTime(date);
} catch (Exception e) {
WmsExpressVo.setAcceptTime(null);
}
}
WmsExpressVo.setFirstStatusName(firstStatusName);
System.out.println(acceptTime);
System.out.println(firstStatusName);
return WmsExpressVo;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* main方法测试
*/
public static void main(String[] args) {
String mailNo = "SF3191365477469";
String result = queryRoute(mailNo,"15075462410");
System.out.println(result);
WmsExpressVo WmsExpress = parseData(result);
}
}

147
klp-wms/src/main/java/com/klp/utils/StoRouteQueryUtil.java Normal file
View File

@@ -0,0 +1,147 @@
package com.klp.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.klp.domain.vo.WmsExpressVo;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.codec.digest.DigestUtils;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;
public class StoRouteQueryUtil {
// 请填写你自己的key/secret
private static final String APP_KEY = "CAKDSqybdwbzlUC";
private static final String APP_SECRET = "wGRMVXwIf8sp4m4W6tWJcOaDfY7EPblQ";
private static final String FROM_CODE = "CAKDSqybdwbzlUC"; // 你的from_code
private static final String API_URL = "https://cloudinter-linkgateway.sto.cn/gateway/link.do";
// 申通签名算法 body+appSecret，MD5后Base64
public static String sign(String body, String secret) {
String text = body + secret;
byte[] md5 = DigestUtils.md5(text);
return Base64.encodeBase64String(md5);
}
/**
* 查询申通轨迹，支持批量单号
* @param waybillNos 运单号集合
* @return 查询结果JSON
*/
public static String queryRoute(List<String> waybillNos) {
try {
// 构造content参数
JSONObject content = new JSONObject();
content.put("order", "asc");
JSONArray waybillNoList = new JSONArray();
for (String no : waybillNos) waybillNoList.add(no);
content.put("waybillNoList", waybillNoList);
String contentStr = content.toJSONString();
// 构造表单参数字符串
StringBuilder form = new StringBuilder();
form.append("api_name=STO_TRACE_QUERY_COMMON");
form.append("&content=").append(URLEncoder.encode(contentStr, "UTF-8"));
form.append("&from_appkey=").append(APP_KEY);
form.append("&from_code=").append(APP_KEY);
form.append("&to_appkey=sto_trace_query");
form.append("&to_code=sto_trace_query");
form.append("&data_digest=").append(URLEncoder.encode(sign(contentStr, APP_SECRET), "UTF-8"));
System.out.println("申通表单请求体：" + form);
URL url = new URL(API_URL);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setDoOutput(true);
conn.setDoInput(true);
conn.setUseCaches(false);
conn.setRequestMethod("POST");
conn.setRequestProperty("Content-Type", "application/x-www-form-urlencoded;charset=UTF-8");
OutputStream out = conn.getOutputStream();
out.write(form.toString().getBytes(StandardCharsets.UTF_8));
out.flush();
out.close();
StringBuilder sbResult = new StringBuilder();
if (200 == conn.getResponseCode()) {
BufferedReader responseReader = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
String readLine;
while ((readLine = responseReader.readLine()) != null) {
sbResult.append(readLine).append("\n");
}
responseReader.close();
}
return sbResult.toString();
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 解析申通返回数据，转为WmsExpressVo列表
*/
public static WmsExpressVo parseData(String result) {
if (result == null || result.trim().isEmpty()) {
return null;
}
// 新增：如果返回是XML，直接打印并返回null
if (result.trim().startsWith("<")) {
System.err.println("申通返回XML错误：" + result);
return null;
}
try {
JSONObject json = JSON.parseObject(result);
JSONObject data = json.getJSONObject("data");
if (data == null) return null;
for (String waybillNo : data.keySet()) {
JSONArray arr = data.getJSONArray(waybillNo);
if (arr == null || arr.isEmpty()) continue;
JSONObject last = arr.getJSONObject(arr.size() - 1);
WmsExpressVo vo = new WmsExpressVo();
vo.setExpressCode(last.getString("waybillNo"));
// 设置时间
String opTime = last.getString("opTime");
if (opTime != null) {
try {
// 解析时间格式 "2025-07-27 13:01:00"
SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
vo.setAcceptTime(sdf.parse(opTime));
} catch (Exception e) {
vo.setAcceptTime(null);
}
}
// 设置状态 - 使用scanType作为状态
vo.setFirstStatusName(last.getString("memo"));
// 设置备注 - 使用memo作为备注
vo.setRemark(last.getString("scanType"));
return vo;
}
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
// main方法测试
public static void main(String[] args) {
List<String> waybillNos = new ArrayList<>();
waybillNos.add("777329412312954"); // 测试单号
String result = queryRoute(waybillNos);
System.out.println("申通原始返回：" + result);
WmsExpressVo vo = parseData(result);
if (vo != null) {
System.out.println("解析后：" + vo);
} else {
System.out.println("未解析到数据");
}
}
}

75
klp-wms/src/main/java/com/klp/utils/YdRouteQueryUtil.java Normal file
View File

@@ -0,0 +1,75 @@
package com.klp.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.klp.domain.vo.WmsExpressVo;
import com.yundasys.OpenApiHttpUtils;
import java.security.MessageDigest;
public class YdRouteQueryUtil {
// 请根据实际环境切换key/secret
private static final String APP_KEY = "004160"; // 生产环境
private static final String APP_SECRET = "ac9ee46d749e44b98e7a9e38f3c8f8f3"; // 生产环境
private static final String API_URL = "https://openapi.yundaex.com/openapi/outer/logictis/query";
/**
* 查询韵达轨迹
* @param mailNo 运单号
* @return 查询结果JSON
*/
public static String queryRoute(String mailNo) {
String jsonParams = "{\"mailno\":\"" + mailNo + "\"}";
return OpenApiHttpUtils.doPostJson(API_URL, jsonParams, APP_KEY, APP_SECRET);
}
/**
* 解析韵达返回数据，转为WmsExpressVo
*/
public static WmsExpressVo parseData(String result) {
if (result == null || result.trim().isEmpty()) {
return null;
}
try {
JSONObject json = JSON.parseObject(result);
JSONObject data = json.getJSONObject("data");
if (data == null) return null;
JSONArray steps = data.getJSONArray("steps");
if (steps == null || steps.isEmpty()) return null;
JSONObject last = steps.getJSONObject(steps.size() - 1);
WmsExpressVo vo = new WmsExpressVo();
vo.setExpressCode(data.getString("mailno"));
vo.setLastUpdateTime(last.getDate("time"));
vo.setLastStatus(last.getString("action"));
vo.setRemark(last.getString("description"));
return vo;
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
// MD5签名算法（如需自定义签名，可用此方法）
public static String md5(String str, String charset) throws Exception {
MessageDigest md = MessageDigest.getInstance("MD5");
md.update(str.getBytes(charset));
byte[] result = md.digest();
StringBuilder sb = new StringBuilder(32);
for (byte b : result) {
int val = b & 0xff;
if (val <= 0xf) sb.append("0");
sb.append(Integer.toHexString(val));
}
return sb.toString().toLowerCase();
}
// main方法测试
public static void main(String[] args) {
String mailNo = "464569453467736";
String result = queryRoute(mailNo);
System.out.println("韵达原始返回：" + result);
WmsExpressVo vo = parseData(result);
System.out.println("解析后：" + vo);
}
}

118
klp-wms/src/main/java/com/klp/utils/YtRouteQueryUtil.java Normal file
View File

@@ -0,0 +1,118 @@
package com.klp.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.klp.domain.vo.WmsExpressVo;
import org.apache.commons.codec.binary.Base64;
import org.apache.commons.codec.digest.DigestUtils;
import java.io.BufferedReader;
import java.io.InputStreamReader;
import java.io.OutputStream;
import java.net.HttpURLConnection;
import java.net.URL;
import java.nio.charset.StandardCharsets;
public class YtRouteQueryUtil {
// 请填写你自己的密钥、method、v
private static final String SECRET = "TEST";
private static final String METHOD = "123456"; // 示例
private static final String VERSION = "v1"; // 示例
private static final String API_URL = " https://openuat.yto56test.com:6443/open/track_query_adapter/v1/hpLkUl/TEST";
// 圆通签名算法 param+method+v+secret，MD5后Base64
public static String sign(String param, String method, String v, String secret) {
String data = param + method + v;
byte[] md5 = DigestUtils.md5(data + secret);
return Base64.encodeBase64String(md5);
}
/**
* 查询圆通轨迹
* @param number 运单号
* @return 查询结果JSON
*/
public static String queryRoute(String number) {
try {
String timestamp = String.valueOf(System.currentTimeMillis());
JSONObject paramObj = new JSONObject();
paramObj.put("NUMBER", number);
String param = paramObj.toJSONString();
String sign = sign(param, METHOD, VERSION, SECRET);
JSONObject req = new JSONObject();
req.put("timestamp", timestamp);
req.put("param", param);
req.put("sign", sign);
req.put("format", "JSON");
req.put("method", METHOD);
req.put("v", VERSION);
String jsonParams = req.toJSONString();
URL url = new URL(API_URL);
HttpURLConnection conn = (HttpURLConnection) url.openConnection();
conn.setDoOutput(true);
conn.setDoInput(true);
conn.setUseCaches(false);
conn.setRequestMethod("POST");
conn.setRequestProperty("Content-Type", "application/json;charset=UTF-8");
OutputStream out = conn.getOutputStream();
out.write(jsonParams.getBytes(StandardCharsets.UTF_8));
out.flush();
out.close();
StringBuilder sbResult = new StringBuilder();
if (200 == conn.getResponseCode()) {
BufferedReader responseReader = new BufferedReader(new InputStreamReader(conn.getInputStream(), "UTF-8"));
String readLine;
while ((readLine = responseReader.readLine()) != null) {
sbResult.append(readLine).append("\n");
}
responseReader.close();
}
return sbResult.toString();
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
/**
* 解析圆通返回数据，转为WmsExpressVo列表
*/
public static WmsExpressVo parseData(String result) {
if (result == null || result.trim().isEmpty()) {
return null;
}
try {
if (result.trim().startsWith("{")) {
JSONObject json = JSON.parseObject(result);
if (json.containsKey("map")) return null; // 查询为空
} else if (result.trim().startsWith("[")) {
JSONArray arr = JSON.parseArray(result);
if (arr.isEmpty()) return null;
JSONObject last = arr.getJSONObject(arr.size() - 1);
WmsExpressVo vo = new WmsExpressVo();
vo.setExpressCode(last.getString("waybill_No"));
vo.setLastUpdateTime(last.getDate("upload_Time"));
vo.setLastStatus(last.getString("infoContent"));
vo.setRemark(last.getString("processInfo"));
return vo;
}
} catch (Exception e) {
e.printStackTrace();
}
return null;
}
// main方法测试
public static void main(String[] args) {
String number = "YT2600227881409"; // 测试单号
String result = queryRoute(number);
System.out.println("圆通原始返回：" + result);
WmsExpressVo vo = parseData(result);
if (vo != null) {
System.out.println("解析后：" + vo);
} else {
System.out.println("解析后无数据");
}
}
}

117
klp-wms/src/main/java/com/klp/utils/ZtoTrackQueryUtil.java Normal file
View File

@@ -0,0 +1,117 @@
package com.klp.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONArray;
import com.alibaba.fastjson2.JSONObject;
import com.klp.domain.vo.WmsExpressVo;
import com.zto.zop.ZopClient;
import com.zto.zop.ZopPublicRequest;
import org.apache.commons.lang3.StringUtils;
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.URL;
import static com.zto.zop.EncryptionType.MD5;
public class ZtoTrackQueryUtil {
// 替换为你的appKey和appSecret
private static final String APP_KEY = "1ebf01ae01cc81d78ba9a";
private static final String APP_SECRET = "4bded7f302da7f7913b01810e3421b80";
// 测试环境
// private static final String API_URL = "https://japi-test.zto.com/zto.merchant.waybill.track.query";
// 正式环境
private static final String API_URL = "https://japi.zto.com/zto.merchant.waybill.track.query";
/**
* 查询中通物流轨迹
*
* @param billCode 运单号
* @return 查询结果JSON
*/
public static WmsExpressVo queryTrack(String billCode,String phoneNumber) throws IOException {
ZopClient client = new ZopClient(APP_KEY, APP_SECRET);
ZopPublicRequest request = new ZopPublicRequest();
request.setBody("{\"billCode\":\""+billCode+"\",\"mobilePhone\":\""+ StringUtils.right(phoneNumber, 4)+"\"}");
request.setUrl(API_URL);
request.setBase64(true);
request.setEncryptionType(MD5);
request.setTimestamp(null);
String execute = client.execute(request);
System.out.println(execute);
return parseData(execute);
}
/**
* 解析中通返回数据，封装为WmsExpressVo
*/
public static WmsExpressVo parseData(String result) {
if (StringUtils.isBlank(result)) {
return null;
}
try {
JSONObject json = JSON.parseObject(result);
if (json == null || !"true".equalsIgnoreCase(String.valueOf(json.get("status")))) {
return null;
}
// 取result数组
if (!json.containsKey("result")) {
return null;
}
// 只取第一个轨迹（如有多条）
Object resultArr = json.get("result");
if (!(resultArr instanceof java.util.List)) {
return null;
}
JSONArray arr = json.getJSONArray("result");
if (arr == null || arr.isEmpty()) {
return null;
}
JSONObject first = arr.getJSONObject(arr.size() - 1); // 取最后一条为最新
if (first == null) {
return null;
}
String scanDate = first.getString("scanDate");
String desc = first.getString("desc");
WmsExpressVo vo = new WmsExpressVo();
// scanDate为时间戳字符串
if (StringUtils.isNotBlank(scanDate)) {
try {
long time = Long.parseLong(scanDate);
vo.setAcceptTime(new java.util.Date(time));
} catch (Exception e) {
vo.setAcceptTime(null);
}
}
vo.setFirstStatusName(desc);
return vo;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
public static String getPublicIp() {
String ip = "";
try {
URL url = new URL("http://ifconfig.me/ip");
BufferedReader in = new BufferedReader(new InputStreamReader(url.openStream()));
ip = in.readLine();
in.close();
} catch (Exception e) {
e.printStackTrace();
}
return ip;
}
// main方法测试
public static void main(String[] args) throws IOException {
System.out.println("本机公网IP为: " + getPublicIp());
String billCode = "78925013374727";
WmsExpressVo result = queryTrack(billCode,"2410");
System.out.println(result);
}
}