app/services/project_factory.rb
# frozen_string_literal: true
class ProjectFactory
def build(project_props = { dhis2_url: "http://play.dhis2.org/demo", user: "admin", password: "district", bypass_ssl: false })
project = Project.new({
name: "Sierra Leone PBF"
}.merge(project_props))
package_quantity_pma = new_package(
"Quantity PMA",
"monthly",
["fosa_group_id"],
[
Rule.new(
name: "Quantity PMA",
kind: "activity",
formulas: [
new_formula(
:difference_percentage,
"if (verified != 0.0, (ABS(claimed - verified) / verified ) * 100.0, 0.0) ",
"Pourcentage difference entre déclaré & vérifié"
),
new_formula(
:quantity,
"IF(difference_percentage < 50, verified , 0.0)",
"Quantity for PBF payment"
),
new_formula(
:amount,
"quantity * tarif",
"Total payment"
)
]
),
Rule.new(
name: "Quantity PMA",
kind: "package",
formulas: [
new_formula(
:quantity_total_pma,
"SUM(%{amount_values})",
"Amount PBF"
)
]
)
]
)
package_quantity_pca = new_package(
"Quantity PCA",
"monthly",
["hospital_group_id"],
[
Rule.new(
name: "Quantity PCA",
kind: "activity",
formulas: [
new_formula(
:difference_percentage,
"if (verified != 0.0, (ABS(claimed - verified) / verified ) * 100.0, 0.0)",
"Pourcentage difference entre déclaré & vérifié"
),
new_formula(
:quantity,
"IF(difference_percentage < 5, verified , 0.0)",
"Quantity for PBF payment"
),
new_formula(
:amount,
"quantity * tarif",
"Total payment"
)
]
),
Rule.new(
name: "Quantity PHU",
kind: "package",
formulas: [
new_formula(
:quantity_total_pca,
"SUM(%{amount_values})",
"Amount PBF"
)
]
)
]
)
package_quality = new_package(
"Quality",
"quarterly",
%w[hospital_group_id fosa_group_id],
[
Rule.new(
name: "Quality assessment",
kind: "activity",
formulas: [
new_formula(
:attributed_points,
"claimed",
"Attrib. Points"
),
new_formula(
:max_points,
"max_score",
"Max Points"
),
new_formula(
:quality_technical_score_value,
"if (max_points != 0.0, (attributed_points / max_points) * 100.0, 0.0)",
"Quality score"
)
]
),
Rule.new(
name: "QUALITY score",
kind: "package",
formulas: [
new_formula(
:attributed_points,
"SUM(%{attributed_points_values})",
"Quality score"
),
new_formula(
:max_points,
"SUM(%{max_points_values})",
"Quality score"
),
new_formula(
:quality_technical_score_value,
"SAFE_DIV(SUM(%{attributed_points_values}),SUM(%{max_points_values})) * 100.0",
"Quality score"
)
]
)
]
)
package_perfomance_admin = new_package(
"Performance Adm",
"quarterly",
["administrative_group_id"],
[
Rule.new(
name: "Performance assessment",
kind: "activity",
formulas: [
new_formula(
:attributed_points,
"claimed",
"Attrib. Points"
),
new_formula(
:max_points,
"max_score",
"Max Points"
),
new_formula(
:performance_score_value,
"if (max_points != 0.0, (attributed_points / max_points) * 100.0, 0.0)",
"Performance score"
)
]
),
Rule.new(
name: "Performance score",
kind: "package",
formulas: [
new_formula(
:attributed_points_perf,
"SUM(%{attributed_points_values})",
"Attributed points"
),
new_formula(
:max_points_perf,
"SUM(%{max_points_values})",
"Max points"
),
new_formula(
:performance_score_value,
"(attributed_points_perf/max_points_perf) * 100.0",
"Performance score"
),
new_formula(
:performance_amount,
"(performance_score_value / 100.0) * 1000",
"Performance amount"
)
]
)
]
)
project.packages = [package_quantity_pma, package_quantity_pca, package_quality, package_perfomance_admin]
payment_pma = project.payment_rules.build(
rule_attributes: {
name: "Payment rule pma",
kind: "payment",
formulas_attributes: [
{
code: :quality_bonus_percentage_value,
expression: "IF(quality_technical_score_value > 50, (0.35 * quality_technical_score_value) + (0.30 * 10.0), 0.0)",
description: "Quality bonus percentage"
},
{
code: :quality_bonus_value,
expression: "quantity_total_pma * quality_bonus_percentage_value",
description: "Bonus qualité "
},
{
code: :quarterly_payment,
expression: "quantity_total_pma + quality_bonus_value",
description: "Quarterly Payment"
}
]
}
)
[package_quantity_pma, package_quality].each do |package|
payment_pma.package_payment_rules.build(package: package)
payment_pma.packages << package
end
package_quality.package_rule.formulas.each do |formula|
formula.formula_mappings.build(
kind: formula.rule.kind,
external_reference: "ext-#{formula.code}"
)
end
payment_pca = project.payment_rules.build(
rule_attributes: {
name: "Payment rule pca",
kind: "payment",
formulas_attributes: [
{
code: :quality_bonus_percentage_value,
expression: "IF(quality_technical_score_value > 50, (0.35 * quality_technical_score_value) + (0.30 * 10.0), 0.0)",
description: "Quality bonus percentage"
},
{
code: :quality_bonus_value,
expression: "quantity_total_pca * quality_bonus_percentage_value",
description: "Bonus qualité "
},
{
code: :quarterly_payment,
expression: "quantity_total_pca + quality_bonus_value",
description: "Quarterly Payment"
}
]
}
)
[package_quantity_pca, package_quality].each do |package|
payment_pca.package_payment_rules.build(package: package)
payment_pca.packages << package
end
project
end
def update_links(project, suffix = "")
project.build_entity_group(
name: "contracted entities",
external_reference: "external_reference"
)
hospital_group = { name: "Hospital", organisation_unit_group_ext_ref: "tDZVQ1WtwpA" }
clinic_group = { name: "Clinic", organisation_unit_group_ext_ref: "RXL3lPSK8oG" }
admin_group = { name: "Administrative", organisation_unit_group_ext_ref: "w0gFTTmsUcF" }
project.build_entity_group(
name: clinic_group[:name],
external_reference: clinic_group[:organisation_unit_group_ext_ref]
)
[
{ name: "Claimed" },
{ name: "Verified" },
{ name: "Validated" },
{ name: "Max. Score" },
{ name: "Tarif" },
{ name: "Budget" },
{ name: "Remoteness Bonus" },
{ name: "Applicable Points" },
{ name: "Waiver" }
].each do |state|
project.states.build(state)
end
claimed_state = project.states.find { |s| s.name == "Claimed" }
tarif_state = project.states.find { |s| s.name == "Tarif" }
activity_1 = project.activities.build(
project: project,
name: "Vaccination", activity_states_attributes: [
{ name: "Vaccination claimed", state: claimed_state, external_reference: "cl-ext-1" },
{ name: "tarif for Vaccination ", state: tarif_state, external_reference: "tarif-ext-1" }
]
)
activity_2 = project.activities.build(
project: project,
name: "Clients sous traitement ARV suivi pendant les 6 premiers mois",
activity_states_attributes: [
{
name: "Clients sous traitement ARV suivi pendant les 6 premiers mois - decl",
state: claimed_state,
external_reference: "cl-ext-2"
},
{
name: "tarif for Clients sous traitement ARV suivi pendant les 6 premiers mois",
state: tarif_state,
external_reference: "tarif-ext-2"
}
]
)
project.packages[0].activities = [activity_1, activity_2]
project.packages[1].activities = [activity_1, activity_2]
project.packages[2].activities = [activity_1, activity_2]
project.packages[3].activities = [activity_1, activity_2]
project.packages[0].activity_rule.decision_tables.build(
content: fixture_content(:scorpio, "decision_table.csv")
)
refresh_packages!(project, suffix)
end
# These only get run by the seed controller. Adding them to the normal build operation would break some specs, since these two are not really related, keeping these separate.
def additional_seed_actions(project, _suffix = "")
verified_state = project.states.find { |s| s.name == "Verified" }
max_state = project.states.find { |s| s.name == "Max. Score" }
activity_1 = project.activities.detect { |a| a.name == "Vaccination" }
activity_1.activity_states.build(
name: "Verified", state: verified_state, external_reference: "M62VHgYT2n0"
)
activity_1.activity_states.build(
name: "Max. Score", state: max_state, external_reference: "FQ2o8UBlcrS"
)
activity_2 = project.activities.last
activity_2.activity_states.build(
name: "Verified", state: verified_state, external_reference: "CecywZWejT3"
)
activity_2.activity_states.build(
name: "Max. Score", state: max_state, external_reference: "bVkFujnp3F2"
)
# Legacy-engine needs this engine, otherwise it won't propagate
# all the values to DHIS when running a simulation
decision_table = project.packages[0].activity_rule.decision_tables.first
decision_table.content << "*,*,*,*,12"
end
def normalized_suffix
suffix = Time.now.to_s[0..15] + " - "
if (suffix || "") =~ /^[0-9]/
# Packages should not start with a number
suffix = "P#{suffix}"
end
suffix
end
private
def states_in(project, state_names)
project.states.select { |s| state_names.include?(s.name) }
end
def fixture_content(type, name)
File.read(File.join("spec", "fixtures", type.to_s, name))
end
def refresh_packages!(project, suffix)
default_quantity_states = states_in(project, %w[Claimed Verified Tarif])
default_quality_states = states_in(project, ["Claimed", "Verified", "Max. Score"])
default_performance_states = states_in(project, ["Claimed", "Max. Score", "Budget"])
hospital_group = { name: "Hospital", organisation_unit_group_ext_ref: "tDZVQ1WtwpA" }
clinic_group = { name: "Clinic", organisation_unit_group_ext_ref: "RXL3lPSK8oG" }
admin_group = { name: "Administrative", organisation_unit_group_ext_ref: "w0gFTTmsUcF" }
# States have been created, now we can update them with actual
# identifiers from DHIS, these are taken from:
#
# https://play.dhis2.org/2.29/api/dataElements?filter=domainType:eq:AGGREGATE
#
# We don't really care what the elements are, we just need to map them.
update_package_with_dhis2(
project.packages[0], suffix, default_quantity_states,
[clinic_group],
%w[FTRrcoaog83 P3jJH5Tu5VC FQ2o8UBlcrS M62VHgYT2n0]
)
update_package_with_dhis2(
project.packages[1], suffix, default_quantity_states,
[hospital_group],
%w[FTRrcoaog83 P3jJH5Tu5VC FQ2o8UBlcrS M62VHgYT2n0]
)
activity_refs = %w[p4K11MFEWtw wWy5TE9cQ0V r6nrJANOqMw a0WhmKHnZ6J nXJJZNVAy0Y
hnwWyM4gDSg CecywZWejT3 bVkFujnp3F2]
update_package_with_dhis2(
project.packages[2], suffix, default_quality_states,
[clinic_group, hospital_group],
activity_refs
)
update_package_with_dhis2(
project.packages[3], suffix, default_performance_states,
[admin_group],
activity_refs
)
end
def update_package_with_dhis2(package, suffix, states, groups, activity_ids)
package.states = states
package.name = suffix + package.name
groups.each_with_index do |group, index|
package.package_entity_groups[index].assign_attributes(group)
end
return if suffix.blank?
created_ged = package.create_data_element_group(activity_ids)
package.data_element_group_ext_ref = created_ged.id
package.activities.flat_map(&:activity_states).each_with_index do |activity_state, index|
activity_state.external_reference = activity_ids[index]
end
end
def new_formula(code, expression, description)
Formula.new(code: code, expression: expression, description: description)
end
def new_package(name, frequency, groups, rules)
Package.new(
name: name,
frequency: frequency,
data_element_group_ext_ref: "data_element_group_ext_ref",
rules: rules,
package_entity_groups: groups.map do |g|
PackageEntityGroup.new(name: g, organisation_unit_group_ext_ref: g)
end
)
end
end