From b46906559b73ee4826b6d316c242802025fb0295 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=88=98=E6=B3=89=E4=BD=B3?= <1107186916@qq.com> Date: Mon, 28 Sep 2026 00:02:44 +0800 Subject: [PATCH] =?UTF-8?q?fix:=20=E8=A1=A5=E9=BD=90=E6=94=B6=E7=A5=A8/?= =?UTF-8?q?=E5=BC=80=E7=A5=A8=E5=8D=95=E6=9D=A1=E9=87=8D=E6=8E=A8=E4=B8=8E?= =?UTF-8?q?=E6=89=B9=E9=87=8F=E6=8E=A8=E9=80=81=E7=AB=AF=E7=82=B9=E6=8E=A5?= =?UTF-8?q?=E7=BA=BF=EF=BC=88=E6=AD=A4=E5=89=8D=E6=8F=90=E4=BA=A4=E9=81=97?= =?UTF-8?q?=E6=BC=8Fswitch=E5=88=86=E6=94=AF=E4=B8=8E=E6=B3=A8=E5=85=A5?= =?UTF-8?q?=EF=BC=89?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../transport/controller/HcsSyncController.java | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/blade-service/blade-transport/src/main/java/org/springblade/transport/controller/HcsSyncController.java b/blade-service/blade-transport/src/main/java/org/springblade/transport/controller/HcsSyncController.java index d04ff7a7..0363060f 100644 --- a/blade-service/blade-transport/src/main/java/org/springblade/transport/controller/HcsSyncController.java +++ b/blade-service/blade-transport/src/main/java/org/springblade/transport/controller/HcsSyncController.java @@ -66,36 +66,42 @@ public class HcsSyncController { private final HcsProjectSyncSupport hcsProjectSyncSupport; private final HcsContractSyncSupport hcsContractSyncSupport; private final HcsPaymentSyncSupport hcsPaymentSyncSupport; + private final HcsInvoiceRegSyncSupport hcsInvoiceRegSyncSupport; + private final HcsReceiptBillSyncSupport hcsReceiptBillSyncSupport; private final HcsMasterDataSupport hcsMasterDataSupport; /** - * 单条重推（bizType：project=项目立项 / contract=合同 / payment=付款申请） + * 单条重推（bizType：project=项目立项 / contract=合同 / payment=付款申请 / invoice-application=开票申请 / invoice-receipt=收票单） */ @PostMapping("/sync/{bizType}/{id}") @ApiOperationSupport(order = 1) - @Operation(summary = "单条推送/重推合规", description = "重置待同步状态后立即推送，bizType：project=项目立项、contract=合同、payment=付款申请") + @Operation(summary = "单条推送/重推合规", description = "重置待同步状态后立即推送，bizType：project、contract、payment、invoice-application、invoice-receipt") public R repush(@Parameter(description = "业务类型", required = true) @PathVariable String bizType, @Parameter(description = "单据ID", required = true) @PathVariable Long id) { String result = switch (bizType) { case HcsSyncConstant.BIZ_TYPE_PROJECT -> hcsProjectSyncSupport.repushProject(id); case HcsSyncConstant.BIZ_TYPE_CONTRACT -> hcsContractSyncSupport.repushContract(id); case HcsSyncConstant.BIZ_TYPE_PAYMENT -> hcsPaymentSyncSupport.repushPayment(id); + case HcsSyncConstant.BIZ_TYPE_INVOICE_APPLICATION -> hcsInvoiceRegSyncSupport.repushInvoiceRegistration(id); + case HcsSyncConstant.BIZ_TYPE_INVOICE_RECEIPT -> hcsReceiptBillSyncSupport.repushReceiptBill(id); default -> throw new IllegalArgumentException("不支持的HCS推送业务类型：" + bizType); }; return R.data(result); } /** - * 批量推送（bizType：project=项目立项 / contract=合同 / payment=付款申请；复用定时扫描逻辑，单轮批量上限 push.batch-size） + * 批量推送（复用定时扫描逻辑，单轮批量上限 push.batch-size） */ @PostMapping("/sync/{bizType}") @ApiOperationSupport(order = 2) - @Operation(summary = "批量推送合规", description = "扫描待同步/待补偿单据推送一轮，bizType：project=项目立项、contract=合同、payment=付款申请") + @Operation(summary = "批量推送合规", description = "扫描待同步/待补偿单据推送一轮，bizType：project、contract、payment、invoice-application、invoice-receipt") public R pushBatch(@Parameter(description = "业务类型", required = true) @PathVariable String bizType) { String result = switch (bizType) { case HcsSyncConstant.BIZ_TYPE_PROJECT -> hcsPushTask.pushUnsyncedProjects(); case HcsSyncConstant.BIZ_TYPE_CONTRACT -> hcsPushTask.pushUnsyncedContracts(); case HcsSyncConstant.BIZ_TYPE_PAYMENT -> hcsPushTask.pushUnsyncedPayments(); + case HcsSyncConstant.BIZ_TYPE_INVOICE_APPLICATION -> hcsPushTask.pushUnsyncedInvoiceApplications(); + case HcsSyncConstant.BIZ_TYPE_INVOICE_RECEIPT -> hcsPushTask.pushUnsyncedInvoiceReceipts(); default -> throw new IllegalArgumentException("不支持的HCS推送业务类型：" + bizType); }; return R.data(result);