FranklinWH-Toolbox/service/services/sitesMonitorServices.go

package services

import (
	"fwh-toolbox-server/domain"
	"fwh-toolbox-server/dto"
	"fwh-toolbox-server/repositories"
	"time"
)

// 从数据库获取站点监控配置列表
func GetSiteMonitorConfig() ([]domain.SitesMonitorConfig, error) {
	return repositories.GetSiteMonitorConfig()
}

// 从数据库获取监控名列表
func GetSiteMonitorNameList() ([]string, error) {
	return repositories.GetSiteMonitorNameList()
}

// 从数据库获取一条站点监控配置
func GetOneSiteMonitorConfig(name string) ([]domain.SitesMonitorConfig, error) {
	return repositories.GetOneSiteMonitorConfig(name)
}

// 插入一条站点监控配置到数据库
func InsertSiteMonitorConfig(config domain.SitesMonitorConfig) error {
	return repositories.InsertSiteMonitorConfig(config)
}

// 更新一条站点监控配置到数据库
func UpdateSiteMonitorConfig(name string, config domain.SitesMonitorConfig) error {
	return repositories.UpdateSiteMonitorConfig(name, config)
}

// 删除一条站点监控配置
func DeleteSiteMonitorConfig(name string) error {
	return repositories.DeleteSiteMonitorConfig(name)
}

// 更新一条站点监控页面配置到数据库
func UpdateSiteMonitorPageConfig(name string, config domain.MonitorPageConfig) error {
	return repositories.UpdateSiteMonitorPageConfig(name, config)
}

// 从fwh_pro获取站点基本信息表
func QuerySiteBaseInfoList(para dto.SiteBaseInfoPara) (*domain.FwhResponse[[]dto.SiteBaseInfo], error) {
	return repositories.QuerySiteBaseInfoList(para)
}

// 从fwh_pro获取站点基本信息表
func QuerySiteInfoList(para dto.SiteInfoPara) (*domain.FwhPageResponse[[]dto.MonitorSiteInfo], error) {
	response, err := repositories.QuerySiteInfoList(para)
	if err != nil {
		return nil, err
	}

	resultInfo := []dto.MonitorSiteInfo{}
	for _, info := range *response.Result {
		resultInfo = append(resultInfo, *dto.FwhSiteInfoToMonitorSiteInfo(&info))
	}
	return &domain.FwhPageResponse[[]dto.MonitorSiteInfo]{
		Code:    response.Code,
		Message: response.Message,
		Result:  &resultInfo,
		Success: response.Success,
		Total:   response.Total,
	}, nil
}

// 从fwh_pro获取站点工作模式信息
func QuerySiteModeInfo(site string) (*domain.FwhResponse[dto.SiteModeInfo], error) {
	return repositories.QuerySiteModeInfo(site)
}

// 从fwh_pro获取站点功率流
func QuerySitePowerFlow(site string, day time.Time) (*domain.FwhResponseA[dto.SitePowerFlow], error) {
	return repositories.QuerySitePowerFlow(site, day)
}

// 从fwh_pro获取站点告警列表
func QuerySiteAlarmList(site string) (*domain.FwhPageResponse[[]dto.SiteAlarmList], error) {
	return repositories.QuerySiteAlarmList(site)
}