2022-10-15 18:00:15 +11:00

462 lines
20 KiB
Go

package queryDeviceList
import (
"GoSungrow/iSolarCloud/api"
"GoSungrow/iSolarCloud/api/apiReflect"
"GoSungrow/iSolarCloud/api/valueTypes"
"github.com/MickMake/GoUnify/Only"
"fmt"
)
const Url = "/v1/devService/queryDeviceList"
const Disabled = false
type RequestData struct {
PsId valueTypes.Integer `json:"ps_id" required:"true"`
}
func (rd RequestData) IsValid() error {
return apiReflect.VerifyOptionsRequired(rd)
}
func (rd RequestData) Help() string {
ret := fmt.Sprintf("")
return ret
}
type ResultData struct {
DevCountByStatusMap struct {
FaultCount valueTypes.Count `json:"fault_count" PointId:"fault_count"`
OfflineCount valueTypes.Count `json:"offline_count" PointId:"offline_count"`
RunCount valueTypes.Count `json:"run_count" PointId:"run_count"`
WarningCount valueTypes.Count `json:"warning_count" PointId:"warning_count"`
} `json:"dev_count_by_status_map"`
DevCountByTypeMap map[string]valueTypes.Integer `json:"dev_count_by_type_map"`
// DevCountByTypeMap struct {
// One4 valueTypes.Integer `json:"14"`
// Two2 valueTypes.Integer `json:"22"`
// } `json:"dev_count_by_type_map"`
DevTypeDefinition map[string]valueTypes.String `json:"dev_type_definition"`
// DevTypeDefinition struct {
// One string `json:"1"`
// One0 string `json:"10"`
// One1 string `json:"11"`
// One2 string `json:"12"`
// One3 string `json:"13"`
// One4 string `json:"14"`
// One5 string `json:"15"`
// One6 string `json:"16"`
// One7 string `json:"17"`
// One8 string `json:"18"`
// One9 string `json:"19"`
// Two0 string `json:"20"`
// Two1 string `json:"21"`
// Two2 string `json:"22"`
// Two3 string `json:"23"`
// Two4 string `json:"24"`
// Two5 string `json:"25"`
// Two6 string `json:"26"`
// Two8 string `json:"28"`
// Two9 string `json:"29"`
// Three string `json:"3"`
// Three0 string `json:"30"`
// Three1 string `json:"31"`
// Three2 string `json:"32"`
// Three3 string `json:"33"`
// Three4 string `json:"34"`
// Three5 string `json:"35"`
// Three6 string `json:"36"`
// Three7 string `json:"37"`
// Three8 string `json:"38"`
// Three9 string `json:"39"`
// Four string `json:"4"`
// Four0 string `json:"40"`
// Four1 string `json:"41"`
// Four2 string `json:"42"`
// Four3 string `json:"43"`
// Four4 string `json:"44"`
// Four5 string `json:"45"`
// Four6 string `json:"46"`
// Four7 string `json:"47"`
// Four8 string `json:"48"`
// Five string `json:"5"`
// Five0 string `json:"50"`
// Six string `json:"6"`
// Seven string `json:"7"`
// Eight string `json:"8"`
// Nine string `json:"9"`
// Nine9 string `json:"99"`
// } `json:"dev_type_definition"`
PageList []struct {
AlarmCount valueTypes.Count `json:"alarm_count" PointId:"alarm_count"`
ChannelId valueTypes.Integer `json:"chnnl_id" PointId:"channel_id"`
CommandStatus valueTypes.Integer `json:"command_status" PointId:"command_status"`
ComponentAmount valueTypes.Integer `json:"component_amount" PointId:"component_amount"`
DataFlag valueTypes.Integer `json:"data_flag" PointId:"data_flag"`
DataFlagDetail valueTypes.Integer `json:"data_flag_detail" PointId:"data_flag_detail"`
DeviceArea valueTypes.Integer `json:"device_area" PointId:"device_area"`
DeviceAreaName valueTypes.String `json:"device_area_name" PointId:"device_area_name"`
DeviceCode valueTypes.Integer `json:"device_code" PointId:"device_code"`
DeviceID valueTypes.Integer `json:"device_id" PointId:"device_id"`
DeviceModelCode valueTypes.String `json:"device_model_code" PointId:"device_model_code"`
DeviceModelID valueTypes.Integer `json:"device_model_id" PointId:"device_model_id"`
DeviceName valueTypes.String `json:"device_name" PointId:"device_name"`
DeviceStatus valueTypes.Bool `json:"device_status" PointId:"device_status"`
DeviceType valueTypes.Integer `json:"device_type" PointId:"device_type"`
FaultCount valueTypes.Count `json:"fault_count" PointId:"fault_count"`
FaultStatus string `json:"fault_status" PointId:"fault_status"`
FunctionEnum valueTypes.String `json:"function_enum" PointId:"function_enum"`
InstallerAlarmCount valueTypes.Count `json:"installer_alarm_count" PointId:"installer_alarm_count"`
InstallerDevFaultStatus valueTypes.Integer `json:"installer_dev_fault_status" PointId:"installer_dev_fault_status"`
InstallerFaultCount valueTypes.Count `json:"installer_fault_count" PointId:"installer_fault_count"`
InverterModelType valueTypes.Integer `json:"inverter_model_type" PointId:"inverter_model_type"`
IsDeveloper valueTypes.Bool `json:"is_developer" PointId:"is_developer"`
IsG2point5Module valueTypes.Bool `json:"is_g2point5_module" PointId:"is_g2point5_module"`
IsInit valueTypes.Bool `json:"is_init" PointId:"is_init"`
IsSecond valueTypes.Bool `json:"is_second" PointId:"is_second"`
IsSupportParamset valueTypes.Bool `json:"is_support_paramset" PointId:"is_support_paramset"`
NodeTimestamps interface{} `json:"node_timestamps" PointId:"node_timestamps"`
OwnerAlarmCount valueTypes.Count `json:"owner_alarm_count" PointId:"owner_alarm_count"`
OwnerDevFaultStatus valueTypes.Integer `json:"owner_dev_fault_status" PointId:"owner_dev_fault_status"`
OwnerFaultCount valueTypes.Count `json:"owner_fault_count" PointId:"owner_fault_count"`
PointData PointData `json:"point_data"`
Points interface{} `json:"points" PointId:"points"`
PsTimezoneInfo struct {
IsDst valueTypes.Bool `json:"is_dst"`
TimeZone valueTypes.String `json:"time_zone"`
} `json:"psTimezoneInfo"`
PsID valueTypes.Integer `json:"ps_id" PointId:"ps_id"`
PsKey valueTypes.PsKey `json:"ps_key" PointId:"ps_key"`
RelState valueTypes.Integer `json:"rel_state" PointId:"rel_state"`
Sn valueTypes.String `json:"sn" PointId:"sn"`
StringAmount valueTypes.Integer `json:"string_amount" PointId:"string_amount"`
TypeName valueTypes.String `json:"type_name" PointId:"type_name"`
UnitName valueTypes.String `json:"unit_name" PointId:"unit_name"`
UUID valueTypes.Integer `json:"uuid" PointId:"uuid"`
UUIDIndexCode valueTypes.String `json:"uuid_index_code" PointId:"uuid_index_code"`
} `json:"pageList"`
RowCount valueTypes.Integer `json:"rowCount" PointIgnore:"true"`
}
type PointData []PointStruct
type PointStruct struct {
CodeID valueTypes.Integer `json:"code_id"`
CodeIDOrderID valueTypes.String `json:"code_id_order_id"`
CodeName valueTypes.String `json:"code_name"`
DevPointLastUpdateTime valueTypes.DateTime `json:"dev_point_last_update_time"`
IsPlatformDefaultUnit valueTypes.Bool `json:"is_platform_default_unit"`
IsShow valueTypes.Bool `json:"is_show"`
OrderID valueTypes.Integer `json:"order_id"`
OrderNum valueTypes.Integer `json:"order_num"`
PointGroupID valueTypes.Integer `json:"point_group_id"`
PointGroupIDOrderID valueTypes.Integer `json:"point_group_id_order_id"`
PointGroupName valueTypes.String `json:"point_group_name"`
PointID valueTypes.Integer `json:"point_id"`
PointName valueTypes.String `json:"point_name"`
PointSign valueTypes.String `json:"point_sign"`
Relate valueTypes.Integer `json:"relate"`
TimeStamp valueTypes.DateTime `json:"time_stamp"`
Unit valueTypes.String `json:"unit"`
ValIsFixd valueTypes.Bool `json:"val_is_fixd"`
ValidSize valueTypes.Integer `json:"valid_size"`
Value valueTypes.Float `json:"value"`
ValueDescription valueTypes.String `json:"value_description"`
}
func (e *ResultData) IsValid() error {
var err error
// switch {
// case e.Dummy == "":
// break
// default:
// err = errors.New(fmt.Sprintf("unknown error '%s'", e.Dummy))
// }
return err
}
func (e *ResultData) GetDataByName(name string) PointData {
var ret PointData
for range Only.Once {
i := len(e.PageList)
if i == 0 {
break
}
for _, p := range e.PageList {
if p.DeviceName.Value() != name {
continue
}
ret = p.PointData
break
}
}
return ret
}
func (e *EndPoint) GetData() api.DataMap {
entries := api.NewDataMap()
for range Only.Once {
// // Used for virtual entries.
// // 0 - sungrow_battery_charging_power
// var PVPowerToBattery VirtualPointStruct
//
// // sensor.sungrow_battery_discharging_power
// var BatteryPowerToLoad VirtualPointStruct
//
// // 0 - sensor.sungrow_total_export_active_power
// var PVPowerToGrid VirtualPointStruct
//
// // sensor.sungrow_purchased_power
// var GridPowerToLoad VirtualPointStruct
//
// // 0 - sensor.sungrow_daily_battery_charging_energy_from_pv
// var YieldBatteryCharge VirtualPointStruct
// // var DailyBatteryChargingEnergy VirtualPointStruct
//
// // sensor.sungrow_daily_battery_discharging_energy
// var DailyBatteryDischargingEnergy VirtualPointStruct
//
// // 0 - sensor.sungrow_daily_feed_in_energy_pv
// var YieldFeedIn VirtualPointStruct
//
// // sensor.sungrow_daily_purchased_energy
// var DailyPurchasedEnergy VirtualPointStruct
//
// var PVPower VirtualPointStruct
//
// var LoadPower VirtualPointStruct
//
// var YieldSelfConsumption VirtualPointStruct
// // var DailyFeedInEnergy VirtualPointStruct
// var TotalPvYield VirtualPointStruct
//
// var DailyTotalLoad VirtualPointStruct
//
// var TotalEnergyConsumption VirtualPointStruct
pkg := apiReflect.GetName("", *e)
name := api.JoinWithDots(0, "", pkg, e.Request.PsId)
entries.StructToPoints(e.Response.ResultData, name, e.Request.PsId.String(), valueTypes.NewDateTime(""))
for _, d := range e.Response.ResultData.PageList {
name2 := api.JoinWithDots(0, "", pkg, d.PsKey)
entries.StructToPoints(d, name2, d.PsKey.Value(), valueTypes.NewDateTime(""))
for _, p := range d.PointData {
pid := valueTypes.SetPointIdValue(p.PointID.Value())
uv := valueTypes.SetUnitValueFloat(p.Value.Value(), p.Unit.Value(), "")
// name2 := fmt.Sprintf("%s.PointData.%s", name, pid)
// name3 := fmt.Sprintf("%s.PointData", name2)
entries.AddUnitValue(name2, d.PsKey.Value(), pid, p.PointName.Value(), p.PointGroupName.Value(), p.TimeStamp, uv)
// Handle virtual results.
// switch pid {
// case "13126":
// // BatteryChargingPower
// entries["PVPowerToBattery"] = entries[pid]
// case "13150":
// // BatteryDischargingPower
// entries["BatteryPowerToLoad"] = entries[pid]
// case "13121":
// // TotalExportActivePower
// entries["PVPowerToGrid"] = entries[pid]
// case "13149":
// // PurchasedPower
// entries["GridPowerToLoad"] = entries[pid]
// case "13003":
// // TotalDcPower
// entries["PVPower"] = addVirtualAlias(entries[pid], "pv_power", "PV Power")
// case "13119":
// // TotalLoadActivePower
// entries["LoadPower"] = addVirtualAlias(entries[pid], "load_power", "Load Power")
//
// // addVirtualAlias(entries[pid], "FOO", "FOO")
//
// case "13112":
// // Daily PV Yield
// entries["DailyPvEnergy"] = addVirtualAlias(entries["DailyPvEnergy"], "daily_pv_energy", "Daily PV Energy")
// case "13174":
// // DailyBatteryChargingEnergyFromPv
// entries["YieldBatteryCharge"] = addVirtualAlias(entries[pid], "pv_battery_charge", "PV Battery Charge")
// case "13029":
// // DailyBatteryDischargingEnergy
// entries["DailyBatteryDischargingEnergy"] = entries[pid]
// case "13122":
// // entries["DailyFeedInEnergy"] = addVirtualAlias(entries[pid], "pv_feed_in", "PV Feed In")
// // @TODO - This may differ from DailyFeedInEnergyPv
// case "13173":
// // DailyFeedInEnergyPv
// entries["YieldFeedIn"] = addVirtualAlias(entries[pid], "pv_feed_in", "PV Feed In")
// case "13147":
// // DailyPurchasedEnergy
// entries["DailyPurchasedEnergy"] = addVirtualAlias(entries[pid], "daily_purchased_energy", "Daily Purchased Energy")
//
// case "13116":
// // DailyLoadEnergyConsumptionFromPv
// entries["YieldSelfConsumption"] = addVirtualAlias(entries[pid], "pv_self_consumption", "PV Self Consumption")
// case "13134":
// // TotalPvYield
// entries["TotalPvYield"] = addVirtualAlias(entries[pid], "pv_total_yield", "PV Total Yield")
//
// case "13199":
// // Daily Load Energy Consumption
// entries["DailyTotalLoad"] = addVirtualAlias(entries[pid], "daily_total_energy", "Daily Total Energy")
//
// case "13130":
// // Total Load Energy Consumption
// entries["TotalEnergyConsumption"] = addVirtualAlias(entries[pid], "total_energy_consumption", "Total Energy Consumption"
// }
}
}
if len(entries.DataPoints) == 0 {
break
}
// TotalDcPower
entries.FromRefAddAlias("p13003", api.VirtualPsId, "power_pv", "")
// BatteryChargingPower
entries.FromRefAddAlias("p13126", api.VirtualPsId, "battery_charge_power", "")
// BatteryDischargingPower
entries.FromRefAddAlias("p13150", api.VirtualPsId, "battery_discharge_power", "")
// TotalExportActivePower
entries.FromRefAddAlias("p13121", api.VirtualPsId, "power_pv_to_grid", "")
// TotalLoadActivePower
entries.FromRefAddAlias("p13119", api.VirtualPsId, "power_load", "")
// PurchasedPower
entries.FromRefAddAlias("p13149", api.VirtualPsId, "power_grid_to_load", "")
// Daily PV Yield
entries.FromRefAddAlias("p13112", api.VirtualPsId, "daily_pv_energy", "")
// DailyPvEnergy := entries.getFloatValue("DailyTotalLoad") - entries.getFloatValue("DailyPurchasedEnergy")
// DailyBatteryChargingEnergyFromPv
entries.FromRefAddAlias("p13174", api.VirtualPsId, "pv_battery_charge_energy", "")
// DailyBatteryDischargingEnergy
entries.FromRefAddAlias("p13029", api.VirtualPsId, "battery_discharge", "")
// @TODO - This may differ from DailyFeedInEnergyPv
// entries["DailyFeedInEnergy"] = entries.AddVirtualAliasFromRef("13122", "pv_feed_in", "PV Feed In")
// DailyFeedInEnergyPv
entries.FromRefAddAlias("p13173", api.VirtualPsId, "pv_feed_in", "")
// DailyPurchasedEnergy
entries.FromRefAddAlias("p13147", api.VirtualPsId, "daily_purchased_energy", "")
// DailyLoadEnergyConsumptionFromPv
entries.FromRefAddAlias("p13116", api.VirtualPsId, "pv_self_consumption", "")
// TotalPvYield
entries.FromRefAddAlias("p13134", api.VirtualPsId, "pv_total_yield", "")
// Daily Load Energy Consumption
entries.FromRefAddAlias("p13199", api.VirtualPsId, "daily_total_energy", "")
// Total Load Energy Consumption
entries.FromRefAddAlias("p13130", api.VirtualPsId, "total_energy_consumption", "")
// entries.AddPointFromRef(api.Point{ Id:"queryDeviceList.p13130" }, api.Point{ PsKey:api.VirtualPsId, Id:"total_energy_consumption" })
// entries.CopyEntry("p13130").CreateAlias()
// entries.GetEntry(api.Point{PsKey:psId, Id:"total_income", Unit:p.TotalIncome.Unit, Type:api.PointTypeTotal}, now, p.TotalIncome.Value)
/*
PVPower - TotalDcPower
PVPowerToBattery - BatteryChargingPower
PVPowerToLoad - TotalDcPower - BatteryChargingPower - TotalExportActivePower
PVPowerToGrid - TotalExportActivePower
LoadPower - TotalLoadActivePower
BatteryPowerToLoad - BatteryDischargingPower
BatteryPowerToGrid - ?
GridPower - lowerUpper(PVPowerToGrid, GridPowerToLoad)
GridPowerToLoad - PurchasedPower
GridPowerToBattery - ?
YieldSelfConsumption - DailyLoadEnergyConsumptionFromPv
YieldBatteryCharge - DailyBatteryChargingEnergyFromPv
YieldFeedIn - DailyFeedInEnergyPv
*/
// Add virtual entries.
// ts := ret.Entries[0].Date
// var value valueTypes.Float
entries.FromRefAddFloat("pv_self_consumption",
api.VirtualPsId,"pv_daily_yield", "",
entries.GetFloatValue("pv_self_consumption", api.LastEntry) + entries.GetFloatValue("pv_battery_charge_energy", api.LastEntry) + entries.GetFloatValue("pv_feed_in", api.LastEntry))
entries.FromRefAddFloat("daily_pv_energy",
api.VirtualPsId,"pv_self_consumption_percent", "",
entries.GetPercent("pv_self_consumption", "daily_pv_energy", api.LastEntry))
entries.FromRefAddFloat("daily_pv_energy",
api.VirtualPsId,"pv_battery_charge_percent", "",
entries.GetPercent("pv_battery_charge_energy", "daily_pv_energy", api.LastEntry))
entries.FromRefAddFloat("daily_pv_energy",
api.VirtualPsId,"pv_feed_in_percent", "",
entries.GetPercent("pv_feed_in", "daily_pv_energy", api.LastEntry))
// @TODO - Add this calculation.
DailyPvEnergy := entries.GetFloatValue("daily_total_energy", api.LastEntry) - entries.GetFloatValue("daily_purchased_energy", api.LastEntry)
// fmt.Sprintf("%f", DailyPvEnergy)
entries.FromRefAddFloat("daily_total_energy",
api.VirtualPsId,"daily_pv_energy_percent", "",
api.GetPercent(DailyPvEnergy, entries.GetValue("daily_total_energy", api.LastEntry)))
entries.FromRefAddFloat("daily_total_energy",
api.VirtualPsId,"daily_purchased_energy_percent", "",
entries.GetPercent("daily_purchased_energy", "daily_total_energy", api.LastEntry))
entries.FromRefAddFloat("power_pv",
api.VirtualPsId,"power_pv_to_load", "",
entries.GetFloatValue("power_pv", api.LastEntry) - entries.GetFloatValue("battery_charge_power", api.LastEntry) - entries.GetFloatValue("power_pv_to_grid", api.LastEntry))
// Battery
entries.FromRefAddFloat("battery_charge_power",
api.VirtualPsId,"power_battery", "",
entries.LowerUpper("battery_discharge_power", "battery_charge_power", api.LastEntry))
entries.FromRefAddFloat("battery_charge_power",
api.VirtualPsId,"power_pv_to_battery", "",
entries.GetFloatValue("battery_charge_power", api.LastEntry))
entries.FromRefAddFloat("battery_discharge_power",
api.VirtualPsId,"power_battery_to_load", "",
entries.GetFloatValue("battery_charge_power", api.LastEntry))
entries.FromRefAddFloat("battery_charge_power",
api.VirtualPsId,"power_battery_to_grid", "",
0.0)
// Grid
entries.FromRefAddFloat("power_grid_to_load",
api.VirtualPsId,"power_grid", "",
entries.LowerUpper("power_pv_to_grid", "power_grid_to_load", api.LastEntry))
entries.FromRefAddFloat("power_grid_to_load",
api.VirtualPsId,"power_grid_to_battery", "",
0.0)
entries.FromRefAddState("power_pv", api.VirtualPsId,"power_pv_active", "")
entries.FromRefAddState("power_battery", api.VirtualPsId,"power_battery_active", "")
entries.FromRefAddState("power_grid", api.VirtualPsId,"power_grid_active", "")
entries.FromRefAddState("power_load", api.VirtualPsId,"power_load_active", "")
entries.FromRefAddState("power_pv_to_battery", api.VirtualPsId,"power_pv_to_battery_active", "")
entries.FromRefAddState("power_pv_to_load", api.VirtualPsId,"power_pv_to_load_active", "")
entries.FromRefAddState("power_pv_to_grid", api.VirtualPsId,"power_pv_to_grid_active", "")
entries.FromRefAddState("power_battery_to_load", api.VirtualPsId,"power_battery_to_load_active", "")
entries.FromRefAddState("power_battery_to_grid", api.VirtualPsId,"power_battery_to_grid_active", "")
entries.FromRefAddState("power_grid_to_load", api.VirtualPsId,"power_grid_to_load_active", "")
entries.FromRefAddState("power_grid_to_battery", api.VirtualPsId,"power_grid_to_battery_active", "")
entries.FromRefAddFloat("pv_battery_charge_energy",
api.VirtualPsId, "battery_energy", "",
entries.LowerUpper("pv_battery_charge_energy", "battery_discharge", api.LastEntry))
entries.FromRefAddFloat("pv_feed_in",
api.VirtualPsId,"grid_energy", "",
entries.LowerUpper("pv_feed_in", "daily_purchased_energy", api.LastEntry))
}
return entries
}