From 6a1546c0d0e56675b4b0cc936d8f2308f6fb2378 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 08 四月 2024 16:28:18 +0800
Subject: [PATCH] Merge branch 'Four-Way-Rack' of http://47.97.1.152:5880/r/zy-asrs-master into Four-Way-Rack

---
 zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/MotionTimer.java |  124 ++++++++++++++++++++--------------------
 1 files changed, 62 insertions(+), 62 deletions(-)

diff --git a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/MotionTimer.java b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/MotionTimer.java
index d8fcd42..7b1ce95 100644
--- a/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/MotionTimer.java
+++ b/zy-asrs-wcs/src/main/java/com/zy/asrs/wcs/core/timer/MotionTimer.java
@@ -108,68 +108,68 @@
         }
     }
 
-//    @Scheduled(cron = "0/1 * * * * ? ")
-//    public synchronized void executeWrkCharge() {
-//        Date now = new Date();
-//        // ANALYZE_INBOUND
-//        for (WrkCharge wrkCharge : wrkChargeMapper.selectByAnalyzeSts()) {
-//            Motion executingMotion = motionService.selectOfTop1(wrkCharge.getUuid(), MotionStsType.EXECUTING.val());
-//            if (executingMotion != null) {//瀛樺湪姝e湪鎵ц鐨刴otion
-//                continue;
-//            }
-//
-//            Motion motion = motionService.selectOfTop1(wrkCharge.getUuid(), MotionStsType.INIT.val());
-//            if (null != motion) {
-//                boolean result = this.executeMotion(motion);
-//                if (!result) {
-//                    continue;
-//                }
-//                // 鏇存柊wrkMast
-//                switch (WrkMastStsType.query(wrkCharge.getWrkSts())) {
-//                    case ANALYZE_CHARGE:
-//                        wrkCharge.setWrkSts(WrkMastStsType.EXECUTE_CHARGE.sts);
-//                        break;
-//                    case ANALYZE_MOVE:
-//                        wrkCharge.setWrkSts(WrkMastStsType.EXECUTE_MOVE.sts);
-//                        break;
-//                }
-//                wrkCharge.setModiTime(now);
-//                if (wrkChargeMapper.updateById(wrkCharge) == 0) {
-//                    log.error("{}鍏朵粬宸ヤ綔妗f洿鏂扮姸鎬佸け璐ワ紒", wrkCharge.getWrkNo());
-//                }
-//            }
-//        }
-//        // EXECUTE_INBOUND
-//        for (WrkCharge wrkCharge : wrkChargeMapper.selectByExecuteSts()) {
-//            if (!motionService.hasRunningMotion(wrkCharge.getUuid())) {
-//                Motion motion = motionService.selectOfTop1(wrkCharge.getUuid(), MotionStsType.WAITING.val());
-//                if (null != motion) {
-//                    boolean result = this.executeMotion(motion);
-//                    if (!result) {
-//                        continue;
-//                    }
-//                } else {
-//                    if (motionService.selectOfTop1(wrkCharge.getUuid(), MotionStsType.EXECUTING.val()) != null) {
-//                        continue;
-//                    }
-//
-//                    // 鏇存柊wrkMast
-//                    switch (WrkMastStsType.query(wrkCharge.getWrkSts())) {
-//                        case EXECUTE_CHARGE:
-//                            wrkCharge.setWrkSts(WrkMastStsType.CHARGE_WORKING.sts);
-//                            break;
-//                        case EXECUTE_MOVE:
-//                            wrkCharge.setWrkSts(WrkMastStsType.COMPLETE_MOVE.sts);
-//                            break;
-//                    }
-//                    wrkCharge.setModiTime(now);
-//                    if (wrkChargeMapper.updateById(wrkCharge) == 0) {
-//                        log.error("{}浠栧伐浣滄。鏇存柊鐘舵�佸け璐ワ紒", wrkCharge.getWrkNo());
-//                    }
-//                }
-//            }
-//        }
-//    }
+    @Scheduled(cron = "0/1 * * * * ? ")
+    public synchronized void executeChargeTask() {
+        Date now = new Date();
+        // ANALYZE_CHARGE
+        for (Task taskCharge : taskService.selectChargeByAnalyzeSts()) {
+            Motion executingMotion = motionService.selectOfTop1(taskCharge.getUuid(), MotionStsType.EXECUTING.val(), taskCharge.getHostId());
+            if (executingMotion != null) {//瀛樺湪姝e湪鎵ц鐨刴otion
+                continue;
+            }
+
+            Motion motion = motionService.selectOfTop1(taskCharge.getUuid(), MotionStsType.INIT.val(), taskCharge.getHostId());
+            if (null != motion) {
+                boolean result = this.executeMotion(motion);
+                if (!result) {
+                    continue;
+                }
+                // 鏇存柊Task
+                switch (TaskStsType.query(taskCharge.getTaskSts())) {
+                    case ANALYZE_CHARGE:
+                        taskCharge.setTaskSts(TaskStsType.EXECUTE_CHARGE.sts);
+                        break;
+                    case ANALYZE_MOVE:
+                        taskCharge.setTaskSts(TaskStsType.EXECUTE_MOVE.sts);
+                        break;
+                }
+                taskCharge.setUpdateTime(now);
+                if (!taskService.updateById(taskCharge)) {
+                    log.error("{}鍏朵粬宸ヤ綔妗f洿鏂扮姸鎬佸け璐ワ紒", taskCharge.getTaskNo());
+                }
+            }
+        }
+        // EXECUTE_CHARGE
+        for (Task taskCharge : taskService.selectChargeByExecuteSts()) {
+            if (!motionService.hasRunningMotion(taskCharge.getUuid(), taskCharge.getHostId())) {
+                Motion motion = motionService.selectOfTop1(taskCharge.getUuid(), MotionStsType.WAITING.val(), taskCharge.getHostId());
+                if (null != motion) {
+                    boolean result = this.executeMotion(motion);
+                    if (!result) {
+                        continue;
+                    }
+                } else {
+                    if (motionService.selectOfTop1(taskCharge.getUuid(), MotionStsType.EXECUTING.val(), taskCharge.getHostId()) != null) {
+                        continue;
+                    }
+
+                    // 鏇存柊Task
+                    switch (TaskStsType.query(taskCharge.getTaskSts())) {
+                        case EXECUTE_CHARGE:
+                            taskCharge.setTaskSts(TaskStsType.CHARGE_WORKING.sts);
+                            break;
+                        case EXECUTE_MOVE:
+                            taskCharge.setTaskSts(TaskStsType.COMPLETE_MOVE.sts);
+                            break;
+                    }
+                    taskCharge.setUpdateTime(now);
+                    if (!taskService.updateById(taskCharge)) {
+                        log.error("{}浠栧伐浣滄。鏇存柊鐘舵�佸け璐ワ紒", taskCharge.getTaskNo());
+                    }
+                }
+            }
+        }
+    }
 
     @Scheduled(cron = "0/1 * * * * ? ")
     public synchronized void executeManualTask() {

--
Gitblit v1.9.1