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