package downStreamService

import (
	"MeterService/dataStruct"
	"MeterService/meter"
	"MeterService/service/downStreamService/proto"
	"MeterService/service/downStreamService/proto/report"
)

func reportData(dataArray *[]*dataStruct.CollectData, config *dataStruct.DtuConfig) {
	var reportHandler proto.ReportHandler
	switch config.Protocol {
	case meter.PlatYcHj212:
		reportHandler = report.NewYcHj212ReportHandler()
	default:
	}
	go func(arr *[]*dataStruct.CollectData, cfg *dataStruct.DtuConfig) {
		reportHandler.Adapter(arr)
		reportHandler.Report(arr, cfg)
	}(dataArray, config)
}