|
@@ -22,7 +22,7 @@ func newUserCenter(hosts []string, key string) *userCenter {
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
|
|
-func (u *userCenter) newClient() zrpc.Client {
|
|
|
|
|
|
+func (u *userCenter) NewClient() zrpc.Client {
|
|
client, err := zrpc.NewClient(zrpc.RpcClientConf{
|
|
client, err := zrpc.NewClient(zrpc.RpcClientConf{
|
|
Etcd: discov.EtcdConf{
|
|
Etcd: discov.EtcdConf{
|
|
Hosts: u.hosts,
|
|
Hosts: u.hosts,
|
|
@@ -38,7 +38,7 @@ func (u *userCenter) newClient() zrpc.Client {
|
|
|
|
|
|
//获取身份列表
|
|
//获取身份列表
|
|
func (u *userCenter) IdentityList(userId int64) []*pb.Identity {
|
|
func (u *userCenter) IdentityList(userId int64) []*pb.Identity {
|
|
- client := u.newClient()
|
|
|
|
|
|
+ client := u.NewClient()
|
|
if client == nil {
|
|
if client == nil {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
@@ -55,7 +55,7 @@ func (u *userCenter) IdentityList(userId int64) []*pb.Identity {
|
|
|
|
|
|
//获取账号id获取个人身份信息
|
|
//获取账号id获取个人身份信息
|
|
func (u *userCenter) IdentityByUserId(userId int64) *pb.Identity {
|
|
func (u *userCenter) IdentityByUserId(userId int64) *pb.Identity {
|
|
- client := u.newClient()
|
|
|
|
|
|
+ client := u.NewClient()
|
|
if client == nil {
|
|
if client == nil {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
@@ -72,7 +72,7 @@ func (u *userCenter) IdentityByUserId(userId int64) *pb.Identity {
|
|
|
|
|
|
//根据职位id获取身份信息
|
|
//根据职位id获取身份信息
|
|
func (u *userCenter) IdentityByPositionId(positionId int64) *pb.Identity {
|
|
func (u *userCenter) IdentityByPositionId(positionId int64) *pb.Identity {
|
|
- client := u.newClient()
|
|
|
|
|
|
+ client := u.NewClient()
|
|
if client == nil {
|
|
if client == nil {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
@@ -89,7 +89,7 @@ func (u *userCenter) IdentityByPositionId(positionId int64) *pb.Identity {
|
|
|
|
|
|
//根据企业员工id获取身份信息
|
|
//根据企业员工id获取身份信息
|
|
func (u *userCenter) IdentityByEntUserId(entUserId int64) *pb.Identity {
|
|
func (u *userCenter) IdentityByEntUserId(entUserId int64) *pb.Identity {
|
|
- client := u.newClient()
|
|
|
|
|
|
+ client := u.NewClient()
|
|
if client == nil {
|
|
if client == nil {
|
|
return nil
|
|
return nil
|
|
}
|
|
}
|
|
@@ -106,7 +106,7 @@ func (u *userCenter) IdentityByEntUserId(entUserId int64) *pb.Identity {
|
|
|
|
|
|
//添加用户
|
|
//添加用户
|
|
func (u *userCenter) UserAdd(req pb.UserAddReq) *pb.UserAddResp {
|
|
func (u *userCenter) UserAdd(req pb.UserAddReq) *pb.UserAddResp {
|
|
- client := u.newClient()
|
|
|
|
|
|
+ client := u.NewClient()
|
|
defer client.Conn().Close()
|
|
defer client.Conn().Close()
|
|
resp, err := usercenter.NewUserCenter(client).UserAdd(context.Background(), &pb.UserAddReq{
|
|
resp, err := usercenter.NewUserCenter(client).UserAdd(context.Background(), &pb.UserAddReq{
|
|
Appid: req.Appid,
|
|
Appid: req.Appid,
|
|
@@ -132,7 +132,7 @@ func (u *userCenter) UserAdd(req pb.UserAddReq) *pb.UserAddResp {
|
|
|
|
|
|
//修改用户
|
|
//修改用户
|
|
func (u *userCenter) UserUpdate(req pb.UserIdReq) *pb.ExamineResp {
|
|
func (u *userCenter) UserUpdate(req pb.UserIdReq) *pb.ExamineResp {
|
|
- client := u.newClient()
|
|
|
|
|
|
+ client := u.NewClient()
|
|
defer client.Conn().Close()
|
|
defer client.Conn().Close()
|
|
resp, err := usercenter.NewUserCenter(client).UserUpdate(context.Background(), &pb.UserIdReq{
|
|
resp, err := usercenter.NewUserCenter(client).UserUpdate(context.Background(), &pb.UserIdReq{
|
|
Appid: req.Appid,
|
|
Appid: req.Appid,
|
|
@@ -156,7 +156,7 @@ func (u *userCenter) UserUpdate(req pb.UserIdReq) *pb.ExamineResp {
|
|
|
|
|
|
//删除用户
|
|
//删除用户
|
|
func (u *userCenter) UserDel(req pb.UserIdReq) *pb.ExamineResp {
|
|
func (u *userCenter) UserDel(req pb.UserIdReq) *pb.ExamineResp {
|
|
- client := u.newClient()
|
|
|
|
|
|
+ client := u.NewClient()
|
|
defer client.Conn().Close()
|
|
defer client.Conn().Close()
|
|
resp, err := usercenter.NewUserCenter(client).UserDel(context.Background(), &pb.UserIdReq{
|
|
resp, err := usercenter.NewUserCenter(client).UserDel(context.Background(), &pb.UserIdReq{
|
|
Appid: req.Appid,
|
|
Appid: req.Appid,
|