diff --git a/order-management-order/src/main/java/com/dxhy/order/consumer/handle/InvoicePushTask.java b/order-management-order/src/main/java/com/dxhy/order/consumer/handle/InvoicePushTask.java index 3a2ce9c..24da886 100644 --- a/order-management-order/src/main/java/com/dxhy/order/consumer/handle/InvoicePushTask.java +++ b/order-management-order/src/main/java/com/dxhy/order/consumer/handle/InvoicePushTask.java @@ -11,6 +11,7 @@ import com.dxhy.base.common.utils.NsrsbhUtils; import com.dxhy.order.baseservice.model.OrderInvoiceInfo; import com.dxhy.order.baseservice.model.queue.CommonTsMqData; import com.dxhy.order.baseservice.model.queue.FpTsMqData; +import com.dxhy.order.consumer.modules.bespoke.service.OrderHandleService; import com.dxhy.order.consumer.modules.manager.service.OrderPushInvoiceService; import com.dxhy.order.invoice.module.invoice.model.PagePushInvalid; import com.dxhy.order.invoice.module.invoice.model.PushInfo; @@ -55,6 +56,9 @@ public class InvoicePushTask { @Resource private InvalidInvoiceService invalidInvoiceService; + @Resource + private OrderHandleService orderHandleService; + @XxlJob("InvoicePushTask") public ReturnT invoicePushTask() { @@ -239,7 +243,7 @@ public class InvoicePushTask { commonTsMqData.setEntId(orderInvoiceInfo.getEntId()); commonTsMqData.setFpTsMqData(fpTsMqData); - orderPushInvoiceService.pushRouting(JsonUtils.getInstance().toJsonString(commonTsMqData)); + orderHandleService.backMsg(JsonUtils.getInstance().toJsonString(commonTsMqData)); } else if (OrderInfoEnum.INTERFACE_TYPE_INVOICE_PUSH_STATUS_2.getKey().equals(type)) { PagePushInvalid pagePushInvalid = new PagePushInvalid(); pagePushInvalid.setDdqqlsh(orderInvoiceInfo.getFpqqlsh());