Versions in this module Expand all Collapse all v0 v0.10.7 Oct 9, 2024 v0.10.6 Oct 6, 2024 Changes in this version + const CountTypeStatus + const CountTypeType + const DeviceTransferToProject + const DeviceTransferToUser + const RangeTypeAll + const RangeTypeArea + const RangeTypeGroup + func DeleteDeviceTimeData(ctx context.Context, svcCtx *svc.ServiceContext, productID, deviceName string) error + func FilterCanBindSubDevices(ctx context.Context, svcCtx *svc.ServiceContext, gateway *devices.Core, ...) (ret []*devices.Core, err error) + func GenID() uint32 + func HandleOnlineFix(ctx context.Context, svcCtx *svc.ServiceContext, ...) (err error) + func Transfer() + type CheckDevice int64 + const CheckDeviceExist + const CheckDeviceStrict + const CheckDeviceType + type DeviceCountLogic struct + DiDB *relationDB.DeviceInfoRepo + PiDB *relationDB.ProductInfoRepo + func NewDeviceCountLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceCountLogic + func (l *DeviceCountLogic) Count(countTypes []string, f relationDB.DeviceFilter) (map[string]int64, error) + func (l *DeviceCountLogic) DeviceCount(in *dm.DeviceCountReq) (*dm.DeviceCountResp, error) + func (l *DeviceCountLogic) FillFilter(rangeType int64, rangeID int64) (*relationDB.DeviceFilter, error) + type DeviceGatewayIndexLogic struct + GdDB *relationDB.GatewayDeviceRepo + func NewDeviceGatewayIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceGatewayIndexLogic + func (l *DeviceGatewayIndexLogic) DeviceGatewayIndex(in *dm.DeviceGatewayIndexReq) (*dm.DeviceGatewayIndexResp, error) + type DeviceGatewayMultiCreateLogic struct + DiDB *relationDB.DeviceInfoRepo + GdDB *relationDB.GatewayDeviceRepo + PiDB *relationDB.ProductInfoRepo + func NewDeviceGatewayMultiCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceGatewayMultiCreateLogic + func (l *DeviceGatewayMultiCreateLogic) DeviceGatewayMultiCreate(in *dm.DeviceGatewayMultiCreateReq) (*dm.Empty, error) + type DeviceGatewayMultiDeleteLogic struct + GdDB *relationDB.GatewayDeviceRepo + func NewDeviceGatewayMultiDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceGatewayMultiDeleteLogic + func (l *DeviceGatewayMultiDeleteLogic) DeviceGatewayMultiDelete(in *dm.DeviceGatewayMultiSaveReq) (*dm.Empty, error) + type DeviceGatewayMultiUpdateLogic struct + DiDB *relationDB.DeviceInfoRepo + GdDB *relationDB.GatewayDeviceRepo + PiDB *relationDB.ProductInfoRepo + func NewDeviceGatewayMultiUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceGatewayMultiUpdateLogic + func (l *DeviceGatewayMultiUpdateLogic) DeviceGatewayMultiUpdate(in *dm.DeviceGatewayMultiSaveReq) (*dm.Empty, error) + type DeviceInfoBindLogic struct + func NewDeviceInfoBindLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoBindLogic + func (l *DeviceInfoBindLogic) DeviceInfoBind(in *dm.DeviceInfoBindReq) (*dm.Empty, error) + type DeviceInfoCanBindLogic struct + func NewDeviceInfoCanBindLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoCanBindLogic + func (l *DeviceInfoCanBindLogic) DeviceInfoCanBind(in *dm.DeviceInfoCanBindReq) (*dm.Empty, error) + type DeviceInfoCountLogic struct + DiDB *relationDB.DeviceInfoRepo + func NewDeviceInfoCountLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoCountLogic + func (l *DeviceInfoCountLogic) DeviceInfoCount(in *dm.DeviceInfoCountReq) (*dm.DeviceInfoCount, error) + type DeviceInfoCreateLogic struct + DiDB *relationDB.DeviceInfoRepo + PiDB *relationDB.ProductInfoRepo + func NewDeviceInfoCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoCreateLogic + func (l *DeviceInfoCreateLogic) CheckDevice(in *dm.DeviceInfo) (bool, error) + func (l *DeviceInfoCreateLogic) CheckProduct(in *dm.DeviceInfo) (*dm.ProductInfo, error) + func (l *DeviceInfoCreateLogic) DeviceInfoCreate(in *dm.DeviceInfo) (resp *dm.Empty, err error) + func (l *DeviceInfoCreateLogic) InitDevice(in devices.Info) error + type DeviceInfoDeleteLogic struct + DiDB *relationDB.DeviceInfoRepo + func NewDeviceInfoDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoDeleteLogic + func (l *DeviceInfoDeleteLogic) DeviceInfoDelete(in *dm.DeviceInfoDeleteReq) (*dm.Empty, error) + type DeviceInfoIndexLogic struct + DiDB *relationDB.DeviceInfoRepo + func NewDeviceInfoIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoIndexLogic + func (l *DeviceInfoIndexLogic) DeviceInfoIndex(in *dm.DeviceInfoIndexReq) (*dm.DeviceInfoIndexResp, error) + type DeviceInfoMultiBindLogic struct + func NewDeviceInfoMultiBindLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoMultiBindLogic + func (l *DeviceInfoMultiBindLogic) DeviceInfoMultiBind(in *dm.DeviceInfoMultiBindReq) (*dm.DeviceInfoMultiBindResp, error) + type DeviceInfoMultiUpdateLogic struct + func NewDeviceInfoMultiUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoMultiUpdateLogic + func (l *DeviceInfoMultiUpdateLogic) DeviceInfoMultiUpdate(in *dm.DeviceInfoMultiUpdateReq) (*dm.Empty, error) + type DeviceInfoReadLogic struct + DiDB *relationDB.DeviceInfoRepo + func NewDeviceInfoReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoReadLogic + func (l *DeviceInfoReadLogic) DeviceInfoRead(in *dm.DeviceInfoReadReq) (*dm.DeviceInfo, error) + type DeviceInfoUnbindLogic struct + func NewDeviceInfoUnbindLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoUnbindLogic + func (l *DeviceInfoUnbindLogic) DeviceInfoUnbind(in *dm.DeviceCore) (*dm.Empty, error) + type DeviceInfoUpdateLogic struct + DiDB *relationDB.DeviceInfoRepo + PiDB *relationDB.ProductInfoRepo + func NewDeviceInfoUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceInfoUpdateLogic + func (l *DeviceInfoUpdateLogic) DeviceInfoUpdate(in *dm.DeviceInfo) (*dm.Empty, error) + func (l *DeviceInfoUpdateLogic) SetDevicePoByDto(old *relationDB.DmDeviceInfo, data *dm.DeviceInfo) error + type DeviceModuleVersionIndexLogic struct + func NewDeviceModuleVersionIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceModuleVersionIndexLogic + func (l *DeviceModuleVersionIndexLogic) DeviceModuleVersionIndex(in *dm.DeviceModuleVersionIndexReq) (*dm.DeviceModuleVersionIndexResp, error) + type DeviceModuleVersionReadLogic struct + func NewDeviceModuleVersionReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceModuleVersionReadLogic + func (l *DeviceModuleVersionReadLogic) DeviceModuleVersionRead(in *dm.DeviceModuleVersionReadReq) (*dm.DeviceModuleVersion, error) + type DeviceMoveLogic struct + func NewDeviceMoveLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceMoveLogic + func (l *DeviceMoveLogic) DeviceMove(in *dm.DeviceMoveReq) (*dm.Empty, error) + type DeviceOnlineMultiFixLogic struct + func NewDeviceOnlineMultiFixLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceOnlineMultiFixLogic + func (l *DeviceOnlineMultiFixLogic) DeviceOnlineMultiFix(in *dm.DeviceOnlineMultiFixReq) (*dm.Empty, error) + type DeviceProfileDeleteLogic struct + func NewDeviceProfileDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceProfileDeleteLogic + func (l *DeviceProfileDeleteLogic) DeviceProfileDelete(in *dm.DeviceProfileReadReq) (*dm.Empty, error) + type DeviceProfileIndexLogic struct + func NewDeviceProfileIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceProfileIndexLogic + func (l *DeviceProfileIndexLogic) DeviceProfileIndex(in *dm.DeviceProfileIndexReq) (*dm.DeviceProfileIndexResp, error) + type DeviceProfileReadLogic struct + func NewDeviceProfileReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceProfileReadLogic + func (l *DeviceProfileReadLogic) DeviceProfileRead(in *dm.DeviceProfileReadReq) (*dm.DeviceProfile, error) + type DeviceProfileUpdateLogic struct + func NewDeviceProfileUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceProfileUpdateLogic + func (l *DeviceProfileUpdateLogic) DeviceProfileUpdate(in *dm.DeviceProfile) (*dm.Empty, error) + type DeviceTransferLogic struct + func NewDeviceTransferLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceTransferLogic + func (l *DeviceTransferLogic) DeviceTransfer(in *dm.DeviceTransferReq) (*dm.Empty, error) + type DeviceTypeCountLogic struct + DiDB *relationDB.DeviceInfoRepo + PiDB *relationDB.ProductInfoRepo + func NewDeviceTypeCountLogic(ctx context.Context, svcCtx *svc.ServiceContext) *DeviceTypeCountLogic + func (l *DeviceTypeCountLogic) DeviceTypeCount(in *dm.DeviceTypeCountReq) (*dm.DeviceTypeCountResp, error) + type RootCheckLogic struct + func NewRootCheckLogic(ctx context.Context, svcCtx *svc.ServiceContext) *RootCheckLogic + func (l *RootCheckLogic) RootCheck(in *dm.RootCheckReq) (*dm.Empty, error)