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