From 7438f17c0b3a9f79ee5890c554bedc64c362859b Mon Sep 17 00:00:00 2001 From: zhangqian <zhangqian@123.com> Date: 星期五, 13 十月 2023 14:04:59 +0800 Subject: [PATCH] 销售计划简单数据权限 --- 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