| | |
| | | import com.baomidou.mybatisplus.core.conditions.update.UpdateWrapper; |
| | | import com.doumee.biz.system.SystemDictDataBiz; |
| | | import com.doumee.core.tms.model.request.TmsLockStatusQueryRequest; |
| | | import com.doumee.core.tms.model.request.TmsOrderInfoRequest; |
| | | import com.doumee.core.tms.model.request.TmsOrderListRequest; |
| | | import com.doumee.core.tms.model.response.TmsBaseResponse; |
| | | import com.doumee.core.tms.model.response.TmsLockStatusQueryResponse; |
| | | import com.doumee.core.tms.model.response.TmsOrderInfoResponse; |
| | | import com.doumee.core.tms.model.response.TmsOrderListResponse; |
| | | import com.doumee.core.utils.Constants; |
| | | import com.doumee.core.utils.HttpsUtil; |
| | |
| | | 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 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; |
| | | |
| | |
| | | @Service |
| | | @Slf4j |
| | | public class TmsServiceImpl implements TmsService { |
| | | |
| | | @Autowired |
| | | private SmsEmailMapper smsEmailMapper; |
| | | @Autowired |
| | | private PlatformWmsJobMapper platformWmsJobMapper; |
| | | @Autowired |
| | |
| | | private SystemDictDataBiz systemDictDataBiz; |
| | | @Autowired |
| | | private WmsInterfaceLogMapper wmsInterfaceLogMapper; |
| | | |
| | | @Value("${debug_model}") |
| | | private Boolean isDebug; |
| | | /** |
| | | * 电子锁上锁时间接口 |
| | | * 根据合同号,查询电子锁上锁情况;存在批量查询的情况; |
| | | * @param param 参数 |
| | | * @return WmsBaseResponse |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public TmsBaseResponse<List<TmsLockStatusQueryResponse>> lockStatusQuery(TmsLockStatusQueryRequest param){ |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_LOCK_STATUS_URL).getCode(); |
| | | |
| | | TmsBaseResponse<List<TmsLockStatusQueryResponse>> response = sendHttpRequest(url,"电子锁上锁时间接口",JSONObject.toJSONString(param) |
| | | TmsBaseResponse<List<TmsLockStatusQueryResponse>> response = sendHttpRequest(url,"【TMS】电子锁上锁时间接口",JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<List<TmsLockStatusQueryResponse>>>(){}); |
| | | return new TmsBaseResponse<>(); |
| | | return response; |
| | | } |
| | | |
| | | /** |
| | | * 合同列表接口 |
| | | * 根据区域ID集合+筛选条件(合同号、制单开始日期、制单结束日期、发货地、到货地、省份,非需要),返回合同列表信息,按照时间倒序展示; |
| | | * @param param 参数 |
| | | * @return WmsBaseResponse |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public TmsBaseResponse<List<TmsOrderListResponse>> orderList(TmsOrderListRequest param){ |
| | | if(StringUtils.isBlank(param.getPhoneNumber())){ |
| | | param.setPhoneNumber("00000000000");//手机号必填 |
| | | } |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_ORDER_LIST_URL).getCode(); |
| | | TmsBaseResponse<List<TmsOrderListResponse>> response = sendHttpRequest(url,"合同列表接口",JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<List<TmsOrderListResponse>>>(){}); |
| | | return new TmsBaseResponse<>(); |
| | | return response; |
| | | } |
| | | /** |
| | | * 合同详情接口 |
| | | * @param param 参数 |
| | | * @return TmsBaseResponse |
| | | */ |
| | | @Override |
| | | public TmsBaseResponse<TmsOrderInfoResponse> orderInfo(TmsOrderInfoRequest param){ |
| | | String url = systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_INTERFACE_URL_PREFIX).getCode() |
| | | +systemDictDataBiz.queryByCode(Constants.TSM_PARAM,Constants.TMS_ORDER_DETAIL_URL).getCode(); |
| | | TmsBaseResponse<TmsOrderInfoResponse> response = sendHttpRequest(url,"合同详情接口",JSONObject.toJSONString(param) |
| | | ,new TypeReference< TmsBaseResponse<TmsOrderInfoResponse>>(){}); |
| | | return response; |
| | | } |
| | | |
| | | /** |