relationDB

package

Go to main page

Versions in this module

v1

v1.2.20

Jan 23, 2025

Changes in this version

type DmProductInfo

+ BindLevel int64

type DmSchemaCore

+ IsPassword int64

type GatewayDeviceRepo

+ func (d GatewayDeviceRepo) Update(ctx context.Context, data *DmGatewayDevice) error

+ func (d GatewayDeviceRepo) UpdateWithField(ctx context.Context, f GatewayDeviceFilter, updates map[string]any) error

v1.2.1

Jan 9, 2025

v1.2.0

Dec 25, 2024

Changes in this version

type GroupInfoFilter

+ IDs []int64

v1.1.1

Dec 18, 2024

Changes in this version

type DeviceFilter

+ TagsLike map[string]string

type DmDeviceInfo

+ LastBind sql.NullTime

type DmProductInfo

+ IsCanCoverBindDevice int64

v1.1.0

Nov 19, 2024

Changes in this version

type GroupInfoFilter

+ HasDevice *devices.Core

+ HasDevices []*devices.Core

+ Purposes []string

v1.0.6

Nov 17, 2024

Changes in this version

type DmGroupInfo

+ Purpose string

type GroupInfoFilter

+ Purpose string

type ProductFilter

+ AreaIDPath string

v1.0.5

Nov 16, 2024

Changes in this version

type DeviceFilter

+ GroupName string

+ ParentGroupID int64

type DeviceSchemaFilter

+ WithProductSchema bool

type DmDeviceInfo

+ Desc string

+ LastIp string

+ type DmSchemaInfo struct

+ DeletedTime stores.DeletedTime

+ DeviceName sql.NullString

+ ID int64

+ ProductID string

+ func (m *DmSchemaInfo) TableName() string

+ type ProductSchemaOldFilter struct

+ ControlMode int64

+ FuncGroup int64

+ ID int64

+ Identifiers []string

+ IsCanSceneLinkage int64

+ Name string

+ ProductID string

+ ProductIDs []string

+ ProductSceneMode string

+ PropertyMode string

+ Tag schema.Tag

+ Tags []schema.Tag

+ Type int64

+ Types []int64

+ UserPerm int64

+ type ProductSchemaOldRepo struct

+ func NewProductSchemaOldRepo(in any) *ProductSchemaOldRepo

+ func (p ProductSchemaOldRepo) CountByFilter(ctx context.Context, f ProductSchemaFilter) (size int64, err error)

+ func (p ProductSchemaOldRepo) DeleteByFilter(ctx context.Context, f ProductSchemaFilter) error

+ func (p ProductSchemaOldRepo) FindByFilter(ctx context.Context, f ProductSchemaFilter, page *stores.PageInfo) ([]*DmProductSchema, error)

+ func (p ProductSchemaOldRepo) FindOneByFilter(ctx context.Context, f ProductSchemaFilter) (*DmProductSchema, error)

+ func (p ProductSchemaOldRepo) FindProductIDByFilter(ctx context.Context, f ProductSchemaFilter) ([]string, error)

+ func (p ProductSchemaOldRepo) Insert(ctx context.Context, data *DmProductSchema) error

+ func (p ProductSchemaOldRepo) MultiInsert(ctx context.Context, data []*DmProductSchema) error

+ func (p ProductSchemaOldRepo) MultiUpdate(ctx context.Context, productID string, schemaInfo *schema.Model) error

+ func (p ProductSchemaOldRepo) Update(ctx context.Context, data *DmProductSchema) error

+ func (p ProductSchemaOldRepo) UpdateTag(ctx context.Context, productIDs []string, identifiers []string, ...) error

+ func (p ProductSchemaOldRepo) UpdateWithCommon(ctx context.Context, common *DmCommonSchema) error

+ type SchemaInfoFilter struct

+ ControlMode int64

+ DeviceName string

+ FuncGroup int64

+ ID int64

+ Identifiers []string

+ IsCanSceneLinkage int64

+ Name string

+ ProductID string

+ ProductSceneMode string

+ PropertyMode string

+ Tag schema.Tag

+ Tags []schema.Tag

+ Type int64

+ Types []int64

+ UserPerm int64

+ type SchemaInfoRepo struct

+ func NewSchemaInfoRepo(in any) *SchemaInfoRepo

+ func (p SchemaInfoRepo) CountByFilter(ctx context.Context, f SchemaInfoFilter) (size int64, err error)

+ func (p SchemaInfoRepo) DeleteByFilter(ctx context.Context, f SchemaInfoFilter) error

+ func (p SchemaInfoRepo) FindByFilter(ctx context.Context, f SchemaInfoFilter, page *stores.PageInfo) ([]*DmSchemaInfo, error)

+ func (p SchemaInfoRepo) FindOneByFilter(ctx context.Context, f SchemaInfoFilter) (*DmSchemaInfo, error)

+ func (p SchemaInfoRepo) Insert(ctx context.Context, data *DmSchemaInfo) error

+ func (p SchemaInfoRepo) MultiInsert(ctx context.Context, data []*DmSchemaInfo) error

+ func (p SchemaInfoRepo) MultiInsert2(ctx context.Context, productID string, deviceName string, ...) error

+ func (p SchemaInfoRepo) MultiUpdate(ctx context.Context, productID string, deviceName string, ...) error

+ func (p SchemaInfoRepo) Update(ctx context.Context, data *DmSchemaInfo) error

+ func (p SchemaInfoRepo) UpdateTag(ctx context.Context, productIDs []string, identifiers []string, ...) error

v1.0.4

Nov 5, 2024

Changes in this version

+ func ToDeviceSchemaDo(productID string, in []*DmDeviceSchema) *schema.Model

+ type DeviceSchemaFilter struct

+ ControlMode int64

+ DeviceName string

+ FuncGroup int64

+ ID int64

+ Identifiers []string

+ IsCanSceneLinkage int64

+ Name string

+ ProductID string

+ ProductSceneMode string

+ PropertyMode string

+ Tag schema.Tag

+ Tags []schema.Tag

+ Type int64

+ Types []int64

+ UserPerm int64

+ type DeviceSchemaRepo struct

+ func NewDeviceSchemaRepo(in any) *DeviceSchemaRepo

+ func (p DeviceSchemaRepo) CountByFilter(ctx context.Context, f DeviceSchemaFilter) (size int64, err error)

+ func (p DeviceSchemaRepo) DeleteByFilter(ctx context.Context, f DeviceSchemaFilter) error

+ func (p DeviceSchemaRepo) FindByFilter(ctx context.Context, f DeviceSchemaFilter, page *stores.PageInfo) ([]*DmDeviceSchema, error)

+ func (p DeviceSchemaRepo) FindOneByFilter(ctx context.Context, f DeviceSchemaFilter) (*DmDeviceSchema, error)

+ func (p DeviceSchemaRepo) Insert(ctx context.Context, data *DmDeviceSchema) error

+ func (p DeviceSchemaRepo) MultiInsert(ctx context.Context, data []*DmDeviceSchema) error

+ func (p DeviceSchemaRepo) MultiInsert2(ctx context.Context, productID string, deviceName string, ...) error

+ func (p DeviceSchemaRepo) MultiUpdate(ctx context.Context, productID string, deviceName string, ...) error

