feature:回推接口调整

release
gaorl 2 years ago
parent f4388eea96
commit 7697e7e271
  1. 5
      order-management-common/src/main/java/com/dxhy/order/model/queue/FpTsMqData.java
  2. 5
      order-management-consumer/src/main/java/com/dxhy/order/consumer/modules/manager/service/impl/PushInvoiceServiceImpl.java

@ -25,6 +25,11 @@ public class FpTsMqData implements Serializable {
*/
private String fpqqlsh;
/**
* 发票请求流水号
*/
private String pushBackLsh;
/**
* 发票代码
* (作废推送需要)

@ -984,7 +984,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();
@ -1487,9 +1487,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);
}

Loading…
Cancel
Save