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

package fwh_pro

import (
	"encoding/json"
	"errors"
	"fmt"
	"fwh-toolbox-server/config"
	"fwh-toolbox-server/dto"
	"net/url"
)

// 查询站点告警信息
func querySiteAlarmList(sn string) ([]byte, 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 := FwhHttpGet(reqUrl, params)
	if err != nil {
		return nil, err
	}
	return response.Body, nil
}

// 从fwh_pro获取站点告警列表
func QuerySiteAlarmList(site string) (dto.SiteAlarmListResponse, error) {
	resByte, err := querySiteAlarmList(site)
	if err != nil {
		return dto.SiteAlarmListResponse{}, err
	}
	var siteAlarmListRes dto.SiteAlarmListResponse
	// 反序列化（unmarshal）
	jsonErr := json.Unmarshal(resByte, &siteAlarmListRes)
	if jsonErr != nil {
		return dto.SiteAlarmListResponse{}, jsonErr
	}

	if siteAlarmListRes.Code == 401 {
		// TODO 尝试重新登录
		return dto.SiteAlarmListResponse{}, errors.New("certification expired")
	}

	return siteAlarmListRes, nil
}