diff --git a/frameworks/native/backup_kit_inner/src/b_incremental_restore_session.cpp b/frameworks/native/backup_kit_inner/src/b_incremental_restore_session.cpp
index 42f9bea125e5fdbef2e5ccb35e32f8e806cbf1db..4c17d2eba22379c51477dc76bb34523456b8fc50 100644
--- a/frameworks/native/backup_kit_inner/src/b_incremental_restore_session.cpp
+++ b/frameworks/native/backup_kit_inner/src/b_incremental_restore_session.cpp
@@ -69,6 +69,38 @@ unique_ptr<BIncrementalRestoreSession> BIncrementalRestoreSession::Init(Callback
     return nullptr;
 }
 
+unique_ptr<BIncrementalRestoreSession> BIncrementalRestoreSession::Init(Callbacks callbacks,
+                                                                        std::string &errMsg, ErrCode &errCode)
+{
+    try {
+        HILOGI("Init IncrementalRestoreSession Begin");
+        auto restore = make_unique<BIncrementalRestoreSession>();
+        ServiceProxy::InvaildInstance();
+        auto proxy = ServiceProxy::GetInstance();
+        if (proxy == nullptr) {
+            errMsg = "Failed to get backup service";
+            errCode = BError(BError::Codes::SDK_BROKEN_IPC);
+            HILOGE("Init IncrementalRestoreSession failed, %{public}s", errMsg.c_str());
+            return nullptr;
+        }
+        errCode = proxy->InitRestoreSession(sptr(new ServiceReverse(callbacks)), errMsg);
+        if (errCode != ERR_OK) {
+            HILOGE("Failed to Restore because of %{public}d", errCode);
+            AppRadar::Info info ("", "", "create restore session failed");
+            AppRadar::GetInstance().RecordRestoreFuncRes(info, "BIncrementalRestoreSession::Init",
+                AppRadar::GetInstance().GetUserId(), BizStageRestore::BIZ_STAGE_CREATE_RESTORE_SESSION_FAIL, errCode);
+            return nullptr;
+        }
+
+        restore->RegisterBackupServiceDied(callbacks.onBackupServiceDied);
+        return restore;
+    } catch (const exception &e) {
+        HILOGE("Failed to Restore because of %{public}s", e.what());
+        errCode = BError(BError::Codes::SDK_INVAL_ARG);
+    }
+    return nullptr;
+}
+
 ErrCode BIncrementalRestoreSession::PublishFile(BFileInfo fileInfo)
 {
     auto proxy = ServiceProxy::GetInstance();
diff --git a/frameworks/native/backup_kit_inner/src/service_proxy.cpp b/frameworks/native/backup_kit_inner/src/service_proxy.cpp
index 7845556880aca234475fd594fbd4603f61b2bda8..e367757bc9582cf4a80a869fd418456241ce1e71 100644
--- a/frameworks/native/backup_kit_inner/src/service_proxy.cpp
+++ b/frameworks/native/backup_kit_inner/src/service_proxy.cpp
@@ -56,6 +56,36 @@ ErrCode ServiceProxy::InitRestoreSession(sptr<IServiceReverse> remote)
     return reply.ReadInt32();
 }
 
