locator/source/locator_ability.cpp

/*
 * Copyright (C) 2022 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

#include "locator_ability.h"

#include "accesstoken_kit.h"
#include "event_runner.h"
#include "ipc_skeleton.h"
#include "privacy_kit.h"
#include "privacy_error.h"
#include "system_ability_definition.h"
#include "uri.h"

#include "common_event_manager.h"
#include "common_hisysevent.h"
#include "location_log_event_ids.h"
#include "common_utils.h"
#include "constant_definition.h"
#ifdef FEATURE_GEOCODE_SUPPORT
#include "geo_convert_proxy.h"
#endif
#ifdef FEATURE_GNSS_SUPPORT
#include "gnss_ability_proxy.h"
#endif
#include "hook_utils.h"
#include "locator_background_proxy.h"
#include "location_config_manager.h"
#include "location_data_rdb_helper.h"
#include "location_log.h"
#include "location_sa_load_manager.h"
#include "locator_required_data_manager.h"
#include "location_data_rdb_manager.h"
#ifdef FEATURE_NETWORK_SUPPORT
#include "network_ability_proxy.h"
#endif
#ifdef FEATURE_PASSIVE_SUPPORT
#include "passive_ability_proxy.h"
#endif
#include "permission_status_change_cb.h"
#include "permission_manager.h"
#ifdef RES_SCHED_SUPPROT
#include "res_type.h"
#include "res_sched_client.h"
#endif
#include "app_mgr_interface.h"
#include "app_state_data.h"
#include "if_system_ability_manager.h"
#include "iservice_registry.h"
#include "geo_convert_request.h"
#include "parameter.h"
#include "self_request_manager.h"
#ifdef LOCATION_HICOLLIE_ENABLE
#include "xcollie/xcollie.h"
#include "xcollie/xcollie_define.h"
#endif
#include "common_event_helper.h"

namespace OHOS {
namespace Location {
const bool REGISTER_RESULT = SystemAbility::MakeAndRegisterAbility(
    LocatorAbility::GetInstance());

const uint32_t EVENT_UPDATE_SA = 0x0001;
const uint32_t EVENT_INIT_REQUEST_MANAGER = 0x0002;
const uint32_t EVENT_APPLY_REQUIREMENTS = 0x0003;
const uint32_t EVENT_RETRY_REGISTER_ACTION = 0x0004;
const uint32_t EVENT_REPORT_LOCATION_MESSAGE = 0x0005;
const uint32_t EVENT_SEND_SWITCHSTATE_TO_HIFENCE = 0x0006;
const uint32_t EVENT_START_LOCATING = 0x0007;
const uint32_t EVENT_STOP_LOCATING = 0x0008;
const uint32_t EVENT_UNLOAD_SA = 0x0010;
const uint32_t EVENT_GET_CACHED_LOCATION_SUCCESS = 0x0014;
const uint32_t EVENT_GET_CACHED_LOCATION_FAILED = 0x0015;
const uint32_t EVENT_REG_LOCATION_ERROR = 0x0011;
const uint32_t EVENT_UNREG_LOCATION_ERROR = 0x0012;
const uint32_t EVENT_REPORT_LOCATION_ERROR = 0x0013;
const uint32_t EVENT_PERIODIC_CHECK = 0x0016;
const uint32_t EVENT_SYNC_LOCATION_STATUS = 0x0017;
const uint32_t EVENT_SYNC_STILL_MOVEMENT_STATE = 0x0018;
const uint32_t EVENT_SYNC_IDLE_STATE = 0x0019;
const uint32_t EVENT_INIT_MSDP_MONITOR_MANAGER = 0x0020;
const uint32_t EVENT_IS_STAND_BY = 0x0021;
const uint32_t EVENT_SET_LOCATION_WORKING_STATE = 0x0022;
const uint32_t EVENT_SEND_GEOREQUEST = 0x0023;
const uint32_t EVENT_SET_SWITCH_STATE_TO_DB = 0x0024;
const uint32_t EVENT_WATCH_SWITCH_PARAMETER = 0x0025;
const uint32_t EVENT_SET_SWITCH_STATE_TO_DB_BY_USERID = 0x0026;
const uint32_t EVENT_START_SCAN_BLUETOOTH_DEVICE = 0x0027;
const uint32_t EVENT_STOP_SCAN_BLUETOOTH_DEVICE = 0x0028;

const uint32_t RETRY_INTERVAL_UNITE = 1000;
const uint32_t RETRY_INTERVAL_OF_INIT_REQUEST_MANAGER = 5 * RETRY_INTERVAL_UNITE;
#ifdef FEATURE_DYNAMIC_OFFLOAD
const uint32_t RETRY_INTERVAL_OF_UNLOAD_SA = 4 * 60 * RETRY_INTERVAL_UNITE;
#else
const uint32_t RETRY_INTERVAL_OF_UNLOAD_SA = 30 * 60 * RETRY_INTERVAL_UNITE;
#endif // FEATURE_DYNAMIC_OFFLOAD
const int COMMON_SA_ID = 4353;
const int COMMON_SWITCH_STATE_ID = 30;
const std::u16string COMMON_DESCRIPTION = u"location.IHifenceAbility";
const std::string UNLOAD_TASK = "locatior_sa_unload";
const std::string WIFI_SCAN_STATE_CHANGE = "wifiScanStateChange";
const uint32_t SET_ENABLE = 3;
const uint32_t EVENT_PERIODIC_INTERVAL = 3 * 60 * 1000;
const uint32_t REQUEST_DEFAULT_TIMEOUT_SECOUND = 5 * 60;
const int LOCATIONHUB_STATE_UNLOAD = 0;
const int LOCATIONHUB_STATE_LOAD = 1;
const int MAX_SIZE = 100;
const int TIMEOUT_WATCHDOG = 60; // s
const int INVALID_REQUESTS_SIZE = 20;
const int MAX_PERMISSION_NUM = 1000;
const int MAX_SWITCH_CALLBACKS_NUM = 1000;
const int LOCATION_SWITCH_IGNORED_STATE_VALID_TIME = 2 * 60 * 1000; // 2min
const int DEFAULT_USERID = 100;

LocatorAbility* LocatorAbility::GetInstance()
{
    static LocatorAbility data;
    return &data;
}

LocatorAbility::LocatorAbility() : SystemAbility(LOCATION_LOCATOR_SA_ID, true)
{
#ifndef TDD_CASES_ENABLED
    locatorHandler_ = std::make_shared<LocatorHandler>(AppExecFwk::EventRunner::Create(true,
        AppExecFwk::ThreadMode::FFRT));
#endif
    requests_ = std::make_shared<std::map<std::string, std::list<std::shared_ptr<Request>>>>();
    receivers_ = std::make_shared<std::map<sptr<IRemoteObject>, std::list<std::shared_ptr<Request>>>>();
    proxyMap_ = std::make_shared<std::map<std::string, sptr<IRemoteObject>>>();
    loadedSaMap_ = std::make_shared<std::map<std::string, sptr<IRemoteObject>>>();
    permissionMap_ = std::make_shared<std::map<uint32_t, std::shared_ptr<PermissionStatusChangeCb>>>();
    InitRequestManagerMap();
    reportManager_ = ReportManager::GetInstance();
    deviceId_ = CommonUtils::InitDeviceId();
#ifdef MOVEMENT_CLIENT_ENABLE
#ifndef TDD_CASES_ENABLED
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendHighPriorityEvent(EVENT_INIT_MSDP_MONITOR_MANAGER, 0, 0);
    }
#endif
#endif
    requestManager_ = RequestManager::GetInstance();
#ifndef TDD_CASES_ENABLED
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendHighPriorityEvent(EVENT_IS_STAND_BY, 0, 0);
    }
#endif
    LBSLOGI(LOCATOR, "LocatorAbility constructed.");
}

LocatorAbility::~LocatorAbility() {}

void LocatorAbility::OnStart()
{
    if (state_ == ServiceRunningState::STATE_RUNNING) {
        LBSLOGI(LOCATOR, "LocatorAbility has already started.");
        return;
    }
    if (!Init()) {
        LBSLOGE(LOCATOR, "failed to init LocatorAbility");
        OnStop();
        return;
    }
    state_ = ServiceRunningState::STATE_RUNNING;
    AddSystemAbilityListener(COMMON_EVENT_SERVICE_ID);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendHighPriorityEvent(EVENT_SET_LOCATION_WORKING_STATE, 0, 0);
        locatorHandler_->SendHighPriorityEvent(EVENT_SYNC_LOCATION_STATUS, 0, 0);
        locatorHandler_->SendHighPriorityEvent(EVENT_WATCH_SWITCH_PARAMETER, 0, 0);
    }
    LBSLOGW(LOCATOR, "LocatorAbility::OnStart start ability success.");
}

void LocatorAbility::OnStop()
{
    state_ = ServiceRunningState::STATE_NOT_START;
    registerToAbility_ = false;
    if (!LocationDataRdbManager::SetLocationWorkingState(0)) {
        LBSLOGD(LOCATOR, "LocatorAbility::reset LocationWorkingState failed.");
    }
    SetLocationhubStateToSyspara(LOCATIONHUB_STATE_UNLOAD);
    LocatorRequiredDataManager::GetInstance()->UnregisterWifiCallBack();
    LBSLOGW(LOCATOR, "LocatorAbility::OnStop ability stopped.");
}

void LocatorAbility::OnAddSystemAbility(int32_t systemAbilityId, const std::string &deviceId)
{
    if (systemAbilityId == COMMON_EVENT_SERVICE_ID) {
        RegisterAction();
        RegisterLocationPrivacyAction();
    }
}

void LocatorAbility::OnRemoveSystemAbility(int32_t systemAbilityId, const std::string& deviceId)
{
    if (systemAbilityId != COMMON_EVENT_SERVICE_ID) {
        LBSLOGE(LOCATOR, "systemAbilityId is not COMMON_EVENT_SERVICE_ID");
        return;
    }

    if (locationPrivacyEventSubscriber_ != nullptr) {
        bool ret = OHOS::EventFwk::CommonEventManager::UnSubscribeCommonEvent(locationPrivacyEventSubscriber_);
        locationPrivacyEventSubscriber_ = nullptr;
        isLocationPrivacyActionRegistered_ = false;
        LBSLOGI(LOCATOR, "UnSubscribeCommonEvent locationPrivacyEventSubscriber_ result = %{public}d", ret);
        return;
    }

    if (locatorEventSubscriber_ == nullptr) {
        LBSLOGE(LOCATOR, "OnRemoveSystemAbility subscribeer is nullptr");
        return;
    }
    bool result = OHOS::EventFwk::CommonEventManager::UnSubscribeCommonEvent(locatorEventSubscriber_);
    isActionRegistered = false;
    LBSLOGI(LOCATOR, "UnSubscribeCommonEvent locatorEventSubscriber_ result = %{public}d", result);
}

bool LocatorAbility::Init()
{
    if (registerToAbility_) {
        return true;
    }
    LBSLOGI(LOCATOR, "LocatorAbility Init.");
    bool ret = Publish(AsObject());
    if (!ret) {
        LBSLOGE(LOCATOR, "Init add system ability failed!");
        return false;
    }
    UpdateSaAbility();
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendHighPriorityEvent(EVENT_INIT_REQUEST_MANAGER, 0, RETRY_INTERVAL_OF_INIT_REQUEST_MANAGER);
        locatorHandler_->SendHighPriorityEvent(EVENT_PERIODIC_CHECK, 0, EVENT_PERIODIC_INTERVAL);
    }
    SetLocationhubStateToSyspara(LOCATIONHUB_STATE_LOAD);
    registerToAbility_ = true;
    return registerToAbility_;
}

void LocatorAbility::InitRequestManagerMap()
{
    std::unique_lock<ffrt::mutex> lock(requestsMutex_);
    if (requests_ != nullptr) {
#ifdef FEATURE_GNSS_SUPPORT
        std::list<std::shared_ptr<Request>> gnssList;
        requests_->insert(make_pair(GNSS_ABILITY, gnssList));
#endif
#ifdef FEATURE_NETWORK_SUPPORT
        std::list<std::shared_ptr<Request>> networkList;
        requests_->insert(make_pair(NETWORK_ABILITY, networkList));
#endif
#ifdef FEATURE_PASSIVE_SUPPORT
        std::list<std::shared_ptr<Request>> passiveList;
        requests_->insert(make_pair(PASSIVE_ABILITY, passiveList));
#endif
    }
}

std::shared_ptr<std::map<std::string, std::list<std::shared_ptr<Request>>>> LocatorAbility::GetRequests()
{
    std::unique_lock<ffrt::mutex> lock(requestsMutex_);
    return requests_;
}

int LocatorAbility::GetActiveRequestNum()
{
    std::unique_lock<ffrt::mutex> lock(requestsMutex_);
    int num = 0;
#ifdef FEATURE_GNSS_SUPPORT
    auto gpsListIter = requests_->find(GNSS_ABILITY);
    if (gpsListIter != requests_->end()) {
        auto list = &(gpsListIter->second);
        num += static_cast<int>(list->size());
    }
#endif
#ifdef FEATURE_NETWORK_SUPPORT
    auto networkListIter = requests_->find(NETWORK_ABILITY);
    if (networkListIter != requests_->end()) {
        auto list = &(networkListIter->second);
        num += static_cast<int>(list->size());
    }
#endif
    return num;
}

std::shared_ptr<std::map<sptr<IRemoteObject>, std::list<std::shared_ptr<Request>>>> LocatorAbility::GetReceivers()
{
    std::unique_lock<ffrt::mutex> lock(receiversMutex_);
    return receivers_;
}

std::shared_ptr<std::map<std::string, sptr<IRemoteObject>>> LocatorAbility::GetProxyMap()
{
    std::unique_lock<std::mutex> lock(proxyMapMutex_);
    return proxyMap_;
}

void LocatorAbility::ApplyRequests(int delay)
{
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendHighPriorityEvent(EVENT_APPLY_REQUIREMENTS, 0, delay * RETRY_INTERVAL_UNITE);
    }
}

void LocatorAbility::InitSaAbility()
{
    LBSLOGI(LOCATOR, "initSaAbility start");
    if (proxyMap_ == nullptr) {
        return;
    }
    UpdateSaAbilityHandler();
}

bool LocatorAbility::CheckSaValid()
{
    std::unique_lock<std::mutex> lock(proxyMapMutex_);
#ifdef FEATURE_GNSS_SUPPORT
    auto objectGnss = proxyMap_->find(GNSS_ABILITY);
    if (objectGnss == proxyMap_->end()) {
        LBSLOGI(LOCATOR, "gnss sa is null");
        return false;
    }
#endif
#ifdef FEATURE_NETWORK_SUPPORT
    auto objectNetwork = proxyMap_->find(NETWORK_ABILITY);
    if (objectNetwork == proxyMap_->end()) {
        LBSLOGI(LOCATOR, "network sa is null");
        return false;
    }
#endif
#ifdef FEATURE_PASSIVE_SUPPORT
    auto objectPassive = proxyMap_->find(PASSIVE_ABILITY);
    if (objectPassive == proxyMap_->end()) {
        LBSLOGI(LOCATOR, "passive sa is null");
        return false;
    }
#endif
    return true;
}

bool LocatorAbility::SetLocationhubStateToSyspara(int value)
{
    char valueArray[MAX_SIZE] = {0};
    (void)sprintf_s(valueArray, sizeof(valueArray), "%d", value);
    int res = SetParameter(LOCATION_LOCATIONHUB_STATE, valueArray);
    if (res != 0) {
        LBSLOGE(LOCATOR, "%{public}s failed, res: %{public}d", __func__, res);
        return false;
    }
    return true;
}

LocationErrCode LocatorAbility::UpdateSaAbility()
{
    auto event = AppExecFwk::InnerEvent::Get(EVENT_UPDATE_SA, 0);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendHighPriorityEvent(event);
    }
    return ERRCODE_SUCCESS;
}

void LocatorAbility::UpdateSaAbilityHandler()
{
    int state = LocationDataRdbManager::QuerySwitchState();
    LBSLOGI(LOCATOR, "update location subability enable state, switch state=%{public}d, action registered=%{public}d",
        state, isActionRegistered);
    if (state == DEFAULT_SWITCH_STATE) {
        return;
    }
    bool isEnabled = (state == ENABLED);
    auto locatorBackgroundProxy = LocatorBackgroundProxy::GetInstance();
    locatorBackgroundProxy->OnSaStateChange(isEnabled);
    UpdateLoadedSaMap();
    std::string callingIdentity = IPCSkeleton::ResetCallingIdentity();
    std::unique_lock<ffrt::mutex> lock(loadedSaMapMutex_);
    for (auto iter = loadedSaMap_->begin(); iter != loadedSaMap_->end(); iter++) {
        sptr<IRemoteObject> remoteObject = iter->second;
        MessageParcel data;
        if (iter->first == GNSS_ABILITY) {
#ifdef FEATURE_GNSS_SUPPORT
            data.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor());
#endif
        } else if (iter->first == NETWORK_ABILITY) {
#ifdef FEATURE_NETWORK_SUPPORT
            data.WriteInterfaceToken(NetworkAbilityProxy::GetDescriptor());
#endif
        } else if (iter->first == PASSIVE_ABILITY) {
#ifdef FEATURE_PASSIVE_SUPPORT
            data.WriteInterfaceToken(PassiveAbilityProxy::GetDescriptor());
#endif
        }
        data.WriteBool(isEnabled);

        MessageParcel reply;
        MessageOption option;
        int error = remoteObject->SendRequest(SET_ENABLE, data, reply, option);
        if (error != ERR_OK) {
            LBSLOGI(LOCATOR, "enable %{public}s ability, remote result %{public}d", (iter->first).c_str(), error);
        }
    }
    SendSwitchState(isEnabled ? 1 : 0);
    IPCSkeleton::SetCallingIdentity(callingIdentity);
}

int32_t LocatorAbility::CallbackEnter(uint32_t code)
{
    CancelIdleState(code);
    RemoveUnloadTask(code);
    return ERRCODE_SUCCESS;
}

int32_t LocatorAbility::CallbackExit(uint32_t code, int32_t result)
{
    PostUnloadTask(code);
    return ERRCODE_SUCCESS;
}

bool LocatorAbility::CheckRequestAvailable(LocatorInterfaceCode code, AppIdentity &identity)
{
    LBSLOGI(LOCATOR, "OnReceived cmd = %{public}u, identity= [%{public}s], timestamp = %{public}s",
            code, identity.ToString().c_str(), std::to_string(CommonUtils::GetCurrentTimeStamp()).c_str());
    if (code == LocatorInterfaceCode::UNREG_SWITCH_CALLBACK ||
        code == LocatorInterfaceCode::STOP_LOCATING ||
        code == LocatorInterfaceCode::STOP_LOCATING ||
        code == LocatorInterfaceCode::DISABLE_LOCATION_MOCK ||
        code == LocatorInterfaceCode::UNREG_LOCATION_ERROR ||
        code == LocatorInterfaceCode::UNREG_LOCATING_REQUIRED_DATA_CALLBACK) {
        return true;
    }
    int currentUserId = LocatorBackgroundProxy::GetInstance()->getCurrentUserId();
    if (CommonUtils::IsAppBelongCurrentAccount(identity, currentUserId)) {
        return true;
    }
    LBSLOGD(LOCATOR, "CheckRequestAvailable fail uid:%{public}d", identity.GetUid());
    return false;
}

bool LocatorAbility::CancelIdleState(uint32_t code)
{
    if (code == static_cast<uint16_t>(LocatorInterfaceCode::PROXY_PID_FOR_FREEZE) ||
        code == static_cast<uint16_t>(LocatorInterfaceCode::RESET_ALL_PROXY)) {
        return true;
    }
    SystemAbilityState state = GetAbilityState();
    if (state != SystemAbilityState::IDLE) {
        return true;
    }
    bool ret = CancelIdle();
    if (!ret) {
        LBSLOGE(LOCATOR, "%{public}s cancel idle failed!", __func__);
        return false;
    }
    return true;
}

void LocatorAbility::RemoveUnloadTask(uint32_t code)
{
    if (locatorHandler_ == nullptr) {
        LBSLOGE(LOCATOR, "%{public}s locatorHandler is nullptr", __func__);
        return;
    }
    if (code == static_cast<uint16_t>(LocatorInterfaceCode::PROXY_PID_FOR_FREEZE) ||
        code == static_cast<uint16_t>(LocatorInterfaceCode::RESET_ALL_PROXY)) {
        return;
    }
    locatorHandler_->RemoveTask(UNLOAD_TASK);
}

void LocatorAbility::PostUnloadTask(uint32_t code)
{
    if (code == static_cast<uint16_t>(LocatorInterfaceCode::PROXY_PID_FOR_FREEZE) ||
        code == static_cast<uint16_t>(LocatorInterfaceCode::RESET_ALL_PROXY)) {
        return;
    }
    auto task = [this]() {
        if (CheckIfLocatorConnecting()) {
            return;
        }
        SaLoadWithStatistic::UnInitLocationSa(LOCATION_LOCATOR_SA_ID);
    };
    if (locatorHandler_ != nullptr) {
        locatorHandler_->PostTask(task, UNLOAD_TASK, RETRY_INTERVAL_OF_UNLOAD_SA);
    }
}

void LocatorAbility::SendSwitchState(const int state)
{
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_SEND_SWITCHSTATE_TO_HIFENCE, state);
    if (locatorHandler_ != nullptr && locatorHandler_->SendEvent(event)) {
        LBSLOGD(LOCATOR, "%{public}s: EVENT_SEND_SWITCHSTATE_TO_HIFENCE Send Success", __func__);
    }
}

bool LocatorAbility::CheckIfLocatorConnecting()
{
    return LocatorRequiredDataManager::GetInstance()->IsWifiConnecting() ||
        LocatorRequiredDataManager::GetInstance()->IsBluetoothConnecting() || GetActiveRequestNum() > 0;
}

ErrCode LocatorAbility::EnableAbility(bool isEnabled)
{
    LBSLOGI(LOCATOR, "EnableAbility %{public}d", isEnabled);
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::ENABLE_ABILITY, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSecureSettings(identity.GetTokenId(), identity.GetFirstTokenId())) {
        LBSLOGE(LOCATOR, "CheckSecureSettings return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    bool privacyState = false;
    LocationErrCode code =
        LocationConfigManager::GetInstance()->GetPrivacyTypeState(PRIVACY_TYPE_STARTUP, privacyState);
    if (code == ERRCODE_SUCCESS && isEnabled && !privacyState && identity.GetBundleName() == "com.ohos.sceneboard") {
        LocationConfigManager::GetInstance()->OpenPrivacyDialog();
        LBSLOGE(LOCATOR, "OpenPrivacyDialog");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    int userId = 0;
    if (!CommonUtils::GetCurrentUserId(userId)) {
        userId = DEFAULT_USERID;
    }
    if (!HookUtils::ExecuteHookEnableAbility(
        identity.GetBundleName().size() == 0 ? std::to_string(identity.GetUid()) : identity.GetBundleName(),
        isEnabled, userId)) {
        return ERRCODE_SUCCESS;
    }
    LocationErrCode errCode = SetSwitchState(isEnabled);
    std::string bundleName;
    bool result = LocationConfigManager::GetInstance()->GetSettingsBundleName(bundleName);
    // settings first enable location, need to update privacy state
    if (code == ERRCODE_SUCCESS && errCode == ERRCODE_SUCCESS && isEnabled && !privacyState &&
        result && !bundleName.empty() && identity.GetBundleName() == bundleName) {
        LocationConfigManager::GetInstance()->SetPrivacyTypeState(PRIVACY_TYPE_STARTUP, true);
    }
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::EnableAbilityForUser(bool isEnabled, int32_t userId)
{
    LBSLOGI(LOCATOR, "EnableAbilityForUser %{public}d, UserId %{public}d", isEnabled, userId);
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::ENABLE_ABILITY_BY_USERID, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSecureSettings(identity.GetTokenId(), identity.GetFirstTokenId())) {
        LBSLOGE(LOCATOR, "CheckSecureSettings return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    bool privacyState = false;
    int currentUserId = 0;
    LocationErrCode code =
        LocationConfigManager::GetInstance()->GetPrivacyTypeState(PRIVACY_TYPE_STARTUP, privacyState);
    if (code == ERRCODE_SUCCESS && isEnabled && !privacyState && identity.GetBundleName() == "com.ohos.sceneboard" &&
        (CommonUtils::GetCurrentUserId(currentUserId) && userId == currentUserId)) {
        LocationConfigManager::GetInstance()->OpenPrivacyDialog();
        LBSLOGE(LOCATOR, "OpenPrivacyDialog");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    if (!HookUtils::ExecuteHookEnableAbility(
        identity.GetBundleName().size() == 0 ? std::to_string(identity.GetUid()) : identity.GetBundleName(),
        isEnabled, userId)) {
        return ERRCODE_SUCCESS;
    }
    SetSwitchStateForUser(isEnabled, userId);
    std::string bundleName;
    bool result = LocationConfigManager::GetInstance()->GetSettingsBundleName(bundleName);
    // settings first enable location, need to update privacy state
    if (code == ERRCODE_SUCCESS && isEnabled && !privacyState &&
        result && !bundleName.empty() && identity.GetBundleName() == bundleName &&
        (CommonUtils::GetCurrentUserId(currentUserId) && userId == currentUserId)) {
        LocationConfigManager::GetInstance()->SetPrivacyTypeState(PRIVACY_TYPE_STARTUP, true);
    }
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::GetSwitchState(int32_t& state)
{
    state = DEFAULT_SWITCH_STATE;
    state = LocationDataRdbManager::QuerySwitchState();
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::IsLocationPrivacyConfirmed(int32_t type, bool& state)
{
    state = false;
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::IS_PRIVACY_COMFIRMED, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    return LocationConfigManager::GetInstance()->GetPrivacyTypeState(type, state);
}

ErrCode LocatorAbility::SetLocationPrivacyConfirmStatus(int32_t type, bool isConfirmed)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::SET_PRIVACY_COMFIRM_STATUS, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSecureSettings(identity.GetTokenId(), identity.GetFirstTokenId())) {
        LBSLOGE(LOCATOR, "CheckSecureSettings return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    return LocationConfigManager::GetInstance()->SetPrivacyTypeState(type, isConfirmed);
}

#ifdef FEATURE_GNSS_SUPPORT
LocationErrCode LocatorAbility::SendGnssRequest(int type, MessageParcel &data, MessageParcel &reply)
{
    if (!SaLoadWithStatistic::InitLocationSa(LOCATION_GNSS_SA_ID)) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    sptr<IRemoteObject> objectGnss =
            CommonUtils::GetRemoteObject(LOCATION_GNSS_SA_ID, CommonUtils::InitDeviceId());
    if (objectGnss == nullptr) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::string callingIdentity = IPCSkeleton::ResetCallingIdentity();
    MessageOption option;
    objectGnss->SendRequest(type, data, reply, option);
    IPCSkeleton::SetCallingIdentity(callingIdentity);
    return LocationErrCode(reply.ReadInt32());
}
#endif

ErrCode LocatorAbility::RegisterGnssStatusCallback(const sptr<IRemoteObject>& cb)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REG_LOCATING_REQUIRED_DATA_CALLBACK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    identity.Marshalling(dataToStub);
    dataToStub.WriteRemoteObject(cb);
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::REG_GNSS_STATUS), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::UnregisterGnssStatusCallback(const sptr<IRemoteObject>& cb)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::UNREG_LOCATING_REQUIRED_DATA_CALLBACK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    dataToStub.WriteRemoteObject(cb);
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::UNREG_GNSS_STATUS), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::RegisterNmeaMessageCallback(const sptr<IRemoteObject>& cb)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REG_NMEA_CALLBACK_V9, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    identity.Marshalling(dataToStub);
    dataToStub.WriteRemoteObject(cb);
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::REG_NMEA), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::UnregisterNmeaMessageCallback(const sptr<IRemoteObject>& cb)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::UNREG_NMEA_CALLBACK_V9, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    dataToStub.WriteRemoteObject(cb);
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::UNREG_NMEA), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::RegisterCachedLocationCallback(int32_t reportingPeriodSec, bool wakeUpCacheQueueFull,
    const sptr<ICachedLocationsCallback>& cb, const std::string& bundleName)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REG_CACHED_CALLBACK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "ParseDataAndStartCacheLocating remote object nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    if (bundleName.empty()) {
        LBSLOGE(LOCATOR, "ParseDataAndStartCacheLocating get empty bundle name");
        return LOCATION_ERRCODE_INVALID_PARAM;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    dataToStub.WriteInt32(reportingPeriodSec);
    dataToStub.WriteBool(wakeUpCacheQueueFull);
    dataToStub.WriteRemoteObject(cb->AsObject());
    dataToStub.WriteString16(Str8ToStr16(bundleName));
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::REG_CACHED), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::UnregisterCachedLocationCallback(const sptr<ICachedLocationsCallback>& cb)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::UNREG_CACHED_CALLBACK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "LocatorAbility::ParseDataAndStopCacheLocating remote object nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    dataToStub.WriteRemoteObject(cb->AsObject());
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::UNREG_CACHED), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::GetCachedGnssLocationsSize(int32_t& size)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::GET_CACHED_LOCATION_SIZE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    size = -1;
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    LocationErrCode errorCode =
        SendGnssRequest(static_cast<int>(GnssInterfaceCode::GET_CACHED_SIZE), dataToStub, replyToStub);
    if (errorCode == ERRCODE_SUCCESS) {
        size = replyToStub.ReadInt32();
    }
    return errorCode;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::FlushCachedGnssLocations()
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::FLUSH_CACHED_LOCATIONS, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::FLUSH_CACHED), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::SendCommand(int32_t scenario, const std::string& command)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::SEND_COMMAND, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    dataToStub.WriteInt32(scenario);
    dataToStub.WriteString16(Str8ToStr16(command));
    LocationErrCode errorCode =
        SendGnssRequest(static_cast<int>(GnssInterfaceCode::SEND_COMMANDS), dataToStub, replyToStub);
    CommandStruct commandStruct;
    commandStruct.packageName = identity.GetBundleName();
    commandStruct.command = command;
    commandStruct.result = true;
    HookUtils::ExecuteHook(LocationProcessStage::LOCATOR_SA_COMMAND_PROCESS, (void *)&commandStruct, nullptr);
    return errorCode;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::AddFence(const GeofenceRequest& request)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::ADD_FENCE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    request.Marshalling(dataToStub);
    return SendGnssRequest(
        static_cast<int>(GnssInterfaceCode::ADD_FENCE_INFO), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::RemoveFence(const GeofenceRequest& request)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REMOVE_FENCE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    request.Marshalling(dataToStub);
    return SendGnssRequest(
        static_cast<int>(GnssInterfaceCode::REMOVE_FENCE_INFO), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::AddGnssGeofence(const GeofenceRequest& request)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::ADD_GNSS_GEOFENCE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckPreciseLocationPermissions(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    std::shared_ptr<GeofenceRequest> geofenceRequest =
        std::make_shared<GeofenceRequest>(const_cast<GeofenceRequest&>(request));
    geofenceRequest->SetBundleName(identity.GetBundleName());
    geofenceRequest->SetUid(identity.GetUid());
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    geofenceRequest->Marshalling(dataToStub);
    return SendGnssRequest(
        static_cast<int>(GnssInterfaceCode::ADD_GNSS_GEOFENCE), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::RemoveGnssGeofence(int32_t fenceId)
{
#ifdef FEATURE_GNSS_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REMOVE_GNSS_GEOFENCE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckPreciseLocationPermissions(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    dataToStub.WriteInt32(fenceId);
    dataToStub.WriteString(identity.GetBundleName());
    return SendGnssRequest(
        static_cast<int>(GnssInterfaceCode::REMOVE_GNSS_GEOFENCE), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

LocationErrCode LocatorAbility::SendLocationMockMsgToGnssSa(const sptr<IRemoteObject> obj,
    const int timeInterval, const std::vector<std::shared_ptr<Location>> &location, int msgId)
{
#ifdef FEATURE_GNSS_SUPPORT
    if (obj == nullptr) {
        LBSLOGE(LOCATOR, "SendLocationMockMsgToGnssSa obj is nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::unique_ptr<GnssAbilityProxy> gnssProxy = std::make_unique<GnssAbilityProxy>(obj);
    LocationErrCode errorCode = LOCATION_ERRCODE_NOT_SUPPORTED;
    if (msgId == static_cast<int>(LocatorInterfaceCode::ENABLE_LOCATION_MOCK)) {
        errorCode = gnssProxy->EnableMock();
    } else if (msgId == static_cast<int>(LocatorInterfaceCode::DISABLE_LOCATION_MOCK)) {
        errorCode = gnssProxy->DisableMock();
    } else if (msgId == static_cast<int>(LocatorInterfaceCode::SET_MOCKED_LOCATIONS)) {
        errorCode = gnssProxy->SetMocked(timeInterval, location);
    }
    return errorCode;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

LocationErrCode LocatorAbility::SendLocationMockMsgToNetworkSa(const sptr<IRemoteObject> obj,
    const int timeInterval, const std::vector<std::shared_ptr<Location>> &location, int msgId)
{
#ifdef FEATURE_NETWORK_SUPPORT
    if (obj == nullptr) {
        LBSLOGE(LOCATOR, "SendLocationMockMsgToNetworkSa obj is nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::unique_ptr<NetworkAbilityProxy> networkProxy =
        std::make_unique<NetworkAbilityProxy>(obj);
    LocationErrCode errorCode = LOCATION_ERRCODE_NOT_SUPPORTED;
    if (msgId == static_cast<int>(LocatorInterfaceCode::ENABLE_LOCATION_MOCK)) {
        errorCode = networkProxy->EnableMock();
    } else if (msgId == static_cast<int>(LocatorInterfaceCode::DISABLE_LOCATION_MOCK)) {
        errorCode = networkProxy->DisableMock();
    } else if (msgId == static_cast<int>(LocatorInterfaceCode::SET_MOCKED_LOCATIONS)) {
        errorCode = networkProxy->SetMocked(timeInterval, location);
    }
    return errorCode;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

LocationErrCode LocatorAbility::SendLocationMockMsgToPassiveSa(const sptr<IRemoteObject> obj,
    const int timeInterval, const std::vector<std::shared_ptr<Location>> &location, int msgId)
{
#ifdef FEATURE_PASSIVE_SUPPORT
    if (obj == nullptr) {
        LBSLOGE(LOCATOR, "SendLocationMockMsgToNetworkSa obj is nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::unique_ptr<PassiveAbilityProxy> passiveProxy =
        std::make_unique<PassiveAbilityProxy>(obj);
    LocationErrCode errorCode = LOCATION_ERRCODE_NOT_SUPPORTED;
    if (msgId == static_cast<int>(LocatorInterfaceCode::ENABLE_LOCATION_MOCK)) {
        errorCode = passiveProxy->EnableMock();
    } else if (msgId == static_cast<int>(LocatorInterfaceCode::DISABLE_LOCATION_MOCK)) {
        errorCode = passiveProxy->DisableMock();
    } else if (msgId == static_cast<int>(LocatorInterfaceCode::SET_MOCKED_LOCATIONS)) {
        errorCode = passiveProxy->SetMocked(timeInterval, location);
    }
    return errorCode;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

LocationErrCode LocatorAbility::ProcessLocationMockMsg(
    const int timeInterval, const std::vector<std::shared_ptr<Location>> &location, int msgId)
{
#if !defined(FEATURE_GNSS_SUPPORT) && !defined(FEATURE_NETWORK_SUPPORT) && !defined(FEATURE_PASSIVE_SUPPORT)
    LBSLOGE(LOCATOR, "%{public}s: mock service unavailable", __func__);
    return LOCATION_ERRCODE_NOT_SUPPORTED;
#endif
    if (!CheckSaValid()) {
        UpdateProxyMap();
    }

    std::unique_lock<std::mutex> lock(proxyMapMutex_);
    std::string callingIdentity = IPCSkeleton::ResetCallingIdentity();
    for (auto iter = proxyMap_->begin(); iter != proxyMap_->end(); iter++) {
        auto obj = iter->second;
        if (iter->first == GNSS_ABILITY) {
#ifdef FEATURE_GNSS_SUPPORT
            SendLocationMockMsgToGnssSa(obj, timeInterval, location, msgId);
#endif
        } else if (iter->first == NETWORK_ABILITY) {
#ifdef FEATURE_NETWORK_SUPPORT
            SendLocationMockMsgToNetworkSa(obj, timeInterval, location, msgId);
#endif
        } else if (iter->first == PASSIVE_ABILITY) {
#ifdef FEATURE_PASSIVE_SUPPORT
            SendLocationMockMsgToPassiveSa(obj, timeInterval, location, msgId);
#endif
        }
    }
    IPCSkeleton::SetCallingIdentity(callingIdentity);
    return ERRCODE_SUCCESS;
}

void LocatorAbility::UpdateLoadedSaMap()
{
    std::unique_lock<ffrt::mutex> lock(loadedSaMapMutex_);
    loadedSaMap_->clear();
    if (LocationSaLoadManager::CheckIfSystemAbilityAvailable(LOCATION_GNSS_SA_ID)) {
        sptr<IRemoteObject> objectGnss =
            CommonUtils::GetRemoteObject(LOCATION_GNSS_SA_ID, CommonUtils::InitDeviceId());
        loadedSaMap_->insert(make_pair(GNSS_ABILITY, objectGnss));
    }
    if (LocationSaLoadManager::CheckIfSystemAbilityAvailable(LOCATION_NETWORK_LOCATING_SA_ID)) {
        sptr<IRemoteObject> objectNetwork =
            CommonUtils::GetRemoteObject(LOCATION_NETWORK_LOCATING_SA_ID, CommonUtils::InitDeviceId());
        loadedSaMap_->insert(make_pair(NETWORK_ABILITY, objectNetwork));
    }
    if (LocationSaLoadManager::CheckIfSystemAbilityAvailable(LOCATION_NOPOWER_LOCATING_SA_ID)) {
        sptr<IRemoteObject> objectPassive =
            CommonUtils::GetRemoteObject(LOCATION_NOPOWER_LOCATING_SA_ID, CommonUtils::InitDeviceId());
        loadedSaMap_->insert(make_pair(PASSIVE_ABILITY, objectPassive));
    }
}

void LocatorAbility::UpdateProxyMap()
{
    std::unique_lock<std::mutex> lock(proxyMapMutex_);
#ifdef FEATURE_GNSS_SUPPORT
    // init gnss ability sa
    if (!SaLoadWithStatistic::InitLocationSa(LOCATION_GNSS_SA_ID)) {
        return;
    }
    sptr<IRemoteObject> objectGnss = CommonUtils::GetRemoteObject(LOCATION_GNSS_SA_ID, CommonUtils::InitDeviceId());
    if (objectGnss != nullptr) {
        proxyMap_->insert(make_pair(GNSS_ABILITY, objectGnss));
    } else {
        LBSLOGE(LOCATOR, "GetRemoteObject gnss sa is null");
    }
#endif
#ifdef FEATURE_NETWORK_SUPPORT
    // init network ability sa
    if (!SaLoadWithStatistic::InitLocationSa(LOCATION_NETWORK_LOCATING_SA_ID)) {
        return;
    }
    sptr<IRemoteObject> objectNetwork = CommonUtils::GetRemoteObject(LOCATION_NETWORK_LOCATING_SA_ID,
        CommonUtils::InitDeviceId());
    if (objectNetwork != nullptr) {
        proxyMap_->insert(make_pair(NETWORK_ABILITY, objectNetwork));
    } else {
        LBSLOGE(LOCATOR, "GetRemoteObject network sa is null");
    }
#endif
#ifdef FEATURE_PASSIVE_SUPPORT
    // init passive ability sa
    if (!SaLoadWithStatistic::InitLocationSa(LOCATION_NOPOWER_LOCATING_SA_ID)) {
        return;
    }
    sptr<IRemoteObject> objectPassive = CommonUtils::GetRemoteObject(LOCATION_NOPOWER_LOCATING_SA_ID,
        CommonUtils::InitDeviceId());
    if (objectPassive != nullptr) {
        proxyMap_->insert(make_pair(PASSIVE_ABILITY, objectPassive));
    } else {
        LBSLOGE(LOCATOR, "GetRemoteObject passive sa is null");
    }
#endif
}

ErrCode LocatorAbility::EnableLocationMock()
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::ENABLE_LOCATION_MOCK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckMockLocationPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckMockLocationPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    int timeInterval = 0;
    std::vector<std::shared_ptr<Location>> location;
    return ProcessLocationMockMsg(timeInterval, location,
        static_cast<int>(LocatorInterfaceCode::ENABLE_LOCATION_MOCK));
}

ErrCode LocatorAbility::DisableLocationMock()
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::DISABLE_LOCATION_MOCK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckMockLocationPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckMockLocationPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    int timeInterval = 0;
    std::vector<std::shared_ptr<Location>> location;
    return ProcessLocationMockMsg(timeInterval, location,
        static_cast<int>(LocatorInterfaceCode::DISABLE_LOCATION_MOCK));
}

ErrCode LocatorAbility::SetMockedLocations(int32_t timeInterval, const std::vector<Location>& locations)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::SET_MOCKED_LOCATIONS, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckMockLocationPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckMockLocationPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    timeInterval = timeInterval < 0 ? 1 : timeInterval;
    auto locationSize = locations.size();
    locationSize = locationSize > INPUT_ARRAY_LEN_MAX ? INPUT_ARRAY_LEN_MAX : locationSize;
    std::vector<std::shared_ptr<Location>> sharedLocations;
    for (size_t i = 0; i < locationSize; i++) {
        sharedLocations.push_back(std::make_shared<Location>(locations[i]));
    }
    return ProcessLocationMockMsg(timeInterval, sharedLocations,
        static_cast<int>(LocatorInterfaceCode::SET_MOCKED_LOCATIONS));
}

ErrCode LocatorAbility::StartLocating(const RequestConfig& requestConfig, const sptr<ILocatorCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::START_LOCATING, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!GetLocationSwitchIgnoredFlag(identity.GetTokenId()) && !CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        WriteLocationInnerEvent(LBS_REQUEST_FAIL_DETAIL, {"REQ_APP_NAME", identity.GetBundleName(),
            "NETWORK_FAIL_CODE", std::to_string(ERRCODE_PERMISSION_DENIED)});
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    bool res = HookUtils::ExecuteHookWhenPreStartLocating(identity.GetBundleName());
    auto reportManager = ReportManager::GetInstance();
    if (reportManager != nullptr && res) {
        if (reportManager->IsAppBackground(identity.GetBundleName(), identity.GetTokenId(),
            identity.GetTokenIdEx(), identity.GetUid(), identity.GetPid()) &&
            !PermissionManager::CheckBackgroundPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
            WriteLocationInnerEvent(LBS_REQUEST_FAIL_DETAIL, {"REQ_APP_NAME", identity.GetBundleName(),
                "NETWORK_FAIL_CODE", std::to_string(LOCATION_ERRCODE_BACKGROUND_PERMISSION_DENIED)});
            return LOCATION_ERRCODE_PERMISSION_DENIED;
        }
    }
    return StartLocatingProcess(requestConfig, cb, identity);
}

bool LocatorAbility::IsCacheVaildScenario(const sptr<RequestConfig>& requestConfig)
{
    if ((requestConfig->GetPriority() == LOCATION_PRIORITY_LOCATING_SPEED) ||
        (requestConfig->GetScenario() == SCENE_DAILY_LIFE_SERVICE) ||
        (requestConfig->GetScenario() == LOCATION_SCENE_DAILY_LIFE_SERVICE) ||
        (requestConfig->GetScenario() == LOCATION_SCENE_LOW_POWER_CONSUMPTION) ||
        ((requestConfig->GetScenario() == SCENE_UNSET) && (requestConfig->GetPriority() == PRIORITY_FAST_FIRST_FIX)) ||
        ((requestConfig->GetScenario() == SCENE_UNSET) && (requestConfig->GetPriority() == PRIORITY_LOW_POWER))) {
        return true;
    }
    return false;
}

bool LocatorAbility::IsSingleRequest(const sptr<RequestConfig>& requestConfig)
{
    if (requestConfig->GetFixNumber() == 1) {
        return true;
    }
    return false;
}

int LocatorAbility::UpdatePermissionUsedRecord(uint32_t tokenId, std::string permissionName,
    int permUsedType, int succCnt, int failCnt)
{
    // permUsedType is invalid, no need to call AddPermissionUsedRecord
    if (permUsedType == -1) {
        return 0;
    }
    Security::AccessToken::AddPermParamInfo info;
    info.tokenId = tokenId;
    info.permissionName = permissionName;
    info.successCount = succCnt;
    info.failCount = failCnt;
    info.type = static_cast<OHOS::Security::AccessToken::PermissionUsedType>(permUsedType);
    int ret = Security::AccessToken::PrivacyKit::AddPermissionUsedRecord(info);
    return ret;
}

bool LocatorAbility::NeedReportCacheLocation(const std::shared_ptr<Request>& request,
    const sptr<ILocatorCallback>& callback)
{
    if (reportManager_ == nullptr || requestManager_ == nullptr || request == nullptr || callback == nullptr ||
        !IsCacheVaildScenario(request->GetRequestConfig())) {
        return false;
    }
    uint32_t tokenId = request->GetTokenId();
    uint32_t firstTokenId = request->GetFirstTokenId();
    if (!PermissionManager::CheckLocationPermission(tokenId, firstTokenId) &&
        !PermissionManager::CheckApproximatelyPermission(tokenId, firstTokenId)) {
        RequestManager::GetInstance()->ReportLocationError(LOCATING_FAILED_LOCATION_PERMISSION_DENIED, request);
        LBSLOGI(LOCATOR, "CheckLocationPermission return false, tokenId=%{public}d", tokenId);
        return false;
    }
    std::string bundleName = request->GetPackageName();
    pid_t uid = request->GetUid();
    pid_t pid = request->GetPid();
    auto reportManager = ReportManager::GetInstance();
    if (reportManager != nullptr) {
        if (reportManager->IsAppBackground(bundleName, tokenId, request->GetTokenIdEx(), uid, pid) &&
            !PermissionManager::CheckBackgroundPermission(tokenId, firstTokenId)) {
            RequestManager::GetInstance()->ReportLocationError(LOCATING_FAILED_BACKGROUND_PERMISSION_DENIED, request);
            LBSLOGE(REPORT_MANAGER, "CheckBackgroundPermission return false, Id=%{public}d", tokenId);
            return false;
        }
    }
    // report cache location
    auto cacheLocation = reportManager_->GetCacheLocation(request);
    if (cacheLocation == nullptr) {
        return false;
    }
    if (IsSingleRequest(request->GetRequestConfig())) {
        return ReportSingleCacheLocation(request, callback, cacheLocation);
    } else {
        return ReportCacheLocation(request, callback, cacheLocation);
    }
}

bool LocatorAbility::ReportSingleCacheLocation(const std::shared_ptr<Request>& request,
    const sptr<ILocatorCallback>& callback, std::unique_ptr<Location>& cacheLocation)
{
    requestManager_->IncreaseWorkingPidsCount(request->GetPid());
    if (requestManager_->IsNeedStartUsingPermission(request->GetPid())) {
        int ret = PrivacyKit::StartUsingPermission(
            request->GetTokenId(), ACCESS_APPROXIMATELY_LOCATION, request->GetPid());
        if (ret != ERRCODE_SUCCESS && ret != Security::AccessToken::ERR_PERMISSION_ALREADY_START_USING &&
            IsHapCaller(request->GetTokenId())) {
            requestManager_->DecreaseWorkingPidsCount(request->GetPid());
            LBSLOGE(LOCATOR, "StartUsingPermission failed ret=%{public}d", ret);
            return false;
        }
    }
    // add location permission using record
    int recordResult = UpdatePermissionUsedRecord(request->GetTokenId(), ACCESS_APPROXIMATELY_LOCATION,
        request->GetPermUsedType(), 1, 0);
    if (recordResult != ERRCODE_SUCCESS && IsHapCaller(request->GetTokenId())) {
        requestManager_->DecreaseWorkingPidsCount(request->GetPid());
        LBSLOGE(LOCATOR, "UpdatePermissionUsedRecord failed ret=%{public}d", recordResult);
        return false;
    }
    LBSLOGI(LOCATOR, "report cache location to %{public}s, uuid: %{public}s",
        request->GetPackageName().c_str(), request->GetUuid().c_str());
    callback->OnLocationReport(cacheLocation);
    requestManager_->DecreaseWorkingPidsCount(request->GetPid());
    if (requestManager_->IsNeedStopUsingPermission(request->GetPid())) {
        PrivacyKit::StopUsingPermission(request->GetTokenId(), ACCESS_APPROXIMATELY_LOCATION, request->GetPid());
    }
    return true;
}

bool LocatorAbility::ReportCacheLocation(const std::shared_ptr<Request>& request,
    const sptr<ILocatorCallback>& callback, std::unique_ptr<Location>& cacheLocation)
{
    // add location permission using record
    int ret = UpdatePermissionUsedRecord(request->GetTokenId(), ACCESS_APPROXIMATELY_LOCATION,
        request->GetPermUsedType(), 1, 0);
    if (ret != ERRCODE_SUCCESS && IsHapCaller(request->GetTokenId())) {
        LBSLOGE(LOCATOR, "UpdatePermissionUsedRecord failed ret=%{public}d", ret);
        return false;
    }
    LBSLOGI(LOCATOR, "report cache location to %{public}s, uuid: %{public}s",
        request->GetPackageName().c_str(), request->GetUuid().c_str());
    callback->OnLocationReport(cacheLocation);
    return false;
}

void LocatorAbility::HandleStartLocating(const std::shared_ptr<Request>& request,
    const sptr<ILocatorCallback>& callback)
{
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::Get(EVENT_START_LOCATING, request);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    if (callback != nullptr) {
        ReportLocationStatus(callback, SESSION_START);
    }
}

ErrCode LocatorAbility::StopLocating(const sptr<ILocatorCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::STOP_LOCATING, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "LocatorAbility::StopLocating remote object nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
#if !defined(FEATURE_GNSS_SUPPORT) && !defined(FEATURE_NETWORK_SUPPORT) && !defined(FEATURE_PASSIVE_SUPPORT)
    LBSLOGE(LOCATOR, "%{public}s: service unavailable", __func__);
    return LOCATION_ERRCODE_NOT_SUPPORTED;
#endif
    if (requestManager_ == nullptr) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::unique_ptr<LocatorCallbackMessage> callbackMessage = std::make_unique<LocatorCallbackMessage>();
    callbackMessage->SetCallback(cb);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::Get(EVENT_STOP_LOCATING, callbackMessage);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    ReportLocationStatus(cb, SESSION_STOP);
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::GetCacheLocation(Location& location)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::GET_CACHE_LOCATION, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!GetLocationSwitchIgnoredFlag(identity.GetTokenId()) && !CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (locatorHandler_ == nullptr) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    auto lastLocation = reportManager_->GetLastLocation();
    std::unique_ptr<RequestConfig> requestConfig = std::make_unique<RequestConfig>();
    sptr<ILocatorCallback> callback;
    std::shared_ptr<Request> request = std::make_shared<Request>(requestConfig, callback, identity);
    std::unique_ptr<Location> loc = reportManager_->GetPermittedLocation(request, lastLocation);
    std::shared_ptr<AppIdentity> identityInfo = std::make_shared<AppIdentity>(identity);
    if (loc == nullptr) {
        locatorHandler_->SendHighPriorityEvent(EVENT_GET_CACHED_LOCATION_FAILED, identityInfo, 0);
        return ERRCODE_LOCATING_CACHE_FAIL;
    }
    reportManager_->UpdateLocationByRequest(identity.GetTokenId(), identity.GetTokenIdEx(), loc);
    location = *loc;
    requestManager_->IncreaseWorkingPidsCount(identity.GetPid());
    if (requestManager_->IsNeedStartUsingPermission(identity.GetPid())) {
        int ret = PrivacyKit::StartUsingPermission(
            identity.GetTokenId(), ACCESS_APPROXIMATELY_LOCATION, identity.GetPid());
        if (ret != ERRCODE_SUCCESS && ret != Security::AccessToken::ERR_PERMISSION_ALREADY_START_USING &&
            IsHapCaller(request->GetTokenId())) {
            LBSLOGE(LOCATOR, "StartUsingPermission failed ret=%{public}d", ret);
            locatorHandler_->SendHighPriorityEvent(EVENT_GET_CACHED_LOCATION_FAILED, identityInfo, 0);
            return ERRCODE_LOCATING_FAIL;
        }
    }
    // add location permission using record
    LBSLOGW(REPORT_MANAGER, "report last location to %{public}d, TimeSinceBoot : %{public}s, SourceType : %{public}d",
            identity.GetTokenId(), std::to_string(loc->GetTimeSinceBoot()).c_str(),
            loc->GetLocationSourceType());
    locatorHandler_->SendHighPriorityEvent(EVENT_GET_CACHED_LOCATION_SUCCESS, identityInfo, 0);
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::ReportLocation(const std::string& abilityName, const Location& location)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REPORT_LOCATION, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (identity.GetUid() != static_cast<pid_t>(getuid()) || identity.GetPid() != getpid()) {
        LBSLOGE(LOCATOR, "check system permission failed, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (requests_ == nullptr) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::unique_ptr<LocationMessage> locationMessage = std::make_unique<LocationMessage>();
    locationMessage->SetAbilityName(abilityName);
    auto loc = std::make_unique<OHOS::Location::Location>(location);
    locationMessage->SetLocation(loc);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_REPORT_LOCATION_MESSAGE, locationMessage);
    if (locatorHandler_ == nullptr || !locatorHandler_->SendEvent(event)) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
#ifdef FEATURE_GNSS_SUPPORT
    if (abilityName == NETWORK_ABILITY) {
        SendNetworkLocation(loc);
    }
#endif
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::ReportLocationStatus(const sptr<ILocatorCallback>& callback, int result)
{
    int state = DISABLED;
    ErrCode errorCode = GetSwitchState(state);
    if (errorCode != ERRCODE_SUCCESS) {
        return errorCode;
    }
    if (state == DISABLED) {
        LBSLOGE(LOCATOR, "%{public}s line:%{public}d location switch is off", __func__, __LINE__);
        return ERRCODE_SWITCH_OFF;
    }
    if (reportManager_->ReportRemoteCallback(callback, ILocatorCallback::RECEIVE_LOCATION_STATUS_EVENT, result)) {
        return ERRCODE_SUCCESS;
    }
    return ERRCODE_SERVICE_UNAVAILABLE;
}

ErrCode LocatorAbility::ReportErrorStatus(const sptr<ILocatorCallback>& callback, int result)
{
    int state = DISABLED;
    ErrCode errorCode = GetSwitchState(state);
    if (errorCode != ERRCODE_SUCCESS) {
        return errorCode;
    }
    if (state == DISABLED) {
        LBSLOGE(LOCATOR, "%{public}s line:%{public}d location switch is off", __func__, __LINE__);
        return ERRCODE_SWITCH_OFF;
    }
    if (reportManager_->ReportRemoteCallback(callback, ILocatorCallback::RECEIVE_ERROR_INFO_EVENT, result)) {
        return ERRCODE_SUCCESS;
    }
    return ERRCODE_SERVICE_UNAVAILABLE;
}

void LocatorAbility::RegisterAction()
{
    if (isActionRegistered) {
        LBSLOGI(LOCATOR, "action has already registered");
        return;
    }
    OHOS::EventFwk::MatchingSkills matchingSkills;
    matchingSkills.AddEvent(MODE_CHANGED_EVENT);
    matchingSkills.AddEvent(OHOS::EventFwk::CommonEventSupport::COMMON_EVENT_DEVICE_IDLE_MODE_CHANGED);
    matchingSkills.AddEvent(OHOS::EventFwk::CommonEventSupport::COMMON_EVENT_SIM_STATE_CHANGED);
    matchingSkills.AddEvent(LOCATION_CUST_CONFIG_POLICY_CHANGE);
    matchingSkills.AddEvent(PACKAGE_REMOVED_EVENT);
    OHOS::EventFwk::CommonEventSubscribeInfo subscriberInfo(matchingSkills);
    locatorEventSubscriber_ = std::make_shared<LocatorEventSubscriber>(subscriberInfo);

    bool result = OHOS::EventFwk::CommonEventManager::SubscribeCommonEvent(locatorEventSubscriber_);
    if (!result) {
        LBSLOGE(LOCATOR, "Failed to subscriber locator event, result = %{public}d", result);
        isActionRegistered = false;
    } else {
        LBSLOGI(LOCATOR, "success to subscriber locator event, result = %{public}d", result);
        isActionRegistered = true;
    }
}

void LocatorAbility::RegisterLocationPrivacyAction()
{
    if (isLocationPrivacyActionRegistered_) {
        LBSLOGI(LOCATOR, "location privacy action has already registered");
        return;
    }
    OHOS::EventFwk::MatchingSkills matchingSkills;
    matchingSkills.AddEvent(LOCATION_PRIVACY_ACCEPT_EVENT);
    matchingSkills.AddEvent(LOCATION_PRIVACY_REJECT_EVENT);
    OHOS::EventFwk::CommonEventSubscribeInfo subscriberInfo(matchingSkills);
    subscriberInfo.SetPermission("ohos.permission.PUBLISH_LOCATION_EVENT");
    locationPrivacyEventSubscriber_ = std::make_shared<LocatorEventSubscriber>(subscriberInfo);

    bool result = OHOS::EventFwk::CommonEventManager::SubscribeCommonEvent(locationPrivacyEventSubscriber_);
    if (!result) {
        LBSLOGE(LOCATOR, "Failed to subscriber location privacy event, result = %{public}d", result);
        isLocationPrivacyActionRegistered_ = false;
    } else {
        LBSLOGI(LOCATOR, "success to subscriber location privacy event, result = %{public}d", result);
        isLocationPrivacyActionRegistered_ = true;
    }
}

ErrCode LocatorAbility::IsGeoConvertAvailable(bool& isAvailable)
{
#ifdef FEATURE_GEOCODE_SUPPORT
    MessageParcel dataParcel;
    MessageParcel replyParcel;
    if (!dataParcel.WriteInterfaceToken(GeoConvertProxy::GetDescriptor())) {
        isAvailable = false;
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    SendGeoRequest(static_cast<int>(LocatorInterfaceCode::GEO_IS_AVAILABLE), dataParcel, replyParcel);
    LocationErrCode errorCode = LocationErrCode(replyParcel.ReadInt32());
    if (errorCode == ERRCODE_SUCCESS) {
        isAvailable = replyParcel.ReadBool();
    } else {
        isAvailable = false;
    }
    return errorCode;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::GetAddressByCoordinate(const sptr<IRemoteObject>& cb,
    const GeocodeConvertLocationRequest& request)
{
#ifdef FEATURE_GEOCODE_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::GET_FROM_COORDINATE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    std::string bundleName =
        identity.GetBundleName().size() > 0 ? identity.GetBundleName() : std::to_string(identity.GetUid());
    MessageParcel data;
    request.Marshalling(data);
    data.WriteRemoteObject(cb);
    MessageParcel dataParcel;
    auto requestTime = CommonUtils::GetCurrentTimeStamp();
    GeoCodeType requestType = GeoCodeType::REQUEST_REVERSE_GEOCODE;
    GeoConvertRequest::OrderParcel(data, dataParcel, cb, requestType, bundleName);
    auto geoConvertRequest = GeoConvertRequest::Unmarshalling(dataParcel, requestType);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_SEND_GEOREQUEST, geoConvertRequest);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    HookUtils::ExecuteHookWhenGetAddressFromLocation(bundleName);
    return ERRCODE_SUCCESS;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::GetAddressByLocationName(const sptr<IRemoteObject>& cb,
    const GeocodeConvertAddressRequest& request)
{
#ifdef FEATURE_GEOCODE_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::GET_FROM_LOCATION_NAME, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    std::string bundleName =
        identity.GetBundleName().size() > 0 ? identity.GetBundleName() : std::to_string(identity.GetUid());
    MessageParcel data;
    request.Marshalling(data);
    data.WriteRemoteObject(cb);
    MessageParcel dataParcel;
    auto requestTime = CommonUtils::GetCurrentTimeStamp();
    GeoCodeType requestType = GeoCodeType::REQUEST_GEOCODE;
    GeoConvertRequest::OrderParcel(data, dataParcel, cb, requestType, bundleName);
    auto geoConvertRequest = GeoConvertRequest::Unmarshalling(dataParcel, requestType);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_SEND_GEOREQUEST, geoConvertRequest);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    HookUtils::ExecuteHookWhenGetAddressFromLocationName(bundleName);
    return ERRCODE_SUCCESS;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

LocationErrCode LocatorAbility::SendGeoRequest(int type, MessageParcel &data, MessageParcel &reply)
{
#ifdef FEATURE_GEOCODE_SUPPORT
    if (!SaLoadWithStatistic::InitLocationSa(LOCATION_GEO_CONVERT_SA_ID)) {
        reply.WriteInt32(ERRCODE_SERVICE_UNAVAILABLE);
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    sptr<IRemoteObject> remoteObject = CommonUtils::GetRemoteObject(LOCATION_GEO_CONVERT_SA_ID,
        CommonUtils::InitDeviceId());
    if (remoteObject == nullptr) {
        reply.WriteInt32(ERRCODE_SERVICE_UNAVAILABLE);
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::string callingIdentity = IPCSkeleton::ResetCallingIdentity();
    MessageOption option;
    remoteObject->SendRequest(type, data, reply, option);
    IPCSkeleton::SetCallingIdentity(callingIdentity);
    return ERRCODE_SUCCESS;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::EnableReverseGeocodingMock()
{
#ifdef FEATURE_GEOCODE_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::ENABLE_REVERSE_GEOCODE_MOCK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckMockLocationPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckMockLocationPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataParcel;
    MessageParcel replyParcel;
    if (!dataParcel.WriteInterfaceToken(GeoConvertProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    SendGeoRequest(static_cast<int>(LocatorInterfaceCode::ENABLE_REVERSE_GEOCODE_MOCK), dataParcel, replyParcel);
    return replyParcel.ReadInt32();
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::DisableReverseGeocodingMock()
{
#ifdef FEATURE_GEOCODE_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::DISABLE_REVERSE_GEOCODE_MOCK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckMockLocationPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckMockLocationPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    MessageParcel dataParcel;
    MessageParcel replyParcel;
    if (!dataParcel.WriteInterfaceToken(GeoConvertProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    SendGeoRequest(static_cast<int>(LocatorInterfaceCode::DISABLE_REVERSE_GEOCODE_MOCK), dataParcel, replyParcel);
    return replyParcel.ReadInt32();
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::SetReverseGeocodingMockInfo(const std::vector<GeocodingMockInfo>& geocodingMockInfo)
{
#ifdef FEATURE_GEOCODE_SUPPORT
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::SET_REVERSE_GEOCODE_MOCKINFO, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckMockLocationPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckMockLocationPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    size_t arraySize = geocodingMockInfo.size();
    arraySize = arraySize > INPUT_ARRAY_LEN_MAX ? INPUT_ARRAY_LEN_MAX : arraySize;
    std::vector<std::shared_ptr<GeocodingMockInfo>> mockInfo;
    for (size_t i = 0; i < arraySize; i++) {
        std::shared_ptr<GeocodingMockInfo> info = std::make_shared<GeocodingMockInfo>(geocodingMockInfo[i]);
        mockInfo.push_back(info);
    }
    MessageParcel dataParcel;
    MessageParcel replyParcel;
    if (!dataParcel.WriteInterfaceToken(GeoConvertProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    dataParcel.WriteInt32(mockInfo.size());
    for (size_t i = 0; i < mockInfo.size(); i++) {
        mockInfo[i]->Marshalling(dataParcel);
    }
    SendGeoRequest(static_cast<int>(LocatorInterfaceCode::SET_REVERSE_GEOCODE_MOCKINFO), dataParcel, replyParcel);
    return LocationErrCode(replyParcel.ReadInt32());
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::ProxyForFreeze(const std::vector<int32_t>& pidList, bool isProxy)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!PermissionManager::CheckRssProcessName(identity.GetTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    ProxyFreezeManager::GetInstance()->ProxyForFreeze(pidList, isProxy);
    if (GetActiveRequestNum() <= 0) {
        LBSLOGD(LOCATOR, "no active request, do not refresh.");
        return ERRCODE_SUCCESS;
    }
    // for proxy uid update, should send message to refresh requests
    ApplyRequests(0);
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::ResetAllProxy()
{
    LBSLOGI(LOCATOR, "Start locator ResetAllProxy");
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!PermissionManager::CheckRssProcessName(identity.GetTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    ProxyFreezeManager::GetInstance()->ResetAllProxy();
    if (GetActiveRequestNum() <= 0) {
        LBSLOGD(LOCATOR, "no active request, do not refresh.");
        return ERRCODE_SUCCESS;
    }
    // for proxy uid update, should send message to refresh requests
    ApplyRequests(0);
    return ERRCODE_SUCCESS;
}

void LocatorAbility::RegisterPermissionCallback(const uint32_t callingTokenId,
    const std::vector<std::string>& permissionNameList)
{
    std::unique_lock<ffrt::mutex> lock(permissionMapMutex_);
    if (permissionMap_ == nullptr) {
        LBSLOGE(LOCATOR, "permissionMap is null.");
        return;
    }
    PermStateChangeScope scopeInfo;
    scopeInfo.permList = permissionNameList;
    scopeInfo.tokenIDs = {callingTokenId};
    auto callbackPtr = std::make_shared<PermissionStatusChangeCb>(scopeInfo);
    permissionMap_->erase(callingTokenId);
    if (permissionMap_->size() <= MAX_PERMISSION_NUM) {
        permissionMap_->insert(std::make_pair(callingTokenId, callbackPtr));
    } else {
        LBSLOGE(LOCATOR, "RegisterPermissionCallback num max");
        return;
    }
    LBSLOGD(LOCATOR, "after Id:%{public}d register, permission callback size:%{public}s",
        callingTokenId, std::to_string(permissionMap_->size()).c_str());
    int32_t res = AccessTokenKit::RegisterPermStateChangeCallback(callbackPtr);
    if (res != SUCCESS) {
        LBSLOGE(LOCATOR, "RegisterPermStateChangeCallback failed.");
    }
}

void LocatorAbility::UnregisterPermissionCallback(const uint32_t callingTokenId)
{
    std::unique_lock<ffrt::mutex> lock(permissionMapMutex_);
    if (permissionMap_ == nullptr) {
        LBSLOGE(LOCATOR, "permissionMap is null.");
        return;
    }
    auto iter = permissionMap_->find(callingTokenId);
    if (iter != permissionMap_->end()) {
        auto callbackPtr = iter->second;
        int32_t res = AccessTokenKit::UnRegisterPermStateChangeCallback(callbackPtr);
        if (res != SUCCESS) {
            LBSLOGE(LOCATOR, "UnRegisterPermStateChangeCallback failed.");
        }
    }
    permissionMap_->erase(callingTokenId);
    LBSLOGD(LOCATOR, "after Id:%{public}d unregister, permission callback size:%{public}s",
        callingTokenId, std::to_string(permissionMap_->size()).c_str());
}

void LocatorAbility::ReportDataToResSched(std::string state)
{
#ifdef RES_SCHED_SUPPROT
    std::unordered_map<std::string, std::string> payload;
    payload["state"] = state;
    uint32_t type = ResourceSchedule::ResType::RES_TYPE_LOCATION_STATUS_CHANGE;
    int64_t value =  ResourceSchedule::ResType::LocationStatus::LOCATION_SWTICH_CHANGE;
    ResourceSchedule::ResSchedClient::GetInstance().ReportData(type, value, payload);
#endif
}

ErrCode LocatorAbility::QuerySupportCoordinateSystemType(std::vector<CoordinateType>& coordinateTypes)
{
#ifdef FEATURE_GNSS_SUPPORT
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    auto errCode = SendGnssRequest(
        static_cast<int>(GnssInterfaceCode::GET_GEOFENCE_SUPPORT_COORDINATE_SYSTEM_TYPE),
        dataToStub, replyToStub);
    if (errCode == ERRCODE_SUCCESS) {
        int size = replyToStub.ReadInt32();
        size = size > COORDINATE_SYSTEM_TYPE_SIZE ? COORDINATE_SYSTEM_TYPE_SIZE : size;
        for (int i = 0; i < size; i++) {
            int coordinateSystemType = replyToStub.ReadInt32();
            coordinateTypes.push_back(static_cast<CoordinateType>(coordinateSystemType));
        }
    }
    return errCode;
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

LocationErrCode LocatorAbility::SendNetworkLocation(const std::unique_ptr<Location>& location)
{
#ifdef FEATURE_GNSS_SUPPORT
    LBSLOGD(LOCATOR, "%{public}s: send network location", __func__);
    int64_t time = location->GetTimeStamp();
    int64_t timeSinceBoot = location->GetTimeSinceBoot();
    double acc = location->GetAccuracy();
    LBSLOGI(LOCATOR,
        "receive network location: [ time=%{public}s timeSinceBoot=%{public}s acc=%{public}f]",
        std::to_string(time).c_str(), std::to_string(timeSinceBoot).c_str(), acc);
    MessageParcel dataToStub;
    MessageParcel replyToStub;
    if (!dataToStub.WriteInterfaceToken(GnssAbilityProxy::GetDescriptor())) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    location->Marshalling(dataToStub);
    return SendGnssRequest(static_cast<int>(GnssInterfaceCode::SEND_NETWORK_LOCATION), dataToStub, replyToStub);
#else
    return ERRCODE_SERVICE_UNAVAILABLE;
#endif
}

ErrCode LocatorAbility::SubscribeBluetoothScanResultChange(
    const sptr<IBluetoothScanResultCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::START_SCAN_BLUETOOTH_DEVICE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!PermissionManager::CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "%{public}s.callback == nullptr", __func__);
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::unique_ptr<BluetoothScanResultCallbackMessage> callbackMessage =
        std::make_unique<BluetoothScanResultCallbackMessage>();
    callbackMessage->SetCallback(cb);
    callbackMessage->SetAppIdentity(identity);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_START_SCAN_BLUETOOTH_DEVICE, callbackMessage);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::UnSubscribeBluetoothScanResultChange(
    const sptr<IBluetoothScanResultCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::STOP_SCAN_BLUETOOTH_DEVICE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "%{public}s.callback == nullptr", __func__);
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    std::unique_ptr<BluetoothScanResultCallbackMessage> callbackMessage =
        std::make_unique<BluetoothScanResultCallbackMessage>();
    callbackMessage->SetCallback(cb);
    callbackMessage->SetAppIdentity(identity);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_STOP_SCAN_BLUETOOTH_DEVICE, callbackMessage);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    return ERRCODE_SUCCESS;
}

LocationErrCode LocatorAbility::RegisterLocationError(const sptr<ILocatorCallback>& callback, AppIdentity &identity)
{
    std::unique_ptr<LocatorCallbackMessage> callbackMessage = std::make_unique<LocatorCallbackMessage>();
    callbackMessage->SetCallback(callback);
    callbackMessage->SetAppIdentity(identity);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_REG_LOCATION_ERROR, callbackMessage);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    return ERRCODE_SUCCESS;
}

LocationErrCode LocatorAbility::UnregisterLocationError(const sptr<ILocatorCallback>& callback, AppIdentity &identity)
{
    std::unique_ptr<LocatorCallbackMessage> callbackMessage = std::make_unique<LocatorCallbackMessage>();
    callbackMessage->SetCallback(callback);
    callbackMessage->SetAppIdentity(identity);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_UNREG_LOCATION_ERROR, callbackMessage);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::SetLocationSwitchIgnored(bool isEnabled)
{
    LBSLOGI(LOCATOR, "SetLocationSwitchIgnored %{public}d", isEnabled);
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::SET_LOCATION_SETTINGS_IGNORED, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckLocationSwitchIgnoredPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckLocationSwitchIgnoredPermission return false, [%{public}s]",
            identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    SetLocationSwitchIgnoredFlag(identity.GetTokenId(), isEnabled);
    return ERRCODE_SUCCESS;
}

ErrCode LocatorAbility::AddBeaconFence(const BeaconFenceRequest& request)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::ADD_BEACON_FENCE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_BEACONFENCE_LOCATION_SWITCH_OFF;
    }
    if (!CheckBluetoothSwitchState()) {
        return ERRCODE_BEACONFENCE_BLUETOOTH_SWITCH_OFF;
    }
    if (!PermissionManager::CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    std::shared_ptr<BeaconFenceRequest> beaconFenceRequest =
        std::make_shared<BeaconFenceRequest>(const_cast<BeaconFenceRequest&>(request));
    beaconFenceRequest->SetBundleName(identity.GetBundleName());
    ErrCode locationErrCode = BeaconFenceManager::GetInstance()->AddBeaconFence(beaconFenceRequest, identity);
    return locationErrCode;
}

ErrCode LocatorAbility::RemoveBeaconFence(const BeaconFence& beaconFence)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REMOVE_BEACON_FENCE, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!PermissionManager::CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    std::shared_ptr<BeaconFence> beacon =
        std::make_shared<BeaconFence>(const_cast<BeaconFence&>(beaconFence));
    ErrCode locationErrCode = BeaconFenceManager::GetInstance()->RemoveBeaconFence(beacon);
    return locationErrCode;
}

ErrCode LocatorAbility::ReportLocationError(int32_t errCodeNum, const std::string& errMsg, const std::string& uuid)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REPORT_LOCATION_ERROR, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (identity.GetUid() != static_cast<pid_t>(getuid()) || identity.GetPid() != getpid()) {
        LBSLOGE(LOCATOR, "check system permission failed, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    std::unique_ptr<LocatorErrorMessage> locatorErrorMessage = std::make_unique<LocatorErrorMessage>();
    locatorErrorMessage->SetUuid(uuid);
    locatorErrorMessage->SetErrCode(errCodeNum);
    locatorErrorMessage->SetErrMsg(errMsg);
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_REPORT_LOCATION_ERROR, locatorErrorMessage);
    if (locatorHandler_ != nullptr) {
        locatorHandler_->SendEvent(event);
    }
    return ERRCODE_SUCCESS;
}

LocationErrCode LocatorAbility::RemoveInvalidRequests()
{
    std::list<std::shared_ptr<Request>> invalidRequestList;
    int32_t requestNum = 0;
    int32_t invalidRequestNum = 0;
    {
        std::unique_lock<ffrt::mutex> lock(requestsMutex_);
#ifdef FEATURE_GNSS_SUPPORT
        auto gpsListIter = requests_->find(GNSS_ABILITY);
        if (gpsListIter != requests_->end()) {
            auto list = &(gpsListIter->second);
            requestNum += static_cast<int>(list->size());
            for (auto& item : *list) {
                if (IsInvalidRequest(item)) {
                    invalidRequestList.push_back(item);
                    invalidRequestNum++;
                }
            }
        }
#endif
#ifdef FEATURE_NETWORK_SUPPORT
        auto networkListIter = requests_->find(NETWORK_ABILITY);
        if (networkListIter != requests_->end()) {
            auto list = &(networkListIter->second);
            requestNum += static_cast<int>(list->size());
            for (auto& item : *list) {
                if (IsInvalidRequest(item)) {
                    invalidRequestList.push_back(item);
                    invalidRequestNum++;
                }
            }
        }
#endif
    }
    LBSLOGI(LOCATOR, "request num : %{public}d, invalid request num: %{public}d", requestNum, invalidRequestNum);
    if (invalidRequestList.size() > INVALID_REQUESTS_SIZE) {
        return ERRCODE_SUCCESS;
    }
    for (auto& item : invalidRequestList) {
        sptr<ILocatorCallback> callback = item->GetLocatorCallBack();
        StopLocating(callback);
    }
    return ERRCODE_SUCCESS;
}

bool LocatorAbility::IsInvalidRequest(std::shared_ptr<Request>& request)
{
    LBSLOGI(LOCATOR, "request : %{public}s %{public}s", request->GetPackageName().c_str(),
        request->GetRequestConfig()->ToString().c_str());
    int64_t timeDiff = fabs(CommonUtils::GetCurrentTime() - request->GetRequestConfig()->GetTimeStamp());
    if (request->GetRequestConfig()->GetFixNumber() == 1 &&
        timeDiff > (request->GetRequestConfig()->GetTimeOut() / MILLI_PER_SEC)) {
        LBSLOGI(LOCATOR, "once request is timeout");
        return true;
    }

    if (timeDiff > REQUEST_DEFAULT_TIMEOUT_SECOUND && !IsProcessRunning(request->GetPid(), request->GetTokenId())) {
        LBSLOGI(LOCATOR, "request process is not running");
        return true;
    }
    return false;
}

bool LocatorAbility::IsProcessRunning(pid_t pid, const uint32_t tokenId)
{
    auto tokenType = Security::AccessToken::AccessTokenKit::GetTokenTypeFlag(tokenId);
    if (tokenType == Security::AccessToken::ATokenTypeEnum::TOKEN_NATIVE) {
        return true;
    }
    sptr<ISystemAbilityManager> samgrClient = SystemAbilityManagerClient::GetInstance().GetSystemAbilityManager();
    if (samgrClient == nullptr) {
        LBSLOGE(LOCATOR, "Get system ability manager failed.");
        return true;
    }
    sptr<AppExecFwk::IAppMgr> iAppManager =
        iface_cast<AppExecFwk::IAppMgr>(samgrClient->GetSystemAbility(APP_MGR_SERVICE_ID));
    if (iAppManager == nullptr) {
        LBSLOGE(LOCATOR, "Failed to get ability manager service.");
        return true;
    }
    std::vector<AppExecFwk::RunningProcessInfo> runningProcessList;
    int32_t res = iAppManager->GetAllRunningProcesses(runningProcessList);
    if (res != ERR_OK) {
        LBSLOGE(LOCATOR, "Failed to get all running process.");
        return true;
    }
    auto it = std::find_if(runningProcessList.begin(), runningProcessList.end(), [pid] (auto runningProcessInfo) {
        return pid == runningProcessInfo.pid_;
    });
    if (it != runningProcessList.end()) {
        LBSLOGD(LOCATOR, "process : %{public}d is found.", pid);
        return true;
    }
    return false;
}

void LocatorAbility::SyncStillMovementState(bool state)
{
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_SYNC_STILL_MOVEMENT_STATE, state);
    if (locatorHandler_ != nullptr && locatorHandler_->SendEvent(event)) {
        LBSLOGD(LOCATOR, "%{public}s: EVENT_SYNC_MOVEMENT_STATE Send Success", __func__);
    }
}

bool LocatorAbility::IsHapCaller(const uint32_t tokenId)
{
    auto tokenType = Security::AccessToken::AccessTokenKit::GetTokenTypeFlag(tokenId);
    if (tokenType == Security::AccessToken::ATokenTypeEnum::TOKEN_HAP) {
        return true;
    }
    return false;
}

void LocatorAbility::SyncIdleState(bool state)
{
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_SYNC_IDLE_STATE, state);
    if (locatorHandler_ != nullptr && locatorHandler_->SendEvent(event)) {
        LBSLOGD(LOCATOR, "%{public}s: EVENT_SYNC_IDLE_STATE Send Success", __func__);
    }
}

void LocatorAbility::SetLocationSwitchIgnoredFlag(uint32_t tokenId, bool enable)
{
    std::unique_lock<std::mutex> lock(LocationSwitchIgnoredFlagMutex_);
    LBSLOGD(LOCATOR, "SetLocationSwitchIgnoredFlag enable = %{public}d", enable);
    AppSwitchIgnoredState appSwitchIgnoredState;
    appSwitchIgnoredState.state = enable;
    appSwitchIgnoredState.timeSinceBoot = CommonUtils::GetSinceBootTime();
    if (enable) {
        locationSettingsIgnoredFlagMap_[tokenId] = appSwitchIgnoredState;
        ApplyRequests(LOCATION_SWITCH_IGNORED_STATE_VALID_TIME / MILLI_PER_SEC);
    } else {
        auto iter = locationSettingsIgnoredFlagMap_.find(tokenId);
        if (iter != locationSettingsIgnoredFlagMap_.end()) {
            locationSettingsIgnoredFlagMap_.erase(iter);
            ApplyRequests(0);
        }
    }
}

bool LocatorAbility::GetLocationSwitchIgnoredFlag(uint32_t tokenId)
{
    std::unique_lock<std::mutex> lock(LocationSwitchIgnoredFlagMutex_);
    auto iter = locationSettingsIgnoredFlagMap_.find(tokenId);
    if (iter == locationSettingsIgnoredFlagMap_.end()) {
        return false;
    }
    AppSwitchIgnoredState appSwitchIgnoredState = iter->second;
    if ((CommonUtils::GetSinceBootTime()- appSwitchIgnoredState.timeSinceBoot) / NANOS_PER_MICRO / MICRO_PER_MILLI >
        LOCATION_SWITCH_IGNORED_STATE_VALID_TIME) {
        locationSettingsIgnoredFlagMap_.erase(iter);
        return false;
    }
    LBSLOGD(LOCATOR, "GetLocationSwitchIgnoredFlag enable = %{public}d", appSwitchIgnoredState.state);
    return appSwitchIgnoredState.state;
}

ErrCode LocatorAbility::RegisterLocatingRequiredDataCallback(const LocatingRequiredDataConfig& dataConfig,
    const sptr<ILocatingRequiredDataCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REG_LOCATING_REQUIRED_DATA_CALLBACK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckPreciseLocationPermissions(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "%{public}s: callback is nullptr.", __func__);
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    auto dataConfigShared =
        std::make_shared<LocatingRequiredDataConfig>(const_cast<LocatingRequiredDataConfig&>(dataConfig));
    auto locatorDataManager = LocatorRequiredDataManager::GetInstance();
    cb->AsObject()->AddDeathRecipient(scanRecipient_);
    return locatorDataManager->RegisterCallback(identity, dataConfigShared, cb->AsObject());
}

ErrCode LocatorAbility::UnRegisterLocatingRequiredDataCallback(const sptr<ILocatingRequiredDataCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::UNREG_LOCATING_REQUIRED_DATA_CALLBACK, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckPreciseLocationPermissions(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!PermissionManager::CheckSystemPermission(identity.GetTokenId(), identity.GetTokenIdEx())) {
        LBSLOGE(LOCATOR, "CheckSystemPermission return false, [%{public}s]", identity.ToString().c_str());
        return LOCATION_ERRCODE_SYSTEM_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "%{public}s: callback is nullptr.", __func__);
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    auto locatorDataManager = LocatorRequiredDataManager::GetInstance();
    cb->AsObject()->RemoveDeathRecipient(scanRecipient_);
    return locatorDataManager->UnregisterCallback(cb->AsObject());
}

ErrCode LocatorAbility::SubscribeLocationError(const sptr<ILocatorCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::REG_LOCATION_ERROR, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "StartLocating remote object nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    return RegisterLocationError(cb, identity);
}

ErrCode LocatorAbility::UnSubscribeLocationError(const sptr<ILocatorCallback>& cb)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::UNREG_LOCATION_ERROR, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationPermission(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "LocatorAbility::StopLocating remote object nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    return UnregisterLocationError(cb, identity);
}

ErrCode LocatorAbility::GetCurrentWifiBssidForLocating(std::string& bssid)
{
    AppIdentity identity;
    GetAppIdentityInfo(identity);
    if (!CheckRequestAvailable(LocatorInterfaceCode::GET_CURRENT_WIFI_BSSID_FOR_LOCATING, identity)) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    if (!CheckLocationSwitchState()) {
        return ERRCODE_SWITCH_OFF;
    }
    if (!CheckPreciseLocationPermissions(identity.GetTokenId(), identity.GetFirstTokenId())) {
        return LOCATION_ERRCODE_PERMISSION_DENIED;
    }
    auto locatorDataManager = LocatorRequiredDataManager::GetInstance();
    return locatorDataManager->GetCurrentWifiBssidForLocating(bssid);
}

ErrCode LocatorAbility::IsPoiServiceSupported(bool& poiServiceSupportState)
{
    LBSLOGI(LOCATOR, "IsPoiServiceSupported enter");
    std::string serviceName;
    bool result = LocationConfigManager::GetInstance()->GetNlpServiceName(serviceName);
    if (!result || serviceName.empty()) {
        LBSLOGE(LOCATOR, "get service name failed!");
        poiServiceSupportState = false;
        return ERRCODE_SUCCESS;
    }
    if (!CommonUtils::CheckAppInstalled(serviceName)) { // app is not installed
        poiServiceSupportState = false;
    } else {
        poiServiceSupportState = true;
    }
    return ERRCODE_SUCCESS;
}

LocationErrCode LocatorAbility::SetSwitchState(bool isEnabled)
{
    int modeValue = isEnabled ? ENABLED : DISABLED;
    int currentSwitchState = LocationDataRdbManager::QuerySwitchState();
    if (modeValue == currentSwitchState) {
        LBSLOGD(LOCATOR, "no need to set location ability, enable:%{public}d", modeValue);
        return ERRCODE_SUCCESS;
    }
    if (LocationDataRdbManager::SetSwitchStateToSysparaForCurrentUser(modeValue)) {
        int userId = 0;
        if (!CommonUtils::GetCurrentUserId(userId)) {
            userId = DEFAULT_USERID;
        }
        CommonEventHelper::PublishLocationModeChangeCommonEventAsUser(modeValue, userId);
    }
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::Get(EVENT_SET_SWITCH_STATE_TO_DB, modeValue);
    if (locatorHandler_ != nullptr && locatorHandler_->SendEvent(event)) {
        LBSLOGD(LOCATOR, "%{public}s: EVENT_SET_SWITCH_STATE_TO_DB Send Success", __func__);
    }
    return ERRCODE_SUCCESS;
}

LocationErrCode LocatorAbility::SetSwitchStateForUser(bool isEnabled, int32_t userId)
{
    int modeValue = isEnabled ? ENABLED : DISABLED;
    std::unique_ptr<LocatorSwitchMessage> locatorSwitchMessage = std::make_unique<LocatorSwitchMessage>();
    locatorSwitchMessage->SetModeValue(modeValue);
    locatorSwitchMessage->SetUserId(userId);
    if (LocationDataRdbManager::SetSwitchStateToSysparaForUser(modeValue, userId)) {
        CommonEventHelper::PublishLocationModeChangeCommonEventAsUser(modeValue, userId);
    }
    AppExecFwk::InnerEvent::Pointer event = AppExecFwk::InnerEvent::
        Get(EVENT_SET_SWITCH_STATE_TO_DB_BY_USERID, locatorSwitchMessage);
    if (locatorHandler_ != nullptr && locatorHandler_->SendEvent(event)) {
        LBSLOGD(LOCATOR, "%{public}s: EVENT_SET_SWITCH_STATE_TO_DB_BY_USERID Send Success", __func__);
    }
    return ERRCODE_SUCCESS;
}

bool LocatorAbility::CheckLocationSwitchState()
{
    int state = DISABLED;
    ErrCode errorCode = GetSwitchState(state);
    if (errorCode != ERRCODE_SUCCESS) {
        LBSLOGE(LOCATOR, "GetSwitchState failed errCode = %{public}d.", errorCode);
    }
    if (state != ENABLED) {
        LBSLOGE(LOCATOR, "switch state is off.");
        return false;
    }
    return true;
}

bool LocatorAbility::CheckBluetoothSwitchState()
{
    Bluetooth::BluetoothState state = Bluetooth::BluetoothHost::GetDefaultHost().GetBluetoothState();
    if (state != Bluetooth::BluetoothState::STATE_ON) {
        return false;
    }
    return true;
}

bool LocatorAbility::CheckLocationPermission(uint32_t callingTokenId, uint32_t callingFirstTokenid)
{
    if (!PermissionManager::CheckLocationPermission(callingTokenId, callingFirstTokenid) &&
        !PermissionManager::CheckApproximatelyPermission(callingTokenId, callingFirstTokenid)) {
        LBSLOGE(LOCATOR, "%{public}d %{public}s failed", callingTokenId, __func__);
        return false;
    } else {
        return true;
    }
}

bool LocatorAbility::CheckPreciseLocationPermissions(uint32_t callingTokenId, uint32_t callingFirstTokenid)
{
    if (!PermissionManager::CheckLocationPermission(callingTokenId, callingFirstTokenid) ||
        !PermissionManager::CheckApproximatelyPermission(callingTokenId, callingFirstTokenid)) {
        LBSLOGE(LOCATOR, "%{public}d %{public}s failed", callingTokenId, __func__);
        return false;
    } else {
        return true;
    }
}

ErrCode LocatorAbility::StartLocatingProcess(const RequestConfig& requestConfig,
    const sptr<ILocatorCallback>& cb, AppIdentity& identity)
{
    if (cb == nullptr) {
        LBSLOGE(LOCATOR, "StartLocating remote object nullptr");
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
#if !defined(FEATURE_GNSS_SUPPORT) && !defined(FEATURE_NETWORK_SUPPORT) && !defined(FEATURE_PASSIVE_SUPPORT)
    LBSLOGE(LOCATOR, "%{public}s: service unavailable", __func__);
    return LOCATION_ERRCODE_NOT_SUPPORTED;
#endif
    if (LocationDataRdbManager::QuerySwitchState() != ENABLED && !GetLocationSwitchIgnoredFlag(identity.GetTokenId())) {
        ReportErrorStatus(cb, ERROR_SWITCH_UNOPEN);
    }
    // update offset before add request
    if (reportManager_ == nullptr || requestManager_ == nullptr) {
        return ERRCODE_SERVICE_UNAVAILABLE;
    }
    reportManager_->UpdateRandom();
    std::unique_ptr<RequestConfig> requestConfigUnique = std::make_unique<RequestConfig>(requestConfig);
    std::shared_ptr<Request> request = std::make_shared<Request>(requestConfigUnique, cb, identity);
    sptr<IRemoteObject::DeathRecipient> death(new (std::nothrow) LocatorCallbackDeathRecipient(identity.GetTokenId()));
    cb->AsObject()->AddDeathRecipient(death);
    request->SetLocatorCallbackRecipient(death);
    OHOS::Security::AccessToken::PermUsedTypeEnum type =
        Security::AccessToken::AccessTokenKit::GetPermissionUsedType(request->GetTokenId(),
        ACCESS_APPROXIMATELY_LOCATION);
    request->SetPermUsedType(static_cast<int>(type));
    if (requestConfigUnique->GetScenario() != SCENE_NO_POWER &&
        requestConfigUnique->GetScenario() != LOCATION_SCENE_NO_POWER_CONSUMPTION &&
        !reportManager_->IsCacheGnssLocationValid()) {
        LocatorRequiredDataManager::GetInstance()->SendWifiScanEvent();
    }
#ifdef EMULATOR_ENABLED
    // for emulator, report cache location is unnecessary
    HandleStartLocating(request, cb);
#else
    if (NeedReportCacheLocation(request, cb)) {
        LBSLOGI(LOCATOR, "report cache location to %{public}s", identity.GetBundleName().c_str());
        if (requestConfigUnique->GetScenario() != SCENE_NO_POWER &&
            requestConfigUnique->GetScenario() != LOCATION_SCENE_NO_POWER_CONSUMPTION) {
            SelfRequestManager::GetInstance()->StartSelfRequest(request);
        }
        cb->AsObject()->RemoveDeathRecipient(death);
    } else {
        HandleStartLocating(request, cb);
    }
#endif
    return ERRCODE_SUCCESS;
}

void LocatorAbility::GetAppIdentityInfo(AppIdentity& identity)
{
    identity.SetPid(IPCSkeleton::GetCallingPid());
    identity.SetUid(IPCSkeleton::GetCallingUid());
    identity.SetTokenId(IPCSkeleton::GetCallingTokenID());
    identity.SetTokenIdEx(IPCSkeleton::GetCallingFullTokenID());
    identity.SetFirstTokenId(IPCSkeleton::GetFirstTokenID());
    if (identity.GetUid() == static_cast<pid_t>(identity.GetFirstTokenId()) &&
        identity.GetUid() == static_cast<pid_t>(getuid()) && identity.GetPid() == getpid()) {
        identity.SetFirstTokenId(0);
    }
    std::string bundleName = "";
    if (!CommonUtils::GetBundleNameByUid(identity.GetUid(), bundleName)) {
        LBSLOGD(LOCATOR, "Fail to Get bundle name: uid = %{public}d.", identity.GetUid());
    }
    identity.SetBundleName(bundleName);
}

void LocationMessage::SetAbilityName(std::string abilityName)
{
    abilityName_ = abilityName;
}

std::string LocationMessage::GetAbilityName()
{
    return abilityName_;
}

void LocationMessage::SetLocation(const std::unique_ptr<Location>& location)
{
    if (location != nullptr) {
        location_ = std::make_unique<Location>(*location);
    }
}

std::unique_ptr<Location> LocationMessage::GetLocation()
{
    if (location_ != nullptr) {
        return std::make_unique<Location>(*location_);
    } else {
        return nullptr;
    }
}

void LocatorCallbackMessage::SetCallback(const sptr<ILocatorCallback>& callback)
{
    callback_ = callback;
}

sptr<ILocatorCallback> LocatorCallbackMessage::GetCallback()
{
    return callback_;
}

void LocatorCallbackMessage::SetAppIdentity(AppIdentity& appIdentity)
{
    appIdentity_ = appIdentity;
}

AppIdentity LocatorCallbackMessage::GetAppIdentity()
{
    return appIdentity_;
}

void BluetoothScanResultCallbackMessage::SetCallback(const sptr<IBluetoothScanResultCallback>& callback)
{
    callback_ = callback;
}

sptr<IBluetoothScanResultCallback> BluetoothScanResultCallbackMessage::GetCallback()
{
    return callback_;
}

void BluetoothScanResultCallbackMessage::SetAppIdentity(AppIdentity& appIdentity)
{
    appIdentity_ = appIdentity;
}

AppIdentity BluetoothScanResultCallbackMessage::GetAppIdentity()
{
    return appIdentity_;
}

void LocatorErrorMessage::SetUuid(std::string uuid)
{
    uuid_ = uuid;
}

std::string LocatorErrorMessage::GetUuid()
{
    return uuid_;
}

void LocatorErrorMessage::SetErrCode(int32_t errCode)
{
    errCode_ = errCode;
}

int32_t LocatorErrorMessage::GetErrCode()
{
    return errCode_;
}

void LocatorErrorMessage::SetNetErrCode(int32_t netErrCode)
{
    netErrCode_ = netErrCode;
}

int32_t LocatorErrorMessage::GetNetErrCode()
{
    return netErrCode_;
}

void LocatorErrorMessage::SetErrMsg(std::string errMsg)
{
    errMsg_ = errMsg;
}

std::string LocatorErrorMessage::GetErrMsg()
{
    return errMsg_;
}

void LocatorSwitchMessage::SetUserId(int32_t userId)
{
    userId_ = userId;
}

int32_t LocatorSwitchMessage::GetUserId()
{
    return userId_;
}

void LocatorSwitchMessage::SetModeValue(int32_t modeValue)
{
    modeValue_ = modeValue;
}

int32_t LocatorSwitchMessage::GetModeValue()
{
    return modeValue_;
}

LocatorHandler::LocatorHandler(const std::shared_ptr<AppExecFwk::EventRunner>& runner) : EventHandler(runner)
{
    InitLocatorHandlerEventMap();
}

LocatorHandler::~LocatorHandler() {}

void LocatorHandler::InitLocatorHandlerEventMap()
{
    if (locatorHandlerEventMap_.size() != 0) {
        return;
    }
    locatorHandlerEventMap_[EVENT_UPDATE_SA] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { UpdateSaEvent(event); };
    locatorHandlerEventMap_[EVENT_INIT_REQUEST_MANAGER] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { InitRequestManagerEvent(event); };
    locatorHandlerEventMap_[EVENT_APPLY_REQUIREMENTS] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { ApplyRequirementsEvent(event); };
    locatorHandlerEventMap_[EVENT_RETRY_REGISTER_ACTION] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { RetryRegisterActionEvent(event); };
    locatorHandlerEventMap_[EVENT_REPORT_LOCATION_MESSAGE] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { ReportLocationMessageEvent(event); };
    locatorHandlerEventMap_[EVENT_SEND_SWITCHSTATE_TO_HIFENCE] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SendSwitchStateToHifenceEvent(event); };
    locatorHandlerEventMap_[EVENT_START_LOCATING] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { StartLocatingEvent(event); };
    locatorHandlerEventMap_[EVENT_STOP_LOCATING] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { StopLocatingEvent(event); };
    locatorHandlerEventMap_[EVENT_UNLOAD_SA] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { UnloadSaEvent(event); };
    locatorHandlerEventMap_[EVENT_GET_CACHED_LOCATION_SUCCESS] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { GetCachedLocationSuccess(event); };
    locatorHandlerEventMap_[EVENT_GET_CACHED_LOCATION_FAILED] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { GetCachedLocationFailed(event); };
    locatorHandlerEventMap_[EVENT_REG_LOCATION_ERROR] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { RegLocationErrorEvent(event); };
    locatorHandlerEventMap_[EVENT_UNREG_LOCATION_ERROR] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { UnRegLocationErrorEvent(event); };
    locatorHandlerEventMap_[EVENT_REPORT_LOCATION_ERROR] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { ReportNetworkLocatingErrorEvent(event); };
    locatorHandlerEventMap_[EVENT_PERIODIC_CHECK] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { RequestCheckEvent(event); };
    locatorHandlerEventMap_[EVENT_SYNC_LOCATION_STATUS] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SyncSwitchStatus(event); };
    locatorHandlerEventMap_[EVENT_SYNC_STILL_MOVEMENT_STATE] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SyncStillMovementState(event); };
    locatorHandlerEventMap_[EVENT_SYNC_IDLE_STATE] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SyncIdleState(event); };
    locatorHandlerEventMap_[EVENT_INIT_MSDP_MONITOR_MANAGER] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { InitMonitorManagerEvent(event); };
    locatorHandlerEventMap_[EVENT_IS_STAND_BY] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { IsStandByEvent(event); };
    ConstructDbHandleMap();
    ConstructGeocodeHandleMap();
    ConstructBluetoothScanHandleMap();
}

void LocatorHandler::ConstructGeocodeHandleMap()
{
    locatorHandlerEventMap_[EVENT_SEND_GEOREQUEST] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SendGeoRequestEvent(event); };
}

void LocatorHandler::ConstructDbHandleMap()
{
    locatorHandlerEventMap_[EVENT_SET_LOCATION_WORKING_STATE] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SetLocationWorkingStateEvent(event); };
    locatorHandlerEventMap_[EVENT_SET_SWITCH_STATE_TO_DB] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SetSwitchStateToDbEvent(event); };
    locatorHandlerEventMap_[EVENT_SET_SWITCH_STATE_TO_DB_BY_USERID] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { SetSwitchStateToDbForUserEvent(event); };
    locatorHandlerEventMap_[EVENT_WATCH_SWITCH_PARAMETER] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { WatchSwitchParameter(event); };
}

void LocatorHandler::ConstructBluetoothScanHandleMap()
{
    locatorHandlerEventMap_[EVENT_START_SCAN_BLUETOOTH_DEVICE] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { StartScanBluetoothDeviceEvent(event); };
    locatorHandlerEventMap_[EVENT_STOP_SCAN_BLUETOOTH_DEVICE] =
        [this](const AppExecFwk::InnerEvent::Pointer& event) { StopScanBluetoothDeviceEvent(event); };
}

void LocatorHandler::GetCachedLocationSuccess(const AppExecFwk::InnerEvent::Pointer& event)
{
    std::shared_ptr<AppIdentity> identity = event->GetSharedObject<AppIdentity>();
    if (identity == nullptr) {
        LBSLOGE(LOCATOR, "%{public}s get identity failed", __func__);
        return;
    }
    int64_t tokenId = identity->GetTokenId();
    OHOS::Security::AccessToken::PermUsedTypeEnum type =
        Security::AccessToken::AccessTokenKit::GetPermissionUsedType(tokenId, ACCESS_APPROXIMATELY_LOCATION);
    auto locatorAbility = LocatorAbility::GetInstance();
    int ret;
    if (locatorAbility != nullptr) {
        ret = locatorAbility->UpdatePermissionUsedRecord(tokenId, ACCESS_APPROXIMATELY_LOCATION,
            static_cast<int>(type), 1, 0);
        LBSLOGD(LOCATOR, "UpdatePermissionUsedRecord, ret=%{public}d", ret);
    }
    auto requestManager = RequestManager::GetInstance();
    requestManager->DecreaseWorkingPidsCount(identity->GetPid());
    if (requestManager->IsNeedStopUsingPermission(identity->GetPid())) {
        ret = PrivacyKit::StopUsingPermission(tokenId, ACCESS_APPROXIMATELY_LOCATION, identity->GetPid());
        LBSLOGD(LOCATOR, "StopUsingPermission, ret=%{public}d", ret);
    }
}

void LocatorHandler::GetCachedLocationFailed(const AppExecFwk::InnerEvent::Pointer& event)
{
    std::shared_ptr<AppIdentity> identity = event->GetSharedObject<AppIdentity>();
    if (identity == nullptr) {
        LBSLOGE(LOCATOR, "%{public}s get identity failed", __func__);
        return;
    }
    int64_t tokenId = identity->GetTokenId();
    OHOS::Security::AccessToken::PermUsedTypeEnum type =
        Security::AccessToken::AccessTokenKit::GetPermissionUsedType(tokenId, ACCESS_APPROXIMATELY_LOCATION);
    auto locatorAbility = LocatorAbility::GetInstance();
    int ret;
    if (locatorAbility != nullptr) {
        ret = locatorAbility->UpdatePermissionUsedRecord(tokenId, ACCESS_APPROXIMATELY_LOCATION,
            static_cast<int>(type), 0, 1);
        LBSLOGD(LOCATOR, "UpdatePermissionUsedRecord, ret=%{public}d", ret);
    }
    auto requestManager = RequestManager::GetInstance();
    requestManager->DecreaseWorkingPidsCount(identity->GetPid());
    if (requestManager->IsNeedStopUsingPermission(identity->GetPid())) {
        ret = PrivacyKit::StopUsingPermission(tokenId, ACCESS_APPROXIMATELY_LOCATION, identity->GetPid());
        LBSLOGD(LOCATOR, "StopUsingPermission, ret=%{public}d", ret);
    }
}

void LocatorHandler::UpdateSaEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto locatorAbility = LocatorAbility::GetInstance();
    if (locatorAbility != nullptr) {
        locatorAbility->UpdateSaAbilityHandler();
    }
}

void LocatorHandler::InitRequestManagerEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    if (!requestManager->InitSystemListeners()) {
        LBSLOGE(LOCATOR, "InitSystemListeners failed");
    }
}

void LocatorHandler::ApplyRequirementsEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    if (requestManager != nullptr) {
        requestManager->HandleRequest();
    }
}

void LocatorHandler::RetryRegisterActionEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto locatorAbility = LocatorAbility::GetInstance();
    if (locatorAbility != nullptr) {
        locatorAbility->RegisterAction();
        locatorAbility->RegisterLocationPrivacyAction();
    }
}

void LocatorHandler::ReportLocationMessageEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto reportManager = ReportManager::GetInstance();
    if (reportManager != nullptr) {
        std::unique_ptr<LocationMessage> locationMessage = event->GetUniqueObject<LocationMessage>();
        if (locationMessage == nullptr) {
            return;
        }
        std::unique_ptr<Location> location = locationMessage->GetLocation();
        std::string abilityName = locationMessage->GetAbilityName();
        int64_t time = location->GetTimeStamp();
        int64_t timeSinceBoot = location->GetTimeSinceBoot();
        double acc = location->GetAccuracy();
        LBSLOGW(LOCATOR,
            "receive location: [%{public}s time=%{public}s timeSinceBoot=%{public}s acc=%{public}f]",
            abilityName.c_str(), std::to_string(time).c_str(), std::to_string(timeSinceBoot).c_str(), acc);
        reportManager->OnReportLocation(location, abilityName);
        if (abilityName == NETWORK_ABILITY || abilityName == GNSS_ABILITY) {
            reportManager->OnReportLocation(location, PASSIVE_ABILITY);
        }
    }
}

void LocatorHandler::SendSwitchStateToHifenceEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto locatorAbility = LocatorAbility::GetInstance();
    if (locatorAbility != nullptr) {
        int state = event->GetParam();
        if (!SaLoadWithStatistic::InitLocationSa(COMMON_SA_ID)) {
            return;
        }
        MessageParcel data;
        MessageParcel reply;
        MessageOption option;
        if (!data.WriteInterfaceToken(COMMON_DESCRIPTION)) {
            return;
        }
        data.WriteInt32(state);
        sptr<IRemoteObject> object =
                CommonUtils::GetRemoteObject(COMMON_SA_ID, CommonUtils::InitDeviceId());
        if (object == nullptr) {
            return;
        }
        std::string callingIdentity = IPCSkeleton::ResetCallingIdentity();
        object->SendRequest(COMMON_SWITCH_STATE_ID, data, reply, option);
        IPCSkeleton::SetCallingIdentity(callingIdentity);
    }
}

void LocatorHandler::StartLocatingEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    std::shared_ptr<Request> request = event->GetSharedObject<Request>();
    if (request == nullptr) {
        return;
    }
    if (requestManager != nullptr) {
        HookUtils::ExecuteHookWhenStartLocation(request);
        requestManager->HandleStartLocating(request);
    }
}

void LocatorHandler::StopLocatingEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    std::unique_ptr<LocatorCallbackMessage> callbackMessage = event->GetUniqueObject<LocatorCallbackMessage>();
    if (callbackMessage == nullptr) {
        return;
    }
    if (requestManager != nullptr) {
        requestManager->HandleStopLocating(callbackMessage->GetCallback());
    }
}

void LocatorHandler::UnloadSaEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto locationSaLoadManager = LocationSaLoadManager::GetInstance();
    if (locationSaLoadManager != nullptr) {
        locationSaLoadManager->UnloadLocationSa(LOCATION_LOCATOR_SA_ID);
    }
}

void LocatorHandler::StartScanBluetoothDeviceEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    std::unique_ptr<BluetoothScanResultCallbackMessage> callbackMessage =
        event->GetUniqueObject<BluetoothScanResultCallbackMessage>();
    if (callbackMessage == nullptr) {
        return;
    }
    LocatorRequiredDataManager::GetInstance()->StartScanBluetoothDevice(
        callbackMessage->GetCallback(), callbackMessage->GetAppIdentity());
}

void LocatorHandler::StopScanBluetoothDeviceEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    std::unique_ptr<BluetoothScanResultCallbackMessage> callbackMessage =
        event->GetUniqueObject<BluetoothScanResultCallbackMessage>();
    if (callbackMessage == nullptr) {
        return;
    }
    LocatorRequiredDataManager::GetInstance()->StopScanBluetoothDevice(callbackMessage->GetCallback()->AsObject());
}

void LocatorHandler::RegLocationErrorEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    std::unique_ptr<LocatorCallbackMessage> callbackMessage = event->GetUniqueObject<LocatorCallbackMessage>();
    if (callbackMessage == nullptr) {
        return;
    }
    if (requestManager != nullptr) {
        requestManager->RegisterLocationErrorCallback(callbackMessage->GetCallback(),
            callbackMessage->GetAppIdentity());
    }
}

void LocatorHandler::UnRegLocationErrorEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    std::unique_ptr<LocatorCallbackMessage> callbackMessage = event->GetUniqueObject<LocatorCallbackMessage>();
    if (callbackMessage == nullptr) {
        return;
    }
    if (requestManager != nullptr) {
        requestManager->UnRegisterLocationErrorCallback(callbackMessage->GetCallback());
    }
}

void LocatorHandler::ReportNetworkLocatingErrorEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    std::unique_ptr<LocatorErrorMessage> locatorErrorMessage = event->GetUniqueObject<LocatorErrorMessage>();
    if (locatorErrorMessage == nullptr) {
        return;
    }
    auto uuid = locatorErrorMessage->GetUuid();
    auto errCode = locatorErrorMessage->GetErrCode();
    auto errMsg = locatorErrorMessage->GetErrMsg();
    auto requestMap = LocatorAbility::GetInstance()->GetRequests();
    if (requestMap == nullptr || requestMap->empty()) {
        LBSLOGE(REQUEST_MANAGER, "requests map is empty");
        return;
    }
    auto requestListIter = requestMap->find(NETWORK_ABILITY);
    if (requestListIter == requestMap->end()) {
        return;
    }
    auto requestList = requestListIter->second;
    for (auto iter = requestList.begin(); iter != requestList.end(); iter++) {
        auto request = *iter;
        if (uuid.compare(request->GetUuid()) == 0) {
            std::string requestInfo = "";
            if (request->GetRequestConfig() != nullptr) {
                requestInfo = request->GetRequestConfig()->ToString();
            }
            RequestManager::GetInstance()->ReportLocationError(errCode, request);
            WriteLocationInnerEvent(LBS_REQUEST_FAIL_DETAIL, {"REQ_APP_NAME", request->GetPackageName(),
                "TRANS_ID", request->GetUuid(), "ERR_CODE", std::to_string(errCode), "NETWORK_FAIL_CODE_MSG", errMsg});
            break;
        }
    }
}

void LocatorHandler::SyncSwitchStatus(const AppExecFwk::InnerEvent::Pointer& event)
{
    LocationDataRdbManager::SyncSwitchStatus();
}

bool LocatorHandler::IsSwitchObserverReg()
{
    std::unique_lock<ffrt::mutex> lock(isSwitchObserverRegMutex_);
    return isSwitchObserverReg_;
}

void LocatorHandler::SetIsSwitchObserverReg(bool isSwitchObserverReg)
{
    std::unique_lock<ffrt::mutex> lock(isSwitchObserverRegMutex_);
    isSwitchObserverReg_ = isSwitchObserverReg;
}

void LocatorHandler::WatchSwitchParameter(const AppExecFwk::InnerEvent::Pointer& event)
{
    if (IsSwitchObserverReg()) {
        return;
    }
    auto eventCallback = [](const char *key, const char *value, void *context) {
        LocationDataRdbManager::SyncSwitchStatus();
    };

    int ret = WatchParameter(LOCATION_SWITCH_MODE, eventCallback, nullptr);
    if (ret != SUCCESS) {
        LBSLOGE(LOCATOR, "WatchParameter fail");
        return;
    }
    SetIsSwitchObserverReg(true);
}

void LocatorHandler::ProcessEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    uint32_t eventId = event->GetInnerEventId();
    LBSLOGD(LOCATOR, "ProcessEvent event:%{public}d, timestamp = %{public}s",
        eventId, std::to_string(CommonUtils::GetCurrentTimeStamp()).c_str());
    auto handleFunc = locatorHandlerEventMap_.find(eventId);
    if (handleFunc != locatorHandlerEventMap_.end() && handleFunc->second != nullptr) {
        auto memberFunc = handleFunc->second;
#ifdef LOCATION_HICOLLIE_ENABLE
        int tid = gettid();
        std::string moduleName = "LocatorHandler";
        XCollieCallback callbackFunc = [moduleName, eventId, tid](void *) {
            LBSLOGE(LOCATOR, "TimeoutCallback tid:%{public}d moduleName:%{public}s excute eventId:%{public}u timeout.",
                tid, moduleName.c_str(), eventId);
        };
        std::string dfxInfo = moduleName + "_" + std::to_string(eventId) + "_" + std::to_string(tid);
        int timerId = HiviewDFX::XCollie::GetInstance().SetTimer(dfxInfo, TIMEOUT_WATCHDOG, callbackFunc, nullptr,
            HiviewDFX::XCOLLIE_FLAG_LOG|HiviewDFX::XCOLLIE_FLAG_RECOVERY);
        memberFunc(event);
        HiviewDFX::XCollie::GetInstance().CancelTimer(timerId);
#else
        memberFunc(event);
#endif
    } else {
        LBSLOGE(LOCATOR, "ProcessEvent event:%{public}d, unsupport service.", eventId);
    }
}

void LocatorHandler::RequestCheckEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto locatorAbility = LocatorAbility::GetInstance();
    if (locatorAbility != nullptr) {
        locatorAbility->RemoveInvalidRequests();
    }
    SendHighPriorityEvent(EVENT_PERIODIC_CHECK, 0, EVENT_PERIODIC_INTERVAL);
}

void LocatorHandler::SyncStillMovementState(const AppExecFwk::InnerEvent::Pointer& event)
{
    bool state = event->GetParam();
    RequestManager::GetInstance()->SyncStillMovementState(state);
    LocatorRequiredDataManager::GetInstance()->SyncStillMovementState(state);
}

void LocatorHandler::SyncIdleState(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    if (requestManager != nullptr) {
        bool state = event->GetParam();
        requestManager->SyncIdleState(state);
    }
}

void LocatorHandler::SendGeoRequestEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto locatorAbility = LocatorAbility::GetInstance();
    if (locatorAbility != nullptr) {
        std::unique_ptr<GeoConvertRequest> geoConvertRequest = event->GetUniqueObject<GeoConvertRequest>();
        if (geoConvertRequest == nullptr) {
            return;
        }
        MessageParcel dataParcel;
        MessageParcel replyParcel;
        if (!dataParcel.WriteInterfaceToken(GeoConvertProxy::GetDescriptor())) {
            return;
        }
        geoConvertRequest->Marshalling(dataParcel);
        locatorAbility->SendGeoRequest(
            geoConvertRequest->GetRequestType() == GeoCodeType::REQUEST_GEOCODE ?
            static_cast<int>(LocatorInterfaceCode::GET_FROM_LOCATION_NAME) :
            static_cast<int>(LocatorInterfaceCode::GET_FROM_COORDINATE),
            dataParcel, replyParcel);
    }
}

void LocatorHandler::InitMonitorManagerEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
#ifdef MOVEMENT_CLIENT_ENABLE
    LocatorMsdpMonitorManager::GetInstance();
#endif
}

void LocatorHandler::IsStandByEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    auto requestManager = RequestManager::GetInstance();
    if (requestManager != nullptr) {
        requestManager->IsStandby();
    }
}

void LocatorHandler::SetLocationWorkingStateEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    if (!LocationDataRdbManager::SetLocationWorkingState(0)) {
        LBSLOGD(LOCATOR, "LocatorAbility::reset LocationWorkingState failed.");
    }
}

void LocatorHandler::SetSwitchStateToDbEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    int modeValue = event->GetParam();
    if (LocationDataRdbManager::SetSwitchStateToDb(modeValue) != ERRCODE_SUCCESS) {
        LBSLOGE(LOCATOR, "%{public}s: can not set state to db", __func__);
        return;
    }
    auto locatorAbility = LocatorAbility::GetInstance();
    if (locatorAbility != nullptr) {
        locatorAbility->UpdateSaAbility();
        locatorAbility->ApplyRequests(0);
        bool isEnabled = (modeValue == ENABLED);
        std::string state = isEnabled ? "enable" : "disable";
        locatorAbility->ReportDataToResSched(state);
        WriteLocationSwitchStateEvent(state);
    }
}

void LocatorHandler::SetSwitchStateToDbForUserEvent(const AppExecFwk::InnerEvent::Pointer& event)
{
    std::unique_ptr<LocatorSwitchMessage> locatorSwitchMessage = event->GetUniqueObject<LocatorSwitchMessage>();
    if (locatorSwitchMessage == nullptr) {
        return;
    }
    auto modeValue = locatorSwitchMessage->GetModeValue();
    auto userId = locatorSwitchMessage->GetUserId();
    if (LocationDataRdbManager::SetSwitchStateToDbForUser(modeValue, userId) != ERRCODE_SUCCESS) {
        LBSLOGE(LOCATOR, "%{public}s: can not set state to db", __func__);
        return;
    }
    LocatorAbility::GetInstance()->UpdateSaAbility();
    LocatorAbility::GetInstance()->ApplyRequests(0);
    int currentUserId = 0;
    if (CommonUtils::GetCurrentUserId(currentUserId) && userId != currentUserId) {
        return;
    }
    bool isEnabled = (modeValue == ENABLED);
    std::string state = isEnabled ? "enable" : "disable";
    // background task only check the current user switch state
    LocatorAbility::GetInstance()->ReportDataToResSched(state);
    WriteLocationSwitchStateEvent(state);
}

LocatorCallbackDeathRecipient::LocatorCallbackDeathRecipient(int32_t tokenId)
{
    tokenId_ = tokenId;
}

LocatorCallbackDeathRecipient::~LocatorCallbackDeathRecipient()
{
}

void LocatorCallbackDeathRecipient::OnRemoteDied(const wptr<IRemoteObject> &remote)
{
    sptr<ILocatorCallback> callback = iface_cast<ILocatorCallback>(remote.promote());
    auto locatorAbility = LocatorAbility::GetInstance();
    if (locatorAbility != nullptr) {
        locatorAbility->RemoveUnloadTask(DEFAULT_CODE);
        locatorAbility->StopLocating(callback);
        locatorAbility->PostUnloadTask(DEFAULT_CODE);
        LBSLOGI(LOCATOR, "locator callback OnRemoteDied Id = %{public}d", tokenId_);
    }
}

ScanCallbackDeathRecipient::ScanCallbackDeathRecipient()
{
}

ScanCallbackDeathRecipient::~ScanCallbackDeathRecipient()
{
}

void ScanCallbackDeathRecipient::OnRemoteDied(const wptr<IRemoteObject> &remote)
{
    auto locatorDataManager = LocatorRequiredDataManager::GetInstance();
    if (locatorDataManager != nullptr) {
        locatorDataManager->UnregisterCallback(remote.promote());
        LBSLOGI(LOCATOR, "scan callback OnRemoteDied");
    }
}
} // namespace Location
} // namespace OHOS