notificationcommon

Documentation

Index

• type NotificationCommon
  • func NewNotificationCommon(data *data.Data, notificationRepo NotificationRepo, ...) *NotificationCommon
  • func (ns *NotificationCommon) AddNotification(ctx context.Context, msg *schema.NotificationMsg) error
  • func (ns *NotificationCommon) SendNotificationToAllFollower(ctx context.Context, msg *schema.NotificationMsg, questionID string)
• type NotificationRepo

Types

type NotificationCommon

type NotificationCommon struct {
	// contains filtered or unexported fields
}

func NewNotificationCommon

func NewNotificationCommon(
	data *data.Data,
	notificationRepo NotificationRepo,
	userCommon *usercommon.UserCommon,
	activityRepo activity_common.ActivityRepo,
	followRepo activity_common.FollowRepo,
	objectInfoService *object_info.ObjService,
	notificationQueueService notice_queue.NotificationQueueService,
) *NotificationCommon

func (*NotificationCommon) AddNotification

func (ns *NotificationCommon) AddNotification(ctx context.Context, msg *schema.NotificationMsg) error

AddNotification need set LoginUserID Type 1 inbox 2 achievement [inbox] Activity [achievement] Rank ObjectInfo.Title ObjectInfo.ObjectID ObjectInfo.ObjectType

func (*NotificationCommon) SendNotificationToAllFollower

func (ns *NotificationCommon) SendNotificationToAllFollower(ctx context.Context, msg *schema.NotificationMsg,
	questionID string)

SendNotificationToAllFollower send notification to all followers

type NotificationRepo

type NotificationRepo interface {
	AddNotification(ctx context.Context, notification *entity.Notification) (err error)
	GetNotificationPage(ctx context.Context, search *schema.NotificationSearch) ([]*entity.Notification, int64, error)
	ClearUnRead(ctx context.Context, userID string, notificationType int) (err error)
	ClearIDUnRead(ctx context.Context, userID string, id string) (err error)
	GetByUserIdObjectIdTypeId(ctx context.Context, userID, objectID string, notificationType int) (*entity.Notification, bool, error)
	UpdateNotificationContent(ctx context.Context, notification *entity.Notification) (err error)
	GetById(ctx context.Context, id string) (*entity.Notification, bool, error)
}