diff --git a/sgx_jmp.rb b/sgx_jmp.rb index 78f498c0c4167c5bb66624793b6ef628e2c38102..cefb94d9e0f1cbdf07076c6dcda67f8596a9f134 100644 --- a/sgx_jmp.rb +++ b/sgx_jmp.rb @@ -202,7 +202,10 @@ def catchup_notify_possible_renewal(db) db.query(<<~SQL).each do |c| SELECT customer_id FROM customer_plans INNER JOIN balances USING (customer_id) - WHERE expires_at < LOCALTIMESTAMP AND balance >= 5 + WHERE + expires_at < LOCALTIMESTAMP + AND expires_at >= LOCALTIMESTAMP - INTERVAL '3 months' + AND balance >= 5 SQL db.query("SELECT pg_notify('possible_renewal', $1)", c.values) end