From b27754470b8655d5a6cf42bfc3bff908fcface03 Mon Sep 17 00:00:00 2001 From: liujiandao <274878379@qq.com> Date: 星期五, 10 十一月 2023 15:02:49 +0800 Subject: [PATCH] wms修改销售明细状态 --- main.go | 21 ++++++++++++++++++++- 1 files changed, 20 insertions(+), 1 deletions(-) diff --git a/main.go b/main.go index 984e465..18843c8 100644 --- a/main.go +++ b/main.go @@ -7,8 +7,11 @@ "aps_crm/middleware" "aps_crm/model" "aps_crm/pkg/logx" + "aps_crm/proto/product_inventory" "aps_crm/router" "fmt" + "google.golang.org/grpc" + "net" "net/http" "os" "os/signal" @@ -46,11 +49,27 @@ WriteTimeout: 5 * time.Second, } + //鍚姩grpc瀹㈡埛绔� go v1.InitProductServiceConn() go middleware.InitUserConn() go v1.InitCodeServiceConn() go v1.InitProductInventoryServiceConn() - + //鍚姩grpc鏈嶅姟 + go func() { + ln, err := net.Listen("tcp", ":"+conf.Conf.System.GrpcPort) + if err != nil { + logx.Errorf("grpc server init error: %v", err.Error()) + panic(fmt.Sprintf("grpc server init error: %v", err.Error())) + } + s := grpc.NewServer() + //todo 娣诲姞鍏蜂綋鏈嶅姟 + product_inventory.RegisterProductInventoryServiceServer(s, &product_inventory.Server{}) + err = s.Serve(ln) + if err != nil { + logx.Errorf("grpc server init error: %v", err.Error()) + panic(fmt.Sprintf("grpc server init error: %v", err.Error())) + } + }() //c := cron.New() //c.AddFunc("@every 15s", service.SyncUserInfo) // 姣�15绉掑悓姝ヤ竴娆� //c.Start() -- Gitblit v1.8.0