openkylin
/
ukui-search
mirror of https://gitee.com/openkylin/ukui-search.git
9
0
Fork 1
Code Issues Projects Releases Wiki Activity

Modify the enqueue method of app info queue.

This commit is contained in:
JunjieBai 2022-08-08 13:57:08 +08:00
parent b1eb17be2a
commit e528b6b3ec
1 changed files with 42 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

59
ukui-search-app-data-service/pending-app-info-queue.cpp
View File

@ -15,18 +15,39 @@ void PendingAppInfoQueue::enqueue(const PendingAppInfo &appInfo)
{ {
QMutexLocker locker(&s_mutex); QMutexLocker locker(&s_mutex);
m_handleTimes++; m_handleTimes++;
int index = m_cache.indexOf(appInfo); int index = m_cache.lastIndexOf(appInfo);
if (index == -1) { if (index == -1) {
m_cache << appInfo; m_cache << appInfo;
} else { } else {
//要插入项操作类型为删除，清除之前所有操作，替换为删除
if (appInfo.handleType() == PendingAppInfo::Delete) {
m_cache.removeAll(appInfo);
m_cache << appInfo;
} else if (m_cache[index].handleType() == PendingAppInfo::Delete) {
//先删后建，分别处理
if (appInfo.handleType() == PendingAppInfo::Insert) {
m_cache << appInfo;
}
} else if (m_cache[index].handleType() <= PendingAppInfo::UpdateLocaleData
and appInfo.handleType() <= PendingAppInfo::UpdateLocaleData) {
//类型为insert, updateall, updatelocaledata时，设置为优先级高的操作类型
if (m_cache[index].handleType() > appInfo.handleType()) {
m_cache.remove(index);
m_cache << appInfo;
}
} else {
m_cache[index].merge(appInfo);
}
/*
//只要操作类型为delete，直接覆盖 //只要操作类型为delete，直接覆盖
if (m_cache[index].handleType() == PendingAppInfo::HandleType::Delete if (m_cache[index].handleType() == PendingAppInfo::Delete
or appInfo.handleType() == PendingAppInfo::HandleType::Delete) { or appInfo.handleType() == PendingAppInfo::Delete) {
m_cache[index].setHandleType(PendingAppInfo::HandleType::Delete); m_cache[index].setHandleType(PendingAppInfo::Delete);
//已插入项操作类型为对所有desktop文件相关数据进行操作 //已插入项操作类型为对所有desktop文件相关数据进行操作
} else if (m_cache[index].handleType() < PendingAppInfo::HandleType::UpdateLocaleData } else if (m_cache[index].handleType() < PendingAppInfo::UpdateLocaleData
and appInfo.handleType() < PendingAppInfo::HandleType::UpdateLocaleData) { and appInfo.handleType() < PendingAppInfo::UpdateLocaleData) {
//设置为优先级高的操作类型 //设置为优先级高的操作类型
if (m_cache[index].handleType() > appInfo.handleType()) { if (m_cache[index].handleType() > appInfo.handleType()) {
m_cache[index].setHandleType(appInfo); m_cache[index].setHandleType(appInfo);
@ -34,6 +55,7 @@ void PendingAppInfoQueue::enqueue(const PendingAppInfo &appInfo)
} else { } else {
m_cache[index].merge(appInfo); m_cache[index].merge(appInfo);
} }
*/
} }
//启动定时器 //启动定时器
@ -103,40 +125,43 @@ void PendingAppInfoQueue::processCache()
if (AppDBManager::getInstance()->startTransaction()) { if (AppDBManager::getInstance()->startTransaction()) {
for (const PendingAppInfo &info : m_pendingAppInfos) { for (const PendingAppInfo &info : m_pendingAppInfos) {
PendingAppInfo::HandleTypes handleTypes = info.handleType(); PendingAppInfo::HandleTypes handleTypes = info.handleType();
if (handleTypes < PendingAppInfo::HandleType::UpdateAll) { if (handleTypes <= PendingAppInfo::UpdateLocaleData) {
switch (handleTypes) { switch (handleTypes) {
case PendingAppInfo::HandleType::Delete: case PendingAppInfo::Delete:
AppDBManager::getInstance()->handleDBItemDelete(info.path()); AppDBManager::getInstance()->handleDBItemDelete(info.path());
break; break;
case PendingAppInfo::HandleType::Insert: case PendingAppInfo::Insert:
AppDBManager::getInstance()->handleDBItemInsert(info.path()); AppDBManager::getInstance()->handleDBItemInsert(info.path());
break; break;
case PendingAppInfo::HandleType::UpdateAll: case PendingAppInfo::UpdateAll:
AppDBManager::getInstance()->handleDBItemUpdate(info.path()); AppDBManager::getInstance()->handleDBItemUpdate(info.path());
break; break;
case PendingAppInfo::UpdateLocaleData:
AppDBManager::getInstance()->handleLocaleDataUpdate(info.path());
break;
default: default:
break; break;
} }
} else { } else {
if (handleTypes & PendingAppInfo::HandleType::Insert) { if (handleTypes & PendingAppInfo::Insert) {
AppDBManager::getInstance()->handleDBItemInsert(info.path()); AppDBManager::getInstance()->handleDBItemInsert(info.path());
} }
if (handleTypes & PendingAppInfo::HandleType::UpdateAll) { if (handleTypes & PendingAppInfo::UpdateAll) {
AppDBManager::getInstance()->handleDBItemUpdate(info.path()); AppDBManager::getInstance()->handleDBItemUpdate(info.path());
} }
if (handleTypes & PendingAppInfo::HandleType::UpdateLocaleData) { if (handleTypes & PendingAppInfo::UpdateLocaleData) {
AppDBManager::getInstance()->handleLocaleDataUpdate(info.path()); AppDBManager::getInstance()->handleLocaleDataUpdate(info.path());
} }
if (handleTypes & PendingAppInfo::HandleType::UpdateLaunchTimes) { if (handleTypes & PendingAppInfo::UpdateLaunchTimes) {
AppDBManager::getInstance()->handleLaunchTimesUpdate(info.path(), info.launchTimes()); AppDBManager::getInstance()->handleLaunchTimesUpdate(info.path(), info.launchTimes());
} }
if (handleTypes & PendingAppInfo::HandleType::UpdateFavorites) { if (handleTypes & PendingAppInfo::UpdateFavorites) {
AppDBManager::getInstance()->handleFavoritesStateUpdate(info.path(), info.favoritesState()); AppDBManager::getInstance()->handleFavoritesStateUpdate(info.path(), info.favoritesState());
} }
if (handleTypes & PendingAppInfo::HandleType::UpdateTop) { if (handleTypes & PendingAppInfo::UpdateTop) {
AppDBManager::getInstance()->handleTopStateUpdate(info.path(), info.topState()); AppDBManager::getInstance()->handleTopStateUpdate(info.path(), info.topState());
} }
if (handleTypes & PendingAppInfo::HandleType::UpdateLock) { if (handleTypes & PendingAppInfo::UpdateLock) {
AppDBManager::getInstance()->handleLockStateUpdate(info.path(), info.lockState()); AppDBManager::getInstance()->handleLockStateUpdate(info.path(), info.lockState());
} }
} }