fixed 组织流水线运行数据控制

app/controllers/api/pm/pipelines_controller.rb

@@ -16,57 +16,54 @@ class Api::Pm::PipelinesController < Api::Pm::BaseController
     db_files = pipelines.pluck(:file_name)
     @run_result = []
     run_files.each do |file_info|
-      # file = file_info.workflow_id
+      file = file_info.workflow_id
       project = Project.find_by(gpid: file_info.repo_id)
       next if project.blank?
-      files = $gitea_client.get_repos_contents_by_owner_repo_filepath(project&.owner&.login, project&.identifier, ".gitea/workflows") rescue []
-      files.map { |i| i['name'] }.each do |file|
-        unless db_files.include?(".gitea/workflows/#{file}")
-          pipeline = Action::Pipeline.find_or_initialize_by(pipeline_name: file.to_s.gsub(".yml", "").gsub(".yaml", ""),
-                                                            file_name: ".gitea/workflows/#{file}",
-                                                            branch: project.default_branch,
-                                                            is_graphic_design: false,
-                                                            disable: false,
-                                                            project_id: project.id)
-          interactor = Repositories::EntriesInteractor.call(@owner, project.identifier, ".gitea/workflows/#{file}", ref: project.default_branch)
-          if interactor.success?
-            pipeline.yaml = decode64_content(interactor.result, @owner, project.repository, project.default_branch, nil)
-          end
-          pipeline.user_id  = current_user.id
-          pipeline.save
-          # 导入的流水线统一先禁用
-          $gitea_hat_client.post_repos_actions_disable(project&.owner&.login, project&.identifier, {query: {workflow: file}}) rescue nil
+      unless db_files.include?(".gitea/workflows/#{file}")
+        pipeline = Action::Pipeline.find_or_initialize_by(pipeline_name: file.to_s.gsub(".yml", "").gsub(".yaml", ""),
+                                        file_name: ".gitea/workflows/#{file}",
+                                        branch: project.default_branch,
+                                        is_graphic_design: false,
+                                        disable: false,
+                                        project_id: project.id)
+        interactor = Repositories::EntriesInteractor.call(@owner, project.identifier, ".gitea/workflows/#{file}", ref: project.default_branch)
+        if interactor.success?
+          pipeline.yaml = decode64_content(interactor.result, @owner, project.repository, project.default_branch, nil)
         end
-        last_action_run = action_runs.where(repo_id: project.gpid).where(workflow_id: file).order(updated: :desc).first
-        last_action_run_json = last_action_run.present? ? {
-          id: last_action_run.id,
-          schedule: last_action_run.schedule_id > 0,
-          title: last_action_run.title,
-          index: last_action_run.index,
-          status: last_action_run.status,
-          started: last_action_run.started,
-          stopped: last_action_run.stopped,
-          length: last_action_run.stopped-last_action_run.started,
-          created: last_action_run.created,
-          updated: last_action_run.updated,
-        } : {}
-
-        total = 0
-        success = 0
-        failure = 0
-        group_data.each do |k,v|
-          total += v if k[0] == file
-          success += v if k[0] == file && k[1] == 1
-          failure += v if k[0] == file && k[1] == 2
-        end
-        @run_result << {
-          repo_id: last_action_run.repo_id,
-          filename: ".gitea/workflows/#{file}",
-          total: total,
-          success: success,
-          failure: failure
-        }.merge(last_action_run_json)
+        pipeline.user_id  = current_user.id
+        pipeline.save
+        # 导入的流水线统一先禁用
+        $gitea_hat_client.post_repos_actions_disable(project&.owner&.login, project&.identifier, {query: {workflow: file}}) rescue nil
       end
+      last_action_run = action_runs.where(repo_id: project.gpid).where(workflow_id: file).order(updated: :desc).first
+      last_action_run_json = last_action_run.present? ? {
+        id: last_action_run.id,
+        schedule: last_action_run.schedule_id > 0,
+        title: last_action_run.title,
+        index: last_action_run.index,
+        status: last_action_run.status,
+        started: last_action_run.started,
+        stopped: last_action_run.stopped,
+        length: last_action_run.stopped-last_action_run.started,
+        created: last_action_run.created,
+        updated: last_action_run.updated,
+      } : {}
+
+      total = 0
+      success = 0
+      failure = 0
+      group_data.each do |k,v|
+        total += v if k[0] == file
+        success += v if k[0] == file && k[1] == 1
+        failure += v if k[0] == file && k[1] == 2
+      end
+      @run_result << {
+        repo_id: last_action_run.repo_id,
+        filename: ".gitea/workflows/#{file}",
+        total: total,
+        success: success,
+        failure: failure
+      }.merge(last_action_run_json)
     end
     # Rails.logger.info("@run_result======#{@run_result}")
     @disabled_workflows = Gitea::RepoUnit.where(repo_id: project_gpids, type: 10).where("config is not null")

app/views/api/pm/pipelines/index.json.jbuilder

@@ -19,7 +19,11 @@ json.projects @pipelines.map(&:project_id).uniq.each do |project_id|
         json.disable pipeline.disable
       end
       json.pipeline_type pipeline.pipeline_type
-      json.run_data @run_result.select { |result| result[:repo_id] == project.gpid && result[:filename] == pipeline.file_name}.first
+      if pipeline.json.blank? && pipeline.yaml.blank?
+        json.run_data nil
+      else
+        json.run_data @run_result.select { |result| result[:repo_id] == project.gpid && result[:filename] == pipeline.file_name}.first
+      end
     end
   end
 end