+ErrCode ServiceProxy::InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg)
+{
+    HITRACE_METER_NAME(HITRACE_TAG_FILEMANAGEMENT, __PRETTY_FUNCTION__);
+    BExcepUltils::BAssert(Remote(), BError::Codes::SDK_INVAL_ARG, "Remote is nullptr");
+    MessageParcel data;
+    if (!data.WriteInterfaceToken(GetDescriptor())) {
+        return BError(BError::Codes::SDK_INVAL_ARG, "Failed to write descriptor").GetCode();
+    }
+    MessageParcel reply;
+    MessageOption option;
+
+    if (!remote) {
+        return BError(BError::Codes::SDK_INVAL_ARG, "Empty reverse stub").GetCode();
+    }
+    if (!data.WriteRemoteObject(remote->AsObject().GetRefPtr())) {
+        return BError(BError::Codes::SDK_INVAL_ARG, "Failed to send the reverse stub").GetCode();
+    }
+
+    int32_t ret = Remote()->SendRequest(
+        static_cast<uint32_t>(IServiceInterfaceCode::SERVICE_CMD_INIT_RESTORE_SESSION_MSG), data, reply, option);
+    if (ret != NO_ERROR) {
+        string str = "Failed to send out the request because of " + to_string(ret);
+        return BError(BError::Codes::SDK_INVAL_ARG, str.data()).GetCode();
+    }
+    if (!reply.ReadString(errMsg)) {
+        return BError(BError::Codes::SDK_INVAL_ARG, "Failed to receive the errMsg").GetCode();
+    }
+    return reply.ReadInt32();
+}
+
 ErrCode ServiceProxy::InitBackupSession(sptr<IServiceReverse> remote)
 {
     HITRACE_METER_NAME(HITRACE_TAG_FILEMANAGEMENT, __PRETTY_FUNCTION__);
diff --git a/interfaces/inner_api/native/backup_kit_inner/impl/b_incremental_restore_session.h b/interfaces/inner_api/native/backup_kit_inner/impl/b_incremental_restore_session.h
index 502fd1a9c39a382a51c9b6965c97a12216ab2ccb..9f1b0b9fddfc8d8124a9cd58c16108b16b8fef24 100644
--- a/interfaces/inner_api/native/backup_kit_inner/impl/b_incremental_restore_session.h
+++ b/interfaces/inner_api/native/backup_kit_inner/impl/b_incremental_restore_session.h
@@ -49,6 +49,17 @@ public:
      */
     static std::unique_ptr<BIncrementalRestoreSession> Init(Callbacks callbacks);
 
+    /**
+     * @brief 获取一个用于控制恢复流程的会话
+     *
+     * @param callbacks 注册的回调函数
+     * @param errMsg 失败信息
+     * @param errCode 错误码
+     * @return std::unique_ptr<BRestoreSession> 指向BRestoreSession的智能指针。失败时为空指针
+     */
+    static std::unique_ptr<BIncrementalRestoreSession> Init(Callbacks callbacks,
+                                                            std::string &errMsg, ErrCode &errCode);
+
     /**
      * @brief 通知备份服务文件内容已就绪
      *
diff --git a/interfaces/inner_api/native/backup_kit_inner/impl/i_service.h b/interfaces/inner_api/native/backup_kit_inner/impl/i_service.h
index 630867b95115dd1de4e9342bbcfb610a9860990f..ec94562938692da901f120a2861ae209107c9c56 100644
--- a/interfaces/inner_api/native/backup_kit_inner/impl/i_service.h
+++ b/interfaces/inner_api/native/backup_kit_inner/impl/i_service.h
@@ -46,6 +46,7 @@ class IService : public IRemoteBroker {
 public:
     virtual ~IService() = default;
     virtual ErrCode InitRestoreSession(sptr<IServiceReverse> remote) = 0;
+    virtual ErrCode InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg) = 0;
     virtual ErrCode InitBackupSession(sptr<IServiceReverse> remote) = 0;
     virtual ErrCode Start() = 0;
     virtual UniqueFd GetLocalCapabilities() = 0;
diff --git a/interfaces/inner_api/native/backup_kit_inner/impl/i_service_ipc_interface_code.h b/interfaces/inner_api/native/backup_kit_inner/impl/i_service_ipc_interface_code.h
index f6027fab4528e8568b4ccbb2eeb259b229ba3b5c..2431573bcd93f94533b5a4c8d2e88ba0b35e6070 100644
--- a/interfaces/inner_api/native/backup_kit_inner/impl/i_service_ipc_interface_code.h
+++ b/interfaces/inner_api/native/backup_kit_inner/impl/i_service_ipc_interface_code.h
@@ -20,6 +20,7 @@
 namespace OHOS::FileManagement::Backup {
 enum class IServiceInterfaceCode {
     SERVICE_CMD_INIT_RESTORE_SESSION,
+    SERVICE_CMD_INIT_RESTORE_SESSION_MSG,
     SERVICE_CMD_INIT_BACKUP_SESSION,
     SERVICE_CMD_GET_LOCAL_CAPABILITIES,
     SERVICE_CMD_PUBLISH_FILE,
diff --git a/interfaces/inner_api/native/backup_kit_inner/impl/service_proxy.h b/interfaces/inner_api/native/backup_kit_inner/impl/service_proxy.h
index 07071b41b773b71af3c7eac1f283f182bd343a5c..e2b849c625df350a8f6127eaa10f8cd19bfdeedd 100644
--- a/interfaces/inner_api/native/backup_kit_inner/impl/service_proxy.h
+++ b/interfaces/inner_api/native/backup_kit_inner/impl/service_proxy.h
@@ -29,6 +29,7 @@ namespace OHOS::FileManagement::Backup {
 class ServiceProxy : public IRemoteProxy<IService> {
 public:
     ErrCode InitRestoreSession(sptr<IServiceReverse> remote) override;
+    ErrCode InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg) override;
     ErrCode InitBackupSession(sptr<IServiceReverse> remote) override;
     ErrCode Start() override;
     UniqueFd GetLocalCapabilities() override;
diff --git a/interfaces/kits/js/backup/session_restore_n_exporter.cpp b/interfaces/kits/js/backup/session_restore_n_exporter.cpp
index ddc36c4c0abbbb33b6754a5105ca9277b9603f56..26afea923e65f273ca4c394b91839d546bd60e45 100644
--- a/interfaces/kits/js/backup/session_restore_n_exporter.cpp
+++ b/interfaces/kits/js/backup/session_restore_n_exporter.cpp
@@ -454,6 +454,8 @@ napi_value SessionRestoreNExporter::Constructor(napi_env env, napi_callback_info
     auto restoreEntity = std::make_unique<RestoreEntity>();
     restoreEntity->callbacks = make_shared<GeneralCallbacks>(env, ptr, callbacks);
     restoreEntity->sessionWhole = nullptr;
+    ErrCode errCode;
+    std::string errMsg;
     restoreEntity->sessionSheet = BIncrementalRestoreSession::Init(BIncrementalRestoreSession::Callbacks {
         .onFileReady = bind(OnFileReadySheet, restoreEntity->callbacks, placeholders::_1, placeholders::_2,
             placeholders::_3, placeholders::_4),
@@ -462,9 +464,12 @@ napi_value SessionRestoreNExporter::Constructor(napi_env env, napi_callback_info
         .onAllBundlesFinished = bind(onAllBundlesEnd, restoreEntity->callbacks, placeholders::_1),
         .onResultReport = bind(OnResultReport, restoreEntity->callbacks, placeholders::_1, placeholders::_2),
         .onBackupServiceDied = bind(OnBackupServiceDied, restoreEntity->callbacks),
-        .onProcess = bind(OnProcess, restoreEntity->callbacks, placeholders::_1, placeholders::_2)});
+        .onProcess = bind(OnProcess, restoreEntity->callbacks, placeholders::_1, placeholders::_2)}, errMsg, errCode);
     if (!restoreEntity->sessionSheet) {
-        NError(BError(BError::Codes::SDK_INVAL_ARG, "Failed to init restore").GetCode()).ThrowErr(env);
+        std::tuple<uint32_t, std::string> errInfo =
+            std::make_tuple(errCode, BError::GetBackupMsgByErrno(errCode) + ", " + errMsg);
+        ErrParam errorParam = [ errInfo ]() { return errInfo;};
+        NError(errorParam).ThrowErr(env);
         return nullptr;
     }
     if (!SetSessionRestoreEntity(env, funcArg, std::move(restoreEntity))) {
diff --git a/services/backup_sa/include/module_ipc/service.h b/services/backup_sa/include/module_ipc/service.h
index fef2dbdbb2055acbcb547e729de987dffac45942..4d257bbce116d0bdcc571bdef51085eec5d16f68 100644
--- a/services/backup_sa/include/module_ipc/service.h
+++ b/services/backup_sa/include/module_ipc/service.h
@@ -49,6 +49,7 @@ class Service : public SystemAbility, public ServiceStub, protected NoCopyable {
     // 以下都是IPC接口
 public:
     ErrCode InitRestoreSession(sptr<IServiceReverse> remote) override;
+    ErrCode InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg) override;
     ErrCode InitBackupSession(sptr<IServiceReverse> remote) override;
     ErrCode Start() override;
     UniqueFd GetLocalCapabilities() override;
@@ -327,6 +328,20 @@ private:
      */
     ErrCode VerifyCaller();
 
+    /**
+     * @brief 获取调用者名称
+     *
+     * @return std::string
+     */
+    std::string GetCallerName();
+
+    /**
+     * @brief 获取用户id
+     *
+     * @return int32_t
+     */
+    int32_t GetUserIdDefault();
+
     /**
      * @brief 验证调用者
      *
@@ -550,6 +565,10 @@ private:
     void ExtensionConnectFailRadarReport(const std::string &bundleName, const ErrCode errCode,
         const IServiceReverse::Scenario scenario);
 
+    void OnStartResRadarReport(const std::vector<std::string> &bundleNameList, int32_t stage);
+
+    void PermissionCheckFailRadar(const std::string &info, const std::string &func);
+
     void UpdateFailedBundles(const std::string &bundleName, BundleTaskInfo taskInfo);
 
     void ClearFailedBundles();
diff --git a/services/backup_sa/include/module_ipc/service_stub.h b/services/backup_sa/include/module_ipc/service_stub.h
index 8ccaddf564edf79eb8112a9b9e540feefa3ac97b..45acead705fc166c7ec52f35acb9c67ab807e7f9 100644
--- a/services/backup_sa/include/module_ipc/service_stub.h
+++ b/services/backup_sa/include/module_ipc/service_stub.h
@@ -35,6 +35,7 @@ private:
     std::map<uint32_t, ServiceInterface> opToInterfaceMap_;
 
     int32_t CmdInitRestoreSession(MessageParcel &data, MessageParcel &reply);
+    int32_t CmdInitRestoreSessionMsg(MessageParcel &data, MessageParcel &reply);
     int32_t CmdInitBackupSession(MessageParcel &data, MessageParcel &reply);
     int32_t CmdStart(MessageParcel &data, MessageParcel &reply);
     int32_t CmdGetLocalCapabilities(MessageParcel &data, MessageParcel &reply);
diff --git a/services/backup_sa/include/module_ipc/svc_session_manager.h b/services/backup_sa/include/module_ipc/svc_session_manager.h
index e124e9b094f966ec849894de1af27d7dbc591dc0..f8bfd92c9bac75f6cdff512dc9272938f94b634d 100644
--- a/services/backup_sa/include/module_ipc/svc_session_manager.h
+++ b/services/backup_sa/include/module_ipc/svc_session_manager.h
@@ -92,6 +92,8 @@ public:
         RestoreTypeEnum restoreDataType {RESTORE_DATA_WAIT_SEND};
         bool isIncrementalBackup {false};
         std::string oldBackupVersion {""};
+        std::string callerName {};
+        std::string activeTime {};
     };
 
 public:
@@ -163,6 +165,20 @@ public:
      */
     void SetSessionUserId(int32_t userId);
 
+    /**
+     * @brief 获取当前处理事务会话对应的callerName
+     *
+     * @return string
+     */
+    std::string GetSessionCallerName();
+
+    /**
+     * @brief 获取当前处理事务会话对应的激活时间
+     *
+     * @return string
+     */
+    std::string GetSessionActiveTime();
+
     /**
      * @brief 更新backupExtNameMap并判断是否完成分发
      *
diff --git a/services/backup_sa/src/module_ipc/service.cpp b/services/backup_sa/src/module_ipc/service.cpp
index 50ac3c848ae1cd83764ca332fbb6b53c46ae7ad6..86f5810cb70ad2e7c33b5e1685385e9729f179d7 100644
--- a/services/backup_sa/src/module_ipc/service.cpp
+++ b/services/backup_sa/src/module_ipc/service.cpp
@@ -90,7 +90,7 @@ const int32_t MAX_TRY_CLEAR_DISPOSE_NUM = 3;
 } // namespace
 
 /* Shell/Xts user id equal to 0/1, we need set default 100 */
-static inline int32_t GetUserIdDefault()
+int32_t Service::GetUserIdDefault()
 {
     auto [isDebug, debugId] = BackupPara().GetBackupDebugOverrideAccount();
     if (isDebug && debugId > DEBUG_ID) {
@@ -104,7 +104,7 @@ static inline int32_t GetUserIdDefault()
     return multiuser.userId;
 }
 
-void OnStartResRadarReport(const std::vector<std::string> &bundleNameList, int32_t stage)
+void Service::OnStartResRadarReport(const std::vector<std::string> &bundleNameList, int32_t stage)
 {
     std::stringstream ss;
     ss << "failedBundles:{";
@@ -220,6 +220,8 @@ void Service::OnStart()
                 .scenario = IServiceReverse::Scenario::CLEAN,
                 .clientProxy = nullptr,
                 .userId = GetUserIdDefault(),
+                .callerName = "BackupSA",
+                .activeTime = TimeUtils::GetCurrentTime(),
             },
             isOccupyingSession_.load());
         HILOGE("SA OnStart, cleaning up backup data");
@@ -337,7 +339,7 @@ void Service::StopAll(const wptr<IRemoteObject> &obj, bool force)
     session_->Deactive(obj, force);
 }
 
