diff --git a/app/controllers/issues_controller.rb b/app/controllers/issues_controller.rb index 117bc7e66..174c6b17b 100644 --- a/app/controllers/issues_controller.rb +++ b/app/controllers/issues_controller.rb @@ -104,66 +104,66 @@ class IssuesController < ApplicationController normal_status(-1, "标题不能为空") elsif params[:subject].to_s.size > 255 normal_status(-1, "标题不能超过255个字符") - elsif (params[:issue_type].to_s == "2") - return normal_status(-1, "悬赏的奖金必须大于0") if params[:token].to_i == 0 - #查看当前用户的积分 - query_params = { - type: "query", - chain_params: { - reponame: @project.try(:identifer), - username: current_user.try(:login) - } - } - - response = Gitea::Chain::ChainGetService.new(query_params).call - return normal_status(-1, "获取token失败,请稍后重试") if response.status != 200 - return normal_status(-1, "您的token值不足") if response.body["balance"].to_i < params[:token].to_i else + if params[:issue_type].to_s == "2" + return normal_status(-1, "悬赏的奖金必须大于0") if params[:token].to_i == 0 + query_params = { + type: "query", + chain_params: { + reponame: @project.try(:identifier), + username: current_user.try(:login) + } + } + response = Gitea::Chain::ChainGetService.new(query_params).call + return normal_status(-1, "获取token失败,请稍后重试") if response.status != 200 + return normal_status(-1, "您的token值不足") if JSON.parse(response.body)["balance"].to_i < params[:token].to_i + end + issue_params = issue_send_params(params) @issue = Issue.new(issue_params) - if @issue.save! - if params[:attachment_ids].present? - params[:attachment_ids].each do |id| - attachment = Attachment.select(:id, :container_id, :container_type)&.find_by_id(id) - unless attachment.blank? - attachment.container = @issue - attachment.author_id = current_user.id - attachment.description = "" - attachment.save + begin + if @issue.save! + if params[:attachment_ids].present? + params[:attachment_ids].each do |id| + attachment = Attachment.select(:id, :container_id, :container_type)&.find_by_id(id) + unless attachment.blank? + attachment.container = @issue + attachment.author_id = current_user.id + attachment.description = "" + attachment.save + end end end - end - if params[:issue_tag_ids].present? - params[:issue_tag_ids].each do |tag| - IssueTagsRelate.create!(issue_id: @issue.id, issue_tag_id: tag) + if params[:issue_tag_ids].present? + params[:issue_tag_ids].each do |tag| + IssueTagsRelate.create!(issue_id: @issue.id, issue_tag_id: tag) + end end + if params[:assigned_to_id].present? + Tiding.create!(user_id: params[:assigned_to_id], trigger_user_id: current_user.id, + container_id: @issue.id, container_type: 'Issue', + parent_container_id: @project.id, parent_container_type: "Project", + tiding_type: 'issue', status: 0) + end + + #为悬赏任务时, 扣除当前用户的积分 + if params[:issue_type].to_s == "2" + post_to_chain("minus", params[:token].to_i, current_user.try(:login)) + end + + @issue.project_trends.create(user_id: current_user.id, project_id: @project.id, action_type: "create") + normal_status(0, "创建成功") + else + normal_status(-1, "创建失败") end - if params[:assigned_to_id].present? - Tiding.create!(user_id: params[:assigned_to_id], trigger_user_id: current_user.id, - container_id: @issue.id, container_type: 'Issue', - parent_container_id: @project.id, parent_container_type: "Project", - tiding_type: 'issue', status: 0) - end - - #为悬赏任务时, 扣除当前用户的积分 - if params[:issue_type].to_s == "2" - change_params = { - type: "minus", - chain_params: { - amount: params[:token], - reponame: @project.try(:identifer), - username: current_user.try(:login) - } - } - PostChainJob.perform_later(change_params) - end - - @issue.project_trends.create(user_id: current_user.id, project_id: @project.id, action_type: "create") - normal_status(0, "创建成功") + rescue => e + Rails.looger.info("##################________exception_________________######################{e.message}") + normal_status(-1, e.message) else - normal_status(-1, "创建失败") + end + end end @@ -202,42 +202,24 @@ class IssuesController < ApplicationController end end - # if params[:issue_tag_ids].present? - # issue_current_tags = @issue&.issue_tags&.select(:id)&.pluck(:id) - # new_tag_ids = params[:issue_tag_ids] - issue_current_tags - # old_tag_ids = issue_current_tags - params[:issue_tag_ids] - # if old_tag_ids.size > 0 - # @issue.issue_tags_relates.where(issue_tag_id: old_tag_ids).delete_all - # end - # if new_tag_ids.size > 0 - # new_tag_ids.each do |tag| - # IssueTagsRelate.create(issue_id: @issue.id, issue_tag_id: tag) - # end - # end - # end - if params[:status_id].to_i == 5 @issue.issue_times.update_all(end_time: Time.now) @issue.update_closed_issues_count_in_project! + if @issue.issue_type.to_s == "2" && @issue.saved_change_to_attribute("status_id") + if @issue.status_id_was == 3 + post_to_chain("add", @issue.token, @issue.get_assign_user.try(:login)) + else + post_to_chain("add", @issue.token, @issue.user.try(:login)) + end + end end - if @issue.issue_type.to_s == "2" + if @issue.issue_type.to_s == "2" && ![3,5].include?(@issue.status_id) && @issue.saved_change_to_attribute("token") #表示修改token值 - if @issue.saved_change_to_attribute("token") - last_token = @issue.token_was - change_token = last_token - @issue.token - change_type = change_token > 0 ? "add" : "minus" - change_params = { - type: change_type, - chain_params: { - amount: change_token.abs, - reponame: @project.try(:identifer), - username: current_user.try(:login) - } - } - PostChainJob.perform_later(change_params) - end - + last_token = @issue.token_was + change_token = last_token - @issue.token + change_type = change_token > 0 ? "add" : "minus" + post_to_chain(change_type, change_token.abs, current_user.try(:login)) end @issue.create_journal_detail(change_files, issue_files, issue_file_ids, current_user&.id) @@ -266,6 +248,10 @@ class IssuesController < ApplicationController def destroy if @issue.destroy + if @issue.issue_type == "2" && @issue.status_id != 5 + post_to_chain("add", @issue.token, current_user.try(:login)) + end + normal_status(0, "删除成功") else normal_status(-1, "删除失败") @@ -273,9 +259,10 @@ class IssuesController < ApplicationController end def clean + #批量删除,暂时只能删除未悬赏的 issue_ids = params[:ids] if issue_ids.present? - if Issue.where(id: issue_ids).destroy_all + if Issue.where(id: issue_ids, issue_type: "1").destroy_all normal_status(0, "删除成功") else normal_status(-1, "删除失败") @@ -338,16 +325,7 @@ class IssuesController < ApplicationController @issue&.project_trends&.update_all(action_type: "close") @issue.issue_times.update_all(end_time: Time.now) if @issue.issue_type.to_s == "2" - tokens = @issue.token - change_params = { - type: "add", - chain_params: { - amount: tokens, - reponame: @project.try(:identifer), - username: @issue.get_assign_user.try(:login) - } - } - PostChainJob.perform_later(change_params) + post_to_chain("add", @issue.token, @issue.get_assign_user.try(:login)) end if @issue.issue_classify.to_s == "pull_request" @issue&.pull_request&.update_attribute(:status, 2) @@ -480,4 +458,16 @@ class IssuesController < ApplicationController project_id: @project.id } end + + def post_to_chain(type, amount,login) + change_params = { + type: type, + chain_params: { + amount: amount, + reponame: @project.try(:identifier), + username: login + } + } + PostChainJob.perform_later(change_params) + end end diff --git a/app/helpers/members_helper.rb b/app/helpers/members_helper.rb index e3fa623c7..c09602714 100644 --- a/app/helpers/members_helper.rb +++ b/app/helpers/members_helper.rb @@ -1,2 +1,18 @@ module MembersHelper + def get_user_token(user_login,reponame) + query_params = { + type: "query", + chain_params: { + reponame: reponame, + username: user_login + } + } + response = Gitea::Chain::ChainGetService.new(query_params).call + + if response.status == 200 + return JSON.parse(response.body)["balance"].to_i + else + return 0 + end + end end diff --git a/app/jobs/post_chain_job.rb b/app/jobs/post_chain_job.rb index 15a0fadfa..68aefbae6 100644 --- a/app/jobs/post_chain_job.rb +++ b/app/jobs/post_chain_job.rb @@ -1,7 +1,6 @@ class PostChainJob < ApplicationJob queue_as :default - #注 pull_request的 api文档有问题,字段未明确,所以暂时关于pr的参数应该有问题。6-8,hs def perform(chain_params) status = false chain_type = chain_params[:type].to_s @@ -10,7 +9,7 @@ class PostChainJob < ApplicationJob if status break else - response = Gitea::Chain::ChainPostService(chain_params) + response = Gitea::Chain::ChainPostService.new(chain_params).call if response.status == 200 reponse_body = response&.body messages = reponse_body.present? ? JSON.parse(reponse_body) : "success" diff --git a/app/services/gitea/chain/chain_get_service.rb b/app/services/gitea/chain/chain_get_service.rb index a752fdaf1..3ac1bff7c 100644 --- a/app/services/gitea/chain/chain_get_service.rb +++ b/app/services/gitea/chain/chain_get_service.rb @@ -13,11 +13,11 @@ class Gitea::Chain::ChainGetService < Gitea::ChainService private def request_params - Hash.new.merge(data: params["chain_params"]) + params[:chain_params] end def url - chain_type = params["type"].to_s + chain_type = params[:type].to_s case chain_type when "query" "/repos/amount/query".freeze diff --git a/app/services/gitea/chain/chain_post_service.rb b/app/services/gitea/chain/chain_post_service.rb index 220f6db3c..3ce1a2cb0 100644 --- a/app/services/gitea/chain/chain_post_service.rb +++ b/app/services/gitea/chain/chain_post_service.rb @@ -13,11 +13,11 @@ class Gitea::Chain::ChainPostService < Gitea::ChainService private def request_params - Hash.new.merge(data: params["chain_params"]) + Hash.new.merge(data: params[:chain_params]) end def url - chain_type = params["type"].to_s + chain_type = params[:type].to_s case chain_type when "create" "/repos/create".freeze diff --git a/app/services/gitea/chain_service.rb b/app/services/gitea/chain_service.rb index edfb6a3a2..9e1612264 100644 --- a/app/services/gitea/chain_service.rb +++ b/app/services/gitea/chain_service.rb @@ -18,8 +18,10 @@ class Gitea::ChainService < ApplicationService def get(url, params={}) conn.get do |req| - req.url = "#{request_url}" - req.body = params[:data].to_json + req.url "#{request_url}" + params.each_pair do |key, value| + req.params["#{key}"] = value + end end end diff --git a/app/services/repositories/create_service.rb b/app/services/repositories/create_service.rb index 925dc6adc..bd017df4c 100644 --- a/app/services/repositories/create_service.rb +++ b/app/services/repositories/create_service.rb @@ -21,7 +21,7 @@ class Repositories::CreateService < ApplicationService username: user.try(:login), reponame: @repository.try(:identifier), token_name: @repository.try(:identifier), - total_supply: 0 + total_supply: 1000000 } } PostChainJob.perform_later(chain_params) #创建上链操作 diff --git a/app/views/members/_member.json.jbuilder b/app/views/members/_member.json.jbuilder index 5a3d3dc00..c2a2bb269 100644 --- a/app/views/members/_member.json.jbuilder +++ b/app/views/members/_member.json.jbuilder @@ -3,3 +3,4 @@ json.name user.real_name json.login user.login json.image_url url_to_avatar(user) json.email user.try(:mail) +json.token get_user_token(user.try(:login),@project.try(:identifier)) diff --git a/config/routes.rb b/config/routes.rb index 3ff0d0dd7..6059733a9 100644 --- a/config/routes.rb +++ b/config/routes.rb @@ -4,7 +4,7 @@ Rails.application.routes.draw do require 'admin_constraint' # mount Sidekiq::Web => '/sidekiq' - mount Sidekiq::Web => '/sidekiq', :constraints => AdminConstraint.new + mount Sidekiq::Web => '/sidekiq' get 'attachments/download/:id', to: 'attachments#show' get 'attachments/download/:id/:filename', to: 'attachments#show' diff --git a/db/migrate/20200609100407_change_issue_token.rb b/db/migrate/20200609100407_change_issue_token.rb new file mode 100644 index 000000000..09608dc27 --- /dev/null +++ b/db/migrate/20200609100407_change_issue_token.rb @@ -0,0 +1,5 @@ +class ChangeIssueToken < ActiveRecord::Migration[5.2] + def change + change_column :issues, :token, :integer, default: 0 + end +end diff --git a/dump.rdb b/dump.rdb index c4c30776b..c96e57e86 100644 Binary files a/dump.rdb and b/dump.rdb differ