#

野心家

2023-03-10 80335b0e3d4c83c583efdfa6d384ac19b4d29cd6

 src/main/java/com/zy/core/thread/LedThread.java

@@ -4,6 +4,7 @@
import com.core.common.Cools;
import com.zy.common.entity.Parameter;
import com.zy.common.model.MatDto;
import com.zy.common.utils.News;
import com.zy.core.Slave;
import com.zy.core.ThreadHandler;
import com.zy.core.cache.MessageQueue;
@@ -52,18 +53,18 @@
    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());
            News.info("led连接构造器错误 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        }
    }

    @Override
    @SuppressWarnings({"InfiniteLoopStatement", "unchecked"})
    public void run() {
        connect();
//        connect();
        close();
        while (true) {
            try {
@@ -92,6 +93,8 @@
                        case 6:
                            errorReset();
                            break;
                        case 7:
                            write7((List<LedCommand>) task.getData());
                        default:
                            break;
                    }
@@ -143,7 +146,7 @@
        area.addPage(page);
        pf.addArea(area);
        if (pf.validate() != null) {
            log.info("pf out of range");
            News.info("pf out of range");
        } else {
            // 更新节目
            screen.writeProgram(pf);
@@ -193,7 +196,7 @@
        pf.addArea(area);
        // 更新节目
        if (pf.validate() != null) {
            log.info("pf out of range");
            News.info("pf out of range");
        } else {
            // 更新节目
            screen.writeProgram(pf);
@@ -202,6 +205,7 @@
        close();
    }
    private void write7(List<LedCommand> list) {

        commandList = list;

        StringBuilder sb = new StringBuilder();
@@ -242,6 +246,8 @@

    @Override
    public boolean connect() {
        String methodName = Thread.currentThread().getStackTrace()[1].getMethodName();

        boolean connRes = false;
        try {
            connRes = screen.connect(slave.getIp(),slave.getPort());
@@ -249,19 +255,17 @@
        } catch (Exception ignore) {
        }
        if (connRes) {
            log.info("led连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
            News.info(methodName + ":led连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        } else {
            log.error("led连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
            News.error(methodName + ":led连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        }
        return connRes;
    }

    @Override
    public void close() {
        screen.disconnect();

    }



    public static void main(String[] args) throws Exception {
        String strQty = "1234";
@@ -308,7 +312,7 @@
            // 更新节目
            if (pf.validate() != null) {
                System.out.println("pf out of range");
                log.info("pf out of range");
                News.info("pf out of range");
            } else {
                // 更新节目
                screen.writeProgram(pf);
@@ -318,37 +322,6 @@
        // 继开与控制器之间的链接
//        screen.disconnect();
    }
































    public static void main1(String[] args) throws Exception {
        Bx5GEnv.initial(3000);