This commit is contained in:
2025-07-23 11:46:55 +08:00
parent b1914b7edc
commit c8f20e6d55
4 changed files with 391 additions and 0 deletions

View File

@@ -0,0 +1,107 @@
package com.ruoyi.oa.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.oa.domain.vo.OaExpressVo;
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 StoRouteQueryUtil {
// 请填写你自己的key/secret
private static final String APP_KEY = "";
private static final String APP_SECRET = "";
private static final String API_URL = "https://open.sto.cn/openapi/traceQuery"; // 申通轨迹查询接口
/**
* 查询申通轨迹
* @param mailNo 运单号
* @return 查询结果JSON
*/
public static String queryRoute(String mailNo) {
try {
// 构造请求参数,具体参数请参考申通官方文档
JSONObject params = new JSONObject();
params.put("appKey", APP_KEY);
params.put("timestamp", System.currentTimeMillis());
params.put("sign", ""); // 签名算法见官方文档
params.put("method", "sto.trace.query.common");
params.put("format", "json");
params.put("billNo", mailNo);
// 其他参数可根据实际需求补充
String jsonParams = params.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;
}
}
/**
* 解析申通返回数据转为OaExpressVo
*/
public static OaExpressVo parseData(String result) {
if (result == null || result.isEmpty()) return null;
try {
JSONObject json = JSON.parseObject(result);
// 具体字段请根据申通返回格式调整
JSONObject data = json.getJSONObject("data");
if (data == null) return null;
OaExpressVo vo = new OaExpressVo();
vo.setExpressCode(data.getString("billNo"));
vo.setLastStatus(data.getString("status"));
vo.setLastUpdateTime(data.getDate("updateTime"));
// 你可以根据实际返回内容补充更多字段
return vo;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
// 申通签名算法 body+appSecretMD5后Base64
public static String sign(String body, String secret) {
String text = body + secret;
byte[] md5 = DigestUtils.md5(text);
return Base64.encodeBase64String(md5);
}
// main方法测试
public static void main(String[] args) {
String mailNo = "测试单号";
String body = "{\"orderNo\":\"" + mailNo + "\"}";
String secret = "你的密钥";
String sign = sign(body, secret);
System.out.println("申通签名:" + sign);
String result = queryRoute(mailNo); // 你可以根据实际参数完善queryRoute
System.out.println("申通原始返回:" + result);
OaExpressVo vo = parseData(result);
System.out.println("解析后:" + vo);
}
}

View File

@@ -0,0 +1,69 @@
package com.ruoyi.oa.utils;
import com.yundasys.OpenApiHttpUtils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.oa.domain.vo.OaExpressVo;
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://u-openapi.yundasys.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);
}
/**
* 解析韵达返回数据转为OaExpressVo
*/
public static OaExpressVo parseData(String result) {
if (result == null || result.isEmpty()) return null;
try {
JSONObject json = JSON.parseObject(result);
// 具体字段请根据韵达返回格式调整
JSONObject data = json.getJSONObject("data");
if (data == null) return null;
OaExpressVo vo = new OaExpressVo();
vo.setExpressCode(data.getString("mailNo"));
vo.setLastStatus(data.getString("status"));
vo.setLastUpdateTime(data.getDate("updateTime"));
// 你可以根据实际返回内容补充更多字段
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 = "测试单号";
String result = queryRoute(mailNo);
System.out.println("韵达原始返回:" + result);
OaExpressVo vo = parseData(result);
System.out.println("解析后:" + vo);
}
}

View File

@@ -0,0 +1,110 @@
package com.ruoyi.oa.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.oa.domain.vo.OaExpressVo;
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 {
// 请填写你自己的key/secret
private static final String APP_KEY = "";
private static final String APP_SECRET = "";
private static final String API_URL = "https://openapi.yto.net.cn/openApi/queryTrack"; // 圆通轨迹查询接口
/**
* 查询圆通轨迹
* @param mailNo 运单号
* @return 查询结果JSON
*/
public static String queryRoute(String mailNo) {
try {
// 构造请求参数,具体参数请参考圆通官方文档
JSONObject params = new JSONObject();
params.put("app_key", APP_KEY);
params.put("timestamp", System.currentTimeMillis());
params.put("sign", ""); // 签名算法见官方文档
params.put("method", "yto.marketing.waybill.trace.get");
params.put("format", "json");
params.put("user_id", ""); // 用户ID如有
params.put("waybill_no", mailNo);
// 其他参数可根据实际需求补充
String jsonParams = params.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;
}
}
/**
* 解析圆通返回数据转为OaExpressVo
*/
public static OaExpressVo parseData(String result) {
if (result == null || result.isEmpty()) return null;
try {
JSONObject json = JSON.parseObject(result);
// 具体字段请根据圆通返回格式调整
JSONObject data = json.getJSONObject("data");
if (data == null) return null;
OaExpressVo vo = new OaExpressVo();
vo.setExpressCode(data.getString("mailNo"));
vo.setLastStatus(data.getString("status"));
vo.setLastUpdateTime(data.getDate("updateTime"));
// 你可以根据实际返回内容补充更多字段
return vo;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
// 圆通签名算法 param+method+v+secretMD5后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);
}
// main方法测试
public static void main(String[] args) {
String mailNo = "测试单号";
String param = "{\"NUMBER\":\"" + mailNo + "\"}";
String method = "yto.marketing.waybill.trace.get"; // 请根据实际接口填写
String v = "1.01"; // 请根据实际接口填写
String secret = "你的密钥";
String sign = sign(param, method, v, secret);
System.out.println("圆通签名:" + sign);
String result = queryRoute(mailNo); // 你可以根据实际参数完善queryRoute
System.out.println("圆通原始返回:" + result);
OaExpressVo vo = parseData(result);
System.out.println("解析后:" + vo);
}
}

View File

@@ -0,0 +1,105 @@
package com.ruoyi.oa.utils;
import com.alibaba.fastjson2.JSON;
import com.alibaba.fastjson2.JSONObject;
import com.ruoyi.oa.domain.vo.OaExpressVo;
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 ZtoRouteQueryUtil {
// 请填写你自己的key/secret
private static final String APP_KEY = "";
private static final String APP_SECRET = "";
private static final String API_URL = "https://japi.zto.com/traceInterfaceNewTraces"; // 中通轨迹查询接口
/**
* 查询中通轨迹
* @param mailNo 运单号
* @return 查询结果JSON
*/
public static String queryRoute(String mailNo) {
try {
// 构造请求参数,具体参数请参考中通官方文档
JSONObject params = new JSONObject();
params.put("company_id", APP_KEY);
params.put("msg_type", "NEW_TRACES");
params.put("data", "[{\"billCode\":\"" + mailNo + "\"}]");
params.put("data_digest", ""); // 签名算法见官方文档
// 其他参数可根据实际需求补充
String jsonParams = params.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;
}
}
/**
* 解析中通返回数据转为OaExpressVo
*/
public static OaExpressVo parseData(String result) {
if (result == null || result.isEmpty()) return null;
try {
JSONObject json = JSON.parseObject(result);
// 具体字段请根据中通返回格式调整
JSONObject data = json.getJSONObject("data");
if (data == null) return null;
OaExpressVo vo = new OaExpressVo();
vo.setExpressCode(data.getString("billCode"));
vo.setLastStatus(data.getString("status"));
vo.setLastUpdateTime(data.getDate("updateTime"));
// 你可以根据实际返回内容补充更多字段
return vo;
} catch (Exception e) {
e.printStackTrace();
return null;
}
}
// 中通签名算法 body+appSecretMD5后Base64
public static String sign(String body, String secret) {
String text = body + secret;
byte[] md5 = DigestUtils.md5(text);
return Base64.encodeBase64String(md5);
}
// main方法测试
public static void main(String[] args) {
String mailNo = "测试单号";
String body = "{\"billCode\":\"" + mailNo + "\"}";
String secret = "你的密钥";
String sign = sign(body, secret);
System.out.println("中通签名:" + sign);
String result = queryRoute(mailNo); // 你可以根据实际参数完善queryRoute
System.out.println("中通原始返回:" + result);
OaExpressVo vo = parseData(result);
System.out.println("解析后:" + vo);
}
}