From 2273bbad084da89c92f2f631d94e73ba2c4ed93c Mon Sep 17 00:00:00 2001
From: DengBiao <2319963317@qq.com>
Date: Mon, 27 Mar 2023 18:55:18 +0800
Subject: [PATCH] update

---
 consume/canal_guide_order_consume.go | 4 ++--
 consume/canal_order_consume.go       | 4 ++--
 2 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/consume/canal_guide_order_consume.go b/consume/canal_guide_order_consume.go
index 81c1771..cc9a5e0 100644
--- a/consume/canal_guide_order_consume.go
+++ b/consume/canal_guide_order_consume.go
@@ -43,7 +43,7 @@ func CanalGuideOrderConsume(queue md.MqQueue) {
 		res, ok = <-delivery
 		if ok == true {
 			//fmt.Println(string(res.Body))
-			fmt.Println(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>")
+			fmt.Println(">>>>>>>>>>>>>>>>>>CanalGuideOrderConsume<<<<<<<<<<<<<<<<<<<<<<<<<")
 			err = handleGuideOrdTable(res.Body, geoIp2db)
 			//_ = res.Reject(false)
 			_ = res.Ack(true)
@@ -124,7 +124,7 @@ func handleGuideOrdTable(msg []byte, geoIp2db *geoip2.DBReader) error {
 			if err != nil {
 				return err
 			}
-			fmt.Printf("CreateDoc ==> %+v \n\n", createDocRet)
+			fmt.Printf("CreateDoc CanalGuide ==> %+v \n\n", createDocRet)
 		}
 	}
 	return nil
diff --git a/consume/canal_order_consume.go b/consume/canal_order_consume.go
index 31c40b7..41b175b 100644
--- a/consume/canal_order_consume.go
+++ b/consume/canal_order_consume.go
@@ -36,7 +36,7 @@ func CanalOrderConsume(queue md.MqQueue) {
 		res, ok = <-delivery
 		if ok == true {
 			//fmt.Println(string(res.Body))
-			fmt.Println(">>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>")
+			fmt.Println(">>>>>>>>>>>>>>>>CanalOrderConsume<<<<<<<<<<<<<<<<<<<<<<<<<")
 			err = handleMallOrdTable(res.Body)
 			//_ = res.Reject(false)
 			_ = res.Ack(true)
@@ -140,7 +140,7 @@ func handleMallOrdTable(msg []byte) error {
 			if err != nil {
 				return err
 			}
-			fmt.Printf("CreateDoc ==> %+v \n\n", createDocRet)
+			fmt.Printf("CreateDoc CanalOrder ==> %+v \n\n", createDocRet)
 		}
 	}
 	return nil