internal/dao/taskDao.go

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