starred/1Panel
1
0
Fork 0
mirror of https://github.com/1Panel-dev/1Panel.git synced 2026-09-22 16:00:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

f (#11834)

Browse Source
This commit is contained in:
KOMATA
2026-02-09 15:33:05 +08:00
committed by GitHub
parent 4b1f643c70
commit 537ff49c0b
1 changed files with 13 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files
agent/app/service/app_sync_task.go
+13 -25
View File
@@ -427,10 +427,13 @@ func (c *appSyncContext) classifyAndPersistAppsWithStats(addCount, updateCount,
for _, tag := range app.TagsKey {
tagId, ok := tagMap[tag]
if ok {
c.appTags = append(c.appTags, &model.AppTag{
AppId: app.ID,
TagId: tagId,
})
exist, _ := appTagRepo.GetFirst(ctx, appTagRepo.WithByTagID(tagId), appTagRepo.WithByAppID(app.ID))
if exist == nil {
c.appTags = append(c.appTags, &model.AppTag{
AppId: app.ID,
TagId: tagId,
})
}
}
}
@@ -479,29 +482,14 @@ func (c *appSyncContext) classifyAndPersistAppsWithStats(addCount, updateCount,
}
}
if len(c.appTags) > 0 {
syncedAppIds := make([]uint, 0, len(addAppArray)+len(updateAppArray)+len(deleteIds))
for _, app := range addAppArray {
if app.ID > 0 && app.Resource == constant.AppResourceRemote {
syncedAppIds = append(syncedAppIds, app.ID)
}
}
for _, app := range updateAppArray {
if app.Resource == constant.AppResourceRemote {
syncedAppIds = append(syncedAppIds, app.ID)
}
}
syncedAppIds = append(syncedAppIds, deleteIds...)
if len(syncedAppIds) > 0 {
if err = appTagRepo.DeleteByAppIds(ctx, syncedAppIds); err != nil {
return
}
}
if err = appTagRepo.BatchCreate(ctx, c.appTags); err != nil {
if len(c.oldAppIds) > 0 {
if err = appTagRepo.DeleteByAppIds(ctx, deleteIds); err != nil {
return
}
} else if len(deleteIds) > 0 {
if err = appTagRepo.DeleteByAppIds(ctx, deleteIds); err != nil {
}
if len(c.appTags) > 0 {
if err = appTagRepo.BatchCreate(ctx, c.appTags); err != nil {
return
}
}