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

//go:generate mockgen -destination ./integral_mock.go -package integralclient -source $GOFILE

package integralclient

import (
	"context"

	"points_service/rpc/integral"

	"github.com/tal-tech/go-zero/zrpc"
)

type (
	CheckReq  = integral.CheckReq
	CheckResp = integral.CheckResp
	AddReq    = integral.AddReq
	AddResp   = integral.AddResp

	Integral interface {
		// 新增积分
		AddFlow(ctx context.Context, in *AddReq) (*AddResp, error)
		// 调整结存
		UpdateBalance(ctx context.Context, in *AddReq) (*AddResp, error)
		// 调整余额
		UpdateTotal(ctx context.Context, in *AddReq) (*AddResp, error)
		// 消耗积分
		IntegralConsume(ctx context.Context, in *AddReq) (*AddResp, error)
		// 积分守护
		IntegralGuard(ctx context.Context, in *AddReq) (*AddResp, error)
		// 到期积分查询
		IntegralCheck(ctx context.Context, in *AddReq) (*AddResp, error)
	}

	defaultIntegral struct {
		cli zrpc.Client
	}
)

func NewIntegral(cli zrpc.Client) Integral {
	return &defaultIntegral{
		cli: cli,
	}
}

// 新增积分
func (m *defaultIntegral) AddFlow(ctx context.Context, in *AddReq) (*AddResp, error) {
	client := integral.NewIntegralClient(m.cli.Conn())
	return client.AddFlow(ctx, in)
}

// 调整结存
func (m *defaultIntegral) UpdateBalance(ctx context.Context, in *AddReq) (*AddResp, error) {
	client := integral.NewIntegralClient(m.cli.Conn())
	return client.UpdateBalance(ctx, in)
}

// 调整余额
func (m *defaultIntegral) UpdateTotal(ctx context.Context, in *AddReq) (*AddResp, error) {
	client := integral.NewIntegralClient(m.cli.Conn())
	return client.UpdateTotal(ctx, in)
}

// 消耗积分
func (m *defaultIntegral) IntegralConsume(ctx context.Context, in *AddReq) (*AddResp, error) {
	client := integral.NewIntegralClient(m.cli.Conn())
	return client.IntegralConsume(ctx, in)
}

// 积分守护
func (m *defaultIntegral) IntegralGuard(ctx context.Context, in *AddReq) (*AddResp, error) {
	client := integral.NewIntegralClient(m.cli.Conn())
	return client.IntegralGuard(ctx, in)
}

// 到期积分查询
func (m *defaultIntegral) IntegralCheck(ctx context.Context, in *AddReq) (*AddResp, error) {
	client := integral.NewIntegralClient(m.cli.Conn())
	return client.IntegralCheck(ctx, in)
}