-static inline void PermissionCheckFailRadar(const std::string &info, const std::string &func)
+void Service::PermissionCheckFailRadar(const std::string &info, const std::string &func)
 {
     std::string funcPos = "Service::";
     AppRadar::Info resInfo("", "", info);
@@ -453,6 +455,8 @@ ErrCode Service::InitRestoreSession(sptr<IServiceReverse> remote)
         .scenario = IServiceReverse::Scenario::RESTORE,
         .clientProxy = remote,
         .userId = GetUserIdDefault(),
+        .callerName = GetCallerName(),
+        .activeTime = TimeUtils::GetCurrentTime(),
     });
     if (ret != ERR_OK) {
         HILOGE("Active restore session error, Already have a session");
@@ -480,6 +484,8 @@ ErrCode Service::InitBackupSession(sptr<IServiceReverse> remote)
         .scenario = IServiceReverse::Scenario::BACKUP,
         .clientProxy = remote,
         .userId = GetUserIdDefault(),
+        .callerName = GetCallerName(),
+        .activeTime = TimeUtils::GetCurrentTime(),
     });
     if (ret != ERR_OK) {
         HILOGE("Active backup session error, Already have a session");
diff --git a/services/backup_sa/src/module_ipc/service_incremental.cpp b/services/backup_sa/src/module_ipc/service_incremental.cpp
index cc77b39cb23d71ef1260429344db18785d8fbb19..49616ee8a75693c0a4c510ad7fe9644fb35b0626 100644
--- a/services/backup_sa/src/module_ipc/service_incremental.cpp
+++ b/services/backup_sa/src/module_ipc/service_incremental.cpp
@@ -43,6 +43,7 @@
 #include "b_radar/b_radar.h"
 #include "b_resources/b_constants.h"
 #include "b_sa/b_sa_utils.h"
+#include "b_utils/b_time.h"
 #include "filemgmt_libhilog.h"
 #include "hisysevent.h"
 #include "ipc_skeleton.h"
@@ -58,26 +59,11 @@ using namespace std;
 const std::string FILE_BACKUP_EVENTS = "FILE_BACKUP_EVENTS";
 
 namespace {
-constexpr int32_t DEBUG_ID = 100;
 constexpr int32_t INDEX = 3;
 constexpr int32_t MS_1000 = 1000;
 const static string UNICAST_TYPE = "unicast";
 } // namespace
 
-static inline int32_t GetUserIdDefault()
-{
-    HITRACE_METER_NAME(HITRACE_TAG_FILEMANAGEMENT, __PRETTY_FUNCTION__);
-    auto [isDebug, debugId] = BackupPara().GetBackupDebugOverrideAccount();
-    if (isDebug && debugId > DEBUG_ID) {
-        return debugId;
-    }
-    auto multiuser = BMultiuser::ParseUid(IPCSkeleton::GetCallingUid());
-    if ((multiuser.userId == BConstants::SYSTEM_UID) || (multiuser.userId == BConstants::XTS_UID)) {
-        return BConstants::DEFAULT_USER_ID;
-    }
-    return multiuser.userId;
-}
-
 ErrCode Service::Release()
 {
     HITRACE_METER_NAME(HITRACE_TAG_FILEMANAGEMENT, __PRETTY_FUNCTION__);
@@ -322,7 +308,9 @@ ErrCode Service::InitIncrementalBackupSession(sptr<IServiceReverse> remote)
                                 .scenario = IServiceReverse::Scenario::BACKUP,
                                 .clientProxy = remote,
                                 .userId = GetUserIdDefault(),
-                                .isIncrementalBackup = true});
+                                .isIncrementalBackup = true,
+                                .callerName = GetCallerName(),
+                                .activeTime = TimeUtils::GetCurrentTime()});
     if (errCode != ERR_OK) {
         HILOGE("Active incremental backup session error, Already have a session");
         StopAll(nullptr, true);
diff --git a/services/backup_sa/src/module_ipc/service_stub.cpp b/services/backup_sa/src/module_ipc/service_stub.cpp
index 89eda115dca683703e171c0cd09cf68b83c55959..ff3d5b2190be36c4c3c364b9b99eec3aafb481cf 100644
--- a/services/backup_sa/src/module_ipc/service_stub.cpp
+++ b/services/backup_sa/src/module_ipc/service_stub.cpp
@@ -52,6 +52,8 @@ void ServiceStub::ServiceStubSupplement()
         &ServiceStub::CmdStartFwkTimer;
     opToInterfaceMap_[static_cast<uint32_t>(IServiceInterfaceCode::SERVICE_CMD_CANCEL_BUNDLE)] =
         &ServiceStub::CmdCancel;
+    opToInterfaceMap_[static_cast<uint32_t>(IServiceInterfaceCode::SERVICE_CMD_INIT_RESTORE_SESSION_MSG)] =
+        &ServiceStub::CmdInitRestoreSessionMsg;
     opToInterfaceMap_[static_cast<uint32_t>(IServiceInterfaceCode::SERVICE_CMD_STOP_EXT_TIMER)] =
         &ServiceStub::CmdStopExtTimer;
 }
@@ -156,6 +158,29 @@ int32_t ServiceStub::CmdInitRestoreSession(MessageParcel &data, MessageParcel &r
     return BError(BError::Codes::OK);
 }
 
+int32_t ServiceStub::CmdInitRestoreSessionMsg(MessageParcel &data, MessageParcel &reply)
+{
+    auto remote = data.ReadRemoteObject();
+    std::string errMsg;
+    if (!remote) {
+        return BError(BError::Codes::SA_INVAL_ARG, "Failed to receive the stub");
+    }
+    auto iremote = iface_cast<IServiceReverse>(remote);
+    if (!iremote) {
+        return BError(BError::Codes::SA_INVAL_ARG, "Failed to receive the reverse stub");
+    }
+    int32_t res = InitRestoreSession(iremote, errMsg);
+    if (!reply.WriteString(errMsg)) {
+        return BError(BError::Codes::SA_BROKEN_IPC, "Failed to send the errMsg");
+    }
+    if (!reply.WriteInt32(res)) {
+        stringstream ss;
+        ss << "Failed to send the result " << res;
+        return BError(BError::Codes::SA_BROKEN_IPC, ss.str());
+    }
+    return BError(BError::Codes::OK);
+}
+
 int32_t ServiceStub::CmdInitBackupSession(MessageParcel &data, MessageParcel &reply)
 {
     auto remote = data.ReadRemoteObject();
diff --git a/services/backup_sa/src/module_ipc/sub_service.cpp b/services/backup_sa/src/module_ipc/sub_service.cpp
index 71f25b5ac465dea39c82dca2109839c3d265c900..87da0624068e6cc7706c8836bd9dd8842219c2a8 100644
--- a/services/backup_sa/src/module_ipc/sub_service.cpp
+++ b/services/backup_sa/src/module_ipc/sub_service.cpp
@@ -45,6 +45,7 @@
 #include "b_radar/b_radar.h"
 #include "b_resources/b_constants.h"
 #include "b_sa/b_sa_utils.h"
+#include "b_utils/b_time.h"
 #include "bundle_mgr_client.h"
 #include "filemgmt_libhilog.h"
 #include "hisysevent.h"
@@ -622,4 +623,68 @@ ErrCode Service::HandleCurAppDone(ErrCode errCode, const std::string &bundleName
     }
     return BError(BError::Codes::OK);
 }
