From efdfa2d6754354c021a19b340088c296fff74ca6 Mon Sep 17 00:00:00 2001
From: wangpengfei <274878379@qq.com>
Date: 星期四, 17 八月 2023 16:33:32 +0800
Subject: [PATCH] add
---
service/user.go | 40 ++++++++++++++++++++++++++++++++++++++++
1 files changed, 40 insertions(+), 0 deletions(-)
diff --git a/service/user.go b/service/user.go
index 3f40330..ad83ad2 100644
--- a/service/user.go
+++ b/service/user.go
@@ -1,12 +1,19 @@
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{}
@@ -93,3 +100,36 @@
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