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

package fwh_pro

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

// 查询站点功率流信息
func querySitePowerFlow(sn string, day time.Time) (*domain.FwhResponseA[dto.SitePowerFlow], error) {
	// 构造 query 参数
	params := url.Values{}
	params.Add("gatewayId", sn)
	params.Add("dayTime", day.Format(time.DateOnly)) // 会自动 URL 编码

	reqUrl := fmt.Sprintf("https://%s/api-energy/power/getFhpPowerByDayOld", config.FWH_ENERGY)
	response, err := FwhHttpGetUnmarshalA[dto.SitePowerFlow](reqUrl, params)
	if err != nil {
		return nil, err
	}
	return response, nil
}

// 从fwh_pro获取站点功率流
func QuerySitePowerFlow(site string, day time.Time) (*domain.FwhResponseA[dto.SitePowerFlow], error) {
	sitePowerFlowRes, err := querySitePowerFlow(site, day)
	if err != nil {
		return nil, err
	}

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

	return sitePowerFlowRes, nil
}