Method finalizeScanFailure

api/service/skill_library_scan.go:964–1001

(jobID int64, scanModel, message, payload string, retryable bool)

}

func (s *SkillLibraryService) finalizeScanFailure(jobID int64, scanModel, message, payload string, retryable bool) error {
	if jobID <= 0 || model.DB == nil {
		return nil
	}
	logger.Warnf(context.Background(), "【技能运行】扫描失败: job_id=%d message=%s retryable=%v", jobID, message, retryable)

	now := s.nowFunc().UTC().UnixMilli()
	var job model.SkillScanJob
	if err := model.DB.Where("id = ?", jobID).First(&job).Error; err != nil {
		return err
	}

	status := model.SkillScanJobStatusFailed
	retryCount := job.RetryCount
	startedTime := job.StartedTime
	finishedTime := now

	if retryable && job.RetryCount < skillScanMaxRetry {
		status = model.SkillScanJobStatusPending
		retryCount = job.RetryCount + 1
		startedTime = 0
		finishedTime = 0
	}

	updates := map[string]interface{}{
		"status":        status,
		"retry_count":   retryCount,
		"started_time":  startedTime,
		"finished_time": finishedTime,
		"message":       message,
		"scan_model":    scanModel,
		"updated_time":  now,
	}
	if payload != "" {
		updates["scan_payload"] = payload
	}
	return model.DB.Model(&model.SkillScanJob{}).Where("id = ?", jobID).Updates(updates).Error
}

func (s *SkillLibraryService) recoverStaleRunningJobs(ctx context.Context) error {
	_ = ctx