mysql

type ActionDef struct {
	Input  schema.Params `json:"input"`  //调用参数
	Output schema.Params `json:"output"` //返回参数
}

type DeviceFilter struct {
	ProductID     string
	DeviceName    string
	Tags          map[string]string
	LastLoginTime struct {
		Start int64
		End   int64
	}
	IsOnline []int64
	Range    int64
	Position string
}

type DmDeviceInfo struct {
	Id          int64        `db:"id"`
	ProductID   string       `db:"productID"`  // 产品id
	DeviceName  string       `db:"deviceName"` // 设备名称
	Secret      string       `db:"secret"`     // 设备秘钥
	FirstLogin  sql.NullTime `db:"firstLogin"` // 激活时间
	LastLogin   sql.NullTime `db:"lastLogin"`  // 最后上线时间
	CreatedTime time.Time    `db:"createdTime"`
	UpdatedTime time.Time    `db:"updatedTime"`
	DeletedTime sql.NullTime `db:"deletedTime"`
	Version     string       `db:"version"`  // 固件版本
	LogLevel    int64        `db:"logLevel"` // 日志级别:1)关闭 2)错误 3)告警 4)信息 5)调试
	Cert        string       `db:"cert"`     // 设备证书
	IsOnline    int64        `db:"isOnline"` // 是否在线,1是2否
	Tags        string       `db:"tags"`     // 设备标签
	Address     string       `db:"address"`  // 所在地址
	Position    string       `db:"position"` // 设备的位置,默认百度坐标系BD09
}

type DmDeviceInfoModel interface {
	InsertDeviceInfo(ctx context.Context, data *DmDeviceInfo) error
	FindByFilter(ctx context.Context, filter DeviceFilter, page def.PageInfo) ([]*DmDeviceInfo, error)
	CountByFilter(ctx context.Context, filter DeviceFilter) (size int64, err error)
	CountGroupByField(ctx context.Context, filter DeviceFilter, fieldName string) (map[string]int64, error)
	FindOneByProductIDAndDeviceName(ctx context.Context, productID string, deviceName string) (*DmDeviceInfo, error)
	UpdateDeviceInfo(ctx context.Context, data *DmDeviceInfo) error
	// contains filtered or unexported methods
}

type DmGatewayDevice struct {
	Id                int64        `db:"id"`
	GatewayProductID  string       `db:"gatewayProductID"`  // 网关产品id
	GatewayDeviceName string       `db:"gatewayDeviceName"` // 网关设备名称
	ProductID         string       `db:"productID"`         // 子设备产品id
	DeviceName        string       `db:"deviceName"`        // 子设备名称
	CreatedTime       time.Time    `db:"createdTime"`       // 创建时间
	UpdatedTime       time.Time    `db:"updatedTime"`       // 更新时间
	DeletedTime       sql.NullTime `db:"deletedTime"`       // 删除时间
}

type DmGatewayDeviceModel interface {
	CreateList(ctx context.Context, gateway *devices.Core, subDevices []*devices.Core) error
	DeleteList(ctx context.Context, gateway *devices.Core, subDevices []*devices.Core) error
	FindByFilter(ctx context.Context, filter GatewayDeviceFilter, page *def.PageInfo) ([]*DmDeviceInfo, error)
	CountByFilter(ctx context.Context, filter GatewayDeviceFilter) (size int64, err error)
	// contains filtered or unexported methods
}

type DmGroupDevice struct {
	Id          int64        `db:"id"`
	GroupID     int64        `db:"groupID"`     // 分组ID
	ProductID   string       `db:"productID"`   // 产品id
	DeviceName  string       `db:"deviceName"`  // 设备名称
	CreatedTime time.Time    `db:"createdTime"` // 创建时间
	UpdatedTime time.Time    `db:"updatedTime"` // 更新时间
	DeletedTime sql.NullTime `db:"deletedTime"` // 删除时间
}

type DmGroupDeviceModel interface {
	// contains filtered or unexported methods
}

type DmGroupInfo struct {
	GroupID     int64        `db:"groupID"`     // 分组ID
	ParentID    int64        `db:"parentID"`    // 父组ID 0-根组
	GroupName   string       `db:"groupName"`   // 分组名称
	Desc        string       `db:"desc"`        // 描述
	Tags        string       `db:"tags"`        // 分组标签
	CreatedTime time.Time    `db:"createdTime"` // 创建时间
	UpdatedTime time.Time    `db:"updatedTime"` // 更新时间
	DeletedTime sql.NullTime `db:"deletedTime"` // 删除时间
}

type DmGroupInfoModel interface {
	// contains filtered or unexported methods
}

type DmGroupModel interface {
	Index(ctx context.Context, in *GroupFilter) ([]*GroupInformation, int64, error)
	IndexAll(ctx context.Context, in *GroupFilter) ([]*GroupInformation, error)
	IndexGD(ctx context.Context, in *GroupDeviceFilter) ([]*DmGroupDevice, int64, error)
	Delete(ctx context.Context, groupID int64) error
	GroupDeviceCreate(ctx context.Context, groupID int64, list []*devices.Core) error
	GroupDeviceDelete(ctx context.Context, groupID int64, list []*devices.Core) error
}

type DmProductFirmware struct {
	Id          int64        `db:"id"`
	ProductID   string       `db:"productID"` // 产品id
	Version     string       `db:"version"`   // 固件版本
	CreatedTime time.Time    `db:"createdTime"`
	UpdatedTime time.Time    `db:"updatedTime"`
	DeletedTime sql.NullTime `db:"deletedTime"`
	Name        string       `db:"name"` // 固件名称
	Desc        string       `db:"desc"` // 描述
	Size        int64        `db:"size"` // 固件大小
	Dir         string       `db:"dir"`  // 固件标识,拿来下载文件
}

