更新

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())