util.go

package iot

import (
	"crypto/hmac"
	"crypto/sha256"
	"encoding/hex"
	"encoding/json"
	"strings"
	"time"
)

// 时间戳：为设备连接平台时的UTC时间，格式为YYYYMMDDHH，如UTC 时间2018/7/24 17:56:20 则应表示为2018072417。
func timeStamp() string {
	strFormatTime := time.Now().Format("2006-01-02 15:04:05")
	strFormatTime = strings.ReplaceAll(strFormatTime, "-", "")
	strFormatTime = strings.ReplaceAll(strFormatTime, " ", "")
	strFormatTime = strFormatTime[0:10]
	return strFormatTime
}

// 设备采集数据UTC时间（格式：yyyyMMdd'T'HHmmss'Z'），如：20161219T114920Z。
//设备上报数据不带该参数或参数格式错误时，则数据上报时间以平台时间为准。
func GetEventTimeStamp() string {
	now := time.Now().UTC()
	return now.Format("20060102T150405Z")
}

func hmacSha256(data string, secret string) string {
	h := hmac.New(sha256.New, []byte(secret))
	h.Write([]byte(data))
	return hex.EncodeToString(h.Sum(nil))
}

func Interface2JsonString(v interface{}) string {
	if v == nil {
		return ""
	}
	byteData, err := json.Marshal(v)
	if err != nil {
		return ""
	}
	return string(byteData)
}

func getTopicRequestId(topic string) string {
	return strings.Split(topic, "=")[1]
}

func formatTopic(topic, deviceId string) string {
	return strings.ReplaceAll(topic, "{device_id}", deviceId)
}

// 根据当前运行的操作系统重新修改文件路径以适配操作系统
func smartFileName(filename string) string {
	// Windows操作系统适配
	if strings.Contains(OsName(), "windows") {
		pathParts := strings.Split(filename, "/")
		pathParts[0] = pathParts[0] + ":"
		return strings.Join(pathParts, "\\")
	}

	return filename
}

func CreateMqttClientId(deviceId string) string {
	segments := make([]string, 4)
	segments[0] = deviceId
	segments[1] = "0"
	segments[2] = "0"
	segments[3] = timeStamp()

	return strings.Join(segments, "_")
}