Commit 11beb6b1 authored by hangjun83's avatar hangjun83

更新

parent fe3f86db
...@@ -333,6 +333,9 @@ class ZhenKhService ...@@ -333,6 +333,9 @@ class ZhenKhService
// yield 循环逐行读取csv内容 // yield 循环逐行读取csv内容
while ($generator->valid()) { while ($generator->valid()) {
$content = $generator->current(); $content = $generator->current();
if(empty($content)){
break;
}
$this->apiService->pushQueue([ $this->apiService->pushQueue([
'params' => current($content), 'params' => current($content),
'consumer' => __CLASS__, 'consumer' => __CLASS__,
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment