快递wms工具类

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.google.gson.Gson;
import com.kuaidi100.sdk.api.QueryTrack;
import com.kuaidi100.sdk.api.Subscribe;
import com.kuaidi100.sdk.contant.ApiInfoConstant;
import com.kuaidi100.sdk.core.IBaseClient;
import com.kuaidi100.sdk.pojo.HttpResult;
import com.kuaidi100.sdk.request.QueryTrackParam;
import com.kuaidi100.sdk.request.QueryTrackReq;
import com.kuaidi100.sdk.request.SubscribeParam;
import com.kuaidi100.sdk.request.SubscribeParameters;
import com.kuaidi100.sdk.request.SubscribeReq;
import com.kuaidi100.sdk.response.QueryTrackResp;
import com.kuaidi100.sdk.response.SubscribeResp;
import com.kuaidi100.sdk.utils.SignUtils;
import jakarta.annotation.Nullable;
import jakarta.validation.constraints.NotNull;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.apache.http.HttpStatus;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Component;import java.util.Objects;/*** @author lisong*/
@Component
@Slf4j
public class WmsUtil {@Value("${wms.kuaidi-100.key}")private String key;@Value("${wms.kuaidi-100.customer}")private String customer;@Value("${wms.kuaidi-100.callbackUrl}")private String callbackUrl;/**** Desc: 订阅物流* @param companyEncoded 物流公司编码* @param wmsOrderNo 物流单号* @param phoneNum   手机号* @author lisong**/public void subscribe(String companyEncoded, String wmsOrderNo, String phoneNum) throws Exception {SubscribeParameters subscribeParameters = new SubscribeParameters();subscribeParameters.setCallbackurl(callbackUrl);subscribeParameters.setPhone(phoneNum);SubscribeParam subscribeParam = new SubscribeParam();subscribeParam.setParameters(subscribeParameters);subscribeParam.setCompany(companyEncoded);subscribeParam.setNumber(wmsOrderNo);subscribeParam.setKey(key);SubscribeReq subscribeReq = new SubscribeReq();subscribeReq.setSchema(ApiInfoConstant.SUBSCRIBE_SCHEMA);subscribeReq.setParam(new Gson().toJson(subscribeParam));IBaseClient subscribe = new Subscribe();HttpResult httpResult = subscribe.execute(subscribeReq);SubscribeResp subscribeResp = handleWmsResult(httpResult, SubscribeResp.class);log.info("订阅物流返回信息:{}", JSON.toJSONString(subscribeResp));}public QueryTrackResp queryTrack(String companyEncoded, String wmsOrderNo, String phoneNum) throws Exception {QueryTrackReq queryTrackReq = new QueryTrackReq();QueryTrackParam queryTrackParam = new QueryTrackParam();queryTrackParam.setCom(companyEncoded);queryTrackParam.setNum(wmsOrderNo);queryTrackParam.setPhone(phoneNum);String param = new Gson().toJson(queryTrackParam);queryTrackReq.setParam(param);queryTrackReq.setCustomer(customer);queryTrackReq.setSign(SignUtils.querySign(param, key, customer));IBaseClient baseClient = new QueryTrack();HttpResult httpResult = baseClient.execute(queryTrackReq);return handleWmsResult(httpResult, QueryTrackResp.class);}/**** Desc: 处理快递100接口返回结果* @param httpResult 快递100接口返回结果* @return* @author lisong**/@Nullable@SuppressWarnings("all")private <T> T handleWmsResult(@NotNull HttpResult httpResult, Class<T> clazz) {if (httpResult.getStatus() == HttpStatus.SC_OK && StringUtils.isNotBlank(httpResult.getBody())) {String body = httpResult.getBody();JSONObject jsonObject = JSON.parseObject(httpResult.getBody());if (Objects.nonNull(jsonObject.get("data"))) {return JSONObject.toJavaObject(jsonObject, clazz);} else if (Objects.nonNull(jsonObject.get("message"))) {QueryTrackResp queryTrackResp = JSON.parseObject(httpResult.getBody(), QueryTrackResp.class);return JSONObject.toJavaObject(jsonObject, clazz);}return JSONObject.toJavaObject(jsonObject, clazz);}return null;}}