#

luxiaotao1123

2020-08-06 687d250bf7f02bebc03e660933a2669fa28d93b5

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

@@ -8,8 +8,12 @@
import com.zy.core.cache.MessageQueue;
import com.zy.core.enums.SlaveType;
import com.zy.core.model.Task;
import com.zy.core.model.protocol.StaProtocol;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;

import java.util.Map;
import java.util.concurrent.ConcurrentHashMap;

/**
 * 输送线线程
@@ -21,6 +25,7 @@

    private Slave slave;
    private SiemensS7Net siemensS7Net;
    private Map<Integer, StaProtocol> station = new ConcurrentHashMap<>();

    public DevpThread(Slave slave) {
        this.slave = slave;
@@ -32,9 +37,23 @@
    public void run() {
        while (true) {
            try {
                int step = 1;
                Task task = MessageQueue.poll(SlaveType.Devp, slave.getId());
                if (task != null) {
                    System.out.println("任务"+task.getId());
                    step = task.getStep();
                }
                switch (step) {
                    // 读数据
                    case 1:
                        readWorkNo();   // 读取工作号
                        readStaDest();  // 读取目标站
                        readStatus();   // 读取状态
                        readError();    // 读取异常信息
                        break;
                    case 2:
                        break;
                    default:
                        break;
                }
                Thread.sleep(3000);
            } catch (Exception e) {
@@ -59,6 +78,35 @@
        return result;
    }

    /**
     * 读取工作号
     */
    private void readWorkNo(){

    }

    /**
     * 读取目标站
     */
    private void readStaDest(){

    }

    /**
     * 读取状态
     */
    private void readStatus(){

    }

    /**
     * 读取异常信息
     */
    private void readError(){

    }


    @Override
    public void close() {