bug修改

pjb

2025-03-07 b41fe423d1a21e4b8f995d8eba98700dcb08e966

bug修改

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

@@ -107,56 +107,59 @@
                        .eq(Task::getTaskSts, TaskStsType.GENERATE_IN.id))

                .stream().sorted(Comparator.comparing(Task::getTaskSts))

                .collect(Collectors.toList());

        if (tasks.size() == 0) {

            return;

        }



        // 数据组装

//        PublishTasksParam tasksParam = new PublishTasksParam();

//        //TODO 确认是否需要单任务多容器码的需求，目前系统都是单容器码生成单任务，多任务明细（物料混装）

//        tasks.forEach(task -> {

//            List<TaskParam> params = new ArrayList<>();

//            TaskParam param = new TaskParam();

//            //设置容器编码

//            param.setTaskCode(task.getTaskNo());

//            List<TaskDescribe> taskDescribes = new ArrayList<>();

//            TaskDescribe describe = new TaskDescribe();

//            //设置目标库位，站点

//            describe.setContainerCode(task.getBarcode())

//                    .setToLocationCode(task.getTargetLoc())

//                    .setToStationCode(task.getTargetSite());

//            taskDescribes.add(describe);

//            param.setTaskDescribe(taskDescribes);

//            params.add(param);

//            tasksParam.setTasks(params);

//        });

//

//        tasksParam.setTaskType("putaway");

//        // TODO 多任务多订单，统一调度，是否会出现部分成功，部分失败的情况

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

//        MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();

//        // 设置请求参数

//        params.add("params", JSONObject.toJSONString(tasksParam));

//        log.info("请求地址：{}，请求参数：{}", Constant.ISSUE_TASK_OF_EVENT, JSONObject.toJSONString(tasksParam));

//        HttpHeaders headers = new HttpHeaders();

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

//        HttpEntity httpEntity = new HttpEntity<>(params, headers);

//        // 请求

//        ResponseEntity<String> exchange = restTemplate.exchange(Constant.ISSUE_TASK_OF_EVENT, HttpMethod.POST, httpEntity, String.class);

//        log.info("下发任务 返回结果：{}", exchange);

//        if (exchange.getBody() == null) {

//            throw new CoolException("下发任务失败！！");

//        } else {

//            CommonReponse reponse = (CommonReponse) JSON.parse(exchange.getBody());

//            if (reponse.getCode() == 0) {

                //请求成功后，统一修改所有任务档状态为入库执行中。

        PublishTasksParam tasksParam = new PublishTasksParam();

        //TODO 确认是否需要单任务多容器码的需求，目前系统都是单容器码生成单任务，多任务明细（物料混装）

        tasks.forEach(task -> {

            List<TaskParam> params = new ArrayList<>();

            TaskParam param = new TaskParam();

            //设置容器编码

            param.setTaskCode(task.getTaskNo());

            List<TaskDescribe> taskDescribes = new ArrayList<>();

            TaskDescribe describe = new TaskDescribe();

            //设置目标库位，站点

            describe.setContainerCode(task.getBarcode())

                    .setToLocationCode(task.getTargetLoc())

                    .setToStationCode(task.getTargetSite());

            taskDescribes.add(describe);

            param.setTaskDescribe(taskDescribes);

            params.add(param);

            tasksParam.setTasks(params);

        });



        tasksParam.setTaskType("putaway");

        // TODO 多任务多订单，统一调度，是否会出现部分成功，部分失败的情况

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

        MultiValueMap<String, Object> params = new LinkedMultiValueMap<>();

        // 设置请求参数

        params.add("params", JSONObject.toJSONString(tasksParam));

        log.info("请求地址：{}，请求参数：{}", "http://192.168.2.200:9046/task/create", JSONObject.toJSONString(tasksParam));

        HttpHeaders headers = new HttpHeaders();

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

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

        // 请求

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

        log.info("下发任务 返回结果：{}", exchange);

        if (exchange.getBody() == null) {

            throw new CoolException("下发任务失败！！");

        } else {

            CommonReponse reponse = (CommonReponse) JSON.parse(exchange.getBody());

            if (reponse.getCode() == 0) {

                //  请求成功后，统一修改所有任务档状态为入库执行中。

                tasks.forEach(task -> {

                    taskService.update(new LambdaUpdateWrapper<Task>()

                            .set(Task::getTaskSts, TaskStsType.WCS_EXECUTE_IN.id)

                            .eq(Task::getBarcode, task.getBarcode()));

                });

//            } else {

//                // TODO 请求失败需确认是否存在部分成功的情况，部分成功需要单独刷新成功的任务档状态

//                throw new CoolException(reponse.getMsg());

//            }

//        }

            } else {

                // TODO 请求失败需确认是否存在部分成功的情况，部分成功需要单独刷新成功的任务档状态

                throw new CoolException(reponse.getMsg());

            }

        }

    }






 zy-asrs-wms/src/main/java/com/zy/asrs/wms/asrs/controller/LocMapController.java

@@ -112,6 +112,9 @@
    @GetMapping("/locMap/getData/{lev}/auth")

    public R getMapData(@PathVariable("lev") Integer lev) {

        LocMap locMap = locMapService.getOne(new LambdaQueryWrapper<LocMap>().eq(LocMap::getMapLev, lev));

        if (locMap == null) {

            return R.ok();

        }

        //解析json地图数据

        List<ArrayList> arrayLists = JSON.parseArray(locMap.getData(), ArrayList.class);