From 1da336624f8928ecc382fc92dd9ada56fd932481 Mon Sep 17 00:00:00 2001
From: whycq <913841844@qq.com>
Date: 星期三, 26 六月 2024 08:10:38 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/asrs/task/AutoMoveScheduler.java | 48 ++++++++++++++++++++++++++++++++++++++++++++----
1 files changed, 44 insertions(+), 4 deletions(-)
diff --git a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
index cb64c93..0275339 100644
--- a/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
+++ b/src/main/java/com/zy/asrs/task/AutoMoveScheduler.java
@@ -56,14 +56,14 @@
* ioType 108.鑷姩璋冩嫧
* crnNo :2鐩爣妤煎眰
*/
- @Scheduled(cron = "0/2 * * * * ? ")
- private void execute2(){
+ @Scheduled(cron = "0/3 * * * * ? ")
+ private synchronized void execute2(){
List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
.eq("wrk_sts", 22)
.andNew().eq("io_type",108)
.andNew()
.eq("crn_no",2).or().eq("crn_no",3)
- .orderBy("appe_time",true)
+ .orderBy("io_pri",false).orderBy("appe_time",true)
);
if (agvWrkMastList.isEmpty()) {
return;
@@ -110,6 +110,7 @@
List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
.eq("wrk_sts", 22)
.andNew().eq("io_type",111)
+ .orderBy("io_pri",false)
.orderBy("appe_time",true)
);
if (agvWrkMastList.isEmpty()) {
@@ -118,6 +119,27 @@
for (AgvWrkMast agvWrkMast : agvWrkMastList) {
try{
autoMoveHandler.start3(agvWrkMast);
+ } catch (Exception e){
+ log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"璋冩嫧鍑哄簱,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage());
+ }
+ }
+
+ }
+
+ @Scheduled(cron = "0/2 * * * * ? ")
+ private void execute4(){
+ List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
+ .eq("wrk_sts", 22)
+ .andNew().eq("io_type",114)
+ .orderBy("io_pri",false)
+ .orderBy("appe_time",true)
+ );
+ if (agvWrkMastList.isEmpty()) {
+ return;
+ }
+ for (AgvWrkMast agvWrkMast : agvWrkMastList) {
+ try{
+ autoMoveHandler.start4(agvWrkMast);
} catch (Exception e){
log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"璋冩嫧鍑哄簱,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage());
}
@@ -158,7 +180,8 @@
List<AgvWrkMast> agvWrkMastList = agvWrkMastService.selectList(new EntityWrapper<AgvWrkMast>()
.eq("wrk_sts", 214)
.eq("loc_no","")
- .eq("io_type",113));
+ .eq("io_type",113)
+ .orderBy("io_pri",false));
if (agvWrkMastList.isEmpty()) {
return;
}
@@ -219,6 +242,23 @@
}
}
+ private boolean determineFloorConnection(Integer floor){
+ try{
+ List<AgvBasDevp> agvBasDevps = agvBasDevpService.selectList(new EntityWrapper<AgvBasDevp>().eq("floor", floor).like("dev_no", "DB_"));
+ if (!agvBasDevps.isEmpty()){
+ for (AgvBasDevp agvBasDevp:agvBasDevps){
+ if (agvBasDevp.getInEnable().equals("Y")){
+ return false;
+ }
+ }
+ return true;
+ }
+ }catch (Exception e){
+ log.error("鍒ゆ柇褰撳墠妤煎眰鎺ラ┏浣嶆槸鍚﹀叏閮ㄥ叧闂紝寮傚父"+e.getMessage());
+ }
+ return false;
+ }
+
/**
* 绔欑偣鏄惁鑷姩
* 鑷姩锛� 鐢熸垚 109 鑷姩鍥炴祦
--
Gitblit v1.9.1