+ func (p DeviceSchemaRepo) Update(ctx context.Context, data *DmDeviceSchema) error

+ func (p DeviceSchemaRepo) UpdateTag(ctx context.Context, productIDs []string, identifiers []string, ...) error

type DmProductInfo

+ DeviceSchemaMode int64

type OtaFirmwareDeviceRepo

+ func (p OtaFirmwareDeviceRepo) FindByFilters(ctx context.Context, f []OtaFirmwareDeviceFilter, page *stores.PageInfo) ([]*DmOtaFirmwareDevice, error)

+ func (p OtaFirmwareDeviceRepo) UpdateStatusByFilters(ctx context.Context, f []OtaFirmwareDeviceFilter, status int64, detail string) error

v1.0.3

Oct 23, 2024

v1.0.2

Oct 22, 2024

Changes in this version

+ type DmDeviceSchema struct

+ DeletedTime stores.DeletedTime

+ DeviceName string

+ ID int64

+ ProductID string

+ ProductInfo *DmProductInfo

+ func (m *DmDeviceSchema) TableName() string

+ type DmProtocolService struct

+ Code string

+ ID int64

+ Ip string

+ Port int64

+ Status int64

+ func (m *DmProtocolService) TableName() string

+ type ProtocolServiceFilter struct

+ Code string

+ ID int64

+ IP string

+ Port int64

+ type ProtocolServiceRepo struct

+ func NewProtocolServiceRepo(in any) *ProtocolServiceRepo

+ func (p ProtocolServiceRepo) CountByFilter(ctx context.Context, f ProtocolServiceFilter) (size int64, err error)

+ func (p ProtocolServiceRepo) Delete(ctx context.Context, id int64) error

+ func (p ProtocolServiceRepo) DeleteByFilter(ctx context.Context, f ProtocolServiceFilter) error

+ func (p ProtocolServiceRepo) DownStatus(ctx context.Context) error

+ func (p ProtocolServiceRepo) FindByFilter(ctx context.Context, f ProtocolServiceFilter, page *stores.PageInfo) ([]*DmProtocolService, error)

+ func (p ProtocolServiceRepo) FindOne(ctx context.Context, id int64) (*DmProtocolService, error)

+ func (p ProtocolServiceRepo) FindOneByFilter(ctx context.Context, f ProtocolServiceFilter) (*DmProtocolService, error)

+ func (p ProtocolServiceRepo) Insert(ctx context.Context, data *DmProtocolService) error

+ func (p ProtocolServiceRepo) MultiInsert(ctx context.Context, data []*DmProtocolService) error

+ func (p ProtocolServiceRepo) Update(ctx context.Context, data *DmProtocolService) error

v1.0.1

Oct 16, 2024

v1.0.0

Oct 12, 2024

v0

v0.2.3

Oct 11, 2024

v0.2.2

Oct 10, 2024

v0.2.1

Oct 10, 2024

Changes in this version

+ const ShareAuthType

+ const ShareAuthTypeAll

+ var ClearDeviceInfo func(ctx context.Context, dev devices.Core) error

+ var MigrateManufacturerInfo = []DmManufacturerInfo

+ var MigrateProductCategory = []DmProductCategory

+ var MigrateProtocolInfo = []DmProtocolInfo

+ func CommonToSchemaDo(in []*DmCommonSchema) *schema.Model

+ func Migrate(c conf.Database) error

+ func NewShadowRepo(in any) shadow.Repo

+ func ToActionDo(in *DmSchemaCore) *schema.Action

+ func ToAffordancePo(in any) string

+ func ToCommonParam(in *DmSchemaCore) schema.CommonParam

+ func ToEventDo(in *DmSchemaCore) *schema.Event

+ func ToPropertyDo(in *DmSchemaCore) *schema.Property

+ func ToSchemaDo(productID string, in []*DmProductSchema) *schema.Model

+ func ToShadowDo(in *DmDeviceShadow) *shadow.Info

+ func ToShadowsDo(in []*DmDeviceShadow) []*shadow.Info

+ type CommonSchemaFilter struct

+ ControlMode int64

+ FuncGroup int64

+ ID int64

+ Identifiers []string

+ IsCanSceneLinkage int64

+ Name string

+ ProductCategoryIDs []int64

+ ProductSceneMode string

+ PropertyMode string

+ Type int64

+ Types []int64

+ UserPerm int64

+ type CommonSchemaRepo struct

+ func NewCommonSchemaRepo(in any) *CommonSchemaRepo

+ func (p CommonSchemaRepo) CountByFilter(ctx context.Context, f CommonSchemaFilter) (size int64, err error)

+ func (p CommonSchemaRepo) DeleteByFilter(ctx context.Context, f CommonSchemaFilter) error

+ func (p CommonSchemaRepo) FindByFilter(ctx context.Context, f CommonSchemaFilter, page *stores.PageInfo) ([]*DmCommonSchema, error)

+ func (p CommonSchemaRepo) FindOneByFilter(ctx context.Context, f CommonSchemaFilter) (*DmCommonSchema, error)

+ func (p CommonSchemaRepo) Insert(ctx context.Context, data *DmCommonSchema) error

+ func (p CommonSchemaRepo) Update(ctx context.Context, data *DmCommonSchema) error

+ type DeviceFilter struct

+ AreaIDPath string

+ AreaIDs []int64

+ CollectType def.SelectType

+ Cores []*devices.Core

+ DeviceAlias string

+ DeviceName string

+ DeviceNames []string

+ DeviceType int64

+ DeviceTypes []int64

+ Distributor *stores.IDPathFilter

+ ExpTime *stores.Cmp

+ Gateway *devices.Core

+ GroupID int64

+ GroupIDs []int64

+ HasOwner int64

+ Iccid string

+ IsOnline int64

+ LastLoginTime *def.TimeRange

+ NeedConfirmJobID int64

+ NeedConfirmVersion string

+ NetType int64

+ NotAreaID int64

+ NotAreaIDs []int64

+ NotGroupID int64

+ NotOtaJobID int64

+ NotVersion string

+ Position stores.Point

+ ProductCategoryID int64

+ ProductCategoryIDs []int64

+ ProductID string

+ ProductIDs []string

+ ProjectIDs []int64

+ Range int64

+ RatedPower *stores.Cmp

+ SharedType def.SelectType

+ Status def.DeviceStatus

+ Statuses []def.DeviceStatus

+ Tags map[string]string

+ TenantCode string

+ TenantCodes []string

+ UserID int64

+ UserIDs []int64

+ Versions []string

+ WithManufacturer bool

+ WithProduct bool

+ type DeviceInfoRepo struct

+ func NewDeviceInfoRepo(in any) *DeviceInfoRepo

+ func (d DeviceInfoRepo) CountByFilter(ctx context.Context, f DeviceFilter) (size int64, err error)

+ func (d DeviceInfoRepo) CountGroupByField(ctx context.Context, f DeviceFilter, columnName string) (map[string]int64, error)

+ func (d DeviceInfoRepo) Delete(ctx context.Context, id int64) error

+ func (d DeviceInfoRepo) FindByFilter(ctx context.Context, f DeviceFilter, page *stores.PageInfo) ([]*DmDeviceInfo, error)

+ func (d DeviceInfoRepo) FindCoreByFilter(ctx context.Context, f DeviceFilter, page *stores.PageInfo) ([]devices.Core, error)

