From 2a7fd275313003968fc186ee4617aec4eca90266 Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期六, 10 五月 2025 16:55:41 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java |   94 +++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 94 insertions(+), 0 deletions(-)

diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
index 7ef38e2..f6068c0 100644
--- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
+++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java
@@ -6,6 +6,7 @@
 import com.core.exception.CoolException;
 import com.zy.asrs.domain.enums.TaskStatusType;
 import com.zy.asrs.entity.*;
+import com.zy.asrs.entity.param.GenerateAgvTaskParam;
 import com.zy.asrs.mapper.*;
 import com.zy.asrs.service.*;
 import com.zy.common.utils.HttpHandler;
@@ -57,11 +58,104 @@
     private CommandInfoService commandInfoService;
     @Autowired
     private ApiLogService apiLogService;
+    @Autowired
+    private OpenService openService;
     @Value("${wcs.urlWcs}")
     private String wcsUrl;
     @Value("${wcs.inboundTaskApplyPathWcs}")
     private String wcsInboundTaskApplyPath;
 
+    public synchronized void demo() {
+        boolean demoEnable = false;
+        Config demoEnableConfig = configService.selectByCode("demoEnable");
+        if(demoEnableConfig != null) {
+            demoEnable = Boolean.parseBoolean(demoEnableConfig.getValue());
+        }
+
+        if (!demoEnable) {
+            return;
+        }
+
+        //婕旂ず妯″紡-AGV鍑哄簱
+        demoAgvOut();
+        //婕旂ず妯″紡-AGV鍏ュ簱
+        demoAgvIn();
+        //婕旂ず妯″紡-鍥涘悜搴撳嚭搴�
+        demoShuttleOut();
+        //婕旂ず妯″紡-鍥涘悜搴撳叆搴�
+        demoShuttleIn();
+    }
+
+    //婕旂ず妯″紡-AGV鍑哄簱
+    private synchronized void demoAgvOut() {
+        LocMast locMast = locMastService.selectByLocNo("1100601");
+        if(locMast == null) {
+            return;
+        }
+
+        if (!locMast.getLocSts().equals("O")) {
+            return;
+        }
+
+        List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>()
+                .eq("mk", "agv")
+                .eq("loc_sts", "F")
+                .notIn("loc_no", "0900601")
+        );
+
+        if (locMasts.isEmpty()) {
+            return;
+        }
+
+        LocMast originLocMast = locMasts.get(0);
+
+        //鐢熸垚AGV鍑哄簱浠诲姟
+        GenerateAgvTaskParam param = new GenerateAgvTaskParam();
+        param.setOriginPoint(originLocMast.getLocNo());
+        param.setTargetPoint(locMast.getLocNo());
+        openService.generateAgvTask(param);
+    }
+
+    //婕旂ず妯″紡-AGV鍏ュ簱
+    private synchronized void demoAgvIn() {
+        LocMast locMast = locMastService.selectByLocNo("0900601");
+        if(locMast == null) {
+            return;
+        }
+
+        if (!locMast.getLocSts().equals("F")) {
+            return;
+        }
+
+        List<LocMast> locMasts = locMastService.selectList(new EntityWrapper<LocMast>()
+                .eq("mk", "agv")
+                .eq("loc_sts", "O")
+                .notIn("loc_no", "1100601")
+        );
+
+        if (locMasts.isEmpty()) {
+            return;
+        }
+
+        LocMast targetLocMast = locMasts.get(0);
+
+        //鐢熸垚AGV鍑哄簱浠诲姟
+        GenerateAgvTaskParam param = new GenerateAgvTaskParam();
+        param.setOriginPoint(locMast.getLocNo());
+        param.setTargetPoint(targetLocMast.getLocNo());
+        openService.generateAgvTask(param);
+    }
+
+    //婕旂ず妯″紡-鍥涘悜搴撳嚭搴�
+    private synchronized void demoShuttleOut() {
+
+    }
+
+    //婕旂ず妯″紡-鍥涘悜搴撳叆搴�
+    private synchronized void demoShuttleIn() {
+
+    }
+
     /**
      * 鍫嗗灈鏈虹珯鍑哄簱鍒板嚭搴撶珯
      */

--
Gitblit v1.9.1