From ee51a946795e372e5d7ed025a71dabd27048975c Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期五, 02 七月 2021 11:14:00 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/thread/SiemensDevpThread.java | 179 +++++++++++++++++++++++++++++++++++++++++++++-------------- 1 files changed, 136 insertions(+), 43 deletions(-) diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java index 3cfbbd6..da72c0a 100644 --- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java +++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java @@ -5,7 +5,6 @@ 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; @@ -40,9 +39,11 @@ 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(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); + add(300);add(301);add(302);add(303);add(304);add(305);add(306);add(307);add(308); + add(129); }}; public SiemensDevpThread(DevpSlave slave) { @@ -105,9 +106,9 @@ * 璇诲彇鐘舵�� ====> 鏁村潡plc */ private void read() throws InterruptedException { - OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 350); + OperateResultExOne<byte[]> result = siemensS7Net.Read("DB100.0", (short) 140); if (result.IsSuccess) { - for (int i = 0; i < staNos.size(); i++) { + for (int i = 0; i < 35; i++) { Integer siteId = staNos.get(i); // 绔欑偣缂栧彿 StaProtocol staProtocol = station.get(siteId); if (null == staProtocol) { @@ -115,22 +116,88 @@ staProtocol.setSiteId(siteId); station.put(siteId, staProtocol); } - 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)); // 鐩爣绔� + staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2)); // 宸ヤ綔鍙� + staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result.Content, i*2 + 70)); // 鐩爣绔� } } - Thread.sleep(100); - OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB100.500", (short) 106); + Thread.sleep(50); + OperateResultExOne<byte[]> result0 = siemensS7Net.Read("DB100.180", (short) 36); + if (result0.IsSuccess) { + for (int i = 0; i < 9; i++) { + Integer siteId = staNos.get(i + 35); // 绔欑偣缂栧彿 + StaProtocol staProtocol = station.get(siteId); + if (null == staProtocol) { + staProtocol = new StaProtocol(); + staProtocol.setSiteId(siteId); + station.put(siteId, staProtocol); + } + staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result0.Content, i*2)); // 宸ヤ綔鍙� + staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result0.Content, i*2 + 18)); // 鐩爣绔� + } + } + Thread.sleep(50); + OperateResultExOne<byte[]> result3 = siemensS7Net.Read("DB100.226", (short) 4); + if (result3.IsSuccess) { + for (int i = 0; i < 1; i++) { + Integer siteId = staNos.get(i + 44); // 绔欑偣缂栧彿 + StaProtocol staProtocol = station.get(siteId); + if (null == staProtocol) { + staProtocol = new StaProtocol(); + staProtocol.setSiteId(siteId); + station.put(siteId, staProtocol); + } + staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result3.Content, i*2)); // 宸ヤ綔鍙� + staProtocol.setStaNo(siemensS7Net.getByteTransform().TransInt16(result3.Content, i*2 + 2)); // 鐩爣绔� + } + } + Thread.sleep(50); + OperateResultExOne<byte[]> result1 = siemensS7Net.Read("DB100.140", (short) 35); if (result1.IsSuccess) { - for (int i = 0; i < staNos.size(); i++) { + for (int i = 0; i < 35; 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) * 100) + remainder; - boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, index, 1); + boolean[] status = siemensS7Net.getByteTransform().TransBool(result1.Content, i, 1); + StaProtocol staProtocol = station.get(siteId); + staProtocol.setAutoing(status[0]); // 鑷姩 + staProtocol.setLoading(status[1]); // 鏈夌墿 + staProtocol.setInEnable(status[2]); // 鍙叆 + staProtocol.setOutEnable(status[3]);// 鍙嚭 + staProtocol.setEmptyMk(status[4]); // 绌烘澘淇″彿 + staProtocol.setFullPlt(status[5]); // 婊℃墭鐩� + staProtocol.setHigh(status[6]); // 楂樺簱浣� + staProtocol.setLow(status[7]); // 浣庡簱浣� + + if (!staProtocol.isPakMk() && !staProtocol.isLoading()) { + staProtocol.setPakMk(true); + } + } + } + Thread.sleep(50); + OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB100.216", (short) 9); + if (result2.IsSuccess) { + for (int i = 0; i < 9; i++) { + Integer siteId = staNos.get(i + 35); // 绔欑偣缂栧彿 + boolean[] status = siemensS7Net.getByteTransform().TransBool(result2.Content, i, 1); + StaProtocol staProtocol = station.get(siteId); + staProtocol.setAutoing(status[0]); // 鑷姩 + staProtocol.setLoading(status[1]); // 鏈夌墿 + staProtocol.setInEnable(status[2]); // 鍙叆 + staProtocol.setOutEnable(status[3]);// 鍙嚭 + staProtocol.setEmptyMk(status[4]); // 绌烘澘淇″彿 + staProtocol.setFullPlt(status[5]); // 婊℃墭鐩� + staProtocol.setHigh(status[6]); // 楂樺簱浣� + staProtocol.setLow(status[7]); // 浣庡簱浣� + + if (!staProtocol.isPakMk() && !staProtocol.isLoading()) { + staProtocol.setPakMk(true); + } + } + } + Thread.sleep(50); + OperateResultExOne<byte[]> result4 = siemensS7Net.Read("DB100.230", (short) 1); + if (result4.IsSuccess) { + for (int i = 0; i < 1; i++) { + Integer siteId = staNos.get(i + 44); // 绔欑偣缂栧彿 + boolean[] status = siemensS7Net.getByteTransform().TransBool(result4.Content, i, 1); StaProtocol staProtocol = station.get(siteId); staProtocol.setAutoing(status[0]); // 鑷姩 staProtocol.setLoading(status[1]); // 鏈夌墿 @@ -147,7 +214,7 @@ } } - if (result.IsSuccess && result1.IsSuccess) { + if (result.IsSuccess && result0.IsSuccess && result1.IsSuccess && result2.IsSuccess && result3.IsSuccess && result4.IsSuccess) { OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId())); @@ -180,13 +247,26 @@ if (null == staProtocol) { return; } - int divides = (int) Arith.divides(0, staProtocol.getSiteId(), 100); - int remainder = (int) Arith.remainder(staProtocol.getSiteId(), 100); - int index = ((divides - 1) * 50) + remainder; + int index = staNos.indexOf(staProtocol.getSiteId()); + OperateResult write; + OperateResult write1; + // 涓�鏈� + if (staProtocol.getSiteId() < 300 && staProtocol.getSiteId() != 129) { + write = siemensS7Net.Write("DB100." + index*2, staProtocol.getWorkNo()); // 宸ヤ綔鍙� + Thread.sleep(100); + write1 = siemensS7Net.Write("DB100." + (index*2 + 70), staProtocol.getStaNo()); // 鐩爣绔� + // 浜屾湡 + } else if (staProtocol.getSiteId() >= 300 && staProtocol.getSiteId() != 129){ + write = siemensS7Net.Write("DB100." + ((index-35)*2 + 180), staProtocol.getWorkNo()); // 宸ヤ綔鍙� + Thread.sleep(100); + write1 = siemensS7Net.Write("DB100." + ((index-35)*2 + 198), staProtocol.getStaNo()); // 鐩爣绔� + // 涓夋湡 129 + } else { + write = siemensS7Net.Write("DB100." + ((index-44)*2 + 226), staProtocol.getWorkNo()); // 宸ヤ綔鍙� + Thread.sleep(100); + write1 = siemensS7Net.Write("DB100." + ((index-44)*2 + 228), staProtocol.getStaNo()); // 鐩爣绔� + } - OperateResult write = siemensS7Net.Write("DB100." + index*2, staProtocol.getWorkNo()); // 宸ヤ綔鍙� - Thread.sleep(300); - OperateResult write1 = siemensS7Net.Write("DB100." + (index*2 + 200), staProtocol.getStaNo()); // 鐩爣绔� if (!write.IsSuccess || !write1.IsSuccess) { staProtocol = station.get(staProtocol.getSiteId()); if (staProtocol.getWorkNo() == 0 && staProtocol.getStaNo() ==0) { @@ -231,25 +311,38 @@ 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) { + System.out.println(staNos.indexOf(129)); + System.out.println(staNos.size()); + for (int i = 0; i<staNos.size(); i++) { +// System.out.println(i*2); +// System.out.println(i*2 + 200); +// System.out.println(i); + } + int index = staNos.indexOf(128); + System.out.println(index*2); + System.out.println(index*2 + 200); } +// 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