fiee/micro-bundle
9
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'feat-cjy-taskBench' into dev

Browse Source
This commit is contained in:
cjy 2025-10-22 18:13:03 +08:00
commit cc63ba31a0
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
internal/dao/taskDao.go
View File

@ -506,6 +506,7 @@ func UpdateTaskProgress(req *CompleteTaskRequest) error {
) )
} }
updateData["complete_video_count"] = newCompleteCount updateData["complete_video_count"] = newCompleteCount
updateData["pending_video_count"] = assignRecord.PendingVideoCount - req.CompleteCount
case "post": case "post":
newCompleteCount := assignRecord.CompletePostCount + req.CompleteCount newCompleteCount := assignRecord.CompletePostCount + req.CompleteCount
if newCompleteCount > assignRecord.AssignPostCount { if newCompleteCount > assignRecord.AssignPostCount {
@ -521,6 +522,7 @@ func UpdateTaskProgress(req *CompleteTaskRequest) error {
) )
} }
updateData["complete_post_count"] = newCompleteCount updateData["complete_post_count"] = newCompleteCount
updateData["pending_post_count"] = assignRecord.PendingPostCount - req.CompleteCount
case "data": case "data":
newCompleteCount := assignRecord.CompleteDataCount + req.CompleteCount newCompleteCount := assignRecord.CompleteDataCount + req.CompleteCount
if newCompleteCount > assignRecord.AssignDataCount { if newCompleteCount > assignRecord.AssignDataCount {
@ -536,6 +538,7 @@ func UpdateTaskProgress(req *CompleteTaskRequest) error {
) )
} }
updateData["complete_data_count"] = newCompleteCount updateData["complete_data_count"] = newCompleteCount
updateData["pending_data_count"] = assignRecord.PendingDataCount - req.CompleteCount
default: default:
tx.Rollback() tx.Rollback()
return commonErr.ReturnError(nil, "无效的任务类型", "任务类型必须是video、post或data") return commonErr.ReturnError(nil, "无效的任务类型", "任务类型必须是video、post或data")
@ -976,9 +979,9 @@ func UpdatePendingCount(req *UpdatePendingCountRequest) error {
PendingVideoCount: req.PendingVideoCount, PendingVideoCount: req.PendingVideoCount,
PendingPostCount: req.PendingPostCount, PendingPostCount: req.PendingPostCount,
PendingDataCount: req.PendingDataCount, PendingDataCount: req.PendingDataCount,
AssignVideoCount: 0, AssignVideoCount: req.PendingVideoCount,
AssignPostCount: 0, AssignPostCount: req.PendingPostCount,
AssignDataCount: 0, AssignDataCount: req.PendingDataCount,
CompleteVideoCount: 0, CompleteVideoCount: 0,
CompletePostCount: 0, CompletePostCount: 0,
CompleteDataCount: 0, CompleteDataCount: 0,