From 2a7e6639e78069d9ab1892ba760049ebde042537 Mon Sep 17 00:00:00 2001
From: v-zhangjc9 <v-zhangjc9.gd@chinatelecom.cn>
Date: Thu, 14 Mar 2024 17:14:47 +0800
Subject: [PATCH] =?UTF-8?q?feat(info-query):=20=E5=A2=9E=E5=8A=A0=E5=88=9D?=
 =?UTF-8?q?=E5=A7=8B=E5=8C=96sync=5Fstate=E6=8E=A5=E5=8F=A3?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/forest/service/InfoService.java      |  3 +++
 .../info/controller/SyncStateController.java     |  5 +++++
 .../service/info/service/SyncStateService.java   | 16 ++++++++++++++++
 3 files changed, 24 insertions(+)

diff --git a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java
index 886c2d5..009853f 100644
--- a/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java
+++ b/service-forest/src/main/java/com/lanyuanxiaoyao/service/forest/service/InfoService.java
@@ -104,6 +104,9 @@ public interface InfoService {
     @Get("/info/sync_state/save_compaction_id")
     void saveCompactionId(@Query("flink_job_id") Long flinkJobId, @Query("alias") String alias, @Query("application_id") String applicationId);
 
+    @Get("/info/sync_state/save")
+    void saveSyncState(@Query("id") String id);
+
     @Get("/info/non_updated_version_tables")
     ImmutableList<String> nonUpdatedVersionTables();
 
diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java
index 90869b6..3da53e6 100644
--- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java
+++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/controller/SyncStateController.java
@@ -39,4 +39,9 @@ public class SyncStateController {
     ) {
         syncStateService.saveCompactionApplicationId(flinkJobId, alias, applicationId);
     }
+
+    @GetMapping("/sync_state/save")
+    public void saveCompactionId(@RequestParam("id") String id) {
+        syncStateService.saveSyncState(id);
+    }
 }
diff --git a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java
index 01e1443..3036590 100644
--- a/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java
+++ b/service-info-query/src/main/java/com/lanyuanxiaoyao/service/info/service/SyncStateService.java
@@ -101,4 +101,20 @@ public class SyncStateService extends BaseService {
                 applicationId
         );
     }
+
+    @Retryable(Throwable.class)
+    public void saveSyncState(String id) {
+        mysqlJdbcTemplate.update(
+                SqlBuilder.insertInto(
+                                TbAppHudiSyncState._origin_,
+                                TbAppHudiSyncState.ID_O,
+                                TbAppHudiSyncState.MESSAGE_ID_O
+                        )
+                        .values()
+                        .addValue(Q, Q)
+                        .precompileSql(),
+                id,
+                "-1:-1:-1"
+        );
+    }
 }