+ func (d DeviceInfoRepo) FindOneByFilter(ctx context.Context, f DeviceFilter) (*DmDeviceInfo, error)

+ func (d DeviceInfoRepo) FindProductIDsByFilter(ctx context.Context, f DeviceFilter) ([]string, error)

+ func (d DeviceInfoRepo) Insert(ctx context.Context, data *DmDeviceInfo) error

+ func (d DeviceInfoRepo) MultiUpdate(ctx context.Context, devices []*devices.Core, info *DmDeviceInfo, ...) error

+ func (d DeviceInfoRepo) Update(ctx context.Context, data *DmDeviceInfo) error

+ func (d DeviceInfoRepo) UpdateOfflineStatus(ctx context.Context, f DeviceFilter) error

+ func (d DeviceInfoRepo) UpdateWithField(ctx context.Context, f DeviceFilter, updates map[string]any) error

+ type DeviceModuleVersionFilter struct

+ DeviceName string

+ ModuleCode string

+ ProductID string

+ type DeviceModuleVersionRepo struct

+ func NewDeviceModuleVersionRepo(in any) *DeviceModuleVersionRepo

+ func (p DeviceModuleVersionRepo) CountByFilter(ctx context.Context, f DeviceModuleVersionFilter) (size int64, err error)

+ func (p DeviceModuleVersionRepo) Delete(ctx context.Context, id int64) error

+ func (p DeviceModuleVersionRepo) DeleteByFilter(ctx context.Context, f DeviceModuleVersionFilter) error

+ func (p DeviceModuleVersionRepo) FindByFilter(ctx context.Context, f DeviceModuleVersionFilter, page *stores.PageInfo) ([]*DmDeviceModuleVersion, error)

+ func (p DeviceModuleVersionRepo) FindOne(ctx context.Context, id int64) (*DmDeviceModuleVersion, error)

+ func (p DeviceModuleVersionRepo) FindOneByFilter(ctx context.Context, f DeviceModuleVersionFilter) (*DmDeviceModuleVersion, error)

+ func (p DeviceModuleVersionRepo) Insert(ctx context.Context, data *DmDeviceModuleVersion) error

+ func (p DeviceModuleVersionRepo) MultiInsert(ctx context.Context, data []*DmDeviceModuleVersion) error

+ func (p DeviceModuleVersionRepo) Update(ctx context.Context, data *DmDeviceModuleVersion) error

+ type DeviceMsgCountFilter struct

+ type DeviceMsgCountRepo struct

+ func NewDeviceMsgCountRepo(in any) *DeviceMsgCountRepo

+ func (d DeviceMsgCountRepo) UpdateWithField(ctx context.Context, f DeviceMsgCountFilter, updates map[string]any) error

+ func (p DeviceMsgCountRepo) CountByFilter(ctx context.Context, f DeviceMsgCountFilter) (size int64, err error)

+ func (p DeviceMsgCountRepo) Delete(ctx context.Context, id int64) error

+ func (p DeviceMsgCountRepo) DeleteByFilter(ctx context.Context, f DeviceMsgCountFilter) error

+ func (p DeviceMsgCountRepo) FindByFilter(ctx context.Context, f DeviceMsgCountFilter, page *stores.PageInfo) ([]*DmDeviceMsgCount, error)

+ func (p DeviceMsgCountRepo) FindOne(ctx context.Context, id int64) (*DmDeviceMsgCount, error)

+ func (p DeviceMsgCountRepo) FindOneByFilter(ctx context.Context, f DeviceMsgCountFilter) (*DmDeviceMsgCount, error)

+ func (p DeviceMsgCountRepo) Insert(ctx context.Context, data *DmDeviceMsgCount) error

+ func (p DeviceMsgCountRepo) MultiInsert(ctx context.Context, data []*DmDeviceMsgCount) error

+ func (p DeviceMsgCountRepo) Update(ctx context.Context, data *DmDeviceMsgCount) error

+ type DeviceProfileFilter struct

+ Code string

+ Codes []string

+ Device devices.Core

+ Devices []*devices.Core

+ type DeviceProfileRepo struct

+ func NewDeviceProfileRepo(in any) *DeviceProfileRepo

+ func (d DeviceProfileRepo) UpdateWithField(ctx context.Context, f DeviceProfileFilter, updates map[string]any) error

+ func (p DeviceProfileRepo) CountByFilter(ctx context.Context, f DeviceProfileFilter) (size int64, err error)

+ func (p DeviceProfileRepo) Delete(ctx context.Context, id int64) error

+ func (p DeviceProfileRepo) DeleteByFilter(ctx context.Context, f DeviceProfileFilter) error

+ func (p DeviceProfileRepo) FindByFilter(ctx context.Context, f DeviceProfileFilter, page *stores.PageInfo) ([]*DmDeviceProfile, error)

+ func (p DeviceProfileRepo) FindOne(ctx context.Context, id int64) (*DmDeviceProfile, error)

+ func (p DeviceProfileRepo) FindOneByFilter(ctx context.Context, f DeviceProfileFilter) (*DmDeviceProfile, error)

+ func (p DeviceProfileRepo) Insert(ctx context.Context, data *DmDeviceProfile) error

+ func (p DeviceProfileRepo) MultiInsert(ctx context.Context, data []*DmDeviceProfile) error

+ func (p DeviceProfileRepo) Update(ctx context.Context, data *DmDeviceProfile) error

+ type DmCommonSchema struct

+ DeletedTime stores.DeletedTime

+ ID int64

+ func (m *DmCommonSchema) TableName() string

+ type DmDeviceInfo struct

+ Adcode string

+ Address string

+ AreaID stores.AreaID

+ AreaIDPath string

+ Cert string

+ DeletedTime stores.DeletedTime

+ DeviceAlias string

+ DeviceName string

+ DeviceType int64

+ Distributor stores.IDPathWithUpdate

+ ExpTime sql.NullTime

+ FirstBind sql.NullTime

+ FirstLogin sql.NullTime

+ HardInfo string

+ ID int64

+ Iccid sql.NullString

+ Imei string

+ IsEnable int64

+ IsOnline int64

+ LastLogin sql.NullTime

+ LogLevel int64

+ Mac string

+ MobileOperator int64

+ NeedConfirmJobID int64

+ NeedConfirmVersion string

+ Phone sql.NullString

+ Position stores.Point

+ ProductID string

+ ProductInfo *DmProductInfo

+ ProjectID stores.ProjectID

+ ProtocolConf map[string]string

+ RatedPower int64

+ Rssi int64

+ SchemaAlias map[string]string

+ Secret string

+ SoftInfo string

+ Status def.DeviceStatus

+ Tags map[string]string

+ TenantCode stores.TenantCode

+ UserID int64

+ Version string

+ func (m *DmDeviceInfo) TableName() string

+ func (u *DmDeviceInfo) AfterDelete(tx *gorm.DB) (err error)

+ func (u *DmDeviceInfo) AfterSave(tx *gorm.DB) (err error)

+ type DmDeviceModuleVersion struct

+ DeviceName string

+ ID int64

+ ModuleCode string

+ ProductID string

+ Version string

+ func (m *DmDeviceModuleVersion) TableName() string

