From dcc528dae89242366a86e8b3709479621b95b0c0 Mon Sep 17 00:00:00 2001
From: zjj <3272660260@qq.com>
Date: 星期六, 22 六月 2024 13:48:09 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java |   38 ++++++++++++++++++++++++++++++++++++++
 1 files changed, 38 insertions(+), 0 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
index 13cf97a..43aae13 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java
@@ -3,11 +3,13 @@
 import com.baomidou.mybatisplus.core.conditions.query.LambdaQueryWrapper;
 import com.zy.asrs.framework.common.Cools;
 import com.zy.asrs.wcs.core.domain.dto.MotionDto;
+import com.zy.asrs.wcs.core.entity.BasConveyorPath;
 import com.zy.asrs.wcs.core.entity.ShuttleStandby;
 import com.zy.asrs.wcs.core.entity.Task;
 import com.zy.asrs.wcs.core.model.enums.DeviceCtgType;
 import com.zy.asrs.wcs.core.model.enums.MotionCtgType;
 import com.zy.asrs.wcs.core.model.enums.TaskStsType;
+import com.zy.asrs.wcs.core.service.BasConveyorPathService;
 import com.zy.asrs.wcs.core.service.ShuttleStandbyService;
 import com.zy.asrs.wcs.core.service.TaskService;
 import com.zy.asrs.wcs.core.utils.ConveyorDispatcher;
@@ -53,6 +55,8 @@
     private DeviceService deviceService;
     @Autowired
     private ShuttleStandbyService shuttleStandbyService;
+    @Autowired
+    private BasConveyorPathService basConveyorPathService;
 
     public List<Motion> generateMotion(Task task) {
         List<Motion> motionList = new ArrayList<>();
@@ -492,6 +496,14 @@
             //绌挎杞﹀嚭鎻愬崌鏈哄悗灏忚溅寰呮満浣�
             String shuttleFromLiftStandbyLoc = shuttleStandbyFrom.getStandbyLoc();
 
+            //鑾峰彇杈撻�佺嚎璺緞
+            BasConveyorPath basConveyorPath = basConveyorPathService.getOne(new LambdaQueryWrapper<BasConveyorPath>()
+                    .eq(BasConveyorPath::getDeviceStn, task.getOriginSite())
+                    .eq(BasConveyorPath::getDeviceNo, liftProtocol.getLiftNo()));
+            if (basConveyorPath == null) {
+                return motionList;
+            }
+
             /**
              * 鍑哄簱
              * 涓�銆佸嚭搴撹捣濮嬪眰鏈夌┛姊溅
@@ -630,6 +642,19 @@
                             dto.setLocNo(shuttleFromLiftStandbyLoc);
                         })),
                         MotionCtgType.SHUTTLE_MOVE
+                ));
+
+                // 杈撻�佺嚎杩愯緭鑷冲嚭搴撳彛
+                motionList.addAll(kernelService.conveyorOutbound(
+                        MotionDto.build((dto -> {
+                            dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+                            dto.setStaNo(basConveyorPath.getDeviceStn());
+                        })),
+                        MotionDto.build((dto -> {
+                            dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+                            dto.setStaNo(basConveyorPath.getStnNo());
+                        })),
+                        MotionCtgType.CONVEYOR_OUTBOUND
                 ));
 
             /**
@@ -877,6 +902,19 @@
                         MotionCtgType.SHUTTLE_MOVE
                 ));
 
+                // 杈撻�佺嚎杩愯緭鑷冲嚭搴撳彛
+                motionList.addAll(kernelService.conveyorOutbound(
+                        MotionDto.build((dto -> {
+                            dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+                            dto.setStaNo(basConveyorPath.getDeviceStn());
+                        })),
+                        MotionDto.build((dto -> {
+                            dto.setDevpNo(basConveyorPath.getDeviceId().intValue());
+                            dto.setStaNo(basConveyorPath.getStnNo());
+                        })),
+                        MotionCtgType.CONVEYOR_OUTBOUND
+                ));
+
             }
 
         }

--
Gitblit v1.9.1