From 8ecad328df8465b3d81c15e37943f6e9d3adf86b Mon Sep 17 00:00:00 2001
From: Junjie <fallin.jie@qq.com>
Date: 星期一, 23 十月 2023 16:32:33 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/SiemensDevpThread.java | 65 +++++---------------------------
1 files changed, 10 insertions(+), 55 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 215d173..14b7d60 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 = 9;
+ private int barcodeSize = 10;
public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{
add(100);add(101);
add(102);add(103);
@@ -174,10 +174,17 @@
//璇绘潯鐮�
Thread.sleep(100);
- OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB1000.200", (short) 88);
+ OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB1000.200", (short) 98);
if (result2.IsSuccess) {
for (int i = 0; i < barcodeSize; i++) {
- String barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,8, "UTF-8");
+ String barcode = null;
+ if (i == 8) {
+ barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,13, "UTF-8");
+ } else if (i == 9) {
+ barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8 + 6,13, "UTF-8");
+ } else {
+ 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);
@@ -194,16 +201,6 @@
StaProtocol staProtocol = station.get(siteId);
staProtocol.setLocType1(siemensS7Net.getByteTransform().TransInt16(result3.Content, i * 2));//璇诲彇楂樹綆淇″彿
}
- }
-
- // 澶栧舰妫�娴� - 102
- Thread.sleep(50);
- OperateResultExOne<byte[]> result102 = siemensS7Net.Read("DB100.100", (short)2);
- if (result102.IsSuccess) {
- //鍑哄叆搴撴ā寮�
- short outInModel = siemensS7Net.getByteTransform().TransInt16(result102.Content, 0);
- StaProtocol staProtocol = station.get(102);
- staProtocol.setOutInModel(outInModel);
}
if (result.IsSuccess && result1.IsSuccess) {
@@ -228,32 +225,6 @@
} else {
OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戣鍙栬緭閫佺嚎plc鐘舵�佷俊鎭け璐� ===>> [id:{1}] [ip:{2}] [port:{3}] [rack:{4}] [slot:{5}]", DateUtils.convert(new Date()), slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot()));
// News.error("璇诲彇杈撻�佺嚎plc鐘舵�佷俊鎭け璐� ===>> [id:{}] [ip:{}] [port:{}] [rack:{}] [slot:{}]", slave.getId(), slave.getIp(), slave.getPort(), slave.getRack(), slave.getSlot());
- }
- }
-
- /**
- * plc涓庢彁鍗囨満浜や簰
- */
- private void write4(Integer siteId, Integer direction) throws InterruptedException {
- if (Cools.isEmpty(siteId, direction)) {
- return;
- }
- switch (siteId) {
- case 102:
- siemensS7Net.Write("DB100.300", direction.shortValue());
- break;
- case 105:
- siemensS7Net.Write("DB100.302", direction.shortValue());
- break;
- case 106:
- siemensS7Net.Write("DB100.304", direction.shortValue());
- break;
- case 107:
- siemensS7Net.Write("DB100.306", direction.shortValue());
- break;
- case 108:
- siemensS7Net.Write("DB100.308", direction.shortValue());
- break;
}
}
@@ -464,22 +435,6 @@
if (null != staProtocol) {
staProtocol.setPakMk(pakMk);
}
- }
-
- /**
- * 鍏呯數鎺у埗
- * @param index 鍏呯數妗╁簭鍙� 0 寮�濮�
- * @param open true 寮�濮嬪厖鐢碉紱false 缁撴潫鍏呯數
- */
- public boolean charge(int index, boolean open) {
- OperateResult write = siemensS7Net.Write("DB102.50." + (index + 3), open);
- if (!write.IsSuccess) {
- News.error("杈撻�佺嚎plc缂栧彿={} {}鍙峰厖鐢垫々{}鎺у埗澶辫触", slave.getId(), index + 1, open?"鎵撳紑":"鍏抽棴");
- return false;
- } else {
- News.error("杈撻�佺嚎plc缂栧彿={} {}鍙峰厖鐢垫々{}鎺у埗鎴愬姛", slave.getId(), index + 1, open?"鎵撳紑":"鍏抽棴");
- }
- return true;
}
@Override
--
Gitblit v1.9.1