blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-04-06 04:15:46 +08:00
Code Issues Packages Projects Releases Wiki Activity

tag

Browse Source
This commit is contained in:
wangchuxiao 2022-03-29 16:04:54 +08:00
parent d0a65c7c68
commit 7e937d7d29
3 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
internal/rpc/office/office.go
View File

@ -165,7 +165,7 @@ func (s *officeServer) SendMsg2Tag(_ context.Context, req *pbOffice.SendMsg2TagR
} }
groupUserIDList = append(groupUserIDList, userIDList...) groupUserIDList = append(groupUserIDList, userIDList...)
} }
log.NewDebug(req.OperationID, utils.GetSelfFuncName(), groupUserIDList, req.GroupList) log.NewInfo(req.OperationID, utils.GetSelfFuncName(), groupUserIDList, req.GroupList)
var userIDList []string var userIDList []string
userIDList = append(userIDList, tagUserIDList...) userIDList = append(userIDList, tagUserIDList...)
userIDList = append(userIDList, groupUserIDList...) userIDList = append(userIDList, groupUserIDList...)

1
internal/rpc/user/user.go
View File

@ -93,6 +93,7 @@ func syncPeerUserConversation(conversation *pbUser.Conversation, operationID str
log.NewError(operationID, utils.GetSelfFuncName(), "SetConversation error", err.Error()) log.NewError(operationID, utils.GetSelfFuncName(), "SetConversation error", err.Error())
return err return err
} }
chat.SetConversationNotification(operationID, conversation.UserID) chat.SetConversationNotification(operationID, conversation.UserID)
} }
return nil return nil

10
pkg/common/db/mysql_model/im_mysql_model/user_model.go
View File

@ -379,10 +379,10 @@ func GetConversations(OwnerUserID string, conversationIDs []string) ([]db.Conver
} }
func CreateConversationIfNotExist(conversation db.Conversation) error { func CreateConversationIfNotExist(conversation db.Conversation) error {
//dbConn, err := db.DB.MysqlDB.DefaultGormDB() dbConn, err := db.DB.MysqlDB.DefaultGormDB()
//if err != nil { if err != nil {
// return err return err
//} }
//err = dbConn.Model(&db.Conversation{}).Where().Find().Error err = dbConn.Model(&db.Conversation{}).Create(conversation).Error
return nil return nil
} }