IOT/SERVER/IotAdmin/iot/protocol/report/el-hj212.go

package iotReportProtocol

import (
	"IotAdmin/core/tools/utils"
	iotInterface "IotAdmin/iot/interface"
	iotReportService "IotAdmin/iot/service/reportService"
	iotStruct "IotAdmin/iot/struct"
	"IotAdmin/iot/struct/electric"
	"fmt"
	"strconv"
	"time"
)

type elHj212 struct {
}

func NewElHj212ReportHandler() iotInterface.ReportHandler {
	return &elHj212{}
}

func (*elHj212) Adapter(data *iotStruct.CollectData) {
	cfg := data.SlaveConfig
	// 获取电表计算参数
	calc, today, err := getMeterElectricCalc(cfg)
	if err != nil {
		data.Logger.Errorf("[%s]获取计算参数失败: %s", cfg.No, err.Error())
		return
	}
	mData := calc.GetMeterData()
	elMeter := mData.(electric.MeterElectric)
	// 计算电表数据
	data.Logger.Debugf("[%d]计算前: [%v]", today, calc)
	elMeter.Time = today
	elMeter.CalcMeterData(data)
	data.Logger.Debugf("[%d]计算后: [%v]", today, calc)

	// 更新电表计算参数
	calc.SetMeterData(elMeter)
	updateMeterCalc(elMeter, &calc)
}

func (*elHj212) Report(data *iotStruct.CollectData, config *iotStruct.ReportConfig) (reportStr *string) {
	if str, ok := packHj212(data, config); ok {
		reportStr = &str
		if receive, err := iotReportService.UpToServer(config.Host, str); err != nil {
			data.Logger.Errorf("[%s:%s]上报数据失败: [ %s ] %s", config.Host, str, err.Error())
		} else {
			data.Logger.Debugf("上报数据 SEND -> %s", str)
			data.Logger.Infof("上报数据 RECE <- %s", receive)
		}
	} else {
		data.Logger.Errorf("[-- %s --]打包数据失败 %v", data.SlaveConfig.No, data)
	}
	return
}

func packHj212(d *iotStruct.CollectData, cfg *iotStruct.ReportConfig) (string, bool) {
	now := time.Now()
	nt := fmt.Sprintf("%04d%02d%02d%02d%02d00", now.Year(), now.Month(), now.Day(), now.Hour(), now.Minute())
	body := fmt.Sprintf("%s=%s", cfg.GetBmYzKey("p"), getBmYzFloatValue(d.P)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pa"), getBmYzFloatValue(d.Pa)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pb"), getBmYzFloatValue(d.Pb)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pc"), getBmYzFloatValue(d.Pc)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("q"), getBmYzFloatValue(d.Q)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("qa"), getBmYzFloatValue(d.Qa)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("qb"), getBmYzFloatValue(d.Qb)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("qc"), getBmYzFloatValue(d.Qc)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pf"), getBmYzFloatValue(d.Pf)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pfa"), getBmYzFloatValue(d.Pfa)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pfb"), getBmYzFloatValue(d.Pfb)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pfc"), getBmYzFloatValue(d.Pfc)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ia"), getBmYzFloatValue(d.Ia)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ib"), getBmYzFloatValue(d.Ib)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ic"), getBmYzFloatValue(d.Ic)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("iz"), getBmYzFloatValue(d.Iz)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ua"), getBmYzFloatValue(d.Ua)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ub"), getBmYzFloatValue(d.Ub)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("uc"), getBmYzFloatValue(d.Uc)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("uab"), getBmYzFloatValue(d.Uab)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ubc"), getBmYzFloatValue(d.Ubc)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("uca"), getBmYzFloatValue(d.Uca)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("dp"), getBmYzFloatValue(d.Dp)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("pv"), getBmYzFloatValue(d.Pv)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("f"), getBmYzFloatValue(d.Freq)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("fw"), getBmYzFloatValue(d.Fw)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("tps"), getBmYzFloatValue(d.Tps)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("tqs"), getBmYzFloatValue(d.Tqs)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("fps"), getBmYzFloatValue(d.Fps)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("fqs"), getBmYzFloatValue(d.Fqs)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("tpe"), getBmYzFloatValue(d.Tpe)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("tqe"), getBmYzFloatValue(d.Tqe)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("fpe"), getBmYzFloatValue(d.Fpe)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("fqe"), getBmYzFloatValue(d.Fqe)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("uaw"), getBmYzFloatValue(d.Uaw)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ubw"), getBmYzFloatValue(d.Ubw)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ucw"), getBmYzFloatValue(d.Ucw)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("uabw"), getBmYzFloatValue(d.Uabw)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ubcw"), getBmYzFloatValue(d.Ubcw)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("ucaw"), getBmYzFloatValue(d.Ucaw)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("inbalance"), getBmYzFloatValue(d.IUnbalance)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("unbalance"), getBmYzFloatValue(d.UUnbalance)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("t"), getBmYzFloatValue(d.TemperatureA)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("t2"), getBmYzFloatValue(d.TemperatureB)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("t3"), getBmYzFloatValue(d.TemperatureC)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("t4"), getBmYzFloatValue(d.TemperatureZ)) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("hua"), packYcHj212Hx(d.Hua, d.HarUa, d.BaseUa, "baseu")) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("hub"), packYcHj212Hx(d.Hub, d.HarUb, d.BaseUb, "baseu")) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("huc"), packYcHj212Hx(d.Huc, d.HarUc, d.BaseUc, "baseu")) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("hia"), packYcHj212Hx(d.Hia, d.HarIa, d.BaseIa, "basei")) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("hib"), packYcHj212Hx(d.Hib, d.HarIb, d.BaseIb, "basei")) +
		fmt.Sprintf("&%s=%s", cfg.GetBmYzKey("hic"), packYcHj212Hx(d.Hic, d.HarIc, d.BaseIc, "basei"))

	str := fmt.Sprintf("st=%s;cn=1;datatime=%s;cphh=&&tid=%s&%s&", cfg.ST, nt, cfg.MN, body)
	crc16 := utils.CalCRC16HJ212([]byte(str))
	str1 := fmt.Sprintf("##00%04d", len(str)) + str + fmt.Sprintf("%04X", crc16) + "\r\n"

	return str1, true
}

func packYcHj212Hx(val [15]float32, hall, base float32, baseStr string) string {
	ret := ""
	for i, v := range val {
		ret += fmt.Sprintf("h%d:%s,", i*2+1, getBmYzFloatValue(v))
	}
	ret += fmt.Sprintf("hall:%s,%s:%s", getBmYzFloatValue(hall), baseStr, getBmYzFloatValue(base))
	return ret
}

func getBmYzFloatValue(value float32) string {
	return strconv.FormatFloat(float64(value), 'f', 3, 32)
}