From 6db4a007c34ece48ffac0a2b6c2f700d7b15c6e5 Mon Sep 17 00:00:00 2001
From: lsh <lsh>
Date: 星期五, 12 七月 2024 09:01:40 +0800
Subject: [PATCH] #

---
 src/main/java/com/zy/core/thread/LedThread.java |  121 ++++++++++++++++++++++++++++++++--------
 1 files changed, 97 insertions(+), 24 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/LedThread.java b/src/main/java/com/zy/core/thread/LedThread.java
index de41c18..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 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 {
@@ -71,6 +77,20 @@
                         // 澶嶄綅
                         case 2:
                             reset();
+                            break;
+                        // 鍐欐暟鎹� 娑叉櫠
+                        case 3:
+                            write7((List<LedCommand>)task.getData());
+                            break;
+                        // 澶嶄綅 娑叉櫠
+                        case 4:
+                            reset7();
+                            break;
+                        case 5:
+                            error((String) task.getData());
+                            break;
+                        case 6:
+                            errorReset();
                             break;
                         default:
                             break;
@@ -96,11 +116,18 @@
         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");
@@ -126,9 +153,9 @@
     }
 
     private void reset() throws Bx5GException {
-//        if (!connect()) {
-//            return;
-//        }
+        if (!connect()) {
+            return;
+        }
 //        if (resetStatus) {
 //            return;
 //        }
@@ -139,20 +166,21 @@
         // 鍒涘缓涓�涓暟鎹〉
         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,13));
@@ -173,6 +201,44 @@
         }
         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
     public boolean connect() {
@@ -192,12 +258,19 @@
 
     @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]);

--
Gitblit v1.9.1