devicegrouplogic

Documentation

Index

• func ToGroupInfoPb(ro *relationDB.DmGroupInfo) *dm.GroupInfo
• type GroupDeviceIndexLogic
  • func NewGroupDeviceIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeviceIndexLogic
  • func (l *GroupDeviceIndexLogic) GroupDeviceIndex(in *dm.GroupDeviceIndexReq) (*dm.GroupDeviceIndexResp, error)
• type GroupDeviceMultiCreateLogic
  • func NewGroupDeviceMultiCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeviceMultiCreateLogic
  • func (l *GroupDeviceMultiCreateLogic) GroupDeviceMultiCreate(in *dm.GroupDeviceMultiCreateReq) (*dm.Response, error)
• type GroupDeviceMultiDeleteLogic
  • func NewGroupDeviceMultiDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeviceMultiDeleteLogic
  • func (l *GroupDeviceMultiDeleteLogic) GroupDeviceMultiDelete(in *dm.GroupDeviceMultiDeleteReq) (*dm.Response, error)
• type GroupInfoCreateLogic
  • func NewGroupInfoCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoCreateLogic
  • func (l *GroupInfoCreateLogic) CheckGroupInfo(in *dm.GroupInfoCreateReq) (bool, error)
  • func (l *GroupInfoCreateLogic) CheckGroupLevel(groupID int64, level int64) (bool, error)
  • func (l *GroupInfoCreateLogic) GroupInfoCreate(in *dm.GroupInfoCreateReq) (*dm.Response, error)
• type GroupInfoDeleteLogic
  • func NewGroupInfoDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoDeleteLogic
  • func (l *GroupInfoDeleteLogic) GroupInfoDelete(in *dm.GroupInfoDeleteReq) (*dm.Response, error)
• type GroupInfoIndexLogic
  • func NewGroupInfoIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoIndexLogic
  • func (l *GroupInfoIndexLogic) GroupInfoIndex(in *dm.GroupInfoIndexReq) (*dm.GroupInfoIndexResp, error)
• type GroupInfoReadLogic
  • func NewGroupInfoReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoReadLogic
  • func (l *GroupInfoReadLogic) GroupInfoRead(in *dm.GroupInfoReadReq) (*dm.GroupInfo, error)
• type GroupInfoUpdateLogic
  • func NewGroupInfoUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoUpdateLogic
  • func (l *GroupInfoUpdateLogic) GroupInfoUpdate(in *dm.GroupInfoUpdateReq) (*dm.Response, error)

Functions

func ToGroupInfoPb

func ToGroupInfoPb(ro *relationDB.DmGroupInfo) *dm.GroupInfo

Types

type GroupDeviceIndexLogic

type GroupDeviceIndexLogic struct {
	logx.Logger
	GdDB *relationDB.GroupDeviceRepo
	DiDB *relationDB.DeviceInfoRepo
	// contains filtered or unexported fields
}

func NewGroupDeviceIndexLogic

func NewGroupDeviceIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeviceIndexLogic

func (*GroupDeviceIndexLogic) GroupDeviceIndex

func (l *GroupDeviceIndexLogic) GroupDeviceIndex(in *dm.GroupDeviceIndexReq) (*dm.GroupDeviceIndexResp, error)

获取分组设备信息列表

type GroupDeviceMultiCreateLogic

type GroupDeviceMultiCreateLogic struct {
	logx.Logger
	GdDB *relationDB.GroupDeviceRepo
	// contains filtered or unexported fields
}

func NewGroupDeviceMultiCreateLogic

func NewGroupDeviceMultiCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeviceMultiCreateLogic

func (*GroupDeviceMultiCreateLogic) GroupDeviceMultiCreate

func (l *GroupDeviceMultiCreateLogic) GroupDeviceMultiCreate(in *dm.GroupDeviceMultiCreateReq) (*dm.Response, error)

创建分组设备

type GroupDeviceMultiDeleteLogic

type GroupDeviceMultiDeleteLogic struct {
	logx.Logger
	GdDB *relationDB.GroupDeviceRepo
	// contains filtered or unexported fields
}

func NewGroupDeviceMultiDeleteLogic

func NewGroupDeviceMultiDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupDeviceMultiDeleteLogic

func (*GroupDeviceMultiDeleteLogic) GroupDeviceMultiDelete

func (l *GroupDeviceMultiDeleteLogic) GroupDeviceMultiDelete(in *dm.GroupDeviceMultiDeleteReq) (*dm.Response, error)

删除分组设备

type GroupInfoCreateLogic

type GroupInfoCreateLogic struct {
	logx.Logger
	GiDB *relationDB.GroupInfoRepo
	// contains filtered or unexported fields
}

func NewGroupInfoCreateLogic

func NewGroupInfoCreateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoCreateLogic

func (*GroupInfoCreateLogic) CheckGroupInfo

func (l *GroupInfoCreateLogic) CheckGroupInfo(in *dm.GroupInfoCreateReq) (bool, error)

发现返回true 没有返回false

func (*GroupInfoCreateLogic) CheckGroupLevel

func (l *GroupInfoCreateLogic) CheckGroupLevel(groupID int64, level int64) (bool, error)

检查当前分组嵌套层数是否超限，是返回true 否则返回false

func (*GroupInfoCreateLogic) GroupInfoCreate

func (l *GroupInfoCreateLogic) GroupInfoCreate(in *dm.GroupInfoCreateReq) (*dm.Response, error)

创建分组

type GroupInfoDeleteLogic

type GroupInfoDeleteLogic struct {
	logx.Logger
	GiDB *relationDB.GroupInfoRepo
	// contains filtered or unexported fields
}

func NewGroupInfoDeleteLogic

func NewGroupInfoDeleteLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoDeleteLogic

func (*GroupInfoDeleteLogic) GroupInfoDelete

func (l *GroupInfoDeleteLogic) GroupInfoDelete(in *dm.GroupInfoDeleteReq) (*dm.Response, error)

删除分组

type GroupInfoIndexLogic

type GroupInfoIndexLogic struct {
	logx.Logger
	GiDB *relationDB.GroupInfoRepo
	// contains filtered or unexported fields
}

func NewGroupInfoIndexLogic

func NewGroupInfoIndexLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoIndexLogic

func (*GroupInfoIndexLogic) GroupInfoIndex

func (l *GroupInfoIndexLogic) GroupInfoIndex(in *dm.GroupInfoIndexReq) (*dm.GroupInfoIndexResp, error)

获取分组信息列表

type GroupInfoReadLogic

type GroupInfoReadLogic struct {
	logx.Logger
	GiDB *relationDB.GroupInfoRepo
	// contains filtered or unexported fields
}

func NewGroupInfoReadLogic

func NewGroupInfoReadLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoReadLogic

func (*GroupInfoReadLogic) GroupInfoRead

func (l *GroupInfoReadLogic) GroupInfoRead(in *dm.GroupInfoReadReq) (*dm.GroupInfo, error)

获取分组信息详情

type GroupInfoUpdateLogic

type GroupInfoUpdateLogic struct {
	logx.Logger
	GiDB *relationDB.GroupInfoRepo
	// contains filtered or unexported fields
}

func NewGroupInfoUpdateLogic

func NewGroupInfoUpdateLogic(ctx context.Context, svcCtx *svc.ServiceContext) *GroupInfoUpdateLogic

func (*GroupInfoUpdateLogic) GroupInfoUpdate

func (l *GroupInfoUpdateLogic) GroupInfoUpdate(in *dm.GroupInfoUpdateReq) (*dm.Response, error)

更新分组