From 46d7d30089caf9081c942f918d3c9ac5c2a12e4b Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Wed, 6 Apr 2022 12:01:29 +0800 Subject: [PATCH 01/21] shell update --- script/build_all_service.sh | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/script/build_all_service.sh b/script/build_all_service.sh index d3b01785f..0d9814bec 100644 --- a/script/build_all_service.sh +++ b/script/build_all_service.sh @@ -32,6 +32,5 @@ for ((i = 0; i < ${#service_source_root[*]}; i++)); do else echo -e "${GREEN_PREFIX}${service_names[$i]} successfully be built ${COLOR_SUFFIX}\n" fi - - done +echo -e ${YELLOW_PREFIX}"all services build success"${COLOR_SUFFIX} From f64c40e91ff2e6f9faf2c1cd54855c7dd3b849fc Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Wed, 6 Apr 2022 14:31:25 +0800 Subject: [PATCH 02/21] tag msg --- internal/rpc/msg/tag_send_msg.go | 5 ++--- 1 file changed, 2 insertions(+), 3 deletions(-) diff --git a/internal/rpc/msg/tag_send_msg.go b/internal/rpc/msg/tag_send_msg.go index 6d8c0a0b3..7f0550d62 100644 --- a/internal/rpc/msg/tag_send_msg.go +++ b/internal/rpc/msg/tag_send_msg.go @@ -10,7 +10,6 @@ import ( "Open_IM/pkg/utils" "context" "strings" - "time" ) func TagSendMessage(operationID, sendID, recvID, content string, senderPlatformID int32) { @@ -25,8 +24,8 @@ func TagSendMessage(operationID, sendID, recvID, content string, senderPlatformI msgData.Content = []byte(content) msgData.Options = map[string]bool{} msgData.Options[constant.IsSenderConversationUpdate] = false - msgData.SendTime = time.Now().Unix() - msgData.CreateTime = time.Now().Unix() + msgData.CreateTime = utils.GetCurrentTimestampByMill() + msgData.ClientMsgID = utils.GetMsgID(sendID) msgData.SenderPlatformID = senderPlatformID req.MsgData = &msgData req.OperationID = operationID From 59cc45eaab0a3da2db7a4a40069f5eb783d82a52 Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Wed, 6 Apr 2022 14:41:36 +0800 Subject: [PATCH 03/21] replace log --- pkg/common/db/mysql.go | 32 ++++++++++++++++---------------- 1 file changed, 16 insertions(+), 16 deletions(-) diff --git a/pkg/common/db/mysql.go b/pkg/common/db/mysql.go index ad35cd5da..32cf7458b 100644 --- a/pkg/common/db/mysql.go +++ b/pkg/common/db/mysql.go @@ -2,7 +2,7 @@ package db import ( "Open_IM/pkg/common/config" - "Open_IM/pkg/common/log" + "fmt" "sync" "time" @@ -24,13 +24,13 @@ func initMysqlDB() { var err1 error db, err := gorm.Open("mysql", dsn) if err != nil { - log.NewError("0", "Open failed ", err.Error(), dsn) + fmt.Println("0", "Open failed ", err.Error(), dsn) } if err != nil { time.Sleep(time.Duration(30) * time.Second) db, err1 = gorm.Open("mysql", dsn) if err1 != nil { - log.NewError("0", "Open failed ", err1.Error(), dsn) + fmt.Println("0", "Open failed ", err1.Error(), dsn) panic(err1.Error()) } } @@ -39,7 +39,7 @@ func initMysqlDB() { sql := fmt.Sprintf("CREATE DATABASE IF NOT EXISTS %s default charset utf8 COLLATE utf8_general_ci;", config.Config.Mysql.DBDatabaseName) err = db.Exec(sql).Error if err != nil { - log.NewError("0", "Exec failed ", err.Error(), sql) + fmt.Println("0", "Exec failed ", err.Error(), sql) panic(err.Error()) } db.Close() @@ -48,11 +48,11 @@ func initMysqlDB() { config.Config.Mysql.DBUserName, config.Config.Mysql.DBPassword, config.Config.Mysql.DBAddress[0], config.Config.Mysql.DBDatabaseName) db, err = gorm.Open("mysql", dsn) if err != nil { - log.NewError("0", "Open failed ", err.Error(), dsn) + fmt.Println("0", "Open failed ", err.Error(), dsn) panic(err.Error()) } - log.NewInfo("open db ok ", dsn) + fmt.Println("open db ok ", dsn) db.AutoMigrate(&Friend{}, &FriendRequest{}, &Group{}, @@ -64,49 +64,49 @@ func initMysqlDB() { db.Set("gorm:table_options", "collation=utf8_unicode_ci") if !db.HasTable(&Friend{}) { - log.NewInfo("CreateTable Friend") + fmt.Println("CreateTable Friend") db.CreateTable(&Friend{}) } if !db.HasTable(&FriendRequest{}) { - log.NewInfo("CreateTable FriendRequest") + fmt.Println("CreateTable FriendRequest") db.CreateTable(&FriendRequest{}) } if !db.HasTable(&Group{}) { - log.NewInfo("CreateTable Group") + fmt.Println("CreateTable Group") db.CreateTable(&Group{}) } if !db.HasTable(&GroupMember{}) { - log.NewInfo("CreateTable GroupMember") + fmt.Println("CreateTable GroupMember") db.CreateTable(&GroupMember{}) } if !db.HasTable(&GroupRequest{}) { - log.NewInfo("CreateTable GroupRequest") + fmt.Println("CreateTable GroupRequest") db.CreateTable(&GroupRequest{}) } if !db.HasTable(&User{}) { - log.NewInfo("CreateTable User") + fmt.Println("CreateTable User") db.CreateTable(&User{}) } if !db.HasTable(&Black{}) { - log.NewInfo("CreateTable Black") + fmt.Println("CreateTable Black") db.CreateTable(&Black{}) } if !db.HasTable(&ChatLog{}) { - log.NewInfo("CreateTable Black") + fmt.Println("CreateTable Black") db.CreateTable(&ChatLog{}) } if !db.HasTable(&Register{}) { - log.NewInfo("CreateTable Black") + fmt.Println("CreateTable Black") db.CreateTable(&Register{}) } if !db.HasTable(&Conversation{}) { - log.NewInfo("CreateTable Black") + fmt.Println("CreateTable Black") db.CreateTable(&Conversation{}) } From ef4d0c3c42d4e905543db8f84d80543ffebc36d0 Mon Sep 17 00:00:00 2001 From: wenxu12345 <44203734@qq.com> Date: Wed, 6 Apr 2022 15:33:16 +0800 Subject: [PATCH 04/21] log --- cmd/open_im_api/main.go | 7 ++++++- cmd/open_im_cms_api/main.go | 2 ++ cmd/open_im_demo/main.go | 7 ++++++- cmd/open_im_msg_gateway/main.go | 2 ++ cmd/open_im_msg_transfer/main.go | 2 ++ cmd/open_im_push/main.go | 2 ++ cmd/rpc/open_im_admin_cms/main.go | 3 ++- cmd/rpc/open_im_auth/main.go | 2 ++ cmd/rpc/open_im_friend/main.go | 2 ++ cmd/rpc/open_im_group/main.go | 2 ++ cmd/rpc/open_im_message_cms/main.go | 2 ++ cmd/rpc/open_im_msg/main.go | 2 ++ cmd/rpc/open_im_office/main.go | 2 ++ cmd/rpc/open_im_statistics/main.go | 2 ++ cmd/rpc/open_im_user/main.go | 2 ++ 15 files changed, 38 insertions(+), 3 deletions(-) diff --git a/cmd/open_im_api/main.go b/cmd/open_im_api/main.go index 342d4a03a..6bbb43dbc 100644 --- a/cmd/open_im_api/main.go +++ b/cmd/open_im_api/main.go @@ -14,6 +14,7 @@ import ( "Open_IM/pkg/common/log" "Open_IM/pkg/utils" "flag" + "fmt" "io" "os" "strconv" @@ -138,5 +139,9 @@ func main() { go apiThird.MinioInit() ginPort := flag.Int("port", 10000, "get ginServerPort from cmd,default 10000 as port") flag.Parse() - r.Run(":" + strconv.Itoa(*ginPort)) + fmt.Println("start api server, port: ", *ginPort) + err := r.Run(":" + strconv.Itoa(*ginPort)) + if err != nil { + log.Error("", "run failed ", *ginPort, err.Error()) + } } diff --git a/cmd/open_im_cms_api/main.go b/cmd/open_im_cms_api/main.go index df39c4672..262020fea 100644 --- a/cmd/open_im_cms_api/main.go +++ b/cmd/open_im_cms_api/main.go @@ -3,6 +3,7 @@ package main import ( "Open_IM/internal/cms_api" "Open_IM/pkg/utils" + "fmt" "github.com/gin-gonic/gin" ) @@ -11,5 +12,6 @@ func main() { gin.SetMode(gin.ReleaseMode) router := cms_api.NewGinRouter() router.Use(utils.CorsHandler()) + fmt.Println("start cms api server, port: ", 8000) router.Run(":" + "8000") } diff --git a/cmd/open_im_demo/main.go b/cmd/open_im_demo/main.go index c35675e20..af7809547 100644 --- a/cmd/open_im_demo/main.go +++ b/cmd/open_im_demo/main.go @@ -4,6 +4,7 @@ import ( "Open_IM/internal/demo/register" "Open_IM/pkg/utils" "flag" + "fmt" "io" "os" "strconv" @@ -33,5 +34,9 @@ func main() { ginPort := flag.Int("port", 42233, "get ginServerPort from cmd,default 42233 as port") flag.Parse() - r.Run(":" + strconv.Itoa(*ginPort)) + fmt.Println("start demo api server, port: ", *ginPort) + err := r.Run(":" + strconv.Itoa(*ginPort)) + if err != nil { + log.Error("", "run failed ", *ginPort, err.Error()) + } } diff --git a/cmd/open_im_msg_gateway/main.go b/cmd/open_im_msg_gateway/main.go index 5296c9bcf..283f831b8 100644 --- a/cmd/open_im_msg_gateway/main.go +++ b/cmd/open_im_msg_gateway/main.go @@ -5,6 +5,7 @@ import ( "Open_IM/pkg/common/constant" "Open_IM/pkg/common/log" "flag" + "fmt" "sync" ) @@ -15,6 +16,7 @@ func main() { flag.Parse() var wg sync.WaitGroup wg.Add(1) + fmt.Println("start rpc/msg_gateway server, port: ", *rpcPort, *wsPort) gate.Init(*rpcPort, *wsPort) gate.Run() wg.Wait() diff --git a/cmd/open_im_msg_transfer/main.go b/cmd/open_im_msg_transfer/main.go index 2a54ac1d8..9dfabecda 100644 --- a/cmd/open_im_msg_transfer/main.go +++ b/cmd/open_im_msg_transfer/main.go @@ -4,6 +4,7 @@ import ( "Open_IM/internal/msg_transfer/logic" "Open_IM/pkg/common/constant" "Open_IM/pkg/common/log" + "fmt" "sync" ) @@ -12,6 +13,7 @@ func main() { wg.Add(1) log.NewPrivateLog(constant.LogFileName) logic.Init() + fmt.Println("start msg_transfer server") logic.Run() wg.Wait() } diff --git a/cmd/open_im_push/main.go b/cmd/open_im_push/main.go index ba8dc65c1..95e8521dd 100644 --- a/cmd/open_im_push/main.go +++ b/cmd/open_im_push/main.go @@ -5,6 +5,7 @@ import ( "Open_IM/pkg/common/constant" "Open_IM/pkg/common/log" "flag" + "fmt" "sync" ) @@ -14,6 +15,7 @@ func main() { var wg sync.WaitGroup wg.Add(1) log.NewPrivateLog(constant.LogFileName) + fmt.Println("start push rpc server, port: ", *rpcPort) logic.Init(*rpcPort) logic.Run() wg.Wait() diff --git a/cmd/rpc/open_im_admin_cms/main.go b/cmd/rpc/open_im_admin_cms/main.go index eae1a4505..c69135645 100644 --- a/cmd/rpc/open_im_admin_cms/main.go +++ b/cmd/rpc/open_im_admin_cms/main.go @@ -3,12 +3,13 @@ package main import ( rpcMessageCMS "Open_IM/internal/rpc/admin_cms" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 11000, "rpc listening port") flag.Parse() + fmt.Println("start cms rpc server, port: ", *rpcPort) rpcServer := rpcMessageCMS.NewAdminCMSServer(*rpcPort) rpcServer.Run() } - diff --git a/cmd/rpc/open_im_auth/main.go b/cmd/rpc/open_im_auth/main.go index 110ea05c6..53b0f9de5 100644 --- a/cmd/rpc/open_im_auth/main.go +++ b/cmd/rpc/open_im_auth/main.go @@ -3,11 +3,13 @@ package main import ( rpcAuth "Open_IM/internal/rpc/auth" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 10600, "RpcToken default listen port 10800") flag.Parse() + fmt.Println("start auth rpc server, port: ", *rpcPort) rpcServer := rpcAuth.NewRpcAuthServer(*rpcPort) rpcServer.Run() diff --git a/cmd/rpc/open_im_friend/main.go b/cmd/rpc/open_im_friend/main.go index 0847699c5..85d05e39c 100644 --- a/cmd/rpc/open_im_friend/main.go +++ b/cmd/rpc/open_im_friend/main.go @@ -3,12 +3,14 @@ package main import ( "Open_IM/internal/rpc/friend" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 10200, "get RpcFriendPort from cmd,default 12000 as port") flag.Parse() + fmt.Println("start friend rpc server, port: ", *rpcPort) rpcServer := friend.NewFriendServer(*rpcPort) rpcServer.Run() } diff --git a/cmd/rpc/open_im_group/main.go b/cmd/rpc/open_im_group/main.go index 8a3f886cb..7afc7ec57 100644 --- a/cmd/rpc/open_im_group/main.go +++ b/cmd/rpc/open_im_group/main.go @@ -3,11 +3,13 @@ package main import ( "Open_IM/internal/rpc/group" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 10500, "get RpcGroupPort from cmd,default 16000 as port") flag.Parse() + fmt.Println("start group rpc server, port: ", *rpcPort) rpcServer := group.NewGroupServer(*rpcPort) rpcServer.Run() } diff --git a/cmd/rpc/open_im_message_cms/main.go b/cmd/rpc/open_im_message_cms/main.go index 0980d3629..16151a2ed 100644 --- a/cmd/rpc/open_im_message_cms/main.go +++ b/cmd/rpc/open_im_message_cms/main.go @@ -3,11 +3,13 @@ package main import ( rpcMessageCMS "Open_IM/internal/rpc/message_cms" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 10900, "rpc listening port") flag.Parse() + fmt.Println("start msg cms rpc server, port: ", *rpcPort) rpcServer := rpcMessageCMS.NewMessageCMSServer(*rpcPort) rpcServer.Run() } diff --git a/cmd/rpc/open_im_msg/main.go b/cmd/rpc/open_im_msg/main.go index 7344facf4..95908f48a 100644 --- a/cmd/rpc/open_im_msg/main.go +++ b/cmd/rpc/open_im_msg/main.go @@ -3,11 +3,13 @@ package main import ( rpcChat "Open_IM/internal/rpc/msg" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 10300, "rpc listening port") flag.Parse() + fmt.Println("start msg rpc server, port: ", *rpcPort) rpcServer := rpcChat.NewRpcChatServer(*rpcPort) rpcServer.Run() } diff --git a/cmd/rpc/open_im_office/main.go b/cmd/rpc/open_im_office/main.go index c4d80cf68..c9a05c791 100644 --- a/cmd/rpc/open_im_office/main.go +++ b/cmd/rpc/open_im_office/main.go @@ -3,11 +3,13 @@ package main import ( rpc "Open_IM/internal/rpc/office" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 11100, "rpc listening port") flag.Parse() + fmt.Println("start office rpc server, port: ", *rpcPort) rpcServer := rpc.NewOfficeServer(*rpcPort) rpcServer.Run() } diff --git a/cmd/rpc/open_im_statistics/main.go b/cmd/rpc/open_im_statistics/main.go index f1f950288..b87440abf 100644 --- a/cmd/rpc/open_im_statistics/main.go +++ b/cmd/rpc/open_im_statistics/main.go @@ -3,11 +3,13 @@ package main import ( "Open_IM/internal/rpc/statistics" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 10800, "rpc listening port") flag.Parse() + fmt.Println("start statistics rpc server, port: ", *rpcPort) rpcServer := statistics.NewStatisticsServer(*rpcPort) rpcServer.Run() } diff --git a/cmd/rpc/open_im_user/main.go b/cmd/rpc/open_im_user/main.go index 91b6e55b5..d8644d028 100644 --- a/cmd/rpc/open_im_user/main.go +++ b/cmd/rpc/open_im_user/main.go @@ -3,11 +3,13 @@ package main import ( "Open_IM/internal/rpc/user" "flag" + "fmt" ) func main() { rpcPort := flag.Int("port", 10100, "rpc listening port") flag.Parse() + fmt.Println("start user rpc server, port: ", *rpcPort) rpcServer := user.NewUserServer(*rpcPort) rpcServer.Run() } From 42225dd35e682b99df450a072eb6baf131dfd7c8 Mon Sep 17 00:00:00 2001 From: wenxu12345 <44203734@qq.com> Date: Wed, 6 Apr 2022 15:54:59 +0800 Subject: [PATCH 05/21] log --- .../mysql_model/im_mysql_model/demo_model.go | 2 +- .../im_mysql_model/group_member_model.go | 4 ++-- .../im_mysql_model/group_request_model.go | 2 +- .../mysql_model/im_mysql_model/message_cms.go | 6 ++--- .../im_mysql_model/statistics_model.go | 22 ++++++++--------- .../mysql_model/im_mysql_model/user_model.go | 24 +++++++++---------- 6 files changed, 30 insertions(+), 30 deletions(-) diff --git a/pkg/common/db/mysql_model/im_mysql_model/demo_model.go b/pkg/common/db/mysql_model/im_mysql_model/demo_model.go index 897e5e212..eff3050be 100644 --- a/pkg/common/db/mysql_model/im_mysql_model/demo_model.go +++ b/pkg/common/db/mysql_model/im_mysql_model/demo_model.go @@ -33,7 +33,7 @@ func ResetPassword(account, password string) error { Password: password, } dbConn, err := db.DB.MysqlDB.DefaultGormDB() - dbConn.LogMode(true) + dbConn.LogMode(false) if err != nil { return err } diff --git a/pkg/common/db/mysql_model/im_mysql_model/group_member_model.go b/pkg/common/db/mysql_model/im_mysql_model/group_member_model.go index b0ffbd4ee..289a157fc 100644 --- a/pkg/common/db/mysql_model/im_mysql_model/group_member_model.go +++ b/pkg/common/db/mysql_model/im_mysql_model/group_member_model.go @@ -71,7 +71,7 @@ func GetGroupMemberIDListByGroupID(groupID string) ([]string, error) { if err != nil { return nil, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var groupMembers []db.GroupMember err = dbConn.Table("group_members").Select("user_id").Where("group_id=?", groupID).Find(&groupMembers).Error if err != nil { @@ -279,7 +279,7 @@ func GetGroupMembersCount(groupId, userName string) (int32, error) { if err != nil { return count, err } - dbConn.LogMode(true) + dbConn.LogMode(false) if err := dbConn.Table("group_members").Where("group_id=?", groupId).Where(fmt.Sprintf(" nickname like '%%%s%%' ", userName)).Count(&count).Error; err != nil { return count, err } diff --git a/pkg/common/db/mysql_model/im_mysql_model/group_request_model.go b/pkg/common/db/mysql_model/im_mysql_model/group_request_model.go index 836f3f0bf..5e27cc3d2 100644 --- a/pkg/common/db/mysql_model/im_mysql_model/group_request_model.go +++ b/pkg/common/db/mysql_model/im_mysql_model/group_request_model.go @@ -123,7 +123,7 @@ func GetUserReqGroupByUserID(userID string) ([]db.GroupRequest, error) { if err != nil { return nil, err } - dbConn.LogMode(true) + dbConn.LogMode(false) err = dbConn.Table("group_requests").Where("user_id=?", userID).Find(&groupRequestList).Error return groupRequestList, err } diff --git a/pkg/common/db/mysql_model/im_mysql_model/message_cms.go b/pkg/common/db/mysql_model/im_mysql_model/message_cms.go index eb4b0cc52..29fb650cf 100644 --- a/pkg/common/db/mysql_model/im_mysql_model/message_cms.go +++ b/pkg/common/db/mysql_model/im_mysql_model/message_cms.go @@ -13,7 +13,7 @@ func GetChatLog(chatLog db.ChatLog, pageNumber, showNumber int32) ([]db.ChatLog, if err != nil { return chatLogs, err } - dbConn.LogMode(true) + dbConn.LogMode(false) db := dbConn.Table("chat_logs"). Where(fmt.Sprintf(" content like '%%%s%%'", chatLog.Content)). Limit(showNumber).Offset(showNumber * (pageNumber - 1)) @@ -43,7 +43,7 @@ func GetChatLogCount(chatLog db.ChatLog) (int64, error) { if err != nil { return count, err } - dbConn.LogMode(true) + dbConn.LogMode(false) db := dbConn.Table("chat_logs"). Where(fmt.Sprintf(" content like '%%%s%%'", chatLog.Content)) if chatLog.SessionType != 0 { @@ -65,4 +65,4 @@ func GetChatLogCount(chatLog db.ChatLog) (int64, error) { err = db.Find(&chatLogs).Count(&count).Error return count, err -} \ No newline at end of file +} diff --git a/pkg/common/db/mysql_model/im_mysql_model/statistics_model.go b/pkg/common/db/mysql_model/im_mysql_model/statistics_model.go index 097c83185..aa07c1688 100644 --- a/pkg/common/db/mysql_model/im_mysql_model/statistics_model.go +++ b/pkg/common/db/mysql_model/im_mysql_model/statistics_model.go @@ -10,7 +10,7 @@ func GetActiveUserNum(from, to time.Time) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("chat_logs").Select("count(distinct(send_id))").Where("create_time >= ? and create_time <= ?", from, to).Count(&num).Error return num, err @@ -21,7 +21,7 @@ func GetIncreaseUserNum(from, to time.Time) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("users").Where("create_time >= ? and create_time <= ?", from, to).Count(&num).Error return num, err @@ -32,7 +32,7 @@ func GetTotalUserNum() (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("users").Count(&num).Error return num, err @@ -43,7 +43,7 @@ func GetTotalUserNumByDate(to time.Time) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("users").Where("create_time <= ?", to).Count(&num).Error return num, err @@ -54,7 +54,7 @@ func GetPrivateMessageNum(from, to time.Time) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("chat_logs").Where("create_time >= ? and create_time <= ? and session_type = ?", from, to, 1).Count(&num).Error return num, err @@ -65,7 +65,7 @@ func GetGroupMessageNum(from, to time.Time) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("chat_logs").Where("create_time >= ? and create_time <= ? and session_type = ?", from, to, 2).Count(&num).Error return num, err @@ -76,7 +76,7 @@ func GetIncreaseGroupNum(from, to time.Time) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("groups").Where("create_time >= ? and create_time <= ?", from, to).Count(&num).Error return num, err @@ -87,7 +87,7 @@ func GetTotalGroupNum() (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("groups").Count(&num).Error return num, err @@ -98,7 +98,7 @@ func GetGroupNum(to time.Time) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var num int32 err = dbConn.Table("groups").Where("create_time <= ?", to).Count(&num).Error return num, err @@ -116,7 +116,7 @@ func GetActiveGroups(from, to time.Time, limit int) ([]*activeGroup, error) { if err != nil { return activeGroups, err } - dbConn.LogMode(true) + dbConn.LogMode(false) err = dbConn.Table("chat_logs").Select("recv_id, count(*) as message_num").Where("create_time >= ? and create_time <= ? and session_type = ?", from, to, 2).Group("recv_id").Limit(limit).Order("message_num DESC").Find(&activeGroups).Error for _, activeGroup := range activeGroups { group := db.Group{ @@ -140,7 +140,7 @@ func GetActiveUsers(from, to time.Time, limit int) ([]*activeUser, error) { if err != nil { return activeUsers, err } - dbConn.LogMode(true) + dbConn.LogMode(false) err = dbConn.Table("chat_logs").Select("send_id, count(*) as message_num").Where("create_time >= ? and create_time <= ? and session_type = ?", from, to, 1).Group("send_id").Limit(limit).Order("message_num DESC").Find(&activeUsers).Error for _, activeUser := range activeUsers { user := db.User{ diff --git a/pkg/common/db/mysql_model/im_mysql_model/user_model.go b/pkg/common/db/mysql_model/im_mysql_model/user_model.go index 5719371c5..003b7afa7 100644 --- a/pkg/common/db/mysql_model/im_mysql_model/user_model.go +++ b/pkg/common/db/mysql_model/im_mysql_model/user_model.go @@ -92,7 +92,7 @@ func UpdateUserInfo(user db.User) error { if err != nil { return err } - dbConn.LogMode(true) + dbConn.LogMode(false) err = dbConn.Table("users").Where("user_id=?", user.UserID).Update(&user).Error return err } @@ -112,7 +112,7 @@ func SelectAllUserID() ([]string, error) { func SelectSomeUserID(userIDList []string) ([]string, error) { dbConn, err := db.DB.MysqlDB.DefaultGormDB() - dbConn.LogMode(true) + dbConn.LogMode(false) if err != nil { return nil, err } @@ -131,7 +131,7 @@ func GetUsers(showNumber, pageNumber int32) ([]db.User, error) { if err != nil { return users, err } - dbConn.LogMode(true) + dbConn.LogMode(false) err = dbConn.Table("users").Limit(showNumber).Offset(showNumber * (pageNumber - 1)).Find(&users).Error if err != nil { return users, err @@ -204,7 +204,7 @@ func UnBlockUser(userId string) error { if err != nil { return err } - dbConn.LogMode(true) + dbConn.LogMode(false) result := dbConn.Where("uid=?", userId).Delete(&db.BlackList{}) return result.Error } @@ -248,7 +248,7 @@ func GetBlockUsers(showNumber, pageNumber int32) ([]BlockUserInfo, error) { if err != nil { return blockUserInfos, err } - dbConn.LogMode(true) + dbConn.LogMode(false) if err = dbConn.Limit(showNumber).Offset(showNumber * (pageNumber - 1)).Find(&blockUsers).Error; err != nil { return blockUserInfos, err } @@ -275,7 +275,7 @@ func GetUserByName(userName string, showNumber, pageNumber int32) ([]db.User, er if err != nil { return users, err } - dbConn.LogMode(true) + dbConn.LogMode(false) err = dbConn.Table("users").Where(fmt.Sprintf(" name like '%%%s%%' ", userName)).Limit(showNumber).Offset(showNumber * (pageNumber - 1)).Find(&users).Error return users, err } @@ -285,7 +285,7 @@ func GetUsersCount(user db.User) (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var count int32 if err := dbConn.Table("users").Where(fmt.Sprintf(" name like '%%%s%%' ", user.Nickname)).Count(&count).Error; err != nil { return 0, err @@ -298,7 +298,7 @@ func GetBlockUsersNumCount() (int32, error) { if err != nil { return 0, err } - dbConn.LogMode(true) + dbConn.LogMode(false) var count int32 if err := dbConn.Model(&db.BlackList{}).Count(&count).Error; err != nil { return 0, err @@ -311,7 +311,7 @@ func SetConversation(conversation db.Conversation) error { if err != nil { return err } - dbConn.LogMode(true) + dbConn.LogMode(false) newConversation := conversation if dbConn.Model(&db.Conversation{}).Find(&newConversation).RowsAffected == 0 { log.NewDebug("", utils.GetSelfFuncName(), "conversation", conversation, "not exist in db, create") @@ -330,7 +330,7 @@ func PeerUserSetConversation(conversation db.Conversation) error { if err != nil { return err } - dbConn.LogMode(true) + dbConn.LogMode(false) newConversation := conversation if dbConn.Model(&db.Conversation{}).Find(&newConversation).RowsAffected == 0 { log.NewDebug("", utils.GetSelfFuncName(), "conversation", conversation, "not exist in db, create") @@ -349,7 +349,7 @@ func SetRecvMsgOpt(conversation db.Conversation) error { if err != nil { return err } - dbConn.LogMode(true) + dbConn.LogMode(false) newConversation := conversation if dbConn.Model(&db.Conversation{}).Find(&newConversation).RowsAffected == 0 { log.NewDebug("", utils.GetSelfFuncName(), "conversation", conversation, "not exist in db, create") @@ -369,7 +369,7 @@ func GetUserAllConversations(ownerUserID string) ([]db.Conversation, error) { if err != nil { return conversations, err } - dbConn.LogMode(true) + dbConn.LogMode(false) err = dbConn.Model(&db.Conversation{}).Where("owner_user_id=?", ownerUserID).Find(&conversations).Error return conversations, err } From 69aba02c9a60a052c8fbbfabe6536b1e79b786fa Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Wed, 6 Apr 2022 16:47:22 +0800 Subject: [PATCH 06/21] send tag modify --- internal/rpc/msg/tag_send_msg.go | 11 +++++++---- internal/rpc/office/office.go | 7 ++++++- 2 files changed, 13 insertions(+), 5 deletions(-) diff --git a/internal/rpc/msg/tag_send_msg.go b/internal/rpc/msg/tag_send_msg.go index 7f0550d62..195640498 100644 --- a/internal/rpc/msg/tag_send_msg.go +++ b/internal/rpc/msg/tag_send_msg.go @@ -3,6 +3,7 @@ package msg import ( "Open_IM/pkg/common/config" "Open_IM/pkg/common/constant" + "Open_IM/pkg/common/db" "Open_IM/pkg/common/log" "Open_IM/pkg/grpc-etcdv3/getcdv3" pbChat "Open_IM/pkg/proto/chat" @@ -12,20 +13,22 @@ import ( "strings" ) -func TagSendMessage(operationID, sendID, recvID, content string, senderPlatformID int32) { - log.NewInfo(operationID, utils.GetSelfFuncName(), "args: ", sendID, recvID, content) +func TagSendMessage(operationID string, user *db.User, recvID, content string, senderPlatformID int32) { + log.NewInfo(operationID, utils.GetSelfFuncName(), "args: ", user.UserID, recvID, content) var req pbChat.SendMsgReq var msgData pbCommon.MsgData - msgData.SendID = sendID + msgData.SendID = user.UserID msgData.RecvID = recvID msgData.ContentType = constant.Custom msgData.SessionType = constant.SingleChatType msgData.MsgFrom = constant.UserMsgType msgData.Content = []byte(content) + msgData.SenderFaceURL = user.FaceURL + msgData.SenderNickname = user.Nickname msgData.Options = map[string]bool{} msgData.Options[constant.IsSenderConversationUpdate] = false msgData.CreateTime = utils.GetCurrentTimestampByMill() - msgData.ClientMsgID = utils.GetMsgID(sendID) + msgData.ClientMsgID = utils.GetMsgID(user.UserID) msgData.SenderPlatformID = senderPlatformID req.MsgData = &msgData req.OperationID = operationID diff --git a/internal/rpc/office/office.go b/internal/rpc/office/office.go index b390b99bc..43e757497 100644 --- a/internal/rpc/office/office.go +++ b/internal/rpc/office/office.go @@ -6,6 +6,7 @@ import ( "Open_IM/pkg/common/constant" "Open_IM/pkg/common/db" "Open_IM/pkg/common/db/mysql_model/im_mysql_model" + imdb "Open_IM/pkg/common/db/mysql_model/im_mysql_model" "Open_IM/pkg/common/log" "Open_IM/pkg/grpc-etcdv3/getcdv3" pbOffice "Open_IM/pkg/proto/office" @@ -179,8 +180,12 @@ func (s *officeServer) SendMsg2Tag(_ context.Context, req *pbOffice.SendMsg2TagR } } log.NewInfo(req.OperationID, utils.GetSelfFuncName(), "total userIDList result: ", userIDList) + us, err := imdb.GetUserByUserID(req.SendID) + if err != nil { + log.NewError(req.OperationID, "GetUserByUserID failed ", err.Error(), req.SendID) + } for _, userID := range userIDList { - msg.TagSendMessage(req.OperationID, req.SendID, userID, req.Content, req.SenderPlatformID) + msg.TagSendMessage(req.OperationID, us, userID, req.Content, req.SenderPlatformID) } var tagSendLogs db.TagSendLog for _, userID := range userIDList { From 4efdabc1ffca43f821da7ca630d7b28052fce8ae Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 15:40:07 +0800 Subject: [PATCH 07/21] getui --- config/config.yaml | 10 ++ internal/cms_api/group/group.go | 5 +- internal/push/getui/push.go | 146 +++++++++++++++++++++++++- internal/push/jpush/push.go | 33 ++++-- internal/push/logic/push_to_client.go | 19 +++- internal/push/push_interface.go | 5 +- internal/rpc/group/callback.go | 4 + internal/rpc/group/group.go | 5 + internal/rpc/msg/tag_send_msg.go | 2 +- pkg/cms_api_struct/group.go | 28 +++-- pkg/common/config/config.go | 9 ++ pkg/common/constant/constant.go | 2 +- pkg/common/db/redisModel.go | 11 ++ pkg/common/http/http_resp.go | 4 +- 14 files changed, 240 insertions(+), 43 deletions(-) diff --git a/config/config.yaml b/config/config.yaml index 452d529a6..003d6f969 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -165,6 +165,7 @@ longconnsvr: websocketMaxMsgLen: 4096 websocketTimeOut: 10 +## 推送只能开启一个 push: tpns: #腾讯推送，暂未测试 暂不要使用 ios: @@ -173,11 +174,20 @@ push: android: accessID: 111 secretKey: 111 + enable: false jpns: #极光推送 在极光后台申请后，修改以下四项，必须修改 appKey: cf47465a368f24c659608e7e masterSecret: 02204efe3f3832947a236ee5 pushUrl: "https://api.jpush.cn/v3/push" pushIntent: "intent:#Intent;component=io.openim.app.enterprisechat/io.openim.app.enterprisechat.MainActivity;end" + enable: false + getui: #个推推送，暂未测试 暂不要使用 + pushUrl: "https://restapi.getui.com/v2/$appId" + sign: "" + appKey: "" + enable: true + intent: "" + manager: #app管理员userID和对应的secret 建议修改。 用于管理后台登录，也可以用户管理后台对应的api appManagerUid: [ "openIM123456","openIM654321", "openIM333", "openIMAdmin"] diff --git a/internal/cms_api/group/group.go b/internal/cms_api/group/group.go index c7013c2bd..740fd5821 100644 --- a/internal/cms_api/group/group.go +++ b/internal/cms_api/group/group.go @@ -43,6 +43,7 @@ func GetGroupById(c *gin.Context) { resp.ProfilePhoto = respPb.CMSGroup.GroupInfo.FaceURL resp.GroupMasterName = respPb.CMSGroup.GroupMasterName resp.GroupMasterId = respPb.CMSGroup.GroupMasterId + resp.IsBanChat = constant.GroupIsBanChat(respPb.CMSGroup.GroupInfo.Status) openIMHttp.RespHttp200(c, constant.OK, resp) } @@ -74,7 +75,7 @@ func GetGroups(c *gin.Context) { GroupMasterName: v.GroupMasterName, GroupMasterId: v.GroupMasterId, CreateTime: (utils.UnixSecondToTime(int64(v.GroupInfo.CreateTime))).String(), - IsBanChat: false, + IsBanChat: constant.GroupIsBanChat(v.GroupInfo.Status), IsBanPrivateChat: false, ProfilePhoto: v.GroupInfo.FaceURL, }) @@ -114,7 +115,7 @@ func GetGroupByName(c *gin.Context) { GroupMasterName: v.GroupMasterName, GroupMasterId: v.GroupMasterId, CreateTime: (utils.UnixSecondToTime(int64(v.GroupInfo.CreateTime))).String(), - IsBanChat: false, + IsBanChat: constant.GroupIsBanChat(v.GroupInfo.Status), IsBanPrivateChat: false, ProfilePhoto: v.GroupInfo.FaceURL, }) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 18d6fd0fc..f834337c8 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -1,12 +1,148 @@ package getui -type Getui struct { +import ( + "Open_IM/pkg/common/config" + "Open_IM/pkg/common/db" + "Open_IM/pkg/common/log" + "Open_IM/pkg/utils" + "bytes" + "encoding/json" + "io/ioutil" + "net/http" + "strconv" + "time" +) + +var ( + GetuiClient *Getui +) + +func init() { + GetuiClient = newGetuiClient() } -func (g *Getui) Push(userIDList []string, alert, detailContent, platform string) (resp string, err error) { - return "", nil +type Getui struct{} + +type GetuiCommonResp struct { + Code int `json:"code"` + Msg string `json:"msg"` + Data interface{} `json:"data"` } -func (g *Getui) Auth(apiKey, secretKey string, timeStamp int64) (token string, err error) { - return "", nil +type AuthReq struct { + Sign string `json:"sign"` + Timestamp string `json:"timestamp"` + Appkey string `json:"appkey"` +} + +type AuthResp struct { + ExpireTime string `json:"expire_time"` + Token string `json:"token"` +} + +type PushReq struct { + RequestID string `json:"request_id"` + Audience struct { + Cid []string `json:"cid"` + } `json:"audience"` + PushMssage struct { + Notification Notification `json:"notification"` + } `json:"push_message"` +} + +type Notification struct { + Title string `json:"title"` + Body string `json:"body"` + ClickType string `json:"click_type"` + Intent string `json:"intent"` + Url string `json:"url"` +} + +type PushResp struct { +} + +func newGetuiClient() *Getui { + return &Getui{} +} + +func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operationID string) (resp string, err error) { + token, err := db.DB.GetGetuiToken() + if err != nil { + log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken", err.Error()) + } + if token == "" || err != nil { + token, expireTime, err := g.Auth(config.Config.Push.Getui.AppKey, config.Config.Push.Getui.Sign, operationID, time.Now().Unix()) + if err != nil { + return "", utils.Wrap(err, "Auth failed") + } + log.NewInfo(operationID, "getui", utils.GetSelfFuncName(), token, expireTime, err) + err = db.DB.SetGetuiToken(token, expireTime-time.Now().Unix()-20) + if err != nil { + return "", utils.Wrap(err, "Auth failed") + } + } + pushReq := PushReq{ + RequestID: utils.OperationIDGenerator(), + Audience: struct { + Cid []string `json:"cid"` + }{Cid: []string{userIDList[0]}}, + } + pushReq.PushMssage.Notification = Notification{ + Title: alert, + Body: alert, + ClickType: "none", + } + if config.Config.Push.Getui.Intent != "" { + pushReq.PushMssage.Notification.Intent = config.Config.Push.Getui.Intent + pushReq.PushMssage.Notification.ClickType = "intent" + } + pushResp := PushResp{} + err = g.request(pushReq, token, &pushResp, operationID) + if err != nil { + return "", utils.Wrap(err, "") + } + respBytes, err := json.Marshal(pushResp) + return string(respBytes), err +} + +func (g *Getui) Auth(appKey, sign, operationID string, timeStamp int64) (token string, expireTime int64, err error) { + log.NewInfo(operationID, utils.GetSelfFuncName(), appKey, sign, timeStamp) + reqAuth := AuthReq{ + Sign: sign, + Timestamp: strconv.Itoa(int(timeStamp)), + Appkey: appKey, + } + respAuth := AuthResp{} + err = g.request(reqAuth, "", &respAuth, operationID) + expire, err := strconv.Atoi(respAuth.ExpireTime) + return respAuth.Token, int64(expire), err +} + +func (g *Getui) request(content interface{}, token string, returnStruct interface{}, operationID string) error { + con, err := json.Marshal(content) + if err != nil { + return err + } + client := &http.Client{} + req, err := http.NewRequest("POST", config.Config.Push.Getui.PushUrl, bytes.NewBuffer(con)) + if err != nil { + return err + } + req.Header.Set(token, token) + req.Header.Set("content-type", "application/json") + req.Header.Set("content-type", "charset=utf-8") + resp, err := client.Do(req) + if err != nil { + return err + } + defer resp.Body.Close() + result, err := ioutil.ReadAll(resp.Body) + if err != nil { + return err + } + log.NewInfo(operationID, "getui", utils.GetSelfFuncName(), string(result)) + if err := json.Unmarshal(result, returnStruct); err != nil { + return err + } + return nil } diff --git a/internal/push/jpush/push.go b/internal/push/jpush/push.go index fbcdb9884..439ee845f 100644 --- a/internal/push/jpush/push.go +++ b/internal/push/jpush/push.go @@ -10,14 +10,29 @@ import ( "net/http" ) -type JPushResp struct { +var ( + JPushClient *JPush +) + +func init() { + JPushClient = newGetuiClient() } -type JPush struct { +type JPush struct{} + +func newGetuiClient() *JPush { + return &JPush{} } -func JGAccountListPush(accounts []string, alert, detailContent, platform string) ([]byte, error) { +func (j *JPush) Auth(apiKey, secretKey string, timeStamp int64) (token string, err error) { + return token, nil +} +func (j *JPush) SetAlias(cid, alias string) (resp string, err error) { + return resp, nil +} + +func (j *JPush) Push(accounts []string, alert, detailContent, platform, operationID string) (string, error) { var pf requestBody.Platform _ = pf.SetPlatform(platform) var au requestBody.Audience @@ -37,25 +52,23 @@ func JGAccountListPush(accounts []string, alert, detailContent, platform string) con, err := json.Marshal(po) if err != nil { - return nil, err + return "", err } - client := &http.Client{} - req, err := http.NewRequest("POST", config.Config.Push.Jpns.PushUrl, bytes.NewBuffer(con)) if err != nil { - return nil, err + return "", err } req.Header.Set("Authorization", common.GetAuthorization(config.Config.Push.Jpns.AppKey, config.Config.Push.Jpns.MasterSecret)) resp, err := client.Do(req) if err != nil { - return nil, err + return "", err } defer resp.Body.Close() result, err := ioutil.ReadAll(resp.Body) if err != nil { - return nil, err + return "", err } - return result, nil + return string(result), nil } diff --git a/internal/push/logic/push_to_client.go b/internal/push/logic/push_to_client.go index a5a6397f2..e527448ce 100644 --- a/internal/push/logic/push_to_client.go +++ b/internal/push/logic/push_to_client.go @@ -7,7 +7,9 @@ package logic import ( - push "Open_IM/internal/push/jpush" + pusher "Open_IM/internal/push" + "Open_IM/internal/push/getui" + jpush "Open_IM/internal/push/jpush" "Open_IM/pkg/common/config" "Open_IM/pkg/common/constant" "Open_IM/pkg/common/log" @@ -99,12 +101,21 @@ func MsgToUser(pushMsg *pbPush.PushMsgReq) { content = constant.ContentType2PushContent[constant.Common] } } - - pushResult, err := push.JGAccountListPush(UIDList, content, jsonCustomContent, constant.PlatformIDToName(t)) + var offlinePusher pusher.OfflinePusher + if config.Config.Push.Getui.Enable { + offlinePusher = getui.GetuiClient + } + if config.Config.Push.Jpns.Enable { + offlinePusher = jpush.JPushClient + } + if offlinePusher == nil { + offlinePusher = jpush.JPushClient + } + pushResult, err := offlinePusher.Push(UIDList, content, jsonCustomContent, constant.PlatformIDToName(t), pushMsg.OperationID) if err != nil { log.NewError(pushMsg.OperationID, "offline push error", pushMsg.String(), err.Error(), constant.PlatformIDToName(t)) } else { - log.NewDebug(pushMsg.OperationID, "offline push return result is ", string(pushResult), pushMsg.MsgData, constant.PlatformIDToName(t)) + log.NewDebug(pushMsg.OperationID, "offline push return result is ", pushResult, pushMsg.MsgData, constant.PlatformIDToName(t)) } } diff --git a/internal/push/push_interface.go b/internal/push/push_interface.go index ea752d149..f89fcf664 100644 --- a/internal/push/push_interface.go +++ b/internal/push/push_interface.go @@ -1,6 +1,5 @@ package push -type offlinePusher interface { - auth(apiKey, secretKey string, timeStamp int64) (token string, err error) - push(userIDList []string, alert, detailContent, platform string) (resp string, err error) +type OfflinePusher interface { + Push(userIDList []string, alert, detailContent, platform, operationID string) (resp string, err error) } diff --git a/internal/rpc/group/callback.go b/internal/rpc/group/callback.go index 8e0fcfb7b..1e9e612a6 100644 --- a/internal/rpc/group/callback.go +++ b/internal/rpc/group/callback.go @@ -7,3 +7,7 @@ import ( func callbackBeforeCreateGroup(req *pbGroup.CreateGroupReq) (bool, error) { return true, nil } + +func callbackAfterCreateGroup(req *pbGroup.CreateGroupReq) { + +} diff --git a/internal/rpc/group/group.go b/internal/rpc/group/group.go index edece9829..6fa270394 100644 --- a/internal/rpc/group/group.go +++ b/internal/rpc/group/group.go @@ -668,6 +668,7 @@ func (s *groupServer) GetGroupById(_ context.Context, req *pbGroup.GetGroupByIdR Status: group.Status, CreatorUserID: group.CreatorUserID, GroupType: group.GroupType, + CreateTime: uint32(group.CreateTime.Unix()), } groupMember, err := imdb.GetGroupMaster(group.GroupID) if err != nil { @@ -677,6 +678,7 @@ func (s *groupServer) GetGroupById(_ context.Context, req *pbGroup.GetGroupByIdR resp.CMSGroup.GroupMasterName = groupMember.Nickname resp.CMSGroup.GroupMasterId = groupMember.UserID resp.CMSGroup.GroupInfo.CreatorUserID = group.CreatorUserID + log.NewInfo(req.OperationID, utils.GetSelfFuncName(), "resp: ", resp.String()) return resp, nil } @@ -704,6 +706,7 @@ func (s *groupServer) GetGroup(_ context.Context, req *pbGroup.GetGroupReq) (*pb groupMember, err := imdb.GetGroupMaster(v.GroupID) if err != nil { log.NewError(req.OperationID, utils.GetSelfFuncName(), "GetGroupMaster error", err.Error()) + continue } resp.CMSGroups = append(resp.CMSGroups, &pbGroup.CMSGroup{ GroupInfo: &open_im_sdk.GroupInfo{ @@ -713,11 +716,13 @@ func (s *groupServer) GetGroup(_ context.Context, req *pbGroup.GetGroupReq) (*pb OwnerUserID: v.CreatorUserID, Status: v.Status, CreatorUserID: v.CreatorUserID, + CreateTime: uint32(v.CreateTime.Unix()), }, GroupMasterName: groupMember.Nickname, GroupMasterId: groupMember.UserID, }) } + log.NewInfo(req.OperationID, utils.GetSelfFuncName(), "resp: ", resp.String()) return resp, nil } diff --git a/internal/rpc/msg/tag_send_msg.go b/internal/rpc/msg/tag_send_msg.go index 7f0550d62..12da1dd44 100644 --- a/internal/rpc/msg/tag_send_msg.go +++ b/internal/rpc/msg/tag_send_msg.go @@ -13,7 +13,7 @@ import ( ) func TagSendMessage(operationID, sendID, recvID, content string, senderPlatformID int32) { - log.NewInfo(operationID, utils.GetSelfFuncName(), "args: ", sendID, recvID, content) + log.NewInfo(operationID, utils.GetSelfFuncName(), "args: ", sendID, recvID, content, senderPlatformID) var req pbChat.SendMsgReq var msgData pbCommon.MsgData msgData.SendID = sendID diff --git a/pkg/cms_api_struct/group.go b/pkg/cms_api_struct/group.go index 9d161b622..7d3333127 100644 --- a/pkg/cms_api_struct/group.go +++ b/pkg/cms_api_struct/group.go @@ -8,7 +8,7 @@ type GroupResponse struct { CreateTime string `json:"create_time"` IsBanChat bool `json:"is_ban_chat"` IsBanPrivateChat bool `json:"is_ban_private_chat"` - ProfilePhoto string `json:"profile_photo"` + ProfilePhoto string `json:"profile_photo"` } type GetGroupByIdRequest struct { @@ -63,7 +63,6 @@ type SetGroupMemberRequest struct { } type SetGroupMemberRespones struct { - } type BanGroupChatRequest struct { @@ -88,7 +87,7 @@ type DeleteGroupResponse struct { } type GetGroupMembersRequest struct { - GroupId string `form:"group_id" binding:"required"` + GroupId string `form:"group_id" binding:"required"` UserName string `form:"user_name"` RequestPagination } @@ -96,24 +95,24 @@ type GetGroupMembersRequest struct { type GroupMemberResponse struct { MemberPosition int `json:"member_position"` MemberNickName string `json:"member_nick_name"` - MemberId string `json:"member_id"` + MemberId string `json:"member_id"` JoinTime string `json:"join_time"` } type GetGroupMembersResponse struct { - GroupMembers []GroupMemberResponse `json:"group_members"` + GroupMembers []GroupMemberResponse `json:"group_members"` ResponsePagination MemberNums int `json:"member_nums"` } type GroupMemberRequest struct { - GroupId string `json:"group_id" binding:"required"` + GroupId string `json:"group_id" binding:"required"` Members []string `json:"members" binding:"required"` } type GroupMemberOperateResponse struct { Success []string `json:"success"` - Failed []string `json:"failed"` + Failed []string `json:"failed"` } type AddGroupMembersRequest struct { @@ -128,19 +127,18 @@ type RemoveGroupMembersRequest struct { GroupMemberRequest } -type RemoveGroupMembersResponse struct{ +type RemoveGroupMembersResponse struct { GroupMemberOperateResponse } type AlterGroupInfoRequest struct { - GroupID string `json:"group_id"` - GroupName string `json:"group_name"` - Notification string `json:"notification"` - Introduction string `json:"introduction"` - ProfilePhoto string `json:"profile_photo"` - GroupType int `json:"group_type"` + GroupID string `json:"group_id"` + GroupName string `json:"group_name"` + Notification string `json:"notification"` + Introduction string `json:"introduction"` + ProfilePhoto string `json:"profile_photo"` + GroupType int `json:"group_type"` } type AlterGroupInfoResponse struct { - } diff --git a/pkg/common/config/config.go b/pkg/common/config/config.go index 8b174f993..5e8eb1e21 100644 --- a/pkg/common/config/config.go +++ b/pkg/common/config/config.go @@ -152,12 +152,21 @@ type config struct { AccessID string `yaml:"accessID"` SecretKey string `yaml:"secretKey"` } + Enable bool `yaml:"enable"` } Jpns struct { AppKey string `yaml:"appKey"` MasterSecret string `yaml:"masterSecret"` PushUrl string `yaml:"pushUrl"` PushIntent string `yaml:"pushIntent"` + Enable bool `yaml:"enable"` + } + Getui struct { + PushUrl string `yaml:"pushUrl"` + Sign string `yaml:"sign"` + AppKey string `yaml:"appkey"` + Enable bool `yaml:"enable"` + Intent string `yaml:"intent"` } } Manager struct { diff --git a/pkg/common/constant/constant.go b/pkg/common/constant/constant.go index 98dfa6092..fdee4f2b7 100644 --- a/pkg/common/constant/constant.go +++ b/pkg/common/constant/constant.go @@ -217,7 +217,7 @@ const ( const FriendAcceptTip = "You have successfully become friends, so start chatting" func GroupIsBanChat(status int32) bool { - if status != GroupBanChat { + if status != GroupStatusMuted { return false } return true diff --git a/pkg/common/db/redisModel.go b/pkg/common/db/redisModel.go index c5594da9a..2faa9a6d8 100644 --- a/pkg/common/db/redisModel.go +++ b/pkg/common/db/redisModel.go @@ -14,6 +14,7 @@ const ( userMinSeq = "REDIS_USER_MIN_SEQ:" uidPidToken = "UID_PID_TOKEN_STATUS:" conversationReceiveMessageOpt = "CON_RECV_MSG_OPT:" + GetuiToken = "GETUI" ) func (d *DataBases) Exec(cmd string, key interface{}, args ...interface{}) (interface{}, error) { @@ -144,3 +145,13 @@ func (d *DataBases) GetMultiConversationMsgOpt(userID string, conversationIDs [] return m, nil } + +func (d *DataBases) SetGetuiToken(token string, expireTime int64) error { + _, err := d.Exec("SET", GetuiToken, token, "ex", expireTime) + return err +} + +func (d *DataBases) GetGetuiToken() (string, error) { + result, err := redis.String(d.Exec("GET", GetuiToken)) + return result, err +} diff --git a/pkg/common/http/http_resp.go b/pkg/common/http/http_resp.go index cdbf04463..8292b6884 100644 --- a/pkg/common/http/http_resp.go +++ b/pkg/common/http/http_resp.go @@ -38,6 +38,6 @@ func RespHttp200(ctx *gin.Context, err error, data interface{}) { } // warp error -func WrapError(err constant.ErrInfo) error { - return status.Error(codes.Code(err.ErrCode), err.ErrMsg) +func WrapError(err constant.ErrInfo, msg ...string) error { + return status.Error(codes.Code(err.ErrCode), err.ErrMsg+msg[0]) } From cbe3abeab05c530e36c54a5493a4f626b0bbf6ee Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 16:15:22 +0800 Subject: [PATCH 08/21] getui --- config/config.yaml | 6 ++++-- internal/push/getui/push.go | 15 +++++++++++---- internal/push/logic/push_to_client.go | 1 + pkg/common/config/config.go | 10 +++++----- 4 files changed, 21 insertions(+), 11 deletions(-) diff --git a/config/config.yaml b/config/config.yaml index 003d6f969..890a4c094 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -183,10 +183,12 @@ push: enable: false getui: #个推推送，暂未测试 暂不要使用 pushUrl: "https://restapi.getui.com/v2/$appId" - sign: "" + masterSecret: "" appKey: "" - enable: true intent: "" + enable: true + + manager: #app管理员userID和对应的secret 建议修改。 用于管理后台登录，也可以用户管理后台对应的api diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index f834337c8..5298441f8 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -6,6 +6,8 @@ import ( "Open_IM/pkg/common/log" "Open_IM/pkg/utils" "bytes" + "crypto/sha512" + "encoding/hex" "encoding/json" "io/ioutil" "net/http" @@ -71,7 +73,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken", err.Error()) } if token == "" || err != nil { - token, expireTime, err := g.Auth(config.Config.Push.Getui.AppKey, config.Config.Push.Getui.Sign, operationID, time.Now().Unix()) + token, expireTime, err := g.Auth(+operationID, time.Now().Unix()) if err != nil { return "", utils.Wrap(err, "Auth failed") } @@ -105,12 +107,17 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat return string(respBytes), err } -func (g *Getui) Auth(appKey, sign, operationID string, timeStamp int64) (token string, expireTime int64, err error) { - log.NewInfo(operationID, utils.GetSelfFuncName(), appKey, sign, timeStamp) +func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireTime int64, err error) { + log.NewInfo(operationID, utils.GetSelfFuncName(), timeStamp) + h := sha512.New() + h.Write([]byte(config.Config.Push.Getui.AppKey + strconv.Itoa(int(timeStamp)) + config.Config.Push.Getui.MasterSecret)) + sum := h.Sum(nil) + sign := hex.EncodeToString(sum) + log.NewInfo(operationID, utils.GetSelfFuncName(), "sha256 result", sign) reqAuth := AuthReq{ Sign: sign, Timestamp: strconv.Itoa(int(timeStamp)), - Appkey: appKey, + Appkey: config.Config.Push.Getui.AppKey, } respAuth := AuthResp{} err = g.request(reqAuth, "", &respAuth, operationID) diff --git a/internal/push/logic/push_to_client.go b/internal/push/logic/push_to_client.go index e527448ce..c6e512ccb 100644 --- a/internal/push/logic/push_to_client.go +++ b/internal/push/logic/push_to_client.go @@ -103,6 +103,7 @@ func MsgToUser(pushMsg *pbPush.PushMsgReq) { } var offlinePusher pusher.OfflinePusher if config.Config.Push.Getui.Enable { + log.NewInfo(pushMsg.OperationID, utils.GetSelfFuncName(), config.Config.Push.Getui) offlinePusher = getui.GetuiClient } if config.Config.Push.Jpns.Enable { diff --git a/pkg/common/config/config.go b/pkg/common/config/config.go index 5e8eb1e21..21af4ced0 100644 --- a/pkg/common/config/config.go +++ b/pkg/common/config/config.go @@ -162,11 +162,11 @@ type config struct { Enable bool `yaml:"enable"` } Getui struct { - PushUrl string `yaml:"pushUrl"` - Sign string `yaml:"sign"` - AppKey string `yaml:"appkey"` - Enable bool `yaml:"enable"` - Intent string `yaml:"intent"` + PushUrl string `yaml:"pushUrl"` + AppKey string `yaml:"appkey"` + Enable bool `yaml:"enable"` + Intent string `yaml:"intent"` + MasterSecret string `yaml:"masterSecret"` } } Manager struct { From 49424b8b5652951d86aab276550382e392bd6d64 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 16:23:53 +0800 Subject: [PATCH 09/21] getui --- internal/push/getui/push.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 5298441f8..37c15e3c9 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -73,7 +73,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken", err.Error()) } if token == "" || err != nil { - token, expireTime, err := g.Auth(+operationID, time.Now().Unix()) + token, expireTime, err := g.Auth(operationID, time.Now().Unix()) if err != nil { return "", utils.Wrap(err, "Auth failed") } From b3b7ae26cf5d93ea0e9a9e26a5bd7b9898fda4f9 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 16:40:39 +0800 Subject: [PATCH 10/21] getui --- internal/push/getui/push.go | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 37c15e3c9..18ae45c9b 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -70,7 +70,7 @@ func newGetuiClient() *Getui { func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operationID string) (resp string, err error) { token, err := db.DB.GetGetuiToken() if err != nil { - log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken", err.Error()) + log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken failed", err.Error()) } if token == "" || err != nil { token, expireTime, err := g.Auth(operationID, time.Now().Unix()) @@ -101,7 +101,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat pushResp := PushResp{} err = g.request(pushReq, token, &pushResp, operationID) if err != nil { - return "", utils.Wrap(err, "") + return "", utils.Wrap(err, "push failed") } respBytes, err := json.Marshal(pushResp) return string(respBytes), err @@ -121,6 +121,10 @@ func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireT } respAuth := AuthResp{} err = g.request(reqAuth, "", &respAuth, operationID) + if err != nil { + return "", 0, err + } + log.NewInfo(operationID, utils.GetSelfFuncName(), "result: ", respAuth) expire, err := strconv.Atoi(respAuth.ExpireTime) return respAuth.Token, int64(expire), err } @@ -135,7 +139,9 @@ func (g *Getui) request(content interface{}, token string, returnStruct interfac if err != nil { return err } - req.Header.Set(token, token) + if token != "" { + req.Header.Set(token, token) + } req.Header.Set("content-type", "application/json") req.Header.Set("content-type", "charset=utf-8") resp, err := client.Do(req) From 046c5238804c91760aabdde20842f7bf800a1eab Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 17:00:28 +0800 Subject: [PATCH 11/21] getui --- internal/push/getui/push.go | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 18ae45c9b..95080f0b8 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -19,6 +19,11 @@ var ( GetuiClient *Getui ) +const ( + PushURL = "/push/single/cid" + AuthURL = "/auth" +) + func init() { GetuiClient = newGetuiClient() } @@ -99,7 +104,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat pushReq.PushMssage.Notification.ClickType = "intent" } pushResp := PushResp{} - err = g.request(pushReq, token, &pushResp, operationID) + err = g.request(PushURL, pushReq, token, &pushResp, operationID) if err != nil { return "", utils.Wrap(err, "push failed") } @@ -120,7 +125,7 @@ func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireT Appkey: config.Config.Push.Getui.AppKey, } respAuth := AuthResp{} - err = g.request(reqAuth, "", &respAuth, operationID) + err = g.request(AuthURL, reqAuth, "", &respAuth, operationID) if err != nil { return "", 0, err } @@ -129,7 +134,7 @@ func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireT return respAuth.Token, int64(expire), err } -func (g *Getui) request(content interface{}, token string, returnStruct interface{}, operationID string) error { +func (g *Getui) request(url, content interface{}, token string, returnStruct interface{}, operationID string) error { con, err := json.Marshal(content) if err != nil { return err From f40369d0610285d2fd68881e0885d92a5a4035e4 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 17:12:11 +0800 Subject: [PATCH 12/21] getui --- internal/push/getui/push.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 95080f0b8..ac40368ed 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -134,13 +134,13 @@ func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireT return respAuth.Token, int64(expire), err } -func (g *Getui) request(url, content interface{}, token string, returnStruct interface{}, operationID string) error { +func (g *Getui) request(url string, content interface{}, token string, returnStruct interface{}, operationID string) error { con, err := json.Marshal(content) if err != nil { return err } client := &http.Client{} - req, err := http.NewRequest("POST", config.Config.Push.Getui.PushUrl, bytes.NewBuffer(con)) + req, err := http.NewRequest("POST", config.Config.Push.Getui.PushUrl+url, bytes.NewBuffer(con)) if err != nil { return err } From 691e2580e5f02fdf378c25797f53e6fa83c6df99 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 17:17:26 +0800 Subject: [PATCH 13/21] getui --- internal/push/getui/push.go | 1 + 1 file changed, 1 insertion(+) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index ac40368ed..62c233523 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -140,6 +140,7 @@ func (g *Getui) request(url string, content interface{}, token string, returnStr return err } client := &http.Client{} + log.Debug(operationID, utils.GetSelfFuncName(), "json:", string(con)) req, err := http.NewRequest("POST", config.Config.Push.Getui.PushUrl+url, bytes.NewBuffer(con)) if err != nil { return err From 06370a763c3f917e02cec5def9dcae0d08adbf32 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 17:20:55 +0800 Subject: [PATCH 14/21] getui --- pkg/common/config/config.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/common/config/config.go b/pkg/common/config/config.go index 21af4ced0..b497ee268 100644 --- a/pkg/common/config/config.go +++ b/pkg/common/config/config.go @@ -163,7 +163,7 @@ type config struct { } Getui struct { PushUrl string `yaml:"pushUrl"` - AppKey string `yaml:"appkey"` + AppKey string `yaml:"appKey"` Enable bool `yaml:"enable"` Intent string `yaml:"intent"` MasterSecret string `yaml:"masterSecret"` From fdefe09187ef8a96cf0dbad4fe1341a7dcb088fb Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 17:32:58 +0800 Subject: [PATCH 15/21] getui --- internal/push/getui/push.go | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 62c233523..040a25d49 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -149,7 +149,6 @@ func (g *Getui) request(url string, content interface{}, token string, returnStr req.Header.Set(token, token) } req.Header.Set("content-type", "application/json") - req.Header.Set("content-type", "charset=utf-8") resp, err := client.Do(req) if err != nil { return err @@ -159,7 +158,7 @@ func (g *Getui) request(url string, content interface{}, token string, returnStr if err != nil { return err } - log.NewInfo(operationID, "getui", utils.GetSelfFuncName(), string(result)) + log.NewInfo(operationID, "getui", utils.GetSelfFuncName(), "resp, ", string(result)) if err := json.Unmarshal(result, returnStruct); err != nil { return err } From a16025ca955c7706e8391127b3ad3eef3a2543be Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 17:41:39 +0800 Subject: [PATCH 16/21] getui --- internal/push/getui/push.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 040a25d49..d68830a2c 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -78,7 +78,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat log.NewError(operationID, utils.OperationIDGenerator(), "GetGetuiToken failed", err.Error()) } if token == "" || err != nil { - token, expireTime, err := g.Auth(operationID, time.Now().Unix()) + token, expireTime, err := g.Auth(operationID, time.Now().UnixNano()/1e6) if err != nil { return "", utils.Wrap(err, "Auth failed") } From 4ae3ad7abdcafab3348ac0b7b5167735b208ee3d Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 17:48:16 +0800 Subject: [PATCH 17/21] getui --- internal/push/getui/push.go | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index d68830a2c..b568d4219 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -6,6 +6,7 @@ import ( "Open_IM/pkg/common/log" "Open_IM/pkg/utils" "bytes" + "crypto/sha256" "crypto/sha512" "encoding/hex" "encoding/json" @@ -114,7 +115,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireTime int64, err error) { log.NewInfo(operationID, utils.GetSelfFuncName(), timeStamp) - h := sha512.New() + h := sha256.New() h.Write([]byte(config.Config.Push.Getui.AppKey + strconv.Itoa(int(timeStamp)) + config.Config.Push.Getui.MasterSecret)) sum := h.Sum(nil) sign := hex.EncodeToString(sum) From 2a0f8f5ce3588eefe4dabd03c9c9d7eff4e7a590 Mon Sep 17 00:00:00 2001 From: Gordon <1432970085@qq.com> Date: Fri, 8 Apr 2022 17:55:44 +0800 Subject: [PATCH 18/21] note --- cmd/Open-IM-SDK-Core | 2 +- pkg/utils/utils.go | 4 ++++ 2 files changed, 5 insertions(+), 1 deletion(-) diff --git a/cmd/Open-IM-SDK-Core b/cmd/Open-IM-SDK-Core index 2257ac8ee..9d67999ce 160000 --- a/cmd/Open-IM-SDK-Core +++ b/cmd/Open-IM-SDK-Core @@ -1 +1 @@ -Subproject commit 2257ac8ee528fb1e0038f85e34c8770fbe4758e3 +Subproject commit 9d67999cec3e4a9792c33a95e5514a945df54052 diff --git a/pkg/utils/utils.go b/pkg/utils/utils.go index d23b1633a..8f0b52d72 100644 --- a/pkg/utils/utils.go +++ b/pkg/utils/utils.go @@ -39,6 +39,8 @@ func cleanUpFuncName(funcName string) string { } return funcName[end+1:] } + +//Get the intersection of two slices func Intersect(slice1, slice2 []uint32) []uint32 { m := make(map[uint32]bool) n := make([]uint32, 0) @@ -53,6 +55,8 @@ func Intersect(slice1, slice2 []uint32) []uint32 { } return n } + +//Get the diff of two slices func Difference(slice1, slice2 []uint32) []uint32 { m := make(map[uint32]bool) n := make([]uint32, 0) From f11f8b3e0ee56c6d751e9fdce9a1b4e6fcdff20d Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 18:27:20 +0800 Subject: [PATCH 19/21] getui --- internal/push/getui/push.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index b568d4219..8139eea0b 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -84,7 +84,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat return "", utils.Wrap(err, "Auth failed") } log.NewInfo(operationID, "getui", utils.GetSelfFuncName(), token, expireTime, err) - err = db.DB.SetGetuiToken(token, expireTime-time.Now().Unix()-20) + err = db.DB.SetGetuiToken(token, 60*60*23) if err != nil { return "", utils.Wrap(err, "Auth failed") } @@ -114,7 +114,7 @@ func (g *Getui) Push(userIDList []string, alert, detailContent, platform, operat } func (g *Getui) Auth(operationID string, timeStamp int64) (token string, expireTime int64, err error) { - log.NewInfo(operationID, utils.GetSelfFuncName(), timeStamp) + log.NewInfo(operationID, utils.GetSelfFuncName(), config.Config.Push.Getui.AppKey, timeStamp, config.Config.Push.Getui.MasterSecret) h := sha256.New() h.Write([]byte(config.Config.Push.Getui.AppKey + strconv.Itoa(int(timeStamp)) + config.Config.Push.Getui.MasterSecret)) sum := h.Sum(nil) From a879bbce5945d7717a15217665c1ced22c2a325d Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 18:29:54 +0800 Subject: [PATCH 20/21] getui --- internal/push/getui/push.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/internal/push/getui/push.go b/internal/push/getui/push.go index 8139eea0b..253830373 100644 --- a/internal/push/getui/push.go +++ b/internal/push/getui/push.go @@ -7,7 +7,7 @@ import ( "Open_IM/pkg/utils" "bytes" "crypto/sha256" - "crypto/sha512" + //"crypto/sha512" "encoding/hex" "encoding/json" "io/ioutil" From a08c499c9595e8673c04c2ef0e38c686bdb2889e Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Fri, 8 Apr 2022 18:35:53 +0800 Subject: [PATCH 21/21] getui --- config/config.yaml | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/config/config.yaml b/config/config.yaml index 890a4c094..da30523d0 100644 --- a/config/config.yaml +++ b/config/config.yaml @@ -180,13 +180,13 @@ push: masterSecret: 02204efe3f3832947a236ee5 pushUrl: "https://api.jpush.cn/v3/push" pushIntent: "intent:#Intent;component=io.openim.app.enterprisechat/io.openim.app.enterprisechat.MainActivity;end" - enable: false + enable: true getui: #个推推送，暂未测试 暂不要使用 pushUrl: "https://restapi.getui.com/v2/$appId" masterSecret: "" appKey: "" intent: "" - enable: true + enable: false