ammeter/protocol/dlt645_test.go

package protocol

import (
	"encoding/hex"
	"testing"

	"github.com/yuguorong/go/log"
)

//fefefefe68040042050821681104333333332516
//fefefefe68040042050821681104333333332516
func TestPacket(t *testing.T) {
	dlt645 := LoadProtocol("DLT645-2007")
	//FEFEFEFE68AAAAAAAAAAAA681300DF16
	readcmd := dlt645.PackageCmd("ReadAddress")
	log.Infof("%X\n", readcmd)

	//fefefefe68010018251120681104333333332016
	cmd := dlt645.PackageCmd("TotalActivePower", "201125180001")
	log.Infof("cmd %X", cmd)
	if cmd == nil {
		t.Error("failed in PackageCmd")
	}
	srecv := hex.EncodeToString(cmd.([]byte))
	t.Logf("param: [%s]\n", srecv)

}

//020068361211
func TestParse(t *testing.T) {
	dlt645 := LoadProtocol("DLT645-2007")

	v := dlt645.PackageCmd("TotalActivePower", "111236680002")
	log.Infof("%X\n", v)

	cap := []byte{104, 2, 0, 104, 54, 18, 17, 104, 145, 8, 51, 51, 51, 51, 51, 51, 51, 51, 196, 22}
	//104, 17, 18, 54, 104, 0, 2, 104, 147, 6, 53, 51, 155, 105, 69, 68, 33, 22}
	//t1 := []byte{0xfe, 0xfe, 0xfe, 0xfe, 0x68, 0x04, 0x00, 0x42, 0x05, 0x08, 0x21, 0x68, 0x11, 0x04, 0x33, 0x33, 0x33, 0x33, 0x25, 0x16}
	addr_ack := []byte{0x68, 0x08, 0x00, 0x01, 0x04, 0x06, 0x01, 0x68, 0x93, 0x06, 0x3B, 0x33, 0x34, 0x37, 0x39, 0x34, 0xC3, 0x16}
	//tcmd := []byte{0xfe, 0xfe, 0xfe, 0xfe, 0x68, 0x06, 0x00, 0x42, 0x05, 0x08, 0x21, 0x68, 0x11, 0x04, 0x33, 0x33, 0x33, 0x33, 0x27, 0x16}

	tack := []byte{0xfe, 0xfe, 0xfe, 0xfe, 0x68, 0x06, 0x00, 0x42, 0x05, 0x08, 0x21, 0x68, 0x91, 0x08, 0x33, 0x33, 0x33, 0x33, 0x47, 0xc5, 0x33, 0x33, 0x1d, 0x16}
	//tdec := []byte{0xfe, 0xfe, 0xfe, 0xfe, 0x68, 0x04, 0x00, 0x42, 0x05, 0x08, 0x21, 0x68, 0x91, 0x08, 0x33, 0x33, 0x33, 0x33, 0xb4, 0xbc, 0x34, 0x33, 0x80, 0x16}
	devname := ""
	v1 := dlt645.ParsePacket(cap, &devname)
	t.Log(v1)
	vret := dlt645.ParsePacket(tack, &devname)
	if vret == nil {
		t.Error("Error in parse packet")
	}

	mret := dlt645.ParsePacket(addr_ack, &devname)
	t.Log(mret, ",", devname)

	t.Logf("Get param: [%#v]\n", vret)
}

//map[CH2O-Rtd:0.008 CN:2011 CO2-Rtd:405.0 DataTime:20211006030527 HUMI-Rtd:43.5 MN:8888888826462285 PM25-Rtd:2.0 TEMP-Rtd:22.0 VOC-Rtd:0.052
func TestHj212(t *testing.T) {
	parten := "##0159ST=22;CN=2011;PW=123456;MN=8888888826462285;CP=&&DataTime=20211006030527;TEMP-Rtd=22.0;HUMI-Rtd=43.5;PM25-Rtd=2.0;CO2-Rtd=405.0;CH2O-Rtd=0.008;VOC-Rtd=0.052;&&8ef7"
	ip := LoadProtocol("HJ212")
	ip.Init("HJ212")
	mret := ip.ParsePacket([]byte(parten))
	log.Info(mret)

}