+std::string Service::GetCallerName()
+{
+    std::string callerName;
+    uint32_t tokenCaller = IPCSkeleton::GetCallingTokenID();
+    int tokenType = Security::AccessToken::AccessTokenKit::GetTokenType(tokenCaller);
+    switch (tokenType) {
+        case Security::AccessToken::ATokenTypeEnum::TOKEN_NATIVE: { /* Update Service */
+            Security::AccessToken::NativeTokenInfo nativeTokenInfo;
+            if (Security::AccessToken::AccessTokenKit::GetNativeTokenInfo(tokenCaller, nativeTokenInfo) != 0) {
+                HILOGE("Failed to get native token info");
+                break;
+            }
+            callerName = nativeTokenInfo.processName;
+            break;
+        }
+        case Security::AccessToken::ATokenTypeEnum::TOKEN_HAP: {
+            Security::AccessToken::HapTokenInfo hapTokenInfo;
+            if (Security::AccessToken::AccessTokenKit::GetHapTokenInfo(tokenCaller, hapTokenInfo) != 0) {
+                HILOGE("Failed to get hap token info");
+                break;
+            }
+            callerName = hapTokenInfo.bundleName;
+            break;
+        }
+        default:
+            HILOGE("Invalid token type, %{public}s", to_string(tokenType).c_str());
+            break;
+    }
+    return callerName;
+}
+
+ErrCode Service::InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg)
+{
+    HITRACE_METER_NAME(HITRACE_TAG_FILEMANAGEMENT, __PRETTY_FUNCTION__);
+    ErrCode ret = VerifyCaller();
+    if (ret != ERR_OK) {
+        HILOGE("Init restore session failed, verify caller failed");
+        return ret;
+    }
+    ret = session_->Active({
+        .clientToken = IPCSkeleton::GetCallingTokenID(),
+        .scenario = IServiceReverse::Scenario::RESTORE,
+        .clientProxy = remote,
+        .userId = GetUserIdDefault(),
+        .callerName = GetCallerName(),
+        .activeTime = TimeUtils::GetCurrentTime(),
+    });
+    if (ret == ERR_OK) {
+        ClearFailedBundles();
+        successBundlesNum_ = 0;
+        return ret;
+    }
+    if (ret == BError(BError::Codes::SA_SESSION_CONFLICT)) {
+        errMsg = BJsonUtil::BuildInitSessionErrInfo(session_->GetSessionUserId(),
+                                                    session_->GetSessionCallerName(),
+                                                    session_->GetSessionActiveTime());
+        HILOGE("Active restore session error, Already have a session");
+        StopAll(nullptr, true);
+        return ret;
+    }
+    HILOGE("Active restore session error");
+    StopAll(nullptr, true);
+    return ret;
+}
 }
\ No newline at end of file
diff --git a/services/backup_sa/src/module_ipc/svc_session_manager.cpp b/services/backup_sa/src/module_ipc/svc_session_manager.cpp
index 7ea412d1b87e7005d17e8be1213802168ae7592d..ba82c1c596fd4138e4521e6006dda93160c0d538 100644
--- a/services/backup_sa/src/module_ipc/svc_session_manager.cpp
+++ b/services/backup_sa/src/module_ipc/svc_session_manager.cpp
@@ -78,8 +78,9 @@ ErrCode SvcSessionManager::Active(Impl newImpl, bool isOccupyingSession)
     unique_lock<shared_mutex> lock(lock_);
     const Impl &oldImpl = impl_;
     if (oldImpl.clientToken) {
-        HILOGE("Already have an active session");
-        return BError(BError::Codes::SA_REFUSED_ACT);
+        HILOGE("Already have an active session, userId=%{public}d, caller=%{public}s, activeTime=%{public}s",
+            impl_.userId, impl_.callerName.c_str(), impl_.activeTime.c_str());
+        return BError(BError::Codes::SA_SESSION_CONFLICT);
     }
 
     if (!isOccupyingSession && !newImpl.clientToken) {
@@ -180,6 +181,26 @@ void SvcSessionManager::SetSessionUserId(int32_t userId)
     impl_.userId = userId;
 }
 
+string SvcSessionManager::GetSessionCallerName()
+{
+    shared_lock<shared_mutex> lock(lock_);
+    if (!impl_.clientToken) {
+        HILOGE("Get scenario failed, No caller token was specified");
+        return "";
+    }
+    return impl_.callerName;
+}
+
+string SvcSessionManager::GetSessionActiveTime()
+{
+    shared_lock<shared_mutex> lock(lock_);
+    if (!impl_.clientToken) {
+        HILOGE("Get scenario failed, No caller token was specified");
+        return "";
+    }
+    return impl_.activeTime;
+}
+
 bool SvcSessionManager::OnBundleFileReady(const string &bundleName, const string &fileName)
 {
     unique_lock<shared_mutex> lock(lock_);
diff --git a/tests/mock/backup_kit_inner/service_proxy_mock.cpp b/tests/mock/backup_kit_inner/service_proxy_mock.cpp
index 4ed01cd8f5dd919b6cf0f14fb7fa44ae95d3258c..15c53566cd9059a292e8543ea1327466139669ba 100644
--- a/tests/mock/backup_kit_inner/service_proxy_mock.cpp
+++ b/tests/mock/backup_kit_inner/service_proxy_mock.cpp
@@ -39,6 +39,14 @@ int32_t ServiceProxy::InitRestoreSession(sptr<IServiceReverse> remote)
     return 0;
 }
 
