david
1268889a78
- Implement EloCalculator service for 2v2 Euchre matches - Create background job processing with GoodJob - Add single match entry form - Add CSV upload for batch match entry - Create player rankings view - Add database schema for matches and elo snapshots
87 lines
2.8 KiB
Ruby
87 lines
2.8 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "csv"
|
|
|
|
module EuchreCamp
|
|
module Actions
|
|
module Admin
|
|
module Matches
|
|
class ProcessUpload < EuchreCamp::Action
|
|
include Deps[repo: 'repositories.matches']
|
|
|
|
def handle(request, response)
|
|
# In Hanami, file uploads are in request.params
|
|
file = request.params[:csv_file]
|
|
|
|
unless file && file[:tempfile]
|
|
response.redirect_to("/admin/matches/upload")
|
|
return
|
|
end
|
|
|
|
matches_created = 0
|
|
errors = []
|
|
|
|
# Parse CSV
|
|
CSV.foreach(file[:tempfile].path, headers: true, header_converters: :symbol) do |row|
|
|
begin
|
|
# Map CSV columns to our database structure
|
|
# Expected columns: played_at, team_1_p1_name, team_1_p2_name, team_1_score, team_2_p1_name, team_2_p2_name, team_2_score
|
|
|
|
# Find or create players by name
|
|
player_1 = find_or_create_player(row[:team_1_p1_name])
|
|
player_2 = find_or_create_player(row[:team_1_p2_name])
|
|
player_3 = find_or_create_player(row[:team_2_p1_name])
|
|
player_4 = find_or_create_player(row[:team_2_p2_name])
|
|
|
|
played_at = begin
|
|
Time.parse(row[:played_at])
|
|
rescue
|
|
Time.now
|
|
end
|
|
|
|
match_data = {
|
|
played_at: played_at,
|
|
team_1_p1_id: player_1[:id],
|
|
team_1_p2_id: player_2[:id],
|
|
team_1_score: row[:team_1_score].to_i,
|
|
team_2_p1_id: player_3[:id],
|
|
team_2_p2_id: player_4[:id],
|
|
team_2_score: row[:team_2_score].to_i,
|
|
status: 'completed'
|
|
}
|
|
|
|
match = repo.create(match_data)
|
|
EuchreCamp::Jobs::CalculateEloJob.perform_later(match[:id])
|
|
matches_created += 1
|
|
|
|
rescue => e
|
|
errors << "Row #{row}: #{e.message}"
|
|
end
|
|
end
|
|
|
|
response.flash[:message] = "Created #{matches_created} matches.#{' Errors: ' + errors.join(', ') if errors.any?}"
|
|
response.redirect_to("/admin/matches")
|
|
end
|
|
|
|
private
|
|
|
|
def find_or_create_player(name)
|
|
rom = EuchreCamp::App["persistence.rom"]
|
|
return nil unless name
|
|
|
|
name = name.strip
|
|
player = rom.relations[:players].where(name: name).one
|
|
|
|
if player
|
|
player
|
|
else
|
|
rom.relations[:players].insert(name: name, rating: 0, current_elo: 1000)
|
|
rom.relations[:players].where(name: name).one
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|