no message

skyouc

6 天以前 e046dba174365eb8934ee1e4206f09821145e876

 zy-asrs-wms/src/main/java/com/zy/asrs/wms/apis/wcs/schedule/ScheduleJobs.java

@@ -76,7 +76,8 @@
    @Transactional(rollbackFor = Exception.class)

    public void conveyorStart() {

        List<Task> tasks = taskService.list(new LambdaQueryWrapper<Task>()

                .eq(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id).eq(Task::getStatus, 1));

                .eq(Task::getTaskSts, TaskStsType.WCS_CONTAINER_RECEIVE.id)

                .eq(Task::getStatus, 1));

        tasks.forEach(task -> {

            try {

                ConveyorStarParam conveyorStarParam = new ConveyorStarParam();

@@ -87,6 +88,7 @@
                log.info("通知ESS输送线流动请求地址：{}，请求参数：{}", "http://192.168.2.200:9046/conveyor/moveContainer", JSONObject.toJSONString(conveyorStarParam));

                HttpHeaders headers = new HttpHeaders();

                headers.add("Content-Type", "application/json");

                headers.add("api-version", "v2.0");

                HttpEntity httpEntity = new HttpEntity<>(conveyorStarParam, headers);

                // 调用三方接口，将任务推送至ESS平台

                ResponseEntity<String> exchange = restTemplate.exchange("http://192.168.2.200:9046/conveyor/moveContainer", HttpMethod.POST, httpEntity, String.class);

@@ -108,9 +110,6 @@
                }

            } catch (Exception ex) {

                log.error(ex.getMessage());

            } finally {

                //如果异常修改禁用状态

               // taskService.update(new LambdaUpdateWrapper<Task>().set(Task::getStatus, 0).eq(Task::getId, task.getId()));

            }

        });



@@ -188,7 +187,6 @@
        }

    }





    /***

     * 入库任务---下发入库任务

     * 每隔3秒，刷新当前通知档列表，下发待入库订单至ESS

@@ -237,6 +235,7 @@
        log.info("下发入库任务请求地址：{}，请求参数：{}", "http://192.168.2.200:9046/task/create", JSONObject.toJSONString(tasksParam));

        HttpHeaders headers = new HttpHeaders();

        headers.add("Content-Type", "application/json");

        headers.add("api-version", "v2.0");

        HttpEntity httpEntity = new HttpEntity<>(tasksParam, headers);

        // 请求

        ResponseEntity<String> exchange = restTemplate.exchange("http://192.168.2.200:9046/task/create", HttpMethod.POST, httpEntity, String.class);