use strict;

#Настраиваемые параметры

# Имя профиля Exchange, который используется для рассылки
my $mapi_profile= "User" ;

# Строка подключения к базе данных, содержащей информацию о лицах,
# которым будут направлены сообщения
my $connection_string='Provider=SQLOLEDB.1;Integrated Security=SSPI;Persist Security Info=False;Initial Catalog=my_database;Data Source=my_sqlserver';

# КОНЕЦ ОБЛАСТИ НАСТРАИВАЕМЫХ ПАРАМЕТРОВ

#Packages
use File::Copy;
use Win32::OLE;
Win32::OLE->Option(Warn =>  1 );


################################################################
#PerlEz.dll Entry
sub Main()
{
Win32::OLE->Initialize(Win32::OLE::COINIT_APARTMENTTHREADED);

#Initalize ADO
my $cn=Win32::OLE->new('ADODB.Connection');
die  "Cannot to create ADO.Connection\n"  unless defined($cn);

$cn->{ConnectionString}=$connection_string;
$cn->{ConnectionTimeout}= 0 ;
$cn->open;
$cn->{CursorLocation}= 3 ; #UseClient

#Open a MAPI session
my $session=Win32::OLE->new('MAPI.Session');
die  "Cannot initialize a MAPI session!\n"  unless (defined($session));

$session->Logon($mapi_profile,undef, 0 );

my $msg=$session->Outbox->Messages->Add( "New Outgoing Mail!" );

# Check addresses
my @addresses=GetAddresses($cn);
for my $c (@addresses)
{
  my $rcp=$msg->Recipients->Add($c);
  $rcp->{Type}= 3 ;
  my $ret=$rcp->Resolve( 1 );

# А здесь формируем сообщение, действительный код опущен ;-)
  
  undef $rcp;
}

#Close a MAPI session
$session->Logoff();
undef $session;


$cn->Close();
undef $cn;

Win32::OLE->Uninitialize();
}

########################################################
#Local subs

#Определение адресатов
sub GetAddresses()
{
  my ($cn)=@_;
  
  my $cmd=Win32::OLE->new('ADODB.Command');
  die  "Cannot create ADO Command!\n"  unless defined($cmd);
  
  $cmd->{ActiveConnection}=$cn;
  $cmd->{CommandTimeout}= 0 ;
  $cmd->{CommandText}='select mail_address from employees where not mail_address is null  group by mail_address';
  $cmd->{CommandType}= 1 ; #Command Text

  my $rs=Win32::OLE->new('ADODB.Recordset');
  die  "Cannot create ADO recordset!\n"  unless defined($rs);

  $rs->open($cmd, undef,  3 ,  1 );
  die  "Cannot open ADO recordset\n"  if Win32::OLE::LastError();
  
  my @list=();

  while(!$rs->{EOF})
  {
    push(@list, $rs->Fields->Item('mail_address')->{Value});
	$rs->MoveNext();
  }
  $rs->Close();
  undef $rs;
  undef $cmd;
  
  @list;
}

################################################################
#Main Code: Console Entry

Main();