From 022351d2ff51c3110e43bb6966656a462c0df363 Mon Sep 17 00:00:00 2001
From: lsh <lsh@163.com>
Date: 星期二, 20 八月 2024 13:00:30 +0800
Subject: [PATCH] #Map

---
 src/main/java/com/zy/core/thread/LedThread.java |   73 ++++++++++++++++++++++++++++++++----
 1 files changed, 64 insertions(+), 9 deletions(-)

diff --git a/src/main/java/com/zy/core/thread/LedThread.java b/src/main/java/com/zy/core/thread/LedThread.java
index fecbd49..36e9753 100644
--- a/src/main/java/com/zy/core/thread/LedThread.java
+++ b/src/main/java/com/zy/core/thread/LedThread.java
@@ -1,8 +1,5 @@
 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;
@@ -23,9 +20,8 @@
 import onbon.bx05.utils.DisplayStyleFactory;
 
 import java.awt.*;
-import java.util.HashSet;
+import java.util.*;
 import java.util.List;
-import java.util.Set;
 
 /**
  * Created by vincent on 2020/9/1
@@ -43,11 +39,18 @@
     private boolean ledMk = false;
     private boolean resetStatus = false;    // 澶嶄綅鐘舵��
 
+    // 鏄剧ず鍣�
+    private StringBuffer stringBuffer = new StringBuffer();
+    private List<LedCommand> commandList;
+
+//    private StringBuffer errorMsg = new StringBuffer();
+    private Map<String,String> errorMsg = new LinkedHashMap<>();
+
     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 +60,7 @@
     @Override
     @SuppressWarnings({"InfiniteLoopStatement", "unchecked"})
     public void run() {
-        connect();
+//        connect();
         close();
         while (true) {
             try {
@@ -71,6 +74,20 @@
                         // 澶嶄綅
                         case 2:
                             reset();
+                            break;
+                        // 鍐欐暟鎹� 娑叉櫠
+                        case 3:
+                            write7((List<LedCommand>)task.getData());
+                            break;
+                        // 澶嶄綅 娑叉櫠
+                        case 4:
+                            reset7();
+                            break;
+                        case 5:
+                            error((Map<String,String>) task.getData());
+                            break;
+                        case 6:
+                            errorReset();
                             break;
                         default:
                             break;
@@ -181,6 +198,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(Map<String,String> msg) {
+        errorMsg.clear();
+        errorMsg.putAll(msg);
+    }
+
+    public void errorReset() {
+        this.errorMsg.clear();
+    }
 
     @Override
     public boolean connect() {
@@ -200,7 +255,7 @@
 
     @Override
     public void close() {
-        screen.disconnect();
+//        screen.disconnect();
     }
 
 

--
Gitblit v1.9.1