From 58365ea8a02e8adee1b56948085998107f9a80b3 Mon Sep 17 00:00:00 2001 From: Junjie <fallin.jie@qq.com> Date: 星期二, 26 九月 2023 20:46:10 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/thread/SiemensDevpThread.java | 34 ++++++++++------------------------ 1 files changed, 10 insertions(+), 24 deletions(-) diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java index 37acf7a..296f4f2 100644 --- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java +++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java @@ -41,7 +41,7 @@ private SiemensS7Net siemensS7Net; private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>(); private short heartBeatVal = 1; - private int barcodeSize = 1; + private int barcodeSize = 9; public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{ add(100);add(101); add(102);add(103); @@ -52,6 +52,9 @@ add(300);add(301); add(340);add(341); add(345);add(346); + add(303);add(317); + add(325);add(331); + add(333);add(339); }}; public static final ArrayList<Integer> outInStaNos = new ArrayList<Integer>() {{ @@ -147,11 +150,11 @@ } } Thread.sleep(200); - OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB1001.0", (short) (staNos.size())); + OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB1001.0", (short) (staNos.size()*2)); if (result1.IsSuccess) { for (int i = 0; i < staNos.size(); i++) { Integer siteId = staNos.get(i); // 绔欑偣缂栧彿 - boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i, 1); + boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i*2, 1); StaProtocol staProtocol = station.get(siteId); staProtocol.setAutoing(status[0]); // 鑷姩 staProtocol.setLoading(status[1]); // 鏈夌墿 @@ -170,32 +173,15 @@ //璇绘潯鐮� Thread.sleep(100); - OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB100.200",(short)24); + OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB1000.200", (short) 72); if (result2.IsSuccess) { - for (int i = 0; i <= barcodeSize; i++) { -// byte[] bytes = siemensS7Net.getByteTransform().TransByte(result2.Content, i * 8, 8); -// String barcode = CommonUtils.bytesToBarcode(bytes); + for (int i = 0; i < barcodeSize; i++) { String barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,8, "UTF-8"); BarcodeThread barcodeThread = (BarcodeThread) SlaveConnection.get(SlaveType.Barcode, i + 1); if(!Cools.isEmpty(barcodeThread) && !barcodeThread.getBarcode().equals(barcode)) { barcodeThread.setBarcode(barcode); } } - } - - // 鍏呯數淇″彿浣�1 - Thread.sleep(50); - OperateResultExOne<byte[]> result32 = siemensS7Net.Read("DB102.109", (short)1); - if (result32.IsSuccess) { - boolean[] status = siemensS7Net.getByteTransform().TransBool(result32.Content, 0, 1); - charge0 = status[0]; //1:鍙互鍏呯數 0锛氬彲鑳界绾� 鍙兘鍦ㄥ厖鐢� - } - // 鍏呯數淇″彿浣�2 - Thread.sleep(50); - OperateResultExOne<byte[]> result31 = siemensS7Net.Read("DB100.201", (short)1); - if (result31.IsSuccess) { - boolean[] status = siemensS7Net.getByteTransform().TransBool(result31.Content, 0, 1); - charge1 = status[0]; } // 澶栧舰妫�娴� - 102 @@ -417,10 +403,10 @@ //浠诲姟涓嬪彂鎴愬姛鏍囪瘑 boolean writeFlag = false; while(writeCount < 5){ - writeResult = siemensS7Net.Write("DB100." + index*4, array); // 宸ヤ綔鍙枫�佺洰鏍囩珯 + writeResult = siemensS7Net.Write("DB1000." + index*4, array); // 宸ヤ綔鍙枫�佺洰鏍囩珯 if(writeResult.IsSuccess){ Thread.sleep(200); - OperateResultExOne<byte[]> readResult = siemensS7Net.Read("DB100." + index*4, (short)4); + OperateResultExOne<byte[]> readResult = siemensS7Net.Read("DB1000." + index*4, (short)4); if(readResult.IsSuccess){ short workNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 0); short staNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 2); -- Gitblit v1.9.1