From b1c2513853e8b3e056e2539c956700ff70ec5220 Mon Sep 17 00:00:00 2001 From: huangjiajun <582604932@qq.com> Date: Wed, 24 Jul 2024 09:25:36 +0800 Subject: [PATCH] =?UTF-8?q?=E6=9B=B4=E6=96=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- consume/zhios_order_total_second.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/consume/zhios_order_total_second.go b/consume/zhios_order_total_second.go index 455ba5b..4b86efd 100644 --- a/consume/zhios_order_total_second.go +++ b/consume/zhios_order_total_second.go @@ -38,6 +38,7 @@ func ZhiosOrderTotalSecond(queue md.MqQueue) { err = handleZhiosOrderTotalSecond(res.Body) //_ = res.Reject(false) if err != nil { + fmt.Println("===================统计", err.Error()) _ = res.Reject(false) //TODO::重新推回队列末尾,避免造成队列堵塞 var msg *md.ZhiosOrderBuckle @@ -73,7 +74,6 @@ func handleZhiosOrderTotalSecond(msg []byte) error { fmt.Println("===with", err.Error()) return err } - fmt.Println(tmpString) err = json.Unmarshal([]byte(tmpString), &canalMsg) if err != nil { fmt.Println("===with", err.Error())