From 7df4fd499fe3d1066d6b94ce8197af830ab342e8 Mon Sep 17 00:00:00 2001
From: Junjie <540245094@qq.com>
Date: 星期二, 03 九月 2024 15:08:21 +0800
Subject: [PATCH] #缓存队列bug fixed

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/OpenServiceImpl.java |   60 ++++++++++++++++++++++--------------------------------------
 1 files changed, 22 insertions(+), 38 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/OpenServiceImpl.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/OpenServiceImpl.java
index 443f8b1..bec6fb0 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/service/impl/OpenServiceImpl.java
+++ b/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);//涓存椂鎺у埗鍙厑璁竓ost涓�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);//涓存椂鎺у埗鍙厑璁竓ost涓�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();

--
Gitblit v1.9.1