syntax = "proto3";

package shm.strain.v1;

// 遥测上报消息
message StrainTelemetry {
  StrainBatch strainBatch = 1;

  message StrainBatch {
    uint64 timestamp = 1;            // 首样本设备时间戳（毫秒）
    uint32 ch_no = 2;                // 通道编号（从 1 开始）
    uint32 sample_interval_ms = 3;   // 采样间隔（ms），100Hz=10, 50Hz=20, 20Hz=50
    repeated sint32 values = 4;      // 该通道的应变值数组（με）
    optional float temperature = 5;   // 该通道温度值（℃）
    optional uint32 battery = 6;     // 电池电量 0-100%
    optional uint32 mode = 7;        // 设备工作模式
    optional uint32 status = 8;      // 状态码，0=正常
  }
}

// 属性上报消息
message StrainDeviceAttributes {
  string firmware_version = 1;       // 固件版本
  string serial_number = 2;          // 设备序列号
  string device_model = 3;           // 设备型号
  uint32 channel_count = 4;          // 通道数
  uint32 sample_interval_ms = 5;     // 采样间隔（ms），所有通道统一
}

pip install paho-mqtt protobuf

protoc --python_out=. strain.proto

#!/usr/bin/env python3
"""应变读数仪模拟器 - 10通道 100Hz"""

import math, random, time
import paho.mqtt.client as mqtt
import strain_pb2

BROKER = "gw.mqtt.inteagle.com"
PORT = 1883
TOKEN = "your_access_token"       # 替换为平台分配的 Access Token
DEVICE_ID = "ZX-0001"             # 替换为平台分配的设备编号
CHANNELS = 10
SAMPLE_INTERVAL_MS = 10           # 100Hz

def on_connect(client, userdata, flags, rc, properties=None):
    print(f"连接{'成功' if rc == 0 else '失败: ' + str(rc)}")

def main():
    client = mqtt.Client(mqtt.CallbackAPIVersion.VERSION2, client_id=f"strain-{DEVICE_ID}")
    client.username_pw_set(TOKEN)
    client.on_connect = on_connect
    client.connect(BROKER, PORT, keepalive=60)
    client.loop_start()
    time.sleep(1)

    # 上报设备属性（仅启动时一次）
    attrs = strain_pb2.StrainDeviceAttributes()
    attrs.firmware_version = "1.0.3"
    attrs.serial_number = DEVICE_ID
    attrs.device_model = "SGR-10"
    attrs.channel_count = CHANNELS
    attrs.sample_interval_ms = SAMPLE_INTERVAL_MS
    client.publish(f"strain/{DEVICE_ID}/attributes", attrs.SerializeToString(), qos=1)
    print("属性上报完成")

    # 持续上报遥测
    topic = f"strain/{DEVICE_ID}/telemetry"
    num_samples = 1000 // SAMPLE_INTERVAL_MS  # 100

    for sec in range(10):
        ts_ms = int(time.time() * 1000)

        for ch in range(1, CHANNELS + 1):
            msg = strain_pb2.StrainTelemetry()
            batch = msg.strainBatch
            batch.timestamp = ts_ms
            batch.ch_no = ch
            batch.sample_interval_ms = SAMPLE_INTERVAL_MS

            # 模拟应变数据
            base = 1500 + ch * 100
            for i in range(num_samples):
                t = i * SAMPLE_INTERVAL_MS / 1000.0
                val = int(base + 200 * math.sin(2 * math.pi * 2.0 * t) + random.randint(-10, 10))
                batch.values.append(val)

            batch.temperature = 25.3
            batch.battery = 85
            batch.status = 0
            client.publish(topic, msg.SerializeToString(), qos=0)

        print(f"第{sec+1}秒: 发送 {CHANNELS} 包")
        time.sleep(1)

    client.loop_stop()
    client.disconnect()
    print("完成")

if __name__ == "__main__":
    main()

python sim_strain.py