+int32_t ServiceProxy::InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg)
+{
+    if (!GetMockInitBackupOrRestoreSession()) {
+        return 1;
+    }
+    return 0;
+}
+
 int32_t ServiceProxy::InitBackupSession(sptr<IServiceReverse> remote)
 {
     if (!GetMockInitBackupOrRestoreSession()) {
diff --git a/tests/mock/module_ipc/include/svc_session_manager_mock.h b/tests/mock/module_ipc/include/svc_session_manager_mock.h
index e8f74bb042c05c7418605739e68aa244abc043bc..fcfb87865130aefb9f55bc6e703c447c240a3a86 100644
--- a/tests/mock/module_ipc/include/svc_session_manager_mock.h
+++ b/tests/mock/module_ipc/include/svc_session_manager_mock.h
@@ -27,6 +27,8 @@ public:
     virtual sptr<IServiceReverse> GetServiceReverseProxy() = 0;
     virtual IServiceReverse::Scenario GetScenario() = 0;
     virtual int32_t GetSessionUserId() = 0;
+    virtual std::string GetSessionCallerName() = 0;
+    virtual std::string GetSessionActiveTime() = 0;
     virtual bool OnBundleFileReady(const std::string&, const std::string&) = 0;
     virtual UniqueFd OnBundleExtManageInfo(const std::string&, UniqueFd) = 0;
     virtual wptr<SvcBackupConnection> GetExtConnection(const BundleName&) = 0;
@@ -72,6 +74,8 @@ public:
     MOCK_METHOD((sptr<IServiceReverse>), GetServiceReverseProxy, ());
     MOCK_METHOD(IServiceReverse::Scenario, GetScenario, ());
     MOCK_METHOD(int32_t, GetSessionUserId, ());
+    MOCK_METHOD(std::string, GetSessionCallerName, ());
+    MOCK_METHOD(std::string, GetSessionActiveTime, ());
     MOCK_METHOD(bool, OnBundleFileReady, (const std::string&, const std::string&));
     MOCK_METHOD(UniqueFd, OnBundleExtManageInfo, (const std::string&, UniqueFd));
     MOCK_METHOD((wptr<SvcBackupConnection>), GetExtConnection, (const BundleName&));
diff --git a/tests/mock/module_ipc/service_mock.cpp b/tests/mock/module_ipc/service_mock.cpp
index dd09cac5ed021f96acf5f462f852d26e90531f34..d197448539fb3aa471260060d82d50c73c9670d2 100644
--- a/tests/mock/module_ipc/service_mock.cpp
+++ b/tests/mock/module_ipc/service_mock.cpp
@@ -26,6 +26,11 @@
 namespace OHOS::FileManagement::Backup {
 using namespace std;
 
+int32_t Service::GetUserIdDefault()
+{
+    return 0;
+}
+
 void Service::OnStart() {}
 
 void Service::OnStop() {}
@@ -47,6 +52,11 @@ ErrCode Service::InitRestoreSession(sptr<IServiceReverse> remote)
     return BError(BError::Codes::OK);
 }
 
+ErrCode Service::InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg)
+{
+    return BError(BError::Codes::OK);
+}
+
 ErrCode Service::InitBackupSession(sptr<IServiceReverse> remote)
 {
     return BError(BError::Codes::OK);
@@ -303,6 +313,15 @@ void Service::FileReadyRadarReport(const std::string &bundleName, const std::str
 void Service::ExtensionConnectFailRadarReport(const std::string &bundleName, const ErrCode errCode,
     const IServiceReverse::Scenario scenario) {}
 
+void Service::PermissionCheckFailRadar(const std::string &info, const std::string &func) {}
+
+void Service::OnStartResRadarReport(const std::vector<std::string> &bundleNameList, int32_t stage) {}
+
+std::string Service::GetCallerName()
+{
+    return "";
+}
+
 void Service::UpdateFailedBundles(const std::string &bundleName, BundleTaskInfo taskInfo) {}
 
 void Service::ClearFailedBundles() {}
diff --git a/tests/mock/module_ipc/service_stub_mock.cpp b/tests/mock/module_ipc/service_stub_mock.cpp
index 97452a3ebb3fea07c203afafc04f213fee20cfa8..c429636896b4da04ce848de39524935298f82b68 100644
--- a/tests/mock/module_ipc/service_stub_mock.cpp
+++ b/tests/mock/module_ipc/service_stub_mock.cpp
@@ -85,6 +85,8 @@ void ServiceStub::ServiceStubSupplement()
         &ServiceStub::CmdUpdateSendRate;
     opToInterfaceMap_[static_cast<uint32_t>(IServiceInterfaceCode::SERVICE_CMD_REPORT_APP_PROCESS_INFO)] =
         &ServiceStub::CmdReportAppProcessInfo;
+    opToInterfaceMap_[static_cast<uint32_t>(IServiceInterfaceCode::SERVICE_CMD_INIT_RESTORE_SESSION_MSG)] =
+        &ServiceStub::CmdInitRestoreSessionMsg;
     opToInterfaceMap_[static_cast<uint32_t>(IServiceInterfaceCode::SERVICE_CMD_CANCEL_BUNDLE)] =
         &ServiceStub::CmdCancel;
 }
@@ -114,6 +116,17 @@ int32_t ServiceStub::CmdInitRestoreSession(MessageParcel &data, MessageParcel &r
     return BError(BError::Codes::OK);
 }
 
+int32_t ServiceStub::CmdInitRestoreSessionMsg(MessageParcel &data, MessageParcel &reply)
+{
+    auto remote = data.ReadRemoteObject();
+    auto iremote = iface_cast<IServiceReverse>(remote);
+    std::string errMsg;
+    int32_t res = InitRestoreSession(iremote, errMsg);
+    reply.WriteString(errMsg);
+    reply.WriteInt32(res);
+    return BError(BError::Codes::OK);
+}
+
 int32_t ServiceStub::CmdInitBackupSession(MessageParcel &data, MessageParcel &reply)
 {
     auto remote = data.ReadRemoteObject();
diff --git a/tests/mock/module_ipc/src/svc_session_manager_mock.cpp b/tests/mock/module_ipc/src/svc_session_manager_mock.cpp
index 0fed3b03e77a1fb148002309d5b2b8691e58761a..255d5ddab81a2e23ceba5ed26943a71aaf8e5700 100644
--- a/tests/mock/module_ipc/src/svc_session_manager_mock.cpp
+++ b/tests/mock/module_ipc/src/svc_session_manager_mock.cpp
@@ -162,6 +162,17 @@ int32_t SvcSessionManager::GetSessionUserId()
 
 void SvcSessionManager::SetSessionUserId(int32_t) {}
 
+std::string SvcSessionManager::GetSessionCallerName()
+{
+    return BSvcSessionManager::sessionManager->GetSessionCallerName();
+}
+
+std::string SvcSessionManager::GetSessionActiveTime()
+{
+    return BSvcSessionManager::sessionManager->GetSessionActiveTime();
+}
+
+
 void SvcSessionManager::SetBundleRestoreType(const std::string &, RestoreTypeEnum) {}
 
 RestoreTypeEnum SvcSessionManager::GetBundleRestoreType(const std::string &bundleName)
diff --git a/tests/mock/module_ipc/svc_session_manager_mock.cpp b/tests/mock/module_ipc/svc_session_manager_mock.cpp
index b5e2a1d1aa565cce177a3a5359409cc1c64a6b8c..6cc240f17553016b18a938b290b6e778edcdfb3c 100644
--- a/tests/mock/module_ipc/svc_session_manager_mock.cpp
+++ b/tests/mock/module_ipc/svc_session_manager_mock.cpp
@@ -305,6 +305,16 @@ void SvcSessionManager::SetSessionUserId(int32_t userId)
     impl_.userId = userId;
 }
 
+string SvcSessionManager::GetSessionCallerName()
+{
+    return impl_.callerName;
+}
+
+string SvcSessionManager::GetSessionActiveTime()
+{
+    return impl_.activeTime;
+}
+
 void SvcSessionManager::SetBundleRestoreType(const std::string &bundleName, RestoreTypeEnum restoreType)
 {
     auto it = impl_.backupExtNameMap.find(bundleName);
diff --git a/tests/mock/module_ipc/svc_session_manager_throw_mock.cpp b/tests/mock/module_ipc/svc_session_manager_throw_mock.cpp
index f1fcc20680542605418a425591fb436f72ebaf25..60d2b8eb25c8112dc3584d05f62b5c3fae9d836d 100644
--- a/tests/mock/module_ipc/svc_session_manager_throw_mock.cpp
+++ b/tests/mock/module_ipc/svc_session_manager_throw_mock.cpp
@@ -185,6 +185,16 @@ void SvcSessionManager::SetSessionUserId(int32_t userId)
     BackupSvcSessionManager::session->SetSessionUserId(userId);
 }
 
+string SvcSessionManager::GetSessionCallerName()
+{
+    return BackupSvcSessionManager::session->GetSessionCallerName();
+}
+
+string SvcSessionManager::GetSessionActiveTime()
+{
+    return BackupSvcSessionManager::session->GetSessionActiveTime();
+}
+
 void SvcSessionManager::SetBundleRestoreType(const std::string &bundleName, RestoreTypeEnum restoreType)
 {
     BackupSvcSessionManager::session->SetBundleRestoreType(bundleName, restoreType);
diff --git a/tests/mock/module_ipc/svc_session_manager_throw_mock.h b/tests/mock/module_ipc/svc_session_manager_throw_mock.h
index 081da93b792e1fde9bbf50a4feb0c6f7f045186a..8e0c798c5bb30dc916a3c0a93faf09de452f8726 100644
--- a/tests/mock/module_ipc/svc_session_manager_throw_mock.h
+++ b/tests/mock/module_ipc/svc_session_manager_throw_mock.h
@@ -61,6 +61,8 @@ public:
     virtual bool NeedToUnloadService() = 0;
     virtual int32_t GetSessionUserId() = 0;
     virtual void SetSessionUserId(int32_t) = 0;
+    virtual std::string GetSessionCallerName() = 0;
+    virtual std::string GetSessionActiveTime() = 0;
     virtual void SetBundleRestoreType(const std::string &, RestoreTypeEnum) = 0;
     virtual RestoreTypeEnum GetBundleRestoreType(const std::string &) = 0;
     virtual void SetBundleVersionCode(const std::string &, int64_t) = 0;
@@ -133,6 +135,8 @@ public:
     MOCK_METHOD(bool, NeedToUnloadService, ());
     MOCK_METHOD(int32_t, GetSessionUserId, ());
     MOCK_METHOD(void, SetSessionUserId, (int32_t));
+    MOCK_METHOD(std::string, GetSessionCallerName, ());
+    MOCK_METHOD(std::string, GetSessionActiveTime, ());
     MOCK_METHOD(void, SetBundleRestoreType, (const std::string &, RestoreTypeEnum));
     MOCK_METHOD(RestoreTypeEnum, GetBundleRestoreType, (const std::string &));
     MOCK_METHOD(void, SetBundleVersionCode, (const std::string &, int64_t));
diff --git a/tests/mock/utils_mock/include/b_jsonutil_mock.h b/tests/mock/utils_mock/include/b_jsonutil_mock.h
index 01cfaff0023c242918b69d5c6d543442caf5daf4..e0e0ad7c231b7a56a57386988ed95e68b6146e4c 100644
--- a/tests/mock/utils_mock/include/b_jsonutil_mock.h
+++ b/tests/mock/utils_mock/include/b_jsonutil_mock.h
@@ -38,6 +38,7 @@ public:
     virtual bool BuildOnProcessErrInfo(std::string&, std::string, int) = 0;
     virtual bool BuildBundleInfoJson(int32_t, std::string&) = 0;
     virtual bool HasUnicastInfo(std::string&) = 0;
+    virtual std::string BuildInitSessionErrInfo(int32_t, std::string, std::string) = 0;
 public:
     BBJsonUtil() = default;
     virtual ~BBJsonUtil() = default;
@@ -62,6 +63,7 @@ public:
     MOCK_METHOD(bool, BuildOnProcessErrInfo, (std::string&, std::string, int));
     MOCK_METHOD(bool, BuildBundleInfoJson, (int32_t, std::string&));
     MOCK_METHOD(bool, HasUnicastInfo, (std::string&));
+    MOCK_METHOD(std::string, BuildInitSessionErrInfo, (int32_t, std::string, std::string));
 };
 } // namespace OHOS::FileManagement::Backup
 #endif // OHOS_FILEMGMT_BACKUP_B_JSONUTIL_MOCK_MOCK_H
diff --git a/tests/mock/utils_mock/src/b_jsonutil_mock.cpp b/tests/mock/utils_mock/src/b_jsonutil_mock.cpp
index 8d802d4186c04b7c4b62d8a26745208ce491ebb1..eea1cfee0298163e3fc50b55bb9af39f5423472f 100644
--- a/tests/mock/utils_mock/src/b_jsonutil_mock.cpp
+++ b/tests/mock/utils_mock/src/b_jsonutil_mock.cpp
@@ -72,4 +72,9 @@ bool BJsonUtil::BuildBundleInfoJson(int32_t userId, string &detailInfo)
 {
     return BBJsonUtil::jsonUtil->BuildBundleInfoJson(userId, detailInfo);
 }
+
+std::string BJsonUtil::BuildInitSessionErrInfo(int32_t userId, string callerName, string activeTime)
+{
+    return BBJsonUtil::jsonUtil->BuildInitSessionErrInfo(userId, callerName, activeTime);
+}
 }
