From 6c5165f73c90fbd4e22e4f9a39497b5a25ee37f9 Mon Sep 17 00:00:00 2001 From: jiangping <jp@doumee.com> Date: 星期四, 26 十二月 2024 09:53:38 +0800 Subject: [PATCH] Merge remote-tracking branch 'origin/master' --- server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java | 164 +++++++++++++++++++++++++++++++++++++++++++----------- 1 files changed, 131 insertions(+), 33 deletions(-) diff --git a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java index e49a6fc..405f54a 100644 --- a/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java +++ b/server/visits/dmvisit_service/src/main/java/com/doumee/service/business/impl/thrid/TmsServiceImpl.java @@ -2,8 +2,6 @@ import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.TypeReference; -import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; -import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; import com.doumee.biz.system.SystemDictDataBiz; import com.doumee.core.tms.model.TMSContants; import com.doumee.core.tms.model.request.*; @@ -11,24 +9,15 @@ import com.doumee.core.utils.Constants; import com.doumee.core.utils.DateUtil; import com.doumee.core.utils.HttpsUtil; -import com.doumee.core.wms.model.request.*; -import com.doumee.core.wms.model.response.WmsBaseDataResponse; -import com.doumee.core.wms.model.response.WmsBaseResponse; -import com.doumee.core.wms.model.response.WmsInventoryDataResponse; import com.doumee.dao.business.*; import com.doumee.dao.business.dao.SmsEmailMapper; import com.doumee.dao.business.model.*; -import com.doumee.service.business.impl.SmsEmailServiceImpl; import com.doumee.service.business.third.TmsService; -import com.doumee.service.business.third.WmsService; -import com.github.yulichang.wrapper.MPJLambdaWrapper; -import io.swagger.models.auth.In; import lombok.extern.slf4j.Slf4j; import org.apache.commons.lang3.StringUtils; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.annotation.Value; import org.springframework.stereotype.Service; -import org.springframework.transaction.annotation.Transactional; import java.util.*; @@ -201,6 +190,41 @@ } /** + * 鏈畬鎴愯鍗曞垪琛ㄦ帴鍙� + * 鏍规嵁鍖哄煙ID闆嗗悎+绛涢�夋潯浠讹紙鍚堝悓鍙枫�佸埗鍗曞紑濮嬫棩鏈熴�佸埗鍗曠粨鏉熸棩鏈熴�佸彂璐у湴銆佸埌璐у湴銆佺渷浠斤紝闈為渶瑕侊級锛岃繑鍥炲悎鍚屽垪琛ㄤ俊鎭紝鎸夌収鏃堕棿鍊掑簭灞曠ず锛� + * @param param 鍙傛暟 + * @return TmsBaseResponse + */ + @Override + public TmsBasePageResponse<TmsOrderNoFinishListResponse> getNotFinishOrderList(TmsOrderNoFinishListRequest param){ + String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() + +TMSContants.InterfacePath.getNotFinishOrderList[0]; + TmsBaseResponse<TmsBasePageResponse<TmsOrderNoFinishListResponse> > response = sendHttpRequest(url,TMSContants.InterfacePath.getNotFinishOrderList[1],JSONObject.toJSONString(param) + ,new TypeReference< TmsBaseResponse<TmsBasePageResponse<TmsOrderNoFinishListResponse>> >(){}); + if(response ==null || response.getData() == null){ + return new TmsBasePageResponse<>(); + } + return response.getData(); + + } + /** + * 鍑哄簱鑳藉姏缁熻 + * 鏌ヨ鏌愪釜鍘�/鍏ㄩ儴鍘傜殑浠婃棩璁″垝閲忋�佷粖鏃ュ嚭搴撻噺銆佷粖鏃ユ湭鍑哄簱閲忔暟鎹�� + * @param param 鍙傛暟 + * @return TmsBaseResponse + */ + @Override + public TmsOutboundCapabilityResponse getOutboundCapability(TmsFacrotyCodeListRequest param){ + String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() + +TMSContants.InterfacePath.getOutboundCapability[0]; + TmsBaseResponse<TmsOutboundCapabilityResponse > response = sendHttpRequest(url,TMSContants.InterfacePath.getOutboundCapability[1],JSONObject.toJSONString(param) + ,new TypeReference< TmsBaseResponse<TmsOutboundCapabilityResponse>>(){}); + if(response ==null || response.getData() == null){ + return new TmsOutboundCapabilityResponse(); + } + return response.getData(); + } + /** * 鍚堝悓鍒楄〃鎺ュ彛 * 鏍规嵁鍖哄煙ID闆嗗悎+绛涢�夋潯浠讹紙鍚堝悓鍙枫�佸埗鍗曞紑濮嬫棩鏈熴�佸埗鍗曠粨鏉熸棩鏈熴�佸彂璐у湴銆佸埌璐у湴銆佺渷浠斤紝闈為渶瑕侊級锛岃繑鍥炲悎鍚屽垪琛ㄤ俊鎭紝鎸夌収鏃堕棿鍊掑簭灞曠ず锛� * @param param 鍙傛暟 @@ -208,27 +232,6 @@ */ @Override public TmsBasePageResponse<TmsOrderListResponse> orderList(TmsOrderListRequest param){ - if(param == null){ - param = new TmsOrderListRequest(); - } - if(param.getParameters() == null){ - param.setParameters( new TmsOrderListParamRequest()); - } - if(param.getPager() == null){ - param.setPager( new TmsOrderListPagerRequest()); - } - if(param.getPager().getPage() == null){ - param.getPager().setPage(1); - } - if(param.getPager().getRows() == null){ - param.getPager().setRows(10); - } - if(StringUtils.isBlank(param.getParameters().getPhoneNumber())){ - param.getParameters().setPhoneNumber("00000000000");//鎵嬫満鍙峰繀濉� - } - if(param.getParameters().getContractNumbers()==null || param.getParameters().getContractNumbers().size()==0){ - param.getParameters().setContractNumbers(null); - } String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() +TMSContants.InterfacePath.getOrderList[0]; TmsBaseResponse<TmsBasePageResponse<TmsOrderListResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderList[1],JSONObject.toJSONString(param) @@ -252,7 +255,8 @@ } String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() +TMSContants.InterfacePath.getOrderDetailByContractNumber[0]; - TmsBaseResponse<TmsOrderInfoResponse> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderDetailByContractNumber[1],param.getContractNumber() + TmsBaseResponse<TmsOrderInfoResponse> response = sendHttpRequest(url,TMSContants.InterfacePath.getOrderDetailByContractNumber[1] + ,param.getContractNumber() ,new TypeReference< TmsBaseResponse<TmsOrderInfoResponse>>(){}); if(response!=null && response.getData()!=null){ result =response.getData(); @@ -267,6 +271,100 @@ result.setCicleStatusList(getCicleStatusList(p1)); return result; } + /** + * 鍏ㄥ浗鍒拌揣鍦板垎甯冩煡璇㈡煡璇� + * @param param 鍙傛暟 + * @return TmsBaseResponse + */ + @Override + public List<TmsDistributionOfDeliveryLocResponse> getDistributionOfDeliveryLocations(TmsFacrotyCodeListRequest param){ + List<TmsDistributionOfDeliveryLocResponse> result = new ArrayList<>(); +// if( param.getFacrotyCodeList() == null || param.getFacrotyCodeList().size() == 0){ +// param.setFacrotyCodeList(new ArrayList<>()); +// param.getFacrotyCodeList().add("0"); +// } + String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() + +TMSContants.InterfacePath.getDistributionOfDeliveryLocations[0]; + TmsBaseResponse< List<TmsDistributionOfDeliveryLocResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getDistributionOfDeliveryLocations[1], + JSONObject.toJSONString(param) + ,new TypeReference< TmsBaseResponse< List<TmsDistributionOfDeliveryLocResponse>>>(){}); + if(response!=null && response.getData()!=null){ + result =response.getData(); + } + + return result; + } + /** + * 瀹炴椂搴撳瓨鏌ヨ + * @return TmsBaseResponse + */ + @Override + public List<TmsInventoryListResponse> getRealTimeInventory( ){ + List<TmsInventoryListResponse> result = new ArrayList<>(); + String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() + +TMSContants.InterfacePath.getRealTimeInventory[0]; + TmsBaseResponse< List<TmsInventoryListResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getRealTimeInventory[1] + ,"{}" + ,new TypeReference< TmsBaseResponse< List<TmsInventoryListResponse>>>(){}); + if(response!=null && response.getData()!=null){ + result =response.getData(); + } + + return result; + } + /** + * 鏌ヨ5涓巶鐨勮繍鍔涜祫婧愬埄鐢ㄦ儏鍐� + * @return TmsBaseResponse + */ + @Override + public List<TmsTotalAndReportVehicleQtyResponse> getTotalAndReportVehicleQty( ){ + List<TmsTotalAndReportVehicleQtyResponse> result = new ArrayList<>(); + String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() + +TMSContants.InterfacePath.getTotalAndReportVehicleQty[0]; + TmsBaseResponse< List<TmsTotalAndReportVehicleQtyResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getTotalAndReportVehicleQty[1] + ,"{}" + ,new TypeReference< TmsBaseResponse< List<TmsTotalAndReportVehicleQtyResponse>>>(){}); + if(response!=null && response.getData()!=null){ + result =response.getData(); + } + + return result; + } + /** + * 杩�7鏃ュ埌璐ф儏鍐�(鍚槑缁�) + * @return TmsBaseResponse + */ + @Override + public List<TmsSevenArrivalStatusAndDetailsResponse> getSevenArrivalStatusAndDetails(TmsSevenArrivalDetailsRequest param ){ + List<TmsSevenArrivalStatusAndDetailsResponse> result = new ArrayList<>(); + String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() + +TMSContants.InterfacePath.getSevenArrivalStatusAndDetails[0]; + TmsBaseResponse< List<TmsSevenArrivalStatusAndDetailsResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getSevenArrivalStatusAndDetails[1] + ,JSONObject.toJSONString(param) + ,new TypeReference< TmsBaseResponse< List<TmsSevenArrivalStatusAndDetailsResponse>>>(){}); + if(response!=null && response.getData()!=null){ + result =response.getData(); + } + return result; + } + /** + * 鎸囧畾鏃堕棿鑼冨洿鍐呯疮璁″嚭搴撻噺 + * @return TmsBaseResponse + */ + @Override + public List<TmsOutQtyAndVehicleQtyResponse> getOutQtyAndVehicleQty(TmsOutQtyAndVehicleQtyRequest param ){ + List<TmsOutQtyAndVehicleQtyResponse> result = new ArrayList<>(); + String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() + +TMSContants.InterfacePath.getOutQtyAndVehicleQty[0]; + TmsBaseResponse< List<TmsOutQtyAndVehicleQtyResponse>> response = sendHttpRequest(url,TMSContants.InterfacePath.getOutQtyAndVehicleQty[1] + ,JSONObject.toJSONString(param) + ,new TypeReference< TmsBaseResponse< List<TmsOutQtyAndVehicleQtyResponse>>>(){}); + if(response!=null && response.getData()!=null){ + result =response.getData(); + } + return result; + } + /** * 鍙戣捣 tms鎺ュ彛璇锋眰 -- Gitblit v1.9.3