diff --git a/order-management-common/src/main/java/com/dxhy/order/model/queue/FpTsMqData.java b/order-management-common/src/main/java/com/dxhy/order/model/queue/FpTsMqData.java index 5b343da7..bc0de3bd 100644 --- a/order-management-common/src/main/java/com/dxhy/order/model/queue/FpTsMqData.java +++ b/order-management-common/src/main/java/com/dxhy/order/model/queue/FpTsMqData.java @@ -25,6 +25,11 @@ public class FpTsMqData implements Serializable { */ private String fpqqlsh; + /** + * 发票请求流水号 + */ + private String pushBackLsh; + /** * 发票代码 * (作废推送需要) diff --git a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java index a6a4809e..c500524b 100644 --- a/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java +++ b/order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java @@ -1076,7 +1076,7 @@ public class PushInvoiceServiceImpl implements PushInvoiceService { if (OrderInfoEnum.INTERFACE_TYPE_INVOICE_PUSH_STATUS_1.getKey().equals(commonTsMqData.getPushType())) { //开票推送相关业务处理 FpTsMqData fpTsMqData = commonTsMqData.getFpTsMqData(); - updatePushErrorMsgToDb(fpTsMqData.getFpqqlsh(), msg, shList); + updatePushErrorMsgToDb(fpTsMqData.getPushBackLsh(), msg, shList); } else if (OrderInfoEnum.INTERFACE_TYPE_INVOICE_PUSH_STATUS_2.getKey().equals(commonTsMqData.getPushType())) { //作废推送相关业务处理 ZfTsMqData zfTsMqData = commonTsMqData.getZfTsMqData(); @@ -1579,9 +1579,10 @@ public class PushInvoiceServiceImpl implements PushInvoiceService { } orderProcessInfoList.addAll(orderProcessInfos); String fpqqlsh = orderProcessInfos.stream().map(t -> t.getFpqqlsh()).collect(Collectors.joining(",")); - fpTsMqData.setFpqqlsh(fpqqlsh); + fpTsMqData.setPushBackLsh(fpqqlsh); log.info("山能易行发票回推重置流水号{}",fpqqlsh); }else{ + fpTsMqData.setPushBackLsh(orderProcessInfo.getFpqqlsh()); orderProcessInfoList.add(orderProcessInfo); }