#缓存队列bug fixed

Junjie

2024-09-11 f4bc29ba8a95c6beb49c69e17d7b0430ac081f43

#缓存队列bug fixed

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

@@ -187,6 +187,32 @@
                }catch (Exception e){
                    throw new CoolException("转发AGV任务出错" + e.getMessage());
                }
            }else {
                Task task = new Task();
                task.setUuid(String.valueOf(snowflakeIdWorker.nextId()));
                task.setTaskNo(String.valueOf(Utils.getTaskNo("IN")));
                task.setWmsTaskNo(param.getTaskNo());
                task.setTaskSts(TaskStsType.NEW_INBOUND.sts);
                task.setTaskCtg(taskCtg.getId());
                task.setPriority(priority);
                task.setOriginSite(param.getOriginSite());
                task.setOriginLoc(null);
                task.setDestSite(destSite);
                task.setDestLoc(param.getDestLoc());
                task.setZpallet(param.getBarcode());
                task.setIoTime(new Date());
                task.setStartTime(new Date());
                task.setStatus(1);
                task.setMemo("");
                task.setShuttleNo(null);//等待主线程分配小车
                task.setRecordLoc("Y");//记录库存信息
                task.setHostId(hostId);//临时控制只允许host为1
                task.setMemo(param.getEndSite());

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


 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/TaskCacheTimer.java

@@ -79,6 +79,12 @@
                    throw new CoolException("缓存删除失败");
                }
            }

            try {
                Thread.sleep(10000);
            } catch (InterruptedException e) {
                throw new RuntimeException(e);
            }
        }
    }