organizationServer.go 2.8 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273
  1. // Code generated by goctl. DO NOT EDIT.
  2. // Source: organization.proto
  3. package server
  4. import (
  5. "context"
  6. "GtDataStore/app/cmd/organization/internal/logic"
  7. "GtDataStore/app/cmd/organization/internal/svc"
  8. "GtDataStore/app/cmd/organization/pb"
  9. )
  10. type OrganizationServer struct {
  11. svcCtx *svc.ServiceContext
  12. pb.UnimplementedOrganizationServer
  13. }
  14. func NewOrganizationServer(svcCtx *svc.ServiceContext) *OrganizationServer {
  15. return &OrganizationServer{
  16. svcCtx: svcCtx,
  17. }
  18. }
  19. func (s *OrganizationServer) GetWorkingUfByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingUfByCodeResp, error) {
  20. l := logic.NewGetWorkingUfByCodeLogic(ctx, s.svcCtx)
  21. return l.GetWorkingUfByCode(in)
  22. }
  23. func (s *OrganizationServer) GetWorkingRoByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingRoByCodeResp, error) {
  24. l := logic.NewGetWorkingRoByCodeLogic(ctx, s.svcCtx)
  25. return l.GetWorkingRoByCode(in)
  26. }
  27. func (s *OrganizationServer) GetWorkingChestByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingChestByCodeResp, error) {
  28. l := logic.NewGetWorkingChestByCodeLogic(ctx, s.svcCtx)
  29. return l.GetWorkingChestByCode(in)
  30. }
  31. func (s *OrganizationServer) GetWorkingPumpByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingPumpByCodeResp, error) {
  32. l := logic.NewGetWorkingPumpByCodeLogic(ctx, s.svcCtx)
  33. return l.GetWorkingPumpByCode(in)
  34. }
  35. func (s *OrganizationServer) GetWorkingValveByCode(ctx context.Context, in *pb.DcWorkingReq) (*pb.GetWorkingValveByCodeResp, error) {
  36. l := logic.NewGetWorkingValveByCodeLogic(ctx, s.svcCtx)
  37. return l.GetWorkingValveByCode(in)
  38. }
  39. func (s *OrganizationServer) MultiAddItemHistoryData(ctx context.Context, in *pb.MultiAddItemHistoryDataReq) (*pb.MultiAddItemHistoryDataResp, error) {
  40. l := logic.NewMultiAddItemHistoryDataLogic(ctx, s.svcCtx)
  41. return l.MultiAddItemHistoryData(in)
  42. }
  43. func (s *OrganizationServer) ItemHistoryDataList(ctx context.Context, in *pb.ItemHistoryDataListReq) (*pb.ItemHistoryDataListResp, error) {
  44. l := logic.NewItemHistoryDataListLogic(ctx, s.svcCtx)
  45. return l.ItemHistoryDataList(in)
  46. }
  47. func (s *OrganizationServer) ItemHistoryDataByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) (*pb.ItemHistoryDataListResp, error) {
  48. l := logic.NewItemHistoryDataByTimeLogic(ctx, s.svcCtx)
  49. return l.ItemHistoryDataByTime(in)
  50. }
  51. func (s *OrganizationServer) ItemHistoryDataMaxMinByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) (*pb.ItemHistoryDataMaxMinResp, error) {
  52. l := logic.NewItemHistoryDataMaxMinByTimeLogic(ctx, s.svcCtx)
  53. return l.ItemHistoryDataMaxMinByTime(in)
  54. }
  55. func (s *OrganizationServer) ItemHistoryDataFirstLastByTime(ctx context.Context, in *pb.ItemHistoryDataByTimeReq) (*pb.ItemHistoryDataFirstLastResp, error) {
  56. l := logic.NewItemHistoryDataFirstLastByTimeLogic(ctx, s.svcCtx)
  57. return l.ItemHistoryDataFirstLastByTime(in)
  58. }