add friend_request service

db/db.go

@@ -57,7 +57,7 @@ func newMysqlClient() {
 		return
 	}
 	orm.RegisterModel(new(CompanyApp), new(ImBase), new(ImChatRoom),
-		new(ImUserRelationship), new(ImUser), new(ImFriendRequest))
+		new(ImUserRelationship), new(ImUser), new(ImFriendRequest),new(ImChatRoomUser))
 	orm.Debug = true
 	MysqlClient = orm.NewOrm()
 	beeLogger.Log.Success("MySQL connect success")

db/db_struct.go

@@ -26,6 +26,16 @@ type ImChatRoom struct {
 	Updatetime   string
 }
 
+type ImChatRoomUser struct {
+	Id         int64
+	RoomId     int64
+	Operator   string
+	Accid      string
+	Role       int64
+	Createtime string
+	Updatetime string
+}
+
 type ImUserRelationship struct {
 	Id         int
 	Accid      string

initialization/Registration_services.go

@@ -8,6 +8,7 @@ import (
 	"im-microservice/sevice/health"
 	"im-microservice/sevice/im_chat_room"
 	"im-microservice/sevice/im_friend_request"
+	"im-microservice/sevice/im_chat_room_user"
 	ic "im-microservice/sevice/im_configure"
 	"im-microservice/sevice/im_user"
 	iur "im-microservice/sevice/im_user_relationship"
@@ -16,6 +17,7 @@ import (
 	grpc_zap "github.com/grpc-ecosystem/go-grpc-middleware/logging/zap"
 	grpc_recovery "github.com/grpc-ecosystem/go-grpc-middleware/recovery"
 	grpc_validator "github.com/grpc-ecosystem/go-grpc-middleware/validator"
+
 	"google.golang.org/grpc"
 	"google.golang.org/grpc/keepalive"
 	"google.golang.org/grpc/reflection"
@@ -41,6 +43,7 @@ func init() {
 
 	rpc_server := grpc.NewServer(grpc.KeepaliveEnforcementPolicy(kaep), grpc.KeepaliveParams(kasp),
 		grpc.UnaryInterceptor(grpc_middleware.ChainUnaryServer(
+			middleware.Interceptor,
 			grpc_validator.UnaryServerInterceptor(),
 			middleware.Interceptor,
 			//middleware.Auth,
@@ -54,6 +57,9 @@ func init() {
 	pb.RegisterImUserServer(rpc_server, &im_user.ImUserServer{})
 	pb.RegisterUserRelationshipServiceServer(rpc_server, &iur.UserRelationshipService{})
 	pb.RegisterImFriendServiceServer(rpc_server, &im_friend_request.ImFriendService{})
+	pb.RegisterChatRoomUserServer(rpc_server, &im_chat_room_user.ChatRoomUserServer{})
+
 	reflection.Register(rpc_server)
 	RpcServer = rpc_server
+
 }

sevice/im_user/im_user_db.go

@@ -37,7 +37,6 @@ func createAccid() string {
 //通过手机号获取用户数据
 func GetImUserByMobile(mobile string) (db.ImUser, error) {
 	var c_user db.ImUser
-	fmt.Println(db.MysqlClient)
 	err := db.MysqlClient.QueryTable(u_table_name).Filter("mobile", mobile).One(&c_user)
 	if err != nil {
 		return c_user, err