create api_entreprise jobs

app/jobs/api_entreprise/association_job.rb

@@ -0,0 +1,7 @@
+class ApiEntreprise::AssociationJob < ApplicationJob
+  def perform(etablissement_id, procedure_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::RNAAdapter.new(etablissement.siret, procedure_id).to_params
+    etablissement.update!(etablissement_params)
+  end
+end

app/jobs/api_entreprise/attestation_fiscale_job.rb

@@ -0,0 +1,8 @@
+class ApiEntreprise::AttestationFiscaleJob < ApplicationJob
+  def perform(etablissement_id, procedure_id, user_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::AttestationFiscaleAdapter.new(etablissement.siret, procedure_id, user_id).to_params
+    attestation_fiscale_url = etablissement_params.delete(:entreprise_attestation_fiscale_url)
+    etablissement.upload_attestation_fiscale(attestation_fiscale_url) if attestation_fiscale_url.present?
+  end
+end

app/jobs/api_entreprise/attestation_sociale_job.rb

@@ -0,0 +1,8 @@
+class ApiEntreprise::AttestationSocialeJob < ApplicationJob
+  def perform(etablissement_id, procedure_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::AttestationSocialeAdapter.new(etablissement.siret, procedure_id).to_params
+    attestation_sociale_url = etablissement_params.delete(:entreprise_attestation_sociale_url)
+    etablissement.upload_attestation_sociale(attestation_sociale_url) if attestation_sociale_url.present?
+  end
+end

app/jobs/api_entreprise/bilans_bdf_job.rb

@@ -0,0 +1,7 @@
+class ApiEntreprise::BilansBdfJob < ApplicationJob
+  def perform(etablissement_id, procedure_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::BilansBdfAdapter.new(etablissement.siret, procedure_id).to_params
+    etablissement.update!(etablissement_params)
+  end
+end

app/jobs/api_entreprise/effectifs_annuels_job.rb

@@ -0,0 +1,7 @@
+class ApiEntreprise::EffectifsAnnuelsJob < ApplicationJob
+  def perform(etablissement_id, procedure_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::EffectifsAnnuelsAdapter.new(etablissement.siret, procedure_id).to_params
+    etablissement.update!(etablissement_params)
+  end
+end

app/jobs/api_entreprise/effectifs_job.rb

@@ -0,0 +1,21 @@
+class ApiEntreprise::EffectifsJob < ApplicationJob
+  def perform(etablissement_id, procedure_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::EffectifsAdapter.new(etablissement.siret, procedure_id, *get_current_valid_month_for_effectif).to_params
+    etablissement.update!(etablissement_params)
+  end
+
+  private
+
+  def get_current_valid_month_for_effectif
+    today = Date.today
+    date_update = Date.new(today.year, today.month, 15)
+
+    if today >= date_update
+      [today.strftime("%Y"), today.strftime("%m")]
+    else
+      date = today - 1.month
+      [date.strftime("%Y"), date.strftime("%m")]
+    end
+  end
+end

app/jobs/api_entreprise/entreprise_job.rb

@@ -0,0 +1,7 @@
+class ApiEntreprise::EntrepriseJob < ApplicationJob
+  def perform(etablissement_id, procedure_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::EntrepriseAdapter.new(etablissement.siret, procedure_id).to_params
+    etablissement.update!(etablissement_params)
+  end
+end

app/jobs/api_entreprise/exercices_job.rb

@@ -0,0 +1,7 @@
+class ApiEntreprise::ExercicesJob < ApplicationJob
+  def perform(etablissement_id, procedure_id)
+    etablissement = Etablissement.find(etablissement_id)
+    etablissement_params = ApiEntreprise::ExercicesAdapter.new(etablissement.siret, procedure_id).to_params
+    etablissement.update!(etablissement_params)
+  end
+end

spec/jobs/api_entreprise/association_job_spec.rb

@@ -0,0 +1,21 @@
+RSpec.describe ApiEntreprise::AssociationJob, type: :job do
+  let(:siret) { '50480511000013' }
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:procedure) { create(:procedure) }
+  let(:procedure_id) { procedure.id }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/associations.json') }
+  let(:status) { 200 }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/associations\/.*token=/)
+      .to_return(body: body, status: status)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  subject { ApiEntreprise::AssociationJob.new.perform(etablissement.id, procedure_id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).association_rna).to eq('W595001988')
+  end
+end

spec/jobs/api_entreprise/attestation_fiscale_job_spec.rb

@@ -0,0 +1,25 @@
+RSpec.describe ApiEntreprise::AttestationFiscaleJob, type: :job do
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:siret) { '41816609600069' }
+  let(:siren) { '418166096' }
+  let(:procedure) { create(:procedure) }
+  let(:user_id) { 1 }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/attestation_fiscale.json') }
+  let(:status) { 200 }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/attestations_fiscales_dgfip\/#{siren}\?.*token=/)
+      .to_return(body: body, status: status)
+    stub_request(:get, "https://storage.entreprise.api.gouv.fr/siade/1569156756-f6b7779f99fa95cd60dc03c04fcb-attestation_fiscale_dgfip.pdf")
+      .to_return(body: "body attestation", status: 200)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:roles).and_return(["attestations_fiscales"])
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  subject { ApiEntreprise::AttestationFiscaleJob.new.perform(etablissement.id, procedure.id, user_id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).entreprise_attestation_fiscale).to be_attached
+  end
+end

spec/jobs/api_entreprise/attestation_sociale_job_spec.rb

@@ -0,0 +1,24 @@
+RSpec.describe ApiEntreprise::AttestationSocialeJob, type: :job do
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:siret) { '41816609600069' }
+  let(:siren) { '418166096' }
+  let(:procedure) { create(:procedure) }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/attestation_sociale.json') }
+  let(:status) { 200 }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/attestations_sociales_acoss\/#{siren}\?.*token=/)
+      .to_return(body: body, status: status)
+    stub_request(:get, "https://storage.entreprise.api.gouv.fr/siade/1569156881-f749d75e2bfd443316e2e02d59015f-attestation_vigilance_acoss.pdf")
+      .to_return(body: "body attestation", status: 200)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:roles).and_return(["attestations_sociales"])
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  subject { ApiEntreprise::AttestationSocialeJob.new.perform(etablissement.id, procedure.id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).entreprise_attestation_sociale).to be_attached
+  end
+end

spec/jobs/api_entreprise/bilans_bdf_job_spec.rb

@@ -0,0 +1,24 @@
+RSpec.describe ApiEntreprise::BilansBdfJob, type: :job do
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:siret) { '41816609600069' }
+  let(:siren) { '418166096' }
+  let(:procedure) { create(:procedure) }
+  let(:procedure_id) { procedure.id }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/bilans_entreprise_bdf.json') }
+  let(:status) { 200 }
+  let(:bilans_bdf) { JSON.parse(body)["bilans"] }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/bilans_entreprises_bdf\/#{siren}\?.*token=/)
+      .to_return(body: body, status: status)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:roles).and_return(["bilans_entreprise_bdf"])
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  subject { ApiEntreprise::BilansBdfJob.new.perform(etablissement.id, procedure_id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).entreprise_bilans_bdf).to eq(bilans_bdf)
+  end
+end

