GtDataStore/app/cmd/organization/organization/organization.go

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

package organization

import (
	"context"

	"GtDataStore/app/cmd/organization/pb"

	"github.com/zeromicro/go-zero/zrpc"
	"google.golang.org/grpc"
)

type (
	DcWorkingReq                = pb.DcWorkingReq
	ItemHistoryData             = pb.ItemHistoryData
	ItemHistoryDataByTimeReq    = pb.ItemHistoryDataByTimeReq
	ItemHistoryDataListReq      = pb.ItemHistoryDataListReq
	MultiAddItemHistoryDataReq  = pb.MultiAddItemHistoryDataReq
	MultiAddItemHistoryDataResp = pb.MultiAddItemHistoryDataResp
	WorkingChest                = pb.WorkingChest
	WorkingPump                 = pb.WorkingPump
	WorkingRo                   = pb.WorkingRo
	WorkingUf                   = pb.WorkingUf
	WorkingValve                = pb.WorkingValve

	Organization interface {
		GetWorkingUfByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingUf, error)
		GetWorkingRoByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingRo, error)
		GetWorkingChestByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingChest, error)
		GetWorkingPumpByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingPump, error)
		GetWorkingValueByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingValve, error)
		MultiAddItemHistoryData(ctx context.Context, in *MultiAddItemHistoryDataReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataResp, error)
		ItemHistoryDataList(ctx context.Context, in *ItemHistoryDataListReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataReq, error)
		ItemHistoryDataByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataReq, error)
	}

	defaultOrganization struct {
		cli zrpc.Client
	}
)

func NewOrganization(cli zrpc.Client) Organization {
	return &defaultOrganization{
		cli: cli,
	}
}

func (m *defaultOrganization) GetWorkingUfByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingUf, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.GetWorkingUfByCode(ctx, in, opts...)
}

func (m *defaultOrganization) GetWorkingRoByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingRo, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.GetWorkingRoByCode(ctx, in, opts...)
}

func (m *defaultOrganization) GetWorkingChestByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingChest, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.GetWorkingChestByCode(ctx, in, opts...)
}

func (m *defaultOrganization) GetWorkingPumpByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingPump, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.GetWorkingPumpByCode(ctx, in, opts...)
}

func (m *defaultOrganization) GetWorkingValueByCode(ctx context.Context, in *DcWorkingReq, opts ...grpc.CallOption) (*WorkingValve, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.GetWorkingValueByCode(ctx, in, opts...)
}

func (m *defaultOrganization) MultiAddItemHistoryData(ctx context.Context, in *MultiAddItemHistoryDataReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataResp, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.MultiAddItemHistoryData(ctx, in, opts...)
}

func (m *defaultOrganization) ItemHistoryDataList(ctx context.Context, in *ItemHistoryDataListReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataReq, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.ItemHistoryDataList(ctx, in, opts...)
}

func (m *defaultOrganization) ItemHistoryDataByTime(ctx context.Context, in *ItemHistoryDataByTimeReq, opts ...grpc.CallOption) (*MultiAddItemHistoryDataReq, error) {
	client := pb.NewOrganizationClient(m.cli.Conn())
	return client.ItemHistoryDataByTime(ctx, in, opts...)
}