ammeter/protocol/dlt645.go

package protocol

import (
	"bytes"
	"encoding/binary"
	"encoding/hex"
	"errors"
	"fmt"
	"reflect"
	"runtime"
	"strconv"

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

/*
		"9521003872": {"2108", "05420005", "05420003", "05420002"}, //6f
		"9521003712": {"2108", "05420001"},                         //1F
		"9521003534": {"2108", "05420006"},                         //-1F
		"9521003697": {"2108", "05420004"},                         //5c

//fefefefe68040042050821681104333333332516
//fefefefe68 04 00 42 05 08 21 68910833333333b4bc34338016

data [{"accessToken":"AZM7QSPRqsV4CUxIGldn",
"id":"1ec23004b88a020bf52b38d8579115b",
"mqttServer":"test-sbuilding.pacom.cn:1885",
"name":"FGGW10-202110020001"}]
reqParam {"gwDevId":"1ec23004b88a020bf52b38d8579115b","pageNum":1,"pageSize":100} https://test-admin.pacom.cn/platform/dev/get-ammeter-list 2021-10-03 23:10:26.175516015 +0800 CST m=+7.127250782
data [
	{"address":"05420005",
	"code":"2108",
	"devName":"AM10-9521003872210805",
	"dutSn":"9521003872",
	"gwDevId":"1ec23004b88a020bf52b38d8579115b",
	"id":"1ec2300601517d0bf52b38d8579115b",
	"protocol":"DLT645-2007"},
	{"address":"05420001","code":"2108","devName":"AM10-9521003712210805","dutSn":"9521003712","gwDevId":"1ec23004b88a020bf52b38d8579115b","id":"1ec230092bb8de0bf52b38d8579115b","protocol":"DLT645-2007"},{"address":"05420006","code":"2108","devName":"AM10-9521003534210805","dutSn":"9521003534","gwDevId":"1ec23004b88a020bf52b38d8579115b","id":"1ec23009ed76090bf52b38d8579115b","protocol":"DLT645-2007"},{"address":"05420004","code":"2108","devName":"AM10-9521003697210805","dutSn":"9521003697","gwDevId":"1ec23004b88a020bf52b38d8579115b","id":"1ec2300abbc2890bf52b38d8579115b","protocol":"DLT645-2007"}]


FE FE FE FE
0	68H	帧起始符
1	A0	地址域
2	A1
3	A2
4	A3
5	A4
6	A5
7	68H	帧起始符
8	C	控制码
9	L	数据域长度
10	DATA	数据域
11	CS	校验码
*/

const (
	C_CODE_MASK = 0x1F //功能码标志位

	//功能码
	C_2007_CODE_BRC = 0x08 //广播校时
	C_2007_CODE_RD  = 0x11 //读数据
	C_2007_CODE_RDM = 0x12 //读后续数据
	C_2007_CODE_RDA = 0x13 //读通信地址
	C_2007_CODE_WR  = 0x14 //写数据
	C_2007_CODE_WRA = 0x15 //写通信地址
	C_2007_CODE_DJ  = 0x16 //冻结
	C_2007_CODE_BR  = 0x17 //更改通信速率
	C_2007_CODE_PD  = 0x18 //修改密码
	C_2007_CODE_XL  = 0x19 //最大需量清零
	C_2007_CODE_DB  = 0x1a //电表清零
	C_2007_CODE_MSG = 0x1b //事件清零

	ERR_2007_RATE  = 0x40 //费率数超
	ERR_2007_DAY   = 0x20 //日时段数超
	ERR_2007_YEAR  = 0x10 //年时区数超
	ERR_2007_BR    = 0x08 //通信速率不能更改
	ERR_2007_PD    = 0x04 //密码错误/未授权
	ERR_2007_DATA  = 0x02 //无请求数据
	ERR_2007_OTHER = 0x01 //其他错误

	/*DLT 645 2007数据标识*/
	DLT_GROUP_ACTIVE_POWER_TOTAL         = 0x0       //组合有功总电能
	DLT_PRIC1_GROUP_ACTIVE_POWER_TOTAL   = 0x100     //组合有功费率1电能
	DLT_PRIC2_GROUP_ACTIVE_POWER_TOTAL   = 0x200     //组合有功费率2电能
	DLT_PRIC3_GROUP_ACTIVE_POWER_TOTAL   = 0x300     //组合有功费率3电能
	DLT_PRIC4_GROUP_ACTIVE_POWER_TOTAL   = 0x400     //组合有功费率4电能
	DLT_GROUP_FORTH_POWER_TOTAL          = 0x10000   //正向有功总电能
	DLT_PRIC1_GROUP_FORTH_POWER_TOTAL    = 0x10100   //正向有功费率1电能
	DLT_PRIC2_GROUP_FORTH_POWER_TOTAL    = 0x10200   //正向有功费率2电能
	DLT_PRIC3_GROUP_FORTH_POWER_TOTAL    = 0x10300   //正向有功费率3电能
	DLT_PRIC4_GROUP_FORTH_POWER_TOTAL    = 0x10400   //正向有功费率4电能
	DLT_GROUP_BACK_POWER_TOTAL           = 0x20000   //反向有功总电能
	DLT_PRIC1_GROUP_BACK_POWER_TOTAL     = 0x20100   //反向有功费率1电能
	DLT_PRIC2_GROUP_BACK_POWER_TOTAL     = 0x20200   //反向有功费率2电能
	DLT_PRIC3_GROUP_BACK_POWER_TOTAL     = 0x20300   //反向有功费率3电能
	DLT_PRIC4_GROUP_BACK_POWER_TOTAL     = 0x20400   //反向有功费率4电能
	DLT_GROUP_NONE1_POWER_TOTAL          = 0x30000   //组合无功1总电能
	DLT_GROUP_NONE2_POWER_TOTAL          = 0x40000   //组合无功2总电能
	DLT_GROUP_QUAD1_NONE_POWER_TOTAL     = 0x50000   //第一象限无功电能
	DLT_GROUP_QUAD2_NONE_POWER_TOTAL     = 0x60000   //第二象限无功电能
	DLT_GROUP_QUAD3_NONE_POWER_TOTAL     = 0x70000   //第三象限无功电能
	DLT_GROUP_QUAD4_NONE_POWER_TOTAL     = 0x80000   //第四象限无功电能
	DLT_GROUP_FORTH_APPARENT_POWER_TOTAL = 0x90000   //正向视在总电能
	DLT_PHASE_A_VOLTAGE                  = 0x2010100 //A相电压
	DLT_PHASE_B_VOLTAGE                  = 0x2010200 //B相电压
	DLT_PHASE_C_VOLTAGE                  = 0x2010300 //C相电压
	DLT_PHASE_A_CURENT                   = 0x2020100 //A相电流
	DLT_PHASE_B_CURENT                   = 0x2020200 //B相电流
	DLT_PHASE_C_CURENT                   = 0x2020300 //C相电流
	DIC_2030000                          = 0x2030000 //总有功功率
	DIC_2030100                          = 0x2030100 //A相有功功率
	DIC_2030200                          = 0x2030200 //B相有功功率
	DIC_2030300                          = 0x2030300 //C相有功功率
	DIC_2040000                          = 0x2040000 //总无功功率
	DIC_2040100                          = 0x2040100 //A相无功功率
	DIC_2040200                          = 0x2040200 //B相无功功率
	DIC_2040300                          = 0x2040300 //C相无功功率
	DIC_2050000                          = 0x2050000 //总视在功率
	DIC_2050100                          = 0x2050100 //A相视在功率
	DIC_2050200                          = 0x2050200 //B相视在功率
	DIC_2050300                          = 0x2050300 //C相视在功率
	DIC_2060000                          = 0x2060000 //总功率因素
	DIC_2060100                          = 0x2060100 //A相功率因素
	DIC_2060200                          = 0x2060200 //B相功率因素
	DIC_2060300                          = 0x2060300 //C相功率因素
	DIC_20C0100                          = 0x20C0100 //AB线电压
	DIC_20C0200                          = 0x20C0200 //BC线电压
	DIC_20C0300                          = 0x20C0300 //CA线电压
	DIC_2800002                          = 0x2800002 //频率
	DIC_4000101                          = 0x4000101 //年月日星期
	DIC_4000102                          = 0x4000102 //时分秒
	DIC_5060001                          = 0x5060001 //上一次日冻结时间
	DIC_5060101                          = 0x5060101 //上一次日冻结正向有功电能
	DIC_30C0000                          = 0x30C0000 //过流总次数，总时间
	DIC_30C0101                          = 0x30C0101 //上一次A相过流记录
	DIC_3300100                          = 0x3300100 //电表清零总次数
	DIC_3300101                          = 0x3300101 //电表清零记录
	DIC_4000501                          = 0x4000501
	DIC_4000502                          = 0x4000502
	DIC_4000503                          = 0x4000503
	DIC_4000504                          = 0x4000504
	DIC_4000505                          = 0x4000505
	DIC_4000506                          = 0x4000506
	DIC_4000507                          = 0x4000507
	DIC_4000403                          = 0x4000403 //资产管理编码
	DIC_4000701                          = 0x4000701 //信号强度
	DIC_4000702                          = 0x4000702 //版本号
	DIC_7000001                          = 0x7000001 //master_api_key
	DIC_7000002                          = 0x7000002 //device_id
)

const (
	DLT_CHAR_HEADER      = 0xFE
	DLT_CHAR_TAIL        = 0x16
	DLT_CHAR_FRAME_START = 0x68
	DLT_DEF_CHAR_OPCODE  = C_2007_CODE_RD
	DLT_ADDR_POS         = 1
	DLT_FILED_POS        = 7
	DLT_OPCODE_POS       = 8
	DLT_DICCODE_POS      = 9
	DLT_DICCODE_LEN      = 4
	DLT_PARAM_POS        = 9
	DLT_ADDR_LEN         = 6
	DLT_LEAD_LEN         = 4
	DLT_CMD_DIR_REVERT   = 0x80
)

/*FE FE FE FE
0	68H	帧起始符
1	A0	地址域
2	A1
3	A2
4	A3
5	A4
6	A5
7	68H	帧起始符
8	C	控制码
9	L	数据域长度
10	DATA	数据域
11	CS	校验码
*/
type dlt645 struct {
	name string
}

func bcd2int(bcd []byte) int64 {
	vi := int64(0)
	for i := 0; i < len(bcd); i++ {
		vi = (vi * 10) + int64((bcd[i]>>4)&0xF)
		vi = (vi * 10) + int64(bcd[i]&0xF)
	}
	return vi
}

func (p *dlt645) setDltAddr(buff []byte, amaddr string) error {
	addr, err := hex.DecodeString(amaddr)
	if err == nil {
		len := len(addr)
		for i := 0; i < len/2; i++ {
			j := len - i - 1
			addr[i], addr[j] = addr[j], addr[i]
		}
		copy(buff, addr)
	}
	return err
}

func (p *dlt645) setDltOpcode(buff []byte, opcode string) error {
	opc, err := hex.DecodeString(opcode)
	if err == nil {
		for i := 0; i < len(opc); i++ {
			buff[i+1] = opc[i] + 0x33
		}
		buff[0] = byte(len(opc))
	}
	return err
}

func (p *dlt645) setDltCheckSum(buff []byte) {
	sum := byte(0)
	pos := 0
	len := len(buff) - 1
	for ; pos < len && buff[pos] == 0xFE; pos++ {
	}
	for ; pos < len; pos++ {
		sum += buff[pos]
	}
	buff[len] = sum
}

func (p *dlt645) PackageCmd(opcode string, param ...interface{}) interface{} {
	amaddr := param[0].(string)
	buff := []byte{0xFE, 0xFE, 0xFE, 0xFE, DLT_CHAR_FRAME_START, 0xAA, 0xAA, 0xAA, 0xAA, 0xAA, 0xAA, DLT_CHAR_FRAME_START, DLT_DEF_CHAR_OPCODE, 0x00, 0x00, 0x00, 0x00, 0x00, 0x00}
	pkPos := DLT_LEAD_LEN + DLT_ADDR_POS
	err := p.setDltAddr(buff[pkPos:pkPos+DLT_ADDR_LEN], amaddr)
	if err != nil {
		log.Error("error in set meter addr ", amaddr)
		return nil
	}
	parampos := pkPos + DLT_ADDR_LEN + 2
	err = p.setDltOpcode(buff[parampos:parampos+5], opcode)
	if err != nil {
		log.Error("error in set op code ", opcode)
		return nil
	}
	p.setDltCheckSum(buff)
	buff = append(buff, 0x16)
	log.Infof("Send cmd [%s] to dtu[%s]\n", hex.EncodeToString(buff), amaddr)
	return buff
}

func Assert(est bool, infoi int) {
	if !est {
		_, file, line, ok := runtime.Caller(1)
		var serror string
		if ok {
			serror = fmt.Sprintf("Assert at [%s:%d]: (%d)", file, line, infoi)
		} else {
			serror = "parsecmd error with info:" + "" + strconv.Itoa(infoi)
		}
		panic(errors.New(serror))
	}
}

func (p *dlt645) skipLeader(buf []byte) (int, int) {
	pos := 0
	lenb := len(buf)
	for ; pos < lenb && (buf[pos] == 0xFF || buf[pos] == DLT_CHAR_HEADER); pos++ {
	}
	return pos, lenb
}

//fefefefe68040042050821681104333333332516
//fefefefe6804004205082168910833333333b4bc34338016
//fefefefe68 060042050821 68 91 08 33 33 33 33 47 c5 33 33 1d |16
func (p *dlt645) ParsePacket(rxb []byte, params ...interface{}) (mapv interface{}) {
	if len(params) <= 0 || len(rxb) < 12 {
		return nil
	}

	defer func() {
		if err := recover(); err != nil {
			log.Infof("%s\n", err)
		}

	}()

	sum := byte(0)
	pos, lenb := p.skipLeader(rxb)
	Assert(rxb[pos] == DLT_CHAR_FRAME_START, int(rxb[pos]))
	for i := pos; i < lenb-2; i++ {
		sum += rxb[i]
	}
	Assert(rxb[lenb-1-1] == sum, int(sum))

	//get addr
	addr := rxb[pos+1 : pos+1+DLT_ADDR_LEN]
	for i := 0; i < DLT_ADDR_LEN/2; i++ {
		addr[i], addr[DLT_ADDR_LEN-i-1] = addr[DLT_ADDR_LEN-i-1], addr[i]
	}
	saddr := hex.EncodeToString(addr)
	if len(params) > 0 && reflect.TypeOf(params[0]).Kind() == reflect.Ptr {
		*params[0].(*string) = saddr
	}

	Assert(rxb[pos+DLT_FILED_POS] == DLT_CHAR_FRAME_START, int(rxb[pos+DLT_FILED_POS]))
	//CMD. opcode
	cmd := rxb[pos+DLT_OPCODE_POS]

	//PARAM = DIC_CODE + PARAM
	pos += DLT_DICCODE_POS
	lenParam := int(rxb[pos])
	pos++

	Assert(lenParam > DLT_DICCODE_LEN, lenParam)

	dicCode := 0
	dicBuff := bytes.NewBuffer(rxb[pos : pos+DLT_DICCODE_LEN])
	binary.Read(dicBuff, binary.LittleEndian, &dicCode)

	Assert(lenParam+pos < lenb-1, lenParam)
	param := make([]byte, lenParam)
	for i := 0; i < lenParam; i++ {
		param[lenParam-i-1] = rxb[pos+i] - 0x33
	}
	pos += lenParam

	Assert(rxb[pos+1] == DLT_CHAR_TAIL, int(rxb[pos+1]))

	if cmd == (C_2007_CODE_RD | DLT_CMD_DIR_REVERT) {
		val := float64(bcd2int(param[:lenParam-DLT_DICCODE_LEN])) / 100.0
		for k, v := range Cmd2Code {
			if int(v) == dicCode {
				mapv := make(map[string]interface{})
				mapv[k] = val
				return mapv
			}
		}
	} else if cmd == (C_2007_CODE_RDA | DLT_CMD_DIR_REVERT) {
		return saddr

	} else {
		log.Error("unkown DLT645 cmd:", cmd)
	}

	return nil
}

func (p *dlt645) VisableData(name string, opcode string, param interface{}) string {
	return ""
}

func (p *dlt645) Init(name string) error {
	p.name = name
	ProtList[p.name] = p
	return nil
}

func (p *dlt645) Uninit() {
}

func (p *dlt645) ChannelDispatch(rxb []byte) int {
	return 0
}

func NewDlt645() IProtocol {
	p := &dlt645{}
	p.Init("DLT645-2007")
	return p
}

var Cmd2Code map[string]uint32

func init() {
	ProtReg["DLT645-2007"] = NewDlt645
	Cmd2Code = map[string]uint32{
		"TotalActivePower": DLT_GROUP_ACTIVE_POWER_TOTAL,
	}
}