From 8c0e14473aa9940f3f196481de11681f145bc47f Mon Sep 17 00:00:00 2001 From: DengBiao <2319963317@qq.com> Date: Fri, 5 May 2023 20:54:18 +0800 Subject: [PATCH] update --- consume/dou_shen_user_register_for_my_my_fans.go | 16 +++++++++++++--- ...u_shen_user_register_for_my_my_recommender.go | 16 +++++++++++++--- ...ou_shen_user_register_for_official_consume.go | 16 +++++++++++++--- ...ou_shen_user_register_for_operation_center.go | 16 +++++++++++++--- 4 files changed, 52 insertions(+), 12 deletions(-) diff --git a/consume/dou_shen_user_register_for_my_my_fans.go b/consume/dou_shen_user_register_for_my_my_fans.go index 4e42611..d0fe704 100644 --- a/consume/dou_shen_user_register_for_my_my_fans.go +++ b/consume/dou_shen_user_register_for_my_my_fans.go @@ -54,7 +54,7 @@ func DouShenUserRegisterConsumeForMyFans(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error { - time.Sleep(time.Duration(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForMyFans err := json.Unmarshal(msgData, &msg) @@ -70,7 +70,7 @@ func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error { return err } if gimUser == nil { - time.Sleep(time.Duration(10) * time.Second) + time.Sleep(time.Duration(20) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone, @@ -79,7 +79,17 @@ func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error { return err } if gimUser == nil { - return errors.New("用户暂未注册im系统") + time.Sleep(time.Duration(30) * time.Second) + gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ + "key": "phone_number", + "value": msg.Phone, + }) + if err != nil { + return err + } + if gimUser == nil { + return errors.New("用户暂未注册im系统") + } } } diff --git a/consume/dou_shen_user_register_for_my_my_recommender.go b/consume/dou_shen_user_register_for_my_my_recommender.go index 3844f7c..0654f4f 100644 --- a/consume/dou_shen_user_register_for_my_my_recommender.go +++ b/consume/dou_shen_user_register_for_my_my_recommender.go @@ -52,7 +52,7 @@ func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error { - time.Sleep(time.Duration(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForMyRecommender err := json.Unmarshal(msgData, &msg) @@ -68,7 +68,7 @@ func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error { return err } if gimUser == nil { - time.Sleep(time.Duration(10) * time.Second) + time.Sleep(time.Duration(20) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone, @@ -77,7 +77,17 @@ func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error { return err } if gimUser == nil { - return errors.New("用户暂未注册im系统") + time.Sleep(time.Duration(30) * time.Second) + gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ + "key": "phone_number", + "value": msg.Phone, + }) + if err != nil { + return err + } + if gimUser == nil { + return errors.New("用户暂未注册im系统") + } } } diff --git a/consume/dou_shen_user_register_for_official_consume.go b/consume/dou_shen_user_register_for_official_consume.go index 680c398..75e04a0 100644 --- a/consume/dou_shen_user_register_for_official_consume.go +++ b/consume/dou_shen_user_register_for_official_consume.go @@ -53,7 +53,7 @@ func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error { - time.Sleep(time.Duration(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForOfficial err := json.Unmarshal(msgData, &msg) @@ -69,7 +69,7 @@ func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error { return err } if gimUser == nil { - time.Sleep(time.Duration(10) * time.Second) + time.Sleep(time.Duration(20) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone, @@ -78,7 +78,17 @@ func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error { return err } if gimUser == nil { - return errors.New("用户暂未注册im系统") + time.Sleep(time.Duration(30) * time.Second) + gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ + "key": "phone_number", + "value": msg.Phone, + }) + if err != nil { + return err + } + if gimUser == nil { + return errors.New("用户暂未注册im系统") + } } } diff --git a/consume/dou_shen_user_register_for_operation_center.go b/consume/dou_shen_user_register_for_operation_center.go index 5a213e0..5b18bfa 100644 --- a/consume/dou_shen_user_register_for_operation_center.go +++ b/consume/dou_shen_user_register_for_operation_center.go @@ -54,7 +54,7 @@ func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error { - time.Sleep(time.Duration(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForOperationCenter err := json.Unmarshal(msgData, &msg) @@ -71,7 +71,7 @@ func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error { } if gimUser == nil { - time.Sleep(time.Duration(10) * time.Second) + time.Sleep(time.Duration(20) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone, @@ -80,7 +80,17 @@ func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error { return err } if gimUser == nil { - return errors.New("用户暂未注册im系统") + time.Sleep(time.Duration(30) * time.Second) + gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ + "key": "phone_number", + "value": msg.Phone, + }) + if err != nil { + return err + } + if gimUser == nil { + return errors.New("用户暂未注册im系统") + } } }