logic

Documentation

Index

• func Auth(ctx context.Context, svcCtx *svc.ServiceContext, in devices.Core) (devices.Auth, error)
• func BindToDeviceCoreDos(in []*dm.DeviceGatewayBindDevice) (ret []*devices.Core)
• func BindToDeviceCoreEvents(in []*dm.DeviceGatewayBindDevice) (ret []*events.DeviceCore)
• func FillAreaDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, areaIDPaths ...string) error
• func FillAreaGroupCount(ctx context.Context, svcCtx *svc.ServiceContext, areaID int64) error
• func FillProjectDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, projectIDs ...int64) error
• func SchemaAccess(ctx context.Context, svcCtx *svc.ServiceContext, authType def.AuthType, ...) (outParam map[string]any, err error)
• func ToCustomTopicDo(info *dm.CustomTopic) *productCustom.CustomTopic
• func ToCustomTopicPb(info *productCustom.CustomTopic) *dm.CustomTopic
• func ToCustomTopicsDo(info []*dm.CustomTopic) (ret []*productCustom.CustomTopic)
• func ToCustomTopicsPb(info []*productCustom.CustomTopic) (ret []*dm.CustomTopic)
• func ToDeviceCoreDo(core *dm.DeviceCore) *devices.Core
• func ToDeviceCoreDos(in []*dm.DeviceCore) (ret []*devices.Core)
• func ToDeviceCoreEvents(in []*dm.DeviceCore) (ret []*events.DeviceCore)
• func ToDeviceCores(in []*dm.DeviceCore) []*devices.Core
• func ToDeviceInfo(ctx context.Context, svcCtx *svc.ServiceContext, in *relationDB.DmDeviceInfo) *dm.DeviceInfo
• func ToDmPoint(point *stores.Point) *dm.Point
• func ToGatewayDevice(gateway *devices.Core, subDevice []*devices.Core) (ret []*relationDB.DmGatewayDevice)
• func ToGatewayPayload(status def.GatewayStatus, in []*devices.Core) *msgGateway.GatewayPayload
• func ToPageInfo(info *dm.PageInfo) *stores.PageInfo
• func ToProductCategoryPb(ctx context.Context, svcCtx *svc.ServiceContext, ...) *dm.ProductCategory
• func ToProductInfo(ctx context.Context, svcCtx *svc.ServiceContext, pi *relationDB.DmProductInfo) *dm.ProductInfo
• func ToProductSchemaPo(info *dm.ProductSchemaInfo) *relationDB.DmProductSchema
• func ToProductSchemaRpc(info *relationDB.DmProductSchema) *dm.ProductSchemaInfo
• func ToProtocolConfigFieldsPb(in protocol.ConfigFields) (ret []*dm.ProtocolConfigField)
• func ToProtocolConfigFieldsPo(in []*dm.ProtocolConfigField) (ret protocol.ConfigFields)
• func ToProtocolConfigInfosPb(in protocol.ConfigInfos) (ret []*dm.ProtocolConfigInfo)
• func ToProtocolConfigInfosPo(in []*dm.ProtocolConfigInfo) (ret protocol.ConfigInfos)
• func ToProtocolInfoPb(in *relationDB.DmProtocolInfo) *dm.ProtocolInfo
• func ToProtocolInfoPo(in *dm.ProtocolInfo) *relationDB.DmProtocolInfo
• func ToStorePoint(point *dm.Point) stores.Point
• func ToTimeRange(in *dm.TimeRange) *def.TimeRange

Functions

func Auth

func Auth(ctx context.Context, svcCtx *svc.ServiceContext, in devices.Core) (devices.Auth, error)

func BindToDeviceCoreDos

func BindToDeviceCoreDos(in []*dm.DeviceGatewayBindDevice) (ret []*devices.Core)

func BindToDeviceCoreEvents

func BindToDeviceCoreEvents(in []*dm.DeviceGatewayBindDevice) (ret []*events.DeviceCore)

func FillAreaDeviceCount

func FillAreaDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, areaIDPaths ...string) error

