From aaacc80a6a075e9c60d56fb63f8fa8c5b83ed4ee Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E8=B7=AF=E6=98=8E=E6=85=A7?= <1191093413@qq.com> Date: Wed, 4 Sep 2024 17:06:18 +0800 Subject: [PATCH] =?UTF-8?q?feature:=E5=9B=9E=E6=8E=A8=E5=AE=9A=E6=97=B6?= =?UTF-8?q?=E4=BB=BB=E5=8A=A1=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../com/dxhy/order/consumer/handle/InvoicePushTask.java | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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());