From 5e4d17f6a07256743a7708d8a3f5ee63fddbb040 Mon Sep 17 00:00:00 2001 From: tqs <56479841@qq.com> Date: 星期五, 31 五月 2024 09:16:49 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java | 45 ++++++++++++++++++++++++++++++++------------- 1 files changed, 32 insertions(+), 13 deletions(-) diff --git a/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java b/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java index 79c41fc..3b1d4fc 100644 --- a/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java +++ b/src/main/java/com/zy/asrs/task/AgvWrkMastScheduler.java @@ -50,15 +50,22 @@ .andNew().eq("io_type",53) .or().eq("io_type",1) .or().eq("io_type",57) + .or().eq("io_type",58) .or().eq("io_type",10) .or().eq("io_type",11) .or().eq("io_type",12) .or().eq("io_type",108) .or().eq("io_type",109) - .or().eq("io_type",112)); + .or().eq("io_type",111) + .or().eq("io_type",112) + .or().eq("io_type",113)); if(!Cools.isEmpty(agvWrkMastList)){ agvWrkMastList.stream().forEach(agvWrkMast -> { - agvWrkMastHandler.completedPutWayWrk(agvWrkMast); + try{ + agvWrkMastHandler.completedPutWayWrk(agvWrkMast); + } catch (Exception e){ + log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负205,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage()); + } }); } } @@ -74,10 +81,15 @@ .or().eq("io_type",101)); if(!Cools.isEmpty(agvWrkMastList)){ agvWrkMastList.stream().forEach(agvWrkMast -> { - ReturnT<String> returnT = agvWrkMastHandler.completedCarryWrk(agvWrkMast); + try{ + agvWrkMastHandler.completedCarryWrk(agvWrkMast); + } catch (Exception e){ + log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负206,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage()); + } }); } } + /* 瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负206.鍑哄簱瀹屾垚 涓� (101.鍑哄簱 || 110.绌烘澘鍑哄簱) @@ -90,7 +102,11 @@ .or().eq("io_type",101)); if(!Cools.isEmpty(agvWrkMastList)){ agvWrkMastList.stream().forEach(agvWrkMast -> { - ReturnT<String> returnT = agvWrkMastHandler.completedCarryWrk2(agvWrkMast); + try{ + agvWrkMastHandler.completedCarryWrk2(agvWrkMast); + } catch (Exception e){ + log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负206,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage()); + } }); } } @@ -109,18 +125,20 @@ .or().eq("io_type", 1) .or().eq("io_type", 10) .or().eq("io_type", 57) + .or().eq("io_type", 58) .or().eq("io_type", 11) .or().eq("io_type", 12) .or().eq("io_type", 109) .or().eq("io_type", 108) - .or().eq("io_type", 112)).getRecords(); + .or().eq("io_type", 112) + .or().eq("io_type", 113)).getRecords(); if(!Cools.isEmpty(agvWrkMastList)){ agvWrkMastList.forEach(agvWrkMast -> { - try { + try{ agvWrkMastHandler.startPutWayWrk(agvWrkMast); - } catch (IOException e) { - log.error(e.getMessage()); + } catch (Exception e){ + log.error("宸ヤ綔鍙�"+agvWrkMast.getWrkNo()+"瀹氭椂澶勭悊AGV宸ヤ綔妗d腑宸ヤ綔鐘舵�佷负206,澶勭悊澶辫触锛�===銆嬪紓甯稿師鍥狅細"+e.getMessage()); } }); } @@ -162,7 +180,9 @@ .or().eq("io_type", 103) .or().eq("io_type", 11) .or().eq("io_type", 110) - .or().eq("io_type", 107)).getRecords(); + .or().eq("io_type", 107) + .or().eq("io_type", 109) + .or().eq("io_type", 108)).getRecords(); if(!Cools.isEmpty(agvWrkMastList)){ List<String> devNos = new ArrayList<>(); @@ -186,15 +206,14 @@ agvWrkMastWorking = agvWrkMastService.selectOne(new EntityWrapper<AgvWrkMast>() .eq("source_loc_no",agvWrkMast.getLocNo()) - .lt("loc_sts",204L)); + .le("wrk_sts",204L)); if(!Cools.isEmpty(agvWrkMastWorking)){ return; } - agvWrkMastHandler.startPutWayWrk(agvWrkMast); - } catch (IOException e) { - log.error(e.getMessage()); + } catch (Exception e) { + log.error("鎼繍锛岀粺鎸囧嚭搴撱�佺Щ搴撱�佺偣鍒扮偣鎼繍绛�"+e.getMessage()); } }); } -- Gitblit v1.9.1