| | |
| | | "srm/api/v1/test" |
| | | "srm/proto/purchase_wms" |
| | | "srm/proto/qualityinspect" |
| | | "srm/proto/supplier" |
| | | |
| | | "srm/core" |
| | | "srm/global" |
| | |
| | | s := grpc.NewServer() |
| | | //todo 添加具体服务 |
| | | purchase_wms.RegisterPurchaseServiceServer(s, &purchase_wms.Server{}) |
| | | supplier.RegisterSupplierServiceServer(s, &supplier.Server{}) |
| | | err = s.Serve(ln) |
| | | if err != nil { |
| | | global.GVA_LOG.Error("grpc server init error: %v", zap.Error(err)) |
| | |
| | | test.InitProductServiceConn() |
| | | qualityinspect.InitConn() |
| | | purchase_wms.InitPurchaseConn() |
| | | test.InitProductServiceConn() |
| | | } |
| | | |
| | | func closeGrpcClient() { |
| | | test.CloseProductServiceConn() |
| | | qualityinspect.CloseConn() |
| | | purchase_wms.ClosePurchaseConn() |
| | | test.CloseProductServiceConn() |
| | | } |