JsonDom操作手册

TYPE ST_SampleData :
STRUCT
	//基本数据类型
	bEnabled : BOOL;
    nCounter : INT;
    fTemperature : REAL;
    sName : STRING(20);
	
	//一维数组
    arrValues : ARRAY[0..2] OF DINT;
	
	//二维数组
    arrMatrix : ARRAY[0..1, 0..2] OF REAL;
	
	//时间类型
    dtTimestamp : DATE_AND_TIME;
    tDuration : TIME;
	
	 // 嵌套结构体
    stSubItem : ST_SubStruct;
    
    // 结构体数组
    arrStructs : ARRAY[0..1] OF ST_SubStruct;
END_STRUCT
END_TYPE

TYPE ST_SubStruct :
STRUCT
    bStatus : BOOL;
    nValue : INT;
    sDescription : STRING(15);
END_STRUCT
END_TYPE

stData : ST_SampleData; //存放测试数据

// 初始化结构体数据
    stData.bEnabled := TRUE;
    stData.nCounter := 42;
    stData.fTemperature := 23.5;
    stData.sName := 'SampleDevice';
    
    // 一维数组
    stData.arrValues[0] := 10;
    stData.arrValues[1] := 20;
    stData.arrValues[2] := 30;
    
    // 二维数组
    stData.arrMatrix[0,0] := 1.1;
    stData.arrMatrix[0,1] := 1.2;
    stData.arrMatrix[0,2] := 1.3;
    stData.arrMatrix[1,0] := 2.1;
    stData.arrMatrix[1,1] := 2.2;
    stData.arrMatrix[1,2] := 2.3;
    
    // 时间类型
    stData.dtTimestamp := DT#2023-05-15-14:30:00;
    stData.tDuration := T#1H2M3S;
    
    // 嵌套结构体
    stData.stSubItem.bStatus := FALSE;
    stData.stSubItem.nValue := 99;
    stData.stSubItem.sDescription := 'Nested item';
    
    // 结构体数组
    stData.arrStructs[0].bStatus := TRUE;
    stData.arrStructs[0].nValue := 100;
    stData.arrStructs[0].sDescription := 'Array item 1';
    
    stData.arrStructs[1].bStatus := FALSE;
    stData.arrStructs[1].nValue := 200;
    stData.arrStructs[1].sDescription := 'Array item 2';

sJsonBuffer : STRING(10000);   // JSON缓冲区
fbJsonDom : MetaCore_JsonDom.FB_JsonSaxWriter;
fbJsonDataType : MetaCore_JsonDom.FB_JsonReadWriteDataType;

fbJsonDom.ResetDocument();
 fbJsonDataType.AddJsonKeyValueFromSymbol(
        fbJsonDom, 
        'data', 
        'ST_SampleData', 
        SIZEOF(stData), 
        ADR(stData)
);
nJsonLength := fbJsonDom.GetDocumentLength(); // 获取JSON文档长度
fbJsonDom.CopyDocument(sJsonBuffer, nJsonLength);

data : ST_SampleData; // 用于接收解析后的数据

fbJsonDataType : MetaCore_JsonDom.FB_JsonReadWriteDataType;

 // 测试JSON转回结构体
    fbJsonDataType.SetSymbolFromJson(
        sJsonBuffer,
        SIZEOF(sJsonBuffer),  
        ADR(data),
        SIZEOF(data)
    );

// MQTT客户端
    Client : MetaCore_IoTMqtt.FB_IotMqttClient;
    MessageQueue : MetaCore_IoTMqtt.FB_IotMqttMessageQueue;
    Message : MetaCore_IoTMqtt.FB_IotMqttMessage;
    sWillingMessage : MetaCore_IoTMqtt.ST_IotMqttWill;
WillingPayload : STRING := 'PLC offline';

// 控制标志
run : BOOL := TRUE;
bPublish : BOOL := FALSE;  // 手动发布触发标志
bDataPublished : BOOL := FALSE;  //是否发布标志
bConnect : BOOL := FALSE;        // 手动连接触发标志

 // MQTT连接管理
