FranklinWH-Toolbox/service/repositories/mqtt/fwh_mqtt/fwh_mqtt_debug.go

// 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
	}

	// Xlog 只在正式服使用
	client, err := getFwhMqttClient(EnvProd)
	if err != nil {
		return "", err
	}

	res, err := client.sendMessageWait(ctx, "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))),
	}, "debug/"+sn, 2001)
	if err != nil {
		return "", err
	}

	b, err := json.Marshal(res.DataArea)
	if err != nil {
		return "", err
	}

	return string(b), nil
}