#

luxiaotao1123

2020-11-20 1e762da8527630096dc84ba589afede826b7f802

 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,18 @@

    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;    //  复位状态

    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());
@@ -37,15 +52,28 @@
    }

    @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;
                        // 复位
                        case 2:
                            reset();
                            break;
                        default:
                            break;
                    }
                }



                Thread.sleep(500);
                Thread.sleep(3000);
            } catch (Exception e) {
                e.printStackTrace();
            }
@@ -57,8 +85,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,6 +101,60 @@
    }


    private void write(List<LedCommand> list) throws Bx5GException {
        pf = new ProgramBxFile( 0, screen.getProfile());
        pf.setFrameShow(false);
        // 分别输入X，Y，width，height
        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;
    }

    private void reset() throws Bx5GException {
        if (!resetStatus) {
            pf = new ProgramBxFile( 0, screen.getProfile());
            pf.setFrameShow(false);
            // 分别输入X，Y，width，height
            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);
            resetStatus = true;
        }
    }


    public static void main(String[] args) throws Exception {
@@ -91,17 +172,22 @@
        TextCaptionBxArea area = new TextCaptionBxArea( 0,0,192,128,screen.getProfile());
        // 创建一个数据页
        // 第一行数据
        TextBxPage page = new TextBxPage("入库");
        // 第二行数据
        page.newLine( "物料：" );
        page.newLine("接收器 RX18 XH 6V （数量：2）");
        page.newLine("中控 BM蓝牙 英文 6V （数量：1）");
        page.newLine("线束 S2588-1-XX 无实物（数量：5）");
        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[2]);
        page.setDisplayStyle(styles[6]);
        area.addPage(page);
        pf.addArea( area );
        // 更新节目