add

wangpengfei

2023-08-17 efdfa2d6754354c021a19b340088c296fff74ca6

 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
}