diff --git a/consume/zhios_fast_return_order_pay.go b/consume/zhios_fast_return_order_pay.go index 1388108..a42bdfe 100644 --- a/consume/zhios_fast_return_order_pay.go +++ b/consume/zhios_fast_return_order_pay.go @@ -44,9 +44,17 @@ func ZhiosFastReturnOrderPay(queue md.MqQueue) { if err == nil { _ = res.Ack(true) } else { - var msg *md.ZhiosFatReturnOrderPay - json.Unmarshal(res.Body, &msg) - ch.Publish(queue.ExchangeName, msg, queue.RoutKey) + var canalMsg *md.ZhiosFatReturnOrderPay + var tmpString string + err := json.Unmarshal(res.Body, &tmpString) + if err == nil { + fmt.Println(tmpString) + err = json.Unmarshal([]byte(tmpString), &canalMsg) + if err == nil { + ch.Publish(queue.ExchangeName, utils.SerializeStr(canalMsg), queue.RoutKey) + } + } + } } else { panic(errors.New("error getting message"))