From bb7ce41d7525f369a93c8b6f76a05fb90d1031b2 Mon Sep 17 00:00:00 2001
From: luxiaotao1123 <t1341870251@163.com>
Date: 星期一, 28 十二月 2020 17:50:58 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/LedThread.java |   95 ++++++++++++++++++++++++++++++++++++++++++-----
 1 files changed, 84 insertions(+), 11 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/LedThread.java b/src/main/java/com/zy/core/thread/LedThread.java
index 511816f..9c57985 100644
--- a/src/main/java/com/zy/core/thread/LedThread.java
+++ b/src/main/java/com/zy/core/thread/LedThread.java
@@ -1,5 +1,6 @@
 package com.zy.core.thread;
 
+import com.zy.common.model.MatDto;
 import com.zy.core.Slave;
 import com.zy.core.ThreadHandler;
 import com.zy.core.cache.MessageQueue;
@@ -9,6 +10,7 @@
 import lombok.Data;
 import lombok.extern.slf4j.Slf4j;
 import onbon.bx05.Bx5GEnv;
+import onbon.bx05.Bx5GException;
 import onbon.bx05.Bx5GScreen;
 import onbon.bx05.Bx5GScreenClient;
 import onbon.bx05.area.TextCaptionBxArea;
@@ -31,13 +33,21 @@
 
     private Slave slave;
     private Bx5GScreenClient screen;
+    ProgramBxFile pf;
+    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();
 
     public LedThread(Slave slave) {
         this.slave = slave;
         try {
             Bx5GEnv.initial(3000);
-            screen = new Bx5GScreenClient("MyScreen");
+            screen = new Bx5GScreenClient("my");
+            screen.turnOn();
         } catch (Exception e) {
             e.printStackTrace();
             log.info("led杩炴帴鏋勯�犲櫒閿欒 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
@@ -47,7 +57,7 @@
     @Override
     @SuppressWarnings({"InfiniteLoopStatement", "unchecked"})
     public void run() {
-        connect();
+//        connect();
         while (true) {
             try {
                 Task task = MessageQueue.poll(SlaveType.Led, slave.getId());
@@ -57,12 +67,16 @@
                         case 1:
                             write((List<LedCommand>)task.getData());
                             break;
+                        // 澶嶄綅
+                        case 2:
+                            reset();
+                            break;
                         default:
                             break;
                     }
                 }
 
-                Thread.sleep(3000);
+                Thread.sleep(1000);
             } catch (Exception e) {
                 e.printStackTrace();
             }
@@ -74,8 +88,7 @@
         boolean connRes = false;
         try {
             connRes = screen.connect(slave.getIp(),slave.getPort());
-        } catch (Exception e) {
-            e.printStackTrace();
+        } catch (Exception ignore) {
         }
         if (connRes) {
             log.info("led杩炴帴鎴愬姛 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
@@ -91,18 +104,78 @@
     }
 
 
-    private void write(List<LedCommand> list) {
+    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 {

--
Gitblit v1.9.1