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

package fwh_pro

import (
	"fmt"
	"fwh-toolbox-server/config"
	"fwh-toolbox-server/domain"
	"fwh-toolbox-server/dto"
	"net/url"
)

// 查询站点告警信息
func querySiteAlarmList(sn string) (*domain.FwhPageResponse[[]dto.SiteAlarmList], error) {
	// 构造 query 参数
	params := url.Values{}
	params.Add("gatewayId", sn)
	params.Add("land", "ZH_CN")

	reqUrl := fmt.Sprintf("https://%s/hes-gateway/manage/getEquipmentAlarm", config.FWH_ENERGY)
	response, err := FwhHttpGetUnmarshalPage[[]dto.SiteAlarmList](reqUrl, params)
	if err != nil {
		return nil, err
	}
	return response, nil
}

// 从fwh_pro获取站点告警列表
func QuerySiteAlarmList(site string) (*domain.FwhPageResponse[[]dto.SiteAlarmList], error) {
	siteAlarmListRes, err := querySiteAlarmList(site)
	if err != nil {
		return nil, err
	}

	if siteAlarmListRes.Code != 200 {
		return nil, fmt.Errorf("[queryMqttLogListOnePage] 查询失败 code: %d, message: %s", siteAlarmListRes.Code, siteAlarmListRes.Message)
	}

	return siteAlarmListRes, nil
}