#

luxiaotao1123

2022-03-16 a32b1370e1c109dcc76eb7c739cf317b41e35984

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

@@ -24,6 +24,7 @@
import com.zy.core.model.protocol.CrnProtocol;
import lombok.Data;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;

import java.text.MessageFormat;
import java.util.Date;
@@ -50,6 +51,11 @@
    @SuppressWarnings("InfiniteLoopStatement")
    public void run() {
        this.connect();
//        try {
//            Thread.sleep(2000);
//        } catch (InterruptedException e) {
//            e.printStackTrace();
//        }
        while (true) {
            try {
                int step = 1;
@@ -88,7 +94,7 @@
                        break;
                }
                // 心跳
//                heartbeat();
                heartbeat();
                Thread.sleep(500);
            } catch (Exception e) {
                e.printStackTrace();
@@ -137,7 +143,7 @@
            log.error("堆垛机plc连接失败！！！ ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
            initCrn();
        }
        melsecMcNet.ConnectClose();
//        melsecMcNet.ConnectClose();
        return result;
    }

@@ -146,9 +152,11 @@
     */
    private void readStatus(){
        try {
            if (this.slave.getId() == 1) {
                System.out.println("===");
            }
//            if (this.slave.getId() == 1 && flag1.equals(0)) {
//                Thread.sleep(3000);
//                flag1=1;
//                System.out.println("===");
//            }
            OperateResultExOne<byte[]> result = melsecMcNet.Read("D20", (short) 70);
            if (result.IsSuccess) {
                if (null == crnProtocol) {
@@ -195,6 +203,7 @@
                BasCrnp basCrnp = new BasCrnp();
                basCrnp.setCrnErr(crnProtocol.getAlarm()==null?0:crnProtocol.getAlarm().longValue());
                basCrnp.setCrnNo(slave.getId());
                basCrnp.setCrnSts((int)crnProtocol.getMode());
                if (!basCrnpService.updateById(crnProtocol.toSqlModel(basCrnp))){
                    log.error("堆垛机plc数据库更新失败 ===>> [id:{}] [ip:{}] [port:{}]", slave.getId(), slave.getIp(), slave.getPort());
                }