#缓存队列bug fixed

Junjie

2024-09-03 7df4fd499fe3d1066d6b94ce8197af830ab342e8

#缓存队列bug fixed

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

@@ -302,45 +302,29 @@
            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")));
        task.setWmsTaskNo(param.getTaskNo());
        task.setTaskSts(TaskStsType.NEW_OUTBOUND.sts);
        task.setTaskCtg(taskCtg.getId());
        task.setPriority(priority);
        task.setOriginSite(originSite);
        task.setOriginLoc(param.getOriginLoc());
        task.setDestSite(param.getDestSite());
        task.setDestLoc(null);
        task.setIoTime(new Date());
        task.setStartTime(new Date());
        task.setStatus(1);
        task.setMemo(param.getEndSite());
        task.setShuttleNo(null);//等待主线程分配小车
        task.setRecordLoc("Y");//记录库存信息
        task.setHostId(hostId);//临时控制只允许host为1
        task.setZpallet(param.getZpallet());

                    Task task = new Task();
                    task.setUuid(String.valueOf(snowflakeIdWorker.nextId()));
                    task.setTaskNo(String.valueOf(Utils.getTaskNo("OUT")));
                    task.setWmsTaskNo(param.getTaskNo());
                    task.setTaskSts(TaskStsType.NEW_OUTBOUND.sts);
                    task.setTaskCtg(taskCtg.getId());
                    task.setPriority(priority);
                    task.setOriginSite(originSite);
                    task.setOriginLoc(param.getOriginLoc());
                    task.setDestSite(param.getDestSite());
                    task.setDestLoc(null);
                    task.setIoTime(new Date());
                    task.setStartTime(new Date());
                    task.setStatus(1);
                    task.setMemo(param.getEndSite());
                    task.setShuttleNo(null);//等待主线程分配小车
                    task.setRecordLoc("Y");//记录库存信息
                    task.setHostId(hostId);//临时控制只允许host为1
                    task.setZpallet(param.getZpallet());

                    boolean result = taskService.save(task);
                    if (!result) {
                        throw new CoolException("生成出库任务失败！");
                    }

                }catch (Exception e){
                    throw new CoolException("转发AGV任务出错" + e.getMessage());
                }
            }
        boolean result = taskService.save(task);
        if (!result) {
            throw new CoolException("生成出库任务失败！");
        }

        return R.ok();