From 1572f45e72cc0fa15c029f9ee2a08474104435e6 Mon Sep 17 00:00:00 2001
From: selfcheer <selfcheer@gmail.com>
Date: 星期五, 19 七月 2024 00:48:43 +0800
Subject: [PATCH] 采购单产品列表去掉过滤重复产品的逻辑

---
 main.go |   43 +++++++++++++++++++++++++++++++++++++++----
 1 files changed, 39 insertions(+), 4 deletions(-)

diff --git a/main.go b/main.go
index 50fa538..2b4c8d8 100644
--- a/main.go
+++ b/main.go
@@ -1,8 +1,14 @@
 package main
 
 import (
+	"fmt"
 	"go.uber.org/zap"
+	"google.golang.org/grpc"
+	"net"
 	"srm/api/v1/test"
+	"srm/proto/purchase_wms"
+	"srm/proto/qualityinspect"
+	"srm/proto/supplier"
 
 	"srm/core"
 	"srm/global"
@@ -33,11 +39,40 @@
 		db, _ := global.GVA_DB.DB()
 		defer db.Close()
 	}
+	//鍚姩grpc鏈嶅姟
+	go func() {
+		ln, err := net.Listen("tcp", ":"+global.GVA_CONFIG.System.GrpcPort)
+		if err != nil {
+			global.GVA_LOG.Error("grpc server init error: %v", zap.Error(err))
+			panic(fmt.Sprintf("grpc server init error: %v", err.Error()))
+		}
+		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))
+			panic(fmt.Sprintf("grpc server init error: %v", err.Error()))
+		}
+	}()
 
-	go test.InitProductServiceConn()
-	defer test.CloseProductServiceConn()
-	initialize.InitRpcClient()
-	defer initialize.CloseRpcClient()
+	go initGrpcClient()
+	defer closeGrpcClient()
 
 	core.RunWindowsServer()
 }
+
+func initGrpcClient() {
+	test.InitProductServiceConn()
+	qualityinspect.InitConn()
+	purchase_wms.InitPurchaseConn()
+	test.InitProductServiceConn()
+}
+
+func closeGrpcClient() {
+	test.CloseProductServiceConn()
+	qualityinspect.CloseConn()
+	purchase_wms.ClosePurchaseConn()
+	test.CloseProductServiceConn()
+}

--
Gitblit v1.8.0