IOT/SERVER/IotAdmin/iot/iot.go

package iot

import (
	"IotAdmin/core/logger"
	iotDb "IotAdmin/iot/db"
	iotMap "IotAdmin/iot/map"
	iotProtocol "IotAdmin/iot/protocol"
	iotService "IotAdmin/iot/service"
	iotDownService "IotAdmin/iot/service/downService"
	iotStruct "IotAdmin/iot/struct"
)

var ()

func InitIotService() {
	iotDownService.DtuRegisterChan = make(chan *iotStruct.DtuRegisterChanMsg, 100)
	iotProtocol.Init()
	iotMap.Init()
	if err := iotDb.Init(); err != nil {
		logger.Errorf("IOT服务启动失败: %s", err.Error())
	} else {
		iotService.Init()
	}
}