package electric import ( "IotAdmin/core/logger" iotStruct "IotAdmin/iot/struct" "encoding/json" ) type MeterElectric struct { MeterElectricBase MeterElectricRef `json:"-"` } type MeterElectricBase struct { Id string `json:"-"` //电表编码 Time int `json:"-"` //计算日期 PowerRate CalcPowerRate //负荷率 TotalEnergy CalcDataEnergy //总电能 DayTotalEnergy CalcDataEnergy //日总电能 isClean bool } type MeterElectricRef struct { PvRef float32 `json:"pvRef"` LvRef float32 `json:"lvRef"` } // CalcPowerRate 负荷率 type CalcPowerRate struct { SumPower float32 //有功功率总和 MaxPower float32 //最大有功功率 Count int //有功功率个数 } // CalcDataEnergy 电能 type CalcDataEnergy struct { Tp float32 Tq float32 Fp float32 Fq float32 } // CalcAndSetPowerRate 计算负荷率 func (m *MeterElectricBase) CalcAndSetPowerRate(colData *iotStruct.CollectData) float32 { m.PowerRate.Count++ m.PowerRate.SumPower += colData.P if m.PowerRate.MaxPower < colData.P { m.PowerRate.MaxPower = colData.P } return m.CalcRate() } // CalcRate 计算负荷率 func (m *MeterElectricBase) CalcRate() float32 { pv := float32(0) if m.PowerRate.MaxPower > float32(0.0001) && m.PowerRate.Count > 0 { pv = m.PowerRate.SumPower / (float32(m.PowerRate.Count) * m.PowerRate.MaxPower) } return pv } // ClearDayEnergy 日总电能清零 func (m *MeterElectricBase) ClearDayEnergy() { m.DayTotalEnergy.Tp = 0 m.DayTotalEnergy.Tq = 0 m.DayTotalEnergy.Fp = 0 m.DayTotalEnergy.Fq = 0 m.PowerRate.Count = 0 m.PowerRate.MaxPower = 0 m.PowerRate.SumPower = 0 logger.Debugf("计算电表数据清零") m.isClean = true } // CalcAndSetDayEnergy 计算并设置日电能 func (m *MeterElectricBase) CalcAndSetDayEnergy(colData *iotStruct.CollectData) { if m.isClean { m.isClean = false logger.Debugf("当日电表日电能第一次采集 电表地址: %d", colData.SlaveConfig.Addr) return } m.DayTotalEnergy.Tp += colData.Tps - m.TotalEnergy.Tp m.DayTotalEnergy.Tq += colData.Tqs - m.TotalEnergy.Tq m.DayTotalEnergy.Fp += colData.Fps - m.TotalEnergy.Fp m.DayTotalEnergy.Fq += colData.Fqs - m.TotalEnergy.Fq } // SetTotalEnergy 设置总电能 func (m *MeterElectricBase) SetTotalEnergy(colData *iotStruct.CollectData) { m.TotalEnergy.Tp = colData.Tps m.TotalEnergy.Tq = colData.Tqs m.TotalEnergy.Fp = colData.Fps m.TotalEnergy.Fq = colData.Fqs } // CalcDiff 计算偏差 func (m *MeterElectricBase) CalcDiff(colData *iotStruct.CollectData) { ref := &MeterElectricRef{} err := json.Unmarshal([]byte(colData.SlaveConfig.OtherConfig), ref) if err != nil { logger.Errorf("计算电表偏差失败, %s", err.Error()) return } colData.Fw = colData.Freq - float32(50.0) colData.Uaw = (colData.Ua - ref.LvRef) * float32(100.0) / ref.LvRef colData.Ubw = (colData.Ub - ref.LvRef) * float32(100.0) / ref.LvRef colData.Ucw = (colData.Uc - ref.LvRef) * float32(100.0) / ref.LvRef colData.Uabw = (colData.Uab - ref.PvRef) * float32(100.0) / ref.PvRef colData.Ubcw = (colData.Ubc - ref.PvRef) * float32(100.0) / ref.PvRef colData.Ucaw = (colData.Uca - ref.PvRef) * float32(100.0) / ref.PvRef } // CalcMeterData 计算电表部分数据 func (m *MeterElectricBase) CalcMeterData(d *iotStruct.CollectData) { m.CalcDiff(d) m.CalcAndSetPowerRate(d) m.CalcAndSetDayEnergy(d) m.SetTotalEnergy(d) d.Tpe = m.DayTotalEnergy.Tp d.Tqe = m.DayTotalEnergy.Tq d.Fpe = m.DayTotalEnergy.Fp d.Fqe = m.DayTotalEnergy.Fq d.Pv = m.CalcRate() } func (m *MeterElectricBase) GetMeterNo() string { return m.Id } func (m *MeterElectricBase) GetUpdateTime() int { return m.Time }