From 5c4ea83ba30511b58a6863af43486e5f113f619d Mon Sep 17 00:00:00 2001 From: Administrator <pjb> Date: 星期四, 05 六月 2025 18:23:21 +0800 Subject: [PATCH] 123 --- src/main/java/com/zy/core/thread/SiemensDevpThread.java | 62 +++++++++++++++++++++++++------ 1 files changed, 50 insertions(+), 12 deletions(-) diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java index af6d15e..0ef6dc6 100644 --- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java +++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java @@ -38,23 +38,61 @@ public class SiemensDevpThread implements Runnable, DevpThread { public static final ArrayList<Integer> staNos1 = new ArrayList<Integer>() {{ - add(101);add(102);add(103);add(104);add(105);add(106);add(107);add(108);add(109);add(110); - add(111);add(112);add(113);add(114);add(115);add(116); // 渚ч潰浠� index 16寮�濮� 闀垮害12 - add(201);add(202);add(203);add(204);add(205);add(206);add(207);add(208);add(209);add(210);add(211);add(212); + add(101); + add(102); + add(103); + add(104); + add(105); + add(106); + add(107); + add(108); + add(109); + add(110); + add(111); + add(112); + add(113); + add(114); + add(115); + add(116); // 渚ч潰浠� index 16寮�濮� 闀垮害12 + add(201); + add(202); + add(203); + add(204); + add(205); + add(206); + add(207); + add(208); + add(209); + add(210); + add(211); + add(212); }}; public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{ - add(301);add(302);add(303);add(304);add(305);add(306);add(307);add(308); + add(301); + add(302); + add(303); + add(304); + add(305); + add(306); + add(307); + add(308); }}; // 姝i潰5涓潯鐮佹壂鎻忕珯 public static final ArrayList<Integer> barcodeSite2 = new ArrayList<Integer>() {{ - add(102);add(105);add(108);add(111);add(114); + add(102); + add(105); + add(108); + add(111); + add(114); }}; // 渚ч潰涓変釜鏉$爜鎵弿绔� public static final ArrayList<Integer> barcodeSite = new ArrayList<Integer>() {{ - add(202);add(206);add(211); + add(202); + add(206); + add(211); }}; /** @@ -256,14 +294,14 @@ if (result2.IsSuccess) { for (int i = 0; i < 5; i++) { String barcode = siemensS7Net.getByteTransform().TransString(result2.Content, i * 40, 40, "UTF-8"); - if(!Cools.isEmpty()){ + if (!Cools.isEmpty()) { barcode = barcode.trim(); } List<String> barcodeList = Arrays.stream(barcode.split(",")).collect(Collectors.toList()); Iterator<String> iterator = barcodeList.iterator(); - while (iterator.hasNext()){ + while (iterator.hasNext()) { String next = iterator.next(); - if(next.length() == 6) { + if (next.length() == 6) { barcode = next; iterator.remove(); break; @@ -515,9 +553,9 @@ // short staNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 2); // if (staProtocol.getWorkNo().equals(workNo) && staProtocol.getStaNo().equals(staNo)) { // //浠诲姟鍛戒护鍐欏叆鎴愬姛 - writeFlag = true; - log.info("鍐欏叆杈撻�佺嚎鍛戒护鍚庤繑鍥炴垚鍔燂紝骞朵笖鍥炶鎴愬姛銆傝緭閫佺嚎plc缂栧彿={}锛寋}锛屽啓鍏ユ鏁�={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); - break; + writeFlag = true; + log.info("鍐欏叆杈撻�佺嚎鍛戒护鍚庤繑鍥炴垚鍔燂紝骞朵笖鍥炶鎴愬姛銆傝緭閫佺嚎plc缂栧彿={}锛寋}锛屽啓鍏ユ鏁�={}", slave.getId(), JSON.toJSON(staProtocol), writeCount); + break; // } else {//杩斿洖缁撴灉鏄垚鍔熶簡锛屼絾鏄湡瀹炲�间笉鐩稿悓 // writeCount++; // OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎鍛戒护鍚庤繑鍥炴垚鍔燂紝浣嗘槸璇诲彇浠诲姟鍊间笉涓�鑷淬�傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2},鍐欏叆娆℃暟={3}", -- Gitblit v1.9.1