data

package

v0.0.0-...-8e7c8ee Latest Latest Go to latest Published: May 23, 2025 License: MIT Imports: 18 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(NewDB, NewData, NewESClient, NewReviewRepo, NewRedisClient)

ProviderSet is data providers.

func NewDB(c *conf.Data) (*gorm.DB, error)

func NewESClient(c *conf.Elasticsearch) *elasticsearch.TypedClient

func NewRedisClient(c *conf.Data) *redis.Client

func NewReviewRepo(data *Data, logger log.Logger) biz.ReviewRepo

type Data struct {
	// TODO wrapped database client
	Q        *query.Query
	ESCli    *elasticsearch.TypedClient
	RedisCli *redis.Client
}

Data .

func NewData(db *gorm.DB, es *elasticsearch.TypedClient, r *redis.Client, logger log.Logger) (*Data, func(), error)

NewData .

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

func (r *ReviewRepo) CreateAppeal(ctx context.Context, appeal *model.ReviewAppealInfo) (int64, error)

func (r *ReviewRepo) GetReviewByOrderID(ctx context.Context, orderID int64) ([]*model.ReviewInfo, error)

func (r *ReviewRepo) GetReviewByReviewID(ctx context.Context, reviewID int64) (*model.ReviewInfo, error)

func (r *ReviewRepo) ListReviewByStoreID(ctx context.Context, storeID int64, page, size int32) ([]*model.ReviewInfo, error)

func (r *ReviewRepo) ListReviewByStoreID_old(ctx context.Context, storeID int64, page, size int32) ([]*model.ReviewInfo, error)

func (r *ReviewRepo) OperateAppeal(ctx context.Context, appeal *model.ReviewAppealInfo) (int64, error)

func (r *ReviewRepo) SaveReply(ctx context.Context, reply *model.ReviewReplyInfo) error

func (r *ReviewRepo) SaveReview(ctx context.Context, rinfo *model.ReviewInfo) (*model.ReviewInfo, error)

Path	Synopsis
model
query