From 2f6008d6be9abf79df5b275efad1a64d9cb01642 Mon Sep 17 00:00:00 2001 From: DengBiao <2319963317@qq.com> Date: Wed, 14 Jun 2023 21:03:56 +0800 Subject: [PATCH] update --- consume/dou_shen_user_register_for_my_my_fans.go | 2 +- consume/dou_shen_user_register_for_my_my_recommender.go | 2 +- consume/dou_shen_user_register_for_official_consume.go | 2 +- consume/dou_shen_user_register_for_operation_center.go | 2 +- consume/init.go | 5 +++-- 5 files changed, 7 insertions(+), 6 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 e30a897..c36d9f9 100644 --- a/consume/dou_shen_user_register_for_my_my_fans.go +++ b/consume/dou_shen_user_register_for_my_my_fans.go @@ -64,7 +64,7 @@ func DouShenUserRegisterConsumeForMyFans(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForMyFans(msgData []byte) error { - time.Sleep(time.Duration(1) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForMyFans err := json.Unmarshal(msgData, &msg) 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 095ee36..3b3f3e6 100644 --- a/consume/dou_shen_user_register_for_my_my_recommender.go +++ b/consume/dou_shen_user_register_for_my_my_recommender.go @@ -63,7 +63,7 @@ func DouShenUserRegisterConsumeForMyRecommender(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForMyRecommender(msgData []byte) error { - time.Sleep(time.Duration(1) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForMyRecommender err := json.Unmarshal(msgData, &msg) diff --git a/consume/dou_shen_user_register_for_official_consume.go b/consume/dou_shen_user_register_for_official_consume.go index bb47638..b1ac1c5 100644 --- a/consume/dou_shen_user_register_for_official_consume.go +++ b/consume/dou_shen_user_register_for_official_consume.go @@ -63,7 +63,7 @@ func DouShenUserRegisterConsumeForOfficial(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForOfficial(msgData []byte) error { - time.Sleep(time.Duration(1) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForOfficial err := json.Unmarshal(msgData, &msg) diff --git a/consume/dou_shen_user_register_for_operation_center.go b/consume/dou_shen_user_register_for_operation_center.go index f27df4b..f4e3e48 100644 --- a/consume/dou_shen_user_register_for_operation_center.go +++ b/consume/dou_shen_user_register_for_operation_center.go @@ -64,7 +64,7 @@ func DouShenUserRegisterConsumeForOperationCenter(queue md.MqQueue) { } func handleDouShenUserRegisterConsumeForOperationCenter(msgData []byte) error { - time.Sleep(time.Duration(1) * time.Second) + time.Sleep(time.Duration(10) * time.Second) //1、解析mq中queue的数据结构体 var msg *md.DouShenUserRegisterMessageStructForOperationCenter err := json.Unmarshal(msgData, &msg) diff --git a/consume/init.go b/consume/init.go index cea1bb6..42de890 100644 --- a/consume/init.go +++ b/consume/init.go @@ -20,12 +20,13 @@ func initConsumes() { jobs[consumeMd.CanalOrderConsumeFunName] = CanalOrderConsume jobs[consumeMd.CanalGuideOrderConsumeFunName] = CanalGuideOrderConsume jobs[consumeMd.ZhiOsUserVisitIpAddressConsumeFunName] = ZhiOsUserVisitIpAddressConsume - jobs[consumeMd.DouShenUserRegisterConsumeForOfficialFunName] = DouShenUserRegisterConsumeForOfficial + jobs[consumeMd.DouShenUserRegisterConsumeForOfficialFunName] = DouShenUserRegisterConsumeForOfficial jobs[consumeMd.DouShenUserRegisterConsumeForOperationCenterFunName] = DouShenUserRegisterConsumeForOperationCenter - jobs[consumeMd.DouShenUserRegisterConsumeForUserRegisterUpLvFunName] = DouShenUserRegisterConsumeForUserRegisterUpLv jobs[consumeMd.DouShenUserRegisterConsumeForMyRecommenderFunName] = DouShenUserRegisterConsumeForMyRecommender jobs[consumeMd.DouShenUserRegisterConsumeForMyFansFunName] = DouShenUserRegisterConsumeForMyFans + jobs[consumeMd.DouShenUserRegisterConsumeForUserRegisterUpLvFunName] = DouShenUserRegisterConsumeForUserRegisterUpLv + jobs[consumeMd.ZhiosFastReturnOrderPayFunName] = ZhiosFastReturnOrderPay jobs[consumeMd.ZhiosFastReturnOrderSuccessFunName] = ZhiosFastReturnOrderSuccess jobs[consumeMd.ZhiosFastReturnOrderRefundFunName] = ZhiosFastReturnOrderRefund