From 3b64c807f60e5d6b71deca3f79c9be4be19abfaa Mon Sep 17 00:00:00 2001 From: Junjie <540245094@qq.com> Date: 星期五, 23 二月 2024 10:47:58 +0800 Subject: [PATCH] #显示器更新 --- src/main/java/com/zy/core/thread/SiemensDevpThread.java | 140 +++++++++++++++++++++++++++++++++++++++++++++- 1 files changed, 135 insertions(+), 5 deletions(-) diff --git a/src/main/java/com/zy/core/thread/SiemensDevpThread.java b/src/main/java/com/zy/core/thread/SiemensDevpThread.java index 3d874c8..09a24c6 100644 --- a/src/main/java/com/zy/core/thread/SiemensDevpThread.java +++ b/src/main/java/com/zy/core/thread/SiemensDevpThread.java @@ -58,6 +58,38 @@ add(309);add(312); }}; + public static final ArrayList<Integer> staNos2 = new ArrayList<Integer>() {{ + add(302);add(304); + add(305);add(306); + add(307);add(308); + add(310);add(311); + add(312);add(313); + add(314);add(315); + add(316);add(318); + add(319);add(320); + add(321);add(322); + add(323);add(324); + add(326);add(327); + add(328);add(329); + add(330);add(332); + add(334);add(335); + add(336);add(337); + add(338);add(342); + add(343);add(344); + }}; + + public static final ArrayList<Integer> staNos3 = new ArrayList<Integer>() {{//218 + add(302);add(304); + add(315);add(322); + add(324);add(330); + add(332);add(337); + }}; + + public static final ArrayList<Integer> staNos4 = new ArrayList<Integer>() {{//250 + add(318);add(320); + add(343); + }}; + //楂樹綆淇″彿绔欑偣 public static final ArrayList<Integer> locType1StaNos = new ArrayList<Integer>() {{ add(100);add(103); @@ -73,6 +105,13 @@ add(105);add(200); add(203);add(205); add(341);add(346); + }}; + + //鍑哄叆搴撶珯鐐规娴嬫姤璀︿俊鎭� + public static final ArrayList<Integer> outInAlarmStaNos = new ArrayList<Integer>(){{ + add(101);add(102);add(104); + add(201);add(202);add(204); + add(340);add(345); }}; public boolean charge0; @@ -131,7 +170,7 @@ 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:{}]", slave.getId(), slave.getIp(), slave.getPort()); } - siemensS7Net.ConnectClose(); +// siemensS7Net.ConnectClose(); return result; } @@ -180,6 +219,10 @@ OperateResultExOne<byte[]> result2 = siemensS7Net.Read("DB1000.200", (short) 98); if (result2.IsSuccess) { for (int i = 0; i < barcodeSize; i++) { + if (i >= 10) { + continue; + } + String barcode = null; if (i == 8) { barcode = siemensS7Net.getByteTransform().TransString(result2.Content,i*8,13, "UTF-8"); @@ -216,6 +259,93 @@ staProtocol.setOutInModel(siemensS7Net.getByteTransform().TransInt16(result4.Content, i * 2));//璇诲彇鍑哄叆搴撴ā寮� } } + +// //鍑哄叆搴撶珯鐐规娴嬫姤璀︿俊鎭� +// Thread.sleep(100); +// for (Integer staNo : outInAlarmStaNos) { +// OperateResultExOne<byte[]> result5 = siemensS7Net.Read("DB" + staNo + ".20.0", (short) 2); +// if (result5.IsSuccess) { +// if (staNo == 101 || staNo == 201) { +// staNo--; +// }else { +// staNo++; +// } +// StaProtocol staProtocol = station.get(staNo); +// boolean[] status = siemensS7Net.getByteTransform().TransBool(result5.Content, 0, 2); +// staProtocol.setBarcodeErr(status[4]);//鎵爜澶辫触 +// staProtocol.setFrontErr(status[8]);//鍓嶈秴闄� +// staProtocol.setBackErr(status[9]);//鍚庤秴闄� +// staProtocol.setLeftErr(status[10]);//宸﹁秴闄� +// staProtocol.setRightErr(status[11]);//鍙宠秴闄� +// staProtocol.setHighErr(status[12]);//瓒呴珮 +// staProtocol.setWeightErr(status[13]);//瓒呴噸 +// } +// } +// +// Thread.sleep(100); +// for (Integer staNo : staNos2) { +// OperateResultExOne<byte[]> result5 = siemensS7Net.Read("DB" + staNo + ".0", (short) 48); +// if (result5.IsSuccess) { +// StaProtocol staProtocol = station.get(staNo); +// StaProtocol staProtocol300 = station.get(300); +// if (null == staProtocol) { +// staProtocol = new StaProtocol(); +// staProtocol.setSiteId(staNo); +// station.put(staNo, staProtocol); +// } +// +// boolean[] status1 = siemensS7Net.getByteTransform().TransBool(result5.Content, 1, 1); +// staProtocol.setAutoing(staProtocol300.isAutoing()); // 鑷姩 +// staProtocol.setLoading(!status1[2]); // 鏈夌墿 +// +// if (staNos3.contains(staNo) || staNos4.contains(staNo)) { +// continue; +// } +// if (staNo == 344) { +// staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result5.Content, 34)); // 宸ヤ綔鍙� +// }else { +// staProtocol.setWorkNo(siemensS7Net.getByteTransform().TransInt16(result5.Content, 22)); // 宸ヤ綔鍙� +// } +// } +// } +// +// Thread.sleep(100); +// for (Integer staNo : staNos3) { +// OperateResultExOne<byte[]> result5 = siemensS7Net.Read("DB" + staNo + ".22.0", (short) 2); +// OperateResultExOne<byte[]> result6 = siemensS7Net.Read("DB" + staNo + ".218.0", (short) 2); +// if (result5.IsSuccess && result6.IsSuccess) { +// StaProtocol staProtocol = station.get(staNo); +// short wrkNo1 = siemensS7Net.getByteTransform().TransInt16(result5.Content, 0); +// short wrkNo2 = siemensS7Net.getByteTransform().TransInt16(result6.Content, 0); +// short wrkNo = 0; +// if (wrkNo1 != 0) { +// wrkNo = wrkNo1; +// } +// if (wrkNo2 != 0) { +// wrkNo = wrkNo2; +// } +// staProtocol.setWorkNo(wrkNo); // 宸ヤ綔鍙� +// } +// } +// +// Thread.sleep(100); +// for (Integer staNo : staNos4) { +// OperateResultExOne<byte[]> result5 = siemensS7Net.Read("DB" + staNo + ".22.0", (short) 2); +// OperateResultExOne<byte[]> result6 = siemensS7Net.Read("DB" + staNo + ".250.0", (short) 2); +// if (result5.IsSuccess && result6.IsSuccess) { +// StaProtocol staProtocol = station.get(staNo); +// short wrkNo1 = siemensS7Net.getByteTransform().TransInt16(result5.Content, 0); +// short wrkNo2 = siemensS7Net.getByteTransform().TransInt16(result6.Content, 0); +// short wrkNo = 0; +// if (wrkNo1 != 0) { +// wrkNo = wrkNo1; +// } +// if (wrkNo2 != 0) { +// wrkNo = wrkNo2; +// } +// staProtocol.setWorkNo(wrkNo); // 宸ヤ綔鍙� +// } +// } if (result.IsSuccess && result1.IsSuccess) { OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆慬id:{1}] <<<<< 瀹炴椂鏁版嵁鏇存柊鎴愬姛",DateUtils.convert(new Date()), slave.getId())); @@ -262,10 +392,10 @@ int writeCount = 0; //浠诲姟涓嬪彂鎴愬姛鏍囪瘑 boolean writeFlag = false; - while(writeCount < 5){ + while(writeCount < 1){ writeResult = siemensS7Net.Write("DB1000." + index*4, array); // 宸ヤ綔鍙枫�佺洰鏍囩珯 if(writeResult.IsSuccess){ - Thread.sleep(200); + Thread.sleep(500); OperateResultExOne<byte[]> readResult = siemensS7Net.Read("DB1000." + index*4, (short)4); if(readResult.IsSuccess){ short workNo = siemensS7Net.getByteTransform().TransInt16(readResult.Content, 0); @@ -305,8 +435,8 @@ OutputQueue.DEVP.offer(MessageFormat.format("銆恵0}銆戝啓鍏ヨ緭閫佺嚎鍛戒护灏濊瘯5娆″け璐ャ�傝緭閫佺嚎plc缂栧彿={1}锛岀珯鐐规暟鎹�={2}", slave.getId(), JSON.toJSON(staProtocol))); log.error("鍐欏叆杈撻�佺嚎鍛戒护灏濊瘯5娆″け璐ャ�傝緭閫佺嚎plc缂栧彿={}锛岀珯鐐规暟鎹�={}", slave.getId(), JSON.toJSON(staProtocol)); - //閲嶆柊娣诲姞鏁版嵁鍒颁换鍔¢槦鍒� - boolean result = MessageQueue.offer(SlaveType.Devp, slave.getId(), new Task(2, staProtocol)); +// //閲嶆柊娣诲姞鏁版嵁鍒颁换鍔¢槦鍒� +// boolean result = MessageQueue.offer(SlaveType.Devp, slave.getId(), new Task(2, staProtocol)); read();//璇诲彇1娆¤澶囩姸鎬� return; } else { -- Gitblit v1.9.1