#

luxiaotao1123

2022-01-17 a7cab611bd98a45c51b0aa96116a0a790f0c97cb

#

 src/main/java/com/zy/core/ServerBootstrap.java

@@ -100,12 +100,12 @@
            SlaveConnection.put(SlaveType.Led, led.getId(), ledThread);
        }
        // 初始化磅秤线程
        log.info("初始化磅秤线程...................................................");
        for (Slave scale : slaveProperties.getScale()) {
            ScaleThread barcodeThread = new ScaleThread(scale);
            new Thread(barcodeThread).start();
            SlaveConnection.put(SlaveType.Scale, scale.getId(), barcodeThread);
        }
//        log.info("初始化磅秤线程...................................................");
//        for (Slave scale : slaveProperties.getScale()) {
//            ScaleThread barcodeThread = new ScaleThread(scale);
//            new Thread(barcodeThread).start();
//            SlaveConnection.put(SlaveType.Scale, scale.getId(), barcodeThread);
//        }
    }



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

@@ -39,6 +39,7 @@
    private MelsecMcNet melsecMcNet;
    private CrnSlave slave;
    private CrnProtocol crnProtocol;
    private short heartBeatVal = 1;
    private boolean resetFlag = false;

    public MelsecCrnThread(CrnSlave slave) {
@@ -86,6 +87,8 @@
                    default:
                        break;
                }
                // 心跳
                heartbeat();
                Thread.sleep(500);
            } catch (Exception e) {
                e.printStackTrace();
@@ -272,6 +275,21 @@
        melsecMcNet.ConnectClose();
    }

    /**
     * 心跳
     */
    private void heartbeat(){
        if (heartBeatVal == 1) {
            heartBeatVal = 2;
        } else {
            heartBeatVal = 1;
        }
        OperateResult write = melsecMcNet.Write("D10", heartBeatVal);
        if (!write.IsSuccess) {
            log.error("输送线plc编号={} 心跳失败", slave.getId());
        }
    }


    /******************************************************************************************/
    /**************************************** 测试专用 *****************************************/