From 5288a0f1a2f187011d57cce2a41871ea09bbdf3b Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 04 一月 2021 11:07:13 +0800
Subject: [PATCH] #
---
src/main/java/com/zy/core/thread/SiemensDevpThread.java | 89 +++++++++++++++++++++++++++++---------------
1 files changed, 58 insertions(+), 31 deletions(-)
diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
index 4dde49d..f1da677 100644
--- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java
+++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java
@@ -5,6 +5,7 @@
import HslCommunication.Profinet.Siemens.SiemensPLCS;
import HslCommunication.Profinet.Siemens.SiemensS7Net;
import com.alibaba.fastjson.JSON;
+import com.core.common.Arith;
import com.core.common.DateUtils;
import com.core.common.SpringUtils;
import com.zy.asrs.entity.BasDevp;
@@ -38,6 +39,22 @@
private SiemensS7Net siemensS7Net;
private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();
private short heartBeatVal = 1;
+ public static final ArrayList<Integer> staNos = new ArrayList<Integer>() {{
+ add(100);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);add(117);
+ add(118);add(119);add(120);add(121);add(122);add(123);add(124);add(125);add(126);add(127);add(128);
+ add(200);add(201);add(202);add(203);add(204);add(205);
+ }};
+
+ public static void main(String[] args) {
+ for (Integer siteId : staNos) {
+ int divides = (int) Arith.divides(0, siteId, 100);
+ int remainder = (int) Arith.remainder(siteId, 100);
+ int index = ((divides - 1) * 50) + remainder;
+ System.out.print(siteId + " 浠诲姟鍦板潃 锛� " + index*2);
+ System.out.print(" 鐩爣鍦板潃 锛� " + (index*2+200) );
+ System.out.println(" 鐘舵�� 锛� " + (index+500) );
+ }
+ }
public SiemensDevpThread(DevpSlave slave) {
this.slave = slave;
@@ -100,23 +117,33 @@
* 璇诲彇鐘舵�� ====> 鏁村潡plc
*/
private void read() throws InterruptedException {
- OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 40);
+ OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 350);
if (result.IsSuccess) {
- for (int i = 1; i <= 8; i++) {
- StaProtocol staProtocol = station.get(i);
+ for (int i = 0; i < staNos.size(); i++) {
+ Integer siteId = staNos.get(i); // 绔欑偣缂栧彿
+ StaProtocol staProtocol = station.get(siteId);
if (null == staProtocol) {
staProtocol = new StaProtocol();
- staProtocol.setSiteId(i);
- station.put(i, staProtocol);
+ staProtocol.setSiteId(siteId);
+ station.put(siteId, staProtocol);
}
- staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, (i-1)*2)); // 宸ヤ綔鍙�
- staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, (i-1)*2+20)); // 鐩爣绔�
+ int divides = (int) Arith.divides(0, siteId, 100);
+ int remainder = (int) Arith.remainder(siteId, 100);
+ int index = ((divides - 1) * 50) + remainder;
+ staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, index*2)); // 宸ヤ綔鍙�
+ staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, index*2 + 200)); // 鐩爣绔�
}
}
Thread.sleep(100);
- OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB100.40", (short) 8);
+ OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB100.500", (short) 106);
if (result1.IsSuccess) {
- for (int i = 1; i <= 8; i++) {
+ for (int i = 0; i < staNos.size(); i++) {
+ Integer siteId = staNos.get(i); // 绔欑偣缂栧彿
+ int divides = (int) Arith.divides(0, siteId, 100);
+ int remainder = (int) Arith.remainder(siteId, 100);
+ int index = ((divides - 1) * 50) + remainder;
+
+
boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i-1, 1);
StaProtocol staProtocol = station.get(i);
staProtocol.setAutoing(status[0]); // 鑷姩
@@ -138,8 +165,8 @@
// 鏍规嵁瀹炴椂淇℃伅鏇存柊鏁版嵁搴�
try {
List<BasDevp> basDevps = new ArrayList<>();
- for (int i = 1; i <= 8; i++) {
- StaProtocol staProtocol = station.get(i);
+ for (Integer siteId : staNos) {
+ StaProtocol staProtocol = station.get(siteId);
basDevps.add(staProtocol.toSqlModel());
}
BasDevpService basDevpService = SpringUtils.getBean(BasDevpService.class);
@@ -218,25 +245,25 @@
siemensS7Net.ConnectClose();
}
- public static void main(String[] args) throws Exception {
- DevpSlave slave = new DevpSlave();
- slave.setIp("192.168.2.125");
- SiemensDevpThread devpThread = new SiemensDevpThread(slave);
- devpThread.connect();
- devpThread.read();
- // 鍐�
- StaProtocol staProtocol = devpThread.getStation().get(1);
- staProtocol.setWorkNo((short) 232);
- staProtocol.setStaNo((short) 6);
- staProtocol.setAutoing(true);
- staProtocol.setEmptyMk(true);
- staProtocol.setInEnable(true);
- devpThread.write(staProtocol);
- System.out.println("----------------------------------------");
- // 璇�
- devpThread.read();
- System.out.println(JSON.toJSONString(devpThread.station));
-
- }
+// public static void main(String[] args) throws Exception {
+// DevpSlave slave = new DevpSlave();
+// slave.setIp("192.168.2.125");
+// SiemensDevpThread devpThread = new SiemensDevpThread(slave);
+// devpThread.connect();
+// devpThread.read();
+// // 鍐�
+// StaProtocol staProtocol = devpThread.getStation().get(1);
+// staProtocol.setWorkNo((short) 232);
+// staProtocol.setStaNo((short) 6);
+// staProtocol.setAutoing(true);
+// staProtocol.setEmptyMk(true);
+// staProtocol.setInEnable(true);
+// devpThread.write(staProtocol);
+// System.out.println("----------------------------------------");
+// // 璇�
+// devpThread.read();
+// System.out.println(JSON.toJSONString(devpThread.station));
+//
+// }
}
--
Gitblit v1.9.1