+ type DmDeviceMsgCount struct

+ Date time.Time

+ ID int64

+ Num int64

+ Type deviceLog.MsgType

+ func (m *DmDeviceMsgCount) TableName() string

+ type DmDeviceProfile struct

+ Code string

+ DeletedTime stores.DeletedTime

+ DeviceName string

+ ID int64

+ Params string

+ ProductID string

+ TenantCode stores.TenantCode

+ func (m *DmDeviceProfile) TableName() string

+ type DmDeviceShadow struct

+ DataID string

+ DeviceName string

+ ID int64

+ ProductID string

+ UpdatedDeviceTime *time.Time

+ Value string

+ func ToShadowPo(info *shadow.Info) *DmDeviceShadow

+ func (m *DmDeviceShadow) TableName() string

+ type DmExample struct

+ ID int64

+ type DmGatewayDevice struct

+ DeletedTime stores.DeletedTime

+ Device *DmDeviceInfo

+ DeviceName string

+ Gateway *DmDeviceInfo

+ GatewayDeviceName string

+ GatewayProductID string

+ ID int64

+ ProductID string

+ TenantCode stores.TenantCode

+ func (m *DmGatewayDevice) TableName() string

+ type DmGroupDevice struct

+ AreaID stores.AreaID

+ DeletedTime stores.DeletedTime

+ Device *DmDeviceInfo

+ DeviceName string

+ GroupID int64

+ ID int64

+ ProductID string

+ ProductInfo *DmProductInfo

+ ProjectID stores.ProjectID

+ TenantCode stores.TenantCode

+ func (m *DmGroupDevice) TableName() string

+ type DmGroupInfo struct

+ AreaID stores.AreaID

+ DeletedTime stores.DeletedTime

+ Desc string

+ DeviceCount int64

+ ID int64

+ IDPath string

+ IsLeaf int64

+ Name string

+ ParentID int64

+ ProductID string

+ ProductInfo *DmProductInfo

+ ProjectID stores.ProjectID

+ Tags map[string]string

+ TenantCode stores.TenantCode

+ func (m *DmGroupInfo) TableName() string

+ type DmManufacturerInfo struct

+ DeletedTime stores.DeletedTime

+ Desc string

+ ID int64

+ Name string

+ Phone string

+ func (m *DmManufacturerInfo) TableName() string

+ type DmOtaFirmwareDevice struct

+ DeletedTime stores.DeletedTime

+ DestVersion string

+ Detail string

+ DeviceName string

+ Files []*DmOtaFirmwareFile

+ Firmware *DmOtaFirmwareInfo

+ FirmwareID int64

+ ID int64

+ Job *DmOtaFirmwareJob

+ JobID int64

+ LastFailureTime sql.NullTime

+ ProductID string

+ PushTime sql.NullTime

+ RetryCount int64

+ SrcVersion string

+ Status msgOta.DeviceStatus

+ Step int64

+ func (m *DmOtaFirmwareDevice) TableName() string

+ type DmOtaFirmwareFile struct

+ FileMd5 string

+ FilePath string

+ FirmwareID int64

+ ID int64

+ Name string

+ Signature string

+ Size int64

+ func (m *DmOtaFirmwareFile) TableName() string

+ type DmOtaFirmwareInfo struct

+ DeletedTime stores.DeletedTime

+ Desc string

+ Extra string

+ Files []*DmOtaFirmwareFile

+ ID int64

+ IsDiff int64

+ IsNeedToVerify int64

+ Jobs []*DmOtaFirmwareJob

+ ModuleCode string

+ Name string

+ ProductID string

+ SignMethod string

+ SrcVersion string

+ Status int64

+ TotalSize int64

+ Version string

+ func (m *DmOtaFirmwareInfo) TableName() string

+ type DmOtaFirmwareJob struct

+ Dynamic DmOtaFirmwareJobDynamic

+ Files []*DmOtaFirmwareFile

+ Firmware *DmOtaFirmwareInfo

+ FirmwareID int64

+ ID int64

+ IsNeedConfirm int64

+ IsNeedPush int64

+ IsOverwriteMode int64

+ MaximumPerMinute int64

+ ProductID string

+ RetryCount int64

+ RetryInterval int64

+ SrcVersions []string

+ Static DmOtaFirmwareJobStatic

+ Status int64

+ TargetID int64

+ TargetSelection int64

+ TimeoutInMinutes int64

+ Type int64

+ UpgradeType msgOta.UpgradeType

+ func (m *DmOtaFirmwareJob) TableName() string

+ type DmOtaFirmwareJobDynamic struct

+ DynamicMode int64

+ type DmOtaFirmwareJobStatic struct

+ ScheduleFinishTime int64

+ ScheduleTime int64

+ TargetDeviceNames []string

+ type DmOtaModuleInfo struct

+ Code string

+ DeletedTime stores.DeletedTime

+ Desc string

+ ID int64

+ Name string

+ ProductID string

+ func (m *DmOtaModuleInfo) TableName() string

+ type DmProductCategory struct

+ DeletedTime stores.DeletedTime

+ Desc string

+ DeviceCount int64

+ HeadImg string

+ ID int64

+ IDPath string

+ IsLeaf int64

+ Name string

+ ParentID int64

+ func (m *DmProductCategory) TableName() string

+ type DmProductCategorySchema struct

+ DeletedTime stores.DeletedTime

+ ID int64

+ Identifier string

+ ProductCategoryID int64

+ func (m *DmProductCategorySchema) TableName() string

+ type DmProductCustom struct

+ CustomTopics []*productCustom.CustomTopic

+ DeletedTime stores.DeletedTime

+ ID int64

+ LoginAuthScript string

+ ProductID string

+ ProductInfo *DmProductInfo

+ ScriptLang int64

+ TransformScript string

+ func (m *DmProductCustom) TableName() string

+ type DmProductID struct

+ ID int64

+ func (m *DmProductID) TableName() string

+ type DmProductInfo struct

+ AuthMode int64

+ AutoRegister int64

+ Category *DmProductCategory

+ CategoryID int64

+ CustomUi map[string]*ProductCustomUi

+ DeletedTime stores.DeletedTime

+ Desc string

+ DeviceType int64

+ ID int64

+ NetType int64

+ ProductID string

+ ProductImg string

+ ProductName string

+ ProductType int64

+ Protocol *DmProtocolInfo

+ ProtocolCode string

+ ProtocolConf map[string]string

+ SceneMode string

+ Secret string

+ Status devices.ProductStatus

+ Tags map[string]string

+ TrialTime int64

+ func (m *DmProductInfo) TableName() string

+ type DmProductRemoteConfig struct

+ Content string

+ DeletedTime stores.DeletedTime

+ ID int64

+ ProductID string

+ ProductInfo *DmProductInfo

+ func (m *DmProductRemoteConfig) TableName() string

+ type DmProductSchema struct

+ DeletedTime stores.DeletedTime

+ ID int64

+ ProductID string

+ ProductInfo *DmProductInfo

+ func ToActionPo(productID string, in *schema.Action) *DmProductSchema

+ func ToEventPo(productID string, in *schema.Event) *DmProductSchema

+ func ToPropertyPo(productID string, in *schema.Property) *DmProductSchema

+ func (m *DmProductSchema) TableName() string

+ type DmProtocolInfo struct