\ No newline at end of file
diff --git a/tests/unittests/backup_api/backup_impl/include/i_service_mock.h b/tests/unittests/backup_api/backup_impl/include/i_service_mock.h
index d0600cbc6ce010d7712e3fefc463926d96a16d62..f923e04ae3e227fb93894f8a2f4c73f1fd7ad750 100644
--- a/tests/unittests/backup_api/backup_impl/include/i_service_mock.h
+++ b/tests/unittests/backup_api/backup_impl/include/i_service_mock.h
@@ -43,6 +43,14 @@ public:
         return BError(BError::Codes::OK);
     }
 
+    int32_t InvokeMsgSendRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option)
+    {
+        code_ = code;
+        reply.WriteString("");
+        reply.WriteInt32(BError(BError::Codes::OK));
+        return BError(BError::Codes::OK);
+    }
+
     int32_t InvokeGetLocalSendRequest(uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option)
     {
         code_ = code;
@@ -59,6 +67,11 @@ public:
         return BError(BError::Codes::OK);
     }
 
+    ErrCode InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg) override
+    {
+        return BError(BError::Codes::OK);
+    }
+
     ErrCode InitBackupSession(sptr<IServiceReverse> remote) override
     {
         return BError(BError::Codes::OK);
diff --git a/tests/unittests/backup_sa/module_ipc/service_incremental_test.cpp b/tests/unittests/backup_sa/module_ipc/service_incremental_test.cpp
index 8cb86458d9bc6826ac1357d691d8135f10149a60..c78dd646994fe17e1191af0d8ae5fc75b8df3fa1 100644
--- a/tests/unittests/backup_sa/module_ipc/service_incremental_test.cpp
+++ b/tests/unittests/backup_sa/module_ipc/service_incremental_test.cpp
@@ -52,6 +52,11 @@ ErrCode Service::InitRestoreSession(sptr<IServiceReverse> remote)
     return BError(BError::Codes::OK);
 }
 
+ErrCode Service::InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg)
+{
+    return BError(BError::Codes::OK);
+}
+
 ErrCode Service::InitBackupSession(sptr<IServiceReverse> remote)
 {
     return BError(BError::Codes::OK);
@@ -158,6 +163,11 @@ ErrCode Service::VerifyCaller(IServiceReverse::Scenario scenario)
     return BError(BError::Codes::OK);
 }
 
+int32_t Service::GetUserIdDefault()
+{
+    return 0;
+}
+
 void Service::OnAllBundlesFinished(ErrCode errCode) {}
 
 void Service::OnStartSched() {}
@@ -264,6 +274,15 @@ void Service::FileReadyRadarReport(const std::string &bundleName, const std::str
 void Service::ExtensionConnectFailRadarReport(const std::string &bundleName, const ErrCode errCode,
     const IServiceReverse::Scenario scenario) {}
 
+void Service::PermissionCheckFailRadar(const std::string &info, const std::string &func) {}
+
+void Service::OnStartResRadarReport(const std::vector<std::string> &bundleNameList, int32_t stage) {}
+
+std::string Service::GetCallerName()
+{
+    return "";
+}
+
 void Service::UpdateFailedBundles(const std::string &bundleName, BundleTaskInfo taskInfo) {}
 
 void Service::ClearFailedBundles() {}
@@ -359,51 +378,6 @@ void ServiceIncrementalTest::TearDownTestCase()
     srProxy = nullptr;
 }
 
