#
1
2 天以前 4e185f9a4d5ba2dffc922c2970badfe0a398e1c5
#
2个文件已修改
20 ■■■■ 已修改文件
rsf-open-api/src/main/java/com/vincent/rsf/openApi/config/PlatformProperties.java 8 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/impl/WmsWcsServiceImpl.java 12 ●●●● 补丁 | 查看 | 原始文档 | blame | 历史
rsf-open-api/src/main/java/com/vincent/rsf/openApi/config/PlatformProperties.java
@@ -71,11 +71,11 @@
    @ConfigurationProperties(prefix = "platform.wcs")
    public class WcsApi {
        /**
         * rcs调用路径
         * wcs调用路径
         */
        private String host;
        /**rcs调用端口**/
        /**wcs调用端口**/
        private String port;
    }
@@ -86,11 +86,11 @@
    @ConfigurationProperties(prefix = "platform.hk")
    public class HkApi {
        /**
         * rcs调用路径
         * hkRcs调用路径
         */
        private String host;
        /**rcs调用端口**/
        /**hkRcs调用端口**/
        private String port;
    }
rsf-open-api/src/main/java/com/vincent/rsf/openApi/service/impl/WmsWcsServiceImpl.java
@@ -129,15 +129,15 @@
    public R wcsReassignLoc(WcsReassignLocParam params)  {
        String createInTask =  wmsApi.getHost() + ":" + wmsApi.getPort() + WmsConstant.WCS_REASSIGN_LOC;
        /**WMS基础配置链接*/
        log.info("WCS任务上报通知,请求地址: {}, 请求参数: {}", createInTask , JSONObject.toJSONString(params));
        log.info("WCS申请任务重新分配入库,请求地址: {}, 请求参数: {}", createInTask , JSONObject.toJSONString(params));
        HttpHeaders headers = new HttpHeaders();
        headers.add("Content-Type", "application/json");
        headers.add("api-version", "v2.0");
        HttpEntity httpEntity = new HttpEntity(params, headers);
        ResponseEntity<String> exchange = restTemplate.exchange(createInTask, HttpMethod.POST, httpEntity, String.class);
        log.info("WCS任务上报通知,响应结果: {}", exchange);
        log.info("WCS申请任务重新分配入库,响应结果: {}", exchange);
        if (Objects.isNull(exchange.getBody())) {
            return R.error().add("WCS任务上报通知告知wms返回参数为空!!!");
            return R.error().add("WCS申请任务重新分配入库告知wms返回参数为空!!!");
        } else {
            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.coercionConfigDefaults()
@@ -168,15 +168,15 @@
    public R wcsChangeLoc(WcsChangeLocParam params)  {
        String createInTask =  wmsApi.getHost() + ":" + wmsApi.getPort() + WmsConstant.WCS_CHANGE_LOC;
        /**WMS基础配置链接*/
        log.info("WCS任务上报通知,请求地址: {}, 请求参数: {}", createInTask , JSONObject.toJSONString(params));
        log.info("WCS申请在库库位更换库位,请求地址: {}, 请求参数: {}", createInTask , JSONObject.toJSONString(params));
        HttpHeaders headers = new HttpHeaders();
        headers.add("Content-Type", "application/json");
        headers.add("api-version", "v2.0");
        HttpEntity httpEntity = new HttpEntity(params, headers);
        ResponseEntity<String> exchange = restTemplate.exchange(createInTask, HttpMethod.POST, httpEntity, String.class);
        log.info("WCS任务上报通知,响应结果: {}", exchange);
        log.info("WCS申请在库库位更换库位,响应结果: {}", exchange);
        if (Objects.isNull(exchange.getBody())) {
            return R.error().add("WCS任务上报通知告知wms返回参数为空!!!");
            return R.error().add("WCS申请在库库位更换库位告知wms返回参数为空!!!");
        } else {
            ObjectMapper objectMapper = new ObjectMapper();
            objectMapper.coercionConfigDefaults()