server

type ConnType struct {
	Conn      gnet.Conn
	ConnTime  string
	UpTime    string
	Imei      string
	Register  bool     //是否解析过注册包头
	Etype     int      //设备类型 1.传感器，2 控制器
	Rst       string   //注册的包头，可以直接识别协议
	Protocol  *Sphinfo //连接协议
	CProtocol *Cphinfo
	Task      timer.TimeNoder //时间轮处理句柄
	CStatus   string
}

type Cphinfo struct {
	Hgp      string `gorm:"column:hgp;type:text"`
	Htp      string `gorm:"column:htp;type:text"`
	Ctrl     string `gorm:"column:ctrl;type:text"`
	Cycle    int    `gorm:"column:cycle;type:int"`
	Sw       int    `gorm:"column:sw;type:int"`
	Protocol []*model.Ctrlinfo
}

type DataHandlerType func([]SaveType, *gorm.DB, *os.File, *redis.Pool)

type IotConnection struct {
	Conn map[string]*ConnType
	Mx   sync.RWMutex
}

type ItoInfo struct {
	ScanTime string      `json:"scan_time"` //采集时间
	IData    []*SaveType `json:"data"`
	Imei     string      `json:"imei"`
}

type SaveType struct {
	Name  string
	Value string
}

type Server struct {
	Port int    `gorm:"column:port;type:int"`
	Info string `gorm:"column:info;type:text"`
}

type Sphinfo struct {
	ID          uint   `gorm:"primary_key;column:id;type:int unsigned;not null"`
	Hgp         string `gorm:"column:hgp;type:text"`
	Htp         string `gorm:"column:htp;type:text"`
	Ctrl        string `gorm:"column:ctrl;type:text"`
	Cycle       int    `gorm:"column:cycle;type:int"`
	Sw          int    `gorm:"column:sw;type:int"`
	Protocol    []*model.Sensorinfo
	Database    *gorm.DB
	Tname       string //存储的表名字
	File        *os.File
	Redis       *redis.Pool
	DataHandler *DataHandlerType
	ItoChan     chan *ItoInfo
}