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

package server

import (
	"context"

	"GtDataStore/app/cmd/organization/internal/logic"
	"GtDataStore/app/cmd/organization/internal/svc"
	"GtDataStore/app/cmd/organization/pb"
)

type OrganizationServer struct {
	svcCtx *svc.ServiceContext
	pb.UnimplementedOrganizationServer
}

func NewOrganizationServer(svcCtx *svc.ServiceContext) *OrganizationServer {
	return &OrganizationServer{
		svcCtx: svcCtx,
	}
}

func (s *OrganizationServer) GetWorkingUfByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingUfByCodeResp, error) {
	l := logic.NewGetWorkingUfByCodeLogic(ctx, s.svcCtx)
	return l.GetWorkingUfByCode(in)
}

func (s *OrganizationServer) GetWorkingRoByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingRoByCodeResp, error) {
	l := logic.NewGetWorkingRoByCodeLogic(ctx, s.svcCtx)
	return l.GetWorkingRoByCode(in)
}

func (s *OrganizationServer) GetWorkingChestByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingChestByCodeResp, error) {
	l := logic.NewGetWorkingChestByCodeLogic(ctx, s.svcCtx)
	return l.GetWorkingChestByCode(in)
}

func (s *OrganizationServer) GetWorkingPumpByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingPumpByCodeResp, error) {
	l := logic.NewGetWorkingPumpByCodeLogic(ctx, s.svcCtx)
	return l.GetWorkingPumpByCode(in)
}

func (s *OrganizationServer) GetWorkingValveByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingValveByCodeResp, error) {
	l := logic.NewGetWorkingValveByCodeLogic(ctx, s.svcCtx)
	return l.GetWorkingValveByCode(in)
}

func (s *OrganizationServer) MultiAddItemHistoryData(ctx context.Context, in *pb.MultiAddItemHistoryDataReq) (*pb.MultiAddItemHistoryDataResp, error) {
	l := logic.NewMultiAddItemHistoryDataLogic(ctx, s.svcCtx)
	return l.MultiAddItemHistoryData(in)
}

func (s *OrganizationServer) ItemHistoryDataList(ctx context.Context, in *pb.ItemHistoryDataListReq) (*pb.ItemHistoryDataListResp, error) {
	l := logic.NewItemHistoryDataListLogic(ctx, s.svcCtx)
	return l.ItemHistoryDataList(in)
}

func (s *OrganizationServer) ItemHistoryDataByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) (*pb.ItemHistoryDataListResp, error) {
	l := logic.NewItemHistoryDataByTimeLogic(ctx, s.svcCtx)
	return l.ItemHistoryDataByTime(in)
}

func (s *OrganizationServer) ItemHistoryDataMaxMinByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) (*pb.ItemHistoryDataMaxMinResp, error) {
	l := logic.NewItemHistoryDataMaxMinByTimeLogic(ctx, s.svcCtx)
	return l.ItemHistoryDataMaxMinByTime(in)
}

func (s *OrganizationServer) ItemHistoryDataFirstLastByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) (*pb.ItemHistoryDataFirstLastResp, error) {
	l := logic.NewItemHistoryDataFirstLastByTimeLogic(ctx, s.svcCtx)
	return l.ItemHistoryDataFirstLastByTime(in)
}