S7协议转HTTP协议

如下来源成都纵横智控-https://www.iotrouter.com/

需求概述

本章要实现一个流程：EG8200采集西门子S7-200Smart的数据，并组装成JSON格式通过HTTP上报应用平台。
要采集的PLC点位表如下：

HTTP通信相关参数格式如下：

需求分析

在制作流程时，基础的逻辑是根据数据走向来制作流程。其中主要工作分为三步：
第一步：通过S7协议读取PLC变量数据，得到的数据存储在内存中（西门子节点）
第二步：将数据按照JSON格式进行格式化（函数节点）
第三步：配置HTTP 请求参数​

需求实现

1 采集PLC数据

从节点库拖入一个西门子节点，以及一个调试节点，调试节点用于查看读取到的PLC数据集，方便定位问题：

双击西门子节点，根据需求概述的内容填写对应的设置参数，如下图所示：

如果设置正确，调试窗口会有日志打印，显示的是读取到的数据内容：

有的时候PLC数据点比较多，手动依次录入比较繁琐。节点支持数据点的导入导出或者参数传递的方式来读取：

本例程用到的传参方案，函数节点内的代码如下：

2数据格式化

根据步骤引导，在调试窗口可以看到读到的PLC数据如下：

因为应用平台已经规定了数据必须按照JSON格式上报。接下来使用函数节点Javascrip代码将数据进行格式化，代码如下：

class DeviceReport {
    constructor(machineNumber, machineGroupNumber) {
        this.deviceInfo = {
            machineNumber: machineNumber,
            machineGroupNumber: machineGroupNumber
        };
        this.status = {
            fan1ContactError: 0,
            fan2ContactError: 0,
            fan3ContactError: 0,
            inverterCommError: 0,
            motorHighTempAlarm: 0,
            temperatureStatusError: 0
        };
        this.data = {
            oilPressure: 0,
            suctionPressure: 0,
            fuelLevel: 0,
            cabinetTemperature: 0,
            engineVoltage: 0,
            engineCurrent: 0,
            engineRuntime: 0,
            pumpPressure: 0,
            motor1Temperature: 0,
            motor2Temperature: 0,
            motor3Temperature: 0,
            fan1Temperature: 0,
            fan2Temperature: 0,
            fan3Temperature: 0
        };
        this.timestamp = null;
    }

    // 设置状态数据（1表示异常，0表示正常）
    setStatusData(statusData) {
        this.status = statusData;
    }

    // 设置传感器数据
    setSensorData(sensorData) {
        this.data = sensorData;
    }

    // 设置时间戳
    setTimestamp(timestamp) {
        this.timestamp = timestamp;
    }
    generateReport() {
        return {
            deviceInfo: this.deviceInfo,
            status: this.status,
            data: this.data,
            timestamp: this.timestamp
        };
    }
}

function dateFormat(fmt, timestamp) {
    let ret;
    const opt = {
        "Y+": timestamp.getFullYear().toString(), // 年
        "m+": (timestamp.getMonth() + 1).toString(),  // 月
        "d+": timestamp.getDate().toString(), // 日
        "H+": timestamp.getHours().toString(), // 时
        "M+": timestamp.getMinutes().toString(), // 分
        "S+": timestamp.getSeconds().toString() // 秒
    };
    for (let k in opt) {
        ret = new RegExp("(" + k + ")").exec(fmt);
        if (ret) {
            fmt = fmt.replace(ret[1], (ret[1].length == 1) ? (opt[k]) : (opt[k].padStart(ret[1].length, "0")))
        };
    };
    return fmt;
}
function setValue(data) {
    var myDeviceReport = new DeviceReport(data.VW120, data.VW750)
    var v0 = data.V0
    var v1 = data.V1
    var v2 = data.V2
    var i0 = data.I0
    var vd4 = data.VD4
    var vd2402 = data.VW2402
    const fmt = dateFormat("YYYY-mm-dd HH:MM:SS", new Date())
    try {
        // 设置状态数据
        const statusData = {
            fan1ContactError: v0[0],
            fan2ContactError: v0[6],
            fan3ContactError: v1[6],
            inverterCommError: v2[5],
            motorHighTempAlarm: i0[0],
            temperatureStatusError: i0[1]
        }
        myDeviceReport.setStatusData(statusData)

        // 设置传感器数据
        const sensorData = {
            oilPressure: vd4[0],
            suctionPressure: vd4[1],
            fuelLevel: vd4[2],
            cabinetTemperature: vd4[3],
            engineVoltage: vd4[4],
            engineCurrent: vd4[5],
            engineRuntime: vd4[6],
            pumpPressure: vd4[7],
            motor1Temperature: vd2402[0],
            motor2Temperature: vd2402[1],
            motor3Temperature: vd2402[2],
            fan1Temperature: vd2402[3],
            fan2Temperature: vd2402[4],
            fan3Temperature: vd2402[5]
        }
        myDeviceReport.setSensorData(sensorData)
        // 设置时间戳
        myDeviceReport.setTimestamp(fmt)
        //生成JSON对象返回
        return myDeviceReport.generateReport()
    } catch (err) {
        node.error(err.message);
        return null
    }

}
var plcData = msg.payload
if (setValue(plcData)){
    msg.payload = JSON.stringify(setValue(plcData),null,2)
    return msg
}

复制以上代码，粘贴到函数节点内，部署后即可看到效果：

可以看到，已经将读到的PLC数据，按照需求要求转换成了最终的JSON格式，且对数据进行了一定程度的计算（两位小数）。此处只是函数节点的冰山一角，因为支持Javascrip语言编程，几乎你能想到的任何功能都可以在这里实现。

3通过http周期上报

拖入一个HTTP节点，根据提示进行配置地址和请求方式，即可实现数据上报：

服务端返回成功，至此，数据上报已经完成，很简单几步即可实现：采集PLC数据并按照自定义JSON格式上报。