+ Code string

+ ConfigFields protocol.ConfigFields

+ ConfigInfos protocol.ConfigInfos

+ DeletedTime stores.DeletedTime

+ Desc string

+ Endpoints []string

+ EtcdKey string

+ ID int64

+ Name string

+ TransProtocol string

+ func (m *DmProtocolInfo) TableName() string

+ type DmSchemaCore struct

+ Affordance string

+ ControlMode int64

+ Desc string

+ ExtendConfig string

+ FuncGroup int64

+ Identifier string

+ IsCanSceneLinkage int64

+ IsHistory int64

+ Name string

+ Order int64

+ Required int64

+ Tag schema.Tag

+ Type int64

+ UserPerm int64

+ type DmUserDeviceCollect struct

+ DeletedTime stores.DeletedTime

+ DeviceName string

+ ID int64

+ ProductID string

+ ProjectID stores.ProjectID

+ TenantCode stores.TenantCode

+ UserID int64

+ func (m *DmUserDeviceCollect) TableName() string

+ type DmUserDeviceShare struct

+ AccessPerm map[string]*SharePerm

+ AuthType def.AuthType

+ DeletedTime stores.DeletedTime

+ DeviceName string

+ ExpTime sql.NullTime

+ ID int64

+ ProductID string

+ ProjectID int64

+ SchemaPerm map[string]*SharePerm

+ SharedUserAccount string

+ SharedUserID int64

+ TenantCode stores.TenantCode

+ func (m *DmUserDeviceShare) TableName() string

+ type ExampleFilter struct

+ type ExampleRepo struct

+ func NewExampleRepo(in any) *ExampleRepo

+ func (d ExampleRepo) UpdateWithField(ctx context.Context, f ExampleFilter, updates map[string]any) error

+ func (p ExampleRepo) CountByFilter(ctx context.Context, f ExampleFilter) (size int64, err error)

+ func (p ExampleRepo) Delete(ctx context.Context, id int64) error

+ func (p ExampleRepo) DeleteByFilter(ctx context.Context, f ExampleFilter) error

+ func (p ExampleRepo) FindByFilter(ctx context.Context, f ExampleFilter, page *stores.PageInfo) ([]*DmExample, error)

+ func (p ExampleRepo) FindOne(ctx context.Context, id int64) (*DmExample, error)

+ func (p ExampleRepo) FindOneByFilter(ctx context.Context, f ExampleFilter) (*DmExample, error)

+ func (p ExampleRepo) Insert(ctx context.Context, data *DmExample) error

+ func (p ExampleRepo) MultiInsert(ctx context.Context, data []*DmExample) error

+ func (p ExampleRepo) Update(ctx context.Context, data *DmExample) error

+ type GatewayDeviceFilter struct

+ Gateway *devices.Core

+ SubDevice *devices.Core

+ SubDevices []*devices.Core

+ type GatewayDeviceRepo struct

+ func NewGatewayDeviceRepo(in any) *GatewayDeviceRepo

+ func (g GatewayDeviceRepo) CountByFilter(ctx context.Context, f GatewayDeviceFilter) (size int64, err error)

+ func (g GatewayDeviceRepo) FindByFilter(ctx context.Context, f GatewayDeviceFilter, page *stores.PageInfo) ([]*DmGatewayDevice, error)

+ func (m GatewayDeviceRepo) DeleteDevAll(ctx context.Context, dev devices.Core) error

+ func (m GatewayDeviceRepo) MultiDelete(ctx context.Context, gateway *devices.Core, subDevice []*devices.Core) error

+ func (m GatewayDeviceRepo) MultiInsert(ctx context.Context, gateway *devices.Core, subDevice []*devices.Core) error

+ func (p GatewayDeviceRepo) FindOneByFilter(ctx context.Context, f GatewayDeviceFilter) (*DmGatewayDevice, error)

+ type GroupDeviceFilter struct

+ DeviceName string

+ GroupIDs []int64

+ ProductID string

+ Versions []string

+ WithDevice bool

+ WithProduct bool

+ type GroupDeviceRepo struct

+ func NewGroupDeviceRepo(in any) *GroupDeviceRepo

+ func (m GroupDeviceRepo) MultiDelete(ctx context.Context, groupID int64, data []*devices.Core) error

+ func (m GroupDeviceRepo) MultiInsert(ctx context.Context, data []*DmGroupDevice) error

+ func (p GroupDeviceRepo) CountByFilter(ctx context.Context, f GroupDeviceFilter) (size int64, err error)

+ func (p GroupDeviceRepo) DeleteByFilter(ctx context.Context, f GroupDeviceFilter) error

+ func (p GroupDeviceRepo) FindByFilter(ctx context.Context, f GroupDeviceFilter, page *stores.PageInfo) ([]*DmGroupDevice, error)

+ func (p GroupDeviceRepo) FindOneByFilter(ctx context.Context, f GroupDeviceFilter) (*DmGroupDevice, error)

+ func (p GroupDeviceRepo) MultiUpdate(ctx context.Context, groupID int64, devices []*DmGroupDevice) error

+ type GroupInfoFilter struct

+ AreaID int64

+ ID int64

+ IDPath string

+ Name string

+ Names []string

+ ParentID int64

+ Tags map[string]string

+ WithProduct bool

+ type GroupInfoRepo struct

+ func NewGroupInfoRepo(in any) *GroupInfoRepo

+ func (d GroupInfoRepo) UpdateWithField(ctx context.Context, f GroupInfoFilter, updates map[string]any) error

+ func (g GroupInfoRepo) DeleteByFilter(ctx context.Context, f GroupInfoFilter) error

+ func (g GroupInfoRepo) FindOneByFilter(ctx context.Context, f GroupInfoFilter) (*DmGroupInfo, error)

+ func (g GroupInfoRepo) Insert(ctx context.Context, data *DmGroupInfo) error

+ func (g GroupInfoRepo) Update(ctx context.Context, data *DmGroupInfo) error

+ func (g GroupInfoRepo) UpdateGroupDeviceCount(ctx context.Context, id int64) error

+ func (p GroupInfoRepo) CountByFilter(ctx context.Context, f GroupInfoFilter) (size int64, err error)

+ func (p GroupInfoRepo) Delete(ctx context.Context, id int64) error

+ func (p GroupInfoRepo) FindByFilter(ctx context.Context, f GroupInfoFilter, page *stores.PageInfo) ([]*DmGroupInfo, error)

+ func (p GroupInfoRepo) FindOne(ctx context.Context, id int64) (*DmGroupInfo, error)

+ type OtaFirmwareDeviceFilter struct

+ DestVersion string

+ DeviceName string

+ DeviceNames []string

+ FirmwareID int64

+ IDs []int64

+ IsOnline int64

+ JobID int64

+ LastFailureTime *stores.Cmp

+ LastLogin time.Time

+ ProductID string

+ PushTime *stores.Cmp

+ RetryCount *stores.Cmp

+ SrcVersion string

+ Statues []int64

+ WithFiles bool

+ WithFirmware bool

+ WithJob bool

+ WithScheduleTime bool

+ type OtaFirmwareDeviceRepo struct

+ func NewOtaFirmwareDeviceRepo(in any) *OtaFirmwareDeviceRepo