type DmProductFirmwareModel interface {
	// contains filtered or unexported methods
}

type DmProductInfo struct {
	ProductID    string       `db:"productID"`    // 产品id
	ProductName  string       `db:"productName"`  // 产品名称
	ProductType  int64        `db:"productType"`  // 产品状态:1:开发中,2:审核中,3:已发布
	AuthMode     int64        `db:"authMode"`     // 认证方式:1:账密认证,2:秘钥认证
	DeviceType   int64        `db:"deviceType"`   // 设备类型:1:设备,2:网关,3:子设备
	CategoryID   int64        `db:"categoryID"`   // 产品品类
	NetType      int64        `db:"netType"`      // 通讯方式:1:其他,2:wi-fi,3:2G/3G/4G,4:5G,5:BLE,6:LoRaWAN
	DataProto    int64        `db:"dataProto"`    // 数据协议:1:自定义,2:数据模板
	AutoRegister int64        `db:"autoRegister"` // 动态注册:1:关闭,2:打开,3:打开并自动创建设备
	Secret       string       `db:"secret"`       // 动态注册产品秘钥
	Desc         string       `db:"desc"`         // 描述
	CreatedTime  time.Time    `db:"createdTime"`
	UpdatedTime  time.Time    `db:"updatedTime"`
	DeletedTime  sql.NullTime `db:"deletedTime"`
	DevStatus    string       `db:"devStatus"` // 产品状态
	Tags         string       `db:"tags"`      // 产品标签
}

type DmProductInfoModel interface {
	FindByFilter(ctx context.Context, filter ProductFilter, page *def.PageInfo) ([]*DmProductInfo, error)
	CountByFilter(ctx context.Context, filter ProductFilter) (size int64, err error)
	// contains filtered or unexported methods
}

type DmProductRemoteConfig struct {
	Id          int64        `db:"id"`
	ProductID   string       `db:"productID"`   // 产品id
	Content     string       `db:"content"`     // 配置内容
	CreatedTime time.Time    `db:"createdTime"` // 创建时间
	UpdatedTime time.Time    `db:"updatedTime"` // 更新时间
	DeletedTime sql.NullTime `db:"deletedTime"` // 删除时间
}

type DmProductRemoteConfigModel interface {
	// contains filtered or unexported methods
}

type DmProductSchema struct {
	Id          int64        `db:"id"`
	ProductID   string       `db:"productID"`  // 产品id
	Tag         int64        `db:"tag"`        // 物模型标签 1:自定义 2:可选 3:必选  必选不可删除
	Type        int64        `db:"type"`       // 物模型类型 1:property属性 2:event事件 3:action行为
	Identifier  string       `db:"identifier"` // 标识符
	Name        string       `db:"name"`       // 功能名称
	Desc        string       `db:"desc"`       // 描述
	Required    int64        `db:"required"`   // 是否必须,1是 2否
	Affordance  string       `db:"affordance"` // 各类型的自定义功能定义
	CreatedTime time.Time    `db:"createdTime"`
	UpdatedTime time.Time    `db:"updatedTime"`
	DeletedTime sql.NullTime `db:"deletedTime"`
}

type DmProductSchemaModel interface {
	DeleteWithFilter(ctx context.Context, filter ProductSchemaFilter) error
	FindByFilter(ctx context.Context, filter ProductSchemaFilter, page *def.PageInfo) ([]*DmProductSchema, error)
	GetCountByFilter(ctx context.Context, filter ProductSchemaFilter) (size int64, err error)
	// contains filtered or unexported methods
}

type DmRemoteConfigModel interface {
	Index(ctx context.Context, in *RemoteConfigFilter) ([]*RemoteConfigInfo, int64, error)
	GetLastRecord(ctx context.Context, in *RemoteConfigFilter) (*RemoteConfigInfo, error)
}

type EventDef struct {
	Type   schema.EventType `json:"type"`   //事件类型: 1:信息:info  2:告警alert  3:故障:fault
	Params schema.Params    `json:"params"` //事件参数
}

type GatewayDeviceFilter struct {
	Gateway devices.Core //必填
}

type GroupDeviceFilter struct {
	Page       *def.PageInfo
	GroupID    int64
	ProductID  string
	DeviceName string
}

type GroupFilter struct {
	Page      *def.PageInfo
	ParentID  int64
	GroupName string
	Tags      map[string]string
}

type GroupInformation struct {
	GroupID     int64
	GroupName   string
	ParentID    int64
	Desc        string
	CreatedTime int64
	Tags        map[string]string
}

type ProductFilter struct {
	DeviceType  int64
	ProductName string
	ProductIDs  []string
	Tags        map[string]string
}

type ProductSchemaFilter struct {
	ProductID   string   //产品id  必填
	Type        int64    //物模型类型 1:property属性 2:event事件 3:action行为
	Tag         int64    //过滤条件: 物模型标签 1:自定义 2:可选 3:必选
	Identifiers []string //过滤标识符列表
}

type PropertyDef struct {
	Define schema.Define       `json:"define"` //数据定义
	Mode   schema.PropertyMode `json:"mode"`   //读写类型: 1:r(只读) 2:rw(可读可写)
}

type RemoteConfigFilter struct {
	Page      *def.PageInfo
	ProductID string
}

type RemoteConfigInfo struct {
	ID          int64
	ProductID   string
	Content     string
	CreatedTime int64
}