From 980ee10a5e68340e33c544cc2b4b9e28c054a6b9 Mon Sep 17 00:00:00 2001 From: DengBiao <2319963317@qq.com> Date: Wed, 19 Apr 2023 20:54:26 +0800 Subject: [PATCH] update --- consume/dou_shen_user_register_for_my_my_fans.go | 4 ++-- consume/dou_shen_user_register_for_my_my_recommender.go | 4 ++-- consume/dou_shen_user_register_for_official_consume.go | 4 ++-- consume/dou_shen_user_register_for_operation_center.go | 4 ++-- 4 files changed, 8 insertions(+), 8 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 defc8a9..fe3c4fe 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(4) * time.Second) + time.Sleep(time.Duration(6) * 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(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone, 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 a56d255..5ad175e 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(4) * time.Second) + time.Sleep(time.Duration(6) * 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(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone, diff --git a/consume/dou_shen_user_register_for_official_consume.go b/consume/dou_shen_user_register_for_official_consume.go index 78c7e5c..f0c0b16 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(4) * time.Second) + time.Sleep(time.Duration(6) * 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(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone, diff --git a/consume/dou_shen_user_register_for_operation_center.go b/consume/dou_shen_user_register_for_operation_center.go index 1d3dd87..6f5e9aa 100644 --- a/consume/dou_shen_user_register_for_operation_center.go +++ b/consume/dou_shen_user_register_for_operation_center.go @@ -52,7 +52,7 @@ func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error { - time.Sleep(time.Duration(4) * time.Second) + time.Sleep(time.Duration(6) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForOperationCenter err := json.Unmarshal(msgData, &msg) @@ -69,7 +69,7 @@ func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error { } if gimUser == nil { - time.Sleep(time.Duration(6) * time.Second) + time.Sleep(time.Duration(10) * time.Second) gimUser, err := db2.UserGetOneByParams(db.ImDb, msg.MasterId, map[string]interface{}{ "key": "phone_number", "value": msg.Phone,