spec/jobs/api_entreprise/effectifs_annuels_job_spec.rb

@@ -0,0 +1,22 @@
+RSpec.describe ApiEntreprise::EffectifsAnnuelsJob, type: :job do
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:siret) { '41816609600069' }
+  let(:siren) { '418166096' }
+  let(:procedure) { create(:procedure) }
+  let(:procedure_id) { procedure.id }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/effectifs_annuels.json') }
+  let(:status) { 200 }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/effectifs_annuels_acoss_covid\/#{siren}\?.*token=/)
+      .to_return(body: body, status: status)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  subject { ApiEntreprise::EffectifsAnnuelsJob.new.perform(etablissement.id, procedure_id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).entreprise_effectif_annuel).to eq(100.5)
+  end
+end

spec/jobs/api_entreprise/effectifs_job_spec.rb

@@ -0,0 +1,28 @@
+RSpec.describe ApiEntreprise::EffectifsJob, type: :job do
+  let(:siret) { '41816609600069' }
+  let(:siren) { '418166096' }
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:procedure) { create(:procedure) }
+  let(:procedure_id) { procedure.id }
+  let(:now) { Time.zone.local(2020, 3, 12) }
+  let(:annee) { "2020" }
+  let(:mois) { "02" }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/effectifs.json') }
+  let(:status) { 200 }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/effectifs_mensuels_acoss_covid\/#{annee}\/#{mois}\/entreprise\/#{siren}\?.*token=/)
+      .to_return(body: body, status: status)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  before { Timecop.freeze(now) }
+  after { Timecop.return }
+
+  subject { ApiEntreprise::EffectifsJob.new.perform(etablissement.id, procedure_id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).entreprise_effectif_mensuel).to eq(100.5)
+  end
+end

spec/jobs/api_entreprise/entreprise_job_spec.rb

@@ -0,0 +1,22 @@
+RSpec.describe ApiEntreprise::EntrepriseJob, type: :job do
+  let(:siret) { '41816609600051' }
+  let(:siren) { '418166096' }
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:procedure) { create(:procedure) }
+  let(:procedure_id) { procedure.id }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/entreprises.json') }
+  let(:status) { 200 }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/entreprises\/#{siren}?.*token=/)
+      .to_return(body: body, status: status)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  subject { ApiEntreprise::EntrepriseJob.new.perform(etablissement.id, procedure_id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).entreprise_numero_tva_intracommunautaire).to eq('FR16418166096')
+  end
+end

spec/jobs/api_entreprise/exercices_job_spec.rb

@@ -0,0 +1,20 @@
+RSpec.describe ApiEntreprise::ExercicesJob, type: :job do
+  let(:siret) { '41816609600051' }
+  let(:procedure) { create(:procedure) }
+  let(:etablissement) { create(:etablissement, siret: siret) }
+  let(:body) { File.read('spec/fixtures/files/api_entreprise/exercices.json') }
+  let(:status) { 200 }
+
+  before do
+    stub_request(:get, /https:\/\/entreprise.api.gouv.fr\/v2\/exercices\/.*token=/)
+      .to_return(body: body, status: status)
+    allow_any_instance_of(ApiEntrepriseToken).to receive(:expired?).and_return(false)
+  end
+
+  subject { ApiEntreprise::ExercicesJob.new.perform(etablissement.id, procedure.id) }
+
+  it 'updates etablissement' do
+    subject
+    expect(Etablissement.find(etablissement.id).exercices[0].ca).to eq('21009417')
+  end
+end