dataDeduplication/rpc/internal/server/deduplicationserver.go

// Code generated by goctl. DO NOT EDIT!
// Source: deduplication.proto

package server

import (
	"context"

	"app.yhyue.com/moapp/dataDeduplication/rpc/deduplication"
	"app.yhyue.com/moapp/dataDeduplication/rpc/internal/logic"
	"app.yhyue.com/moapp/dataDeduplication/rpc/internal/svc"
)

type DeduplicationServer struct {
	svcCtx *svc.ServiceContext
}

func NewDeduplicationServer(svcCtx *svc.ServiceContext) *DeduplicationServer {
	return &DeduplicationServer{
		svcCtx: svcCtx,
	}
}

//  数据判重
func (s *DeduplicationServer) DataDeduplication(ctx context.Context, in *deduplication.Request) (*deduplication.Response, error) {
	l := logic.NewDataDeduplicationLogic(ctx, s.svcCtx)
	return l.DataDeduplication(in)
}

//  获取企业数据总量
func (s *DeduplicationServer) GetEntCount(ctx context.Context, in *deduplication.GetEntCountRequest) (*deduplication.GetEntCountResponse, error) {
	l := logic.NewGetEntCountLogic(ctx, s.svcCtx)
	return l.GetEntCount(in)
}

//   根据账户id进行判重
func (s *DeduplicationServer) DataDeduplicateByAccount(ctx context.Context, in *deduplication.ByAccountRequest) (*deduplication.Response, error) {
	l := logic.NewDataDeduplicateByAccountLogic(ctx, s.svcCtx)
	return l.DataDeduplicateByAccount(in)
}

//   根据账户id判重并存入数据
func (s *DeduplicationServer) DataDeduplicateAndSave(ctx context.Context, in *deduplication.ByAccountRequest) (*deduplication.Response, error) {
	l := logic.NewDataDeduplicateAndSaveLogic(ctx, s.svcCtx)
	return l.DataDeduplicateAndSave(in)
}