update

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

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