From e5df488268e29b272932e6cc1d2b1e7034590ba0 Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期三, 12 六月 2024 11:40:45 +0800 Subject: [PATCH] weedfs包放到项目里 --- proto/inventory_order/inventory_order_grpc.pb.go | 216 ++++++++++++++++++++++++++++++++++++++++++++++++++++++ 1 files changed, 216 insertions(+), 0 deletions(-) diff --git a/proto/inventory_order/inventory_order_grpc.pb.go b/proto/inventory_order/inventory_order_grpc.pb.go index eaeb0a2..ced1aa4 100644 --- a/proto/inventory_order/inventory_order_grpc.pb.go +++ b/proto/inventory_order/inventory_order_grpc.pb.go @@ -19,6 +19,12 @@ // For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream. type InventoryOrderServiceClient interface { CreateNewOrder(ctx context.Context, in *CreateNewOrderRequest, opts ...grpc.CallOption) (*CreateNewOrderResponse, error) + CreateOperationList(ctx context.Context, in *CreateOperationListRequest, opts ...grpc.CallOption) (*CreateOperationListResponse, error) + UpdateMaterialApplyStatus(ctx context.Context, in *UpdateMaterialApplyStatusRequest, opts ...grpc.CallOption) (*UpdateMaterialApplyStatusResponse, error) + GetWarehouseInfo(ctx context.Context, in *GetWarehouseInfoRequest, opts ...grpc.CallOption) (*GetWarehouseInfoResponse, error) + UpdateOutsourceOrder(ctx context.Context, in *UpdateOutsourceOrderRequest, opts ...grpc.CallOption) (*UpdateOutsourceOrderResponse, error) + GetOperationInfo(ctx context.Context, in *GetOperationInfoRequest, opts ...grpc.CallOption) (*GetOperationInfoResponse, error) + GetWorkerList(ctx context.Context, in *GetWorkerListRequest, opts ...grpc.CallOption) (*GetWorkerListResponse, error) } type inventoryOrderServiceClient struct { @@ -38,11 +44,71 @@ return out, nil } +func (c *inventoryOrderServiceClient) CreateOperationList(ctx context.Context, in *CreateOperationListRequest, opts ...grpc.CallOption) (*CreateOperationListResponse, error) { + out := new(CreateOperationListResponse) + err := c.cc.Invoke(ctx, "/inventoryOrderService/CreateOperationList", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *inventoryOrderServiceClient) UpdateMaterialApplyStatus(ctx context.Context, in *UpdateMaterialApplyStatusRequest, opts ...grpc.CallOption) (*UpdateMaterialApplyStatusResponse, error) { + out := new(UpdateMaterialApplyStatusResponse) + err := c.cc.Invoke(ctx, "/inventoryOrderService/UpdateMaterialApplyStatus", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *inventoryOrderServiceClient) GetWarehouseInfo(ctx context.Context, in *GetWarehouseInfoRequest, opts ...grpc.CallOption) (*GetWarehouseInfoResponse, error) { + out := new(GetWarehouseInfoResponse) + err := c.cc.Invoke(ctx, "/inventoryOrderService/GetWarehouseInfo", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *inventoryOrderServiceClient) UpdateOutsourceOrder(ctx context.Context, in *UpdateOutsourceOrderRequest, opts ...grpc.CallOption) (*UpdateOutsourceOrderResponse, error) { + out := new(UpdateOutsourceOrderResponse) + err := c.cc.Invoke(ctx, "/inventoryOrderService/UpdateOutsourceOrder", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *inventoryOrderServiceClient) GetOperationInfo(ctx context.Context, in *GetOperationInfoRequest, opts ...grpc.CallOption) (*GetOperationInfoResponse, error) { + out := new(GetOperationInfoResponse) + err := c.cc.Invoke(ctx, "/inventoryOrderService/GetOperationInfo", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + +func (c *inventoryOrderServiceClient) GetWorkerList(ctx context.Context, in *GetWorkerListRequest, opts ...grpc.CallOption) (*GetWorkerListResponse, error) { + out := new(GetWorkerListResponse) + err := c.cc.Invoke(ctx, "/inventoryOrderService/GetWorkerList", in, out, opts...) + if err != nil { + return nil, err + } + return out, nil +} + // InventoryOrderServiceServer is the server API for InventoryOrderService service. // All implementations must embed UnimplementedInventoryOrderServiceServer // for forward compatibility type InventoryOrderServiceServer interface { CreateNewOrder(context.Context, *CreateNewOrderRequest) (*CreateNewOrderResponse, error) + CreateOperationList(context.Context, *CreateOperationListRequest) (*CreateOperationListResponse, error) + UpdateMaterialApplyStatus(context.Context, *UpdateMaterialApplyStatusRequest) (*UpdateMaterialApplyStatusResponse, error) + GetWarehouseInfo(context.Context, *GetWarehouseInfoRequest) (*GetWarehouseInfoResponse, error) + UpdateOutsourceOrder(context.Context, *UpdateOutsourceOrderRequest) (*UpdateOutsourceOrderResponse, error) + GetOperationInfo(context.Context, *GetOperationInfoRequest) (*GetOperationInfoResponse, error) + GetWorkerList(context.Context, *GetWorkerListRequest) (*GetWorkerListResponse, error) mustEmbedUnimplementedInventoryOrderServiceServer() } @@ -52,6 +118,24 @@ func (UnimplementedInventoryOrderServiceServer) CreateNewOrder(context.Context, *CreateNewOrderRequest) (*CreateNewOrderResponse, error) { return nil, status.Errorf(codes.Unimplemented, "method CreateNewOrder not implemented") +} +func (UnimplementedInventoryOrderServiceServer) CreateOperationList(context.Context, *CreateOperationListRequest) (*CreateOperationListResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method CreateOperationList not implemented") +} +func (UnimplementedInventoryOrderServiceServer) UpdateMaterialApplyStatus(context.Context, *UpdateMaterialApplyStatusRequest) (*UpdateMaterialApplyStatusResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method UpdateMaterialApplyStatus not implemented") +} +func (UnimplementedInventoryOrderServiceServer) GetWarehouseInfo(context.Context, *GetWarehouseInfoRequest) (*GetWarehouseInfoResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetWarehouseInfo not implemented") +} +func (UnimplementedInventoryOrderServiceServer) UpdateOutsourceOrder(context.Context, *UpdateOutsourceOrderRequest) (*UpdateOutsourceOrderResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method UpdateOutsourceOrder not implemented") +} +func (UnimplementedInventoryOrderServiceServer) GetOperationInfo(context.Context, *GetOperationInfoRequest) (*GetOperationInfoResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetOperationInfo not implemented") +} +func (UnimplementedInventoryOrderServiceServer) GetWorkerList(context.Context, *GetWorkerListRequest) (*GetWorkerListResponse, error) { + return nil, status.Errorf(codes.Unimplemented, "method GetWorkerList not implemented") } func (UnimplementedInventoryOrderServiceServer) mustEmbedUnimplementedInventoryOrderServiceServer() {} @@ -84,6 +168,114 @@ return interceptor(ctx, in, info, handler) } +func _InventoryOrderService_CreateOperationList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(CreateOperationListRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(InventoryOrderServiceServer).CreateOperationList(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/inventoryOrderService/CreateOperationList", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(InventoryOrderServiceServer).CreateOperationList(ctx, req.(*CreateOperationListRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _InventoryOrderService_UpdateMaterialApplyStatus_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(UpdateMaterialApplyStatusRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(InventoryOrderServiceServer).UpdateMaterialApplyStatus(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/inventoryOrderService/UpdateMaterialApplyStatus", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(InventoryOrderServiceServer).UpdateMaterialApplyStatus(ctx, req.(*UpdateMaterialApplyStatusRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _InventoryOrderService_GetWarehouseInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetWarehouseInfoRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(InventoryOrderServiceServer).GetWarehouseInfo(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/inventoryOrderService/GetWarehouseInfo", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(InventoryOrderServiceServer).GetWarehouseInfo(ctx, req.(*GetWarehouseInfoRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _InventoryOrderService_UpdateOutsourceOrder_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(UpdateOutsourceOrderRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(InventoryOrderServiceServer).UpdateOutsourceOrder(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/inventoryOrderService/UpdateOutsourceOrder", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(InventoryOrderServiceServer).UpdateOutsourceOrder(ctx, req.(*UpdateOutsourceOrderRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _InventoryOrderService_GetOperationInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetOperationInfoRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(InventoryOrderServiceServer).GetOperationInfo(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/inventoryOrderService/GetOperationInfo", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(InventoryOrderServiceServer).GetOperationInfo(ctx, req.(*GetOperationInfoRequest)) + } + return interceptor(ctx, in, info, handler) +} + +func _InventoryOrderService_GetWorkerList_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) { + in := new(GetWorkerListRequest) + if err := dec(in); err != nil { + return nil, err + } + if interceptor == nil { + return srv.(InventoryOrderServiceServer).GetWorkerList(ctx, in) + } + info := &grpc.UnaryServerInfo{ + Server: srv, + FullMethod: "/inventoryOrderService/GetWorkerList", + } + handler := func(ctx context.Context, req interface{}) (interface{}, error) { + return srv.(InventoryOrderServiceServer).GetWorkerList(ctx, req.(*GetWorkerListRequest)) + } + return interceptor(ctx, in, info, handler) +} + // InventoryOrderService_ServiceDesc is the grpc.ServiceDesc for InventoryOrderService service. // It's only intended for direct use with grpc.RegisterService, // and not to be introspected or modified (even as a copy) @@ -95,6 +287,30 @@ MethodName: "CreateNewOrder", Handler: _InventoryOrderService_CreateNewOrder_Handler, }, + { + MethodName: "CreateOperationList", + Handler: _InventoryOrderService_CreateOperationList_Handler, + }, + { + MethodName: "UpdateMaterialApplyStatus", + Handler: _InventoryOrderService_UpdateMaterialApplyStatus_Handler, + }, + { + MethodName: "GetWarehouseInfo", + Handler: _InventoryOrderService_GetWarehouseInfo_Handler, + }, + { + MethodName: "UpdateOutsourceOrder", + Handler: _InventoryOrderService_UpdateOutsourceOrder_Handler, + }, + { + MethodName: "GetOperationInfo", + Handler: _InventoryOrderService_GetOperationInfo_Handler, + }, + { + MethodName: "GetWorkerList", + Handler: _InventoryOrderService_GetWorkerList_Handler, + }, }, Streams: []grpc.StreamDesc{}, Metadata: "inventory_order.proto", -- Gitblit v1.8.0