-/**
- * @tc.number: SUB_ServiceIncremental_GetUserIdDefault_0000
- * @tc.name: SUB_ServiceIncremental_GetUserIdDefault_0000
- * @tc.desc: 测试 GetUserIdDefault 的正常/异常分支
- * @tc.size: MEDIUM
- * @tc.type: FUNC
- * @tc.level Level 1
- * @tc.require: issueIAKC3I
- */
-HWTEST_F(ServiceIncrementalTest, SUB_ServiceIncremental_GetUserIdDefault_0000, TestSize.Level1)
-{
-    GTEST_LOG_(INFO) << "ServiceIncrementalTest-begin SUB_ServiceIncremental_GetUserIdDefault_0000";
-    try {
-        EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
-            .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)));
-        auto ret = GetUserIdDefault();
-        EXPECT_EQ(ret, DEBUG_ID + 1);
-
-        EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(false, 0)));
-        EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-        ret = GetUserIdDefault();
-        EXPECT_EQ(ret, BConstants::DEFAULT_USER_ID);
-
-        EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(true, 0)));
-        EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-        ret = GetUserIdDefault();
-        EXPECT_EQ(ret, BConstants::DEFAULT_USER_ID);
-
-        EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(false, 0)));
-        EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::XTS_UID));
-        ret = GetUserIdDefault();
-        EXPECT_EQ(ret, BConstants::DEFAULT_USER_ID);
-
-        EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(false, 0)));
-        EXPECT_CALL(*skeleton, GetCallingUid())
-            .WillOnce(Return(BConstants::SPAN_USERID_UID + BConstants::SPAN_USERID_UID));
-        ret = GetUserIdDefault();
-        EXPECT_EQ(ret, 2);
-    } catch (...) {
-        EXPECT_TRUE(false);
-        GTEST_LOG_(INFO) << "ServiceIncrementalTest-an exception occurred by GetUserIdDefault.";
-    }
-    GTEST_LOG_(INFO) << "ServiceIncrementalTest-end SUB_ServiceIncremental_GetUserIdDefault_0000";
-}
-
 /**
  * @tc.number: SUB_ServiceIncremental_GetLocalCapabilitiesIncremental_0000
  * @tc.name: SUB_ServiceIncremental_GetLocalCapabilitiesIncremental_0000
diff --git a/tests/unittests/backup_sa/module_ipc/service_other_test.cpp b/tests/unittests/backup_sa/module_ipc/service_other_test.cpp
index a2f71964b3683507412a13084aebac81e684b3a1..f686a5b3483f738aa1e7511073eed714711d06a9 100644
--- a/tests/unittests/backup_sa/module_ipc/service_other_test.cpp
+++ b/tests/unittests/backup_sa/module_ipc/service_other_test.cpp
@@ -258,28 +258,28 @@ HWTEST_F(ServiceTest, SUB_Service_GetUserIdDefault_0000, TestSize.Level1)
     try {
         EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)));
-        auto ret = GetUserIdDefault();
+        auto ret = service->GetUserIdDefault();
         EXPECT_EQ(ret, DEBUG_ID + 1);
 
         EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(false, 0)));
         EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-        ret = GetUserIdDefault();
+        ret = service->GetUserIdDefault();
         EXPECT_EQ(ret, BConstants::DEFAULT_USER_ID);
 
         EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(true, 0)));
         EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-        ret = GetUserIdDefault();
+        ret = service->GetUserIdDefault();
         EXPECT_EQ(ret, BConstants::DEFAULT_USER_ID);
 
         EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(false, 0)));
         EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::XTS_UID));
-        ret = GetUserIdDefault();
+        ret = service->GetUserIdDefault();
         EXPECT_EQ(ret, BConstants::DEFAULT_USER_ID);
 
         EXPECT_CALL(*param, GetBackupDebugOverrideAccount()).WillOnce(Return(make_pair<bool, int32_t>(false, 0)));
         EXPECT_CALL(*skeleton, GetCallingUid())
             .WillOnce(Return(BConstants::SPAN_USERID_UID + BConstants::SPAN_USERID_UID));
-        ret = GetUserIdDefault();
+        ret = service->GetUserIdDefault();
         EXPECT_EQ(ret, 2);
     } catch (...) {
         EXPECT_TRUE(false);
diff --git a/tests/unittests/backup_sa/module_ipc/service_stub_test.cpp b/tests/unittests/backup_sa/module_ipc/service_stub_test.cpp
index 3d2029c7a150018ffe3105978a8a1fc7242e6d58..353ed10841ef71a3cccb8d0e21f1da7bf2543da5 100644
--- a/tests/unittests/backup_sa/module_ipc/service_stub_test.cpp
+++ b/tests/unittests/backup_sa/module_ipc/service_stub_test.cpp
@@ -44,6 +44,7 @@ const string FILE_NAME = "1.tar";
 class ServiceMock final : public ServiceStub {
 public:
     MOCK_METHOD1(InitRestoreSession, ErrCode(sptr<IServiceReverse> remote));
+    MOCK_METHOD2(InitRestoreSession, ErrCode(sptr<IServiceReverse> remote, std::string &errMsg));
     MOCK_METHOD1(InitBackupSession, ErrCode(sptr<IServiceReverse> remote));
     MOCK_METHOD0(Start, ErrCode());
     MOCK_METHOD0(GetLocalCapabilities, UniqueFd());
diff --git a/tests/unittests/backup_sa/module_ipc/service_test.cpp b/tests/unittests/backup_sa/module_ipc/service_test.cpp
index ff2176f75f40ab5065ad42a9ce2cb07d711a236e..1ca6f3daad5da097cd2c2cb8ef50d0134e5bdf07 100644
--- a/tests/unittests/backup_sa/module_ipc/service_test.cpp
+++ b/tests/unittests/backup_sa/module_ipc/service_test.cpp
@@ -80,6 +80,7 @@ ErrCode ServiceTest::Init(IServiceReverse::Scenario scenario)
                 "}]";
     bundleNames.emplace_back(BUNDLE_NAME);
     detailInfos.emplace_back(json);
+    string errMsg;
     ErrCode ret = 0;
     if (scenario == IServiceReverse::Scenario::RESTORE) {
         EXPECT_TRUE(servicePtr_ != nullptr);
@@ -88,6 +89,8 @@ ErrCode ServiceTest::Init(IServiceReverse::Scenario scenario)
         EXPECT_GE(fd, BError(BError::Codes::OK));
         ret = servicePtr_->InitRestoreSession(remote_);
         EXPECT_EQ(ret, BError(BError::Codes::OK));
+        ret = servicePtr_->InitRestoreSession(remote_, errMsg);
+        EXPECT_EQ(ret, BError(BError::Codes::OK));
         ret = servicePtr_->AppendBundlesRestoreSession(move(fd), bundleNames, detailInfos);
         EXPECT_EQ(ret, BError(BError::Codes::OK));
         ret = servicePtr_->Finish();
diff --git a/tests/unittests/backup_sa/module_ipc/service_throw_test.cpp b/tests/unittests/backup_sa/module_ipc/service_throw_test.cpp
index 27c48d5e9b331a62eabac24d543cad86e16908cc..da38c049cb17ba45d8652499eb8601ede5be0ce4 100644
--- a/tests/unittests/backup_sa/module_ipc/service_throw_test.cpp
+++ b/tests/unittests/backup_sa/module_ipc/service_throw_test.cpp
@@ -140,8 +140,9 @@ HWTEST_F(ServiceThrowTest, SUB_Service_throw_InitRestoreSession_0100, testing::e
     EXPECT_EQ(ret, BError(BError::Codes::SA_REFUSED_ACT).GetCode());
 
     EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0));
-    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
+    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0)).WillOnce(Return(0));
+    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL))
+        .WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
     EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)));
     EXPECT_CALL(*sessionMock, Active(_)).WillOnce(Return(BError(BError::Codes::SA_REFUSED_ACT)));
@@ -150,8 +151,9 @@ HWTEST_F(ServiceThrowTest, SUB_Service_throw_InitRestoreSession_0100, testing::e
     EXPECT_EQ(ret, BError(BError::Codes::SA_REFUSED_ACT).GetCode());
 
     EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0));
-    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
+    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0)).WillOnce(Return(0));
+    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL))
+        .WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
     EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)));
     EXPECT_CALL(*sessionMock, Active(_)).WillOnce(Return(BError(BError::Codes::OK)));
@@ -181,8 +183,9 @@ HWTEST_F(ServiceThrowTest, SUB_Service_throw_InitBackupSession_0100, testing::ex
     EXPECT_EQ(ret, BError(BError::Codes::SA_REFUSED_ACT).GetCode());
 
     EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0));
-    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
+    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0)).WillOnce(Return(0));
+    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL))
+        .WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
     EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)));
     EXPECT_CALL(*sessionMock, Active(_)).WillOnce(Return(BError(BError::Codes::SA_REFUSED_ACT)));
@@ -191,8 +194,9 @@ HWTEST_F(ServiceThrowTest, SUB_Service_throw_InitBackupSession_0100, testing::ex
     EXPECT_EQ(ret, BError(BError::Codes::SA_REFUSED_ACT).GetCode());
 
     EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0));
-    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
+    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0)).WillOnce(Return(0));
+    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL))
+        .WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
     EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)));
     EXPECT_CALL(*sessionMock, Active(_)).WillOnce(Return(BError(BError::Codes::OK)));
@@ -915,8 +919,9 @@ HWTEST_F(ServiceThrowTest, SUB_Service_throw_InitIncrementalBackupSession_0100,
     EXPECT_EQ(ret, BError(BError::Codes::SA_REFUSED_ACT).GetCode());
 
     EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0));
-    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
+    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0)).WillOnce(Return(0));
+    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL))
+        .WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
     EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)))
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)));
@@ -926,8 +931,9 @@ HWTEST_F(ServiceThrowTest, SUB_Service_throw_InitIncrementalBackupSession_0100,
     EXPECT_EQ(ret, BError(BError::Codes::SA_REFUSED_ACT).GetCode());
 
     EXPECT_CALL(*skeleton, GetCallingUid()).WillOnce(Return(BConstants::SYSTEM_UID));
-    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0));
-    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
+    EXPECT_CALL(*skeleton, GetCallingTokenID()).WillOnce(Return(0)).WillOnce(Return(0)).WillOnce(Return(0));
+    EXPECT_CALL(*token, GetTokenType(_)).WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL))
+        .WillOnce(Return(Security::AccessToken::ATokenTypeEnum::TOKEN_SHELL));
     EXPECT_CALL(*param, GetBackupDebugOverrideAccount())
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)))
             .WillOnce(Return(make_pair<bool, int32_t>(true, DEBUG_ID + 1)))
diff --git a/tests/unittests/backup_sa/module_ipc/svc_session_manager_test.cpp b/tests/unittests/backup_sa/module_ipc/svc_session_manager_test.cpp
index 4e603fb6bd51abd3dd23bc278e6a7b5f83e1d0a1..a32ca5a1a95ae2497fa3c2f5ff5371f8eb54a8fc 100644
--- a/tests/unittests/backup_sa/module_ipc/svc_session_manager_test.cpp
+++ b/tests/unittests/backup_sa/module_ipc/svc_session_manager_test.cpp
@@ -133,7 +133,7 @@ HWTEST_F(SvcSessionManagerTest, SUB_backup_sa_session_Active_0100, testing::ext:
         EXPECT_TRUE(sessionManagerPtr_ != nullptr);
         sessionManagerPtr_->impl_.clientToken = CLIENT_TOKEN_ID;
         auto res = sessionManagerPtr_->Active(newImpl);
-        EXPECT_EQ(res, BError(BError::Codes::SA_REFUSED_ACT).GetCode());
+        EXPECT_EQ(res, BError(BError::Codes::SA_SESSION_CONFLICT).GetCode());
 
         sessionManagerPtr_->impl_.clientToken = 0;
         res = sessionManagerPtr_->Active(newImpl);
diff --git a/tests/unittests/backup_sa/session/service_proxy_mock.cpp b/tests/unittests/backup_sa/session/service_proxy_mock.cpp
index d41b0a5b8496a10d2e93ddc5d09551fd839b72f0..d75c3196a8cf6ab5c58835646f0b8f8669515a36 100644
--- a/tests/unittests/backup_sa/session/service_proxy_mock.cpp
+++ b/tests/unittests/backup_sa/session/service_proxy_mock.cpp
@@ -25,6 +25,11 @@ int32_t ServiceProxy::InitRestoreSession(sptr<IServiceReverse> remote)
     return 0;
 }
 
+int32_t ServiceProxy::InitRestoreSession(sptr<IServiceReverse> remote, std::string &errMsg)
+{
+    return 0;
+}
+
 int32_t ServiceProxy::InitBackupSession(sptr<IServiceReverse> remote)
 {
     return 0;
diff --git a/tests/unittests/backup_sa/session/service_proxy_mock.h b/tests/unittests/backup_sa/session/service_proxy_mock.h
index 18df7af1a3d956b08ce7d511d1e37cedcd2afab4..bf0537b8f09d9e2029ccb19abd4d99b247a25f99 100644
--- a/tests/unittests/backup_sa/session/service_proxy_mock.h
+++ b/tests/unittests/backup_sa/session/service_proxy_mock.h
@@ -27,6 +27,7 @@ public:
     ~ServiceProxyMock() override {}
 public:
     MOCK_METHOD1(InitRestoreSession, ErrCode(sptr<IServiceReverse> remote));
+    MOCK_METHOD2(InitRestoreSession, ErrCode(sptr<IServiceReverse> remote, std::string &errMsg));
     MOCK_METHOD1(InitBackupSession, ErrCode(sptr<IServiceReverse> remote));
     MOCK_METHOD0(Start, ErrCode());
     MOCK_METHOD0(AsObject, sptr<IRemoteObject>());
diff --git a/utils/include/b_error/b_error.h b/utils/include/b_error/b_error.h
index 9e685afd823177c468c9096393aa6847aac1e64d..9073fcc0d24aa2687bc5cd4ae2fe6f5208357ef4 100644
--- a/utils/include/b_error/b_error.h
+++ b/utils/include/b_error/b_error.h
@@ -73,6 +73,7 @@ public:
         SA_BOOT_EXT_TIMEOUT = 0x3005,
         SA_BUNDLE_INFO_EMPTY = 0x3006,
         SA_BOOT_EXT_FAIL = 0x3007,
+        SA_SESSION_CONFLICT = 0x3008,
 
         // 0x4000~0x4999 backup_SDK错误
         SDK_INVAL_ARG = 0x4000,
@@ -120,6 +121,7 @@ public:
         E_TASKFAIL = 13500010,
         E_CANCEL_UNSTARTED_TASK = 13500011,
         E_CANCEL_NO_TASK = 13500012,
+        E_CONFLICT = 13500013,
     };
 
 public:
@@ -268,6 +270,7 @@ private:
         {Codes::SA_EXT_ERR_CALL, "SA Extension received invalid arguments"},
         {Codes::SA_EXT_ERR_SAMGR, "SA Extension get samgr failed"},
         {Codes::SA_EXT_RELOAD_FAIL, "SA Extension reload failed"},
+        {Codes::SA_SESSION_CONFLICT, "Session Conflict"},
     };
 
     static inline const std::map<int, int> errCodeTable_ {
@@ -303,6 +306,7 @@ private:
         {static_cast<int>(Codes::SA_EXT_ERR_CALL), BackupErrorCode::E_INVAL},
         {static_cast<int>(Codes::SA_EXT_ERR_SAMGR), BackupErrorCode::E_IPCSS},
         {static_cast<int>(Codes::SA_EXT_RELOAD_FAIL), BackupErrorCode::E_BEF},
+        {static_cast<int>(Codes::SA_SESSION_CONFLICT), BackupErrorCode::E_CONFLICT},
         {BackupErrorCode::E_IPCSS, BackupErrorCode::E_IPCSS},
         {BackupErrorCode::E_INVAL, BackupErrorCode::E_INVAL},
         {BackupErrorCode::E_NOTEXIST, BackupErrorCode::E_NOTEXIST},
@@ -322,6 +326,7 @@ private:
         {BackupErrorCode::E_BEF, BackupErrorCode::E_BEF},
         {BackupErrorCode::E_CANCEL_UNSTARTED_TASK, BackupErrorCode::E_CANCEL_UNSTARTED_TASK},
         {BackupErrorCode::E_CANCEL_NO_TASK, BackupErrorCode::E_CANCEL_NO_TASK},
+        {BackupErrorCode::E_CONFLICT, BackupErrorCode::E_CONFLICT},
     };
 
     static inline const std::map<int, int> sysErrnoCodeTable_ {
@@ -359,6 +364,7 @@ private:
         {BackupErrorCode::E_BEF, "SA failed to boot application extension"},
         {BackupErrorCode::E_CANCEL_UNSTARTED_TASK, "Cancel unstarted backup or restore task "},
         {BackupErrorCode::E_CANCEL_NO_TASK, "Cancel a backup or restore task that does not exist"},
+        {BackupErrorCode::E_CONFLICT, "Session Conflict"},
     };
 
 private:
diff --git a/utils/include/b_jsonutil/b_jsonutil.h b/utils/include/b_jsonutil/b_jsonutil.h
index ebaadfbeec6011bd03ebfbbaea3176df3a30e1a1..22bf8050605d1764497db7490eca15ce5b4b3081 100644
--- a/utils/include/b_jsonutil/b_jsonutil.h
+++ b/utils/include/b_jsonutil/b_jsonutil.h
@@ -168,6 +168,17 @@ public:
      *
      */
     static std::string ParseBackupVersion();
