我正在尝试将邮件列表从 CSV 导入我的数据库。我的 Laravel 中有两个模型负责执行此操作:Target
和Mailing
(一个Target
有很多Mailing
s)
我正在使用带有 Beanstalkd 的队列系统。我在用着:
Queue::push('ImportCSV', array(
'file' => $file->getClientOriginalName(),
'target' => $name
));
推送我的工作,然后我有 ImportCSV 工作类:
class ImportCSV
{
public function fire($job, $data)
{
Log::info("Starting to add {$data['target']} to database");
$target = new Target();
$target->name = $data['target'];
$target->save();
$reader = new \EasyCSV\Reader($data['file']);
// There must be a Email field in CSV file
/*if(!in_array('Email', $reader->getHeaders() ))
throw new Exception("Email field not found", 1);*/
while ($row = $reader->getRow())
{
$mailing = new Mailing();
$mailing->target()->associate($target);
$mailing->email = $row['Email'];
$mailing->save();
}
Log::info("Mailing list {$target->name} added to database");
$job->delete();
}
}
自从我在日志文件中收到这些消息以来,所有代码似乎都在工作
[2013-09-10 21:03:25] log.INFO: Starting to add TEst to database [] []
[2013-09-10 21:03:25] log.INFO: Mailing list TEst added to database [] []
但是没有记录添加到我的数据库中。我应该如何在工作中使用模型?例如,我已经在控制器中对其进行了测试,一切正常