data

package

v0.0.49 Latest Latest Go to latest Published: Sep 14, 2026 License: MIT Imports: 7 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(
	data.ProviderSet,
	NewMessageDeliveryWriter,
	wire.Bind(new(data.QueryProvider), new(*data.Data)),
)

ProviderSet 汇总 Admin 数据访问依赖注入提供者和查询接口绑定。

This section is empty.

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

MessageDeliveryWriter 封装消息投递需要的幂等批量写入和可空时间更新。

func NewMessageDeliveryWriter(queryProvider data.QueryProvider) *MessageDeliveryWriter

NewMessageDeliveryWriter 创建消息投递写入器。

func (w *MessageDeliveryWriter) CreateIgnore(ctx context.Context, list []*models.BaseMessageDelivery, batchSize int) (int64, error)

CreateIgnore 幂等批量创建用户投递记录并返回实际新增数量。

func (w *MessageDeliveryWriter) RevokeMessage(ctx context.Context, messageID int64, revokedAt time.Time) error

RevokeMessage 批量撤回指定消息的全部用户投递记录。

func (w *MessageDeliveryWriter) SetAllReadAt(ctx context.Context, userID, beforeDeliveryID int64, readAt time.Time) error

SetAllReadAt 按水位线批量设置当前用户消息已读时间。

func (w *MessageDeliveryWriter) SetArchivedAt(ctx context.Context, userID, id int64, archivedAt *time.Time) error

SetArchivedAt 设置或清空当前用户单条投递记录的归档时间。

func (w *MessageDeliveryWriter) SetReadAt(ctx context.Context, userID int64, ids []int64, readAt *time.Time) error

SetReadAt 批量设置或清空当前用户投递记录的已读时间。