#缓存队列bug fixed

Junjie

2024-09-03 6294dd1b096fd4a77864dd4680d58a814acd7a08

#缓存队列bug fixed

 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/OpenServiceImpl.java

@@ -148,6 +148,17 @@
            priority = param.getPriority();
        }

        if (createWcsTaskParam != null) {
            //转发agv
            if (!createWcsTaskParam.getFrmPos().equals("06YZ0001")){
                try {
                    AgvTaskCreateParam agvTaskCreateParam = new AgvTaskCreateParam();
                    getInRequestParam(agvTaskCreateParam, createWcsTaskParam);
                    String httpRequest = doHttpRequest(agvTaskCreateParam, "172.18.16.248:443", "/rcs/rtas/api/robot/controller/task/submit");
                    if (!httpRequest.equals("SUCCESS")){
                        throw new CoolException("转发AGV任务失败" + httpRequest);
                    }

        Task task = new Task();
        task.setUuid(String.valueOf(snowflakeIdWorker.nextId()));
        task.setTaskNo(String.valueOf(Utils.getTaskNo("IN")));
@@ -172,17 +183,6 @@
        boolean result = taskService.save(task);
        if (!result) {
            throw new CoolException("生成入库任务失败！");
        }

        if (createWcsTaskParam != null) {
            //转发agv
            if (!createWcsTaskParam.getFrmPos().equals("06YZ0001")){
                try {
                    AgvTaskCreateParam agvTaskCreateParam = new AgvTaskCreateParam();
                    getInRequestParam(agvTaskCreateParam, createWcsTaskParam);
                    String httpRequest = doHttpRequest(agvTaskCreateParam, "172.18.16.248:443", "/rcs/rtas/api/robot/controller/task/submit");
                    if (!httpRequest.equals("SUCCESS")){
                        throw new CoolException("转发AGV任务失败" + httpRequest);
                    }
                }catch (Exception e){
                    throw new CoolException("转发AGV任务出错" + e.getMessage());
@@ -302,6 +302,16 @@
            priority = param.getPriority();
        }

        if (createWcsTaskParam != null) {
            if (!createWcsTaskParam.getFrmPos().equals("06YZ0001")){
                try {
                    AgvTaskCreateParam agvTaskCreateParam = new AgvTaskCreateParam();
                    getInRequestParam(agvTaskCreateParam, createWcsTaskParam);
                    String httpRequest = doHttpRequest(agvTaskCreateParam, "172.18.16.248:443", "/rcs/rtas/api/robot/controller/task/submit");
                    if (!httpRequest.equals("SUCCESS")){
                        throw new CoolException("转发AGV任务失败" + httpRequest);
                    }

        Task task = new Task();
        task.setUuid(String.valueOf(snowflakeIdWorker.nextId()));
        task.setTaskNo(String.valueOf(Utils.getTaskNo("OUT")));
@@ -327,15 +337,6 @@
            throw new CoolException("生成出库任务失败！");
        }

        if (createWcsTaskParam != null) {
            if (!createWcsTaskParam.getFrmPos().equals("06YZ0001")){
                try {
                    AgvTaskCreateParam agvTaskCreateParam = new AgvTaskCreateParam();
                    getInRequestParam(agvTaskCreateParam, createWcsTaskParam);
                    String httpRequest = doHttpRequest(agvTaskCreateParam, "172.18.16.248:443", "/rcs/rtas/api/robot/controller/task/submit");
                    if (!httpRequest.equals("SUCCESS")){
                        throw new CoolException("转发AGV任务失败" + httpRequest);
                    }
                }catch (Exception e){
                    throw new CoolException("转发AGV任务出错" + e.getMessage());
                }