fix bug

internal/demo/register/onboarding_process.go

@@ -21,7 +21,7 @@ import (
 	"time"
 )
 
-func onboardingProcess(operationID, userID, userName string) {
+func onboardingProcess(operationID, userID, userName, faceURL string) {
 	if err := createOrganizationUser(operationID, userID, userName); err != nil {
 		log.NewError(operationID, utils.GetSelfFuncName(), "createOrganizationUser failed", err.Error())
 	}
@@ -40,7 +40,7 @@ func onboardingProcess(operationID, userID, userName string) {
 		log.NewError(operationID, utils.GetSelfFuncName(), err.Error())
 	}
 	log.NewInfo(operationID, utils.GetSelfFuncName(), groupIDList)
-	joinGroups(operationID, userID, userName, groupIDList)
+	joinGroups(operationID, userID, userName, faceURL, groupIDList)
 	log.NewInfo(operationID, utils.GetSelfFuncName(), "fineshed")
 	oaNotification(operationID, userID)
 }
@@ -157,7 +157,7 @@ func GetDepartmentGroupIDList(operationID, departmentID string) ([]string, error
 	return getDepartmentParentIDListResp.GroupIDList, nil
 }
 
-func joinGroups(operationID, userID, userName string, groupIDList []string) {
+func joinGroups(operationID, userID, userName, faceURL string, groupIDList []string) {
 	defer func() {
 		log.NewInfo(operationID, utils.GetSelfFuncName(), userID, groupIDList)
 	}()
@@ -185,12 +185,12 @@ func joinGroups(operationID, userID, userName string, groupIDList []string) {
 			log.NewError(req.OperationID, utils.GetSelfFuncName(), resp)
 			continue
 		}
-		onboardingProcessNotification(operationID, userID, groupID, userName)
+		onboardingProcessNotification(operationID, userID, groupID, userName, faceURL)
 	}
 }
 
 // welcome user join department notification
-func onboardingProcessNotification(operationID, userID, groupID, userName string) {
+func onboardingProcessNotification(operationID, userID, groupID, userName, faceURL string) {
 	defer func() {
 		log.NewInfo(operationID, utils.GetSelfFuncName(), userID, groupID)
 	}()
@@ -204,13 +204,15 @@ func onboardingProcessNotification(operationID, userID, groupID, userName string
 	//}
 	welcomeString := fmt.Sprintf("欢迎%s加入部门", userName)
 	notification := &msg.NotificationMsg{
-		SendID:      userID,
-		RecvID:      groupID,
-		Content:     []byte(welcomeString),
-		MsgFrom:     constant.UserMsgType,
-		ContentType: constant.Text,
-		SessionType: constant.GroupChatType,
-		OperationID: operationID,
+		SendID:         userID,
+		RecvID:         groupID,
+		Content:        []byte(welcomeString),
+		MsgFrom:        constant.UserMsgType,
+		ContentType:    constant.Text,
+		SessionType:    constant.GroupChatType,
+		OperationID:    operationID,
+		SenderNickname: userName,
+		SenderFaceURL:  faceURL,
 	}
 
 	// notification user join group

internal/demo/register/set_password.go

@@ -96,7 +96,7 @@ func SetPassword(c *gin.Context) {
 	}
 	log.Info(params.OperationID, "end setPassword", account, params.Password)
 	// demo onboarding
-	onboardingProcess(params.OperationID, userID, params.Nickname)
+	onboardingProcess(params.OperationID, userID, params.Nickname, params.FaceURL)
 	c.JSON(http.StatusOK, gin.H{"errCode": constant.NoError, "errMsg": "", "data": openIMRegisterResp.UserToken})
 	return
 }

internal/rpc/msg/send_msg.go

@@ -553,13 +553,15 @@ func modifyMessageByUserMessageReceiveOptoptimization(userID, sourceID string, s
 }
 
 type NotificationMsg struct {
-	SendID      string
-	RecvID      string
-	Content     []byte //  open_im_sdk.TipsComm
-	MsgFrom     int32
-	ContentType int32
-	SessionType int32
-	OperationID string
+	SendID         string
+	RecvID         string
+	Content        []byte //  open_im_sdk.TipsComm
+	MsgFrom        int32
+	ContentType    int32
+	SessionType    int32
+	OperationID    string
+	SenderNickname string
+	SenderFaceURL  string
 }
 
 func Notification(n *NotificationMsg) {
@@ -579,6 +581,8 @@ func Notification(n *NotificationMsg) {
 	msg.CreateTime = utils.GetCurrentTimestampByMill()
 	msg.ClientMsgID = utils.GetMsgID(n.SendID)
 	msg.Options = make(map[string]bool, 7)
+	msg.SenderNickname = n.SenderNickname
+	msg.SenderFaceURL = n.SenderFaceURL
 	switch n.SessionType {
 	case constant.GroupChatType, constant.SuperGroupChatType:
 		msg.RecvID = ""

internal/rpc/user/user.go

@@ -284,7 +284,7 @@ func (s *userServer) SetRecvMsgOpt(ctx context.Context, req *pbUser.SetRecvMsgOp
 	stringList := strings.Split(req.ConversationID, "_")
 	if len(stringList) > 1 {
 		switch stringList[0] {
-		case "single_":
+		case "single":
 			conversation.UserID = stringList[1]
 			conversation.ConversationType = constant.SingleChatType
 		case "group":