From ccbcfdb4241951a36c1d2fe1e0bca6e8b8deb719 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 19 九月 2022 12:48:47 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/LedThread.java |  245 +++++++++++++++++++++++++++---------------------
 1 files changed, 137 insertions(+), 108 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/LedThread.java b/src/main/java/com/zy/core/thread/LedThread.java
index 9c57985..197b219 100644
--- a/src/main/java/com/zy/core/thread/LedThread.java
+++ b/src/main/java/com/zy/core/thread/LedThread.java
@@ -1,5 +1,8 @@
 package com.zy.core.thread;
 
+import com.alibaba.fastjson.JSON;
+import com.core.common.Cools;
+import com.zy.common.entity.Parameter;
 import com.zy.common.model.MatDto;
 import com.zy.core.Slave;
 import com.zy.core.ThreadHandler;
@@ -37,17 +40,14 @@
     TextCaptionBxArea area;
     DisplayStyleFactory.DisplayStyle[] styles = DisplayStyleFactory.getStyles().toArray(new DisplayStyleFactory.DisplayStyle[0]);
     private Set<Integer> workNos = new HashSet<>();
-    private boolean resetStatus = false;    //  澶嶄綅鐘舵��
-
-    // 鏄剧ず鍣�
-    private StringBuffer stringBuffer = new StringBuffer();
+    private boolean ledMk = true;
+    private boolean resetStatus = false;    // 澶嶄綅鐘舵��
 
     public LedThread(Slave slave) {
         this.slave = slave;
         try {
             Bx5GEnv.initial(3000);
             screen = new Bx5GScreenClient("my");
-            screen.turnOn();
         } catch (Exception e) {
             e.printStackTrace();
             log.info("led杩炴帴鏋勯�犲櫒閿欒 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
@@ -57,7 +57,8 @@
     @Override
     @SuppressWarnings({"InfiniteLoopStatement", "unchecked"})
     public void run() {
-//        connect();
+        connect();
+        close();
         while (true) {
             try {
                 Task task = MessageQueue.poll(SlaveType.Led, slave.getId());
@@ -76,11 +77,101 @@
                     }
                 }
 
-                Thread.sleep(1000);
+                Thread.sleep(400);
             } catch (Exception e) {
                 e.printStackTrace();
             }
         }
+    }
+
+    private void write(List<LedCommand> list) throws Bx5GException {
+        if (!connect()) {
+            return;
+        }
+        pf = new ProgramBxFile( 0, screen.getProfile());
+        pf.setFrameShow(false);
+        // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eight
+        area = new TextCaptionBxArea( 0,0,96,48, screen.getProfile());
+        // 鍒涘缓涓�涓暟鎹〉
+        TextBxPage page = new TextBxPage();
+        for (LedCommand command : list) {
+            page.newLine(command.getTitle() +"锛�"+command.getWorkNo()+")");
+            page.newLine("婧愬簱浣嶏細"+command.getSourceLocNo());
+            page.newLine("鐩爣绔欙細"+command.getStaNo());
+            if (!command.isEmptyMk()) {
+                for (MatDto matDto : command.getMatDtos()) {
+                    page.newLine(matDto.getMaknx() + "銆愭暟閲�" + matDto.getCount() +"銆�");
+                }
+            }
+            page.newLine("\n");
+        }
+
+        // 璁剧疆瀛椾綋
+        page.setFont(new Font("瀹嬩綋",Font.PLAIN,12));
+        // 璁剧疆鏂囨湰棰滆壊
+        page.setForeground(Color.red);
+        // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
+        page.setDisplayStyle(styles[6]);
+        area.clearPages();
+        area.addPage(page);
+        pf.addArea(area);
+        if (pf.validate() != null) {
+            log.info("pf out of range");
+        } else {
+            // 鏇存柊鑺傜洰
+            screen.writeProgram(pf);
+//            resetStatus = false;
+        }
+        close();
+    }
+
+    private void reset() throws Bx5GException {
+//        if (!connect()) {
+//            return;
+//        }
+//        if (resetStatus) {
+//            return;
+//        }
+        pf = new ProgramBxFile( 0, screen.getProfile());
+        pf.setFrameShow(false);
+        // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eight
+        area = new TextCaptionBxArea( 0,0,96,48, screen.getProfile());
+        // 鍒涘缓涓�涓暟鎹〉
+        TextBxPage page = new TextBxPage();
+
+        List<String> list = null;
+        try {
+            String ledDefaultMsg = Parameter.get().getLedDefaultMsg();
+            list = JSON.parseArray(ledDefaultMsg, String.class);
+        } catch (Exception ignore) {
+        }
+        if (!Cools.isEmpty(list)) {
+            for (String str : list) {
+                page.newLine(str);
+            }
+        } else {
+            page.newLine("鑷姩鍖栫珛浣撲粨搴�");
+            page.newLine("瑗挎牸杩堣偂浠芥湁闄愬叕鍙�");
+        }
+
+        // 璁剧疆瀛椾綋
+        page.setFont(new Font("瀹嬩綋",Font.PLAIN,13));
+        // 璁剧疆鏂囨湰棰滆壊
+        page.setForeground(Color.red);
+        // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
+        page.setDisplayStyle(styles[6]);
+        area.clearPages();
+        area.addPage(page);
+        pf.addArea(area);
+        // 鏇存柊鑺傜洰
+        if (pf.validate() != null) {
+            log.info("pf out of range");
+        } else {
+            // 鏇存柊鑺傜洰
+            screen.writeProgram(pf);
+//            resetStatus = true;
+        }
+        close();
     }
 
     @Override
@@ -88,6 +179,7 @@
         boolean connRes = false;
         try {
             connRes = screen.connect(slave.getIp(),slave.getPort());
+            screen.turnOn();
         } catch (Exception ignore) {
         }
         if (connRes) {
@@ -104,117 +196,54 @@
     }
 
 
-    private void write(List<LedCommand> list) throws Bx5GException {
-//        pf = new ProgramBxFile( 0, screen.getProfile());
-//        pf.setFrameShow(false);
-//        // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eight
-//        area = new TextCaptionBxArea( 0,0,192,128,screen.getProfile());
-//        // 鍒涘缓涓�涓暟鎹〉
-//        TextBxPage page = new TextBxPage();
-//        for (LedCommand command : list) {
-//            page.newLine(command.getTitle() +"锛�"+command.getWorkNo()+")");
-//            page.newLine("婧愬簱浣嶏細"+command.getSourceLocNo());
-//            page.newLine("鐩爣绔欙細"+command.getStaNo());
-//            if (!command.isEmptyMk()) {
-//                for (MatDto matDto : command.getMatDtos()) {
-//                    page.newLine(matDto.getMaknx() + "銆愭暟閲�" + matDto.getCount() +"銆�");
-//                }
-//            }
-//            page.newLine("\n");
-//        }
-//
-//        // 璁剧疆瀛椾綋
-//        page.setFont(new Font("瀹嬩綋",Font.PLAIN,12));
-//        // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
-//        page.setDisplayStyle(styles[6]);
-//        area.clearPages();
-//        area.addPage(page);
-//        pf.addArea(area);
-//        // 鏇存柊鑺傜洰
-//        screen.writeProgram(pf);
-//        resetStatus = false;
-
-        StringBuilder sb = new StringBuilder();
-        for (LedCommand command : list) {
-            sb.append(command.getTitle() +"锛�"+command.getWorkNo()+")").append("\n");
-            sb.append("婧愬簱浣嶏細"+command.getSourceLocNo()).append("\n");
-            sb.append("鐩爣绔欙細"+command.getStaNo()).append("\n");
-            if (!command.isEmptyMk()) {
-                for (MatDto matDto : command.getMatDtos()) {
-                    sb.append(matDto.getMaknx() + "銆愭暟閲�" + matDto.getCount() +"銆�").append("\n");
-                }
-            }
-            sb.append("\n");
-        }
-        stringBuffer.delete(0, stringBuffer.length());
-        stringBuffer.append(sb.toString());
-        resetStatus = false;
-    }
-
-    private void reset() throws Bx5GException {
-        if (!resetStatus) {
-//            pf = new ProgramBxFile( 0, screen.getProfile());
-//            pf.setFrameShow(false);
-//            // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eight
-//            area = new TextCaptionBxArea( 0,0,192,128,screen.getProfile());
-//            // 鍒涘缓涓�涓暟鎹〉
-//            TextBxPage page = new TextBxPage();
-//            page.newLine("骞垮痉涓壃鐗╂祦瑁呭鏈夐檺鍏徃");
-//            page.newLine("鑷姩鍖栫珛浣撲粨搴�");
-//            page.newLine("娴欐睙涓壃鐗╂祦瑁呭鏈夐檺鍏徃");
-//            // 璁剧疆瀛椾綋
-//            page.setFont(new Font("瀹嬩綋",Font.PLAIN,12));
-//            // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
-//            page.setDisplayStyle(styles[6]);
-//            area.clearPages();
-//            area.addPage(page);
-//            pf.addArea(area);
-//            // 鏇存柊鑺傜洰
-//            screen.writeProgram(pf);
-
-            stringBuffer.delete(0, stringBuffer.length());
-            resetStatus = true;
-        }
-    }
-
 
     public static void main(String[] args) throws Exception {
         Bx5GEnv.initial(3000);
         Bx5GScreenClient screen = new Bx5GScreenClient("my");
         DisplayStyleFactory.DisplayStyle[] styles = DisplayStyleFactory.getStyles().toArray(new DisplayStyleFactory.DisplayStyle[0]);
-        if (!screen.connect("192.168.10.61",5005)) {
+        if (!screen.connect("192.168.10.101",5005)) {
             System.err.println("杩炴帴澶辫触锛侊紒锛侊紒");
             return;
         }
         screen.turnOn();
-        ProgramBxFile pf = new ProgramBxFile( 0, screen.getProfile());
-        pf.setFrameShow(false);
-        // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eigth
-        TextCaptionBxArea area = new TextCaptionBxArea( 0,0,192,128,screen.getProfile());
-        // 鍒涘缓涓�涓暟鎹〉
-        // 绗竴琛屾暟鎹�
-        TextBxPage page = new TextBxPage("鍏ㄦ澘鍏ュ簱");
-        page.newLine("鐩爣搴撲綅锛�0100204");
-        // 绗簩琛屾暟鎹�
-        page.newLine("鎺ユ敹鍣� RX18 XH 6V 銆愭暟閲忥細2銆�");
-        page.newLine("涓帶 BM钃濈墮 鑻辨枃 6V 銆愭暟閲忥細1銆�");
-        page.newLine("绾挎潫 S2588-1-XX 鏃犲疄鐗┿�愭暟閲忥細5銆�");
-        page.newLine("鎺ユ敹鍣� RX18 XH 6V 銆愭暟閲忥細2銆�");
-        page.newLine("涓帶 BM钃濈墮 鑻辨枃 6V 銆愭暟閲忥細1銆�");
-        page.newLine("绾挎潫 S2588-1-XX 鏃犲疄鐗┿�愭暟閲忥細5銆�");
-        page.newLine("鎺ユ敹鍣� RX18 XH 6V 銆愭暟閲忥細2銆�");
-        page.newLine("涓帶 BM钃濈墮 鑻辨枃 6V 銆愭暟閲忥細1銆�");
-        page.newLine("绾挎潫 S2588-1-XX 鏃犲疄鐗┿�愭暟閲忥細5銆�");
-        // 璁剧疆瀛椾綋
-        page.setFont( new Font("瀹嬩綋",Font.PLAIN,12));
-        // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
-        page.setDisplayStyle(styles[6]);
-        area.addPage(page);
-        pf.addArea( area );
-        // 鏇存柊鑺傜洰
-        screen.writeProgram(pf);
+
+
+        while (true) {
+            Thread.sleep(5000L);
+
+            ProgramBxFile pf = new ProgramBxFile( 0, screen.getProfile());
+            pf.setFrameShow(false);
+            // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eigth
+            TextCaptionBxArea area = new TextCaptionBxArea(  0,0,192,96,screen.getProfile());
+
+            // 鍒涘缓涓�涓暟鎹〉
+            // 绗竴琛屾暟鎹�
+            TextBxPage page = new TextBxPage("鍑哄簱浠诲姟锛�303锛�");
+            page.newLine("婧愬簱浣嶏細0100204");
+            page.newLine("鐩爣绔欙細1000");
+            // 璁剧疆瀛椾綋
+            page.setFont( new Font("瀹嬩綋",Font.PLAIN,15));
+            // 璁剧疆鏂囨湰棰滆壊
+            page.setForeground(Color.red);
+            // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
+            page.setDisplayStyle(styles[6]);
+            area.clearPages();
+            area.addPage(page);
+            pf.addArea( area );
+
+            // 鏇存柊鑺傜洰
+            // 鏇存柊鑺傜洰
+            if (pf.validate() != null) {
+                System.out.println("pf out of range");
+                log.info("pf out of range");
+            } else {
+                // 鏇存柊鑺傜洰
+                screen.writeProgram(pf);
+            }
+        }
+
         // 缁у紑涓庢帶鍒跺櫒涔嬮棿鐨勯摼鎺�
-        screen.disconnect();
+//        screen.disconnect();
     }
 
 

--
Gitblit v1.9.1