+ func (p OtaFirmwareDeviceRepo) BatchUpdateField(ctx context.Context, f OtaFirmwareDeviceFilter, ...) error

+ func (p OtaFirmwareDeviceRepo) CountByFilter(ctx context.Context, f OtaFirmwareDeviceFilter) (size int64, err error)

+ func (p OtaFirmwareDeviceRepo) Delete(ctx context.Context, id int64) error

+ func (p OtaFirmwareDeviceRepo) DeleteByFilter(ctx context.Context, f OtaFirmwareDeviceFilter) error

+ func (p OtaFirmwareDeviceRepo) FindByFilter(ctx context.Context, f OtaFirmwareDeviceFilter, page *stores.PageInfo) ([]*DmOtaFirmwareDevice, error)

+ func (p OtaFirmwareDeviceRepo) FindOne(ctx context.Context, id int64) (*DmOtaFirmwareDevice, error)

+ func (p OtaFirmwareDeviceRepo) FindOneByFilter(ctx context.Context, f OtaFirmwareDeviceFilter) (*DmOtaFirmwareDevice, error)

+ func (p OtaFirmwareDeviceRepo) Insert(ctx context.Context, data *DmOtaFirmwareDevice) error

+ func (p OtaFirmwareDeviceRepo) MultiInsert(ctx context.Context, data []*DmOtaFirmwareDevice) error

+ func (p OtaFirmwareDeviceRepo) Update(ctx context.Context, data *DmOtaFirmwareDevice) error

+ func (p OtaFirmwareDeviceRepo) UpdateStatusByFilter(ctx context.Context, f OtaFirmwareDeviceFilter, status int64, detail string) error

+ type OtaFirmwareFileFilter struct

+ FirmwareID int64

+ ID int64

+ Size *int64

+ type OtaFirmwareFileRepo struct

+ func NewOtaFirmwareFileRepo(in any) *OtaFirmwareFileRepo

+ func (g OtaFirmwareFileRepo) Delete(ctx context.Context, id int64) error

+ func (g OtaFirmwareFileRepo) DeleteByFilter(ctx context.Context, f OtaFirmwareFileFilter) error

+ func (g OtaFirmwareFileRepo) FindOne(ctx context.Context, id int64) (*DmOtaFirmwareFile, error)

+ func (g OtaFirmwareFileRepo) FindOneByFilter(ctx context.Context, f OtaFirmwareFileFilter) (*DmOtaFirmwareFile, error)

+ func (g OtaFirmwareFileRepo) Insert(ctx context.Context, data *DmOtaFirmwareFile) error

+ func (g OtaFirmwareFileRepo) Update(ctx context.Context, data *DmOtaFirmwareFile) error

+ func (m OtaFirmwareFileRepo) MultiInsert(ctx context.Context, data []*DmOtaFirmwareFile) error

+ func (p OtaFirmwareFileRepo) CountByFilter(ctx context.Context, f OtaFirmwareFileFilter) (size int64, err error)

+ func (p OtaFirmwareFileRepo) FindByFilter(ctx context.Context, f OtaFirmwareFileFilter, page *stores.PageInfo) ([]*DmOtaFirmwareFile, error)

+ type OtaFirmwareInfoFilter struct

+ ID int64

+ Name string

+ ProductID string

+ Version string

+ WithFiles bool

+ WithJobs bool

+ WithProduct bool

+ type OtaFirmwareInfoRepo struct

+ func NewOtaFirmwareInfoRepo(in any) *OtaFirmwareInfoRepo

+ func (g OtaFirmwareInfoRepo) Delete(ctx context.Context, id int64) error

+ func (g OtaFirmwareInfoRepo) DeleteByFilter(ctx context.Context, f OtaFirmwareInfoFilter) error

+ func (g OtaFirmwareInfoRepo) FindOne(ctx context.Context, id int64) (*DmOtaFirmwareInfo, error)

+ func (g OtaFirmwareInfoRepo) FindOneByFilter(ctx context.Context, f OtaFirmwareInfoFilter) (*DmOtaFirmwareInfo, error)

+ func (g OtaFirmwareInfoRepo) Insert(ctx context.Context, data *DmOtaFirmwareInfo) error

+ func (g OtaFirmwareInfoRepo) Update(ctx context.Context, data *DmOtaFirmwareInfo) error

+ func (m OtaFirmwareInfoRepo) MultiInsert(ctx context.Context, data []*DmOtaFirmwareInfo) error

+ func (p OtaFirmwareInfoRepo) CountByFilter(ctx context.Context, f OtaFirmwareInfoFilter) (size int64, err error)

+ func (p OtaFirmwareInfoRepo) FindByFilter(ctx context.Context, f OtaFirmwareInfoFilter, page *stores.PageInfo) ([]*DmOtaFirmwareInfo, error)

+ type OtaJobFilter struct

+ DeviceName string

+ FirmwareID int64

+ ProductID string

+ Statues []int64

+ UpgradeType int64

+ WithFiles bool

+ WithFirmware bool

+ type OtaJobRepo struct

+ func NewOtaJobRepo(in any) *OtaJobRepo

+ func (p OtaJobRepo) CountByFilter(ctx context.Context, f OtaJobFilter) (size int64, err error)

+ func (p OtaJobRepo) Delete(ctx context.Context, id int64) error

+ func (p OtaJobRepo) DeleteByFilter(ctx context.Context, f OtaJobFilter) error

+ func (p OtaJobRepo) FindByFilter(ctx context.Context, f OtaJobFilter, page *stores.PageInfo) ([]*DmOtaFirmwareJob, error)

+ func (p OtaJobRepo) FindOne(ctx context.Context, id int64) (*DmOtaFirmwareJob, error)

+ func (p OtaJobRepo) FindOneByFilter(ctx context.Context, f OtaJobFilter) (*DmOtaFirmwareJob, error)

+ func (p OtaJobRepo) Insert(ctx context.Context, data *DmOtaFirmwareJob) error

+ func (p OtaJobRepo) MultiInsert(ctx context.Context, data []*DmOtaFirmwareJob) error

+ func (p OtaJobRepo) Update(ctx context.Context, data *DmOtaFirmwareJob) error

+ type OtaModuleInfoFilter struct

+ Code string

+ ID int64

+ Name string

+ ProductID string

+ type OtaModuleInfoRepo struct

+ func NewOtaModuleInfoRepo(in any) *OtaModuleInfoRepo

+ func (p OtaModuleInfoRepo) CountByFilter(ctx context.Context, f OtaModuleInfoFilter) (size int64, err error)

+ func (p OtaModuleInfoRepo) Delete(ctx context.Context, id int64) error

+ func (p OtaModuleInfoRepo) DeleteByFilter(ctx context.Context, f OtaModuleInfoFilter) error

+ func (p OtaModuleInfoRepo) FindByFilter(ctx context.Context, f OtaModuleInfoFilter, page *stores.PageInfo) ([]*DmOtaModuleInfo, error)

+ func (p OtaModuleInfoRepo) FindOne(ctx context.Context, id int64) (*DmOtaModuleInfo, error)

+ func (p OtaModuleInfoRepo) FindOneByFilter(ctx context.Context, f OtaModuleInfoFilter) (*DmOtaModuleInfo, error)

+ func (p OtaModuleInfoRepo) Insert(ctx context.Context, data *DmOtaModuleInfo) error

