organization

deploy_k8s/dockerfiles/api.Dockerfile

@@ -0,0 +1,15 @@
+FROM ubuntu
+
+# 设置固定的项目路径
+ENV WORKDIR /bin
+ENV CONFIG_NAME $WORKDIR/config/config.yaml
+
+# 将可执行文件复制到目标目录
+ADD ../cmd/bin/open_im_api $WORKDIR/main
+
+# 创建用于挂载的几个目录，添加可执行权限
+RUN mkdir $WORKDIR/logs $WORKDIR/config $WORKDIR/db && \
+  chmod +x $WORKDIR/main
+
+WORKDIR $WORKDIR
+CMD ./main

deploy_k8s/script/build_push_all_images.sh

@@ -0,0 +1,28 @@
+#/bin/sh
+#service_source_root=(
+#  #api service file
+#  ../cmd/open_im_api/
+#  ../cmd/open_im_cms_api/
+#  #rpc service file
+#  ../cmd/rpc/open_im_user/
+#  ../cmd/rpc/open_im_friend/
+#  ../cmd/rpc/open_im_group/
+#  ../cmd/rpc/open_im_auth/
+#  ../cmd/rpc/open_im_admin_cms/
+#  ../cmd/rpc/open_im_message_cms/
+#  ../cmd/rpc/open_im_statistics/
+#  ../cmd/rpc/open_im_office/
+#  ../cmd/rpc/open_im_organization/
+#  ../cmd/rpc/open_im_conversation/
+#  ../cmd/rpc/open_im_cache/
+#  ../cmd/open_im_msg_gateway/
+#  ../cmd/open_im_msg_transfer/
+#  ../cmd/rpc/open_im_msg/
+#  ../cmd/open_im_push/
+#  ../cmd/Open-IM-SDK-Core/
+#  ../cmd/open_im_demo/
+#)
+#
+dockerfile_list=pwd
+
+docker build -t  $image . -f deploy.Dockerfile

internal/rpc/user/user.go

@@ -7,7 +7,6 @@ import (
 	"Open_IM/pkg/common/db"
 	imdb "Open_IM/pkg/common/db/mysql_model/im_mysql_model"
 	errors "Open_IM/pkg/common/http"
-
 	"Open_IM/pkg/common/log"
 	"Open_IM/pkg/common/token_verify"
 	"Open_IM/pkg/grpc-etcdv3/getcdv3"
@@ -410,7 +409,21 @@ func (s *userServer) UpdateUserInfo(ctx context.Context, req *pbUser.UpdateUserI
 	if req.UserInfo.FaceURL != "" {
 		go s.SyncJoinedGroupMemberFaceURL(req.UserInfo.UserID, req.UserInfo.FaceURL, req.OperationID, req.OpUserID)
 	}
-
+	//updateUserInfoToCacheReq := &cache.UpdateUserInfoToCacheReq{
+	//	OperationID:  req.OperationID,
+	//	UserInfoList: []*sdkws.UserInfo{req.UserInfo},
+	//}
+	//cacheEtcdConn := getcdv3.GetConn(config.Config.Etcd.EtcdSchema, strings.Join(config.Config.Etcd.EtcdAddr, ","), config.Config.RpcRegisterName.OpenImCacheName)
+	//cacheClient := cache.NewCacheClient(cacheEtcdConn)
+	//resp, err := cacheClient.UpdateUserInfoToCache(context.Background(), updateUserInfoToCacheReq)
+	//if err != nil {
+	//	log.NewError(req.OperationID, utils.GetSelfFuncName(), err.Error(), updateUserInfoToCacheReq.String())
+	//	return &pbUser.UpdateUserInfoResp{CommonResp: &pbUser.CommonResp{ErrCode: constant.ErrServer.ErrCode, ErrMsg: err.Error()}}, nil
+	//}
+	//if resp.CommonResp.ErrCode != 0 {
+	//	log.NewError(req.OperationID, utils.GetSelfFuncName(), resp.String())
+	//	return &pbUser.UpdateUserInfoResp{CommonResp: &pbUser.CommonResp{ErrCode: constant.ErrServer.ErrCode, ErrMsg: resp.CommonResp.ErrMsg}}, nil
+	//}
 	return &pbUser.UpdateUserInfoResp{CommonResp: &pbUser.CommonResp{}}, nil
 }