cmd/logic/PollScheduleTask.go

@@ -24,18 +24,6 @@ func (c *ScheduleTaskLogic) PollScheduleTask() {
 	log.GetLogger().Info("查询到执行记录", zap.Int("记录数量", len(executionRecords)))
 
 	for _, executionRecord := range executionRecords {
-
-		finalResultSet := make(map[int]struct{}, 2) //所有作品的发布状态
-		finalResult := 0                            //所有作品发布状态的最终结果
-		//查看是否有作品数量不够的
-		count := int64(0)
-		if err := db.CronDB.Model(&model.ExecutionResult{}).
-			Where(&model.ExecutionResult{Status: 2}). //查看处理中的记录
-			Where("execution_id = ?", executionRecord.ID).Count(&count).Error; err != nil {
-		}
-		if count > 0 {
-			finalResultSet[model.ExecutionRecordResultFailure] = struct{}{}
-		}
 		executionResult := make([]model.ExecutionResult, 0, 4)
 		if err := db.CronDB.Model(&model.ExecutionResult{}).
 			Where(&model.ExecutionResult{Status: 1}). //查看处理中的记录
@@ -63,6 +51,8 @@ func (c *ScheduleTaskLogic) PollScheduleTask() {
 				workUUIDResult[v.WorkUUID] = true
 			}
 		}
+		finalResultSet := make(map[int]struct{}, 2) //所有作品的发布状态
+		finalResult := 0                            //所有作品发布状态的最终结果
 		for _, v := range uuids {
 			now = time.Now()
 			result := 0 //作品的发布状态