floraachy
/
pcm-coordinator
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge pull request 'fix task bugs' (#201) from tzwang/pcm-coordinator:master into master 

Former-commit-id: 1cbcfb05bd9e498fac30e75d60152ad4bf2e2ac4
This commit is contained in:
tzwang 2024-05-22 11:55:55 +08:00
parent f70207a2a4 7fcfcfe7ac
commit 969fb1d832
1 changed files with 2 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
api/internal/logic/core/pagelisttasklogic.go
View File

@ -120,6 +120,7 @@ func (l *PageListTaskLogic) updateTaskStatus(tasklist []*types.TaskModel, ch cha
tx = l.svcCtx.DbEngin.Model(task).Table("task").Where("deleted_at is null").Updates(task) tx = l.svcCtx.DbEngin.Model(task).Table("task").Where("deleted_at is null").Updates(task)
if tx.Error != nil { if tx.Error != nil {
logx.Errorf(tx.Error.Error()) logx.Errorf(tx.Error.Error())
ch <- struct{}{}
return return
} }
ch <- struct{}{} ch <- struct{}{}
@ -138,6 +139,7 @@ func (l *PageListTaskLogic) updateTaskStatus(tasklist []*types.TaskModel, ch cha
tx = l.svcCtx.DbEngin.Model(task).Table("task").Where("deleted_at is null").Updates(task) tx = l.svcCtx.DbEngin.Model(task).Table("task").Where("deleted_at is null").Updates(task)
if tx.Error != nil { if tx.Error != nil {
logx.Errorf(tx.Error.Error()) logx.Errorf(tx.Error.Error())
ch <- struct{}{}
return return
} }
ch <- struct{}{} ch <- struct{}{}