#

luxiaotao1123

2020-08-12 30438080e4b44e7b5f68c41f66e42fbff99bd021

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

@@ -1,10 +1,9 @@
package com.zy.core.thread;

import HslCommunication.Core.Types.OperateResult;
import HslCommunication.Enthernet.SimplifyNet.NetSimplifyClient;
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 lombok.Data;
import lombok.extern.slf4j.Slf4j;

@@ -17,6 +16,8 @@
public class BarcodeThread implements Runnable, ThreadHandler {

    private Slave slave;
    private String barcode;
    private NetSimplifyClient netSimplifyClient;

    public BarcodeThread(Slave slave) {
        this.slave = slave;
@@ -28,10 +29,8 @@
    public void run() {
        while (true) {
            try {
                Task task = MessageQueue.poll(SlaveType.Barcode, slave.getId());
                if (task != null) {
                    System.out.println("任务"+task.getId());
                }
//                Task task = MessageQueue.poll(SlaveType.Barcode, slave.getId());
                barcode = "10001136";
                Thread.sleep(3000);
            } catch (Exception e) {
                e.printStackTrace();
@@ -42,12 +41,26 @@

    @Override
    public boolean connect() {

        return false;
        boolean result = false;
        netSimplifyClient = new NetSimplifyClient(slave.getIp(), slave.getPort());
        OperateResult connect = netSimplifyClient.ConnectServer();
        if (connect.IsSuccess) {
            result = true;
            log.info("条码扫描仪连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        } else {
            log.info("条码扫描仪连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        }
        return result;
    }

    @Override
    public void close() {

    }

    public static void main(String[] args) {
        BarcodeThread barcodeThread = new BarcodeThread();
        boolean connect = barcodeThread.connect();
        System.out.println(connect);
    }
}