From 6194956fa9d039eda543bc292e456909787eb066 Mon Sep 17 00:00:00 2001
From: zhangqian <zhangqian@123.com>
Date: 星期一, 16 十月 2023 14:49:58 +0800
Subject: [PATCH] Revert "aps grpc env"
---
service/user.go | 40 ----------------------------------------
1 files changed, 0 insertions(+), 40 deletions(-)
diff --git a/service/user.go b/service/user.go
index ad83ad2..3f40330 100644
--- a/service/user.go
+++ b/service/user.go
@@ -1,19 +1,12 @@
package service
import (
- "aps_crm/conf"
"aps_crm/constvar"
"aps_crm/model"
"aps_crm/pkg/ecode"
"aps_crm/pkg/encrypt"
- "aps_crm/pkg/logx"
- "aps_crm/proto/user"
- "context"
"errors"
- "google.golang.org/grpc"
- "google.golang.org/grpc/credentials/insecure"
"gorm.io/gorm"
- "time"
)
type UserService struct{}
@@ -99,37 +92,4 @@
func (userService *UserService) GetUserList() (userList []*model.User, err error) {
return model.NewUserSearch(nil).FindAll()
-}
-
-var (
- userConn *grpc.ClientConn
-)
-
-func InitUserConn() {
- var err error
- userConn, err = grpc.Dial(conf.Conf.GrpcServiceAddr.Aps, grpc.WithTransportCredentials(insecure.NewCredentials()))
- if err != nil {
- logx.Errorf("grpc dial user service error: %v", err.Error())
- return
- }
- defer userConn.Close()
-}
-
-func (userService *UserService) SyncUserInfo() (err error) {
- cli := user.NewUserServiceClient(userConn)
-
- users := []*user.User{
- // ... fetched users
- }
-
- ctx, cancel := context.WithTimeout(context.Background(), time.Second)
- defer cancel()
- r, err := cli.SyncUser(ctx, &user.UserRequest{Users: users})
- if err != nil {
- logx.Fatalf("could not sync users: %v", err)
- }
-
- logx.Infof("Synced: %v, Message: %s", r.List, r.Message)
-
- return nil
}
--
Gitblit v1.8.0