From 16f1a5b3c7717d10f3d26c87a827339e7e9b8b0c Mon Sep 17 00:00:00 2001 From: lsh <lsh123456> Date: 星期五, 07 十月 2022 15:12:34 +0800 Subject: [PATCH] # --- src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java | 39 ++++++++++++++++++++++++++++++++++++--- 1 files changed, 36 insertions(+), 3 deletions(-) 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 7ca0561..8f0e4a6 100644 --- a/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java +++ b/src/main/java/com/zy/asrs/service/impl/MainServiceImpl.java @@ -2005,16 +2005,26 @@ newSingle = 0;//娴嬭瘯瀹屾垚锛屽瘎瀛樺櫒鍦板潃娓呴浂锛�3===>>0 break; case 5://鏆傚仠淇″彿 - olsStatus = 5;//plc缁欏嚭鏆傚仠淇″彿 + olsStatus = 99;//plc缁欏嚭鏆傚仠淇″彿 newStatus = 0;//WCS鏀跺埌鏆傚仠淇″彿鍚庯紝鏇存柊testMast newSingle = 6;//鏆傚仠娴嬭瘯锛屽瘎瀛樺櫒鍦板潃锛�5===>>6 + break; + case 7://绱ф�ュ嚭搴撶‘璁ゅ厖鐢电嚎宸茬粡鎷斿嚭 + olsStatus = 99;//plc缁欏嚭鏆傚仠淇″彿 + newStatus = 0;//WCS鏀跺埌鏆傚仠淇″彿鍚庯紝鏇存柊testMast + newSingle = 6;//鏆傚仠娴嬭瘯锛屽瘎瀛樺櫒鍦板潃锛�7===>>6 + break; + case 8://瑙i櫎鏆傚仠 + olsStatus = 99; + newStatus = 0; + newSingle = 0;//娴嬭瘯澶嶆牳锛屽瘎瀛樺櫒鍦板潃锛�6===>>0 break; } TestMast testMast = testMastService.selectOne(new EntityWrapper<TestMast>() .eq("channel",(i+1)).eq("status",olsStatus));//鏌ユ壘鍘熸潵鐨勭姸鎬� if(null != testMast && - (devpThread.startSignal[i] == 1 || devpThread.startSignal[i] == 3 || devpThread.startSignal[i] == 5)){ + (devpThread.startSignal[i] == 1 || devpThread.startSignal[i] == 3)){ testMast.setStatus(newStatus); testMast.setModiTime(new Date()); if(!testMastService.update(testMast,new EntityWrapper<TestMast>() @@ -2027,11 +2037,34 @@ staProtocol.setStaNo(newSingle);//淇敼PLC瀵勫瓨鍣ㄥ湴鍧�鍊�,1==>2鎴�3==>0,5==>6 boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol)); if(!result){ - log.error("鏇存柊娴嬭瘯淇″彿澶辫触===>>[channel:{},locNo:{},barcode:{}]", i, testMast.getLocNo(), testMast.getBarcode()); + log.error("鏇存柊娴嬭瘯淇″彿澶辫触===>>[channel:{},locNo:{},barcode:{}]", i+1, testMast.getLocNo(), testMast.getBarcode()); // throw new CoolException("鏇存柊娴嬭瘯淇″彿澶辫触===>>" + i); } else { devpThread.startSignal[i] = newSingle; } + }else if (testMast == null && devpThread.startSignal[i] == 5){ + + }else if (testMast == null && devpThread.startSignal[i] == 7){ + LocMast locMast = locMastService.selectOne(new EntityWrapper<LocMast>() + .eq("channel",(i+1))); + if (locMast.getLocSts().equals("F")){ + locMast.setPackStatus(7); //7.绱ф�ュ嚭搴� + locMastService.update(locMast,new EntityWrapper<LocMast>() + .eq("channel",(i+1))); + } + //澶嶄綅PLC淇″彿锛屽�熺敤杈撻�佺珯鐐瑰疄浣撶被 + StaProtocol staProtocol = new StaProtocol(); + staProtocol.setSiteId(i*2);//瀵勫瓨鍣ㄥ湴鍧� + staProtocol.setStaNo(newSingle);//淇敼PLC瀵勫瓨鍣ㄥ湴鍧�鍊�,7==>6 + boolean result = MessageQueue.offer(SlaveType.Devp, devp.getId(), new Task(3, staProtocol)); + if(!result){ + log.error("鏇存柊搴撲綅绱ф�ュ嚭搴撲俊鍙峰け璐�===>>[channel:{},locNo:{},barcode:{}]", i+1, locMast.getLocNo(), locMast.getBarcode()); +// throw new CoolException("鏇存柊娴嬭瘯淇″彿澶辫触===>>" + i); + } else { + devpThread.startSignal[i] = newSingle; + } + }else if (testMast == null && devpThread.startSignal[i] == 8){ + } } -- Gitblit v1.9.1