package entityManager

import (
	"gitee.com/fierce_wolf/go-fox-edge-common/commEntity"
	"gitee.com/fierce_wolf/go-fox-edge-common/commEntityManager"
	"gitee.com/fierce_wolf/go-fox-edge-common/commRedisService"
	"gitee.com/fierce_wolf/go-fox-edge-common/commSql"
	"gitee.com/fierce_wolf/go-fox-edge-common/commUtil/Map"
)

func Instance(others map[string]interface{}) {
	producer := commRedisService.IRedisManager.GetRedisProducer()
	consumer := commRedisService.IRedisManager.GetRedisConsumer()

	consumer[commEntity.Type.ConfigEntity.Type()] = nil
	consumer[commEntity.Type.ChannelEntity.Type()] = nil
	Map.Append(consumer, others)

	producer[commEntity.Type.ChannelStatusEntity.Type()] = nil

	// 初始化数据库的字典
	var entityTypes []string
	for k1 := range consumer {
		entityTypes = append(entityTypes, k1)
	}
	for k2 := range producer {
		entityTypes = append(entityTypes, k2)
	}
	commSql.Instance(entityTypes)
}

func InitLoadEntity() {
	commEntityManager.InitLoadEntity()
}

// Scheduler 线程函数
func Scheduler() {
	commEntityManager.Scheduler()
}