diff --git a/src/worker/sql.rs b/src/worker/sql.rs index 40a3943..a4813c6 100644 --- a/src/worker/sql.rs +++ b/src/worker/sql.rs @@ -646,8 +646,7 @@ WITH adjusted_income AS ( GROUP BY d.id, d.employer_user_id, c.title_of_nobility ) UPDATE falukant_data.director d - SET income = des.desired_income, - updated_at = NOW() + SET income = des.desired_income FROM desired des WHERE d.id = des.id AND d.income IS DISTINCT FROM des.desired_income @@ -686,16 +685,18 @@ new_sats AS ( END )::int AS new_satisfaction FROM salary_gap sg +), +updated_satisfaction AS ( + UPDATE falukant_data.director dir + SET satisfaction = ns.new_satisfaction + FROM new_sats ns + WHERE dir.id = ns.id + AND dir.satisfaction IS DISTINCT FROM ns.new_satisfaction + RETURNING dir.employer_user_id ) -UPDATE falukant_data.director dir - SET satisfaction = ns.new_satisfaction - FROM new_sats ns - WHERE dir.id = ns.id - AND dir.satisfaction IS DISTINCT FROM ns.new_satisfaction -RETURNING dir.employer_user_id +SELECT employer_user_id FROM updated_satisfaction UNION -SELECT ai.employer_user_id - FROM adjusted_income ai; +SELECT employer_user_id FROM adjusted_income; "#; pub const QUERY_GET_DIRECTOR_USER: &str = r#"