Client(
      sClientId := 'PLC_Client',
      sHostName := '192.168.105.16',
      nHostPort := 1883,
      nKeepAlive := 5,
      stWill := sWillingMessage,
      ipMessageQueue := ADR(MessageQueue),
      bError => ,
      hrErrorCode => ,
      eConnectionState => ,
      bConnected => 
);
Client.Execute(bCo

// 发布消息
IF Client.bConnected AND bPublish THEN

	    Client.Publish(
        'plc/data',
        ADR(sJsonBuffer),
        nJsonLength,  // 使用实际JSON长度
        2,            // QoS=2确保可靠传输
        FALSE,
        FALSE
    );
    
// 发布后重置触发标志
bPublish := FALSE; 
bDataPublished := TRUE;
END_IF

import paho.mqtt.client as mqtt
import json
from datetime import datetime

def on_connect(client, userdata, flags, rc):
    print(f" Connected to MQTT broker with code: {rc}")
    client.subscribe("plc/data")

def parse_duration(duration_str):
    """解析CODESYS的TIME格式（如T1H2M3S）"""
    if not isinstance(duration_str, str) or not duration_str.startswith('T'):
        return None
    
    hours = minutes = seconds = 0
    time_str = duration_str[1:]  # 去掉'T'
    
    if 'H' in time_str:
        hours = int(time_str.split('H')[0])
        time_str = time_str.split('H')[1]
    if 'M' in time_str:
        minutes = int(time_str.split('M')[0])
        time_str = time_str.split('M')[1]
    if 'S' in time_str:
        seconds = int(time_str.split('S')[0])
    
    return {
        'hours': hours,
        'minutes': minutes,
        'seconds': seconds,
        'total_seconds': hours*3600 + minutes*60 + seconds
    }

def on_message(client, userdata, msg):
    try:
        # 原始数据检查
        raw_data = msg.payload.decode('utf-8')
        print(f"\n Raw message length: {len(raw_data)} bytes")
        
        # 调试：打印前200个字符（避免日志过长）
        print(f" Sample data (first 200 chars):\n{raw_data[:200]}{'...' if len(raw_data)>200 else ''}")

        try:
            data = json.loads(raw_data)
        except json.JSONDecodeError as e:
            print(f" JSON解析失败！错误位置：{e.pos}，可能原因：数据截断或格式错误")
            print(f" 错误附近的上下文：\n{raw_data[max(0, e.pos-50):e.pos+50]}")
            return

        # 美化打印完整JSON
        print("\n 完整JSON数据结构：")
        print(json.dumps(data, indent=2, ensure_ascii=False))

        # 提取数据字段
        plc_data = data.get('data', {})
        
        # 基本字段
        print("\n 基本数据：")
        print(f"• 设备名称: {plc_data.get('sName', 'N/A')}")
        print(f"• 使能状态: {'ON' if plc_data.get('bEnabled') else 'OFF'}")
        print(f"• 计数器值: {plc_data.get('nCounter', 0)}")
        print(f"• 温度: {plc_data.get('fTemperature', 0.0):.2f}°C")
        
        # 数组数据
        print("\n 数组数据：")
        print(f"• 一维数组: {plc_data.get('arrValues', [])}")
        print(f"• 二维数组: {plc_data.get('arrMatrix', [])}")

        # 智能时间处理
        print("\n 时间数据：")
        timestamp = plc_data.get('dtTimestamp')
        if timestamp:
            if isinstance(timestamp, (int, float)):  # Unix时间戳
                dt = datetime.fromtimestamp(timestamp)
                print(f"• 时间戳 (Unix): {timestamp} → {dt.isoformat()}")
            elif isinstance(timestamp, str):  # ISO格式
                try:
                    dt = datetime.strptime(timestamp, "%Y-%m-%dT%H:%M:%S")
                    print(f"• 时间戳 (ISO): {dt.isoformat()}")
                except ValueError:
                    print(f"• 无法解析的时间格式: {timestamp}")
        
        # 持续时间处理
        duration = plc_data.get('tDuration')
        if duration:
            if isinstance(duration, str):
                parsed = parse_duration(duration)
                if parsed:
                    print(f"• 持续时间: {duration}")
                    print(f"  → 合计: {parsed['total_seconds']}秒 (H:M:S = {parsed['hours']}:{parsed['minutes']}:{parsed['seconds']})")
                else:
                    print(f"• 非标准持续时间格式: {duration}")
            elif isinstance(duration, (int, float)):
                print(f"• 持续时间 (秒): {duration}")
        
        # 结构体数据
        print("\n 结构体数据：")
        if 'stSubItem' in plc_data:
            sub = plc_data['stSubItem']
            print(f"• 子结构体: Status={sub.get('bStatus')}, Value={sub.get('nValue')}, Desc='{sub.get('sDescription','')}'")
        
        if 'arrStructs' in plc_data:
            print("• 结构体数组:")
            for i, item in enumerate(plc_data['arrStructs']):
                print(f"  [{i}] Status={item.get('bStatus')}, Value={item.get('nValue')}, Desc='{item.get('sDescription','')}'")

    except Exception as e:
        print(f"\n‼️ 处理消息时发生严重错误: {str(e)}")
        import traceback
        traceback.print_exc()

# MQTT客户端配置
client = mqtt.Client(
    client_id="PythonSubscriber",
    protocol=mqtt.MQTTv311,
    transport="tcp"
)

# 回调绑定
client.on_connect = on_connect
client.on_message = on_message

# 连接设置
broker_ip = "192.168.105.16"
client.connect(broker_ip, 1883, 60)

print(f" 开始监听MQTT主题 plc/data，连接服务器: {broker_ip}...")

try:
    client.loop_forever()
except KeyboardInterrupt:
    print("\n手动停止订阅")
    client.disconnect()

cd $HOME
sudo dpkg -i SF4601_JsonDom_1.0.3_amd64.deb

sudo nano /usr/local/etc/SinsegyeRTE/SinsegyeRTE.cfg

[ComponentManager]
  Component.0=retainDeamon
  Component.1=CmpCanBusUtils
  Component.2=CmpSinsegyeLibs
  Component.3=SinsegyeCmp
  Component.4=jsondom

sudo systemctl restart sinsegyerte.service

cd $HOME
sudo dpkg -i SF4601_JsonDom_1.0.3_amd64.deb

sudo systemctl restart sinsegyerte.service

sudo dpkg -r jsondom

sudo nano /usr/local/etc/SinsegyeRTE/SinsegyeRTE.cfg

sudo systemctl restart sinsegyerte.service