From 968072c0fb57b0a95ce2d45daed8f3e2e735b27c Mon Sep 17 00:00:00 2001 From: luxiaotao1123 <t1341870251@163.com> Date: 星期四, 03 九月 2020 17:02:53 +0800 Subject: [PATCH] # --- src/main/java/com/zy/core/thread/LedThread.java | 144 +++++++++++++++++++++++++++++++++++++++++++++--- 1 files changed, 135 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 471ec1f..0384e64 100644 --- a/src/main/java/com/zy/core/thread/LedThread.java +++ b/src/main/java/com/zy/core/thread/LedThread.java @@ -1,10 +1,16 @@ 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; +import com.zy.core.enums.SlaveType; +import com.zy.core.model.Task; +import com.zy.core.model.command.LedCommand; 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; @@ -14,6 +20,9 @@ import onbon.bx05.utils.DisplayStyleFactory; import java.awt.*; +import java.util.HashSet; +import java.util.List; +import java.util.Set; /** * Created by vincent on 2020/9/1 @@ -24,12 +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<>(); public LedThread(Slave slave) { this.slave = slave; try { Bx5GEnv.initial(3000); - screen = new Bx5GScreenClient("MyScreen"); + screen = new Bx5GScreenClient("my"); + screen.turnOn(); + pf = new ProgramBxFile( 0, screen.getProfile()); + pf.setFrameShow(false); + // 鍒嗗埆杈撳叆X锛孻锛寃idth锛宧eight + area = new TextCaptionBxArea( 0,0,192,128,screen.getProfile()); } catch (Exception e) { e.printStackTrace(); log.info("led杩炴帴鏋勯�犲櫒閿欒 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort()); @@ -37,15 +55,24 @@ } @Override - @SuppressWarnings("InfiniteLoopStatement") + @SuppressWarnings({"InfiniteLoopStatement", "unchecked"}) public void run() { connect(); while (true) { try { + Task task = MessageQueue.poll(SlaveType.Led, slave.getId()); + if (task != null) { + switch (task.getStep()) { + // 鍐欐暟鎹� + case 1: + write((List<LedCommand>)task.getData()); + break; + default: + break; + } + } - - - Thread.sleep(500); + Thread.sleep(3000); } catch (Exception e) { e.printStackTrace(); } @@ -57,8 +84,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()); @@ -74,7 +100,103 @@ } + private void write(List<LedCommand> list) throws Bx5GException { + // 鍒涘缓涓�涓暟鎹〉 + TextBxPage page = new TextBxPage(); + for (LedCommand command : list) { + page.newLine("鍑哄簱浠诲姟锛�"+command.getWorkNo()+")"); + page.newLine("婧愬簱浣嶏細"+command.getSourceLocNo()); + page.newLine("鐩爣绔欙細"+command.getStaNo()); + 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.addPage(page); + pf.addArea(area); + // 鏇存柊鑺傜洰 + screen.writeProgram(pf); + } + + + + 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)) { + 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); + // 缁у紑涓庢帶鍒跺櫒涔嬮棿鐨勯摼鎺� + screen.disconnect(); + } + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + + public static void main1(String[] args) throws Exception { Bx5GEnv.initial(3000); // 鍒涘缓screen瀵硅薄锛岀敤浜庡鎺у埗鍣ㄨ繘琛岃闂紝瀹㈡埛绔ā寮� Bx5GScreenClient screen = new Bx5GScreenClient("my"); @@ -136,9 +258,13 @@ // 鍒涘缓涓�涓暟鎹〉 // 绗竴琛屾暟鎹� - TextBxPage page = new TextBxPage("浠伴偊绉戞妧娆㈣繋浣�"); + TextBxPage page = new TextBxPage("鍏ュ簱"); // 绗簩琛屾暟鎹� - page.newLine( "杩欐槸绗簩琛�" ); + page.newLine( "鐗╂枡锛�" ); + page.newLine("鎺ユ敹鍣� RX18 XH 6V 锛堟暟閲忥細2锛�"); + page.newLine("涓帶 BM钃濈墮 鑻辨枃 6V 锛堟暟閲忥細1锛�"); + page.newLine("绾挎潫 S2588-1-XX 鏃犲疄鐗╋紙鏁伴噺锛�5锛�"); + page.newLine("鐩爣搴撲綅锛�0100204"); // 璁剧疆瀛椾綋 page.setFont( new Font("瀹嬩綋",Font.PLAIN,12) ); // 璁剧疆鏄剧ず鐗规妧涓哄揩閫熸墦鍑� -- Gitblit v1.9.1