215 |
|
|
216 |
} elsif (defined($send_opt)) { |
} elsif (defined($send_opt)) { |
217 |
|
|
218 |
my $my_q; |
$nos->send_queued_messages($send_opt); |
|
if ($send_opt ne '') { |
|
|
my $l_id = $lists->search_like( name => $send_opt )->first || |
|
|
die "can't find list $send_opt"; |
|
|
$my_q = $queue->search_like( list_id => $l_id ) || |
|
|
die "can't find list $send_opt"; |
|
|
} else { |
|
|
$my_q = $queue->retrieve_all; |
|
|
} |
|
|
|
|
|
while (my $m = $my_q->next) { |
|
|
next if ($m->all_sent); |
|
|
|
|
|
print "sending message ",$m->message_id," enqueued on ",$m->date," to list ",$m->list_id->name,"\n"; |
|
|
my $msg = $m->message_id->message; |
|
|
|
|
|
foreach my $u ($user_list->search(list_id => $m->list_id)) { |
|
|
|
|
|
if ($sent->search( message_id => $m->message_id, user_id => $u->user_id )) { |
|
|
print "SKIP ",$u->user_id->email," message allready sent\n"; |
|
|
} else { |
|
|
print "\t",$u->user_id->email,"\n"; |
|
|
|
|
|
my $hdr = "From: " . $u->list_id->name . " <" . $u->list_id->email . ">\n" . |
|
|
"To: " . $u->user_id->full_name . " <". $u->user_id->email. ">\n"; |
|
|
|
|
|
# FIXME do real sending :-) |
|
|
$nos->send_email("$hdr\n$msg"); |
|
|
|
|
|
$sent->create({ |
|
|
message_id => $m->message_id, |
|
|
user_id => $u->user_id, |
|
|
}); |
|
|
$sent->dbi_commit; |
|
|
} |
|
|
} |
|
|
$m->all_sent(1); |
|
|
$m->update; |
|
|
$m->dbi_commit; |
|
|
} |
|
219 |
|
|
220 |
} else { |
} else { |
221 |
die "see perldoc $0 for help"; |
die "see perldoc $0 for help"; |