+
+    /**
+     * @brief 拼接session冲突时报错信息
+     *
+     * @param userId 用户id
+     * @param callerName session创建方
+     * @param activeTime session创建时间
+     *
+     * @return 拼接结果
+     */
+    static std::string BuildInitSessionErrInfo(int32_t userId, std::string callerName, std::string activeTime);
 };
 } // namespace OHOS::FileManagement::Backup
 
diff --git a/utils/src/b_jsonutil/b_jsonutil.cpp b/utils/src/b_jsonutil/b_jsonutil.cpp
index 5892f745729ced2d07cae76c21f767f19cb51e07..960f88764582ce83a6427c78ede77be6318ee96c 100644
--- a/utils/src/b_jsonutil/b_jsonutil.cpp
+++ b/utils/src/b_jsonutil/b_jsonutil.cpp
@@ -460,4 +460,40 @@ std::string BJsonUtil::ParseBackupVersion()
     cJSON_Delete(root);
     return backupVersion;
 }
+
+std::string BJsonUtil::BuildInitSessionErrInfo(int32_t userId, std::string callerName, std::string activeTime)
+{
+    cJSON *info = cJSON_CreateObject();
+    if (info == nullptr) {
+        HILOGE("Failed to create cJSON object info, update errMsg failed");
+        return "";
+    }
+    cJSON *sessionInfoArray = cJSON_CreateArray();
+    if (sessionInfoArray == nullptr) {
+        HILOGE("Failed to create cJSON array sessionInfoArray, update errMsg failed");
+        cJSON_Delete(info);
+        return "";
+    }
+    cJSON_AddItemToObject(info, "sessionInfo", sessionInfoArray);
+    cJSON *sessionInfoObject = cJSON_CreateObject();
+    if (sessionInfoObject == nullptr) {
+        HILOGE("Failed to create cJSON object sessionInfoObject, update errMsg failed");
+        cJSON_Delete(info);
+        return "";
+    }
+    cJSON_AddItemToArray(sessionInfoArray, sessionInfoObject);
+    cJSON_AddStringToObject(sessionInfoObject, "userId", to_string(userId).c_str());
+    cJSON_AddStringToObject(sessionInfoObject, "name", callerName.c_str());
+    cJSON_AddStringToObject(sessionInfoObject, "activeTime", activeTime.c_str());
+    char *jsonStr = cJSON_Print(info);
+    if (jsonStr == nullptr) {
+        HILOGE("update errMsg failed");
+        cJSON_Delete(info);
+        return "";
+    }
+    std::string errMsg = jsonStr;
+    cJSON_Delete(info);
+    cJSON_free(jsonStr);
+    return errMsg;
+}
 }
\ No newline at end of file