// debug 设备调试数据 package fwh_mqtt import ( "context" "encoding/json" "fmt" "hash/crc32" "strings" "time" ) func EnableXlog(ctx context.Context, sn string) (string, error) { dataArea := map[string]string{ "xlogaddr": "18.188.130.67:9081", } dataStr, err := json.Marshal(dataArea) if err != nil { return "", err } res, err := sendMessage(ctx, "fwh/s2c/debug/"+sn, FwhMqttMsg{ CmdType: 2000, // xlog请求 Type: 0, // IBG Snno: 123, TimeStamp: time.Now().Unix(), EquipNo: sn, DataArea: dataArea, Len: len(dataStr), Crc: strings.ToUpper(fmt.Sprintf("%08X", crc32.ChecksumIEEE(dataStr))), }, "fwh/c2s/debug/"+sn) if err != nil { return "", err } b, err := json.Marshal(res.DataArea) if err != nil { return "", err } return string(b), nil }