我不想使用zend框架2将同一封邮件发送给从数据库检索到的多个收件人。使用我的解决方案,我只能将电子邮件发送到数据库的第一行,我不知道到底是什么问题。这是我在indexController中的操作:
public function eventdetailsAction() {
$id = (int) $this->params()->fromRoute('id', 0);
$this->layout()->setVariable('lang', $this->params()->fromRoute('lang', 'en_US'));
$this->layout()->setVariable('action', $this->params()->fromRoute('action', 'index'));
$request = $this->getRequest();
$aPost = $request->getPost();
if (isset($aPost['invitUser'])) {
$user = new Container('user');
$db = $this->getServiceLocator()->get('db1');
if (!$user->offsetExists('id')) {
$idconnected = '0';
} else {
$user = new Container('user');
$db = $this->getServiceLocator()->get('db1');
if (!$user->offsetExists('id')) {
$idconnected = '0';
} else {
$idconnected = $user->offsetGet('id');
$mail = $db->query("SELECT * FROM user")->execute()->current();
print_r($mail);
exit();
$message = new Message();
foreach ($mail as $recip) {
$message->addTo($recip)
->addFrom('xxxxx@gmail.com')
->setSubject('Invitation for the event : Event Latino');
}
// Setup SMTP transport using LOGIN authentication
$transport = new SmtpTransport();
$options = new SmtpOptions(array(
'host' => 'smtp.gmail.com',
'connection_class' => 'login',
'connection_config' => array(
'ssl' => 'tls',
'username' => 'xxxxx@gmail.com',
'password' => 'xxxxxx'
),
'port' => 587,
));
$html = new MimePart('<b>Invitation for the event: Latin Night, orgonized by Mr. Jony Cornillon. Date : 06/04/2015</b>');
$html->type = "text/html";
$body = new MimeMessage();
$body->addPart($html);
//$body->setParts(array($html));
$message->setBody($body);
$transport->setOptions($options);
$transport->send($message);
}
}
}
}
而且,当我放置printr($mail); exit();
来显示结果时,页面上将只显示第一行。请帮忙。
在下面的行中,您正在执行查询,然后从返回的execute()
调用的结果集中获取current()
记录。这将始终为您提供结果集中的第一条记录。
$mail = $db->query("SELECT * FROM user")->execute()->current();
将其更改为
$mail = $db->query("SELECT * FROM user")->execute();
并且您应该能够按预期对结果集进行迭代。
我找到了另一个解决方案,我可以用print_r
成功地从数据库中下载所有电子邮件。然而,现在当我把结果集放在message->addTo()
上时,会出现一个错误。这是我的新代码
$sql = "SELECT * FROM user";
$statement = $db->query($sql);
$res = $statement->execute();
if ($res instanceof ResultInterface && $res->isQueryResult()) {
$resultSet = new ResultSet;
$resultSet->initialize($res);
$message = new Message();
foreach ($resultSet as $row) {
echo $row->email . PHP_EOL;
$message->addTo($row->email)
->addTo('xxxxx@hotmail.com', 'eee@web.com')
->addFrom('xxxxx@gmail.com')
->setSubject('Invitation for the event : Event Latino');
}
请帮忙。谢谢