feature:回推定时任务修改

zkh
路明慧 11 months ago
parent ddffd22909
commit aaacc80a6a
  1. 6
      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.OrderInvoiceInfo;
import com.dxhy.order.baseservice.model.queue.CommonTsMqData; import com.dxhy.order.baseservice.model.queue.CommonTsMqData;
import com.dxhy.order.baseservice.model.queue.FpTsMqData; 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.consumer.modules.manager.service.OrderPushInvoiceService;
import com.dxhy.order.invoice.module.invoice.model.PagePushInvalid; import com.dxhy.order.invoice.module.invoice.model.PagePushInvalid;
import com.dxhy.order.invoice.module.invoice.model.PushInfo; import com.dxhy.order.invoice.module.invoice.model.PushInfo;
@ -55,6 +56,9 @@ public class InvoicePushTask {
@Resource @Resource
private InvalidInvoiceService invalidInvoiceService; private InvalidInvoiceService invalidInvoiceService;
@Resource
private OrderHandleService orderHandleService;
@XxlJob("InvoicePushTask") @XxlJob("InvoicePushTask")
public ReturnT<String> invoicePushTask() { public ReturnT<String> invoicePushTask() {
@ -239,7 +243,7 @@ public class InvoicePushTask {
commonTsMqData.setEntId(orderInvoiceInfo.getEntId()); commonTsMqData.setEntId(orderInvoiceInfo.getEntId());
commonTsMqData.setFpTsMqData(fpTsMqData); 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)) { } else if (OrderInfoEnum.INTERFACE_TYPE_INVOICE_PUSH_STATUS_2.getKey().equals(type)) {
PagePushInvalid pagePushInvalid = new PagePushInvalid(); PagePushInvalid pagePushInvalid = new PagePushInvalid();
pagePushInvalid.setDdqqlsh(orderInvoiceInfo.getFpqqlsh()); pagePushInvalid.setDdqqlsh(orderInvoiceInfo.getFpqqlsh());

Loading…
Cancel
Save