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