#

luxiaotao1123

2020-08-06 687d250bf7f02bebc03e660933a2669fa28d93b5

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

@@ -37,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) {
@@ -64,6 +78,35 @@
        return result;
    }

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

    }

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

    }

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

    }

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

    }


    @Override
    public void close() {