From d251a0234fae2d58ff8a9d92069064617dc0a94b Mon Sep 17 00:00:00 2001 From: 18516761980 <4761516tqsxp> Date: 星期四, 09 六月 2022 13:36:43 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/controller/SiteController.java | 3 + src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 25 +++++++----- src/main/java/com/zy/core/CrnThread.java | 6 +++ src/main/java/com/zy/core/thread/MelsecCrnThread.java | 8 ++++ src/main/webapp/views/pipeline.html | 3 + src/main/java/com/zy/core/MainProcess.java | 12 ------ src/main/java/com/zy/asrs/domain/vo/SiteTableVo.java | 2 + src/main/resources/application.yml | 9 ---- 8 files changed, 37 insertions(+), 31 deletions(-) diff --git a/src/main/java/com/zy/asrs/controller/SiteController.java b/src/main/java/com/zy/asrs/controller/SiteController.java index 520935e..fdeb421 100644 --- a/src/main/java/com/zy/asrs/controller/SiteController.java +++ b/src/main/java/com/zy/asrs/controller/SiteController.java @@ -63,6 +63,8 @@ vo.setPakMk(staProtocol.isPakMk()?"Y":"N"); // 鍏ュ簱鏍囪 vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N"); // 绌烘澘淇″彿 vo.setStaNo(staProtocol.getStaNo()); // 鐩爣绔� +// vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "浣�" : "楂�"); //楂樹綆搴撲綅 + vo.setLocType1(devp.getDevNo()==102 ? "楂�" : "浣�"); } return R.ok().add(list); } @@ -137,6 +139,7 @@ vo.setPakMk(staProtocol.isPakMk()?"Y":"N"); // 闇�姹�1 vo.setEmptyMk(staProtocol.isEmptyMk()?"Y":"N"); // 绌烘澘淇″彿 vo.setStaNo(staProtocol.getStaNo()); // 鐩爣绔� + vo.setLocType1(staProtocol.isHigh() != staProtocol.isLow() && staProtocol.isLow() ? "浣�" : "楂�"); //楂樹綆搴撲綅 return R.ok().add(vo); } } diff --git a/src/main/java/com/zy/asrs/domain/vo/SiteTableVo.java b/src/main/java/com/zy/asrs/domain/vo/SiteTableVo.java index aa3f0d3..42b7bc9 100644 --- a/src/main/java/com/zy/asrs/domain/vo/SiteTableVo.java +++ b/src/main/java/com/zy/asrs/domain/vo/SiteTableVo.java @@ -35,4 +35,6 @@ // 鐩爣绔� private Short staNo = 0; + //楂樹綆搴撲綅 + private String locType1 = "-"; } diff --git a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java index 3f234cf..c40650e 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -90,8 +90,6 @@ @Value("${wms.url}") private String wmsUrl; - @Value("${crnBackHp.enable}") - private boolean crnBackHp; /** * 缁勬墭 @@ -531,6 +529,11 @@ log.error("{}鍙峰爢鍨涙満灏氭湭鍦ㄦ暟鎹簱杩涜缁存姢锛�", crn.getId()); continue; } + + if(crnThread.isBackHpFlag()){ + continue; + } + // 鍙湁褰撳爢鍨涙満绌洪棽 骞朵笖 鏃犱换鍔℃椂鎵嶇户缁墽琛� if (crnProtocol.getStatusType() == CrnStatusType.IDLE && crnProtocol.getTaskNo() == 0 && crnProtocol.getModeType() == CrnModeType.AUTO) { // 濡傛灉鏈�杩戜竴娆℃槸鍏ュ簱妯″紡 @@ -556,20 +559,15 @@ } // 搴撲綅绉昏浆 this.locToLoc(crn, crnProtocol); + this.crnRebackHp(crnProtocol, crnThread); -// if (crnBackHp) { -// -// //鍫嗗灈鏈烘病鏈夋墽琛屼腑浠诲姟锛岃澶囧瓨鍦ㄥ叆搴撲换鍔℃椂鍙洖鍘熺偣 -// this.crnRebackHp(crnProtocol); -// -// } } } /** * 鍥炲師鐐癸紝鍫嗗灈鏈烘病鏈夋墽琛屼腑浠诲姟锛岃澶囧瓨鍦ㄥ叆搴撲换鍔℃椂鍙洖鍘熺偣 */ - public synchronized void crnRebackHp(CrnProtocol crnProtocol){ + public synchronized void crnRebackHp(CrnProtocol crnProtocol, CrnThread crnThread){ // for (CrnSlave crn : slaveProperties.getCrn()) { // // 鑾峰彇鍫嗗灈鏈轰俊鎭� // CrnThread crnThread = (CrnThread) SlaveConnection.get(SlaveType.Crn, crn.getId()); @@ -597,12 +595,11 @@ return; } - //杈撻�佺嚎娌℃湁鍏ュ簱浠诲姟锛岃繃婊�2 if (wrkMastMapper.selectDevWorking(crnProtocol.getCrnNo()) == null) { return; } -// log.info("鍫嗗灈鏈哄彫鍥炲師鐐�==>>" + crn.getId() + "鍙峰爢鍨涙満鏈夊叆搴撲换鍔�,鍙洖鍘熺偣"); + log.info("鍫嗗灈鏈哄彫鍥炲師鐐�==>>" + crnProtocol.getCrnNo() + "鍙峰爢鍨涙満鏈夊叆搴撲换鍔�,鍙洖鍘熺偣"); // 鍛戒护涓嬪彂鍖� -------------------------------------------------------------------------- CrnCommand crnCommand = new CrnCommand(); crnCommand.setCrnNo(crnProtocol.getCrnNo()); // 鍫嗗灈鏈虹紪鍙� @@ -618,6 +615,7 @@ if (!MessageQueue.offer(SlaveType.Crn, crnProtocol.getCrnNo(), new Task(2, crnCommand))) { log.error("鍫嗗灈鏈哄洖鍘熺偣鍛戒护涓嬪彂澶辫触锛屽爢鍨涙満鍙�={}锛屼换鍔℃暟鎹�={}", crnProtocol.getCrnNo(), JSON.toJSON(crnCommand)); } + crnThread.setBackHpFlag(true); } // } } @@ -841,6 +839,11 @@ } log.error("{}浠诲姟鍑哄簱澶辫触锛屾祬搴撲綅鍫靛锛�", wrkMast.getWrkNo()); continue; + } else if (shallowLoc.getLocSts().equals("Q") || shallowLoc.getLocSts().equals("S")){ + WrkMast waitWrkMast = wrkMastMapper.selectByLocNo(shallowLocNo); + if (null != waitWrkMast && waitWrkMast.getWrkSts()==4) { + continue; + } } } diff --git a/src/main/java/com/zy/core/CrnThread.java b/src/main/java/com/zy/core/CrnThread.java index 70c3d75..7b4ded6 100644 --- a/src/main/java/com/zy/core/CrnThread.java +++ b/src/main/java/com/zy/core/CrnThread.java @@ -8,4 +8,10 @@ void setResetFlag(boolean flag); + void setBackHpFlag(boolean flag); + + /** + * 鍫嗗灈鏈烘槸鍚﹀湪鍥炲師鐐硅繍鍔ㄤ腑鏍囪 + */ + boolean isBackHpFlag(); } diff --git a/src/main/java/com/zy/core/MainProcess.java b/src/main/java/com/zy/core/MainProcess.java index 1ef107e..c7ed6a0 100644 --- a/src/main/java/com/zy/core/MainProcess.java +++ b/src/main/java/com/zy/core/MainProcess.java @@ -24,9 +24,6 @@ private MainServiceImpl mainService; // 鎵�灞炵嚎绋� private Thread thread; - @Value("${crnBackHp.enable}") - private boolean crnBackHp; - private boolean look = true; /** * =====>> 寮�濮嬪伐浣� @@ -69,15 +66,6 @@ mainService.ledExecute(); // 鍏朵粬 ===>> LED鏄剧ず鍣ㄥ浣嶏紝鏄剧ず榛樿淇℃伅 mainService.ledReset(); - -// if (crnBackHp) { -// if (look) { -// //鍫嗗灈鏈烘病鏈夋墽琛屼腑浠诲姟锛岃澶囧瓨鍦ㄥ叆搴撲换鍔℃椂鍙洖鍘熺偣 -// mainService.crnRebackHp(); -// } -// } -// look = !look; - mainService.outOfDevp(); diff --git a/src/main/java/com/zy/core/thread/MelsecCrnThread.java b/src/main/java/com/zy/core/thread/MelsecCrnThread.java index 3df19a6..cb42c1f 100644 --- a/src/main/java/com/zy/core/thread/MelsecCrnThread.java +++ b/src/main/java/com/zy/core/thread/MelsecCrnThread.java @@ -43,6 +43,11 @@ private short heartBeatVal = 1; private boolean resetFlag = false; + /** + * 鍫嗗灈鏈烘槸鍚﹀湪鍥炲師鐐硅繍鍔ㄤ腑鏍囪 + */ + private boolean backHpFlag = false; + public MelsecCrnThread(CrnSlave slave) { this.slave = slave; } @@ -191,6 +196,9 @@ if (crnProtocol.getStatusType().equals(CrnStatusType.WAITING)) { log.error("-------------------------------------------绗竴姝ャ�乕鍫嗗灈鏈哄彿锛歿}][宸ヤ綔鍙凤細{}]==>> 鐘舵�佷负90锛岀瓑寰呯‘璁わ紒锛�",slave.getId(),crnProtocol.getTaskNo()); if (resetFlag) { + if(crnProtocol.getTaskNo()==9999){ + backHpFlag = false; + } CrnCommand crnCommand = new CrnCommand(); crnCommand.setAckFinish((short)1); if (write(crnCommand)) { diff --git a/src/main/resources/application.yml b/src/main/resources/application.yml index eb77c87..ce2f08e 100644 --- a/src/main/resources/application.yml +++ b/src/main/resources/application.yml @@ -9,10 +9,7 @@ datasource: driver-class-name: com.microsoft.sqlserver.jdbc.SQLServerDriver # url: jdbc:sqlserver://47.97.1.152:51433;databasename=xgmasrs - # username: sa - # password: Zoneyung@zy56$ - url: jdbc:sqlserver://192.168.4.15:1433;databasename=klsasrs2 -# url: jdbc:sqlserver://localhost:1433;databasename=xgmasrs + url: jdbc:sqlserver://localhost:1433;databasename=klsasrs2 username: sa password: sa@123 mvc: @@ -39,10 +36,6 @@ wms: url: localhost:8080/klswms - -#鍫嗗灈鏈烘病鏈夋墽琛屼腑浠诲姟锛岃緭閫佹湁鍏ュ簱浠诲姟锛屽彨鍥炲師鐐� -crnBackHp: - enable: false # 涓嬩綅鏈洪厤缃� wcs-slave: diff --git a/src/main/webapp/views/pipeline.html b/src/main/webapp/views/pipeline.html index 56decc6..01be111 100644 --- a/src/main/webapp/views/pipeline.html +++ b/src/main/webapp/views/pipeline.html @@ -73,6 +73,7 @@ <th>鍏ュ簱鏍囪</th> <th>绌烘澘淇″彿</th> <th>鐩爣绔�</th> + <th>楂樹綆搴撲綅</th> </tr> </thead> <!-- 琛ㄦ牸鍐呭 --> @@ -202,6 +203,7 @@ setVal(tr.children("td").eq(6), table[i-1].pakMk); setVal(tr.children("td").eq(7), table[i-1].emptyMk); setVal(tr.children("td").eq(8), table[i-1].staNo); + setVal(tr.children("td").eq(9), table[i-1].locType1); } } else if (res.code === 403){ window.location.href = baseUrl+"/login"; @@ -287,6 +289,7 @@ " <td></td>\n" + " <td></td>\n" + " <td></td>\n" + + " <td></td>\n" + " </tr>\n"; } $('#site-table tbody').after(html); -- Gitblit v1.9.1