From dc75a8eacde2b0025bb966997205ac7c618d8299 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=88=98=E6=B3=89=E4=BD=B3?= <1107186916@qq.com>
Date: Wed, 28 Oct 2026 14:16:33 +0800
Subject: [PATCH] =?UTF-8?q?:feat:=20HCS=E5=AE=9A=E6=97=B6=E6=8E=A8?=
 =?UTF-8?q?=E9=80=81=E5=90=8E=E6=8C=89=E5=8E=9F=E5=8D=95=E5=9B=9E=E5=86=99?=
 =?UTF-8?q?=E5=90=88=E5=90=8C/=E9=A1=B9=E7=9B=AE=E5=8F=98=E6=9B=B4?=
 =?UTF-8?q?=E5=8D=95=E5=90=8C=E6=AD=A5=E7=8A=B6=E6=80=81?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../org/springblade/transport/task/HcsPushTask.java    | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/blade-service/blade-transport/src/main/java/org/springblade/transport/task/HcsPushTask.java b/blade-service/blade-transport/src/main/java/org/springblade/transport/task/HcsPushTask.java
index 874fc41f..2738bab2 100644
--- a/blade-service/blade-transport/src/main/java/org/springblade/transport/task/HcsPushTask.java
+++ b/blade-service/blade-transport/src/main/java/org/springblade/transport/task/HcsPushTask.java
@@ -42,6 +42,8 @@ import org.springblade.transport.pojo.entity.InvoiceApplication;
 import org.springblade.transport.pojo.entity.InvoiceReceipt;
 import org.springblade.transport.pojo.entity.PaymentApplication;
 import org.springblade.transport.pojo.entity.ProjectApply;
+import org.springblade.transport.service.IContractChangeService;
+import org.springblade.transport.service.IProjectChangeService;
 import org.springblade.transport.support.hcs.HcsContractSpecSyncSupport;
 import org.springblade.transport.support.hcs.HcsContractSyncSupport;
 import org.springblade.transport.support.hcs.HcsInvoiceRegSyncSupport;
@@ -108,6 +110,8 @@ public class HcsPushTask {
 	private final HcsPaymentSyncSupport hcsPaymentSyncSupport;
 	private final HcsInvoiceRegSyncSupport hcsInvoiceRegSyncSupport;
 	private final HcsReceiptBillSyncSupport hcsReceiptBillSyncSupport;
+	private final IContractChangeService contractChangeService;
+	private final IProjectChangeService projectChangeService;
 	private final BladeRedis bladeRedis;
 
 	/**
@@ -211,10 +215,13 @@ public class HcsPushTask {
 		for (ProjectApply projectApply : projectList) {
 			try {
 				hcsProjectSyncSupport.pushProject(projectApply);
+				// 推送成功回写原项目最近一条待同步变更单，闭合变更单同步状态（C102-1 首推或 C102-2 更新均覆盖）
+				projectChangeService.writeBackSyncStatus(projectApply.getId(), HcsSyncConstant.HCS_STATUS_SYNCED);
 				successCount++;
 			} catch (Exception exception) {
 				String message = StringUtil.isBlank(exception.getMessage()) ? "推送异常" : exception.getMessage();
 				hcsProjectSyncSupport.markFailed(projectApply, message);
+				projectChangeService.writeBackSyncStatus(projectApply.getId(), HcsSyncConstant.HCS_STATUS_FAILED);
 				failCount++;
 			}
 		}
@@ -242,10 +249,13 @@ public class HcsPushTask {
 		for (ContractManage contractManage : contractList) {
 			try {
 				hcsContractSyncSupport.pushContract(contractManage);
+				// 推送成功回写原合同最近一条待同步变更单，闭合变更单同步状态（C103-1 首推或 C103-11 更新均覆盖）
+				contractChangeService.writeBackSyncStatus(contractManage.getId(), HcsSyncConstant.HCS_STATUS_SYNCED);
 				successCount++;
 			} catch (Exception exception) {
 				String message = StringUtil.isBlank(exception.getMessage()) ? "推送异常" : exception.getMessage();
 				hcsContractSyncSupport.markFailed(contractManage, message);
+				contractChangeService.writeBackSyncStatus(contractManage.getId(), HcsSyncConstant.HCS_STATUS_FAILED);
 				failCount++;
 			}
 		}