package device

import (
	"vamicro/iotData-service/model"
)

var CollectorMsgChan = make(chan model.Device, 100)

func Collector() {
	// RT02信息接收
	go RT02MsgServer()

	// 处理消息
	for {
		select {
		case msg := <-CollectorMsgChan:
			// 插入设备数据
			msg.Update()

		}
	}
}