From 5989fd098fea045da7a3612d2c9b0da38b2d1d27 Mon Sep 17 00:00:00 2001
From: lsh <lsh>
Date: 星期日, 26 五月 2024 08:32:16 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/LedThread.java |  212 ++++++++++++++++++++++++++++++++++------------------
 1 files changed, 138 insertions(+), 74 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/LedThread.java b/src/main/java/com/zy/core/thread/LedThread.java
index deb64fe..0cbc00a 100644
--- a/src/main/java/com/zy/core/thread/LedThread.java
+++ b/src/main/java/com/zy/core/thread/LedThread.java
@@ -40,14 +40,20 @@
     TextCaptionBxArea area;
     DisplayStyleFactory.DisplayStyle[] styles = DisplayStyleFactory.getStyles().toArray(new DisplayStyleFactory.DisplayStyle[0]);
     private Set<Integer> workNos = new HashSet<>();
-    private boolean ledMk = true;
-//    private boolean resetStatus = false;    // 澶嶄綅鐘舵��
+    private boolean ledMk = false;
+    private boolean resetStatus = false;    // 澶嶄綅鐘舵��
+
+    // 鏄剧ず鍣�
+    private StringBuffer stringBuffer = new StringBuffer();
+    private List<LedCommand> commandList;
+
+    private StringBuffer errorMsg = new StringBuffer();
 
     public LedThread(Slave slave) {
         this.slave = slave;
         try {
-            Bx5GEnv.initial(3000);
-            screen = new Bx5GScreenClient("my");
+//            Bx5GEnv.initial(3000);
+//            screen = new Bx5GScreenClient("my");
         } catch (Exception e) {
             e.printStackTrace();
             log.info("led杩炴帴鏋勯�犲櫒閿欒 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
@@ -57,7 +63,7 @@
     @Override
     @SuppressWarnings({"InfiniteLoopStatement", "unchecked"})
     public void run() {
-        connect();
+//        connect();
         close();
         while (true) {
             try {
@@ -72,9 +78,19 @@
                         case 2:
                             reset();
                             break;
-                        // 璀﹀憡淇℃伅
+                        // 鍐欐暟鎹� 娑叉櫠
                         case 3:
-                            write(String.valueOf(task.getData()));
+                            write7((List<LedCommand>)task.getData());
+                            break;
+                        // 澶嶄綅 娑叉櫠
+                        case 4:
+                            reset7();
+                            break;
+                        case 5:
+                            error((String) task.getData());
+                            break;
+                        case 6:
+                            errorReset();
                             break;
                         default:
                             break;
@@ -89,29 +105,36 @@
     }
 
     private void write(List<LedCommand> list) throws Bx5GException {
-//        if (!connect()) {
-//            return;
-//        }
+        if (!connect()) {
+            return;
+        }
         pf = new ProgramBxFile( 0, screen.getProfile());
         pf.setFrameShow(false);
         // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eight
-        area = new TextCaptionBxArea( 0,0,192,128, screen.getProfile());
+        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.getIoType() < 100 ? command.getLocNo() : command.getSourceLocNo()));
             page.newLine("鐩爣绔欙細"+command.getStaNo());
             if (!command.isEmptyMk()) {
                 for (MatDto matDto : command.getMatDtos()) {
-                    page.newLine(matDto.getMaknx() + "銆愭暟閲�" + matDto.getCount() +"銆�");
+                    //鍘绘帀灏忔暟鐐�
+                    String strQty = matDto.getCount().toString();
+                    int idx = strQty.lastIndexOf(".");
+                    if(idx >= 0){
+                        strQty.substring(0,idx);
+                    }
+                    page.newLine(matDto.getMaknx() + "[鏁伴噺" + strQty +"]");
+//                    page.newLine(matDto.getMaknx() + "銆愭暟閲�" + matDto.getCount() +"銆�");
                 }
             }
             page.newLine("\n");
         }
 
         // 璁剧疆瀛椾綋
-        page.setFont(new Font("瀹嬩綋",Font.PLAIN,14));
+        page.setFont(new Font("瀹嬩綋",Font.PLAIN,12));
         // 璁剧疆鏂囨湰棰滆壊
         page.setForeground(Color.red);
         // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
@@ -119,67 +142,48 @@
         area.clearPages();
         area.addPage(page);
         pf.addArea(area);
-        // 鏇存柊鑺傜洰
-        screen.writeProgram(pf);
-//        resetStatus = false;
-        close();
-    }
-
-    private void write(String str) throws Bx5GException {
-//        if (!connect() || Cools.isEmpty(str)) {
-//            return;
-//        }
-        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(str);
-        page.newLine("\n");
-        // 璁剧疆瀛椾綋
-        page.setFont(new Font("瀹嬩綋",Font.PLAIN,14));
-        // 璁剧疆鏂囨湰棰滆壊
-        page.setForeground(Color.red);
-        // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
-        page.setDisplayStyle(styles[6]);
-        area.clearPages();
-        area.addPage(page);
-        pf.addArea(area);
-        // 鏇存柊鑺傜洰
-        screen.writeProgram(pf);
-//        resetStatus = false;
+        if (pf.validate() != null) {
+            log.info("pf out of range");
+        } else {
+            // 鏇存柊鑺傜洰
+            screen.writeProgram(pf);
+//            resetStatus = false;
+        }
         close();
     }
 
     private void reset() throws Bx5GException {
-//        if (!connect()) {
+        if (!connect()) {
+            return;
+        }
+//        if (resetStatus) {
 //            return;
 //        }
         pf = new ProgramBxFile( 0, screen.getProfile());
         pf.setFrameShow(false);
         // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eight
-        area = new TextCaptionBxArea( 0,0,192,128, screen.getProfile());
+        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("娴欐睙涓壃绔嬪簱鎶�鏈湁闄愬叕鍙�");
-        }
+//        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.newLine("鍔涙簮鏅鸿兘浠撳偍");
 
         // 璁剧疆瀛椾綋
-        page.setFont(new Font("瀹嬩綋",Font.PLAIN,15));
+        page.setFont(new Font("瀹嬩綋",Font.PLAIN,13));
         // 璁剧疆鏂囨湰棰滆壊
         page.setForeground(Color.red);
         // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
@@ -188,8 +192,52 @@
         area.addPage(page);
         pf.addArea(area);
         // 鏇存柊鑺傜洰
-        screen.writeProgram(pf);
+        if (pf.validate() != null) {
+            log.info("pf out of range");
+        } else {
+            // 鏇存柊鑺傜洰
+            screen.writeProgram(pf);
+//            resetStatus = true;
+        }
         close();
+    }
+    private void write7(List<LedCommand> list) {
+        commandList = list;
+
+        StringBuilder sb = new StringBuilder();
+        for (LedCommand command : list) {
+            sb.append(command.getTitle()).append("锛�").append(command.getWorkNo()).append(")").append("\n");
+            sb.append("婧愬簱浣嶏細").append(command.getSourceLocNo()).append("\n");
+            sb.append("鐩爣绔欙細").append(command.getStaNo()).append("\n");
+            if (!command.isEmptyMk()) {
+                for (MatDto matDto : command.getMatDtos()) {
+                    sb.append("鐗╂枡缂栫爜锛�").append(matDto.getMatNo()).append("\n");
+                    sb.append("鏁伴噺锛�").append(matDto.getCount()).append("\n");
+                }
+            }
+            sb.append("\n");
+        }
+        stringBuffer.delete(0, stringBuffer.length());
+        stringBuffer.append(sb.toString());
+
+        errorReset();
+    }
+
+
+    private void reset7() {
+        commandList = null;
+
+        stringBuffer.delete(0, stringBuffer.length());
+    }
+
+
+    private void error(String msg) {
+        errorMsg.delete(0, errorMsg.length());
+        errorMsg.append(msg);
+    }
+
+    public void errorReset() {
+        this.errorMsg.delete(0, errorMsg.length());
     }
 
     @Override
@@ -198,28 +246,35 @@
         try {
             connRes = screen.connect(slave.getIp(),slave.getPort());
             screen.turnOn();
-            if (connRes) {
-                log.info("led杩炴帴鎴愬姛 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
-                reset();
-            } else {
-                log.error("led杩炴帴澶辫触锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
-            }
-        } catch (Exception ignore) { }
+        } catch (Exception ignore) {
+        }
+        if (connRes) {
+            log.info("led杩炴帴鎴愬姛 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+        } else {
+            log.error("led杩炴帴澶辫触锛侊紒锛� ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
+        }
         return connRes;
     }
 
     @Override
     public void close() {
-        screen.disconnect();
+//        screen.disconnect();
     }
 
 
 
     public static void main(String[] args) throws Exception {
+        String strQty = "1234";
+        int index = strQty.lastIndexOf(".");
+        if(index>=0) {
+            strQty=strQty.substring(0, index);
+        }
+        System.out.println("2==>>"+strQty);
+
         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;
         }
@@ -232,7 +287,7 @@
             ProgramBxFile pf = new ProgramBxFile( 0, screen.getProfile());
             pf.setFrameShow(false);
             // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eigth
-            TextCaptionBxArea area = new TextCaptionBxArea(  0,0,192,128,screen.getProfile());
+            TextCaptionBxArea area = new TextCaptionBxArea(  0,0,192,96,screen.getProfile());
 
             // 鍒涘缓涓�涓暟鎹〉
             // 绗竴琛屾暟鎹�
@@ -240,7 +295,9 @@
             page.newLine("婧愬簱浣嶏細0100204");
             page.newLine("鐩爣绔欙細1000");
             // 璁剧疆瀛椾綋
-            page.setFont( new Font("瀹嬩綋",Font.PLAIN,12));
+            page.setFont( new Font("瀹嬩綋",Font.PLAIN,15));
+            // 璁剧疆鏂囨湰棰滆壊
+            page.setForeground(Color.red);
             // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑�
             page.setDisplayStyle(styles[6]);
             area.clearPages();
@@ -248,7 +305,14 @@
             pf.addArea( area );
 
             // 鏇存柊鑺傜洰
-            screen.writeProgram(pf);
+            // 鏇存柊鑺傜洰
+            if (pf.validate() != null) {
+                System.out.println("pf out of range");
+                log.info("pf out of range");
+            } else {
+                // 鏇存柊鑺傜洰
+                screen.writeProgram(pf);
+            }
         }
 
         // 缁у紑涓庢帶鍒跺櫒涔嬮棿鐨勯摼鎺�

--
Gitblit v1.9.1