用户

sevice/im_user/im_user.go

@@ -53,7 +53,7 @@ func (u *ImUserServer) ImUserRegister(ctx context.Context, in *pb.ImUserRequest)
 	}
 	reply = &pb.ImUserReply{}
 	// 是否已经注册过, 如果已经注册返回用户信息
-	if c_user, _ := helper.GetImUserByMobile(imUser.Mobile); c_user.Appid != "" {
+	if c_user, _ := GetImUserByMobile(imUser.Mobile); c_user.Appid != "" {
 		reply.Appid = c_user.Appid
 
 		return
@@ -92,13 +92,13 @@ func (u *ImUserServer) ImUserLogin(ctx context.Context, in *pb.ImUserRequest) (r
 		return
 	}
 	reply = &pb.ImUserReply{}
-	c_user, _ := helper.GetImUserByMobile(imUser.Mobile)
+	c_user, _ := GetImUserByMobile(imUser.Mobile)
 	if c_user.Appid == "" {
 		err = errors.New("用户不存在")
 		return
 	}
 	//更新用户登录时间
-	if res, _ := helper.SaveUpdatetime(imUser.Mobile, imUser.Platfrom); res != 1 {
+	if res, _ := SaveUpdatetime(imUser.Mobile, imUser.Platfrom); res != 1 {
 		err = errors.New("用户登录时间更新失败")
 		return
 	}
@@ -111,7 +111,7 @@ func (u *ImUserServer) ImUserLoginOut(ctx context.Context, in *pb.ImUserOutReque
 	imUserOut := &ImUserQ{
 		Appid: in.GetAppid(),
 	}
-	if res, _ := helper.SaveLoginOut(imUserOut.Appid); res != 1 {
+	if res, _ := SaveLoginOut(imUserOut.Appid); res != 1 {
 		err = errors.New("用户更改登录状态信息失败")
 		return
 	}
@@ -125,7 +125,7 @@ func (u *ImUserServer) ImUserForbiddenWords(ctx context.Context, in *pb.ImUserSe
 		Appid: in.GetAppid(),
 		Mute:  in.GetMute(),
 	}
-	if res, _ := helper.SetImUserMute(imUserSet.Appid, "mute_estoppel", imUserSet.Mute); res != 1 {
+	if res, _ := SetImUserMute(imUserSet.Appid, "mute_estoppel", imUserSet.Mute); res != 1 {
 		err = errors.New("用户禁言失败")
 		return
 	}
@@ -140,7 +140,7 @@ func (u *ImUserServer) ImUserForbiddenAV(ctx context.Context, in *pb.ImUserSetRe
 		Appid: in.GetAppid(),
 		Mute:  in.GetMute(),
 	}
-	if res, _ := helper.SetImUserMute(imUserSet.Appid, "mute_audio_video", imUserSet.Mute); res != 1 {
+	if res, _ := SetImUserMute(imUserSet.Appid, "mute_audio_video", imUserSet.Mute); res != 1 {
 		err = errors.New("用户禁言失败")
 		return
 	}
@@ -159,7 +159,7 @@ func (u *ImUserServer) ImUserOne(ctx context.Context, in *pb.ImUserOneRequest) (
 		return
 	}
 	reply = &pb.ImUserOneReply{}
-	c_user, err := helper.GetImUserByAppid(imUserId.Appid)
+	c_user, err := GetImUserByAppid(imUserId.Appid)
 	if err != nil {
 		return
 	}
@@ -187,7 +187,7 @@ func getImUser(imuser db.ImUser) *pb.ImUserOneReply {
 
 //获取用户列表
 func (u *ImUserServer) ImUserList(ctx context.Context, in *pb.ImUserListRequest) (reply *pb.ImUserListReply, err error) {
-	results, err := helper.GetImUserList(in)
+	results, err := GetImUserList(in)
 	if err != nil {
 		return
 	}