Sha256: ccc346f974f7e6c8d314b14db9e9355364682907a1ce88bf459e2d28d607a9b8
Contents?: true
Size: 1.14 KB
Versions: 13
Compression:
Stored size: 1.14 KB
Contents
require 'csv'
require 'date'
class TaxJp::WithheldTaxes::BonusDbBuilder < TaxJp::DbBuilder
def initialize(db_path = nil)
@db_path = db_path || TaxJp::WithheldTaxes::Bonus::DB_PATH
end
def run(options = {})
with_database(options) do |db|
Dir.glob(File.join(TaxJp::Utils.data_dir, '源泉徴収税', '源泉徴収税賞与-*.tsv')).each do |filename|
valid_from, valid_until = TaxJp::Utils.filename_to_date(filename)
CSV.foreach(filename, col_sep: "\t") do |row|
next if row[1].to_i == 0 && row[2].to_i == 0
db.execute(insert_sql, [valid_from.to_s, valid_until.to_s] + row.map{|col| TaxJp::Utils.normalize_amount(col)})
end
end
end
end
private
def recreate_schema(db)
db.execute(TaxJp::Utils.load_file(File.join('源泉徴収税', 'schema_bonus.sql')))
end
def insert_sql
ret = 'insert into bonus_withheld_taxes (valid_from, valid_until, tax_ratio, '
8.times do |i|
ret << "dependent_#{i}_salary_from, dependent_#{i}_salary_to, "
end
ret << 'sub_salary_from, sub_salary_to) values (?, ?, ?, '
ret << '?, ' * 16
ret << '?, ?)'
ret
end
end
Version data entries
13 entries across 13 versions & 1 rubygems