FranklinWH-Toolbox/service/ext/api/fwh_pro/fwh_realtimeAalrm.go

package fwh_pro

import (
	"io"
	"net/http"
	"net/url"
	"time"

	"go.uber.org/zap"
)

// 查询站点告警信息
func QuerySiteAlarmList(sn string) ([]byte, error) {
	baseURL := "https://energy.franklinwh.com/hes-gateway/manage/getEquipmentAlarm"

	token := getLoginToken()

	// 构造 query 参数
	params := url.Values{}
	params.Add("gatewayId", sn)
	params.Add("land", "ZH_CN")

	// 拼接到 URL
	finalURL := baseURL + "?" + params.Encode()

	// 创建请求
	req, err := http.NewRequest(
		http.MethodGet,
		finalURL,
		nil)
	if err != nil {
		zap.L().Error("NewRequest failed.", zap.String("err", err.Error()))
		return nil, err
	}

	// 设置 Content-Type 和 Authorization
	req.Header.Set("Content-Type", "application/json")
	req.Header.Set("Logintoken", token)

	// 发送请求
	client := &http.Client{Timeout: 5 * time.Second}
	resp, err := client.Do(req)
	if err != nil {
		zap.L().Error("Do Send failed.", zap.String("err", err.Error()))
		return nil, err
	}
	defer resp.Body.Close()

	body, _ := io.ReadAll(resp.Body)
	// logger.Std.Printf("Status: %s\nBody: %s\n", resp.Status, body)
	return body, nil
}