+ func (p OtaModuleInfoRepo) MultiInsert(ctx context.Context, data []*DmOtaModuleInfo) error

+ func (p OtaModuleInfoRepo) Update(ctx context.Context, data *DmOtaModuleInfo) error

+ type ProductCategoryFilter struct

+ ID int64

+ IDPath string

+ IDs []int64

+ Name string

+ ParentID int64

+ ProductIDs []string

+ type ProductCategoryRepo struct

+ func NewProductCategoryRepo(in any) *ProductCategoryRepo

+ func (d ProductCategoryRepo) UpdateWithField(ctx context.Context, f ProductCategoryFilter, updates map[string]any) error

+ func (p ProductCategoryRepo) CountByFilter(ctx context.Context, f ProductCategoryFilter) (size int64, err error)

+ func (p ProductCategoryRepo) Delete(ctx context.Context, id int64) error

+ func (p ProductCategoryRepo) DeleteByFilter(ctx context.Context, f ProductCategoryFilter) error

+ func (p ProductCategoryRepo) FindByFilter(ctx context.Context, f ProductCategoryFilter, page *stores.PageInfo) ([]*DmProductCategory, error)

+ func (p ProductCategoryRepo) FindOne(ctx context.Context, id int64) (*DmProductCategory, error)

+ func (p ProductCategoryRepo) FindOneByFilter(ctx context.Context, f ProductCategoryFilter) (*DmProductCategory, error)

+ func (p ProductCategoryRepo) Insert(ctx context.Context, data *DmProductCategory) error

+ func (p ProductCategoryRepo) MultiInsert(ctx context.Context, data []*DmProductCategory) error

+ func (p ProductCategoryRepo) Update(ctx context.Context, data *DmProductCategory) error

+ type ProductCategorySchemaFilter struct

+ Identifiers []string

+ ProductCategoryID int64

+ ProductCategoryIDs []int64

+ type ProductCategorySchemaRepo struct

+ func NewProductCategorySchemaRepo(in any) *ProductCategorySchemaRepo

+ func (p ProductCategorySchemaRepo) CountByFilter(ctx context.Context, f ProductCategorySchemaFilter) (size int64, err error)

+ func (p ProductCategorySchemaRepo) Delete(ctx context.Context, id int64) error

+ func (p ProductCategorySchemaRepo) DeleteByFilter(ctx context.Context, f ProductCategorySchemaFilter) error

+ func (p ProductCategorySchemaRepo) FindByFilter(ctx context.Context, f ProductCategorySchemaFilter, page *stores.PageInfo) ([]*DmProductCategorySchema, error)

+ func (p ProductCategorySchemaRepo) FindOne(ctx context.Context, id int64) (*DmProductCategorySchema, error)

+ func (p ProductCategorySchemaRepo) FindOneByFilter(ctx context.Context, f ProductCategorySchemaFilter) (*DmProductCategorySchema, error)

+ func (p ProductCategorySchemaRepo) Insert(ctx context.Context, data *DmProductCategorySchema) error

+ func (p ProductCategorySchemaRepo) MultiInsert(ctx context.Context, data []*DmProductCategorySchema) error

+ func (p ProductCategorySchemaRepo) MultiUpdate(ctx context.Context, productCategoryID int64, identifiers []string) error

+ func (p ProductCategorySchemaRepo) Update(ctx context.Context, data *DmProductCategorySchema) error

+ type ProductCustomRepo struct

+ func NewProductCustomRepo(in any) *ProductCustomRepo

+ func (p ProductCustomRepo) FindOneByProductID(ctx context.Context, productID string) (*DmProductCustom, error)

+ func (p ProductCustomRepo) Insert(ctx context.Context, data *DmProductCustom) error

+ func (p ProductCustomRepo) Update(ctx context.Context, data *DmProductCustom) error

+ type ProductCustomUi struct

+ Path string

+ Type string

+ Version int64

+ type ProductFilter struct

+ AreaID int64

+ CategoryIDs []int64

+ DeviceType int64

+ DeviceTypes []int64

+ NetType int64

+ ProductIDs []string

+ ProductName string

+ ProductNames []string

+ ProtocolCode string

+ ProtocolConf map[string]string

+ SceneMode string

+ SceneModes []string

+ Status devices.ProductStatus

+ Statuses []devices.ProductStatus

+ Tags map[string]string

+ WithCategory bool

+ WithProtocol bool

+ type ProductIDFilter struct

+ type ProductIDRepo struct

+ func NewProductIDRepo(in any) *ProductIDRepo

+ func (d ProductIDRepo) UpdateWithField(ctx context.Context, f ProductIDFilter, updates map[string]any) error

+ func (p ProductIDRepo) CountByFilter(ctx context.Context, f ProductIDFilter) (size int64, err error)

+ func (p ProductIDRepo) Delete(ctx context.Context, id int64) error

+ func (p ProductIDRepo) DeleteByFilter(ctx context.Context, f ProductIDFilter) error

+ func (p ProductIDRepo) FindByFilter(ctx context.Context, f ProductIDFilter, page *stores.PageInfo) ([]*DmProductID, error)

+ func (p ProductIDRepo) FindOne(ctx context.Context, id int64) (*DmProductID, error)

+ func (p ProductIDRepo) FindOneByFilter(ctx context.Context, f ProductIDFilter) (*DmProductID, error)

+ func (p ProductIDRepo) GenID(ctx context.Context) (int64, error)

+ func (p ProductIDRepo) Insert(ctx context.Context, data *DmProductID) error

+ func (p ProductIDRepo) MultiInsert(ctx context.Context, data []*DmProductID) error

+ func (p ProductIDRepo) Update(ctx context.Context, data *DmProductID) error

+ type ProductInfoRepo struct

+ func NewProductInfoRepo(in any) *ProductInfoRepo

+ func (p ProductInfoRepo) CountByFilter(ctx context.Context, f ProductFilter) (size int64, err error)

+ func (p ProductInfoRepo) DeleteByFilter(ctx context.Context, f ProductFilter) error

+ func (p ProductInfoRepo) FindByFilter(ctx context.Context, f ProductFilter, page *stores.PageInfo) ([]*DmProductInfo, error)

+ func (p ProductInfoRepo) FindOneByFilter(ctx context.Context, f ProductFilter) (*DmProductInfo, error)

+ func (p ProductInfoRepo) Insert(ctx context.Context, data *DmProductInfo) error

+ func (p ProductInfoRepo) Update(ctx context.Context, data *DmProductInfo) error

+ type ProductRemoteConfigRepo struct

+ func NewProductRemoteConfigRepo(in any) *ProductRemoteConfigRepo

+ func (p ProductRemoteConfigRepo) CountByFilter(ctx context.Context, f RemoteConfigFilter) (size int64, err error)

+ func (p ProductRemoteConfigRepo) DeleteByFilter(ctx context.Context, f RemoteConfigFilter) error

+ func (p ProductRemoteConfigRepo) FindByFilter(ctx context.Context, f RemoteConfigFilter, page *stores.PageInfo) ([]*DmProductRemoteConfig, error)

+ func (p ProductRemoteConfigRepo) FindOneByFilter(ctx context.Context, f RemoteConfigFilter) (*DmProductRemoteConfig, error)

