From 3845999a338b696f62f76b217bb871d5e759b37b Mon Sep 17 00:00:00 2001
From: Junjie <xjj@123>
Date: 星期日, 07 四月 2024 16:56:41 +0800
Subject: [PATCH] #

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/kernel/AnalyzeService.java |   93 ++++++++++++++++++++++++++++++++++++++++++++++
 1 files changed, 93 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 08280d0..f2ce497 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
@@ -4,6 +4,7 @@
 import com.zy.asrs.framework.common.Cools;
 import com.zy.asrs.wcs.core.domain.dto.MotionDto;
 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.model.enums.WorkZoneType;
@@ -982,6 +983,98 @@
         return motionList;
     }
 
+    /**
+     * 鐢熸垚灏忚溅鎵嬪姩鍔ㄤ綔
+     */
+    public List<Motion> generateShuttleManualMotion(Task task) {
+        List<Motion> motionList = new ArrayList<>();
+        if (task.getTaskSts() != TaskStsType.NEW_MOVE.getId()) {
+            return motionList;
+        }
 
+        String targetLoc = task.getDestLoc();//浠诲姟鐩爣(鍊熺敤瀛楁)
+        String targetSite = task.getDestSite();//浠诲姟绫诲瀷(鍊熺敤瀛楁)
+
+        //鑾峰彇绌挎杞︾被鍨�
+        DeviceType deviceType = deviceTypeService.getOne(new LambdaQueryWrapper<DeviceType>()
+                .eq(DeviceType::getFlag, String.valueOf(SlaveType.Shuttle))
+                .eq(DeviceType::getStatus, 1));
+        if (deviceType == null) {
+            return motionList;
+        }
+
+        Device device = deviceService.getOne(new LambdaQueryWrapper<Device>()
+                .eq(Device::getDeviceNo, task.getShuttleNo())
+                .eq(Device::getDeviceType, deviceType.getId())
+                .eq(Device::getHostId, task.getHostId())
+                .eq(Device::getStatus, 1));
+        if (device == null) {
+            return motionList;
+        }
+
+        ShuttleThread shuttleThread = (ShuttleThread) SlaveConnection.get(SlaveType.Shuttle, device.getId().intValue());
+        if (shuttleThread == null) {
+            return motionList;
+        }
+
+        ShuttleProtocol shuttleProtocol = shuttleThread.getStatus();
+        if (shuttleProtocol == null || shuttleProtocol.getShuttleNo() == null) {
+            return motionList;
+        }
+
+        if (targetSite.equals("moveLoc")) {//绉诲姩
+            String shuttleLocNo = shuttleProtocol.getCurrentLocNo();
+
+            // 鍒ゆ柇绌挎杞︽槸鍚﹀湪鐩爣灞�
+            if (Utils.getLev(shuttleLocNo) == Utils.getLev(targetLoc)) {
+
+                // 绌挎杞﹁蛋琛岃嚦鐩爣搴撲綅
+                motionList.addAll(kernelService.shuttleMove(
+                        MotionDto.build((dto -> {
+                            dto.setShuttleNo(shuttleProtocol.getShuttleNo().intValue());
+                            dto.setLocNo(shuttleLocNo);
+                        })),
+                        MotionDto.build((dto -> {
+                            dto.setShuttleNo(shuttleProtocol.getShuttleNo().intValue());
+                            dto.setLocNo(targetLoc);
+                        })),
+                        MotionCtgType.SHUTTLE_MOVE
+                ));
+
+            }
+        } else if (targetSite.equals("palletLift")) {
+            //鎵樼洏椤跺崌
+            motionList.add(Motion.build(motion -> {
+                motion.setDeviceCtg(DeviceCtgType.SHUTTLE.val());
+                motion.setDevice(String.valueOf(task.getShuttleNo()));
+                motion.setMotionCtg(MotionCtgType.SHUTTLE_PALLET_LIFT.val());
+            }));
+        } else if (targetSite.equals("palletDown")) {
+            //鎵樼洏涓嬮檷
+            motionList.add(Motion.build(motion -> {
+                motion.setDeviceCtg(DeviceCtgType.SHUTTLE.val());
+                motion.setDevice(String.valueOf(task.getShuttleNo()));
+                motion.setMotionCtg(MotionCtgType.SHUTTLE_PALLET_DOWN.val());
+            }));
+        } else if (targetSite.equals("chargeOpen")) {
+            //鍏呯數寮�
+            motionList.add(Motion.build(motion -> {
+                motion.setDeviceCtg(DeviceCtgType.SHUTTLE.val());
+                motion.setDevice(String.valueOf(task.getShuttleNo()));
+                motion.setMotionCtg(MotionCtgType.SHUTTLE_CHARGE_ON.val());
+            }));
+        } else if (targetSite.equals("chargeClose")) {
+            //鍏呯數鍏�
+            motionList.add(Motion.build(motion -> {
+                motion.setDeviceCtg(DeviceCtgType.SHUTTLE.val());
+                motion.setDevice(String.valueOf(task.getShuttleNo()));
+                motion.setMotionCtg(MotionCtgType.SHUTTLE_CHARGE_OFF.val());
+            }));
+        } else if (targetSite.equals("reset")) {
+            //澶嶄綅
+        }
+
+        return motionList;
+    }
 
 }

--
Gitblit v1.9.1