forked from Gitlink/forgeplus
87 lines
4.5 KiB
Ruby
87 lines
4.5 KiB
Ruby
class Api::Pm::PipelinesController < Api::Pm::BaseController
|
|
include RepositoriesHelper
|
|
|
|
def index
|
|
@owner = Owner.find_by(login: params[:owner_id].to_s) || Owner.find_by(id: params[:owner_id].to_s)
|
|
tip_exception('组织未找到') if @owner.blank?
|
|
unless @owner.is_a?(Organization) && @owner.is_member?(current_user.id)
|
|
tip_exception('没有查看组织的权限')
|
|
end
|
|
@project_ids = @owner.projects.ids
|
|
if params[:project_ids].present?
|
|
@project_ids = params[:project_ids].split(",")
|
|
end
|
|
projects = Project.where(id: @project_ids)
|
|
projects = projects.where(is_public: ActiveModel::Type::Boolean.new.cast(params[:is_public])) if params[:is_public].present?
|
|
project_gpids = projects.pluck(:gpid)
|
|
@project_ids = projects.ids
|
|
action_runs = Gitea::ActionRun.where(owner_id: @owner.gitea_uid)
|
|
group_data = action_runs.where(status: [1,2]).group(:workflow_id, :status, :repo_id).count
|
|
pipelines = Action::Pipeline.where(project_id: @project_ids).order(updated_at: :desc)
|
|
run_files = Gitea::ActionRun.select(:workflow_id, :repo_id).where(owner_id: @owner.gitea_uid).group(:workflow_id, :repo_id)
|
|
db_files = pipelines.pluck(:file_name)
|
|
@run_result = []
|
|
run_files.each do |file_info|
|
|
file = file_info.workflow_id
|
|
project = Project.find_by(gpid: file_info.repo_id)
|
|
next if project.blank?
|
|
if params[:generate_actions].present?
|
|
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,
|
|
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)
|
|
file = interactor.result
|
|
pipeline.sha = file['content']['sha']
|
|
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
|
|
end
|
|
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.zero? ? Time.now.to_i : last_action_run.started,
|
|
stopped: last_action_run.stopped.zero? ? Time.now.to_i : last_action_run.stopped,
|
|
length: last_action_run.stopped.zero? ? 0 : 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 && k[2] == file_info.repo_id
|
|
success += v if k[0] == file && k[1] == 1 && k[2] == file_info.repo_id
|
|
failure += v if k[0] == file && k[1] == 2 && k[2] == file_info.repo_id
|
|
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")
|
|
@pipelines = Action::Pipeline.select("distinct project_id,max(updated_at) as updated_at, max(created_at) as created_at")
|
|
.where(project_id: @project_ids).group(:project_id).order("created_at desc")
|
|
@pipelines = @pipelines.where("pipeline_name like ?", "%#{params[:pipeline_name]}%") if params[:pipeline_name].present?
|
|
@pipelines = @pipelines.where(pipeline_type: params[:pipeline_type]) if params[:pipeline_type].present?
|
|
@pipelines = kaminari_paginate(@pipelines)
|
|
end
|
|
|
|
end
|