func FillAreaGroupCount

func FillAreaGroupCount(ctx context.Context, svcCtx *svc.ServiceContext, areaID int64) error

func FillProjectDeviceCount

func FillProjectDeviceCount(ctx context.Context, svcCtx *svc.ServiceContext, projectIDs ...int64) error

func SchemaAccess

func SchemaAccess(ctx context.Context, svcCtx *svc.ServiceContext, authType def.AuthType, dev devices.Core, param map[string]any) (outParam map[string]any, err error)

func ToCustomTopicDo

func ToCustomTopicDo(info *dm.CustomTopic) *productCustom.CustomTopic

func ToCustomTopicPb

func ToCustomTopicPb(info *productCustom.CustomTopic) *dm.CustomTopic

func ToCustomTopicsDo

func ToCustomTopicsDo(info []*dm.CustomTopic) (ret []*productCustom.CustomTopic)

func ToCustomTopicsPb

func ToCustomTopicsPb(info []*productCustom.CustomTopic) (ret []*dm.CustomTopic)

func ToDeviceCoreDo

func ToDeviceCoreDo(core *dm.DeviceCore) *devices.Core

func ToDeviceCoreDos

func ToDeviceCoreDos(in []*dm.DeviceCore) (ret []*devices.Core)

func ToDeviceCoreEvents

func ToDeviceCoreEvents(in []*dm.DeviceCore) (ret []*events.DeviceCore)

func ToDeviceCores

func ToDeviceCores(in []*dm.DeviceCore) []*devices.Core

func ToDeviceInfo

func ToDeviceInfo(ctx context.Context, svcCtx *svc.ServiceContext, in *relationDB.DmDeviceInfo) *dm.DeviceInfo

func ToDmPoint

func ToDmPoint(point *stores.Point) *dm.Point

func ToGatewayDevice

func ToGatewayDevice(gateway *devices.Core, subDevice []*devices.Core) (ret []*relationDB.DmGatewayDevice)

func ToGatewayPayload

func ToGatewayPayload(status def.GatewayStatus, in []*devices.Core) *msgGateway.GatewayPayload

func ToPageInfo

func ToPageInfo(info *dm.PageInfo) *stores.PageInfo

func ToProductCategoryPb

func ToProductCategoryPb(ctx context.Context, svcCtx *svc.ServiceContext, info *relationDB.DmProductCategory, children []*relationDB.DmProductCategory) *dm.ProductCategory

func ToProductInfo

func ToProductInfo(ctx context.Context, svcCtx *svc.ServiceContext, pi *relationDB.DmProductInfo) *dm.ProductInfo

func ToProductSchemaPo

func ToProductSchemaPo(info *dm.ProductSchemaInfo) *relationDB.DmProductSchema

func ToProductSchemaRpc

func ToProductSchemaRpc(info *relationDB.DmProductSchema) *dm.ProductSchemaInfo

func ToProtocolConfigFieldsPb

func ToProtocolConfigFieldsPb(in protocol.ConfigFields) (ret []*dm.ProtocolConfigField)

func ToProtocolConfigFieldsPo

func ToProtocolConfigFieldsPo(in []*dm.ProtocolConfigField) (ret protocol.ConfigFields)

func ToProtocolConfigInfosPb

func ToProtocolConfigInfosPb(in protocol.ConfigInfos) (ret []*dm.ProtocolConfigInfo)

func ToProtocolConfigInfosPo

func ToProtocolConfigInfosPo(in []*dm.ProtocolConfigInfo) (ret protocol.ConfigInfos)

func ToProtocolInfoPb

func ToProtocolInfoPb(in *relationDB.DmProtocolInfo) *dm.ProtocolInfo

func ToProtocolInfoPo

func ToProtocolInfoPo(in *dm.ProtocolInfo) *relationDB.DmProtocolInfo

func ToStorePoint

func ToStorePoint(point *dm.Point) stores.Point

func ToTimeRange

func ToTimeRange(in *dm.TimeRange) *def.TimeRange