#

luxiaotao1123

2020-08-07 3866f14deeae4e7a7c0cb4d3b98c4ce7d5c48e4f

#

 pom.xml

@@ -92,6 +92,11 @@
            <version>1.16.22</version>
            <scope>provided</scope>
        </dependency>
        <dependency>
            <groupId>com.github.dathlin</groupId>
            <artifactId>HslCommunication</artifactId>
            <version>2.0.0</version>
        </dependency>
        <!-- okHttp3 -->
        <dependency>
            <groupId>com.squareup.okhttp3</groupId>

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

@@ -1,5 +1,8 @@
package com.zy.core.thread;

import com.zy.common.HslCommunication.Core.Types.OperateResult;
import com.zy.common.HslCommunication.Profinet.Siemens.SiemensPLCS;
import com.zy.common.HslCommunication.Profinet.Siemens.SiemensS7Net;
import com.zy.core.Slave;
import com.zy.core.ThreadHandler;
import com.zy.core.cache.MessageQueue;
@@ -16,6 +19,7 @@
@Slf4j
public class CrnThread implements Runnable, ThreadHandler {

    SiemensS7Net siemensNet;
    private Slave slave;

    public CrnThread(Slave slave) {
@@ -27,9 +31,24 @@
    public void run() {
        while (true) {
            try {
                Task task = MessageQueue.poll(SlaveType.Crn, slave.getId());
                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:
                        readStatus();   // 读取状态
                        break;
                    case 2:
                        break;
                    case 3:
                        break;
                    case 4:
                        break;
                    default:
                        break;
                }
                Thread.sleep(3000);
            } catch (Exception e) {
@@ -41,7 +60,21 @@

    @Override
    public boolean connect() {
        return false;
        boolean result = false;
        siemensNet = new SiemensS7Net(SiemensPLCS.S1200,slave.getIp());
        OperateResult connect = siemensNet.ConnectServer();
        if(connect.IsSuccess){
            result = true;
            log.info("堆垛机plc连接成功 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        } else {
            log.info("堆垛机plc连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
        }
        siemensNet.ConnectClose();
        return result;
    }

    private void readStatus(){

    }

    @Override