IOT/SERVER/IotAdmin/iot/struct/electric/meter.go

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
}