File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -4,6 +4,7 @@ class BulkMessageWorker
4
4
def perform ( message_id )
5
5
message = Message . find ( message_id )
6
6
return unless message . present? && message . status == "queued"
7
+
7
8
message . update_attribute ( :started_at , Time . now )
8
9
9
10
recipients = self . class . build_recipients ( message . recipients )
@@ -27,8 +28,10 @@ def self.build_recipients(recipient_types)
27
28
def self . user_ids ( type )
28
29
case type
29
30
when "all"
30
- User . non_admins . pluck ( :id )
31
+ # Everyone, including admins that completed a questionnaire
32
+ User . non_admins . pluck ( :id ) + Questionnaire . pluck ( :user_id )
31
33
when "incomplete"
34
+ # Incomplete applications, excluding admins that don't have a questionnaire
32
35
User . non_admins . pluck ( :id ) - Questionnaire . pluck ( :user_id )
33
36
when "complete"
34
37
Questionnaire . pluck ( :user_id )
@@ -74,6 +77,7 @@ def self.user_ids_from_query(type)
74
77
result = Blazer ::RunStatement . new . perform ( Blazer . data_sources [ model . data_source ] , model . statement )
75
78
user_id_column = result . columns . index ( "user_id" )
76
79
raise "Blazer query is missing required \" user_id\" column" unless user_id_column . present?
80
+
77
81
result . rows . map { |row | row [ user_id_column ] }
78
82
else
79
83
raise "Unknown recipient query type: #{ recipient_query . type . inspect } (in message recipient query: #{ type . inspect } "
You can’t perform that action at this time.
0 commit comments