diff --git a/services/distributeddataservice/framework/checker/checker_manager.cpp b/services/distributeddataservice/framework/checker/checker_manager.cpp
index e02f50c64a219711e8456453445ac5c0bb8d33d3..3797302025a7966f5cde6f4152f79b5daa1f08c5 100644
--- a/services/distributeddataservice/framework/checker/checker_manager.cpp
+++ b/services/distributeddataservice/framework/checker/checker_manager.cpp
@@ -126,6 +126,7 @@ std::vector<CheckerManager::StoreInfo> CheckerManager::GetDynamicStores()
     }
     return res;
 }
+
 std::vector<CheckerManager::StoreInfo> CheckerManager::GetStaticStores()
 {
     std::vector<CheckerManager::StoreInfo> res;
@@ -140,6 +141,24 @@ std::vector<CheckerManager::StoreInfo> CheckerManager::GetStaticStores()
     }
     return res;
 }
+
+std::set<std::string> CheckerManager::GetKvStores()
+{
+    std::set<std::string> stores;
+    for (auto &[name, checker] : checkers_) {
+        if (checker == nullptr) {
+            continue;
+        }
+        for (auto &storeInfo : checker->GetDynamicStores()) {
+            stores.insert(std::move(storeInfo.bundleName));
+        }
+        for (auto &storeInfo : checker->GetStaticStores()) {
+            stores.insert(std::move(storeInfo.bundleName));
+        }
+    }
+    return stores;
+}
+
 bool CheckerManager::IsDynamic(const CheckerManager::StoreInfo &info)
 {
     for (auto &[name, checker] : checkers_) {
diff --git a/services/distributeddataservice/framework/include/checker/checker_manager.h b/services/distributeddataservice/framework/include/checker/checker_manager.h
index f532799490683bc98a9ee2bbea1bf09eaf36f519..09c290391a82bf4973ace103c1b82a6ebace70eb 100644
--- a/services/distributeddataservice/framework/include/checker/checker_manager.h
+++ b/services/distributeddataservice/framework/include/checker/checker_manager.h
@@ -15,9 +15,11 @@
 
 #ifndef OHOS_DISTRIBUTED_DATA_SERVICES_FRAMEWORK_CHECKER_CHECKER_MANAGER_H
 #define OHOS_DISTRIBUTED_DATA_SERVICES_FRAMEWORK_CHECKER_CHECKER_MANAGER_H
+#include <set>
 #include <vector>
-#include "visibility.h"
+
 #include "concurrent_map.h"
+#include "visibility.h"
 namespace OHOS {
 namespace DistributedData {
 class CheckerManager {
@@ -68,6 +70,8 @@ public:
     API_EXPORT bool IsSwitches(const StoreInfo &info);
     API_EXPORT void LoadCheckers(std::vector<std::string> &checkers);
     API_EXPORT Checker *GetChecker(const std::string &checker);
+    API_EXPORT std::set<std::string> GetKvStores();
+
 private:
     std::map<std::string, Checker *> checkers_;
     ConcurrentMap<std::string, std::function<Checker *()>> getters_;
diff --git a/services/distributeddataservice/service/cloud/cloud_service_impl.cpp b/services/distributeddataservice/service/cloud/cloud_service_impl.cpp
index a286b810c841e70a093285af889b592a55e73452..6d943d30aa3b82e9a06c8544f5436d938fea07fb 100644
--- a/services/distributeddataservice/service/cloud/cloud_service_impl.cpp
+++ b/services/distributeddataservice/service/cloud/cloud_service_impl.cpp
@@ -397,17 +397,9 @@ std::map<std::string, std::vector<std::string>> CloudServiceImpl::GetDbInfoFromE
     return dbInfos;
 }
 
-bool CloudServiceImpl::DoKvCloudSync(int32_t userId, const std::string &bundleName, int32_t triggerMode)
+bool CloudServiceImpl::DoPrioritySync(int32_t userId, CloudSyncScene scene)
 {
-    auto stores = CheckerManager::GetInstance().GetDynamicStores();
-    auto staticStores = CheckerManager::GetInstance().GetStaticStores();
-    stores.insert(stores.end(), staticStores.begin(), staticStores.end());
-    bool found = std::any_of(stores.begin(), stores.end(), [&bundleName](const CheckerManager::StoreInfo &storeInfo) {
-        return bundleName.empty() || storeInfo.bundleName == bundleName;
-    });
-    if (!found) {
-        return found;
-    }
+    auto stores = CheckerManager::GetInstance().GetKvStores();
     std::vector<int32_t> users;
     if (userId != INVALID_USER_ID) {
         users.emplace_back(userId);
@@ -416,12 +408,11 @@ bool CloudServiceImpl::DoKvCloudSync(int32_t userId, const std::string &bundleNa
     }
     for (auto user : users) {
         for (const auto &store : stores) {
-            int32_t mode = (store.bundleName != bundleName && triggerMode == MODE_PUSH) ? MODE_CONSISTENCY
-                                                                                        : triggerMode;
-            syncManager_.DoCloudSync(SyncManager::SyncInfo(user, store.bundleName, store.storeId, {}, mode));
+            syncManager_.DoCloudSync(
+                SyncManager::SyncInfo(user, store.bundleName, store.storeId, {}, ConvertSceneToMode(scene)));
         }
     }
-    return found;
+    return true;
 }
 
 int32_t CloudServiceImpl::NotifyDataChange(const std::string &id, const std::string &bundleName)
@@ -1195,20 +1186,31 @@ bool CloudServiceImpl::ReleaseUserInfo(int32_t user, CloudSyncScene scene)
     return true;
 }
 
-bool CloudServiceImpl::DoCloudSync(int32_t user, CloudSyncScene scene)
+bool CloudServiceImpl::DoGeneralSync(int32_t userId, int32_t triggerMode)
 {
     auto [status, cloudInfo] = GetCloudInfo(user);
     if (status != SUCCESS) {
-        Report(GetDfxFaultType(scene), Fault::CSF_CLOUD_INFO, "", "DoCloudSync ret=" + std::to_string(status));
+        Report(GetDfxFaultType(scene), Fault::CSF_CLOUD_INFO, "", "DoGeneralSync ret=" + std::to_string(status));
         return false;
     }
+    auto stores = CheckerManager::GetInstance().GetKvStores();
     for (const auto &appInfo : cloudInfo.apps) {
         SyncManager::SyncInfo info(user, appInfo.first);
+        if (!stores.empty() && stores.find(appInfo.first) != stores.end()) {
+            continue;
+        }
         syncManager_.DoCloudSync(info);
     }
     return true;
 }
 
+bool CloudServiceImpl::DoCloudSync(int32_t user, CloudSyncScene scene)
+{
+    DoPrioritySync(user, scene);
+    DoGeneralSync(user, scene);
+    return true;
+}
+
 bool CloudServiceImpl::StopCloudSync(int32_t user, CloudSyncScene scene)
 {
     syncManager_.StopCloudSync(user);
@@ -1705,4 +1707,14 @@ QueryLastResults CloudServiceImpl::AssembleLastResults(const std::vector<Databas
     }
     return results;
 }
+
+int32_t CloudServiceImpl::ConvertSceneToMode(CloudSyncScene scene)
+{
+    switch (scene) {
+        case CloudSyncScene::NETWORK_RECOVERY:
+            return SyncTriggerMode::MODE_ONLINE;
+        default:
+            return SyncTriggerMode::CONSISTENCY;
+    }
+}
 } // namespace OHOS::CloudData
\ No newline at end of file
diff --git a/services/distributeddataservice/service/cloud/cloud_service_impl.h b/services/distributeddataservice/service/cloud/cloud_service_impl.h
index c1ec1dd099cb44a31eabce1bd26ef50a685672ad..1f98174a3ccd10b821d2a650af842435eb4ead46 100644
--- a/services/distributeddataservice/service/cloud/cloud_service_impl.h
+++ b/services/distributeddataservice/service/cloud/cloud_service_impl.h
@@ -179,7 +179,9 @@ private:
         const DistributedData::ExtraData &extraData, const SchemaMeta &schemaMeta);
     std::shared_ptr<DistributedData::SharingCenter> GetSharingHandle(const HapInfo &hapInfo);
     bool GetStoreMetaData(StoreMetaData &meta);
-    bool DoKvCloudSync(int32_t userId, const std::string &bundleName = "", int32_t triggerMode = 0);
+    bool DoPrioritySync(int32_t userId, CloudSyncScene scene);
+    bool DoGeneralSync(int32_t userId, CloudSyncScene scene);
+    int32_t ConvertSceneToMode(CloudSyncScene scene);
 
     using SaveStrategy = int32_t (*)(const std::vector<CommonType::Value> &values, const HapInfo &hapInfo);
     static const SaveStrategy STRATEGY_SAVERS[Strategy::STRATEGY_BUTT];
@@ -209,6 +211,7 @@ private:
     static constexpr Handle WORK_RELEASE = &CloudServiceImpl::ReleaseUserInfo;
     static constexpr Handle WORK_DO_CLOUD_SYNC = &CloudServiceImpl::DoCloudSync;
     static constexpr Handle WORK_STOP_CLOUD_SYNC = &CloudServiceImpl::StopCloudSync;
+    static constexpr Handle WORK_DO_GENERAL_SYNC = &CloudServiceImpl::DoGeneralSync;
 };
 } // namespace OHOS::CloudData