josh/sungrow
1
0
Fork 0
Code Issues Releases Activity

expand register map

Browse source
This commit is contained in:
Josh Deprez 2021-01-26 10:24:25 +11:00
parent ff0dc5a5e1
commit 57c59041a6
1 changed files with 65 additions and 34 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

99
sungrow_map.go
View file

@ -20,36 +20,39 @@ func (r *register) read(data []byte) (float64, error) {
var sungrowInputRegs = map[uint16]*register{ var sungrowInputRegs = map[uint16]*register{
// 4990 - 4999: serial number in ASCII // 4990 - 4999: serial number in ASCII
5001: {"nominal_power", u16, 0.1, "kW"}, 5001: {"nominal_power", u16req, 0.1, "kW"},
5003: {"daily_power_yield", u16, 0.1, "kWh"}, 5003: {"daily_power_yield", u16req, 0.1, "kWh"},
5004: {"total_power_yield", u32, 1, "kWh"}, 5004: {"total_power_yield", u32req, 1, "kWh"},
5006: {"total_running_time", u32, 1, "h"}, 5006: {"total_running_time", u32req, 1, "h"},
5008: {"internal_temperature", u16, 0.1, "°C"}, 5008: {"internal_temperature", u16req, 0.1, "°C"},
5011: {"pv1_potential", u16, 0.1, "V"}, 5011: {"pv1_potential", u16req, 0.1, "V"},
5012: {"pv1_current", u16, 0.1, "A"}, 5012: {"pv1_current", u16req, 0.1, "A"},
5013: {"pv2_potential", u16, 0.1, "V"}, 5013: {"pv2_potential", u16req, 0.1, "V"},
5014: {"pv2_current", u16, 0.1, "A"}, 5014: {"pv2_current", u16req, 0.1, "A"},
//5015: {"pv3_potential", u16, 0.1, "V"}, 5015: {"pv3_potential", u16opt, 0.1, "V"},
//5016: {"pv3_current", u16, 0.1, "A"}, 5016: {"pv3_current", u16opt, 0.1, "A"},
5017: {"total_dc_power", u32, 1, "W"}, 5017: {"total_dc_power", u32req, 1, "W"},
5019: {"phase_a_potential", u16, 0.1, "V"}, 5019: {"phase_a_potential", u16req, 0.1, "V"},
//5020: {"phase_b_potential", u16, 0.1, "V"}, 5020: {"phase_b_potential", u16opt, 0.1, "V"},
//5021: {"phase_c_potential", u16, 0.1, "V"}, 5021: {"phase_c_potential", u16opt, 0.1, "V"},
5022: {"phase_a_current", u16, 0.1, "A"}, 5022: {"phase_a_current", u16req, 0.1, "A"},
//5023: {"phase_b_current", u16, 0.1, "A"}, 5023: {"phase_b_current", u16opt, 0.1, "A"},
//5024: {"phase_c_current", u16, 0.1, "A"}, 5024: {"phase_c_current", u16opt, 0.1, "A"},
5031: {"output_real_power", u32, 1, "VA"}, 5031: {"output_real_power", u32req, 1, "VA"},
5033: {"output_reactive_power", s32, 1, "VAr"}, 5033: {"output_reactive_power", s32opt, 1, "VAr"},
5035: {"power_factor", s16, 0.001, ""}, 5035: {"power_factor", s16opt, 0.001, ""},
5036: {"frequency", u16, 0.1, "Hz"}, 5036: {"frequency", u16req, 0.1, "Hz"},
5049: {"nominal_reactive_power", s16, 0.1, "kVA"}, 5049: {"nominal_reactive_power", s16opt, 0.1, "kVA"},
5083: {"meter_power", s32, 1, "W"}, 5083: {"meter_power", s32opt, 1, "W"},
5085: {"meter_a_phase_power", s32, 1, "W"}, 5085: {"meter_a_phase_power", s32opt, 1, "W"},
5097: {"daily_import_energy", u32, 0.1, "kWh"}, 5087: {"meter_b_phase_power", s32opt, 1, "W"},
5089: {"meter_c_phase_power", s32opt, 1, "W"},
5091: {"register_5091", s32opt, 1, "unknown"},
5097: {"daily_import_energy", u32req, 0.1, "kWh"},
5113: {"daily_running_time", u16, 1, "m"}, 5113: {"daily_running_time", u16req, 1, "m"},
5144: {"total_power_yield_2", u32, 0.1, "kWh"}, 5144: {"total_power_yield_2", u32req, 0.1, "kWh"},
5148: {"frequency_2", frequency2, 0.01, "Hz"}, 5148: {"frequency_2", frequency2, 0.01, "Hz"},
} }
@ -68,30 +71,58 @@ func frequency2(data []byte) (float64, error) {
return float64(n), nil return float64(n), nil
} }
func u16(data []byte) (float64, error) { func u16opt(data []byte) (float64, error) {
return float64(binary.BigEndian.Uint16(data)), nil
}
func u16req(data []byte) (float64, error) {
n := binary.BigEndian.Uint16(data) n := binary.BigEndian.Uint16(data)
if n == 0xFFFF { if n == 0xFFFF {
// probably a misread // probably a misread
return 0, fmt.Errorf("likely misread: u16 read %v", n) return 0, fmt.Errorf("likely misread: u16req read %v", n)
} }
return float64(n), nil return float64(n), nil
} }
func s16(data []byte) (float64, error) { func s16opt(data []byte) (float64, error) {
return float64(int16(binary.BigEndian.Uint16(data))), nil return float64(int16(binary.BigEndian.Uint16(data))), nil
} }
func u32(data []byte) (float64, error) { func s16req(data []byte) (float64, error) {
n := binary.BigEndian.Uint16(data)
if n == 0x7FFF {
// probably a misread
return 0, fmt.Errorf("likely misread: s16req read %v", n)
}
return float64(int16(n)), nil
}
func u32opt(data []byte) (float64, error) {
// Little-endian big-endian :#
return float64(uint32(binary.BigEndian.Uint16(data)) + uint32(binary.BigEndian.Uint16(data[2:]))<<16), nil
}
func u32req(data []byte) (float64, error) {
// Little-endian big-endian :# // Little-endian big-endian :#
n := uint32(binary.BigEndian.Uint16(data)) + uint32(binary.BigEndian.Uint16(data[2:]))<<16 n := uint32(binary.BigEndian.Uint16(data)) + uint32(binary.BigEndian.Uint16(data[2:]))<<16
if n == 0xFFFFFFFF { if n == 0xFFFFFFFF {
// probably a misread // probably a misread
return 0, fmt.Errorf("likely misread: u32 read %v", n) return 0, fmt.Errorf("likely misread: u32req read %v", n)
} }
return float64(n), nil return float64(n), nil
} }
func s32(data []byte) (float64, error) { func s32opt(data []byte) (float64, error) {
// Little-endian big-endian :# // Little-endian big-endian :#
return float64(int32(binary.BigEndian.Uint16(data)) + int32(binary.BigEndian.Uint16(data[2:]))<<16), nil return float64(int32(binary.BigEndian.Uint16(data)) + int32(binary.BigEndian.Uint16(data[2:]))<<16), nil
} }
func s32req(data []byte) (float64, error) {
// Little-endian big-endian :#
n := uint32(binary.BigEndian.Uint16(data)) + uint32(binary.BigEndian.Uint16(data[2:]))<<16
if n == 0x7FFFFFFF {
// probably a misread
return 0, fmt.Errorf("likely misread: s32req read %v", n)
}
return float64(int32(n)), nil
}