+ func (p ProductRemoteConfigRepo) Insert(ctx context.Context, data *DmProductRemoteConfig) error

+ func (p ProductRemoteConfigRepo) Update(ctx context.Context, data *DmProductRemoteConfig) error

+ type ProductSchemaFilter struct

+ ControlMode int64

+ FuncGroup int64

+ ID int64

+ Identifiers []string

+ IsCanSceneLinkage int64

+ Name string

+ ProductID string

+ ProductIDs []string

+ ProductSceneMode string

+ PropertyMode string

+ Tag schema.Tag

+ Tags []schema.Tag

+ Type int64

+ Types []int64

+ UserPerm int64

+ type ProductSchemaRepo struct

+ func NewProductSchemaRepo(in any) *ProductSchemaRepo

+ func (p ProductSchemaRepo) CountByFilter(ctx context.Context, f ProductSchemaFilter) (size int64, err error)

+ func (p ProductSchemaRepo) DeleteByFilter(ctx context.Context, f ProductSchemaFilter) error

+ func (p ProductSchemaRepo) FindByFilter(ctx context.Context, f ProductSchemaFilter, page *stores.PageInfo) ([]*DmProductSchema, error)

+ func (p ProductSchemaRepo) FindOneByFilter(ctx context.Context, f ProductSchemaFilter) (*DmProductSchema, error)

+ func (p ProductSchemaRepo) FindProductIDByFilter(ctx context.Context, f ProductSchemaFilter) ([]string, error)

+ func (p ProductSchemaRepo) Insert(ctx context.Context, data *DmProductSchema) error

+ func (p ProductSchemaRepo) MultiInsert(ctx context.Context, data []*DmProductSchema) error

+ func (p ProductSchemaRepo) MultiUpdate(ctx context.Context, productID string, schemaInfo *schema.Model) error

+ func (p ProductSchemaRepo) Update(ctx context.Context, data *DmProductSchema) error

+ func (p ProductSchemaRepo) UpdateTag(ctx context.Context, productIDs []string, identifiers []string, ...) error

+ func (p ProductSchemaRepo) UpdateWithCommon(ctx context.Context, common *DmCommonSchema) error

+ type ProtocolInfoFilter struct

+ Code string

+ ID int64

+ Name string

+ NotCodes []string

+ TransProtocol string

+ type ProtocolInfoRepo struct

+ func NewProtocolInfoRepo(in any) *ProtocolInfoRepo

+ func (p ProtocolInfoRepo) CountByFilter(ctx context.Context, f ProtocolInfoFilter) (size int64, err error)

+ func (p ProtocolInfoRepo) Delete(ctx context.Context, id int64) error

+ func (p ProtocolInfoRepo) DeleteByFilter(ctx context.Context, f ProtocolInfoFilter) error

+ func (p ProtocolInfoRepo) FindByFilter(ctx context.Context, f ProtocolInfoFilter, page *stores.PageInfo) ([]*DmProtocolInfo, error)

+ func (p ProtocolInfoRepo) FindOne(ctx context.Context, id int64) (*DmProtocolInfo, error)

+ func (p ProtocolInfoRepo) FindOneByFilter(ctx context.Context, f ProtocolInfoFilter) (*DmProtocolInfo, error)

+ func (p ProtocolInfoRepo) Insert(ctx context.Context, data *DmProtocolInfo) error

+ func (p ProtocolInfoRepo) MultiInsert(ctx context.Context, data []*DmProtocolInfo) error

+ func (p ProtocolInfoRepo) Update(ctx context.Context, data *DmProtocolInfo) error

+ type RemoteConfigFilter struct

+ ProductID string

+ type ShadowRepo struct

+ func (p *ShadowRepo) FindByFilter(ctx context.Context, f shadow.Filter) ([]*shadow.Info, error)

+ func (p *ShadowRepo) MultiDelete(ctx context.Context, f shadow.Filter) error

+ func (p *ShadowRepo) MultiUpdate(ctx context.Context, data []*shadow.Info) error

+ type SharePerm struct

+ Perm int64

+ type UserDeviceCollectFilter struct

+ Cores []*devices.Core

+ UserID int64

+ type UserDeviceCollectRepo struct

+ func NewUserDeviceCollectRepo(in any) *UserDeviceCollectRepo

+ func (d UserDeviceCollectRepo) UpdateWithField(ctx context.Context, f UserDeviceCollectFilter, updates map[string]any) error

+ func (p UserDeviceCollectRepo) CountByFilter(ctx context.Context, f UserDeviceCollectFilter) (size int64, err error)

+ func (p UserDeviceCollectRepo) Delete(ctx context.Context, id int64) error

+ func (p UserDeviceCollectRepo) DeleteByFilter(ctx context.Context, f UserDeviceCollectFilter) error

+ func (p UserDeviceCollectRepo) FindByFilter(ctx context.Context, f UserDeviceCollectFilter, page *stores.PageInfo) ([]*DmUserDeviceCollect, error)

+ func (p UserDeviceCollectRepo) FindOne(ctx context.Context, id int64) (*DmUserDeviceCollect, error)

+ func (p UserDeviceCollectRepo) FindOneByFilter(ctx context.Context, f UserDeviceCollectFilter) (*DmUserDeviceCollect, error)

+ func (p UserDeviceCollectRepo) Insert(ctx context.Context, data *DmUserDeviceCollect) error

+ func (p UserDeviceCollectRepo) MultiInsert(ctx context.Context, data []*DmUserDeviceCollect) error

+ func (p UserDeviceCollectRepo) Update(ctx context.Context, data *DmUserDeviceCollect) error

+ type UserDeviceShareFilter struct

+ DeviceName string

+ Devices []*devices.Core

+ ExpTime *stores.Cmp

+ ID int64

+ IDs []int64

+ ProductID string

+ ProjectID int64

+ SharedUserID int64

+ SharedUserIDs []int64

+ type UserDeviceShareRepo struct

+ func NewUserDeviceShareRepo(in any) *UserDeviceShareRepo

+ func (d UserDeviceShareRepo) UpdateWithField(ctx context.Context, f UserDeviceShareFilter, updates map[string]any) error

+ func (p UserDeviceShareRepo) CountByFilter(ctx context.Context, f UserDeviceShareFilter) (size int64, err error)

+ func (p UserDeviceShareRepo) Delete(ctx context.Context, id int64) error

+ func (p UserDeviceShareRepo) DeleteByFilter(ctx context.Context, f UserDeviceShareFilter) error

+ func (p UserDeviceShareRepo) FindByFilter(ctx context.Context, f UserDeviceShareFilter, page *stores.PageInfo) ([]*DmUserDeviceShare, error)

+ func (p UserDeviceShareRepo) FindOne(ctx context.Context, id int64) (*DmUserDeviceShare, error)

+ func (p UserDeviceShareRepo) FindOneByFilter(ctx context.Context, f UserDeviceShareFilter) (*DmUserDeviceShare, error)

+ func (p UserDeviceShareRepo) Insert(ctx context.Context, data *DmUserDeviceShare) error

+ func (p UserDeviceShareRepo) MultiInsert(ctx context.Context, data []*DmUserDeviceShare) error

+ func (p UserDeviceShareRepo) Update(ctx context.Context, data *DmUserDeviceShare) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL